package com.aps.job.service.impl;
|
|
import cn.hutool.core.collection.ListUtil;
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONArray;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.aps.common.core.utils.StringUtils;
|
import com.aps.common.security.utils.SecurityUtils;
|
import com.aps.job.domain.ApsWeldSeamStandardJob;
|
import com.aps.job.mapper.ApsWeldSeamStandardMapper;
|
import com.aps.job.mapper.ApsWeldSeamStandardJobMapper;
|
import com.aps.job.service.IApsWeldSeamStandardJobService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.MediaType;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.atomic.AtomicLong;
|
|
/**
|
* 焊缝标准Job Service业务层处理
|
*
|
* @author user
|
* @date 2023-11-05
|
*/
|
@Slf4j
|
@Service
|
public class ApsWeldSeamStandardJobServiceImpl implements IApsWeldSeamStandardJobService
|
{
|
@Autowired
|
private ApsWeldSeamStandardJobMapper apsWeldSeamStandardJobMapper;
|
|
@Autowired
|
private ApsWeldSeamStandardMapper apsWeldSeamStandardMapper;
|
|
@Autowired
|
private RestTemplate restTemplate;
|
|
@Value("${pipingIntegrationplatform.apsWeldSeamStandard}")
|
private String apsWeldSeamStandardUrl;
|
|
/**
|
* 查询焊缝标准列表
|
*
|
* @param apsWeldSeamStandardJob 焊缝标准
|
* @return 焊缝标准集合
|
*/
|
@Override
|
public List<ApsWeldSeamStandardJob> selectApsWeldSeamStandardJobList(ApsWeldSeamStandardJob apsWeldSeamStandardJob)
|
{
|
return apsWeldSeamStandardJobMapper.selectApsWeldSeamStandardJobList(apsWeldSeamStandardJob);
|
}
|
|
/**
|
* 删除所有焊缝标准Job数据
|
*
|
* @return 结果
|
*/
|
@Override
|
public int deleteAllApsWeldSeamStandardJob()
|
{
|
return apsWeldSeamStandardJobMapper.deleteAllApsWeldSeamStandardJob();
|
}
|
|
/**
|
* 批量新增焊缝标准Job
|
*
|
* @param list 焊缝标准Job列表
|
* @return 结果
|
*/
|
@Override
|
public int batchInsertApsWeldSeamStandardJob(List<ApsWeldSeamStandardJob> list)
|
{
|
return apsWeldSeamStandardJobMapper.batchInsertApsWeldSeamStandardJob(list);
|
}
|
|
/**
|
* 同步物料标准焊缝数据
|
*
|
* @return 结果
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public boolean syncWeldSeamStandardData()
|
{
|
try {
|
log.info("开始同步物料标准焊缝数据");
|
// 使用POST方法调用接口
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_JSON);
|
|
// 准备请求参数 - 传递工厂代码字符串数组，设置为空数组
|
String[] plantCodeArray = new String[0];
|
|
// 直接使用字符串数组作为请求体
|
HttpEntity<String[]> requestEntity = new HttpEntity<>(plantCodeArray, headers);
|
|
ResponseEntity<String> responseEntity = restTemplate.postForEntity(apsWeldSeamStandardUrl, requestEntity, String.class);
|
if (!responseEntity.getStatusCode().is2xxSuccessful()) {
|
log.error("获取物料标准焊缝数据失败");
|
return false;
|
}
|
|
String responseBody = responseEntity.getBody();
|
if (StringUtils.isEmpty(responseBody)) {
|
return false;
|
}
|
|
JSONObject responseJson = JSON.parseObject(responseBody);
|
|
// 检查返回码
|
if (responseJson.getIntValue("code") != 0) {
|
return false;
|
}
|
|
// 获取接口返回的数据
|
JSONArray weldSeamList = responseJson.getJSONArray("ok");
|
if (weldSeamList == null || weldSeamList.isEmpty()) {
|
return false;
|
}
|
|
// 解析数据并转换为实体对象
|
List<ApsWeldSeamStandardJob> jobList = new ArrayList<>();
|
AtomicLong idCounter = new AtomicLong(System.currentTimeMillis()); // 使用当前时间戳作为起始ID
|
|
for (int i = 0; i < weldSeamList.size(); i++) {
|
JSONObject item = weldSeamList.getJSONObject(i);
|
|
// 使用正确的字段名称 plantCode
|
String plantCode = item.getString("plantCode");
|
|
// 获取UHP和LOD数量
|
BigDecimal uhpCount = null;
|
BigDecimal lodCount = null;
|
|
try {
|
uhpCount = item.getBigDecimal("uhpCount");
|
} catch (Exception e) {
|
// 忽略异常
|
}
|
|
try {
|
lodCount = item.getBigDecimal("lodCount");
|
} catch (Exception e) {
|
// 忽略异常
|
}
|
|
// 判断数据是否完整
|
if (StringUtils.isEmpty(plantCode)) {
|
continue;
|
}
|
|
ApsWeldSeamStandardJob job = new ApsWeldSeamStandardJob();
|
// 为id赋值，使用自增长整型
|
job.setId(idCounter.incrementAndGet());
|
job.setItemCode(plantCode); // 映射关系: plantCode -> itemCode
|
job.setHupQty(uhpCount); // 映射关系: uhpCount -> hupQty
|
job.setLodQty(lodCount); // 映射关系: lodCount -> lodQty
|
job.setDelFlag(0);
|
// 不再设置createBy和createTime
|
jobList.add(job);
|
}
|
|
if (jobList.isEmpty()) {
|
return false;
|
}
|
log.info("清空旧数据 deleteAllApsWeldSeamStandardJob");
|
// 清空旧数据
|
deleteAllApsWeldSeamStandardJob();
|
|
// 批量插入新数据
|
List<List<ApsWeldSeamStandardJob>> dataGroup = ListUtil.split(jobList, 1000);
|
for (List<ApsWeldSeamStandardJob> data : dataGroup) {
|
batchInsertApsWeldSeamStandardJob(data);
|
}
|
|
// 删除业务表数据（全量覆盖）
|
deleteAllApsWeldSeamStandard();
|
// 同步数据到业务表
|
for (List<ApsWeldSeamStandardJob> data : dataGroup) {
|
syncToBizTable(data);
|
}
|
return true;
|
} catch (Exception e) {
|
log.error("同步物料标准焊缝数据异常", e);
|
throw e;
|
}
|
}
|
|
private void deleteAllApsWeldSeamStandard() {
|
apsWeldSeamStandardMapper.deleteAllApsWeldSeamStandard();
|
}
|
/**
|
* 同步数据到业务表
|
*
|
* @param jobList 焊缝标准Job数据列表
|
*/
|
private void syncToBizTable(List<ApsWeldSeamStandardJob> jobList) {
|
try {
|
if (jobList == null || jobList.isEmpty()) {
|
return;
|
}
|
|
// 批量插入数据到业务表
|
apsWeldSeamStandardMapper.batchInsertApsWeldSeamStandard(jobList);
|
} catch (Exception e) {
|
log.error("同步物料标准焊缝数据到业务表异常", e);
|
throw e;
|
}
|
}
|
}
|
