<?php
/***
 * 千寻数据采集
 */

namespace app\api\controller\reservoir;

use app\common\controller\Api;
use think\Request;
use think\Db;
use qx\Qx;
use addons\alisms\controller\Index;

/**
 * Class Equipment
 * @package app\api\controller\reservoir
 */
class Equipment extends Api
{
    protected $model = '';
    protected $noNeedLogin = ['waterlevel_for_xiongyue', 'rainfall_for_xiongyue', 'reservoirWaterlevelPush', 'reservoirRainfallPush', 'getRainEquipment', 'abnormal', 'day30', 'getQxList', 'equipmentType', 'getData', 'getDisplacement', 'getAllData', 'getIsotonic', 'getRainfall', 'getWaterLevel', 'getReservoirId', 'getSeepage', 'qx_url_data', 'getWaterLevelKevin'];
    protected $noNeedRight = '*';

    //硬件分类编码 1=水位计 L4_NW ；2=渗流计 L3_SL；3=渗压计 L3_SY（L3_DX）；5=雨量计 L3_SL；6=位移检测 L1_GP；
    protected $equipmentCateType = ["1" => "L4_NW", "2" => "L3_SL", "3" => "L3_SY", "5" => "L3_SL", "6" => "L1_GP"];

    public function _initialize()
    {
        parent::_initialize(); // TODO: Change the autogenerated stub
        $this->model = new \app\admin\model\reservoir\Equipment;

    }

    public function getrianequipmentlist($ids = null)
    {
        $map = [];
        $map['reservoir_id'] = ['=', $ids];
        $type = $this->request->param('type', 1);
        if (in_array($type, ['1', '2', '3', '4', '5', '6', '7'])) {
            $map['type'] = ['=', $type];
        }
        $list = $this->model
            ->field('id,deviceId,name,status,from_unixtime(createtime,"%Y-%m-%d") as ctrs')
            ->where($map)
            ->select();
        $this->success('', $list);
    }

    public function day30()
    {
        $list = Db::name('reservoir_list')->field('id,name')->select();
        foreach ($list as $key => $item) {
            for ($i = 30; $i >= 1; $i--) {
                $k = $i - 1;
                ${'predaystart' . $i} = strtotime(date('Y-m-d', strtotime("-$i day")));
                ${'predayend' . $i} = strtotime(date('Y-m-d', strtotime("-$k day")));

                ${'predaycount' . $i} = array_sum([
                    Db::name('reservoir_hkws_warning')->where('createtime', '>=', ${'predaystart' . $i})->where('createtime', '<', ${'predayend' . $i})->where('reservoir_id', $item['id'])->count(),
                    Db::name('reservoir_warning_crack')->where('createtime', '>=', ${'predaystart' . $i})->where('createtime', '<', ${'predayend' . $i})->where('reservoir_id', $item['id'])->count(),
                    Db::name('reservoir_warning_displacement')->where('createtime', '>=', ${'predaystart' . $i})->where('createtime', '<', ${'predayend' . $i})->where('reservoir_id', $item['id'])->count(),
                    Db::name('reservoir_warning_invade')->where('createtime', '>=', ${'predaystart' . $i})->where('createtime', '<', ${'predayend' . $i})->where('reservoir_id', $item['id'])->count(),
                    Db::name('reservoir_warning_rainfall')->where('createtime', '>=', ${'predaystart' . $i})->where('createtime', '<', ${'predayend' . $i})->where('reservoir_id', $item['id'])->count(),
                    Db::name('reservoir_warning_settlement')->where('createtime', '>=', ${'predaystart' . $i})->where('createtime', '<', ${'predayend' . $i})->where('reservoir_id', $item['id'])->count(),
                    Db::name('reservoir_warning_waterlevel')->where('createtime', '>=', ${'predaystart' . $i})->where('createtime', '<', ${'predayend' . $i})->where('reservoir_id', $item['id'])->count(),
                    Db::name('reservoir_warning_waterseepage')->where('createtime', '>=', ${'predaystart' . $i})->where('createtime', '<', ${'predayend' . $i})->where('reservoir_id', $item['id'])->count(),
                    Db::name('reservoir_warning_weather')->where('createtime', '>=', ${'predaystart' . $i})->where('createtime', '<', ${'predayend' . $i})->where('reservoir_id', $item['id'])->count()
                ]);

                $res[$item['id']]['date'][] = date('Y-m-d', strtotime("-$i day"));
                $res[$item['id']]['count'][] = ${'predaycount' . $i};
                $res[$item['id']]['name'] = $item['name'];
            }
            $today = strtotime(date("Y-m-d", time()));
            $todaylist = array_sum([
                Db::name('reservoir_hkws_warning')->where('createtime', '>=', $today)->where('reservoir_id', $item['id'])->count(),
                Db::name('reservoir_warning_crack')->where('createtime', '>=', $today)->where('reservoir_id', $item['id'])->count(),
                Db::name('reservoir_warning_displacement')->where('createtime', '>=', $today)->where('reservoir_id', $item['id'])->count(),
                Db::name('reservoir_warning_invade')->where('createtime', '>=', $today)->where('reservoir_id', $item['id'])->count(),
                Db::name('reservoir_warning_rainfall')->where('createtime', '>=', $today)->where('reservoir_id', $item['id'])->count(),
                Db::name('reservoir_warning_settlement')->where('createtime', '>=', $today)->where('reservoir_id', $item['id'])->count(),
                Db::name('reservoir_warning_waterlevel')->where('createtime', '>=', $today)->where('reservoir_id', $item['id'])->count(),
                Db::name('reservoir_warning_waterseepage')->where('createtime', '>=', $today)->where('reservoir_id', $item['id'])->count(),
                Db::name('reservoir_warning_weather')->where('createtime', '>=', $today)->where('reservoir_id', $item['id'])->count()
            ]);
            $res[$item['id']]['date'][] = date("Y-m-d", time());
            $res[$item['id']]['count'][] = $todaylist;

        }
        //dump($res);
        foreach ($res as $key => $item) {
            foreach ($item['date'] as $key1 => $item1) {
                $arr[] = [$item['count'][$key1], 1, 1, $item['name'], 1920];
            }
        }
        $this->success('', $arr);
    }

    // 异常
    public function abnormal()
    {
        $crack = Db::name('reservoir_dam_crack')->order('id desc')->value('warning');
        $displacement = Db::name('reservoir_dam_displacement')->order('id desc')->value('warning');
        $settlement = Db::name('reservoir_dam_settlement')->order('id desc')->value('warning');
        $th = Db::name('reservoir_dam_th')->order('id desc')->value('warning');
        $waterseepage = Db::name('reservoir_dam_waterseepage')->order('id desc')->value('warning');
        $count = 0;
        $data = [$crack, $displacement, $settlement, $th, $waterseepage];
        foreach ($data as $key => $item) {
            $item == '0' ? $count++ : '';
        }
        $error = count($data) - $count;
        $bili = ($count / count($data)) * 100;
        $this->success('', ['zc' => $count, 'yc' => $error, 'bilv' => $bili]);
    }

    //县市雨量计水位计统计
    public function getRainEquipment($id)
    {
        $reservoirids = Db::name('reservoir_list')->where('county_id', $id)->field('id')->select();
        $ids = [];
        foreach ($reservoirids as $k => $v) {
            $ids[] = $v['id'];
        }
        $res['equipment']['rain'] = Db::name('reservoir_equipment')->where('type', '5')->where('reservoir_id', 'in', $ids)->where('company_type', '1')->count();//雨量计
        $res['equipment']['water'] = Db::name('reservoir_equipment')->where('type', '1')->where('reservoir_id', 'in', $ids)->where('company_type', '1')->count();//水位计
        $res['warning']['rain'] = Db::name('reservoir_warning_rainfall')->where('deal', 1)->where('reservoir_id', 'in', $ids)->count();//雨量不正常
        $res['warning']['water'] = Db::name('reservoir_warning_waterlevel')->where('deal', 1)->where('reservoir_id', 'in', $ids)->count();//水位不正常
        $this->success('', $res);
    }

    // 设备列表
    public function list($ids = null)
    {
        $res = Db::name('reservoir_hkws_hardware')
            ->field('name as DeviceName,case status when 1 then "在线" else "离线" end as EquipmentState,scode as EquipmentSerialNumber,from_unixtime(createtime,"%Y-%m-%d") as CreationTime')
            ->where('reservoir_id', $ids)
            ->select();
        $res2 = Db::name('reservoir_equipment')
            ->field('name as DeviceName,case status when 1 then "在线" else "离线" end as EquipmentState,deviceId as EquipmentSerialNumber,from_unixtime(createtime,"%Y-%m-%d") as CreationTime')
            ->where('reservoir_id', $ids)
            ->where('company_type', '1')
            ->select();
        $list = array_merge($res, $res2);
        $data = ['list' => $list];
        $this->success('', $list);
    }

    //获取千寻设备
    public function getQxList()
    {
        $qx = new Qx();
        $info = json_decode($qx->geturl("http://openapi.qxwz.com/rest/linkx.devices.list/ack/U48c2jnr9901?pageNo=1&pageSize=2000"), true);
        foreach ($info['data']['items'] as $k => $v) {
            $data[] = [
                'deviceId' => $v['deviceId'],
                'apiKey' => $v['apiKey'],
                'name' => $v['name'],
                'status' => '1',
                'reservoir_id' => $this->getReservoirId($v['name']),
                'type' => $this->equipmentType($v['name']),
                'createtime' => time()
            ];
        }
        Db::name('reservoir_equipment')->where('id', '>=', '0')->where('company_type', '1')->delete();
        Db::name('reservoir_equipment')->insertAll($data);
    }

    public function getReservoirId($name)
    {
        $name = strstr($name, '水库', true);
        $id = Db::name('reservoir_list')->where('name', 'like', "%$name%")->value('id');
        return $id;
    }

    //统一采集数据接口
    public function getAllData()
    {
        $this->getWaterLevel();//水位
        $this->getRainfall();//雨量
        $this->getSeepage();//渗流
        $this->getIsotonic();//渗压
        $this->getDisplacement();//坝体位移
    }

    public function getSeepage()
    {
        $list = Db::name('reservoir_equipment')->where('type', '2')->where('company_type', '1')->select();
        $data = [];
        $startTime = Db::name('reservoir_dam_seepage')->order('createtime desc')->value('createtime');
        $startTime = $startTime ? ($startTime + 1) * 1000 : time() * 1000 - 2592000000;
        $endTime = time() * 1000;
        foreach ($list as $k => $v) {
            $qx = new Qx();
            $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/" . $qx->AccessKey . "?deviceId=" . $v['deviceId'] . "&startTime=" . $startTime . "&endTime=" . $endTime;
            $info = json_decode($qx->geturl($url), true);
            if (!isset($info['data'])) {
                continue;
            }
            $info = reset($info['data']);
            $info = end($info);
            if ($info) {
                $this->warning($v['deviceId'], $info);
                foreach ($info as $k2 => $v2) {
                    $data[] = [
                        'reservoir_id' => $v['reservoir_id'],
                        'value' => $v2['value'],
                        'createtime' => $v2['reportTime'] / 1000,
                        'reporttime' => $v2['reportTime'],
                        'equipment_id' => $v['deviceId']
                    ];
                }
            }
        }
        Db::name('reservoir_dam_seepage')->insertAll($data);
    }

    //采集渗压硬件数据
    public function getIsotonic()
    {
        $list = Db::name('reservoir_equipment')->where('type', '3')->where('company_type', '1')->select();
        $data = [];
        $startTime = Db::name('reservoir_dam_isotonic')->order('createtime desc')->value('createtime');
        $startTime = $startTime ? ($startTime + 1) * 1000 : time() * 1000 - 2592000000;
        $endTime = time() * 1000;
        foreach ($list as $k => $v) {
            $qx = new Qx();
            $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/" . $qx->AccessKey . "?deviceId=" . $v['deviceId'] . "&startTime=" . $startTime . "&endTime=" . $endTime;
            $info = json_decode($qx->geturl($url), true);
            if (!isset($info['data'])) {
                continue;
            }
            //kevin 追加浸润性深度（根据reportTime）
            $dx_info = [];
            $dx_info = end($info['data']);
            $dx_info = end($dx_info);
            $dx_data = [];
            if (!empty($dx_info)) {
                foreach ($dx_info as $dk => $dv) {
                    $dx_data[$dv['reportTime']] = $dv['value'];
                }
            }
            //渗压数据
            $info = reset($info['data']);
            $info = end($info);

            if ($info) {
                $this->warning($v['deviceId'], $info);
                foreach ($info as $k2 => $v2) {
                    $dx_value=0;
                    if($dx_data[$v2['reportTime']]){
                        $dx_value = $dx_data[$v2['reportTime']];
                    }else{
                        if ($v2['value']>0){
                            $dx_value = bcdiv($v2['value'],9.8,2);
                        }
                    }
                    $data[] = [
                        'reservoir_id' => $v['reservoir_id'],
                        'value' => $v2['value'],
                        "dx_value" => $dx_value,//$dx_data[$v2['reportTime']] ? $dx_data[$v2['reportTime']] : 0,//追加浸润性深度数据（根据渗压的reportTime与浸润性reportTime相同拿值）
                        'temp' => $v2['temp'],
                        'createtime' => $v2['reportTime'] / 1000,
                        'reporttime' => $v2['reportTime'],
                        'equipment_id' => $v['deviceId']
                    ];
                }
            }
        }
        Db::name('reservoir_dam_isotonic')->insertAll($data);
    }

    //采集偏移硬件数据
    public function getDisplacement()
    {
        $list = Db::name('reservoir_equipment')->where('type', '6')->where('company_type', '1')->select();
        $data = [];
        $startTime = Db::name('reservoir_dam_displacement')->order('createtime desc')->value('createtime');
        $startTime = $startTime ? ($startTime + 1) * 1000 : time() * 1000 - 2592000000;
        $endTime = time() * 1000;
        foreach ($list as $k => $v) {
            $qx = new Qx();
            $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/" . $qx->AccessKey . "?deviceId=" . $v['deviceId'] . "&startTime=" . $startTime . "&endTime=" . $endTime;
            $info = json_decode($qx->geturl($url), true);
            if (!isset($info['data'])) {
                continue;
            }
            $info = end($info['data']);
            $info = end($info);
            if ($info) {
                $this->warning($v['deviceId'], $info);
                foreach ($info as $k2 => $v2) {
                    $data[] = [
                        'reservoir_id' => $v['reservoir_id'],
                        'vertical' => $v2['gpsTotalZ'],
                        'horizontal' => $v2['gpsTotalX'],
                        'horizontalY' => $v2['gpsTotalY'],
                        'createtime' => $v2['reportTime'] / 1000,
                        'reporttime' => $v2['reportTime'],
                        'number' => $v['deviceId']
                    ];
                }
            }
        }
        Db::name('reservoir_dam_displacement')->insertAll($data);
    }

    //采集降雨量硬件数据
    public function getRainfall()
    {
        $list = Db::name('reservoir_equipment')->where('type', '5')->where('company_type', '1')->select();
        $data = [];
        $startTime = Db::name('reservoir_rain_rainfall')->order('createtime desc')->value('createtime');
        $startTime = $startTime ? ($startTime + 1) * 1000 : time() * 1000 - 2592000000;
        $endTime = time() * 1000;
        foreach ($list as $k => $v) {
            $qx = new Qx();
            $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/" . $qx->AccessKey . "?deviceId=" . $v['deviceId'] . "&startTime=" . $startTime . "&endTime=" . $endTime;
            $info = json_decode($qx->geturl($url), true);
            if (!isset($info['data'])) {
                continue;
            }
            $info = end($info['data']);
            $info = end($info);
            if ($info) {
                $this->warning($v['deviceId'], $info);
                foreach ($info as $k2 => $v2) {
                    $data[] = [
                        'reservoir_id' => $v['reservoir_id'],
                        'rainfall' => $v2['value'],
                        'total_rainfall' => $v2['totalValue'],
                        'createtime' => $v2['reportTime'] / 1000,
                        'reporttime' => $v2['reportTime'],
                        'number' => $v['deviceId']
                    ];
                }
            }
        }
        Db::name('reservoir_rain_rainfall')->insertAll($data);
    }

    /**
     * 1、采集水位数据（千寻）
     * kevin 2023.02.14 新版本
     * 硬件类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他【目前已对接使用1、2、3、5、6】
     */
    public function getWaterLevelKevin()
    {
        $w = [];
        $w["type"] = ["=", "1"];//硬件类型 1=水位计
        $w["company_type"] = ["=", "1"];//设备商 1=千寻，2=匠星

        $list = Db::name('reservoir_equipment')->where($w)->select();
        $data = [];
        $startTime = Db::name('reservoir_rain_water_level')->order('createtime desc')->value('createtime');
        $startTime = $startTime ? ($startTime + 1) * 1000 : time() * 1000 - 2592000000;//千寻有效查询一个月
        $endTime = time() * 1000;
        foreach ($list as $k => $v) {
            $qx = new Qx();
            $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/" . $qx->AccessKey . "?deviceId=" . $v['deviceId'] . "&startTime=" . $startTime . "&endTime=" . $endTime;
            $info = json_decode($qx->geturl($url), true);
            if (!isset($info['data'])) {
                continue;
            }
            $info = end($info['data']);
            $info = end($info);
            if ($info) {
                $this->warning($v['deviceId'], $info);
                foreach ($info as $k2 => $v2) {
                    $data[] = [
                        'reservoir_id' => $v['reservoir_id'],
                        'water_level' => $v2['value'],
                        'createtime' => $v2['reportTime'] / 1000,
                        'reporttime' => $v2['reportTime'],
                        'number' => $v['deviceId']
                    ];
                }
            }
        }
        Db::name('reservoir_rain_water_level')->insertAll($data);
    }

    //采集水位硬件数据
    public function getWaterLevel()
    {
        $list = Db::name('reservoir_equipment')->where('type', '1')->where('company_type', '1')->select();
        $data = [];
        $startTime = Db::name('reservoir_rain_water_level')->order('createtime desc')->value('createtime');
        $startTime = $startTime ? ($startTime + 1) * 1000 : time() * 1000 - 2592000000;
        $endTime = time() * 1000;
        foreach ($list as $k => $v) {
            $qx = new Qx();
            $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/" . $qx->AccessKey . "?deviceId=" . $v['deviceId'] . "&startTime=" . $startTime . "&endTime=" . $endTime;
            $info = json_decode($qx->geturl($url), true);
            if (!isset($info['data'])) {
                continue;
            }
            $info = end($info['data']);
            $info = end($info);
            if ($info) {
                $this->warning($v['deviceId'], $info);
                foreach ($info as $k2 => $v2) {
                    $data[] = [
                        'reservoir_id' => $v['reservoir_id'],
                        'water_level' => $v2['value'],
                        'createtime' => $v2['reportTime'] / 1000,
                        'reporttime' => $v2['reportTime'],
                        'number' => $v['deviceId']
                    ];
                }
            }
        }
        Db::name('reservoir_rain_water_level')->insertAll($data);
    }

    public function equipmentType($type)
    {
        if (strstr($type, '水位计')) {
            return '1';
        } elseif (strstr($type, '量水堰')) {
            return '2';
        } elseif (strstr($type, '渗压计')) {
            return '3';
        } elseif (strstr($type, '雨量计')) {
            return '5';
        } elseif (strstr($type, '监测点')) {
            return '6';
        } else {
            return '7';
        }
    }

    /**
     * 设备预警记录
     */
    public function warning($deviceid, $data)
    {
        $type = $this->model->where('deviceId', $deviceid)->value('type');
        $threshold = Db::name('reservoir_threshold')->where('deviceId', $deviceid)->field('config,reservoir_id')->order("id desc")->find();
        if (!$threshold) {
            return;
        }
        $config = json_decode($threshold['config'], true);
        $reservoir = Db::name('reservoir_list')->where('id', $threshold['reservoir_id'])->field('user_mobile,name')->find();

        if (!$config) {
            return;
        }
        //水位
        if ($type == '1') {
            $arr = explode(',', $config['value']);
            sort($arr);
            foreach ($data as $k => $v) {
                if ($v['value'] < $arr[0] || $v['value'] > $arr[1]) {
                    $insert = [
                        'value' => $v['value'],
                        'warning' => $arr[0] . ',' . $arr[1],
                        'equipment_id' => $deviceid,
                        'reservoir_id' => $threshold['reservoir_id'],
                        'createtime' => time(),
                        'reporttime' => $v['reportTime']
                    ];
                    Db::name('reservoir_warning_waterlevel')->insert($insert);
                    // $sms = new Index();
                    // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
                }
            }
        }
        //渗压
        elseif ($type == '3') {
            $arr = explode(',', $config['value']);
            sort($arr);
            foreach ($data as $k => $v) {
                if ($v['value'] < $arr[0] || $v['value'] > $arr[1]) {
                    $insert = [
                        'value' => $v['value'],
                        'warning' => $arr[0] . ',' . $arr[1],
                        'equipment_id' => $deviceid,
                        'reservoir_id' => $threshold['reservoir_id'],
                        'createtime' => time(),
                        'reporttime' => $v['reportTime']
                    ];
                    Db::name('reservoir_warning_isotonic')->insert($insert);
                    // $sms = new Index();
                    // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
                }
            }
        } //雨量
        elseif ($type == '5') {
            $arr = explode(',', $config['value']);
            sort($arr);
            foreach ($data as $k => $v) {
                if ($v['value'] < $arr[0] || $v['value'] > $arr[1]) {
                    $insert = [
                        'value' => $v['value'],
                        'warning' => $arr[0] . ',' . $arr[1],
                        'equipment_id' => $deviceid,
                        'reservoir_id' => $threshold['reservoir_id'],
                        'createtime' => time(),
                        'reporttime' => $v['reportTime']
                    ];
                    Db::name('reservoir_warning_rainfall')->insert($insert);
                    // $sms = new Index();
                    // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
                }
            }
        } //位移
        elseif ($type == '6') {
            foreach ($data as $key => $val) {
                foreach ($config as $k => $v) {
                    $arr = explode(',', $v);
                    sort($arr);
                    $value = $val['gpsTotal' . strtoupper($k)];
                    if ($value < $arr[0] || $value > $arr[1]) {
                        $insert = [
                            'value' => $value,
                            'warning' => $arr[0] . ',' . $arr[1],
                            'equipment_id' => $deviceid,
                            'reservoir_id' => $threshold['reservoir_id'],
                            'createtime' => time(),
                            'reporttime' => $val['reportTime'],
                            'shaft' => $k
                        ];
                        Db::name('reservoir_warning_displacement')->insert($insert);
                        // $sms = new Index();
                        // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
                    }
                }
            }
        }
    }

    /**
     * 千寻的封装
     */
    public function qx_url_data()
    {

        $param = $this->request->param("");
        $qx = new Qx();
        $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/" . $qx->AccessKey . "?deviceId=" . $param['deviceId'] . "&startTime=" . $param['startTime'] . "&endTime=" . $param['endTime'];
        $info = json_decode($qx->geturl($url), true);
        $this->success("", $info);
//        if (!isset($info['data'])) {
//            continue;
//        }
//        $info = end($info['data']);
//        $info = end($info);
    }


    /**
     * 水位数据接收推送（蚂蚱冲、西甲冲、三岔河）
     * 每小时推给平台一次（硬件是山洪防办的）
     *
     */
    public function reservoirWaterlevelPush()
    {
        $post = $this->request->param("");
        file_put_contents("xiongyue_waterlevel.log", date("Y-m-d H:i:s") . "：" . json_encode($post) . PHP_EOL, FILE_APPEND);
        $deviceId = ["xy1000000110", "xy1000000112", "xy1000000114"];
        $reservoir_id = Db::name("reservoir_equipment")->where("deviceId", $post['deviceId'])->value("reservoir_id");

        if (in_array($post['deviceId'], $deviceId)) {
            if (!empty($post['L4_NW'])) {
                $list = $post['L4_NW'];
                foreach ($list as $k => $v) {
                    $info = $v;
                    if ($info) {
                        $this->warning($post['deviceId'], $info);
                        foreach ($info as $k2 => $v2) {
                            $data[] = [
                                'reservoir_id' => $reservoir_id,
                                'water_level' => $v2['value'],
                                'createtime' => $v2['reportTime'] / 1000,
                                'reporttime' => $v2['reportTime'],
                                'number' => $post['deviceId']
                            ];
                        }
                    }
                }
                $rr = Db::name('reservoir_rain_water_level22')->insertAll($data);
                if ($rr) {
                    $this->success("入库成功");
                } else {
                    $this->error("入库失败");
                }
            } else {
                $this->error("无效数据");
            }
        } else {
            $this->error("无效的设备ID");
        }


    }

    /**
     * 雨量数据接收推送（蚂蚱冲、西甲冲、三岔河）
     * 每小时推给平台一次（硬件是山洪防办的）
     */
    public function reservoirRainfallPush()
    {
        $post = $this->request->param("");
        file_put_contents("xiongyue_rainfall.log", date("Y-m-d H:i:s") . "：" . json_encode($post) . PHP_EOL, FILE_APPEND);
        $deviceId = ["xy1000000111", "xy1000000113", "xy1000000115"];

        $reservoir_id = Db::name("reservoir_equipment")->where("deviceId", $post['deviceId'])->value("reservoir_id");

        if (in_array($post['deviceId'], $deviceId)) {
            if (!empty($post['L3_YL'])) {
                $list = $post['L3_YL'];
                foreach ($list as $k => $v) {
                    $info = $v;
                    if ($info) {
                        $this->warning($v['deviceId'], $info);
                        foreach ($info as $k2 => $v2) {
                            $data[] = [
                                'reservoir_id' => $reservoir_id,
                                'rainfall' => $v2['value'],
                                'total_rainfall' => $v2['totalValue'],
                                'createtime' => $v2['reportTime'] / 1000,
                                'reporttime' => $v2['reportTime'],
                                'number' => $post['deviceId']
                            ];
                        }
                    }
                }
                $rr = Db::name('reservoir_rain_rainfall22')->insertAll($data);
                if ($rr) {
                    $this->success("入库成功!");
                } else {
                    $this->error("入库失败!");
                }
            } else {
                $this->error("无效数据!");
            }
        } else {
            $this->error("无效的设备ID!");
        }
    }

    /**
     * 水位数据接收推送（只处理鲁嘎水库）
     * 数据在中间库（硬件是雄越的、硬件是每5分钟生成一条记录）
     * 鲁嘎水位计编号deviceId：xy1000000116
     * 中间库的测站编码stcd：31006499
     */
    public function waterlevel_for_xiongyue()
    {
        $deviceId = "xy1000000116";
        $stcd = "31006499";

        $where = [];
        $where["deviceId"] = ["=", $deviceId];
        $where["type"] = ["=", 1];
        $where["company_type"] = ["=", 4];
        $equipment = Db::name('reservoir_equipment')->where($where)->find();

        if (!empty($equipment)) {
            $data = [];
            $w = [];
            $w["number"] = ["=", $equipment['deviceId']];
            $w["reservoir_id"] = ["=", $equipment['reservoir_id']];
            $last_record = Db::name('reservoir_rain_water_level')->where($w)->order('createtime desc')->find();
            if (!empty($last_record)) {
                $startTime = $last_record['createtime'];
            }
            $startTime = $startTime ? ($startTime + 1) : 1679500800;//1679500800=2023-03-23中间库开始有数据的
            $endTime = time();

            $info = [];
            $wh = [];
            $wh["stcd"] = ["=", $stcd];
            //最近时间
            $jin_time = Db::connect("db_b")->name("rsv_wl")->where($wh)->where("tm", "between time", [$startTime, $endTime])->order("tm desc")->value("UNIX_TIMESTAMP(tm)");
            //最远时间
            $yuan_time = Db::connect("db_b")->name("rsv_wl")->where($wh)->where("tm", "between time", [$startTime, $endTime])->order("tm asc")->value("UNIX_TIMESTAMP(tm)");
            if (!empty($jin_time) && !empty($yuan_time)) {
                $jin_time = strtotime(date("Y-m-d H:00:00", $jin_time)) + 3600;//只保留整点
                $yuan_time = strtotime(date("Y-m-d H:00:00", $yuan_time));//只保留整点
                $hour = ($jin_time - $yuan_time) / 3600;//多少个小时
                for ($i = 1; $i <= $hour; $i++) {
                    $end_time = $yuan_time + 3600;//远时间+1小时
                    $wh2 = [];
                    $wh2["stcd"] = ["=", $stcd];
                    $record = Db::connect("db_b")->name("rsv_wl")->where($wh2)->where("tm", "between time", [$yuan_time, $end_time])->field("z as value,UNIX_TIMESTAMP(tm)*1000 as reportTime")->order("tm asc")->find();
                    if (!empty($record)) {
                        $this->warning($equipment['deviceId'], [$record]);
                        $data[] = [
                            'reservoir_id' => $equipment['reservoir_id'],
                            'water_level' => $record['value'],
                            'createtime' => $record['reportTime'] / 1000,
                            'reporttime' => $record['reportTime'],
                            'number' => $equipment['deviceId']
                        ];
                        $yuan_time = $end_time;
                    }
                }
            }
        }
        $rr = Db::name('reservoir_rain_water_level')->insertAll($data);
        echo "all：" . count($data) . ";succ：" . $rr;
    }

    /**
     * 雨量数据接收推送（只处理鲁嘎水库）
     * 数据在中间库（硬件是雄越的、硬件是每5分钟生成一条记录）
     * 鲁嘎雨量计编号deviceId：xy1000000117
     * 中间库的测站编码stcd：31006499
     */
    public function rainfall_for_xiongyue()
    {
        $deviceId = "xy1000000117";
        $stcd = "31006499";

        $where = [];
        $where["deviceId"] = ["=", $deviceId];
        $where["type"] = ["=", 5];
        $where["company_type"] = ["=", 4];
        $equipment = Db::name('reservoir_equipment')->where($where)->find();

        if (!empty($equipment)) {
            $data = [];
            $w = [];
            $w["number"] = ["=", $equipment['deviceId']];
            $w["reservoir_id"] = ["=", $equipment['reservoir_id']];
            $last_record = Db::name('reservoir_rain_rainfall')->where($w)->order('createtime desc')->find();

            if (!empty($last_record)) {
                $startTime = $last_record['createtime'];
            }
            $startTime = $startTime ? ($startTime + 1) : 1679500800;//1679500800=2023-03-23中间库开始有数据的
            $endTime = time();

            $info = [];
            $wh = [];
            $wh["stcd"] = ["=", $stcd];
            //最近时间
            $jin_time = Db::connect("db_b")->name("rsv_wl")->where($wh)->where("tm", "between time", [$startTime, $endTime])->order("tm desc")->value("UNIX_TIMESTAMP(tm)");
            //最远时间
            $yuan_time = Db::connect("db_b")->name("rsv_wl")->where($wh)->where("tm", "between time", [$startTime, $endTime])->order("tm asc")->value("UNIX_TIMESTAMP(tm)");
            if (!empty($jin_time) && !empty($yuan_time)) {
                $jin_time = strtotime(date("Y-m-d H:00:00", $jin_time)) + 3600;//只保留整点
                $yuan_time = strtotime(date("Y-m-d H:00:00", $yuan_time));//只保留整点
                $hour = ($jin_time - $yuan_time) / 3600;//多少个小时
                $last_day_rainfall = $last_record['total_rainfall'] > 0 ? $last_record['total_rainfall'] : 0;

                for ($i = 1; $i <= $hour; $i++) {
                    $end_time = $yuan_time + 3600;//远时间+1小时
                    $wh2 = [];
                    $wh2["stcd"] = ["=", $stcd];
                    //最>=整点的的一条数据
                    $record = Db::connect("db_b")->name("rsv_wl")->where($wh2)->where("tm", "between time", [$yuan_time, $end_time])->field("dyp as value,UNIX_TIMESTAMP(tm)*1000 as reportTime")->order("tm asc")->find();

                    $hour_rainfall = 0;//小时降雨量
                    //小时降雨量需要用日累积量-上一个小时的日累计降雨量（雄越没提供小时降雨量数据，只提供了日降雨量数据）

                    if (!empty($record)) {
                        $hour_rainfall = $record['value'] - $last_day_rainfall >= 0 ? $record['value'] - $last_day_rainfall : $record['value'];
                        $last_day_rainfall = $record['value'];

                        $this->warning($equipment['deviceId'], [$record]);

                        $data[] = [
                            'reservoir_id' => $equipment['reservoir_id'],
                            'rainfall' => $hour_rainfall,//小时降雨量
                            'total_rainfall' => $record['value'],//日累计降雨量
                            'createtime' => $record['reportTime'] / 1000,
                            'reporttime' => $record['reportTime'],
                            'number' => $equipment['deviceId']
                        ];
                        $yuan_time = $end_time;
                    }
                }
            }
        }
        $rr = Db::name('reservoir_rain_rainfall')->insertAll($data);
        echo "all：" . count($data) . ";succ：" . $rr;
    }

}