package org.springblade.qinzhesync.service;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.springblade.core.tool.api.R;
|
import org.springblade.qinzhesync.utils.SnowflakeIdGenerator;
|
import org.springblade.system.feign.ISysClient;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Qualifier;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.jdbc.core.RowMapper;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* 勤哲主制分工表数据同步的服务
|
*/
|
@Service
|
@Slf4j
|
public class QinzheSyncService {
|
@Qualifier("primaryJdbcTemplate")
|
@Autowired
|
private JdbcTemplate mdmJdbcTemplate;
|
|
@Qualifier("qinzheJdbcTemplate")
|
@Autowired
|
private JdbcTemplate qinzheJdbcTemplate;
|
@Autowired
|
private ISysClient sysClient;
|
@Autowired
|
private SnowflakeIdGenerator idGen;
|
|
|
private static final String DEFAULT_QUERY_SQL = "select 产品号 cph,零件号 ljh,零件名称 ljmc,主制 zz,主制工段 zzgd,主管工艺 zggy,副管 fg,车间计划员 cjjhy,计划员 jhy from v_张立虎_2厂主制分工表";
|
private static final String QINZHE_QUERY_KEY = "QINZHE_QUERY";
|
|
/**
|
* 批量插入数据数量
|
*/
|
static final int BATCH_SIZE = 2000;//5000;
|
|
@Transactional
|
public void syncData(){
|
/*
|
Map mmdData = mdmJdbcTemplate.queryForMap("select count(*) n from mdm_machine");
|
log.info("mdm:{}",mmdData);
|
Map qinzheData = qinzheJdbcTemplate.queryForMap("select count(*) n from mdm_machine");
|
log.info("qingzhe:{}",qinzheData);
|
*/
|
cleanLocalTable();
|
//cleanQinzheDataInDivision();
|
saveQinzheFgb();
|
}
|
|
/**
|
* 将勤哲系统的数据先一次性导入mdm系统数据库临时表
|
*/
|
public void saveQinzheFgb(){
|
|
List<QinzheZzFgb> fgbList = this.qinzheJdbcTemplate.query(this.getQuerySql(),new RowMapper<QinzheZzFgb>(){
|
@Override
|
public QinzheZzFgb mapRow(ResultSet rs, int rowNum) throws SQLException {
|
QinzheZzFgb fgb = new QinzheZzFgb();
|
fgb.setCph(rs.getString("cph"));
|
fgb.setLjh(rs.getString("ljh"));;
|
fgb.setLjmc(rs.getString("ljmc"));
|
fgb.setZz(rs.getString("zz"));
|
fgb.setZzgd(rs.getString("zzgd"));
|
fgb.setZggy(rs.getString("zggy"));
|
fgb.setFg(rs.getString("fg"));
|
fgb.setCjjhy(rs.getString("cjjhy"));
|
fgb.setJhy(rs.getString("jhy"));
|
|
return fgb;
|
}
|
});
|
|
insertToLocalTable(fgbList);
|
|
//updateProduceDivision(fgbList);
|
}
|
|
/**
|
* 清除本地临时表数据
|
*/
|
private void cleanLocalTable(){
|
this.mdmJdbcTemplate.update("delete from mdm_qinzhe_fgb");
|
}
|
|
/**
|
* 将从勤哲查询到的数据插入本地临时表
|
* @param fgbList
|
*/
|
private void insertToLocalTable(List<QinzheZzFgb> fgbList) {
|
String insSql = "insert into mdm_qinzhe_fgb (cph,ljh,ljmc,zz,zzgd,zggy,fg,cjjhy,jhy,source,update_time) values (?,?,?,?,?,?,?,?,?,'QZ',CURRENT_TIMESTAMP)";
|
|
QinzheZzFgb fgb;
|
List<Object[]> args = new ArrayList<>();
|
int insertedAmount = 0;//已插入数据的数量
|
while(insertedAmount < fgbList.size()) {
|
int added = 0;
|
for(int i=insertedAmount;added<BATCH_SIZE && i<fgbList.size();i++){
|
fgb = fgbList.get(i);
|
args.add(new String[]{fgb.getCph(),fgb.getLjh(),fgb.getLjmc(),fgb.getZz(),fgb.getZzgd(),fgb.getZggy(),fgb.getFg(),fgb.getCjjhy(),fgb.getJhy()});
|
|
added ++;
|
}
|
|
mdmJdbcTemplate.batchUpdate(insSql, args);
|
args.clear();
|
insertedAmount += added;
|
}
|
}
|
|
/**
|
* 根据配置获取勤哲查询sql（参数管理里可配置）
|
* @return
|
*/
|
String getQuerySql(){
|
String querySql = DEFAULT_QUERY_SQL;
|
R<String> sqlResult = sysClient.getParamValue(QINZHE_QUERY_KEY);
|
if(sqlResult.isSuccess()){
|
querySql = sqlResult.getData();
|
}
|
return querySql;
|
}
|
}
|
