Browse Source

修复了隐患治理档案有些数据的隐患排查内容缺失的问题

master
liwenxuan 7 months ago
parent
commit
810447f8c3
  1. 2
      src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhzldaJobHandler.java
  2. 95
      src/main/resources/mapper/FxfxdxMapper.xml

2
src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhzldaJobHandler.java

@ -115,7 +115,7 @@ public class YhzldaJobHandler {
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
String formattedDate = LocalDateTime.now().format(formatter); String formattedDate = LocalDateTime.now().format(formatter);
System.out.println(" 当前时间: " + formattedDate); // 示例输出:2025-03-12 08:29:25 System.out.println(" 当前时间: " + formattedDate); // 示例输出:2025-03-12 08:29:25
System.out.println("失败"+(x+1)+",隐患排查任务"); System.out.println("失败"+(x+1)+",隐患治理档案");
if(!postIsNull){ if(!postIsNull){
System.out.println("post:" + post.toString()); System.out.println("post:" + post.toString());
XxlJobHelper.log("执行日志:" + company + post.toString()); XxlJobHelper.log("执行日志:" + company + post.toString());

95
src/main/resources/mapper/FxfxdxMapper.xml

@ -411,16 +411,16 @@
<select id="getOneYhzldasPage" resultType="com.hxjt.dataupload.model.entity.doubleprevent.Yhzlda"> <select id="getOneYhzldasPage" resultType="com.hxjt.dataupload.model.entity.doubleprevent.Yhzlda">
SELECT SELECT
(case (case
when b.ORGANID = '309_ORG' then '山东恒信高科能源有限公司' when b.ORGANID = '309_ORG' then '山东恒信高科能源有限公司'
else '恒信中碳氢能源科技(山东)有限公司' else '恒信中碳氢能源科技(山东)有限公司'
end) AS qiyemingcheng, end) AS qiyemingcheng,
(case (case
when b.ORGANID = '309_ORG' then '91370921328482832M' when b.ORGANID = '309_ORG' then '91370921328482832M'
else '91370921MA94AF5H3N' else '91370921MA94AF5H3N'
end) AS qiyebianma, end) AS qiyebianma,
(case (case
when b.ORGANID = '309_ORG' then '370910170' when b.ORGANID = '309_ORG' then '370910170'
else '370980326' else '370980326'
end) AS weixianhuaxuepindeng, end) AS weixianhuaxuepindeng,
a.ID AS yinhuanbianhao, a.ID AS yinhuanbianhao,
b.NAME AS yinhuanshejiduixiang, b.NAME AS yinhuanshejiduixiang,
@ -436,8 +436,8 @@
a.FNAME AS yinhuanmingcheng, a.FNAME AS yinhuanmingcheng,
-- 根据隐患等级代码判断隐患级别 -- 根据隐患等级代码判断隐患级别
(CASE (CASE
WHEN a.FLEVEL = '1' THEN '重大隐患' WHEN a.FLEVEL = '1' THEN '重大隐患'
ELSE '一般隐患' ELSE '一般隐患'
END) AS yinhuanjibie, END) AS yinhuanjibie,
h.EMPNAME AS paicharenyuan, h.EMPNAME AS paicharenyuan,
--a.FREGISTTIME AS tijiaoriq1, --a.FREGISTTIME AS tijiaoriq1,
@ -446,44 +446,44 @@
a.FSRC AS jianchaleixing, a.FSRC AS jianchaleixing,
-- 根据管理类型代码判断治理类型 -- 根据管理类型代码判断治理类型
(CASE (CASE
WHEN a.FMANAGETYPE = '1' THEN '限期整改' WHEN a.FMANAGETYPE = '1' THEN '限期整改'
ELSE '即查即改' ELSE '即查即改'
END) AS zhilileixing, END) AS zhilileixing,
-- 根据危险类型代码判断隐患类型 -- 根据危险类型代码判断隐患类型
(CASE (CASE
WHEN a.fdangertype = '1' THEN '安全' WHEN a.fdangertype = '1' THEN '安全'
WHEN a.fdangertype = '2' THEN '工艺' WHEN a.fdangertype = '2' THEN '工艺'
WHEN a.fdangertype = '3' THEN '电气' WHEN a.fdangertype = '3' THEN '电气'
WHEN a.fdangertype = '4' THEN '仪表' WHEN a.fdangertype = '4' THEN '仪表'
WHEN a.fdangertype = '5' THEN '消防' WHEN a.fdangertype = '5' THEN '消防'
WHEN a.fdangertype = '6' THEN '总图' WHEN a.fdangertype = '6' THEN '总图'
WHEN a.fdangertype = '7' THEN '设备' WHEN a.fdangertype = '7' THEN '设备'
ELSE '其他' ELSE '其他'
END) AS yinhuanleixing, END) AS yinhuanleixing,
-- 根据任务类型代码判断隐患类别 -- 根据任务类型代码判断隐患类别
(CASE (CASE
WHEN a.ftasktype = '1' THEN '主要责任人登记隐患' WHEN a.ftasktype = '1' THEN '主要责任人登记隐患'
WHEN a.FTASKTYPE = '2' THEN '技术负责人登记隐患' WHEN a.FTASKTYPE = '2' THEN '技术负责人登记隐患'
WHEN a.FTASKTYPE = '3' THEN '操作负责人登记隐患' WHEN a.FTASKTYPE = '3' THEN '操作负责人登记隐患'
ELSE '其他隐患' ELSE '其他隐患'
END) AS yinhuanleibie, END) AS yinhuanleibie,
a.FDANGERDESC AS yinhuanmiaoshu, a.FDANGERDESC AS yinhuanmiaoshu,
a.fdangerreason AS yuanyinfenxi, a.fdangerreason AS yuanyinfenxi,
a.fremark AS kongzhicuoshi, a.fremark AS kongzhicuoshi,
-- 资金万元计算(当前代码被注释,如需启用请确保逻辑正确) -- 资金万元计算(当前代码被注释,如需启用请确保逻辑正确)
/*(CASE /*(CASE
WHEN a.fcost IS NULL OR a.fcost = '' THEN NULL WHEN a.fcost IS NULL OR a.fcost = '' THEN NULL
WHEN a.fcost = '0' THEN '0' WHEN a.fcost = '0' THEN '0'
ELSE ELSE
-- 将字符串转换为数值,除以10000 ,再转换回字符串并保留两位小数 -- 将字符串转换为数值,除以10000 ,再转换回字符串并保留两位小数
CAST(ROUND(TRY_CONVERT(DECIMAL(18, 2), a.fcost) / 10000, 2) AS VARCHAR(20)) CAST(ROUND(TRY_CONVERT(DECIMAL(18, 2), a.fcost) / 10000, 2) AS VARCHAR(20))
END) AS zijinwanyuan,*/ END) AS zijinwanyuan,*/
a.fcost AS zijinwanyuan, a.fcost AS zijinwanyuan,
-- 根据状态代码判断隐患状态 -- 根据状态代码判断隐患状态
(CASE (CASE
WHEN a.fstate = '1' THEN '待验收' WHEN a.fstate = '1' THEN '待验收'
WHEN a.fstate = '9' THEN '已验收' WHEN a.fstate = '9' THEN '已验收'
ELSE '整改中' ELSE '整改中'
END) AS yinhuanzhuangtai, END) AS yinhuanzhuangtai,
i.EMPNAME AS zhenggairen, i.EMPNAME AS zhenggairen,
FORMAT(a.fmangerdeadline, FORMAT(a.fmangerdeadline,
@ -496,38 +496,47 @@
k.ACCOUNTDESC AS chuangjianren, k.ACCOUNTDESC AS chuangjianren,
FORMAT(a.CREASTAMP, FORMAT(a.CREASTAMP,
'yyyy-MM-dd HH:mm:ss') AS chuangjianshijian 'yyyy-MM-dd HH:mm:ss') AS chuangjianshijian
FROM FROM
ISM_CHECKINFO A ISM_CHECKINFO A
-- 左连接隐患信息表 -- 左连接隐患信息表
LEFT JOIN ISM_HAZARD b ON LEFT JOIN ISM_HAZARD b ON
a.FCODE = b.ID a.FCODE = b.ID
-- 左连接隐患单元表 -- 左连接隐患单元表
LEFT JOIN ISM_HAZARDUNIT c ON LEFT JOIN ISM_HAZARDUNIT c ON
a.FUINTID = c.ID a.FUINTID = c.ID
-- 左连接风险控制措施表 -- 左连接风险控制措施表
LEFT JOIN ISM_RISKMEASURE d ON LEFT JOIN ISM_RISKMEASURE d ON
a.FMEASURE = d.ID a.FMEASURE = d.ID
-- 左连接风险事件表 -- 左连接风险事件表
LEFT JOIN ISM_RISKEVENT e ON LEFT JOIN ISM_RISKEVENT e ON
e.RISKUNITID = c.ID e.RISKUNITID = c.ID
-- 左连接检查记录表 -- 左连接检查记录表
LEFT JOIN ISM_CHECKRECORD f ON LEFT JOIN ISM_CHECKRECORD f ON
a.FTASKID = f.ID a.FTASKID = f.ID
-- 左连接故障排除 -- -- 左连接排查任务
LEFT JOIN ISM_TROUBLESHOOT g ON -- LEFT JOIN ISM_TROUBLESHOOT g ON
f.FTROUBLESHOOTID = g.ID -- f.FTROUBLESHOOTID = g.ID
-- 左连接员工表,关联登记人 -- 左连接员工表,关联登记人
LEFT JOIN PF_EMPLOYEE h ON left JOIN ISM_TROUBLESHOOT g ON
d.id = g.FRISKMEASUREID
LEFT JOIN PF_EMPLOYEE h ON
a.FREGISTRANT = h.ID a.FREGISTRANT = h.ID
-- 左连接员工表,关联整改人 -- 左连接员工表,关联整改人
LEFT JOIN PF_EMPLOYEE i ON LEFT JOIN PF_EMPLOYEE i ON
a.fliableper = i.ID a.fliableper = i.ID
-- 左连接员工表,关联复查人 -- 左连接员工表,关联复查人
LEFT JOIN PF_EMPLOYEE j ON LEFT JOIN PF_EMPLOYEE j ON
a.fcheckper = j.ID a.fcheckper = j.ID
-- 左连接账户表,关联创建人 -- 左连接账户表,关联创建人
LEFT JOIN PF_ACCOUNT k ON LEFT JOIN PF_ACCOUNT k ON
a.CREATOR = k.ID a.CREATOR = k.ID
/*WHERE
a.ISDELETE = 'N'
AND e.ISDELETE = 'N'
and a.CREASTAMP >= '2025-01-01 00:00:00.000'
--and a.fmeasure='e8211360c0204428bc247c5c7d5cfd8e'
order by
chuangjianshijian desc*/
WHERE WHERE
a.ISDELETE = 'N' a.ISDELETE = 'N'
AND e.ISDELETE = 'N' AND e.ISDELETE = 'N'

Loading…
Cancel
Save