<?php
/***
 * 匠星设备采集数据
 */

namespace app\api\controller\reservoir;

use app\common\controller\Api;
use app\common\helper\HttpHelper;
use think\Exception;
use think\exception\PDOException;
use think\Request;
use think\Db;
use qx\Qx;
use addons\alisms\controller\Index;

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

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

    //统一采集数据接口
    public function getAllData()
    {
        //水库水位（SUCC）
        $r1 = $this->getWaterLevel();

        //水库降雨量(SUCC-总降雨量吴总那边未处理完)
        $r2 = $this->getRainfall();

        //渗流(SUCC)
        $r3 = $this->getSeepage();

        //渗压(SUCC)
        $r4 = $this->getIsotonic();

        //坝体地表位移表
        $r5 = $this->getDisplacement();
        $res = [
            "r1" => $r1,
            "r2" => $r2,
            "r3" => $r3,
            "r4" => $r4,
            "r5" => $r5,
        ];
        $this->success("success", $res);
    }

    /**
     * 1. 采集水位硬件数据
     * 类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
     */
    public function getWaterLevel()
    {
        $list = Db::name('reservoir_equipment')->where('type', '1')->where('company_type', '2')->where('company_type', '2')->select();

        $url = "http://47.108.153.209:2010/api/device/data";
        $upt_succ = 0;
        // 启动事务
        Db::startTrans();
        try {

            foreach ($list as $k => $v) {

                $startTime = Db::name('reservoir_rain_water_level')->where(["number" => $v['deviceId'], "reservoir_id" => $v['reservoir_id']])->order('createtime desc')->value('createtime');
                $startTime = $startTime ? $startTime + 1 : strtotime("2022-07-14 00:00:00");//数据是从07-14开始才有的，所以默认这个时间点
                $time_arr = time_to_today_end($startTime);
                if (!empty($time_arr)) {
                    foreach ($time_arr as $k2 => $v2) {
                        if (!empty($v2)) {
                            $s_time = $v2[0];
                            $e_time = $v2[1];
                            $url = "http://47.108.153.209:2010/api/device/data";//. "?deviceId=" .$v['apiKey']. "&startTime=" . $s_time . "&endTime=" . $e_time;
                            $param = ["deviceId" => $v['apiKey'], "startTime" => $s_time, "endTime" => $e_time];
                            $res = HttpHelper::get($url, $param);
                            if (!empty($res)) {
                                $r = json_decode($res, true);
                                if (!empty($r) && $r['code'] == 0) {
                                    $water_data = $r['data']['L4_NW'][$v['deviceId']];
                                    if (!empty($water_data)) {
                                        $this->warning($v['deviceId'], $water_data);
                                        foreach ($water_data as $k3 => $v3) {
                                            $insert_data = [];
                                            $insert_data = [
                                                'reservoir_id' => $v['reservoir_id'],
                                                'water_level' => $v3['value'],
                                                'createtime' => $v3['reportTime'] / 1000,
                                                'reporttime' => $v3['reportTime'],
                                                'number' => $v['deviceId']
                                            ];
                                            $rr = Db::name('reservoir_rain_water_level')->insertGetId($insert_data);
                                            if ($rr) {
                                                $upt_succ = $upt_succ + 1;
                                            }
                                        }

                                    }
                                }
                            }
                        }
                    }
                }
            }
            Db::commit();
            return "水位新增成功数量：" . $upt_succ;
//            $this->success("水位新增成功数量：" . $upt_succ, $upt_succ);
        } catch (PDOException $e) {
            Db::rollback();
            return $e->getMessage();
//            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            return $e->getMessage();
//            $this->error($e->getMessage());
        }
    }

    /**
     * 2. 采集降雨量硬件数据
     * 类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
     */
    public function getRainfall()
    {
        $list = Db::name('reservoir_equipment')->where('type', '5')->where('company_type', '2')->select();

        $url = "http://47.108.153.209:2010/api/device/data";
        $upt_succ = 0;
        // 启动事务
        Db::startTrans();
        try {

            foreach ($list as $k => $v) {

                $startTime = Db::name('reservoir_rain_rainfall')->where(["number" => $v['deviceId'], "reservoir_id" => $v['reservoir_id']])->order('createtime desc')->value('createtime');
                $startTime = $startTime ? $startTime + 1 : strtotime("2022-07-14 00:00:00");//数据是从07-14开始才有的，所以默认这个时间点
                $time_arr = time_to_today_end($startTime);
                if (!empty($time_arr)) {
                    foreach ($time_arr as $k2 => $v2) {
                        if (!empty($v2)) {
                            $s_time = $v2[0];
                            $e_time = $v2[1];
                            $url = "http://47.108.153.209:2010/api/device/data";//. "?deviceId=" .$v['apiKey']. "&startTime=" . $s_time . "&endTime=" . $e_time;
                            $param = ["deviceId" => $v['apiKey'], "startTime" => $s_time, "endTime" => $e_time];
                            $res = HttpHelper::get($url, $param);
                            if (!empty($res)) {
                                $r = json_decode($res, true);
                                if (!empty($r) && $r['code'] == 0) {
                                    $rain_data = $r['data']['L3_YL'][$v['deviceId']];
                                    if (!empty($rain_data)) {
                                        $this->warning($v['deviceId'], $rain_data);
                                        foreach ($rain_data as $k3 => $v3) {
                                            $insert_data = [];
                                            $insert_data = [
                                                'reservoir_id' => $v['reservoir_id'],
                                                'rainfall' => $v3['value'],
                                                'total_rainfall' => $v3['totalValue'],
                                                'createtime' => $v3['reportTime'] / 1000,
                                                'reporttime' => $v3['reportTime'],
                                                'number' => $v['deviceId']
                                            ];
                                            $rr = Db::name('reservoir_rain_rainfall')->insertGetId($insert_data);
                                            if ($rr) {
                                                $upt_succ = $upt_succ + 1;
                                            }
                                        }

                                    }
                                }
                            }
                        }
                    }
                }
            }
            Db::commit();
            return "雨量新增成功数量：" . $upt_succ;
//            $this->success("雨量新增成功数量：" . $upt_succ, $upt_succ);
        } catch (PDOException $e) {
            Db::rollback();
            return $e->getMessage();
//            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            return $e->getMessage();
//            $this->error($e->getMessage());
        }
    }


    /**
     * 3. 采集渗流计硬件数据
     * 类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
     */
    public function getSeepage()
    {
        $list = Db::name('reservoir_equipment')->where('type', '2')->where('company_type', '2')->select();


        $url = "http://47.108.153.209:2010/api/device/data";
        $upt_succ = 0;
        // 启动事务
        Db::startTrans();
        try {

            foreach ($list as $k => $v) {

                $startTime = Db::name('reservoir_dam_seepage')->where(["equipment_id" => $v['deviceId'], "reservoir_id" => $v['reservoir_id']])->order('createtime desc')->value('createtime');
                $startTime = $startTime ? $startTime + 1 : strtotime("2022-12-10 00:00:00");//数据是从07-14开始才有的，所以默认这个时间点
                $time_arr = time_to_today_end($startTime);
                if (!empty($time_arr)) {
                    foreach ($time_arr as $k2 => $v2) {
                        if (!empty($v2)) {
                            $s_time = $v2[0];
                            $e_time = $v2[1];
                            $url = "http://47.108.153.209:2010/api/device/data";//. "?deviceId=" .$v['apiKey']. "&startTime=" . $s_time . "&endTime=" . $e_time;
                            $param = ["deviceId" => $v['apiKey'], "startTime" => $s_time, "endTime" => $e_time];
                            $res = HttpHelper::get($url, $param);

                            if (!empty($res)) {
                                $r = json_decode($res, true);
                                if (!empty($r) && $r['code'] == 0) {
                                    $seepage_data = $r['data']['L3_SL'][$v['deviceId']];
                                    if (!empty($seepage_data)) {
                                        $this->warning($v['deviceId'], $seepage_data);
                                        foreach ($seepage_data as $k3 => $v3) {
                                            $insert_data = [];
                                            $insert_data = [
                                                'reservoir_id' => $v['reservoir_id'],
                                                'value' => $v3['value'],
                                                'createtime' => $v3['reportTime'] / 1000,
                                                'reporttime' => $v3['reportTime'],
                                                'equipment_id' => $v['deviceId']
                                            ];
                                            $rr = Db::name('reservoir_dam_seepage')->insertGetId($insert_data);
                                            if ($rr) {
                                                $upt_succ = $upt_succ + 1;
                                            }
                                        }

                                    }
                                }
                            }
                        }
                    }
                }
            }
            Db::commit();
            return "渗流量新增成功数量：" . $upt_succ;
//            $this->success("渗流量新增成功数量：" . $upt_succ, $upt_succ);
        } catch (PDOException $e) {
            Db::rollback();
            return $e->getMessage();
//            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            return $e->getMessage();
//            $this->error($e->getMessage());
        }
    }

    /**
     * 4. 采集渗压计硬件数据
     * 类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
     */
    public function getIsotonic()
    {
        $list = Db::name('reservoir_equipment')->where('type', '3')->where('company_type', '2')->select();


        $url = "http://47.108.153.209:2010/api/device/data";
        $upt_succ = 0;
        // 启动事务
        Db::startTrans();
        try {

            foreach ($list as $k => $v) {

                $startTime = Db::name('reservoir_dam_isotonic')->where(["equipment_id" => $v['deviceId'], "reservoir_id" => $v['reservoir_id']])->order('createtime desc')->value('createtime');
                $startTime = $startTime ? $startTime + 1 : strtotime("2022-12-10 00:00:00");//数据是从07-14开始才有的，所以默认这个时间点
                $time_arr = time_to_today_end($startTime);
                if (!empty($time_arr)) {
                    foreach ($time_arr as $k2 => $v2) {
                        if (!empty($v2)) {
                            $s_time = $v2[0];
                            $e_time = $v2[1];
                            $url = "http://47.108.153.209:2010/api/device/data";//. "?deviceId=" .$v['apiKey']. "&startTime=" . $s_time . "&endTime=" . $e_time;
                            $param = ["deviceId" => $v['apiKey'], "startTime" => $s_time, "endTime" => $e_time];
                            $res = HttpHelper::get($url, $param);

                            if (!empty($res)) {
                                $r = json_decode($res, true);
                                if (!empty($r) && $r['code'] == 0) {
                                    $iso_data = $r['data']['L3_SY'][$v['deviceId']];
                                    if (!empty($iso_data)) {
                                        $this->warning($v['deviceId'], $iso_data);
                                        foreach ($iso_data as $k3 => $v3) {
                                            $insert_data = [];
                                            $insert_data = [
                                                'reservoir_id' => $v['reservoir_id'],
                                                'value' => $v3['value'] * 9.8,//压强公式 P=ρgh  9.8*1*h
                                                "dx_value" => $v3['value'],
                                                'temp' => $v3['temp'] > 0 ? $v3['temp'] : 0,
                                                'createtime' => $v3['reportTime'] / 1000,
                                                'reporttime' => $v3['reportTime'],
                                                'equipment_id' => $v['deviceId']
                                            ];
                                            $rr = Db::name('reservoir_dam_isotonic')->insertGetId($insert_data);
                                            if ($rr) {
                                                $upt_succ = $upt_succ + 1;
                                            }
                                        }

                                    }
                                }
                            }
                        }
                    }
                }
            }
            Db::commit();
            return "渗压新增成功数量：" . $upt_succ;
//            $this->success("渗压新增成功数量：" . $upt_succ, $upt_succ);
        } catch (PDOException $e) {
            Db::rollback();
            return $e->getMessage();
//            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            return $e->getMessage();
//            $this->error($e->getMessage());
        }
    }

    /**
     * 5. 采集坝体位移检测硬件数据
     * 类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
     */
    public function getDisplacement()
    {
        $list = Db::name('reservoir_equipment')->where('type', '6')->where('company_type', '2')->select();

        $url = "http://47.108.153.209:2010/api/device/data";
        $upt_succ = 0;
        // 启动事务
        Db::startTrans();
        try {

            foreach ($list as $k => $v) {

                $startTime = Db::name('reservoir_dam_displacement')->where(["number" => $v['deviceId'], "reservoir_id" => $v['reservoir_id']])->order('createtime desc')->value('createtime');
                $startTime = $startTime ? $startTime + 1 : strtotime("2022-07-14 00:00:00");//数据是从07-14开始才有的，所以默认这个时间点
                $time_arr = time_to_today_end($startTime);
                if (!empty($time_arr)) {
                    foreach ($time_arr as $k2 => $v2) {
                        if (!empty($v2)) {
                            $s_time = $v2[0];
                            $e_time = $v2[1];
                            $url = "http://47.108.153.209:2010/api/device/data";//. "?deviceId=" .$v['apiKey']. "&startTime=" . $s_time . "&endTime=" . $e_time;
                            $param = ["deviceId" => $v['apiKey'], "startTime" => $s_time, "endTime" => $e_time];
                            $res = HttpHelper::get($url, $param);
                            if (!empty($res)) {
                                $r = json_decode($res, true);
                                if (!empty($r) && $r['code'] == 0) {
                                    $seepage_data = $r['data']['L1_GP'][$v['deviceId']];
                                    if (!empty($seepage_data)) {
                                        $this->warning($v['deviceId'], $seepage_data);
                                        foreach ($seepage_data as $k3 => $v3) {
                                            $insert_data = [];
                                            $insert_data = [
                                                'reservoir_id' => $v['reservoir_id'],
                                                'vertical' => $v3['gpsTotalZ'],
                                                'horizontal' => $v3['gpsTotalX'],
                                                'horizontalY' => $v3['gpsTotalY'],
                                                'createtime' => $v3['reportTime'] / 1000,
                                                'reporttime' => $v3['reportTime'],
                                                'number' => $v['deviceId']
                                            ];
                                            $rr = Db::name('reservoir_dam_displacement')->insertGetId($insert_data);
                                            if ($rr) {
                                                $upt_succ = $upt_succ + 1;
                                            }
                                        }

                                    }
                                }
                            }
                        }
                    }
                }
            }
            Db::commit();
            return "坝体位移新增成功数量：" . $upt_succ;
//            $this->success("坝体位移新增成功数量：" . $upt_succ, $upt_succ);
        } catch (PDOException $e) {
            Db::rollback();
            return $e->getMessage();
//            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            return $e->getMessage();
//            $this->error($e->getMessage());
        }
    }


    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')->find();
        $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']));
                }
            }
        }
        //渗压
        if ($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 jx_url_data()
    {
        $prm = $this->request->param();
        $apiKey = $prm['deviceId'];
        $startTime = $prm['startTime'];
        $endTime = $prm['endTime'];
        $url = "http://47.108.153.209:2010/api/device/data";
        $param = ["deviceId" => $apiKey, "startTime" => $startTime, "endTime" => $endTime];
        $res = HttpHelper::get($url, $param);
        $info = json_decode($res, true);
        $this->success("", $info);
    }


}