package com.vincent.rsf.server.manager.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.vincent.rsf.framework.exception.CoolException;
|
import com.vincent.rsf.server.api.controller.erp.params.SyncOrdersItem;
|
import com.vincent.rsf.server.manager.entity.Matnr;
|
import com.vincent.rsf.server.manager.enums.CusItemSyncMode;
|
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.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Collection;
|
import java.util.Collections;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.stream.Collectors;
|
|
/**
|
* cus_barcode_sync_view 与 man_matnr 同步（云仓通知单、无订单组托等共用）。
|
* 副库读无事务（{@link CusBarcodeSyncViewQueryService} {@code NOT_SUPPORTED}），主库写 {@link CusBarcodeSyncMatnrApplyService} {@code REQUIRES_NEW}。
|
*/
|
@Service
|
@Slf4j
|
public class CusBarcodeSyncMatnrService {
|
|
@Autowired
|
private CusBarcodeSyncViewQueryService cusBarcodeSyncViewQueryService;
|
@Autowired
|
private MatnrService matnrService;
|
@Autowired
|
private ConfigService configService;
|
@Autowired
|
private CusBarcodeSyncMatnrApplyService cusBarcodeSyncMatnrApplyService;
|
|
/** 与云仓通知单同步：按明细 matnr 查视图并写入/更新物料 */
|
public void syncFromOrderItems(List<SyncOrdersItem> orderItems, Long loginUserId) {
|
if (orderItems == null || orderItems.isEmpty()) {
|
return;
|
}
|
List<String> matnrCodes = orderItems.stream()
|
.map(SyncOrdersItem::getMatnr)
|
.filter(StringUtils::isNotBlank)
|
.map(String::trim)
|
.distinct()
|
.collect(Collectors.toList());
|
if (matnrCodes.isEmpty()) {
|
return;
|
}
|
syncAlignedWithBarcodeView(matnrCodes, buildOrderItemByMatnrCode(orderItems), loginUserId);
|
}
|
|
/** 无订单组托等：仅按物料号（与视图 barcode 一致）走同一套视图策略 */
|
public void syncFromMatnrCodes(Collection<String> matnrCodes, Long loginUserId) {
|
if (matnrCodes == null || matnrCodes.isEmpty()) {
|
return;
|
}
|
List<String> codes = matnrCodes.stream()
|
.map(StringUtils::trimToNull)
|
.filter(Objects::nonNull)
|
.distinct()
|
.collect(Collectors.toList());
|
if (codes.isEmpty()) {
|
return;
|
}
|
syncAlignedWithBarcodeView(codes, Collections.emptyMap(), loginUserId);
|
}
|
|
private static Map<String, SyncOrdersItem> buildOrderItemByMatnrCode(List<SyncOrdersItem> orderItems) {
|
Map<String, SyncOrdersItem> map = new LinkedHashMap<>();
|
if (orderItems == null) {
|
return map;
|
}
|
for (SyncOrdersItem item : orderItems) {
|
if (StringUtils.isBlank(item.getMatnr())) {
|
continue;
|
}
|
String key = StringUtils.trimToNull(item.getMatnr().trim());
|
if (key == null) {
|
continue;
|
}
|
map.putIfAbsent(key, item);
|
}
|
return map;
|
}
|
|
private CusItemSyncMode resolveCusItemSyncMode() {
|
Config c = configService.getOne(new LambdaQueryWrapper<Config>()
|
.eq(Config::getFlag, GlobalConfigCode.CUS_ITEM_SYNC_MODE)
|
.eq(Config::getDeleted, 0), false);
|
if (c == null) {
|
return CusItemSyncMode.NONE;
|
}
|
return CusItemSyncMode.fromConfig(c.getVal());
|
}
|
|
private void syncAlignedWithBarcodeView(List<String> matnrCodes, Map<String, SyncOrdersItem> orderItemByCode, Long loginUserId) {
|
CusItemSyncMode mode = resolveCusItemSyncMode();
|
if (mode == CusItemSyncMode.NONE) {
|
syncMatnrNonForceFromView(matnrCodes, orderItemByCode, loginUserId);
|
return;
|
}
|
List<Map<String, Object>> viewItems = cusBarcodeSyncViewQueryService.listByItemNos(matnrCodes);
|
for (String code : matnrCodes) {
|
if (!CusBarcodeSyncViewQueryService.orderMatnrHitsBarcodeView(code, viewItems)) {
|
throw new CoolException("物料未在视图 cus_barcode_sync_view 中：" + code);
|
}
|
}
|
cusBarcodeSyncMatnrApplyService.applyFromViewRows(viewItems, orderItemByCode, loginUserId);
|
}
|
|
private void syncMatnrNonForceFromView(List<String> matnrCodes, Map<String, SyncOrdersItem> orderItemByCode, Long loginUserId) {
|
List<Map<String, Object>> viewItems = null;
|
try {
|
viewItems = cusBarcodeSyncViewQueryService.listByItemNos(matnrCodes);
|
} catch (Exception ex) {
|
log.warn("查询 cus_barcode_sync_view 失败，将仅按物料表校验：{}", ex.getMessage());
|
}
|
if (viewItems != null && !viewItems.isEmpty()) {
|
try {
|
cusBarcodeSyncMatnrApplyService.applyFromViewRows(viewItems, orderItemByCode, loginUserId);
|
} catch (Exception ex) {
|
log.warn("按条码视图写入物料主数据失败：{}", ex.getMessage());
|
}
|
}
|
for (String code : matnrCodes) {
|
if (CusBarcodeSyncViewQueryService.orderMatnrHitsBarcodeView(code, viewItems)) {
|
continue;
|
}
|
Matnr m = findLocalMatnrForOrderCode(code);
|
if (m == null) {
|
throw new CoolException("物料不存在：" + code);
|
}
|
}
|
}
|
|
private Matnr findLocalMatnrForOrderCode(String orderMatnr) {
|
String t = StringUtils.trimToNull(orderMatnr);
|
if (t == null) {
|
return null;
|
}
|
return matnrService.getOneByCodeAndBatch(t, "");
|
}
|
|
}
|
