合规性分析添加日志

onemap-modules/onemap-apply/src/main/java/com/onemap/apply/service/impl/fzss/hgxfxjg/HgxfxHandleService.java

@@ -29,6 +29,8 @@ public class HgxfxHandleService {
     private HgxfxScxSortationMapper hgxfxScxSortationMapper;
     @Autowired
     private AnalyseService analyseService;
+    @Autowired
+    private FxrwrzMapper fxrwrzMapper;
 
     public void hgxfxHandle(String bsm, String ewkt) {
         QueryWrapper<HgxfxDTO> hgxfxWrapper = new QueryWrapper<HgxfxDTO>();
@@ -42,11 +44,12 @@ public class HgxfxHandleService {
         QueryWrapper<HgxfxDTO> v1_update = new QueryWrapper<HgxfxDTO>();
         v1_update.eq("bsm", bsm);
         hgxfxDTO.setRwkssj(new Date());
-
+        insertFxrwrz(StringUtils.getUUID(), bsm, hgxfxDTO.getXmmc(), "合规性分析开始。。。");
         getHgxfxScx(bsm, ewkt, "0");
 
         //更新结束时间
         hgxfxDTO.setRwjssj(new Date());
+        insertFxrwrz(StringUtils.getUUID(), bsm, hgxfxDTO.getXmmc(), "合规性分析结束。。。");
         hgxfxMapper.update(hgxfxDTO, v1_update);
     }
 
@@ -59,6 +62,7 @@ public class HgxfxHandleService {
         for (HgxfxScxRwDTO v01_scx : scxRwDTOList) {
             String bsm = v01_scx.getBsm();
             String scxbsm = v01_scx.getScxbsm();
+            String scxName = v01_scx.getScxname()
             // 任务开始时间
             Date kssj = new Date();
             QueryWrapper<HgxfxScxTableDTO> v1_select = new QueryWrapper<HgxfxScxTableDTO>();
@@ -71,9 +75,23 @@ public class HgxfxHandleService {
             }
             getHgxfxScx(rwbsm, ewkt, v01_scx.getScxbsm());
             // 任务开始时间
-            Date jssj = new Date();
-            //添加记录
+            insertFxrwrz(bsm, rwbsm, scxName, null);
+        }
+    }
+
+    private void insertFxrwrz(String bsm, String rwbsm, String scxName, String rznr) {
+        //添加记录
+        FxrwrzDTO fxrwrzDTO = new FxrwrzDTO();
+        fxrwrzDTO.setBsm(bsm);
+        fxrwrzDTO.setRwbsm(rwbsm);
+        fxrwrzDTO.setRwlx(scxName);
+        if (StringUtils.isNotEmpty(rznr)) {
+            fxrwrzDTO.setRzlr(rznr);
+        } else {
+            fxrwrzDTO.setRzlr(scxName + "完成");
         }
+        fxrwrzDTO.setRzsj(new Date());
+        fxrwrzMapper.insert(fxrwrzDTO);
     }
 
     private List<String> getHgxfxScxJgIntersects(String bsm, String rwbsm, String scxbsm, String ewkt, HgxfxScxTableDTO dataTable) {
@@ -134,100 +152,4 @@ public class HgxfxHandleService {
         }
     }
 
-//    public void hgxfxHandle(String bsm, String ewkt) {
-//        //String ewkt = "SRID=4525;MULTIPOLYGON(((37342998.802186266 2026355.2598068258,37342865.92545163 2026357.1014534528,37342817.87560371 2026357.767365824,37342802.97989663 2026372.974932678,37342803.898728564 2026506.9421275943,37342819.00023294 2026521.733922014,37342900.08195203 2026520.6101232516,37342911.12435312 2026520.139866627,37342921.978652984 2026519.0511605758,37342932.75255981 2026517.3415217374,37342943.41078094 2026515.0165252725,37342953.9178506 2026512.0838249521,37342964.23945906 2026508.5530478982,37342974.34150494 2026504.4360855871,37342984.190657474 2026499.7461450424,37342993.75455573 2026494.4988803158,37343003.123444214 2026488.6354845203,37343042.17791849 2026462.6041323764,37343046.33985531 2026441.8032885736,37343039.5553245 2026431.6244374511,37343033.89487493 2026422.4690548987,37343028.79298549 2026412.7975274948,37343024.36349438 2026402.800136831,37343020.62692146 2026392.523455117,37343017.60047662 2026382.0158757505,37343014.53736561 2026367.7884403756,37342998.802186266 2026355.2598068258)),((37342684.474113196 2026681.7678619213,37342697.86007041 2026684.1221921882,37342780.41605009 2026697.5276640216,37342785.17736046 2026693.44891586,37342784.243153 2026557.2187332094,37342769.141550235 2026542.4269937698,37342683.52653461 2026543.613566511,37342684.474113196 2026681.7678619213)))";
-//        QueryWrapper<HgxfxDTO> hgxfxWrapper = new QueryWrapper<HgxfxDTO>();
-//        hgxfxWrapper.eq("bsm", bsm);
-//        HgxfxDTO hgxfxDTO = hgxfxMapper.selectOne(hgxfxWrapper);
-//        if (StringUtils.isNull(hgxfxDTO)) {
-//            return;
-//        }
-//
-//        //更新开始时间
-//        QueryWrapper<HgxfxDTO> v1_update = new QueryWrapper<HgxfxDTO>();
-//        v1_update.eq("bsm", bsm);
-//        hgxfxDTO.setRwkssj(new Date());
-//        hgxfxMapper.update(hgxfxDTO, v1_update);
-//
-//
-//        //查询审查项
-//        QueryWrapper<HgxfxScxRwDTO> scxRwWrapper = new QueryWrapper<HgxfxScxRwDTO>();
-//        scxRwWrapper.eq("rwbsm", bsm);
-//        List<HgxfxScxRwDTO> scxRwDTOList = hgxfxScxRwMapper.selectList(scxRwWrapper);
-//        if (scxRwDTOList.size() > 0) {
-//            //查询审查项对应的数据库表
-//            for (HgxfxScxRwDTO scxRwDTO : scxRwDTOList) {
-//
-//                FxrwrzDTO fxrwrzDTO = new FxrwrzDTO();
-//                fxrwrzDTO.setBsm(scxRwDTO.getBsm());
-//                fxrwrzDTO.setRwbsm(scxRwDTO.getRwbsm());
-//                fxrwrzDTO.setRzsj(new Date());
-//
-//                QueryWrapper<HgxfxScxTableDTO> scxTableWrapper = new QueryWrapper<HgxfxScxTableDTO>();
-//                scxTableWrapper.eq("bsm", scxRwDTO.getScxbsm());
-//                scxTableWrapper.orderByDesc("xssx");
-//                List<HgxfxScxTableDTO> hgxfxScxTableDTOList = hgxfxScxTableMapper.selectList(scxTableWrapper);
-//                if (hgxfxScxTableDTOList.size() > 0) {
-//                    for (HgxfxScxTableDTO scxTable : hgxfxScxTableDTOList) {
-//                        fxrwrzDTO.setRzlx("info");
-//                        fxrwrzDTO.setRwlx(scxTable.getYsmc());
-//                        fxrwrzDTO.setRzlr(scxTable.getYsmc() + "完成");
-//                        String v_sjy = scxTable.getSjy();
-//                        Integer v_srid = scxTable.getSrid();
-//                        Integer v_rwsrid = scxTable.getRwsrid();
-//                        RequestResult result = analyseService.intersectsTableWkt(v_sjy, v_srid, null, ewkt, v_rwsrid);
-//                        int resultCode = (int) result.get("statuscode");
-//                        if (resultCode == 200) {
-//                            System.out.println("************");
-//                            Object resultData = result.get("data");
-//                            if (StringUtils.isNotNull(resultData)) {
-//                                List<String> resultList = (List<String>) resultData;
-//                                for (Object gg : resultList) {
-//                                    System.out.println(gg.toString());
-//                                }
-//                                if (resultList.size() > 0) {
-//                                    String v_tjzd = scxTable.getTjzd();
-//                                    List<String> outputColumn = Arrays.asList(v_tjzd.split(","));
-//                                    RequestResult result2 = analyseService.intersectionTableWkt(v_sjy, v_srid, resultList, ewkt, v_rwsrid, outputColumn);
-//                                    int resultCode2 = (int) result2.get("statuscode");
-//                                    if (resultCode2 == 200) {
-//                                        System.out.println("************");
-//                                        Object resultData2 = result2.get("data");
-//                                        if (StringUtils.isNotNull(resultData2)) {
-//                                            List<Map> resultList2 = (List<Map>) resultData2;
-//                                            for (Map gg2 : resultList2) {
-//                                                HgxfxRwJgTempDTO dtoRk = new HgxfxRwJgTempDTO();
-//                                                dtoRk.setBsm(scxRwDTO.getBsm());
-//                                                dtoRk.setRwbsm(scxRwDTO.getRwbsm());
-//                                                dtoRk.setScxbsm(scxRwDTO.getScxbsm());
-//                                                dtoRk.setYslx(gg2.get("dlbm").toString());
-//                                                dtoRk.setYslxmc(gg2.get("dlmc").toString());
-//                                                dtoRk.setMj(Double.parseDouble(gg2.get("geom_area").toString()));
-//                                                dtoRk.setGeom(gg2.get("geom").toString());
-//                                                hgxfxRwJgTempMapper.insert(dtoRk);
-//                                                System.out.println(gg2.toString());
-//                                            }
-//                                        }
-//                                    }
-//                                    System.out.println(result2);
-//                                }
-//                            }
-//
-//                        }
-//
-//                    }
-//                }
-////                List<HgxfxRwJgDTO> listHgxfxRwJgDTO= hgxfxRwJgTempMapper.groupByYslx(scxRwDTO.getBsm(), scxRwDTO.getRwbsm(), scxRwDTO.getScxbsm());
-////                for(HgxfxRwJgDTO kk:listHgxfxRwJgDTO){
-////                    hgxfxRwJgMapper.insert(kk);
-////                }
-////                fxrwrzMapper.insert(fxrwrzDTO);
-//            }
-//        }
-//
-//        //更新任务截止时间
-////        hgxfxDTO.setRwjssj(new Date());
-////        hgxfxMapper.updateById(hgxfxDTO);
-//    }
-
 }