package com.cloud.control.controller;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.cloud.control.service.ClusterService;
import com.cloud.control.service.TaskService;
import com.cloud.model.common.Result;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Map;
@Slf4j
@RestController
@RequestMapping(value = "data/api-c/task")
@Api(value = "data/api-c/task" ,description = "布控列表查询")
public class TaskController {

    @Autowired
    private TaskService taskService;
    @Autowired
    private ClusterService clusterService;

    private SimpleDateFormat sdfTime = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");

    private SimpleDateFormat sdfDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    @RequestMapping(value = "findTaskList",method = RequestMethod.POST)
    @ApiOperation(value = "",notes = "任务列表",produces = MediaType.APPLICATION_JSON_UTF8_VALUE,httpMethod = "POST")
    @ApiImplicitParam(value = "{\"startTime\":\"\",\"endTime\":\"\",\"likeName\":\"\",\"status\":1," +
            "\"source\":\"\",\"page\":1,\"size\":4,\"sortName\":\"可空/name-- 布控任务  /startTime 开始时间/endTime结束时间/status 布控状态 " +
            "/personCount 布控人数/ source来源/scope 范围/  createBy 操作人\",\"sortType\":\"desc/asc\"}",dataType = "Map")
    public Result findTaskListByPage(@RequestBody Map<String,Object> requMap) throws ParseException {
     String startStr  =  (String) requMap.get("startTime");
        Date startTime = null;
       if (!StringUtils.isBlank(startStr)){
           startTime = sdfTime.parse(startStr);
       }
        String endStr = (String) requMap.get("endTime");
        Date endTime = null;
       if (!StringUtils.isBlank(endStr)){
            endTime = sdfTime.parse(endStr);
       }
        String likeName = (String) requMap.get("likeName");
        Integer status = (Integer) requMap.get("status");
        String source = (String) requMap.get("source");
        Integer page = (Integer) requMap.get("page");
        Integer size = (Integer) requMap.get("size");
        String sortName = (String) requMap.get("sortName");
        //  name-- 布控任务  startTime -- 开始时间  endTime --  status 布控状态 -- personCount 布控人数
        //  source   scope   createBy 操作人
        String sortType = (String) requMap.get("sortType"); //
        if (startTime != null && startTime.toString().isEmpty()){ startTime = null; }
        if (endTime != null && endTime.toString().isEmpty()){ endTime = null;}
        if (StringUtils.isBlank(likeName)){ likeName = null;}
        if (StringUtils.isBlank(source)){ source = null;}
        if (page == null){ page = 1;}
        if (size == null) {size = 10;}
        if (sortType == null || sortType.equalsIgnoreCase("desc")){ sortType= "desc";}
        else {sortType = "asc";}
        int from = (page - 1)* size;
        JSONObject respTask = taskService.queryTaskListByPage(startTime, endTime, likeName, status, source,
                from, size,sortName,sortType);
        return Result.ok("查询布控任务列表成功。", respTask);
    }

    @RequestMapping(value = "findSourceList",method = RequestMethod.POST)
    @ApiOperation(value = "",notes = "来源列表",produces = MediaType.APPLICATION_JSON_UTF8_VALUE,httpMethod = "POST")
    public Result findSourceList() throws ParseException {
        JSONObject respTask = taskService.querySoureList();
        return Result.ok("查询布控任务列表成功。", respTask);
    }

    @RequestMapping(value = "findOneTask",method = RequestMethod.POST)
    @ApiOperation(value = "",notes = "查询任务信息",produces = MediaType.APPLICATION_JSON_UTF8_VALUE,httpMethod = "POST")
    @ApiImplicitParam(value = "{\"taskId\":\"id\"}")
    public Result findOneTask(@RequestBody Map<String,String> reqMap) throws ParseException {
           String taskId = reqMap.get("taskId");
            if (StringUtils.isBlank(taskId)){
                throw new IllegalArgumentException("taskId 为空");
            }
        JSONObject respTask = taskService.queryTaskById(taskId);
        return Result.ok("查询布控任务列表成功。", respTask);
    }

    @RequestMapping(value = "findScopeDetailByTaskId",method = RequestMethod.POST)
    @ApiOperation(value = "",notes = "查询布控范围列表详情",produces = MediaType.APPLICATION_JSON_UTF8_VALUE,httpMethod = "POST")
    @ApiImplicitParam(value = "{\"taskId\":\"id\"}")
    public Result findScopeDetailByTaskId(@RequestBody Map<String,String> reqMap) throws ParseException {
        String taskId = reqMap.get("taskId");
        if (StringUtils.isBlank(taskId)){
            throw new IllegalArgumentException("taskId 为空");
        }
        JSONArray respTask = taskService.queryTaskScopeDetailById(taskId);
        return Result.ok("查询布控范围列表详情。", respTask);
    }

    /**
     * 测试使用
     * @return
     */
    @RequestMapping(value = "findAllNode",method = RequestMethod.POST)
    @ApiOperation(value = "",notes = "测试使用 查询全部节点数据",
            produces = MediaType.APPLICATION_JSON_UTF8_VALUE,httpMethod = "POST")
    public Result findAllNode(@RequestBody Map<String,Object> reqMap){
//        Date date = (Date) reqMap.get("date");
//        log.info(date+"时间类型接收");
        Result allNode = clusterService.findAllNode();
        return allNode;
    }

    /**
     * 前端创建布控任务
     * @return
     */
    @RequestMapping(value = "addTask",method = RequestMethod.POST)
    @ApiOperation(value = "",notes = "前端创建布控任务",
            produces = MediaType.APPLICATION_JSON_UTF8_VALUE,httpMethod = "POST")
    @ApiImplicitParam(value = "{\"taskName\":\"\",\"threshold\":69,\"startTime\":\"yyyy/MM/dd HH:mm:ss\"," +
            "\"endTime\":\"yyyy/MM/dd HH:mm:ss\",\"Ids\":[\"devid1\",\"devid2\"]}")
    public Result addTask(@RequestBody Map<String,Object> reqMap) throws ParseException {
        String taskName = (String) reqMap.get("taskName");
        Integer threshold = (Integer) reqMap.get("threshold");
              String start  = (String) reqMap.get("startTime");
        Date startTime = sdfTime.parse(start);
                String end = (String) reqMap.get("endTime");
        Date endTime = sdfTime.parse(end);
        List<String> devIds = (List<String>) reqMap.get("Ids");
        if (StringUtils.isBlank(taskName) || threshold == null || startTime == null || endTime == null || devIds == null || devIds.size() <1){
            String reqParamMsg = "taskName:"+taskName+"threshold:"+threshold+"startTime:"+startTime+"endTime:"+endTime+"devIds:"+devIds.toString();
            return Result.error(new IllegalArgumentException(reqParamMsg+"参数为空"));
        }
        JSONObject jsonObj = taskService.addTaskForIndevice(null,taskName, threshold, startTime, endTime,
                devIds,false,null);
        if (jsonObj.getString("code")!=null){
            return Result.custom("布控任务已存在",40010,false,jsonObj);
        }
        if (jsonObj.getBoolean("result")){
          return  Result.ok(jsonObj.getString("msg"),jsonObj);
        }else {
            return  Result.error(new RuntimeException(jsonObj.getString("msg")));
        }
    }

    /**
     * 前端修改布控任务
     * @return
     */
    @RequestMapping(value = "updateTask",method = RequestMethod.POST)
    @ApiOperation(value = "",notes = "前端修改布控任务",
            produces = MediaType.APPLICATION_JSON_UTF8_VALUE,httpMethod = "POST")
    @ApiImplicitParam(value = "{\"taskName\":\"\",\"id\":\"taskId\",\"threshold\":69,\"startTime\":\"yyyy/MM/dd HH:mm:ss\"," +
            "\"endTime\":\"yyyy/MM/dd HH:mm:ss\",\"nowDevIds\":[\"devId1\",\"devId2\"]}")
    public Result updateTask(@RequestBody Map<String,Object> reqMap) throws ParseException {
        String taskName = (String) reqMap.get("taskName");
        String uuid = (String) reqMap.get("id");
        Integer threshold = (Integer) reqMap.get("threshold");
                String start = (String) reqMap.get("startTime");
        Date startTime = sdfTime.parse(start);
              String end = (String) reqMap.get("endTime");
        Date endTime = sdfTime.parse(end);
        List<String> nowDevIds = (List<String>) reqMap.get("nowDevIds");
        if (StringUtils.isBlank(uuid) ){
            String reqParamMsg = "taskName:"+taskName+"threshold:"+threshold+"startTime:"
                    +startTime+"endTime:"+endTime+"nowDevIds:"+nowDevIds.toString();
            return Result.error(new IllegalArgumentException(reqParamMsg+"参数为空"));
        }
        JSONObject jsonObj = taskService.updateTask(uuid,taskName, threshold, startTime, endTime, nowDevIds);
        if (jsonObj.getBoolean("result")){
            return  Result.ok(jsonObj.getString("msg"),jsonObj);
        }else {
            return  Result.error(new RuntimeException(jsonObj.getString("msg")));
        }
    }

    /**
     * 前端停止布控任务
     * @return
     */
    @RequestMapping(value = "stopTask",method = RequestMethod.POST)
    @ApiOperation(value = "",notes = "停止布控任务",
            produces = MediaType.APPLICATION_JSON_UTF8_VALUE,httpMethod = "POST")
    @ApiImplicitParam(value = "{\"id\":\"taskId\"}")
    public Result stopTask(@RequestBody Map<String,Object> reqMap){
        String uuid = (String) reqMap.get("id");
//        String taskName = (String) reqMap.get("taskName");
        if (StringUtils.isBlank(uuid) ){
            String reqParamMsg = "uuid:"+uuid;
            return Result.error(new IllegalArgumentException(reqParamMsg+"参数为空"));
        }
        JSONObject jsonObj = taskService.stopTask(uuid); // taskName
        if (jsonObj.getBoolean("result")){
            return  Result.ok(jsonObj.getString("msg"),jsonObj);
        }else{
            return  Result.error(new RuntimeException(jsonObj.getString("msg")));
        }
    }

    /**
     * 前端删除布控任务
     * @return
     */
    @RequestMapping(value = "delTask",method = RequestMethod.POST)
    @ApiOperation(value = "",notes = "删除布控任务 ",
            produces = MediaType.APPLICATION_JSON_UTF8_VALUE,httpMethod = "POST")
    @ApiImplicitParam(value = "{\"id\":\"taskId\"}")
    public Result delTask(@RequestBody Map<String,Object> reqMap){
        String uuid = (String) reqMap.get("id");
//        String taskName = (String) reqMap.get("taskName");
//        List<String> devIds = (List<String>) reqMap.get("devIds");
        if (StringUtils.isBlank(uuid)){ //  ||  devIds == null || devIds.size() <1
            String reqParamMsg = "uuid:"+uuid; // +"devIds:"+devIds.toString()
            return Result.error(new IllegalArgumentException(reqParamMsg+"参数为空"));
        }
        JSONObject jsonObj = taskService.delTask(uuid); // devIds   taskName
        if (jsonObj.getBoolean("result")){
            return  Result.ok(jsonObj.getString("msg"),jsonObj);
        }else{
            return  Result.error(new RuntimeException(jsonObj.getString("msg")));
        }
    }

    /**
     * c 调用 创建 布控任务
     * @return
     */
    @RequestMapping(value = "addTaskByNode",method = RequestMethod.POST)
    @ApiOperation(value = "",notes = "c 调用创建布控报警底库任务",
            produces = MediaType.APPLICATION_JSON_UTF8_VALUE,httpMethod = "POST")
    @ApiImplicitParam(value = "{\"TableName\":\"\",\"SyncType\":\"1/0\",\"threshold\":60,\"StartTime\":\"yyyy/MM/dd HH:mm:ss\"," +
            "  \"EndTime\":\"yyyy/MM/dd HH:mm:ss\",\"enabled\":\"1\",\"cluId\":\"\",\"devId\":\"\",\"uuid\":\"\"}")
    public Result addTaskByNode(@RequestBody  Map<String,Object> reqMap) throws ParseException {
        String taskName = (String) reqMap.get("TableName");
        String syncType = (String) reqMap.get("SyncType");
        Integer threshold = (Integer) reqMap.get("threshold");
        String  start = (String) reqMap.get("StartTime");
        Date startTime = sdfDate.parse(start);
        String  end =(String) reqMap.get("EndTime");
        Date endTime = sdfDate.parse(end);
        String enabled = (String) reqMap.get("enabled");
        String cluId = (String) reqMap.get("cluId");
        String devId = (String) reqMap.get("devId");
        String uuid = (String) reqMap.get("uuid");
        if (StringUtils.isBlank(taskName) || threshold == null || startTime == null || endTime == null || StringUtils.isBlank(cluId)
        || StringUtils.isBlank(devId)|| StringUtils.isBlank(uuid)){
            String reqParamMsg = "taskName:"+taskName+"threshold:"+threshold+"startTime:"+startTime+"endTime:"+endTime+
                    "cluId:"+cluId.toString()+"devId:"+devId;
            return Result.error(new IllegalArgumentException(reqParamMsg+"参数为空"));
        }
        JSONObject jsonObj = taskService.addTaskByNode(uuid,taskName, threshold, startTime, endTime,syncType, enabled,cluId,devId);
        if (jsonObj.getBoolean("result")){
            return  Result.ok(jsonObj.getString("msg"),jsonObj);
        }else {
            return  Result.error(new RuntimeException(jsonObj.getString("msg")));
        }
    }

    @RequestMapping(value = "getAddToCtlTree")
    @ApiOperation(value = "获取加入布控树", notes = "获取加入布控树", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
    public Result getAddToCtlTree(){
        try {
            return Result.ok("查询成功", taskService.getAddToCtlTree());
        } catch (Exception e) {
            e.printStackTrace();
            return Result.error(e);
        }
    }

}