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

<?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";

    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：拓扑索尔
        $data3['manufacturerName']=$Data['manufacturerName'];//厂商名称：ST、ZHYQ、shanghaijunyanTest、Topsail
        $data3['model']=$Data['model'];//设备型号 烟感型号:517N01、水表型号：PT124B-2892-010、宇洁戎情水表型号：WPTA、拓扑索尔水表液位：TH12
        $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'] = 3002;
                            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'] = 3002;
                                echo json_encode($res);
                                exit();
                            }
//                            print_r("测试".$R);
//                            exit();
                            $token = json_decode(gettoken(), true);

                            $sendata = [
                                "verifyCode" => $data['device_id'],//"868744030067098"
                                "nodeId" => $data['device_id'],
                                "timeout" => 0
                            ];
                            $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'] = 3002;
                                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'] = 3002;
                                    echo json_encode($res);
                                    exit();
                                }

//                                $list = array();
//                                $data5['deviceType'] = $data['deviceType'];//设备类型
//                                $data5['name'] = $data['name'];//设备类型
//                                $data5['manufacturerName'] = $data['manufacturerName'];//厂商名称
//                                $data5['model'] = $data['model'];//设备型号
//                                $data5['isSecure'] = $data['isSecure'];
//                                $data5['manufacturerId'] = $data['manufacturerId'];//设备型号
//                                $data5['protocolType'] = $data['protocolType'];
//                                $data5['location'] = $data['location'];
//                                $data5['updatetime'] = date('Y-m-d H:i:s');

                                $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']."'");
//                                print_r("select * from devcie where device_id='".$Data['device_code']."'");
//                                exit();
                                $device_query=ytapi187_query("select * from device where device_id='".$Data['device_code']."'");
//                                $res = Db::name('device')->where('id', $data['id'])->update($data5);
//                                $res1 = Db::name('device')->where('id', $data['id'])->find();

                                $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';
                                    $device_status=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'] = 3002;
                                    echo json_encode($res);
                                    exit();
                                }


                            } else {
                                $res['msg'] = "添加失败，请稍后再试";
                                $res['flag'] = 3002;
                                echo json_encode($res);
                                exit();
                            }
                        } else {
                            $res['msg'] = '该设备编号已经添加';
                            $res['flag'] = 3002;
                            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'] = 3002;
                        echo json_encode($res);
                        exit();
                }
                break;
            case '3'://烟感
                $data2['dwtype'] = 'YTSM';
                switch ($data['transfer_type']) {
                    case 'NB':

                        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'] = 3002;
                        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';
                switch ($data['transfer_type']) {
                    case 'NB':

                        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'] = 3002;
                        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'] = 3002;
                echo json_encode($res);
                exit();
                break;
        }

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