fengchunyu
/
dataCompareSy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

涉稳,列管人员清洗

Browse Source
develop
hanrenchun 10 months ago
parent 35a7e20edb
commit 7644ac767f
2 changed files with 64 additions and 70 deletions
Show Stats Download Patch File Download Diff File

7
src/main/java/com/ssf/mysqloracletest/task/VLgryGjxxTask.java
Unescape View File

@ -88,8 +88,7 @@ public class VLgryGjxxTask {
lgryMap.put("minTime", oneYearLaterFormattedDate); lgryMap.put("minTime", oneYearLaterFormattedDate);
List<VLgryGjxxOracle> list = vLgryGjxxOracleService.getLgryListByTime(lgryMap); List<VLgryGjxxOracle> list = vLgryGjxxOracleService.getLgryListByTime(lgryMap);
CountDownLatch latch = new CountDownLatch(list.size()); CountDownLatch latch = new CountDownLatch(list.size());
ExecutorService LgryPool = Executors.newFixedThreadPool(5);
LgryPool.submit(() -> {
try { try {
for (VLgryGjxxOracle lgry : list) { for (VLgryGjxxOracle lgry : list) {
if ("10".equals(lgry.getYJLX())) { if ("10".equals(lgry.getYJLX())) {
@ -165,7 +164,7 @@ public class VLgryGjxxTask {
logger.info("Lgrys:" + StringKit.getTrace(e)); logger.info("Lgrys:" + StringKit.getTrace(e));
} }
latch.countDown(); latch.countDown();
});
try { try {
// Wait for all threads to complete // Wait for all threads to complete
@ -173,8 +172,6 @@ public class VLgryGjxxTask {
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
} }
// 关闭线程池
LgryPool.shutdown();
} catch ( } catch (
Exception e) { Exception e) {

127
src/main/java/com/ssf/mysqloracletest/task/VSwryGjxxTask.java
Unescape View File

@ -88,76 +88,75 @@ public class VSwryGjxxTask {
SwryMap.put("minTime", oneYearLaterFormattedDate); SwryMap.put("minTime", oneYearLaterFormattedDate);
List<VSwryGjxxOracle> Swrys = vSySwryGjxxOracleService.getSwryListByTime(SwryMap); List<VSwryGjxxOracle> Swrys = vSySwryGjxxOracleService.getSwryListByTime(SwryMap);
CountDownLatch latch = new CountDownLatch(Swrys.size()); CountDownLatch latch = new CountDownLatch(Swrys.size());
ExecutorService SwryPool = Executors.newFixedThreadPool(5);
SwryPool.submit(() -> { try {
try { for (VSwryGjxxOracle swry : Swrys) {
for (VSwryGjxxOracle swry : Swrys) { if ("02".equals(swry.getGJLX())) {
if ("02".equals(swry.getGJLX())) { TransitImpVehicleRecord transitImpVehicleRecord = new TransitImpVehicleRecord();
TransitImpVehicleRecord transitImpVehicleRecord = new TransitImpVehicleRecord(); transitImpVehicleRecord.setDeviceCode(swry.getVALUE3());
transitImpVehicleRecord.setDeviceCode(swry.getVALUE3()); transitImpVehicleRecord.setLongitude(NumKit.checkBigDecimal(swry.getJDZB()));
transitImpVehicleRecord.setLongitude(NumKit.checkBigDecimal(swry.getJDZB())); transitImpVehicleRecord.setLatitude(NumKit.checkBigDecimal(swry.getWDZB()));
transitImpVehicleRecord.setLatitude(NumKit.checkBigDecimal(swry.getWDZB())); transitImpVehicleRecord.setDeviceAddress(swry.getVALUE1());
transitImpVehicleRecord.setDeviceAddress(swry.getVALUE1()); transitImpVehicleRecord.setPlateNo(swry.getVALUE2());
transitImpVehicleRecord.setPlateNo(swry.getVALUE2()); transitImpVehicleRecord.setGlobalPic(swry.getVALUE5());
transitImpVehicleRecord.setGlobalPic(swry.getVALUE5()); transitImpVehicleRecord.setPlatePic(swry.getVALUE4());
transitImpVehicleRecord.setPlatePic(swry.getVALUE4()); transitImpVehicleRecord.setOwnerName(swry.getZDRYXM());
transitImpVehicleRecord.setOwnerName(swry.getZDRYXM()); transitImpVehicleRecord.setIdCard(swry.getZDRYSFZH());
transitImpVehicleRecord.setIdCard(swry.getZDRYSFZH()); transitImpVehicleRecord.setPassTime(NumKit.checkLong(swry.getGJSJ()));
transitImpVehicleRecord.setPassTime(NumKit.checkLong(swry.getGJSJ())); transitImpVehicleRecord.setPartitionField(dateFormat.parse(swry.getGJSJ()));
transitImpVehicleRecord.setPartitionField(dateFormat.parse(swry.getGJSJ())); transitImpVehicleRecord.setImpUserTypeName("涉稳人员");
transitImpVehicleRecord.setImpUserTypeName("涉稳人员"); TransitImpVehicleRecord one = transitImpVehicleRecordService.lambdaQuery().eq(TransitImpVehicleRecord::getGlobalPic, swry.getVALUE5()).one();
TransitImpVehicleRecord one = transitImpVehicleRecordService.lambdaQuery().eq(TransitImpVehicleRecord::getGlobalPic, swry.getVALUE5()).one(); if (one == null) {
if (one == null) { boolean save = transitImpVehicleRecordService.save(transitImpVehicleRecord);
boolean save = transitImpVehicleRecordService.save(transitImpVehicleRecord); if (save) {
if (save) { logger.info("Swry-" + swry.getGJXXID() + ":插入成功");
logger.info("Swry-" + swry.getGJXXID() + ":插入成功"); }
} } else {
} else { UpdateWrapper<TransitImpVehicleRecord> transitImpVehicleRecordUpdateWrapper = new UpdateWrapper<>();
UpdateWrapper<TransitImpVehicleRecord> transitImpVehicleRecordUpdateWrapper = new UpdateWrapper<>(); transitImpVehicleRecordUpdateWrapper.eq("global_pic", swry.getVALUE5());
transitImpVehicleRecordUpdateWrapper.eq("global_pic", swry.getVALUE5()); boolean update = transitImpVehicleRecordService.update(transitImpVehicleRecord, transitImpVehicleRecordUpdateWrapper);
boolean update = transitImpVehicleRecordService.update(transitImpVehicleRecord, transitImpVehicleRecordUpdateWrapper); if (update) {
if (update) { logger.info("Swry-" + swry.getGJXXID() + ":更新成功");
logger.info("Swry-" + swry.getGJXXID() + ":更新成功");
}
} }
} }
if ("03".equals(swry.getGJLX())) { }
TransitImpUserRecord transitImpUserRecord = new TransitImpUserRecord(); if ("03".equals(swry.getGJLX())) {
transitImpUserRecord.setDeviceCode(swry.getVALUE6()); TransitImpUserRecord transitImpUserRecord = new TransitImpUserRecord();
transitImpUserRecord.setLongitude(NumKit.checkBigDecimal(swry.getJDZB())); transitImpUserRecord.setDeviceCode(swry.getVALUE6());
transitImpUserRecord.setLatitude(NumKit.checkBigDecimal(swry.getWDZB())); transitImpUserRecord.setLongitude(NumKit.checkBigDecimal(swry.getJDZB()));
transitImpUserRecord.setDeviceAddress(swry.getVALUE1()); transitImpUserRecord.setLatitude(NumKit.checkBigDecimal(swry.getWDZB()));
transitImpUserRecord.setGlobalPic(swry.getVALUE4()); transitImpUserRecord.setDeviceAddress(swry.getVALUE1());
transitImpUserRecord.setUserPic(swry.getVALUE3()); transitImpUserRecord.setGlobalPic(swry.getVALUE4());
transitImpUserRecord.setSimilarity(swry.getVALUE2()); transitImpUserRecord.setUserPic(swry.getVALUE3());
transitImpUserRecord.setOwnerName(swry.getZDRYXM()); transitImpUserRecord.setSimilarity(swry.getVALUE2());
transitImpUserRecord.setIdCard(swry.getZDRYSFZH()); transitImpUserRecord.setOwnerName(swry.getZDRYXM());
transitImpUserRecord.setPassTime(NumKit.checkLong(swry.getGJSJ())); transitImpUserRecord.setIdCard(swry.getZDRYSFZH());
transitImpUserRecord.setPartitionField(dateFormat.parse(swry.getGJSJ())); transitImpUserRecord.setPassTime(NumKit.checkLong(swry.getGJSJ()));
transitImpUserRecord.setImpUserTypeName("涉稳人员"); transitImpUserRecord.setPartitionField(dateFormat.parse(swry.getGJSJ()));
TransitImpUserRecord one = transitImpUserRecordService.lambdaQuery().eq(TransitImpUserRecord::getGlobalPic, swry.getVALUE4()).one(); transitImpUserRecord.setImpUserTypeName("涉稳人员");
if (one == null) { TransitImpUserRecord one = transitImpUserRecordService.lambdaQuery().eq(TransitImpUserRecord::getGlobalPic, swry.getVALUE4()).one();
boolean save = transitImpUserRecordService.save(transitImpUserRecord); if (one == null) {
if (save) { boolean save = transitImpUserRecordService.save(transitImpUserRecord);
logger.info("Swry-" + swry.getGJXXID() + ":插入成功"); if (save) {
} logger.info("Swry-" + swry.getGJXXID() + ":插入成功");
} else { }
UpdateWrapper<TransitImpUserRecord> transitImpUserRecordUpdateWrapper = new UpdateWrapper<>(); } else {
transitImpUserRecordUpdateWrapper.eq("global_pic", swry.getVALUE4()); UpdateWrapper<TransitImpUserRecord> transitImpUserRecordUpdateWrapper = new UpdateWrapper<>();
boolean update = transitImpUserRecordService.update(transitImpUserRecord, transitImpUserRecordUpdateWrapper); transitImpUserRecordUpdateWrapper.eq("global_pic", swry.getVALUE4());
if (update) { boolean update = transitImpUserRecordService.update(transitImpUserRecord, transitImpUserRecordUpdateWrapper);
logger.info("Swry-" + swry.getGJXXID() + ":更新成功"); if (update) {
} logger.info("Swry-" + swry.getGJXXID() + ":更新成功");
} }
} }
} }
} catch (Exception e) {
logger.info("Swrys:" + StringKit.getTrace(e));
} }
latch.countDown(); } catch (Exception e) {
}); logger.info("Swrys:" + StringKit.getTrace(e));
}
latch.countDown();
try { try {
// Wait for all threads to complete // Wait for all threads to complete
@ -165,8 +164,6 @@ public class VSwryGjxxTask {
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
} }
// 关闭线程池
SwryPool.shutdown();
} catch ( } catch (

Write Preview
Loading…
Cancel
Save