从业人员的数据清洗逻辑修改

src/main/java/com/ssf/mysqloracletest/domain/MetaActualUnitUserInfo.java

@@ -24,7 +24,7 @@ public class MetaActualUnitUserInfo implements Serializable {
     /**
      * 单位id
      */
-    private Long unitId;
+    private String unitId;
 
     /**
      * 单位名称

src/main/java/com/ssf/mysqloracletest/task/MetaActualUnitUserInfoTask.java

@@ -55,14 +55,13 @@ public class MetaActualUnitUserInfoTask {
             Page<VSySydwCyryMysql> page = new Page<>(1, 1000);
             List<VSySydwCyryMysql> resultList = vSySydwCyryMysqlService.page(page, queryWrapper).getRecords();
             CountDownLatch latch = new CountDownLatch(resultList.size());
-            ExecutorService cyryPool = Executors.newFixedThreadPool(5);
 
 
             for (VSySydwCyryMysql bean : resultList) {
-                cyryPool.submit(() -> {
+
                     cleanCyry(bean);
                     latch.countDown();
-                });
+
             }
 
 
@@ -76,11 +75,9 @@ public class MetaActualUnitUserInfoTask {
         VSySydwCyryMysql cyry = new VSySydwCyryMysql();
         try {
             BeanUtils.copyProperties(bean, cyry);
-            MetaActualUnitUserInfo metaActualUnitUserInfo = new MetaActualUnitUserInfo();
             VSySydwCyryMysql vSySydwCyryMysql = vSySydwCyryMysqlService.selectCyryById(cyry.getID());
-            if (cyry.getDWID() != null) {
-                metaActualUnitUserInfo.setUnitId(Long.parseLong(cyry.getDWID()));
-            }
+            MetaActualUnitUserInfo metaActualUnitUserInfo = new MetaActualUnitUserInfo();
+            metaActualUnitUserInfo.setUnitId(cyry.getDWID());
             metaActualUnitUserInfo.setUnitName(cyry.getDWMC());
             metaActualUnitUserInfo.setStaffName(cyry.getXM());
             metaActualUnitUserInfo.setIdentityId(cyry.getZJHM());