301 lines
10 KiB
Java
301 lines
10 KiB
Java
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.task.dto.IdDto;
|
|
import com.rzyc.bean.task.dto.UserWarningDto;
|
|
import com.rzyc.bean.task.vo.TaskDetailVo;
|
|
import com.rzyc.bean.task.vo.TaskVo;
|
|
import com.rzyc.enums.DelState;
|
|
import com.rzyc.model.*;
|
|
import com.rzyc.model.sys.SysWarning;
|
|
import com.rzyc.model.sys.SysWarningType;
|
|
import com.rzyc.model.sys.SysWarningUser;
|
|
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;
|
|
}
|
|
|
|
}
|