From 5970546604083ced7f600fb96549d898cc5e4971 Mon Sep 17 00:00:00 2001 From: liwenxuan <1298531568@qq.com> Date: Fri, 7 Mar 2025 16:26:10 +0800 Subject: [PATCH] =?UTF-8?q?=E9=A3=8E=E9=99=A9=E5=88=86=E6=9E=90=E5=8D=95?= =?UTF-8?q?=E5=85=83=20=E9=A3=8E=E9=99=A9=E4=BA=8B=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../doubleprevent/FxfxdxJobHandler.java | 2 +- .../doubleprevent/FxfxdyJobHandler.java | 112 ++++++++ .../doubleprevent/FxsjJobHandler.java | 67 +++++ .../hxjt/dataupload/mapper/FxfxdxMapper.java | 6 + .../model/entity/doubleprevent/Fxfxdy.java | 259 ++++++++++++++++++ .../model/entity/doubleprevent/Fxsj.java | 113 ++++++++ .../dataupload/service/FxfxdxService.java | 10 +- .../service/impl/FxfxdxServiceImpl.java | 12 + src/main/resources/mapper/FxfxdxMapper.xml | 85 ++++++ 9 files changed, 663 insertions(+), 3 deletions(-) create mode 100644 src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdyJobHandler.java create mode 100644 src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxsjJobHandler.java create mode 100644 src/main/java/com/hxjt/dataupload/model/entity/doubleprevent/Fxfxdy.java create mode 100644 src/main/java/com/hxjt/dataupload/model/entity/doubleprevent/Fxsj.java diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdxJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdxJobHandler.java index 9913216..634c51f 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdxJobHandler.java +++ b/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) { diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdyJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdyJobHandler.java new file mode 100644 index 0000000..5a340a3 --- /dev/null +++ b/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 fxfxdxs = fxfxdxService.getFxfxdys(); + ArrayList 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 方法调用成功"); + } + +} diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxsjJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxsjJobHandler.java new file mode 100644 index 0000000..76d4369 --- /dev/null +++ b/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 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 方法调用成功"); + } + +} diff --git a/src/main/java/com/hxjt/dataupload/mapper/FxfxdxMapper.java b/src/main/java/com/hxjt/dataupload/mapper/FxfxdxMapper.java index 2134d65..567e689 100644 --- a/src/main/java/com/hxjt/dataupload/mapper/FxfxdxMapper.java +++ b/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 getFxfxdxs(); ArrayList getZdwxys(); + + ArrayList getFxfxdys(); + + ArrayList getFxsjs(); } diff --git a/src/main/java/com/hxjt/dataupload/model/entity/doubleprevent/Fxfxdy.java b/src/main/java/com/hxjt/dataupload/model/entity/doubleprevent/Fxfxdy.java new file mode 100644 index 0000000..8c4dc96 --- /dev/null +++ b/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 + '\'' + + '}'; + } +} diff --git a/src/main/java/com/hxjt/dataupload/model/entity/doubleprevent/Fxsj.java b/src/main/java/com/hxjt/dataupload/model/entity/doubleprevent/Fxsj.java new file mode 100644 index 0000000..c607f23 --- /dev/null +++ b/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 + '\'' + + '}'; + } +} diff --git a/src/main/java/com/hxjt/dataupload/service/FxfxdxService.java b/src/main/java/com/hxjt/dataupload/service/FxfxdxService.java index a8936ee..ec07845 100644 --- a/src/main/java/com/hxjt/dataupload/service/FxfxdxService.java +++ b/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 getFxfxdxs(); - + //重大危险源名称对照 ArrayList getZdwxys(); + //风险分析单元 + ArrayList getFxfxdys(); + //风险事件 + ArrayList getFxsjs(); } diff --git a/src/main/java/com/hxjt/dataupload/service/impl/FxfxdxServiceImpl.java b/src/main/java/com/hxjt/dataupload/service/impl/FxfxdxServiceImpl.java index e2f195c..6766a5c 100644 --- a/src/main/java/com/hxjt/dataupload/service/impl/FxfxdxServiceImpl.java +++ b/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 getZdwxys() { return fxfxdxMapper.getZdwxys(); } + + @Override + public ArrayList getFxfxdys() { + return fxfxdxMapper.getFxfxdys(); + } + + @Override + public ArrayList getFxsjs() { + return fxfxdxMapper.getFxsjs(); + } } diff --git a/src/main/resources/mapper/FxfxdxMapper.xml b/src/main/resources/mapper/FxfxdxMapper.xml index c736ae5..2c94f3b 100644 --- a/src/main/resources/mapper/FxfxdxMapper.xml +++ b/src/main/resources/mapper/FxfxdxMapper.xml @@ -51,4 +51,89 @@ a.dslevel = b.id + + + \ No newline at end of file