package org.springblade.mdm.task;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import lombok.extern.slf4j.Slf4j;
|
import org.flowable.engine.TaskService;
|
import org.flowable.task.api.TaskQuery;
|
import org.springblade.core.secure.utils.AuthUtil;
|
import org.springblade.core.tool.utils.Func;
|
import org.springblade.mdm.basesetting.producedivision.entity.MdmUser;
|
import org.springblade.mdm.basesetting.producedivision.service.MdmUserService;
|
import org.springblade.mdm.commons.contants.ParamConstants;
|
import org.springblade.mdm.commons.service.InternalEmailProperties;
|
import org.springblade.mdm.commons.service.InternalEmailService;
|
import org.springblade.mdm.commons.service.ParamService;
|
import org.springblade.mdm.program.service.NcProgramApprovedService;
|
import org.springblade.mdm.program.vo.NcProgramExportDncPageVO;
|
import org.springblade.mdm.program.vo.NcProgramExportDncQueryVO;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
|
/**
|
* 内部邮件任务提醒定时任务
|
*/
|
@Slf4j
|
@Component
|
@EnableScheduling
|
public class InternalEmailNotifyTask {
|
@Autowired
|
private MdmUserService mdmUserService;
|
@Autowired
|
private ParamService paramService;
|
@Autowired
|
private TaskService taskService;
|
@Autowired
|
private InternalEmailService internalEmailService;
|
@Autowired
|
private NcProgramApprovedService ncProgramApprovedService;
|
@Autowired
|
private InternalEmailProperties internalEmailProperties;
|
//@Value("${mail-remind.sender-account:xxx}")
|
//private String senderAccount;
|
|
@Scheduled(cron = "${task.cron.innernal_email_notify:0 0 9 * * ?}")
|
public void execute() {
|
String notifyFlag = paramService.getParamValue(ParamConstants.EMAIL_NOTIFY_FLAG,ParamConstants.EMAIL_NOTIFY_FLAG_OFF);
|
|
if("1".equals(notifyFlag)){
|
//状态为开启，执行邮件通知
|
queryAllUserTodo();
|
}
|
|
}
|
|
void queryAllUserTodo(){
|
List<MdmUser> allUsers = mdmUserService.list();
|
|
for(MdmUser user : allUsers){
|
queryAndSendNotify(user);
|
}
|
}
|
|
/**
|
* 查询用户todo并发送通知邮件
|
* @param user
|
*/
|
private void queryAndSendNotify(MdmUser user) {
|
long flowTodoCount = queryFlowTodo(user.getId());
|
long expTodoCount = queryExportTodo(user.getId());
|
if(flowTodoCount + expTodoCount > 0){
|
sendRemindEmail(flowTodoCount,expTodoCount,user.getAccount());
|
}
|
|
}
|
|
/**
|
* 发送提醒邮件
|
* @param flowTodoCount
|
* @param expTodoCount
|
* @param userAccount
|
*/
|
void sendRemindEmail(long flowTodoCount,long expTodoCount,String userAccount){
|
String content = buildMailConent(flowTodoCount,expTodoCount);
|
internalEmailService.send(this.internalEmailProperties.getSenderAccount(),userAccount,null,null,"MDM程序管理任务提醒",content,null);
|
}
|
String buildMailConent(long flowTodoCount,long expTodoCount){
|
String content= String.format("您共有%s条任务待处理",(flowTodoCount+expTodoCount));
|
if(flowTodoCount>0){
|
content += "，"+flowTodoCount+"条为待审批流程";
|
}
|
if(flowTodoCount>0){
|
content += "，"+expTodoCount+"条为待导出工控网程序";
|
}
|
|
return content+"。";
|
}
|
|
private long queryFlowTodo(long userId){
|
String userIdStr = "" + userId;
|
|
TaskQuery todoQuery = taskService.createTaskQuery().taskAssignee(userIdStr).active().includeProcessVariables();
|
|
return todoQuery.count();
|
}
|
|
private long queryExportTodo(long userId){
|
|
NcProgramExportDncQueryVO query = new NcProgramExportDncQueryVO();
|
query.setCurrent(1);
|
query.setSize(1);
|
|
List<String> userRoleAliasList = Func.toStrList(",", AuthUtil.getUserRole());//角色别名，多个角色逗号分隔
|
String managerRole = paramService.getProgramManagerRoleAlias();
|
if(!userRoleAliasList.contains(managerRole) && !AuthUtil.isAdministrator() && !AuthUtil.isAdmin()){
|
//非数控管理员角色、管理员，限制未只能导出自己的程序
|
query.setUserId(userId);
|
}
|
|
IPage<NcProgramExportDncPageVO> pages = ncProgramApprovedService.exportDncPageQuery(query);
|
return pages.getTotal();
|
|
}
|
}
|
