hanrenchun
1 year ago
parent
1365a98cd6
commit
7a9f6d19a5
@ -0,0 +1,151 @@
|
|||||||
|
package com.ssf.mysqloracletest.domain;
|
||||||
|
|
||||||
|
import com.baomidou.mybatisplus.annotation.IdType;
|
||||||
|
import com.baomidou.mybatisplus.annotation.TableField;
|
||||||
|
import com.baomidou.mybatisplus.annotation.TableId;
|
||||||
|
import com.baomidou.mybatisplus.annotation.TableName;
|
||||||
|
import java.io.Serializable;
|
||||||
|
import java.util.Date;
|
||||||
|
import lombok.Data;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 实有人口信息表
|
||||||
|
* @TableName meta_actual_user_info
|
||||||
|
*/
|
||||||
|
@TableName(value ="meta_actual_user_info")
|
||||||
|
@Data
|
||||||
|
public class MetaActualUserInfo implements Serializable {
|
||||||
|
/**
|
||||||
|
* 主键
|
||||||
|
*/
|
||||||
|
@TableId(type = IdType.AUTO)
|
||||||
|
private Long id;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 照片
|
||||||
|
*/
|
||||||
|
private String userPic;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 姓名
|
||||||
|
*/
|
||||||
|
private String userName;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 身份证号码
|
||||||
|
*/
|
||||||
|
private String idCard;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 性别
|
||||||
|
*/
|
||||||
|
private Integer sex;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 移动号码
|
||||||
|
*/
|
||||||
|
private String phone;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 联系电话
|
||||||
|
*/
|
||||||
|
private String landline;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 实有人口类型
|
||||||
|
*/
|
||||||
|
private Integer actualUserType;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 户籍所属辖区
|
||||||
|
*/
|
||||||
|
private String houseHoldRegister;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 户籍地址详情
|
||||||
|
*/
|
||||||
|
private String houseHoldAddress;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 现住地详址
|
||||||
|
*/
|
||||||
|
private String habitationAddress;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 派出所代码
|
||||||
|
*/
|
||||||
|
private String policeStationCode;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 派出所名称
|
||||||
|
*/
|
||||||
|
private String policeStationName;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 警务区编码
|
||||||
|
*/
|
||||||
|
private String policeDistrictCode;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 警务区名称
|
||||||
|
*/
|
||||||
|
private String policeDistrictName;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 管理状态
|
||||||
|
*/
|
||||||
|
private String managementStatus;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 房屋ID
|
||||||
|
*/
|
||||||
|
private String homeId;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 房屋代码
|
||||||
|
*/
|
||||||
|
private String homeCode;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 户号
|
||||||
|
*/
|
||||||
|
private String accountNumber;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 元数据创建时间
|
||||||
|
*/
|
||||||
|
private String metaCreateTime;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 元数据更新时间
|
||||||
|
*/
|
||||||
|
private String metaUpdateTime;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建时间
|
||||||
|
*/
|
||||||
|
private Date createTime;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建者
|
||||||
|
*/
|
||||||
|
private Integer createBy;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 更新时间
|
||||||
|
*/
|
||||||
|
private Date updateTime;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 更新者
|
||||||
|
*/
|
||||||
|
private Integer updateBy;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 0:不活跃,1:活跃
|
||||||
|
*/
|
||||||
|
private Integer isActive;
|
||||||
|
|
||||||
|
@TableField(exist = false)
|
||||||
|
private static final long serialVersionUID = 1L;
|
||||||
|
}
|
||||||
@ -0,0 +1,18 @@
|
|||||||
|
package com.ssf.mysqloracletest.mapper;
|
||||||
|
|
||||||
|
import com.ssf.mysqloracletest.domain.MetaActualUserInfo;
|
||||||
|
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @author 28758
|
||||||
|
* @description 针对表【meta_actual_user_info(实有人口信息表)】的数据库操作Mapper
|
||||||
|
* @createDate 2023-12-02 17:31:50
|
||||||
|
* @Entity com.ssf.mysqloracletest.domain.MetaActualUserInfo
|
||||||
|
*/
|
||||||
|
public interface MetaActualUserInfoMapper extends BaseMapper<MetaActualUserInfo> {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@ -0,0 +1,13 @@
|
|||||||
|
package com.ssf.mysqloracletest.service;
|
||||||
|
|
||||||
|
import com.ssf.mysqloracletest.domain.MetaActualUserInfo;
|
||||||
|
import com.baomidou.mybatisplus.extension.service.IService;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @author 28758
|
||||||
|
* @description 针对表【meta_actual_user_info(实有人口信息表)】的数据库操作Service
|
||||||
|
* @createDate 2023-12-02 17:31:50
|
||||||
|
*/
|
||||||
|
public interface MetaActualUserInfoService extends IService<MetaActualUserInfo> {
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,22 @@
|
|||||||
|
package com.ssf.mysqloracletest.service.impl;
|
||||||
|
|
||||||
|
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 org.springframework.stereotype.Service;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @author 28758
|
||||||
|
* @description 针对表【meta_actual_user_info(实有人口信息表)】的数据库操作Service实现
|
||||||
|
* @createDate 2023-12-02 17:31:50
|
||||||
|
*/
|
||||||
|
@Service
|
||||||
|
public class MetaActualUserInfoServiceImpl extends ServiceImpl<MetaActualUserInfoMapper, MetaActualUserInfo>
|
||||||
|
implements MetaActualUserInfoService{
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@ -0,0 +1,137 @@
|
|||||||
|
package com.ssf.mysqloracletest.task;
|
||||||
|
|
||||||
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
||||||
|
import com.ssf.mysqloracletest.domain.MetaActualUserInfo;
|
||||||
|
import com.ssf.mysqloracletest.domain.VSySyrkMysql;
|
||||||
|
import com.ssf.mysqloracletest.service.MetaActualUserInfoService;
|
||||||
|
import com.ssf.mysqloracletest.service.VSySyrkMysqlService;
|
||||||
|
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.scheduling.annotation.Scheduled;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
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;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 用户数据接入
|
||||||
|
*/
|
||||||
|
@Component
|
||||||
|
public class MetaActualUserInfoTask {
|
||||||
|
|
||||||
|
private static final Logger logger = LoggerFactory.getLogger(MetaActualUserInfoTask.class);
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private VSySyrkMysqlService vSySyrkMysqlService;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private MetaActualUserInfoService metaActualUserInfoService;
|
||||||
|
|
||||||
|
final int oncesCounts = NumKit.checkInt(ConfigParam.oncesCounts) == 0 ? 1000 : NumKit.checkInt(ConfigParam.oncesCounts);
|
||||||
|
|
||||||
|
private boolean syrkTag = false;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 连云港 对接海康平台获取人员基础数据
|
||||||
|
* //
|
||||||
|
*/
|
||||||
|
@Scheduled(initialDelay = 100, fixedDelay = 3000)
|
||||||
|
public void transsyrk() {
|
||||||
|
|
||||||
|
if (syrkTag) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!"true".equals(ConfigParam.metaActualUserInfoSwitch)) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
try {
|
||||||
|
int countsyrk = vSySyrkMysqlService.count();
|
||||||
|
logger.info("countsyrk:" + countsyrk);
|
||||||
|
|
||||||
|
if (countsyrk > 0) {
|
||||||
|
|
||||||
|
syrkTag = true;
|
||||||
|
|
||||||
|
int count = countsyrk / oncesCounts;
|
||||||
|
CountDownLatch latch = new CountDownLatch(count);
|
||||||
|
ExecutorService syrkPool = Executors.newFixedThreadPool(50);
|
||||||
|
|
||||||
|
for (int i = 0; i <= count; i++) {
|
||||||
|
Map syrkMap = new HashMap();
|
||||||
|
syrkMap.put("rowStart", i * oncesCounts);
|
||||||
|
syrkMap.put("rowEnd", (i + 1) * oncesCounts);
|
||||||
|
syrkPool.submit(() -> {
|
||||||
|
try {
|
||||||
|
List<VSySyrkMysql> list = vSySyrkMysqlService.lambdaQuery().list();
|
||||||
|
for (VSySyrkMysql syrk : list) {
|
||||||
|
MetaActualUserInfo metaActualUserInfo = new MetaActualUserInfo();
|
||||||
|
metaActualUserInfo.setUserName(syrk.getXM());
|
||||||
|
metaActualUserInfo.setIdCard(syrk.getSFZH());
|
||||||
|
if (syrk.getXB() != null) {
|
||||||
|
metaActualUserInfo.setSex(Integer.parseInt(syrk.getXB()));
|
||||||
|
}
|
||||||
|
metaActualUserInfo.setPhone(syrk.getSJHM());
|
||||||
|
metaActualUserInfo.setLandline(syrk.getLXDH());
|
||||||
|
if (syrk.getRYLX() != null) {
|
||||||
|
metaActualUserInfo.setActualUserType(Integer.parseInt(syrk.getRYLX()));
|
||||||
|
}
|
||||||
|
metaActualUserInfo.setHouseHoldRegister(syrk.getHJSSXQ());
|
||||||
|
metaActualUserInfo.setHouseHoldAddress(syrk.getHJDXZ());
|
||||||
|
metaActualUserInfo.setHabitationAddress(syrk.getXJZDXZ());
|
||||||
|
metaActualUserInfo.setPoliceStationCode(syrk.getPCSDM());
|
||||||
|
metaActualUserInfo.setPoliceStationName(syrk.getPCSMC());
|
||||||
|
metaActualUserInfo.setPoliceDistrictCode(syrk.getJWQDM());
|
||||||
|
metaActualUserInfo.setPoliceDistrictName(syrk.getJWQMC());
|
||||||
|
metaActualUserInfo.setManagementStatus(syrk.getSTS());
|
||||||
|
metaActualUserInfo.setHomeId(syrk.getFJID());
|
||||||
|
metaActualUserInfo.setHomeCode(syrk.getFJDM());
|
||||||
|
// metaActualUserInfo.setAccountNumber();
|
||||||
|
metaActualUserInfo.setMetaCreateTime(syrk.getYSBZK_RKSJ());
|
||||||
|
metaActualUserInfo.setMetaUpdateTime(syrk.getYSBZK_GXSJ());
|
||||||
|
MetaActualUserInfo one = metaActualUserInfoService.lambdaQuery().eq(MetaActualUserInfo::getIdCard, syrk.getSFZH()).one();
|
||||||
|
if (one == null) {
|
||||||
|
metaActualUserInfoService.save(metaActualUserInfo);
|
||||||
|
logger.info("syrk-" + syrk.getSFZH() + ":插入成功");
|
||||||
|
} else {
|
||||||
|
UpdateWrapper<MetaActualUserInfo> metaActualUserInfoUpdateWrapper = new UpdateWrapper<>();
|
||||||
|
metaActualUserInfoUpdateWrapper.eq("id_card",syrk.getSFZH());
|
||||||
|
metaActualUserInfoService.update(metaActualUserInfo, metaActualUserInfoUpdateWrapper);
|
||||||
|
logger.info("syrk-" + syrk.getSFZH() + ":更新成功");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.info("syrks:" + e.getMessage());
|
||||||
|
}
|
||||||
|
latch.countDown();
|
||||||
|
});
|
||||||
|
logger.info("syrkMap数据总量:" + countsyrk + "," + "当前处理下标:" + syrkMap.get("rowStart") + "/" + syrkMap.get("rowEnd"));
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Wait for all threads to complete
|
||||||
|
latch.await();
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
// 关闭线程池
|
||||||
|
syrkPool.shutdown();
|
||||||
|
}
|
||||||
|
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.info(StringKit.getTrace(e));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
Loading…
Reference in new issue