USKYZHAF/Home/Controller/ManholeCoverwarnController.class.php

<?php

namespace Home\Controller;

use Think\Controller;

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

class ManholeCoverwarnController extends PushWarnController
{
    public function message_manhole_cover()
    {
        $Data = I('post.');
        //日志打印
        $filename_log = "/var/www/html/jdxf/log/manhole_cover_b_log" . date("Y-m-d") . ".log";
        $this->printing_log($Data, $filename_log);
        if (!empty($Data['device_code'])) {
            $device_code = $Data['device_code'];
        }
        $insert_id = $Data['insert_id'];
        $remarks = $Data['bz'];
        $time = $Data['time'];
        $evt = $Data['evt'];

        switch ($evt) {
            case 'JG01':
                $evt_name = '恢复';
                $where = " AND data2 like '%a%'";
                break;
            case 'JG02':
                $evt_name = '打开告警';
                $where = " AND data2 like '%a%'";
                break;
            case 'JG03':
                $evt_name = '角度传感器异常';
                $where = " AND data2 like '%a%'";
                break;
            case 'JG04':
                $evt_name = '温湿度传感器异常';
                $where = " AND data2 like '%a%'";
                break;
            default:
                $evt_name = '其他' . $evt;
                $where = " AND data2 like '%a%'";
                break;
        }


        $data = M()->query("select s.owner_name,s.unitinfo,s.company,c.owner_address from sp_owner s ,sp_owner_company c where s.company=c.owner_id and s.owner_code ='" . $device_code . "'");
        $union_sql = M()->query("select phone from sp_owner_phone  WHERE owner_code='" . $data[0]['company'] . "' " . $where . "  union select phone from sp_owner_phone  WHERE owner_code in (select other_code from sp_owner_fujin where owner_code='" . $data[0]['company'] . "') " . $where . " ");
        if (count($union_sql) == 0) {
            echo "phone is null";
            exit;
        }
        $openids = $this->array_column1($union_sql, "phone");
        if (empty($openids)) {
            echo 'open is null';
            exit;
        }
        $status11 = M()->query("SELECT statustime FROM sp_devices_status where deviceid='" . $device_code . "'");
        $op = M()->query("SELECT openid FROM sp_wx_customuser WHERE type='wx' and idphone in($openids)");

        $access_token = GetAccess_Token1();
        $address = '警报地址：' . $data[0]['owner_address'] . $data[0]['unitinfo'];
        $type = $evt_name;

        //keyword3.DATA
        if (empty($time)) {
            $time = $status11[0]['statustime'];
        }
        //remark.DATA
        if (empty($remarks)) {
            $remarks = '设备名称：' . $data[0]['owner_name'];
        }

        $url = "https://iot.usky.cn/jdxf/wxapp2.php/Home/Fireinfo/index/type/128/id/" . $insert_id;;
        foreach ($op as $o) {
            if (!empty($o['openid'])) {
                $R = $this->SendDeviceAlarm($access_token, $o['openid'], $address, $device_code, $type, $time, $remarks, $url);
                //日志打印
                $filename_log = "/var/www/html/jdxf/log/manhole_cover_t_log" . date("Y-m-d") . ".log";
                $this->printing_log($R, $filename_log);
                print_r($R);
            }
        }

    }

}