package cn.huge.module.sync.service;
|
|
import cn.huge.module.client.api.impl.CustClientImpl;
|
import cn.huge.module.sync.dao.mapper.SyncMapper;
|
import cn.huge.module.sync.domain.source.SourceCtAccount;
|
import cn.huge.module.sync.domain.source.SourceCtUnit;
|
import cn.huge.module.sync.domain.target.TargetCtAccount;
|
import cn.huge.module.sync.domain.target.TargetCtUnit;
|
import org.apache.commons.beanutils.BeanUtils;
|
import org.apache.commons.beanutils.ConvertUtils;
|
import org.apache.commons.beanutils.converters.DateConverter;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.domain.PageRequest;
|
import org.springframework.data.domain.Sort;
|
import org.springframework.stereotype.Service;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.lang.reflect.Field;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
|
/**
|
* @author liyj
|
* @version 1.0.0
|
* @title: 客户用户账号表业务逻辑处理
|
* @Description 客户用户账号表业务逻辑处理
|
* @company hugeinfo
|
* @Time 2024-08-17 15:30:56
|
*/
|
@Slf4j
|
@Service
|
@Transactional(rollbackFor = Exception.class)
|
public class SyncService {
|
@Autowired
|
private SyncMapper syncMapper;
|
@Autowired
|
private CustClientImpl custClient;
|
|
private static final String MYSQL_TABLE = "dyh_ct_account";
|
|
public void syncData() {
|
try {
|
List<SourceCtAccount> sourceTableList = new ArrayList<>();
|
|
int page = 1;
|
int size = 1000;
|
|
//查询mysql总量
|
int total = syncMapper.countData(MYSQL_TABLE);
|
|
//查出最大页数
|
int maxPage = 1;
|
maxPage = (total / size);
|
if (0 != total % size) {
|
maxPage += 1;
|
}
|
|
for (int i = 1; i <= maxPage; i++) {
|
// 查询MySQL表结构
|
Sort sort = Sort.by(Sort.Direction.ASC, "create_time");
|
PageRequest pageRequest = PageRequest.of(page-1, size, sort);
|
sourceTableList = syncMapper.pageInfo(MYSQL_TABLE, pageRequest);
|
page++;
|
|
List<TargetCtAccount> targetTableList = new ArrayList<>();
|
for(SourceCtAccount sourceTable: sourceTableList){
|
TargetCtAccount tagetTable = new TargetCtAccount();
|
ConvertUtils.register(new DateConverter(null), java.util.Date.class);
|
BeanUtils.copyProperties(tagetTable, sourceTable);
|
// for(Field field: sourceCtUnit.getClass().getDeclaredFields()){
|
// convertType(field.get(sourceCtUnit), field.getName(), targetCtUnit);
|
// }
|
//字段名不一致，手动set
|
tagetTable.setCipher(sourceTable.getCipher());
|
tagetTable.setAccType(1);
|
targetTableList.add(tagetTable);
|
}
|
if(CollectionUtils.isNotEmpty(targetTableList)){
|
custClient.saveTableList1(targetTableList);
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 时间转换的时候，调用初始化，时间类型转换
|
* 使用：直接在实体中加上一个注解形式。
|
*/
|
public static void initDate(){
|
// 时间注册
|
DateConverter converter = new DateConverter(null);
|
converter.setPattern(new String("yyyy-MM-dd HH:mm:ss"));
|
ConvertUtils.register(converter, Date.class);
|
}
|
|
|
public void convertType(Object value, String columnName, TargetCtUnit targetCtUnit) {
|
if (value == null) {
|
targetCtUnit.setUnitType(Integer.valueOf("NULL"));
|
}else if("unitType".equals(columnName) || "joinWay".equals(columnName) || "findStatus".equals(columnName)
|
|| "dispStatus".equals(columnName)|| "deleteStatus".equals(columnName)){
|
targetCtUnit.setUnitType(Integer.parseInt((String) value));
|
}
|
|
}
|
}
|
