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

曹妃甸动火作业搬到港务局

cmt1.0
limingyu 2023-11-14 10:16:26 +08:00
parent a95159f2b2
commit 5b22778601
56 changed files with 7843 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pom.xml
View File

@ -210,6 +210,19 @@
<version>${batik.version}</version>
</dependency>
<!--mq开始-->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client-java</artifactId>
<version>5.0.5</version>
</dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.2.2</version>
</dependency>
<!--mq结束-->
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-java-sdk-core</artifactId>
@ -461,7 +474,11 @@
<artifactId>hutool-all</artifactId>
<version>5.0.5</version>
</dependency>
</dependencies>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
<build>
<!-- <finalName>qa-prevention-gwj</finalName>
<plugins>

1513
src/main/java/com/zcloud/controller/app/highriskwork/AppHotworkCfdController.java Normal file
View File

File diff suppressed because it is too large Load Diff

160
src/main/java/com/zcloud/controller/eightWork/AppEightWorkCfdController.java Normal file
View File

@ -0,0 +1,160 @@
package com.zcloud.controller.eightWork;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.entity.Response;
import com.zcloud.logs.LogAnno;
import com.zcloud.service.eightWork.EightWorkCfdService;
import com.zcloud.service.highriskwork.*;
import com.zcloud.service.system.DictionariesService;
import com.zcloud.service.system.UsersService;
import com.zcloud.util.Tools;
import com.zcloud.util.Warden;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* 说明：八项作业
* 作者：luoxiaobao
* 时间：2021-08-31
* 官网：www.zcloudchina.com
*/
@Controller
@RequestMapping("/app/eightwork/cfd")
public class AppEightWorkCfdController extends BaseController {
@Autowired
private EightWorkCfdService eightworkCfdService;
@Autowired
private DictionariesService dictionariesService;
@Autowired
private UsersService usersService;
@Autowired
private ConfinedSpaceService confinedSpaceService;
@Autowired
private BlindBoardService blindBoardService;
@Autowired
private BreakGroundService breakGroundService;
@Autowired
private HighWorkService highWorkService;
@Autowired
private HoistingService hoistingService;
@Autowired
private ElectricityService electricityService;
@Autowired
private HotworkService hotworkService;
@Autowired
private CutRoadService cutRoadService;
/**八项作业列表
* @param page
* @throws Exception
*/
@RequestMapping(value="/list")
@ResponseBody
@LogAnno(menuType= "手机",menuServer= "八项作业",instructionsOperate = "八项作业",instructionsType = "列表")
public Object list(Page page) 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());
// pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID());
page.setPd(pd);
List<PageData> varList = eightworkCfdService.list(page); //列出confinedspace列表
map.put("varList", varList);
map.put("page", page);
map.put("result", errInfo);
return map;
}
/**
* description:
* accidentType-风险点
* hiddenLevel-隐患级别
*
* @return tree or list
* @throws Exception all
*/
@RequestMapping(value = "/getInfo")
@ResponseBody
public Response getInfo() throws Exception {
Response response = Response.getResponse();
try {
PageData request = this.getPageData();
if (StringUtils.isBlank(request.getString("vectors"))) throw new RuntimeException("未找到要获取的数据字典类型");
List<String> vectors = Warden.getList(request.getString("vectors"),String.class);
for (String vector: vectors) {
switch (vector) {
case "accidentType":
//事故类型
response.put("accidentType", dictionariesService.getTreeById("cee1190ea96a4ca9b7bca81e11f0d0f8"));
continue;
default:
}
}
return response.OK();
} catch (Exception e) {
e.printStackTrace();
return response.errorMessage(e.getMessage());
}
}
/**
* 获取全部用户列表
* @return
* @throws Exception
*/
@RequestMapping(value = "/getAllUserList")
@ResponseBody
public Object getAllUserList() throws Exception{
Map<String,Object> map = new HashMap<>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
return usersService.getAllUserList();
}
/**
* 高危作业待办数量统计
* @return
* @throws Exception
*/
@RequestMapping(value = "/countCheck")
@ResponseBody
public Object countCheck() throws Exception{
Map<String, Object> map = new HashMap<>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
PageData count1 = confinedSpaceService.countCheck(pd);
PageData count2 = blindBoardService.countCheck(pd);
PageData count3 = breakGroundService.countCheck(pd);
PageData count4 = highWorkService.countCheck(pd);
PageData count5 = hoistingService.countCheck(pd);
PageData count6 = electricityService.countCheck(pd);
PageData count7 = hotworkService.countCheck(pd);
PageData count8 = cutRoadService.countCheck(pd);
map.put("result", errInfo);
map.put("count1", count1);
map.put("count2", count2);
map.put("count3", count3);
map.put("count4", count4);
map.put("count5", count5);
map.put("count6", count6);
map.put("count7", count7);
map.put("count8", count8);
return map;
}
}

318
src/main/java/com/zcloud/controller/highriskwork/HotworkCfdController.java Normal file
View File

@ -0,0 +1,318 @@
package com.zcloud.controller.highriskwork;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.logs.LogAnno;
import com.zcloud.service.highriskwork.HotworkAcceptUserCfdService;
import com.zcloud.service.highriskwork.HotworkCfdService;
import com.zcloud.service.highriskwork.HotworkGasCfdService;
import com.zcloud.util.Jurisdiction;
import com.zcloud.util.ObjectExcelView;
import com.zcloud.util.Tools;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* 说明：动火作业
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
@Controller
@RequestMapping("/hotwork/cfd")
public class HotworkCfdController extends BaseController {
@Autowired
private HotworkCfdService hotworkCfdService;
@Autowired
private HotworkGasCfdService hotworkGasCfdService;
@Autowired
private HotworkAcceptUserCfdService hotworkacceptuserCfdService;
/**新增
* @param
* @throws Exception
*/
@RequestMapping(value="/add")
@RequiresPermissions("hotwork:add")
@ResponseBody
public Object add() throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
pd.put("HOTWORK_ID", this.get32UUID()); //主键
hotworkCfdService.save(pd);
map.put("result", errInfo);
return map;
}
/**删除
* @param out
* @throws Exception
*/
@RequestMapping(value="/delete")
@RequiresPermissions("hotwork:del")
@ResponseBody
public Object delete() throws Exception{
Map<String,String> map = new HashMap<String,String>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
hotworkCfdService.delete(pd);
map.put("result", errInfo); //返回结果
return map;
}
/**修改
* @param
* @throws Exception
*/
@RequestMapping(value="/edit")
@RequiresPermissions("hotwork:edit")
@ResponseBody
public Object edit() throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
hotworkCfdService.edit(pd);
map.put("result", errInfo);
return map;
}
/**列表
* @param page
* @throws Exception
*/
@RequestMapping(value="/list")
@RequiresPermissions("hotwork:list")
@ResponseBody
@LogAnno(menuType= "高危作业管理",menuServer= "动火作业管理",instructionsOperate = "动火作业数据",instructionsType = "列表")
public Object list(Page page) 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());
pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); //企业ID
pd.put("ISMAIN", Jurisdiction.getIS_MAIN());
pd.put("ISSUPERVISE", Jurisdiction.getISSUPERVISE());
pd.put("DEPARTMENT_ID", Jurisdiction.getDEPARTMENT_ID());
String DEPTIDS = pd.getString("DEPTIDS");
if(Tools.notEmpty(DEPTIDS)) {
String DEPT_IDS[] = DEPTIDS.split(",");
pd.put("DEPT_IDS", DEPT_IDS);
}
page.setPd(pd);
List<PageData> varList = hotworkCfdService.list(page); //列出Hotwork列表
map.put("varList", varList);
map.put("page", page);
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 = hotworkCfdService.findById(pd); //根据ID读取
map.put("pd", pd);
map.put("measuresList", hotworkCfdService.listAllMeasures(pd));
map.put("gasList", hotworkGasCfdService.listAll(pd));
map.put("imgList", hotworkacceptuserCfdService.findByIds(pd));
map.put("imgList1", hotworkacceptuserCfdService.findById(pd));
map.put("result", errInfo);
return map;
}
/**批量删除
* @param
* @throws Exception
*/
@RequestMapping(value="/deleteAll")
@RequiresPermissions("hotwork:del")
@ResponseBody
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(",");
hotworkCfdService.deleteAll(ArrayDATA_IDS);
errInfo = "success";
}else{
errInfo = "error";
}
map.put("result", errInfo); //返回结果
return map;
}
/**导出到excel
* @param
* @throws Exception
*/
@RequestMapping(value="/excel")
@RequiresPermissions("toExcel")
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("所属企业"); //1
titles.add("删除标志"); //2
titles.add("创建时间"); //3
titles.add("添加人"); //4
titles.add("修改时间"); //5
titles.add("修改人"); //6
titles.add("编号"); //7
titles.add("作业内容"); //8
titles.add("工作开始时间"); //9
titles.add("工作结束时间"); //10
titles.add("确认单位"); //11
titles.add("确认单位人"); //12
titles.add("确认单位签字"); //13
titles.add("确认单位签字时间"); //14
titles.add("审核部门"); //15
titles.add("审核人"); //16
titles.add("审核签字"); //17
titles.add("审核签字时间"); //18
titles.add("审批部门"); //19
titles.add("审批部门人"); //20
titles.add("审批部门签字"); //21
titles.add("审批部门签字时间"); //22
titles.add("状态"); //23
titles.add("确认意见"); //24
titles.add("审核意见"); //25
titles.add("审批意见"); //26
titles.add("其他防护措施"); //27
titles.add("验收部门"); //28
titles.add("验收人"); //29
titles.add("验收签字"); //30
titles.add("验收签字时间"); //31
titles.add("验收意见"); //32
titles.add("申请部门"); //33
titles.add("申请人"); //34
titles.add("动火地点"); //35
titles.add("作业级别"); //36
titles.add("作业人"); //37
titles.add("特殊作业"); //38
titles.add("风险辨识"); //39
titles.add("作业负责人"); //40
titles.add("分析部门"); //41
titles.add("分析人"); //42
titles.add("监护人部门"); //43
titles.add("监护人"); //44
titles.add("监护人签字"); //45
titles.add("监护人签字时间"); //46
titles.add("监护人意见"); //47
titles.add("动火点车间"); //48
titles.add("动火点车间负责人"); //49
titles.add("车间负责人签字"); //50
titles.add("车间负责人签字时间"); //51
titles.add("车间负责人意见"); //52
titles.add("班长部门"); //53
titles.add("班长"); //54
titles.add("班长签字"); //55
titles.add("班长签字时间"); //56
titles.add("班长意见"); //57
titles.add("交底人"); //58
titles.add("教育人"); //59
titles.add("接受教育人"); //60
titles.add("初审人"); //61
dataMap.put("titles", titles);
List<PageData> varOList = hotworkCfdService.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("CORPINFO_ID")); //1
vpd.put("var2", varOList.get(i).get("ISDELETE").toString()); //2
vpd.put("var3", varOList.get(i).getString("CREATTIME")); //3
vpd.put("var4", varOList.get(i).getString("CREATOR")); //4
vpd.put("var5", varOList.get(i).getString("OPERATTIME")); //5
vpd.put("var6", varOList.get(i).getString("OPERATOR")); //6
vpd.put("var7", varOList.get(i).getString("CHECK_NO")); //7
vpd.put("var8", varOList.get(i).getString("WORK_CONTENT")); //8
vpd.put("var9", varOList.get(i).getString("WORK_START_DATE")); //9
vpd.put("var10", varOList.get(i).getString("WORK_END_DATE")); //10
vpd.put("var11", varOList.get(i).getString("CONFIRM_DEPARTMENT_ID")); //11
vpd.put("var12", varOList.get(i).getString("CONFIRM_USER_ID")); //12
vpd.put("var13", varOList.get(i).getString("CONFIRM_USER_SIGNER_PATH")); //13
vpd.put("var14", varOList.get(i).getString("CONFIRM_USER_SIGNER_TIME")); //14
vpd.put("var15", varOList.get(i).getString("AUDIT_DEPARTMENT_ID")); //15
vpd.put("var16", varOList.get(i).getString("AUDIT_USER_ID")); //16
vpd.put("var17", varOList.get(i).getString("AUDIT_USER_SIGNER_PATH")); //17
vpd.put("var18", varOList.get(i).getString("AUDIT_USER_SIGNER_TIME")); //18
vpd.put("var19", varOList.get(i).getString("APPROVE_DEPARTMENT_ID")); //19
vpd.put("var20", varOList.get(i).getString("APPROVE_USER_ID")); //20
vpd.put("var21", varOList.get(i).getString("APPROVE_USER_SIGNER_PATH")); //21
vpd.put("var22", varOList.get(i).getString("APPROVE_USER_SIGNER_TIME")); //22
vpd.put("var23", varOList.get(i).getString("APPLY_STATUS")); //23
vpd.put("var24", varOList.get(i).getString("CONFIRM_CONTENT")); //24
vpd.put("var25", varOList.get(i).getString("AUDIT_CONTENT")); //25
vpd.put("var26", varOList.get(i).getString("APPROVE_CONTENT")); //26
vpd.put("var27", varOList.get(i).getString("OTHER_PROTECTIVE_MEASURES")); //27
vpd.put("var28", varOList.get(i).getString("ACCEPT_DEPARTMENT_ID")); //28
vpd.put("var29", varOList.get(i).getString("ACCEPT_USER_ID")); //29
vpd.put("var30", varOList.get(i).getString("ACCEPT_USER_SIGNER_PATH")); //30
vpd.put("var31", varOList.get(i).getString("ACCEPT_USER_SIGNER_TIME")); //31
vpd.put("var32", varOList.get(i).getString("ACCEPT_CONTENT")); //32
vpd.put("var33", varOList.get(i).getString("APPLY_DEPARTMENT_ID")); //33
vpd.put("var34", varOList.get(i).getString("APPLY_USER_ID")); //34
vpd.put("var35", varOList.get(i).getString("WORK_PLACE")); //35
vpd.put("var36", varOList.get(i).getString("WORK_LEVEL")); //36
vpd.put("var37", varOList.get(i).getString("WORK_USER")); //37
vpd.put("var38", varOList.get(i).getString("SPECIAL_WORK")); //38
vpd.put("var39", varOList.get(i).getString("RISK_IDENTIFICATION")); //39
vpd.put("var40", varOList.get(i).getString("WORK_MANAGER")); //40
vpd.put("var41", varOList.get(i).getString("ANALYZE_DEPARTMENT_ID")); //41
vpd.put("var42", varOList.get(i).getString("ANALYZE_USER_ID")); //42
vpd.put("var43", varOList.get(i).getString("GUARDIAN_DEPARTMENT_ID")); //43
vpd.put("var44", varOList.get(i).getString("GUARDIAN_USER_ID")); //44
vpd.put("var45", varOList.get(i).getString("GUARDIAN_USER_SIGNER_PATH")); //45
vpd.put("var46", varOList.get(i).getString("GUARDIAN_USER_SIGNER_TIME")); //46
vpd.put("var47", varOList.get(i).getString("GUARDIAN_CONTENT")); //47
vpd.put("var48", varOList.get(i).getString("LEADER_DEPARTMENT_ID")); //48
vpd.put("var49", varOList.get(i).getString("LEADER_USER_ID")); //49
vpd.put("var50", varOList.get(i).getString("LEADER_USER_SIGNER_PATH")); //50
vpd.put("var51", varOList.get(i).getString("LEADER_USER_SIGNER_TIME")); //51
vpd.put("var52", varOList.get(i).getString("LEADER_CONTENT")); //52
vpd.put("var53", varOList.get(i).getString("MONITOR_DEPARTMENT_ID")); //53
vpd.put("var54", varOList.get(i).getString("MONITOR_USER_ID")); //54
vpd.put("var55", varOList.get(i).getString("MONITOR_USER_SIGNER_PATH")); //55
vpd.put("var56", varOList.get(i).getString("MONITOR_USER_SIGNER_TIME")); //56
vpd.put("var57", varOList.get(i).getString("MONITOR_CONTENT")); //57
vpd.put("var58", varOList.get(i).getString("CONFESS_USER")); //58
vpd.put("var59", varOList.get(i).getString("EDUCATE_USER")); //59
vpd.put("var60", varOList.get(i).getString("ACCEPT_EDUCATE_USER")); //60
vpd.put("var61", varOList.get(i).getString("TRIAL_USER")); //61
varList.add(vpd);
}
dataMap.put("varList", varList);
ObjectExcelView erv = new ObjectExcelView();
mv = new ModelAndView(erv,dataMap);
return mv;
}
}

234
src/main/java/com/zcloud/controller/specialoperation/AppPersonnelManagementCfdController.java Normal file
View File

@ -0,0 +1,234 @@
package com.zcloud.controller.specialoperation;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.logs.LogAnno;
import com.zcloud.service.specialoperation.PersonnelManagementCfdService;
import com.zcloud.util.DateUtil;
import com.zcloud.util.Jurisdiction;
import com.zcloud.util.ObjectExcelView;
import com.zcloud.util.Tools;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;
import java.util.*;
/**
* 说明：特种作业人员管理
* 作者：luoxiaobao
* 时间：2022-06-16
* 官网：www.zcloudchina.com
*/
@Controller
@RequestMapping("/app/personnelmanagement/cfd")
public class AppPersonnelManagementCfdController extends BaseController {
@Autowired
private PersonnelManagementCfdService personnelmanagementCfdService;
/**新增
* @param
* @throws Exception
*/
@RequestMapping(value="/add")
@ResponseBody
@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();
pd.put("PERSONNELMANAGEMENT_ID", this.get32UUID()); //主键
pd.put("CREATOR", Jurisdiction.getUsername()); //添加人
pd.put("CREATTIME", DateUtil.date2Str(new Date())); //添加时间
pd.put("OPERATOR", Jurisdiction.getUsername()); //修改人
pd.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
pd.put("ISDELETE", "0"); //是否删除
pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); //企业ID
personnelmanagementCfdService.save(pd);
map.put("result", errInfo);
return map;
}
/**删除
* @param
* @throws Exception
*/
@RequestMapping(value="/delete")
@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();
personnelmanagementCfdService.delete(pd);
map.put("result", errInfo); //返回结果
return map;
}
/**修改
* @param
* @throws Exception
*/
@RequestMapping(value="/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();
personnelmanagementCfdService.edit(pd);
map.put("result", errInfo);
return map;
}
/**列表
* @param page
* @throws Exception
*/
@RequestMapping(value="/list")
@ResponseBody
@LogAnno(menuType= "综合管理",menuServer= "特种作业",instructionsOperate = "特种作业人员管理",instructionsType = "列表")
public Object list(Page page) throws Exception{
Map<String,Object> map = new HashMap<String,Object>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
pd.put("CORPINFO_ID", pd.get("CORPINFO_ID")); //企业ID
page.setPd(pd);
List<PageData> varList = personnelmanagementCfdService.namelist(pd); //列出PersonnelManagement列表
map.put("varList", varList);
map.put("page", page);
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 = personnelmanagementCfdService.findById(pd); //根据ID读取
map.put("pd", pd);
map.put("result", errInfo);
return map;
}
/**批量删除
* @param
* @throws Exception
*/
@RequestMapping(value="/deleteAll")
@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(",");
personnelmanagementCfdService.deleteAll(ArrayDATA_IDS);
errInfo = "success";
}else{
errInfo = "error";
}
map.put("result", errInfo); //返回结果
return map;
}
/**判断特种作业证书编号是否存在
* @return
*/
@RequestMapping(value="/hasCertificate")
@ResponseBody
@LogAnno(menuType= "综合管理",menuServer= "特种作业",instructionsOperate = "特种作业人员管理",instructionsType = "判断特种作业证书编号是否存在")
public Object hasCertificate() throws Exception{
Map<String,String> map = new HashMap<String,String>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
if(personnelmanagementCfdService.findByCertificate(pd) != null){
map.put("msg","特种作业证书编号已存在");
}
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("添加人"); //1
titles.add("添加单位"); //2
titles.add("单位名称"); //3
titles.add("人员类型"); //4
titles.add("作业类别"); //5
titles.add("操作项目"); //6
titles.add("姓名"); //7
titles.add("性别"); //8
titles.add("特种作业证书编号"); //9
titles.add("复审时间"); //10
titles.add("手机号码"); //11
titles.add("身份证号码"); //12
titles.add("发证机关"); //13
titles.add("有效期"); //14
titles.add("添加时间"); //15
titles.add("修改人"); //16
titles.add("修改时间"); //17
titles.add("是否删除"); //18
titles.add("企业ID"); //19
dataMap.put("titles", titles);
List<PageData> varOList = personnelmanagementCfdService.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("CREATOR")); //1
vpd.put("var2", varOList.get(i).getString("ADDUNITS")); //2
vpd.put("var3", varOList.get(i).getString("UNITS_NAME")); //3
vpd.put("var4", varOList.get(i).getString("TYPE")); //4
vpd.put("var5", varOList.get(i).getString("JOB_TYPE")); //5
vpd.put("var6", varOList.get(i).getString("OPERATIONITEM")); //6
vpd.put("var7", varOList.get(i).getString("NAME")); //7
vpd.put("var8", varOList.get(i).getString("SEX")); //8
vpd.put("var9", varOList.get(i).getString("CERTIFICATE_NUM")); //9
vpd.put("var10", varOList.get(i).getString("REVIEWTIME")); //10
vpd.put("var11", varOList.get(i).getString("PHONENUM")); //11
vpd.put("var12", varOList.get(i).getString("IDENTITYCARD")); //12
vpd.put("var13", varOList.get(i).getString("LICENSING")); //13
vpd.put("var14", varOList.get(i).getString("VALID")); //14
vpd.put("var15", varOList.get(i).getString("CREATETIME")); //15
vpd.put("var16", varOList.get(i).getString("OPERATOR")); //16
vpd.put("var17", varOList.get(i).getString("OPERATTIME")); //17
vpd.put("var18", varOList.get(i).getString("ISDELETE")); //18
vpd.put("var19", varOList.get(i).getString("CORPINFO_ID")); //19
varList.add(vpd);
}
dataMap.put("varList", varList);
ObjectExcelView erv = new ObjectExcelView();
mv = new ModelAndView(erv,dataMap);
return mv;
}
}

244
src/main/java/com/zcloud/controller/specialoperation/PersonnelManagementCfdController.java Normal file
View File

@ -0,0 +1,244 @@
package com.zcloud.controller.specialoperation;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.logs.LogAnno;
import com.zcloud.service.specialoperation.PersonnelManagementCfdService;
import com.zcloud.util.DateUtil;
import com.zcloud.util.Jurisdiction;
import com.zcloud.util.ObjectExcelView;
import com.zcloud.util.Tools;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;
import java.util.*;
/**
* 说明：特种作业人员管理
* 作者：luoxiaobao
* 时间：2022-06-16
* 官网：www.zcloudchina.com
*/
@Controller
@RequestMapping("/personnelmanagement/cfd")
public class PersonnelManagementCfdController extends BaseController {
@Autowired
private PersonnelManagementCfdService personnelmanagementCfdService;
/**新增
* @param
* @throws Exception
*/
@RequestMapping(value="/add")
@RequiresPermissions("personnelmanagement:add")
@ResponseBody
@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();
pd.put("PERSONNELMANAGEMENT_ID", this.get32UUID()); //主键
pd.put("CREATOR", Jurisdiction.getUsername()); //添加人
pd.put("CREATTIME", DateUtil.date2Str(new Date())); //添加时间
pd.put("OPERATOR", Jurisdiction.getUsername()); //修改人
pd.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间
pd.put("ISDELETE", "0"); //是否删除
pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); //企业ID
personnelmanagementCfdService.save(pd);
map.put("result", errInfo);
return map;
}
/**删除
* @param out
* @throws Exception
*/
@RequestMapping(value="/delete")
@RequiresPermissions("personnelmanagement: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();
personnelmanagementCfdService.delete(pd);
map.put("result", errInfo); //返回结果
return map;
}
/**修改
* @param
* @throws Exception
*/
@RequestMapping(value="/edit")
@RequiresPermissions("personnelmanagement: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();
personnelmanagementCfdService.edit(pd);
map.put("result", errInfo);
return map;
}
/**列表
* @param page
* @throws Exception
*/
@RequestMapping(value="/list")
@RequiresPermissions("personnelmanagement:list")
@ResponseBody
@LogAnno(menuType= "综合管理",menuServer= "特种作业",instructionsOperate = "特种作业人员管理",instructionsType = "列表")
public Object list(Page page) 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());
pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); //企业ID
page.setPd(pd);
List<PageData> varList = personnelmanagementCfdService.list(page); //列出PersonnelManagement列表
map.put("varList", varList);
map.put("page", page);
map.put("result", errInfo);
return map;
}
/**去修改页面获取数据
* @param
* @throws Exception
*/
@RequestMapping(value="/goEdit")
@RequiresPermissions("personnelmanagement:edit")
@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 = personnelmanagementCfdService.findById(pd); //根据ID读取
map.put("pd", pd);
map.put("result", errInfo);
return map;
}
/**批量删除
* @param
* @throws Exception
*/
@RequestMapping(value="/deleteAll")
@RequiresPermissions("personnelmanagement: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(",");
personnelmanagementCfdService.deleteAll(ArrayDATA_IDS);
errInfo = "success";
}else{
errInfo = "error";
}
map.put("result", errInfo); //返回结果
return map;
}
/**判断特种作业证书编号是否存在
* @return
*/
@RequestMapping(value="/hasCertificate")
@ResponseBody
@LogAnno(menuType= "综合管理",menuServer= "特种作业",instructionsOperate = "特种作业人员管理",instructionsType = "判断特种作业证书编号是否存在")
public Object hasCertificate() throws Exception{
Map<String,String> map = new HashMap<String,String>();
String errInfo = "success";
PageData pd = new PageData();
pd = this.getPageData();
if(personnelmanagementCfdService.findByCertificate(pd) != null){
map.put("msg","特种作业证书编号已存在");
}
map.put("result", errInfo); //返回结果
return map;
}
/**导出到excel
* @param
* @throws Exception
*/
@RequestMapping(value="/excel")
@RequiresPermissions("toExcel")
@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("添加人"); //1
titles.add("添加单位"); //2
titles.add("单位名称"); //3
titles.add("人员类型"); //4
titles.add("作业类别"); //5
titles.add("操作项目"); //6
titles.add("姓名"); //7
titles.add("性别"); //8
titles.add("特种作业证书编号"); //9
titles.add("复审时间"); //10
titles.add("手机号码"); //11
titles.add("身份证号码"); //12
titles.add("发证机关"); //13
titles.add("有效期"); //14
titles.add("添加时间"); //15
titles.add("修改人"); //16
titles.add("修改时间"); //17
titles.add("是否删除"); //18
titles.add("企业ID"); //19
dataMap.put("titles", titles);
List<PageData> varOList = personnelmanagementCfdService.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("CREATOR")); //1
vpd.put("var2", varOList.get(i).getString("ADDUNITS")); //2
vpd.put("var3", varOList.get(i).getString("UNITS_NAME")); //3
vpd.put("var4", varOList.get(i).getString("TYPE")); //4
vpd.put("var5", varOList.get(i).getString("JOB_TYPE")); //5
vpd.put("var6", varOList.get(i).getString("OPERATIONITEM")); //6
vpd.put("var7", varOList.get(i).getString("NAME")); //7
vpd.put("var8", varOList.get(i).getString("SEX")); //8
vpd.put("var9", varOList.get(i).getString("CERTIFICATE_NUM")); //9
vpd.put("var10", varOList.get(i).getString("REVIEWTIME")); //10
vpd.put("var11", varOList.get(i).getString("PHONENUM")); //11
vpd.put("var12", varOList.get(i).getString("IDENTITYCARD")); //12
vpd.put("var13", varOList.get(i).getString("LICENSING")); //13
vpd.put("var14", varOList.get(i).getString("VALID")); //14
vpd.put("var15", varOList.get(i).getString("CREATETIME")); //15
vpd.put("var16", varOList.get(i).getString("OPERATOR")); //16
vpd.put("var17", varOList.get(i).getString("OPERATTIME")); //17
vpd.put("var18", varOList.get(i).getString("ISDELETE")); //18
vpd.put("var19", varOList.get(i).getString("CORPINFO_ID")); //19
varList.add(vpd);
}
dataMap.put("varList", varList);
ObjectExcelView erv = new ObjectExcelView();
mv = new ModelAndView(erv,dataMap);
return mv;
}
}

68
src/main/java/com/zcloud/dto/Response.java Normal file
View File

@ -0,0 +1,68 @@
package com.zcloud.dto;
import com.alibaba.fastjson.JSON;
import lombok.Data;
@Data
public class Response {
private String result;
private String exception;
private String code;
private String message;
public Response Ok() {
this.result = "succeed";
this.code = "0";
return this;
}
public static Response OK() {
Response response = new Response();
response.result = "succeed";
response.code = "0";
return response;
}
public Response Error() {
this.result = "succeed";
this.code = "9999";
this.exception = "系统异常";
return this;
}
public Response Error(String errorMessage) {
this.result = "succeed";
this.code = "9999";
this.exception = errorMessage;
return this;
}
public Response Error(String code, String errorMessage) {
this.result = "succeed";
this.code = code;
this.exception = errorMessage;
return this;
}
public static Response ERROR() {
Response response = new Response();
response.result = "succeed";
response.code = "0";
return response;
}
public static Response ERROR(String errorMessage) {
Response response = new Response();
response.result = "exception";
response.code = "9999";
response.exception = errorMessage;
return response;
}
public void setMessage(Object obj) {
this.message = JSON.toJSONString(obj);
}
}

7
src/main/java/com/zcloud/dto/TenCorpConst.java Normal file
View File

@ -0,0 +1,7 @@
package com.zcloud.dto;
public class TenCorpConst {
public static final String confinedSpace = "confined-space";
public static final String electricity = "electricity";
public static final String hotWork = "hot-work";
}

45
src/main/java/com/zcloud/dto/TenCorpDto.java Normal file
View File

@ -0,0 +1,45 @@
package com.zcloud.dto;
import com.alibaba.fastjson.JSON;
import com.zcloud.entity.PageData;
import lombok.Data;
@Data
public class TenCorpDto {
// 请秋id
private String id;
// 消息来源名称
private String producer_name = "qa-prevention-cfd";
private String topic;
//印记(方便寻找该条请求)
private String mark;
// 标记名称
private String mark_name;
// 消息发送时间(yyyy-MM-dd HH:mm:ss:SSS)
private String time_stamp;
// 消息体
// 八项作业根据这个区分接口
private String message;
// 消息体
private PageData data;
public TenCorpDto() {
this.id = Warden.get32UUID();
}
@Override
public String toString() {
return JSON.toJSONString(this);
}
public PageData getPd() {
PageData info = new PageData();
info.put("ID", this.id);
info.put("PRODUCER_NAME", this.producer_name);
info.put("MARK", this.mark);
info.put("MARK_NAME", this.mark_name);
info.put("MESSAGE", this.message);
info.put("TOPIC",this.topic);
return info;
}
}

87
src/main/java/com/zcloud/dto/Warden.java Normal file
View File

@ -0,0 +1,87 @@
package com.zcloud.dto;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.zcloud.entity.PageData;
import com.zcloud.util.DateUtil;
import com.zcloud.util.Jurisdiction;
import com.zcloud.util.UuidUtil;
import org.apache.commons.lang.StringUtils;
import java.util.*;
public class Warden {
public static List<PageData> getList(String raw) {
return JSON.parseArray(raw, PageData.class);
}
public static <T> List<T> getList(String raw, Class<T> clazz) {
return JSON.parseArray(raw, clazz);
}
public static List<PageData> getList(JSONArray raw) {
return JSON.parseArray(raw.toJSONString(), PageData.class);
}
public static PageData getPageData(JSONObject raw) {
return JSON.parseObject(raw.toJSONString(), PageData.class);
}
public static PageData getPageData(String raw) {
return JSON.parseObject(raw, PageData.class);
}
public static String get32UUID() {
return UuidUtil.get32UUID();
}
public static List<Map<String, String>> getVueUploadEntity(String url) {
List<Map<String, String>> list = new ArrayList<>();
Map<String, String> map = new HashMap<>();
map.put("name", get32UUID());
map.put("url", url);
list.add(map);
return list;
}
public static void initDate(PageData entity) {
entity.put("CREATOR", Jurisdiction.getUSER_ID());
entity.put("CREATE_TIME", DateUtil.getTime());
entity.put("CREATOR_NAME", Jurisdiction.getName());
entity.put("CREATTIME", DateUtil.getTime());
entity.put("OPERATOR", Jurisdiction.getUSER_ID());
entity.put("OPERATOR_NAME", Jurisdiction.getName());
entity.put("OPERAT_TIME", DateUtil.getTime());
entity.put("OPERATTIME", DateUtil.getTime());
entity.put("ISDELETE", "0");
}
public static void updateDate(PageData entity) {
entity.put("OPERATOR", Jurisdiction.getUSER_ID());
entity.put("OPERAT_TIME", DateUtil.getTime());
entity.put("OPERATTIME", DateUtil.getTime());
entity.put("ISDELETE", "0");
}
public static Date addDate(Date date, long day) {
if (date == null) {
return new Date();
}
long time = date.getTime(); // 得到指定日期的毫秒数
day = day * 24 * 60 * 60 * 1000; // 要加上的天数转换成毫秒数
time += day; // 相加得到新的毫秒数
return new Date(time); // 将毫秒数转换成日期
}
public static String checkId(Object object) {
if (object == null || StringUtils.isEmpty(object.toString())) {
return get32UUID();
} else {
return object.toString();
}
}
}

26
src/main/java/com/zcloud/mapper/datasource/eightWork/EightWorkCfdMapper.java Normal file
View File

@ -0,0 +1,26 @@
package com.zcloud.mapper.datasource.eightWork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：有限空间作业
* 作者：luoxiaobao
* 时间：2021-09-13
* 官网：www.zcloudchina.com
*/
public interface EightWorkCfdMapper {
/**列表
* @param page
* @throws Exception
*/
List<PageData> datalist(Page page);
List<PageData> getWorkUserLabels(List<String> workUserIds);
}

67
src/main/java/com/zcloud/mapper/datasource/highriskwork/HotworkAcceptUserCfdMapper.java Normal file
View File

@ -0,0 +1,67 @@
package com.zcloud.mapper.datasource.highriskwork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：图片管理
* 作者：luoxiaobao
* 时间：2020-12-24
* 官网：www.zcloudchina.com
*/
public interface HotworkAcceptUserCfdMapper {
/**新增
* @param pd
* @throws Exception
*/
void save(PageData pd);
/**删除
* @param pd
* @throws Exception
*/
void delete(PageData pd);
/**删除
* @param pd
* @throws Exception
*/
void deleteList(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);
/**通过id获取数据
* @param pd
* @throws Exception
*/
List<PageData> findById(PageData pd);
List<PageData> findByIds(PageData pd);
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
void deleteAll(String[] ArrayDATA_IDS);
List<PageData> listAllByIds(PageData pd);
}

89
src/main/java/com/zcloud/mapper/datasource/highriskwork/HotworkCfdMapper.java Normal file
View File

@ -0,0 +1,89 @@
package com.zcloud.mapper.datasource.highriskwork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：动火作业
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
public interface HotworkCfdMapper {
/**新增
* @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);
List<PageData> jhdatalistPage(Page page);
List<PageData> aqdatalistPage(Page page);
List<PageData> jsdatalistPage(Page page);
/**列表(全部)
* @param pd
* @throws Exception
*/
List<PageData> listAll(PageData pd);
/**通过id获取数据
* @param pd
* @throws Exception
*/
PageData findById(PageData pd);
void cancel(PageData pd);
PageData checkno(PageData pd);
void editSpecialwork(PageData pd);
void editSpecialwork1(PageData pd);
void editSpecialwork2(PageData pd);
void editSpecialwork3(PageData pd);
void editSpecialwork4(PageData pd);
void editSpecialwork5(PageData pd);
void editSpecialwork6(PageData pd);
void editSpecialwork7(PageData pd);
void edittime(PageData pd);
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
void deleteAll(String[] ArrayDATA_IDS);
List<PageData> listAllMeasures(PageData pd);
/**
* 待办作业数
* @param pd
* @return
* @throws Exception
*/
PageData countCheck(PageData pd);
PageData getCode(PageData pd);
}

59
src/main/java/com/zcloud/mapper/datasource/highriskwork/HotworkGasCfdMapper.java Normal file
View File

@ -0,0 +1,59 @@
package com.zcloud.mapper.datasource.highriskwork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：动火气体检测
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
public interface HotworkGasCfdMapper {
/**新增
* @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);
/**通过id获取数据
* @param pd
* @throws Exception
*/
PageData findById(PageData pd);
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
void deleteAll(String[] ArrayDATA_IDS);
}

59
src/main/java/com/zcloud/mapper/datasource/highriskwork/HotworkLogCfdMapper.java Normal file
View File

@ -0,0 +1,59 @@
package com.zcloud.mapper.datasource.highriskwork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：动火日志
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
public interface HotworkLogCfdMapper {
/**新增
* @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);
/**通过id获取数据
* @param pd
* @throws Exception
*/
PageData findById(PageData pd);
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
void deleteAll(String[] ArrayDATA_IDS);
}

59
src/main/java/com/zcloud/mapper/datasource/highriskwork/HotworkToMeasuresCfdMapper.java Normal file
View File

@ -0,0 +1,59 @@
package com.zcloud.mapper.datasource.highriskwork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：动火措施中间表
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
public interface HotworkToMeasuresCfdMapper {
/**新增
* @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);
/**通过id获取数据
* @param pd
* @throws Exception
*/
PageData findById(PageData pd);
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
void deleteAll(String[] ArrayDATA_IDS);
}

59
src/main/java/com/zcloud/mapper/datasource/mq/MqErrorMessageLogMapper.java Normal file
View File

@ -0,0 +1,59 @@
package com.zcloud.mapper.datasource.mq;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：mq错误信息日志表
* 作者：luoxiaobao
* 时间：2023-06-28
* 官网：www.zcloudchina.com
*/
public interface MqErrorMessageLogMapper{
/**新增
* @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);
/**通过id获取数据
* @param pd
* @throws Exception
*/
PageData findById(PageData pd);
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
void deleteAll(String[] ArrayDATA_IDS);
}

59
src/main/java/com/zcloud/mapper/datasource/mq/MqMessageLogMapper.java Normal file
View File

@ -0,0 +1,59 @@
package com.zcloud.mapper.datasource.mq;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：mq消费者\生产者动作记录表
* 作者：luoxiaobao
* 时间：2023-06-28
* 官网：www.zcloudchina.com
*/
public interface MqMessageLogMapper{
/**新增
* @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);
/**通过id获取数据
* @param pd
* @throws Exception
*/
PageData findById(PageData pd);
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
void deleteAll(String[] ArrayDATA_IDS);
}

67
src/main/java/com/zcloud/mapper/datasource/specialoperation/PersonnelManagementCfdMapper.java Normal file
View File

@ -0,0 +1,67 @@
package com.zcloud.mapper.datasource.specialoperation;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：特种作业人员管理
* 作者：luoxiaobao
* 时间：2022-06-16
* 官网：www.zcloudchina.com
*/
public interface PersonnelManagementCfdMapper {
/**新增
* @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> namelist(PageData pd);
/**通过id获取数据
* @param pd
* @throws Exception
*/
PageData findById(PageData pd);
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
void deleteAll(String[] ArrayDATA_IDS);
/**
* 判断特种作业证书编号是否存在，减少返回字段，优化压力
* @param pd
* @return
*/
PageData findByCertificate(PageData pd);
}

7
src/main/java/com/zcloud/mapper/datasource/system/UsersMapper.java
View File

@ -36,6 +36,13 @@ public interface UsersMapper {
PageData findBySelect(PageData pd);
PageData findByName(PageData pd);
/**
* 获取全部用户名称列表
* @return
* @throws Exception
*/
List<PageData> getAllUserList()throws Exception;
/**用户列表
* @param page
* @return

26
src/main/java/com/zcloud/service/eightWork/EightWorkCfdService.java Normal file
View File

@ -0,0 +1,26 @@
package com.zcloud.service.eightWork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：有限空间作业
* 作者：luoxiaobao
* 时间：2021-09-13
* 官网：www.zcloudchina.com
*/
public interface EightWorkCfdService {
/**列表
* @param page
* @throws Exception
*/
public List<PageData> list(Page page)throws Exception;
List<PageData> getWorkUserLabels(List<String> workUserIds)throws Exception;
}

41
src/main/java/com/zcloud/service/eightWork/impl/EightWorkCfdServiceImpl.java Normal file
View File

@ -0,0 +1,41 @@
package com.zcloud.service.eightWork.impl;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.eightWork.EightWorkCfdMapper;
import com.zcloud.service.eightWork.EightWorkCfdService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
* 说明：有限空间作业
* 作者：luoxiaobao
* 时间：2021-09-13
* 官网：www.zcloudchina.com
*/
@Service
@Transactional //开启事物
public class EightWorkCfdServiceImpl implements EightWorkCfdService {
@Autowired
private EightWorkCfdMapper eightworkCfdMapper;
/**列表
* @param page
* @throws Exception
*/
public List<PageData> list(Page page)throws Exception{
return eightworkCfdMapper.datalist(page);
}
@Override
public List<PageData> getWorkUserLabels(List<String> workUserIds) throws Exception {
return eightworkCfdMapper.getWorkUserLabels(workUserIds);
}
}

67
src/main/java/com/zcloud/service/highriskwork/HotworkAcceptUserCfdService.java Normal file
View File

@ -0,0 +1,67 @@
package com.zcloud.service.highriskwork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：图片管理
* 作者：luoxiaobao
* 时间：2020-12-24
* 官网：www.zcloudchina.com
*/
public interface HotworkAcceptUserCfdService {
/**新增
* @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 deleteList(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 List<PageData> findById(PageData pd)throws Exception;
public List<PageData> findByIds(PageData pd)throws Exception;
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
public void deleteAll(String[] ArrayDATA_IDS)throws Exception;
public List<PageData> listAllByIds(PageData pd)throws Exception;
}

88
src/main/java/com/zcloud/service/highriskwork/HotworkCfdService.java Normal file
View File

@ -0,0 +1,88 @@
package com.zcloud.service.highriskwork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：动火作业
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
public interface HotworkCfdService {
/**新增
* @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;
public List<PageData> jhlist(Page page)throws Exception;
public List<PageData> aqlist(Page page)throws Exception;
public List<PageData> jslist(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;
public void cancel(PageData pd)throws Exception;
public PageData checkno(PageData pd)throws Exception;
public void editSpecialwork(PageData pd)throws Exception;
public void editSpecialwork1(PageData pd)throws Exception;
public void editSpecialwork2(PageData pd)throws Exception;
public void editSpecialwork3(PageData pd)throws Exception;
public void editSpecialwork4(PageData pd)throws Exception;
public void editSpecialwork5(PageData pd)throws Exception;
public void editSpecialwork6(PageData pd)throws Exception;
public void editSpecialwork7(PageData pd)throws Exception;
public void edittime(PageData pd)throws Exception;
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
public void deleteAll(String[] ArrayDATA_IDS)throws Exception;
public List<PageData> listAllMeasures(PageData pd)throws Exception;
/**
* 待办作业数
* @param pd
* @return
* @throws Exception
*/
PageData countCheck(PageData pd)throws Exception;
PageData getCode(PageData pd)throws Exception;
}

59
src/main/java/com/zcloud/service/highriskwork/HotworkGasCfdService.java Normal file
View File

@ -0,0 +1,59 @@
package com.zcloud.service.highriskwork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：动火气体检测
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
public interface HotworkGasCfdService {
/**新增
* @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;
}

59
src/main/java/com/zcloud/service/highriskwork/HotworkLogCfdService.java Normal file
View File

@ -0,0 +1,59 @@
package com.zcloud.service.highriskwork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：动火日志
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
public interface HotworkLogCfdService {
/**新增
* @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;
}

59
src/main/java/com/zcloud/service/highriskwork/HotworkToMeasuresCfdService.java Normal file
View File

@ -0,0 +1,59 @@
package com.zcloud.service.highriskwork;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：动火措施中间表
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
public interface HotworkToMeasuresCfdService {
/**新增
* @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;
}

102
src/main/java/com/zcloud/service/highriskwork/impl/HotworkAcceptUserCfdServiceImpl.java Normal file
View File

@ -0,0 +1,102 @@
package com.zcloud.service.highriskwork.impl;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.highriskwork.HotworkAcceptUserCfdMapper;
import com.zcloud.service.highriskwork.HotworkAcceptUserCfdService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
* 说明：图片管理
* 作者：luoxiaobao
* 时间：2020-12-24
* 官网：www.zcloudchina.com
*/
@Service
@Transactional //开启事物
public class HotworkAcceptUserCfdServiceImpl implements HotworkAcceptUserCfdService {
@Autowired
private HotworkAcceptUserCfdMapper hotworkAcceptUserCfdMapper;
/**新增
* @param pd
* @throws Exception
*/
public void save(PageData pd)throws Exception{
hotworkAcceptUserCfdMapper.save(pd);
}
/**删除
* @param pd
* @throws Exception
*/
public void delete(PageData pd)throws Exception{
hotworkAcceptUserCfdMapper.delete(pd);
}
/**删除
* @param pd
* @throws Exception
*/
public void deleteList(PageData pd)throws Exception{
hotworkAcceptUserCfdMapper.deleteList(pd);
}
/**修改
* @param pd
* @throws Exception
*/
public void edit(PageData pd)throws Exception{
hotworkAcceptUserCfdMapper.edit(pd);
}
/**列表
* @param page
* @throws Exception
*/
public List<PageData> list(Page page)throws Exception{
return hotworkAcceptUserCfdMapper.datalistPage(page);
}
/**列表(全部)
* @param pd
* @throws Exception
*/
public List<PageData> listAll(PageData pd)throws Exception{
return hotworkAcceptUserCfdMapper.listAll(pd);
}
/**通过id获取数据
* @param pd
* @throws Exception
*/
public List<PageData> findById(PageData pd)throws Exception{
return hotworkAcceptUserCfdMapper.findById(pd);
}
public List<PageData> findByIds(PageData pd)throws Exception{
return hotworkAcceptUserCfdMapper.findByIds(pd);
}
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
public void deleteAll(String[] ArrayDATA_IDS)throws Exception{
hotworkAcceptUserCfdMapper.deleteAll(ArrayDATA_IDS);
}
/**列表(全部)
* @param pd
* @throws Exception
*/
public List<PageData> listAllByIds(PageData pd)throws Exception{
return hotworkAcceptUserCfdMapper.listAllByIds(pd);
}
}

150
src/main/java/com/zcloud/service/highriskwork/impl/HotworkCfdServiceImpl.java Normal file
View File

@ -0,0 +1,150 @@
package com.zcloud.service.highriskwork.impl;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.highriskwork.HotworkCfdMapper;
import com.zcloud.service.highriskwork.HotworkCfdService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
* 说明：动火作业
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
@Service
@Transactional //开启事物
public class HotworkCfdServiceImpl implements HotworkCfdService {
@Autowired
private HotworkCfdMapper hotworkCfdMapper;
/**新增
* @param pd
* @throws Exception
*/
public void save(PageData pd)throws Exception{
hotworkCfdMapper.save(pd);
}
/**删除
* @param pd
* @throws Exception
*/
public void delete(PageData pd)throws Exception{
hotworkCfdMapper.delete(pd);
}
/**修改
* @param pd
* @throws Exception
*/
public void edit(PageData pd)throws Exception{
hotworkCfdMapper.edit(pd);
}
/**列表
* @param page
* @throws Exception
*/
public List<PageData> list(Page page)throws Exception{
return hotworkCfdMapper.datalistPage(page);
}
public List<PageData> jhlist(Page page)throws Exception{
return hotworkCfdMapper.jhdatalistPage(page);
}
public List<PageData> aqlist(Page page)throws Exception{
return hotworkCfdMapper.aqdatalistPage(page);
}
public List<PageData> jslist(Page page)throws Exception{
return hotworkCfdMapper.jsdatalistPage(page);
}
/**列表(全部)
* @param pd
* @throws Exception
*/
public List<PageData> listAll(PageData pd)throws Exception{
return hotworkCfdMapper.listAll(pd);
}
/**通过id获取数据
* @param pd
* @throws Exception
*/
public PageData findById(PageData pd)throws Exception{
return hotworkCfdMapper.findById(pd);
}
public void cancel(PageData pd)throws Exception{
hotworkCfdMapper.cancel(pd);
}
public PageData checkno(PageData pd)throws Exception{
return hotworkCfdMapper.checkno(pd);
}
public void editSpecialwork(PageData pd)throws Exception{
hotworkCfdMapper.editSpecialwork(pd);
}
public void editSpecialwork1(PageData pd)throws Exception{
hotworkCfdMapper.editSpecialwork1(pd);
}
public void editSpecialwork2(PageData pd)throws Exception{
hotworkCfdMapper.editSpecialwork2(pd);
}
public void editSpecialwork3(PageData pd)throws Exception{
hotworkCfdMapper.editSpecialwork3(pd);
}
public void editSpecialwork4(PageData pd)throws Exception{
hotworkCfdMapper.editSpecialwork4(pd);
}
public void editSpecialwork5(PageData pd)throws Exception{
hotworkCfdMapper.editSpecialwork5(pd);
}
public void editSpecialwork6(PageData pd)throws Exception{
hotworkCfdMapper.editSpecialwork6(pd);
}
public void editSpecialwork7(PageData pd)throws Exception{
hotworkCfdMapper.editSpecialwork7(pd);
}
public void edittime(PageData pd)throws Exception{
hotworkCfdMapper.edittime(pd);
}
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
public void deleteAll(String[] ArrayDATA_IDS)throws Exception{
hotworkCfdMapper.deleteAll(ArrayDATA_IDS);
}
/**列表(全部)
* @param pd
* @throws Exception
*/
public List<PageData> listAllMeasures(PageData pd)throws Exception{
return hotworkCfdMapper.listAllMeasures(pd);
}
/**
* 待办作业数
* @param pd
* @return
*/
@Override
public PageData countCheck(PageData pd) throws Exception {
return hotworkCfdMapper.countCheck(pd);
}
@Override
public PageData getCode(PageData pd)throws Exception{
return hotworkCfdMapper.getCode(pd);
}
}

83
src/main/java/com/zcloud/service/highriskwork/impl/HotworkGasCfdServiceImpl.java Normal file
View File

@ -0,0 +1,83 @@
package com.zcloud.service.highriskwork.impl;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.highriskwork.HotworkGasCfdMapper;
import com.zcloud.service.highriskwork.HotworkGasCfdService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
* 说明：动火气体检测
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
@Service
@Transactional //开启事物
public class HotworkGasCfdServiceImpl implements HotworkGasCfdService {
@Autowired
private HotworkGasCfdMapper hotworkGasCfdMapper;
/**新增
* @param pd
* @throws Exception
*/
public void save(PageData pd)throws Exception{
hotworkGasCfdMapper.save(pd);
}
/**删除
* @param pd
* @throws Exception
*/
public void delete(PageData pd)throws Exception{
hotworkGasCfdMapper.delete(pd);
}
/**修改
* @param pd
* @throws Exception
*/
public void edit(PageData pd)throws Exception{
hotworkGasCfdMapper.edit(pd);
}
/**列表
* @param page
* @throws Exception
*/
public List<PageData> list(Page page)throws Exception{
return hotworkGasCfdMapper.datalistPage(page);
}
/**列表(全部)
* @param pd
* @throws Exception
*/
public List<PageData> listAll(PageData pd)throws Exception{
return hotworkGasCfdMapper.listAll(pd);
}
/**通过id获取数据
* @param pd
* @throws Exception
*/
public PageData findById(PageData pd)throws Exception{
return hotworkGasCfdMapper.findById(pd);
}
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
public void deleteAll(String[] ArrayDATA_IDS)throws Exception{
hotworkGasCfdMapper.deleteAll(ArrayDATA_IDS);
}
}

83
src/main/java/com/zcloud/service/highriskwork/impl/HotworkLogCfdServiceImpl.java Normal file
View File

@ -0,0 +1,83 @@
package com.zcloud.service.highriskwork.impl;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.highriskwork.HotworkLogCfdMapper;
import com.zcloud.service.highriskwork.HotworkLogCfdService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
* 说明：动火日志
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
@Service
@Transactional //开启事物
public class HotworkLogCfdServiceImpl implements HotworkLogCfdService {
@Autowired
private HotworkLogCfdMapper hotworkLogCfdMapper;
/**新增
* @param pd
* @throws Exception
*/
public void save(PageData pd)throws Exception{
hotworkLogCfdMapper.save(pd);
}
/**删除
* @param pd
* @throws Exception
*/
public void delete(PageData pd)throws Exception{
hotworkLogCfdMapper.delete(pd);
}
/**修改
* @param pd
* @throws Exception
*/
public void edit(PageData pd)throws Exception{
hotworkLogCfdMapper.edit(pd);
}
/**列表
* @param page
* @throws Exception
*/
public List<PageData> list(Page page)throws Exception{
return hotworkLogCfdMapper.datalistPage(page);
}
/**列表(全部)
* @param pd
* @throws Exception
*/
public List<PageData> listAll(PageData pd)throws Exception{
return hotworkLogCfdMapper.listAll(pd);
}
/**通过id获取数据
* @param pd
* @throws Exception
*/
public PageData findById(PageData pd)throws Exception{
return hotworkLogCfdMapper.findById(pd);
}
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
public void deleteAll(String[] ArrayDATA_IDS)throws Exception{
hotworkLogCfdMapper.deleteAll(ArrayDATA_IDS);
}
}

83
src/main/java/com/zcloud/service/highriskwork/impl/HotworkToMeasuresCfdServiceImpl.java Normal file
View File

@ -0,0 +1,83 @@
package com.zcloud.service.highriskwork.impl;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.highriskwork.HotworkToMeasuresCfdMapper;
import com.zcloud.service.highriskwork.HotworkToMeasuresCfdService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
* 说明：动火措施中间表
* 作者：luoxiaobao
* 时间：2021-09-18
* 官网：www.zcloudchina.com
*/
@Service
@Transactional //开启事物
public class HotworkToMeasuresCfdServiceImpl implements HotworkToMeasuresCfdService {
@Autowired
private HotworkToMeasuresCfdMapper hotworkToMeasuresCfdMapper;
/**新增
* @param pd
* @throws Exception
*/
public void save(PageData pd)throws Exception{
hotworkToMeasuresCfdMapper.save(pd);
}
/**删除
* @param pd
* @throws Exception
*/
public void delete(PageData pd)throws Exception{
hotworkToMeasuresCfdMapper.delete(pd);
}
/**修改
* @param pd
* @throws Exception
*/
public void edit(PageData pd)throws Exception{
hotworkToMeasuresCfdMapper.edit(pd);
}
/**列表
* @param page
* @throws Exception
*/
public List<PageData> list(Page page)throws Exception{
return hotworkToMeasuresCfdMapper.datalistPage(page);
}
/**列表(全部)
* @param pd
* @throws Exception
*/
public List<PageData> listAll(PageData pd)throws Exception{
return hotworkToMeasuresCfdMapper.listAll(pd);
}
/**通过id获取数据
* @param pd
* @throws Exception
*/
public PageData findById(PageData pd)throws Exception{
return hotworkToMeasuresCfdMapper.findById(pd);
}
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
public void deleteAll(String[] ArrayDATA_IDS)throws Exception{
hotworkToMeasuresCfdMapper.deleteAll(ArrayDATA_IDS);
}
}

11
src/main/java/com/zcloud/service/mq/LogService.java Normal file
View File

@ -0,0 +1,11 @@
package com.zcloud.service.mq;
import com.zcloud.entity.PageData;
public interface LogService {
void saveLog(PageData pageData);
void saveLog(PageData pageData,String type);
void saveErrorMessage(PageData pageData,String errorMessage);
}

11
src/main/java/com/zcloud/service/mq/SendMessageService.java Normal file
View File

@ -0,0 +1,11 @@
package com.zcloud.service.mq;
import com.zcloud.dto.TenCorpDto;
public interface SendMessageService {
void sendMessage(TenCorpDto tenCorpDto) throws Exception;
void SendDelayQueue(TenCorpDto tenCorpDto);
void SendDelayQueue(String message);
}

43
src/main/java/com/zcloud/service/mq/impl/LogServiceImpl.java Normal file
View File

@ -0,0 +1,43 @@
package com.zcloud.service.mq.impl;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.mq.MqErrorMessageLogMapper;
import com.zcloud.mapper.datasource.mq.MqMessageLogMapper;
import com.zcloud.service.mq.LogService;
import com.zcloud.util.DateUtil;
import com.zcloud.util.Warden;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@Service
public class LogServiceImpl implements LogService {
@Resource
private MqErrorMessageLogMapper mqErrorMessageLogMapper;
@Resource
private MqMessageLogMapper mqMessageLogMapper;
@Override
@Async
public void saveLog(PageData pageData) {
this.saveLog(pageData,"0");
}
@Override
public void saveLog(PageData pageData, String type) {
}
@Override
@Async
public void saveErrorMessage(PageData log,String errorMessage) {
log.put("ERROR_MESSAGE", errorMessage);
log.put("MESSAGE_ERROR_LOG_ID", Warden.get32UUID());
log.put("TYPE", "0");
log.put("TIME", DateUtil.getTime());
mqErrorMessageLogMapper.save(log);
}
}

129
src/main/java/com/zcloud/service/mq/impl/SendMessageServiceImpl.java Normal file
View File

@ -0,0 +1,129 @@
package com.zcloud.service.mq.impl;
import com.alibaba.fastjson.JSONObject;
import com.zcloud.dto.TenCorpDto;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.mq.MqErrorMessageLogMapper;
import com.zcloud.mapper.datasource.mq.MqMessageLogMapper;
import com.zcloud.service.mq.LogService;
import com.zcloud.service.mq.SendMessageService;
import com.zcloud.util.DateUtil;
import com.zcloud.util.Warden;
import com.zcloud.util.mq.MqUtil;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.client.producer.SendStatus;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.messaging.support.GenericMessage;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@Service
public class SendMessageServiceImpl implements SendMessageService {
@Value("${mq.topic.info}")
private String info;
@Resource
private RocketMQTemplate rocketMQTemplate;
@Resource
private MqErrorMessageLogMapper mqErrorMessageLogMapper;
@Resource
private LogService logService;
@Resource
private MqMessageLogMapper mqMessageLogMapper;
public void sendMessage(TenCorpDto tenCorpDto) throws Exception {
try {
PageData log = tenCorpDto.getPd();
log.put("MESSAGE_LOG_ID", Warden.get32UUID());
log.put("CREATE_TIME", DateUtil.getTime());
mqMessageLogMapper.save(log);
System.out.println("生产者:" + tenCorpDto.toString());
SendResult sendResult = rocketMQTemplate.syncSend(this.info, tenCorpDto.toString());
if (!sendResult.getSendStatus().equals(SendStatus.SEND_OK)) {
throw new RuntimeException("产品入栈失败");
}
} catch (Exception e) {
e.printStackTrace();
PageData log = tenCorpDto.getPd();
log.put("MESSAGE_ERROR_LOG_ID", Warden.get32UUID());
log.put("ERROR_MESSAGE", e.getMessage());
log.put("TYPE", "0");
log.put("TIME", DateUtil.getTime());
mqErrorMessageLogMapper.save(log);
}
}
@Override
public void SendDelayQueue(TenCorpDto tenCorpDto) {
PageData log = tenCorpDto.getPd();
log.put("MESSAGE_LOG_ID", Warden.get32UUID());
try {
log.put("CREATE_TIME", DateUtil.getTime());
log.put("PRODUCER_NAME",tenCorpDto.getProducer_name());
log.put("TYPE","0");
log.put("PLAN_TIME",tenCorpDto.getTime_stamp());
mqMessageLogMapper.save(log);
System.out.println("生产者:" + tenCorpDto.toString());
// 推送消息
SendResult sendResult = rocketMQTemplate.syncSend(
MqUtil.analysistopic(tenCorpDto.getTopic()),
new GenericMessage<>(tenCorpDto.toString()),
3000,
MqUtil.analysisTime(tenCorpDto.getTime_stamp()));
if (!sendResult.getSendStatus().equals(SendStatus.SEND_OK)) {
throw new RuntimeException("产品入栈失败");
}
} catch (Exception e) {
e.printStackTrace();
log.put("ERROR_MESSAGE", e.getMessage());
log.put("MESSAGE_ERROR_LOG_ID", Warden.get32UUID());
log.put("TYPE", "0");
log.put("TIME", DateUtil.getTime());
mqErrorMessageLogMapper.save(log);
}
}
@Override
public void SendDelayQueue(String message) {
TenCorpDto tenCorpDto = JSONObject.parseObject(message,TenCorpDto.class);
try {
PageData log = tenCorpDto.getPd();
log.put("CREATE_TIME", DateUtil.getTime());
log.put("PRODUCER_NAME",tenCorpDto.getProducer_name());
log.put("MESSAGE_LOG_ID", Warden.get32UUID());
mqMessageLogMapper.save(log);
System.out.println("生产者:" + tenCorpDto.toString());
// 推送消息
SendResult sendResult = rocketMQTemplate.syncSend(
MqUtil.analysistopic(tenCorpDto.getTopic()),
new GenericMessage<>(message),
3000,
MqUtil.analysisTime(tenCorpDto.getTime_stamp()));
if (!sendResult.getSendStatus().equals(SendStatus.SEND_OK)) {
throw new RuntimeException("产品入栈失败");
}
} catch (Exception e) {
PageData log = tenCorpDto.getPd();
logService.saveErrorMessage(log,e.getMessage());
e.printStackTrace();
}
}
public static void main(String[] args) {
try {
System.out.println(MqUtil.analysisTime("2023-06-30 14:30:00:000"));
}catch (Exception e){
e.printStackTrace();
}
}
}

67
src/main/java/com/zcloud/service/specialoperation/PersonnelManagementCfdService.java Normal file
View File

@ -0,0 +1,67 @@
package com.zcloud.service.specialoperation;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
* 说明：特种作业人员管理
* 作者：luoxiaobao
* 时间：2022-06-16
* 官网：www.zcloudchina.com
*/
public interface PersonnelManagementCfdService {
/**新增
* @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;
public List<PageData> namelist(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
* @return
* @throws Exception
*/
public PageData findByCertificate(PageData pd)throws Exception;
}

95
src/main/java/com/zcloud/service/specialoperation/impl/PersonnelManagementCfdServiceImpl.java Normal file
View File

@ -0,0 +1,95 @@
package com.zcloud.service.specialoperation.impl;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.specialoperation.PersonnelManagementCfdMapper;
import com.zcloud.service.specialoperation.PersonnelManagementCfdService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
* 说明：特种作业人员管理
* 作者：luoxiaobao
* 时间：2022-06-16
* 官网：www.zcloudchina.com
*/
@Service
@Transactional //开启事物
public class PersonnelManagementCfdServiceImpl implements PersonnelManagementCfdService {
@Autowired
private PersonnelManagementCfdMapper personnelmanagementCfdMapper;
/**新增
* @param pd
* @throws Exception
*/
public void save(PageData pd)throws Exception{
personnelmanagementCfdMapper.save(pd);
}
/**删除
* @param pd
* @throws Exception
*/
public void delete(PageData pd)throws Exception{
personnelmanagementCfdMapper.delete(pd);
}
/**修改
* @param pd
* @throws Exception
*/
public void edit(PageData pd)throws Exception{
personnelmanagementCfdMapper.edit(pd);
}
/**列表
* @param page
* @throws Exception
*/
public List<PageData> list(Page page)throws Exception{
return personnelmanagementCfdMapper.datalistPage(page);
}
/**列表(全部)
* @param pd
* @throws Exception
*/
public List<PageData> listAll(PageData pd)throws Exception{
return personnelmanagementCfdMapper.listAll(pd);
}
public List<PageData> namelist(PageData pd)throws Exception{
return personnelmanagementCfdMapper.namelist(pd);
}
/**通过id获取数据
* @param pd
* @throws Exception
*/
public PageData findById(PageData pd)throws Exception{
return personnelmanagementCfdMapper.findById(pd);
}
/**批量删除
* @param ArrayDATA_IDS
* @throws Exception
*/
public void deleteAll(String[] ArrayDATA_IDS)throws Exception{
personnelmanagementCfdMapper.deleteAll(ArrayDATA_IDS);
}
/**
* 判断特种作业证书编号是否存在
* @param pd
* @return
* @throws Exception
*/
public PageData findByCertificate(PageData pd) throws Exception {
return personnelmanagementCfdMapper.findByCertificate(pd);
}
}

2
src/main/java/com/zcloud/service/system/DictionariesService.java
View File

@ -34,6 +34,8 @@ public interface DictionariesService {
*/
public PageData findById(PageData pd)throws Exception;
public List<PageData> getTreeById(String id) throws Exception;
/**通过id获取数据
* @param pd
* @throws Exception

7
src/main/java/com/zcloud/service/system/UsersService.java
View File

@ -28,6 +28,13 @@ public interface UsersService {
*/
public PageData findByUsername(PageData pd)throws Exception;
/**
* 获取全部用户信息列表
* @return
* @throws Exception
*/
Object getAllUserList()throws Exception;
/**通过组ID获取组下级角色列表
* @param pd
* @return

13
src/main/java/com/zcloud/service/system/impl/DictionariesServiceImpl.java
View File

@ -4,6 +4,7 @@ import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -64,6 +65,18 @@ public class DictionariesServiceImpl implements DictionariesService {
return dictionariesMapper.listSubDictByParentIdAndCourseware(pd);
}
@Override
public List<PageData> getTreeById(String id) throws Exception {
List<Dictionaries> _list = this.listSubDictByParentId(id); //用传过来的ID获取此ID下的子列表数据
return _list.stream().map(n -> {
PageData entity = new PageData();
entity.put("DICTIONARIES_ID", n.getDICTIONARIES_ID());
entity.put("BIANMA", n.getBIANMA());
entity.put("NAME", n.getNAME());
return entity;
}).collect(Collectors.toList());
}
/**
* 获取所有数据并填充每条数据的子级列表(递归处理)用于代码生成器引用数据字典
* @param MENU_ID

34
src/main/java/com/zcloud/service/system/impl/UsersServiceImpl.java
View File

@ -79,6 +79,40 @@ public class UsersServiceImpl implements UsersService {
return usersMapper.findById(pd);
}
/**
* 获取全部用户信息列表
* @return
* @throws Exception
*/
@Override
@Transactional
public Object getAllUserList() throws Exception {
Map<String,Object> map = new HashMap<>();
String errInfo = "success";
// List<PageData> varList = new ArrayList<>();
// List<PageData> corpInfoList = corpInfoMapper.getAllCorpInfoList();
// 所有企业列表
// Map<String, Object> corpInfoListMap = new HashMap<>();
// Map<String, Object> corpInfoListMapLived = new HashMap<>();
// for (PageData pageData : corpInfoList) {
// corpInfoListMap.put(pageData.getString("CORPINFO_ID"),pageData);
// }
// 所有部门列表
// List<PageData> departmentList = departmentMapper.getAllDepartmentList();
// Map<String, Object> departmentListMap = new HashMap<>();
// for (PageData pageData : departmentList) {
// departmentListMap.put(pageData.getString("DEPARTMENT_ID"),pageData);
// }
// 所有人员列表
List<PageData> userList = usersMapper.getAllUserList();
map.put("userList", userList);
map.put("result",errInfo);
return map;
}
/**通过用户ID获取用户信息
* @param pd
* @return

3
src/main/java/com/zcloud/util/Const.java
View File

@ -55,5 +55,8 @@ public class Const {
public final static String OA_APPID = "wx69f7e25b3760001c";//公众号
public final static String OA_SECRET = "087fe91f660300df63d0ef16fd162124";//公众号
// mq
public static final String topic_eightWork="eightWork";
public static final String topic_info="info";
}

4
src/main/java/com/zcloud/util/Warden.java
View File

@ -42,6 +42,10 @@ public class Warden {
return JSON.parseObject(raw.toJSONString(), PageData.class);
}
public static <T> List<T> getList(String raw, Class<T> clazz) {
return JSON.parseArray(raw, clazz);
}
public static void initData(PageData entity) {
entity.put("CREATE_TIME", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
entity.put("CRATED_DATE", new Date());

49
src/main/java/com/zcloud/util/mq/MqSendUtil.java Normal file
View File

@ -0,0 +1,49 @@
package com.zcloud.util.mq;
import com.zcloud.dto.Response;
import com.zcloud.dto.TenCorpDto;
import com.zcloud.service.mq.SendMessageService;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
/**
* @author zhangyue
* @date 2023/9/23/023 13:54
*/
@Component
public class MqSendUtil {
@Resource
private SendMessageService sendMessageService;
public Response sendMessage(TenCorpDto tenCorpDto) throws Exception {
try {
sendMessageService.sendMessage(tenCorpDto);
} catch (Exception e) {
e.printStackTrace();
}
return Response.OK();
}
public Response timelyQueue(TenCorpDto tenCorpDto) throws Exception {
try {
sendMessageService.sendMessage(tenCorpDto);
} catch (Exception e) {
e.printStackTrace();
}
return Response.OK();
}
public Response sendDelayQueue(TenCorpDto tenCorpDto) throws Exception {
try {
sendMessageService.SendDelayQueue(tenCorpDto);
return Response.OK();
} catch (Exception e) {
e.printStackTrace();
return Response.ERROR(e.getMessage());
}
}
}

87
src/main/java/com/zcloud/util/mq/MqUtil.java Normal file
View File

@ -0,0 +1,87 @@
package com.zcloud.util.mq;
import com.zcloud.util.Const;
import java.text.SimpleDateFormat;
import java.util.Date;
public class MqUtil {
private final static SimpleDateFormat timeFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS");
public static Integer analysisTime(String time) throws Exception{
Date agreed_date = timeFormat.parse(time);
long time_difference = agreed_date.getTime() - new Date().getTime();
if (time_difference < 0){
return 0;
}
if (time_difference > 2*60*60*1000){
return 18;
}
if (time_difference > 60 * 60 * 1000){
return 17;
}
if (time_difference > 30 * 60 * 1000){
return 16;
}
if (time_difference > 20 * 60 * 1000){
return 15;
}
if (time_difference > 10 * 60 * 1000){
return 14;
}
if (time_difference > 9 * 60 * 1000){
return 13;
}
if (time_difference > 8 * 60 * 1000){
return 12;
}
if (time_difference > 7 * 60 * 1000){
return 11;
}
if (time_difference > 6 * 60 * 1000){
return 10;
}
if (time_difference > 5 * 60 * 1000){
return 9;
}
if (time_difference > 4 * 60 * 1000){
return 8;
}
if (time_difference > 3 * 60 * 1000){
return 7;
}
if (time_difference > 2 * 60 * 1000){
return 6;
}
if (time_difference > 60 * 1000){
return 5;
}
if (time_difference > 30 * 1000){
return 4;
}
if (time_difference > 10 * 1000){
return 3;
}
// if (time_difference > 5 * 1000){
// return 2;
// }
if (time_difference > 1000){
return 2;
}
return 0;
}
public static String analysistopic(String producerName) {
switch (producerName){
case "eightWork" : return Const.topic_eightWork;
case "info" : return Const.topic_info;
default: return "";
}
}
public static Date dateFormat(String date) throws Exception{
return timeFormat.parse(date);
}
}

275
src/main/resources/mybatis/datasource/eightWork/EightWorkCfdMapper.xml Normal file
View File

@ -0,0 +1,275 @@
<?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.eightWork.EightWorkCfdMapper">
<!-- &lt;!&ndash;表名 &ndash;&gt;-->
<!-- <sql id="tableName">-->
<!-- BUS_CONFINEDSPACE-->
<!-- </sql>-->
<!-- &lt;!&ndash;数据字典表名 &ndash;&gt;-->
<!-- <sql id="dicTableName">-->
<!-- SYS_DICTIONARIES-->
<!-- </sql>-->
<!-- &lt;!&ndash; 字段 &ndash;&gt;-->
<!-- <sql id="Field">-->
<!-- f.CORPINFO_ID,-->
<!-- f.ISDELETE,-->
<!-- f.CREATTIME,-->
<!-- f.CREATOR,-->
<!-- f.OPERATTIME,-->
<!-- f.OPERATOR,-->
<!-- f.CHECK_NO,-->
<!-- f.WORK_CONTENT,-->
<!-- f.WORK_START_DATE,-->
<!-- f.WORK_END_DATE,-->
<!-- f.CONFIRM_DEPARTMENT_ID,-->
<!-- f.CONFIRM_USER_ID,-->
<!-- f.CONFIRM_USER_SIGNER_PATH,-->
<!-- f.CONFIRM_USER_SIGNER_TIME,-->
<!-- f.AUDIT_DEPARTMENT_ID,-->
<!-- f.AUDIT_USER_ID,-->
<!-- f.AUDIT_USER_SIGNER_PATH,-->
<!-- f.AUDIT_USER_SIGNER_TIME,-->
<!-- f.APPROVE_DEPARTMENT_ID,-->
<!-- f.APPROVE_USER_ID,-->
<!-- f.APPROVE_USER_SIGNER_PATH,-->
<!-- f.APPROVE_USER_SIGNER_TIME,-->
<!-- f.APPLY_STATUS,-->
<!-- f.CONFIRM_CONTENT,-->
<!-- f.AUDIT_CONTENT,-->
<!-- f.APPROVE_CONTENT,-->
<!-- f.OTHER_PROTECTIVE_MEASURES,-->
<!-- f.ACCEPT_DEPARTMENT_ID,-->
<!-- f.ACCEPT_USER_ID,-->
<!-- f.ACCEPT_USER_SIGNER_PATH,-->
<!-- f.ACCEPT_USER_SIGNER_TIME,-->
<!-- f.ACCEPT_CONTENT,-->
<!-- f.APPLY_DEPARTMENT_ID,-->
<!-- f.APPLY_USER_ID,-->
<!-- f.BELONG_CORP,-->
<!-- f.LIMITSPACE_ID,-->
<!-- f.WORK_USER,-->
<!-- f.SPECIAL_WORK,-->
<!-- f.RISK_IDENTIFICATION,-->
<!-- f.MEDIUM_NAME,-->
<!-- f.EDUCATE_USER,-->
<!-- f.ANALYZE_DEPARTMENT_ID,-->
<!-- f.ANALYZE_USER_ID,-->
<!-- f.GUARDIAN_DEPARTMENT_ID,-->
<!-- f.GUARDIAN_USER_ID,-->
<!-- f.GUARDIAN_USER_SIGNER_PATH,-->
<!-- f.GUARDIAN_USER_SIGNER_TIME,-->
<!-- f.GUARDIAN_CONTENT,-->
<!-- f.CONFESS_USER,-->
<!-- f.ACCEPT_CONFESS_USER,-->
<!-- f.GUARDIAN_USER,-->
<!-- f.CONFINEDSPACE_ID,-->
<!-- f.CONFESS_DEPARTMENT_ID,-->
<!-- f.CONFESS_USER_ID,-->
<!-- f.CONFESS_USER_SIGNER_PATH,-->
<!-- f.CONFESS_USER_SIGNER_TIME,-->
<!-- f.ACCEPT_CONFESS_DEPARTMENT_ID,-->
<!-- f.ACCEPT_CONFESS_USER_ID,-->
<!-- f.ACCEPT_CONFESS_USER_SIGNER_PATH,-->
<!-- f.ACCEPT_CONFESS_USER_SIGNER_TIME-->
<!-- </sql>-->
<!-- &lt;!&ndash; 字段用于新增 &ndash;&gt;-->
<!-- <sql id="Field2">-->
<!-- CORPINFO_ID,-->
<!-- ISDELETE,-->
<!-- CREATTIME,-->
<!-- CREATOR,-->
<!-- OPERATTIME,-->
<!-- OPERATOR,-->
<!-- CHECK_NO,-->
<!-- WORK_CONTENT,-->
<!-- WORK_START_DATE,-->
<!-- WORK_END_DATE,-->
<!-- CONFIRM_DEPARTMENT_ID,-->
<!-- CONFIRM_USER_ID,-->
<!-- CONFIRM_USER_SIGNER_PATH,-->
<!-- CONFIRM_USER_SIGNER_TIME,-->
<!-- AUDIT_DEPARTMENT_ID,-->
<!-- AUDIT_USER_ID,-->
<!-- AUDIT_USER_SIGNER_PATH,-->
<!-- AUDIT_USER_SIGNER_TIME,-->
<!-- APPROVE_DEPARTMENT_ID,-->
<!-- APPROVE_USER_ID,-->
<!-- APPROVE_USER_SIGNER_PATH,-->
<!-- APPROVE_USER_SIGNER_TIME,-->
<!-- APPLY_STATUS,-->
<!-- CONFIRM_CONTENT,-->
<!-- AUDIT_CONTENT,-->
<!-- APPROVE_CONTENT,-->
<!-- OTHER_PROTECTIVE_MEASURES,-->
<!-- ACCEPT_DEPARTMENT_ID,-->
<!-- ACCEPT_USER_ID,-->
<!-- ACCEPT_USER_SIGNER_PATH,-->
<!-- ACCEPT_USER_SIGNER_TIME,-->
<!-- ACCEPT_CONTENT,-->
<!-- APPLY_DEPARTMENT_ID,-->
<!-- APPLY_USER_ID,-->
<!-- BELONG_CORP,-->
<!-- LIMITSPACE_ID,-->
<!-- WORK_USER,-->
<!-- SPECIAL_WORK,-->
<!-- RISK_IDENTIFICATION,-->
<!-- MEDIUM_NAME,-->
<!-- EDUCATE_USER,-->
<!-- ANALYZE_DEPARTMENT_ID,-->
<!-- ANALYZE_USER_ID,-->
<!-- GUARDIAN_DEPARTMENT_ID,-->
<!-- GUARDIAN_USER_ID,-->
<!-- GUARDIAN_USER_SIGNER_PATH,-->
<!-- GUARDIAN_USER_SIGNER_TIME,-->
<!-- GUARDIAN_CONTENT,-->
<!-- CONFESS_USER,-->
<!-- ACCEPT_CONFESS_USER,-->
<!-- GUARDIAN_USER,-->
<!-- CONFINEDSPACE_ID,-->
<!-- CONFESS_DEPARTMENT_ID,-->
<!-- CONFESS_USER_ID,-->
<!-- CONFESS_USER_SIGNER_PATH,-->
<!-- CONFESS_USER_SIGNER_TIME,-->
<!-- ACCEPT_CONFESS_DEPARTMENT_ID,-->
<!-- ACCEPT_CONFESS_USER_ID,-->
<!-- ACCEPT_CONFESS_USER_SIGNER_PATH,-->
<!-- ACCEPT_CONFESS_USER_SIGNER_TIME-->
<!-- </sql>-->
<!-- &lt;!&ndash; 字段值 &ndash;&gt;-->
<!-- <sql id="FieldValue">-->
<!-- #{CORPINFO_ID},-->
<!-- #{ISDELETE},-->
<!-- #{CREATTIME},-->
<!-- #{CREATOR},-->
<!-- #{OPERATTIME},-->
<!-- #{OPERATOR},-->
<!-- #{CHECK_NO},-->
<!-- #{WORK_CONTENT},-->
<!-- #{WORK_START_DATE},-->
<!-- #{WORK_END_DATE},-->
<!-- #{CONFIRM_DEPARTMENT_ID},-->
<!-- #{CONFIRM_USER_ID},-->
<!-- #{CONFIRM_USER_SIGNER_PATH},-->
<!-- #{CONFIRM_USER_SIGNER_TIME},-->
<!-- #{AUDIT_DEPARTMENT_ID},-->
<!-- #{AUDIT_USER_ID},-->
<!-- #{AUDIT_USER_SIGNER_PATH},-->
<!-- #{AUDIT_USER_SIGNER_TIME},-->
<!-- #{APPROVE_DEPARTMENT_ID},-->
<!-- #{APPROVE_USER_ID},-->
<!-- #{APPROVE_USER_SIGNER_PATH},-->
<!-- #{APPROVE_USER_SIGNER_TIME},-->
<!-- #{APPLY_STATUS},-->
<!-- #{CONFIRM_CONTENT},-->
<!-- #{AUDIT_CONTENT},-->
<!-- #{APPROVE_CONTENT},-->
<!-- #{OTHER_PROTECTIVE_MEASURES},-->
<!-- #{ACCEPT_DEPARTMENT_ID},-->
<!-- #{ACCEPT_USER_ID},-->
<!-- #{ACCEPT_USER_SIGNER_PATH},-->
<!-- #{ACCEPT_USER_SIGNER_TIME},-->
<!-- #{ACCEPT_CONTENT},-->
<!-- #{APPLY_DEPARTMENT_ID},-->
<!-- #{APPLY_USER_ID},-->
<!-- #{BELONG_CORP},-->
<!-- #{LIMITSPACE_ID},-->
<!-- #{WORK_USER},-->
<!-- #{SPECIAL_WORK},-->
<!-- #{RISK_IDENTIFICATION},-->
<!-- #{MEDIUM_NAME},-->
<!-- #{EDUCATE_USER},-->
<!-- #{ANALYZE_DEPARTMENT_ID},-->
<!-- #{ANALYZE_USER_ID},-->
<!-- #{GUARDIAN_DEPARTMENT_ID},-->
<!-- #{GUARDIAN_USER_ID},-->
<!-- #{GUARDIAN_USER_SIGNER_PATH},-->
<!-- #{GUARDIAN_USER_SIGNER_TIME},-->
<!-- #{GUARDIAN_CONTENT},-->
<!-- #{CONFESS_USER},-->
<!-- #{ACCEPT_CONFESS_USER},-->
<!-- #{GUARDIAN_USER},-->
<!-- #{CONFINEDSPACE_ID},-->
<!-- #{CONFESS_DEPARTMENT_ID},-->
<!-- #{CONFESS_USER_ID},-->
<!-- #{CONFESS_USER_SIGNER_PATH},-->
<!-- #{CONFESS_USER_SIGNER_TIME},-->
<!-- #{ACCEPT_CONFESS_DEPARTMENT_ID},-->
<!-- #{ACCEPT_CONFESS_USER_ID},-->
<!-- #{ACCEPT_CONFESS_USER_SIGNER_PATH},-->
<!-- #{ACCEPT_CONFESS_USER_SIGNER_TIME}-->
<!-- </sql>-->
<!-- 列表 -->
<select id="datalist" parameterType="page" resultType="pd">
select
CONCAT_WS(" ","受限空间作业",f.CHECK_NO) as CHECK_NO,f.CONFINEDSPACE_ID as ID
from
bus_confinedspace_cfd f
where f.ISDELETE = '0' and f.APPLY_STATUS &gt; 0 and f.APPLY_STATUS &lt; 6 and f.CORPINFO_ID = #{pd.CORPINFO_ID}
union
select
CONCAT_WS(" ","盲板抽堵作业",b.CHECK_NO) as CHECK_NO,b.BLINDBOARD_ID as ID
from
bus_blindboard b
where b.CORPINFO_ID = #{pd.CORPINFO_ID} and b.APPLY_STATUS &gt; 0 and b.APPLY_STATUS &lt; 6 and b.ISDELETE = '0'
union
select
CONCAT_WS(" ","临时用电作业",e.CHECK_NO) as CHECK_NO,e.ELECTRICITY_ID as ID
from
bus_electricity e
where e.CORPINFO_ID = #{pd.CORPINFO_ID} and e.APPLY_STATUS &gt; 0 and e.APPLY_STATUS &lt; 5 and e.ISDELETE = '0'
union
select
CONCAT_WS(" ","吊装作业",g.CHECK_NO) as CHECK_NO,g.HOISTING_ID as ID
from
bus_hoisting_cfd g
where g.CORPINFO_ID = #{pd.CORPINFO_ID} and g.APPLY_STATUS &gt; 0 and g.APPLY_STATUS &lt; 6 and g.ISDELETE = '0'
union
select
CONCAT_WS(" ","动土作业",a.CHECK_NO) as CHECK_NO ,a.BREAKGROUND_ID as ID
from
bus_breakground a
where a.CORPINFO_ID = #{pd.CORPINFO_ID} and a.APPLY_STATUS &gt; 0 and a.APPLY_STATUS &lt; 6 and a.ISDELETE = '0'
union
select
CONCAT_WS(" ","断路作业",d.CHECK_NO) as CHECK_NO,d.CUTROAD_ID as ID
from
bus_cutroad d
where d.CORPINFO_ID = #{pd.CORPINFO_ID} and d.APPLY_STATUS &gt; 0 and d.APPLY_STATUS &lt; 6 and d.ISDELETE = '0'
union
select
CONCAT_WS(" ","高处作业",w.CHECK_NO) as CHECK_NO,w.HIGHWORK_ID as ID
from
bus_highwork w
where w.CORPINFO_ID = #{pd.CORPINFO_ID} and w.APPLY_STATUS &gt; 0 and w.APPLY_STATUS &lt; 6 and w.ISDELETE = '0'
union
select
CONCAT_WS(" ","动火作业",h.CHECK_NO) as CHECK_NO,h.HOTWORK_ID as ID
from
bus_hotwork_cfd h
where h.CORPINFO_ID = #{pd.CORPINFO_ID} and h.APPLY_STATUS &gt; 0 and h.APPLY_STATUS &lt; 8 and h.ISDELETE = '0'
</select>
<select id="getWorkUserLabels" parameterType="java.util.List" resultType="pd">
select
if (CONCAT(c.CORP_NAME,'-',d.NAME,'-',f.NAME) is not null ,CONCAT(c.CORP_NAME,'-',d.NAME,'-',f.NAME), '') as label
from
SYS_USER f
left join BUS_CORP_INFO c on f.CORPINFO_ID = c.CORPINFO_ID
left join OA_DEPARTMENT d on d.DEPARTMENT_ID = f.DEPARTMENT_ID
where f.USER_ID in
<foreach collection="list" open="(" separator="," close=")" item="item" index="index">
#{item}
</foreach>
</select>
</mapper>

217
src/main/resources/mybatis/datasource/highriskwork/HotworkAcceptUserCfdMapper.xml Normal file
View File

@ -0,0 +1,217 @@
<?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.highriskwork.HotworkAcceptUserCfdMapper">
<!--表名 -->
<sql id="tableName">
BUS_HOTWORK_ACCEPTUSER_CFD
</sql>
<!--数据字典表名 -->
<sql id="dicTableName">
SYS_DICTIONARIES
</sql>
<sql id="Field">
f.ACCEPT_CONFESS_ID,
f.HOTWORK_ID,
f.CORPINFO_ID,
f.ISDELETE,
f.OPERATTIME,
f.OPERATOR,
f.ACCEPT_CONFESS_DEPARTMENT_ID,
f.ACCEPT_CONFESS_USER_ID,
f.ACCEPT_CONFESS_USER_SIGNER_PATH,
f.ACCEPT_CONFESS_USER_SIGNER_TIME,
f.ISSELF,
f.ACCEPT_USER_ID,
f.ACCEPT_USER_SIGNER_PATH,
f.ACCEPT_USER_SIGNER_TIME,
f.ACCEPT_DEPARTMENT_ID
</sql>
<!-- 字段用于新增 -->
<sql id="Field2">
ACCEPT_CONFESS_ID,
HOTWORK_ID,
CORPINFO_ID,
ISDELETE,
OPERATTIME,
OPERATOR,
ACCEPT_CONFESS_DEPARTMENT_ID,
ACCEPT_CONFESS_USER_ID,
ACCEPT_CONFESS_USER_SIGNER_PATH,
ACCEPT_CONFESS_USER_SIGNER_TIME,
ISSELF,
ACCEPT_USER_ID,
ACCEPT_USER_SIGNER_PATH,
ACCEPT_USER_SIGNER_TIME,
ACCEPT_DEPARTMENT_ID
</sql>
<!-- 字段值 -->
<sql id="FieldValue">
#{ACCEPT_CONFESS_ID},
#{HOTWORK_ID},
#{CORPINFO_ID},
#{ISDELETE},
#{OPERATTIME},
#{OPERATOR},
#{ACCEPT_CONFESS_DEPARTMENT_ID},
#{ACCEPT_CONFESS_USER_ID},
#{ACCEPT_CONFESS_USER_SIGNER_PATH},
#{ACCEPT_CONFESS_USER_SIGNER_TIME},
#{ISSELF},
#{ACCEPT_USER_ID},
#{ACCEPT_USER_SIGNER_PATH},
#{ACCEPT_USER_SIGNER_TIME},
#{ACCEPT_DEPARTMENT_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
ACCEPT_CONFESS_ID = #{ACCEPT_CONFESS_ID}
</delete>
<!-- 修改 -->
<update id="edit" parameterType="pd">
update
<include refid="tableName"></include>
set
ACCEPT_CONFESS_ID = #{ACCEPT_CONFESS_ID},
HOTWORK_ID = #{HOTWORK_ID},
CORPINFO_ID = #{CORPINFO_ID},
OPERATTIME = #{OPERATTIME},
OPERATOR = #{OPERATOR},
ACCEPT_CONFESS_DEPARTMENT_ID = #{ACCEPT_CONFESS_DEPARTMENT_ID},
ACCEPT_CONFESS_USER_ID = #{ACCEPT_CONFESS_USER_ID},
ACCEPT_CONFESS_USER_SIGNER_PATH = #{ACCEPT_CONFESS_USER_SIGNER_PATH},
ACCEPT_CONFESS_USER_SIGNER_TIME = #{ACCEPT_CONFESS_USER_SIGNER_TIME},
ISSELF = #{ISSELF}
where
ACCEPT_CONFESS_ID = #{ACCEPT_CONFESS_ID}
</update>
<!-- 通过ID获取数据 -->
<select id="findById" parameterType="pd" resultType="pd">
select
f.ACCEPT_CONFESS_ID,
f.HOTWORK_ID,
f.CORPINFO_ID,
f.ISDELETE,
f.OPERATTIME,
f.OPERATOR,
f.ACCEPT_USER_ID,
f.ACCEPT_USER_SIGNER_PATH,
f.ACCEPT_USER_SIGNER_TIME,
f.ACCEPT_DEPARTMENT_ID
from
<include refid="tableName"></include> f
where
f.HOTWORK_ID = #{HOTWORK_ID} and f.CORPINFO_ID = #{CORPINFO_ID} and f.ACCEPT_USER_ID = #{ACCEPT_USER_ID}
order by f.ACCEPT_USER_SIGNER_TIME asc
</select>
<select id="findByIds" parameterType="pd" resultType="pd">
select
f.ACCEPT_CONFESS_ID,
f.HOTWORK_ID,
f.CORPINFO_ID,
f.ISDELETE,
f.OPERATTIME,
f.OPERATOR,
f.ACCEPT_CONFESS_DEPARTMENT_ID,
f.ACCEPT_CONFESS_USER_ID,
f.ACCEPT_CONFESS_USER_SIGNER_PATH,
f.ACCEPT_CONFESS_USER_SIGNER_TIME
from
<include refid="tableName"></include> f
where
f.HOTWORK_ID = #{HOTWORK_ID} and f.CORPINFO_ID = #{CORPINFO_ID} and f.ACCEPT_CONFESS_USER_ID = #{ACCEPT_CONFESS_USER_ID}
order by f.ACCEPT_CONFESS_USER_SIGNER_TIME asc
</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>
</select>
<!-- 列表(全部) -->
<select id="listAll" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where 1=1
<if test="ISSELF != null and ISSELF != ''"><!-- 关键词检索 -->
and
f.ISSELF=#{ISSELF}
</if>
<if test="HOTWORK_ID != null and HOTWORK_ID != ''"><!-- 关键词检索 -->
and
f.HOTWORK_ID=#{HOTWORK_ID}
</if>
</select>
<!-- 批量删除 -->
<delete id="deleteAll" parameterType="String">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
ACCEPT_CONFESS_ID in
<foreach item="item" index="index" collection="ArrayDATA_IDS" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
<!-- 列表 -->
<select id="listAllByIds" parameterType="String" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where 1=1
<if test="ArrayDATA_IDS != null and ArrayDATA_IDS != ''"><!-- 关键词检索 -->
and f.ACCEPT_CONFESS_ID in
<foreach item="item" index="index" collection="ArrayDATA_IDS" open="(" separator="," close=")">
#{item}
</foreach>
</if>
</select>
</mapper>

1713
src/main/resources/mybatis/datasource/highriskwork/HotworkCfdMapper.xml Normal file
View File

File diff suppressed because it is too large Load Diff

138
src/main/resources/mybatis/datasource/highriskwork/HotworkGasCfdMapper.xml Normal file
View File

@ -0,0 +1,138 @@
<?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.highriskwork.HotworkGasCfdMapper">
<!--表名 -->
<sql id="tableName">
BUS_HOTWORKGAS_CFD
</sql>
<!--数据字典表名 -->
<sql id="dicTableName">
SYS_DICTIONARIES
</sql>
<!-- 字段 -->
<sql id="Field">
f.HOTWORK_ID,
f.ANALYZE_TIME,
f.ANALYZE_PLACE,
f.ANALYZE_RESULT,
f.ANALYZE_USER,
f.ISDELETE,
f.HOTWORKGAS_ID
</sql>
<!-- 字段用于新增 -->
<sql id="Field2">
HOTWORK_ID,
ANALYZE_TIME,
ANALYZE_PLACE,
ANALYZE_RESULT,
ANALYZE_USER,
ISDELETE,
HOTWORKGAS_ID
</sql>
<!-- 字段值 -->
<sql id="FieldValue">
#{HOTWORK_ID},
#{ANALYZE_TIME},
#{ANALYZE_PLACE},
#{ANALYZE_RESULT},
#{ANALYZE_USER},
#{ISDELETE},
#{HOTWORKGAS_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">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
HOTWORKGAS_ID = #{HOTWORKGAS_ID}
</delete>
<!-- 修改 -->
<update id="edit" parameterType="pd">
update
<include refid="tableName"></include>
set
HOTWORK_ID = #{HOTWORK_ID},
ANALYZE_TIME = #{ANALYZE_TIME},
ANALYZE_PLACE = #{ANALYZE_PLACE},
ANALYZE_RESULT = #{ANALYZE_RESULT},
ANALYZE_USER = #{ANALYZE_USER},
ISDELETE = #{ISDELETE},
HOTWORKGAS_ID = HOTWORKGAS_ID
where
HOTWORKGAS_ID = #{HOTWORKGAS_ID}
</update>
<!-- 通过ID获取数据 -->
<select id="findById" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.HOTWORK_ID = #{HOTWORK_ID}
</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-->
<!-- (-->
<!-- &lt;!&ndash; 根据需求自己加检索条件-->
<!-- 字段1 LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')-->
<!-- or-->
<!-- 字段2 LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')-->
<!-- &ndash;&gt;-->
<!-- )-->
</if>
ORDER BY f.ANALYZE_TIME desc
</select>
<!-- 列表(全部) -->
<select id="listAll" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where f.ISDELETE = '0' and f.HOTWORK_ID = #{HOTWORK_ID}
ORDER BY f.ANALYZE_TIME desc
</select>
<!-- 批量删除 -->
<delete id="deleteAll" parameterType="String">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
HOTWORKGAS_ID in
<foreach item="item" index="index" collection="ArrayDATA_IDS" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
</mapper>

127
src/main/resources/mybatis/datasource/highriskwork/HotworkLogCfdMapper.xml Normal file
View File

@ -0,0 +1,127 @@
<?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.highriskwork.HotworkLogCfdMapper">
<!--表名 -->
<sql id="tableName">
BUS_HOTWORKLOG_CFD
</sql>
<!--数据字典表名 -->
<sql id="dicTableName">
SYS_DICTIONARIES
</sql>
<!-- 字段 -->
<sql id="Field">
f.HOTWORK_ID,
f.ACTION,
f.CREATTIME,
f.CREATOR,
f.HOTWORKLOG_ID
</sql>
<!-- 字段用于新增 -->
<sql id="Field2">
HOTWORK_ID,
ACTION,
CREATTIME,
CREATOR,
HOTWORKLOG_ID
</sql>
<!-- 字段值 -->
<sql id="FieldValue">
#{HOTWORK_ID},
#{ACTION},
#{CREATTIME},
#{CREATOR},
#{HOTWORKLOG_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">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
HOTWORKLOG_ID = #{HOTWORKLOG_ID}
</delete>
<!-- 修改 -->
<update id="edit" parameterType="pd">
update
<include refid="tableName"></include>
set
HOTWORK_ID = #{HOTWORK_ID},
ACTION = #{ACTION},
CREATTIME = #{CREATTIME},
CREATOR = #{CREATOR},
HOTWORKLOG_ID = HOTWORKLOG_ID
where
HOTWORKLOG_ID = #{HOTWORKLOG_ID}
</update>
<!-- 通过ID获取数据 -->
<select id="findById" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.HOTWORKLOG_ID = #{HOTWORKLOG_ID}
</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>
</select>
<!-- 列表(全部) -->
<select id="listAll" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
</select>
<!-- 批量删除 -->
<delete id="deleteAll" parameterType="String">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
HOTWORKLOG_ID in
<foreach item="item" index="index" collection="ArrayDATA_IDS" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
</mapper>

145
src/main/resources/mybatis/datasource/highriskwork/HotworkToMeasuresCfdMapper.xml Normal file
View File

@ -0,0 +1,145 @@
<?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.highriskwork.HotworkToMeasuresCfdMapper">
<!--表名 -->
<sql id="tableName">
BUS_HOTWORKTOMEASURES_CFD
</sql>
<!--数据字典表名 -->
<sql id="dicTableName">
SYS_DICTIONARIES
</sql>
<!-- 字段 -->
<sql id="Field">
f.HOTWORK_ID,
f.BUS_HOTWORK_MEASURES_ID,
f.STATUS,
f.ANSWER1,
f.ANSWER2,
f.ANSWER3,
f.ANSWER4,
f.HOTWORKTOMEASURES_ID,
f.CONFIRM_ID,
f.CONFIRM_NAME
</sql>
<!-- 字段用于新增 -->
<sql id="Field2">
HOTWORK_ID,
BUS_HOTWORK_MEASURES_ID,
STATUS,
ANSWER1,
ANSWER2,
ANSWER3,
ANSWER4,
HOTWORKTOMEASURES_ID,
CONFIRM_ID,
CONFIRM_NAME
</sql>
<!-- 字段值 -->
<sql id="FieldValue">
#{HOTWORK_ID},
#{BUS_HOTWORK_MEASURES_ID},
#{STATUS},
#{ANSWER1},
#{ANSWER2},
#{ANSWER3},
#{ANSWER4},
#{HOTWORKTOMEASURES_ID},
#{CONFIRM_ID},
#{CONFIRM_NAME}
</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
HOTWORK_ID = #{HOTWORK_ID}
</delete>
<!-- 修改 -->
<update id="edit" parameterType="pd">
update
<include refid="tableName"></include>
set
HOTWORK_ID = #{HOTWORK_ID},
BUS_HOTWORK_MEASURES_ID = #{BUS_HOTWORK_MEASURES_ID},
STATUS = #{STATUS},
ANSWER1 = #{ANSWER1},
ANSWER2 = #{ANSWER2},
ANSWER3 = #{ANSWER3},
ANSWER4 = #{ANSWER4},
HOTWORKTOMEASURES_ID = HOTWORKTOMEASURES_ID,
ICONFIRM_ID = #{CONFIRM_ID},
CONFRM_NAME = #{CONFIRM_NAME}
where
HOTWORKTOMEASURES_ID = #{HOTWORKTOMEASURES_ID}
</update>
<!-- 通过ID获取数据 -->
<select id="findById" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.HOTWORKTOMEASURES_ID = #{HOTWORKTOMEASURES_ID}
</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>
</select>
<!-- 列表(全部) -->
<select id="listAll" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
</select>
<!-- 批量删除 -->
<delete id="deleteAll" parameterType="String">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
HOTWORKTOMEASURES_ID in
<foreach item="item" index="index" collection="ArrayDATA_IDS" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
</mapper>

131
src/main/resources/mybatis/datasource/mq/MqErrorMessageLogMapper.xml Normal file
View File

@ -0,0 +1,131 @@
<?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.mq.MqErrorMessageLogMapper">
<!--表名 -->
<sql id="tableName">
MQ_MESSAGE_ERROR_LOG
</sql>
<!--数据字典表名 -->
<sql id="dicTableName">
SYS_DICTIONARIES
</sql>
<!-- 字段 -->
<sql id="Field">
f.MESSAGE_LOG_ID,
f.ERROR_MESSAGE,
f.TIME,
f.TYPE,
f.SOURCE,
f.MESSAGE_ERROR_LOG_ID
</sql>
<!-- 字段用于新增 -->
<sql id="Field2">
MESSAGE_LOG_ID,
ERROR_MESSAGE,
TIME,
TYPE,
SOURCE,
MESSAGE_ERROR_LOG_ID
</sql>
<!-- 字段值 -->
<sql id="FieldValue">
#{MESSAGE_LOG_ID},
#{ERROR_MESSAGE},
#{TIME},
#{TYPE},
#{SOURCE},
#{MESSAGE_ERROR_LOG_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">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
MESSAGE_ERROR_LOG_ID = #{MESSAGE_ERROR_LOG_ID}
</delete>
<!-- 修改 -->
<update id="edit" parameterType="pd">
update
<include refid="tableName"></include>
set
MESSAGE_LOG_ID = #{MESSAGE_LOG_ID},
ERROR_MESSAGE = #{ERROR_MESSAGE},
TIME = #{TIME},
TYPE = #{TYPE},
SOURCE = #{SOURCE},
MESSAGE_ERROR_LOG_ID = MESSAGE_ERROR_LOG_ID
where
MESSAGE_ERROR_LOG_ID = #{MESSAGE_ERROR_LOG_ID}
</update>
<!-- 通过ID获取数据 -->
<select id="findById" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.MESSAGE_ERROR_LOG_ID = #{MESSAGE_ERROR_LOG_ID}
</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>
</select>
<!-- 列表(全部) -->
<select id="listAll" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
</select>
<!-- 批量删除 -->
<delete id="deleteAll" parameterType="String">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
MESSAGE_ERROR_LOG_ID in
<foreach item="item" index="index" collection="ArrayDATA_IDS" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
</mapper>

143
src/main/resources/mybatis/datasource/mq/MqMessageLogMapper.xml Normal file
View File

@ -0,0 +1,143 @@
<?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.mq.MqMessageLogMapper">
<!--表名 -->
<sql id="tableName">
MQ_MESSAGE_LOG
</sql>
<!--数据字典表名 -->
<sql id="dicTableName">
SYS_DICTIONARIES
</sql>
<!-- 字段 -->
<sql id="Field">
f.ID,
f.PRODUCER_NAME,
f.MARK,
f.MARK_NAME,
f.MESSAGE,
f.CREATE_TIME,
f.MESSAGE_LOG_ID,
f.TYPE,
f.DIGESTION_FLAG,
f.PLAN_TIME
</sql>
<!-- 字段用于新增 -->
<sql id="Field2">
ID,
PRODUCER_NAME,
MARK,
MARK_NAME,
MESSAGE,
CREATE_TIME,
MESSAGE_LOG_ID,
TYPE,
DIGESTION_FLAG,
PLAN_TIME
</sql>
<!-- 字段值 -->
<sql id="FieldValue">
#{ID},
#{PRODUCER_NAME},
#{MARK},
#{MARK_NAME},
#{MESSAGE},
#{CREATE_TIME},
#{MESSAGE_LOG_ID},
#{TYPE},
#{DIGESTION_FLAG},
#{PLAN_TIME}
</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
MESSAGE_LOG_ID = #{MESSAGE_LOG_ID}
</delete>
<!-- 修改 -->
<update id="edit" parameterType="pd">
update
<include refid="tableName"></include>
set
ID = #{ID},
PRODUCER_NAME = #{PRODUCER_NAME},
MARK = #{MARK},
MARK_NAME = #{MARK_NAME},
MESSAGE = #{MESSAGE},
CREATE_TIME = #{CREATE_TIME},
TYPE = #{TYPE},
DIGESTION_FLAG = #{DIGESTION_FLAG},
PLAN_TIME = #{PLAN_TIME},
MESSAGE_LOG_ID = MESSAGE_LOG_ID
where
MESSAGE_LOG_ID = #{MESSAGE_LOG_ID}
</update>
<!-- 通过ID获取数据 -->
<select id="findById" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.MESSAGE_LOG_ID = #{MESSAGE_LOG_ID}
</select>
<!-- 列表 -->
<select id="datalistPage" parameterType="page" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where 1=1
<if test="pd.KEYWORDS != null and pd.KEYWORDS != ''"><!-- 关键词检索 -->
and
(
<!-- 根据需求自己加检索条件
字段1 LIKE '%'+ #{pd.KEYWORDS}+'%'
or
字段2 LIKE '%'+ #{pd.KEYWORDS}+'%'
-->
)
</if>
</select>
<!-- 列表(全部) -->
<select id="listAll" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
</select>
<!-- 批量删除 -->
<delete id="deleteAll" parameterType="String">
delete from
<include refid="tableName"></include>
where
MESSAGE_LOG_ID in
<foreach item="item" index="index" collection="array" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
</mapper>

225
src/main/resources/mybatis/datasource/specialoperation/PersonnelManagementMapper.xml Normal file
View File

@ -0,0 +1,225 @@
<?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.specialoperation.PersonnelManagementCfdMapper">
<!--表名 -->
<sql id="tableName">
BUS_PERSONNELMANAGEMENT
</sql>
<!--数据字典表名 -->
<sql id="dicTableName">
SYS_DICTIONARIES
</sql>
<!-- 字段 -->
<sql id="Field">
f.CREATOR,
f.UNITS_ID,
f.PTYPE,
f.JOB_TYPE,
f.OPERATIONITEM,
f.NAME,
f.SEX,
f.CERTIFICATE_NUM,
f.REVIEWTIME,
f.PHONENUM,
f.IDENTITYCARD,
f.LICENSING,
f.VALID_STIME,
f.VALID_ETIME,
f.CREATTIME,
f.OPERATOR,
f.OPERATTIME,
f.ISDELETE,
f.CORPINFO_ID,
f.PERSONNELMANAGEMENT_ID
</sql>
<!-- 字段用于新增 -->
<sql id="Field2">
CREATOR,
UNITS_ID,
PTYPE,
JOB_TYPE,
OPERATIONITEM,
NAME,
SEX,
CERTIFICATE_NUM,
REVIEWTIME,
PHONENUM,
IDENTITYCARD,
LICENSING,
VALID_STIME,
VALID_ETIME,
CREATTIME,
OPERATOR,
OPERATTIME,
ISDELETE,
CORPINFO_ID,
PERSONNELMANAGEMENT_ID
</sql>
<!-- 字段值 -->
<sql id="FieldValue">
#{CREATOR},
#{UNITS_ID},
#{PTYPE},
#{JOB_TYPE},
#{OPERATIONITEM},
#{NAME},
#{SEX},
#{CERTIFICATE_NUM},
#{REVIEWTIME},
#{PHONENUM},
#{IDENTITYCARD},
#{LICENSING},
#{VALID_STIME},
#{VALID_ETIME},
#{CREATTIME},
#{OPERATOR},
#{OPERATTIME},
#{ISDELETE},
#{CORPINFO_ID},
#{PERSONNELMANAGEMENT_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">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
PERSONNELMANAGEMENT_ID = #{PERSONNELMANAGEMENT_ID}
</delete>
<!-- 修改 -->
<update id="edit" parameterType="pd">
update
<include refid="tableName"></include>
set
UNITS_ID = #{UNITS_ID},
PTYPE = #{PTYPE},
JOB_TYPE = #{JOB_TYPE},
OPERATIONITEM = #{OPERATIONITEM},
NAME = #{NAME},
SEX = #{SEX},
CERTIFICATE_NUM = #{CERTIFICATE_NUM},
REVIEWTIME = #{REVIEWTIME},
PHONENUM = #{PHONENUM},
IDENTITYCARD = #{IDENTITYCARD},
LICENSING = #{LICENSING},
VALID_STIME = #{VALID_STIME},
VALID_ETIME = #{VALID_ETIME}
where
PERSONNELMANAGEMENT_ID = #{PERSONNELMANAGEMENT_ID}
</update>
<!-- 通过社会信用代码获取数据 -->
<select id="findByCertificate" parameterType="pd" resultType="pd" >
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.CERTIFICATE_NUM = #{CERTIFICATE_NUM}
<if test="PERSONNELMANAGEMENT_ID != null and PERSONNELMANAGEMENT_ID !=''">
and f.PERSONNELMANAGEMENT_ID != #{PERSONNELMANAGEMENT_ID}
</if>
</select>
<!-- 通过ID获取数据 -->
<select id="findById" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.PERSONNELMANAGEMENT_ID = #{PERSONNELMANAGEMENT_ID}
</select>
<!-- 列表 -->
<select id="datalistPage" parameterType="page" resultType="pd">
select
f.*,
a.NAME as JOBTYPE,
r.UNITS_NAME as UNITS_NAME
from
<include refid="tableName"></include> f
left join sys_dictionaries a on a.DICTIONARIES_ID = f.JOB_TYPE
left join bus_corp_info b on b.CORPINFO_ID = f.CORPINFO_ID
left join `qa-cfd-regulatory`.bus_units r on r.UNITS_ID = f.UNITS_ID
where f.ISDELETE = '0'
<if test="pd.KEYWORDS != null and pd.KEYWORDS != ''"><!-- 关键词检索 -->
and
(
f.CERTIFICATE_NUM LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')
or
f.NAME LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')
or
r.UNITS_NAME LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')
)
</if>
<if test="pd.JOB_TYPE != null and pd.JOB_TYPE !=''">
and f.JOB_TYPE = #{pd.JOB_TYPE}
</if>
<if test="pd.PTYPE != null and pd.PTYPE !=''">
and f.PTYPE = #{pd.PTYPE}
</if>
<if test="pd.CORPINFO_ID != null and pd.ORPINFO_ID != ''">
and f.CORPINFO_ID = #{pd.CORPINFO_ID}
</if>
ORDER BY f.OPERATTIME DESC
</select>
<!-- 列表(全部) -->
<select id="listAll" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
<if test="UNITS_ID != null and UNITS_ID !=''">
and f.UNITS_ID = #{UNITS_ID}
</if>
</select>
<select id="namelist" parameterType="pd" resultType="pd">
select
concat(f.NAME,' ',f.CERTIFICATE_NUM) NAME
from
<include refid="tableName"></include> f
left join sys_dictionaries a on a.DICTIONARIES_ID = f.JOB_TYPE
left join bus_corp_info b on b.CORPINFO_ID = f.CORPINFO_ID
left join bus_units r on r.UNITS_ID = f.UNITS_ID
where f.ISDELETE = '0'
<if test="CORPINFO_ID != null and ORPINFO_ID != ''">
and f.CORPINFO_ID = #{CORPINFO_ID}
</if>
ORDER BY f.OPERATTIME DESC
</select>
<!-- 批量删除 -->
<delete id="deleteAll" parameterType="String">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
PERSONNELMANAGEMENT_ID in
<foreach item="item" index="index" collection="ArrayDATA_IDS" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
</mapper>

29
src/main/resources/mybatis/datasource/system/UsersMapper.xml
View File

@ -749,6 +749,35 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
order by u.DEPARTMENT_ID asc, u.SORT asc,u.LAST_LOGIN desc
</select>
<!--获取全部用户信息列表-->
<select id="getAllUserList" resultType="com.zcloud.entity.PageData">
select
f.USER_ID as value,
f.USER_ID as id,
f.USER_ID,
f.USERNAME,
f.NAME,
f.DEPARTMENT_ID,
f.CORPINFO_ID,
f.empNo,
f.cardNo,
d.NAME as DEPARTMENT_NAME,
c.CORP_NAME,
if (CONCAT(c.CORP_NAME,'-',d.NAME,'-',f.NAME) is not null,CONCAT(c.CORP_NAME,'-',d.NAME,'-',f.NAME),'') as label
from
<include refid="tableName"></include> f
left join OA_DEPARTMENT d on d.DEPARTMENT_ID = f.DEPARTMENT_ID
left join BUS_CORP_INFO c on c.CORPINFO_ID = f.CORPINFO_ID
where f.ISDELETE = '0'
AND f.USERNAME != 'admin'
and f.USERNAME is not null
and TRIM(f.USERNAME) != ''
and f.`NAME` is not null
and TRIM(f.`NAME`) != ''
and TRIM(if (CONCAT(c.CORP_NAME,'-',d.NAME,'-',f.NAME) is not null,CONCAT(c.CORP_NAME,'-',d.NAME,'-',f.NAME),'')) != ''
order by CONVERT( f.NAME USING gbk )
</select>
<!-- 通过企业ID获取用户信息 -->
<select id="getDepartmentId" parameterType="String" resultMap="userAndRoleResultMap">
select