From b003a49794f49a329e2702918ecfc8d14b371d0d Mon Sep 17 00:00:00 2001
From: chen.lin <1442464845@qq.com>
Date: 星期三, 04 三月 2026 14:51:25 +0800
Subject: [PATCH] 云仓WMS接口流程
---
rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/ScheduleJobs.java | 230 ++++++++++++++++++++++++++++++++++++++++++++++++++------
1 files changed, 203 insertions(+), 27 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/ScheduleJobs.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/ScheduleJobs.java
index a44caf1..9eaaa0e 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/ScheduleJobs.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/ScheduleJobs.java
@@ -1,15 +1,25 @@
package com.vincent.rsf.server.manager.schedules;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.vincent.rsf.framework.common.Cools;
import com.vincent.rsf.framework.exception.CoolException;
import com.vincent.rsf.server.common.config.SysStockProperties;
-import com.vincent.rsf.server.common.utils.CommonUtil;
import com.vincent.rsf.server.common.utils.DateUtils;
import com.vincent.rsf.server.manager.entity.*;
+import com.vincent.rsf.server.manager.enums.*;
import com.vincent.rsf.server.manager.service.*;
+import com.vincent.rsf.server.manager.service.impl.WarehouseAreasItemServiceImpl;
+import com.vincent.rsf.server.system.constant.GlobalConfigCode;
import com.vincent.rsf.server.system.constant.SerialRuleCode;
+import com.vincent.rsf.server.system.entity.Config;
+import com.vincent.rsf.server.system.entity.FieldsItem;
+import com.vincent.rsf.server.system.service.ConfigService;
+import com.vincent.rsf.server.system.service.FieldsItemService;
+import com.vincent.rsf.server.system.service.impl.FieldsItemServiceImpl;
import com.vincent.rsf.server.system.utils.SerialRuleUtils;
import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@@ -17,6 +27,7 @@
import javax.annotation.Resource;
import java.util.ArrayList;
+import java.util.Collections;
import java.util.Date;
import java.util.List;
import java.util.Objects;
@@ -35,35 +46,197 @@
private PurchaseService purchaseService;
@Autowired
private PurchaseItemService purchaseItemService;
-
@Autowired
private AsnOrderService asnOrderService;
-
@Autowired
private MatnrService matnrService;
-
@Autowired
private AsnOrderItemService asnOrderItemService;
-
@Resource
private SysStockProperties flowProperties;
- /**
+ @Autowired
+ private ConfigService configService;
+ @Autowired
+ private WarehouseAreasService warehouseAreasService;
+ @Autowired
+ private WarehouseAreasItemServiceImpl warehouseAreasItemService;
+ @Autowired
+ private CompanysService companysService;
+ @Autowired
+ private TransferService transferService;
+ @Autowired
+ private OutStockService outStockService;
+ @Autowired
+ private FieldsItemService fieldsItemService;
+
+// /**
+// * @author Ryan
+// * @date 2025/5/9
+// * @description: 鐩存帴缁勬墭寮�鍏充负true锛屽皢鏀惰揣鍗曠洿鎺ュ姞鍏ヤ复鏃跺簱瀛�
+// * @version 1.0
+// */
+// @Scheduled(cron = "0/25 * * * * ?")
+// @Transactional(rollbackFor = Exception.class)
+// public synchronized void IgnoreReceipt() {
+// Config config = configService.getOne(new LambdaQueryWrapper<Config>().eq(Config::getFlag, GlobalConfigCode.DIRECT_WAIT_PAKIN));
+// if (Objects.isNull(config)) {
+// return;
+// }
+// if (!Boolean.parseBoolean(config.getVal())) {
+// return;
+// }
+// //鑷姩鏀惰揣鍗�
+// List<WkOrder> orders = asnOrderService.list(new LambdaQueryWrapper<WkOrder>()
+// .eq(WkOrder::getType, OrderType.ORDER_IN.type)
+// .eq(WkOrder::getExceStatus, AsnExceStatus.ASN_EXCE_STATUS_UN_EXCE.val));
+// if (!orders.isEmpty()) {
+// for (WkOrder order : orders) {
+// if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER_TERANSFER.type)) {
+// WkOrder one = outStockService.getOne(new LambdaQueryWrapper<WkOrder>()
+// .eq(WkOrder::getPoCode, order.getPoCode())
+// .eq(WkOrder::getWkType, OrderWorkType.ORDER_WORK_TYPE_STOCK_TERANSFER.type));
+// if (Objects.isNull(one)) {
+// throw new CoolException("鏁版嵁閿欒");
+// }
+// if (!one.getExceStatus().equals(AsnExceStatus.OUT_STOCK_STATUS_TASK_DONE.val)) {
+// continue;
+// }
+// }
+//
+// List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, order.getId()));
+// if (orderItems.isEmpty()) {
+// return;
+// }
+// // 鏀惰揣鍖哄凡鍋滅敤锛氫笉鍐嶅啓鍏ユ敹璐у尯锛屼粎鏇存柊鍗曟嵁鐘舵�佷笌鏁伴噺
+//// List<WarehouseAreas> receiptAreas = warehouseAreasService.list(new LambdaQueryWrapper<WarehouseAreas>()
+//// .eq(WarehouseAreas::getType, WarehouseAreasType.WAREHOUSE_AREAS_TYPE_RECEIPT.type));
+//// WarehouseAreas receiptArea = receiptAreas.isEmpty() ? null : receiptAreas.get(0);
+//// List<WarehouseAreasItem> items = new ArrayList<>();
+// for (WkOrderItem item : orderItems) {
+//// Long areaId = receiptArea == null ? null : receiptArea.getId();
+//// String areaName = receiptArea == null ? null : receiptArea.getName();
+//// WarehouseAreasItem param = new WarehouseAreasItem();
+//// BeanUtils.copyProperties(item, param);
+//// param.setAsnCode(order.getCode()).setAsnId(order.getId());
+//// if (areaId != null) {
+//// param.setAreaId(areaId).setAreaName(areaName);
+//// }
+//// items.add(param);
+//// Matnr matnr = matnrService.getOne(new LambdaQueryWrapper<Matnr>().eq(Matnr::getId, item.getMatnrId()));
+//// if (Objects.isNull(matnr)) {
+//// throw new CoolException("鐗╂枡涓嶅瓨鍦紒锛�");
+//// }
+//// if (receiptArea != null) {
+//// try {
+//// updateReceipt(receiptArea, item, order, matnr);
+//// } catch (Exception e) {
+//// throw new CoolException(e.getMessage());
+//// }
+//// }
+// if (!asnOrderItemService.update(new LambdaUpdateWrapper<WkOrderItem>().set(WkOrderItem::getQty, item.getAnfme()).eq(WkOrderItem::getId, item.getId()))) {
+// throw new CoolException("鏀惰揣鍗曟槑缁嗗畬鎴愭暟閲忎慨鏀瑰け璐ワ紒锛�");
+// }
+// }
+//// if (!warehouseAreasItemService.saveBatch(items)) {
+//// throw new CoolException("鏀惰揣鍗曚繚瀛樿嚦鏀惰揣鍖烘墽琛屽け璐ワ紒锛�");
+//// }
+//
+// if (!asnOrderService.update(new LambdaUpdateWrapper<WkOrder>()
+// .set(WkOrder::getQty, order.getAnfme())
+// .set(WkOrder::getExceStatus, AsnExceStatus.ASN_EXCE_STATUS_RECEIPT_DONE.val)
+// .eq(WkOrder::getId, order.getId()))) {
+// throw new CoolException("鏀惰揣鍗曠姸鎬佷慨鏀瑰け璐ワ紒锛�");
+// }
+// }
+// }
+// }
+
+
+ /** 鏀惰揣鍖哄凡鍋滅敤锛屾柟娉曟暣浣撴敞閲�
* @author Ryan
- * @description 鏍规嵁PO鍗曟嵁鐢熸垚ASN鍗�,鑷姩鐢熸垚ASN鍗曚负鍏ㄩ噺鐢熸垚
- * @throws
+ * @date 2025/5/12
+ * @description: 鏀惰揣鍖哄簱瀛樻洿鏂�
+ */
+// @Transactional(rollbackFor = Exception.class)
+// public void updateReceipt(WarehouseAreas areasItem, WkOrderItem orderItem, WkOrder wkOrder, Matnr matnr) throws Exception {
+// Companys companys = new Companys();
+// if (StringUtils.isNoneBlank(orderItem.getSplrCode())) {
+// companys = companysService.getOne(new LambdaQueryWrapper<Companys>().eq(Companys::getCode, orderItem.getSplrCode()));
+// }
+// WarehouseAreasItem item = new WarehouseAreasItem();
+// item.setTrackCode(orderItem.getBarcode())
+// .setAreaName(areasItem.getName())
+// .setAreaId(areasItem.getId())
+// .setAsnItemId(orderItem.getId())
+// .setAsnCode(wkOrder.getCode())
+// .setAsnId(wkOrder.getId())
+// .setProdTime(orderItem.getProdTime())
+// .setPlatItemId(orderItem.getPlatItemId())
+// .setPlatOrderCode(orderItem.getPlatOrderCode())
+// .setPlatWorkCode(orderItem.getPlatWorkCode())
+// .setProjectCode(orderItem.getProjectCode())
+// .setSplrId(companys.getId())
+// .setUnit(orderItem.getStockUnit())
+// .setStockUnit(orderItem.getStockUnit())
+// .setMatnrCode(matnr.getCode())
+// .setAnfme(orderItem.getAnfme())
+// .setMatnrId(matnr.getId())
+// .setIsptResult(orderItem.getIsptResult())
+// .setMaktx(matnr.getName())
+// .setSplrBatch(orderItem.getSplrBatch())
+// .setWeight(matnr.getWeight())
+// .setFieldsIndex(orderItem.getFieldsIndex())
+// .setShipperId(matnr.getShipperId());
+// List<WarehouseAreasItem> warehousList = StringUtils.isNotBlank(orderItem.getFieldsIndex())
+// ? warehouseAreasItemService.list(new LambdaQueryWrapper<WarehouseAreasItem>().eq(WarehouseAreasItem::getFieldsIndex, orderItem.getFieldsIndex()))
+// : Collections.emptyList();
+// WarehouseAreasItem warehousItem = warehousList.isEmpty() ? null : warehousList.get(0);
+// if (!Objects.isNull(warehousItem)) {
+// List<FieldsItem> fieldsList = fieldsItemService.list(new LambdaQueryWrapper<FieldsItem>()
+// .eq(FieldsItem::getUuid, orderItem.getFieldsIndex()).last("LIMIT 1"));
+// FieldsItem fieldsItem = fieldsList.isEmpty() ? null : fieldsList.get(0);
+// if (!Objects.isNull(fieldsItem)) {
+// throw new CoolException("绁ㄥ彿锛�" + fieldsItem.getValue() + "宸插湪鏀惰揣鍖猴紝涓嶅彲鎺ㄩ�佺浉褰撶エ鍙锋暟鎹�傝鑱旂郴绠＄悊鍛橈紒锛�" );
+// }
+// }
+// LambdaQueryWrapper<WarehouseAreasItem> queryWrapper = new LambdaQueryWrapper<WarehouseAreasItem>()
+// .eq(WarehouseAreasItem::getMatnrCode, orderItem.getMatnrCode())
+// .eq(!Cools.isEmpty(orderItem.getFieldsIndex()), WarehouseAreasItem::getFieldsIndex, orderItem.getFieldsIndex())
+// .eq(WarehouseAreasItem::getAsnCode, orderItem.getOrderCode())
+// .eq(StringUtils.isNotBlank(orderItem.getSplrBatch()), WarehouseAreasItem::getSplrBatch, orderItem.getSplrBatch());
+// if (Objects.isNull(orderItem.getIsptResult())) {
+// queryWrapper.isNull(WarehouseAreasItem::getIsptResult);
+// } else {
+// queryWrapper.eq(WarehouseAreasItem::getIsptResult, orderItem.getIsptResult());
+// }
+// List<WarehouseAreasItem> serviceList = warehouseAreasItemService.list(queryWrapper);
+// WarehouseAreasItem serviceOne = serviceList.isEmpty() ? null : serviceList.get(0);
+// if (!Objects.isNull(serviceOne)) {
+// item.setId(serviceOne.getId());
+// item.setAnfme(orderItem.getAnfme());
+// }
+// if (!warehouseAreasItemService.saveOrUpdate(item)) {
+// throw new CoolException("鏀惰揣澶辫触锛侊紒");
+// }
+// }
+
+
+ /**
* @return
+ * @throws
+ * @author Ryan
+ * @description 鏍规嵁PO鍗曟嵁鐢熸垚ASN鍗�, 鑷姩鐢熸垚ASN鍗曚负鍏ㄩ噺鐢熸垚
* @time 2025/3/3 15:44
*/
@Scheduled(cron = "0 0/05 * * * ? ")
-// @Scheduled(cron = "0/5 * * * * ?")
@Transactional(rollbackFor = Exception.class)
- public void genAsnOrder() {
+ public synchronized void genAsnOrder() {
//鍒ゆ柇鏄惁寮�鍚嚜鍔ㄧ敓鎴怉SN鍗曟嵁
if (!flowProperties.getFlagAutoAsn()) {
return;
}
//鑾峰彇鏈敓鎴怉SN鍗曟嵁
- List<Purchase> purchases = purchaseService.list(new LambdaQueryWrapper<Purchase>().eq(Purchase::getStatus, 0));
+ List<Purchase> purchases = purchaseService.list(new LambdaQueryWrapper<Purchase>().eq(Purchase::getExceStatus, 0));
//PO鍗曚负绌猴紝鐩存帴璺冲嚭褰撳墠浠诲姟
if (purchases.isEmpty()) {
return;
@@ -80,7 +253,7 @@
if (items.isEmpty()) {
throw new CoolException("瀛愬垪琛ㄦ暟鎹负绌猴紝璇锋煡璇O鍗曟槸鍚︽纭綍鍏ワ紒锛�");
}
- AsnOrder order = new AsnOrder();
+ WkOrder order = new WkOrder();
//鏍规嵁缂栫爜瑙勫垯鐢熸垚ASN鍗曞彿
String code = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_ASN_ORDER, purchase);
order.setAnfme(purchase.getAnfme())
@@ -92,9 +265,9 @@
if (!asnOrderService.save(order)) {
throw new CoolException("ASN鍗曟嵁淇濆瓨澶辫触锛侊紒");
}
- List<AsnOrderItem> orderItems = new ArrayList<>();
+ List<WkOrderItem> orderItems = new ArrayList<>();
items.forEach(item -> {
- AsnOrderItem orderItem = new AsnOrderItem();
+ WkOrderItem orderItem = new WkOrderItem();
Matnr matnr = matnrService.getOne(new LambdaQueryWrapper<Matnr>().eq(Matnr::getCode, item.getMatnrCode()));
if (Objects.isNull(matnr)) {
throw new CoolException("鏁版嵁閿欒锛氬綋鍓嶇墿鏂欎笉瀛樺湪!!");
@@ -105,10 +278,10 @@
}
// String barcode = code + matnr.getCode();
orderItem.setAnfme(item.getAnfme())
- .setAsnId(order.getId())
+ .setOrderId(order.getId())
.setQty(item.getQty())
.setSplrName(item.getSplrName())
- .setAsnCode(code)
+ .setOrderCode(code)
.setSplrCode(item.getSplrCode())
.setPoDetlId(item.getId())
.setPlatItemId(item.getPlatItemId())
@@ -118,7 +291,7 @@
.setPurUnit(item.getUnit())
.setMatnrCode(matnr.getCode())
.setMaktx(matnr.getName())
- .setMatnrId(matnr.getId() + "");
+ .setMatnrId(matnr.getId());
orderItems.add(orderItem);
});
if (!asnOrderItemService.saveBatch(orderItems)) {
@@ -126,35 +299,39 @@
}
//浠诲姟鎵ц瀹屾垚锛屼慨鏀瑰凡瀹屾垚鏁伴噺鍜孭O鍗曟墽琛岀姸鎬�
- purchase.setQty(purchase.getAnfme()).setStatus(1);
+ purchase.setQty(purchase.getAnfme())
+ .setExceStatus(POExceStatus.PO_EXCE_STATUS_EXCE_ING.val);
if (!purchaseService.saveOrUpdate(purchase)) {
throw new CoolException("PO鍗曟墽琛屽畬鎴愬悗锛屼繚瀛樺け璐ワ紒锛�");
}
-
});
}
-
/**
- * 鐢熸垚鐗╂枡鏍囩
+ * @param
+ * @return
+ * @author Ryan
+ * @description 鐢熸垚鐗╂枡鏍囩
+ * @time 2025/3/29 12:35
*/
@Scheduled(cron = "0 0/05 * * * ? ")
@Transactional(rollbackFor = Exception.class)
public void generateMatnrLabel() {
- List<AsnOrderItem> list = asnOrderItemService.list(new LambdaQueryWrapper<AsnOrderItem>()
- .isNull(AsnOrderItem::getTrackCode)
- .select(AsnOrderItem::getId));
+ List<WkOrderItem> list = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>()
+ .isNull(WkOrderItem::getTrackCode)
+ .select(WkOrderItem::getId));
if (Objects.isNull(list) || list.isEmpty()) {
return;
}
- List<AsnOrderItem> items = new ArrayList<>();
+ List<WkOrderItem> items = new ArrayList<>();
list.forEach(item -> {
String trackCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_LABEL_CODE, item);
if (StringUtils.isBlank(trackCode)) {
throw new CoolException("鍗曟嵁璺熻釜鐮佺敓鎴愬け璐ワ細璇锋鏌ャ�宻ys_asn_mantr_label銆嶆槸鍚﹂厤缃畬鎴愶紒锛�");
}
- item.setTrackCode(trackCode);
+// item.setTrackCode(trackCode);
+ item.setBarcode(trackCode);
items.add(item);
});
@@ -162,5 +339,4 @@
throw new CoolException("鐢熸垚缂栫爜澶辫触锛侊紒");
}
}
-
}
--
Gitblit v1.9.1