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

实有房屋代号

Browse Source
develop
hanrenchun 8 months ago
parent 67dddb4769
commit 8633a2b667
2 changed files with 54 additions and 56 deletions
Show Stats Download Patch File Download Diff File

108
src/main/java/com/ssf/mysqloracletest/task/SydzToEstateInfoTask.java
Unescape View File

@ -50,23 +50,23 @@ public class SydzToEstateInfoTask {
try { try {
List<VSySydzMysql> sydzs = sydzMysqlService.selectVSySydz(new VSySydzMysql()); List<VSySydzMysql> sydzs = sydzMysqlService.selectVSySydz(new VSySydzMysql());
CountDownLatch latch = new CountDownLatch(sydzs.size()); // CountDownLatch latch = new CountDownLatch(sydzs.size());
ExecutorService jwtSyfwPool = Executors.newFixedThreadPool(50); // ExecutorService jwtSyfwPool = Executors.newFixedThreadPool(50);
for (VSySydzMysql bean : sydzs) { for (VSySydzMysql bean : sydzs) {
jwtSyfwPool.submit(() -> { // jwtSyfwPool.submit(() -> {
cleanJwtSyfw(bean); cleanJwtSyfw(bean);
latch.countDown(); // latch.countDown();
}); // });
} }
try { // try {
// Wait for all threads to complete // // Wait for all threads to complete
latch.await(); // latch.await();
} catch (InterruptedException e) { // } catch (InterruptedException e) {
e.printStackTrace(); // e.printStackTrace();
} // }
// 关闭线程池 // // 关闭线程池
jwtSyfwPool.shutdown(); // jwtSyfwPool.shutdown();
} catch (Exception e) { } catch (Exception e) {
logger.info(StringKit.getTrace(e)); logger.info(StringKit.getTrace(e));
} }
@ -78,62 +78,60 @@ public class SydzToEstateInfoTask {
try { try {
BeanUtils.copyProperties(bean, beanCp); BeanUtils.copyProperties(bean, beanCp);
// String dzdxtymc = StringKit.toString(beanCp.getDZDXTYMC());
String dzdxtymc = StringKit.toString(beanCp.getDZDXTYMC()); // dzdxtymc = StringKit.convertChineseUnitToDigit(dzdxtymc);
dzdxtymc = StringKit.convertChineseUnitToDigit(dzdxtymc);
// dzdxtymc = dzdxtymc.replaceAll("号","幢"); // dzdxtymc = dzdxtymc.replaceAll("号","幢");
String home = ""; String home = "1";
try { // try {
home = StringKit.extractDigits(dzdxtymc.substring(0, dzdxtymc.indexOf("室"))); // home = StringKit.extractDigits(dzdxtymc.substring(0, dzdxtymc.indexOf("室")));
} catch (Exception e) { // } catch (Exception e) {
home = ""; // home = "1";
} // }
String unit = "1"; String unit = "1";
try { // try {
unit = StringKit.extractDigits(dzdxtymc.substring(0, dzdxtymc.indexOf("单元"))); // unit = StringKit.extractDigits(dzdxtymc.substring(0, dzdxtymc.indexOf("单元")));
} catch (Exception e) { // } catch (Exception e) {
unit = "1"; // unit = "1";
} // }
String build = ""; String build = "1";
try { // try {
build = StringKit.extractDigits(dzdxtymc.substring(0, dzdxtymc.indexOf("幢"))); // build = StringKit.extractDigits(dzdxtymc.substring(0, dzdxtymc.indexOf("幢")));
} catch (Exception e) { // } catch (Exception e) {
build = ""; // build = "1";
} // }
String address = ""; // String address = "";
try { // try {
int index = dzdxtymc.indexOf("号"); // int index = dzdxtymc.indexOf("号");
if (index != -1) { // if (index != -1) {
address = dzdxtymc.substring(0, index); // address = dzdxtymc.substring(0, index);
} // }
} catch (Exception e) { // } catch (Exception e) {
logger.info("小区地址未匹配到请求中户籍地址:" + build); // logger.info("小区地址未匹配到请求中户籍地址:" + build);
} // }
if ("".equals(home) || "".equals(unit) || "".equals(address)){ // if ("".equals(home) || "".equals(unit) || "".equals(address)){
beanCp.setStatus("2"); // beanCp.setStatus("2");
sydzMysqlService.updateVSySydzById(beanCp); // sydzMysqlService.updateVSySydzById(beanCp);
return; // return;
} // }
MetaRealEstateInfo realEstateInfo = new MetaRealEstateInfo(); MetaRealEstateInfo realEstateInfo = new MetaRealEstateInfo();
// realEstateInfo.setHomeId(); // realEstateInfo.setHomeId();
realEstateInfo.setPoliceStationCode(StringKit.toString(bean.getZRQDM())); realEstateInfo.setPoliceStationCode(StringKit.toString(bean.getZRQDM()));
realEstateInfo.setPoliceDistrictCode(StringKit.toString(bean.getZRQDM())); realEstateInfo.setPoliceDistrictCode(StringKit.toString(bean.getZRQDM()));
realEstateInfo.setRealEstateBriefAddress(address + "号"); realEstateInfo.setRealEstateBriefAddress(StringKit.toString(StringKit.convertChineseUnitToDigit(beanCp.getDZDXTYMC())));
realEstateInfo.setRealEstateAddress(StringKit.toString(StringKit.convertChineseUnitToDigit(beanCp.getDZDXTYMC()))); realEstateInfo.setRealEstateAddress(StringKit.toString(StringKit.convertChineseUnitToDigit(beanCp.getDZDXTYMC())));
realEstateInfo.setUnitName(unit); realEstateInfo.setUnitName(unit);
realEstateInfo.setBuildingName(build); realEstateInfo.setBuildingName(build);
realEstateInfo.setHomeName(home); realEstateInfo.setHomeName(home);
realEstateInfo.setLongitude(NumKit.checkDouble(bean.getJDZB())); realEstateInfo.setLongitude(NumKit.checkDouble(bean.getJDZB()));
realEstateInfo.setLatitude(NumKit.checkDouble(bean.getCJSJ())); realEstateInfo.setLatitude(NumKit.checkDouble(bean.getCJSJ()));
boolean b = estateInfoService.save(realEstateInfo); boolean save = estateInfoService.save(realEstateInfo);
if (save) {
if (b) {
beanCp.setStatus("1"); beanCp.setStatus("1");
sydzMysqlService.updateVSySydzById(beanCp); sydzMysqlService.updateVSySydzById(beanCp);
} }

2
src/main/resources/mapper/VSySydzMysqlMapper.xml
Unescape View File

@ -22,7 +22,7 @@
<select id="selectVSySydz" parameterType="java.lang.String" resultMap="VSySydzResult"> <select id="selectVSySydz" parameterType="java.lang.String" resultMap="VSySydzResult">
select * from v_sy_sydz select * from v_sy_sydz
where status is null and DZDXMC like '%室%' order by cjsj desc limit 200; where status is null and DZDXMC like '%号%' order by cjsj desc limit 200;
</select> </select>
<insert id="insertVSySydz" parameterType="com.ssf.mysqloracletest.domain.VSySydzMysql" useGeneratedKeys="true" <insert id="insertVSySydz" parameterType="com.ssf.mysqloracletest.domain.VSySydzMysql" useGeneratedKeys="true"

Write Preview
Loading…
Cancel
Save