diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/MetaActualUserInfoMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/MetaActualUserInfoMapper.java index ef05e4e..e98626a 100644 --- a/src/main/java/com/ssf/mysqloracletest/mapper/MetaActualUserInfoMapper.java +++ b/src/main/java/com/ssf/mysqloracletest/mapper/MetaActualUserInfoMapper.java @@ -4,6 +4,8 @@ import com.ssf.mysqloracletest.domain.MetaActualUserInfo; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import org.apache.ibatis.annotations.Mapper; +import java.util.List; + /** * @author 28758 * @description 针对表【meta_actual_user_info(实有人口信息表)】的数据库操作Mapper @@ -13,6 +15,56 @@ import org.apache.ibatis.annotations.Mapper; @Mapper public interface MetaActualUserInfoMapper extends BaseMapper { + /** + * 查询实有人口信息 + * + * @param id 实有人口信息主键 + * @return 实有人口信息 + */ + public MetaActualUserInfo selectMetaActualUserInfoById(Long id); + + /** + * 查询实有人口信息列表 + * + * @param metaActualUserInfo 实有人口信息 + * @return 实有人口信息集合 + */ + public List selectMetaActualUserInfoList(MetaActualUserInfo metaActualUserInfo); + + public List selectMetaActualUserInfoListByHomeId(MetaActualUserInfo metaActualUserInfo); + + /** + * 新增实有人口信息 + * + * @param metaActualUserInfo 实有人口信息 + * @return 结果 + */ + public int insertMetaActualUserInfo(MetaActualUserInfo metaActualUserInfo); + + /** + * 修改实有人口信息 + * + * @param metaActualUserInfo 实有人口信息 + * @return 结果 + */ + public int updateMetaActualUserInfo(MetaActualUserInfo metaActualUserInfo); + + /** + * 删除实有人口信息 + * + * @param id 实有人口信息主键 + * @return 结果 + */ + public int deleteMetaActualUserInfoById(Long id); + + /** + * 批量删除实有人口信息 + * + * @param ids 需要删除的数据主键集合 + * @return 结果 + */ + public int deleteMetaActualUserInfoByIds(Long[] ids); + } diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/MetaRealEstateInfoMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/MetaRealEstateInfoMapper.java index dac757b..f4217e8 100644 --- a/src/main/java/com/ssf/mysqloracletest/mapper/MetaRealEstateInfoMapper.java +++ b/src/main/java/com/ssf/mysqloracletest/mapper/MetaRealEstateInfoMapper.java @@ -13,4 +13,6 @@ import org.apache.ibatis.annotations.Mapper; @Mapper public interface MetaRealEstateInfoMapper extends BaseMapper { + public MetaRealEstateInfo getListByAddress(MetaRealEstateInfo metaRealEstateInfo); + } diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/VillageActualUserInfoMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/VillageActualUserInfoMapper.java index 6dfb27f..03493d7 100644 --- a/src/main/java/com/ssf/mysqloracletest/mapper/VillageActualUserInfoMapper.java +++ b/src/main/java/com/ssf/mysqloracletest/mapper/VillageActualUserInfoMapper.java @@ -27,6 +27,8 @@ public interface VillageActualUserInfoMapper { */ public List selectVillageActualUserInfoList(VillageActualUserInfo bean); + public List selectVillageActualUserInfoListLimit1(VillageActualUserInfo bean); + public List selectVillageActualUserInfoListAndPicExists(VillageActualUserInfo bean); /** diff --git a/src/main/java/com/ssf/mysqloracletest/service/MetaActualUserInfoService.java b/src/main/java/com/ssf/mysqloracletest/service/MetaActualUserInfoService.java index b6f41bf..1f156e6 100644 --- a/src/main/java/com/ssf/mysqloracletest/service/MetaActualUserInfoService.java +++ b/src/main/java/com/ssf/mysqloracletest/service/MetaActualUserInfoService.java @@ -3,6 +3,8 @@ package com.ssf.mysqloracletest.service; import com.ssf.mysqloracletest.domain.MetaActualUserInfo; import com.baomidou.mybatisplus.extension.service.IService; +import java.util.List; + /** * @author 28758 * @description 针对表【meta_actual_user_info(实有人口信息表)】的数据库操作Service @@ -10,4 +12,55 @@ import com.baomidou.mybatisplus.extension.service.IService; */ public interface MetaActualUserInfoService extends IService { + /** + * 查询实有人口信息 + * + * @param id 实有人口信息主键 + * @return 实有人口信息 + */ + public MetaActualUserInfo selectMetaActualUserInfoById(Long id); + + /** + * 查询实有人口信息列表 + * + * @param metaActualUserInfo 实有人口信息 + * @return 实有人口信息集合 + */ + public List selectMetaActualUserInfoList(MetaActualUserInfo metaActualUserInfo); + + + public List selectMetaActualUserInfoListByHomeId(MetaActualUserInfo metaActualUserInfo); + + /** + * 新增实有人口信息 + * + * @param metaActualUserInfo 实有人口信息 + * @return 结果 + */ + public int insertMetaActualUserInfo(MetaActualUserInfo metaActualUserInfo); + + /** + * 修改实有人口信息 + * + * @param metaActualUserInfo 实有人口信息 + * @return 结果 + */ + public int updateMetaActualUserInfo(MetaActualUserInfo metaActualUserInfo); + + /** + * 批量删除实有人口信息 + * + * @param ids 需要删除的实有人口信息主键集合 + * @return 结果 + */ + public int deleteMetaActualUserInfoByIds(Long[] ids); + + /** + * 删除实有人口信息信息 + * + * @param id 实有人口信息主键 + * @return 结果 + */ + public int deleteMetaActualUserInfoById(Long id); + } diff --git a/src/main/java/com/ssf/mysqloracletest/service/MetaRealEstateInfoService.java b/src/main/java/com/ssf/mysqloracletest/service/MetaRealEstateInfoService.java index 5e4cd1c..29bd29b 100644 --- a/src/main/java/com/ssf/mysqloracletest/service/MetaRealEstateInfoService.java +++ b/src/main/java/com/ssf/mysqloracletest/service/MetaRealEstateInfoService.java @@ -20,4 +20,6 @@ public interface MetaRealEstateInfoService extends IService */ boolean insertOrUpdate(MetaRealEstateInfo metaRealEstateInfo); + MetaRealEstateInfo getListByAddress(MetaRealEstateInfo metaRealEstateInfo); + } diff --git a/src/main/java/com/ssf/mysqloracletest/service/VillageActualUserInfoService.java b/src/main/java/com/ssf/mysqloracletest/service/VillageActualUserInfoService.java index cb0a8c3..a993ba0 100644 --- a/src/main/java/com/ssf/mysqloracletest/service/VillageActualUserInfoService.java +++ b/src/main/java/com/ssf/mysqloracletest/service/VillageActualUserInfoService.java @@ -23,6 +23,8 @@ public interface VillageActualUserInfoService { */ public List selectVillageActualUserInfoList(VillageActualUserInfo villageActualUserInfo); + public List selectVillageActualUserInfoListLimit1(VillageActualUserInfo villageActualUserInfo); + public List selectVillageActualUserInfoListAndPicExists(VillageActualUserInfo villageActualUserInfo); diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/MetaActualUserInfoServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/MetaActualUserInfoServiceImpl.java index 1ce3f76..208e509 100644 --- a/src/main/java/com/ssf/mysqloracletest/service/impl/MetaActualUserInfoServiceImpl.java +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/MetaActualUserInfoServiceImpl.java @@ -3,20 +3,95 @@ package com.ssf.mysqloracletest.service.impl; import com.baomidou.dynamic.datasource.annotation.DS; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ssf.mysqloracletest.domain.MetaActualUserInfo; -import com.ssf.mysqloracletest.service.MetaActualUserInfoService; import com.ssf.mysqloracletest.mapper.MetaActualUserInfoMapper; +import com.ssf.mysqloracletest.service.MetaActualUserInfoService; import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; + /** -* @author 28758 -* @description 针对表【meta_actual_user_info(实有人口信息表)】的数据库操作Service实现 -* @createDate 2023-12-02 17:31:50 -*/ + * @author 28758 + * @description 针对表【meta_actual_user_info(实有人口信息表)】的数据库操作Service实现 + * @createDate 2023-12-02 17:31:50 + */ @Service @DS("mysql") public class MetaActualUserInfoServiceImpl extends ServiceImpl - implements MetaActualUserInfoService{ + implements MetaActualUserInfoService { + @Resource + private MetaActualUserInfoMapper metaActualUserInfoMapper; + + /** + * 查询实有人口信息 + * + * @param id 实有人口信息主键 + * @return 实有人口信息 + */ + @Override + public MetaActualUserInfo selectMetaActualUserInfoById(Long id) { + return metaActualUserInfoMapper.selectMetaActualUserInfoById(id); + } + + /** + * 查询实有人口信息列表 + * + * @param metaActualUserInfo 实有人口信息 + * @return 实有人口信息 + */ + @Override + public List selectMetaActualUserInfoList(MetaActualUserInfo metaActualUserInfo) { + return metaActualUserInfoMapper.selectMetaActualUserInfoList(metaActualUserInfo); + } + + @Override + public List selectMetaActualUserInfoListByHomeId(MetaActualUserInfo metaActualUserInfo) { + return metaActualUserInfoMapper.selectMetaActualUserInfoListByHomeId(metaActualUserInfo); + } + + /** + * 新增实有人口信息 + * + * @param metaActualUserInfo 实有人口信息 + * @return 结果 + */ + @Override + public int insertMetaActualUserInfo(MetaActualUserInfo metaActualUserInfo) { + return metaActualUserInfoMapper.insertMetaActualUserInfo(metaActualUserInfo); + } + + /** + * 修改实有人口信息 + * + * @param metaActualUserInfo 实有人口信息 + * @return 结果 + */ + @Override + public int updateMetaActualUserInfo(MetaActualUserInfo metaActualUserInfo) { + return metaActualUserInfoMapper.updateMetaActualUserInfo(metaActualUserInfo); + } + + /** + * 批量删除实有人口信息 + * + * @param ids 需要删除的实有人口信息主键 + * @return 结果 + */ + @Override + public int deleteMetaActualUserInfoByIds(Long[] ids) { + return metaActualUserInfoMapper.deleteMetaActualUserInfoByIds(ids); + } + /** + * 删除实有人口信息信息 + * + * @param id 实有人口信息主键 + * @return 结果 + */ + @Override + public int deleteMetaActualUserInfoById(Long id) { + return metaActualUserInfoMapper.deleteMetaActualUserInfoById(id); + } } diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/MetaRealEstateInfoServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/MetaRealEstateInfoServiceImpl.java index 0176857..9d66846 100644 --- a/src/main/java/com/ssf/mysqloracletest/service/impl/MetaRealEstateInfoServiceImpl.java +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/MetaRealEstateInfoServiceImpl.java @@ -4,8 +4,10 @@ package com.ssf.mysqloracletest.service.impl; import com.baomidou.dynamic.datasource.annotation.DS; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ssf.mysqloracletest.domain.MetaRealEstateInfo; +import com.ssf.mysqloracletest.mapper.JcjJxxViewMysqlMapper; import com.ssf.mysqloracletest.mapper.MetaRealEstateInfoMapper; import com.ssf.mysqloracletest.service.MetaRealEstateInfoService; +import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; /** @@ -16,11 +18,19 @@ import org.springframework.stereotype.Service; */ @Service @DS("mysql") +@RequiredArgsConstructor public class MetaRealEstateInfoServiceImpl extends ServiceImpl implements MetaRealEstateInfoService { + private final MetaRealEstateInfoMapper realEstateInfoMapper; + @Override public boolean insertOrUpdate(MetaRealEstateInfo metaRealEstateInfo) { return false; } + @Override + public MetaRealEstateInfo getListByAddress(MetaRealEstateInfo metaRealEstateInfo){ + return realEstateInfoMapper.getListByAddress(metaRealEstateInfo); + } + } diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/VillageActualUserInfoServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/VillageActualUserInfoServiceImpl.java index b6d6bcb..ef5f19b 100644 --- a/src/main/java/com/ssf/mysqloracletest/service/impl/VillageActualUserInfoServiceImpl.java +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/VillageActualUserInfoServiceImpl.java @@ -25,7 +25,7 @@ import java.util.List; * @date 2023-04-17 */ @Service -@DS("mysqlSy") +@DS("mysql") public class VillageActualUserInfoServiceImpl implements VillageActualUserInfoService { private static final Logger logger = LoggerFactory.getLogger(VillageActualUserInfoServiceImpl.class); @@ -58,6 +58,11 @@ public class VillageActualUserInfoServiceImpl implements VillageActualUserInfoSe List list = ActualUserInfoDao.selectVillageActualUserInfoList(villageActualUserInfo); return list; } + @Override + public List selectVillageActualUserInfoListLimit1(VillageActualUserInfo villageActualUserInfo) { + List list = ActualUserInfoDao.selectVillageActualUserInfoListLimit1(villageActualUserInfo); + return list; + } /** * diff --git a/src/main/java/com/ssf/mysqloracletest/task/MetaActualUserInfoTask.java b/src/main/java/com/ssf/mysqloracletest/task/MetaActualUserInfoTask.java index 805c058..bf17e4a 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/MetaActualUserInfoTask.java +++ b/src/main/java/com/ssf/mysqloracletest/task/MetaActualUserInfoTask.java @@ -1,7 +1,6 @@ package com.ssf.mysqloracletest.task; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ssf.mysqloracletest.domain.MetaActualUserInfo; import com.ssf.mysqloracletest.domain.MetaRealEstateInfo; @@ -21,9 +20,7 @@ import org.springframework.beans.BeanUtils; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; -import java.util.HashMap; import java.util.List; -import java.util.Map; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; @@ -93,10 +90,10 @@ public class MetaActualUserInfoTask { VillageActualUserInfo userInfoPara = new VillageActualUserInfo(); userInfoPara.setIdcard(StringKit.toString(beanCp.getSFZH())); - List actualUserInfos = actualUserInfoService.selectVillageActualUserInfoList(userInfoPara); + List actualUserInfos = actualUserInfoService.selectVillageActualUserInfoListLimit1(userInfoPara); String userPic = ""; - if(actualUserInfos!=null && actualUserInfos.size()>0){ + if (actualUserInfos != null && actualUserInfos.size() > 0) { userPic = StringKit.toString(actualUserInfos.get(0).getUserPic()); } @@ -117,12 +114,12 @@ public class MetaActualUserInfoTask { actualUserInfo.setPoliceDistrictName(StringKit.toString(beanCp.getJWQMC())); actualUserInfo.setManagementStatus(StringKit.toString(beanCp.getSTS())); - // 构造查询条件 - QueryWrapper queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("real_estate_address", StringKit.toString(beanCp.getXJZDXZ())); - MetaRealEstateInfo estateInfo = estateInfoService.getOne(queryWrapper); + MetaRealEstateInfo metaRealEstateInfoPara = new MetaRealEstateInfo(); + metaRealEstateInfoPara.setRealEstateAddress(StringKit.toString(beanCp.getXJZDXZ())); + MetaRealEstateInfo estateInfo = estateInfoService.getListByAddress(metaRealEstateInfoPara); - if(estateInfo !=null){ + + if (estateInfo != null) { actualUserInfo.setHomeId(StringKit.toString(estateInfo.getId())); } actualUserInfo.setHomeCode(StringKit.toString(beanCp.getFJDM())); @@ -143,4 +140,30 @@ public class MetaActualUserInfoTask { } + + + /** + * 清洗实有人口 + */ + @Scheduled(initialDelay = 100, fixedDelay = 3000) + public void transMetaActualUserInfoByHomeId() { + + if (!"true".equals(ConfigParam.metaActualUserInfoSwitch)) { + return; + } + try { + + List actualUserInfos = metaActualUserInfoService.selectMetaActualUserInfoListByHomeId(new MetaActualUserInfo()); + for (MetaActualUserInfo bean:actualUserInfos){ + //根据 有房屋记录的数据 + + + } + } catch (Exception e) { + logger.info(StringKit.getTrace(e)); + } + } + + + } diff --git a/src/main/java/com/ssf/mysqloracletest/task/UnitInfoTask.java b/src/main/java/com/ssf/mysqloracletest/task/UnitInfoTask.java index 9b1ea70..6834440 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/UnitInfoTask.java +++ b/src/main/java/com/ssf/mysqloracletest/task/UnitInfoTask.java @@ -1,24 +1,22 @@ package com.ssf.mysqloracletest.task; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ssf.mysqloracletest.domain.MetaActualUnitInfo; import com.ssf.mysqloracletest.domain.VSySydwmMysql; import com.ssf.mysqloracletest.service.MetaActualUnitInfoService; import com.ssf.mysqloracletest.service.VSySydwMysqlService; import com.ssf.mysqloracletest.utils.ConfigParam; -import com.ssf.mysqloracletest.utils.NumKit; import com.ssf.mysqloracletest.utils.StringKit; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.springframework.beans.BeanUtils; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import javax.annotation.Resource; import java.math.BigDecimal; -import java.util.HashMap; import java.util.List; -import java.util.Map; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; @@ -37,10 +35,6 @@ public class UnitInfoTask { @Resource private MetaActualUnitInfoService metaActualUnitInfoService; - final int oncesCounts = NumKit.checkInt(ConfigParam.oncesCounts) == 0 ? 10000 : NumKit.checkInt(ConfigParam.oncesCounts); - - private boolean NsydwTag = false; - /** * 连云港 对接海康平台获取人员基础数据 * // @@ -48,104 +42,89 @@ public class UnitInfoTask { @Scheduled(initialDelay = 100, fixedDelay = 3000) public void transNsydw() { - if (NsydwTag) { - return; - } - if (!"true".equals(ConfigParam.NewNsydwSwitch)) { return; } - try { - int countNsydw = vSySydwMysqlService.count(); - logger.info("countNsydw:" + countNsydw); - - if (countNsydw > 0) { - - NsydwTag = true; - - int count = countNsydw / oncesCounts; - CountDownLatch latch = new CountDownLatch(count); - ExecutorService NsydwPool = Executors.newFixedThreadPool(50); - - for (int i = 0; i <= count; i++) { - Map NsydwMap = new HashMap(); - NsydwMap.put("rowStart", i * oncesCounts); - NsydwMap.put("rowEnd", (i + 1) * oncesCounts); - NsydwPool.submit(() -> { - try { - List Nsydws = vSySydwMysqlService.lambdaQuery().list(); - for (VSySydwmMysql Nsydw : Nsydws) { - MetaActualUnitInfo unitInfo = new MetaActualUnitInfo(); - int unit = Integer.parseInt(Nsydw.getDWZT()); - BigDecimal XDecimal = new BigDecimal(Nsydw.getX()); - BigDecimal YDecimal = new BigDecimal(Nsydw.getY()); - //设置目标字段的值 - //ID（id）----->unit_id(单位ID) - unitInfo.setUnitId(Nsydw.getID()); - //DWMC（单位名称）----->unit_name(单位名称) - unitInfo.setUintName(Nsydw.getDWMC()); - //DZ（地址）----->unit_address(单位地址) - unitInfo.setUintAddress(Nsydw.getDZ()); - //LXDH（联系电话）----->phone(联系电话) - unitInfo.setPhone(Nsydw.getLXDH()); - //PCSBM（派出所编码）----->police_station_code(派出所代码) - unitInfo.setPoliceStationCode(Nsydw.getPCSBM()); - //PCSMC（派出所名称）----->police_station_name(派出所名称) - unitInfo.setPoliceStationName(Nsydw.getPCSMC()); - //JWQBM（警务区编码）----->police_district_code(警务区编码) - unitInfo.setPoliceDistrictCode(Nsydw.getJWQBM()); - //JWQMC（警务区名称）----->police_district_code(警务区名称) - unitInfo.setPoliceDistrictCode(Nsydw.getDWMC()); - //DWZT（单位状态 1有效）----->unit_state(单位状态 1有效) - unitInfo.setUnitState(unit); - //X（经度）----->longitude(经度) - unitInfo.setLongitude(XDecimal); - //Y（纬度）----->latitude(纬度) - unitInfo.setLatitude(YDecimal); - //DWLXMC（单位类型名称）----->unit_type_name(单位类型名称) - unitInfo.setUnitTypeName(Nsydw.getDWLXMC()); - //FRZJHM（法人证件号码）----->legal_person_id_card - unitInfo.setLegalPersonIdCard(Nsydw.getFRZJHM()); - //FRXM（法人姓名）----->legal_person(企业法定代表人) - unitInfo.setLegalPerson(Nsydw.getFRXM()); - //YSBZK_RKSJ（入库时间）----->meta_create_time(元数据创建时间) - unitInfo.setMetaCreateTime(Nsydw.getYSBZK_RKSJ()); - //YSBZK_GXSJ（更新时间）----->meta_update_time(元数据更新时间) - unitInfo.setMetaUpdateTime(Nsydw.getYSBZK_GXSJ()); - //确定一个数据是否唯一 - MetaActualUnitInfo one = metaActualUnitInfoService.lambdaQuery().eq(MetaActualUnitInfo::getUnitId,Nsydw.getID()).one(); - if (one == null) { - metaActualUnitInfoService.save(unitInfo); - logger.info("Nsydw-" + Nsydw.getID() + ":插入成功"); - } else { - metaActualUnitInfoService.update(unitInfo,new UpdateWrapper<>(unitInfo)); - logger.info("Nsydw-" + Nsydw.getID() + ":更新成功"); - } - } - } catch (Exception e) { - logger.info("Nsydws:" + StringKit.getTrace(e)); - } - latch.countDown(); - }); - logger.info("NsydwMap数据总量:" + countNsydw + "," + "当前处理下标:" + NsydwMap.get("rowStart") + "/" + NsydwMap.get("rowEnd")); - } - - try { - // Wait for all threads to complete - latch.await(); - } catch (InterruptedException e) { - e.printStackTrace(); - } - // 关闭线程池 - NsydwPool.shutdown(); + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.isNull("STATUS"); + Page page = new Page<>(1, 1000); + List resultList = vSySydwMysqlService.page(page, queryWrapper).getRecords(); + + CountDownLatch latch = new CountDownLatch(resultList.size()); + ExecutorService NsydwPool = Executors.newFixedThreadPool(5); + for (VSySydwmMysql bean : resultList) { + NsydwPool.submit(() -> { + cleanSydw(bean); + logger.info("清洗完成"); + latch.countDown(); + }); } + try { + // Wait for all threads to complete + latch.await(); + } catch (InterruptedException e) { + e.printStackTrace(); + } + // 关闭线程池 + NsydwPool.shutdown(); } catch (Exception e) { logger.info(StringKit.getTrace(e)); } } + private void cleanSydw(VSySydwmMysql bean) { + VSySydwmMysql sydwMysqlCp = new VSySydwmMysql(); + try { + BeanUtils.copyProperties(bean, sydwMysqlCp); + MetaActualUnitInfo unitInfo = new MetaActualUnitInfo(); + //ID（id）----->unit_id(单位ID) + unitInfo.setUnitId(sydwMysqlCp.getID()); + //DWMC（单位名称）----->unit_name(单位名称) + unitInfo.setUintName(sydwMysqlCp.getDWMC()); + //DZ（地址）----->unit_address(单位地址) + unitInfo.setUintAddress(sydwMysqlCp.getDZ()); + //LXDH（联系电话）----->phone(联系电话) + unitInfo.setPhone(sydwMysqlCp.getLXDH()); + //PCSBM（派出所编码）----->police_station_code(派出所代码) + unitInfo.setPoliceStationCode(sydwMysqlCp.getPCSBM()); + //PCSMC（派出所名称）----->police_station_name(派出所名称) + unitInfo.setPoliceStationName(sydwMysqlCp.getPCSMC()); + //JWQBM（警务区编码）----->police_district_code(警务区编码) + unitInfo.setPoliceDistrictCode(sydwMysqlCp.getJWQBM()); + //JWQMC（警务区名称）----->police_district_name(警务区名称) + unitInfo.setPoliceDistrictName(sydwMysqlCp.getJWQMC()); + //DWZT（单位状态 1有效）----->unit_state(单位状态 1有效) + unitInfo.setUnitState(Integer.parseInt(sydwMysqlCp.getDWZT())); + //X（经度）----->longitude(经度) + unitInfo.setLongitude(new BigDecimal(sydwMysqlCp.getX())); + //Y（纬度）----->latitude(纬度) + unitInfo.setLatitude(new BigDecimal(sydwMysqlCp.getY())); + //DWLXMC（单位类型名称）----->unit_type_name(单位类型名称) + unitInfo.setUnitTypeName(sydwMysqlCp.getDWLXMC()); + //FRZJHM（法人证件号码）----->legal_person_id_card + unitInfo.setLegalPersonIdCard(sydwMysqlCp.getFRZJHM()); + //FRXM（法人姓名）----->legal_person(企业法定代表人) + unitInfo.setLegalPerson(sydwMysqlCp.getFRXM()); + //YSBZK_RKSJ（入库时间）----->meta_create_time(元数据创建时间) + unitInfo.setMetaCreateTime(sydwMysqlCp.getYSBZK_RKSJ()); + //YSBZK_GXSJ（更新时间）----->meta_update_time(元数据更新时间) + unitInfo.setMetaUpdateTime(sydwMysqlCp.getYSBZK_GXSJ()); + boolean b = metaActualUnitInfoService.save(unitInfo); + + if (b) { + sydwMysqlCp.setSTATUS("1"); + vSySydwMysqlService.updateVSySydwById(sydwMysqlCp); + logger.info("状态修改为：1"); + } + } catch (Exception e) { + logger.info(StringKit.getTrace(e)); + sydwMysqlCp.setSTATUS("2"); + vSySydwMysqlService.updateVSySydwById(sydwMysqlCp); + logger.info("状态修改为：2"); + } + } } diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index fb86b6a..4994c83 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -1 +1 @@ -server: port: 1204 spring: datasource: dynamic: primary: mysql #设置默认的数据源或者数据源组,默认值即为master strict: false #设置严格模式,默认false不启动. 启动后再为匹配到指定数据源时候回抛出异常,不启动会使用默认数据源. datasource: oracleSydz: url: jdbc:mysql://121.41.91.94:12036/yhzafk?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT driver-class-name: com.mysql.cj.jdbc.Driver username: root password: '!QAZ1qaz' mysql: url: jdbc:mysql://121.41.91.94:12036/yhzafk?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT driver-class-name: com.mysql.cj.jdbc.Driver username: root password: '!QAZ1qaz' mysqlSy: url: jdbc:mysql://121.41.91.94:12036/watu3?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT driver-class-name: com.mysql.cj.jdbc.Driver username: root password: '!QAZ1qaz' mybatis-plus: mapper-locations: - classpath:mapper/*.xml \ No newline at end of file +server: port: 1204 spring: datasource: dynamic: primary: mysql #设置默认的数据源或者数据源组,默认值即为master strict: false #设置严格模式,默认false不启动. 启动后再为匹配到指定数据源时候回抛出异常,不启动会使用默认数据源. datasource: oracleSydz: url: jdbc:mysql://121.41.91.94:12036/yhzafk?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT&connectTimeout=150000 driver-class-name: com.mysql.cj.jdbc.Driver username: root password: '!QAZ1qaz' mysql: url: jdbc:mysql://121.41.91.94:12036/yhzafk?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT&connectTimeout=150000 driver-class-name: com.mysql.cj.jdbc.Driver username: root password: '!QAZ1qaz' mybatis-plus: configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl mapper-locations: - classpath:mapper/*.xml mybatis: configuration: map-underscore-to-camel-case: true mapper-locations: mybatis/**/*Mapper.xml typeAliasesPackage: com.ssf.mysqloracletest.**.domain logging: level: root: info com.ssf.mysqloracletest: debug \ No newline at end of file diff --git a/src/main/resources/mapper/MetaActualUserInfoMapper.xml b/src/main/resources/mapper/MetaActualUserInfoMapper.xml new file mode 100644 index 0000000..3481a5e --- /dev/null +++ b/src/main/resources/mapper/MetaActualUserInfoMapper.xml @@ -0,0 +1,159 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + select id, user_pic, user_name, id_card, sex, phone, landline, house_hold_register, house_hold_address, habitation_address, police_station_code, police_station_name, police_district_code, police_district_name, management_status, home_id, home_code, account_number, meta_create_time, meta_update_time, actual_user_type from meta_actual_user_info + + + + + + + + insert into meta_actual_user_info + + user_pic, + user_name, + id_card, + sex, + phone, + landline, + house_hold_register, + house_hold_address, + habitation_address, + police_station_code, + police_station_name, + police_district_code, + police_district_name, + management_status, + home_id, + home_code, + account_number, + meta_create_time, + meta_update_time, + actual_user_type, + + + #{userPic}, + #{userName}, + #{idCard}, + #{sex}, + #{phone}, + #{landline}, + #{houseHoldRegister}, + #{houseHoldAddress}, + #{habitationAddress}, + #{policeStationCode}, + #{policeStationName}, + #{policeDistrictCode}, + #{policeDistrictName}, + #{managementStatus}, + #{homeId}, + #{homeCode}, + #{accountNumber}, + #{metaCreateTime}, + #{metaUpdateTime}, + #{actualUserType}, + + + + + update meta_actual_user_info + + user_pic = #{userPic}, + user_name = #{userName}, + id_card = #{idCard}, + sex = #{sex}, + phone = #{phone}, + landline = #{landline}, + house_hold_register = #{houseHoldRegister}, + house_hold_address = #{houseHoldAddress}, + habitation_address = #{habitationAddress}, + police_station_code = #{policeStationCode}, + police_station_name = #{policeStationName}, + police_district_code = #{policeDistrictCode}, + police_district_name = #{policeDistrictName}, + management_status = #{managementStatus}, + home_id = #{homeId}, + home_code = #{homeCode}, + account_number = #{accountNumber}, + meta_create_time = #{metaCreateTime}, + meta_update_time = #{metaUpdateTime}, + actual_user_type = #{actualUserType}, + + where id = #{id} + + + + delete from meta_actual_user_info where id = #{id} + + + + delete from meta_actual_user_info where id in + + #{id} + + + + + + + + \ No newline at end of file diff --git a/src/main/resources/mapper/MetaRealEstateInfoMapper.xml b/src/main/resources/mapper/MetaRealEstateInfoMapper.xml new file mode 100644 index 0000000..5551659 --- /dev/null +++ b/src/main/resources/mapper/MetaRealEstateInfoMapper.xml @@ -0,0 +1,95 @@ + + + + + + + + + + + + + + + + select id, home_id, police_station_code, police_district_code, real_estate_address, longitude, latitude from meta_real_estate_info + + + + + + + + + + + insert into meta_real_estate_info + + home_id, + police_station_code, + police_district_code, + real_estate_address, + longitude, + latitude, + + + #{homeId}, + #{policeStationCode}, + #{policeDistrictCode}, + #{realEstateAddress}, + #{longitude}, + #{latitude}, + + + + + update meta_real_estate_info + + home_id = #{homeId}, + police_station_code = #{policeStationCode}, + police_district_code = #{policeDistrictCode}, + real_estate_address = #{realEstateAddress}, + longitude = #{longitude}, + latitude = #{latitude}, + + where id = #{id} + + + + delete from meta_real_estate_info where id = #{id} + + + + delete from meta_real_estate_info where id in + + #{id} + + + \ No newline at end of file diff --git a/src/main/resources/mapper/VSySyrkMysqlMapper.xml b/src/main/resources/mapper/VSySyrkMysqlMapper.xml index 8a78b58..a0f926e 100644 --- a/src/main/resources/mapper/VSySyrkMysqlMapper.xml +++ b/src/main/resources/mapper/VSySyrkMysqlMapper.xml @@ -95,6 +95,10 @@ CDC_JYM, YSBZK_RKSJ, YSBZK_GXSJ, + HJDXZ, + XJZDXZ, + RYLX, + HJSSXQ, status, @@ -135,6 +139,10 @@ #{CDC_JYM}, #{YSBZK_RKSJ}, #{YSBZK_GXSJ}, + #{HJDXZ}, + #{XJZDXZ}, + #{RYLX}, + #{HJSSXQ}, #{status}, @@ -179,6 +187,10 @@ CDC_JYM=#{CDC_JYM}, YSBZK_RKSJ=#{YSBZK_RKSJ}, YSBZK_GXSJ=#{YSBZK_GXSJ}, + HJDXZ=#{HJDXZ}, + XJZDXZ=#{XJZDXZ}, + RYLX=#{RYLX}, + HJSSXQ=#{HJSSXQ}, status=#{status}, where ID = #{ID} diff --git a/src/main/resources/mapper/VillageActualUserInfoMapper.xml b/src/main/resources/mapper/VillageActualUserInfoMapper.xml index 7f27828..5503e40 100644 --- a/src/main/resources/mapper/VillageActualUserInfoMapper.xml +++ b/src/main/resources/mapper/VillageActualUserInfoMapper.xml @@ -141,6 +141,59 @@ + +