<?php

namespace app\api\controller\datacenter;

use app\common\controller\Api;

use think\Db;
use think\Request;
const GO_MIDDLE_HOST_PORT = 'http://121.37.3.63:9023/';//$collectType
const COLLECT_TYPE_TASK_ARRAY = [0,1,3,13,16,27,45,46,47,48];
class Savadatas extends Api
{
    protected $noNeedLogin = ['*'];
    /**
     * 定时任务拉取go中台 管网列表数据
     *
     */
    public function updateSiteList()
    {
        $list = file_get_contents(GO_MIDDLE_HOST_PORT.'/apiGetSiteList');
        $list = json_decode($list,true)['data'];
        if (empty($list)) {
            $this->error('查询失败');
        }

        $res = Db::table('wrp_pipes_network')->column('id', 'siteId');

        foreach ($list as $val) {
            $data = [
                'x' => $val['x'],
                'y' => $val['y'],
                'z' => $val['z'],
                'siteId' => $val['siteId'],
                'siteType' => $val['siteType'],
                'network_name' => $val['siteName'],
                'description' => $val['description'],
                'boundary' => $val['boundary'],
                'createtime' => $val['createdAt'],
                'updatetime' => $val['updatedAt'],
                'deletetime' => $val['deletedAt'],
            ];

            $siteId = $val['siteId'];
            if (isset($res[$siteId])) {
                Db::table('wrp_pipes_network')->where('id', $res[$siteId])->update($data);
            } else {
                Db::table('wrp_pipes_network')->insert($data);
            }
        }

        $this->success('更新完成');
    }

    /**
     * 定时任务拉取go中台 设备列表数据
     *
     */
    public function updateSiteDeviceList()
    {
        $list = file_get_contents(GO_MIDDLE_HOST_PORT.'/apiGetDeviceList');
        $list = json_decode($list,true)['data'];
        if (empty($list)) {
            $this->error('查询失败');
        }
        $res = Db::table('wrp_pipes_site_device')->column('id', 'deviceId');
        foreach ($list as $val) {
            $data = [
                'x' => $val['x'],
                'y' => $val['y'],
                'z' => $val['z'],
                'deviceId' => $val['deviceId'],
                'deviceName' => $val['deviceName'],
                'siteId' => $val['siteId'],
                'groupId' => $val['groupId'],
                'deviceType' => $val['deviceType'],
                'description' => $val['description'],
                'healthScore' => $val['healthScore'],
                'createdAt' => $val['createdAt'],
                'updatedAt' => $val['updatedAt'],
                'deletedAt' => $val['deletedAt']
            ];

            $deviceId = $val['deviceId'];
            if (isset($res[$deviceId])) {
                Db::table('wrp_pipes_site_device')->where('id', $res[$deviceId])->update($data);
            } else {
                Db::table('wrp_pipes_site_device')->insert($data);
            }
        }

        $this->success('更新完成');
    }

    /**
     * 定时任务拉取go中台 设备类型数据
     *
     */
    public function updateSiteDeviceTypeList()
    {
        $list = file_get_contents(GO_MIDDLE_HOST_PORT.'/apiGetDeviceTypeList?type=1');
        $list = json_decode($list,true)['data'];
        if (empty($list)) {
            $this->error('查询失败');
        }

        $res = Db::table('wrp_pipes_site_device_type')->column('id', 'code');

        foreach ($list as $val) {
            $data = [
                'code' => $val['code'],
                'name' => $val['name'],
                'type' => $val['type'],
                'created_at' => $val['created_at'],
                'updated_at' => $val['updated_at']
            ];

            $code = $val['code'];
            if (isset($res[$code])) {
                Db::table('wrp_pipes_site_device_type')->where('id', $res[$code])->update($data);
            } else {
                Db::table('wrp_pipes_site_device_type')->insert($data);
            }
        }

        $this->success('更新完成');
    }

    /**
     * 定时任务拉取go中台 设备采集量类型
     *
     */
    public function updateSiteDeviceGathererTypeList()
    {
        $list = file_get_contents(GO_MIDDLE_HOST_PORT.'/apiGetDeviceTypeList?type=2');
        $list = json_decode($list,true)['data'];
        if (empty($list)) {
            $this->error('查询失败');
        }

        $res = Db::table('wrp_pipes_site_device_gatherer_type')->column('id', 'code');

        foreach ($list as $val) {
            $data = [
                'code' => $val['code'],
                'name' => $val['name'],
                'type' => $val['type'],
                'created_at' => $val['created_at'],
                'updated_at' => $val['updated_at']
            ];

            $code = $val['code'];
            if (isset($res[$code])) {
                Db::table('wrp_pipes_site_device_gatherer_type')->where('id', $res[$code])->update($data);
            } else {
                Db::table('wrp_pipes_site_device_gatherer_type')->insert($data);
            }
        }

        $this->success('更新完成');
    }

    /**
     * 定时任务拉取go中台 采集量的数据类型
     *
     */
    public function updateSiteDeviceGathererDataType()
    {
        $list = file_get_contents(GO_MIDDLE_HOST_PORT.'/apiGetDeviceDataType?scope=0');
        $list = json_decode($list, true)['data'];

        if (empty($list)) {
            $this->error('查询失败');
        }

// 构建查询条件
        $codes = array_column($list, 'id');
        $scopes = array_column($list, 'scope');

// 一次性查询所有符合条件的记录
        $existRecords = Db::table('wrp_pipes_site_device_gatherer_data')
            ->whereIn('code', $codes)
            ->whereIn('scope', $scopes)
            ->select();

// 将查询结果转换成以code和scope作为键的关联数组
        $existRecordsMap = [];
        foreach ($existRecords as $record) {
            $existRecordsMap[$record['code']][$record['scope']] = $record;
        }

        foreach ($list as $item) {
            $code = $item['id'];
            $scope = $item['scope'];
            $data = [
                'code' => $code,
                'collectionId' => $item['collectionId'],
                'siteId' => $item['siteId'],
                'deviceId' => $item['deviceId'],
                'collectionType' => $item['collectionType'],
                'unit' => $item['unit'],
                'scope' => $scope,
                'createdAt' => $item['createdAt'],
                'updatedAt' => $item['updatedAt'],
                'deletedAt' => $item['deletedAt']
            ];

            if (isset($existRecordsMap[$code][$scope])) {
                Db::table('wrp_pipes_site_device_gatherer_data')
                    ->where('id', $existRecordsMap[$code][$scope]['id'])
                    ->update($data);
            } else {
                Db::table('wrp_pipes_site_device_gatherer_data')->insert($data);
            }
        }

        $this->success('更新完成');
    }

    /**
     * 定时任务拉取go中台 水锤事件类型数据
     *
     */
    public function updateWaterhammerTypeList ()
    {
        $list = file_get_contents(GO_MIDDLE_HOST_PORT.'/apiGetWaterhammerTypeList');
        $list = json_decode($list,true)['data'];
        if (empty($list)) {
            $this->error('查询失败');
        }

        $res = Db::table('wrp_pipes_site_waterhammer_type')->column('id', 'middleId');

        foreach ($list as $val) {
            $data = [
                'middleId' => $val['id'],
                'code' => $val['code'],
                'codeMsg' => $val['codeMsg'],
                'name' => $val['name'],
                'createdAt' => $val['createdAt'],
                'updatedAt' => $val['updatedAt'],
                'deletedAt' => $val['deletedAt'],
            ];

            $middleId = $val['id'];
            if (isset($res[$middleId])) {
                Db::table('wrp_pipes_site_waterhammer_type')->where('id', $res[$middleId])->update($data);
            } else {
                Db::table('wrp_pipes_site_waterhammer_type')->insert($data);
            }
        }

        $this->success('更新完成');
    }

    /**
     * 定时任务拉取go中台 空气阀的阀门状态
     *
     */
    public function updateValveStatusTypeList ()
    {
        $list = file_get_contents(GO_MIDDLE_HOST_PORT.'/apiGetValvestatuTypeList');
        $list = json_decode($list,true)['data'];
        if (empty($list)) {
            $this->error('查询失败');
        }

        $res = Db::table('wrp_pipes_site_valve_status_type')->column('id', 'middleId');

        foreach ($list as $val) {
            $data = [
                'middleId' => $val['id'],
                'code' => $val['code'],
                'codeMsg' => $val['codeMsg'],
                'name' => $val['name'],
                'createdAt' => $val['createdAt'],
                'updatedAt' => $val['updatedAt'],
                'deletedAt' => $val['deletedAt'],
            ];

            $middleId = $val['id'];
            if (isset($res[$middleId])) {
                Db::table('wrp_pipes_site_valve_status_type')->where('id', $res[$middleId])->update($data);
            } else {
                Db::table('wrp_pipes_site_valve_status_type')->insert($data);
            }
        }

        $this->success('更新完成');
    }

    /**
     * 定时任务拉取go中台 调流调压阀事件类型
     *
     */
    public function updateValveEventTypeList ()
    {
        $list = file_get_contents(GO_MIDDLE_HOST_PORT.'/apiGetValveafvTypeList');
        $list = json_decode($list,true)['data'];
        if (empty($list)) {
            $this->error('查询失败');
        }

        $res = Db::table('wrp_pipes_site_valve_event_type')->column('id', 'middleId');

        foreach ($list as $val) {
            $data = [
                'middleId' => $val['id'],
                'code' => $val['code'],
                'name' => $val['name'],
                'createdAt' => $val['createdAt'],
                'updatedAt' => $val['updatedAt'],
                'deletedAt' => $val['deletedAt'],
            ];

            $middleId = $val['id'];
            if (isset($res[$middleId])) {
                Db::table('wrp_pipes_site_valve_event_type')->where('id', $res[$middleId])->update($data);
            } else {
                Db::table('wrp_pipes_site_valve_event_type')->insert($data);
            }
        }

        $this->success('更新完成');
    }

    /**
     * 定时任务拉取go中台 告警类型列表
     *
     */
    public function updateAlarmTypeList ()
    {
        $list = file_get_contents(GO_MIDDLE_HOST_PORT.'/apiGetAlarmTypeList');
        $list = json_decode($list,true)['data'];
        if (empty($list)) {
            $this->error('查询失败');
        }

        $res = Db::table('wrp_pipes_site_alarm_type')->column('id', 'middleId');

        foreach ($list as $val) {
            $data = [
                'middleId' => $val['id'],
                'code' => $val['code'],
                'name' => $val['name'],
                'createdAt' => $val['createdAt'],
                'updatedAt' => $val['updatedAt'],
                'deletedAt' => $val['deletedAt'],
            ];

            $middleId = $val['id'];
            if (isset($res[$middleId])) {
                Db::table('wrp_pipes_site_alarm_type')->where('id', $res[$middleId])->update($data);
            } else {
                Db::table('wrp_pipes_site_alarm_type')->insert($data);
            }
        }

        $this->success('更新完成');
    }

    /**
     * 定时任务拉取go中台 设备采集的数据
     *
     */
    public function geiDeviceData() {

// 计算五分钟前的时间戳
        $startTime = urlencode(date('Y-m-d H:i:s',strtotime('-5 minutes')));
        $endTime = urlencode(date('Y-m-d H:i:s',time()-1));

// 查询设备采集数据列表
        $gathererData = Db::table('wrp_pipes_site_device_gatherer_data')->select();

        if (is_array($gathererData)) {
            foreach ($gathererData as $val) {
                $list = file_get_contents(GO_MIDDLE_HOST_PORT.'/apiGetMonitorData?deviceId='.$val['deviceId'].'&collectionId='.$val['collectionId'].'&startTime='.$startTime.'&endTime='.$endTime);
                $list = json_decode($list, true)['data'];
                if (!empty($list)) {
                    // 检查是否已经存在相同的记录，避免重复插入
                    foreach ($list as $item) {
                        if (!empty($item)) {
                            foreach ($item as $v) {
                                $exist = Db::table('wrp_pipes_site_device_lf_collect_data')
                                    ->where('collectTime', $v['collectTime'])
                                    ->where('collectionId', $v['collectionId'])
                                    ->where('deviceId', $v['deviceId'])
                                    ->find();
                                if (!$exist) {
                                    Db::table('wrp_pipes_site_device_lf_collect_data')->insert($v);
                                }
                            }
                        }
                    }
                }

            }
        }

        $this->success('更新完成', $list);
    }
    public function task () {
        foreach (COLLECT_TYPE_TASK_ARRAY as $item) {
            $this->getDeviceDatas($item);
        }
        $this->success('更新完成', COLLECT_TYPE_TASK_ARRAY);
    }

    /**
     * 定时任务拉取go中台 根据传递得设备采集ID获取对应的数据
     *
     */
    public function getDeviceDatas($collectType=0) {
// 计算五分钟前的时间戳
        $startTime = urlencode(date('Y-m-d H:i:s',strtotime('-5 minutes')));
        $endTime = urlencode(date('Y-m-d H:i:s',time()-1));
        $where = [];
// 查询设备采集数据列表
        if (empty($collectType)) {
            $where['collectionType'] = ['NOT IN' , implode(',', COLLECT_TYPE_TASK_ARRAY)];
        } elseif (in_array($collectType, COLLECT_TYPE_TASK_ARRAY)) {
            $where['collectionType'] = $collectType;
        } else {
            return;
        }
        $gathererData = Db::table('wrp_pipes_site_device_gatherer_data')->where($where)->select();
//        dump($where);
//        dump($gathererData);die;
        if (!empty($gathererData)) {
            foreach ($gathererData as $val) {
                $list = file_get_contents(GO_MIDDLE_HOST_PORT.'/apiGetMonitorData?deviceId='.$val['deviceId'].'&collectionId='.$val['collectionId'].'&startTime='.$startTime.'&endTime='.$endTime);
                $list = json_decode($list, true)['data'];
                if (!empty($list)) {
                    // 检查是否已经存在相同的记录，避免重复插入
                    if (empty($collectType)) {
                        foreach ($list as $item) {
                            if (!empty($item)) {
                                foreach ($item as $v) {
                                    $exist = Db::table('wrp_pipes_site_device_lf_collect_data')
                                        ->where('collectTime', $v['collectTime'])
                                        ->where('collectionId', $v['collectionId'])
                                        ->where('deviceId', $v['deviceId'])
                                        ->find();
                                    if (!$exist) {
                                        Db::table('wrp_pipes_site_device_lf_collect_data')->insert($v);
                                    }
                                }
                            }
                        }
                    } else {
                        foreach ($list as $key => $item) {
                            if (!empty($item)) {
                                $pos = strpos($key, '_'); // 找到第一个下划线的位置
                                if ($pos !== false) {
                                    // 截取从第一个下划线之后的字符串
                                    $suffix = '_' . substr($key, $pos + 1);
                                    $tableNames = 'wrp_pipes_site_device_lf_collect_data'.$suffix;
                                    foreach ($item as $v) {
                                        $exist = Db::table($tableNames)
                                            ->where('collectTime', $v['collectTime'])
                                            ->where('collectionId', $v['collectionId'])
                                            ->where('deviceId', $v['deviceId'])
                                            ->find();
                                        if (!$exist) {
                                            Db::table($tableNames)->insert($v);
                                        }
                                    }
                                }
                            }
                        }
                    }
                }

            }
        }
        $this->success('更新完成', $collectType);
    }

}