13 changed files with 462 additions and 239 deletions
@ -0,0 +1,32 @@
|
||||
package com.logpm.factorydata.suofeiya.pros; |
||||
|
||||
import lombok.Data; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
/** |
||||
* 老系统配置 |
||||
* @author zhaoqiaobo |
||||
* @Date 2024/5/29 |
||||
**/ |
||||
@Data |
||||
@Component |
||||
public class PushProperties { |
||||
|
||||
/** |
||||
* 回传索菲亚推送地址 |
||||
*/ |
||||
private String pushHost; |
||||
|
||||
/** |
||||
* 寄存仓库存管理接口 paStatusUrl |
||||
*/ |
||||
private String paStatusUrl; |
||||
/** |
||||
* 配送单计划接口 shipPlanUrl |
||||
*/ |
||||
private String shipPlanUrl; |
||||
|
||||
/** 是否回传推送工厂 */ |
||||
private Boolean pushEnable = true; |
||||
|
||||
} |
||||
@ -0,0 +1,14 @@
|
||||
package com.logpm.factorydata.suofeiya.service; |
||||
|
||||
/** |
||||
* 索菲亚工厂数据处理 服务类 |
||||
* |
||||
* @Author zqb |
||||
* @Date 2024/4/26 |
||||
**/ |
||||
public interface FactoryDataService { |
||||
|
||||
void factoryOrder(String msg); |
||||
|
||||
void nodeDataPush(String msg); |
||||
} |
||||
@ -0,0 +1,335 @@
|
||||
package com.logpm.factorydata.suofeiya.service.impl; |
||||
|
||||
import cn.hutool.core.bean.BeanUtil; |
||||
import cn.hutool.core.collection.CollUtil; |
||||
import cn.hutool.core.date.DateUtil; |
||||
import cn.hutool.core.io.FileUtil; |
||||
import cn.hutool.core.util.CharsetUtil; |
||||
import cn.hutool.core.util.EnumUtil; |
||||
import cn.hutool.core.util.ObjectUtil; |
||||
import cn.hutool.core.util.StrUtil; |
||||
import cn.hutool.core.util.URLUtil; |
||||
import cn.hutool.crypto.digest.MD5; |
||||
import cn.hutool.http.HttpUtil; |
||||
import cn.hutool.json.JSONArray; |
||||
import cn.hutool.json.JSONObject; |
||||
import cn.hutool.json.JSONUtil; |
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.logpm.factorydata.enums.SaxStatusEnums; |
||||
import com.logpm.factorydata.suofeiya.entity.DeliveryNoteEntity; |
||||
import com.logpm.factorydata.suofeiya.entity.FactoryOrderLogEntity; |
||||
import com.logpm.factorydata.suofeiya.entity.OrderInfoEntity; |
||||
import com.logpm.factorydata.suofeiya.entity.PackageInfoEntity; |
||||
import com.logpm.factorydata.suofeiya.enums.FactoryNodeEnums; |
||||
import com.logpm.factorydata.suofeiya.enums.NodeMappingEnums; |
||||
import com.logpm.factorydata.suofeiya.enums.NodeNeedEnums; |
||||
import com.logpm.factorydata.suofeiya.pros.FactoryDataSuoFeiYaProperties; |
||||
import com.logpm.factorydata.suofeiya.pros.OldProperties; |
||||
import com.logpm.factorydata.suofeiya.service.DeliveryNoteService; |
||||
import com.logpm.factorydata.suofeiya.service.FactoryDataService; |
||||
import com.logpm.factorydata.suofeiya.service.FactoryOrderLogService; |
||||
import com.logpm.factorydata.suofeiya.service.OrderInfoService; |
||||
import com.logpm.factorydata.suofeiya.service.PackageInfoService; |
||||
import com.logpm.factorydata.suofeiya.vo.DeliveryNoteVO; |
||||
import com.logpm.factorydata.suofeiya.vo.FactoryAuthVO; |
||||
import com.logpm.factorydata.suofeiya.vo.OrderInfoVO; |
||||
import com.logpm.factorydata.suofeiya.vo.PackageInfoVO; |
||||
import com.logpm.factorydata.vo.PushData; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.springblade.common.constant.WorkNodeEnums; |
||||
import org.springblade.core.secure.utils.AuthUtil; |
||||
import org.springframework.stereotype.Service; |
||||
import org.springframework.transaction.annotation.Transactional; |
||||
|
||||
import java.util.ArrayList; |
||||
import java.util.HashMap; |
||||
import java.util.HashSet; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
import java.util.Set; |
||||
import java.util.stream.Collectors; |
||||
|
||||
/** |
||||
* 索菲亚工厂数据处理 业务实现类 |
||||
* |
||||
* @Author zqb |
||||
* @Date 2024/4/26 |
||||
**/ |
||||
@Slf4j |
||||
@Service |
||||
@AllArgsConstructor |
||||
public class FactoryDataServiceImpl implements FactoryDataService { |
||||
|
||||
private final DeliveryNoteService deliveryNoteService; |
||||
private final OrderInfoService orderInfoService; |
||||
private final PackageInfoService packageInfoService; |
||||
private final FactoryOrderLogService logService; |
||||
private final OldProperties oldProperties; |
||||
private final FactoryDataSuoFeiYaProperties dataSuoFeiYaProperties; |
||||
|
||||
@Override |
||||
@Transactional(rollbackFor = Exception.class) |
||||
public void factoryOrder(String msg) { |
||||
if (StrUtil.isEmpty(msg)) { |
||||
log.error("消息内容为空"); |
||||
return; |
||||
} |
||||
FactoryOrderLogEntity logEntity = JSONUtil.toBean(msg, FactoryOrderLogEntity.class); |
||||
if (ObjectUtil.isEmpty(logEntity)) { |
||||
log.error("消息内容为空"); |
||||
return; |
||||
} |
||||
// 去 minio 下载文件到本地，然后解析文件内容为实体对象
|
||||
DeliveryNoteVO vo = null; |
||||
Long logId = logEntity.getId(); |
||||
String logUrl = logEntity.getLogUrl(); |
||||
if (StrUtil.isNotEmpty(logUrl)) { |
||||
List<String> res = new ArrayList<>(); |
||||
FileUtil.readLines(URLUtil.url(logUrl), CharsetUtil.CHARSET_UTF_8, res); |
||||
if (CollUtil.isNotEmpty(res)) { |
||||
String content = res.get(0); |
||||
if (StrUtil.isNotEmpty(content)) { |
||||
vo = JSONUtil.toBean(content, DeliveryNoteVO.class); |
||||
} |
||||
} |
||||
} |
||||
if (ObjectUtil.isNotNull(vo)) { |
||||
// 1 解析数据保存入库
|
||||
// 车次号唯一
|
||||
String logisticID = vo.getLogisticID(); |
||||
List<DeliveryNoteEntity> list = deliveryNoteService.list(Wrappers.<DeliveryNoteEntity>lambdaQuery() |
||||
.eq(DeliveryNoteEntity::getLogisticID, logisticID)); |
||||
if (CollUtil.isNotEmpty(list)) { |
||||
log.error("车次号{} 数据已经处理过了, logId: {}", logisticID, logId); |
||||
return; |
||||
} |
||||
// 处理额外的字段
|
||||
if (CollUtil.isNotEmpty(vo.getOrderExtendFields())) { |
||||
vo.setOrderExtendField(JSONUtil.toJsonStr(vo.getOrderExtendFields())); |
||||
} |
||||
vo.setLogId(ObjectUtil.isNotEmpty(logId) ? logId.toString() : null); |
||||
vo.setTenantCode(AuthUtil.getTenantId()); |
||||
deliveryNoteService.save(vo); |
||||
List<OrderInfoVO> orderInfos = vo.getOrderInfo(); |
||||
if (CollUtil.isNotEmpty(orderInfos)) { |
||||
List<OrderInfoEntity> infoEntities = new ArrayList<>(); |
||||
for (OrderInfoVO orderInfo : orderInfos) { |
||||
OrderInfoEntity orderInfoEntity = new OrderInfoEntity(); |
||||
BeanUtil.copyProperties(orderInfo, orderInfoEntity); |
||||
orderInfoEntity.setLogId(ObjectUtil.isNotEmpty(logId) ? logId.toString() : null); |
||||
orderInfoEntity.setDeliveryNoteId(vo.getId().toString()); |
||||
orderInfoEntity.setTenantCode(AuthUtil.getTenantId()); |
||||
infoEntities.add(orderInfoEntity); |
||||
} |
||||
orderInfoService.saveBatch(infoEntities); |
||||
} |
||||
if (CollUtil.isNotEmpty(vo.getPackageInfo())) { |
||||
List<PackageInfoEntity> packageInfoEntities = new ArrayList<>(); |
||||
for (PackageInfoVO packageInfo : vo.getPackageInfo()) { |
||||
PackageInfoEntity entity = new PackageInfoEntity(); |
||||
BeanUtil.copyProperties(packageInfo, entity); |
||||
entity.setDeliveryNoteId(vo.getId().toString()); |
||||
entity.setLogId(ObjectUtil.isNotEmpty(logId) ? logId.toString() : null); |
||||
entity.setTenantCode(AuthUtil.getTenantId()); |
||||
packageInfoEntities.add(entity); |
||||
} |
||||
packageInfoService.saveBatch(packageInfoEntities); |
||||
} |
||||
// 2 构建暂存单，发送 mq 消息
|
||||
FactoryOrderLogEntity logEntity1 = new FactoryOrderLogEntity(); |
||||
logEntity1.setSaxStatus(SaxStatusEnums.SUCCESS.getCode()); |
||||
logEntity1.setId(logId); |
||||
logService.saveOrUpdate(logEntity1); |
||||
// 处理暂存单
|
||||
deliveryNoteService.buildAdvance(vo); |
||||
} |
||||
} |
||||
|
||||
@Override |
||||
public void nodeDataPush(String msg) { |
||||
if (checkData(msg)) { |
||||
return; |
||||
} |
||||
JSONObject entries = JSONUtil.parseObj(msg); |
||||
// 节点
|
||||
String node = entries.getStr("node"); |
||||
String main = entries.getStr("main"); |
||||
WorkNodeEnums workNodeEnums = EnumUtil.fromString(WorkNodeEnums.class, node); |
||||
FactoryNodeEnums factoryNode = NodeMappingEnums.getFactoryByNodeAndStatus(workNodeEnums); |
||||
// 2 获取业务数据
|
||||
List<PushData> content = entries.getBeanList("content", PushData.class); |
||||
Map<String, Set<String>> packageCodeMap = new HashMap<>(); |
||||
if (CollUtil.isNotEmpty(content)) { |
||||
List<String> packageCodes = content.stream().map(PushData::getPackageCode).collect(Collectors.toList()); |
||||
if (CollUtil.isNotEmpty(packageCodes)) { |
||||
List<PackageInfoEntity> list = packageInfoService.list(Wrappers.<PackageInfoEntity>lambdaQuery() |
||||
.select(PackageInfoEntity::getPaNo, PackageInfoEntity::getOrderType) |
||||
.in(PackageInfoEntity::getPaNo, packageCodes) |
||||
.eq(PackageInfoEntity::getTenantCode, AuthUtil.getTenantId()) |
||||
); |
||||
if (CollUtil.isNotEmpty(list)) { |
||||
for (PackageInfoEntity packageInfoEntity : list) { |
||||
if (packageCodeMap.containsKey(packageInfoEntity.getOrderType())) { |
||||
packageCodeMap.get(packageInfoEntity.getOrderType()).add(packageInfoEntity.getPaNo()); |
||||
} else { |
||||
Set<String> objects = new HashSet<>(); |
||||
objects.add(packageInfoEntity.getPaNo()); |
||||
packageCodeMap.put(packageInfoEntity.getOrderType(), objects); |
||||
} |
||||
} |
||||
} |
||||
} |
||||
} |
||||
FactoryAuthVO authVO = deliveryNoteService.findFactoryAuthByTenantCode(AuthUtil.getTenantId()); |
||||
if (ObjectUtil.isEmpty(authVO)) { |
||||
return; |
||||
} |
||||
String companyCode = authVO.getCompanyCode(); |
||||
String appKey = authVO.getAppKey(); |
||||
// 获取毫秒值
|
||||
Long time = DateUtil.current(); |
||||
if (!ObjectUtil.equal(workNodeEnums.getCode(), NodeNeedEnums.PLAN_DISTRIBUTION.getCode()) || !ObjectUtil.equal(workNodeEnums.getCode(), NodeNeedEnums.PLAN_BILLOFLADING.getCode())) { |
||||
// 推送入库出库数据
|
||||
// 按订单号和运单号进行分组
|
||||
if (CollUtil.isNotEmpty(content)) { |
||||
for (Map.Entry<String, Set<String>> entry : packageCodeMap.entrySet()) { |
||||
String key = entry.getKey(); |
||||
Set<String> value = entry.getValue(); |
||||
JSONObject jsons = new JSONObject(); |
||||
List<JSONObject> packages = new ArrayList<>(); |
||||
for (PushData pushData : content) { |
||||
String packageCode = pushData.getPackageCode(); |
||||
// 新系统自动生成的包条码，不用回传
|
||||
if (StrUtil.isNotEmpty(packageCode) && packageCode.startsWith("HT")) { |
||||
if (packageCode.length() == 22) { |
||||
continue; |
||||
} |
||||
} |
||||
if (value.contains(packageCode)) { |
||||
JSONObject js = new JSONObject(); |
||||
js.set("paNo", packageCode); |
||||
js.set("subinventoryCode", ""); |
||||
js.set("locatorCode", ""); |
||||
js.set("updateDate", DateUtil.now()); |
||||
js.set("paStausNo", "正常"); |
||||
js.set("logisticsStatus", factoryNode.getText()); |
||||
packages.add(js); |
||||
} |
||||
} |
||||
jsons.set("packageInfo", new JSONArray(packages)); |
||||
jsons.set("orderType", key); |
||||
String jsonStr = JSONUtil.toJsonStr(jsons); |
||||
if (oldProperties.getEnable()) { |
||||
try { |
||||
log.info("推送节点数据：{}", jsonStr); |
||||
String post = HttpUtil.post(oldProperties.getPushNodeUrl(), jsonStr); |
||||
log.info("推送结果：{}", post); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
log.error("推送节点数据错误：{}", e); |
||||
} |
||||
} |
||||
if (dataSuoFeiYaProperties.getPush().getPushEnable()) { |
||||
String paStatusUrl = dataSuoFeiYaProperties.getPush().getPaStatusUrl(); |
||||
sendFactory(companyCode, jsonStr, time, appKey, paStatusUrl); |
||||
} |
||||
} |
||||
} |
||||
} else { |
||||
// 推送配送单计划
|
||||
if (CollUtil.isNotEmpty(content)) { |
||||
for (Map.Entry<String, Set<String>> entry : packageCodeMap.entrySet()) { |
||||
String key = entry.getKey(); |
||||
Set<String> value = entry.getValue(); |
||||
JSONObject jsons = new JSONObject(); |
||||
List<String> packages = new ArrayList<>(); |
||||
for (PushData pushData : content) { |
||||
String packageCode = pushData.getPackageCode(); |
||||
// 新系统自动生成的包条码，不用回传
|
||||
if (StrUtil.isNotEmpty(packageCode) && packageCode.startsWith("HT")) { |
||||
if (packageCode.length() == 22) { |
||||
continue; |
||||
} |
||||
} |
||||
if (value.contains(packageCode)) { |
||||
packages.add(pushData.getPackageCode()); |
||||
} |
||||
} |
||||
if (StrUtil.isNotEmpty(main)) { |
||||
JSONObject jsonObject = JSONUtil.parseObj(main); |
||||
jsons.set("shipPlanNo", jsonObject.getStr("trainNumber")); |
||||
jsons.set("receiver", jsonObject.getStr("receiver")); |
||||
jsons.set("receiveAddr", jsonObject.getStr("receiveAddr")); |
||||
jsons.set("receiveTel", jsonObject.getStr("receiveTel")); |
||||
jsons.set("planDeliveryDate", jsonObject.getStr("planDeliveryDate")); |
||||
} |
||||
jsons.set("paNo", JSONUtil.toJsonStr(packages)); |
||||
jsons.set("remark", ""); |
||||
jsons.set("orderExtendFields", new JSONArray()); |
||||
jsons.set("orderType", key); |
||||
String jsonStr = JSONUtil.toJsonStr(jsons); |
||||
if (oldProperties.getEnable()) { |
||||
try { |
||||
log.info("推送节点数据：{}", jsonStr); |
||||
String post = HttpUtil.post(oldProperties.getPushNodePlanUrl(), jsonStr); |
||||
log.info("推送结果：{}", post); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
log.error("推送节点数据错误：{}", e); |
||||
} |
||||
} |
||||
if (dataSuoFeiYaProperties.getPush().getPushEnable()) { |
||||
String paStatusUrl = dataSuoFeiYaProperties.getPush().getShipPlanUrl(); |
||||
sendFactory(companyCode, jsonStr, time, appKey, paStatusUrl); |
||||
} |
||||
} |
||||
} |
||||
} |
||||
} |
||||
|
||||
private void sendFactory(String companyCode, String jsonStr, Long time, String appKey, String paStatusUrl) { |
||||
try { |
||||
Map<String, Object> param = new HashMap<>(); |
||||
param.put("companyCode", companyCode); |
||||
param.put("params", jsonStr); |
||||
param.put("timestamp", time); |
||||
// 加密
|
||||
String digest = MD5.create().digestHex(jsonStr + appKey + time); |
||||
param.put("digest", digest); |
||||
log.info("推送节点数据：{}", JSONUtil.toJsonStr(param)); |
||||
String post = HttpUtil.post(dataSuoFeiYaProperties.getPush().getPushHost() + paStatusUrl, param); |
||||
log.info("推送结果：{}", post); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
log.error("推送节点数据错误：{}", e); |
||||
} |
||||
} |
||||
|
||||
private boolean checkData(String msg) { |
||||
if (StrUtil.isEmpty(msg)) { |
||||
return true; |
||||
} |
||||
if (!msg.contains("brand") || !msg.contains("content") || !msg.contains("node")) { |
||||
return true; |
||||
} |
||||
JSONObject entries = JSONUtil.parseObj(msg); |
||||
String node = entries.getStr("node"); |
||||
if (StrUtil.isEmpty(node)) { |
||||
return true; |
||||
} |
||||
// 不是志邦需要的节点数据直接不处理
|
||||
if (!EnumUtil.contains(NodeNeedEnums.class, node)) { |
||||
return true; |
||||
} |
||||
WorkNodeEnums workNodeEnums = EnumUtil.fromString(WorkNodeEnums.class, node); |
||||
if (ObjectUtil.isEmpty(workNodeEnums)) { |
||||
return true; |
||||
} |
||||
List<JSONObject> content = entries.getBeanList("content", JSONObject.class); |
||||
if (CollUtil.isEmpty(content)) { |
||||
return true; |
||||
} |
||||
return false; |
||||
} |
||||
} |
||||
Loading…
Reference in new issue