|
|
@@ -6,6 +6,8 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
import com.management.platform.entity.*;
|
|
|
import com.management.platform.entity.dto.TaskDto;
|
|
|
+import com.management.platform.mapper.TaskExecutorMapper;
|
|
|
+import com.management.platform.mapper.TaskMapper;
|
|
|
import com.management.platform.mapper.UserMapper;
|
|
|
import com.management.platform.mapper.WxCorpInfoMapper;
|
|
|
import com.management.platform.service.InformationService;
|
|
|
@@ -129,6 +131,35 @@ public class TaskController {
|
|
|
return taskService.getTaskDetail(id,request);
|
|
|
}
|
|
|
|
|
|
+
|
|
|
+/* @RequestMapping("sendMsg")
|
|
|
+ public HttpRespMsg sendMsg(){
|
|
|
+ String token = request.getHeader("Token");
|
|
|
+ User user = userMapper.selectById(token);
|
|
|
+ List<WxCorpInfo> wxCorpInfos = wxCorpInfoMapper.selectList(new QueryWrapper<WxCorpInfo>().eq("company_id",user.getCompanyId()));
|
|
|
+ for (WxCorpInfo wxCorpInfo : wxCorpInfos) {
|
|
|
+ LocalDate now = LocalDate.now();
|
|
|
+ List<Task> taskList = taskMapper.selectList(new QueryWrapper<Task>().eq("company_id", wxCorpInfo.getCompanyId()).ne("status",2).and(wrapper -> wrapper.eq("end_date", now).or().eq("end_date", now.plusDays(1))));
|
|
|
+ List<User> userList = userMapper.selectList(new QueryWrapper<User>().eq("company_id", wxCorpInfo.getCompanyId()));
|
|
|
+ List<Integer> taskIds = taskList.stream().map(Task::getId).distinct().collect(Collectors.toList());
|
|
|
+ taskIds.add(-1);
|
|
|
+ List<TaskExecutor> taskExecutorList = taskExecutorMapper.selectList(new QueryWrapper<TaskExecutor>().in("task_id", taskIds));
|
|
|
+ for (Task task : taskList) {
|
|
|
+ List<String> list = taskExecutorList.stream().filter(tl -> tl.getTaskId().equals(task.getId())).map(TaskExecutor::getExecutorId).distinct().collect(Collectors.toList());
|
|
|
+ String corpUserid = userList.stream().filter(ul -> list.contains(ul.getId())).map(User::getCorpwxUserid).distinct().collect(Collectors.joining(","));
|
|
|
+ StringBuilder stringBuilder=new StringBuilder();
|
|
|
+ stringBuilder.append("您负责的任务["+task.getTaskName()+"]");
|
|
|
+ if(task.getEndDate().isEqual(now)){
|
|
|
+ stringBuilder.append("今天");
|
|
|
+ }else if(task.getEndDate().isEqual(now.plusDays(1))){
|
|
|
+ stringBuilder.append("一天后");
|
|
|
+ }
|
|
|
+ stringBuilder.append("截止,请抓紧时间完成!");
|
|
|
+ wxCorpInfoService.sendWXCorpMsg(wxCorpInfo,corpUserid,stringBuilder.toString(),"task",null);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return new HttpRespMsg();
|
|
|
+ }*/
|
|
|
/**
|
|
|
* 定时修改过期的任务状态
|
|
|
*/
|
zhouyy