From 50a8af3bf3cb43d862fc6431f5ba1dee06b00aa0 Mon Sep 17 00:00:00 2001
From: hanrenchun <hanrenchun>
Date: Thu, 7 Dec 2023 09:12:57 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=8E=E4=B8=9A=E4=BA=BA=E5=91=98=E7=9A=84?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E6=B8=85=E6=B4=97=E9=80=BB=E8=BE=91=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../domain/MetaActualUnitUserInfo.java              |  2 +-
 .../task/MetaActualUnitUserInfoTask.java            | 13 +++++--------
 2 files changed, 6 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/ssf/mysqloracletest/domain/MetaActualUnitUserInfo.java b/src/main/java/com/ssf/mysqloracletest/domain/MetaActualUnitUserInfo.java
index 2dada95..9eac1a5 100644
--- a/src/main/java/com/ssf/mysqloracletest/domain/MetaActualUnitUserInfo.java
+++ b/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;
 
     /**
      * 单位名称
diff --git a/src/main/java/com/ssf/mysqloracletest/task/MetaActualUnitUserInfoTask.java b/src/main/java/com/ssf/mysqloracletest/task/MetaActualUnitUserInfoTask.java
index e9fe224..d9efc3c 100644
--- a/src/main/java/com/ssf/mysqloracletest/task/MetaActualUnitUserInfoTask.java
+++ b/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());
@@ -100,7 +97,7 @@ public class MetaActualUnitUserInfoTask {
             metaActualUnitUserInfo.setMetaUpdateTime(vSySydwCyryMysql.getYSBZK_GXSJ());
             //确定一个数据是否唯一
             boolean save = metaActualUnitUserInfoService.save(metaActualUnitUserInfo);
-            if (save){
+            if (save) {
                 cyry.setStatus("1");
                 vSySydwCyryMysqlService.updateCyryById(cyry);
             }