diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/specialassignments/MbcdzyJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/specialassignments/MbcdzyJobHandler.java new file mode 100644 index 0000000..f612a73 --- /dev/null +++ b/src/main/java/com/hxjt/dataupload/jobhandler/specialassignments/MbcdzyJobHandler.java @@ -0,0 +1,178 @@ +package com.hxjt.dataupload.jobhandler.specialassignments; + +import com.alibaba.fastjson.JSONObject; +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.hxjt.dataupload.model.entity.tszy.aqcs.Aqcs; +import com.hxjt.dataupload.model.entity.tszy.upload.Mbcdzy; +import com.hxjt.dataupload.model.entity.tszy.upload.Sxkjzy; +import com.hxjt.dataupload.service.FxfxdxService; +import com.hxjt.dataupload.utils.HttpUtils; +import com.hxjt.dataupload.utils.JingWeiDuConverter; +import com.hxjt.dataupload.utils.tszy.MbcdzyUtil; +import com.hxjt.dataupload.utils.tszy.SxkjzyUtil; +import com.xxl.job.core.context.XxlJobHelper; +import com.xxl.job.core.handler.annotation.XxlJob; +import org.apache.commons.lang3.StringUtils; +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.time.LocalDateTime; +import java.time.format.DateTimeFormatter; +import java.util.ArrayList; +import java.util.List; + + +@Component +public class MbcdzyJobHandler { + + + private Logger log = LoggerFactory.getLogger(MbcdzyJobHandler.class); + + @Autowired + FxfxdxService fxfxdxService; + + @XxlJob(value = "MbcdzyJobHandler", init = "init", destroy = "destroy") + public void execute(String param) { + String jobParam = XxlJobHelper.getJobParam(); + + int pageSize = 1000; + int success = 0; + int fail = 0; + long total = 0; + + + int pageNum = 1; + do { + List onePage = new ArrayList<>(); + // 1. 启动分页（必须紧邻查询语句） + PageHelper.startPage(pageNum, pageSize); + // 2. 执行查询（此时SQL已被自动拦截并添加分页逻辑） + if (jobParam.equals("全量")) { + onePage = fxfxdxService.getOneMbcdzysPage("N"); + } else { + onePage = fxfxdxService.getOneMbcdzysPage("Y"); + } + + // 3. 封装分页结果 + PageInfo pageInfo = new PageInfo<>(onePage); + //设置总数 + total = pageInfo.getTotal(); + System.out.println("总条数:" + total); + System.out.println("第" + pageNum + "页"); + System.out.println("本页条数:" + pageInfo.getList().size()); + //处理经纬度 + for (int x = 0; x < pageInfo.getList().size(); x++) { + pageInfo.getList().get(x).setJingweidu(JingWeiDuConverter.createGeoPoint(pageInfo.getList().get(x).getJingweidu())); + } + //对本页数据进行上传 + for (int x = 0; x < pageInfo.getList().size(); x++) { + + String qiyebianma = pageInfo.getList().get(x).getQiyebianma(); + String url = "https://www.ny-fxfk.com/space-ningyanghuagongchany/sapi/qpaas/tiga/dys/keyAuthentication/mangbanchouduanquanz/v1/mangbanchouduanquanz"; + switch (qiyebianma) { + case "370910170": + //恒信高科 + //查询安全措施 + ArrayList aqcsList = fxfxdxService.queryDhAqcsByBianhao(pageInfo.getList().get(x).getZuoyepiaobianhao()); + //根据安全措施列表便利处理给当前上传对象赋值相关字段 + for (Aqcs aqcs: aqcsList) { + MbcdzyUtil.handle(pageInfo.getList().get(x),aqcs); + //System.out.println(aqcs); + } + JSONObject jsonObject = (JSONObject) JSONObject.toJSON(pageInfo.getList().get(x)); + String post = null; + + //System.out.println(jsonObject); + + + try { + post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "v3N8M5tIrV7wroWdO4fmCD2897D9726FD394"); + boolean thisFailFlag = false; + boolean postIsNull = false; + boolean postNoMsgs = false; + if(!StringUtils.isBlank(post)){ + JSONObject postJsonObj = JSONObject.parseObject(post); + if(postJsonObj.get("msg")!=null && postJsonObj.get("code")!=null && postJsonObj.get("status")!=null && !StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ + if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status + //成功 + System.out.println("成功"+(x+1)+","); + + + /*DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formattedDate = LocalDateTime.now().format(formatter); + System.out.println(" 当前时间: " + formattedDate); // 示例输出：2025-03-12 08:29:25 + System.out.println(jsonObject); + System.out.println("post:" + post.toString());*/ + + success++; + }else{ + thisFailFlag = true; + } + }else{ + thisFailFlag = true; + postNoMsgs = true; + } + }else{ + postIsNull = true; + thisFailFlag = true; + } + if(thisFailFlag){//异常情况 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formattedDate = LocalDateTime.now().format(formatter); + System.out.println(" 当前时间: " + formattedDate); // 示例输出：2025-03-12 08:29:25 + System.out.println("失败"+(x+1)+",盲板抽堵作业"); + if(!postIsNull){ + System.out.println("post:" + post.toString()); + XxlJobHelper.log("执行日志:(恒信高科)" + post.toString()); + } + + System.out.println(jsonObject); + + fail++; + Thread.sleep(120000); + } + } catch (Exception e) { + e.printStackTrace(); + XxlJobHelper.log("错误信息:" + e); + XxlJobHelper.log("请求体:" + jsonObject); + + + } + break; + case "370980326": + //中碳氢能源 + System.out.println(1); + } + + + } + pageNum++; + + } while (total > (pageNum - 1) * pageSize); + + + + + if (total > 0) { + XxlJobHelper.log("执行日志:本次有" + total + "条需要上传,成功上传" + success + "条,失败" + fail + "条"); + } else { + XxlJobHelper.log("执行日志:本次无新数据需上传"); + } + + + } + + + 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 b1b6c1c..896ec9f 100644 --- a/src/main/java/com/hxjt/dataupload/mapper/FxfxdxMapper.java +++ b/src/main/java/com/hxjt/dataupload/mapper/FxfxdxMapper.java @@ -3,6 +3,7 @@ package com.hxjt.dataupload.mapper; import com.hxjt.dataupload.model.entity.doubleprevent.*; import com.hxjt.dataupload.model.entity.tszy.aqcs.Aqcs; import com.hxjt.dataupload.model.entity.tszy.upload.Dhzy; +import com.hxjt.dataupload.model.entity.tszy.upload.Mbcdzy; import com.hxjt.dataupload.model.entity.tszy.upload.Sxkjzy; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; @@ -35,4 +36,6 @@ public interface FxfxdxMapper { ArrayList queryDhAqcsByBianhao(@Param("bianhao")String isSingleDay); List getOneSxkjzysPage(@Param("isSingleDay")String isSingleDay); + + List getOneMbcdzysPage(@Param("isSingleDay")String isSingleDay); } diff --git a/src/main/java/com/hxjt/dataupload/model/entity/tszy/upload/Mbcdzy.java b/src/main/java/com/hxjt/dataupload/model/entity/tszy/upload/Mbcdzy.java new file mode 100644 index 0000000..3c47b8e --- /dev/null +++ b/src/main/java/com/hxjt/dataupload/model/entity/tszy/upload/Mbcdzy.java @@ -0,0 +1,540 @@ +package com.hxjt.dataupload.model.entity.tszy.upload; + +import org.springframework.stereotype.Repository; + +@Repository +public class Mbcdzy { + + private String zuoyepiaobianhao; + private String zuoyeshenqingdanwei; + private String qiyebianma; + private String zuoyeleibie; + private String shijizuoyekaishishij; + private String shishijieshushijian; + private String donghuodidianjidongh; + private String zuoyeneirong; + private String jingweidu; + private String zuoyezhuangtai; + private String jianhuren; + private String zuoyeren; + private String zuoyedanwei; + private String shifouchengbaoshangz; + private String zuoyefuzeren; + private String fuzerenlianxifangshi; + private String zuoyeshifoubiangengg; + private String zuoyebiangengyuanyin; + private String zuoyeshifouquxiao; + private String zuoyezuofeiyuanyin; + private String zuoyepiao; + private String shijizuoyejieshushij; + private String jieshoujiaodiren; + private String anquanjiaodiren; + private String mangbanweizhibianhao; + private String mangbanweizhitu; + private String bianhao; + private String guige; + private String caizhi; + private String yalif; + private String wendu; + private String jiezhi; + private String shebeiguandaomingche; + private String zuoyedianweichangyah; + private String querenren; + private String chuandaigetifanghuzh; + private String querenren1; + private String shiyongfangbaodengju; + private String querenren2; + private String a30mneiwudonghuozuoye; + private String querenren3; + private String caiyongfangzhisuanji; + private String querenren4; + private String caiqufangtangcuoshi; + private String querenren5; + private String caiqufangdongcuoshi; + private String querenren6; + private String weitongshijinxingman; + private String querenren7; + private String yibanlixiangyinganqu; + private String querenren8; + private String zuoyexianchangsizhou; + private String querenren9; + private String fengxianbianshijiegu; + private String qitaanquancuoshi; + private String bianzhirenanquancuos; + private String querenren10; + private String guanliandeqitateshuz; + private String shifouweiqiyetuisong; + + + public String getZuoyepiaobianhao() { + return zuoyepiaobianhao; + } + + public void setZuoyepiaobianhao(String zuoyepiaobianhao) { + this.zuoyepiaobianhao = zuoyepiaobianhao; + } + + public String getZuoyeshenqingdanwei() { + return zuoyeshenqingdanwei; + } + + public void setZuoyeshenqingdanwei(String zuoyeshenqingdanwei) { + this.zuoyeshenqingdanwei = zuoyeshenqingdanwei; + } + + public String getQiyebianma() { + return qiyebianma; + } + + public void setQiyebianma(String qiyebianma) { + this.qiyebianma = qiyebianma; + } + + public String getZuoyeleibie() { + return zuoyeleibie; + } + + public void setZuoyeleibie(String zuoyeleibie) { + this.zuoyeleibie = zuoyeleibie; + } + + public String getShijizuoyekaishishij() { + return shijizuoyekaishishij; + } + + public void setShijizuoyekaishishij(String shijizuoyekaishishij) { + this.shijizuoyekaishishij = shijizuoyekaishishij; + } + + public String getShishijieshushijian() { + return shishijieshushijian; + } + + public void setShishijieshushijian(String shishijieshushijian) { + this.shishijieshushijian = shishijieshushijian; + } + + public String getDonghuodidianjidongh() { + return donghuodidianjidongh; + } + + public void setDonghuodidianjidongh(String donghuodidianjidongh) { + this.donghuodidianjidongh = donghuodidianjidongh; + } + + public String getZuoyeneirong() { + return zuoyeneirong; + } + + public void setZuoyeneirong(String zuoyeneirong) { + this.zuoyeneirong = zuoyeneirong; + } + + public String getJingweidu() { + return jingweidu; + } + + public void setJingweidu(String jingweidu) { + this.jingweidu = jingweidu; + } + + public String getZuoyezhuangtai() { + return zuoyezhuangtai; + } + + public void setZuoyezhuangtai(String zuoyezhuangtai) { + this.zuoyezhuangtai = zuoyezhuangtai; + } + + public String getJianhuren() { + return jianhuren; + } + + public void setJianhuren(String jianhuren) { + this.jianhuren = jianhuren; + } + + public String getZuoyeren() { + return zuoyeren; + } + + public void setZuoyeren(String zuoyeren) { + this.zuoyeren = zuoyeren; + } + + public String getZuoyedanwei() { + return zuoyedanwei; + } + + public void setZuoyedanwei(String zuoyedanwei) { + this.zuoyedanwei = zuoyedanwei; + } + + public String getShifouchengbaoshangz() { + return shifouchengbaoshangz; + } + + public void setShifouchengbaoshangz(String shifouchengbaoshangz) { + this.shifouchengbaoshangz = shifouchengbaoshangz; + } + + public String getZuoyefuzeren() { + return zuoyefuzeren; + } + + public void setZuoyefuzeren(String zuoyefuzeren) { + this.zuoyefuzeren = zuoyefuzeren; + } + + public String getFuzerenlianxifangshi() { + return fuzerenlianxifangshi; + } + + public void setFuzerenlianxifangshi(String fuzerenlianxifangshi) { + this.fuzerenlianxifangshi = fuzerenlianxifangshi; + } + + public String getZuoyeshifoubiangengg() { + return zuoyeshifoubiangengg; + } + + public void setZuoyeshifoubiangengg(String zuoyeshifoubiangengg) { + this.zuoyeshifoubiangengg = zuoyeshifoubiangengg; + } + + public String getZuoyebiangengyuanyin() { + return zuoyebiangengyuanyin; + } + + public void setZuoyebiangengyuanyin(String zuoyebiangengyuanyin) { + this.zuoyebiangengyuanyin = zuoyebiangengyuanyin; + } + + public String getZuoyeshifouquxiao() { + return zuoyeshifouquxiao; + } + + public void setZuoyeshifouquxiao(String zuoyeshifouquxiao) { + this.zuoyeshifouquxiao = zuoyeshifouquxiao; + } + + public String getZuoyezuofeiyuanyin() { + return zuoyezuofeiyuanyin; + } + + public void setZuoyezuofeiyuanyin(String zuoyezuofeiyuanyin) { + this.zuoyezuofeiyuanyin = zuoyezuofeiyuanyin; + } + + public String getZuoyepiao() { + return zuoyepiao; + } + + public void setZuoyepiao(String zuoyepiao) { + this.zuoyepiao = zuoyepiao; + } + + public String getShijizuoyejieshushij() { + return shijizuoyejieshushij; + } + + public void setShijizuoyejieshushij(String shijizuoyejieshushij) { + this.shijizuoyejieshushij = shijizuoyejieshushij; + } + + public String getJieshoujiaodiren() { + return jieshoujiaodiren; + } + + public void setJieshoujiaodiren(String jieshoujiaodiren) { + this.jieshoujiaodiren = jieshoujiaodiren; + } + + public String getAnquanjiaodiren() { + return anquanjiaodiren; + } + + public void setAnquanjiaodiren(String anquanjiaodiren) { + this.anquanjiaodiren = anquanjiaodiren; + } + + public String getMangbanweizhibianhao() { + return mangbanweizhibianhao; + } + + public void setMangbanweizhibianhao(String mangbanweizhibianhao) { + this.mangbanweizhibianhao = mangbanweizhibianhao; + } + + public String getMangbanweizhitu() { + return mangbanweizhitu; + } + + public void setMangbanweizhitu(String mangbanweizhitu) { + this.mangbanweizhitu = mangbanweizhitu; + } + + public String getBianhao() { + return bianhao; + } + + public void setBianhao(String bianhao) { + this.bianhao = bianhao; + } + + public String getGuige() { + return guige; + } + + public void setGuige(String guige) { + this.guige = guige; + } + + public String getCaizhi() { + return caizhi; + } + + public void setCaizhi(String caizhi) { + this.caizhi = caizhi; + } + + public String getYalif() { + return yalif; + } + + public void setYalif(String yalif) { + this.yalif = yalif; + } + + public String getWendu() { + return wendu; + } + + public void setWendu(String wendu) { + this.wendu = wendu; + } + + public String getJiezhi() { + return jiezhi; + } + + public void setJiezhi(String jiezhi) { + this.jiezhi = jiezhi; + } + + public String getShebeiguandaomingche() { + return shebeiguandaomingche; + } + + public void setShebeiguandaomingche(String shebeiguandaomingche) { + this.shebeiguandaomingche = shebeiguandaomingche; + } + + public String getZuoyedianweichangyah() { + return zuoyedianweichangyah; + } + + public void setZuoyedianweichangyah(String zuoyedianweichangyah) { + this.zuoyedianweichangyah = zuoyedianweichangyah; + } + + public String getQuerenren() { + return querenren; + } + + public void setQuerenren(String querenren) { + this.querenren = querenren; + } + + public String getChuandaigetifanghuzh() { + return chuandaigetifanghuzh; + } + + public void setChuandaigetifanghuzh(String chuandaigetifanghuzh) { + this.chuandaigetifanghuzh = chuandaigetifanghuzh; + } + + public String getQuerenren1() { + return querenren1; + } + + public void setQuerenren1(String querenren1) { + this.querenren1 = querenren1; + } + + public String getShiyongfangbaodengju() { + return shiyongfangbaodengju; + } + + public void setShiyongfangbaodengju(String shiyongfangbaodengju) { + this.shiyongfangbaodengju = shiyongfangbaodengju; + } + + public String getQuerenren2() { + return querenren2; + } + + public void setQuerenren2(String querenren2) { + this.querenren2 = querenren2; + } + + public String getA30mneiwudonghuozuoye() { + return a30mneiwudonghuozuoye; + } + + public void setA30mneiwudonghuozuoye(String a30mneiwudonghuozuoye) { + this.a30mneiwudonghuozuoye = a30mneiwudonghuozuoye; + } + + public String getQuerenren3() { + return querenren3; + } + + public void setQuerenren3(String querenren3) { + this.querenren3 = querenren3; + } + + public String getCaiyongfangzhisuanji() { + return caiyongfangzhisuanji; + } + + public void setCaiyongfangzhisuanji(String caiyongfangzhisuanji) { + this.caiyongfangzhisuanji = caiyongfangzhisuanji; + } + + public String getQuerenren4() { + return querenren4; + } + + public void setQuerenren4(String querenren4) { + this.querenren4 = querenren4; + } + + public String getCaiqufangtangcuoshi() { + return caiqufangtangcuoshi; + } + + public void setCaiqufangtangcuoshi(String caiqufangtangcuoshi) { + this.caiqufangtangcuoshi = caiqufangtangcuoshi; + } + + public String getQuerenren5() { + return querenren5; + } + + public void setQuerenren5(String querenren5) { + this.querenren5 = querenren5; + } + + public String getCaiqufangdongcuoshi() { + return caiqufangdongcuoshi; + } + + public void setCaiqufangdongcuoshi(String caiqufangdongcuoshi) { + this.caiqufangdongcuoshi = caiqufangdongcuoshi; + } + + public String getQuerenren6() { + return querenren6; + } + + public void setQuerenren6(String querenren6) { + this.querenren6 = querenren6; + } + + public String getWeitongshijinxingman() { + return weitongshijinxingman; + } + + public void setWeitongshijinxingman(String weitongshijinxingman) { + this.weitongshijinxingman = weitongshijinxingman; + } + + public String getQuerenren7() { + return querenren7; + } + + public void setQuerenren7(String querenren7) { + this.querenren7 = querenren7; + } + + public String getYibanlixiangyinganqu() { + return yibanlixiangyinganqu; + } + + public void setYibanlixiangyinganqu(String yibanlixiangyinganqu) { + this.yibanlixiangyinganqu = yibanlixiangyinganqu; + } + + public String getQuerenren8() { + return querenren8; + } + + public void setQuerenren8(String querenren8) { + this.querenren8 = querenren8; + } + + public String getZuoyexianchangsizhou() { + return zuoyexianchangsizhou; + } + + public void setZuoyexianchangsizhou(String zuoyexianchangsizhou) { + this.zuoyexianchangsizhou = zuoyexianchangsizhou; + } + + public String getQuerenren9() { + return querenren9; + } + + public void setQuerenren9(String querenren9) { + this.querenren9 = querenren9; + } + + public String getFengxianbianshijiegu() { + return fengxianbianshijiegu; + } + + public void setFengxianbianshijiegu(String fengxianbianshijiegu) { + this.fengxianbianshijiegu = fengxianbianshijiegu; + } + + public String getQitaanquancuoshi() { + return qitaanquancuoshi; + } + + public void setQitaanquancuoshi(String qitaanquancuoshi) { + this.qitaanquancuoshi = qitaanquancuoshi; + } + + public String getBianzhirenanquancuos() { + return bianzhirenanquancuos; + } + + public void setBianzhirenanquancuos(String bianzhirenanquancuos) { + this.bianzhirenanquancuos = bianzhirenanquancuos; + } + + public String getQuerenren10() { + return querenren10; + } + + public void setQuerenren10(String querenren10) { + this.querenren10 = querenren10; + } + + public String getGuanliandeqitateshuz() { + return guanliandeqitateshuz; + } + + public void setGuanliandeqitateshuz(String guanliandeqitateshuz) { + this.guanliandeqitateshuz = guanliandeqitateshuz; + } + + public String getShifouweiqiyetuisong() { + return shifouweiqiyetuisong; + } + + public void setShifouweiqiyetuisong(String shifouweiqiyetuisong) { + this.shifouweiqiyetuisong = shifouweiqiyetuisong; + } +} diff --git a/src/main/java/com/hxjt/dataupload/service/FxfxdxService.java b/src/main/java/com/hxjt/dataupload/service/FxfxdxService.java index afedcfc..b0cc5f6 100644 --- a/src/main/java/com/hxjt/dataupload/service/FxfxdxService.java +++ b/src/main/java/com/hxjt/dataupload/service/FxfxdxService.java @@ -3,6 +3,7 @@ package com.hxjt.dataupload.service; import com.hxjt.dataupload.model.entity.doubleprevent.*; import com.hxjt.dataupload.model.entity.tszy.aqcs.Aqcs; import com.hxjt.dataupload.model.entity.tszy.upload.Dhzy; +import com.hxjt.dataupload.model.entity.tszy.upload.Mbcdzy; import com.hxjt.dataupload.model.entity.tszy.upload.Sxkjzy; @@ -35,6 +36,9 @@ public interface FxfxdxService { List getOneDhzysPage(String isSingleDay); //动火安全措施 ArrayList queryDhAqcsByBianhao(String bianhao); - + //受限空间作业 List getOneSxkjzysPage(String isSingleDay); + //盲板抽堵作业 + List getOneMbcdzysPage(String isSingleDay); + } 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 4e33676..99ca90b 100644 --- a/src/main/java/com/hxjt/dataupload/service/impl/FxfxdxServiceImpl.java +++ b/src/main/java/com/hxjt/dataupload/service/impl/FxfxdxServiceImpl.java @@ -4,6 +4,7 @@ import com.hxjt.dataupload.mapper.FxfxdxMapper; import com.hxjt.dataupload.model.entity.doubleprevent.*; import com.hxjt.dataupload.model.entity.tszy.aqcs.Aqcs; import com.hxjt.dataupload.model.entity.tszy.upload.Dhzy; +import com.hxjt.dataupload.model.entity.tszy.upload.Mbcdzy; import com.hxjt.dataupload.model.entity.tszy.upload.Sxkjzy; import com.hxjt.dataupload.service.FxfxdxService; import org.springframework.beans.factory.annotation.Autowired; @@ -75,4 +76,9 @@ public class FxfxdxServiceImpl implements FxfxdxService { public List getOneSxkjzysPage(String isSingleDay) { return fxfxdxMapper.getOneSxkjzysPage(isSingleDay); } + + @Override + public List getOneMbcdzysPage(String isSingleDay) { + return fxfxdxMapper.getOneMbcdzysPage(isSingleDay); + } } diff --git a/src/main/java/com/hxjt/dataupload/utils/tszy/MbcdzyUtil.java b/src/main/java/com/hxjt/dataupload/utils/tszy/MbcdzyUtil.java new file mode 100644 index 0000000..a2fe996 --- /dev/null +++ b/src/main/java/com/hxjt/dataupload/utils/tszy/MbcdzyUtil.java @@ -0,0 +1,45 @@ +package com.hxjt.dataupload.utils.tszy; + +import com.hxjt.dataupload.model.entity.tszy.aqcs.Aqcs; +import com.hxjt.dataupload.model.entity.tszy.upload.Mbcdzy; + + +public class MbcdzyUtil { + public static void handle(Mbcdzy mbcdzy, Aqcs aqcs) { + if(aqcs.getAncuoneirong().startsWith("在管道、设备上作业时，应降低系")){ + mbcdzy.setZuoyedianweichangyah(aqcs.getShifousheji().equals("Y")?"是":"否"); + mbcdzy.setQuerenren(aqcs.getQuerenren()); + }else if(aqcs.getAncuoneirong().startsWith("在有毒介质的管道")){ + mbcdzy.setChuandaigetifanghuzh(aqcs.getShifousheji().equals("Y")?"是":"否"); + mbcdzy.setQuerenren1(aqcs.getQuerenren()); + }else if(aqcs.getAncuoneirong().startsWith("在火灾爆炸危险场所，作业人员穿防静电")){ + mbcdzy.setShiyongfangbaodengju(aqcs.getShifousheji().equals("Y")?"是":"否"); + mbcdzy.setQuerenren2(aqcs.getQuerenren()); + }else if(aqcs.getAncuoneirong().startsWith("在火灾爆炸危险场所，距作业地点3")){ + mbcdzy.setA30mneiwudonghuozuoye(aqcs.getShifousheji().equals("Y")?"是":"否"); + mbcdzy.setQuerenren3(aqcs.getQuerenren()); + }else if(aqcs.getAncuoneirong().startsWith("在强腐蚀性介质的管")){ + mbcdzy.setCaiyongfangzhisuanji(aqcs.getShifousheji().equals("Y")?"是":"否"); + mbcdzy.setQuerenren4(aqcs.getQuerenren()); + }else if(aqcs.getAncuoneirong().startsWith("介质温度较高可能造成烫")){ + mbcdzy.setCaiqufangtangcuoshi(aqcs.getShifousheji().equals("Y")?"是":"否"); + mbcdzy.setQuerenren5(aqcs.getQuerenren()); + }else if(aqcs.getAncuoneirong().startsWith("介质温度较低可能")){ + mbcdzy.setCaiqufangdongcuoshi(aqcs.getShifousheji().equals("Y")?"是":"否"); + mbcdzy.setQuerenren6(aqcs.getQuerenren()); + }else if(aqcs.getAncuoneirong().startsWith("同一管道上未同时进行两")){ + mbcdzy.setWeitongshijinxingman(aqcs.getShifousheji().equals("Y")?"是":"否"); + mbcdzy.setQuerenren7(aqcs.getQuerenren()); + }else if(aqcs.getAncuoneirong().startsWith("其他相关特殊作业已办理相应")){ + mbcdzy.setYibanlixiangyinganqu(aqcs.getShifousheji().equals("Y")?"是":"否"); + mbcdzy.setQuerenren8(aqcs.getQuerenren()); + }else if(aqcs.getAncuoneirong().startsWith("作业现场四周已设")){ + mbcdzy.setZuoyexianchangsizhou(aqcs.getShifousheji().equals("Y")?"是":"否"); + mbcdzy.setQuerenren9(aqcs.getQuerenren()); + }else if(aqcs.getAncuoneirong().startsWith("其他安全措施")){ + mbcdzy.setQitaanquancuoshi(DhAqcsUtil.processSecurityMeasures(aqcs.getAncuoneirong())); + mbcdzy.setBianzhirenanquancuos(aqcs.getQuerenren()); + mbcdzy.setQuerenren10(aqcs.getQuerenren()); + } + } +} diff --git a/src/main/resources/mapper/FxfxdxMapper.xml b/src/main/resources/mapper/FxfxdxMapper.xml index b0e929b..aeb0afb 100644 --- a/src/main/resources/mapper/FxfxdxMapper.xml +++ b/src/main/resources/mapper/FxfxdxMapper.xml @@ -794,4 +794,130 @@ order by a.APPLYTIME desc + + \ No newline at end of file