|
@@ -2,7 +2,6 @@ package com.zfire.mall.manager.logic.k3;
|
|
|
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
-import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.zfire.mall.manager.bean.ExcelData;
|
|
@@ -14,18 +13,17 @@ import com.zfire.mall.manager.enums.ExamineStatusEnum;
|
|
|
import com.zfire.mall.manager.exception.RemoteServiceException;
|
|
|
import com.zfire.mall.manager.logic.stock.StockCommonLogic;
|
|
|
import com.zfire.mall.manager.plus.entity.*;
|
|
|
-import com.zfire.mall.manager.plus.service.KingDeeSupplierService;
|
|
|
-import com.zfire.mall.manager.plus.service.KingDeeTransferItemService;
|
|
|
-import com.zfire.mall.manager.plus.service.KingDeeTransferService;
|
|
|
-import com.zfire.mall.manager.plus.service.StockService;
|
|
|
+import com.zfire.mall.manager.plus.service.*;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
+import org.springframework.util.CollectionUtils;
|
|
|
|
|
|
import java.math.BigDecimal;
|
|
|
import java.util.*;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
@Service
|
|
|
@Slf4j
|
|
@@ -50,6 +48,9 @@ public class K3TransferLogic {
|
|
|
@Autowired
|
|
|
StockCommonLogic stockCommonLogic;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ StockCorrespondService stockCorrespondService;
|
|
|
+
|
|
|
|
|
|
// public void allSync(String orgId, String orgNumber, String startTime, String endTime) throws Exception {
|
|
|
// // 调用调拨单接口
|
|
@@ -142,9 +143,26 @@ public class K3TransferLogic {
|
|
|
public void add(KingTransferAddOrUp kingTransferAdd) {
|
|
|
kingTransferAdd.setId(IdWorker.getIdStr());
|
|
|
kingTransferAdd.setBillNo(kingTransferAdd.getId());
|
|
|
+ kingTransferAdd.setCancelStatus(ExamineStatusEnum.WAIT.getKey());
|
|
|
kingTransferAdd.insert();
|
|
|
+
|
|
|
+ List<StockCorrespond> list = stockCorrespondService.lambdaQuery().list();
|
|
|
for (KingDeeTransferItem kingDeeTransferItem : kingTransferAdd.getKingDeeTransferItems()) {
|
|
|
kingDeeTransferItem.setBillNo(kingTransferAdd.getId());
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ List<StockCorrespond> collect = list.stream().filter(item -> item.getId().equals(kingDeeTransferItem.getSrcStockId())).collect(Collectors.toList());
|
|
|
+ List<StockCorrespond> destStock = list.stream().filter(item -> item.getId().equals(kingDeeTransferItem.getDestStockId())).collect(Collectors.toList());
|
|
|
+
|
|
|
+ if (CollectionUtils.isEmpty(collect))
|
|
|
+ throw new RemoteServiceException("未找到对应仓库");
|
|
|
+
|
|
|
+
|
|
|
+ StockCorrespond stockCorrespond = collect.get(0);
|
|
|
+ StockCorrespond stockDestCorrespond = destStock.get(0);
|
|
|
+ kingDeeTransferItem.setSrcStockName(stockCorrespond.getName());
|
|
|
+ kingDeeTransferItem.setDestStockName(stockDestCorrespond.getName());
|
|
|
}
|
|
|
|
|
|
kingDeeTransferItemService.saveBatch(kingTransferAdd.getKingDeeTransferItems());
|