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 page = new Page<>(1, 1000); List 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); }