实有人员清洗到业务表

develop
fengchunyu 10 months ago
parent 2b346567ed
commit 854d5da804

@ -18,11 +18,11 @@ metaImpUserSwitch=false
NewNalarminfoSwitch=false NewNalarminfoSwitch=false
metaHandleAlarmSwitch=false metaHandleAlarmSwitch=false
metaActualUnitUserInfoSwitch=false metaActualUnitUserInfoSwitch=false
metaActualUserInfoSwitch=false metaActualUserInfoSwitch=true
actualTimecjxxSwitch=false actualTimecjxxSwitch=false
actualTimejjxxSwitch=false actualTimejjxxSwitch=false
RentalHouseSwitch=false RentalHouseSwitch=false
metaRealEstateInfoSwitch=true metaRealEstateInfoSwitch=false

@ -1,60 +1,104 @@
package com.ssf.mysqloracletest.domain; package com.ssf.mysqloracletest.domain;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data; import lombok.Data;
import java.io.Serializable; import java.io.Serializable;
/** /**
*
* @TableName v_sy_syrk * @TableName v_sy_syrk
*/ */
@Data @Data
@TableName(value = "v_sy_syrk")
public class VSySyrkMysql implements Serializable { public class VSySyrkMysql implements Serializable {
/** /**
* *
*/ */
@TableField(value = "ZJLID")
private String ZJLID; private String ZJLID;
@TableField(value = "YSXTJRZJ")
private String YSXTJRZJ; private String YSXTJRZJ;
@TableField(value = "XXSC_PDBZ")
private String XXSC_PDBZ; private String XXSC_PDBZ;
@TableField(value = "ID")
private String ID; private String ID;
@TableField(value = "RYFJID")
private String RYFJID; private String RYFJID;
@TableField(value = "RYID")
private String RYID; private String RYID;
@TableField(value = "SFZH")
private String SFZH; private String SFZH;
@TableField(value = "XM")
private String XM; private String XM;
@TableField(value = "XB")
private String XB; private String XB;
@TableField(value = "MZ")
private String MZ; private String MZ;
@TableField(value = "HYZK")
private String HYZK; private String HYZK;
@TableField(value = "WHCD")
private String WHCD; private String WHCD;
@TableField(value = "CSRQ")
private String CSRQ; private String CSRQ;
@TableField(value = "SJHM")
private String SJHM; private String SJHM;
@TableField(value = "LXDH")
private String LXDH; private String LXDH;
@TableField(value = "HJSSXQ")
private String HJSSXQ; private String HJSSXQ;
@TableField(value = "HJDXZ")
private String HJDXZ; private String HJDXZ;
@TableField(value = "XJZDXZ")
private String XJZDXZ; private String XJZDXZ;
@TableField(value = "RYLX")
private String RYLX; private String RYLX;
@TableField(value = "PCSDM")
private String PCSDM; private String PCSDM;
@TableField(value = "PCSMC")
private String PCSMC; private String PCSMC;
@TableField(value = "CJWHDM")
private String CJWHDM; private String CJWHDM;
@TableField(value = "CJWHMC")
private String CJWHMC; private String CJWHMC;
@TableField(value = "JWQDM")
private String JWQDM; private String JWQDM;
@TableField(value = "JWQMC")
private String JWQMC; private String JWQMC;
@TableField(value = "WGDM")
private String WGDM; private String WGDM;
@TableField(value = "WGMC")
private String WGMC; private String WGMC;
@TableField(value = "JZWID")
private String JZWID; private String JZWID;
@TableField(value = "FJID")
private String FJID; private String FJID;
@TableField(value = "FJDM")
private String FJDM; private String FJDM;
@TableField(value = "XQID")
private String XQID; private String XQID;
@TableField(value = "STS")
private String STS; private String STS;
@TableField(value = "CR_ID")
private String CR_ID; private String CR_ID;
@TableField(value = "CR_MC")
private String CR_MC; private String CR_MC;
@TableField(value = "CR_DT")
private String CR_DT; private String CR_DT;
@TableField(value = "CH_ID")
private String CH_ID; private String CH_ID;
@TableField(value = "CH_MC")
private String CH_MC; private String CH_MC;
@TableField(value = "CH_DT")
private String CH_DT; private String CH_DT;
@TableField(value = "CDC_JYM")
private String CDC_JYM; private String CDC_JYM;
@TableField(value = "YSBZK_RKSJ")
private String YSBZK_RKSJ; private String YSBZK_RKSJ;
@TableField(value = "YSBZK_GXSJ")
private String YSBZK_GXSJ; private String YSBZK_GXSJ;
@TableField(value = "status")
private String status;
} }

@ -0,0 +1,239 @@
package com.ssf.mysqloracletest.domain;
import lombok.Data;
/**
* TODO
*
* @author dinosuar
* @version 1.0
* @String 2021/2/24 15:04
**/
@Data
public class VillageActualUserInfo {
/**
*
*/
private Long id;
/**
* -
*/
// @Excel(name = "公安部-记录唯一标识")
private String gaRecordId;
/**
* ID
*/
// @Excel(name = "建筑物ID")
private String buildingId;
/**
* ID
*/
// @Excel(name = "人员房屋ID")
private String userHomeId;
/**
* ID
*/
// @Excel(name = "源数据实有人口ID")
private String actualUserId;
/**
* ID
*/
// @Excel(name = "记录唯一ID")
private String recordId;
/**
*
*/
// @Excel(name = "网格代码")
private String gridCode;
/**
*
*/
// @Excel(name = "网格名称")
private String gridName;
/**
* ID
*/
// @Excel(name = "房屋ID")
private String homeId;
/**
*
*/
// @Excel(name = "房屋代码")
private String homeCode;
/**
*
*/
// @Excel(name = "警务区编码")
private String policeDistrictCode;
/**
*
*/
// @Excel(name = "警务区名称")
private String policeDistrict;
/**
*
*/
// @Excel(name = "派出所名称")
private String policeStationName;
/**
*
*/
// @Excel(name = "派出所代码")
private String policeStationCode;
/**
*
*/
// @Excel(name = "人员类别")
private String personCategory;
/**
*
*/
// @Excel(name = "姓名")
private String userName;
/**
*
*/
// @Excel(name = "证件号码")
private String idcard;
/**
*
*/
// @Excel(name = "手机号码")
private String phone;
/**
*
*/
// @Excel(name = "联系电话")
private String landline;
/**
*
*/
// @Excel(name = "性别")
private String sex;
/**
*
*/
// @Excel(name = "民族")
private String nation;
/**
*
*/
// @Excel(name = "婚姻状况")
private String marriage;
/**
*
*/
// @Excel(name = "学历")
private String education;
/**
*
*/
// @JsonFormat(pattern = "yyyy-MM-dd")
// @Excel(name = "出生日期", width = 30, StringFormat = "yyyy-MM-dd")
private String birthday;
/**
*
*/
// @Excel(name = "户籍")
private String houseHoldRegister;
/**
*
*/
// @Excel(name = "户籍地址")
private String houseHoldAddress;
/**
*
*/
// @Excel(name = "实际居住地")
private String habitation;
/**
* /
*/
// @Excel(name = "社区/村编码")
private String blockCode;
/**
* /
*/
// @Excel(name = "社区/村名称")
private String blockName;
/**
*
*/
// @Excel(name = "数据有效状态")
private String dateStatus;
/**
* 0:,1:
*/
// @Excel(name = "0:不活跃,1:活跃")
private String isactive;
/**
* c1
*/
// @Excel(name = "扩展字段c1")
private String c1;
private String c1New;
/**
* c2
*/
// @Excel(name = "扩展字段c2")
private String c2;
/**
* c3
*/
// @Excel(name = "扩展字段c3")
private String c3;
/**
* c4
*/
// @Excel(name = "扩展字段c4")
private String c4;
/**
* c5
*/
// @Excel(name = "扩展字段c5")
private String c5;
private String createtimeV;
private String updatetimeV;
private String picStatus;
private String userPic;
}

@ -5,7 +5,6 @@ import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
@Mapper @Mapper
public interface JcjJxxViewMysqlMapper extends BaseMapper<JcjJjxxViewMysql> { public interface JcjJxxViewMysqlMapper extends BaseMapper<JcjJjxxViewMysql> {
public JcjJjxxViewMysql selectJcjJxxByJJBH(String JJBH); public JcjJjxxViewMysql selectJcjJxxByJJBH(String JJBH);

@ -2,6 +2,7 @@ package com.ssf.mysqloracletest.mapper;
import com.ssf.mysqloracletest.domain.MetaActualUnitUserInfo; import com.ssf.mysqloracletest.domain.MetaActualUnitUserInfo;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/** /**
* @author 28758 * @author 28758
@ -9,6 +10,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
* @createDate 2023-12-02 10:31:32 * @createDate 2023-12-02 10:31:32
* @Entity com.ssf.mysqloracletest.domain.MetaActualUnitUserInfo * @Entity com.ssf.mysqloracletest.domain.MetaActualUnitUserInfo
*/ */
@Mapper
public interface MetaActualUnitUserInfoMapper extends BaseMapper<MetaActualUnitUserInfo> { public interface MetaActualUnitUserInfoMapper extends BaseMapper<MetaActualUnitUserInfo> {
} }

@ -2,6 +2,7 @@ package com.ssf.mysqloracletest.mapper;
import com.ssf.mysqloracletest.domain.MetaActualUserInfo; import com.ssf.mysqloracletest.domain.MetaActualUserInfo;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/** /**
* @author 28758 * @author 28758
@ -9,6 +10,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
* @createDate 2023-12-02 17:31:50 * @createDate 2023-12-02 17:31:50
* @Entity com.ssf.mysqloracletest.domain.MetaActualUserInfo * @Entity com.ssf.mysqloracletest.domain.MetaActualUserInfo
*/ */
@Mapper
public interface MetaActualUserInfoMapper extends BaseMapper<MetaActualUserInfo> { public interface MetaActualUserInfoMapper extends BaseMapper<MetaActualUserInfo> {
} }

@ -2,6 +2,7 @@ package com.ssf.mysqloracletest.mapper;
import com.ssf.mysqloracletest.domain.MetaAlarmInfo; import com.ssf.mysqloracletest.domain.MetaAlarmInfo;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/** /**
* @author 10503 * @author 10503
@ -9,6 +10,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
* @createDate 2023-12-01 14:48:34 * @createDate 2023-12-01 14:48:34
* @Entity com.ssf.mysqloracletest.domain.MetaAlarmInfo * @Entity com.ssf.mysqloracletest.domain.MetaAlarmInfo
*/ */
@Mapper
public interface MetaAlarmInfoMapper extends BaseMapper<MetaAlarmInfo> { public interface MetaAlarmInfoMapper extends BaseMapper<MetaAlarmInfo> {
} }

@ -2,6 +2,7 @@ package com.ssf.mysqloracletest.mapper;
import com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo; import com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/** /**
* @author 28758 * @author 28758
@ -9,6 +10,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
* @createDate 2023-12-01 19:02:18 * @createDate 2023-12-01 19:02:18
* @Entity com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo * @Entity com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo
*/ */
@Mapper
public interface MetaHandleAlarmInfoMapper extends BaseMapper<MetaHandleAlarmInfo> { public interface MetaHandleAlarmInfoMapper extends BaseMapper<MetaHandleAlarmInfo> {
} }

@ -2,6 +2,7 @@ package com.ssf.mysqloracletest.mapper;
import com.ssf.mysqloracletest.domain.MetaImpUserInfo; import com.ssf.mysqloracletest.domain.MetaImpUserInfo;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/** /**
* @author 28758 * @author 28758
@ -9,6 +10,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
* @createDate 2023-12-01 16:43:42 * @createDate 2023-12-01 16:43:42
* @Entity com.ssf.mysqloracletest.domain.MetaImpUserInfo * @Entity com.ssf.mysqloracletest.domain.MetaImpUserInfo
*/ */
@Mapper
public interface MetaImpUserInfoMapper extends BaseMapper<MetaImpUserInfo> { public interface MetaImpUserInfoMapper extends BaseMapper<MetaImpUserInfo> {
} }

@ -2,6 +2,7 @@ package com.ssf.mysqloracletest.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ssf.mysqloracletest.domain.VJwtSyfw; import com.ssf.mysqloracletest.domain.VJwtSyfw;
import org.apache.ibatis.annotations.Mapper;
import java.util.List; import java.util.List;
@ -11,6 +12,7 @@ import java.util.List;
* @author ruoyi * @author ruoyi
* @date 2023-12-04 * @date 2023-12-04
*/ */
@Mapper
public interface VJwtSyfwMapper extends BaseMapper<VJwtSyfw> { public interface VJwtSyfwMapper extends BaseMapper<VJwtSyfw> {
/** /**
* *

@ -0,0 +1,60 @@
package com.ssf.mysqloracletest.mapper;
import com.ssf.mysqloracletest.domain.VillageActualUserInfo;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
*
*
* @author chglee
* @email 1992lcg@163.com
* @date 2017-10-03 16:17:48
*/
@Mapper
public interface VillageActualUserInfoMapper {
/**
*
*/
public VillageActualUserInfo selectVillageActualUserInfoById(Long id);
public VillageActualUserInfo selectVillageActualUserInfoByIdcard(String idcard);
/**
*
*/
public List<VillageActualUserInfo> selectVillageActualUserInfoList(VillageActualUserInfo bean);
public List<VillageActualUserInfo> selectVillageActualUserInfoListAndPicExists(VillageActualUserInfo bean);
/**
*
*/
public int insertVillageActualUserInfo(VillageActualUserInfo bean);
/**
*
*/
public int updateVillageActualUserInfo(VillageActualUserInfo bean);
public int updateVillageActualUserInfoByIdcard(VillageActualUserInfo bean);
/**
*
*/
public int deleteVillageActualUserInfoById(Long id);
public int deleteVillageActualUserInfoByUpdatetime(VillageActualUserInfo bean);
/**
*
*
* @param ids
* @return
*/
public int deleteVillageActualUserInfoByIds(Long[] ids);
}

@ -0,0 +1,52 @@
package com.ssf.mysqloracletest.service;
import com.ssf.mysqloracletest.domain.VillageActualUserInfo;
import java.util.List;
/**
*
*
* @author chglee
* @email 1992lcg@163.com
* @date 2017-09-09 10:03:34
*/
public interface VillageActualUserInfoService {
/**
*
*/
public VillageActualUserInfo selectVillageActualUserInfoById(Long id);
/**
*
*/
public List<VillageActualUserInfo> selectVillageActualUserInfoList(VillageActualUserInfo villageActualUserInfo);
public List<VillageActualUserInfo> selectVillageActualUserInfoListAndPicExists(VillageActualUserInfo villageActualUserInfo);
/**
*
*/
public int insertVillageActualUserInfo(VillageActualUserInfo villageActualUserInfo);
/**
*
*/
public int updateVillageActualUserInfo(VillageActualUserInfo villageActualUserInfo);
/**
*
*/
public int deleteVillageActualUserInfoByIds(Long[] ids);
/**
*
*/
public int deleteVillageActualUserInfoById(Long id);
public int deleteVillageActualUserInfoByUpdatetime(VillageActualUserInfo bean);
}

@ -1,5 +1,6 @@
package com.ssf.mysqloracletest.service.impl; package com.ssf.mysqloracletest.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ssf.mysqloracletest.domain.MetaActualUnitInfo; import com.ssf.mysqloracletest.domain.MetaActualUnitInfo;
import com.ssf.mysqloracletest.mapper.MetaActualUnitInfoMapper; import com.ssf.mysqloracletest.mapper.MetaActualUnitInfoMapper;
@ -15,6 +16,7 @@ import org.springframework.stereotype.Service;
*/ */
@Service @Service
@RequiredArgsConstructor @RequiredArgsConstructor
@DS("mysql")
public class MetaActualUnitInfoServiceImpl extends ServiceImpl<MetaActualUnitInfoMapper, MetaActualUnitInfo> implements MetaActualUnitInfoService { public class MetaActualUnitInfoServiceImpl extends ServiceImpl<MetaActualUnitInfoMapper, MetaActualUnitInfo> implements MetaActualUnitInfoService {
} }

@ -1,5 +1,6 @@
package com.ssf.mysqloracletest.service.impl; package com.ssf.mysqloracletest.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ssf.mysqloracletest.domain.MetaActualUnitUserInfo; import com.ssf.mysqloracletest.domain.MetaActualUnitUserInfo;
import com.ssf.mysqloracletest.service.MetaActualUnitUserInfoService; import com.ssf.mysqloracletest.service.MetaActualUnitUserInfoService;
@ -12,6 +13,7 @@ import org.springframework.stereotype.Service;
* @createDate 2023-12-02 10:31:32 * @createDate 2023-12-02 10:31:32
*/ */
@Service @Service
@DS("mysql")
public class MetaActualUnitUserInfoServiceImpl extends ServiceImpl<MetaActualUnitUserInfoMapper, MetaActualUnitUserInfo> public class MetaActualUnitUserInfoServiceImpl extends ServiceImpl<MetaActualUnitUserInfoMapper, MetaActualUnitUserInfo>
implements MetaActualUnitUserInfoService{ implements MetaActualUnitUserInfoService{

@ -1,5 +1,6 @@
package com.ssf.mysqloracletest.service.impl; package com.ssf.mysqloracletest.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ssf.mysqloracletest.domain.MetaActualUserInfo; import com.ssf.mysqloracletest.domain.MetaActualUserInfo;
import com.ssf.mysqloracletest.service.MetaActualUserInfoService; import com.ssf.mysqloracletest.service.MetaActualUserInfoService;
@ -12,6 +13,7 @@ import org.springframework.stereotype.Service;
* @createDate 2023-12-02 17:31:50 * @createDate 2023-12-02 17:31:50
*/ */
@Service @Service
@DS("mysql")
public class MetaActualUserInfoServiceImpl extends ServiceImpl<MetaActualUserInfoMapper, MetaActualUserInfo> public class MetaActualUserInfoServiceImpl extends ServiceImpl<MetaActualUserInfoMapper, MetaActualUserInfo>
implements MetaActualUserInfoService{ implements MetaActualUserInfoService{

@ -1,5 +1,6 @@
package com.ssf.mysqloracletest.service.impl; package com.ssf.mysqloracletest.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ssf.mysqloracletest.domain.MetaAlarmInfo; import com.ssf.mysqloracletest.domain.MetaAlarmInfo;
import com.ssf.mysqloracletest.service.MetaAlarmInfoService; import com.ssf.mysqloracletest.service.MetaAlarmInfoService;
@ -14,6 +15,7 @@ import org.springframework.stereotype.Service;
*/ */
@Service @Service
@RequiredArgsConstructor @RequiredArgsConstructor
@DS("mysql")
public class MetaAlarmInfoServiceImpl extends ServiceImpl<MetaAlarmInfoMapper, MetaAlarmInfo> implements MetaAlarmInfoService{ public class MetaAlarmInfoServiceImpl extends ServiceImpl<MetaAlarmInfoMapper, MetaAlarmInfo> implements MetaAlarmInfoService{
} }

@ -1,5 +1,6 @@
package com.ssf.mysqloracletest.service.impl; package com.ssf.mysqloracletest.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo; import com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo;
import com.ssf.mysqloracletest.service.MetaHandleAlarmInfoService; import com.ssf.mysqloracletest.service.MetaHandleAlarmInfoService;
@ -12,6 +13,7 @@ import org.springframework.stereotype.Service;
* @createDate 2023-12-01 19:02:18 * @createDate 2023-12-01 19:02:18
*/ */
@Service @Service
@DS("mysql")
public class MetaHandleAlarmInfoServiceImpl extends ServiceImpl<MetaHandleAlarmInfoMapper, MetaHandleAlarmInfo> public class MetaHandleAlarmInfoServiceImpl extends ServiceImpl<MetaHandleAlarmInfoMapper, MetaHandleAlarmInfo>
implements MetaHandleAlarmInfoService{ implements MetaHandleAlarmInfoService{

@ -1,5 +1,6 @@
package com.ssf.mysqloracletest.service.impl; package com.ssf.mysqloracletest.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ssf.mysqloracletest.domain.MetaImpUserInfo; import com.ssf.mysqloracletest.domain.MetaImpUserInfo;
import com.ssf.mysqloracletest.service.MetaImpUserInfoService; import com.ssf.mysqloracletest.service.MetaImpUserInfoService;
@ -12,6 +13,7 @@ import org.springframework.stereotype.Service;
* @createDate 2023-12-01 16:43:42 * @createDate 2023-12-01 16:43:42
*/ */
@Service @Service
@DS("mysql")
public class MetaImpUserInfoServiceImpl extends ServiceImpl<MetaImpUserInfoMapper, MetaImpUserInfo> public class MetaImpUserInfoServiceImpl extends ServiceImpl<MetaImpUserInfoMapper, MetaImpUserInfo>
implements MetaImpUserInfoService{ implements MetaImpUserInfoService{

@ -1,6 +1,7 @@
package com.ssf.mysqloracletest.service.impl; package com.ssf.mysqloracletest.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ssf.mysqloracletest.domain.MetaRealEstateInfo; import com.ssf.mysqloracletest.domain.MetaRealEstateInfo;
import com.ssf.mysqloracletest.mapper.MetaRealEstateInfoMapper; import com.ssf.mysqloracletest.mapper.MetaRealEstateInfoMapper;
@ -14,6 +15,7 @@ import org.springframework.stereotype.Service;
* @since 2023-12-05 09:24:09 * @since 2023-12-05 09:24:09
*/ */
@Service @Service
@DS("mysql")
public class MetaRealEstateInfoServiceImpl extends ServiceImpl<MetaRealEstateInfoMapper, MetaRealEstateInfo> implements MetaRealEstateInfoService { public class MetaRealEstateInfoServiceImpl extends ServiceImpl<MetaRealEstateInfoMapper, MetaRealEstateInfo> implements MetaRealEstateInfoService {
@Override @Override

@ -13,6 +13,7 @@ import org.springframework.stereotype.Service;
* @createDate 2023-12-04 10:11:22 * @createDate 2023-12-04 10:11:22
*/ */
@Service @Service
@DS("mysql")
public class MetaRentalHousingInfoServiceImpl extends ServiceImpl<MetaRentalHousingInfoMapper, MetaRentalHousingInfo> public class MetaRentalHousingInfoServiceImpl extends ServiceImpl<MetaRentalHousingInfoMapper, MetaRentalHousingInfo>
implements MetaRentalHousingInfoService{ implements MetaRentalHousingInfoService{

@ -1,12 +1,13 @@
package com.ssf.mysqloracletest.service.impl; package com.ssf.mysqloracletest.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ssf.mysqloracletest.domain.VJwtSyfw; import com.ssf.mysqloracletest.domain.VJwtSyfw;
import com.ssf.mysqloracletest.mapper.VJwtSyfwMapper; import com.ssf.mysqloracletest.mapper.VJwtSyfwMapper;
import com.ssf.mysqloracletest.service.JwtSyfwService; import com.ssf.mysqloracletest.service.JwtSyfwService;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List; import java.util.List;
/** /**
@ -16,12 +17,12 @@ import java.util.List;
* @date 2023-12-04 * @date 2023-12-04
*/ */
@Service @Service
@RequiredArgsConstructor @DS("mysql")
public class VJwtSyfwServiceImpl extends ServiceImpl<VJwtSyfwMapper, VJwtSyfw> public class VJwtSyfwServiceImpl extends ServiceImpl<VJwtSyfwMapper, VJwtSyfw>
implements JwtSyfwService { implements JwtSyfwService {
@Resource
private final VJwtSyfwMapper vJwtSyfwMapper; private VJwtSyfwMapper vJwtSyfwMapper;
/** /**

@ -0,0 +1,158 @@
package com.ssf.mysqloracletest.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.ssf.mysqloracletest.domain.VillageActualUserInfo;
import com.ssf.mysqloracletest.mapper.VillageActualUserInfoMapper;
import com.ssf.mysqloracletest.service.VillageActualUserInfoService;
import com.ssf.mysqloracletest.utils.ConfigParam;
import com.ssf.mysqloracletest.utils.StringKit;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.io.File;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* Service
*
* @author ruoyi
* @date 2023-04-17
*/
@Service
@DS("mysqlSy")
public class VillageActualUserInfoServiceImpl implements VillageActualUserInfoService {
private static final Logger logger = LoggerFactory.getLogger(VillageActualUserInfoServiceImpl.class);
@Resource
private VillageActualUserInfoMapper ActualUserInfoDao;
/**
*
*/
@Override
public VillageActualUserInfo selectVillageActualUserInfoById(Long id) {
VillageActualUserInfo v = ActualUserInfoDao.selectVillageActualUserInfoById(id);
return v;
}
/**
*
*/
public VillageActualUserInfo selectVillageActualUserInfoByIdcard(String idcard) {
VillageActualUserInfo v = ActualUserInfoDao.selectVillageActualUserInfoByIdcard(idcard);
return v;
}
/**
*
*/
@Override
public List<VillageActualUserInfo> selectVillageActualUserInfoList(VillageActualUserInfo villageActualUserInfo) {
List<VillageActualUserInfo> list = ActualUserInfoDao.selectVillageActualUserInfoList(villageActualUserInfo);
return list;
}
/**
*
*/
@Override
public List<VillageActualUserInfo> selectVillageActualUserInfoListAndPicExists(VillageActualUserInfo villageActualUserInfo) {
List<VillageActualUserInfo> list = ActualUserInfoDao.selectVillageActualUserInfoListAndPicExists(villageActualUserInfo);
return list;
}
/**
*
*/
@Override
public int insertVillageActualUserInfo(VillageActualUserInfo villageActualUserInfo) {
return ActualUserInfoDao.insertVillageActualUserInfo(villageActualUserInfo);
}
public int saveOrUpdate(VillageActualUserInfo villageActualUserInfo) {
try {
String idcard = StringKit.toString(villageActualUserInfo.getIdcard());
VillageActualUserInfo bean = selectVillageActualUserInfoByIdcard(idcard);
int res = 0;
if (bean == null) {
villageActualUserInfo.setC1("1");
res = ActualUserInfoDao.insertVillageActualUserInfo(villageActualUserInfo);
} else {
VillageActualUserInfo beanUp = new VillageActualUserInfo();
BeanUtils.copyProperties(villageActualUserInfo, beanUp);
updateVillageActualUserInfoByIdcard(beanUp);
}
return res;
} catch (Exception e) {
logger.info(StringKit.getTrace(e));
return 0;
}
}
/**
*
*/
@Override
public int updateVillageActualUserInfo(VillageActualUserInfo villageActualUserInfo) {
return ActualUserInfoDao.updateVillageActualUserInfo(villageActualUserInfo);
}
public int updateVillageActualUserInfoByIdcard(VillageActualUserInfo bean) {
VillageActualUserInfo beanCheck = selectVillageActualUserInfoByIdcard(bean.getIdcard());
String versionCheck = StringKit.toString(beanCheck.getC1());
String c1 = "".equals(StringKit.toString(bean.getC1())) ? "1" : bean.getC1();
int version = Integer.valueOf(c1);
bean.setC1(StringKit.toString(version));
bean.setC1New(StringKit.toString(version + 1));
if ("".equals(versionCheck) || c1.equals(versionCheck)) {
return ActualUserInfoDao.updateVillageActualUserInfoByIdcard(bean);
}
return 0;
}
/**
*
*/
@Override
public int deleteVillageActualUserInfoByIds(Long[] ids) {
return ActualUserInfoDao.deleteVillageActualUserInfoByIds(ids);
}
/**
*
*/
@Override
public int deleteVillageActualUserInfoById(Long id) {
return ActualUserInfoDao.deleteVillageActualUserInfoById(id);
}
@Override
public int deleteVillageActualUserInfoByUpdatetime(VillageActualUserInfo bean) {
return ActualUserInfoDao.deleteVillageActualUserInfoByUpdatetime(bean);
}
private static String getFolderPath(String picpath) {
String floderPath;
Date date = new Date();
SimpleDateFormat simpleDate = new SimpleDateFormat("yyyyMMdd");
String day = simpleDate.format(date);
floderPath = picpath + ConfigParam.seq + "userinfo" + ConfigParam.seq + day + ConfigParam.seq;
File fileFloderPath = new File(floderPath);
//创建文件夹
if (!fileFloderPath.exists()) {
fileFloderPath.mkdirs();
}
return floderPath;
}
}

@ -2,10 +2,8 @@ package com.ssf.mysqloracletest.task;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.ssf.mysqloracletest.domain.MetaActualUnitUserInfo; import com.ssf.mysqloracletest.domain.MetaActualUnitUserInfo;
import com.ssf.mysqloracletest.domain.MetaImpUserInfo;
import com.ssf.mysqloracletest.domain.VSySydwCyryMysql; import com.ssf.mysqloracletest.domain.VSySydwCyryMysql;
import com.ssf.mysqloracletest.service.MetaActualUnitUserInfoService; import com.ssf.mysqloracletest.service.MetaActualUnitUserInfoService;
import com.ssf.mysqloracletest.service.MetaImpUserInfoService;
import com.ssf.mysqloracletest.service.VSySydwCyryMysqlService; import com.ssf.mysqloracletest.service.VSySydwCyryMysqlService;
import com.ssf.mysqloracletest.utils.ConfigParam; import com.ssf.mysqloracletest.utils.ConfigParam;
import com.ssf.mysqloracletest.utils.NumKit; import com.ssf.mysqloracletest.utils.NumKit;
@ -19,12 +17,9 @@ import javax.annotation.Resource;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/** /**
* *
*/ */
@Component @Component
public class MetaActualUnitUserInfoTask { public class MetaActualUnitUserInfoTask {
@ -66,68 +61,53 @@ public class MetaActualUnitUserInfoTask {
cyryTag = true; cyryTag = true;
int count = countcyry / oncesCounts; int count = countcyry / oncesCounts;
CountDownLatch latch = new CountDownLatch(count);
ExecutorService cyryPool = Executors.newFixedThreadPool(50);
for (int i = 0; i <= count; i++) { for (int i = 0; i <= count; i++) {
Map cyryMap = new HashMap(); Map cyryMap = new HashMap();
cyryMap.put("rowStart", i * oncesCounts); cyryMap.put("rowStart", i * oncesCounts);
cyryMap.put("rowEnd", (i + 1) * oncesCounts); cyryMap.put("rowEnd", (i + 1) * oncesCounts);
cyryPool.submit(() -> { try {
try { List<VSySydwCyryMysql> list = vSySydwCyryMysqlService.lambdaQuery().list();
List<VSySydwCyryMysql> list = vSySydwCyryMysqlService.lambdaQuery().list(); for (VSySydwCyryMysql cyry : list) {
for (VSySydwCyryMysql cyry : list) { MetaActualUnitUserInfo metaActualUnitUserInfo = new MetaActualUnitUserInfo();
MetaActualUnitUserInfo metaActualUnitUserInfo = new MetaActualUnitUserInfo(); if (cyry.getDWID() != null) {
if (cyry.getDWID()!=null) { metaActualUnitUserInfo.setUnitId(Long.parseLong(cyry.getDWID()));
metaActualUnitUserInfo.setUnitId(Long.parseLong(cyry.getDWID())); }
} metaActualUnitUserInfo.setUnitName(cyry.getDWMC());
metaActualUnitUserInfo.setUnitName(cyry.getDWMC()); metaActualUnitUserInfo.setStaffName(cyry.getXM());
metaActualUnitUserInfo.setStaffName(cyry.getXM()); metaActualUnitUserInfo.setIdentityId(cyry.getZJHM());
metaActualUnitUserInfo.setIdentityId(cyry.getZJHM()); metaActualUnitUserInfo.setContactInfo(cyry.getLXDH());
metaActualUnitUserInfo.setContactInfo(cyry.getLXDH()); if (cyry.getXB() != null) {
if (cyry.getXB()!=null) { metaActualUnitUserInfo.setSex(Integer.parseInt(cyry.getXB()));
metaActualUnitUserInfo.setSex(Integer.parseInt(cyry.getXB())); }
} if (cyry.getRYFL() != null) {
if (cyry.getRYFL()!=null) { metaActualUnitUserInfo.setStaffType(Integer.parseInt(cyry.getRYFL()));
metaActualUnitUserInfo.setStaffType(Integer.parseInt(cyry.getRYFL())); }
} if ("Y".equals(cyry.getZT())) {
if ("Y".equals(cyry.getZT())){ metaActualUnitUserInfo.setStaffState(1);
metaActualUnitUserInfo.setStaffState(1); } else if ("N".equals(cyry.getZT())) {
}else if ("N".equals(cyry.getZT())){ metaActualUnitUserInfo.setStaffState(2);
metaActualUnitUserInfo.setStaffState(2); }
} metaActualUnitUserInfo.setMetaCreateTime(cyry.getYSBZK_RKSJ());
metaActualUnitUserInfo.setMetaCreateTime(cyry.getYSBZK_RKSJ()); metaActualUnitUserInfo.setMetaUpdateTime(cyry.getYSBZK_GXSJ());
metaActualUnitUserInfo.setMetaUpdateTime(cyry.getYSBZK_GXSJ()); //确定一个数据是否唯一
//确定一个数据是否唯一 MetaActualUnitUserInfo one = metaActualUnitUserInfoService.lambdaQuery().eq(MetaActualUnitUserInfo::getIdentityId, cyry.getZJHM())
MetaActualUnitUserInfo one = metaActualUnitUserInfoService.lambdaQuery().eq(MetaActualUnitUserInfo::getIdentityId, cyry.getZJHM()) .eq(MetaActualUnitUserInfo::getStaffType, cyry.getRYFL()).one();
.eq(MetaActualUnitUserInfo::getStaffType, cyry.getRYFL()).one(); if (one == null) {
if (one == null) { metaActualUnitUserInfoService.save(metaActualUnitUserInfo);
metaActualUnitUserInfoService.save(metaActualUnitUserInfo); logger.info("cyry-" + cyry.getZJHM() + ":插入成功");
logger.info("cyry-" + cyry.getZJHM() + ":插入成功"); } else {
} else { UpdateWrapper<MetaActualUnitUserInfo> metaActualUnitUserInfoUpdateWrapper = new UpdateWrapper<>();
UpdateWrapper<MetaActualUnitUserInfo> metaActualUnitUserInfoUpdateWrapper = new UpdateWrapper<>(); metaActualUnitUserInfoUpdateWrapper.eq("identity_id", cyry.getZJHM());
metaActualUnitUserInfoUpdateWrapper.eq("identity_id", cyry.getZJHM()); metaActualUnitUserInfoUpdateWrapper.eq("staff_type", cyry.getRYFL());
metaActualUnitUserInfoUpdateWrapper.eq("staff_type", cyry.getRYFL()); metaActualUnitUserInfoService.update(metaActualUnitUserInfo, metaActualUnitUserInfoUpdateWrapper);
metaActualUnitUserInfoService.update(metaActualUnitUserInfo,metaActualUnitUserInfoUpdateWrapper); logger.info("cyry-" + cyry.getZJHM() + ":更新成功");
logger.info("cyry-" + cyry.getZJHM() + ":更新成功");
}
} }
} catch (Exception e) {
logger.info("cyrys:" + e.getMessage());
} }
latch.countDown(); } catch (Exception e) {
}); logger.info("cyrys:" + e.getMessage());
}
logger.info("cyryMap数据总量:" + countcyry + "," + "当前处理下标:" + cyryMap.get("rowStart") + "/" + cyryMap.get("rowEnd")); logger.info("cyryMap数据总量:" + countcyry + "," + "当前处理下标:" + cyryMap.get("rowStart") + "/" + cyryMap.get("rowEnd"));
} }
try {
// Wait for all threads to complete
latch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
// 关闭线程池
cyryPool.shutdown();
} }
} catch (Exception e) { } catch (Exception e) {

@ -1,19 +1,26 @@
package com.ssf.mysqloracletest.task; 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.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ssf.mysqloracletest.domain.MetaActualUserInfo; import com.ssf.mysqloracletest.domain.MetaActualUserInfo;
import com.ssf.mysqloracletest.domain.MetaRealEstateInfo;
import com.ssf.mysqloracletest.domain.VSySyrkMysql; import com.ssf.mysqloracletest.domain.VSySyrkMysql;
import com.ssf.mysqloracletest.domain.VillageActualUserInfo;
import com.ssf.mysqloracletest.service.MetaActualUserInfoService; import com.ssf.mysqloracletest.service.MetaActualUserInfoService;
import com.ssf.mysqloracletest.service.MetaRealEstateInfoService;
import com.ssf.mysqloracletest.service.VSySyrkMysqlService; import com.ssf.mysqloracletest.service.VSySyrkMysqlService;
import com.ssf.mysqloracletest.service.VillageActualUserInfoService;
import com.ssf.mysqloracletest.utils.ConfigParam; import com.ssf.mysqloracletest.utils.ConfigParam;
import com.ssf.mysqloracletest.utils.NumKit; import com.ssf.mysqloracletest.utils.NumKit;
import com.ssf.mysqloracletest.utils.StringKit; import com.ssf.mysqloracletest.utils.StringKit;
import lombok.RequiredArgsConstructor;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.scheduling.annotation.Scheduled; import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -25,111 +32,113 @@ import java.util.concurrent.Executors;
* *
*/ */
@Component @Component
@RequiredArgsConstructor
public class MetaActualUserInfoTask { public class MetaActualUserInfoTask {
private static final Logger logger = LoggerFactory.getLogger(MetaActualUserInfoTask.class); private static final Logger logger = LoggerFactory.getLogger(MetaActualUserInfoTask.class);
@Resource private final VSySyrkMysqlService vSySyrkMysqlService;
private VSySyrkMysqlService vSySyrkMysqlService; private final VillageActualUserInfoService actualUserInfoService;
@Resource private final MetaActualUserInfoService metaActualUserInfoService;
private MetaActualUserInfoService metaActualUserInfoService;
final int oncesCounts = NumKit.checkInt(ConfigParam.oncesCounts) == 0 ? 1000 : NumKit.checkInt(ConfigParam.oncesCounts); private final MetaRealEstateInfoService estateInfoService;
private boolean syrkTag = false;
/** /**
* *
* //
*/ */
@Scheduled(initialDelay = 100, fixedDelay = 3000) @Scheduled(initialDelay = 100, fixedDelay = 3000)
public void transsyrk() { public void transMetaActualUserInfo() {
if (syrkTag) {
return;
}
if (!"true".equals(ConfigParam.metaActualUserInfoSwitch)) { if (!"true".equals(ConfigParam.metaActualUserInfoSwitch)) {
return; return;
} }
logger.info("syrk Scheduled start");
try {
QueryWrapper<VSySyrkMysql> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("status");
Page<VSySyrkMysql> page = new Page<>(1, 1000);
List<VSySyrkMysql> resultList = vSySyrkMysqlService.page(page, queryWrapper).getRecords();
logger.info("VSySyrkMysql size:" + resultList.size());
CountDownLatch latch = new CountDownLatch(resultList.size());
ExecutorService syrkPool = Executors.newFixedThreadPool(20);
for (VSySyrkMysql bean : resultList) {
syrkPool.submit(() -> {
cleansyrk(bean);
latch.countDown();
});
}
try {
// Wait for all threads to complete
latch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
// 关闭线程池
syrkPool.shutdown();
} catch (Exception e) {
logger.info(StringKit.getTrace(e));
}
}
private void cleansyrk(VSySyrkMysql bean) {
logger.info("VSySyrkMysql thread start;" + bean.getSFZH());
VSySyrkMysql beanCp = new VSySyrkMysql();
try { try {
int countsyrk = vSySyrkMysqlService.count(); BeanUtils.copyProperties(bean, beanCp);
logger.info("countsyrk:" + countsyrk);
VillageActualUserInfo userInfoPara = new VillageActualUserInfo();
if (countsyrk > 0) { userInfoPara.setIdcard(StringKit.toString(beanCp.getSFZH()));
List<VillageActualUserInfo> actualUserInfos = actualUserInfoService.selectVillageActualUserInfoList(userInfoPara);
syrkTag = true;
String userPic = "";
int count = countsyrk / oncesCounts; if(actualUserInfos!=null && actualUserInfos.size()>0){
CountDownLatch latch = new CountDownLatch(count); userPic = StringKit.toString(actualUserInfos.get(0).getUserPic());
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();
} }
MetaActualUserInfo actualUserInfo = new MetaActualUserInfo();
actualUserInfo.setUserPic(userPic);
actualUserInfo.setUserName(StringKit.toString(beanCp.getXM()));
actualUserInfo.setIdCard(StringKit.toString(beanCp.getSFZH()));
actualUserInfo.setSex(NumKit.checkInt(beanCp.getXB()));
actualUserInfo.setPhone(StringKit.toString(beanCp.getSJHM()));
actualUserInfo.setLandline(StringKit.toString(beanCp.getLXDH()));
actualUserInfo.setActualUserType(NumKit.checkInt(beanCp.getRYLX()));
actualUserInfo.setHouseHoldRegister(StringKit.toString(beanCp.getHJSSXQ()));
actualUserInfo.setHouseHoldAddress(StringKit.toString(beanCp.getHJDXZ()));
actualUserInfo.setHabitationAddress(StringKit.toString(beanCp.getXJZDXZ()));
actualUserInfo.setPoliceStationCode(StringKit.toString(beanCp.getPCSDM()));
actualUserInfo.setPoliceStationName(StringKit.toString(beanCp.getPCSMC()));
actualUserInfo.setPoliceDistrictCode(StringKit.toString(beanCp.getJWQDM()));
actualUserInfo.setPoliceDistrictName(StringKit.toString(beanCp.getJWQMC()));
actualUserInfo.setManagementStatus(StringKit.toString(beanCp.getSTS()));
// 构造查询条件
QueryWrapper<MetaRealEstateInfo> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("real_estate_address", StringKit.toString(beanCp.getXJZDXZ()));
MetaRealEstateInfo estateInfo = estateInfoService.getOne(queryWrapper);
if(estateInfo !=null){
actualUserInfo.setHomeId(StringKit.toString(estateInfo.getId()));
}
actualUserInfo.setHomeCode(StringKit.toString(beanCp.getFJDM()));
// actualUserInfo.setAccountNumber();
actualUserInfo.setMetaCreateTime(StringKit.toString(beanCp.getYSBZK_RKSJ()));
actualUserInfo.setMetaUpdateTime(StringKit.toString(beanCp.getYSBZK_GXSJ()));
boolean b = metaActualUserInfoService.save(actualUserInfo);
if (b) {
beanCp.setStatus("1");
vSySyrkMysqlService.updateVSySyrkById(beanCp);
}
} catch (Exception e) { } catch (Exception e) {
logger.info(StringKit.getTrace(e)); logger.info(StringKit.getTrace(e));
beanCp.setStatus("2");
vSySyrkMysqlService.updateVSySyrkById(beanCp);
} }
} }

@ -66,7 +66,7 @@ public class MetaHandleAlarmTask {
int count = countcjxx / oncesCounts; int count = countcjxx / oncesCounts;
CountDownLatch latch = new CountDownLatch(count); CountDownLatch latch = new CountDownLatch(count);
ExecutorService cjxxPool = Executors.newFixedThreadPool(50); ExecutorService cjxxPool = Executors.newFixedThreadPool(20);
for (int i = 0; i <= count; i++) { for (int i = 0; i <= count; i++) {
Map cjxxMap = new HashMap(); Map cjxxMap = new HashMap();

@ -1,7 +1,5 @@
package com.ssf.mysqloracletest.task; package com.ssf.mysqloracletest.task;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.ssf.mysqloracletest.domain.MetaImpUserInfo; import com.ssf.mysqloracletest.domain.MetaImpUserInfo;
import com.ssf.mysqloracletest.domain.ZhxfZdrygkRyjbxxViewMysql; import com.ssf.mysqloracletest.domain.ZhxfZdrygkRyjbxxViewMysql;
@ -19,12 +17,9 @@ import javax.annotation.Resource;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/** /**
* *
*/ */
@Component @Component
public class MetaImpUserInfoTask { public class MetaImpUserInfoTask {
@ -48,10 +43,6 @@ public class MetaImpUserInfoTask {
@Scheduled(initialDelay = 100, fixedDelay = 3000) @Scheduled(initialDelay = 100, fixedDelay = 3000)
public void transzdry() { public void transzdry() {
if (zdryTag) {
return;
}
if (!"true".equals(ConfigParam.metaImpUserSwitch)) { if (!"true".equals(ConfigParam.metaImpUserSwitch)) {
return; return;
} }
@ -63,74 +54,58 @@ public class MetaImpUserInfoTask {
if (countzdry > 0) { if (countzdry > 0) {
zdryTag = true;
int count = countzdry / oncesCounts; int count = countzdry / oncesCounts;
CountDownLatch latch = new CountDownLatch(count);
ExecutorService zdryPool = Executors.newFixedThreadPool(50);
for (int i = 0; i <= count; i++) { for (int i = 0; i <= count; i++) {
Map zdryMap = new HashMap(); Map zdryMap = new HashMap();
zdryMap.put("rowStart", i * oncesCounts); zdryMap.put("rowStart", i * oncesCounts);
zdryMap.put("rowEnd", (i + 1) * oncesCounts); zdryMap.put("rowEnd", (i + 1) * oncesCounts);
zdryPool.submit(() -> { try {
try { List<ZhxfZdrygkRyjbxxViewMysql> list = zdryMysqlService.lambdaQuery().list();
List<ZhxfZdrygkRyjbxxViewMysql> list = zdryMysqlService.lambdaQuery().list(); for (ZhxfZdrygkRyjbxxViewMysql zdry : list) {
for (ZhxfZdrygkRyjbxxViewMysql zdry : list) { MetaImpUserInfo metaImpUserInfo = new MetaImpUserInfo();
MetaImpUserInfo metaImpUserInfo = new MetaImpUserInfo(); metaImpUserInfo.setUserName(zdry.getXM());
metaImpUserInfo.setUserName(zdry.getXM()); metaImpUserInfo.setIdCard(zdry.getZJHM());
metaImpUserInfo.setIdCard(zdry.getZJHM()); if (zdry.getXB() != null) {
if (zdry.getXB()!=null) { metaImpUserInfo.setSex(Integer.parseInt(zdry.getXB()));
metaImpUserInfo.setSex(Integer.parseInt(zdry.getXB())); }
} metaImpUserInfo.setPhone(zdry.getSJHM());
metaImpUserInfo.setPhone(zdry.getSJHM()); String s = "000000";
String s = "000000"; if (zdry.getZDRYXL() != null && !zdry.getZDRYXL().contains(",")) {
if (zdry.getZDRYXL()!=null && !zdry.getZDRYXL().contains(",")){ String substring = zdry.getZDRYXL().substring(0, 4);
String substring = zdry.getZDRYXL().substring(0, 4); substring = substring + s;
substring=substring+ s; metaImpUserInfo.setImpUserType(substring);
metaImpUserInfo.setImpUserType(substring); } else if (zdry.getZDRYXL().contains(",")) {
}else if (zdry.getZDRYXL().contains(",")){ String[] split = zdry.getZDRYXL().split(",");
String[] split = zdry.getZDRYXL().split(","); String substring = split[0].substring(0, 4);
String substring = split[0].substring(0, 4); String substring1 = split[1].substring(0, 4);
String substring1 = split[1].substring(0, 4); substring = substring + s + "," + substring1 + s;
substring = substring+s+","+substring1+s; metaImpUserInfo.setImpUserType(substring);
metaImpUserInfo.setImpUserType(substring); }
} metaImpUserInfo.setImpUserSubType(zdry.getZDRYXL());
metaImpUserInfo.setImpUserSubType(zdry.getZDRYXL()); metaImpUserInfo.setHouseHoldRegister(zdry.getHJDQH());
metaImpUserInfo.setHouseHoldRegister(zdry.getHJDQH()); metaImpUserInfo.setHouseHoldAddress(zdry.getHJDXZ());
metaImpUserInfo.setHouseHoldAddress(zdry.getHJDXZ()); metaImpUserInfo.setHabitationRegister(zdry.getXZDHQ());
metaImpUserInfo.setHabitationRegister(zdry.getXZDHQ()); metaImpUserInfo.setHabitationAddress(zdry.getXZDXZ());
metaImpUserInfo.setHabitationAddress(zdry.getXZDXZ()); metaImpUserInfo.setRegisterUnitCode(zdry.getDJRDWDM());
metaImpUserInfo.setRegisterUnitCode(zdry.getDJRDWDM()); metaImpUserInfo.setRegisterUnitName(zdry.getDJRDWMC());
metaImpUserInfo.setRegisterUnitName(zdry.getDJRDWMC()); //确定一个数据是否唯一
//确定一个数据是否唯一 MetaImpUserInfo one = metaImpUserInfoService.lambdaQuery().eq(MetaImpUserInfo::getIdCard, zdry.getZJHM()).one();
MetaImpUserInfo one = metaImpUserInfoService.lambdaQuery().eq(MetaImpUserInfo::getIdCard, zdry.getZJHM()).one(); if (one == null) {
if (one == null) { metaImpUserInfoService.save(metaImpUserInfo);
metaImpUserInfoService.save(metaImpUserInfo); logger.info("zdry-" + zdry.getZJHM() + ":插入成功");
logger.info("zdry-" + zdry.getZJHM() + ":插入成功"); } else {
} else { UpdateWrapper<MetaImpUserInfo> metaImpUserInfoUpdateWrapper = new UpdateWrapper<>();
UpdateWrapper<MetaImpUserInfo> metaImpUserInfoUpdateWrapper = new UpdateWrapper<>(); metaImpUserInfoUpdateWrapper.eq("id_card", zdry.getZJHM());
metaImpUserInfoUpdateWrapper.eq("id_card", zdry.getZJHM()); metaImpUserInfoService.update(metaImpUserInfo, metaImpUserInfoUpdateWrapper);
metaImpUserInfoService.update(metaImpUserInfo,metaImpUserInfoUpdateWrapper); logger.info("zdry-" + zdry.getZJHM() + ":更新成功");
logger.info("zdry-" + zdry.getZJHM() + ":更新成功");
}
} }
} catch (Exception e) {
logger.info("zdrys:" + e.getMessage());
} }
latch.countDown(); } catch (Exception e) {
}); logger.info("zdrys:" + e.getMessage());
}
logger.info("zdryMap数据总量:" + countzdry + "," + "当前处理下标:" + zdryMap.get("rowStart") + "/" + zdryMap.get("rowEnd")); logger.info("zdryMap数据总量:" + countzdry + "," + "当前处理下标:" + zdryMap.get("rowStart") + "/" + zdryMap.get("rowEnd"));
} }
try {
// Wait for all threads to complete
latch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
// 关闭线程池
zdryPool.shutdown();
} }
} catch (Exception e) { } catch (Exception e) {

@ -51,7 +51,7 @@ public class MetaRealEstateInfoTask {
List<VJwtSyfw> resultList = jwySyfwService.page(page, queryWrapper).getRecords(); List<VJwtSyfw> resultList = jwySyfwService.page(page, queryWrapper).getRecords();
CountDownLatch latch = new CountDownLatch(resultList.size()); CountDownLatch latch = new CountDownLatch(resultList.size());
ExecutorService jwtSyfwPool = Executors.newFixedThreadPool(50); ExecutorService jwtSyfwPool = Executors.newFixedThreadPool(5);
for (VJwtSyfw bean : resultList) { for (VJwtSyfw bean : resultList) {
jwtSyfwPool.submit(() -> { jwtSyfwPool.submit(() -> {
@ -59,8 +59,6 @@ public class MetaRealEstateInfoTask {
latch.countDown(); latch.countDown();
}); });
} }
try { try {
// Wait for all threads to complete // Wait for all threads to complete
latch.await(); latch.await();
@ -72,9 +70,6 @@ public class MetaRealEstateInfoTask {
} catch (Exception e) { } catch (Exception e) {
logger.info(StringKit.getTrace(e)); logger.info(StringKit.getTrace(e));
} }
} }
private void cleanJwtSyfw(VJwtSyfw bean) { private void cleanJwtSyfw(VJwtSyfw bean) {
@ -104,4 +99,7 @@ public class MetaRealEstateInfoTask {
} }
} }

@ -55,7 +55,7 @@ public class RentalHousingTask {
int count = countRentalHouse / oncesCounts; int count = countRentalHouse / oncesCounts;
CountDownLatch latch = new CountDownLatch(count); CountDownLatch latch = new CountDownLatch(count);
ExecutorService RentalHousePool = Executors.newFixedThreadPool(50); ExecutorService RentalHousePool = Executors.newFixedThreadPool(5);
for (int i = 0; i <= count; i++) { for (int i = 0; i <= count; i++) {
Map HouseMap = new HashMap(); Map HouseMap = new HashMap();

@ -1 +1 @@
server: port: 5678 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' mybatis-plus: mapper-locations: - classpath:mapper/*.xml 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

@ -46,6 +46,7 @@
<result property="CDC_JYM" column="CDC_JYM" jdbcType="VARCHAR"/> <result property="CDC_JYM" column="CDC_JYM" jdbcType="VARCHAR"/>
<result property="YSBZK_RKSJ" column="YSBZK_RKSJ" jdbcType="VARCHAR"/> <result property="YSBZK_RKSJ" column="YSBZK_RKSJ" jdbcType="VARCHAR"/>
<result property="YSBZK_GXSJ" column="YSBZK_GXSJ" jdbcType="VARCHAR"/> <result property="YSBZK_GXSJ" column="YSBZK_GXSJ" jdbcType="VARCHAR"/>
<result property="status" column="status" jdbcType="VARCHAR"/>
</resultMap> </resultMap>
<select id="selectVSySyrkById" parameterType="java.lang.String" resultMap="BaseResultMap"> <select id="selectVSySyrkById" parameterType="java.lang.String" resultMap="BaseResultMap">
@ -94,6 +95,7 @@
<if test="CDC_JYM != null and CDC_JYM != '' ">CDC_JYM,</if> <if test="CDC_JYM != null and CDC_JYM != '' ">CDC_JYM,</if>
<if test="YSBZK_RKSJ != null and YSBZK_RKSJ != '' ">YSBZK_RKSJ,</if> <if test="YSBZK_RKSJ != null and YSBZK_RKSJ != '' ">YSBZK_RKSJ,</if>
<if test="YSBZK_GXSJ != null and YSBZK_GXSJ != '' ">YSBZK_GXSJ,</if> <if test="YSBZK_GXSJ != null and YSBZK_GXSJ != '' ">YSBZK_GXSJ,</if>
<if test="status != null and status != '' ">status,</if>
</trim> </trim>
<trim prefix="values (" suffix=")" suffixOverrides=","> <trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="ZJLID != null and ZJLID != '' ">#{ZJLID},</if> <if test="ZJLID != null and ZJLID != '' ">#{ZJLID},</if>
@ -133,6 +135,7 @@
<if test="CDC_JYM != null and CDC_JYM != '' ">#{CDC_JYM},</if> <if test="CDC_JYM != null and CDC_JYM != '' ">#{CDC_JYM},</if>
<if test="YSBZK_RKSJ != null and YSBZK_RKSJ != '' ">#{YSBZK_RKSJ},</if> <if test="YSBZK_RKSJ != null and YSBZK_RKSJ != '' ">#{YSBZK_RKSJ},</if>
<if test="YSBZK_GXSJ != null and YSBZK_GXSJ != '' ">#{YSBZK_GXSJ},</if> <if test="YSBZK_GXSJ != null and YSBZK_GXSJ != '' ">#{YSBZK_GXSJ},</if>
<if test="status != null and status != '' ">#{status},</if>
</trim> </trim>
</insert> </insert>
@ -176,6 +179,7 @@
<if test="CDC_JYM != null and CDC_JYM != '' ">CDC_JYM=#{CDC_JYM},</if> <if test="CDC_JYM != null and CDC_JYM != '' ">CDC_JYM=#{CDC_JYM},</if>
<if test="YSBZK_RKSJ != null and YSBZK_RKSJ != '' ">YSBZK_RKSJ=#{YSBZK_RKSJ},</if> <if test="YSBZK_RKSJ != null and YSBZK_RKSJ != '' ">YSBZK_RKSJ=#{YSBZK_RKSJ},</if>
<if test="YSBZK_GXSJ != null and YSBZK_GXSJ != '' ">YSBZK_GXSJ=#{YSBZK_GXSJ},</if> <if test="YSBZK_GXSJ != null and YSBZK_GXSJ != '' ">YSBZK_GXSJ=#{YSBZK_GXSJ},</if>
<if test="status != null and status != '' ">status=#{status},</if>
</trim> </trim>
where ID = #{ID} where ID = #{ID}
</update> </update>

@ -0,0 +1,342 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ssf.mysqloracletest.mapper.VillageActualUserInfoMapper">
<resultMap type="com.ssf.mysqloracletest.domain.VillageActualUserInfo" id="VillageActualUserInfoResult">
<result property="id" column="id"/>
<result property="gaRecordId" column="ga_record_id"/>
<result property="buildingId" column="building_id"/>
<result property="userHomeId" column="user_home_id"/>
<result property="actualUserId" column="actual_user_id"/>
<result property="recordId" column="record_id"/>
<result property="gridCode" column="grid_code"/>
<result property="gridName" column="grid_name"/>
<result property="homeId" column="home_id"/>
<result property="homeCode" column="home_code"/>
<result property="policeDistrictCode" column="police_district_code"/>
<result property="policeDistrict" column="police_district"/>
<result property="policeStationName" column="police_station_name"/>
<result property="policeStationCode" column="police_station_code"/>
<result property="personCategory" column="person_category"/>
<result property="userName" column="user_name"/>
<result property="idcard" column="idcard"/>
<result property="phone" column="phone"/>
<result property="landline" column="landline"/>
<result property="sex" column="sex"/>
<result property="nation" column="nation"/>
<result property="marriage" column="marriage"/>
<result property="education" column="education"/>
<result property="birthday" column="birthday"/>
<result property="houseHoldRegister" column="house_hold_register"/>
<result property="houseHoldAddress" column="house_hold_address"/>
<result property="habitation" column="habitation"/>
<result property="blockCode" column="block_code"/>
<result property="blockName" column="block_name"/>
<result property="dateStatus" column="date_status"/>
<result property="isactive" column="isactive"/>
<result property="c1" column="c1"/>
<result property="c2" column="c2"/>
<result property="c3" column="c3"/>
<result property="c4" column="c4"/>
<result property="c5" column="c5"/>
<result property="userPic" column="user_pic"/>
<result property="picStatus" column="pic_status"/>
</resultMap>
<sql id="selectVillageActualUserInfoVo">
select
id,
ga_record_id,
building_id,
user_home_id,
actual_user_id,
record_id,
grid_code,
grid_name,
home_id,
home_code,
police_district_code,
police_district,
police_station_name,
police_station_code,
person_category,
user_name,
idcard,
phone,
landline,
sex,
nation,
marriage,
education,
birthday,
house_hold_register,
house_hold_address,
habitation,
block_code,
block_name,
date_status,
user_pic,
pic_status,
isactive,
c1,
c2,
c3,
c4,
c5
from
village_actual_user_info
</sql>
<select id="selectVillageActualUserInfoList" parameterType="com.ssf.mysqloracletest.domain.VillageActualUserInfo"
resultMap="VillageActualUserInfoResult">
<include refid="selectVillageActualUserInfoVo"/>
<where>
<if test="gaRecordId != null and gaRecordId != ''">and ga_record_id = #{gaRecordId}</if>
<if test="buildingId != null and buildingId != ''">and building_id = #{buildingId}</if>
<if test="userHomeId != null and userHomeId != ''">and user_home_id = #{userHomeId}</if>
<if test="actualUserId != null and actualUserId != ''">and actual_user_id = #{actualUserId}</if>
<if test="recordId != null and recordId != ''">and record_id = #{recordId}</if>
<if test="gridCode != null and gridCode != ''">and grid_code = #{gridCode}</if>
<if test="gridName != null and gridName != ''">and grid_name like concat('%', #{gridName}, '%')</if>
<if test="homeId != null and homeId != ''">and home_id = #{homeId}</if>
<if test="homeCode != null and homeCode != ''">and home_code = #{homeCode}</if>
<if test="policeDistrictCode != null and policeDistrictCode != ''">and police_district_code =
#{policeDistrictCode}
</if>
<if test="policeDistrict != null and policeDistrict != ''">and police_district = #{policeDistrict}</if>
<if test="policeStationName != null and policeStationName != ''">and police_station_name like concat('%',
#{policeStationName}, '%')
</if>
<if test="policeStationCode != null and policeStationCode != ''">and police_station_code =
#{policeStationCode}
</if>
<if test="personCategory != null ">and person_category = #{personCategory}</if>
<if test="userName != null and userName != ''">and user_name like concat('%', #{userName}, '%')</if>
<if test="idcard != null and idcard != ''">and idcard like concat('%', #{idcard}, '%')</if>
<if test="phone != null and phone != ''">and phone = #{phone}</if>
<if test="landline != null and landline != ''">and landline = #{landline}</if>
<if test="sex != null ">and sex = #{sex}</if>
<if test="nation != null ">and nation = #{nation}</if>
<if test="marriage != null ">and marriage = #{marriage}</if>
<if test="education != null ">and education = #{education}</if>
<if test="birthday != null ">and birthday = #{birthday}</if>
<if test="houseHoldRegister != null and houseHoldRegister != ''">and house_hold_register =
#{houseHoldRegister}
</if>
<if test="houseHoldAddress != null and houseHoldAddress != ''">and house_hold_address =
#{houseHoldAddress}
</if>
<if test="habitation != null and habitation != ''">and habitation = #{habitation}</if>
<if test="blockCode != null and blockCode != ''">and block_code = #{blockCode}</if>
<if test="blockName != null and blockName != ''">and block_name like concat('%', #{blockName}, '%')</if>
<if test="dateStatus != null and dateStatus != ''">and date_status = #{dateStatus}</if>
<if test="isactive != null ">and isactive = #{isactive}</if>
<if test="c1 != null and c1 != ''">and c1 = #{c1}</if>
<if test="c2 != null and c2 != ''">and c2 = #{c2}</if>
<if test="c3 != null and c3 != ''">and c3 = #{c3}</if>
<if test="c4 != null and c4 != ''">and c4 = #{c4}</if>
<if test="c5 != null and c5 != ''">and c5 = #{c5}</if>
</where>
</select>
<select id="selectVillageActualUserInfoListAndPicExists" parameterType="com.ssf.mysqloracletest.domain.VillageActualUserInfo"
resultMap="VillageActualUserInfoResult">
<include refid="selectVillageActualUserInfoVo"/>
where idcard like concat('%', #{idcard}, '%') and user_pic is null and pic_status is null limit 1000
</select>
<select id="selectVillageActualUserInfoById" parameterType="Long" resultMap="VillageActualUserInfoResult">
<include refid="selectVillageActualUserInfoVo"/>
where id = #{id}
</select>
<select id="selectVillageActualUserInfoByIdcard" parameterType="String" resultMap="VillageActualUserInfoResult">
<include refid="selectVillageActualUserInfoVo"/>
where idcard = #{idcard} limit 1
</select>
<insert id="insertVillageActualUserInfo" parameterType="com.ssf.mysqloracletest.domain.VillageActualUserInfo"
useGeneratedKeys="true" keyProperty="id">
insert into village_actual_user_info
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="gaRecordId != null">ga_record_id,</if>
<if test="buildingId != null">building_id,</if>
<if test="userHomeId != null">user_home_id,</if>
<if test="actualUserId != null">actual_user_id,</if>
<if test="recordId != null">record_id,</if>
<if test="gridCode != null">grid_code,</if>
<if test="gridName != null">grid_name,</if>
<if test="homeId != null">home_id,</if>
<if test="homeCode != null">home_code,</if>
<if test="policeDistrictCode != null">police_district_code,</if>
<if test="policeDistrict != null">police_district,</if>
<if test="policeStationName != null">police_station_name,</if>
<if test="policeStationCode != null">police_station_code,</if>
<if test="personCategory != null">person_category,</if>
<if test="userName != null">user_name,</if>
<if test="idcard != null">idcard,</if>
<if test="phone != null">phone,</if>
<if test="landline != null">landline,</if>
<if test="sex != null">sex,</if>
<if test="nation != null">nation,</if>
<if test="marriage != null">marriage,</if>
<if test="education != null">education,</if>
<if test="birthday != null">birthday,</if>
<if test="houseHoldRegister != null">house_hold_register,</if>
<if test="houseHoldAddress != null">house_hold_address,</if>
<if test="habitation != null">habitation,</if>
<if test="blockCode != null">block_code,</if>
<if test="blockName != null">block_name,</if>
<if test="dateStatus != null">date_status,</if>
<if test="isactive != null">isactive,</if>
<if test="c1 != null">c1,</if>
<if test="c2 != null">c2,</if>
<if test="c3 != null">c3,</if>
<if test="c4 != null">c4,</if>
<if test="c5 != null">c5,</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="gaRecordId != null">#{gaRecordId},</if>
<if test="buildingId != null">#{buildingId},</if>
<if test="userHomeId != null">#{userHomeId},</if>
<if test="actualUserId != null">#{actualUserId},</if>
<if test="recordId != null">#{recordId},</if>
<if test="gridCode != null">#{gridCode},</if>
<if test="gridName != null">#{gridName},</if>
<if test="homeId != null">#{homeId},</if>
<if test="homeCode != null">#{homeCode},</if>
<if test="policeDistrictCode != null">#{policeDistrictCode},</if>
<if test="policeDistrict != null">#{policeDistrict},</if>
<if test="policeStationName != null">#{policeStationName},</if>
<if test="policeStationCode != null">#{policeStationCode},</if>
<if test="personCategory != null">#{personCategory},</if>
<if test="userName != null">#{userName},</if>
<if test="idcard != null">#{idcard},</if>
<if test="phone != null">#{phone},</if>
<if test="landline != null">#{landline},</if>
<if test="sex != null">#{sex},</if>
<if test="nation != null">#{nation},</if>
<if test="marriage != null">#{marriage},</if>
<if test="education != null">#{education},</if>
<if test="birthday != null">#{birthday},</if>
<if test="houseHoldRegister != null">#{houseHoldRegister},</if>
<if test="houseHoldAddress != null">#{houseHoldAddress},</if>
<if test="habitation != null">#{habitation},</if>
<if test="blockCode != null">#{blockCode},</if>
<if test="blockName != null">#{blockName},</if>
<if test="dateStatus != null">#{dateStatus},</if>
<if test="isactive != null">#{isactive},</if>
<if test="c1 != null">#{c1},</if>
<if test="c2 != null">#{c2},</if>
<if test="c3 != null">#{c3},</if>
<if test="c4 != null">#{c4},</if>
<if test="c5 != null">#{c5},</if>
</trim>
</insert>
<update id="updateVillageActualUserInfo" parameterType="com.ssf.mysqloracletest.domain.VillageActualUserInfo">
update village_actual_user_info
<trim prefix="SET" suffixOverrides=",">
<if test="gaRecordId != null">ga_record_id = #{gaRecordId},</if>
<if test="buildingId != null">building_id = #{buildingId},</if>
<if test="userHomeId != null">user_home_id = #{userHomeId},</if>
<if test="actualUserId != null">actual_user_id = #{actualUserId},</if>
<if test="recordId != null">record_id = #{recordId},</if>
<if test="gridCode != null">grid_code = #{gridCode},</if>
<if test="gridName != null">grid_name = #{gridName},</if>
<if test="homeId != null">home_id = #{homeId},</if>
<if test="homeCode != null">home_code = #{homeCode},</if>
<if test="policeDistrictCode != null">police_district_code = #{policeDistrictCode},</if>
<if test="policeDistrict != null">police_district = #{policeDistrict},</if>
<if test="policeStationName != null">police_station_name = #{policeStationName},</if>
<if test="policeStationCode != null">police_station_code = #{policeStationCode},</if>
<if test="personCategory != null">person_category = #{personCategory},</if>
<if test="userName != null">user_name = #{userName},</if>
<if test="idcard != null">idcard = #{idcard},</if>
<if test="phone != null">phone = #{phone},</if>
<if test="landline != null">landline = #{landline},</if>
<if test="sex != null">sex = #{sex},</if>
<if test="nation != null">nation = #{nation},</if>
<if test="marriage != null">marriage = #{marriage},</if>
<if test="education != null">education = #{education},</if>
<if test="birthday != null">birthday = #{birthday},</if>
<if test="houseHoldRegister != null">house_hold_register = #{houseHoldRegister},</if>
<if test="houseHoldAddress != null">house_hold_address = #{houseHoldAddress},</if>
<if test="habitation != null">habitation = #{habitation},</if>
<if test="blockCode != null">block_code = #{blockCode},</if>
<if test="blockName != null">block_name = #{blockName},</if>
<if test="dateStatus != null">date_status = #{dateStatus},</if>
<if test="isactive != null">isactive = #{isactive},</if>
<if test="c1 != null">c1 = #{c1},</if>
<if test="c2 != null">c2 = #{c2},</if>
<if test="c3 != null">c3 = #{c3},</if>
<if test="c4 != null">c4 = #{c4},</if>
<if test="c5 != null">c5 = #{c5},</if>
<if test="picStatus != null">pic_status = #{picStatus},</if>
<if test="userPic != null">user_pic = #{userPic},</if>
</trim>
where id = #{id}
</update>
<update id="updateVillageActualUserInfoByIdcard"
parameterType="com.ssf.mysqloracletest.domain.VillageActualUserInfo">
update village_actual_user_info
<trim prefix="SET" suffixOverrides=",">
<if test="gaRecordId != null">ga_record_id = #{gaRecordId},</if>
<if test="buildingId != null">building_id = #{buildingId},</if>
<if test="userHomeId != null">user_home_id = #{userHomeId},</if>
<if test="actualUserId != null">actual_user_id = #{actualUserId},</if>
<if test="recordId != null">record_id = #{recordId},</if>
<if test="gridCode != null">grid_code = #{gridCode},</if>
<if test="gridName != null">grid_name = #{gridName},</if>
<if test="homeId != null">home_id = #{homeId},</if>
<if test="homeCode != null">home_code = #{homeCode},</if>
<if test="policeDistrictCode != null">police_district_code = #{policeDistrictCode},</if>
<if test="policeDistrict != null">police_district = #{policeDistrict},</if>
<if test="policeStationName != null">police_station_name = #{policeStationName},</if>
<if test="policeStationCode != null">police_station_code = #{policeStationCode},</if>
<if test="personCategory != null">person_category = #{personCategory},</if>
<if test="userName != null">user_name = #{userName},</if>
<if test="idcard != null">idcard = #{idcard},</if>
<if test="phone != null">phone = #{phone},</if>
<if test="landline != null">landline = #{landline},</if>
<if test="sex != null">sex = #{sex},</if>
<if test="nation != null">nation = #{nation},</if>
<if test="marriage != null">marriage = #{marriage},</if>
<if test="education != null">education = #{education},</if>
<if test="birthday != null">birthday = #{birthday},</if>
<if test="houseHoldRegister != null">house_hold_register = #{houseHoldRegister},</if>
<if test="houseHoldAddress != null">house_hold_address = #{houseHoldAddress},</if>
<if test="habitation != null">habitation = #{habitation},</if>
<if test="blockCode != null">block_code = #{blockCode},</if>
<if test="blockName != null">block_name = #{blockName},</if>
<if test="dateStatus != null">date_status = #{dateStatus},</if>
<if test="isactive != null">isactive = #{isactive},</if>
<if test="c2 != null">c2 = #{c2},</if>
<if test="c3 != null">c3 = #{c3},</if>
<if test="c4 != null">c4 = #{c4},</if>
<if test="c5 != null">c5 = #{c5},</if>
<if test="c1 != null and c1 != ''">c1 = #{c1New},</if>
</trim>
where idcard = #{idcard} and c1 = #{c1}
</update>
<delete id="deleteVillageActualUserInfoById" parameterType="Long">
delete from village_actual_user_info where id = #{id}
</delete>
<delete id="deleteVillageActualUserInfoByIds" parameterType="String">
delete from village_actual_user_info where id in
<foreach item="id" collection="array" open="(" separator="," close=")">
#{id}
</foreach>
</delete>
<delete id="deleteVillageActualUserInfoByUpdatetime"
parameterType="com.ssf.mysqloracletest.domain.VillageActualUserInfo">
delete from village_actual_user_info where DATE_FORMAT(updatetime, '%Y-%m-%d') != '${updatetimeV}'
</delete>
</mapper>
Loading…
Cancel
Save