风险管控措施

src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxgkcsJobHandler.java

@@ -0,0 +1,66 @@
+package com.hxjt.dataupload.jobhandler.doubleprevent;
+
+import com.alibaba.fastjson.JSONObject;
+import com.hxjt.dataupload.model.entity.doubleprevent.Fxgkcs;
+import com.hxjt.dataupload.model.entity.doubleprevent.Fxsj;
+import com.hxjt.dataupload.service.FxfxdxService;
+import com.hxjt.dataupload.utils.HttpUtils;
+import com.xxl.job.core.context.XxlJobHelper;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import org.apache.http.protocol.HTTP;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.io.IOException;
+import java.util.ArrayList;
+
+
+@Component
+public class FxgkcsJobHandler {
+
+    private Logger log = LoggerFactory.getLogger(FxgkcsJobHandler.class);
+
+    @Autowired
+    FxfxdxService fxfxdxService;
+
+    @XxlJob(value = "FxgkcsJobHandler", init = "init", destroy = "destroy")
+    public void execute(String param) {
+
+        ArrayList<Fxgkcs> fxgkcs = fxfxdxService.getFxgkcss();
+
+        for (int i = 0; i < fxgkcs.size(); i++) {
+
+            String company = fxgkcs.get(i).getQiyemingcheng();
+            String url = "https://www.ny-fxfk.com/space-ningyanghuagongchany/sapi/qpaas/tiga/dys/keyAuthentication/fengxianguankongqing/v1/fengxianguankongqing";
+            switch (company) {
+                case "山东恒信高科能源有限公司":
+                case "恒信中碳氢能源科技（山东）有限公司":
+                    JSONObject jsonObject = (JSONObject) JSONObject.toJSON(fxgkcs.get(i));
+                    String post = null;
+                    try {
+                        post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "7CTkAyBoL26Jo7ZMNVmg0EA57A0791FD71AB");
+                        //System.out.println("post:"+post.toString());
+                        XxlJobHelper.log("执行日志:"+company+post.toString());
+                    } catch (IOException e) {
+                        e.printStackTrace();
+                        XxlJobHelper.handleFail("任务执行失败"+e.getMessage());
+                    }
+                    break;
+                //System.out.println("post:"+post1.toString());
+            }
+        }
+
+    }
+
+
+    private void init() {
+        log.info("init 方法调用成功");
+    }
+
+    private void destroy() {
+        log.info("destroy 方法调用成功");
+    }
+
+}

src/main/java/com/hxjt/dataupload/mapper/FxfxdxMapper.java

@@ -2,6 +2,7 @@ package com.hxjt.dataupload.mapper;
 
 import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdx;
 import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdy;
+import com.hxjt.dataupload.model.entity.doubleprevent.Fxgkcs;
 import com.hxjt.dataupload.model.entity.doubleprevent.Fxsj;
 import org.apache.ibatis.annotations.Mapper;
 
@@ -16,4 +17,6 @@ public interface FxfxdxMapper {
     ArrayList<Fxfxdy> getFxfxdys();
 
     ArrayList<Fxsj> getFxsjs();
+
+    ArrayList<Fxgkcs> getFxgkcss();
 }

src/main/java/com/hxjt/dataupload/model/entity/doubleprevent/Fxgkcs.java

@@ -0,0 +1,204 @@
+package com.hxjt.dataupload.model.entity.doubleprevent;
+
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class Fxgkcs {
+    private String qiyemingcheng;
+    private String qiyebianma;
+    private String weixianhuaxuepindeng;
+    private String fengxianfenxiduixian;
+    private String fengxianfenxiduixia1;
+    private String qukuaimingcheng;
+    private String qukuaibianma;
+    private String fengxianshijianmingc;
+    private String fengxianshijianid;
+    private String xuhao;
+    private String guankongfangshi;
+    private String guankongcuoshineiron;
+    private String yinhuanpaichaneiron1;
+    private String guankongcuoshifenlei;
+    private String guankongcuoshifenle1;
+    private String guankongcuoshifenle2;
+    private String guankongzhuti;
+    private String jiluren;
+    private String jilushijian;
+
+    public String getQiyemingcheng() {
+        return qiyemingcheng;
+    }
+
+    public void setQiyemingcheng(String qiyemingcheng) {
+        this.qiyemingcheng = qiyemingcheng;
+    }
+
+    public String getQiyebianma() {
+        return qiyebianma;
+    }
+
+    public void setQiyebianma(String qiyebianma) {
+        this.qiyebianma = qiyebianma;
+    }
+
+    public String getWeixianhuaxuepindeng() {
+        return weixianhuaxuepindeng;
+    }
+
+    public void setWeixianhuaxuepindeng(String weixianhuaxuepindeng) {
+        this.weixianhuaxuepindeng = weixianhuaxuepindeng;
+    }
+
+    public String getFengxianfenxiduixian() {
+        return fengxianfenxiduixian;
+    }
+
+    public void setFengxianfenxiduixian(String fengxianfenxiduixian) {
+        this.fengxianfenxiduixian = fengxianfenxiduixian;
+    }
+
+    public String getFengxianfenxiduixia1() {
+        return fengxianfenxiduixia1;
+    }
+
+    public void setFengxianfenxiduixia1(String fengxianfenxiduixia1) {
+        this.fengxianfenxiduixia1 = fengxianfenxiduixia1;
+    }
+
+    public String getQukuaimingcheng() {
+        return qukuaimingcheng;
+    }
+
+    public void setQukuaimingcheng(String qukuaimingcheng) {
+        this.qukuaimingcheng = qukuaimingcheng;
+    }
+
+    public String getQukuaibianma() {
+        return qukuaibianma;
+    }
+
+    public void setQukuaibianma(String qukuaibianma) {
+        this.qukuaibianma = qukuaibianma;
+    }
+
+    public String getFengxianshijianmingc() {
+        return fengxianshijianmingc;
+    }
+
+    public void setFengxianshijianmingc(String fengxianshijianmingc) {
+        this.fengxianshijianmingc = fengxianshijianmingc;
+    }
+
+    public String getFengxianshijianid() {
+        return fengxianshijianid;
+    }
+
+    public void setFengxianshijianid(String fengxianshijianid) {
+        this.fengxianshijianid = fengxianshijianid;
+    }
+
+    public String getXuhao() {
+        return xuhao;
+    }
+
+    public void setXuhao(String xuhao) {
+        this.xuhao = xuhao;
+    }
+
+    public String getGuankongfangshi() {
+        return guankongfangshi;
+    }
+
+    public void setGuankongfangshi(String guankongfangshi) {
+        this.guankongfangshi = guankongfangshi;
+    }
+
+    public String getGuankongcuoshineiron() {
+        return guankongcuoshineiron;
+    }
+
+    public void setGuankongcuoshineiron(String guankongcuoshineiron) {
+        this.guankongcuoshineiron = guankongcuoshineiron;
+    }
+
+    public String getYinhuanpaichaneiron1() {
+        return yinhuanpaichaneiron1;
+    }
+
+    public void setYinhuanpaichaneiron1(String yinhuanpaichaneiron1) {
+        this.yinhuanpaichaneiron1 = yinhuanpaichaneiron1;
+    }
+
+    public String getGuankongcuoshifenlei() {
+        return guankongcuoshifenlei;
+    }
+
+    public void setGuankongcuoshifenlei(String guankongcuoshifenlei) {
+        this.guankongcuoshifenlei = guankongcuoshifenlei;
+    }
+
+    public String getGuankongcuoshifenle1() {
+        return guankongcuoshifenle1;
+    }
+
+    public void setGuankongcuoshifenle1(String guankongcuoshifenle1) {
+        this.guankongcuoshifenle1 = guankongcuoshifenle1;
+    }
+
+    public String getGuankongcuoshifenle2() {
+        return guankongcuoshifenle2;
+    }
+
+    public void setGuankongcuoshifenle2(String guankongcuoshifenle2) {
+        this.guankongcuoshifenle2 = guankongcuoshifenle2;
+    }
+
+    public String getGuankongzhuti() {
+        return guankongzhuti;
+    }
+
+    public void setGuankongzhuti(String guankongzhuti) {
+        this.guankongzhuti = guankongzhuti;
+    }
+
+    public String getJiluren() {
+        return jiluren;
+    }
+
+    public void setJiluren(String jiluren) {
+        this.jiluren = jiluren;
+    }
+
+    public String getJilushijian() {
+        return jilushijian;
+    }
+
+    public void setJilushijian(String jilushijian) {
+        this.jilushijian = jilushijian;
+    }
+
+
+    @Override
+    public String toString() {
+        return "Fxgkcs{" +
+                "qiyemingcheng='" + qiyemingcheng + '\'' +
+                ", qiyebianma='" + qiyebianma + '\'' +
+                ", weixianhuaxuepindeng='" + weixianhuaxuepindeng + '\'' +
+                ", fengxianfenxiduixian='" + fengxianfenxiduixian + '\'' +
+                ", fengxianfenxiduixia1='" + fengxianfenxiduixia1 + '\'' +
+                ", qukuaimingcheng='" + qukuaimingcheng + '\'' +
+                ", qukuaibianma='" + qukuaibianma + '\'' +
+                ", fengxianshijianmingc='" + fengxianshijianmingc + '\'' +
+                ", fengxianshijianid='" + fengxianshijianid + '\'' +
+                ", xuhao='" + xuhao + '\'' +
+                ", guankongfangshi='" + guankongfangshi + '\'' +
+                ", guankongcuoshineiron='" + guankongcuoshineiron + '\'' +
+                ", yinhuanpaichaneiron1='" + yinhuanpaichaneiron1 + '\'' +
+                ", guankongcuoshifenlei='" + guankongcuoshifenlei + '\'' +
+                ", guankongcuoshifenle1='" + guankongcuoshifenle1 + '\'' +
+                ", guankongcuoshifenle2='" + guankongcuoshifenle2 + '\'' +
+                ", guankongzhuti='" + guankongzhuti + '\'' +
+                ", jiluren='" + jiluren + '\'' +
+                ", jilushijian='" + jilushijian + '\'' +
+                '}';
+    }
+}

src/main/java/com/hxjt/dataupload/service/FxfxdxService.java

@@ -2,6 +2,7 @@ package com.hxjt.dataupload.service;
 
 import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdx;
 import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdy;
+import com.hxjt.dataupload.model.entity.doubleprevent.Fxgkcs;
 import com.hxjt.dataupload.model.entity.doubleprevent.Fxsj;
 
 
@@ -16,4 +17,6 @@ public interface FxfxdxService {
     ArrayList<Fxfxdy> getFxfxdys();
     //风险事件
     ArrayList<Fxsj> getFxsjs();
+    //风险管控措施
+    ArrayList<Fxgkcs> getFxgkcss();
 }

src/main/java/com/hxjt/dataupload/service/impl/FxfxdxServiceImpl.java

@@ -3,6 +3,7 @@ package com.hxjt.dataupload.service.impl;
 import com.hxjt.dataupload.mapper.FxfxdxMapper;
 import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdx;
 import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdy;
+import com.hxjt.dataupload.model.entity.doubleprevent.Fxgkcs;
 import com.hxjt.dataupload.model.entity.doubleprevent.Fxsj;
 import com.hxjt.dataupload.service.FxfxdxService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -32,4 +33,9 @@ public class FxfxdxServiceImpl implements FxfxdxService {
     public ArrayList<Fxsj> getFxsjs() {
         return fxfxdxMapper.getFxsjs();
     }
+
+    @Override
+    public ArrayList<Fxgkcs> getFxgkcss() {
+        return fxfxdxMapper.getFxgkcss();
+    }
 }

src/main/resources/mapper/FxfxdxMapper.xml

@@ -136,4 +136,65 @@
 		LEFT JOIN PF_ACCOUNT f ON a.CREATOR = f.id
 		WHERE a.ISDELETE = 'N'
 	</select>
+
+	<select id="getFxgkcss" resultType="com.hxjt.dataupload.model.entity.doubleprevent.Fxgkcs">
+		-- 隐患排查与风险管控信息查询
+		-- 此查询旨在从多个相关表中获取恒信中碳氢能源科技（山东）有限公司的隐患排查与风险管控相关信息
+		SELECT
+			(case
+				when b.ORGANID = '309_ORG' then '山东恒信高科能源有限公司'
+				else '恒信中碳氢能源科技（山东）有限公司'
+			end) AS qiyemingcheng,
+			(case
+				when b.ORGANID = '309_ORG' then '91370921328482832M'
+				else '91370921MA94AF5H3N'
+			end) AS qiyebianma,
+			(case
+				when b.ORGANID = '309_ORG' then '370910170'
+				else '370980326'
+			end) AS weixianhuaxuepindeng,
+			b.name AS fengxianfenxiduixian,
+			b.code AS fengxianfenxiduixia1,
+			c.NAME AS qukuaimingcheng,
+			c.ID AS qukuaibianma,
+			d.NAME AS fengxianshijianmingc,
+			d.ID AS fengxianshijianid,
+			a.id AS xuhao,
+			(CASE
+				WHEN a.FDATASRC = '1' THEN '自动化监控'
+				ELSE '隐患排查'
+			END) AS guankongfangshi,
+			a.FRISKMEASUREDESC AS guankongcuoshineiron,
+			g.FTROUBLESHOOT AS yinhuanpaichaneiron1,
+			(CASE
+				WHEN e.FNAME = '人员操作' THEN '操作行为'
+				ELSE e.FNAME
+			END) AS guankongcuoshifenlei,
+			(CASE
+				WHEN f.FNAME = '其他' THEN '其它'
+				ELSE f.FNAME
+			END) AS guankongcuoshifenle1,
+			a.FCLASSIFY3 AS guankongcuoshifenle2,
+			'岗位级' AS guankongzhuti,
+			h.ACCOUNTDESC AS jiluren,
+			FORMAT(a.CREASTAMP, 'yyyy-MM-dd HH:mm:ss') AS jilushijian
+		FROM
+			ISM_RISKMEASURE a
+		-- 左连接风险信息表
+		LEFT JOIN ISM_HAZARD b ON a.FHAZARDID = b.ID
+		-- 左连接风险单元表
+		LEFT JOIN ISM_HAZARDUNIT c ON a.FRISKUNITID = c.ID
+		-- 左连接风险事件表
+		LEFT JOIN ISM_RISKEVENT d ON a.FRISKEVENTID = d.ID
+		-- 左连接风险分类表1
+		LEFT JOIN ISM_CONMEATYPE e ON a.FCLASSIFY1 = e.ID
+		-- 左连接风险分类表2
+		LEFT JOIN ISM_CONMEATYPE f ON a.FCLASSIFY2 = f.ID
+		-- 左连接故障排除表
+		LEFT JOIN ISM_TROUBLESHOOT g ON a.ID = g.FRISKMEASUREID
+		-- 左连接账户表
+		LEFT JOIN PF_ACCOUNT h ON a.CREATOR = h.id
+		WHERE
+			 a.ISDELETE = 'N';
+	</select>
 </mapper>