package com.rzyc.controller;

import com.common.utils.RandomNumber;
import com.common.utils.StringUtils;
import com.common.utils.model.MultiResult;
import com.common.utils.model.Pager;
import com.common.utils.model.SingleResult;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.rzyc.bean.UserDepart;
import com.rzyc.bean.task.dto.AddTaskDto;
import com.rzyc.bean.task.dto.IdDto;
import com.rzyc.bean.task.dto.UserWarningDto;
import com.rzyc.bean.task.vo.TaskDetailVo;
import com.rzyc.bean.task.vo.TaskNameVo;
import com.rzyc.bean.task.vo.TaskVo;
import com.rzyc.bean.task.vo.ThingVo;
import com.rzyc.enums.DelState;
import com.rzyc.mapper.SysWarningTypeMapper;
import com.rzyc.model.*;
import com.rzyc.model.task.dto.TaskAddOrUpdateDto;
import com.rzyc.model.user.SysUser;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.beanutils.ConvertUtils;
import org.apache.commons.beanutils.converters.DateConverter;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import javax.validation.Valid;
import java.util.Date;
import java.util.List;

/**
 * @ClassName: TaskController
 * @description:
 * @author: ZQW
 * * @create: 2022-09-20 15:21
 **/

@Api(tags = "工作任务")
@CrossOrigin("*")
@RequestMapping("task")
@RestController
@Validated
public class TaskController extends BaseController{





    /**
     * @Description: 待办事项列表
     * @Author ZQW
     * @CreateTime 2022/9/23 10:20
     */
   /* @ApiOperation(value = "待办事项列表",position = 2)
    @GetMapping("thingsList")
    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "id",value = "任务类型id")
    })
    public MultiResult<ThingVo> thingsList(@Valid IdDto idDto){
        MultiResult<ThingVo> result = new MultiResult<>();
        List<ThingVo> thingVos = oaTaskMapper.thingsList(idDto);
        System.out.println("查询的数据=====" + thingVos);
        result.setData(thingVos);
        return result;
    }*/

    /**
     * @return: 查询我发布的任务
     * @Author: ZQW
     * @Date: 2022/9/20
     */
    @ApiOperation(value = "查询我发布的任务",position = 3)
    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "id",value = "发布人id")
    })
    @GetMapping("deliverTaskList")
    public MultiResult<TaskVo> deliverTaskList(@Valid IdDto idDto) throws Exception{
        MultiResult<TaskVo> result = new MultiResult<>();
        SysUser user = sysUserMapper.selectByPrimaryKey(idDto.getId());
        System.out.println("user=========" + user);
        List<TaskVo> oaTasks = oaTaskMapper.deliverTaskList("%%",idDto.getId());

        if(null == user){
            result.setCode(0);
            result.setMessage("未知错误");
            return result;
        }
        if(oaTasks != null){
            result.setData(oaTasks);
        }

        return result;
    }

    /**
     * @Description: 查询我收到的任务
     * @Author ZQW
     * @CreateTime 2022/9/26 9:34
     */
    @ApiOperation(value = "查询我收到的任务",position = 4)
    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "id",value = "接收用户id")
    })
    @GetMapping("getTaskList")
    public MultiResult<TaskVo> getTaskList(@Valid IdDto idDto){
        MultiResult<TaskVo> result = new MultiResult<>();
        SysUser user = sysUserMapper.selectByPrimaryKey(idDto.getId());
        List<TaskVo> oaTasks = oaTaskMapper.getTaskList("%%",idDto.getId());

        if(null == user){
            result.setCode(0);
            result.setMessage("未知错误");
            return result;
        }
        if(oaTasks != null){
            result.setData(oaTasks);
        }
        return result;
    }



    /**
     * @return: 新增任务执行情况
     * @Author: ZQW
     * @Date: 2022/9/20
     */
    @ApiOperation(value = "新增或修改任务执行情况",position = 10)
    @PostMapping("addExecute")
    public SingleResult<String> addExecute(@Valid TaskAddOrUpdateDto addTaskDto) throws Exception{
        SingleResult<String> result = new SingleResult<>();
        OADistribution oaDistribution = new OADistribution();
        BeanUtils.copyProperties(oaDistribution,addTaskDto);
        //日期格式转换
        ConvertUtils.register(new DateConverter(null), Date.class);

        SysUser sysUser = sysUserMapper.selectByPrimaryKey(addTaskDto.getSysuserid());
        OATask oaTask = oaTaskMapper.findById(addTaskDto.getOataskid());
        System.out.println("任务 ========"  + oaTask);
        if(null == sysUser){
            result.setCode(0);
            result.setMessage("用户不存在");
            return result;
        }

        if(null == oaTask){
            result.setCode(0);
            result.setMessage("未知任务");
            return result;
        }

        if(StringUtils.isBlank(addTaskDto.getOadistributionid())){
            oaDistribution.setOadistributionid(RandomNumber.getUUid());
            oaDistribution.setSyschinaname(sysUser.getChinaname());
            oaDistribution.setSystelephone(sysUser.getMobiletel());
            oaDistribution.setCreatedby(getUserId());
            oaDistribution.setCreatedon(new Date());
            oaDistributionMapper.insert(oaDistribution);
        }else {
            oaDistribution.setModifiedby(getUserId());
            oaDistribution.setModifiedon(new Date());
            oaDistributionMapper.updateById(oaDistribution);
        }

        return result;
    }

    /**
     * @Description: 发布任务详情
     * @Author ZQW
     * @CreateTime 2022/9/29 13:56
     */
    @ApiOperation(value = "发布(收到)任务详情",position = 11)
    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "id",value = "任务1id")
    })
    @GetMapping("deliverTaskDetail")
    public SingleResult<TaskDetailVo> deliverTaskDetail(@Valid IdDto idDto){
        SingleResult<TaskDetailVo> result = new SingleResult<>();
        TaskDetailVo detailVo = oaTaskMapper.selectDetail(idDto.getId());
        result.setData(detailVo);
        return result;
    }


    /**
     * 智能预警类型列表
     * @version v1.0
     * @author dong
     * @date 2023/2/8 10:02
     */
    @ApiOperation(value = "智能预警类型列表")
    @GetMapping("warningTypeList")
    public MultiResult<SysWarningType> warningTypeList()throws Exception{
        MultiResult<SysWarningType> result = new MultiResult<>();
        List<SysWarningType> warningTypes = sysWarningTypeMapper.findAll();
        result.setData(warningTypes);
//        addWarning();
        return result;
    }

    public void addWarning()throws Exception{

        String uesrId = "8D35010B-EB9A-40EE-BDEB-CDAE969D5EF4";

        SysWarning sysWarning = new SysWarning();
        sysWarning.setWarningId(RandomNumber.getUUid());
        sysWarning.setSendId(uesrId);
        sysWarning.setWarningInfo("企业重大隐患预警");
        sysWarning.setWarningTime(new Date());
        sysWarning.setTypeId("110cfd4e-a754-11ed-b840-00163e0c1c62");
        sysWarning.setDelState(DelState.NOT_DEL.getState());
        sysWarning.setCreateBy(uesrId);
        sysWarning.setModifyBy(uesrId);
        sysWarning.setCreateTime(new Date());
        sysWarning.setModifyTime(new Date());
        sysWarningMapper.insert(sysWarning);

        SysWarningUser warningUser = new SysWarningUser();
        warningUser.setWarningUserId(RandomNumber.getUUid());
        warningUser.setWarningId(sysWarning.getWarningId());
        warningUser.setTypeId("110cfd4e-a754-11ed-b840-00163e0c1c62");
        warningUser.setUserId(uesrId);
        warningUser.setState(1);
        warningUser.setDelState(DelState.NOT_DEL.getState());
        warningUser.setCreateBy(uesrId);
        warningUser.setModifyBy(uesrId);
        warningUser.setCreateTime(new Date());
        warningUser.setModifyTime(new Date());
        sysWarningUserMapper.insert(warningUser);

        warningUser = new SysWarningUser();
        warningUser.setWarningUserId(RandomNumber.getUUid());
        warningUser.setWarningId(sysWarning.getWarningId());
        warningUser.setTypeId("110cfd4e-a754-11ed-b840-00163e0c1c62");
        warningUser.setUserId("879a81b3-2379-4ad7-bab8-0ea51dcecf9e");
        warningUser.setState(1);
        warningUser.setDelState(DelState.NOT_DEL.getState());
        warningUser.setCreateBy(uesrId);
        warningUser.setModifyBy(uesrId);
        warningUser.setCreateTime(new Date());
        warningUser.setModifyTime(new Date());
        sysWarningUserMapper.insert(warningUser);

    }

    /**
     * 用户智能预警数量
     * @version v1.0
     * @author dong
     * @date 2023/2/8 14:30
     */
    @ApiOperation(value = "用户智能预警数量")
    @ApiImplicitParam(name = "userId",value = "用户id")
    @GetMapping("userWarningNum/{userId}")
    public MultiResult<SysWarningType> userWarningNum(@PathVariable String userId)throws Exception{
        MultiResult<SysWarningType> result = new MultiResult<>();
        List<SysWarningType> warningTypes = sysWarningTypeMapper.userWarningNum(userId);
        result.setData(warningTypes);
        return result;
    }

    /**
     * 用户智能预警分页
     * @version v1.0
     * @author dong
     * @date 2023/2/8 14:43
     */
    @ApiOperation(value = "用户智能预警分页")
    @GetMapping("userWarningPage")
    public SingleResult<Pager<SysWarningUser>> userWarningPage(@Valid UserWarningDto userWarningDto)throws Exception{
        SingleResult<Pager<SysWarningUser>> result = new SingleResult<>();
        PageHelper.startPage(userWarningDto.getPage(), userWarningDto.getPageSize());
        Page<SysWarningUser> page = (Page<SysWarningUser>)sysWarningUserMapper.userWarningList(userWarningDto.getUserId(),userWarningDto.getState(),userWarningDto.getTypeId());
        Pager<SysWarningUser> pager = new Pager<>();
        getDatePage(pager,page);
        result.setData(pager);
        return result;
    }

    /**
     * 用户智能预警已读
     * @version v1.0
     * @author dong
     * @date 2023/2/8 15:35
     */
    @ApiOperation(value = "用户智能预警已读")
    @ApiImplicitParam(name = "warningUserId",value = "预警接收用户id")
    @PostMapping("userWarningRead/{warningUserId}")
    public SingleResult<String> userWarningRead(@PathVariable String warningUserId)throws Exception{
        SingleResult<String> result = new SingleResult<>();
        sysWarningUserMapper.changeState(warningUserId);
        return result;
    }

}