|
@@ -12,7 +12,9 @@ import com.ruoyi.project.invoice.service.ITApproveReserveInvoiceService;
|
|
|
import com.ruoyi.project.invoice.service.ITInvoiceBookingworkticketService;
|
|
|
import com.ruoyi.project.pssr.domain.TPssrApprove;
|
|
|
import com.ruoyi.project.pssr.service.ITPssrApproveService;
|
|
|
+import com.ruoyi.project.system.domain.SysMessage;
|
|
|
import com.ruoyi.project.system.domain.SysUser;
|
|
|
+import com.ruoyi.project.system.service.ISysMessageService;
|
|
|
import com.ruoyi.project.system.service.ISysUserService;
|
|
|
import org.activiti.engine.delegate.DelegateTask;
|
|
|
import org.activiti.engine.delegate.TaskListener;
|
|
@@ -31,6 +33,7 @@ public class ConfirmTaskCreateListener implements Serializable, TaskListener {
|
|
|
public void notify(DelegateTask delegateTask) {
|
|
|
String id = delegateTask.getExecution().getProcessInstanceBusinessKey();
|
|
|
ITPssrApproveService approveService = (ITPssrApproveService) SpringContextUtils.getBean("tPssrApproveService");
|
|
|
+ ISysMessageService sysMessageService = (ISysMessageService) SpringContextUtils.getBean("sysMessageService");
|
|
|
ISysUserService sysUserService = (ISysUserService) SpringContextUtils.getBean("sysUserService");
|
|
|
JiGuangPushService jiGuangPushService = (JiGuangPushService) SpringContextUtils.getBean("jiGuangPushService");
|
|
|
IMailService mailService = (IMailService) SpringContextUtils.getBean("mailService");
|
|
@@ -83,9 +86,23 @@ public class ConfirmTaskCreateListener implements Serializable, TaskListener {
|
|
|
String html = start + prime + end;
|
|
|
logger.info("html:" + html);
|
|
|
mailService.sendHtmlMail(email, "PSSR:您有一个新的待办任务 PSSR:You have a pending PSSR task (" + apNo + ")", html);
|
|
|
- jiGuangPushService.send("PSSR审批", "您有一个新的待办任务,请及时处理。", assignee);
|
|
|
+
|
|
|
} catch (Exception e) {
|
|
|
logger.error("邮件发送失败" + JSON.toJSONString(e));
|
|
|
}
|
|
|
+ try {
|
|
|
+ //极光推送
|
|
|
+ jiGuangPushService.send("PSSR审批", "您有一个新的待办任务,请及时处理。", assignee);
|
|
|
+
|
|
|
+ //系统消息推送
|
|
|
+ SysMessage sysMessage = new SysMessage();
|
|
|
+ sysMessage.setMsgTitle("PSSR审批");
|
|
|
+ sysMessage.setMsgContent("您有一个新的待办任务,请及时处理。");
|
|
|
+ sysMessage.setUserId(Long.parseLong(assignee));
|
|
|
+ sysMessageService.insertSysMessage(sysMessage);
|
|
|
+ } catch (Exception e) {
|
|
|
+ logger.error("推送失败:{}" , JSON.toJSONString(e));
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
}
|