diff --git a/config/application.properties b/config/application.properties index 95922a7..8191809 100644 --- a/config/application.properties +++ b/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 diff --git a/src/main/java/com/ssf/mysqloracletest/domain/MetaImpUserInfo.java b/src/main/java/com/ssf/mysqloracletest/domain/MetaImpUserInfo.java new file mode 100644 index 0000000..3213d2c --- /dev/null +++ b/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; +} \ No newline at end of file diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/MetaImpUserInfoMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/MetaImpUserInfoMapper.java new file mode 100644 index 0000000..93421a3 --- /dev/null +++ b/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 { + +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/service/MetaImpUserInfoService.java b/src/main/java/com/ssf/mysqloracletest/service/MetaImpUserInfoService.java new file mode 100644 index 0000000..757d8b1 --- /dev/null +++ b/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 { + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/MetaImpUserInfoServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/MetaImpUserInfoServiceImpl.java new file mode 100644 index 0000000..c3c2c29 --- /dev/null +++ b/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 + implements MetaImpUserInfoService{ + +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/task/metaImpUserInfoTask.java b/src/main/java/com/ssf/mysqloracletest/task/metaImpUserInfoTask.java index ca3fe8d..945f1a0 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/metaImpUserInfoTask.java +++ b/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() + ":更新成功"); } } diff --git a/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java b/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java index 7b66844..9930f7e 100644 --- a/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java +++ b/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")); }