diff --git a/src/main/java/com/zcloud/controller/gf/AppGFBlindBoardController.java b/src/main/java/com/zcloud/controller/gf/AppGFBlindBoardController.java index 095bc093..3046d6f5 100644 --- a/src/main/java/com/zcloud/controller/gf/AppGFBlindBoardController.java +++ b/src/main/java/com/zcloud/controller/gf/AppGFBlindBoardController.java @@ -5,9 +5,9 @@ import com.alibaba.fastjson.JSONObject; import com.zcloud.controller.base.BaseController; import com.zcloud.entity.Page; import com.zcloud.entity.PageData; +import com.zcloud.service.bus.NoticeCorpService; import com.zcloud.service.gf.*; import com.zcloud.util.*; -import org.apache.commons.io.FileUtils; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; @@ -48,6 +48,8 @@ public class AppGFBlindBoardController extends BaseController { private GFBlindBoardToMeasuresService GFblindBoardToMeasuresService; @Autowired private Smb smb; + @Autowired + private NoticeCorpService noticeCorpService; /**获取编码 * @param * @throws Exception @@ -189,11 +191,161 @@ public class AppGFBlindBoardController extends BaseController { paramsList.add(params4); sendMessageUtil.sendMessages(mes, paramsList); } - + this.sendNotice(pd); map.put("result", errInfo); return map; } + /** + * 发送通知公告 + * @param pageData + */ + public void sendNotice(PageData pageData) { + try{ + PageData blindBoard = GFblindboardService.findById(pageData); + String blindBoardState = blindBoard.getString("APPLY_STATUS"); //状态 + if(blindBoard != null){ + if(blindBoardState.equals("1")){ //作业负责人待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条盲板抽堵作业待确认"); // 站内信标题 + mes.put("CORPINFO_ID", blindBoard.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", blindBoard.get("CONSTRUCTION_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", blindBoard.getString("CHECK_NO"));// 作业编号 + content.put("params1", "盲板抽堵申请作业"); // 作业名称 + content.put("params2", "作业负责人待审核"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //盲板抽堵监护人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条盲板抽堵作业待进行签字"); // 站内信标题 + mes.put("CORPINFO_ID", blindBoard.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", blindBoard.get("GUARDIAN_USER_ID")); // 接收人员ID + content.put("number", blindBoard.getString("CHECK_NO"));// 作业编号 + content.put("params1", "盲板抽堵申请作业"); // 作业名称 + content.put("params2", "监护人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //盲板抽堵安全交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条盲板抽堵作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", blindBoard.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", blindBoard.get("CONFESS_USER_ID")); // 接收人员ID + content.put("number", blindBoard.getString("CHECK_NO"));// 作业编号 + content.put("params1", "盲板抽堵申请作业"); // 作业名称 + content.put("params2", "安全交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //盲板抽堵接收交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条盲板抽堵作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", blindBoard.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", blindBoard.get("ACCEPT_CONFESS_USER_ID")); // 接收人员ID + content.put("number", blindBoard.getString("CHECK_NO"));// 作业编号 + content.put("params1", "盲板抽堵申请作业"); // 作业名称 + content.put("params2", "接受交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(blindBoardState.equals("4")){ //所在单位领导人待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条盲板抽堵作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", blindBoard.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", blindBoard.get("LEADER_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", blindBoard.getString("CHECK_NO"));// 作业编号 + content.put("params1", "盲板抽堵申请作业"); // 作业名称 + content.put("params2", "所在单位意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(blindBoardState.equals("5")){ //待验收 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条盲板抽堵作业待验收"); // 站内信标题 + mes.put("CORPINFO_ID", blindBoard.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", blindBoard.get("ACCEPT_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", blindBoard.getString("CHECK_NO"));// 作业编号 + content.put("params1", "盲板抽堵申请作业"); // 作业名称 + content.put("params2", "作业待验收"); + content.put("params3", "验收");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + } + + if(blindBoardState.equals("-2")){ //作业负责人审核打回发站内信 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条盲板抽堵作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", blindBoard.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", blindBoard.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", blindBoard.getString("CHECK_NO"));// 作业编号 + content.put("params1", "盲板抽堵申请作业"); // 作业名称 + content.put("params2", "盲板抽堵申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(blindBoardState.equals("-5")){ //所在单位审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条盲板抽堵作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", blindBoard.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", blindBoard.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", blindBoard.getString("CHECK_NO"));// 作业编号 + content.put("params1", "盲板抽堵申请作业"); // 作业名称 + content.put("params2", "盲板抽堵申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if (blindBoardState.equals("-6")) { + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条盲板抽堵作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", blindBoard.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", blindBoard.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", blindBoard.getString("CHECK_NO"));// 作业编号 + content.put("params1", "盲板抽堵申请作业"); // 作业名称 + content.put("params2", "盲板抽堵申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + }catch (Exception e){ +// FHLOG.save("动火审批", "发送站内信失败!"); + + } + + + } + /**上传图 * @param * @throws Exception diff --git a/src/main/java/com/zcloud/controller/gf/AppGFBreakGroundController.java b/src/main/java/com/zcloud/controller/gf/AppGFBreakGroundController.java index 533dff14..f5ed0b87 100644 --- a/src/main/java/com/zcloud/controller/gf/AppGFBreakGroundController.java +++ b/src/main/java/com/zcloud/controller/gf/AppGFBreakGroundController.java @@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject; import com.zcloud.controller.base.BaseController; import com.zcloud.entity.Page; import com.zcloud.entity.PageData; +import com.zcloud.service.bus.NoticeCorpService; import com.zcloud.service.gf.GFBreakGroundAcceptUserService; import com.zcloud.service.gf.GFBreakGroundLogService; import com.zcloud.service.gf.GFBreakGroundService; @@ -46,6 +47,8 @@ public class AppGFBreakGroundController extends BaseController { private SendMessageUtil sendMessageUtil; @Autowired private Smb smb; + @Autowired + private NoticeCorpService noticeCorpService; /**获取编码 * @param * @throws Exception @@ -155,7 +158,7 @@ public class AppGFBreakGroundController extends BaseController { paramsList.add(params4); sendMessageUtil.sendMessages(mes, paramsList); } - + this.sendNotice(pd); map.put("result", errInfo); return map; } @@ -500,6 +503,7 @@ public class AppGFBreakGroundController extends BaseController { break; } GFbreakGroundLogService.save(log); + this.sendNotice(pd); map.put("result", errInfo); return map; } @@ -761,6 +765,7 @@ public class AppGFBreakGroundController extends BaseController { break; } GFbreakGroundLogService.save(log); + this.sendNotice(pd); map.put("result", errInfo); return map; } @@ -1230,4 +1235,214 @@ public class AppGFBreakGroundController extends BaseController { return map; } + /** + * 发送通知公告 + * @param pageData + */ + public void sendNotice(PageData pageData) { + try{ + PageData breakGround = GFbreakGroundService.findById(pageData); + String breakGroundState = breakGround.getString("APPLY_STATUS"); //状态 + if(breakGround != null){ + if(breakGroundState.equals("1")){ //作业负责人待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业待确认"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.get("CONSTRUCTION_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "作业负责人待审核"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //动土监护人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业待进行签字"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.get("GUARDIAN_USER_ID")); // 接收人员ID + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "监护人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //动土安全交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.get("CONFESS_USER_ID")); // 接收人员ID + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "安全交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //动土接收交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.get("ACCEPT_CONFESS_USER_ID")); // 接收人员ID + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "接受交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(breakGroundState.equals("2")){ //所在单位待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.get("PRODUCTION_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "所在单位意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(breakGroundState.equals("3")){ //有关部门待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.get("SAFETY_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "有关部门待审核"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(breakGroundState.equals("4")){ //审批部门待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.get("LEADER_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "审批部门待审核"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(breakGroundState.equals("5")){ //待验收 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业待验收"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.get("ACCEPT_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "作业待验收"); + content.put("params3", "验收");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + } + + if(breakGroundState.equals("-2")){ //作业负责人审核打回发站内信 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "动土申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(breakGroundState.equals("-3")){ //所在单位审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "动土申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(breakGroundState.equals("-4")){ //有关部门审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "动土申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(breakGroundState.equals("-5")){ //审批部门审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "动土申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if (breakGroundState.equals("-6")) { //验收打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条动土作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", breakGround.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", breakGround.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", breakGround.getString("CHECK_NO"));// 作业编号 + content.put("params1", "动土申请作业"); // 作业名称 + content.put("params2", "动土申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + }catch (Exception e){ +// FHLOG.save("动火审批", "发送站内信失败!"); + + } + + + } + } diff --git a/src/main/java/com/zcloud/controller/gf/AppGFConfinedSpaceController.java b/src/main/java/com/zcloud/controller/gf/AppGFConfinedSpaceController.java index 76e94b66..d70ea087 100644 --- a/src/main/java/com/zcloud/controller/gf/AppGFConfinedSpaceController.java +++ b/src/main/java/com/zcloud/controller/gf/AppGFConfinedSpaceController.java @@ -7,6 +7,7 @@ import com.zcloud.dto.TenCorpConst; import com.zcloud.dto.TenCorpDto; import com.zcloud.entity.Page; import com.zcloud.entity.PageData; +import com.zcloud.service.bus.NoticeCorpService; import com.zcloud.service.gf.*; import com.zcloud.service.mq.SendMessageService; import com.zcloud.util.*; @@ -53,6 +54,8 @@ public class AppGFConfinedSpaceController extends BaseController { @Resource private SendMessageService mqClient; + @Autowired + private NoticeCorpService noticeCorpService; /**获取编码 * @param * @throws Exception @@ -174,10 +177,176 @@ public class AppGFConfinedSpaceController extends BaseController { tenCorpDto.setData(pd); tenCorpDto.setMark_name("CONFINEDSPACE_ID"); mqClient.SendDelayQueue(tenCorpDto); + this.sendNotice(pd); map.put("result", errInfo); return map; } + /** + * 发送通知公告 + * @param pageData + */ + public void sendNotice(PageData pageData) { + try{ + PageData confinedspace = GFconfinedspaceService.findById(pageData); + String confinedspaceState = confinedspace.getString("APPLY_STATUS"); //状态 + if(confinedspace != null){ + if(confinedspaceState.equals("1")){ //作业负责人待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条受限空间作业待确认"); // 站内信标题 + mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", confinedspace.get("CONFIRM_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号 + content.put("params1", "受限空间申请作业"); // 作业名称 + content.put("params2", "作业负责人确认"); + content.put("params3", "确认");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //受限空间气体分析发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条受限空间作业待进行气体分析"); // 站内信标题 + mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", confinedspace.get("ANALYZE_USER_ID")); // 接收人员ID + content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号 + content.put("params1", "受限空间申请作业"); // 作业名称 + content.put("params2", "气体分析"); + content.put("params3", "进行气体分析");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //受限空间安全交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条受限空间作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", confinedspace.get("CONFESS_USER_ID")); // 接收人员ID + content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号 + content.put("params1", "受限空间申请作业"); // 作业名称 + content.put("params2", "安全交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //受限空间接收交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条受限空间作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", confinedspace.get("ACCEPT_CONFESS_USER_ID")); // 接收人员ID + content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号 + content.put("params1", "受限空间申请作业"); // 作业名称 + content.put("params2", "接受交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(confinedspaceState.equals("4")){ //所在单位待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条受限空间作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", confinedspace.get("APPROVE_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号 + content.put("params1", "有限空间申请作业"); // 作业名称 + content.put("params2", "所在单位待审核"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(confinedspaceState.equals("5")){ //待验收 + if (confinedspace.get("GUARDIAN_USER_SIGNER_PATH") == null) { + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条有限空间作业待验收"); // 站内信标题 + mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", confinedspace.get("ACCEPT_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号 + content.put("params1", "有限空间申请作业"); // 作业名称 + content.put("params2", "作业待验收"); + content.put("params3", "验收");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //受限空间监护人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条受限空间作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", confinedspace.get("GUARDIAN_USER_ID")); // 接收人员ID + content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号 + content.put("params1", "受限空间申请作业"); // 作业名称 + content.put("params2", "监护人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + } + } + + if(confinedspaceState.equals("-4")){ //作业负责人审核打回发站内信 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条受限空间作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", confinedspace.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号 + content.put("params1", "受限空间申请作业"); // 作业名称 + content.put("params2", "受限空间申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(confinedspaceState.equals("-5")){ //所在单位审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条受限空间作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", confinedspace.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号 + content.put("params1", "受限空间申请作业"); // 作业名称 + content.put("params2", "受限空间申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if (confinedspaceState.equals("-6")) { + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条受限空间作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", confinedspace.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", confinedspace.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", confinedspace.getString("CHECK_NO"));// 作业编号 + content.put("params1", "受限空间申请作业"); // 作业名称 + content.put("params2", "受限空间申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + }catch (Exception e){ +// FHLOG.save("动火审批", "发送站内信失败!"); + + } + + + } + /**删除 * @param * @throws Exception @@ -463,6 +632,7 @@ public class AppGFConfinedSpaceController extends BaseController { // paramsList.add(params4); // sendMessageUtil.sendMessages(mes, paramsList); } + this.sendNotice(pd); map.put("result", errInfo); return map; } @@ -694,7 +864,7 @@ public class AppGFConfinedSpaceController extends BaseController { break; } GFconfinedspaceLogService.save(log); - + this.sendNotice(pd); map.put("result", errInfo); return map; } @@ -1229,6 +1399,7 @@ public class AppGFConfinedSpaceController extends BaseController { break; } GFconfinedspaceLogService.save(log); + this.sendNotice(pd); map.put("result", errInfo); return map; } diff --git a/src/main/java/com/zcloud/controller/gf/AppGFCutRoadController.java b/src/main/java/com/zcloud/controller/gf/AppGFCutRoadController.java index 9b3f375f..1122ab23 100644 --- a/src/main/java/com/zcloud/controller/gf/AppGFCutRoadController.java +++ b/src/main/java/com/zcloud/controller/gf/AppGFCutRoadController.java @@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject; import com.zcloud.controller.base.BaseController; import com.zcloud.entity.Page; import com.zcloud.entity.PageData; +import com.zcloud.service.bus.NoticeCorpService; import com.zcloud.service.gf.*; import com.zcloud.util.*; import org.apache.commons.lang.StringUtils; @@ -41,6 +42,8 @@ public class AppGFCutRoadController extends BaseController { private GFCutRoadAcceptUserService cutroadacceptuserService; @Autowired private SendMessageUtil sendMessageUtil; + @Autowired + private NoticeCorpService noticeCorpService; /**获取编码 * @param * @throws Exception @@ -154,6 +157,216 @@ public class AppGFCutRoadController extends BaseController { return map; } + /** + * 发送通知公告 + * @param pageData + */ + public void sendNotice(PageData pageData) { + try{ + PageData cutRoad = GFcutRoadService.findById(pageData); + String cutRoadState = cutRoad.getString("APPLY_STATUS"); //状态 + if(cutRoad != null){ + if(cutRoadState.equals("1")){ //作业负责人待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业待确认"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.get("CONSTRUCTION_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "作业负责人意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //断路安全监护人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.get("GUARDIAN_USER_ID")); // 接收人员ID + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "监护人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //断路安全安全交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.get("CONFESS_USER_ID")); // 接收人员ID + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "安全交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //断路安全接收交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.get("ACCEPT_CONFESS_USER_ID")); // 接收人员ID + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "接受交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(cutRoadState.equals("2")){ //所在单位待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.get("PRODUCTION_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "所在单位意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(cutRoadState.equals("3")){ //消防、安全管理部门待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.get("SAFETY_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "消防、安全管理部门意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(cutRoadState.equals("4")){ //审批部门待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.get("LEADER_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "审批部门意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(cutRoadState.equals("5")){ //待验收 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业待验收"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.get("ACCEPT_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "作业待验收"); + content.put("params3", "验收");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + } + + if(cutRoadState.equals("-2")){ //作业负责人审核打回发站内信 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "断路安全申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(cutRoadState.equals("-3")){ //所在单位审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "断路安全申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(cutRoadState.equals("-4")){ //消防、安全管理部门审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "断路安全申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(cutRoadState.equals("-5")){ //审批部门审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "断路安全申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if (cutRoadState.equals("-6")) {//验收打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条断路安全作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", cutRoad.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", cutRoad.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", cutRoad.getString("CHECK_NO"));// 作业编号 + content.put("params1", "断路安全申请作业"); // 作业名称 + content.put("params2", "断路安全申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + }catch (Exception e){ +// FHLOG.save("动火审批", "发送站内信失败!"); + + } + + + } + /**上传图 * @param * @throws Exception @@ -759,6 +972,7 @@ public class AppGFCutRoadController extends BaseController { break; } GFcutRoadLogService.save(log); + this.sendNotice(pd); map.put("result", errInfo); return map; } diff --git a/src/main/java/com/zcloud/controller/gf/AppGFElectricityController.java b/src/main/java/com/zcloud/controller/gf/AppGFElectricityController.java index fc56ce84..dc83b16e 100644 --- a/src/main/java/com/zcloud/controller/gf/AppGFElectricityController.java +++ b/src/main/java/com/zcloud/controller/gf/AppGFElectricityController.java @@ -7,6 +7,7 @@ import com.zcloud.dto.TenCorpConst; import com.zcloud.dto.TenCorpDto; import com.zcloud.entity.Page; import com.zcloud.entity.PageData; +import com.zcloud.service.bus.NoticeCorpService; import com.zcloud.service.gf.*; import com.zcloud.service.mq.SendMessageService; import com.zcloud.util.*; @@ -51,6 +52,8 @@ public class AppGFElectricityController extends BaseController { @Resource private SendMessageService mqClient; + @Autowired + private NoticeCorpService noticeCorpService; /**获取编码 * @param @@ -176,10 +179,203 @@ public class AppGFElectricityController extends BaseController { paramsList1.add(params6); sendMessageUtil.sendMessages(mes1, paramsList1); } + this.sendNotice(pd); map.put("result", errInfo); return map; } + /** + * 发送通知公告 + * @param pageData + */ + public void sendNotice(PageData pageData) { + try { + PageData electricity = GFelectricityService.findById(pageData); + String electricityState = electricity.getString("APPLY_STATUS"); //状态 + if (electricity != null) { + if (electricityState.equals("1")) { //作业负责人待审核 + PageData mes = new PageData(); + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业待确认"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.get("CONFIRM_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "作业负责人待审核"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //临时用电监护人发站内信 + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.get("GUARDIAN_USER_ID")); // 接收人员ID + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "监护人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //临时用电安全交底人发站内信 + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.get("CONFESS_USER_ID")); // 接收人员ID + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "安全交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //临时用电接收交底人发站内信 + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.get("ACCEPT_CONFESS_USER_ID")); // 接收人员ID + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "接受交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + if (StringUtils.equals(electricity.get("ISANALYZE").toString(), "1")) { + //临时用电气体检测发站内信 + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业待进行气体检测"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.get("ANALYZE_USER_ID")); // 接收人员ID + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "气体检测"); + content.put("params3", "检测");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + } else if (electricityState.equals("2")) { //用电单位待审核 + PageData mes = new PageData(); + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.get("AUDIT_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "用电单位意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if (electricityState.equals("3")) { //配送电单位待审核 + PageData mes = new PageData(); + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.get("APPROVE_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "配送电单位意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if (electricityState.equals("4")) { //待验收 + PageData mes = new PageData(); + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业待验收"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.get("ACCEPT_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "完工验收"); + content.put("params3", "验收");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + + if (electricityState.equals("-2")) { //作业负责人审核打回发站内信 + PageData mes = new PageData(); + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "临时用电申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if (electricityState.equals("-3")) { //用电单位审核打回 + PageData mes = new PageData(); + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "临时用电申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if (electricityState.equals("-4")) { //配送电单位审核打回 + PageData mes = new PageData(); + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "临时用电申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if (electricityState.equals("-5")) { //验收打回 + PageData mes = new PageData(); + mes.put("BIANMA", "PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条临时用电作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", electricity.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", electricity.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", electricity.getString("CHECK_NO"));// 作业编号 + content.put("params1", "临时用电申请作业"); // 作业名称 + content.put("params2", "临时用电申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + } + }catch(Exception e){ +// FHLOG.save("动火审批", "发送站内信失败!"); + } + } + /**删除 */ @RequestMapping(value="/delete") @@ -891,6 +1087,7 @@ public class AppGFElectricityController extends BaseController { break; } GFelectricityLogService.save(log); + this.sendNotice(pd); map.put("result", errInfo); return map; } diff --git a/src/main/java/com/zcloud/controller/gf/AppGFHighWorkController.java b/src/main/java/com/zcloud/controller/gf/AppGFHighWorkController.java index 0acf912e..1538eea4 100644 --- a/src/main/java/com/zcloud/controller/gf/AppGFHighWorkController.java +++ b/src/main/java/com/zcloud/controller/gf/AppGFHighWorkController.java @@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject; import com.zcloud.controller.base.BaseController; import com.zcloud.entity.Page; import com.zcloud.entity.PageData; +import com.zcloud.service.bus.NoticeCorpService; import com.zcloud.service.gf.*; import com.zcloud.util.*; import org.apache.commons.io.FileUtils; @@ -45,6 +46,8 @@ public class AppGFHighWorkController extends BaseController { private SendMessageUtil sendMessageUtil; @Autowired private Smb smb; + @Autowired + private NoticeCorpService noticeCorpService; /**获取编码 * @param * @throws Exception @@ -139,9 +142,220 @@ public class AppGFHighWorkController extends BaseController { sendMessageUtil.sendMessages(mes, paramsList); } map.put("result", errInfo); + this.sendNotice(pd); return map; } + /** + * 发送通知公告 + * @param pageData + */ + public void sendNotice(PageData pageData) { + try{ + PageData highwork = GFhighworkService.findById(pageData); + String highworkState = highwork.getString("APPLY_STATUS"); //状态 + if(highwork != null){ + if(highworkState.equals("1")){ //作业负责人待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业待确认"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.get("CONSTRUCTION_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "作业负责人待审核"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //高处监护人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.get("GUARDIAN_USER_ID")); // 接收人员ID + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "监护人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //高处安全交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.get("CONFESS_USER_ID")); // 接收人员ID + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "安全交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //高处接收交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.get("ACCEPT_CONFESS_USER_ID")); // 接收人员ID + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "接受交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(highworkState.equals("2")){ //所在单位领导人待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.get("LEADER_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "所在单位意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(highworkState.equals("3")){ //审核部门待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.get("AUDIT_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "审核部门意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(highworkState.equals("4")){ //审批部门待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.get("APPROVE_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "审批部门意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(highworkState.equals("5")){ //待验收 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业待验收"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.get("ACCEPT_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "作业待验收"); + content.put("params3", "验收");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + } + + if(highworkState.equals("-2")){ //作业负责人审核打回发站内信 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "高处申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(highworkState.equals("-3")){ //所在单位审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "高处申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(highworkState.equals("-4")){ //审核部门审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "高处申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(highworkState.equals("-5")){ //审批部门审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "高处申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if (highworkState.equals("-6")) {//验收打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条高处作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", highwork.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", highwork.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", highwork.getString("CHECK_NO"));// 作业编号 + content.put("params1", "高处申请作业"); // 作业名称 + content.put("params2", "高处申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + }catch (Exception e){ +// FHLOG.save("动火审批", "发送站内信失败!"); + + } + + + } + /**删除 * @param * @throws Exception @@ -1026,6 +1240,7 @@ public class AppGFHighWorkController extends BaseController { break; } GFhighWorkLogService.save(log); + this.sendNotice(pd); map.put("result", errInfo); return map; } diff --git a/src/main/java/com/zcloud/controller/gf/AppGFHoistingController.java b/src/main/java/com/zcloud/controller/gf/AppGFHoistingController.java index 32c52b33..8a2e7510 100644 --- a/src/main/java/com/zcloud/controller/gf/AppGFHoistingController.java +++ b/src/main/java/com/zcloud/controller/gf/AppGFHoistingController.java @@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject; import com.zcloud.controller.base.BaseController; import com.zcloud.entity.Page; import com.zcloud.entity.PageData; +import com.zcloud.service.bus.NoticeCorpService; import com.zcloud.service.gf.*; import com.zcloud.util.*; import org.apache.commons.lang.StringUtils; @@ -41,6 +42,8 @@ public class AppGFHoistingController extends BaseController { private GFHoistingToMeasuresService GFhighWorkToMeasuresService; @Autowired private SendMessageUtil sendMessageUtil; + @Autowired + private NoticeCorpService noticeCorpService; /**获取编码 * @param * @throws Exception @@ -134,10 +137,221 @@ public class AppGFHoistingController extends BaseController { paramsList.add(params4); sendMessageUtil.sendMessages(mes, paramsList); } + this.sendNotice(pd); map.put("result", errInfo); return map; } + /** + * 发送通知公告 + * @param pageData + */ + public void sendNotice(PageData pageData) { + try{ + PageData hoisting = GFhoistingService.findById(pageData); + String hoistingState = hoisting.getString("APPLY_STATUS"); //状态 + if(hoisting != null){ + if(hoistingState.equals("1")){ //作业指挥待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业待确认"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.get("LEADER_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "作业指挥待审核"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //吊装监护人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.get("GUARDIAN_USER_ID")); // 接收人员ID + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "监护人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //吊装安全交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.get("CONFESS_USER_ID")); // 接收人员ID + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "安全交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + //吊装接收交底人发站内信 + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业待签字"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.get("ACCEPT_CONFESS_USER_ID")); // 接收人员ID + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "接受交底人签字"); + content.put("params3", "签字");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(hoistingState.equals("2")){ //所在单位待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.get("CONSTRUCTION_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "所在单位意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(hoistingState.equals("3")){ //审核部门待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.get("AUDIT_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "审核部门意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(hoistingState.equals("4")){ //审批部门待审核 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业待审核"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.get("APPROVE_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "审批部门意见"); + content.put("params3", "审核");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(hoistingState.equals("5")){ //待验收 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业待验收"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.get("ACCEPT_USER_ID")); // 接收人员ID + PageData content = new PageData(); + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "作业待验收"); + content.put("params3", "验收");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + } + + if(hoistingState.equals("-2")){ //作业负责人审核打回发站内信 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "吊装申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(hoistingState.equals("-3")){ //所在单位审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "吊装申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(hoistingState.equals("-4")){ //审核部门审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "吊装申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if(hoistingState.equals("-5")){ //审批部门审核打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "吊装申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } else if (hoistingState.equals("-6")) {//验收打回 + PageData mes = new PageData(); + mes.put("BIANMA","PROCESS_WORK_001"); + mes.put("SENDER_ID", "系统管理员"); // 发送人员ID + mes.put("SENDER_NAME", "1"); // 发送人员姓名 + mes.put("SYNOPSIS", "友情提示:有一条吊装作业打回待处理"); // 站内信标题 + mes.put("CORPINFO_ID", hoisting.get("CORPINFO_ID"));// 企业id + mes.put("RECEIVER_ID", hoisting.getString("CREATOR")); // 接收人员ID + PageData content = new PageData(); + content.put("number", hoisting.getString("CHECK_NO"));// 作业编号 + content.put("params1", "吊装申请作业"); // 作业名称 + content.put("params2", "吊装申请管理"); + content.put("params3", "处理");// 作业操作 + mes.put("CONTENT", content);// 站内信内容 + noticeCorpService.sendNotice(mes); + } + }catch (Exception e){ +// FHLOG.save("动火审批", "发送站内信失败!"); + + } + + + } + /**删除 * @throws Exception */ @@ -968,6 +1182,7 @@ public class AppGFHoistingController extends BaseController { break; } GFhighWorkLogService.save(log); + this.sendNotice(pd); map.put("result", errInfo); return map; }