wxapp2/Home/Controller/ManholeCoverwarnController.class.php

<?php

namespace Home\Controller;

use Think\Controller;

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

class ManholeCoverwarnController extends PushWarnController
{
    /**
     * "evt"      => "09",
     * "IMEI"     => 设备编号,
     * "DateTime" => 时间,
     * "Interval" => 间隔时间,
     * "Status"   => 状态,
     * "Battery"  => 电量,
     * "Signal"   => 信号,
     * "Unit"     => 单位,
     * "Pressure" => 水压值,
     * "phone" => 电话,
     * "insert_id" => 插入表id
     * @return [type] [description]
     */
    public function message_manhole_cover()
    {
        $Data = I('post.');
        $log = "[时间" . date("Y-m-d H:i:s") . "]报警数据：" . json_encode($Data) . "\r\n";
        $filename_log = "/var/www/html/jdxf/log/Gg_log" . date("Y-m-d") . ".log";
        file_put_contents($filename_log, $log, FILE_APPEND | LOCK_EX);
        print_r($Data);
        if (empty($Data['phone'])) {
            dump($Data['phone']);
            exit;
        }
        if (!empty($Data['device_code'])) {
            $dataid = $Data['device_code'];
        } else {
            exit;
        }
        $openids = $Data['phone'];
        $insert_id = $Data['insert_id'];
        $user_from = $Data['user_from'];
//            $evt_name=$Data['evt_name'];
        $time = $Data['time'];
        $bz = $Data['bz'];

        switch ($Data['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 = '其他' . $Data['evt'];
                $where = " AND data2 like '%a%'";
                break;
        }


        $company = 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 ='" . $dataid . "'");
        $union_sql = M()->query("select phone from sp_owner_phone  WHERE owner_code='" . $company[0]['company'] . "' " . $where . "  union select phone from sp_owner_phone  WHERE owner_code in (select other_code from sp_owner_fujin where owner_code='" . $company[0]['company'] . "') " . $where . "");
        if (count($union_sql) == 0) {
            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='" . $dataid . "'");
        $op = M()->query("SELECT openid FROM sp_wx_customuser WHERE type='wx' and idphone in($openids)");

        $access_token = GetAccess_Token1();
        $address = '警报地址：' . $company[0]['owner_address'] . $company[0]['unitinfo'];
        $deviceid = $dataid;
        $type = $evt_name;
        if (empty($Data['phone'])) {
            $time = $status11[0]['statustime'];
        }

        $ljcompany = $company[0]['company'];
        if (!empty($bz)) {
            $remark = $bz;
        } else {
            $remark = '设备名称：' . $company[0]['owner_name'];
        }
        $ljurl = "https://qhome.usky.cn/jdxf/wxapp2.php/Home/Fireinfo/index/type/128/id/" . $insert_id;
//              $op=array(['openid'=>$Data['phone']]);
//              print_r($op);
        foreach ($op as $o) {
            if (!empty($o['openid'])) {
//                  print_r('参数1'.$access_token);
//                  print_r('参数2'.$o['openid']);
//                  print_r('参数3'.$address);
//                  print_r('参数4'.$deviceid);
//                  print_r('参数5'.$type);
//                  print_r('参数6'.$time);
//                  print_r('参数7'.$remark);
//                  print_r('参数8'.$ljurl);
                //token，微信id，地址，设备号，类型，时间，设备名称（或者其他内容）
                //{{first.DATA}}$address
                //设备号：{{keyword1.DATA}}$deviceid
                //报警类型：{{keyword2.DATA}}$type
                //时间：{{keyword3.DATA}}$time
                //{{remark.DATA}}$remark
                $a = $this->SendDeviceAlarm($access_token, $o['openid'], $address, $deviceid, $type, $time, $remark, $ljurl, $url = '');
                print_r($a);
            }
        }

    }

}