692 lines
30 KiB
Java
692 lines
30 KiB
Java
|
package com.zcloud.service.inspection.impl;
|
|||
|
|
|
|||
|
|
import com.alibaba.fastjson.JSON;
|
|||
|
|
import com.alibaba.fastjson.JSONObject;
|
|||
|
|
import com.zcloud.entity.Page;
|
|||
|
|
import com.zcloud.entity.PageData;
|
|||
|
|
import com.zcloud.mapper.datasource.inspection.SafetyEnvironmentalMapper;
|
|||
|
|
import com.zcloud.service.bus.*;
|
|||
|
|
import com.zcloud.service.inspection.*;
|
|||
|
|
import com.zcloud.service.system.DepartmentService;
|
|||
|
|
import com.zcloud.util.DateUtil;
|
|||
|
|
import com.zcloud.util.Tools;
|
|||
|
|
import com.zcloud.util.UuidUtil;
|
|||
|
|
import org.apache.commons.lang.StringUtils;
|
|||
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|||
|
|
import org.springframework.stereotype.Service;
|
|||
|
|
import org.springframework.transaction.annotation.Transactional;
|
|||
|
|
|
|||
|
|
import javax.annotation.Resource;
|
|||
|
|
import java.util.ArrayList;
|
|||
|
|
import java.util.Date;
|
|||
|
|
import java.util.List;
|
|||
|
|
import java.util.stream.Collectors;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 说明：安全环保检查
|
|||
|
|
* 作者：luoxiaobao
|
|||
|
|
* 时间：2022-06-08
|
|||
|
|
* 官网：www.zcloudchina.com
|
|||
|
|
*/
|
|||
|
|
@Service
|
|||
|
|
@Transactional //开启事物
|
|||
|
|
public class SafetyEnvironmentalServiceImpl implements SafetyEnvironmentalService {
|
|||
|
|
|
|||
|
|
@Resource
|
|||
|
|
private SafetyEnvironmentalMapper safetyenvironmentalMapper;
|
|||
|
|
@Autowired
|
|||
|
|
private SafetyEnvironmentalInspectorService safetyenvironmentalinspectorService;
|
|||
|
|
@Autowired
|
|||
|
|
private SafetyEnvironmentalSituationService safetyenvironmentalsituationService;
|
|||
|
|
@Autowired
|
|||
|
|
private SafetyEnvironmentalExplainService safetyEnvironmentalExplainService;
|
|||
|
|
@Autowired
|
|||
|
|
private HiddenService hiddenService;
|
|||
|
|
@Autowired
|
|||
|
|
private HiddenUserService hiddenUserService; // 隐患相关人员信息
|
|||
|
|
@Autowired
|
|||
|
|
private ImgFilesService imgFilesService;
|
|||
|
|
@Autowired
|
|||
|
|
private SafetyEnvironmentalLogService safetyenvironmentallogService;
|
|||
|
|
@Autowired
|
|||
|
|
private NoticeCorpService noticeCorpService;
|
|||
|
|
@Autowired
|
|||
|
|
private HiddenExamineService hiddenExamineService;
|
|||
|
|
@Autowired
|
|||
|
|
private DepartmentService departmentService;
|
|||
|
|
@Autowired
|
|||
|
|
private SafetyEnvironmentalExplainService explainService;
|
|||
|
|
|
|||
|
|
@Resource
|
|||
|
|
private NoticeCorpUtil noticeCorpUtil;
|
|||
|
|
|
|||
|
|
/**新增
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
public List<PageData> save(PageData pd)throws Exception{
|
|||
|
|
List<PageData> hiddenList = new ArrayList<PageData>();
|
|||
|
|
String currentTime = DateUtil.date2Str(new Date());
|
|||
|
|
if (Tools.notEmpty(pd.getString("SITUATIONJSON"))) {
|
|||
|
|
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.getString("SITUATIONJSON"));
|
|||
|
|
String time = currentTime;
|
|||
|
|
for (JSONObject json : list) {
|
|||
|
|
PageData situationPd = new PageData();
|
|||
|
|
situationPd.put("INSPECTION_SITUATION_ID", UuidUtil.get32UUID()); //主键
|
|||
|
|
situationPd.put("INSPECTION_ID", pd.getString("INSPECTION_ID")); //检查ID
|
|||
|
|
situationPd.put("SITUATION", json.get("SITUATION")); //检查情况
|
|||
|
|
situationPd.put("ISDELETE", "0"); //是否删除(0:有效 1：删除)
|
|||
|
|
situationPd.put("CREATOR", pd.getString("CREATOR")); //添加人
|
|||
|
|
situationPd.put("CREATTIME", time); //添加时间
|
|||
|
|
situationPd.put("OPERATOR", pd.getString("OPERATOR")); //修改人
|
|||
|
|
situationPd.put("OPERATTIME", time); //修改时间
|
|||
|
|
situationPd.put("CORPINFO_ID", pd.getString("CORPINFO_ID")); //企业ID
|
|||
|
|
safetyenvironmentalsituationService.save(situationPd);
|
|||
|
|
time = DateUtil.calculateDateSecond(time, 1);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (Tools.notEmpty(pd.getString("INSPECTORJSON"))) {
|
|||
|
|
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.getString("INSPECTORJSON"));
|
|||
|
|
String time = currentTime;
|
|||
|
|
for (int i = 0; i < list.size(); i++) {
|
|||
|
|
JSONObject json = list.get(i);
|
|||
|
|
if (i == 0) {
|
|||
|
|
pd.put("INSPECTION_LEADDEPARTMENT_ID", json.getString("INSPECTION_DEPARTMENT_ID"));
|
|||
|
|
}
|
|||
|
|
PageData inspector = new PageData();
|
|||
|
|
inspector.put("INSPECTION_INSPECTOR_ID", UuidUtil.get32UUID()); //主键
|
|||
|
|
inspector.put("INSPECTION_ID", pd.getString("INSPECTION_ID")); //检查ID
|
|||
|
|
inspector.put("INSPECTION_USER_ID", json.get("INSPECTION_USER_ID")); //检查人
|
|||
|
|
inspector.put("ISDELETE", "0"); //是否删除(0:有效 1：删除)
|
|||
|
|
inspector.put("CREATOR", pd.getString("CREATOR")); //添加人
|
|||
|
|
inspector.put("CREATTIME", time); //添加时间
|
|||
|
|
inspector.put("OPERATOR", pd.getString("OPERATOR")); //修改人
|
|||
|
|
inspector.put("OPERATTIME", time); //修改时间
|
|||
|
|
inspector.put("CORPINFO_ID", pd.getString("CORPINFO_ID")); //企业ID
|
|||
|
|
boolean note_flag = true;
|
|||
|
|
if(StringUtils.isNotBlank(pd.getString("OPERATOR"))){
|
|||
|
|
if (pd.getString("OPERATOR").equals(json.get("INSPECTION_USER_ID"))){
|
|||
|
|
if (StringUtils.isNotBlank(pd.getString("CONFIRM_MESSAGE"))){
|
|||
|
|
inspector.put("INSPECTION_USER_OPINION",pd.getString("CONFIRM_MESSAGE"));
|
|||
|
|
inspector.put("INSPECTION_USER_SIGN_IMG",pd.getString("CONFIRM_MESSAGE_SIGN_ROUTE"));
|
|||
|
|
inspector.put("INSPECTION_USER_SIGN_TIME",pd.getString("CONFIRM_MESSAGE_TIME"));
|
|||
|
|
// 若，检查人只有一人，且已签字。将此条安全环保检查记录状态设置为‘2’
|
|||
|
|
if (list.size() == 1){
|
|||
|
|
pd.put("INSPECTION_STATUS",2);
|
|||
|
|
note_flag = false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
safetyenvironmentalinspectorService.save(inspector);
|
|||
|
|
if (note_flag) noticeCorpUtil.SE_OneStepUtil(inspector);
|
|||
|
|
time = DateUtil.calculateDateSecond(time, 1);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (Tools.notEmpty(pd.getString("HIDDENJSON"))) {
|
|||
|
|
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.getString("HIDDENJSON"));
|
|||
|
|
String time = currentTime;
|
|||
|
|
for (JSONObject json : list) {
|
|||
|
|
PageData hidden = new PageData();
|
|||
|
|
hidden.put("HIDDEN_ID", UuidUtil.get32UUID()); //主键
|
|||
|
|
hidden.put("FOREIGN_ID", pd.getString("INSPECTION_ID")); //外键ID
|
|||
|
|
hidden.put("HIDDENDESCR", json.getString("HIDDENDESCR")); //隐患描述
|
|||
|
|
hidden.put("HIDDENPART", json.getString("HIDDENPART")); //隐患部位
|
|||
|
|
hidden.put("HIDDENLEVEL", json.getString("HIDDENLEVEL")); //隐患级别
|
|||
|
|
hidden.put("HIDDENTYPE", json.getString("HIDDENTYPE")); //隐患类型1
|
|||
|
|
hidden.put("HIDDENTYPE2", json.getString("HIDDENTYPE2")); //隐患类型2
|
|||
|
|
hidden.put("LONGITUDE", json.getString("LONGITUDE")); //隐患位置经度
|
|||
|
|
hidden.put("LATITUDE", json.getString("LATITUDE")); //隐患位置纬度
|
|||
|
|
hidden.put("DISCOVERYTIME", json.getString("DISCOVERYTIME")); //隐患发现时间
|
|||
|
|
hidden.put("HIDDENFINDDEPT", json.getString("HIDDENFINDDEPT")); //隐患发现部门（隐患责任人部门）
|
|||
|
|
hidden.put("CREATOR", json.getString("CREATOR")); //发现人（隐患责任人）
|
|||
|
|
hidden.put("SOURCE", json.getString("SOURCE")); //发现人（隐患责任人）
|
|||
|
|
hidden.put("ISRELEVANT",json.getString("ISRELEVANT"));//是否相关方1是2否
|
|||
|
|
hidden.put("STATE", "100"); //隐患状态 100-安全环保检查暂存的隐患（流程完转0）
|
|||
|
|
hidden.put("CREATTIME", time); //发现时间
|
|||
|
|
hidden.put("CORPINFO_ID", pd.getString("CORPINFO_ID"));
|
|||
|
|
hidden.put("ISDELETE", "0"); //是否删除(0:有效 1：删除)
|
|||
|
|
hidden.put("POSITIONDESC",json.getString("POSITIONDESC"));
|
|||
|
|
|
|||
|
|
PageData before = new PageData();// 添加隐患初始信息
|
|||
|
|
before.put("TYPE","0");
|
|||
|
|
before.put("STATE","2");
|
|||
|
|
before.put("HIDDEN_ID",hidden.getString("HIDDEN_ID"));
|
|||
|
|
before.put("spare1",json.getString("HIDDENLEVEL"));
|
|||
|
|
before.put("CREATOR", json.getString("CREATOR"));
|
|||
|
|
before.put("OPERATOR",json.getString("CREATOR"));
|
|||
|
|
hiddenExamineService.saveApp(before);
|
|||
|
|
hiddenService.save(hidden);
|
|||
|
|
|
|||
|
|
PageData findUser = new PageData();
|
|||
|
|
findUser.put("HIDDENUSER_ID", UuidUtil.get32UUID());
|
|||
|
|
findUser.put("HIDDEN_ID",hidden.getString("HIDDEN_ID"));
|
|||
|
|
findUser.put("USER_ID",json.getString("CREATOR"));
|
|||
|
|
findUser.put("TYPE","1");
|
|||
|
|
findUser.put("IS_MAIN","0");
|
|||
|
|
hiddenUserService.save(findUser);
|
|||
|
|
hiddenList.add(hidden);
|
|||
|
|
time = DateUtil.calculateDateSecond(time, 1);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
PageData log = new PageData();
|
|||
|
|
log.put("INSPECTION_LOG_ID", UuidUtil.get32UUID()); //安全环保检查操作记录ID
|
|||
|
|
log.put("INSPECTION_ID", pd.getString("INSPECTION_ID")); //安全环保检查ID
|
|||
|
|
log.put("ACTION", "安全环保检查申请"); //操作内容
|
|||
|
|
log.put("CREATTIME", pd.getString("CREATTIME")); //添加时间
|
|||
|
|
log.put("CREATOR", pd.getString("ACTION_USER")); //添加人姓名
|
|||
|
|
safetyenvironmentallogService.save(log);
|
|||
|
|
|
|||
|
|
safetyenvironmentalMapper.save(pd);
|
|||
|
|
return hiddenList;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public List<PageData> getHiddenCountByDepat(PageData pd) throws Exception {
|
|||
|
|
return safetyenvironmentalMapper.getHiddenCountByDepat(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public List<PageData> getHiddenCountByUser(PageData pd) throws Exception {
|
|||
|
|
return safetyenvironmentalMapper.getHiddenCountByUser(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**删除
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
@Transactional
|
|||
|
|
public void delete(PageData pd)throws Exception{
|
|||
|
|
safetyenvironmentalMapper.delete(pd);
|
|||
|
|
safetyenvironmentalsituationService.deleteByInspection(pd);
|
|||
|
|
safetyenvironmentalinspectorService.deleteByInspection(pd);
|
|||
|
|
safetyEnvironmentalExplainService.deleteByInspection(pd);
|
|||
|
|
if (StringUtils.isNotBlank(pd.getString("hide")) && "1".equals(pd.getString("hide"))){
|
|||
|
|
PageData key = new PageData();
|
|||
|
|
key.put("FOREIGN_ID",pd.getString("INSPECTION_ID"));
|
|||
|
|
key.put("SOURCE","5");
|
|||
|
|
hiddenService.deleteByKey(key);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/**修改
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
public void edieditsttust(PageData pd)throws Exception{
|
|||
|
|
safetyenvironmentalMapper.edieditsttust(pd); //执行考评方法时，将检查状态改成已归档，因为bug6535提出，要是隐患考评完毕，状态应该是8已归档
|
|||
|
|
}
|
|||
|
|
/**修改
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
public List<PageData> edit(PageData pd)throws Exception{
|
|||
|
|
List<PageData> hiddenList = new ArrayList<PageData>();
|
|||
|
|
String currentTime = DateUtil.date2Str(new Date());
|
|||
|
|
String[] delInspectors = "".equals(pd.getString("delInspectors")) ? new String[0] : pd.getString("delInspectors").split(",");
|
|||
|
|
if (delInspectors.length > 0) {
|
|||
|
|
PageData delArr = new PageData();
|
|||
|
|
delArr.put("ArrayDATA_IDS", delInspectors); //待删除ids
|
|||
|
|
delArr.put("OPERATOR", pd.getString("OPERATOR")); //修改人
|
|||
|
|
delArr.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
|||
|
|
safetyenvironmentalinspectorService.deleteAll(delArr); // 删除意见的
|
|||
|
|
}
|
|||
|
|
if (Tools.notEmpty(pd.getString("INSPECTORJSON"))) {
|
|||
|
|
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.getString("INSPECTORJSON"));
|
|||
|
|
String time = currentTime;
|
|||
|
|
for (int i = 0; i < list.size(); i++) {
|
|||
|
|
JSONObject json = list.get(i);
|
|||
|
|
if (i == 0) {
|
|||
|
|
pd.put("INSPECTION_LEADDEPARTMENT_ID", json.getString("INSPECTION_DEPARTMENT_ID"));
|
|||
|
|
}
|
|||
|
|
PageData inspector = new PageData();
|
|||
|
|
if(StringUtils.isNotBlank(pd.getString("OPERATOR"))){
|
|||
|
|
if (pd.getString("OPERATOR").equals(json.get("INSPECTION_USER_ID"))){
|
|||
|
|
if (StringUtils.isNotBlank(pd.getString("CONFIRM_MESSAGE"))){
|
|||
|
|
inspector.put("INSPECTION_USER_OPINION",pd.getString("CONFIRM_MESSAGE"));
|
|||
|
|
inspector.put("INSPECTION_USER_SIGN_IMG",pd.getString("CONFIRM_MESSAGE_SIGN_ROUTE"));
|
|||
|
|
inspector.put("INSPECTION_USER_SIGN_TIME",pd.getString("CONFIRM_MESSAGE_TIME"));
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (Tools.isEmpty(json.getString("INSPECTION_INSPECTOR_ID"))) {
|
|||
|
|
inspector.put("INSPECTION_INSPECTOR_ID", UuidUtil.get32UUID()); //主键
|
|||
|
|
inspector.put("INSPECTION_ID", pd.getString("INSPECTION_ID")); //检查ID
|
|||
|
|
inspector.put("INSPECTION_USER_ID", json.get("INSPECTION_USER_ID")); //检查人
|
|||
|
|
inspector.put("ISDELETE", "0"); //是否删除(0:有效 1：删除)
|
|||
|
|
inspector.put("CREATOR", pd.getString("CREATOR")); //添加人
|
|||
|
|
inspector.put("CREATTIME", time); //添加时间
|
|||
|
|
inspector.put("OPERATOR", pd.getString("OPERATOR")); //修改人
|
|||
|
|
inspector.put("OPERATTIME", time); //修改时间
|
|||
|
|
inspector.put("CORPINFO_ID", pd.getString("CORPINFO_ID")); //企业ID
|
|||
|
|
boolean note_flag = true;
|
|||
|
|
if(StringUtils.isNotBlank(pd.getString("OPERATOR"))){
|
|||
|
|
if (pd.getString("OPERATOR").equals(json.get("INSPECTION_USER_ID"))){
|
|||
|
|
if (StringUtils.isNotBlank(pd.getString("CONFIRM_MESSAGE"))){
|
|||
|
|
inspector.put("INSPECTION_USER_OPINION",pd.getString("CONFIRM_MESSAGE"));
|
|||
|
|
inspector.put("INSPECTION_USER_SIGN_IMG",pd.getString("CONFIRM_MESSAGE_SIGN_ROUTE"));
|
|||
|
|
inspector.put("INSPECTION_USER_SIGN_TIME",pd.getString("CONFIRM_MESSAGE_TIME"));
|
|||
|
|
// 若，检查人只有一人，且已签字。将此条安全环保检查记录状态设置为‘2’
|
|||
|
|
if (list.size() == 1){
|
|||
|
|
pd.put("INSPECTION_STATUS",2);
|
|||
|
|
note_flag = false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
safetyenvironmentalinspectorService.save(inspector);
|
|||
|
|
if (note_flag) noticeCorpUtil.SE_OneStepUtil(inspector);
|
|||
|
|
time = DateUtil.calculateDateSecond(time, 1);
|
|||
|
|
} else {
|
|||
|
|
inspector.put("INSPECTION_INSPECTOR_ID", json.getString("INSPECTION_INSPECTOR_ID")); //主键
|
|||
|
|
inspector.put("INSPECTION_ID", pd.getString("INSPECTION_ID")); //检查ID
|
|||
|
|
inspector.put("INSPECTION_USER_ID", json.getString("INSPECTION_USER_ID")); //检查人
|
|||
|
|
inspector.put("OPERATOR", pd.getString("OPERATOR")); //修改人
|
|||
|
|
inspector.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
|||
|
|
boolean note_flag = true;
|
|||
|
|
if(StringUtils.isNotBlank(pd.getString("OPERATOR"))){
|
|||
|
|
if (pd.getString("OPERATOR").equals(json.get("INSPECTION_USER_ID"))){
|
|||
|
|
if (StringUtils.isNotBlank(pd.getString("CONFIRM_MESSAGE"))){
|
|||
|
|
inspector.put("INSPECTION_USER_OPINION",pd.getString("CONFIRM_MESSAGE"));
|
|||
|
|
inspector.put("INSPECTION_USER_SIGN_IMG",pd.getString("CONFIRM_MESSAGE_SIGN_ROUTE"));
|
|||
|
|
inspector.put("INSPECTION_USER_SIGN_TIME",pd.getString("CONFIRM_MESSAGE_TIME"));
|
|||
|
|
// 若，检查人只有一人，且已签字。将此条安全环保检查记录状态设置为‘2’
|
|||
|
|
if (list.size() == 1){
|
|||
|
|
pd.put("INSPECTION_STATUS",2);
|
|||
|
|
note_flag = false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
safetyenvironmentalinspectorService.edit(inspector);
|
|||
|
|
PageData inspector_information = safetyenvironmentalinspectorService.findById(inspector);
|
|||
|
|
if (note_flag) noticeCorpUtil.SE_OneStepUtil(inspector_information);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
String[] delSituations = "".equals(pd.getString("delSituations")) ? new String[0] : pd.getString("delSituations").split(",");
|
|||
|
|
if (delSituations.length > 0) {
|
|||
|
|
PageData delArr = new PageData();
|
|||
|
|
delArr.put("ArrayDATA_IDS", delSituations); //待删除ids
|
|||
|
|
delArr.put("OPERATOR", pd.getString("OPERATOR")); //修改人
|
|||
|
|
delArr.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
|||
|
|
safetyenvironmentalsituationService.deleteAll(delArr);
|
|||
|
|
}
|
|||
|
|
if (Tools.notEmpty(pd.getString("SITUATIONJSON"))) {
|
|||
|
|
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.getString("SITUATIONJSON"));
|
|||
|
|
String time = currentTime;
|
|||
|
|
for (JSONObject json : list) {
|
|||
|
|
PageData situationPd = new PageData();
|
|||
|
|
if (Tools.isEmpty(json.getString("INSPECTION_SITUATION_ID"))) {
|
|||
|
|
situationPd.put("INSPECTION_SITUATION_ID", UuidUtil.get32UUID()); //主键
|
|||
|
|
situationPd.put("INSPECTION_ID", pd.getString("INSPECTION_ID")); //检查ID
|
|||
|
|
situationPd.put("SITUATION", json.get("SITUATION")); //检查情况
|
|||
|
|
situationPd.put("ISDELETE", "0"); //是否删除(0:有效 1：删除)
|
|||
|
|
situationPd.put("CREATOR", pd.getString("CREATOR")); //添加人
|
|||
|
|
situationPd.put("CREATTIME", time); //添加时间
|
|||
|
|
situationPd.put("OPERATOR", pd.getString("OPERATOR")); //修改人
|
|||
|
|
situationPd.put("OPERATTIME", time); //修改时间
|
|||
|
|
situationPd.put("CORPINFO_ID", pd.getString("CORPINFO_ID")); //企业ID
|
|||
|
|
safetyenvironmentalsituationService.save(situationPd);
|
|||
|
|
time = DateUtil.calculateDateSecond(time, 1);
|
|||
|
|
} else {
|
|||
|
|
situationPd.put("INSPECTION_SITUATION_ID", json.getString("INSPECTION_SITUATION_ID")); //主键
|
|||
|
|
situationPd.put("INSPECTION_ID", pd.getString("INSPECTION_ID")); //检查ID
|
|||
|
|
situationPd.put("SITUATION", json.getString("SITUATION")); //检查情况
|
|||
|
|
situationPd.put("OPERATOR", pd.getString("OPERATOR")); //修改人
|
|||
|
|
situationPd.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
|||
|
|
safetyenvironmentalsituationService.edit(situationPd);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
String[] delHiddens = "".equals(pd.getString("delHiddens")) ? new String[0] : pd.getString("delHiddens").split(",");
|
|||
|
|
if (delHiddens.length > 0) {
|
|||
|
|
PageData delArr = new PageData();
|
|||
|
|
delArr.put("ArrayDATA_IDS", delHiddens); //待删除ids
|
|||
|
|
delArr.put("OPERATOR", pd.getString("OPERATOR")); //修改人
|
|||
|
|
delArr.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
|||
|
|
imgFilesService.deleteInspectionHiddenFile(delArr);
|
|||
|
|
hiddenService.deleteArray(delArr);
|
|||
|
|
}
|
|||
|
|
if (Tools.notEmpty(pd.getString("HIDDENJSON"))) {
|
|||
|
|
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.getString("HIDDENJSON"));
|
|||
|
|
String time = currentTime;
|
|||
|
|
for (JSONObject json : list) {
|
|||
|
|
PageData hidden = new PageData();
|
|||
|
|
if (Tools.isEmpty(json.getString("HIDDEN_ID"))) {
|
|||
|
|
hidden.put("HIDDEN_ID", UuidUtil.get32UUID()); //主键
|
|||
|
|
hidden.put("FOREIGN_ID", pd.getString("INSPECTION_ID")); //外键ID
|
|||
|
|
hidden.put("HIDDENDESCR", json.getString("HIDDENDESCR")); //隐患描述
|
|||
|
|
hidden.put("HIDDENPART", json.getString("HIDDENPART")); //隐患部位
|
|||
|
|
hidden.put("HIDDENLEVEL", json.getString("HIDDENLEVEL")); //隐患级别
|
|||
|
|
hidden.put("HIDDENTYPE", json.getString("HIDDENTYPE")); //隐患类型1
|
|||
|
|
hidden.put("HIDDENTYPE2", json.getString("HIDDENTYPE2")); //隐患类型2
|
|||
|
|
hidden.put("LONGITUDE", json.getString("LONGITUDE")); //隐患位置经度
|
|||
|
|
hidden.put("LATITUDE", json.getString("LATITUDE")); //隐患位置纬度
|
|||
|
|
hidden.put("DISCOVERYTIME", json.getString("DISCOVERYTIME")); //隐患发现时间
|
|||
|
|
hidden.put("HIDDENFINDDEPT", json.getString("HIDDENFINDDEPT")); //隐患发现部门（隐患责任人部门）
|
|||
|
|
hidden.put("CREATOR", json.getString("CREATOR")); //发现人（隐患责任人）
|
|||
|
|
hidden.put("SOURCE", json.getString("SOURCE")); //发现人（隐患责任人）
|
|||
|
|
hidden.put("STATE", "100"); //隐患状态 100-安全环保检查暂存的隐患（流程完转0）
|
|||
|
|
hidden.put("CREATTIME", time); //发现时间
|
|||
|
|
hidden.put("CORPINFO_ID", pd.getString("CORPINFO_ID"));
|
|||
|
|
hidden.put("ISDELETE", "0"); //是否删除(0:有效 1：删除)
|
|||
|
|
hidden.put("POSITIONDESC",json.getString("POSITIONDESC"));
|
|||
|
|
hidden.put("ISRELEVANT",json.getString("ISRELEVANT"));
|
|||
|
|
hiddenService.save(hidden);
|
|||
|
|
time = DateUtil.calculateDateSecond(time, 1);
|
|||
|
|
} else {
|
|||
|
|
hidden.put("HIDDEN_ID", json.getString("HIDDEN_ID")); //主键
|
|||
|
|
hidden.put("FOREIGN_ID", pd.getString("INSPECTION_ID")); //外键ID
|
|||
|
|
hidden.put("HIDDENDESCR", json.getString("HIDDENDESCR")); //隐患描述
|
|||
|
|
hidden.put("HIDDENPART", json.getString("HIDDENPART")); //隐患部位
|
|||
|
|
hidden.put("HIDDENLEVEL", json.getString("HIDDENLEVEL")); //隐患级别
|
|||
|
|
hidden.put("HIDDENTYPE", json.getString("HIDDENTYPE")); //隐患类型1
|
|||
|
|
hidden.put("HIDDENTYPE2", json.getString("HIDDENTYPE2")); //隐患类型2
|
|||
|
|
hidden.put("LONGITUDE", json.getString("LONGITUDE")); //隐患位置经度
|
|||
|
|
hidden.put("LATITUDE", json.getString("LATITUDE")); //隐患位置纬度
|
|||
|
|
hidden.put("DISCOVERYTIME", json.getString("DISCOVERYTIME")); //隐患发现时间
|
|||
|
|
hidden.put("HIDDENFINDDEPT", json.getString("HIDDENFINDDEPT")); //隐患发现部门（隐患责任人部门）
|
|||
|
|
hidden.put("CREATOR", json.getString("CREATOR")); //发现人（隐患责任人）
|
|||
|
|
hidden.put("SOURCE", json.getString("SOURCE")); //发现人（隐患责任人）
|
|||
|
|
hidden.put("STATE", "100"); //隐患状态 100-安全环保检查暂存的隐患（流程完转0）
|
|||
|
|
hidden.put("ISDELETE", "0"); //是否删除(0:有效 1：删除)
|
|||
|
|
hidden.put("POSITIONDESC",json.getString("POSITIONDESC"));
|
|||
|
|
hidden.put("ISRELEVANT",json.getString("ISRELEVANT"));
|
|||
|
|
hiddenService.editInfo(hidden);
|
|||
|
|
|
|||
|
|
PageData del = new PageData();
|
|||
|
|
del.put("TYPE","1");
|
|||
|
|
del.put("HIDDEN_ID",hidden.getString("HIDDEN_ID"));
|
|||
|
|
hiddenUserService.deleteByHidden(del); // 先删除后添加
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
PageData findUser = new PageData();
|
|||
|
|
findUser.put("HIDDENUSER_ID", UuidUtil.get32UUID());
|
|||
|
|
findUser.put("HIDDEN_ID",hidden.getString("HIDDEN_ID"));
|
|||
|
|
findUser.put("USER_ID",json.getString("CREATOR"));
|
|||
|
|
findUser.put("TYPE","1");
|
|||
|
|
findUser.put("IS_MAIN","0");
|
|||
|
|
hiddenUserService.save(findUser);
|
|||
|
|
hiddenList.add(hidden);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
String[] delHiddenFiles = "".equals(pd.getString("delHiddenFiles")) ? new String[0] : pd.getString("delHiddenFiles").split(",");
|
|||
|
|
for (String delHiddenFile : delHiddenFiles) {
|
|||
|
|
PageData delFile = new PageData();
|
|||
|
|
delFile.put("FILEPATH", delHiddenFile); //路径
|
|||
|
|
imgFilesService.deleteByPath(delFile);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
PageData log = new PageData();
|
|||
|
|
log.put("INSPECTION_LOG_ID", UuidUtil.get32UUID()); //安全环保检查操作记录ID
|
|||
|
|
log.put("INSPECTION_ID", pd.getString("INSPECTION_ID")); //安全环保检查ID
|
|||
|
|
log.put("ACTION", "安全环保检查重新申请"); //操作内容
|
|||
|
|
log.put("CREATTIME", pd.getString("CREATTIME")); //添加时间
|
|||
|
|
log.put("CREATOR", pd.getString("ACTION_USER")); //添加人姓名
|
|||
|
|
safetyenvironmentallogService.save(log);
|
|||
|
|
// 编辑的时候自动清空附件
|
|||
|
|
if (!"1".equals(pd.getString("unClear"))){
|
|||
|
|
pd.put("INSPECTED_EXPLAIN_FILENAME",null);
|
|||
|
|
pd.put("INSPECTED_EXPLAIN_FILEPATH",null);
|
|||
|
|
}
|
|||
|
|
// 安全环保检查申辩记录没用存对应关系，所以做如下处理
|
|||
|
|
try {
|
|||
|
|
if (StringUtils.isNotBlank(pd.getString("unClear"))) {
|
|||
|
|
PageData explain_condition = new PageData();
|
|||
|
|
explain_condition.put("INSPECTION_EXPLAIN_ID", pd.getString("explainId"));
|
|||
|
|
explain_condition.put("INSPECTION_ID",pd.getString("INSPECTION_ID"));
|
|||
|
|
explainService.killAllMessage(explain_condition);
|
|||
|
|
|
|||
|
|
} else {
|
|||
|
|
PageData explain_condition = new PageData();
|
|||
|
|
explain_condition.put("INSPECTION_ID",pd.getString("INSPECTION_ID"));
|
|||
|
|
PageData explain = explainService.findMessage(explain_condition);
|
|||
|
|
if (explain == null || explain.size() <= 0){
|
|||
|
|
explain = explainService.findMessageByTime(explain_condition);
|
|||
|
|
if (explain != null || explain.size() >= 0 || "1".equals(explain.getString("VALID"))){
|
|||
|
|
explain.put("OPERATTIME", DateUtil.date2Str(new Date()));
|
|||
|
|
explain.put("ISPASS","1");
|
|||
|
|
explain.put("VALID","0");
|
|||
|
|
explainService.edit(explain);
|
|||
|
|
}
|
|||
|
|
}else {
|
|||
|
|
explain.put("OPERATTIME", DateUtil.date2Str(new Date()));
|
|||
|
|
explain.put("ISPASS","1");
|
|||
|
|
explain.put("VALID","0");
|
|||
|
|
explainService.edit(explain);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
} catch (Exception e) {
|
|||
|
|
e.printStackTrace();
|
|||
|
|
}
|
|||
|
|
safetyenvironmentalMapper.edit(pd);
|
|||
|
|
return hiddenList;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**列表
|
|||
|
|
* @param page
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
public List<PageData> list(Page page)throws Exception{
|
|||
|
|
return safetyenvironmentalMapper.datalistPage(page);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**列表(全部)
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
public List<PageData> listAll(PageData pd)throws Exception{
|
|||
|
|
return safetyenvironmentalMapper.listAll(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**列表(全部)
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
public List<PageData> findByyin(PageData pd)throws Exception{
|
|||
|
|
return safetyenvironmentalMapper.findByyin(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**通过id获取数据
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
public PageData findById(PageData pd)throws Exception{
|
|||
|
|
return safetyenvironmentalMapper.findById(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public PageData findShowById(PageData pd) throws Exception {
|
|||
|
|
PageData data = safetyenvironmentalMapper.findById(pd);
|
|||
|
|
data.put("situationList", safetyenvironmentalsituationService.listAll(pd));
|
|||
|
|
pd.put("FOREIGN_ID",pd.getString("INSPECTION_ID"));
|
|||
|
|
data.put("hiddenList", hiddenService.listAllInspection(pd));
|
|||
|
|
pd.put("ISVERIFY",'1'); //查询已核实的数据
|
|||
|
|
data.put("inspectorList", safetyenvironmentalinspectorService.listAll(pd));
|
|||
|
|
return data;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public PageData findFormById(PageData pd) throws Exception {
|
|||
|
|
PageData data = safetyenvironmentalMapper.findById(pd);
|
|||
|
|
List<PageData> INSPECTORList = safetyenvironmentalinspectorService.listAll(pd);
|
|||
|
|
List<PageData> inspectorList = new ArrayList<>();
|
|||
|
|
for (PageData bean : INSPECTORList) {
|
|||
|
|
PageData u = new PageData();
|
|||
|
|
u.put("INSPECTION_INSPECTOR_ID", bean.getString("INSPECTION_INSPECTOR_ID"));
|
|||
|
|
u.put("INSPECTION_DEPARTMENT_ID",bean.getString("INSPECTION_DEPARTMENT_ID"));
|
|||
|
|
u.put("INSPECTION_DEPARTMENT_NAME",bean.getString("INSPECTION_DEPARTMENT_NAME"));
|
|||
|
|
u.put("INSPECTION_USER_ID",bean.getString("INSPECTION_USER_ID"));
|
|||
|
|
u.put("INSPECTION_USER_NAME",bean.getString("INSPECTION_USER_NAME"));
|
|||
|
|
u.put("img",bean.getString("INSPECTION_USER_SIGN_IMG"));
|
|||
|
|
u.put("opinion",bean.getString("INSPECTION_USER_OPINION"));
|
|||
|
|
u.put("time",bean.getString("INSPECTION_USER_SIGN_TIME"));
|
|||
|
|
inspectorList.add(u);
|
|||
|
|
}
|
|||
|
|
data.put("inspectorList", inspectorList);
|
|||
|
|
|
|||
|
|
List<PageData> SITUATIONList = safetyenvironmentalsituationService.listAll(pd);
|
|||
|
|
List<PageData> situationList = new ArrayList<>();
|
|||
|
|
for (PageData bean : SITUATIONList) {
|
|||
|
|
PageData u = new PageData();
|
|||
|
|
u.put("INSPECTION_SITUATION_ID", bean.getString("INSPECTION_SITUATION_ID"));
|
|||
|
|
u.put("SITUATION",bean.getString("SITUATION"));
|
|||
|
|
situationList.add(u);
|
|||
|
|
}
|
|||
|
|
data.put("situationList", situationList);
|
|||
|
|
pd.put("FOREIGN_ID",pd.getString("INSPECTION_ID"));
|
|||
|
|
data.put("hiddenList", hiddenService.listAllInspection(pd));
|
|||
|
|
pd.put("ISVERIFY",'1'); //查询已核实的数据
|
|||
|
|
data.put("inspectorVerifyList", safetyenvironmentalinspectorService.listAll(pd));
|
|||
|
|
return data;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**批量删除
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
public void deleteAll(PageData pd)throws Exception{
|
|||
|
|
safetyenvironmentalMapper.deleteAll(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**列表(根据所选ID获取数据)
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
public List<PageData> findByIds(PageData pd) throws Exception {
|
|||
|
|
return safetyenvironmentalMapper.findByIds(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public void editStatus(PageData pd) throws Exception {
|
|||
|
|
safetyenvironmentalMapper.editStatus(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public void explain(PageData pd) throws Exception {
|
|||
|
|
PageData data = safetyenvironmentalMapper.findById(pd);
|
|||
|
|
pd.put("STATE", "101"); // 101.检查已归档，待指派
|
|||
|
|
pd.put("INSPECTION_SOURCE",data.getString("INSPECTION_SOURCE"));
|
|||
|
|
hiddenService.editStateInspection(pd);
|
|||
|
|
|
|||
|
|
data.put("INSPECTION_STATUS",pd.getString("INSPECTION_STATUS"));
|
|||
|
|
data.put("INSPECTED_EXPLAIN_REFUSE",pd.getString("INSPECTED_EXPLAIN_REFUSE"));
|
|||
|
|
data.put("INSPECTION_ORIGINATOR_SIGN_IMG",pd.getString("INSPECTION_ORIGINATOR_SIGN_IMG"));
|
|||
|
|
data.put("INSPECTION_ORIGINATOR_SIGN_TIME", DateUtil.date2Str(new Date())); //签字时间
|
|||
|
|
data.put("OPERATOR", pd.getString("OPERATOR")); //修改人
|
|||
|
|
data.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
|
|||
|
|
safetyenvironmentalMapper.edit(data);
|
|||
|
|
|
|||
|
|
PageData log = new PageData();
|
|||
|
|
log.put("INSPECTION_LOG_ID", UuidUtil.get32UUID()); //安全环保检查操作记录ID
|
|||
|
|
log.put("INSPECTION_ID", pd.getString("INSPECTION_ID")); //安全环保检查ID
|
|||
|
|
log.put("ACTION", "安全环保检查申辩处理"); //操作内容
|
|||
|
|
log.put("CREATTIME", pd.getString("CREATTIME")); //添加时间
|
|||
|
|
log.put("CREATOR", pd.getString("ACTION_USER")); //添加人姓名
|
|||
|
|
safetyenvironmentallogService.save(log);
|
|||
|
|
|
|||
|
|
PageData condition = new PageData();
|
|||
|
|
condition.put("INSPECTION_ID",data.getString("INSPECTION_ID"));
|
|||
|
|
PageData explain = safetyEnvironmentalExplainService.findMessage(condition);
|
|||
|
|
if (explain == null || explain.size() <= 0){
|
|||
|
|
explain = safetyEnvironmentalExplainService.findMessageByTime(condition);
|
|||
|
|
}
|
|||
|
|
if (explain != null || explain.size() > 0){
|
|||
|
|
explain.put("VALID","0");
|
|||
|
|
explain.put("ISPASS","2");
|
|||
|
|
explain.put("OPERATTIME",DateUtil.date2Str(new Date()));
|
|||
|
|
safetyEnvironmentalExplainService.edit(explain);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public PageData statisticsBranch(PageData pd) throws Exception {
|
|||
|
|
return safetyenvironmentalMapper.statisticsBranch(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public List<PageData> statisticsJointStock(PageData pd) throws Exception {
|
|||
|
|
return safetyenvironmentalMapper.statisticsJointStock(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**被检查人签字/申辩数
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
@Override
|
|||
|
|
public PageData checkedCount(PageData pd) throws Exception {
|
|||
|
|
return safetyenvironmentalMapper.checkedCount(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**打回数
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
@Override
|
|||
|
|
public PageData repulseCount(PageData pd) throws Exception {
|
|||
|
|
return safetyenvironmentalMapper.repulseCount(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**指派+验收数
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
@Override
|
|||
|
|
public PageData repulseAndCheckCountCount(PageData pd) throws Exception {
|
|||
|
|
return safetyenvironmentalMapper.repulseAndCheckCountCount(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public List<PageData> pleadList(Page page) throws Exception {
|
|||
|
|
return safetyenvironmentalMapper.pleadlistPage(page);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public List<PageData> checkList(Page page) {
|
|||
|
|
return safetyenvironmentalMapper.checklistPage(page);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public PageData departmentUtil(PageData data) throws Exception {
|
|||
|
|
PageData condition = new PageData();
|
|||
|
|
condition.put("DEPARTMENT_ID",data.getString("INSPECTED_DEPARTMENT_ID"));
|
|||
|
|
List<PageData> parent_list = departmentService.getGenealogy(condition);
|
|||
|
|
if (parent_list != null && parent_list.size() > 0) {
|
|||
|
|
String corp_infos = parent_list.stream().map(n -> n.getString("NAME")).collect(Collectors.joining("-"));
|
|||
|
|
data.put("INSPECTED_DEPARTMENT_NAMES", corp_infos);
|
|||
|
|
}else{
|
|||
|
|
data.put("INSPECTED_DEPARTMENT_NAMES", "");
|
|||
|
|
}
|
|||
|
|
return data;
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 获取所有的安全环保信息
|
|||
|
|
* @param pd
|
|||
|
|
* @return
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
@Override
|
|||
|
|
public List<PageData> statisticsBranchGroupDept(PageData pd) throws Exception{
|
|||
|
|
return safetyenvironmentalMapper.statisticsBranchGroupDept(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
@Override
|
|||
|
|
public String getHiddenTotal(Page page) {
|
|||
|
|
// return safetyenvironmentalMapper.datalistPage(page);
|
|||
|
|
return safetyenvironmentalMapper.getHiddenTotal(page);
|
|||
|
|
}
|
|||
|
|
/**指派+验收数
|
|||
|
|
* @param pd
|
|||
|
|
* @throws Exception
|
|||
|
|
*/
|
|||
|
|
@Override
|
|||
|
|
public PageData repulseAndCheckCountCountV2(PageData pd) throws Exception {
|
|||
|
|
return safetyenvironmentalMapper.repulseAndCheckCountCountV2(pd);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|