清单排查、隐患流程对接代码

pull/14/head
songwenxuan 2023-12-21 08:28:37 +08:00
parent 3b1afc8344
commit 336916d4b9
16 changed files with 116 additions and 55 deletions

View File

@ -74,6 +74,7 @@ public class CheckRecordController extends BaseController {
private HiddenMailService hiddenMailService;
@Autowired
private MessageService messageService;
/**
*
*

View File

@ -2833,6 +2833,7 @@ public class HiddenController extends BaseController {
@RequestMapping(value = "/assign")
@RequiresPermissions("hidden:add")
@ResponseBody
@DockAnnotation
public Object assign() throws Exception {
Map<String, Object> map = new HashMap<String, Object>();
String errInfo = "success";
@ -2873,6 +2874,7 @@ public class HiddenController extends BaseController {
*/
@RequestMapping(value = "/finalcheck")
@ResponseBody
@DockAnnotation
public Object finalcheck() throws Exception {
// 获取IP
HttpServletRequest request = this.getRequest();

View File

@ -1,5 +1,6 @@
package com.zcloud.controller.bus;
import com.zcloud.aspect.DockAnnotation;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
@ -288,6 +289,7 @@ public class HiddenExamineController extends BaseController {
@RequestMapping(value = "/delayedExamine")
@RequiresPermissions("hidden:edit")
@ResponseBody
@DockAnnotation()
public Object delayedExamine() throws Exception {
Map<String, Object> map = new HashMap<String, Object>();
String errInfo = "success";
@ -417,6 +419,7 @@ public class HiddenExamineController extends BaseController {
@RequestMapping(value = "/specialExamine")
@RequiresPermissions("hidden:edit")
@ResponseBody
@DockAnnotation
public Object specialExamine(@RequestParam(value = "FFILE", required = false) MultipartFile file) throws Exception {
Map<String, Object> map = new HashMap<String, Object>();
String errInfo = "success";

View File

@ -577,6 +577,7 @@ public class HiddenApiController extends BaseController {
@RequestMapping(value = "/unableRectify")
@RequiresPermissions("hidden:list")
@ResponseBody
@DockAnnotation(isAdd = true)
public Object unableRectify() throws Exception {
Map<String, Object> map = new HashMap<String, Object>();
Integer code = 000000;
@ -609,7 +610,7 @@ public class HiddenApiController extends BaseController {
examine.put("OPERATOR", Jurisdiction.getUSER_ID());
examine.put("OPERATTIME", DateUtil.date2Str(new Date()));
examine = hiddenExamineApiService.save(examine);
pd.put("examine",JSON.toJSONString(examine));
messageService.sendMessageByParameter("HIDDEN_MAIL_005", "友情提示:有一条隐患需要特殊审核",
hidden.getString("CORPINFO_ID"), hidden.getString("CONFIRM_USER"), hidden.getString("HIDDEN_ID"),
hidden.getString("HIDDENDESCR"), "特殊处置审核", "审核", "", "");
@ -633,8 +634,7 @@ public class HiddenApiController extends BaseController {
inspection.put("HIDDEN_vector", pd.getString("HIDDEN_ID"));
noticeUtil.SE_ThreeStepUtil(inspection);
}
map.put("dockData",JSON.toJSONString(pd));
return ResultCodeConstant.resMap(code, map);
}
@ -647,6 +647,7 @@ public class HiddenApiController extends BaseController {
@RequestMapping(value = "/delayed")
@RequiresPermissions("hidden:list")
@ResponseBody
@DockAnnotation(isAdd = true)
public Object delayed() throws Exception {
Map<String, Object> map = new HashMap<String, Object>();
String errInfo = "success";
@ -685,11 +686,12 @@ public class HiddenApiController extends BaseController {
examine.put("DISPOSAL_FILE", Const.FILEPATHYHTP + Jurisdiction.getCORPINFO_ID() + "/" + ffile + "/" + fileName);
}
examine = hiddenExamineApiService.save(examine);
pd.put("examine",JSON.toJSONString(examine));
messageService.sendMessageByParameter("HIDDEN_MAIL_007", "友情提示:有一条隐患需要延期审核",
hidden.getString("CORPINFO_ID"), pd.getString("USER_ID"), hidden.getString("HIDDEN_ID"),
hidden.getString("HIDDENDESCR"), "延期审核", "审核", "", "");
map.put("msg", "隐患延期申成功。请通知隐患确认人进行延期确认操作!");
map.put("dockData",JSON.toJSONString(pd));
return ResultCodeConstant.resMap(code, map);
}
@ -702,6 +704,7 @@ public class HiddenApiController extends BaseController {
*/
@RequestMapping(value = "/check")
@ResponseBody
@DockAnnotation(isAdd = true)
public Object check() throws Exception {
Map<String, Object> map = new HashMap<String, Object>();
Integer code = 000000;
@ -728,16 +731,21 @@ public class HiddenApiController extends BaseController {
if (hiddenCheckList.size() == 0) {
return ResultCodeConstant.resMap(000220, map);
}
Map<String, String> hiddenCheckMap = new HashMap<>();
int count = 1;
for (PageData pageData : hiddenCheckList) {
if ("1".equals(pageData.getString("STATUS"))) {
checkCount++; //以前验收的++
}
if (Jurisdiction.getUSER_ID().equals(pageData.getString("USER_ID"))) {
check = pageData;
hiddenCheckApiService.checkHidden(pd.getString("HIDDEN_ID"), pageData.getString("HIDDENCHECK_ID"), pd.getString("CHECKDESCR"), pd.getString("CHECK_TIME"), Jurisdiction.getDEPARTMENT_ID(), Jurisdiction.getUSER_ID());
PageData exampd = hiddenCheckApiService.checkHidden(pd.getString("HIDDEN_ID"), pageData.getString("HIDDENCHECK_ID"), pd.getString("CHECKDESCR"), pd.getString("CHECK_TIME"), Jurisdiction.getDEPARTMENT_ID(), Jurisdiction.getUSER_ID());
hiddenCheckMap.put("exampd"+count, JSON.toJSONString(exampd));
count++;
checkCount++; //本次的++
}
}
pd.put("hiddenCheckMap", JSON.toJSONString(hiddenCheckMap));
if (hiddenCheckList.size() != 0) {
if (checkCount != hiddenCheckList.size()) { //还有没有验收的人
return ResultCodeConstant.resMap(000203, map);
@ -783,13 +791,15 @@ public class HiddenApiController extends BaseController {
/** 验收打回 **/
hiddenApiService.repulseCheck(pd.getString("HIDDEN_ID"));
/** 记录打回 **/
hiddenExamineApiService.saveRepulseCheck(pd.getString("HIDDEN_ID"), pd.getString("CONTENT"));
PageData exam = hiddenExamineApiService.saveRepulseCheck(pd.getString("HIDDEN_ID"), pd.getString("CONTENT"));
pd.put("exam",JSON.toJSONString(exam));
/** 给隐患整改人发送站内信**/
messageService.sendMessageByParameter("HIDDEN_MAIL_002", "友情提示:有一条隐患被打回",
hidden.getString("CORPINFO_ID"), pd.getString("USER_ID"), hidden.getString("HIDDEN_ID"),
hidden.getString("HIDDENDESCR"), "整改", "重新整改", "", "");
}
map.put("check", check);
map.put("dockData",JSON.toJSONString(pd));
return ResultCodeConstant.resMap(code, map);
}

View File

@ -1,13 +1,12 @@
package com.zcloud.controller.inspection;
import com.alibaba.fastjson.JSON;
import com.zcloud.aspect.DockAnnotation;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.entity.hotWorkApplication.Color;
import com.zcloud.entity.hotWorkApplication.Node;
import com.zcloud.entity.hotWorkApplication.Overseer;
import com.zcloud.entity.system.Department;
import com.zcloud.entity.system.User;
import com.zcloud.service.bus.HiddenCheckService;
import com.zcloud.service.bus.HiddenService;
import com.zcloud.service.bus.NoticeCorpService;
@ -21,8 +20,6 @@ import com.zcloud.service.system.UsersService;
import com.zcloud.util.*;
import org.apache.commons.lang.StringUtils;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.apache.shiro.session.Session;
import org.apache.xmlgraphics.xmp.schemas.pdf.PDFAAdapter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
@ -33,7 +30,6 @@ import org.springframework.web.servlet.ModelAndView;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.util.*;
import java.util.stream.Collectors;
/**
*
@ -276,6 +272,7 @@ public class SafetyEnvironmentalController extends BaseController {
@RequestMapping(value = "/add")
@RequiresPermissions("safetyenvironmental:add")
@ResponseBody
@DockAnnotation(isAdd = true)
public Object add() throws Exception {
Map<String, Object> map = new HashMap<String, Object>();
String errInfo = "success";
@ -307,6 +304,7 @@ public class SafetyEnvironmentalController extends BaseController {
List<PageData> hiddenList = safetyenvironmentalService.save(pd);
pd.put("hiddenList", hiddenList);
map.put("pd", pd);
map.put("dockData", JSON.toJSONString(pd));
map.put("result", errInfo);
return map;
}
@ -460,6 +458,7 @@ public class SafetyEnvironmentalController extends BaseController {
@RequestMapping(value = "/hide")
@RequiresPermissions("safetyenvironmental:del")
@ResponseBody
@DockAnnotation
public Object hide() throws Exception {
Map<String, String> map = new HashMap<String, String>();
String errInfo = "success";

View File

@ -1,5 +1,7 @@
package com.zcloud.controller.inspection;
import com.alibaba.fastjson.JSON;
import com.zcloud.aspect.DockAnnotation;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
@ -98,6 +100,7 @@ public class SafetyEnvironmentalExplainController extends BaseController {
@RequestMapping(value="/add")
@RequiresPermissions("safetyenvironmentalexplain:add")
@ResponseBody
@DockAnnotation(isAdd = true)
public Object add(@RequestParam(value="file",required=false) MultipartFile file) throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
@ -143,11 +146,13 @@ public class SafetyEnvironmentalExplainController extends BaseController {
pd.put("INSPECTED_EXPLAIN_FILENAME", file.getOriginalFilename());
pd.put("INSPECTED_EXPLAIN_FILEPATH", Const.FILEPATHFILE + Jurisdiction.getCORPINFO_ID() + "/" + ffile + "/" + fileName);
}
safetyenvironmentalexplainService.save(pd);
PageData logData = safetyenvironmentalexplainService.save(pd);
pd.put("logData",JSON.toJSONString(logData));
noticeCorpUtil.SE_PleadingStepUtil(pd);
map.put("pd", pd);
map.put("result", errInfo);
map.put("dockData", JSON.toJSONString(pd));
return map;
}

View File

@ -1,5 +1,7 @@
package com.zcloud.controller.inspection;
import com.alibaba.fastjson.JSON;
import com.zcloud.aspect.DockAnnotation;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
@ -82,6 +84,7 @@ public class SafetyEnvironmentalInspectorController extends BaseController {
@RequestMapping(value="/verify")
@RequiresPermissions("safetyenvironmentalinspector:add")
@ResponseBody
@DockAnnotation(isAdd = true)
public Object verify() throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
@ -110,9 +113,12 @@ public class SafetyEnvironmentalInspectorController extends BaseController {
uBean.put("INSPECTION_USER_SIGN_IMG", Const.FILEPATHFILE + pd.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName);
}
safetyenvironmentalinspectorService.verify(uBean);
pd.put("uBean",JSON.toJSONString(uBean));
PageData verify = safetyenvironmentalinspectorService.verify(uBean);
pd.put("verify",JSON.toJSONString(verify));
map.put("pd", pd);
map.put("result", errInfo);
map.put("dockData", JSON.toJSONString(pd));
return map;
}

View File

@ -77,18 +77,19 @@ public interface HiddenCheckApiService {
public List<PageData> findByHidden(String hiddenId)throws Exception;
/**
* id id
* @param HIDDEN_ID
* @param HIDDENCHECK_ID id
* @param CHECKDESCR
* @param CHECK_TIME
* @param DEPARTMENT_ID
* @param USER_ID
* @return
* @throws Exception
*/
public int checkHidden(String HIDDEN_ID,String HIDDENCHECK_ID,String CHECKDESCR,
String CHECK_TIME,String DEPARTMENT_ID, String USER_ID)throws Exception;
* id id
*
* @param HIDDEN_ID
* @param HIDDENCHECK_ID id
* @param CHECKDESCR
* @param CHECK_TIME
* @param DEPARTMENT_ID
* @param USER_ID
* @return
* @throws Exception
*/
public PageData checkHidden(String HIDDEN_ID, String HIDDENCHECK_ID, String CHECKDESCR,
String CHECK_TIME, String DEPARTMENT_ID, String USER_ID)throws Exception;
/**
* @param hiddenId

View File

@ -118,12 +118,13 @@ public interface HiddenExamineApiService {
public PageData saveConfirm(PageData pd,String hiddenExamineType)throws Exception;
/**
*
* @param hiddenId
* @param EXAMINE
* @throws Exception
*/
public int saveRepulseCheck(String hiddenId ,String EXAMINE)throws Exception;
*
*
* @param hiddenId
* @param EXAMINE
* @throws Exception
*/
public PageData saveRepulseCheck(String hiddenId , String EXAMINE)throws Exception;
/**
* ,

View File

@ -169,8 +169,8 @@ public class HiddenCheckApiServiceImpl implements HiddenCheckApiService {
* @param pd
* @throws Exception
*/
public int checkHidden(String HIDDEN_ID, String HIDDENCHECK_ID,String CHECKDESCR, String CHECK_TIME,
String DEPARTMENT_ID, String USER_ID) throws Exception {
public PageData checkHidden(String HIDDEN_ID, String HIDDENCHECK_ID, String CHECKDESCR, String CHECK_TIME,
String DEPARTMENT_ID, String USER_ID) throws Exception {
PageData pd = new PageData();
pd.put("HIDDENCHECK_ID",HIDDENCHECK_ID);
pd.put("HIDDEN_ID",HIDDEN_ID); //隐患ID
@ -192,7 +192,9 @@ public class HiddenCheckApiServiceImpl implements HiddenCheckApiService {
examPd.put("spare2",CHECK_TIME);
examPd.put("TYPE","8");
hiddenExamineApiMapper.save(examPd);
return hiddenCheckApiMapper.checkHidden(pd);
int result = hiddenCheckApiMapper.checkHidden(pd);
examPd.put("result",result);
return examPd;
}
/**
* @param hiddenId

View File

@ -195,11 +195,12 @@ public class HiddenExamineApiServiceImpl implements HiddenExamineApiService {
}
/**
*
*
* @param hiddenId
* @param EXAMINE
* @throws Exception
*/
public int saveRepulseCheck(String hiddenId ,String EXAMINE)throws Exception{
public PageData saveRepulseCheck(String hiddenId , String EXAMINE)throws Exception{
PageData exam = new PageData();// 添加隐患初始信息
exam.put("HIDDENEXAMINE_ID",UuidUtil.get32UUID());
exam.put("CREATOR",Jurisdiction.getUSER_ID());
@ -210,7 +211,9 @@ public class HiddenExamineApiServiceImpl implements HiddenExamineApiService {
exam.put("STATE",-1);//验收打回变成初始状态-1
exam.put("EXAMINE",EXAMINE);//打回意见
exam.put("HIDDEN_ID",hiddenId);//隐患ID
return hiddenExamineApiMapper.save(exam);
int saveInt = hiddenExamineApiMapper.save(exam);
exam.put("saveInt",saveInt);
return exam;
}
public PageData saveRectify(String hiddenId )throws Exception{

View File

@ -13,11 +13,14 @@ import java.util.List;
*/
public interface SafetyEnvironmentalExplainService{
/**
* @param pd
* @throws Exception
*/
public void save(PageData pd)throws Exception;
/**
*
*
* @param pd
* @return
* @throws Exception
*/
public PageData save(PageData pd)throws Exception;
/**
* @param pd

View File

@ -68,10 +68,12 @@ public interface SafetyEnvironmentalInspectorService{
List<PageData> findByIds(PageData pd)throws Exception;
/**
*
* @param pd
*/
void verify(PageData pd)throws Exception;
*
*
* @param pd
* @return
*/
PageData verify(PageData pd)throws Exception;
/**ID
* @param pd

View File

@ -7,7 +7,6 @@ import com.zcloud.service.bus.HiddenService;
import com.zcloud.service.inspection.SafetyEnvironmentalExplainService;
import com.zcloud.service.inspection.SafetyEnvironmentalLogService;
import com.zcloud.service.inspection.SafetyEnvironmentalService;
import com.zcloud.util.Jurisdiction;
import com.zcloud.util.Tools;
import com.zcloud.util.UuidUtil;
import org.springframework.beans.factory.annotation.Autowired;
@ -37,12 +36,15 @@ public class SafetyEnvironmentalExplainServiceImpl implements SafetyEnvironmenta
@Autowired
private SafetyEnvironmentalLogService safetyenvironmentallogService;
/**
* @param pd
* @throws Exception
*/
/**
*
*
* @param pd
* @return
* @throws Exception
*/
@Transactional
public void save(PageData pd)throws Exception{
public PageData save(PageData pd)throws Exception{
PageData inspection = safetyEnvironmentalService.findById(pd);
inspection.put("INSPECTED_EXPLAIN", pd.getString("INSPECTED_EXPLAIN"));
if (Tools.notEmpty(pd.getString("INSPECTED_EXPLAIN_FILENAME"))) {
@ -81,6 +83,7 @@ public class SafetyEnvironmentalExplainServiceImpl implements SafetyEnvironmenta
safetyenvironmentallogService.save(log);
safetyenvironmentalexplainMapper.save(pd);
return log;
}
/**

View File

@ -1,5 +1,6 @@
package com.zcloud.service.inspection.impl;
import com.alibaba.fastjson.JSON;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.inspection.SafetyEnvironmentalInspectorMapper;
@ -35,7 +36,8 @@ public class SafetyEnvironmentalInspectorServiceImpl implements SafetyEnvironmen
private NoticeCorpUtil util;
@Override
public void verify(PageData pd) throws Exception {
public PageData verify(PageData pd) throws Exception {
PageData pageData = new PageData();
if ("1".equals(pd.getString("INSPECTION_STATUS"))) { //检查进度状态 1.部分检查人员已核实
List<PageData> list = safetyenvironmentalinspectorMapper.listOtherNotVerify(pd);
if (list.size() == 0) {
@ -56,8 +58,10 @@ public class SafetyEnvironmentalInspectorServiceImpl implements SafetyEnvironmen
log.put("ACTION", "安全环保检查申请"); //操作内容
log.put("CREATTIME", pd.getString("OPERATTIME")); //添加时间
log.put("CREATOR", pd.getString("ACTION_USER")); //添加人姓名
pageData.put("log", JSON.toJSONString(log));
safetyenvironmentallogService.save(log);
safetyenvironmentalinspectorMapper.edit(pd);
return pageData;
}
/**

View File

@ -19,6 +19,7 @@ import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.stream.Collectors;
@ -70,6 +71,8 @@ public class SafetyEnvironmentalServiceImpl implements SafetyEnvironmentalServic
if (Tools.notEmpty(pd.getString("SITUATIONJSON"))) {
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.getString("SITUATIONJSON"));
String time = currentTime;
HashMap<String, String> situationMap = new HashMap<>();
int count = 1;
for (JSONObject json : list) {
PageData situationPd = new PageData();
situationPd.put("INSPECTION_SITUATION_ID", UuidUtil.get32UUID()); //主键
@ -81,13 +84,18 @@ public class SafetyEnvironmentalServiceImpl implements SafetyEnvironmentalServic
situationPd.put("OPERATOR", pd.getString("OPERATOR")); //修改人
situationPd.put("OPERATTIME", time); //修改时间
situationPd.put("CORPINFO_ID", pd.getString("CORPINFO_ID")); //企业ID
situationMap.put("situationPd"+count,JSON.toJSONString(situationPd));
count++;
safetyenvironmentalsituationService.save(situationPd);
time = DateUtil.calculateDateSecond(time, 1);
}
pd.put("situationMap",situationMap);
}
if (Tools.notEmpty(pd.getString("INSPECTORJSON"))) {
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.getString("INSPECTORJSON"));
String time = currentTime;
HashMap<String, String> inspectorMap = new HashMap<>();
int count = 1;
for (int i = 0; i < list.size(); i++) {
JSONObject json = list.get(i);
if (i == 0) {
@ -103,6 +111,8 @@ public class SafetyEnvironmentalServiceImpl implements SafetyEnvironmentalServic
inspector.put("OPERATOR", pd.getString("OPERATOR")); //修改人
inspector.put("OPERATTIME", time); //修改时间
inspector.put("CORPINFO_ID", pd.getString("CORPINFO_ID")); //企业ID
inspectorMap.put("inspector"+count,JSON.toJSONString(inspector));
count++;
boolean note_flag = true;
if(StringUtils.isNotBlank(pd.getString("OPERATOR"))){
if (pd.getString("OPERATOR").equals(json.get("INSPECTION_USER_ID"))){
@ -122,10 +132,13 @@ public class SafetyEnvironmentalServiceImpl implements SafetyEnvironmentalServic
if (note_flag) noticeCorpUtil.SE_OneStepUtil(inspector);
time = DateUtil.calculateDateSecond(time, 1);
}
pd.put("inspectorMap",JSON.toJSONString(inspectorMap));
}
if (Tools.notEmpty(pd.getString("HIDDENJSON"))) {
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.getString("HIDDENJSON"));
String time = currentTime;
HashMap<String, String> hiddenMap = new HashMap<>();
int count = 1;
for (JSONObject json : list) {
PageData hidden = new PageData();
hidden.put("HIDDEN_ID", UuidUtil.get32UUID()); //主键
@ -147,7 +160,7 @@ public class SafetyEnvironmentalServiceImpl implements SafetyEnvironmentalServic
hidden.put("CORPINFO_ID", pd.getString("CORPINFO_ID"));
hidden.put("ISDELETE", "0"); //是否删除(0:有效 1删除)
hidden.put("POSITIONDESC",json.getString("POSITIONDESC"));
hiddenMap.put("hidden"+count,JSON.toJSONString(hidden));
PageData before = new PageData();// 添加隐患初始信息
before.put("TYPE","0");
before.put("STATE","2");
@ -164,10 +177,13 @@ public class SafetyEnvironmentalServiceImpl implements SafetyEnvironmentalServic
findUser.put("USER_ID",json.getString("CREATOR"));
findUser.put("TYPE","1");
findUser.put("IS_MAIN","0");
hiddenMap.put("findUser"+count,JSON.toJSONString(findUser));
count++;
hiddenUserService.save(findUser);
hiddenList.add(hidden);
time = DateUtil.calculateDateSecond(time, 1);
}
pd.put("hiddenMap",JSON.toJSONString(hiddenMap));
}
PageData log = new PageData();
@ -176,8 +192,8 @@ public class SafetyEnvironmentalServiceImpl implements SafetyEnvironmentalServic
log.put("ACTION", "安全环保检查申请"); //操作内容
log.put("CREATTIME", pd.getString("CREATTIME")); //添加时间
log.put("CREATOR", pd.getString("ACTION_USER")); //添加人姓名
pd.put("log",JSON.toJSONString(log));
safetyenvironmentallogService.save(log);
safetyenvironmentalMapper.save(pd);
return hiddenList;
}