ytapi/admin/controller/Dataacceptance.php.bak.2021-11-05-1

<?php

namespace app\admin\controller;

use think\Controller;
use think\Session;
use think\Db;
use think\Request;
use think\Log;

class Dataacceptance extends Controller
{
    public function getData()
    {
        $Data = input('');
        if (is_array($Data)) {
            $getDataJson = json_encode($Data, 320);
            $getdata = json_decode($getDataJson, true);//转成数组
        } else {
            $getDataJson = $Data;
            $getdata = json_decode($getDataJson, true);//转成数组
        }
        $json_string = json_encode($getdata, JSON_FORCE_OBJECT);
        Log::record('yangpu4GRawData:' . $json_string);


        $bin_data = $getdata['msg']['value']['bin_data'];
        if (empty($bin_data)) {
            $returnInformation['code'] = false;
            $returnInformation['msg'] = "数据格式错误";
            return json_encode($returnInformation);
        }
        Log::record('yangpu4GData' . ':' . $bin_data);
        //数据类型
        $type = substr($bin_data, 8, 2);
        //数据长度
        $length = substr($bin_data, 10, 4);
        //设备类型
        $device_type = substr($bin_data, 14, 2);
        //设备编号截取拼接
        $devide_id1 = ((int)substr($bin_data, 16, 2)) - 30;
        $devide_id2 = ((int)substr($bin_data, 18, 2)) - 30;
        $devide_id3 = ((int)substr($bin_data, 20, 2)) - 30;
        $devide_id4 = ((int)substr($bin_data, 22, 2)) - 30;
        $devide_id5 = ((int)substr($bin_data, 24, 2)) - 30;
        $devide_id6 = ((int)substr($bin_data, 26, 2)) - 30;
        $devide_id7 = ((int)substr($bin_data, 28, 2)) - 30;
        $devide_id8 = ((int)substr($bin_data, 30, 2)) - 30;
        $devide_id9 = ((int)substr($bin_data, 32, 2)) - 30;
        $devide_id10 = ((int)substr($bin_data, 34, 2)) - 30;
        $devide_id11 = ((int)substr($bin_data, 36, 2)) - 30;
        $devide_id12 = ((int)substr($bin_data, 38, 2)) - 30;
        $devide_id13 = ((int)substr($bin_data, 40, 2)) - 30;
        $devide_id14 = ((int)substr($bin_data, 42, 2)) - 30;
        $devide_id15 = ((int)substr($bin_data, 44, 2)) - 30;
        $device_code = $devide_id1 . $devide_id2 . $devide_id3 . $devide_id4 . $devide_id5 . $devide_id6 . $devide_id7 . $devide_id8 . $devide_id9 . $devide_id10 . $devide_id11 . $devide_id12 . $devide_id13 . $devide_id14 . $devide_id15;
        //发送时间截取拼接
        $send_time1 = substr($bin_data, 48, 2);
        $send_time2 = substr($bin_data, 50, 2);
        $send_time3 = substr($bin_data, 52, 2);
        $send_time4 = substr($bin_data, 54, 2);
        $send_time5 = substr($bin_data, 56, 2);
        $send_time6 = substr($bin_data, 58, 2);
        $time = '20' . $send_time1 . '-' . $send_time2 . '-' . $send_time3 . ' ' . $send_time4 . ':' . $send_time5 . ':' . $send_time6;

//        print_r($time);

        //电池电量
        $battery_level = hexdec(substr($bin_data, 60, 2));
        //信号强度
        $signal_strength = substr($bin_data, 62, 2);
        if ((int)$signal_strength <= 6 && (int)$signal_strength != 0) {
            $signal_level = 1;
        } else if ((int)$signal_strength <= 12) {
            $signal_level = 2;
        } else if ((int)$signal_strength <= 18) {
            $signal_level = 3;
        } else if ((int)$signal_strength <= 24) {
            $signal_level = 4;
        } else if ((int)$signal_strength <= 31) {
            $signal_level = 5;
        } else {
            $signal_level = 0;
        }

        //设备采集数据解析
        $device_type_10 = hexdec($device_type);
        if ($device_type_10 != 1 && $device_type_10 != 2 && $device_type_10 != 3 && $device_type_10 != 4) {//&& $device_type_10 != 7 && $device_type_10 != 8 && $device_type_10 != 9
            $returnInformation['code'] = false;
            $returnInformation['msg'] = "该类型未定义";
            return json_encode($returnInformation);
        }
        $sample_data = substr($bin_data, 64, 8);
        $sample_data_unit1 = substr($bin_data, 64, 2);
        $sample_data_unit2 = substr($bin_data, 66, 2);
        $sample_data_unit3 = substr($bin_data, 68, 2);
        $sample_data_unit4 = substr($bin_data, 70, 2);

        $sample_data_unit1_high = substr($sample_data_unit1, 0, 1);
        $sample_data_unit1_low = substr($sample_data_unit1, 1, 1);

        $sample_data_unit2_high = substr($sample_data_unit2, 0, 1);
        $sample_data_unit2_low = substr($sample_data_unit2, 1, 1);

        $sample_data_unit3_high = substr($sample_data_unit3, 0, 1);
        $sample_data_unit3_low = substr($sample_data_unit3, 1, 1);

        $sample_data_unit4_high = substr($sample_data_unit4, 0, 1);
        $sample_data_unit4_low = substr($sample_data_unit4, 1, 1);

        $value=$sample_data_unit2_low.$sample_data_unit3_high.$sample_data_unit3_low.$sample_data_unit4_high.$sample_data_unit4_low;
        switch ($sample_data_unit2_high) {
            case '1':
                $alarm_value=(int)$value*0.1;
                break;
            case '2':
                $alarm_value=(int)$value*0.01;
                break;
            case '3':
                $alarm_value=(int)$value*0.001;
                break;
            case '4':
                $alarm_value=(int)$value*0.0001;
                break;
        }


        if ($sample_data_unit1_low==1){
            $alarm_type='WP'.$sample_data_unit1_high;
            $alarm_value=$alarm_value;
        }else if ($sample_data_unit1_low==2){
            $alarm_type='WP'.$sample_data_unit1_high;
            $alarm_value=$alarm_value*0.1;

        }else if ($sample_data_unit1_low==3){
            $alarm_type='WP'.$sample_data_unit1_high;
            $alarm_value=$alarm_value*1000;

        }else if ($sample_data_unit1_low==4){
            $alarm_type='LL'.$sample_data_unit1_high;
            $alarm_value=$alarm_value;
        }else{
            $returnInformation['code'] = false;
            $returnInformation['msg'] = "单位未定义";
            return json_encode($returnInformation);
        }


        switch ($alarm_type) {
            case 'LL0':
            case 'WP0':
                $alarm_data='正常';
                break;
            case 'WP1':
                $alarm_data='低压';
                break;
            case 'WP2':
                $alarm_data='高压';
                break;
            case 'LL3':
            case 'WP3':
                $alarm_data='故障';
                break;
            case 'LL4':
            case 'WP4':
                $alarm_data='波动告警';
                break;
            case 'LL5':
            case 'WP5':
                $alarm_data='碰撞告警';
                break;
            case 'LL6':
            case 'WP6':
                $alarm_data='倾斜告警';
                break;
            case 'LL7':
            case 'WP7':
                $alarm_data='水流告警';
                break;
            case 'LL8':
            case 'WP8':
                $alarm_data='进水告警';
                break;
            case 'LL9':
            case 'WP9':
                $alarm_data='低电量告警';
                break;
            case 'LL1':
                $alarm_data='低水位';
                break;
            case 'LL2':
                $alarm_data='高水位';
                break;
            default:
                $returnInformation['code'] = false;
                $returnInformation['msg'] = "未知告警";
                return json_encode($returnInformation);
                break;
        }

        $res_owner=add("select owner_code,dwtype,company from sp_owner where owner_code='".$device_code."'");
        if (empty($res_owner)){
            $returnInformation['code'] = false;
            $returnInformation['msg'] = "该设备未注册";
            return json_encode($returnInformation);
        }

        ////闵行MQTT
        $json_data_one=$this->mh_array_turn_json(1,$device_code,$signal_level*20,$battery_level,strtotime($time),'',$alarm_type);
        if (!empty($json_data_two)){
            $this->message_push_mh("mh/water/info",$json_data_one,0);
        }




        $sql="INSERT INTO sp_d".$device_code." (id,device_code,port,time,status,address,ncmd,data1,data2,data3,data4,data5) VALUES ('','".$device_code."','tp_water_pressure','".$time."','','','','".$alarm_type."','".$battery_level."','".$signal_level."','".$alarm_value."','11111111111')";
        Log::record('yangpu4GRawSql:' . $sql);
        $R = addDataInfo($sql);

        //addDataInfoInsert
        if ($alarm_data=='低压'||$alarm_data=='高压'|$alarm_data=='低水位'|$alarm_data=='高水位'|$alarm_data=='故障'|$alarm_data=='波动告警'){
            $sql1="INSERT INTO sp_sj2017 (id,port,device_code,time,status,address,ncmd,data1,data2,data3,data4,data5,cllxr,clsj,clr,clnr,clwb,cldh,clzt,cllx,video) 
                    VALUES ('','tp_water_pressure','".$device_code."','".$time."','','拓普索尔4G','','".$alarm_type."','".$battery_level."','".$signal_level."','".$alarm_value."','拓普索尔','','0','','','','','0','','')";
            Log::record('yangpu4GAlarmSql:' . $sql1);
            $Res = addDataInfoInsert($sql1);
            //闵行MQTT
            if ($alarm_type=='WP1'||$alarm_type=='WP2'||$alarm_type=='LL9'||$alarm_type=='WP9'){
                $json_data_two=$this->mh_array_turn_json(2,$device_code,$signal_level*20,$battery_level,strtotime($time),'',$alarm_type);
                if (!empty($json_data_two)){
                    $this->message_push_mh("mh/water/alert",$json_data_two,0);
                }
                $device = Db::name('yt_t_mhwater')->where('device_code', $device_code)->find();
                $json_data_three=$this->date_array_turn_json($device,strtotime($time),$alarm_data,0,'','');
                if (!empty($json_data_three)){
                    $this->message_push_mh("mh/water/statistics",$json_data_three,0);

                }
                $json_data_four=$this->date_array_turn_json($device,strtotime($time),$alarm_data,1,'','');
                if (!empty($json_data_four)){
                    $this->message_push_mh("mh/water/statistics",$json_data_four,0);
                }

            }


//            print_r('id'.$Res);
            $phone_data=add("select phone from sp_owner_phone where owner_code='".$res_owner[0]['company']."' group by phone");
            $openids = $this->array_column1($phone_data, "phone");



            $wx_data['IMEI']=$device_code;
            $wx_data['phone']=$openids;
            $wx_data['evt']=$alarm_type;
            $wx_data['time']=$time;
            $wx_data['insert_id']=$Res;
            $wx_data['bz']='';
            $wx_data['user_from']='water_form';
            $wx_data['Status']=$alarm_type;

            if ($res_owner[0]['dwtype']==2){
                $url        = "https://iot.usky.cn/jdxf/wxapp2.php/Home/Waterwarn/message_water";
            }else{
                $url        = "https://iot.usky.cn/jdxf/wxapp2.php/Home/Yeweiwarn/message_water";
            }

            Log::record('yangpu4GWxUrl'.':'.$url);
            Log::record('yangpu4GWxData'.':'.json_encode($wx_data, JSON_FORCE_OBJECT));
            $res = $this->curl($url,$wx_data);
            print_r($res);

        }

        $returnInformation['code'] = true;
        $returnInformation['msg'] = "成功";
        return json_encode($returnInformation);
    }

    public function array_column1($rows, $column_key, $index_key = null) {
        $data = array();
        if (empty($index_key)) {
            foreach ($rows as $row) {
                $data[] = $row[$column_key];
            }
            $data=implode(",",$data);
        } else {
            foreach ($rows as $row) {
                $data[$row[$index_key]] = $row[$column_key];
            }
        }
        return $data;
    }

    public function curl($url,$data=''){
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (compatible; MSIE 5.01; Windows NT 5.0)');
        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
        curl_setopt($ch, CURLOPT_AUTOREFERER, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        $info = curl_exec($ch);
        if (curl_errno($ch)) {
            $info = 'ERROR: ' . curl_error($ch);
        }
        curl_close($ch);
        return $info;
    }

    /**
     * @param $type 1心跳 2报警
     * @param $DeviceCode 设备编号
     * @param $signalLevel 信号
     * @param $volt 电量
     * @param $createdTime 时间 时间戳
     * @param $param 暂留
     * @param $alarm_type 告警编码
     * @return false|string|null
     */
    public function mh_array_turn_json($type,$DeviceCode,$signalLevel,$volt,$createdTime,$param,$alarm_type){
        $device = Db::name('yt_t_mhwater')->where('device_code', $DeviceCode)->find();
        $param = [];
        if ($type==1){
            if (!empty($device)){
                $arr = [
                    "deviceCode" => $device['mh_device_code'],
                    "signalLevel"=>$signalLevel,
                    "volt"=>$volt,
                    "lon"=>(double)$device['longitude'],
                    "lat"=>(double)$device['latitude'],
                    "createdTime"=>$createdTime,
                    "param"=>(object)$param
                ];
                $json_data=json_encode($arr);

            }else{
                $json_data = null;
            }
        }else{
            if (!empty($device)){
                $eventCode1 = "02";
                $eventName1 = "预警事件";
                switch ($alarm_type) {
                    case 'WP1':
                    case 'WP2':
                        $eventCode2 = '02008';
                        $eventName2 = '水压报警';
                        break;
                    case 'LL9':
                    case 'WP9':
                        $eventCode2 = '02002';
                        $eventName2 = '电量不足';
                        break;
                    default:
                        $eventCode2 = '02000';
                        $eventName2 = '其他';
                        break;
                }
                $arr = [
                    "deviceCode" => $device['mh_device_code'],
                    "lon"=>(double)$device['longitude'],
                    "lat"=>(double)$device['latitude'],
                    "createdTime"=>$createdTime,
                    "addr"=>"上海市",
                    "eventCode1"=>$eventCode1,
                    "eventName1"=>$eventName1,
                    "eventCode2"=>$eventCode2,
                    "eventName2"=>$eventName2,
                    "description"=>"备注信息",
                    "param"=>(object)$param
                ];
                $json_data=json_encode($arr);
            }else{
                $json_data = null;
            }
        }
        return $json_data;
    }



    public function date_array_turn_json($device,$createdTime,$ajDescribe,$ajFlag,$enclosure,$image){
        if (!empty($device)){
            $arr = [
                "createTime" =>date("Y-m-d H:i:s",$createdTime) ,
                "ajType"=>$device['aj_type'],
                "street"=>$device['street'],
                "address"=>$device['company_address'].'，'.$device['device_address'],
                "grid"=>$device['grid'],
                "ajDescribe"=>$ajDescribe,
                "dutyGroup"=>$device['company_name'],
                "ajFlag"=>$ajFlag,
                "endTime"=>date("Y-m-d H:i:s",$createdTime+86400),
                "enclosure"=>$enclosure,
                "image"=>$image
            ];
            $json_data=json_encode($arr);
        }else{
            $json_data=null;
        }
        return $json_data;
    }

    public function message_push_mh($topic,$msg,$qos){
        vendor('phpMQTT.phpMQTT');
        $server = '47.98.201.73';     // 服务器IP
        $port = 1883;            // 服务器端口
        $username = 'usky';              // 用户名
        $password = 'usky';              // 密码
        $client_id = 'pub_' . uniqid();
        $mqtt = new \phpMQTT($server, $port, $client_id);
        if ($mqtt->connect(true, NULL, $username, $password)) {
            $mqtt->publish($topic, $msg, $qos);
            usleep(100000);
            $mqtt->close();
            Log::record('MH—4G-MQTT-Push success!('.$topic.')['.date('Y-m-d H:i:s').']:'.json_encode($msg));
        } else {
            Log::record('MH—4G-MQTT-Time out!('.$topic.')['.date('Y-m-d H:i:s').']:'.json_encode($msg));
        }
    }
}