盲板抽堵作业

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<Mbcdzy> onePage = new ArrayList<>();
+            // 1. 启动分页（必须紧邻查询语句）
+            PageHelper.startPage(pageNum, pageSize);
+            // 2. 执行查询（此时SQL已被自动拦截并添加分页逻辑）
+            if (jobParam.equals("全量")) {
+                onePage = fxfxdxService.getOneMbcdzysPage("N");
+            } else {
+                onePage = fxfxdxService.getOneMbcdzysPage("Y");
+            }
+
+            // 3. 封装分页结果
+            PageInfo<Mbcdzy> 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<Aqcs> 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 方法调用成功");
+    }
+
+}

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<Aqcs> queryDhAqcsByBianhao(@Param("bianhao")String isSingleDay);
 
     List<Sxkjzy> getOneSxkjzysPage(@Param("isSingleDay")String isSingleDay);
+
+    List<Mbcdzy> getOneMbcdzysPage(@Param("isSingleDay")String isSingleDay);
 }

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;
+    }
+}

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<Dhzy> getOneDhzysPage(String isSingleDay);
     //动火安全措施
     ArrayList<Aqcs> queryDhAqcsByBianhao(String bianhao);
-
+    //受限空间作业
     List<Sxkjzy> getOneSxkjzysPage(String isSingleDay);
+    //盲板抽堵作业
+    List<Mbcdzy> getOneMbcdzysPage(String isSingleDay);
+
 }

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<Sxkjzy> getOneSxkjzysPage(String isSingleDay) {
         return fxfxdxMapper.getOneSxkjzysPage(isSingleDay);
     }
+
+    @Override
+    public List<Mbcdzy> getOneMbcdzysPage(String isSingleDay) {
+        return fxfxdxMapper.getOneMbcdzysPage(isSingleDay);
+    }
 }

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());
+        }
+    }
+}

src/main/resources/mapper/FxfxdxMapper.xml

@@ -794,4 +794,130 @@
 		order by
 			a.APPLYTIME desc
 	</select>
+
+	<select id="getOneMbcdzysPage" resultType="com.hxjt.dataupload.model.entity.tszy.upload.Mbcdzy">
+
+		--盲板抽堵
+
+		SELECT
+			a.ID as zuoyepiaobianhao,
+			--zuoyeshenqingdanwei
+			(CASE
+				WHEN C.FNAME like '%中碳%' THEN '恒信中碳氢能源科技（山东）有限公司'
+				ELSE '山东恒信高科能源有限公司'
+			END) AS zuoyeshenqingdanwei,
+			--qiyebianma
+			(CASE
+				WHEN C.FNAME like '%中碳%' THEN '370980326'
+				ELSE '370910170'
+			END) AS qiyebianma,
+			'盲板抽堵作业' as zuoyeleibie,
+			FORMAT(A.PBDATE,
+			'yyyy-MM-dd HH:mm:ss')as shijizuoyekaishishij,
+			FORMAT(A.PEDATE,
+			'yyyy-MM-dd HH:mm:ss')as shishijieshushijian,
+			A.OTLOCARION AS donghuodidianjidongh,
+			A.OTCONTENT AS zuoyeneirong,
+			--经纬度
+			STUFF( COALESCE(',' + NULLIF(REPLACE( CAST(B.XVAL AS VARCHAR(255)), ';', ','),
+			''),
+			'') +
+			COALESCE(',' + NULLIF(CAST(B.YVAL AS VARCHAR(255)),
+			''),
+			''),
+			1,
+			1,
+			'' ) AS jingweidu,
+			'已验收' AS zuoyezhuangtai,
+			A.GUARDNAME AS jianhuren,
+			a.firewritename AS zuoyeren,
+			A.SDUNITNAME AS zuoyedanwei,
+			-- 通过机构路径改进
+		(case
+				when A.UNITID is null then '是'
+				else '否'
+			end) as shifouchengbaoshangz,
+			D.FIREPERSONNAME4 AS zuoyefuzeren,
+			(CASE
+				WHEN (F.MOBILE IS NULL
+				OR F.MOBILE = '') THEN '13853732279'
+				ELSE F.MOBILE
+			END) as fuzerenlianxifangshi,
+			-- 是否变更
+		 '否' AS zuoyeshifoubiangengg,
+			--是否取消
+		 '否' AS zuoyeshifouquxiao,
+			--作业票附件需要改进
+			--实际作业结束时间
+			FORMAT(A.PEDATE,
+			'yyyy-MM-dd HH:mm:ss')as shijizuoyejieshushij,
+			--交底人
+			d.firepersonname3 AS jieshoujiaodiren,
+			d.firepersonname2 AS anquanjiaodiren,
+			-- 一张票可能对应多个盲板，只取一个，见outer apply
+			--盲板位置编号没有
+			--盲板位置图有
+			--盲板参数编号
+			h.cutpostion as bianhao,
+			--规格
+			h.fdepth as guige,
+			--材质
+			h.pipedia as caizhi,
+			--压力
+			h.ftrend as yalif,
+			--温度
+			h.facloaction AS wendu,
+			--介质
+			h.underfac AS jiezhi,
+			--设备/管道名称
+			h.ffield1 AS shebeiguandaomingche,
+			-- 风险辨识结果需改进
+			REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE(REPLACE
+				 (a.haziden, 'BS01', '物体打击'), 'BS02', '机械伤害'), 'BS03', '起重伤害'), 'BS04', '触电'), 'BS05', '灼烫'), 'BS06', '火灾'),
+				 'BS07', '坍塌'), 'BS08', '高处坠落'), 'BS09', '中毒和窒息'), 'BS10', '锅炉爆炸'), 'BS11', '容器爆炸'), 'BS12', '淹溺'), 'BS13', '其它爆炸'), 'BS14', '其它伤害') AS fengxianbianshijiegu,
+			-- 关联其他作业票需改进
+			A.NAME08 AS guanliandeqitateshuz,
+			'是' as shifouweiqiyetuisong
+		FROM
+			OTM_OPERATICK A
+		LEFT JOIN ISM_AREA B ON
+			A.otlocarionid = B.id
+		LEFT JOIN OTM_OTKIND C ON
+			A.OTKIND = C.ID
+		LEFT JOIN OTM_OTMSUB D ON
+			A.ID = D.PID
+		LEFT JOIN PF_EMPLOYEE F ON
+			D.FIREPERSONID1 = F.ID
+		LEFT JOIN PF_ORGAN G ON
+			a.otunit = G.ORGANCODE
+			-- 只取一个盲板的参数
+		 OUTER APPLY (
+			SELECT
+				top 1 h.*
+			FROM
+										OTM_UNDERFACSIT H
+			WHERE
+				h.FOTID = a.ID
+			ORDER BY
+				CREASTAMP
+									) H
+		where
+			a.isdelete = 'N'
+			and d.showflag = '1'
+			--and a.APPLYTIME >= '2024-01-01 00:00:00.000'
+			and c.id in('457abb402d9b42ad8b8fd601d24fcece', '7314a6809e66452e9e5e51dfab9a2b3d')
+			--AND OTBILLID='DH20250213197'
+			<choose>
+				<when test='isSingleDay == "Y"'>
+
+					AND (DATEDIFF(dd, a.APPLYTIME, GETDATE() - 1) = 0)
+				</when>
+				<otherwise>
+
+					and a.APPLYTIME >= '2024-01-01 00:00:00.000'
+				</otherwise>
+			</choose>
+		order by
+			a.APPLYTIME desc
+	</select>
 </mapper>