ytapi/application/admin/controller/Dataacceptance.php.bak.2021-11-04

<?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);
        }


        $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);
//            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;
    }
}