package com.cloud.control.controller;


import com.alibaba.fastjson.JSONArray;
import com.cloud.control.model.TaskUser;
import com.cloud.control.service.TaskUserService;
import com.cloud.control.vo.TaskUserEditVo;
import com.cloud.model.common.Result;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.util.MultiValueMap;
import org.springframework.web.bind.annotation.*;

import java.util.List;
import java.util.Map;

@Slf4j
@RestController
@RequestMapping(value = "data/api-c/taskUser/")
public class TaskUserController {
    @Autowired
    private TaskUserService taskUserService;

    @RequestMapping(value = "saveTaskUser")
    @ApiOperation(value = "保存任务布控人员" ,notes = "保存任务布控人员", httpMethod = "POST", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
    public Result saveTaskUser(@RequestBody Map<String, Object> map){
        try {
            return Result.ok("保存成功", taskUserService.saveTaskUser(map));
        } catch (Exception e) {
            e.printStackTrace();
            return Result.error(e);
        }
    }

    @RequestMapping(value = "findTaskUserMenus")
    @ApiOperation(value = "从底库中选择", notes = "从底库中选择", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "params", value = "无用参数", required = false, dataType = "String", paramType = "query"),
            @ApiImplicitParam(name = "name", value = "姓名或底库名", required = false, dataType = "String", paramType = "query")
    })
    public Result findTaskUserMenusFromCluster(@RequestParam Map<String, Object> params){
        try {
            return Result.ok("查询成功", taskUserService.findTaskUserMenusFromCluster(params));
        } catch (Exception e) {
            e.printStackTrace();
            return Result.error(e);
        }
    }

    @RequestMapping(value = "findUserFromPlat")
    @ApiOperation(value = "从平台人员中选择", notes = "从平台人员中选择", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "params", value = "无用参数", required = false, dataType = "String", paramType = "query"),
            @ApiImplicitParam(name = "name", value = "组织机构名称/姓名", required = false, dataType = "String", paramType = "query"),
            @ApiImplicitParam(name = "orgById", value = "组织机构id", required = true, dataType = "long", paramType = "query")
    })
    public Result findTaskUserMenusFromPlat(@RequestParam Map<String, Object> params){
        try {
            return Result.ok("查询成功", taskUserService.findTaskUserMenusFromPlat(params));
        } catch (Exception e) {
            e.printStackTrace();
            return Result.error(e);
        }
    }

    @RequestMapping(value = "select",method = RequestMethod.POST)
    @ApiOperation(value = "查询布控人员列表", notes = "查询布控人员列表", httpMethod = "POST", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "orderBy", value = "排序列", required = false, dataType = "String", paramType = "query"),
            @ApiImplicitParam(name = "sortType", value = "排序规则", required = false, dataType = "String", paramType = "query"),
            @ApiImplicitParam(name = "taskId", value = "任务id", required = false, dataType = "String", paramType = "query"),
            @ApiImplicitParam(name = "start", value = "分页起始", required = false, dataType = "int", paramType = "query"),
            @ApiImplicitParam(name = "length", value = "分页截止", required = false, dataType = "int", paramType = "query"),
    })
    public Result select(@RequestParam Map<String,Object> params){
        Map map = taskUserService.select(params);
        return Result.custom("查询布控人员列表成功。",0,true,map);
    }

    @RequestMapping(value = "stopControl",method = RequestMethod.POST)
    public Result stopControl(@RequestParam List<String> ids){
        try{
            taskUserService.stopControl(ids);
            return Result.custom("停止布控成功！",0,true,null);
        }catch (Exception e){
            e.printStackTrace();
        }
        return Result.custom("停止布控失败!",1,false,null);
    }

    @RequestMapping(value = "deleteTaskUser",method = RequestMethod.POST)
    public Result deleteTaskUser(@RequestBody List<TaskUser> list){
        try{
            taskUserService.deleteTaskUser(list);
            return Result.custom("删除人员成功！",0,true,null);
        }catch (Exception e){
            e.printStackTrace();
        }
        return Result.custom("删除人员失败!",1,false,null);
    }

    @RequestMapping(value = "editShow",method = RequestMethod.POST)
    public Result editShow(String id){
        try{
            Map map = taskUserService.selectById(id);
            return Result.custom("回显人员成功！",0,true,map);
        }catch (Exception e){
            e.printStackTrace();
        }
        return Result.custom("回显人员失败!",1,false,null);
    }

    /**
     *
     * @param taskUser
     * @return
     */
    @RequestMapping(value = "save",method = RequestMethod.POST)
    public Result save(TaskUser taskUser){
        try{
            taskUserService.save(taskUser);
            return Result.custom("修改人员成功！",0,true,null);
        }catch (Exception e){
            e.printStackTrace();
        }
        return Result.custom("修改人员失败!",1,false,null);
    }
    /**
     * 给分析设备往布控表加人接口
     * */
    @RequestMapping(value = "addFromAnaly",method = RequestMethod.POST)
    public Result addFromAnaly(@RequestBody TaskUser taskUser){
        try{
            taskUserService.add(taskUser);
            return Result.custom("分析添加人员成功！",0,true,null);
        }catch (Exception e){
            e.printStackTrace();
        }
        return Result.custom("分析添加人员失败!",1,false,null);
    }

    /**
     * 布控人员更新（给C用）
     * */
    @RequestMapping(value = "updateFromC",method = RequestMethod.POST)
    public Result updateFromC(@RequestBody List<TaskUser> taskUsers){
        try{
            taskUserService.saveFromC(taskUsers);
            return Result.custom("分析更新人员成功！",0,true,null);
        }catch (Exception e){
            e.printStackTrace();
        }
        return Result.custom("分析更新人员失败!",1,false,null);
    }

    /**
     * 加入布控接口
     * */
    @RequestMapping(value = "joinControl",method = RequestMethod.POST)
    public Result joinControl(@RequestBody TaskUser taskUser){
        try{
            taskUserService.joinControl(taskUser);
            return Result.custom("加入布控成功！",0,true,null);
        }catch (Exception e){
            e.printStackTrace();
        }
        return Result.custom("加入布控失败!",1,false,null);
    }

}