|
@@ -5,18 +5,13 @@ import cn.hutool.core.util.ObjectUtil;
|
|
|
import cn.hutool.extra.spring.SpringUtil;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.TypeReference;
|
|
|
-import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.jeeplus.domain.*;
|
|
|
import com.jeeplus.flowable.feign.*;
|
|
|
-import com.jeeplus.sys.feign.IOfficeApi;
|
|
|
-import com.jeeplus.sys.feign.IPostApi;
|
|
|
import com.jeeplus.sys.feign.IUserApi;
|
|
|
-import com.jeeplus.sys.service.dto.PostDTO;
|
|
|
import com.jeeplus.sys.service.dto.UserDTO;
|
|
|
import com.xxl.job.core.context.XxlJobHelper;
|
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
|
import com.xxl.job.executor.feign.*;
|
|
|
-import org.apache.commons.lang3.ObjectUtils;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
@@ -63,6 +58,23 @@ public class SampleXxlJob {
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
+ * 将交接完成的员工账号进行冻结
|
|
|
+ */
|
|
|
+ @XxlJob("staffHeir")
|
|
|
+ public void getList(){
|
|
|
+ String list = SpringUtil.getBean(JyUserFeignApi.class).getList();
|
|
|
+ List<StaffHeirInfoDTO> staffUserInfoDTOS = JSON.parseObject(list, new TypeReference<List<StaffHeirInfoDTO>>() {});
|
|
|
+ for (StaffHeirInfoDTO staffUserInfoDTO : staffUserInfoDTOS) {
|
|
|
+ if ("5".equals(staffUserInfoDTO.getStatus())){
|
|
|
+ //将员工账号冻结
|
|
|
+ SpringUtil.getBean(JyUserFeignApi.class).updateUserById(staffUserInfoDTO.getCreateById(),"0");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
* 嘉溢转正申请发送通知
|
|
|
*/
|
|
|
@XxlJob("regularApply")
|
|
@@ -510,22 +522,22 @@ public class SampleXxlJob {
|
|
|
System.out.println("进来了---");
|
|
|
//获取报批签发逾期的数据
|
|
|
String json = SpringUtil.getBean ( ReportsSubmitFeignApi.class ).findReportsSubmitListExccedTime();
|
|
|
- List<JyProjectReportsSubmitInfo> jyProjectReportsSubmitInfos=JSON.parseObject(json,new TypeReference<List<JyProjectReportsSubmitInfo>>(){});
|
|
|
- for (JyProjectReportsSubmitInfo jyProjectReportsSubmitInfo : jyProjectReportsSubmitInfos) {
|
|
|
+ List<JyProjectReportsSubmitInfoDTO> jyProjectReportsSubmitInfoDTOS =JSON.parseObject(json,new TypeReference<List<JyProjectReportsSubmitInfoDTO>>(){});
|
|
|
+ for (JyProjectReportsSubmitInfoDTO jyProjectReportsSubmitInfoDTO : jyProjectReportsSubmitInfoDTOS) {
|
|
|
//修改报批签发状态
|
|
|
- SpringUtil.getBean( IJyProjectApi.class).updateExceedTimeStatus(jyProjectReportsSubmitInfo.getId(),jyProjectReportsSubmitInfo.getStatus(),"1");
|
|
|
+ SpringUtil.getBean( JyProjectAuditFeignApi.class).updateExceedTimeStatus(jyProjectReportsSubmitInfoDTO.getId(), jyProjectReportsSubmitInfoDTO.getStatus(),"1");
|
|
|
}
|
|
|
//获取报批签发未逾期的数据
|
|
|
String json1 = SpringUtil.getBean ( ReportsSubmitFeignApi.class ).findReportsSubmitListInTime();
|
|
|
- List<JyProjectReportsSubmitInfo> jyProjectReportsSubmitInfoList=JSON.parseObject(json1,new TypeReference<List<JyProjectReportsSubmitInfo>>(){});
|
|
|
- for (JyProjectReportsSubmitInfo jyProjectReportsSubmitInfo : jyProjectReportsSubmitInfoList) {
|
|
|
+ List<JyProjectReportsSubmitInfoDTO> jyProjectReportsSubmitInfoDTOList =JSON.parseObject(json1,new TypeReference<List<JyProjectReportsSubmitInfoDTO>>(){});
|
|
|
+ for (JyProjectReportsSubmitInfoDTO jyProjectReportsSubmitInfoDTO : jyProjectReportsSubmitInfoDTOList) {
|
|
|
//对数据进行发送通知
|
|
|
String taskName = null;
|
|
|
String titleStr = null;
|
|
|
//创建calendar对象
|
|
|
Calendar instance = Calendar.getInstance();
|
|
|
//将日期设置为用印修改时间
|
|
|
- instance.setTime(jyProjectReportsSubmitInfo.getFirstSubmitTime());
|
|
|
+ instance.setTime(jyProjectReportsSubmitInfoDTO.getFirstSubmitTime());
|
|
|
//往后推两周
|
|
|
instance.add(Calendar.MONTH,2);
|
|
|
//获取推送后的日期
|
|
@@ -535,17 +547,17 @@ public class SampleXxlJob {
|
|
|
//如果当前时间小于首次发起报批签发两个月后的时间且在期限时间七天之内
|
|
|
taskName = "嘉溢-报批签发";
|
|
|
if(newDate.after(new Date()) && interval1 <= 7 && interval1 >=0){
|
|
|
- titleStr = "项目【"+ jyProjectReportsSubmitInfo.getProjectName().substring(0,jyProjectReportsSubmitInfo.getProjectName().lastIndexOf(","))+"】还未完成,";
|
|
|
+ titleStr = "项目【"+ jyProjectReportsSubmitInfoDTO.getProjectName().substring(0, jyProjectReportsSubmitInfoDTO.getProjectName().lastIndexOf(","))+"】还未完成,";
|
|
|
titleStr = titleStr + "剩余:" + interval1 + "天。请尽快发起!";
|
|
|
}else {
|
|
|
- titleStr = "项目【"+ jyProjectReportsSubmitInfo.getProjectName().substring(0,jyProjectReportsSubmitInfo.getProjectName().lastIndexOf(","))+"】还未完成";
|
|
|
+ titleStr = "项目【"+ jyProjectReportsSubmitInfoDTO.getProjectName().substring(0, jyProjectReportsSubmitInfoDTO.getProjectName().lastIndexOf(","))+"】还未完成";
|
|
|
}
|
|
|
|
|
|
Set<String> noticeUserSet = new HashSet<String>();
|
|
|
//发送通知
|
|
|
- if(StringUtils.isNotBlank(jyProjectReportsSubmitInfo.getCreateById())){
|
|
|
+ if(StringUtils.isNotBlank(jyProjectReportsSubmitInfoDTO.getCreateById())){
|
|
|
|
|
|
- String byIdForXXL = SpringUtil.getBean(IUserApi.class).getByIdForXXL(jyProjectReportsSubmitInfo.getCreateById());
|
|
|
+ String byIdForXXL = SpringUtil.getBean(IUserApi.class).getByIdForXXL(jyProjectReportsSubmitInfoDTO.getCreateById());
|
|
|
UserDTO createUser = JSON.parseObject(byIdForXXL, new TypeReference<UserDTO>() {});
|
|
|
if(null != createUser && StringUtils.isNotBlank(createUser.getId())){
|
|
|
noticeUserSet.add(createUser.getId());
|
|
@@ -560,9 +572,9 @@ public class SampleXxlJob {
|
|
|
myNotice.setUpdateTime(new Date());
|
|
|
myNotice.setDelFlag(0);
|
|
|
//根据procInsId获取taskId
|
|
|
- String currentTask = SpringUtil.getBean(IFlowableApi.class).getTaskIdByprocInstId(jyProjectReportsSubmitInfo.getProcInsId());
|
|
|
+ String currentTask = SpringUtil.getBean(IFlowableApi.class).getTaskIdByprocInstId(jyProjectReportsSubmitInfoDTO.getProcInsId());
|
|
|
myNotice.setTaskId(currentTask);
|
|
|
- myNotice.setDefId(jyProjectReportsSubmitInfo.getProcessDefinitionId());
|
|
|
+ myNotice.setDefId(jyProjectReportsSubmitInfoDTO.getProcessDefinitionId());
|
|
|
myNotice.setTitle(titleStr);
|
|
|
myNotice.setTaskName(taskName);
|
|
|
myNotice.setLink("结束");
|
|
@@ -572,7 +584,7 @@ public class SampleXxlJob {
|
|
|
|
|
|
for (String noticeUserId : noticeUserList) {
|
|
|
myNotice.setNoticeId(noticeUserId);
|
|
|
- String byIdForXXL = SpringUtil.getBean(IUserApi.class).getByIdForXXL(jyProjectReportsSubmitInfo.getCreateById());
|
|
|
+ String byIdForXXL = SpringUtil.getBean(IUserApi.class).getByIdForXXL(jyProjectReportsSubmitInfoDTO.getCreateById());
|
|
|
UserDTO createUser = JSON.parseObject(byIdForXXL, new TypeReference<UserDTO>() {});
|
|
|
myNotice.setNoticeName(createUser.getName());
|
|
|
//根据taskName和通知人 查询重复数量
|