From 8e2ba687b00f230ade708fa82b8c9f67cf842f0d Mon Sep 17 00:00:00 2001
From: zhou zhou <3272660260@qq.com>
Date: 星期四, 15 一月 2026 13:52:34 +0800
Subject: [PATCH] #
---
rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java | 532 ++++++++++++++++++++++++++++++++++++----------------------
1 files changed, 329 insertions(+), 203 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java
index e40184c..bdaf340 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java
@@ -2,10 +2,11 @@
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.vincent.rsf.framework.common.Cools;
import com.vincent.rsf.framework.common.R;
import com.vincent.rsf.framework.exception.CoolException;
-import com.vincent.rsf.server.api.controller.params.*;
+import com.vincent.rsf.server.api.controller.erp.params.*;
import com.vincent.rsf.server.api.entity.dto.*;
import com.vincent.rsf.server.manager.enums.*;
import com.vincent.rsf.server.api.service.MobileService;
@@ -28,10 +29,7 @@
import com.vincent.rsf.server.system.entity.*;
import com.vincent.rsf.server.system.mapper.FieldsMapper;
import com.vincent.rsf.server.system.mapper.TenantMapper;
-import com.vincent.rsf.server.system.service.ConfigService;
-import com.vincent.rsf.server.system.service.FieldsItemService;
-import com.vincent.rsf.server.system.service.UserLoginService;
-import com.vincent.rsf.server.system.service.UserService;
+import com.vincent.rsf.server.system.service.*;
import com.vincent.rsf.server.system.utils.SerialRuleUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
@@ -91,13 +89,10 @@
private FieldsMapper fieldsMapper;
@Autowired
private IsptHistoriesMapper isptHistoriesMapper;
-
@Autowired
private AsnOrderLogService asnOrderLogService;
-
@Autowired
private WaitPakinService waitPakinService;
-
@Autowired
private WaitPakinItemService waitPakinItemService;
@Autowired
@@ -128,6 +123,12 @@
private ConfigService configService;
@Autowired
private CompanysService companysService;
+ @Autowired
+ private OutStockService outStockService;
+ @Autowired
+ private WarehouseRoleMenuService warehouseRoleMenuService;
+ @Autowired
+ private BasContainerService basContainerService;
/**
* @return
@@ -176,14 +177,14 @@
if (StringUtils.isBlank(barcode)) {
return R.error("鏍囩鐮佷笉鑳戒负绌猴紒锛�");
}
- List<AsnOrderItem> asnOrderItem = asnOrderItemMapper.selectList(new LambdaQueryWrapper<AsnOrderItem>()
- .eq(AsnOrderItem::getTrackCode, barcode));
+ List<WkOrderItem> wkOrderItem = asnOrderItemMapper.selectList(new LambdaQueryWrapper<WkOrderItem>()
+ .eq(WkOrderItem::getTrackCode, barcode));
- if (Objects.isNull(asnOrderItem)) {
+ if (Objects.isNull(wkOrderItem)) {
throw new CoolException("鍗曟嵁鏄庣粏涓嶅瓨鍦紒锛�");
}
- List<AsnOrderItem> items = new ArrayList<>();
- for (AsnOrderItem record : asnOrderItem) {
+ List<WkOrderItem> items = new ArrayList<>();
+ for (WkOrderItem record : wkOrderItem) {
if (!Objects.isNull(record.getFieldsIndex())) {
Map<String, String> fields = FieldsUtils.getFields(record.getFieldsIndex());
record.setExtendFields(fields);
@@ -231,21 +232,34 @@
String asnCode = receipts.stream().findFirst().get().getAsnCode();
- AsnOrder asnOrder = asnOrderMapper.getOne(new LambdaQueryWrapper<AsnOrder>()
- .eq(AsnOrder::getCode, asnCode));
- if (Objects.isNull(asnOrder)) {
+ WkOrder wkOrder = asnOrderMapper.getOne(new LambdaQueryWrapper<WkOrder>()
+ .eq(WkOrder::getCode, asnCode));
+
+ // 鍒ゆ柇璋冩嫈鍗曞嚭搴撴槸鍚﹀畬鎴�
+ if (wkOrder.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER_TERANSFER.type)) {
+ WkOrder one = outStockService.getOne(new LambdaQueryWrapper<WkOrder>()
+ .eq(WkOrder::getPoId, wkOrder.getPoId())
+ .eq(WkOrder::getWkType, OrderWorkType.ORDER_WORK_TYPE_STOCK_TERANSFER.type)
+ .eq(WkOrder::getType, OrderType.ORDER_OUT.type));
+ if (Objects.isNull(one)) {
+ throw new CoolException("鏁版嵁閿欒锛侊紒");
+ }
+ if (!one.getExceStatus().equals(AsnExceStatus.OUT_STOCK_STATUS_TASK_DONE.val)) {
+ throw new CoolException("璋冩嫈鍑哄簱鍗曟湭瀹屾垚锛屼笉鍙墽琛屾敹璐ф搷浣滐紒锛�");
+ }
+ }
+
+ if (Objects.isNull(wkOrder)) {
throw new CoolException("鏁版嵁閿欒锛氫富鍗曚笉瀛樺湪锛侊紒");
}
- //TODO /**鏀惰揣鏁伴噺绱姞锛�1. 浼氬嚭瓒呮敹鎯呭喌 2. 浼氭湁鏀惰揣涓嶈冻鎯呭喌*/
- Double rcptedQty = asnOrder.getQty() + receiptQty;
-
- asnOrder.setQty(rcptedQty).setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_EXCE_ING.val);
- if (!asnOrderMapper.updateById(asnOrder)) {
+ // TODO /**鏀惰揣鏁伴噺绱姞锛�1. 浼氬嚭瓒呮敹鎯呭喌 2. 浼氭湁鏀惰揣涓嶈冻鎯呭喌*/
+ Double rcptedQty = Math.round((wkOrder.getQty() + receiptQty) * 10000) / 10000.0;
+ wkOrder.setQty(rcptedQty).setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_EXCE_ING.val);
+ if (!asnOrderMapper.updateById(wkOrder)) {
throw new CoolException("宸叉敹璐ф暟閲忎慨鏀瑰け璐ワ紒锛�");
}
-
- Config config = configService.getOne(new LambdaQueryWrapper<Config>().eq(Config::getFlag, GlobalConfigCode.ALLOW_OVER_CHANGE));
-
+ Config config = configService
+ .getOne(new LambdaQueryWrapper<Config>().eq(Config::getFlag, GlobalConfigCode.ALLOW_OVER_CHANGE));
List<Map<String, Object>> receipts1 = (List<Map<String, Object>>) params.get("receipts");
for (Map<String, Object> rcpt : receipts1) {
@@ -260,17 +274,20 @@
if (Objects.isNull(dto.getReceiptQty())) {
throw new CoolException("鏀惰揣鏁版嵁涓嶈兘涓虹┖锛侊紒");
}
-// if (dto.getReceiptQty().compareTo(dto.getAnfme()) > 0) {
-// throw new CoolException("鏀惰揣鏁伴噺涓嶈兘澶т簬閲囪喘鏁伴噺锛侊紒");
-// }
-// AsnOrderItem orderItem = asnOrderItemMapper.selectOne(new LambdaQueryWrapper<AsnOrderItem>()
-// .eq(AsnOrderItem::getAsnCode, asnCode)
-// .eq(AsnOrderItem::getId, dto.getId())
-// .eq(AsnOrderItem::getTrackCode, dto.getBarcode())
-// .eq(AsnOrderItem::getSplrBatch, dto.getSplrBatch()));
+ // if (dto.getReceiptQty().compareTo(dto.getAnfme()) > 0) {
+ // throw new CoolException("鏀惰揣鏁伴噺涓嶈兘澶т簬閲囪喘鏁伴噺锛侊紒");
+ // }
+ // AsnOrderItem orderItem = asnOrderItemMapper.selectOne(new
+ // LambdaQueryWrapper<AsnOrderItem>()
+ // .eq(AsnOrderItem::getAsnCode, asnCode)
+ // .eq(AsnOrderItem::getId, dto.getId())
+ // .eq(AsnOrderItem::getTrackCode, dto.getBarcode())
+ // .eq(AsnOrderItem::getSplrBatch, dto.getSplrBatch()));
- AsnOrderItem orderItem = asnOrderItemMapper.selectOne(new LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getId, dto.getId()));
- //asnOrderItemMapper.resultById(new LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getId, dto.getId()));
+ WkOrderItem orderItem = asnOrderItemMapper
+ .selectOne(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getId, dto.getId()));
+ // asnOrderItemMapper.resultById(new
+ // LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getId, dto.getId()));
if (Objects.isNull(orderItem)) {
throw new CoolException("閫氱煡鍗曟槑缁嗕笉瀛樺湪锛侊紒");
@@ -288,7 +305,7 @@
throw new CoolException("璇疯緭鍏ユ纭殑鏃堕棿鏍煎紡锛侊紒");
}
- Double itemRcptQty = dto.getReceiptQty() + orderItem.getQty();
+ Double itemRcptQty = Math.round((dto.getReceiptQty() + orderItem.getQty()) * 10000) / 10000.0;
Boolean allowOver = false;
if (!Objects.isNull(config)) {
if (Boolean.parseBoolean(config.getVal())) {
@@ -300,44 +317,46 @@
}
orderItem.setQty(itemRcptQty)
-// .setSplrBatch(dto.getSplrBatch())
+ // .setSplrBatch(dto.getSplrBatch())
.setUpdateBy(loginUserId)
.setStockUnit(dto.getStockUnit())
.setProdTime(dto.getProdTime());
-// if (!Objects.isNull(rcpt)) {
-// try {
-// if (Objects.isNull(rcpt.get("fieldsindex")) || StringUtils.isBlank(rcpt.get("fieldsindex").toString())) {
-// StringBuffer sb = new StringBuffer();
-// if (!dto.getExtendFields().isEmpty()) {
-// dto.getExtendFields().forEach(field -> {
-// field.keySet().forEach(key -> {
-// sb.append(field.get(key));
-// });
-// });
-// }
-// sb.append(dto.getAsnCode() + dto.getMatnr() + dto.getSplrBatch() + orderItem.getIsptResult$());
-// //鑾峰彇16浣島uid
-// String uuid16 = Cools.md5Chinese(sb.toString());
-// rcpt.put("index", uuid16);
-// orderItem.setFieldsIndex(uuid16);
-// }
-// //淇濆瓨鎴栨洿鏂版墿灞曞瓧娈�
-// FieldsUtils.updateFieldsValue(rcpt);
-// } catch (Exception e) {
-// throw new RuntimeException(e);
-// }
-// }
+ // if (!Objects.isNull(rcpt)) {
+ // try {
+ // if (Objects.isNull(rcpt.get("fieldsindex")) ||
+ // StringUtils.isBlank(rcpt.get("fieldsindex").toString())) {
+ // StringBuffer sb = new StringBuffer();
+ // if (!dto.getExtendFields().isEmpty()) {
+ // dto.getExtendFields().forEach(field -> {
+ // field.keySet().forEach(key -> {
+ // sb.append(field.get(key));
+ // });
+ // });
+ // }
+ // sb.append(dto.getAsnCode() + dto.getMatnr() + dto.getSplrBatch() +
+ // orderItem.getIsptResult$());
+ // //鑾峰彇16浣島uid
+ // String uuid16 = Cools.md5Chinese(sb.toString());
+ // rcpt.put("index", uuid16);
+ // orderItem.setFieldsIndex(uuid16);
+ // }
+ // //淇濆瓨鎴栨洿鏂版墿灞曞瓧娈�
+ // FieldsUtils.updateFieldsValue(rcpt);
+ // } catch (Exception e) {
+ // throw new RuntimeException(e);
+ // }
+ // }
if (asnOrderItemMapper.updateById(orderItem) < 1) {
throw new CoolException("閫氱煡鍗曟槑缁嗘暟閲忎慨鏀瑰け璐ワ紒锛�");
}
- /**淇濆瓨鏄庣粏鑷虫敹璐у尯**/
- extracted(loginUserId, dto, areasItem, orderItem, asnOrder, matnr);
+ /** 淇濆瓨鏄庣粏鑷虫敹璐у尯 **/
+ extracted(loginUserId, dto, areasItem, orderItem, wkOrder, matnr);
}
- AsnOrder order = asnOrderMapper.getOne(new LambdaQueryWrapper<AsnOrder>().eq(AsnOrder::getCode, asnCode));
+ WkOrder order = asnOrderMapper.getOne(new LambdaQueryWrapper<WkOrder>().eq(WkOrder::getCode, asnCode));
if (order.getQty().compareTo(order.getAnfme()) >= 0.00) {
order.setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_RECEIPT_DONE.val).setRleStatus(Short.valueOf("1"));
if (!asnOrderMapper.updateById(order)) {
@@ -348,11 +367,13 @@
return R.ok("鏀惰揣鎴愬姛锛侊紒");
}
- private void extracted(Long loginUserId, ReceiptDetlsDto dto, WarehouseAreas areasItem, AsnOrderItem orderItem, AsnOrder asnOrder, Matnr matnr) {
+ private void extracted(Long loginUserId, ReceiptDetlsDto dto, WarehouseAreas areasItem, WkOrderItem orderItem,
+ WkOrder wkOrder, Matnr matnr) {
Companys companys = new Companys();
if (StringUtils.isNoneBlank(orderItem.getSplrCode())) {
- companys = companysService.getOne(new LambdaQueryWrapper<Companys>().eq(Companys::getCode, orderItem.getSplrCode()));
+ companys = companysService
+ .getOne(new LambdaQueryWrapper<Companys>().eq(Companys::getCode, orderItem.getSplrCode()));
}
WarehouseAreasItem item = new WarehouseAreasItem();
@@ -360,18 +381,20 @@
.setAreaName(areasItem.getName())
.setAreaId(areasItem.getId())
.setAsnItemId(orderItem.getId())
- .setAsnCode(asnOrder.getCode())
- .setAsnId(asnOrder.getId())
+ .setAsnCode(wkOrder.getCode())
+ .setAsnId(wkOrder.getId())
.setProdTime(dto.getProdTime())
.setSplrId(companys.getId())
.setWeight(dto.getWeigth())
.setPlatOrderCode(orderItem.getPlatOrderCode())
.setPlatWorkCode(orderItem.getPlatWorkCode())
.setProjectCode(orderItem.getProjectCode())
- //搴撳瓨鍗曚綅涓烘渶灏忓崟浣�
+ // 搴撳瓨鍗曚綅涓烘渶灏忓崟浣�
.setUnit(orderItem.getStockUnit())
.setStockUnit(orderItem.getStockUnit())
- .setBatch(StringUtils.isBlank(orderItem.getBatch()) ? SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_RECEIPT_BATCH, dto) : orderItem.getBatch())
+ .setBatch(StringUtils.isBlank(orderItem.getBatch())
+ ? SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_RECEIPT_BATCH, dto)
+ : orderItem.getBatch())
.setAnfme(dto.getReceiptQty())
.setSplrBatch(dto.getSplrBatch())
.setMatnrCode(matnr.getCode())
@@ -383,10 +406,10 @@
.setWeight(matnr.getWeight())
.setFieldsIndex(orderItem.getFieldsIndex())
.setShipperId(matnr.getShipperId());
- //TODO 渚涘簲鍟嗘爣璇嗘湭璁剧疆锛屾爣璇嗙敱PO鍗曚緵搴斿晢缂栫爜杞崲
+ // TODO 渚涘簲鍟嗘爣璇嗘湭璁剧疆锛屾爣璇嗙敱PO鍗曚緵搴斿晢缂栫爜杞崲
LambdaQueryWrapper<WarehouseAreasItem> queryWrapper = new LambdaQueryWrapper<WarehouseAreasItem>()
-// .eq(WarehouseAreasItem::getAsnItemId, item.getAsnItemId())
+ // .eq(WarehouseAreasItem::getAsnItemId, item.getAsnItemId())
.eq(WarehouseAreasItem::getMatnrCode, item.getMatnrCode())
.eq(!Cools.isEmpty(item.getFieldsIndex()), WarehouseAreasItem::getFieldsIndex, item.getFieldsIndex())
.eq(WarehouseAreasItem::getAsnCode, item.getAsnCode())
@@ -401,32 +424,32 @@
if (!Objects.isNull(serviceOne)) {
item.setId(serviceOne.getId());
- item.setAnfme(item.getAnfme() + serviceOne.getAnfme());
+ Double anfme = Math.round((item.getAnfme() + serviceOne.getAnfme()) * 10000) / 10000.0;
+ item.setAnfme(anfme);
}
- //鏈川妫�
+ // 鏈川妫�
if (!warehouseAreasItemService.saveOrUpdate(item)) {
throw new CoolException("鏀惰揣澶辫触锛侊紒");
}
-// if (null != orderItem.getSafeQty() || null != orderItem.getDisQty() ) {
-//
-// }
-// else {
-// //涓嶅悎鏍兼暟閲�
-// if (orderItem.getDisQty().compareTo(0.00) > 0) {
-// item.setIsptQty(orderItem.getDisQty()).setFlagNorm(QlyIsptResult.QLY_ISPT_RESULT_DEFECT.val);
-// if (!warehouseAreasItemService.saveOrUpdate(item)) {
-// throw new CoolException("鏀惰揣澶辫触锛侊紒");
-// }
-// }
-//
-// item.setIsptQty(orderItem.getSafeQty()).setFlagNorm(QlyIsptResult.QLY_ISPT_RESULT_EXCELLENT.val);
-// if (!warehouseAreasItemService.saveOrUpdate(item)) {
-// throw new CoolException("鏀惰揣澶辫触锛侊紒");
-// }
-// }
-
+ // if (null != orderItem.getSafeQty() || null != orderItem.getDisQty() ) {
+ //
+ // }
+ // else {
+ // //涓嶅悎鏍兼暟閲�
+ // if (orderItem.getDisQty().compareTo(0.00) > 0) {
+ // item.setIsptQty(orderItem.getDisQty()).setFlagNorm(QlyIsptResult.QLY_ISPT_RESULT_DEFECT.val);
+ // if (!warehouseAreasItemService.saveOrUpdate(item)) {
+ // throw new CoolException("鏀惰揣澶辫触锛侊紒");
+ // }
+ // }
+ //
+ // item.setIsptQty(orderItem.getSafeQty()).setFlagNorm(QlyIsptResult.QLY_ISPT_RESULT_EXCELLENT.val);
+ // if (!warehouseAreasItemService.saveOrUpdate(item)) {
+ // throw new CoolException("鏀惰揣澶辫触锛侊紒");
+ // }
+ // }
}
@@ -442,27 +465,26 @@
throw new CoolException("閫氱煡鍗曚笉鑳戒负绌猴紒锛�");
}
- List<Short> shorts = Arrays.asList(AsnExceStatus.ASN_EXCE_STATUS_TASK_CANCEL.val, AsnExceStatus.ASN_EXCE_STATUS_TASK_CLOSE
- .val, AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val);
- AsnOrder order = asnOrderMapper.getOne(new LambdaQueryWrapper<AsnOrder>()
- .notIn(AsnOrder::getExceStatus, shorts)
- .eq(AsnOrder::getCode, params.getAsnCode()));
+ List<Short> shorts = Arrays.asList(AsnExceStatus.ASN_EXCE_STATUS_TASK_CANCEL.val,
+ AsnExceStatus.ASN_EXCE_STATUS_TASK_CLOSE.val, AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val);
+ WkOrder order = asnOrderMapper.getOne(new LambdaQueryWrapper<WkOrder>()
+ .notIn(WkOrder::getExceStatus, shorts)
+ .eq(WkOrder::getCode, params.getAsnCode()));
if (Objects.isNull(order)) {
throw new CoolException("璇锋鏌ヨ鍗曠姸鎬佹槸鍚﹀凡瀹屾垚鎴栧凡鍙栨秷锛侊紒");
}
- List<AsnOrderItem> asnOrderItem = asnOrderItemMapper.selectList(new LambdaQueryWrapper<AsnOrderItem>()
- .eq(AsnOrderItem::getAsnCode, params.getAsnCode())
- .eq(!Objects.isNull(params.getTrackCode()), AsnOrderItem::getTrackCode, params.getTrackCode())
- .eq(!Cools.isEmpty(params.getMatnrCode()), AsnOrderItem::getMatnrCode, params.getMatnrCode())
- );
+ List<WkOrderItem> wkOrderItem = asnOrderItemMapper.selectList(new LambdaQueryWrapper<WkOrderItem>()
+ .eq(WkOrderItem::getOrderCode, params.getAsnCode())
+ .eq(!Objects.isNull(params.getTrackCode()), WkOrderItem::getTrackCode, params.getTrackCode())
+ .eq(!Cools.isEmpty(params.getMatnrCode()), WkOrderItem::getMatnrCode, params.getMatnrCode()));
- if (Objects.isNull(asnOrderItem)) {
+ if (Objects.isNull(wkOrderItem)) {
throw new CoolException("鍗曟嵁鏄庣粏涓嶅瓨鍦紒锛�");
}
- List<AsnOrderItem> items = new ArrayList<>();
- for (AsnOrderItem record : asnOrderItem) {
+ List<WkOrderItem> items = new ArrayList<>();
+ for (WkOrderItem record : wkOrderItem) {
if (!Objects.isNull(record.getFieldsIndex())) {
Map<String, String> fields = FieldsUtils.getFields(record.getFieldsIndex());
record.setExtendFields(fields);
@@ -480,9 +502,10 @@
* @description 鑾峰彇鎵�鏈夐�氱煡鍗�
*/
@Override
- public List<AsnOrder> getAllAsnOrders() {
- List<AsnOrder> asnOrders = asnOrderMapper.list(new LambdaQueryWrapper<AsnOrder>().eq(AsnOrder::getWkType, OrderWorkType.ORDER_WORK_TYPE_PURCHASE.type));
- return asnOrders;
+ public List<WkOrder> getAllAsnOrders() {
+ List<WkOrder> wkOrders = asnOrderMapper.list(
+ new LambdaQueryWrapper<WkOrder>().eq(WkOrder::getWkType, OrderWorkType.ORDER_WORK_TYPE_PURCHASE.type));
+ return wkOrders;
}
/**
@@ -493,9 +516,39 @@
* @time 2025/3/11 10:12
*/
@Override
- public R getReceiptAreas() {
+ public R getReceiptAreas(User user) {
+ Long[] userRoleIds = user.getUserRoleIds();
+ List<WarehouseRoleMenu> warehouseRoleMenus = warehouseRoleMenuService
+ .list(new LambdaQueryWrapper<WarehouseRoleMenu>()
+ .in(WarehouseRoleMenu::getRoleId, Arrays.asList(userRoleIds)));
+ Set<WarehouseRoleMenu> warehouseRoleMenusSet = new HashSet<>(warehouseRoleMenus);
+ List<Long> longs = warehouseRoleMenusSet.stream().map(WarehouseRoleMenu::getMenuId)
+ .collect(Collectors.toList());
List<WarehouseAreas> areas = warehouseAreasService.list(new LambdaQueryWrapper<WarehouseAreas>()
- .eq(WarehouseAreas::getType, WarehouseAreaType.WAREHOUSE_AREA_RECEIPT.type));
+ .eq(WarehouseAreas::getType, WarehouseAreaType.WAREHOUSE_AREA_RECEIPT.type)
+ .in(WarehouseAreas::getId, longs));
+ return R.ok(areas);
+ }
+
+ /**
+ * @param
+ * @return
+ * @author Ryan
+ * @description 鑾峰彇闆嗚揣鍖�
+ * @time 2025/3/11 10:12
+ */
+ @Override
+ public R getAreasUserAll(User user) {
+ Long[] userRoleIds = user.getUserRoleIds();
+ List<WarehouseRoleMenu> warehouseRoleMenus = warehouseRoleMenuService
+ .list(new LambdaQueryWrapper<WarehouseRoleMenu>()
+ .in(WarehouseRoleMenu::getRoleId, Arrays.asList(userRoleIds)));
+ Set<WarehouseRoleMenu> warehouseRoleMenusSet = new HashSet<>(warehouseRoleMenus);
+ List<Long> longs = warehouseRoleMenusSet.stream().map(WarehouseRoleMenu::getMenuId)
+ .collect(Collectors.toList());
+ List<WarehouseAreas> areas = warehouseAreasService.list(new LambdaQueryWrapper<WarehouseAreas>()
+ .eq(WarehouseAreas::getType, WarehouseAreaType.WAREHOUSE_AREA_COLLECTION.type)
+ .in(WarehouseAreas::getId, longs));
return R.ok(areas);
}
@@ -517,7 +570,7 @@
* @param
* @return
* @author Ryan
- * @description 鑾峰彇缁勭洏鏄庣粏
+ * @description 鑾峰彇缁勭洏鏄庣粏锛堟敮鎸佸垎椤靛姞杞芥洿澶氾級
* @time 2025/4/7 16:58
*/
@Override
@@ -532,10 +585,24 @@
.or().eq(!Cools.isEmpty(code), WarehouseAreasItem::getTrackCode, code)
.or().eq(!Cools.isEmpty(batch), WarehouseAreasItem::getSplrBatch, batch)
.or().eq(!Cools.isEmpty(matnrCode), WarehouseAreasItem::getMatnrCode, matnrCode)
- .or().eq(!Cools.isEmpty(asnCode), WarehouseAreasItem::getAsnCode, asnCode);
- List<WarehouseAreasItem> list = warehouseAreasItemService.list(queryWrapper);
- list.removeIf(e -> e.getAnfme() <= e.getWorkQty());
- return R.ok(list);
+ .or().eq(!Cools.isEmpty(asnCode), WarehouseAreasItem::getAsnCode, asnCode)
+ .apply("anfme > work_qty")
+ ;
+
+ long pageNum = 1;
+ long pageSize = 10;
+ if (!Cools.isEmpty(params.get("pageNum"))) {
+ pageNum = Long.parseLong(params.get("pageNum").toString());
+ }
+ if (!Cools.isEmpty(params.get("pageSize"))) {
+ pageSize = Long.parseLong(params.get("pageSize").toString());
+ }
+ // 浣跨敤 MyBatis-Plus Page 鍒嗛〉
+ Page<WarehouseAreasItem> page = new Page<>(pageNum, pageSize);
+ Page<WarehouseAreasItem> resultPage = warehouseAreasItemService.page(page, queryWrapper);
+// List<WarehouseAreasItem> list = warehouseAreasItemService.list(queryWrapper);
+// list.removeIf(e -> e.getAnfme() <= e.getWorkQty());
+ return R.ok(resultPage);
}
/**
@@ -549,6 +616,17 @@
@Override
public WaitPakin mergeItems(WaitPakinParam waitPakin, Long userId) {
return waitPakinService.mergeItems(waitPakin, userId);
+ }
+
+ /**
+ * @author Munch D. Luffy
+ * @date 2026/01/09
+ * @description: PDA缁勬嫋
+ * @version 1.0
+ */
+ @Override
+ public WaitPakin mergeItemsWcs(WaitPakinParam waitPakin, Long userId) {
+ return waitPakinService.mergeItemsWcs(waitPakin, userId);
}
/**
@@ -571,13 +649,14 @@
*/
@Override
public R inspect(String code, Long loginUserId) {
- AsnOrder asnOrders = asnOrderMapper.getOne(new LambdaQueryWrapper<AsnOrder>().eq(AsnOrder::getCode, code));
- if (Objects.isNull(asnOrders)) {
+ WkOrder wkOrders = asnOrderMapper.getOne(new LambdaQueryWrapper<WkOrder>().eq(WkOrder::getCode, code));
+ if (Objects.isNull(wkOrders)) {
throw new CoolException("鍗曟嵁涓嶅瓨鍦紒锛�");
}
InspectDetlDto detlDto = new InspectDetlDto();
- detlDto.setCode(asnOrders.getCode()).setId(asnOrders.getId()).setPoCode(asnOrders.getPoCode());
- List<AsnOrderItem> orderItems = asnOrderItemMapper.selectList(new LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getAsnCode, code));
+ detlDto.setCode(wkOrders.getCode()).setId(wkOrders.getId()).setPoCode(wkOrders.getPoCode());
+ List<WkOrderItem> orderItems = asnOrderItemMapper
+ .selectList(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderCode, code));
if (orderItems.isEmpty()) {
detlDto.setItems(new ArrayList<>());
} else {
@@ -585,7 +664,8 @@
orderItems.forEach(dto -> {
InspectItemDto itemDto = new InspectItemDto();
if (!Objects.isNull(dto.getMatnrCode())) {
- Matnr matnr = matnrMapper.selectOne(new LambdaQueryWrapper<Matnr>().eq(Matnr::getCode, dto.getMatnrCode()));
+ Matnr matnr = matnrMapper
+ .selectOne(new LambdaQueryWrapper<Matnr>().eq(Matnr::getCode, dto.getMatnrCode()));
itemDto.setGroup(matnr.getGroupCode());
}
itemDto.setMaktx(dto.getMaktx())
@@ -599,7 +679,8 @@
detlDto.setItems(itemDtos);
}
- List<IsptHistories> histories = isptHistoriesMapper.selectList(new LambdaQueryWrapper<IsptHistories>().eq(IsptHistories::getAsnId, asnOrders.getId()));
+ List<IsptHistories> histories = isptHistoriesMapper
+ .selectList(new LambdaQueryWrapper<IsptHistories>().eq(IsptHistories::getAsnId, wkOrders.getId()));
detlDto.setHistories(histories);
return R.ok(detlDto);
}
@@ -616,12 +697,12 @@
if (org.apache.commons.lang3.StringUtils.isBlank(id)) {
throw new CoolException("鍙傛暟涓嶈兘涓虹┖锛侊紒");
}
- AsnOrder asnOrder = asnOrderMapper.getById(id);
- if (Objects.isNull(asnOrder)) {
+ WkOrder wkOrder = asnOrderMapper.getById(id);
+ if (Objects.isNull(wkOrder)) {
throw new CoolException("鍗曟嵁涓嶅瓨鍦紒锛�");
}
- List<AsnOrder> orders = new ArrayList<>();
- orders.add(asnOrder);
+ List<WkOrder> orders = new ArrayList<>();
+ orders.add(wkOrder);
if (asnOrderMapper.notifyInspect(orders)) {
return R.ok("涓婃姤鎴愬姛锛侊紒");
} else {
@@ -648,7 +729,8 @@
throw new CoolException("璐ㄦ鍗曟嵁涓嶅瓨鍦紒!");
}
List<QlyIsptItem> isptItems = qlyIsptItemService.list(new LambdaQueryWrapper<QlyIsptItem>()
- .eq(StringUtils.isNotBlank(params.getMatnrCode()), QlyIsptItem::getMatnrCode, StringUtils.isNotBlank(params.getMatnrCode()) ? params.getMatnrCode() : null)
+ .eq(StringUtils.isNotBlank(params.getMatnrCode()), QlyIsptItem::getMatnrCode,
+ StringUtils.isNotBlank(params.getMatnrCode()) ? params.getMatnrCode() : null)
.eq(QlyIsptItem::getIspectId, inspect.getId()));
if (Objects.isNull(isptItems)) {
throw new CoolException("璐ㄦ鍗曟槑缁嗕笉瀛樺湪锛侊紒");
@@ -661,7 +743,7 @@
.setId(isptItem.getId())
.setMatnrCode(isptItem.getMatnrCode())
.setMaktx(isptItem.getMaktx())
-// .setDisQty(isptItem.getDisQty())
+ // .setDisQty(isptItem.getDisQty())
.setDlyQty(isptItem.getDlyQty())
.setRcptQty(isptItem.getRcptQty())
.setIsptResult(isptItem.getIsptResult())
@@ -669,7 +751,7 @@
.setSplrName(isptItem.getSplrName())
.setPicPath(isptItem.getPicPath())
.setMemo(isptItem.getMemo());
-// .setSafeQty(isptItem.getSafeQty());
+ // .setSafeQty(isptItem.getSafeQty());
dtos.add(objDto);
});
return R.ok(dtos);
@@ -710,16 +792,15 @@
}
WaitPakin waitPakin = waitPakinService.getOne(new LambdaQueryWrapper<WaitPakin>()
.eq(WaitPakin::getBarcode, params.getBarcode())
- .eq(WaitPakin::getIoStatus,PakinIOStatus.PAKIN_IO_STATUS_DONE.val)
- );
- if (Cools.isEmpty(waitPakin)){
+ .eq(WaitPakin::getIoStatus, PakinIOStatus.PAKIN_IO_STATUS_DONE.val));
+ if (Cools.isEmpty(waitPakin)) {
throw new CoolException("鏈壘鍒扮粍鎵樻暟鎹�,璇锋鏌ョ姸鎬�");
}
- List<WaitPakinItem> waitPakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>().eq(WaitPakinItem::getPakinId, waitPakin.getId()));
- if (Cools.isEmpty(waitPakinItems)){
+ List<WaitPakinItem> waitPakinItems = waitPakinItemService
+ .list(new LambdaQueryWrapper<WaitPakinItem>().eq(WaitPakinItem::getPakinId, waitPakin.getId()));
+ if (Cools.isEmpty(waitPakinItems)) {
throw new CoolException("鏁版嵁閿欒锛屾湭鎵惧埌缁勬墭鏄庣粏");
}
-
return R.ok(waitPakinItems);
}
@@ -740,28 +821,30 @@
if (Objects.isNull(params.getItemList()) || params.getItemList().isEmpty()) {
throw new CoolException("鍗曟嵁鏄庣粏涓嶈兘涓虹┖锛侊紒");
}
- Long OrderId = params.getItemList().stream().findFirst().get().getAsnId();
- /**鑾峰彇骞冲簱璁㈠崟*/
- AsnOrder order = asnOrderMapper.getOne(new LambdaQueryWrapper<AsnOrder>()
- .eq(AsnOrder::getId, OrderId)
- .eq(AsnOrder::getWkType, OrderWorkType.ORDER_WORK_TYPE_OTHER_IN.type)
- .eq(AsnOrder::getType, OrderType.ORDER_IN.type));
+ Long OrderId = params.getItemList().stream().findFirst().get().getOrderId();
+ /** 鑾峰彇骞冲簱璁㈠崟 */
+ WkOrder order = asnOrderMapper.getOne(new LambdaQueryWrapper<WkOrder>()
+ .eq(WkOrder::getId, OrderId)
+ .eq(WkOrder::getWkType, OrderWorkType.ORDER_WORK_TYPE_OTHER_IN.type)
+ .eq(WkOrder::getType, OrderType.ORDER_IN.type));
if (Objects.isNull(order)) {
throw new CoolException("闈炲钩搴撳崟鎹笉鍙墽琛屼汉宸ヤ笂鏋讹紒锛�");
}
Stock stock = new Stock();
-// if (!Objects.isNull(order.getPoCode()) && StringUtils.isNotBlank(order.getPoCode())) {
-// Purchase purchase = purchaseService.getOne(new LambdaQueryWrapper<Purchase>().eq(Purchase::getCode, order.getPoCode()));
-// if (!Objects.isNull(purchase)) {
-// stock.setPlatOrderNo(purchase.getPlatCode()).setPlatToken(purchase.getPlatId());
-// }
-// }
+ // if (!Objects.isNull(order.getPoCode()) &&
+ // StringUtils.isNotBlank(order.getPoCode())) {
+ // Purchase purchase = purchaseService.getOne(new
+ // LambdaQueryWrapper<Purchase>().eq(Purchase::getCode, order.getPoCode()));
+ // if (!Objects.isNull(purchase)) {
+ // stock.setPlatOrderNo(purchase.getPlatCode()).setPlatToken(purchase.getPlatId());
+ // }
+ // }
String ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_STOCK_CODE, null);
if (StringUtils.isBlank(ruleCode)) {
throw new CoolException("褰撳墠涓氬姟锛�" + SerialRuleCode.SYS_STOCK_CODE + "锛岀紪鐮佽鍒欎笉瀛樺湪锛侊紒");
}
- List<AsnOrderItem> itemList = params.getItemList();
- double sum = itemList.stream().mapToDouble(AsnOrderItem::getAnfme).sum();
+ List<WkOrderItem> itemList = params.getItemList();
+ double sum = itemList.stream().mapToDouble(WkOrderItem::getAnfme).sum();
stock.setAnfme(sum)
.setSourceId(order.getId())
.setType(order.getType())
@@ -771,12 +854,12 @@
if (!stockService.save(stock)) {
throw new CoolException("搴撳瓨淇濆瓨澶辫触锛侊紒");
}
- //TODO 骞冲簱涓婃灦绛栫暐闂锛� 1 骞冲簱搴撲綅鏄崟鐙璁★紝杩樻槸涓庝骇搴撲竴璧风敤绫诲瀷鍖哄垎
+ // TODO 骞冲簱涓婃灦绛栫暐闂锛� 1 骞冲簱搴撲綅鏄崟鐙璁★紝杩樻槸涓庝骇搴撲竴璧风敤绫诲瀷鍖哄垎
Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getCode, params.getLocCode()));
if (Objects.isNull(loc)) {
throw new CoolException("搴撲綅涓嶅瓨鍦紒锛�");
}
- //locItemSerivce
+ // locItemSerivce
List<LocItem> locItems = new ArrayList<>();
itemList.forEach(asnOrderItem -> {
LocItem item = new LocItem();
@@ -831,21 +914,24 @@
if (Objects.isNull(task)) {
throw new CoolException("鎷栫洏浠诲姟涓嶅瓨鍦紒锛�");
}
- List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>().eq(TaskItem::getTaskId, task.getId()));
+ List<TaskItem> taskItems = taskItemService
+ .list(new LambdaQueryWrapper<TaskItem>().eq(TaskItem::getTaskId, task.getId()));
if (taskItems.isEmpty()) {
throw new CoolException("鎷栫洏浠诲姟鏄庣粏涓嶅瓨鍦紒锛�");
}
TaskQueueDto queueDto = new TaskQueueDto();
queueDto.setTask(task).setTaskItems(taskItems);
List<Long> list = taskItems.stream().map(TaskItem::getMatnrId).collect(Collectors.toList());
- List<LocAreaMatRela> matRelas = locAreaMatRelaMapper.selectList(new LambdaQueryWrapper<LocAreaMatRela>().in(LocAreaMatRela::getMatnrId,
- list));
+ List<LocAreaMatRela> matRelas = locAreaMatRelaMapper
+ .selectList(new LambdaQueryWrapper<LocAreaMatRela>().in(LocAreaMatRela::getMatnrId,
+ list));
TaskLocAreaDto locAreaDto = new TaskLocAreaDto();
- /**鍒ゆ柇鏄惁涓虹┖*/
+ /** 鍒ゆ柇鏄惁涓虹┖ */
if (matRelas.isEmpty()) {
locAreaDto.setLocs(new ArrayList<>());
} else {
- Long ids = matRelas.stream().map(LocAreaMatRela::getLocId).collect(Collectors.toList()).stream().findFirst().get();
+ Long ids = matRelas.stream().map(LocAreaMatRela::getLocId).collect(Collectors.toList()).stream().findFirst()
+ .get();
List<Loc> locs = locService.list(new LambdaQueryWrapper<Loc>().eq(Loc::getId, ids));
if (locs.isEmpty()) {
locAreaDto.setLocs(new ArrayList<>());
@@ -878,7 +964,8 @@
if (Objects.isNull(task)) {
throw new CoolException("鎷栫洏浠诲姟涓嶅瓨鍦紒锛�");
}
- List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>().eq(TaskItem::getTaskId, task.getId()));
+ List<TaskItem> taskItems = taskItemService
+ .list(new LambdaQueryWrapper<TaskItem>().eq(TaskItem::getTaskId, task.getId()));
if (!taskItems.isEmpty()) {
throw new CoolException("鎷栫洏浠诲姟鏄庣粏涓嶅瓨鍦紒锛�");
}
@@ -897,17 +984,18 @@
/**
* @param
+ * @param user
* @return
* @author Ryan
* @description 閫氳繃瀹瑰櫒鑾峰彇缁勬嫋鐗╂枡
* @time 2025/4/9 16:57
*/
@Override
- public R getItemByContainer(Map<String, Object> params) {
-// if (Objects.isNull(params.get("code"))) {
-// throw new CoolException("鍙傛暟涓嶈兘涓虹┖锛侊紒");
-// }
- //鑾峰彇缁勬嫋鏈敓鎴愪换鍔＄殑缁勬嫋妗�
+ public R getItemByContainer(Map<String, Object> params, User user) {
+ // if (Objects.isNull(params.get("code"))) {
+ // throw new CoolException("鍙傛暟涓嶈兘涓虹┖锛侊紒");
+ // }
+ // 鑾峰彇缁勬嫋鏈敓鎴愪换鍔＄殑缁勬嫋妗�
List<Short> asList = Arrays.asList(Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val));
Short flagDefect = 0;
if (!Objects.isNull(params.get("type")) && params.get("type").equals("defective")) {
@@ -915,16 +1003,44 @@
}
List<WaitPakin> waitPakin = waitPakinService.list(new LambdaQueryWrapper<WaitPakin>()
.eq(WaitPakin::getBarcode, params.get("barcode").toString())
-// .eq(WaitPakin::getFlagDefect, flagDefect)
+ // .eq(WaitPakin::getFlagDefect, flagDefect)
.in(WaitPakin::getIoStatus, asList));
if (!Cools.isEmpty(waitPakin)) {
throw new CoolException("鎵樼洏涓嶅彲鐢�,鍦ㄧ粍鎵樹腑宸插瓨鍦�");
}
- List<Loc> locs = locService.list(new LambdaQueryWrapper<Loc>().eq(Loc::getBarcode, params.get("barcode").toString()));
+ List<Loc> locs = locService
+ .list(new LambdaQueryWrapper<Loc>().eq(Loc::getBarcode, params.get("barcode").toString()));
if (!Cools.isEmpty(locs)) {
throw new CoolException("鎵樼洏涓嶅彲鐢紝鍦ㄥ簱浣嶄腑宸插瓨鍦�");
}
- return R.ok("鎵樼洏鍙敤");
+ List<BasContainer> containers = basContainerService.list();
+ for (BasContainer container : containers) {
+ String codeType = container.getCodeType(); // 鑾峰彇姝ｅ垯琛ㄨ揪寮�
+ if (params.get("barcode").toString().matches(codeType)) { // 鍒ゆ柇鏉＄爜鏄惁绗﹀悎杩欎釜姝ｅ垯
+ List<WarehouseRoleMenu> warehouseRoleMenus = warehouseRoleMenuService
+ .list(new LambdaQueryWrapper<WarehouseRoleMenu>()
+ .in(WarehouseRoleMenu::getRoleId, Arrays.asList(user.getUserRoleIds())));
+ Set<WarehouseRoleMenu> warehouseRoleMenusSet = new HashSet<>(warehouseRoleMenus);
+ // 鑾峰彇 menuId 闆嗗悎
+ Set<Long> menuIdSet = warehouseRoleMenusSet.stream()
+ .map(WarehouseRoleMenu::getMenuId)
+ .collect(Collectors.toSet());
+ // 鑾峰彇 areaList 骞惰浆鎹负 Long 绫诲瀷鐨� Set
+ List<Integer> areaList = container.getAreas();
+ Set<Long> areaSet = new HashSet<>();
+ if (areaList != null) {
+ areaList.forEach(area -> areaSet.add(area.longValue()));
+ }
+ // 姹備袱涓泦鍚堢殑浜ら泦
+ menuIdSet.retainAll(areaSet);
+
+ List<WarehouseAreas> areas = warehouseAreasService.list(new LambdaQueryWrapper<WarehouseAreas>()
+ .in(WarehouseAreas::getId, menuIdSet));
+ return R.ok(areas);
+
+ }
+ }
+ return R.ok(new ArrayList<>());
}
/**
@@ -936,37 +1052,41 @@
*/
@Override
public R getUnItemByContainer(Map<String, Object> params) {
- if (Cools.isEmpty(params.get("barcode")) && Cools.isEmpty(params.get("code"))){
+ if (Cools.isEmpty(params.get("barcode")) && Cools.isEmpty(params.get("code"))) {
throw new CoolException("瀹瑰櫒鍙蜂笌缁勬墭妗ｇ紪鐮佷笉鑳藉叏涓虹┖");
}
- //鑾峰彇缁勬嫋鏈敓鎴愪换鍔＄殑缁勬嫋妗�
-// List<Short> asList = Arrays.asList(Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val), Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val));
+ // 鑾峰彇缁勬嫋鏈敓鎴愪换鍔＄殑缁勬嫋妗�
+ // List<Short> asList =
+ // Arrays.asList(Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val),
+ // Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val));
WaitPakin waitPakin = waitPakinService.getOne(new LambdaQueryWrapper<WaitPakin>()
- .eq(!Cools.isEmpty(params.get("barcode")),WaitPakin::getBarcode, params.get("barcode"))
- .eq(!Cools.isEmpty(params.get("code")),WaitPakin::getCode, params.get("code"))
+ .eq(!Cools.isEmpty(params.get("barcode")), WaitPakin::getBarcode, params.get("barcode"))
+ .eq(!Cools.isEmpty(params.get("code")), WaitPakin::getCode, params.get("code"))
.eq(WaitPakin::getIoStatus, PakinIOStatus.PAKIN_IO_STATUS_DONE.val));
if (Objects.isNull(waitPakin)) {
return R.error("鏈壘鍒拌瀹瑰櫒鐮佺殑缁勬墭鏄庣粏锛岃妫�鏌ョ粍鎵樼姸鎬�");
}
List<WaitPakinItem> pakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>()
.eq(WaitPakinItem::getPakinId, waitPakin.getId()));
-// if (pakinItems.isEmpty()) {
-// return R.ok(new ArrayList<>());
-// }
-// List<Long> list = pakinItems.stream().map(WaitPakinItem::getSource).collect(Collectors.toList());
-// LambdaQueryWrapper<WarehouseAreasItem> queryWrapper = new LambdaQueryWrapper<WarehouseAreasItem>().in(WarehouseAreasItem::getId, list);
-// List<WarehouseAreasItem> warehouseAreasItems = warehouseAreasItemService.list(queryWrapper);
-// for (int i = 0; i < warehouseAreasItems.size(); i++) {
-// for (WaitPakinItem pakinItem : pakinItems) {
-// if (warehouseAreasItems.get(i).getId().equals(pakinItem.getSource())) {
-// warehouseAreasItems.get(i).setAnfme(pakinItem.getAnfme());
-// }
-// }
-// }
+ // if (pakinItems.isEmpty()) {
+ // return R.ok(new ArrayList<>());
+ // }
+ // List<Long> list =
+ // pakinItems.stream().map(WaitPakinItem::getSource).collect(Collectors.toList());
+ // LambdaQueryWrapper<WarehouseAreasItem> queryWrapper = new
+ // LambdaQueryWrapper<WarehouseAreasItem>().in(WarehouseAreasItem::getId, list);
+ // List<WarehouseAreasItem> warehouseAreasItems =
+ // warehouseAreasItemService.list(queryWrapper);
+ // for (int i = 0; i < warehouseAreasItems.size(); i++) {
+ // for (WaitPakinItem pakinItem : pakinItems) {
+ // if (warehouseAreasItems.get(i).getId().equals(pakinItem.getSource())) {
+ // warehouseAreasItems.get(i).setAnfme(pakinItem.getAnfme());
+ // }
+ // }
+ // }
return R.ok(pakinItems);
}
-
/**
* @param
@@ -977,7 +1097,8 @@
*/
@Override
public R defectProducts(String trackCode) {
- AsnOrderItem orderItem = asnOrderItemMapper.selectOne(new LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getTrackCode, trackCode));
+ WkOrderItem orderItem = asnOrderItemMapper
+ .selectOne(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getTrackCode, trackCode));
return R.ok(orderItem);
}
@@ -989,11 +1110,13 @@
*/
@Override
public R getPakinInStock(String barcode) {
- WaitPakin waitPakin = waitPakinService.getOne(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getBarcode, barcode));
+ WaitPakin waitPakin = waitPakinService
+ .getOne(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getBarcode, barcode));
if (Objects.isNull(waitPakin)) {
throw new CoolException("缁勬嫋鍗曟嵁涓嶅瓨鍦紒锛�");
}
- List<WaitPakinItem> pakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>().eq(WaitPakinItem::getPakinId, waitPakin.getId()));
+ List<WaitPakinItem> pakinItems = waitPakinItemService
+ .list(new LambdaQueryWrapper<WaitPakinItem>().eq(WaitPakinItem::getPakinId, waitPakin.getId()));
if (pakinItems.isEmpty()) {
return R.ok(new ArrayList<>());
}
@@ -1034,7 +1157,8 @@
@Override
public synchronized R generateTask(Map<String, Object> map, Long loginUserId) {
String barcode = map.get("barcode").toString();
- List<WaitPakin> waitPakins = waitPakinService.list(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getBarcode, barcode));
+ List<WaitPakin> waitPakins = waitPakinService
+ .list(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getBarcode, barcode));
if (waitPakins.isEmpty()) {
throw new CoolException("鍗曟嵁涓嶅瓨鍦� 锛侊紒");
}
@@ -1049,12 +1173,12 @@
/**
* 鑾峰彇ReceiptDetlsDtos
*/
- private R getAsnOrderItem(List<AsnOrderItem> items) {
+ private R getAsnOrderItem(List<WkOrderItem> items) {
List<ReceiptDetlsDto> detlsDtos = new ArrayList<>();
items.forEach(asnOrderItem -> {
ReceiptDetlsDto detlsDto = new ReceiptDetlsDto();
- detlsDto.setAsnCode(asnOrderItem.getAsnCode())
+ detlsDto.setAsnCode(asnOrderItem.getOrderCode())
.setId(asnOrderItem.getId())
.setMaktx(asnOrderItem.getMaktx())
.setFieldsIndex(asnOrderItem.getFieldsIndex())
@@ -1068,40 +1192,43 @@
.setSplrBatch(asnOrderItem.getSplrBatch())
.setExtendFields(asnOrderItem.getExtendFields())
.setMatnr(asnOrderItem.getMatnrCode())
- .setInspect(asnOrderItem.getIsptResult$()) //璐ㄦ缁撴灉
+ .setInspect(asnOrderItem.getIsptResult$()) // 璐ㄦ缁撴灉
.setPlatItemId(asnOrderItem.getPlatItemId());
Matnr matnr = matnrMapper.selectById(asnOrderItem.getMatnrId());
if (Objects.isNull(matnr)) {
throw new CoolException("鏁版嵁閿欒锛氬綋鍓嶇墿鏂欎笉瀛樺湪锛侊紒");
}
- //SET 鐗╂枡鏈�澶у瓨鏀炬暟閲�
+ // SET 鐗╂枡鏈�澶у瓨鏀炬暟閲�
detlsDto.setMaxQty(matnr.getMaxQty())
.setMatnrId(matnr.getId());
-// QlyInspect inspect = qlyInspectMapper.selectOne(new LambdaQueryWrapper<QlyInspect>()
-// .eq(QlyInspect::getAsnId, asnOrderItem.getAsnId()));
-// if (!Objects.isNull(inspect)) {
-// //set 璐ㄦ缁撴灉
-// detlsDto.setInspect(inspect.getStatus$());
-// }
- //鑾峰彇褰撳墠搴撳瓨淇℃伅
+ // QlyInspect inspect = qlyInspectMapper.selectOne(new
+ // LambdaQueryWrapper<QlyInspect>()
+ // .eq(QlyInspect::getAsnId, asnOrderItem.getAsnId()));
+ // if (!Objects.isNull(inspect)) {
+ // //set 璐ㄦ缁撴灉
+ // detlsDto.setInspect(inspect.getStatus$());
+ // }
+ // 鑾峰彇褰撳墠搴撳瓨淇℃伅
LocItem stockItem = locItemService.getOne(new LambdaQueryWrapper<LocItem>()
-// .eq(LocItem::getOrderItemId, asnOrderItem.getId())
+ // .eq(LocItem::getOrderItemId, asnOrderItem.getId())
.eq(LocItem::getFieldsIndex, asnOrderItem.getFieldsIndex())
.eq(LocItem::getBatch, asnOrderItem.getSplrBatch())
.eq(LocItem::getMatnrId, asnOrderItem.getMatnrId()));
- //SET 褰撳墠搴撳瓨鏁伴噺
+ // SET 褰撳墠搴撳瓨鏁伴噺
if (Objects.isNull(stockItem)) {
detlsDto.setStockQty(0.0);
} else {
- detlsDto.setStockQty(stockItem.getAnfme() + stockItem.getWorkQty());
+ Double anfme = Math.round((stockItem.getAnfme() + stockItem.getWorkQty()) * 10000) / 10000.0;
+ detlsDto.setStockQty(anfme);
}
if (!Objects.isNull(asnOrderItem.getPoDetlId())) {
- //鑾峰彇閲囪喘鍗曟槑缁嗕俊鎭�
- PurchaseItem purchaseItem = purchaseItemMapper.selectOne(new LambdaQueryWrapper<PurchaseItem>().eq(PurchaseItem::getId, asnOrderItem.getPoDetlId()));
+ // 鑾峰彇閲囪喘鍗曟槑缁嗕俊鎭�
+ PurchaseItem purchaseItem = purchaseItemMapper.selectOne(
+ new LambdaQueryWrapper<PurchaseItem>().eq(PurchaseItem::getId, asnOrderItem.getPoDetlId()));
if (Objects.isNull(purchaseItem)) {
- //SET 骞冲彴琛屽彿
+ // SET 骞冲彴琛屽彿
detlsDto.setPlatformId(purchaseItem.getPlatItemId());
}
}
@@ -1110,6 +1237,5 @@
return R.ok(detlsDtos);
}
-
}
--
Gitblit v1.9.1