forked from integrated_whb/integrated_whb
BUS_HIDDENDANGERCHECKSTANDARD_HIDDENEXAMINE和
BUS_HIDDENDANGERCHECKSTANDARD_HIDDEN_USER后台初始化pull/4/head
parent
d30cfe3624
commit
77e8562313
|
|
@ -79,7 +79,7 @@ public class AppCheckRecordController extends BaseController {
|
|||
@RequestMapping(value = "/add")
|
||||
@ResponseBody
|
||||
@Transactional
|
||||
@LogAnno(menuType= "手机",menuServer= "隐患排查",instructionsOperate = "清单排查",instructionsType = "新增记录")
|
||||
@LogAnno(menuType= "手机",menuServer= "风险排查",instructionsOperate = "清单排查",instructionsType = "新增记录")
|
||||
public Object add() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
|
|
|
|||
|
|
@ -0,0 +1,535 @@
|
|||
package com.zcloud.controller.hiddenDangerCheckStandard;
|
||||
|
||||
import com.alibaba.fastjson.JSON;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import com.zcloud.controller.base.BaseController;
|
||||
import com.zcloud.entity.PageData;
|
||||
import com.zcloud.logs.LogAnno;
|
||||
import com.zcloud.service.check.*;
|
||||
import com.zcloud.service.corp.CorpInfoService;
|
||||
import com.zcloud.service.hidden.HiddenService;
|
||||
import com.zcloud.service.hiddenDangerCheckStandard.*;
|
||||
import com.zcloud.service.offduty.OffDutyService;
|
||||
import com.zcloud.service.risk.IdentificationPartsService;
|
||||
import com.zcloud.service.sms.MSMLoginService;
|
||||
import com.zcloud.service.sms.SMSManagementService;
|
||||
import com.zcloud.service.system.DepartmentService;
|
||||
import com.zcloud.service.system.ImgFilesService;
|
||||
import com.zcloud.service.system.UsersService;
|
||||
import com.zcloud.util.DateUtil;
|
||||
import com.zcloud.util.ObjectExcelView;
|
||||
import com.zcloud.util.SendMessageUtil;
|
||||
import com.zcloud.util.Tools;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Controller;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.ResponseBody;
|
||||
import org.springframework.web.servlet.ModelAndView;
|
||||
|
||||
import java.util.*;
|
||||
|
||||
/**
|
||||
* 说明：清单检查记录 作者：luoxiaobao 时间：2021-01-04 官网：www.zcloudchina.com
|
||||
*/
|
||||
@Controller
|
||||
@RequestMapping("/app/customCheckRecord")
|
||||
public class AppCustomCheckRecordController extends BaseController {
|
||||
|
||||
@Autowired
|
||||
private CustomCheckRecordService customCheckRecordService;
|
||||
@Autowired
|
||||
private CustomCheckRecordItemService customCheckRecordItemService;
|
||||
@Autowired
|
||||
private CustomItemService customItemService;
|
||||
@Autowired
|
||||
private CustomService customService;
|
||||
|
||||
@Autowired
|
||||
private CustomHiddenService customHiddenService;
|
||||
@Autowired
|
||||
private CheckUserService checkuserService;
|
||||
@Autowired
|
||||
private CorpInfoService corpinfoService;
|
||||
@Autowired
|
||||
private UsersService usersService;
|
||||
@Autowired
|
||||
private SMSManagementService smsmanagementService;
|
||||
@Autowired
|
||||
private MSMLoginService msmloginService;
|
||||
@Autowired
|
||||
private IdentificationPartsService identificationPartsService;
|
||||
@Autowired
|
||||
private DepartmentService departmentService;
|
||||
@Autowired
|
||||
private ImgFilesService imgFilesService;
|
||||
@Autowired
|
||||
private OffDutyService offDutyService;
|
||||
@Autowired
|
||||
private SysDateService sysDateService;
|
||||
@Autowired
|
||||
private ListDisableTimeService listDisableTimeService;
|
||||
@Autowired
|
||||
private SendMessageUtil sendMessageUtil;
|
||||
/**
|
||||
* 新增
|
||||
*
|
||||
* @param
|
||||
* @throws Exception
|
||||
*/
|
||||
@RequestMapping(value = "/add")
|
||||
@ResponseBody
|
||||
@Transactional
|
||||
@LogAnno(menuType= "手机",menuServer= "隐患排查",instructionsOperate = "清单排查",instructionsType = "新增记录")
|
||||
public Object add() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
if (pd.get("CHECKRECORD_ID") == null || Tools.isEmpty(pd.getString("CHECKRECORD_ID"))) {
|
||||
pd.put("CHECKRECORD_ID", this.get32UUID()); // 主键
|
||||
pd.put("ISDELETE", "0"); // 是否删除
|
||||
pd.put("CREATTIME", DateUtil.date2Str(new Date())); // 创建时间
|
||||
pd.put("FINISHED", "0"); // 是否完成
|
||||
pd.put("ISSTATISTICS", "1");
|
||||
pd.put("TYPE", "1");
|
||||
customCheckRecordService.save(pd);
|
||||
}
|
||||
|
||||
if (pd.get("ITEMS") != null && !pd.get("ITEMS").equals("")) {
|
||||
List<JSONObject> list = (List<JSONObject>) JSON.parse(pd.get("ITEMS").toString());
|
||||
for (JSONObject json : list) {
|
||||
PageData item = new PageData();
|
||||
item.put("RECORDITEM_ID", json.get("RECORDITEM_ID")); // 主键
|
||||
item = customCheckRecordItemService.findById(item);
|
||||
if (item == null) {
|
||||
item = new PageData();
|
||||
item.put("RECORDITEM_ID", json.get("RECORDITEM_ID")); // 主键
|
||||
item.put("CUSTOM_ITEM_ID", json.get("CUSTOM_ITEM_ID"));
|
||||
PageData chei = customItemService.findById(item);
|
||||
item.put("ISNORMAL", json.get("ISNORMAL"));
|
||||
item.put("CHECK_RESULT", json.get("CHECK_RESULT"));
|
||||
item.put("CHECKRECORD_ID", pd.get("CHECKRECORD_ID"));
|
||||
item.put("CUSTOM_ID", pd.get("CUSTOM_ID"));
|
||||
item.put("CHECK_CATEGORY", chei.get("CHECK_CATEGORY"));
|
||||
item.put("CHECK_CATEGORY_NAME", chei.get("CHECK_CATEGORY_NAME"));
|
||||
item.put("CHECK_ITEM", chei.get("CHECK_ITEM"));
|
||||
item.put("CHECK_ITEM_NAME", chei.get("CHECK_ITEM_NAME"));
|
||||
item.put("CHECK_CONTENT", chei.get("CHECK_CONTENT"));
|
||||
item.put("CHECK_STANDARD", chei.get("CHECK_STANDARD"));
|
||||
item.put("REFERENCE_BASIS", chei.get("REFERENCE_BASIS"));
|
||||
item.put("COMMON_ITEM_SORT", chei.get("COMMON_ITEM_SORT"));
|
||||
item.put("LONGITUDE", pd.get("LONGITUDE"));
|
||||
item.put("LATITUDE", pd.get("LATITUDE"));
|
||||
item.put("CORPINFO_ID", pd.get("CORPINFO_ID"));
|
||||
item.put("ISDELETE", pd.get("0"));
|
||||
item.put("CREATOR_ID", pd.get("USER_ID"));
|
||||
item.put("CREATOR_NAME", pd.get("CREATOR"));
|
||||
item.put("CREATE_TIME", DateUtil.date2Str(new Date()));
|
||||
customCheckRecordItemService.save(item);
|
||||
} else {
|
||||
item.put("LONGITUDE", pd.get("LONGITUDE"));
|
||||
item.put("LATITUDE", pd.get("LATITUDE"));
|
||||
item.put("ISNORMAL", json.get("ISNORMAL"));
|
||||
item.put("CHECK_RESULT", json.get("CHECK_RESULT"));
|
||||
customCheckRecordItemService.edit(item);
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
if (pd.get("IDS") != null && !pd.get("IDS").equals("")) {
|
||||
String ids = pd.get("IDS").toString();
|
||||
String ArrayDATA_IDS[] = ids.split(",");
|
||||
PageData hiddens = new PageData();
|
||||
hiddens.put("CHECKRECORD_ID", pd.get("CHECKRECORD_ID"));
|
||||
PageData list = customService.findById(pd);
|
||||
if(list.getString("TYPE").equals("listType0001")){
|
||||
hiddens.put("STATE", "0");
|
||||
}else{
|
||||
hiddens.put("STATE", "1");
|
||||
}
|
||||
hiddens.put("IDS", ArrayDATA_IDS);
|
||||
customHiddenService.updateAll(hiddens);
|
||||
}
|
||||
map.put("result", errInfo);
|
||||
return map;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 完成检查
|
||||
*
|
||||
* @param
|
||||
* @throws Exception
|
||||
*/
|
||||
@RequestMapping(value = "/finish")
|
||||
@ResponseBody
|
||||
@Transactional
|
||||
@LogAnno(menuType= "手机",menuServer= "隐患排查",instructionsOperate = "清单检查情况",instructionsType = "完成检查")
|
||||
public Object finish() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
PageData sysdate = new PageData();
|
||||
sysdate.put("DATE", pd.get("CHECK_TIME"));
|
||||
sysdate = sysDateService.findByDate(sysdate);
|
||||
PageData list = customService.findById(pd);
|
||||
String periodstart = "";
|
||||
String periodend = "";
|
||||
if(!list.get("TYPE").toString().equals("listType0005")) {
|
||||
switch (list.get("PERIOD").toString()) {
|
||||
case "checkPeriod0001":
|
||||
periodstart = sysdate.getString("DAY_START");
|
||||
periodend = sysdate.getString("DAY_END");
|
||||
break;
|
||||
case "checkPeriod0002":
|
||||
periodstart = sysdate.getString("WEEK_START");
|
||||
periodend = sysdate.getString("WEEK_END");
|
||||
break;
|
||||
case "checkPeriod0003":
|
||||
periodstart = sysdate.getString("XUN_START");
|
||||
periodend = sysdate.getString("XUN_END");
|
||||
break;
|
||||
case "checkPeriod0004":
|
||||
periodstart = sysdate.getString("MONTH_START");
|
||||
periodend = sysdate.getString("MONTH_END");
|
||||
break;
|
||||
case "checkPeriod0005":
|
||||
periodstart = sysdate.getString("QUARTER_START");
|
||||
periodend = sysdate.getString("QUARTER_END");
|
||||
break;
|
||||
case "checkPeriod0006":
|
||||
periodstart = sysdate.getString("YEAR_START");
|
||||
periodend = sysdate.getString("YEAR_END");
|
||||
break;
|
||||
case "checkPeriod0007":
|
||||
periodstart = sysdate.getString("HALFYEAR_START");
|
||||
periodend = sysdate.getString("HALFYEAR_END");
|
||||
break;
|
||||
}
|
||||
pd.put("PERIODSTART", periodstart);
|
||||
pd.put("PERIODEND", periodend);
|
||||
} else {
|
||||
pd.put("PERIODSTART", list.get("START_DATE"));
|
||||
pd.put("PERIODEND", list.get("END_DATE"));
|
||||
}
|
||||
pd.put("FINISHED", "1"); // 是否完成
|
||||
customCheckRecordService.edit(pd);
|
||||
checkuserService.delete(pd);
|
||||
if (pd.get("OTHER") != null && !pd.get("OTHER").equals("")) {
|
||||
List<JSONObject> list1 = (List<JSONObject>) JSON.parse(pd.get("OTHER").toString());
|
||||
for (JSONObject json : list1) {
|
||||
if (json.get("DEPARTMENT_ID") != null && json.get("DEPARTMENT_ID") != "" && json.get("USER_ID") != null
|
||||
&& json.get("USER_ID") != "") {
|
||||
PageData other = new PageData();
|
||||
other.put("CHECKUSER_ID", this.get32UUID()); // 主键
|
||||
other.put("CHECKRECORD_ID", pd.get("CHECKRECORD_ID"));
|
||||
other.put("DEPARTMENT_ID", json.get("DEPARTMENT_ID"));
|
||||
other.put("USER_ID", json.get("USER_ID"));
|
||||
other.put("DEPARTMENT_NAME", json.get("DEPARTMENT_NAME"));
|
||||
other.put("USER_NAME", json.get("USER_NAME"));
|
||||
checkuserService.save(other);
|
||||
}
|
||||
}
|
||||
}
|
||||
customHiddenService.submit(pd);// 清单内隐患提交
|
||||
customHiddenService.submitList(pd);// 其他隐患提交
|
||||
List<PageData> hList = customHiddenService.getHiddenByRecord(pd);// 查询隐患，并发短信
|
||||
if (hList.size() > 0) {
|
||||
for (PageData h : hList) {
|
||||
if ("2".equals(h.get("RECTIFICATIONTYPE").toString())) {// 给整改人发送短信，暂时先用发验证码代替
|
||||
// 发短信
|
||||
PageData mes = new PageData();
|
||||
mes.put("RECEIVER_ID", h.get("RECTIFICATIONOR"));// 收信人userid
|
||||
mes.put("templateCode", "SMS_215820677");// 短信模板编码
|
||||
mes.put("CORPINFO_ID", pd.get("CORPINFO_ID"));// 企业id
|
||||
|
||||
// 参数集合
|
||||
List<PageData> paramsList = new ArrayList<PageData>();
|
||||
// 第1个参数
|
||||
PageData params1 = new PageData();
|
||||
params1.put("name", "time");// 存入短信模板中的参数名称
|
||||
params1.put("value", h.get("RECTIFICATIONDEADLINE"));// 存入上面参数名称所传递的值
|
||||
paramsList.add(params1);
|
||||
|
||||
sendMessageUtil.sendMessages(mes, paramsList);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
map.put("result", errInfo);
|
||||
return map;
|
||||
}
|
||||
|
||||
@RequestMapping(value = "/goMapWeui")
|
||||
@ResponseBody
|
||||
public Object goMapWeui() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
PageData checkrecord = customCheckRecordService.findById(pd);
|
||||
List<PageData> varList = customCheckRecordItemService.listAllForMap(checkrecord);
|
||||
pd.put("CORPINFO_ID", checkrecord.get("CORPINFO_ID"));
|
||||
PageData cinfo = corpinfoService.findById(pd);
|
||||
checkrecord.put("FIND_CHECKRECORD_ID", checkrecord.get("CHECKRECORD_ID"));
|
||||
List<PageData> hdList = customHiddenService.listAll(checkrecord);
|
||||
map.put("varList", varList);
|
||||
map.put("hdList", hdList);
|
||||
map.put("pd", pd);
|
||||
map.put("cinfo", cinfo);
|
||||
map.put("checkrecord", checkrecord);
|
||||
map.put("result", errInfo);
|
||||
return map;
|
||||
}
|
||||
|
||||
/**
|
||||
* 删除
|
||||
*
|
||||
* @param out
|
||||
* @throws Exception
|
||||
*/
|
||||
@RequestMapping(value = "/delete")
|
||||
// @RequiresPermissions("checkrecord:del")
|
||||
@ResponseBody
|
||||
@LogAnno(menuType= "手机",menuServer= "隐患排查",instructionsOperate = "清单检查情况",instructionsType = "删除检查记录")
|
||||
public Object delete() throws Exception {
|
||||
Map<String, String> map = new HashMap<String, String>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
customCheckRecordService.delete(pd);
|
||||
map.put("result", errInfo); // 返回结果
|
||||
return map;
|
||||
}
|
||||
|
||||
/**
|
||||
* 修改
|
||||
*
|
||||
* @param
|
||||
* @throws Exception
|
||||
*/
|
||||
@RequestMapping(value = "/edit")
|
||||
// @RequiresPermissions("checkrecord:edit")
|
||||
@ResponseBody
|
||||
@LogAnno(menuType= "手机",menuServer= "隐患排查",instructionsOperate = "清单检查情况",instructionsType = "修改")
|
||||
public Object edit() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
customCheckRecordService.edit(pd);
|
||||
map.put("result", errInfo);
|
||||
return map;
|
||||
}
|
||||
|
||||
/**
|
||||
* 指定辨识部位检查记录
|
||||
*
|
||||
* @param
|
||||
* @throws Exception
|
||||
*/
|
||||
@RequestMapping(value = "/recordByIde")
|
||||
@ResponseBody
|
||||
@LogAnno(menuType= "手机",menuServer= "隐患排查",instructionsOperate = "清单检查情况",instructionsType = "指定辨识部位检查记录")
|
||||
public Object recordByIde() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
String KEYWORDS = pd.getString("KEYWORDS"); // 关键词检索条件
|
||||
if (Tools.notEmpty(KEYWORDS))
|
||||
pd.put("KEYWORDS", KEYWORDS.trim());
|
||||
List<PageData> varList = customCheckRecordService.recordByIde(pd);
|
||||
map.put("varList", varList);
|
||||
map.put("result", errInfo);
|
||||
return map;
|
||||
}
|
||||
|
||||
/**
|
||||
* 列表
|
||||
*
|
||||
* @param page
|
||||
* @throws Exception
|
||||
*/
|
||||
@RequestMapping(value = "/list")
|
||||
@ResponseBody
|
||||
@LogAnno(menuType= "手机",menuServer= "隐患排查",instructionsOperate = "清单检查情况",instructionsType = "检查记录列表")
|
||||
public Object list() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
String KEYWORDS = pd.getString("KEYWORDS"); // 关键词检索条件
|
||||
if (Tools.notEmpty(KEYWORDS))
|
||||
pd.put("KEYWORDS", KEYWORDS.trim());
|
||||
PageData ls = customService.findById(pd);
|
||||
|
||||
List<PageData> varList = customCheckRecordService.appdatalist(pd);
|
||||
map.put("varList", varList);
|
||||
map.put("ls", ls);
|
||||
map.put("result", errInfo);
|
||||
return map;
|
||||
}
|
||||
|
||||
/**
|
||||
* 去修改页面获取数据
|
||||
*
|
||||
* @param
|
||||
* @throws Exception
|
||||
*/
|
||||
@RequestMapping(value = "/goEdit")
|
||||
@ResponseBody
|
||||
@LogAnno(menuType= "手机",menuServer= "隐患排查",instructionsOperate = "清单检查情况",instructionsType = "去修改页面获取数据")
|
||||
public Object goEdit() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
pd = customCheckRecordService.findById(pd); // 根据ID读取
|
||||
PageData users = checkuserService.getCheckUser(pd);
|
||||
List<PageData> varList = customCheckRecordItemService.listAll(pd);
|
||||
pd.put("USERS", users.get("USERS"));
|
||||
PageData pd2 = new PageData();
|
||||
pd2.put("FOREIGN_KEY",pd.get("CHECKRECORD_ID"));
|
||||
pd2.put("TYPE","13");
|
||||
List<PageData> qianming = imgFilesService.listAll(pd2);
|
||||
|
||||
|
||||
map.put("qianming", qianming);
|
||||
map.put("varList", varList);
|
||||
map.put("pd", pd);
|
||||
map.put("result", errInfo);
|
||||
return map;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 去修改页面获取数据Weui
|
||||
*
|
||||
* @param
|
||||
* @throws Exception
|
||||
*/
|
||||
@RequestMapping(value = "/goEditWeui")
|
||||
@ResponseBody
|
||||
@LogAnno(menuType= "手机",menuServer= "隐患排查",instructionsOperate = "清单检查情况",instructionsType = "去修改页面获取数据")
|
||||
public Object goEditWeui() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
String IDENTIFICATION_ID = pd.getString("IDENTIFICATION_ID");
|
||||
pd = customCheckRecordService.findById(pd); // 根据ID读取
|
||||
PageData users = checkuserService.getCheckUser(pd);
|
||||
pd.put("IDENTIFICATION_ID", IDENTIFICATION_ID);
|
||||
List<PageData> varList = customCheckRecordItemService.listAll(pd);
|
||||
PageData idData = new PageData();
|
||||
idData.put("IDENTIFICATIONPARTS_ID", IDENTIFICATION_ID);
|
||||
idData = identificationPartsService.findById(idData);
|
||||
pd.put("USERS", users.get("USERS"));
|
||||
map.put("varList", varList);
|
||||
map.put("pd", pd);
|
||||
map.put("idData", idData);
|
||||
map.put("result", errInfo);
|
||||
return map;
|
||||
}
|
||||
|
||||
/**
|
||||
* 批量删除
|
||||
*
|
||||
* @param
|
||||
* @throws Exception
|
||||
*/
|
||||
@RequestMapping(value = "/deleteAll")
|
||||
// @RequiresPermissions("checkrecord:del")
|
||||
@ResponseBody
|
||||
@LogAnno(menuType= "手机",menuServer= "隐患排查",instructionsOperate = "清单检查情况",instructionsType = "批量删除")
|
||||
public Object deleteAll() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
String DATA_IDS = pd.getString("DATA_IDS");
|
||||
if (Tools.notEmpty(DATA_IDS)) {
|
||||
String ArrayDATA_IDS[] = DATA_IDS.split(",");
|
||||
customCheckRecordService.deleteAll(ArrayDATA_IDS);
|
||||
errInfo = "success";
|
||||
} else {
|
||||
errInfo = "error";
|
||||
}
|
||||
map.put("result", errInfo); // 返回结果
|
||||
return map;
|
||||
}
|
||||
|
||||
/**
|
||||
* 导出到excel
|
||||
*
|
||||
* @param
|
||||
* @throws Exception
|
||||
*/
|
||||
@RequestMapping(value = "/excel")
|
||||
@LogAnno(menuType= "手机",menuServer= "隐患排查",instructionsOperate = "清单检查情况",instructionsType = "导出到excel")
|
||||
public ModelAndView exportExcel() throws Exception {
|
||||
ModelAndView mv = new ModelAndView();
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
Map<String, Object> dataMap = new HashMap<String, Object>();
|
||||
List<String> titles = new ArrayList<String>();
|
||||
titles.add("清单ID"); // 1
|
||||
titles.add("清单名称"); // 2
|
||||
titles.add("企业"); // 3
|
||||
titles.add("添加人"); // 4
|
||||
titles.add("创建时间"); // 5
|
||||
titles.add("修改人"); // 6
|
||||
titles.add("修改时间"); // 7
|
||||
titles.add("是否删除"); // 8
|
||||
dataMap.put("titles", titles);
|
||||
List<PageData> varOList = customCheckRecordService.listAll(pd);
|
||||
List<PageData> varList = new ArrayList<PageData>();
|
||||
for (int i = 0; i < varOList.size(); i++) {
|
||||
PageData vpd = new PageData();
|
||||
vpd.put("var1", varOList.get(i).getString("CUSTOM_ID")); // 1
|
||||
vpd.put("var2", varOList.get(i).getString("LIST_NAME")); // 2
|
||||
vpd.put("var3", varOList.get(i).getString("CORPINFO_ID")); // 3
|
||||
vpd.put("var4", varOList.get(i).getString("CREATOR")); // 4
|
||||
vpd.put("var5", varOList.get(i).getString("CREATTIME")); // 5
|
||||
vpd.put("var6", varOList.get(i).getString("OPERATOR")); // 6
|
||||
vpd.put("var7", varOList.get(i).getString("OPERATTIME")); // 7
|
||||
vpd.put("var8", varOList.get(i).get("ISDELETE").toString()); // 8
|
||||
varList.add(vpd);
|
||||
}
|
||||
dataMap.put("varList", varList);
|
||||
ObjectExcelView erv = new ObjectExcelView();
|
||||
mv = new ModelAndView(erv, dataMap);
|
||||
return mv;
|
||||
}
|
||||
|
||||
@RequestMapping(value = "/goMap")
|
||||
@ResponseBody
|
||||
public Object goMap() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
pd = this.getPageData();
|
||||
PageData checkrecord = customCheckRecordService.findById(pd);
|
||||
List<PageData> varList = customCheckRecordItemService.listAllForMap(checkrecord);
|
||||
PageData cinfo = corpinfoService.findById(pd);
|
||||
checkrecord.put("FIND_CHECKRECORD_ID", checkrecord.get("CHECKRECORD_ID"));
|
||||
List<PageData> hdList = customHiddenService.listAll(checkrecord);
|
||||
map.put("varList", varList);
|
||||
map.put("hdList", hdList);
|
||||
map.put("pd", pd);
|
||||
map.put("cinfo", cinfo);
|
||||
map.put("checkrecord", checkrecord);
|
||||
map.put("result", errInfo);
|
||||
return map;
|
||||
}
|
||||
|
||||
}
|
||||
|
|
@ -166,7 +166,7 @@ public class AppCustomController extends BaseController {
|
|||
@RequestMapping(value = "/getCheckItem")
|
||||
@ResponseBody
|
||||
@LogAnno(menuType = "手机", menuServer = "隐患排查", instructionsOperate = "清单管理", instructionsType = "获取清单风险点")
|
||||
public Object getRisk() throws Exception {
|
||||
public Object getCheckItem() throws Exception {
|
||||
Map<String, Object> map = new HashMap<String, Object>();
|
||||
String errInfo = "success";
|
||||
PageData pd = new PageData();
|
||||
|
|
@ -197,7 +197,7 @@ public class AppCustomController extends BaseController {
|
|||
checkmap.put(item.getString("CHECK_ITEM"), checkmap.get(item.getString("CHECK_ITEM")) + 1);
|
||||
}
|
||||
}
|
||||
map.put("CHECK_ITEM", records.get(0).get("CHECK_ITEM"));
|
||||
map.put("CHECKRECORD_ID", records.get(0).get("CHECKRECORD_ID"));
|
||||
map.put("checkmap", checkmap);
|
||||
}
|
||||
}
|
||||
|
|
@ -453,7 +453,7 @@ public class AppCustomController extends BaseController {
|
|||
if (pd.getString("TYPE").equals("listType0005")) {
|
||||
if (DateUtil.timeCalendar(new Date(), DateUtil.fomatDateTime(pd.getString("START_DATE") + " 00:00:00"), DateUtil.fomatDateTime(pd.getString("END_DATE") + " 23:59:59"))) {
|
||||
PageData type = new PageData();
|
||||
type.put("LISTMANAGER_ID", pd.get("LISTMANAGER_ID"));
|
||||
type.put("CUSTOM_ID", pd.get("CUSTOM_ID"));
|
||||
type.put("IS_XUN", 1);//查询方法和旬一样,直接借用
|
||||
type.put("FINISHED", '0');
|
||||
type.put("USER_ID", USER_ID);
|
||||
|
|
@ -473,7 +473,7 @@ public class AppCustomController extends BaseController {
|
|||
String cycle = pd.getString("PERIODNAME");
|
||||
if (cycle.equals("每日")) {
|
||||
PageData type = new PageData();
|
||||
type.put("LISTMANAGER_ID", pd.get("LISTMANAGER_ID"));
|
||||
type.put("CUSTOM_ID", pd.get("CUSTOM_ID"));
|
||||
type.put("IS_DAY", 1);
|
||||
type.put("FINISHED", '0');
|
||||
type.put("USER_ID", USER_ID);
|
||||
|
|
@ -486,7 +486,7 @@ public class AppCustomController extends BaseController {
|
|||
}
|
||||
} else if (cycle.equals("每周")) {
|
||||
PageData type = new PageData();
|
||||
type.put("LISTMANAGER_ID", pd.get("LISTMANAGER_ID"));
|
||||
type.put("CUSTOM_ID", pd.get("CUSTOM_ID"));
|
||||
type.put("IS_WEEK", 1);
|
||||
type.put("FINISHED", '0');
|
||||
type.put("USER_ID", USER_ID);
|
||||
|
|
@ -501,7 +501,7 @@ public class AppCustomController extends BaseController {
|
|||
//1-10
|
||||
if (DateUtil.timeCalendar(new Date(), DateUtil.fomatDateTime(DateUtil.getYear() + "-" + DateUtil.getMonth() + "-" + "01 00:00:00"), DateUtil.fomatDateTime(DateUtil.getYear() + "-" + DateUtil.getMonth() + "-" + "10 23:59:59"))) {
|
||||
PageData type = new PageData();
|
||||
type.put("LISTMANAGER_ID", pd.get("LISTMANAGER_ID"));
|
||||
type.put("CUSTOM_ID", pd.get("CUSTOM_ID"));
|
||||
type.put("IS_XUN", 1);
|
||||
type.put("FINISHED", '0');
|
||||
type.put("USER_ID", USER_ID);
|
||||
|
|
@ -518,7 +518,7 @@ public class AppCustomController extends BaseController {
|
|||
//10-20
|
||||
if (DateUtil.timeCalendar(new Date(), DateUtil.fomatDateTime(DateUtil.getYear() + "-" + DateUtil.getMonth() + "-" + "11 00:00:00"), DateUtil.fomatDateTime(DateUtil.getYear() + "-" + DateUtil.getMonth() + "-" + "20 23:59:59"))) {
|
||||
PageData type = new PageData();
|
||||
type.put("LISTMANAGER_ID", pd.get("LISTMANAGER_ID"));
|
||||
type.put("CUSTOM_ID", pd.get("CUSTOM_ID"));
|
||||
type.put("IS_XUN", 1);
|
||||
type.put("FINISHED", '0');
|
||||
type.put("USER_ID", USER_ID);
|
||||
|
|
@ -535,7 +535,7 @@ public class AppCustomController extends BaseController {
|
|||
//20-月底
|
||||
if (DateUtil.timeCalendar(new Date(), DateUtil.fomatDateTime(DateUtil.getYear() + "-" + DateUtil.getMonth() + "-" + "21 00:00:00"), DateUtil.fomatDateTime(DateUtil.getMonthEndDay() + " 23:59:59"))) {
|
||||
PageData type = new PageData();
|
||||
type.put("LISTMANAGER_ID", pd.get("LISTMANAGER_ID"));
|
||||
type.put("CUSTOM_ID", pd.get("CUSTOM_ID"));
|
||||
type.put("IS_XUN", 1);
|
||||
type.put("FINISHED", '0');
|
||||
type.put("USER_ID", USER_ID);
|
||||
|
|
@ -551,7 +551,7 @@ public class AppCustomController extends BaseController {
|
|||
}
|
||||
} else if (cycle.equals("每月")) {
|
||||
PageData type = new PageData();
|
||||
type.put("LISTMANAGER_ID", pd.get("LISTMANAGER_ID"));
|
||||
type.put("CUSTOM_ID", pd.get("CUSTOM_ID"));
|
||||
type.put("IS_MONTH", 1);
|
||||
type.put("FINISHED", '0');
|
||||
type.put("USER_ID", USER_ID);
|
||||
|
|
@ -564,7 +564,7 @@ public class AppCustomController extends BaseController {
|
|||
}
|
||||
} else if (cycle.equals("每季")) {
|
||||
PageData type = new PageData();
|
||||
type.put("LISTMANAGER_ID", pd.get("LISTMANAGER_ID"));
|
||||
type.put("CUSTOM_ID", pd.get("CUSTOM_ID"));
|
||||
type.put("IS_QUARTER", 1);
|
||||
type.put("FINISHED", '0');
|
||||
type.put("USER_ID", USER_ID);
|
||||
|
|
@ -577,7 +577,7 @@ public class AppCustomController extends BaseController {
|
|||
}
|
||||
} else if (cycle.equals("半年")) {
|
||||
PageData type = new PageData();
|
||||
type.put("LISTMANAGER_ID", pd.get("LISTMANAGER_ID"));
|
||||
type.put("CUSTOM_ID", pd.get("CUSTOM_ID"));
|
||||
type.put("IS_HALFYEAR", 1);
|
||||
type.put("FINISHED", '0');
|
||||
type.put("USER_ID", USER_ID);
|
||||
|
|
@ -590,7 +590,7 @@ public class AppCustomController extends BaseController {
|
|||
}
|
||||
} else if (cycle.equals("每年")) {
|
||||
PageData type = new PageData();
|
||||
type.put("LISTMANAGER_ID", pd.get("LISTMANAGER_ID"));
|
||||
type.put("CUSTOM_ID", pd.get("CUSTOM_ID"));
|
||||
type.put("IS_YEAR", 1);
|
||||
type.put("FINISHED", '0');
|
||||
type.put("USER_ID", USER_ID);
|
||||
|
|
|
|||
File diff suppressed because it is too large
Load Diff
|
|
@ -0,0 +1,80 @@
|
|||
package com.zcloud.mapper.datasource.hiddenDangerCheckStandard;
|
||||
|
||||
import com.zcloud.entity.Page;
|
||||
import com.zcloud.entity.PageData;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 说明：隐患审核
|
||||
* 作者：luoxiaobao
|
||||
* 时间：2022-04-14
|
||||
* 官网：www.zcloudchina.com
|
||||
*/
|
||||
public interface CustomHiddenExamineMapper {
|
||||
|
||||
/**新增
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
void save(PageData pd);
|
||||
|
||||
/**删除
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
void delete(PageData pd);
|
||||
|
||||
/**修改
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
void edit(PageData pd);
|
||||
|
||||
/**修改确认打回的信息
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
void editrepulse(PageData pd);
|
||||
|
||||
/**列表
|
||||
* @param page
|
||||
* @throws Exception
|
||||
*/
|
||||
List<PageData> datalistPage(Page page);
|
||||
|
||||
/**列表(全部)
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
List<PageData> listAll(PageData pd);
|
||||
|
||||
/**通过id获取数据
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
PageData findById(PageData pd);
|
||||
|
||||
/**批量删除
|
||||
* @param ArrayDATA_IDS
|
||||
* @throws Exception
|
||||
*/
|
||||
void deleteAll(String[] ArrayDATA_IDS);
|
||||
/**修改
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
void updateBySpecial(PageData pd);
|
||||
|
||||
/**列表
|
||||
* @param page
|
||||
* @throws Exception
|
||||
*/
|
||||
List<PageData> listAndHiddendatalistPage(Page page);
|
||||
public PageData findByIdAndHidden(PageData pd);
|
||||
|
||||
List<PageData> findByHiddenId(PageData pd);
|
||||
|
||||
void deleteByHiddenId(PageData pd);
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,67 @@
|
|||
package com.zcloud.mapper.datasource.hiddenDangerCheckStandard;
|
||||
|
||||
import com.zcloud.entity.Page;
|
||||
import com.zcloud.entity.PageData;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 说明：隐患 相关人员信息
|
||||
* 作者：luoxiaobao
|
||||
* 时间：2022-04-22
|
||||
* 官网：www.zcloudchina.com
|
||||
*/
|
||||
public interface CustomHiddenUserMapper {
|
||||
|
||||
/**新增
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
void save(PageData pd);
|
||||
|
||||
/**删除
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
void delete(PageData pd);
|
||||
|
||||
/**修改
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
void edit(PageData pd);
|
||||
|
||||
/**列表
|
||||
* @param page
|
||||
* @throws Exception
|
||||
*/
|
||||
List<PageData> datalistPage(Page page);
|
||||
|
||||
/**列表(全部)
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
List<PageData> listAll(PageData pd);
|
||||
List<PageData> listAllUser(PageData pd);
|
||||
|
||||
/**通过id获取数据
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
PageData findById(PageData pd);
|
||||
|
||||
/**批量删除
|
||||
* @param ArrayDATA_IDS
|
||||
* @throws Exception
|
||||
*/
|
||||
void deleteAll(String[] ArrayDATA_IDS);
|
||||
|
||||
/**
|
||||
* 根据隐患id删除
|
||||
* @param pd
|
||||
*/
|
||||
void deleteByHidden (PageData pd);
|
||||
|
||||
List<PageData> verifylist(PageData pd);
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,121 @@
|
|||
package com.zcloud.service.hiddenDangerCheckStandard;
|
||||
|
||||
import com.zcloud.entity.Page;
|
||||
import com.zcloud.entity.PageData;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 说明：隐患审核
|
||||
* 作者：luoxiaobao
|
||||
* 时间：2022-04-14
|
||||
* 官网：www.zcloudchina.com
|
||||
*/
|
||||
public interface CustomHiddenExamineService {
|
||||
|
||||
/**新增
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public PageData save(PageData pd)throws Exception;
|
||||
PageData appSave(PageData pd) throws Exception;
|
||||
|
||||
|
||||
/**手机端打回保存
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void saverepulse(PageData pd)throws Exception;
|
||||
|
||||
/**删除
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void delete(PageData pd)throws Exception;
|
||||
|
||||
/**修改
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void edit(PageData pd)throws Exception;
|
||||
|
||||
/**修改确认打回的信息
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void editrepulse(PageData pd)throws Exception;
|
||||
|
||||
/**列表
|
||||
* @param page
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> list(Page page)throws Exception;
|
||||
|
||||
/**列表(全部)
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> listAll(PageData pd)throws Exception;
|
||||
|
||||
/**查询隐患确认打回的数据
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> findByHiddenId(PageData pd)throws Exception;
|
||||
|
||||
|
||||
/**通过id获取数据
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public PageData findById(PageData pd)throws Exception;
|
||||
|
||||
/**批量删除
|
||||
* @param ArrayDATA_IDS
|
||||
* @throws Exception
|
||||
*/
|
||||
public void deleteAll(String[] ArrayDATA_IDS)throws Exception;
|
||||
|
||||
/**列表(全部)
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> listAllByHiddenId(String hiddenId)throws Exception;
|
||||
|
||||
|
||||
/** 特殊审核通过的时候使用，存意见 和 附件
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void updateBySpecial(PageData pd)throws Exception;
|
||||
|
||||
/**列表
|
||||
* @param page
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> listAndHidden(Page page)throws Exception;
|
||||
|
||||
/**通过id获取数据
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public PageData findByIdAndHidden(PageData pd)throws Exception;
|
||||
|
||||
public PageData saveApp(PageData pd)throws Exception;
|
||||
|
||||
/**通过隐患id删除数据
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void deleteByHiddenId(PageData pd)throws Exception;
|
||||
|
||||
/**
|
||||
* pc的隐患确认信息初始化
|
||||
* @param pd
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public PageData saveConfirm(PageData pd)throws Exception;
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,95 @@
|
|||
package com.zcloud.service.hiddenDangerCheckStandard;
|
||||
|
||||
import com.zcloud.entity.Page;
|
||||
import com.zcloud.entity.PageData;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 说明：隐患 相关人员信息
|
||||
* 作者：luoxiaobao
|
||||
* 时间：2022-04-22
|
||||
* 官网：www.zcloudchina.com
|
||||
*/
|
||||
public interface CustomHiddenUserService {
|
||||
|
||||
/**新增
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void save(PageData pd)throws Exception;
|
||||
|
||||
/**删除
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void delete(PageData pd)throws Exception;
|
||||
|
||||
/**修改
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void edit(PageData pd)throws Exception;
|
||||
|
||||
/**列表
|
||||
* @param page
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> list(Page page)throws Exception;
|
||||
|
||||
/**列表(全部)
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> listAll(PageData pd)throws Exception;
|
||||
|
||||
/**通过id获取数据
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public PageData findById(PageData pd)throws Exception;
|
||||
|
||||
/**批量删除
|
||||
* @param ArrayDATA_IDS
|
||||
* @throws Exception
|
||||
*/
|
||||
public void deleteAll(String[] ArrayDATA_IDS)throws Exception;
|
||||
|
||||
/**
|
||||
* 添加隐患整改人
|
||||
* @throws Exception
|
||||
*/
|
||||
public void saveRectificationo (String userIds ,String hiddenId ,String type)throws Exception;
|
||||
|
||||
/**
|
||||
* 根据隐患ids获取隐患相关人员
|
||||
* @param hiddenIds
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> getHiddenUserByHiddenIds (String [] hiddenIds ,String type) throws Exception;
|
||||
|
||||
/**
|
||||
* 获取隐患发现人
|
||||
* @param varList
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> getHiddebFind (List<PageData> varList) throws Exception;
|
||||
|
||||
/**
|
||||
* 获取安全管理部门责任人
|
||||
* @param pd
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> verifylist(PageData pd) throws Exception;
|
||||
|
||||
/**
|
||||
* 根据隐患id删除
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
void deleteByHidden (PageData pd) throws Exception;
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,190 @@
|
|||
package com.zcloud.service.hiddenDangerCheckStandard.impl;
|
||||
|
||||
import com.zcloud.entity.Page;
|
||||
import com.zcloud.entity.PageData;
|
||||
import com.zcloud.mapper.datasource.bus.HiddenExamineMapper;
|
||||
import com.zcloud.mapper.datasource.hiddenDangerCheckStandard.CustomHiddenExamineMapper;
|
||||
import com.zcloud.service.bus.HiddenExamineService;
|
||||
import com.zcloud.service.hiddenDangerCheckStandard.CustomHiddenExamineService;
|
||||
import com.zcloud.util.DateUtil;
|
||||
import com.zcloud.util.Jurisdiction;
|
||||
import com.zcloud.util.UuidUtil;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 说明：隐患审核
|
||||
* 作者：luoxiaobao
|
||||
* 时间：2022-04-14
|
||||
* 官网：www.zcloudchina.com
|
||||
*/
|
||||
@Service
|
||||
@Transactional //开启事物
|
||||
public class CustomHiddenExamineServiceImpl implements CustomHiddenExamineService {
|
||||
|
||||
@Resource
|
||||
private CustomHiddenExamineMapper customHiddenExamineMapper;
|
||||
/**新增
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public PageData save(PageData pd)throws Exception{
|
||||
pd.put("HIDDENEXAMINE_ID", UuidUtil.get32UUID());
|
||||
pd.put("CREATOR", Jurisdiction.getUSER_ID());
|
||||
pd.put("CREATTIME", DateUtil.date2Str(new Date()));
|
||||
pd.put("OPERATOR",Jurisdiction.getUSER_ID());
|
||||
pd.put("OPERATTIME",DateUtil.date2Str(new Date()));
|
||||
customHiddenExamineMapper.save(pd);
|
||||
return pd;
|
||||
}
|
||||
|
||||
/**手机端打回保存
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void saverepulse(PageData pd)throws Exception{
|
||||
customHiddenExamineMapper.save(pd);
|
||||
}
|
||||
|
||||
/**删除
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void delete(PageData pd)throws Exception{
|
||||
customHiddenExamineMapper.delete(pd);
|
||||
}
|
||||
|
||||
/**修改
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void edit(PageData pd)throws Exception{
|
||||
// pd.put("OPERATOR",Jurisdiction.getUSER_ID());
|
||||
// pd.put("OPERATTIME",DateUtil.date2Str(new Date()));
|
||||
customHiddenExamineMapper.edit(pd);
|
||||
}
|
||||
|
||||
/**修改确认打回的信息
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void editrepulse(PageData pd)throws Exception{
|
||||
customHiddenExamineMapper.editrepulse(pd);
|
||||
}
|
||||
|
||||
/**列表
|
||||
* @param page
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> list(Page page)throws Exception{
|
||||
return customHiddenExamineMapper.datalistPage(page);
|
||||
}
|
||||
|
||||
/**列表(全部)
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> listAll(PageData pd)throws Exception{
|
||||
return customHiddenExamineMapper.listAll(pd);
|
||||
}
|
||||
|
||||
/**查询隐患确认打回的数据
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> findByHiddenId(PageData pd)throws Exception{
|
||||
return customHiddenExamineMapper.findByHiddenId(pd);
|
||||
}
|
||||
|
||||
/**通过id获取数据
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public PageData findById(PageData pd)throws Exception{
|
||||
return customHiddenExamineMapper.findById(pd);
|
||||
}
|
||||
|
||||
/**批量删除
|
||||
* @param ArrayDATA_IDS
|
||||
* @throws Exception
|
||||
*/
|
||||
public void deleteAll(String[] ArrayDATA_IDS)throws Exception{
|
||||
customHiddenExamineMapper.deleteAll(ArrayDATA_IDS);
|
||||
}
|
||||
public List<PageData> listAllByHiddenId(String hiddenId)throws Exception{
|
||||
PageData pd = new PageData();
|
||||
pd.put("HIDDEN_ID",hiddenId);
|
||||
return customHiddenExamineMapper.listAll(pd);
|
||||
}
|
||||
public void updateBySpecial(PageData pd)throws Exception{
|
||||
customHiddenExamineMapper.updateBySpecial(pd);
|
||||
}
|
||||
|
||||
/**列表
|
||||
* @param page
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> listAndHidden(Page page)throws Exception{
|
||||
return customHiddenExamineMapper.listAndHiddendatalistPage(page);
|
||||
}
|
||||
/**通过id获取数据
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public PageData findByIdAndHidden(PageData pd)throws Exception{
|
||||
return customHiddenExamineMapper.findByIdAndHidden(pd);
|
||||
}
|
||||
public PageData saveApp(PageData pd)throws Exception{
|
||||
pd.put("HIDDENEXAMINE_ID", UuidUtil.get32UUID());
|
||||
pd.put("CREATTIME", DateUtil.date2Str(new Date()));
|
||||
pd.put("OPERATTIME",DateUtil.date2Str(new Date()));
|
||||
customHiddenExamineMapper.save(pd);
|
||||
return pd;
|
||||
}
|
||||
|
||||
public PageData appSave(PageData pd)throws Exception{
|
||||
pd.put("HIDDENEXAMINE_ID", UuidUtil.get32UUID());
|
||||
pd.put("CREATOR", pd.getString("CREATOR"));
|
||||
pd.put("CREATTIME", DateUtil.date2Str(new Date()));
|
||||
pd.put("OPERATOR",pd.getString("OPERATOR"));
|
||||
pd.put("OPERATTIME",DateUtil.date2Str(new Date()));
|
||||
customHiddenExamineMapper.save(pd);
|
||||
return pd;
|
||||
}
|
||||
|
||||
public void deleteByHiddenId(PageData pd)throws Exception{
|
||||
customHiddenExamineMapper.deleteByHiddenId(pd);
|
||||
}
|
||||
/**
|
||||
* pc的隐患确认信息初始化
|
||||
* 需求：隐患确认之后，显示隐患发现人填入的隐患等级等信息
|
||||
* @param pd
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public PageData saveConfirm(PageData pd)throws Exception{
|
||||
|
||||
PageData before = new PageData();// 添加隐患初始信息
|
||||
before.put("TYPE","0"); //.0.隐患开始数据;1.特殊审核;2.延期审核 3.验收打回。4.隐患确认记录,.5重大隐患修改，6确认时打回;
|
||||
before.put("STATE","2");//是否通过审核 ,1未通过。2通过 -1（初始）16隐患确认打回
|
||||
before.put("HIDDEN_ID",pd.get("HIDDEN_ID"));
|
||||
before.put("spare1",pd.getString("HIDDENLEVEL")); // 隐患级别
|
||||
before.put("spare2",pd.getString("RECTIFICATIONOR"));//整改负责人
|
||||
before.put("spare3",pd.getString("RECTIFICATIONDEADLINE")); //整改完成期限
|
||||
before.put("spare4",pd.getString("RECTIFICATIONDEPT")); //整改负责人部门
|
||||
|
||||
before.put("HIDDENEXAMINE_ID", UuidUtil.get32UUID());
|
||||
before.put("CREATOR", Jurisdiction.getUSER_ID());
|
||||
before.put("CREATTIME", DateUtil.date2Str(new Date()));
|
||||
before.put("OPERATOR",Jurisdiction.getUSER_ID());
|
||||
before.put("OPERATTIME",DateUtil.date2Str(new Date()));
|
||||
|
||||
customHiddenExamineMapper.save(before);
|
||||
return pd;
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -0,0 +1,196 @@
|
|||
package com.zcloud.service.hiddenDangerCheckStandard.impl;
|
||||
|
||||
import com.zcloud.entity.Page;
|
||||
import com.zcloud.entity.PageData;
|
||||
import com.zcloud.mapper.datasource.hiddenDangerCheckStandard.CustomHiddenUserMapper;
|
||||
import com.zcloud.service.hiddenDangerCheckStandard.CustomHiddenUserService;
|
||||
import com.zcloud.util.Jurisdiction;
|
||||
import com.zcloud.util.Tools;
|
||||
import com.zcloud.util.UuidUtil;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* 说明：隐患 相关人员信息
|
||||
* 作者：luoxiaobao
|
||||
* 时间：2022-04-22
|
||||
* 官网：www.zcloudchina.com
|
||||
*/
|
||||
@Service
|
||||
@Transactional //开启事物
|
||||
public class CustomHiddenUserServiceImpl implements CustomHiddenUserService {
|
||||
|
||||
@Autowired
|
||||
private CustomHiddenUserMapper customHiddenUserMapper;
|
||||
|
||||
/**新增
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void save(PageData pd)throws Exception{
|
||||
customHiddenUserMapper.save(pd);
|
||||
}
|
||||
|
||||
/**删除
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void delete(PageData pd)throws Exception{
|
||||
customHiddenUserMapper.delete(pd);
|
||||
}
|
||||
|
||||
/**修改
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public void edit(PageData pd)throws Exception{
|
||||
customHiddenUserMapper.edit(pd);
|
||||
}
|
||||
|
||||
/**列表
|
||||
* @param page
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> list(Page page)throws Exception{
|
||||
return customHiddenUserMapper.datalistPage(page);
|
||||
}
|
||||
|
||||
/**列表(全部)
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> listAll(PageData pd)throws Exception{
|
||||
return customHiddenUserMapper.listAll(pd);
|
||||
}
|
||||
|
||||
/**通过id获取数据
|
||||
* @param pd
|
||||
* @throws Exception
|
||||
*/
|
||||
public PageData findById(PageData pd)throws Exception{
|
||||
return customHiddenUserMapper.findById(pd);
|
||||
}
|
||||
|
||||
/**批量删除
|
||||
* @param ArrayDATA_IDS
|
||||
* @throws Exception
|
||||
*/
|
||||
public void deleteAll(String[] ArrayDATA_IDS)throws Exception{
|
||||
customHiddenUserMapper.deleteAll(ArrayDATA_IDS);
|
||||
}
|
||||
|
||||
/**
|
||||
* 添加隐患相关人员信息 -- 有主要处理人
|
||||
* @param userIds 用户ids
|
||||
* @param hiddenId 隐患id
|
||||
* @param type 类别
|
||||
* @throws Exception
|
||||
*/
|
||||
public void saveRectificationo(String userIds ,String hiddenId,String type)throws Exception{
|
||||
if(!Tools.isEmpty(hiddenId)){
|
||||
PageData del = new PageData();
|
||||
del.put("TYPE",type);
|
||||
del.put("HIDDEN_ID",hiddenId);
|
||||
customHiddenUserMapper.deleteByHidden(del); // 先删除后添加
|
||||
}
|
||||
if(!Tools.isEmpty(userIds)){
|
||||
String removeLoginUser = userIds.replaceAll(Jurisdiction.getUSER_ID(),""); //去除当前登录人的用户id
|
||||
String userID [] = removeLoginUser.split(",");
|
||||
for (int i =0;i<userID.length;i++){
|
||||
if(!Tools.isEmpty(userID[i])){
|
||||
PageData pd = new PageData();
|
||||
pd.put("HIDDENUSER_ID", UuidUtil.get32UUID());
|
||||
pd.put("HIDDEN_ID",hiddenId);
|
||||
pd.put("USER_ID",userID[i]);
|
||||
pd.put("TYPE",type);
|
||||
pd.put("IS_MAIN","0");
|
||||
customHiddenUserMapper.save(pd);
|
||||
}
|
||||
}
|
||||
}
|
||||
PageData pd = new PageData();
|
||||
pd.put("HIDDENUSER_ID", UuidUtil.get32UUID());
|
||||
pd.put("HIDDEN_ID",hiddenId);
|
||||
pd.put("USER_ID",Jurisdiction.getUSER_ID());
|
||||
pd.put("TYPE",type);
|
||||
pd.put("IS_MAIN","1");
|
||||
customHiddenUserMapper.save(pd);
|
||||
}
|
||||
/**
|
||||
* 根据隐患ids获取隐患相关人员
|
||||
* @param hiddenIds
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> getHiddenUserByHiddenIds (String [] hiddenIds ,String type) throws Exception{
|
||||
PageData pageData = new PageData();
|
||||
pageData.put("TYPE",type);
|
||||
if(hiddenIds.length>0){
|
||||
pageData.put("hiddenIds",hiddenIds);
|
||||
}
|
||||
return customHiddenUserMapper.listAllUser(pageData);
|
||||
}
|
||||
/**
|
||||
* 获取隐患发现人
|
||||
* @param varList
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public List<PageData> getHiddebFind (List<PageData> varList) throws Exception{
|
||||
if(varList.size() == 0){
|
||||
return varList;
|
||||
}
|
||||
Map<String,Integer> mapKey = new HashMap<>();
|
||||
String [] hiddenIds = new String[varList.size()];
|
||||
for (int i =0 ;i<varList.size();i++){
|
||||
hiddenIds[i] = varList.get(i).getString("HIDDEN_ID");
|
||||
mapKey.put(varList.get(i).getString("HIDDEN_ID"),i);
|
||||
}
|
||||
|
||||
List<PageData> hiddenFindUserList = this.getHiddenUserByHiddenIds(hiddenIds,"1");
|
||||
Map<String,Object> hiddenUserMap = new HashMap<>();
|
||||
for (PageData pageData : hiddenFindUserList){
|
||||
String hiddenId = pageData.getString("HIDDEN_ID");
|
||||
String userName = pageData.getString("NAME") +";";
|
||||
String deptName = pageData.getString("deptName")+";";
|
||||
if(hiddenUserMap.containsKey(hiddenId + "findUserNames")){
|
||||
userName += hiddenUserMap.get(hiddenId +"findUserNames");
|
||||
deptName += hiddenUserMap.get(hiddenId +"findDeptNames");
|
||||
}
|
||||
hiddenUserMap.put(hiddenId +"findUserNames",userName);
|
||||
hiddenUserMap.put(hiddenId +"findDeptNames",deptName);
|
||||
}
|
||||
for (PageData pageData:varList){
|
||||
String hiddenId = pageData.getString("HIDDEN_ID");
|
||||
if(hiddenUserMap.containsKey(hiddenId + "findUserNames")){
|
||||
pageData.put("findUserNames" ,hiddenUserMap.get(hiddenId + "findUserNames") );
|
||||
if(pageData.getString("findUserNames").lastIndexOf(";") == pageData.getString("findUserNames").length() - 1){ //判断最后一个的索引是否是；
|
||||
pageData.put("findUserNames" ,pageData.getString("findUserNames").substring(0,pageData.getString("findUserNames").length() - 1));
|
||||
}
|
||||
}
|
||||
if(hiddenUserMap.containsKey(hiddenId + "findDeptNames")){
|
||||
pageData.put("findDeptNames" ,hiddenUserMap.get(hiddenId + "findDeptNames") );
|
||||
if(pageData.getString("findDeptNames").lastIndexOf(";") == pageData.getString("findDeptNames").length() - 1){ //判断最后一个的索引是否是；
|
||||
pageData.put("findDeptNames" ,pageData.getString("findDeptNames").substring(0,pageData.getString("findDeptNames").length() - 1));
|
||||
}
|
||||
}
|
||||
}
|
||||
return varList;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<PageData> verifylist(PageData pd) throws Exception {
|
||||
return customHiddenUserMapper.verifylist(pd);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteByHidden(PageData pd) throws Exception {
|
||||
customHiddenUserMapper.deleteByHidden(pd);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -114,6 +114,9 @@
|
|||
<include refid="tableName"></include>
|
||||
set
|
||||
ISNORMAL = #{ISNORMAL},
|
||||
<if test="CHECK_RESULT != null"><!-- 检查结果 -->
|
||||
CHECK_RESULT = #{CHECK_RESULT},
|
||||
</if>
|
||||
LONGITUDE=#{LONGITUDE},
|
||||
LATITUDE=#{LATITUDE}
|
||||
where
|
||||
|
|
|
|||
|
|
@ -0,0 +1,427 @@
|
|||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.zcloud.mapper.datasource.hiddenDangerCheckStandard.CustomHiddenExamineMapper">
|
||||
|
||||
<!--表名 -->
|
||||
<sql id="tableName">
|
||||
BUS_HIDDENDANGERCHECKSTANDARD_HIDDENEXAMINE
|
||||
</sql>
|
||||
|
||||
<!--数据字典表名 -->
|
||||
<sql id="dicTableName">
|
||||
SYS_DICTIONARIES
|
||||
</sql>
|
||||
|
||||
<!-- 字段 -->
|
||||
<sql id="Field">
|
||||
f.HIDDEN_ID,
|
||||
f.EXAMINE,
|
||||
f.CREATOR,
|
||||
f.CREATTIME,
|
||||
f.OPERATOR,
|
||||
f.OPERATTIME,
|
||||
f.STATE,
|
||||
f.TYPE,
|
||||
f.DISPOSAL_PLAN,
|
||||
f.DISPOSAL_FILE,
|
||||
f.DELAY_TIME,
|
||||
f.spare1,
|
||||
f.spare2,
|
||||
f.spare3,
|
||||
f.spare4,
|
||||
f.spare5,
|
||||
f.HIDDENEXAMINE_ID,
|
||||
f.REPULSE_CAUSE
|
||||
</sql>
|
||||
|
||||
<!-- 字段用于新增 -->
|
||||
<sql id="Field2">
|
||||
HIDDEN_ID,
|
||||
EXAMINE,
|
||||
CREATOR,
|
||||
CREATTIME,
|
||||
OPERATOR,
|
||||
OPERATTIME,
|
||||
STATE,
|
||||
TYPE,
|
||||
DISPOSAL_PLAN,
|
||||
DISPOSAL_FILE,
|
||||
DELAY_TIME,
|
||||
spare1,
|
||||
spare2,
|
||||
spare3,
|
||||
spare4,
|
||||
spare5,
|
||||
HIDDENEXAMINE_ID,
|
||||
REPULSE_CAUSE
|
||||
</sql>
|
||||
|
||||
<!-- 字段值 -->
|
||||
<sql id="FieldValue">
|
||||
#{HIDDEN_ID},
|
||||
#{EXAMINE},
|
||||
#{CREATOR},
|
||||
#{CREATTIME},
|
||||
#{OPERATOR},
|
||||
#{OPERATTIME},
|
||||
#{STATE},
|
||||
#{TYPE},
|
||||
#{DISPOSAL_PLAN},
|
||||
#{DISPOSAL_FILE},
|
||||
#{DELAY_TIME},
|
||||
#{spare1},
|
||||
#{spare2},
|
||||
#{spare3},
|
||||
#{spare4},
|
||||
#{spare5},
|
||||
#{HIDDENEXAMINE_ID},
|
||||
#{REPULSE_CAUSE}
|
||||
</sql>
|
||||
|
||||
<!-- 新增-->
|
||||
<insert id="save" parameterType="pd">
|
||||
insert into
|
||||
<include refid="tableName"></include>
|
||||
(
|
||||
<include refid="Field2"></include>
|
||||
) values (
|
||||
<include refid="FieldValue"></include>
|
||||
)
|
||||
</insert>
|
||||
|
||||
<!-- 删除-->
|
||||
<delete id="delete" parameterType="pd">
|
||||
update
|
||||
<include refid="tableName"></include>
|
||||
set
|
||||
ISDELETE = '1'
|
||||
where
|
||||
HIDDENEXAMINE_ID = #{HIDDENEXAMINE_ID}
|
||||
</delete>
|
||||
|
||||
<delete id="deleteByHiddenId" parameterType="pd">
|
||||
delete from
|
||||
<include refid="tableName"></include>
|
||||
where
|
||||
HIDDEN_ID = #{HIDDEN_ID}
|
||||
</delete>
|
||||
|
||||
<!-- 修改 -->
|
||||
<update id="edit" parameterType="pd">
|
||||
update
|
||||
<include refid="tableName"></include>
|
||||
set
|
||||
OPERATOR = #{OPERATOR},
|
||||
OPERATTIME = #{OPERATTIME},
|
||||
STATE = #{STATE}
|
||||
where
|
||||
HIDDENEXAMINE_ID = #{HIDDENEXAMINE_ID}
|
||||
</update>
|
||||
|
||||
<!-- 修改确认打回的信息 -->
|
||||
<update id="editrepulse" parameterType="pd">
|
||||
update
|
||||
<include refid="tableName"></include> f
|
||||
set
|
||||
f.spare5 = 1
|
||||
where
|
||||
HIDDENEXAMINE_ID = #{HIDDENEXAMINE_ID}
|
||||
</update>
|
||||
|
||||
<!-- 通过ID获取数据 -->
|
||||
<select id="findById" parameterType="pd" resultType="pd">
|
||||
select
|
||||
<include refid="Field"></include>
|
||||
from
|
||||
<include refid="tableName"></include> f
|
||||
where
|
||||
f.HIDDENEXAMINE_ID = #{HIDDENEXAMINE_ID}
|
||||
</select>
|
||||
|
||||
<!-- 通过ID获取数据 -->
|
||||
<select id="findByHiddenId" parameterType="pd" resultType="pd">
|
||||
select
|
||||
<include refid="Field"></include>
|
||||
from
|
||||
<include refid="tableName"></include> f
|
||||
where
|
||||
f.HIDDEN_ID = #{HIDDEN_ID}
|
||||
and f.TYPE = '6'
|
||||
and f.STATE = '16'
|
||||
</select>
|
||||
|
||||
<!-- 列表 -->
|
||||
<select id="datalistPage" parameterType="page" resultType="pd">
|
||||
select
|
||||
<include refid="Field"></include>
|
||||
from
|
||||
<include refid="tableName"></include> f
|
||||
where f.ISDELETE = '0'
|
||||
<if test="pd.KEYWORDS != null and pd.KEYWORDS != ''"><!-- 关键词检索 -->
|
||||
and
|
||||
(
|
||||
<!-- 根据需求自己加检索条件
|
||||
字段1 LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')
|
||||
or
|
||||
字段2 LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')
|
||||
-->
|
||||
)
|
||||
</if>
|
||||
order by f.STATE desc , CREATTIME desc
|
||||
</select>
|
||||
|
||||
<!-- 列表(全部) -->
|
||||
<select id="listAll" parameterType="pd" resultType="pd">
|
||||
select
|
||||
f.HIDDEN_ID,
|
||||
f.EXAMINE,
|
||||
f.CREATOR,
|
||||
f.CREATTIME,
|
||||
f.OPERATOR,
|
||||
f.OPERATTIME,
|
||||
f.STATE,
|
||||
f.TYPE,
|
||||
f.DISPOSAL_PLAN,
|
||||
f.DISPOSAL_FILE,
|
||||
f.DELAY_TIME,
|
||||
f.spare1,
|
||||
f.spare2,
|
||||
|
||||
f.spare4,
|
||||
f.spare5,
|
||||
f.HIDDENEXAMINE_ID,
|
||||
f.REPULSE_CAUSE,
|
||||
<!--, user.name as editUserName-->
|
||||
dept.name as editDeptName
|
||||
, LEVEL.name as editLevelName
|
||||
, users.NAME as NEWRECTIFICATIONOR
|
||||
,exa.RECTIFICATIONDEADLINE as spare3
|
||||
,re.name as editUserName
|
||||
from
|
||||
<include refid="tableName"></include> f
|
||||
LEFT JOIN sys_user user on user.USER_ID = f.spare2
|
||||
LEFT JOIN sys_user users on users.USER_ID = f.NEW_RECTIFICATIONOR
|
||||
LEFT JOIN oa_department dept on dept.DEPARTMENT_ID = f.spare4
|
||||
LEFT JOIN sys_dictionaries LEVEL on LEVEL.BIANMA = f.spare1
|
||||
LEFT JOIN BUS_HIDDEN exa ON f.HIDDEN_ID = exa.HIDDEN_ID
|
||||
LEFT JOIN sys_user re ON re.USER_ID = exa.RECTIFICATIONOR
|
||||
where 1=1
|
||||
<if test="HIDDEN_ID != null and HIDDEN_ID != ''">
|
||||
and f.HIDDEN_ID = #{HIDDEN_ID}
|
||||
</if>
|
||||
<if test="TYPE != null and TYPE != ''">
|
||||
and f.TYPE = #{TYPE}
|
||||
</if>
|
||||
<if test="STATE != null and STATE != ''">
|
||||
and f.STATE = #{STATE}
|
||||
</if>
|
||||
order by field (f.TYPE ,'0','4') desc ,CREATTIME
|
||||
</select>
|
||||
|
||||
<!-- 批量删除 -->
|
||||
<delete id="deleteAll" parameterType="String">
|
||||
update
|
||||
set
|
||||
ISDELETE = '1'
|
||||
where
|
||||
HIDDENEXAMINE_ID in
|
||||
<foreach item="item" index="index" collection="ArrayDATA_IDS" open="(" separator="," close=")">
|
||||
#{item}
|
||||
</foreach>
|
||||
</delete>
|
||||
<update id="updateBySpecial" parameterType="pd">
|
||||
update
|
||||
<include refid="tableName"></include>
|
||||
set
|
||||
OPERATOR = #{OPERATOR},
|
||||
OPERATTIME = #{OPERATTIME},
|
||||
STATE = #{STATE},
|
||||
DISPOSAL_PLAN = #{DISPOSAL_PLAN},
|
||||
DISPOSAL_FILE = #{DISPOSAL_FILE}
|
||||
<if test="spare1 != null and spare1 != ''">
|
||||
, spare1 = #{spare1}
|
||||
</if>
|
||||
<if test="spare2 != null and spare2 != ''">
|
||||
, spare2 = #{spare2}
|
||||
</if>
|
||||
<if test="spare3 != null and spare3 != ''">
|
||||
, spare3 = #{spare3}
|
||||
</if>
|
||||
<if test="spare4 != null and spare4 != ''">
|
||||
, spare4 = #{spare4}
|
||||
</if>
|
||||
<if test="NEW_RECTIFICATIONOR != null and NEW_RECTIFICATIONOR != ''">
|
||||
, NEW_RECTIFICATIONOR = #{NEW_RECTIFICATIONOR}
|
||||
</if>
|
||||
where
|
||||
HIDDENEXAMINE_ID = #{HIDDENEXAMINE_ID}
|
||||
</update>
|
||||
<select id="listAndHiddendatalistPage" parameterType="page" resultType="pd">
|
||||
select
|
||||
f.*
|
||||
,exa.DISPOSAL_PLAN
|
||||
,exa.HIDDENEXAMINE_ID
|
||||
,re.NAME as RECTIFICATIONORNAME
|
||||
,confirmUser.NAME as confirmUserName
|
||||
,hiddenType.NAME as hiddenTypeName
|
||||
,hregion.HIDDENREGION as hregionName
|
||||
,lv.NAME as HIDDENLEVELNAME
|
||||
,exa.STATE as exaSTATE
|
||||
from
|
||||
BUS_HIDDENEXAMINE exa
|
||||
left join BUS_HIDDEN f on exa.HIDDEN_ID =f.HIDDEN_ID
|
||||
LEFT JOIN sys_user confirmUser on confirmUser.USER_ID = f.CONFIRM_USER <!-- 隐患确认人 -->
|
||||
left join <include refid="dicTableName"></include> lv on f.HIDDENLEVEL = lv.BIANMA
|
||||
left join <include refid="dicTableName"></include> hiddenType on f.HIDDENTYPE = hiddenType.BIANMA <!-- 隐患类型-->
|
||||
left join sys_user re on re.USER_ID = f.RECTIFICATIONOR
|
||||
left join bus_hiddenregion hregion on hregion.HIDDENREGION_ID = f.HIDDENPART
|
||||
LEFT JOIN bus_hiddencheck hch on hch.HIDDEN_ID = f.HIDDEN_ID
|
||||
left join bus_hidden_user bhu on bhu.HIDDEN_ID = f.HIDDEN_ID
|
||||
where f.ISDELETE = '0'
|
||||
<if test='pd.roleLevel != null and pd.roleLevel != "" and pd.keyType !="2" and pd.keyIsSpecial !="2" '><!-- 权限显示 -->
|
||||
<choose>
|
||||
<when test='pd.roleLevel == "0" '>
|
||||
</when>
|
||||
<when test='pd.roleLevel == "1"'>
|
||||
and (confirmUser.DEPARTMENT_ID in (${pd.supDeparIds}) or bhu.DEPARTMENT_ID in (${pd.supDeparIds}) or f.RECTIFICATIONDEPT in (${pd.supDeparIds}) or hch.DEPARTMENT_ID in (${pd.supDeparIds}))
|
||||
</when>
|
||||
<when test='pd.roleLevel == "2"'>
|
||||
and (bhu.USER_ID =#{pd.loginUserId} or f.CONFIRM_USER = #{pd.loginUserId} or f.RECTIFICATIONOR = #{pd.loginUserId} or f.CHECKOR = #{pd.loginUserId} )
|
||||
</when>
|
||||
</choose>
|
||||
</if>
|
||||
and f.state != '0'
|
||||
and f.state not in ('100','101','102')
|
||||
and f.CORPINFO_ID = #{pd.CORPINFO_ID}
|
||||
<if test='pd.stateConfirm != null and pd.stateConfirm != "" and pd.stateConfirm == "1"'><!-- 未确认确认隐患 -->
|
||||
and f.state = '-2'
|
||||
</if>
|
||||
<if test="pd.stateConfirm != null and pd.stateConfirm != '' and pd.stateConfirm == '2'"><!-- 确认确认隐患 -->
|
||||
and f.state != '-2'
|
||||
</if>
|
||||
<if test="pd.keySource != null and pd.keySource != '' "><!-- 隐患来源 -->
|
||||
<choose>
|
||||
<when test="pd.keySource == 1">
|
||||
AND f.SOURCE = '1'
|
||||
</when>
|
||||
<when test="pd.keySource == 2">
|
||||
AND f.SOURCE = '2'
|
||||
</when>
|
||||
<when test="pd.keySource == 4">
|
||||
AND f.SOURCE = '4'
|
||||
</when>
|
||||
<when test="pd.keySource == 5">
|
||||
AND f.SOURCE = '5'
|
||||
</when>
|
||||
<when test="pd.keySource == 6">
|
||||
AND f.SOURCE = '6'
|
||||
</when>
|
||||
</choose>
|
||||
</if>
|
||||
<!-- <if test="pd.SOURCE != null and pd.SOURCE != '' "><!– 隐患来源 –>-->
|
||||
<!-- and f.SOURCE in('2','3')-->
|
||||
<!-- </if>-->
|
||||
<if test="pd.keyHiddenDescr != null and pd.keyHiddenDescr != ''"><!-- 隐患描述 -->
|
||||
and (f.HIDDENDESCR LIKE CONCAT(CONCAT('%', #{pd.keyHiddenDescr}),'%'))
|
||||
</if>
|
||||
<if test="pd.keyFindUserName != null and pd.keyFindUserName != ''"><!-- 隐患发现人 -->
|
||||
and f.HIDDEN_ID in (select hfu.HIDDEN_ID from BUS_HIDDEN_USER hfu LEFT JOIN sys_user user on user.USER_ID = hfu.USER_ID where user.NAME LIKE CONCAT(CONCAT('%', #{pd.keyFindUserName}),'%') )
|
||||
</if>
|
||||
<if test="pd.keyFindUserDept != null and pd.keyFindUserDept != ''"><!-- 隐患发现部门 -->
|
||||
and f.HIDDEN_ID in (select hfu.HIDDEN_ID from BUS_HIDDEN_USER hfu LEFT JOIN sys_user user on user.USER_ID = hfu.USER_ID where user.DEPARTMENT_ID = #{pd.keyFindUserDept} )
|
||||
</if>
|
||||
<if test="pd.keyHiddenType != null and pd.keyHiddenType != ''"><!-- 隐患类型 -->
|
||||
and f.HIDDENTYPE = #{pd.keyHiddenType}
|
||||
</if>
|
||||
<if test="pd.keyHiddenPart != null and pd.keyHiddenPart != ''"><!-- 隐患部位 -->
|
||||
and f.HIDDENPART = #{pd.keyHiddenPart}
|
||||
</if>
|
||||
<if test="pd.keyHiddenlevel != null and pd.keyHiddenlevel != ''"><!-- 隐患级别 -->
|
||||
and f.HIDDENLEVEL = #{pd.keyHiddenlevel}
|
||||
</if>
|
||||
<if test='pd.CONFIRM_USER != null and pd.CONFIRM_USER != ""'><!-- 隐患确认人 -->
|
||||
and f.CONFIRM_USER = #{pd.CONFIRM_USER}
|
||||
</if>
|
||||
<!-- <if test="pd.keyFindEndTime != null and pd.keyFindEndTime != ''"><!– 隐患发现时间 –>-->
|
||||
<!-- and f.DISCOVERYTIME <= #{pd.keyFindEndTime}-->
|
||||
<!-- </if>-->
|
||||
<if test="pd.STARTTIME != null and pd.STARTTIME != ''"><!-- 隐患发现时间 -->
|
||||
and f.DISCOVERYTIME >= #{pd.STARTTIME}
|
||||
</if>
|
||||
<if test="pd.ENDTIME != null and pd.ENDTIME != ''">
|
||||
and f.DISCOVERYTIME <= #{pd.ENDTIME}
|
||||
</if>
|
||||
<if test="pd.keyConfirmUser != null and pd.keyConfirmUser != ''"><!-- 确认人 -->
|
||||
and (confirmUser.NAME LIKE CONCAT(CONCAT('%', #{pd.keyConfirmUser}),'%'))
|
||||
</if>
|
||||
<if test="pd.keyPrincipal != null and pd.keyPrincipal != ''"><!-- 确认人 -->
|
||||
and (re.NAME LIKE CONCAT(CONCAT('%', #{pd.keyPrincipal}),'%'))
|
||||
</if>
|
||||
<if test="pd.keyMajor != null and pd.keyMajor != ''"><!-- 重大隐患 -->
|
||||
and (lv.PARENT_ID = '5ff9daf78e9a4fb1b40d77980656799d' or lv.DICTIONARIES_ID='5ff9daf78e9a4fb1b40d77980656799d' )
|
||||
</if>
|
||||
<if test="pd.keyHiddenSpecialType != null and pd.keyHiddenSpecialType != ''">
|
||||
and f.HIDDEN_ID in (select hex.HIDDEN_ID from bus_hiddenexamine hex
|
||||
where hex.TYPE = #{pd.keyHiddenSpecialType} and hex.STATE ='1' )
|
||||
</if>
|
||||
<if test='pd.keyType != null and pd.keyType != "" '><!-- 是否是特殊处理隐患 -->
|
||||
and exa.TYPE = #{pd.keyType}
|
||||
</if>
|
||||
<if test='pd.keyIsSpecial != null and pd.keyIsSpecial != "" '><!-- 是否是特殊处理隐患 -->
|
||||
and exa.TYPE = #{pd.keyIsSpecial}
|
||||
</if>
|
||||
<if test='pd.keyHiddenStatus != null and pd.keyHiddenStatus != "" '><!-- 是否是特殊处理隐患 -->
|
||||
and f.STATE = #{pd.keyHiddenStatus}
|
||||
</if>
|
||||
GROUP BY exa.HIDDENEXAMINE_ID
|
||||
<!--order by exa.STATE , exa.CREATTIME desc -->
|
||||
order by
|
||||
FIELD ( exa.STATE, '-1' ) DESC,<!--根据bug7404进行的修改，首先的这个排序是有审核按钮的排在前面，这个条件根据前台得出的 -->
|
||||
f.CREATTIME DESC <!--没有审核按钮的按时间排序 -->
|
||||
|
||||
|
||||
</select>
|
||||
|
||||
<!-- 通过ID获取数据 -->
|
||||
<select id="findByIdAndHidden" parameterType="pd" resultType="pd">
|
||||
select
|
||||
f.*,
|
||||
cr.NAME CREATORNAME,
|
||||
re.NAME RECTIFICATIONORNAME,
|
||||
ch.NAME CHECKORNAME,
|
||||
crd.NAME HIDDENFINDDEPTNAME,
|
||||
red.NAME RECTIFICATIONDEPTNAME,
|
||||
chd.NAME CHECKDEPTNAME,
|
||||
lv.NAME HIDDENLEVELNAME,
|
||||
bc.LIST_NAME,
|
||||
lv.NAME HIDDENLEVELNAME,
|
||||
ht.NAME HIDDENTYPENAME,
|
||||
ht2.NAME HIDDENTYPENAME2,
|
||||
conUser.NAME as conUserName,
|
||||
hregion.HIDDENREGION as hregionName,
|
||||
exa.EXAMINE,
|
||||
exa.STATE AS exaState,
|
||||
exa.TYPE as exaType,
|
||||
exa.DISPOSAL_PLAN,
|
||||
exa.DISPOSAL_FILE,
|
||||
exa.DELAY_TIME,
|
||||
exa.HIDDENEXAMINE_ID
|
||||
from
|
||||
BUS_HIDDENEXAMINE exa
|
||||
left join BUS_HIDDEN f on exa.HIDDEN_ID =f.HIDDEN_ID
|
||||
left join sys_user cr on cr.USER_ID = f.CREATOR
|
||||
left join sys_user re on re.USER_ID = f.RECTIFICATIONOR
|
||||
left join sys_user ch on ch.USER_ID = f.CHECKOR
|
||||
left join sys_user conUser on conUser.USER_ID = f.CONFIRM_USER
|
||||
left join oa_department crd on crd.DEPARTMENT_ID = f.HIDDENFINDDEPT
|
||||
left join oa_department red on red.DEPARTMENT_ID = f.RECTIFICATIONDEPT
|
||||
left join oa_department chd on chd.DEPARTMENT_ID = f.CHECKDEPT
|
||||
left join bus_checkrecord bc on bc.CHECKRECORD_ID = f.CHECKRECORD_ID and bc.ISDELETE = 0
|
||||
left join <include refid="dicTableName"></include> lv on f.HIDDENLEVEL = lv.BIANMA
|
||||
left join <include refid="dicTableName"></include> ht on f.HIDDENTYPE = ht.BIANMA
|
||||
left join <include refid="dicTableName"></include> ht2 on f.HIDDENTYPE2 = ht2.BIANMA
|
||||
left join bus_hiddenregion hregion on hregion.HIDDENREGION_ID = f.HIDDENPART
|
||||
where
|
||||
exa.HIDDENEXAMINE_ID = #{HIDDENEXAMINE_ID}
|
||||
</select>
|
||||
</mapper>
|
||||
|
|
@ -0,0 +1,165 @@
|
|||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.zcloud.mapper.datasource.hiddenDangerCheckStandard.CustomHiddenUserMapper">
|
||||
|
||||
<!--表名 -->
|
||||
<sql id="tableName">
|
||||
BUS_HIDDENDANGERCHECKSTANDARD_HIDDEN_USER
|
||||
</sql>
|
||||
|
||||
<!--数据字典表名 -->
|
||||
<sql id="dicTableName">
|
||||
SYS_DICTIONARIES
|
||||
</sql>
|
||||
|
||||
<!-- 字段 -->
|
||||
<sql id="Field">
|
||||
f.HIDDEN_ID,
|
||||
f.USER_ID,
|
||||
f.TYPE,
|
||||
f.IS_MAIN,
|
||||
f.HIDDENUSER_ID
|
||||
</sql>
|
||||
|
||||
<!-- 字段用于新增 -->
|
||||
<sql id="Field2">
|
||||
HIDDEN_ID,
|
||||
USER_ID,
|
||||
TYPE,
|
||||
IS_MAIN,
|
||||
HIDDENUSER_ID
|
||||
</sql>
|
||||
|
||||
<!-- 字段值 -->
|
||||
<sql id="FieldValue">
|
||||
#{HIDDEN_ID},
|
||||
#{USER_ID},
|
||||
#{TYPE},
|
||||
#{IS_MAIN},
|
||||
#{HIDDENUSER_ID}
|
||||
</sql>
|
||||
|
||||
<!-- 新增-->
|
||||
<insert id="save" parameterType="pd">
|
||||
insert into
|
||||
<include refid="tableName"></include>
|
||||
(
|
||||
<include refid="Field2"></include>
|
||||
) values (
|
||||
<include refid="FieldValue"></include>
|
||||
)
|
||||
</insert>
|
||||
|
||||
<!-- 删除-->
|
||||
<delete id="delete" parameterType="pd">
|
||||
delete from <include refid="tableName"></include> where HIDDEN_ID = #{HIDDEN_ID}
|
||||
</delete>
|
||||
|
||||
<!-- 修改 -->
|
||||
<update id="edit" parameterType="pd">
|
||||
update
|
||||
<include refid="tableName"></include>
|
||||
set
|
||||
HIDDEN_ID = #{HIDDEN_ID},
|
||||
USER_ID = #{USER_ID},
|
||||
TYPE = #{TYPE},
|
||||
IS_MAIN = #{IS_MAIN},
|
||||
HIDDENUSER_ID = HIDDENUSER_ID
|
||||
where
|
||||
HIDDENUSER_ID = #{HIDDENUSER_ID}
|
||||
</update>
|
||||
|
||||
<!-- 通过ID获取数据 -->
|
||||
<select id="findById" parameterType="pd" resultType="pd">
|
||||
select
|
||||
<include refid="Field"></include>
|
||||
from
|
||||
<include refid="tableName"></include> f
|
||||
where
|
||||
f.HIDDENUSER_ID = #{HIDDENUSER_ID}
|
||||
</select>
|
||||
|
||||
<!-- 列表 -->
|
||||
<select id="datalistPage" parameterType="page" resultType="pd">
|
||||
select
|
||||
<include refid="Field"></include>
|
||||
from
|
||||
<include refid="tableName"></include> f
|
||||
where f.ISDELETE = '0'
|
||||
</select>
|
||||
|
||||
<!-- 列表(全部) -->
|
||||
<select id="listAll" parameterType="pd" resultType="pd">
|
||||
select
|
||||
<include refid="Field"></include>, u.* ,dept.NAME as deptName
|
||||
from
|
||||
<include refid="tableName"></include> f
|
||||
left join sys_user u on u.USER_ID = f.USER_ID
|
||||
left join oa_department dept on dept.DEPARTMENT_ID = u.DEPARTMENT_ID
|
||||
where 1=1
|
||||
<if test="TYPE != null and TYPE != ''"><!-- 关键词检索 -->
|
||||
and TYPE = #{TYPE}
|
||||
</if>
|
||||
<if test="hiddenIds != null and hiddenIds != ''">
|
||||
and HIDDEN_ID in
|
||||
<foreach item="item" index="index" collection="hiddenIds" open="(" separator="," close=")">
|
||||
#{item}
|
||||
</foreach>
|
||||
</if>
|
||||
<if test="HIDDEN_ID != null and HIDDEN_ID != ''">
|
||||
and HIDDEN_ID = #{HIDDEN_ID}
|
||||
</if>
|
||||
</select>
|
||||
<!-- 列表(全部) -->
|
||||
<select id="listAllUser" parameterType="pd" resultType="pd">
|
||||
select
|
||||
<include refid="Field"></include>, u.* ,dept.NAME as deptName
|
||||
from
|
||||
<include refid="tableName"></include> f
|
||||
left join sys_user u on u.USER_ID = f.USER_ID
|
||||
left join oa_department dept on dept.DEPARTMENT_ID = u.DEPARTMENT_ID
|
||||
where 1=1
|
||||
<if test="TYPE != null and TYPE != ''"><!-- 关键词检索 -->
|
||||
and TYPE = #{TYPE}
|
||||
</if>
|
||||
<if test="hiddenIds != null and hiddenIds != ''">
|
||||
and HIDDEN_ID in
|
||||
<foreach item="item" index="index" collection="hiddenIds" open="(" separator="," close=")">
|
||||
#{item}
|
||||
</foreach>
|
||||
</if>
|
||||
<if test="HIDDEN_ID != null and HIDDEN_ID != ''">
|
||||
and HIDDEN_ID = #{HIDDEN_ID}
|
||||
</if>
|
||||
</select>
|
||||
|
||||
<!-- 批量删除 -->
|
||||
<delete id="deleteAll" parameterType="String">
|
||||
update
|
||||
<include refid="tableName"></include>
|
||||
set
|
||||
ISDELETE = '1'
|
||||
where
|
||||
HIDDENUSER_ID in
|
||||
<foreach item="item" index="index" collection="ArrayDATA_IDS" open="(" separator="," close=")">
|
||||
#{item}
|
||||
</foreach>
|
||||
</delete>
|
||||
<!-- 批量删除 -->
|
||||
<delete id="deleteByHidden" parameterType="pd">
|
||||
delete
|
||||
from
|
||||
<include refid="tableName"></include>
|
||||
where HIDDEN_ID = #{HIDDEN_ID}
|
||||
and TYPE = #{TYPE}
|
||||
</delete>
|
||||
|
||||
<select id="verifylist" parameterType="pd" resultType="pd">
|
||||
select
|
||||
<include refid="Field"></include>
|
||||
from
|
||||
<include refid="tableName"></include> f
|
||||
where f.USER_ID = #{USER_ID}
|
||||
and f.TYPE = 3
|
||||
</select>
|
||||
</mapper>
|
||||
Loading…
Reference in New Issue