USKYZHAF/Home/Controller/DeviceConfigController.class.php.bak.2021-05-25

<?php

namespace Home\Controller;

use Think\Controller;
use Think\Db;

include '../Common/function.php';

class DeviceConfigController extends ComController
{
    private $host = "https://device.api.ct10649.com:8743/";
    private $appId = "wvdOfp7JVe0ULwnFKwBF0edfbcAa";
    private $secret = "Bihoe_rY9vebXMw6sFfpQy0jiRca";
    private $appId1 = "bIS92ndpAf_fhmPdLaNuTidbFfka";
    private $secret1 = "NZMe1G42OdSmzlEuDpR_3ywKPhIa";

    public function getDeviceList()
    {
        $Data = I();
        $company_code = $Data['company_code'];
        $device_data1 = M()->query("SELECT a.id,a.owner_code,a.owner_name,a.dwtype,IF(timestampdiff(HOUR,max(`b`.`data_time`),now())<12,'在线','离线') AS device_state,a.install_time,a.unitinfo FROM sp_owner AS a JOIN sp_owner_status  AS b ON a.owner_code=b.device_id WHERE a.dwtype!=1 AND a.company='" . $company_code . "' GROUP BY a.owner_code ORDER BY a.install_time DESC");
        $device_data2 = M()->query("SELECT a.id,a.owner_code,a.owner_name,a.dwtype,IF(true_status=0,'在线','离线') AS device_state,a.install_time,a.unitinfo FROM sp_owner AS a JOIN sp_devices_status AS b ON a.owner_code=b.deviceid WHERE a.company='" . $company_code . "' AND a.dwtype=1 GROUP BY a.owner_code ORDER BY a.install_time DESC");
        $device_data = array_merge($device_data1, $device_data2);
        array_multisort(array_column($device_data, 'install_time'), SORT_DESC, $device_data);
        $res['msg'] = '操作成功';
        $res['flag'] = true;
        $res['data'] = $device_data;
        echo json_encode($res);
    }

    public function setDevice()
    {
        $Data = I('');
        $data['owner_code'] = $Data['device_code'];
        $data['owner_name'] = $Data['device_name'];
        $data['unitinfo'] = $Data['unitinfo'];
        $data['louyu'] = $Data['louyu'];
        $data['sim'] = $Data['sim'];
        $data['maintainTime'] = $Data['maintainTime'];
        $data['dest_address'] = $Data['dest_address'];
        $data['addr1'] = $Data['addr1'];
        $data['addr2'] = $Data['addr2'];
        $data['addr3'] = $Data['addr3'];
        $data['address'] = $Data['address'];
        $data['posistion'] = $Data['posistion'];
        $data['install_time'] = date("Y-m-d H:i:s");
        $data['install_man'] = $_SESSION['phone'];
        $data['dwtype'] = $Data['type'];
        $data['owner_xh'] = '0' . $data['owner_xh_a'] . $data['owner_xh_b'] . $data['owner_xh_c'];
        $data['s_interval'] = $Data['s_interval'];
        $data['community'] = $Data['community'];
        $data['company'] = $Data['company_code'];
        $data['rtmp'] = $Data['rtmp'];
        $data['hls'] = $Data['hls'];
        $data['html5'] = $Data['html5'];
        $data['danwei'] = $Data['danwei'];
        $data['owner_bl'] = $Data['owner_bl'];
        $data['push_param1'] = $Data['push_param1'];
        $data['push_param2'] = $Data['push_param2'];
        $data['push_param3'] = $Data['push_param3'];
        $data['push_param4'] = $Data['push_param4'];
        $data['login_param'] = $Data['login_param'];
        $data['transfer_type'] = $Data['transfer_type'];

        $data1['deviceid'] = $Data['device_code'];
        $data1['deviceno'] = 0;
        $data1['devicestatus'] = '75';
        $data1['statustime'] = 0;
        $data1['f_evt'] = 40;
        $data1['c_evt'] = "00";
        $data1['w_evt'] = "";
        $data1['true_status'] = '75';
        $data1['lastcommtime'] = '0';

        $data2['owner_code'] = $Data['device_code'];
        $data2['owner_dwtype'] = $Data['type'];
        $data2['device_name'] = $Data['device_name'];
        $data2['object_name'] = $Data['unitinfo'];
        $data2['min_level'] = $Data['louyu'];
        $data2['max_level'] = $Data['louyu'];
        $data2['is_top'] = $Data['is_top'];
        $data2['start_port'] = '0';
        $data2['rec_cur'] = '0';

        $data3['deviceType'] = $Data['deviceType'];//设备类型 水表 Smoke:烟感、MultiSensor：水表、WaterMeter：宇洁戎情水表、topsailSensor：拓扑索尔 烟感 TBSNode：拓扑索尔烟感
        $data3['manufacturerName'] = $Data['manufacturerName'];//厂商名称：ST、ZHYQ、shanghaijunyanTest、Topsail、Turboes
        $data3['model'] = $Data['model'];//设备型号 烟感型号:517N01、水表型号：PT124B-2892-010、宇洁戎情水表型号：WPTA、拓扑索尔水表液位：TH12、拓扑索尔烟感：Public
        $data3['location'] = $Data['location'];//地址 区域
        $data3['protocolType'] = $Data['protocolType'];//协议

        switch ($Data['type']) {
            case '1'://报警主机
                $data2['dwtype'] = 'YTUI';
                $Res1 = M('owner')->add($data);
                $Res2 = M('devices_status')->add($data1);
                $Res3 = M('object_share')->add($data2);
                break;
            case '2'://消防水
                $data2['dwtype'] = 'YTWP';
                $data2['start_port'] = '0';
                $data2['rec_cur'] = '0';
                $Res = M()->query("SELECT max(object_code) AS object_code FROM sp_object_share WHERE object_code LIKE '" . $data2['dwtype'] . "-" . $Data['company_code'] . "%'");
                if (empty($Res)) {
                    $data2['object_code'] = $data2['dwtype'] . '-' . $Data['company_code'] . '001';
                } else {
                    $sort = (int)substr($Res[0]['object_code'], 10, 3) + 1;
                    $num = str_pad($sort, 3, "0", STR_PAD_LEFT);
                    $data2['object_code'] = $data2['dwtype'] . '-' . $Data['company_code'] . $num;
                }
                switch ($data['transfer_type']) {
                    case 'NB':
                        if (empty($data3['deviceType']) || empty($data3['manufacturerName']) || empty($data3['model']) || empty($data3['location']) || empty($data3['protocolType'])) {
                            $res['msg'] = "请填写好必要内容";
                            $res['flag'] = false;
                            echo json_encode($res);
                            exit();
                        }
                        $R = ytapi187_query("select * from device where device_id='" . $Data['device_code'] . "'");
                        if (empty($R)) {
                            if (empty($Data['device_code']) || empty($Data['device_name'])) {
                                $res['msg'] = '请填写好必要内容';
                                $res['flag'] = false;
                                echo json_encode($res);
                                exit();
                            }

                            $token = json_decode(gettoken(), true);
                            $sendata = [
                                "verifyCode" => $Data['device_code'],//"868744030067098"
                                "nodeId" => $Data['device_code'],
                                "timeout" => 0
                            ];

                            $header = [
                                "Content-Type:application/json",
                                "app_key:" . $this->appId,
                                "Authorization:Bearer " . $token["accessToken"]
                            ];

                            $rescurl = curl($this->host . "iocm/app/reg/v1.1.0/deviceCredentials?appId=" . $this->appId, json_encode($sendata), $header);
                            if ($rescurl[0] == 200) {
                                $res1 = json_decode($rescurl[1], true);
                            } else {
                                $res['msg'] = $rescurl;
                                $res['flag'] = false;
                                echo json_encode($res);
                                exit();
                            }
                            $list = array();
                            $list['device_id'] = trim($Data['device_code']);
                            $list['name'] = $Data['device_name'];
                            $list['iot_id'] = $res1['deviceId'];
                            $list['psk'] = $res1['psk'];
                            $list['addtime'] = date('Y-m-d H:i:s');
                            $list['updatetime'] = date('Y-m-d H:i:s');
                            $device_table = "dev_" . $Data['device_code'];
                            $create_sql = "
                            CREATE TABLE `" . $device_table . "` (
                              `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
                              `device_id` varchar(200) DEFAULT NULL,
                              `iot_id` varchar(255) DEFAULT NULL,
                              `service` text,
                              `addtime` varchar(50) DEFAULT NULL,
                              `notifyType` varchar(50) DEFAULT NULL,
                              PRIMARY KEY (`id`)
                            ) ENGINE=InnoDB DEFAULT CHARSET=utf8;";

                            ytapi187_inset($create_sql);

                            $rs = ytapi187_inset("INSERT INTO device (device_id,name,addtime,updatetime,iot_id,psk,manufacturerId,manufacturerName,deviceType
                                ,model,location,isSecure,status,protocolType,owner_id) values ('" . $list['device_id'] . "','" . $list['name'] . "','" . $list['addtime'] . "',
                                '" . $list['updatetime'] . "','" . $list['iot_id'] . "','" . $list['psk'] . "','','','','','','','','','')");
                            if ($rs) {
                                $owner1 = M()->query("SELECT company,louyu,unitinfo FROM sp_owner WHERE owner_code = '" . $Data['device_code'] . "'");
                                if ($owner1) {
                                    $data4['owner_name'] = $Data['device_name'];
                                    $data4['unitinfo'] = $Data['unitinfo'];
                                    $data4['louyu'] = $Data['louyu'];
                                    $data4['company'] = $Data['company_code'];
                                    $where4['owner_code'] = $Data['device_code'];
                                    $res4 = M('owner')->where($where4)->save($data4);
                                } else {
                                    $token = json_decode(gettoken(), true);
                                    $sendata = [
                                        "name" => $Data['device_code'],
                                        "deviceType" => $Data['deviceType'],
                                        "manufacturerName" => $Data['manufacturerName'],
                                        "manufacturerId" => $Data['manufacturerId'],//厂商ID ST、ZHYQ、JunyanTest、Topsail
                                        "model" => $Data['model'],
                                        "protocolType" => $Data['protocolType'],
                                        "location" => trim($Data['location']),
                                    ];
                                    $header = [
                                        "Content-Type:application/json",
                                        "app_key:" . $this->appId,
                                        "Authorization:Bearer " . $token["accessToken"]
                                    ];
                                    $rescurl = curl($this->host . "iocm/app/dm/v1.4.0/devices/" . $list['iot_id'] . "?appId=" . $this->appId, json_encode($sendata, 320), $header, "PUT");
                                }
                                if ($rescurl[0] == 204) {//成功
                                    $res1 = json_decode($rescurl[1], true);
                                } else {//失败
                                    $res['msg'] = $rescurl[1];
                                    $res['flag'] = false;
                                    echo json_encode($res);
                                    exit();
                                }

                                $device_update = ytapi187_inset("UPDATE device set deviceType='" . $Data['deviceType'] . "',name='" . $Data['device_name'] . "',manufacturerName=
                                '" . $Data['manufacturerName'] . "',model='" . $Data['model'] . "',isSecure='" . $Data['isSecure'] . "',manufacturerId='" . $Data['manufacturerId'] . "',
                                protocolType='" . $Data['protocolType'] . "',location='" . $Data['location'] . "',updatetime='" . date('Y-m-d H:i:s') . "' where device_id=
                                '" . $Data['device_code'] . "'");
                                $device_query = ytapi187_query("select * from device where device_id='" . $Data['device_code'] . "'");
                                $device_id = $device_query[0]['device_id'];
                                $deviceType = $Data['deviceType'];
                                $create_sql = addtable($device_id, $deviceType);
                                $table = Db::execute($create_sql);
                                $deviceStatus = M()->query("SELECT statustime FROM sp_devices_status WHERE deviceid = '" . $device_query[0]['device_id'] . "'");
                                if (!$deviceStatus) {
                                    $data6['deviceid'] = $device_query[0]['device_id'];
                                    $data6['deviceno'] = 0;
                                    $data6['devicestatus'] = '75';
                                    $data6['statustime'] = date('Y-m-d H:i:s');
                                    $data6['f_evt'] = 40;
                                    $data6['c_evt'] = 00;
                                    $data6['w_evt'] = "";
                                    $data6['true_status'] = '75';
                                    $data6['lastcommtime'] = '0';
                                    $Res2 = M('devices_status')->add($data6);
                                }
                                if ($Data['company_code']) {
                                    ;
                                    $Res1 = M('owner')->add($data);
//                                    $Res2 = M('devices_status')->add($data1);
                                    $Res3 = M('object_share')->add($data2);
                                }
                                if ($device_update) {
                                    $res['msg'] = "操作成功";
                                    $res['flag'] = true;
                                    echo json_encode($res);
                                    exit();
                                } else {
                                    $res['msg'] = "添加失败，请稍后再试";
                                    $res['flag'] = false;
                                    echo json_encode($res);
                                    exit();
                                }


                            } else {
                                $res['msg'] = "添加失败，请稍后再试";
                                $res['flag'] = false;
                                echo json_encode($res);
                                exit();
                            }
                        } else {
                            $res['msg'] = '该设备编号已经添加';
                            $res['flag'] = false;
                            echo json_encode($res);
                            exit();
                        }
                        break;
                    case 'Lora':
                    case '4G':
                        $Res1 = M('owner')->add($data);
                        $Res2 = M('devices_status')->add($data1);
                        $Res3 = M('object_share')->add($data2);
                        break;
                    default:
                        $res['msg'] = '操作失败，该传输方式不存在，请联系管理员';
                        $res['flag'] = false;
                        echo json_encode($res);
                        exit();
                }
                break;
            case '3'://烟感
                $data2['dwtype'] = 'YTSM';
                $data2['start_port'] = '0';
                $data2['rec_cur'] = '0';
                $Res = M()->query("SELECT max(object_code) AS object_code FROM sp_object_share WHERE object_code LIKE '" . $data2['dwtype'] . "-" . $Data['company_code'] . "%'");
                if (empty($Res)) {
                    $data2['object_code'] = $data2['dwtype'] . '-' . $Data['company_code'] . '001';
                } else {
                    $sort = (int)substr($Res[0]['object_code'], 10, 3) + 1;
                    $num = str_pad($sort, 3, "0", STR_PAD_LEFT);
                    $data2['object_code'] = $data2['dwtype'] . '-' . $Data['company_code'] . $num;
                }
                switch ($data['transfer_type']) {
                    case 'NB':
                        if (empty($data3['deviceType']) || empty($data3['manufacturerName']) || empty($data3['model']) || empty($data3['location']) || empty($data3['protocolType'])) {
                            $res['msg'] = "请填写好必要内容";
                            $res['flag'] = false;
                            echo json_encode($res);
                            exit();
                        }
                        $R = ytapi187_query("select * from device where device_id='" . $Data['device_code'] . "'");
                        if (empty($R)) {
                            if (empty($Data['device_code']) || empty($Data['device_name'])) {
                                $res['msg'] = '请填写好必要内容';
                                $res['flag'] = false;
                                echo json_encode($res);
                                exit();
                            }

                            $token = json_decode(gettoken1(), true);
                            $sendata = [
                                "verifyCode" => $Data['device_code'],//"868744030067098"
                                "nodeId" => $Data['device_code'],
                                "timeout" => 0
                            ];

//                            print_r("accessToken=".$token["accessToken"]);
                            $header = [
                                "Content-Type:application/json",
                                "app_key:" . $this->appId1,
                                "Authorization:Bearer " . $token["accessToken"]
                            ];

                            $rescurl = curl($this->host . "iocm/app/reg/v1.1.0/deviceCredentials?appId=" . $this->appId1, json_encode($sendata), $header);
                            if ($rescurl[0] == 200) {
                                $res1 = json_decode($rescurl[1], true);
                            } else {
                                $res['msg'] = $rescurl;
                                $res['flag'] = false;
                                echo json_encode($res);
                                exit();
                            }
                            $list = array();
                            $list['device_id'] = trim($Data['device_code']);
                            $list['name'] = $Data['device_name'];
                            $list['iot_id'] = $res1['deviceId'];
                            $list['psk'] = $res1['psk'];
                            $list['addtime'] = date('Y-m-d H:i:s');
                            $list['updatetime'] = date('Y-m-d H:i:s');
                            $device_table = "dev_" . $Data['device_code'];
                            $create_sql = "
                            CREATE TABLE `" . $device_table . "` (
                              `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
                              `device_id` varchar(200) DEFAULT NULL,
                              `iot_id` varchar(255) DEFAULT NULL,
                              `service` text,
                              `addtime` varchar(50) DEFAULT NULL,
                              `notifyType` varchar(50) DEFAULT NULL,
                              PRIMARY KEY (`id`)
                            ) ENGINE=InnoDB DEFAULT CHARSET=utf8;";

                            ytapi187_inset($create_sql);

                            $rs = ytapi187_inset("INSERT INTO device (device_id,name,addtime,updatetime,iot_id,psk,manufacturerId,manufacturerName,deviceType
                                ,model,location,isSecure,status,protocolType,owner_id) values ('" . $list['device_id'] . "','" . $list['name'] . "','" . $list['addtime'] . "',
                                '" . $list['updatetime'] . "','" . $list['iot_id'] . "','" . $list['psk'] . "','','','','','','','','','')");
                            if ($rs) {
                                $owner1 = M()->query("SELECT company,louyu,unitinfo FROM sp_owner WHERE owner_code = '" . $Data['device_code'] . "'");
                                if ($owner1) {
                                    $data4['owner_name'] = $Data['device_name'];
                                    $data4['unitinfo'] = $Data['unitinfo'];
                                    $data4['louyu'] = $Data['louyu'];
                                    $data4['company'] = $Data['company_code'];
                                    $where4['owner_code'] = $Data['device_code'];
                                    $res4 = M('owner')->where($where4)->save($data4);
                                } else {
                                    $token = json_decode(gettoken1(), true);
                                    $sendata = [
                                        "name" => $Data['device_code'],
                                        "deviceType" => $Data['deviceType'],
                                        "manufacturerName" => $Data['manufacturerName'],
                                        "manufacturerId" => $Data['manufacturerId'],//厂商ID ST、ZHYQ、JunyanTest、Topsail
                                        "model" => $Data['model'],
                                        "protocolType" => $Data['protocolType'],
                                        "location" => trim($Data['location']),
                                    ];
                                    $header = [
                                        "Content-Type:application/json",
                                        "app_key:" . $this->appId1,
                                        "Authorization:Bearer " . $token["accessToken"]
                                    ];
                                    $rescurl = curl($this->host . "iocm/app/dm/v1.4.0/devices/" . $list['iot_id'] . "?appId=" . $this->appId1, json_encode($sendata, 320), $header, "PUT");
                                }
                                if ($rescurl[0] == 204) {//成功
                                    $res1 = json_decode($rescurl[1], true);
                                } else {//失败
                                    $res['msg'] = $rescurl[1];
                                    $res['flag'] = false;
                                    echo json_encode($res);
                                    exit();
                                }

                                $device_update = ytapi187_inset("UPDATE device set deviceType='" . $Data['deviceType'] . "',name='" . $Data['device_name'] . "',manufacturerName=
                                '" . $Data['manufacturerName'] . "',model='" . $Data['model'] . "',isSecure='" . $Data['isSecure'] . "',manufacturerId='" . $Data['manufacturerId'] . "',
                                protocolType='" . $Data['protocolType'] . "',location='" . $Data['location'] . "',updatetime='" . date('Y-m-d H:i:s') . "' where device_id=
                                '" . $Data['device_code'] . "'");
                                $device_query = ytapi187_query("select * from device where device_id='" . $Data['device_code'] . "'");
                                $device_id = $device_query[0]['device_id'];
                                $deviceType = $Data['deviceType'];
                                $create_sql = addtable($device_id, $deviceType);
                                $table = Db::execute($create_sql);
                                $deviceStatus = M()->query("SELECT statustime FROM sp_devices_status WHERE deviceid = '" . $device_query[0]['device_id'] . "'");
                                if (!$deviceStatus) {
                                    $data6['deviceid'] = $device_query[0]['device_id'];
                                    $data6['deviceno'] = 0;
                                    $data6['devicestatus'] = '75';
                                    $data6['statustime'] = date('Y-m-d H:i:s');
                                    $data6['f_evt'] = 40;
                                    $data6['c_evt'] = 00;
                                    $data6['w_evt'] = "";
                                    $data6['true_status'] = '75';
                                    $data6['lastcommtime'] = '0';
                                    $Res2 = M('devices_status')->add($data6);
                                }
                                if ($Data['company_code']) {
                                    $Res1 = M('owner')->add($data);
//                                  $Res2 = M('devices_status')->add($data1);
                                    $Res3 = M('object_share')->add($data2);
                                }
                                if ($device_update) {
                                    $res['msg'] = "操作成功";
                                    $res['flag'] = true;
                                    echo json_encode($res);
                                    exit();
                                } else {
                                    $res['msg'] = "添加失败，请稍后再试";
                                    $res['flag'] = false;
                                    echo json_encode($res);
                                    exit();
                                }


                            } else {
                                $res['msg'] = "添加失败，请稍后再试";
                                $res['flag'] = false;
                                echo json_encode($res);
                                exit();
                            }
                        } else {
                            $res['msg'] = '该设备编号已经添加';
                            $res['flag'] = false;
                            echo json_encode($res);
                            exit();
                        }
                        break;
                    case 'Lora':
                        $url="https://ttl.turboes.com/api/api/login";
                        $parameter=[
                            "appKey" => "wLHvcVHS",
                            "appSecret" => "a9daf060059d205280646a1880cd1fc24f3c5c69"
                        ];
                        $accessToken = json_post($url,$parameter);
                        $accessToken_array=json_decode($accessToken,true);

                        if ($accessToken_array['code']==200){
                            $url1="https://ttl.turboes.com/api/ttl/api/v1/device";
                            $parameter1=[
                                "access_token"=>$accessToken_array['data']['token'],
                                "nodeId" => $Data['device_code'],
                                "nodeName" => $Data['device_name'],
                                "appKey" => "nIeDYZ3ufbV3bBoC ",
                                "platfromProtocolType" => $Data['platfromProtocolType'],
                                "platfromId" => $Data['platfromId'],
                                "productKey" => $Data['productKey'],
                                "protocol_NB" => [
                                    "nodeName" => $Data['device_code']
                                ],
                                "protocol_LORA" => [
                                    "devEui" => $Data['devEui'],
                                    "region" => $Data['region'],
                                    "activationType" => $Data['activationType'],
                                    "AppKey" => $Data['AppKey'],
                                    "NwkSKey" => $Data['NwkSKey'],
                                    "AppSKey" => $Data['AppSKey'],
                                    "DevAddr" => $Data['DevAddr'],
                                ]
                            ];
                            $R = json_post($url1,$parameter1);
                            $R1 = json_decode($R,true);
                            if ($R1['code']==200){
                                $Res1 = M('owner')->add($data);
                                $Res2 = M('devices_status')->add($data1);
                                $Res3 = M('object_share')->add($data2);
                            }else{
                                $res['msg'] = $accessToken_array['message'];
                                $res['flag'] = false;
                                echo json_encode($res);
                                exit();
                            }
                        }else{
                            $res['msg'] = $accessToken_array['message'];
                            $res['flag'] = false;
                            echo json_encode($res);
                            exit();
                        }
                        exit();

                        break;
                    case '4G':
                        $Res1 = M('owner')->add($data);
                        $Res2 = M('devices_status')->add($data1);
                        $Res3 = M('object_share')->add($data2);
                        break;
                    default:
                        $res['msg'] = '操作失败，该传输方式不存在，请联系管理员';
                        $res['flag'] = false;
                        echo json_encode($res);
                        exit();
                }
                break;
            case '4'://消防栓
                $data2['dwtype'] = 'YTFH';
                $Res1 = M('owner')->add($data);
                $Res2 = M('devices_status')->add($data1);
                $Res3 = M('object_share')->add($data2);
                break;
            case '5'://液位
                $data2['dwtype'] = 'YTLL';
                $data2['start_port'] = '0';
                $data2['rec_cur'] = '0';
                $Res = M()->query("SELECT max(object_code) AS object_code FROM sp_object_share WHERE object_code LIKE '" . $data2['dwtype'] . "-" . $Data['company_code'] . "%'");
                if (empty($Res)) {
                    $data2['object_code'] = $data2['dwtype'] . '-' . $Data['company_code'] . '001';
                } else {
                    $sort = (int)substr($Res[0]['object_code'], 10, 3) + 1;
                    $num = str_pad($sort, 3, "0", STR_PAD_LEFT);
                    $data2['object_code'] = $data2['dwtype'] . '-' . $Data['company_code'] . $num;
                }
                switch ($data['transfer_type']) {
                    case 'NB':
                        if (empty($data3['deviceType']) || empty($data3['manufacturerName']) || empty($data3['model']) || empty($data3['location']) || empty($data3['protocolType'])) {
                            $res['msg'] = "请填写好必要内容";
                            $res['flag'] = false;
                            echo json_encode($res);
                            exit();
                        }
                        $R = ytapi187_query("select * from device where device_id='" . $Data['device_code'] . "'");
                        if (empty($R)) {
                            if (empty($Data['device_code']) || empty($Data['device_name'])) {
                                $res['msg'] = '请填写好必要内容';
                                $res['flag'] = false;
                                echo json_encode($res);
                                exit();
                            }

                            $token = json_decode(gettoken(), true);
                            $sendata = [
                                "verifyCode" => $Data['device_code'],//"868744030067098"
                                "nodeId" => $Data['device_code'],
                                "timeout" => 0
                            ];

                            $header = [
                                "Content-Type:application/json",
                                "app_key:" . $this->appId,
                                "Authorization:Bearer " . $token["accessToken"]
                            ];

                            $rescurl = curl($this->host . "iocm/app/reg/v1.1.0/deviceCredentials?appId=" . $this->appId, json_encode($sendata), $header);
                            if ($rescurl[0] == 200) {
                                $res1 = json_decode($rescurl[1], true);
                            } else {
                                $res['msg'] = $rescurl;
                                $res['flag'] = false;
                                echo json_encode($res);
                                exit();
                            }
                            $list = array();
                            $list['device_id'] = trim($Data['device_code']);
                            $list['name'] = $Data['device_name'];
                            $list['iot_id'] = $res1['deviceId'];
                            $list['psk'] = $res1['psk'];
                            $list['addtime'] = date('Y-m-d H:i:s');
                            $list['updatetime'] = date('Y-m-d H:i:s');
                            $device_table = "dev_" . $Data['device_code'];
                            $create_sql = "
                            CREATE TABLE `" . $device_table . "` (
                              `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
                              `device_id` varchar(200) DEFAULT NULL,
                              `iot_id` varchar(255) DEFAULT NULL,
                              `service` text,
                              `addtime` varchar(50) DEFAULT NULL,
                              `notifyType` varchar(50) DEFAULT NULL,
                              PRIMARY KEY (`id`)
                            ) ENGINE=InnoDB DEFAULT CHARSET=utf8;";

                            ytapi187_inset($create_sql);

                            $rs = ytapi187_inset("INSERT INTO device (device_id,name,addtime,updatetime,iot_id,psk,manufacturerId,manufacturerName,deviceType
                                ,model,location,isSecure,status,protocolType,owner_id) values ('" . $list['device_id'] . "','" . $list['name'] . "','" . $list['addtime'] . "',
                                '" . $list['updatetime'] . "','" . $list['iot_id'] . "','" . $list['psk'] . "','','','','','','','','','')");
                            if ($rs) {
                                $owner1 = M()->query("SELECT company,louyu,unitinfo FROM sp_owner WHERE owner_code = '" . $Data['device_code'] . "'");
                                if ($owner1) {
                                    $data4['owner_name'] = $Data['device_name'];
                                    $data4['unitinfo'] = $Data['unitinfo'];
                                    $data4['louyu'] = $Data['louyu'];
                                    $data4['company'] = $Data['company_code'];
                                    $where4['owner_code'] = $Data['device_code'];
                                    $res4 = M('owner')->where($where4)->save($data4);
                                } else {
                                    $token = json_decode(gettoken(), true);
                                    $sendata = [
                                        "name" => $Data['device_code'],
                                        "deviceType" => $Data['deviceType'],
                                        "manufacturerName" => $Data['manufacturerName'],
                                        "manufacturerId" => $Data['manufacturerId'],//厂商ID ST、ZHYQ、JunyanTest、Topsail
                                        "model" => $Data['model'],
                                        "protocolType" => $Data['protocolType'],
                                        "location" => trim($Data['location']),
                                    ];
                                    $header = [
                                        "Content-Type:application/json",
                                        "app_key:" . $this->appId,
                                        "Authorization:Bearer " . $token["accessToken"]
                                    ];
                                    $rescurl = curl($this->host . "iocm/app/dm/v1.4.0/devices/" . $list['iot_id'] . "?appId=" . $this->appId, json_encode($sendata, 320), $header, "PUT");
                                }
                                if ($rescurl[0] == 204) {//成功
                                    $res1 = json_decode($rescurl[1], true);
                                } else {//失败
                                    $res['msg'] = $rescurl[1];
                                    $res['flag'] = false;
                                    echo json_encode($res);
                                    exit();
                                }

                                $device_update = ytapi187_inset("UPDATE device set deviceType='" . $Data['deviceType'] . "',name='" . $Data['device_name'] . "',manufacturerName=
                                '" . $Data['manufacturerName'] . "',model='" . $Data['model'] . "',isSecure='" . $Data['isSecure'] . "',manufacturerId='" . $Data['manufacturerId'] . "',
                                protocolType='" . $Data['protocolType'] . "',location='" . $Data['location'] . "',updatetime='" . date('Y-m-d H:i:s') . "' where device_id=
                                '" . $Data['device_code'] . "'");
                                $device_query = ytapi187_query("select * from device where device_id='" . $Data['device_code'] . "'");
                                $device_id = $device_query[0]['device_id'];
                                $deviceType = $Data['deviceType'];
                                $create_sql = addtable($device_id, $deviceType);
                                $table = Db::execute($create_sql);
                                $deviceStatus = M()->query("SELECT statustime FROM sp_devices_status WHERE deviceid = '" . $device_query[0]['device_id'] . "'");
                                if (!$deviceStatus) {
                                    $data6['deviceid'] = $device_query[0]['device_id'];
                                    $data6['deviceno'] = 0;
                                    $data6['devicestatus'] = '75';
                                    $data6['statustime'] = date('Y-m-d H:i:s');
                                    $data6['f_evt'] = 40;
                                    $data6['c_evt'] = 00;
                                    $data6['w_evt'] = "";
                                    $data6['true_status'] = '75';
                                    $data6['lastcommtime'] = '0';
                                    $Res2 = M('devices_status')->add($data6);
                                }
                                if ($Data['company_code']) {
                                    ;
                                    $Res1 = M('owner')->add($data);
//                                    $Res2 = M('devices_status')->add($data1);
                                    $Res3 = M('object_share')->add($data2);
                                }
                                if ($device_update) {
                                    $res['msg'] = "操作成功";
                                    $res['flag'] = true;
                                    echo json_encode($res);
                                    exit();
                                } else {
                                    $res['msg'] = "添加失败，请稍后再试";
                                    $res['flag'] = false;
                                    echo json_encode($res);
                                    exit();
                                }


                            } else {
                                $res['msg'] = "添加失败，请稍后再试";
                                $res['flag'] = false;
                                echo json_encode($res);
                                exit();
                            }
                        } else {
                            $res['msg'] = '该设备编号已经添加';
                            $res['flag'] = false;
                            echo json_encode($res);
                            exit();
                        }
                        break;
                    case 'Lora':
                        $a = '';
                        break;
                    case '4G':
                        $Res1 = M('owner')->add($data);
                        $Res2 = M('devices_status')->add($data1);
                        $Res3 = M('object_share')->add($data2);
                        break;
                    default:
                        $res['msg'] = '操作失败，该传输方式不存在，请联系管理员';
                        $res['flag'] = false;
                        echo json_encode($res);
                        exit();
                }
                break;
            case '6'://RTU
                $Res1 = M('owner')->add($data);
                $Res2 = M('devices_status')->add($data1);
                break;
            case '7'://电气火灾
                $Res1 = M('owner')->add($data);
                $Res2 = M('devices_status')->add($data1);
                break;
            case '16'://视频监测
                $data2['dwtype'] = 'YTVA';
                $Res1 = M('owner')->add($data);
                $Res2 = M('devices_status')->add($data1);
                $Res3 = M('object_share')->add($data2);
                break;
            case '17'://电梯监测
                $data2['dwtype'] = 'YTLF';
                $Res1 = M('owner')->add($data);
                $Res2 = M('devices_status')->add($data1);
                $Res3 = M('object_share')->add($data2);
                break;
            case '128'://井盖
                $data2['dwtype'] = 'YTMC';
                $Res1 = M('owner')->add($data);
                $Res2 = M('devices_status')->add($data1);
                $Res3 = M('object_share')->add($data2);
                break;
            case '129'://地磁
                $Res1 = M('owner')->add($data);
                $Res2 = M('devices_status')->add($data1);
                break;
            case '130'://门禁
                $Res1 = M('owner')->add($data);
                $Res2 = M('devices_status')->add($data1);
                break;
            case '131'://可燃气体
                $Res1 = M('owner')->add($data);
                $Res2 = M('devices_status')->add($data1);
                break;
            default:
                $res['msg'] = '操作失败，设备类型尚未定义，请联系管理员';
                $res['flag'] = false;
                echo json_encode($res);
                exit();
                break;
        }

        if ($Res1 == 1 && $Res2 == 1) {
            $res['msg'] = '操作成功';
            $res['flag'] = true;
        } else {
            $res['msg'] = '操作失败';
            $res['flag'] = true;
        }
    }

    public function getNbApplicationList(){
        $url="https://ttl.turboes.com/api/api/login";
        $parameter=[
            "appKey" => "wLHvcVHS",
            "appSecret" => "a9daf060059d205280646a1880cd1fc24f3c5c69"
        ];
        $accessToken = json_post($url,$parameter);
        $accessToken_array=json_decode($accessToken,true);
//        print_r($accessToken_array);

        if ($accessToken_array['code']==200){
            $url="https://ttl.turboes.com/api/ttl/api/v1/app?access_token=".$accessToken_array['data']['token'];
//            $parameter=[
//                "access_token" => $accessToken_array['data']['token']
//            ];
//            print_r(json_encode($parameter));

            $R= curl_get($url);

            $R1=json_decode($R,true);
            if ($R1['code']==200){
                $res['msg'] = "操作成功";
                $res['data'] = $R1['data'];
                $res['flag'] = true;
                echo json_encode($res);
            }else{
                $res['msg'] = $R1['message'];
                $res['flag'] = false;
                echo json_encode($res);
                exit();
            }
        }else{
            $res['msg'] = $accessToken_array['message'];
            $res['flag'] = false;
            echo json_encode($res);
            exit();
        }
    }
}