guoyuepeng
/
qa-prevention-gwj
1
0
Fork 3
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

八项作业消息通知

limingyu-20240328-0328测试内容
limingyu 2024-02-05 11:44:40 +08:00
parent 7d8727867d
commit e127913c6a
7 changed files with 1383 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

156
src/main/java/com/zcloud/controller/gf/AppGFBlindBoardController.java
View File

@ -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

217
src/main/java/com/zcloud/controller/gf/AppGFBreakGroundController.java
View File

@ -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("动火审批", "发送站内信失败！");
}
}
}

173
src/main/java/com/zcloud/controller/gf/AppGFConfinedSpaceController.java
View File

@ -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;
}

214
src/main/java/com/zcloud/controller/gf/AppGFCutRoadController.java
View File

@ -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;
}

197
src/main/java/com/zcloud/controller/gf/AppGFElectricityController.java
View File

@ -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;
}

215
src/main/java/com/zcloud/controller/gf/AppGFHighWorkController.java
View File

@ -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;
}

215
src/main/java/com/zcloud/controller/gf/AppGFHoistingController.java
View File

@ -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;
}