重点人员清洗

config/application.properties

@@ -8,9 +8,13 @@ syrkSwitch=false
 jksbSwitch=false
 
 
-cjxxSwitch=true
+cjxxSwitch=false
 zdrySwitch=false
 cyrySwitch=false
+JjxxSwitch=false
+
+NewNsydwSwitch=false
+metaImpUserSwitch=true
 
 
 

src/main/java/com/ssf/mysqloracletest/domain/MetaImpUserInfo.java

@@ -0,0 +1,116 @@
+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_imp_user_info
+ */
+@TableName(value ="meta_imp_user_info")
+@Data
+public class MetaImpUserInfo 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 impUserType;
+
+    /**
+     * 重点人小类
+     */
+    private String impUserSubType;
+
+    /**
+     * 户籍地区号
+     */
+    private String houseHoldRegister;
+
+    /**
+     * 户籍地详址
+     */
+    private String houseHoldAddress;
+
+    /**
+     * 现住地区号
+     */
+    private String habitationRegister;
+
+    /**
+     * 现住地详址
+     */
+    private String habitationAddress;
+
+    /**
+     * 登记人单位代码
+     */
+    private String registerUnitCode;
+
+    /**
+     * 登记人单位名称
+     */
+    private String registerUnitName;
+
+    /**
+     * 创建时间
+     */
+    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;
+}

src/main/java/com/ssf/mysqloracletest/mapper/MetaImpUserInfoMapper.java

@@ -0,0 +1,18 @@
+package com.ssf.mysqloracletest.mapper;
+
+import com.ssf.mysqloracletest.domain.MetaImpUserInfo;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author 28758
+* @description 针对表【meta_imp_user_info(重点人员信息表)】的数据库操作Mapper
+* @createDate 2023-12-01 16:43:42
+* @Entity com.ssf.mysqloracletest.domain.MetaImpUserInfo
+*/
+public interface MetaImpUserInfoMapper extends BaseMapper<MetaImpUserInfo> {
+
+}
+
+
+
+

src/main/java/com/ssf/mysqloracletest/service/MetaImpUserInfoService.java

@@ -0,0 +1,13 @@
+package com.ssf.mysqloracletest.service;
+
+import com.ssf.mysqloracletest.domain.MetaImpUserInfo;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author 28758
+* @description 针对表【meta_imp_user_info(重点人员信息表)】的数据库操作Service
+* @createDate 2023-12-01 16:43:42
+*/
+public interface MetaImpUserInfoService extends IService<MetaImpUserInfo> {
+
+}

src/main/java/com/ssf/mysqloracletest/service/impl/MetaImpUserInfoServiceImpl.java

@@ -0,0 +1,22 @@
+package com.ssf.mysqloracletest.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ssf.mysqloracletest.domain.MetaImpUserInfo;
+import com.ssf.mysqloracletest.service.MetaImpUserInfoService;
+import com.ssf.mysqloracletest.mapper.MetaImpUserInfoMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author 28758
+* @description 针对表【meta_imp_user_info(重点人员信息表)】的数据库操作Service实现
+* @createDate 2023-12-01 16:43:42
+*/
+@Service
+public class MetaImpUserInfoServiceImpl extends ServiceImpl<MetaImpUserInfoMapper, MetaImpUserInfo>
+    implements MetaImpUserInfoService{
+
+}
+
+
+
+

src/main/java/com/ssf/mysqloracletest/task/metaImpUserInfoTask.java

@@ -1,18 +1,15 @@
 package com.ssf.mysqloracletest.task;
 
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.ssf.mysqloracletest.domain.MetaImpUserInfo;
 import com.ssf.mysqloracletest.domain.ZhxfZdrygkRyjbxxViewMysql;
-import com.ssf.mysqloracletest.domain.ZhxfZdrygkRyjbxxViewOracle;
 import com.ssf.mysqloracletest.service.MetaImpUserInfoService;
 import com.ssf.mysqloracletest.service.ZhxfZdrygkRyjbxxViewMysqlService;
-import com.ssf.mysqloracletest.service.ZhxfZdrygkRyjbxxViewOracleService;
 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;
 
@@ -97,7 +94,7 @@ public class metaImpUserInfoTask {
                                     metaImpUserInfoService.save(metaImpUserInfo);
                                     logger.info("zdry-" + zdry.getZJHM() + ":插入成功");
                                 } else {
-                                    metaImpUserInfoService.update(new QueryWrapper<>(metaImpUserInfo));
+                                    metaImpUserInfoService.update(metaImpUserInfo,new UpdateWrapper<>(metaImpUserInfo));
                                     logger.info("zdry-" + zdry.getZJHM() + ":更新成功");
                                 }
                             }

src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java

@@ -26,4 +26,7 @@ public class ConfigParam {
 
     public static String metaImpUserSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("metaImpUserSwitch"));
 
+    //将数据洗进 --->业务表的开关----------------------------------------------------------------------------------------------------------
+    public static String NewNsydwSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("NewNsydwSwitch"));
+    public static String NewNalarminfoSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("NewNalarminfoSwitch"));
 }