风险分析单元

风险事件

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

@@ -79,7 +79,7 @@ public class FxfxdxJobHandler {
             //System.out.println(fxfxdxs.get(i).toString());
         }
         for (int i = 0; i < fxfxdxs.size(); i++) {
-
+            
             String company = fxfxdxs.get(i).getQiyemingcheng();
             String url = "https://www.ny-fxfk.com/space-ningyanghuagongchany/sapi/qpaas/tiga/dys/keyAuthentication/fengxianfenxiduixian/v1/fengxianfenxiduixian";
             switch (company) {

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

@@ -0,0 +1,112 @@
+package com.hxjt.dataupload.jobhandler.doubleprevent;
+
+import com.alibaba.fastjson.JSONObject;
+import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdx;
+import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdy;
+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 FxfxdyJobHandler {
+
+    private Logger log = LoggerFactory.getLogger(FxfxdyJobHandler.class);
+
+    @Autowired
+    FxfxdxService fxfxdxService;
+
+    @XxlJob(value = "FxfxdyJobHandler", init = "init", destroy = "destroy")
+    public void execute(String param) {
+
+        ArrayList<Fxfxdy> fxfxdxs = fxfxdxService.getFxfxdys();
+        ArrayList<Fxfxdx> zdwxys = fxfxdxService.getZdwxys();
+        for (int i = 0; i < fxfxdxs.size(); i++) {
+            System.out.println(fxfxdxs.get(i));
+            String HAZARD_NAME = fxfxdxs.get(i).getFengxianfenxiduixian();
+            for (int j = 0; j < zdwxys.size(); j++) {
+                String DANGESOURCE_NAME = zdwxys.get(j).getZhongdaweixianyuanmi();
+                switch (HAZARD_NAME) {
+                    case "重大危险源甲醇中间储存":
+                        if (DANGESOURCE_NAME.equals("甲醇中间储存单元")) {
+                            fxfxdxs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME);
+
+                        }
+                        break;
+                    case "重大危险源化产油库":
+                        if (DANGESOURCE_NAME.equals("化产油库区")) {
+                            fxfxdxs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME);
+
+                        }
+                        break;
+                    case "重大危险源甲醇储罐":
+                        if (DANGESOURCE_NAME.equals("甲醇储存单元")) {
+                            fxfxdxs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME);
+
+                        }
+                        break;
+                    case "重大危险源空分站":
+                        if (DANGESOURCE_NAME.equals("空分站单元")) {
+                            fxfxdxs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME);
+
+                        }
+                        break;
+                    case "重大危险源气柜储存":
+                        if (DANGESOURCE_NAME.equals("气柜")) {
+                            fxfxdxs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME);
+
+                        }
+                        break;
+                    case "重大危险源粗苯蒸馏":
+                        if (DANGESOURCE_NAME.equals("粗苯蒸馏单元")) {
+                            fxfxdxs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME);
+
+                        }
+                        break;
+                }
+            }
+            System.out.println(fxfxdxs.get(i));
+        }
+        for (int i = 0; i < fxfxdxs.size(); i++) {
+
+            String company = fxfxdxs.get(i).getQiyemingcheng();
+            String url = "https://www.ny-fxfk.com/space-ningyanghuagongchany/sapi/qpaas/tiga/dys/keyAuthentication/fengxianfenxidanyuan/v1/fengxianfenxidanyuan";
+            switch (company) {
+                case "山东恒信高科能源有限公司":
+                case "恒信中碳氢能源科技（山东）有限公司":
+                    JSONObject jsonObject = (JSONObject) JSONObject.toJSON(fxfxdxs.get(i));
+                    String post = null;
+                    try {
+                        post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "RZdFEDt03BmZvGwkuL6KAE15B7F9249CFBE9");
+                        //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/jobhandler/doubleprevent/FxsjJobHandler.java

@@ -0,0 +1,67 @@
+package com.hxjt.dataupload.jobhandler.doubleprevent;
+
+import com.alibaba.fastjson.JSONObject;
+import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdx;
+import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdy;
+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 FxsjJobHandler {
+
+    private Logger log = LoggerFactory.getLogger(FxsjJobHandler.class);
+
+    @Autowired
+    FxfxdxService fxfxdxService;
+
+    @XxlJob(value = "FxsjJobHandler", init = "init", destroy = "destroy")
+    public void execute(String param) {
+
+        ArrayList<Fxsj> fxsjs = fxfxdxService.getFxsjs();
+
+        for (int i = 0; i < fxsjs.size(); i++) {
+
+            String company = fxsjs.get(i).getQiyemingcheng();
+            String url = "https://www.ny-fxfk.com/space-ningyanghuagongchany/sapi/qpaas/tiga/dys/keyAuthentication/fengxianshijianxinxi/v1/fengxianshijianxinxi";
+            switch (company) {
+                case "山东恒信高科能源有限公司":
+                case "恒信中碳氢能源科技（山东）有限公司":
+                    JSONObject jsonObject = (JSONObject) JSONObject.toJSON(fxsjs.get(i));
+                    String post = null;
+                    try {
+                        post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "GGUIPRh5bemgUmX8bvyn76E2ACA7DEE82AB4");
+                        //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

@@ -1,6 +1,8 @@
 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.Fxsj;
 import org.apache.ibatis.annotations.Mapper;
 
 import java.util.ArrayList;
@@ -10,4 +12,8 @@ public interface FxfxdxMapper {
     ArrayList<Fxfxdx> getFxfxdxs();
 
     ArrayList<Fxfxdx> getZdwxys();
+
+    ArrayList<Fxfxdy> getFxfxdys();
+
+    ArrayList<Fxsj> getFxsjs();
 }

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

@@ -0,0 +1,259 @@
+package com.hxjt.dataupload.model.entity.doubleprevent;
+
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class Fxfxdy {
+    //企业名称
+    //企业营业执照中的企业名称
+    private String qiyemingcheng;
+    //信用代码
+    //企业营业执照的统一信用代 码
+    private String qiyebianma;
+    //企业编码
+    //危险化学品登记综合服务系 统中的企业编码
+    private String weixianhuaxuepindeng;
+    //风险分析对象名 称
+    //风险分析单元所属的风险分 析对象名称
+    //需与风险分析对象接口中对 应记录的字段值一致以实现 关联
+    private String fengxianfenxiduixian;
+    //风险分析对象编 码
+    //风险分析单元所属的风险分 析对象编码，填写危险化学 品登记综合服务系统中的危 险源编码
+    //需与风险分析对象接口中对 应记录的字段值一致以实现 关联
+    private String fengxianfenxiduixia1;
+    //责任部门
+    //风险分析单元所属的风险分 析对象的责任部门
+    //需与风险分析对象接口中对 应记录的字段值一致以实现 关联
+    private String suoshubumenchejian;
+    //责任人
+    //风险分析单元所属的风险分 析对象的责任人
+    //需与风险分析对象接口中对 应记录的字段值一致以实现 关联
+    private String bumenchejianfuzeren;
+    //风险分析单元名 称
+    //风险分析单元名称
+    private String qukuaimingcheng;
+    //风险分析单元编 号
+    //唯一标识
+    //风险分析单元唯一编号
+    private String danyuanbianma;
+    //固有风险等级
+    //需传枚举值：低风险、一般 风险、较大风险、重大风险
+    private String fengxiandengji;
+    //风险辨识方法
+    //需传枚举值：SCL、JHA、 HAZOP、其他
+    private String fengxianbianshifangf;
+    //是否涉及重大危 险源###########################################################
+    //需传枚举值：是、否
+    private String zhongdaweixianyuande;
+    //重大危险源名称##################################################################
+    //是否为重大危险源=是时必 填
+    private String zhongdaweixianyuanmi;
+    //是否涉及重点监 管化工工艺
+    //需传枚举值：是、否
+    private String shifoushejizhongdia1;
+    //重点监管化工工 艺名称
+    //是否涉及重点监管化工工艺 =是时必填
+    private String zhongdianjianguanhua;
+    //是否涉及重点监 管危化品
+    //需传枚举值：是、否
+    private String shifoushejizhongdian;
+    //重点监管危化品 名称
+    //是否涉及重点监管危化品= 是时必填
+    private String zhongdianjianguanwei;
+    //是否涉及使用爆 炸品
+    //需传枚举值：是、否
+    private String shifoushejijuduyizhi;
+    //创建人
+    //记录的创建人
+    private String jiluren;
+    //创建时间
+    //记录的创建时间
+    //时间格式：yyyy-MM-dd HH:mm:ss
+    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 getSuoshubumenchejian() {
+        return suoshubumenchejian;
+    }
+
+    public void setSuoshubumenchejian(String suoshubumenchejian) {
+        this.suoshubumenchejian = suoshubumenchejian;
+    }
+
+    public String getBumenchejianfuzeren() {
+        return bumenchejianfuzeren;
+    }
+
+    public void setBumenchejianfuzeren(String bumenchejianfuzeren) {
+        this.bumenchejianfuzeren = bumenchejianfuzeren;
+    }
+
+    public String getQukuaimingcheng() {
+        return qukuaimingcheng;
+    }
+
+    public void setQukuaimingcheng(String qukuaimingcheng) {
+        this.qukuaimingcheng = qukuaimingcheng;
+    }
+
+    public String getDanyuanbianma() {
+        return danyuanbianma;
+    }
+
+    public void setDanyuanbianma(String danyuanbianma) {
+        this.danyuanbianma = danyuanbianma;
+    }
+
+    public String getFengxiandengji() {
+        return fengxiandengji;
+    }
+
+    public void setFengxiandengji(String fengxiandengji) {
+        this.fengxiandengji = fengxiandengji;
+    }
+
+    public String getFengxianbianshifangf() {
+        return fengxianbianshifangf;
+    }
+
+    public void setFengxianbianshifangf(String fengxianbianshifangf) {
+        this.fengxianbianshifangf = fengxianbianshifangf;
+    }
+
+    public String getZhongdaweixianyuande() {
+        return zhongdaweixianyuande;
+    }
+
+    public void setZhongdaweixianyuande(String zhongdaweixianyuande) {
+        this.zhongdaweixianyuande = zhongdaweixianyuande;
+    }
+
+    public String getZhongdaweixianyuanmi() {
+        return zhongdaweixianyuanmi;
+    }
+
+    public void setZhongdaweixianyuanmi(String zhongdaweixianyuanmi) {
+        this.zhongdaweixianyuanmi = zhongdaweixianyuanmi;
+    }
+
+    public String getShifoushejizhongdia1() {
+        return shifoushejizhongdia1;
+    }
+
+    public void setShifoushejizhongdia1(String shifoushejizhongdia1) {
+        this.shifoushejizhongdia1 = shifoushejizhongdia1;
+    }
+
+    public String getZhongdianjianguanhua() {
+        return zhongdianjianguanhua;
+    }
+
+    public void setZhongdianjianguanhua(String zhongdianjianguanhua) {
+        this.zhongdianjianguanhua = zhongdianjianguanhua;
+    }
+
+    public String getShifoushejizhongdian() {
+        return shifoushejizhongdian;
+    }
+
+    public void setShifoushejizhongdian(String shifoushejizhongdian) {
+        this.shifoushejizhongdian = shifoushejizhongdian;
+    }
+
+    public String getZhongdianjianguanwei() {
+        return zhongdianjianguanwei;
+    }
+
+    public void setZhongdianjianguanwei(String zhongdianjianguanwei) {
+        this.zhongdianjianguanwei = zhongdianjianguanwei;
+    }
+
+    public String getShifoushejijuduyizhi() {
+        return shifoushejijuduyizhi;
+    }
+
+    public void setShifoushejijuduyizhi(String shifoushejijuduyizhi) {
+        this.shifoushejijuduyizhi = shifoushejijuduyizhi;
+    }
+
+    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 "Fxfxdy{" +
+                "qiyemingcheng='" + qiyemingcheng + '\'' +
+                ", qiyebianma='" + qiyebianma + '\'' +
+                ", weixianhuaxuepindeng='" + weixianhuaxuepindeng + '\'' +
+                ", fengxianfenxiduixian='" + fengxianfenxiduixian + '\'' +
+                ", fengxianfenxiduixia1='" + fengxianfenxiduixia1 + '\'' +
+                ", suoshubumenchejian='" + suoshubumenchejian + '\'' +
+                ", bumenchejianfuzeren='" + bumenchejianfuzeren + '\'' +
+                ", qukuaimingcheng='" + qukuaimingcheng + '\'' +
+                ", danyuanbianma='" + danyuanbianma + '\'' +
+                ", fengxiandengji='" + fengxiandengji + '\'' +
+                ", fengxianbianshifangf='" + fengxianbianshifangf + '\'' +
+                ", zhongdaweixianyuande='" + zhongdaweixianyuande + '\'' +
+                ", zhongdaweixianyuanmi='" + zhongdaweixianyuanmi + '\'' +
+                ", shifoushejizhongdia1='" + shifoushejizhongdia1 + '\'' +
+                ", zhongdianjianguanhua='" + zhongdianjianguanhua + '\'' +
+                ", shifoushejizhongdian='" + shifoushejizhongdian + '\'' +
+                ", zhongdianjianguanwei='" + zhongdianjianguanwei + '\'' +
+                ", shifoushejijuduyizhi='" + shifoushejijuduyizhi + '\'' +
+                ", jiluren='" + jiluren + '\'' +
+                ", jilushijian='" + jilushijian + '\'' +
+                '}';
+    }
+}

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

@@ -0,0 +1,113 @@
+package com.hxjt.dataupload.model.entity.doubleprevent;
+
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class Fxsj {
+    private String qiyemingcheng;
+    private String qiyebianma;
+    private String weixianhuaxuepindeng;
+    private String fengxianfenxiduixian;
+    private String fengxianfenxiduixia1;
+    private String fengxianfenxidanyuan;
+    private String fengxianfenxidanyua1;
+    private String fengxianshijianmingc;
+    private String fengxianshijianbianh;
+    private String chuangjianren;
+
+    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 getFengxianfenxidanyuan() {
+        return fengxianfenxidanyuan;
+    }
+
+    public void setFengxianfenxidanyuan(String fengxianfenxidanyuan) {
+        this.fengxianfenxidanyuan = fengxianfenxidanyuan;
+    }
+
+    public String getFengxianfenxidanyua1() {
+        return fengxianfenxidanyua1;
+    }
+
+    public void setFengxianfenxidanyua1(String fengxianfenxidanyua1) {
+        this.fengxianfenxidanyua1 = fengxianfenxidanyua1;
+    }
+
+    public String getFengxianshijianmingc() {
+        return fengxianshijianmingc;
+    }
+
+    public void setFengxianshijianmingc(String fengxianshijianmingc) {
+        this.fengxianshijianmingc = fengxianshijianmingc;
+    }
+
+    public String getFengxianshijianbianh() {
+        return fengxianshijianbianh;
+    }
+
+    public void setFengxianshijianbianh(String fengxianshijianbianh) {
+        this.fengxianshijianbianh = fengxianshijianbianh;
+    }
+
+    public String getChuangjianren() {
+        return chuangjianren;
+    }
+
+    public void setChuangjianren(String chuangjianren) {
+        this.chuangjianren = chuangjianren;
+    }
+
+    @Override
+    public String toString() {
+        return "Fxsj{" +
+                "qiyemingcheng='" + qiyemingcheng + '\'' +
+                ", qiyebianma='" + qiyebianma + '\'' +
+                ", weixianhuaxuepindeng='" + weixianhuaxuepindeng + '\'' +
+                ", fengxianfenxiduixian='" + fengxianfenxiduixian + '\'' +
+                ", fengxianfenxiduixia1='" + fengxianfenxiduixia1 + '\'' +
+                ", fengxianfenxidanyuan='" + fengxianfenxidanyuan + '\'' +
+                ", fengxianfenxidanyua1='" + fengxianfenxidanyua1 + '\'' +
+                ", fengxianshijianmingc='" + fengxianshijianmingc + '\'' +
+                ", fengxianshijianbianh='" + fengxianshijianbianh + '\'' +
+                ", chuangjianren='" + chuangjianren + '\'' +
+                '}';
+    }
+}

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

@@ -1,13 +1,19 @@
 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.Fxsj;
 
 
 import java.util.ArrayList;
 
 public interface FxfxdxService {
-
+    //风险分析对象
     ArrayList<Fxfxdx> getFxfxdxs();
-
+    //重大危险源名称对照
     ArrayList<Fxfxdx> getZdwxys();
+    //风险分析单元
+    ArrayList<Fxfxdy> getFxfxdys();
+    //风险事件
+    ArrayList<Fxsj> getFxsjs();
 }

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

@@ -2,6 +2,8 @@ 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.Fxsj;
 import com.hxjt.dataupload.service.FxfxdxService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -20,4 +22,14 @@ public class FxfxdxServiceImpl implements FxfxdxService {
     public ArrayList<Fxfxdx> getZdwxys() {
         return fxfxdxMapper.getZdwxys();
     }
+
+    @Override
+    public ArrayList<Fxfxdy> getFxfxdys() {
+        return fxfxdxMapper.getFxfxdys();
+    }
+
+    @Override
+    public ArrayList<Fxsj> getFxsjs() {
+        return fxfxdxMapper.getFxsjs();
+    }
 }

src/main/resources/mapper/FxfxdxMapper.xml

@@ -51,4 +51,89 @@
          a.dslevel = b.id
     </select>
 
+	<select id="getFxfxdys" resultType="com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdy">
+		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.ORGANNAME AS suoshubumenchejian,
+			d.EMPNAME AS bumenchejianfuzeren,
+			a.NAME AS qukuaimingcheng,
+			a.ID AS danyuanbianma,
+			-- 根据风险等级代码转换为风险等级描述
+			(CASE
+				WHEN a.rlevel = '4' THEN '低风险'
+				WHEN a.rlevel = '3' THEN '一般风险'
+				WHEN a.rlevel = '2' THEN '较大风险'
+				WHEN a.rlevel = '1' THEN '重大风险'
+				ELSE '低风险'
+			END) AS fengxiandengji,
+			'SCL' AS fengxianbianshifangf,
+			(CASE
+				WHEN b.BIGDANGER = 'Y' THEN '是'
+				ELSE '否'
+			END) AS zhongdaweixianyuande,
+			'否' AS shifoushejizhongdia1,
+			'否' AS shifoushejizhongdian,
+			'否' AS shifoushejijuduyizhi,
+			e.ACCOUNTDESC AS jiluren,
+			FORMAT(a.CREASTAMP,
+			'yyyy-MM-dd HH:mm:ss') AS jilushijian
+		FROM
+			ISM_HAZARDUNIT a
+		LEFT JOIN ISM_HAZARD b ON
+			a.HAZARDID = b.ID
+		LEFT JOIN PF_ORGAN c ON
+			b.fdutydeptid = c.id
+		LEFT JOIN PF_EMPLOYEE d ON
+			b.FDUTYID = d.id
+		LEFT JOIN PF_ACCOUNT e ON
+			b.CREATOR = e.id
+		WHERE
+			a.ISDELETE = 'N';
+	</select>
+
+	<select id="getFxsjs" resultType="com.hxjt.dataupload.model.entity.doubleprevent.Fxsj">
+		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 fengxianfenxidanyuan,
+			c.ID AS fengxianfenxidanyua1,
+			a.NAME AS fengxianshijianmingc,
+			a.ID AS fengxianshijianbianh,
+			f.ACCOUNTDESC AS chuangjianren,
+			FORMAT(a.CREASTAMP, 'yyyy-MM-dd HH:mm:ss') AS chuangjianshijian
+		FROM
+			ISM_RISKEVENT a
+		-- 左连接风险信息表
+		LEFT JOIN ISM_HAZARD b ON a.HAZARDID = b.ID
+		-- 左连接风险单元表
+		LEFT JOIN ISM_HAZARDUNIT c ON a.RISKUNITID = c.ID
+		-- 左连接账户表
+		LEFT JOIN PF_ACCOUNT f ON a.CREATOR = f.id
+		WHERE a.ISDELETE = 'N'
+	</select>
 </mapper>