package com.vincent.rsf.server.manager.schedules;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.vincent.rsf.framework.common.Cools;
|
import com.vincent.rsf.framework.exception.CoolException;
|
import com.vincent.rsf.server.api.config.RemotesInfoProperties;
|
import com.vincent.rsf.server.api.entity.CommonResponse;
|
import com.vincent.rsf.server.api.entity.constant.RcsConstant;
|
import com.vincent.rsf.server.manager.entity.BasStation;
|
import com.vincent.rsf.server.manager.service.impl.BasStationServiceImpl;
|
import com.vincent.rsf.server.system.constant.GlobalConfigCode;
|
import com.vincent.rsf.server.system.entity.Config;
|
import com.vincent.rsf.server.system.service.ConfigService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.HttpMethod;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
|
/**
|
* @author Munch D. Luffy
|
* @date 2026/03/23
|
* 自动同步至MES
|
*/
|
@Slf4j
|
@Component
|
public class SynchronizationToMESSchedules {
|
|
@Autowired
|
private ConfigService configService;
|
@Autowired
|
private BasStationServiceImpl basStationService;
|
@Autowired
|
private RestTemplate restTemplate;
|
@Autowired
|
private RemotesInfoProperties.WmsOpenApi wmsOpenApi;
|
|
/**
|
* @author Munch D. Luffy
|
* @date 2026/01/15
|
* @description: 缓存区域自动生成移库任务
|
* @version 1.0
|
*/
|
@Scheduled(cron = "0 0/01 * * * ? ")
|
@Transactional(rollbackFor = Exception.class)
|
public void siteSynchronizationToMES() throws Exception {
|
Config config = configService.getOne(new LambdaQueryWrapper<Config>().eq(Config::getFlag, GlobalConfigCode.AUTO_SITE_SYNCHRONIZATION_TO_MES));
|
if (Cools.isEmpty(config) || !Boolean.parseBoolean(config.getVal())) {
|
return;
|
}
|
|
String autoSiteSynchronizationToMesValue = configService.getVal(GlobalConfigCode.AUTO_SITE_SYNCHRONIZATION_TO_MES_VALUE, String.class);
|
if (Cools.isEmpty(autoSiteSynchronizationToMesValue)) {
|
return;
|
}
|
Integer autoValue = Integer.parseInt(autoSiteSynchronizationToMesValue);
|
if (autoValue < 0) {
|
List<BasStation> basStationList = basStationService.list();
|
syncStationsToMes(basStationList);
|
} else if (autoValue > 0) {
|
List<BasStation> basStationList = basStationService.list();
|
syncStationsToMes(basStationList);
|
autoValue = autoValue - 1;
|
configService.setVal(GlobalConfigCode.AUTO_SITE_SYNCHRONIZATION_TO_MES_VALUE, String.valueOf(autoValue));
|
} else {
|
configService.setVal(GlobalConfigCode.AUTO_SITE_SYNCHRONIZATION_TO_MES, false);
|
}
|
}
|
|
private void syncStationsToMes(List<BasStation> basStationList) {
|
if (Cools.isEmpty(basStationList)) {
|
log.info("站点同步至MES跳过：站点列表为空");
|
return;
|
}
|
if (Cools.isEmpty(wmsOpenApi) || Cools.isEmpty(wmsOpenApi.getHost()) || Cools.isEmpty(wmsOpenApi.getPort())) {
|
throw new CoolException("open-api配置缺失，无法同步站点信息到MES");
|
}
|
|
List<Map<String, Object>> params = new ArrayList<>();
|
for (BasStation basStation : basStationList) {
|
if (Cools.isEmpty(basStation) || Cools.isEmpty(basStation.getStationName())) {
|
continue;
|
}
|
Map<String, Object> item = new HashMap<>();
|
item.put("ConnPortCode", basStation.getStationName());
|
item.put("ConnPortName", Cools.isEmpty(basStation.getStationId()) ? basStation.getStationName() : basStation.getStationId());
|
item.put("WorkshopCode", "YZ");
|
item.put("WorkshopName", "银座车间");
|
item.put("ProductionLineCode", "YZ");
|
item.put("ProductionLineName", "银座仓库");
|
item.put("CreatedBy", "WMSSystem");
|
item.put("IsValid", Objects.equals(basStation.getStatus(), 1));
|
params.add(item);
|
}
|
|
if (params.isEmpty()) {
|
log.info("站点同步至MES跳过：无可同步站点数据");
|
return;
|
}
|
|
String url = wmsOpenApi.getHost() + ":" + wmsOpenApi.getPort() + RcsConstant.SITE_SYNCHRONIZATION_TO_MES;
|
HttpHeaders headers = new HttpHeaders();
|
headers.add("Content-Type", "application/json");
|
headers.add("api-version", "v2.0");
|
HttpEntity<List<Map<String, Object>>> httpEntity = new HttpEntity<>(params, headers);
|
|
log.info("站点同步至MES开始，请求地址：{}，请求参数条数：{}", url, params.size());
|
ResponseEntity<CommonResponse> response = restTemplate.exchange(url, HttpMethod.POST, httpEntity, CommonResponse.class);
|
CommonResponse body = response.getBody();
|
log.info("站点同步至MES返回结果：{}", JSONObject.toJSONString(body));
|
|
if (Cools.isEmpty(body)) {
|
throw new CoolException("站点同步至MES失败：返回结果为空");
|
}
|
if (!Objects.equals(body.getCode(), 200)) {
|
throw new CoolException("站点同步至MES失败：" + body.getMsg());
|
}
|
}
|
}
|
