package com.boying.controller;

import cn.hutool.core.date.DateUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.extension.api.R;
import com.boying.entity.*;
import com.boying.service.*;
import com.boying.util.ExcelUtils;
import com.boying.util.SnmpUtil;
import com.google.gson.Gson;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @author kdq
 * @version 1.0.0
 * @ClassName ApiController.java
 * @Description TODO
 * @createTime 2023年06月16日 09:44:00
 */
@RestController
@RequestMapping("/api")
@RequiredArgsConstructor
public class ApiController {
    @Autowired
    private SystemInfoService systemInfoService;
    @Autowired
    private SnmpInfoService snmpInfoService;
    @Autowired
    private InspectionTaskService inspectionTaskService;
    @Autowired
    private TaskInfoService taskInfoService;
    @Autowired
    private DongHuanZhuangTaiService dongHuanZhuangTaiService;
    @Autowired
    private DongHuanBaoJingService dongHuanBaoJingService;
    @Autowired
    private WarnService warnService;
    @Value("${donghuan.ip}")
    private String ip;
    @Value("${donghuan.loginUrl}")
    private String loginUrl;
    @Value("${donghuan.deviceClassUrl}")
    private String deviceClassUrl;
    @Value("${donghuan.intelligentUrl}")
    private String intelligentUrl;
    @Value("${donghuan.findDevice}")
    private String findDevice;
    @Value("${donghuan.findDeviceVar}")
    private String findDeviceVar;
    @Value("${donghuan.findControlByDeviceId}")
    private String findControlByDeviceId;
    @Value("${donghuan.control}")
    private String control;
    @Value("${donghuan.findValueByDeviceId}")
    private String findValueByDeviceId;
    @Value("${donghuan.findValueByIntelligentId}")
    private String findValueByIntelligentId;
    @Value("${donghuan.findValueByStationId}")
    private String findValueByStationId;
    @Value("${donghuan.meterDatas}")
    private String meterDatas;
    @Value("${donghuan.varDatas}")
    private String varDatas;
    @Value("${donghuan.alarm}")
    private String alarm;

    private String token;

    @GetMapping("/getHost")
    public R getServer(){
        Map<String,Object> map = new HashMap<>();
        try {
            QueryWrapper<SystemInfo> wrapper = new QueryWrapper<>();
            wrapper.select(" id,host_name,state");
            wrapper.lambda()
                    .eq(SystemInfo::getState,1);
            QueryWrapper<SystemInfo> wrapper1 = new QueryWrapper<>();
            wrapper1.select(" id,host_name,state");
            List<SystemInfo> systemInfos = systemInfoService.list(wrapper1);
            List<SystemInfo> systemInfos2 = systemInfoService.list(wrapper);
            map.put("count",systemInfos.size());
            map.put("normalCount",systemInfos2.size());
            return R.ok(map);
        } catch (Exception e) {
            return R.failed("出错");
        }
    }

    @GetMapping("/getSnmp")
    public R getSnmp(){
        Map<String,Object> map = new HashMap<>();
        try {
            QueryWrapper<SnmpInfo> wrapper = new QueryWrapper<>();
            wrapper.select(" id,host_name,state");
            wrapper.lambda()
                    .eq(SnmpInfo::getState,1);
            QueryWrapper<SnmpInfo> wrapper1 = new QueryWrapper<>();
            wrapper1.select(" id,host_name,state");
            List<SnmpInfo> snmpInfos = snmpInfoService.list(wrapper1);
            List<SnmpInfo> snmpInfos2 = snmpInfoService.list(wrapper);
            map.put("count",snmpInfos.size());
            map.put("normalCount",snmpInfos2.size());
            return R.ok(map);
        } catch (Exception e) {
            return R.failed("出错");
        }
    }

    @GetMapping("/getTask")
    public R getTask(){
        Map<String,Object> map = new HashMap<>();
        try {
            QueryWrapper<InspectionTask> wrapper = new QueryWrapper<>();
            wrapper.select(" id,is_ok");
            wrapper.lambda()
                    .eq(InspectionTask::getIsOk,1);
            QueryWrapper<InspectionTask> wrapper1 = new QueryWrapper<>();
            wrapper1.select(" id,is_ok");
            List<InspectionTask> inspectionTasks = inspectionTaskService.list(wrapper1);
            List<InspectionTask> inspectionTasks2 = inspectionTaskService.list(wrapper);
            map.put("count",inspectionTasks.size());
            map.put("normalCount",inspectionTasks2.size());
            return R.ok(map);
        } catch (Exception e) {
            return R.failed("出错");
        }
    }

    @GetMapping("/getTaskInfoById")
    public R getTaskInfoById(String id){
        try {
            QueryWrapper<TaskInfo> wrapper = new QueryWrapper<>();
            wrapper.select(" id,task_id,task_date,is_ok,content");
            wrapper.lambda()
                    .eq(TaskInfo::getTaskId,id);
            List<TaskInfo> infos = taskInfoService.list(wrapper);
            return R.ok(infos);
        } catch (Exception e) {
            return R.failed("出错");
        }
    }

    @GetMapping("/getTaskByDate")
    public R getTaskByDate(String startDate,String endDate){
        try {
            QueryWrapper<InspectionTask> wrapper = new QueryWrapper<>();
            wrapper.select(" id,title,start_date");
            wrapper.lambda()
                    .between(StringUtils.isNotBlank(startDate) && StringUtils.isNotBlank(endDate),InspectionTask::getStartDate,startDate,endDate);
            return R.ok(inspectionTaskService.list(wrapper));
        } catch (Exception e) {
            return R.failed("出错");
        }
    }
    @GetMapping("/getUps")
    public R getUps(){
        Map<String,Object> map = new HashMap<>();
        try {
             map.put("ups",4);
             map.put("ups2",4);
             map.put("dianchi",6);
             map.put("dianchi2",6);
            return R.ok(map);
        } catch (Exception e) {
            return R.failed("出错");
        }
    }

    @GetMapping("/getKongtiao")
    public R getKongtiao(){
        Map<String,Object> map = new HashMap<>();
        try {
           map.put("upsKongtiao",2);
            map.put("upsKongtiao2",2);
            map.put("zhongxinKongtiao",4);
            map.put("zhongxinKongtiao2",4);
            return R.ok(map);
        }catch (Exception e){
            return R.failed("出错");
        }
    }

    /**
     * 根据类型查询报警日志
     * @param type
     * @return
     */
    @GetMapping("/getWarn")
    public R getWarn(Integer type){
        QueryWrapper<WarnLog> wrapper = new QueryWrapper<>();
        wrapper.lambda().eq(type != null,WarnLog::getType,type)
                .orderByDesc(WarnLog::getWarnDate)
                .last( " limit 11");
        List<WarnLog> list = warnService.list(wrapper);
        return R.ok(list);
    }

    /**
     * 地图数据
     * @param
     * @return
     */
    @GetMapping("/getMapData")
    public R getMapData(){
        List<Map<String,Object>> list = new ArrayList<>();
        Map<String,Object> map1 = new HashMap<>();
        map1.put("lon","118.14360");
        map1.put("lat","39.67260");
        map1.put("address","河北省唐山市路北区长宁道603号");
        map1.put("health",0);

        Map<String,Object> map2 = new HashMap<>();
        map2.put("lon","118.26958");
        map2.put("lat","39.68333");
        map2.put("address","河北省唐山市开平区东西大街199号");
        map2.put("health",0);

        Map<String,Object> map3 = new HashMap<>();
        map3.put("lon","118.15782");
        map3.put("lat","39.63102");
        map3.put("address","河北省唐山市路南区新华西道76号4层");
        map3.put("health",0);

        Map<String,Object> map4 = new HashMap<>();
        map4.put("lon","118.09289");
        map4.put("lat","39.58163");
        map4.put("address","河北省唐山市丰南区正苑大街7号");
        map4.put("health",0);

        Map<String,Object> map5 = new HashMap<>();
        map5.put("lon","118.14114");
        map5.put("lat","39.83368");
        map5.put("address","河北省唐山市丰润区曹雪芹大街17号");
        map5.put("health",0);

        Map<String,Object> map6 = new HashMap<>();
        map6.put("lon","118.45153");
        map6.put("lat","39.74049");
        map6.put("address","河北省唐山市古冶区永盛路");
        map6.put("health",0);
        list.add(map1);
        list.add(map2);
        list.add(map3);
        list.add(map4);
        list.add(map5);
        list.add(map6);
        return R.ok(list);
    }

    @GetMapping("/test")
    public R test(){
        SnmpUtil.getDonghuanInfo("1.3.6.1.4.1.32701.4.1.7.1.3.17");
        return R.ok("11111");
    }

    @RequestMapping("/upload")
    public R upload(@RequestParam("file") MultipartFile file,@RequestParam("type") Integer type)throws Exception{
        String name = file.getOriginalFilename();
        String[] split = name.split("\\.");
        if(!split[1].equals("xlsx")) {
            throw new Exception("文件格式错误");
        }
        if(type == 0){
            // 获取Excel中的数据
            List<DongHuanZhuangTai> detaileds = ExcelUtils.excelToShopIdList(file.getInputStream(),type);
            // 向数据库遍历添加数据库
            QueryWrapper<DongHuanZhuangTai> wrapper = new QueryWrapper<>();
            wrapper.lambda()
                    .eq(DongHuanZhuangTai::getType,type);
            dongHuanZhuangTaiService.remove(wrapper);
            dongHuanZhuangTaiService.saveBatch(detaileds);
            return R.ok("成功");
        }else {
            List<DongHuanBaoJing> dongHuanBaoJings = ExcelUtils.excelToShopIdList2(file.getInputStream(), type);
            // 向数据库遍历添加数据库
            QueryWrapper<DongHuanBaoJing> wrapper = new QueryWrapper<>();
            wrapper.lambda()
                    .eq(DongHuanBaoJing::getType,type);
            dongHuanBaoJingService.remove(wrapper);
            dongHuanBaoJingService.saveBatch(dongHuanBaoJings);
            return R.ok("成功");
        }
    }

}