Compare commits

..

No commits in common. "93e1885898a69c04d067227bef1a87d12bd94d72" and "55bdb3c95a93469abaaac533a7b64f3435475c44" have entirely different histories.

34 changed files with 341 additions and 484 deletions

View File

@ -220,7 +220,6 @@ public class InventoryController extends BaseController {
.itemId(item.getId())
.uniqNo(qrCodeContent.getUniqNo())
.materialNo(qrCodeContent.getMaterialNo())
.materialDesc(qrCodeContent.getMaterialDesc())
.materialId(material.getId())
.batchNo(qrCodeContent.getBatchNo())
.serialNo(qrCodeContent.getSerialNo())

View File

@ -1,8 +1,6 @@
package com.nflg.wms.admin.controller;
/**
* 普通物料收货单
*/
/* * 普通物料收货单*/
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.convert.Convert;
@ -42,10 +40,6 @@ import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
/**
* 普通物料收货单
*/
@RestController
@RequestMapping("/pgi/normal")
public class NormalPGIController extends BaseController {
@ -77,23 +71,12 @@ public class NormalPGIController extends BaseController {
private IWmsPoReceiptItemService wmsPoReceiptItemService;
//收货单分页
/**
* 送货单列表
* @param request
* @return
*/
@PostMapping("search")
@ApiMark(moduleName = "送货单管理", apiName = "送货单列表")
public ApiResult<PageData<SrmOrderVO>> search(@Valid @RequestBody SRMOrderSearchQO request) {
return ApiResult.success(wmsSrmOrderService.search(request));
}
/**
* 送货单详情
* @param orderId 订单ID
* @return
*/
//收货单详情
@GetMapping("getOrderItem")
@ApiMark(moduleName = "送货单管理", apiName = "获取送货单详情")
@ -105,11 +88,16 @@ public class NormalPGIController extends BaseController {
return ApiResult.success(srmOrderItemVOS);
}
/**
* 获取扫码的详情信息
* @param orderItemId 订单项ID
* @return
*/
//PDA 扫码获取收货信息
@GetMapping("getOrderItemByOrderNo")
@ApiMark(moduleName = "送货单管理", apiName = "PDA扫描送货单号获取送货单详情")
public ApiResult<PDAOrderVO> getOrderItemByOrderNo(@RequestParam String orderNo) {
PDAOrderVO pdaOrderVO = normalPGIControllerService.getOrderItemByOrderNo(orderNo);
return ApiResult.success(pdaOrderVO);
}
// 查看扫码记录
@GetMapping("getScanCodes")
@ApiMark(moduleName = "送货单管理", apiName = "获取扫码的详情信息")
@ -119,247 +107,6 @@ public class NormalPGIController extends BaseController {
return ApiResult.success(pdas);
}
/**
* 扫描送货单号获取送货单详情PDA
* @param orderNo 送货单号
* @return
*/
//PDA 扫码获取收货信息
@GetMapping("PDA/getOrderItemByOrderNo")
@ApiMark(moduleName = "送货单管理", apiName = "PDA扫描送货单号获取送货单详情")
public ApiResult<PDAOrderVO> getOrderItemByOrderNo(@RequestParam String orderNo) {
PDAOrderVO pdaOrderVO = normalPGIControllerService.getOrderItemByOrderNo(orderNo);
return ApiResult.success(pdaOrderVO);
}
/**
* 收货确认(PDA使用)
*
* @param request
* @return
*/
//收货确认
@PostMapping("PDA/takeDelivery")
@ApiMark(moduleName = "送货单管理", apiName = "收货确认")
public ApiResult<Void> takeDelivery(@Valid @RequestBody List<SrmMaterialReceiptQO> request) {
VUtil.trueThrowBusinessError(CollectionUtil.isEmpty(request)).throwMessage("收货参数为空");
WmsSrmOrder order = wmsSrmOrderService.lambdaQuery().eq(WmsSrmOrder::getNoteNum, request.get(0).getNoteNum()).one();
VUtil.trueThrowBusinessError(Objects.isNull(order)).throwMessage("收货单不存在");
List<SAPSyncParamsDTO> sapSyncParamsDTOS = getSapSyncParamsDTOS(request, order);
WmsPoReceipt wmsPoReceipt = new WmsPoReceipt()
.setCreateTime(LocalDateTime.now())
.setId(IdUtil.getSnowflakeNextId())
.setOrderNo(order.getNoteNum())
.setCreateUserName(UserUtil.getUserName())
.setCreateUserId(UserUtil.getUserId())
.setFactoryCode(order.getIuCode())
.setIsCompleted(false);
WmsQcReceive wmsQcReceive = new WmsQcReceive()
.setCreateTime(LocalDateTime.now())
.setId(IdUtil.getSnowflakeNextId())
.setIsCompleted((short) 0)
.setOrderNo(order.getNoteNum())
.setCreateUserName(UserUtil.getUserName())
.setFactoryCode(order.getIuCode())
.setCreateUserId(UserUtil.getUserId());
List<WmsPoReceiptItem> wmsPoReceiptItems = new ArrayList<>();
List<WmsQcReceiveItem> wmsQcReceiveItems = new ArrayList<>();
List<SrmMaterialReceiptScanCodes> srmMaterialReceiptScanCodes = new ArrayList<>();
List<QCMaterialSyncDTO> qcMaterialSyncDTOS = new ArrayList<>();
for (SrmMaterialReceiptQO item : request) {
if (item.getReceiptNum().equals(BigDecimal.ZERO))
continue;
SAPSyncParamsDTO materialInfoInOrder = sapSyncParamsDTOS.stream()
.filter(sapSyncParamsDTO ->
sapSyncParamsDTO.getEbeln().equals(item.getPoNum())
&& sapSyncParamsDTO.getEbelp().equals(item.getPoLineNumber()))
.findFirst()
.orElse(null);
//数量验证(判断收货数量是否大于了未收数量)
VUtil.trueThrowBusinessError(item.getReceiptNum().compareTo(materialInfoInOrder.getTransportNum()) > 0).throwMessage("物料收货数量[" + item.getReceiptNum() + "]大于了未收数量[" + materialInfoInOrder.getTransportNum() + "],订单号:" + item.getPoNum());
//序列号和批次号验证
List<SrmMaterialReceiptScanCodes> codes = normalPGIControllerService.validateScanCodes(item, materialInfoInOrder);
if (CollectionUtil.isNotEmpty(codes)) {
srmMaterialReceiptScanCodes.addAll(codes);
}
boolean isQuality = materialInfoInOrder.getKzkri().equals("X");
// 如果是质检单
if (isQuality) {
setQcMaterialSyncDto(qcMaterialSyncDTOS, item, order, codes, materialInfoInOrder, wmsQcReceiveItems, wmsQcReceive.getId());
} else {
setPoReceive(item, wmsPoReceiptItems, wmsPoReceipt.getId(), materialInfoInOrder);
}
}
normalPGIControllerService.takeDelivery(wmsPoReceipt, wmsQcReceive, wmsPoReceiptItems, wmsQcReceiveItems, srmMaterialReceiptScanCodes, qcMaterialSyncDTOS, order.getId());
return ApiResult.success();
}
/**
* 普通物料的上架任务PDA
* @param orederNo 送货单号或是任务单号
* @return
*/
@GetMapping("PDA/task")
@ApiMark(moduleName = "送货单管理", apiName = "普通物料上架任务")
public ApiResult<List<PoReceiveTaskVO>> takeDelivery(@Valid @RequestParam String orederNo) {
List<WmsPoReceipt> wmsPoReceipts = wmsPoReceiptItemService.getTask(orederNo);
if (CollectionUtil.isNotEmpty(wmsPoReceipts)) {
return ApiResult.success(Convert.toList(PoReceiveTaskVO.class, wmsPoReceipts));
}
return ApiResult.success(new ArrayList<>());
}
/**
* 上架任务详情PDA
* * @param id 任务ID
* */
@GetMapping("PDA/task/item")
@ApiMark(moduleName = "送货单管理", apiName = "普通上架物料详情")
public ApiResult<List<PoReceiveTaskItemVO>> takeDeliveryItem(@Valid @RequestParam Long taskId) {
List<WmsPoReceiptItem> wmsPoReceipts = wmsPoReceiptItemService.lambdaQuery()
.eq(WmsPoReceiptItem::getReceiveId, taskId)
.list();
if (CollectionUtil.isNotEmpty(wmsPoReceipts)) {
return ApiResult.success(Convert.toList(PoReceiveTaskItemVO.class, wmsPoReceipts));
} else {
return ApiResult.success(new ArrayList<>());
}
}
/**
* 采购物料入库确认PDA
* @param request
* @return
*/
@PostMapping("PDA/task/confirm")
@ApiMark(moduleName = "送货单管理", apiName = "普通物料任务上架确认")
public ApiResult<Void> takeDeliveryConfirm(@Valid @RequestBody PoReceiveTaskConfirmQO request) {
//首先判断是否已经确认
WmsPoReceipt wmsPoReceipt = wmsPoReceiptService.getById(request.getTaskId());
VUtil.trueThrowBusinessError(Objects.isNull(wmsPoReceipt)).throwMessage("收货单不存在");
VUtil.trueThrowBusinessError(Objects.equals(wmsPoReceipt.getIsCompleted(), true)).throwMessage("此任务已入库");
List<Long> uniqueIds = request.getItems().stream()
.map(PoReceiveTaskItemConfirmQO::getId) // 提取每个对象的 ID
.distinct() // 去重
.collect(Collectors.toList());
List<WmsPoReceiptItem> wmsPoReceiptItems = wmsPoReceiptItemService.lambdaQuery()
.in(WmsPoReceiptItem::getId, uniqueIds)
.list();
VUtil.trueThrowBusinessError(CollectionUtil.isEmpty(wmsPoReceiptItems)).throwMessage("获取入库详情失败");
List<WmsPoReceiptItem> receiptItems = new ArrayList<>();
List<StorageLocationDTO> storageLocationDTOS = new ArrayList<>();
List<InventoryDTO> inventories = new ArrayList<>();
List<ZWM3A17DTO> zwm3A17DTOS = new ArrayList<>();
for (WmsPoReceiptItem item : wmsPoReceiptItems) {
PoReceiveTaskItemConfirmQO qo = request.getItems().stream()
.filter(q -> q.getId().equals(item.getId()))
.findFirst()
.orElse(null);
if (Objects.isNull(qo))
continue;
item.setCrossQty(qo.getCrossQty());
item.setReceivedWarehouse(qo.getReceivedWarehouse());
item.setInQty(item.getReceiptNum());
item.setUpdateTime(LocalDateTime.now());
item.setUpdateUserId(UserUtil.getUserId());
item.setUpdateUserName(UserUtil.getUserName());
receiptItems.add(item);
//储位处理
if (!qo.getStorageLocation().equals(qo.getStorageLocationNew())) {
List<String> bins = Arrays.asList(item.getStorageLocation().split("/"));
storageLocationDTOS.add(new StorageLocationDTO()
.setBinNos(bins)
.setMaterialNo(item.getItemCode())
.setWarehouseNo(item.getReceivedWarehouse())
.setFactory(wmsPoReceipt.getFactoryCode())
);
}
// SAP 和条码处理
//传入SAP的信息
ZWM3A17DTO zwm3A17DTO = zwm3A17DTOS.stream()
.filter(zwm3A17DTO1 -> zwm3A17DTO1.getEbeln().equals(item.getPoNum()))
.findFirst()
.orElse(null);
if (Objects.isNull(zwm3A17DTO)) {
zwm3A17DTO = new ZWM3A17DTO()
.setEbeln(item.getPoNum())
.setUsnam(UserUtil.getUserName())
.setItem1(new ArrayList<>())
.setItem2(new ArrayList<>());
zwm3A17DTOS.add(zwm3A17DTO);
}
List<ZWM3A17Item1DTO> item1 = zwm3A17DTO.getItem1();
List<ZWM3A17Item2DTO> item2 = zwm3A17DTO.getItem2();
List<SrmMaterialReceiptScanCodes> scanCode = srmMaterialReceiptScanCodesRepository.findByOrderItemId(item.getOrderItemId().toString());
if (CollectionUtil.isEmpty(scanCode)) {
scanCode.forEach(code -> {
// 库存
InventoryDTO inventoryDTO = new InventoryDTO()
.setMaterialNo(item.getItemCode())
.setFactoryNo(wmsPoReceipt.getFactoryCode())
.setWarehouseNo(item.getReceivedWarehouse())
.setBatchNumber(code.getBatchNumber())
.setNum(code.getCodeNum());
inventories.add(inventoryDTO);
item1.add(new ZWM3A17Item1DTO()
.setEBELP(item.getPoLineNumber())
.setMATNR(item.getItemCode())
.setERFMG(code.getCodeNum())
.setMEINS(item.getUomCode())
.setCHARG(code.getBatchNumber())
.setWERKS(wmsPoReceipt.getFactoryCode())
.setLGORT(item.getReceivedWarehouse())
.setKZKRI("")
);
item2.add(new ZWM3A17Item2DTO()
.setEBELP(item.getPoLineNumber())
.setFLAG("")
.setFLAG(code.getSerialNumbers()));
});
} else {
// 库存
InventoryDTO inventoryDTO = new InventoryDTO()
.setMaterialNo(item.getItemCode())
.setFactoryNo(wmsPoReceipt.getFactoryCode())
.setWarehouseNo(item.getReceivedWarehouse())
.setBatchNumber("")
.setNum(item.getInQty());
inventories.add(inventoryDTO);
item1.add(new ZWM3A17Item1DTO()
.setEBELP(item.getPoLineNumber())
.setMATNR(item.getItemCode())
.setERFMG(item.getInQty())
.setMEINS(item.getUomCode())
.setCHARG("")
.setWERKS(wmsPoReceipt.getFactoryCode())
.setLGORT(item.getReceivedWarehouse())
.setKZKRI("")
);
}
}
normalPGIControllerService.takeDeliveryConfirm(receiptItems, storageLocationDTOS, inventories, zwm3A17DTOS, request.getTaskId());
return ApiResult.success();
}
private List<SAPSyncParamsDTO> getSapSyncParamsDTOS(List<SrmMaterialReceiptQO> request, WmsSrmOrder order) {
List<Triple<String, String, String>> uniqueCombinations = request.stream()
.map(item -> Triple.of(item.getPoNum(), order.getSupplierNum(), item.getItemCode()))
@ -526,7 +273,7 @@ public class NormalPGIController extends BaseController {
content.setLineVOList(new ArrayList<>());
dto.setContent(content);
dto.setCode("SCAN_RCV_RECEIVE_TO_SRM");
qcDto.setPushDto(dto);
qcDto.setPushDto(srmPushDto);
}
srmPushDto = qcDto.getPushDto();
@ -563,6 +310,216 @@ public class NormalPGIController extends BaseController {
qcDto.getReceiptIds().add(qmsReceiptItem.getId());
}
//收货确认
@PostMapping("takeDelivery")
@ApiMark(moduleName = "送货单管理", apiName = "收货确认")
public ApiResult<Void> takeDelivery(@Valid @RequestBody List<SrmMaterialReceiptQO> request) {
VUtil.trueThrowBusinessError(CollectionUtil.isEmpty(request)).throwMessage("收货参数为空");
WmsSrmOrder order = wmsSrmOrderService.lambdaQuery().eq(WmsSrmOrder::getId, request.get(0).getNoteNum()).one();
VUtil.trueThrowBusinessError(Objects.isNull(order)).throwMessage("收货单不存在");
List<SAPSyncParamsDTO> sapSyncParamsDTOS = getSapSyncParamsDTOS(request, order);
WmsPoReceipt wmsPoReceipt = new WmsPoReceipt()
.setCreateTime(LocalDateTime.now())
.setId(IdUtil.getSnowflakeNextId())
.setOrderNo(order.getNoteNum())
.setCreateUserName(UserUtil.getUserName())
.setCreateUserId(UserUtil.getUserId())
.setFactoryCode(order.getIuCode())
.setIsCompleted(false);
WmsQcReceive wmsQcReceive = new WmsQcReceive()
.setCreateTime(LocalDateTime.now())
.setId(IdUtil.getSnowflakeNextId())
.setIsCompleted((short) 0)
.setOrderNo(order.getNoteNum())
.setCreateUserName(UserUtil.getUserName())
.setFactoryCode(order.getIuCode())
.setCreateUserId(UserUtil.getUserId());
List<WmsPoReceiptItem> wmsPoReceiptItems = new ArrayList<>();
List<WmsQcReceiveItem> wmsQcReceiveItems = new ArrayList<>();
List<SrmMaterialReceiptScanCodes> srmMaterialReceiptScanCodes = new ArrayList<>();
List<QCMaterialSyncDTO> qcMaterialSyncDTOS = new ArrayList<>();
for (SrmMaterialReceiptQO item : request) {
if (item.getReceiptNum().equals(BigDecimal.ZERO))
continue;
SAPSyncParamsDTO materialInfoInOrder = sapSyncParamsDTOS.stream()
.filter(sapSyncParamsDTO ->
sapSyncParamsDTO.getEbeln().equals(item.getPoNum())
&& sapSyncParamsDTO.getEbelp().equals(item.getPoLineNumber()))
.findFirst()
.orElse(null);
//数量验证(判断收货数量是否大于了未收数量)
VUtil.trueThrowBusinessError(item.getReceiptNum().compareTo(materialInfoInOrder.getTransportNum()) > 0).throwMessage("物料收货数量[" + item.getReceiptNum() + "]大于了未收数量[" + materialInfoInOrder.getTransportNum() + "],订单号:" + item.getPoNum());
//序列号和批次号验证
List<SrmMaterialReceiptScanCodes> codes = normalPGIControllerService.validateScanCodes(item, materialInfoInOrder);
if (CollectionUtil.isNotEmpty(codes)) {
srmMaterialReceiptScanCodes.addAll(codes);
}
boolean isQuality = materialInfoInOrder.getKzkri().equals("X");
// 如果是质检单
if (isQuality) {
setQcMaterialSyncDto(qcMaterialSyncDTOS, item, order, codes, materialInfoInOrder, wmsQcReceiveItems, wmsQcReceive.getId());
} else {
setPoReceive(item, wmsPoReceiptItems, wmsPoReceipt.getId(), materialInfoInOrder);
}
}
normalPGIControllerService.takeDelivery(wmsPoReceipt, wmsQcReceive, wmsPoReceiptItems, wmsQcReceiveItems, srmMaterialReceiptScanCodes, qcMaterialSyncDTOS, order.getId());
return ApiResult.success();
}
@GetMapping("task")
@ApiMark(moduleName = "送货单管理", apiName = "普通物料上架任务")
public ApiResult<List<PoReceiveTaskVO>> takeDelivery(@Valid @RequestBody String orederNo) {
List<WmsPoReceipt> wmsPoReceipts = wmsPoReceiptItemService.getTask(orederNo);
if (CollectionUtil.isNotEmpty(wmsPoReceipts)) {
return ApiResult.success(Convert.toList(PoReceiveTaskVO.class, wmsPoReceipts));
}
return ApiResult.success(new ArrayList<>());
}
@GetMapping("task/item")
@ApiMark(moduleName = "送货单管理", apiName = "普通上架物料详情")
public ApiResult<List<PoReceiveTaskItemVO>> takeDeliveryItem(@Valid @RequestBody Long taskId) {
List<WmsPoReceiptItem> wmsPoReceipts = wmsPoReceiptItemService.lambdaQuery()
.eq(WmsPoReceiptItem::getReceiveId, taskId)
.list();
if (CollectionUtil.isNotEmpty(wmsPoReceipts)) {
return ApiResult.success(Convert.toList(PoReceiveTaskItemVO.class, wmsPoReceipts));
} else {
return ApiResult.success(new ArrayList<>());
}
}
@PostMapping("task/confirm")
@ApiMark(moduleName = "送货单管理", apiName = "普通物料任务上架确认")
public ApiResult<Void> takeDeliveryConfirm(@Valid @RequestBody PoReceiveTaskConfirmQO request) {
//首先判断是否已经确认
WmsPoReceipt wmsPoReceipt = wmsPoReceiptService.getById(request.getTaskId());
VUtil.trueThrowBusinessError(Objects.isNull(wmsPoReceipt)).throwMessage("收货单不存在");
VUtil.trueThrowBusinessError(Objects.equals(wmsPoReceipt.getIsCompleted(), true)).throwMessage("此任务已入库");
List<Long> uniqueIds = request.getItems().stream()
.map(PoReceiveTaskItemConfirmQO::getId) // 提取每个对象的 ID
.distinct() // 去重
.collect(Collectors.toList());
List<WmsPoReceiptItem> wmsPoReceiptItems = wmsPoReceiptItemService.lambdaQuery()
.in(WmsPoReceiptItem::getId, uniqueIds)
.list();
VUtil.trueThrowBusinessError(CollectionUtil.isEmpty(wmsPoReceiptItems)).throwMessage("获取入库详情失败");
List<WmsPoReceiptItem> receiptItems = new ArrayList<>();
List<StorageLocationDTO> storageLocationDTOS = new ArrayList<>();
List<InventoryDTO> inventories = new ArrayList<>();
List<ZWM3A17DTO> zwm3A17DTOS = new ArrayList<>();
for (WmsPoReceiptItem item : wmsPoReceiptItems) {
PoReceiveTaskItemConfirmQO qo = request.getItems().stream()
.filter(q -> q.getId().equals(item.getId()))
.findFirst()
.orElse(null);
if (Objects.isNull(qo))
continue;
item.setCrossQty(qo.getCrossQty());
item.setReceivedWarehouse(qo.getReceivedWarehouse());
item.setInQty(item.getReceiptNum());
item.setUpdateTime(LocalDateTime.now());
item.setUpdateUserId(UserUtil.getUserId());
item.setUpdateUserName(UserUtil.getUserName());
receiptItems.add(item);
//储位处理
if (!qo.getStorageLocation().equals(qo.getStorageLocationNew())) {
List<String> bins = Arrays.asList(item.getStorageLocation().split("/"));
storageLocationDTOS.add(new StorageLocationDTO()
.setBinNos(bins)
.setMaterialNo(item.getItemCode())
.setWarehouseNo(item.getReceivedWarehouse())
.setFactory(wmsPoReceipt.getFactoryCode())
);
}
// SAP 和条码处理
//传入SAP的信息
ZWM3A17DTO zwm3A17DTO = zwm3A17DTOS.stream()
.filter(zwm3A17DTO1 -> zwm3A17DTO1.getEbeln().equals(item.getPoNum()))
.findFirst()
.orElse(null);
if (Objects.isNull(zwm3A17DTO)) {
zwm3A17DTO = new ZWM3A17DTO()
.setEbeln(item.getPoNum())
.setUsnam(UserUtil.getUserName())
.setItem1(new ArrayList<>())
.setItem2(new ArrayList<>());
zwm3A17DTOS.add(zwm3A17DTO);
}
List<ZWM3A17Item1DTO> item1 = zwm3A17DTO.getItem1();
List<ZWM3A17Item2DTO> item2 = zwm3A17DTO.getItem2();
List<SrmMaterialReceiptScanCodes> scanCode = srmMaterialReceiptScanCodesRepository.findByOrderItemId(item.getOrderItemId().toString());
if (CollectionUtil.isEmpty(scanCode)) {
scanCode.forEach(code -> {
// 库存
InventoryDTO inventoryDTO = new InventoryDTO()
.setMaterialNo(item.getItemCode())
.setFactoryNo(wmsPoReceipt.getFactoryCode())
.setWarehouseNo(item.getReceivedWarehouse())
.setBatchNumber(code.getBatchNumber())
.setNum(code.getCodeNum());
inventories.add(inventoryDTO);
item1.add(new ZWM3A17Item1DTO()
.setEBELP(item.getPoLineNumber())
.setMATNR(item.getItemCode())
.setERFMG(code.getCodeNum())
.setMEINS(item.getUomCode())
.setCHARG(code.getBatchNumber())
.setWERKS(wmsPoReceipt.getFactoryCode())
.setLGORT(item.getReceivedWarehouse())
.setKZKRI("")
);
item2.add(new ZWM3A17Item2DTO()
.setEBELP(item.getPoLineNumber())
.setFLAG("")
.setFLAG(code.getSerialNumbers()));
});
} else {
// 库存
InventoryDTO inventoryDTO = new InventoryDTO()
.setMaterialNo(item.getItemCode())
.setFactoryNo(wmsPoReceipt.getFactoryCode())
.setWarehouseNo(item.getReceivedWarehouse())
.setBatchNumber("")
.setNum(item.getInQty());
inventories.add(inventoryDTO);
item1.add(new ZWM3A17Item1DTO()
.setEBELP(item.getPoLineNumber())
.setMATNR(item.getItemCode())
.setERFMG(item.getInQty())
.setMEINS(item.getUomCode())
.setCHARG("")
.setWERKS(wmsPoReceipt.getFactoryCode())
.setLGORT(item.getReceivedWarehouse())
.setKZKRI("")
);
}
}
normalPGIControllerService.takeDeliveryConfirm(receiptItems, storageLocationDTOS, inventories, zwm3A17DTOS, request.getTaskId());
return ApiResult.success();
}
/****
//一键收货

View File

@ -75,11 +75,11 @@ public class NormalQMController extends BaseController {
}
/**
* 质检物料上架任务PDA
* @param orderNo 送货单号或任务单号
* 质检物料上架任务
* @param orderNo
* @return
*/
@GetMapping("/PDA/task")
@GetMapping("task")
@ApiMark(moduleName = "质检物料管理", apiName = "质检物料上架任务")
public ApiResult<List<QCTaskVO>> getTasks(@RequestParam String orderNo) {
List<QCTaskVO> tasks = wmsQcReceiveService.getTasks(orderNo);
@ -88,9 +88,8 @@ public class NormalQMController extends BaseController {
/**
* 质检物料上架物料详情
* @param taskId 任务ID
* **/
@GetMapping("PDA/task/item")
@GetMapping("task/item")
@ApiMark(moduleName = "质检物料管理", apiName = "质检任务上架物料详情")
public ApiResult<List<QCTaskItemVO>> getTaskItem(@Valid @NotNull @RequestParam Long taskId) {
List<QCTaskItemVO> tasks = normalQMControllerService.getTaskItem(taskId);
@ -99,9 +98,8 @@ public class NormalQMController extends BaseController {
/**
* 质检物料上架任务确认
* @param request
* **/
@PostMapping("PDA/task/confirm")
@PostMapping("task/confirm")
@ApiMark(moduleName = "质检物料管理", apiName = "质检任务上架确认")
public ApiResult<Void> confirm(@Valid @RequestBody List<QCReceiveTaskConfirmQO> request) {
if (CollectionUtil.isEmpty(request))

View File

@ -40,7 +40,6 @@ public class POReceiptController {
/**
* 采购单入库列表
* @param request
*/
@PostMapping("search")
@ApiMark(moduleName = "采购单入库管理", apiName = "采购单入库列表")
@ -50,7 +49,6 @@ public class POReceiptController {
/**
* 采购单入库明细
* @param inId 入库单ID
*/
@GetMapping("getItems")
@ApiMark(moduleName = "采购单入库管理", apiName = "采购单入库列表")
@ -61,7 +59,6 @@ public class POReceiptController {
/**
* 获取扫码的详情信息
* @param orderItemId 收货单项ID
*/
@GetMapping("getScanCodes")
@ApiMark(moduleName = "采购单入库管理", apiName = "获取扫码的详情信息")

View File

@ -20,11 +20,6 @@ import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* 质检物料入库单
* @param request
* @return
*/
@RestController
@RequestMapping("qc")
public class QCReceiptController {
@ -38,23 +33,12 @@ public class QCReceiptController {
@Resource
private SrmMaterialReceiptScanCodesRepository srmMaterialReceiptCanCodesRepository;
/**
* 质检物料入库单列表
* @param request
* @return
*/
@PostMapping("search")
@ApiMark(moduleName = "质检物料入库单", apiName = "入库列表")
public ApiResult<PageData<QCReceiptVO>> search(@Valid @RequestBody QCReceiptQO request) {
return ApiResult.success(qcReceiveService.search(request));
}
/**
* 质检物料入库单详情
* @param inId 入库单ID
* @return
*/
@GetMapping("getItems")
@ApiMark(moduleName = "质检物料入库单", apiName = "入库详情")
public ApiResult<List<QCReceiveTaskItemVO>> search(@RequestParam Long inId) {
@ -62,11 +46,6 @@ public class QCReceiptController {
.lambdaQuery().eq(WmsQcReceiveItem::getReceiveId, inId).list()));
}
/**
* 质检物料入库单扫码详情
* @param orderItemId 收货单详情ID
* @return
*/
@GetMapping("getScanCodes")
@ApiMark(moduleName = "质检物料入库单", apiName = "获取扫码的详情信息")
public ApiResult<List<PDAScanCodeVO>> getScanCodes(@RequestParam String orderItemId) {

View File

@ -112,6 +112,9 @@ public class StructuralPackageOrderController extends BaseController {
@Resource
private IUserSupplierService userSupplierService;
@Resource
private IWmsInventoryService inventoryService;
@Resource
private IWmsStorageService storageService;
@ -334,6 +337,15 @@ public class StructuralPackageOrderController extends BaseController {
return ApiResult.success(vo);
}
/**
* 获取零件扫码记录
* @param id 零件id
*/
@GetMapping("getScanRecord")
public ApiResult<List<PackageMaterialScanRecord>> getScanRecord(@Valid @RequestParam @NotNull Long id) {
return ApiResult.success(packageMaterialScanRecordRepository.findByTrayItemId(id));
}
/**
* 删除
* @param ids 要删除的id列表
@ -846,15 +858,4 @@ public class StructuralPackageOrderController extends BaseController {
public ApiResult<List<WmsInTaskItem>> getTicketItems(@Valid @RequestParam @NotBlank String taskNo) {
return ApiResult.success(inTaskItemService.getByNo(taskNo));
}
/**
* 获取扫码记录
* @param poNum 采购订单号
* @param materialNo 物料编号
*/
@GetMapping("getScanRecord")
public ApiResult<List<PackageMaterialScanRecord>> getScanRecord(@Valid @RequestParam @NotBlank String poNum
, @Valid @RequestParam @NotBlank String materialNo) {
return ApiResult.success(packageMaterialScanRecordRepository.findByPoNumAndMaterialNo(poNum, materialNo));
}
}

View File

@ -113,7 +113,6 @@ public class TransferCompanyController extends BaseController {
.throwMessage("物料" + item.getMatnr() + "的申请数量超出库存限制");
WmsTransferCompanyItem data = Convert.convert(WmsTransferCompanyItem.class, item);
data.setOrderId(order.getId());
data.setLeft(data.getNum());
transferCompanyItemService.save(data);
});
});

View File

@ -43,11 +43,6 @@ public class InventoryCheckTaskScanRecord {
*/
private String materialNo;
/**
* 物料描述
*/
private String materialDesc;
/**
* 批次号
*/

View File

@ -26,11 +26,6 @@ public class PackageMaterialScanRecord {
*/
private String materialNo;
/**
* 采购订单号
*/
private String poNum;
/**
* 二维码内容
*/

View File

@ -9,5 +9,6 @@ import java.util.List;
@Repository
public interface PackageMaterialScanRecordRepository extends MongoRepository<PackageMaterialScanRecord, String> {
List<PackageMaterialScanRecord> findByPoNumAndMaterialNo(String poNum, String materialNo);
List<PackageMaterialScanRecord> findByTrayItemId(Long trayItemId);
}

View File

@ -113,8 +113,7 @@ public class NormalPGIControllerService {
*/
public PDAOrderVO getOrderItemByOrderNo(@RequestParam String orderNo) {
// 根据订单编号查询订单主表信息
WmsSrmOrder order = wmsSrmOrderService.lambdaQuery().eq(WmsSrmOrder::getNoteNum, orderNo)
.eq(WmsSrmOrder::getIsCompleted, false).one();
WmsSrmOrder order = wmsSrmOrderService.lambdaQuery().eq(WmsSrmOrder::getNoteNum, orderNo).eq(WmsSrmOrder::getIsCompleted, false).one();
VUtil.trueThrowBusinessError(Objects.isNull(order)).throwMessage("此收货单[" + orderNo + "] 单号无效");
PDAOrderVO pdaOrderVO = new PDAOrderVO();
@ -141,8 +140,7 @@ public class NormalPGIControllerService {
itemVO.setIsQuality(item.getIsQuality());
itemVO.setOrderQty(item.getOrderQty());
itemVO.setUomCode(item.getUomCode());
itemVO.setLineNumber(item.getLineNumber());
itemVO.setDeliveryQty(item.getDeliveryQty().subtract(item.getReceiptQty()));
itemVO.setDeliveryQty(item.getDeliveryQty().multiply(item.getReceiptQty()));
// SAP 系统获取物料相关信息
SAPSyncParamsDTO syncParamsDTO = sapCommonService.getMaterialInfoInOrder(item.getPoNum(), order.getSupplierNum(), item.getItemCode());
if (Objects.nonNull(syncParamsDTO)) {
@ -215,7 +213,7 @@ public class NormalPGIControllerService {
//生成普通物料的入库待检单并修改送货单相应的收货数量
if (CollectionUtil.isNotEmpty(wmsPoReceiptItems)) {
wmsPoReceipt.setInNum(basdeSerialNumberControllerService.generateSerialNumber(2));
wmsPoReceipt.setInNum(basdeSerialNumberControllerService.generateSerialNumber(1));
wmsPoReceiptService.save(wmsPoReceipt);
wmsPoReceiptItemService.saveBatch(wmsPoReceiptItems);
@ -225,7 +223,7 @@ public class NormalPGIControllerService {
}
//生成质检物料的入库待检单并修改送货单相应的收货数量
if (CollectionUtil.isNotEmpty(wmsQcReceiveItems)) {
wmsQcReceive.setInNo(basdeSerialNumberControllerService.generateSerialNumber(1));
wmsQcReceive.setInNo(basdeSerialNumberControllerService.generateSerialNumber(2));
wmsQcReceiveService.save(wmsQcReceive);
wmsQcReceiveItemService.saveBatch(wmsQcReceiveItems);
for (WmsQcReceiveItem wmsQcReceiveItem : wmsQcReceiveItems) {
@ -243,7 +241,7 @@ public class NormalPGIControllerService {
if (CollectionUtil.isNotEmpty(srmMaterialReceiptScanCodes)) {
srmMaterialReceiptCanCodesRepository.insert(srmMaterialReceiptScanCodes);
}
/** 调试暂时关闭
if (CollectionUtil.isNotEmpty(qcMaterialSyncDTOS)) {
for (QCMaterialSyncDTO dto : qcMaterialSyncDTOS) {
//导入SAP
@ -264,7 +262,6 @@ public class NormalPGIControllerService {
}
}
}
*/
}
@Transactional

View File

@ -9,7 +9,6 @@ import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
@ -22,25 +21,6 @@ public class SAPCommonService {
private SapService sapService;
public SAPSyncParamsDTO getMaterialInfoInOrder(String orderNo, String supplierNo, String materialNo) {
SAPSyncParamsDTO dto = new SAPSyncParamsDTO();
dto.setMaktx("物料描述");
dto.setEbelp("1");
dto.setMatnr(materialNo);
dto.setMenge(new BigDecimal(100));
dto.setWemng(new BigDecimal(10));
dto.setMeins("PC");
dto.setEbeln(orderNo);
dto.setTransportNum(new BigDecimal(80));
dto.setMatkl("物料组");
dto.setWgbez("物料描述");
dto.setWerks("1010");
dto.setLbprt("1");
dto.setKzkri("");
dto.setWarehouseNo("122222");
dto.setBinNos("2121");
return dto;
/**
//获取订单信息
SAPMaterialInfoInOrderDTO materialInfoInOrder = CollectionUtil.get(sapService.zim004(orderNo, supplierNo, materialNo), 0);
VUtil.trueThrowBusinessError(Objects.isNull(materialInfoInOrder)).throwMessage("无法获取到有效订单信息" + orderNo);
@ -73,7 +53,6 @@ public class SAPCommonService {
syncParams.setBinNos(dbWarehouse.getBinNos());
}
return syncParams;
*/
}
}

View File

@ -2,7 +2,7 @@ server:
port: 8101
spring:
application:
name: auth-local
name: auth
profiles:
active: sit
config:

View File

@ -5,7 +5,6 @@ import lombok.Data;
import lombok.experimental.Accessors;
import java.math.BigDecimal;
import java.util.Objects;
@Data
@Accessors(chain = true)
@ -137,15 +136,6 @@ public class AllocationOrderDTO{
*/
private String ekgrp;
/**
* 转储数量
*/
private BigDecimal num;
public BigDecimal getNum() {
return Objects.isNull(num) ? sqsl2 : num;
}
@JsonIgnore
private String key;

View File

@ -4,11 +4,9 @@ import cn.hutool.core.date.DateTime;
import lombok.Data;
import lombok.experimental.Accessors;
import java.time.LocalDate;
@Data
@Accessors(chain = true)
public class QCReceiptQO extends SearchBaseQO {
public class QCReceiptQO extends PageQO {
/**
* 送货单号
@ -28,30 +26,22 @@ public class QCReceiptQO extends SearchBaseQO {
/**
* 送货开始时间
*/
private LocalDate deliveryStartDate;
private DateTime deliveryStartDate;
/**
* 送货结束时间
*/
private LocalDate deliveryEndDate;
public LocalDate getDeliveryEndDate() {
return deliveryEndDate == null ? null : deliveryEndDate.plusDays(1);
}
private DateTime deliveryEndDate;
/**
* 收货开始时间
*/
private LocalDate receiveStartDate;
private DateTime receiveStartDate;
/**
* 收货结束时间
*/
private LocalDate receiveEndDate;
public LocalDate getReceiveEndDate() {
return receiveEndDate == null ? null : receiveEndDate.plusDays(1);
}
private DateTime receiveEndDate;
/**
* 入库单号

View File

@ -55,7 +55,7 @@ public class SRMOrderReceiveItemQO {
/**
* 送货单行状态
*/
private String noteLineStatus;
private Integer noteLineStatus;
/**
* 采购订单类型

View File

@ -25,5 +25,4 @@ public class SRMOrderSearchQO extends SearchBaseQO {
* 物料编号
*/
private String itemCode;
}

View File

@ -20,12 +20,7 @@ public class InTaskVO {
private String orderNumber;
/**
* 创建时间
*/
private LocalDateTime createTime;
/**
* 上架时间
* 任务时间
*/
private LocalDateTime updateTime;

View File

@ -58,13 +58,4 @@ public class InventoryCheckTaskItemMaterialVO {
* 库存数量
*/
private BigDecimal inventoryNum;
/**
* 差异数量
*/
private BigDecimal differenceNum;
public BigDecimal getDifferenceNum() {
return this.inventoryNum.subtract(this.num);
}
}

View File

@ -4,8 +4,6 @@ import cn.hutool.core.date.DateTime;
import lombok.Data;
import lombok.experimental.Accessors;
import java.time.LocalDateTime;
@Data
@Accessors(chain = true)
public class QCReceiptVO {
@ -61,11 +59,11 @@ public class QCReceiptVO {
/**
* 是否已入库true false
*/
private Boolean isCompleted;
private boolean isCompleted;
/**
* 收货时间
*/
private LocalDateTime receiveTime;
private DateTime receiveTime;
/**
* 收货人
*/

View File

@ -121,4 +121,15 @@ public class QCReceiveTaskItemVO {
*/
private String materialDocYear;
/**
* 入库时间
*/
private LocalDateTime updateTime;
/**
* 入库人姓名
*/
private String updateUserName;
}

View File

@ -1,18 +1,10 @@
package com.nflg.wms.common.pojo.vo;
import lombok.Data;
import lombok.experimental.Accessors;
import java.time.LocalDateTime;
@Data
@Accessors(chain = true)
public class SrmOrderVO {
/**
* 送货单ID
*/
private Long Id;
/**
* 送货单号
@ -57,5 +49,5 @@ public class SrmOrderVO {
/**
* 是否完成收货
*/
private Boolean isCompleted;
private boolean isCompleted;
}

View File

@ -110,9 +110,4 @@ public class TransferCompanyItemVO {
* 剩余数量
*/
private BigDecimal left;
/**
* 转储数量
*/
private BigDecimal num;
}

View File

@ -141,4 +141,19 @@ public class WmsQcReceiveItem implements Serializable {
* 物料年度凭证
*/
private String materialDocYear;
/**
* 入库时间
*/
private LocalDateTime updateTime;
/**
* 入库人ID
*/
private Long updateUserId;
/**
* 入库人姓名
*/
private String updateUserName;
}

View File

@ -84,7 +84,7 @@ public class WmsSrmOrderItem implements Serializable {
/**
* 送货单行状态
*/
private String noteLineStatus;
private Short noteLineStatus;
/**
* 采购订单类型

View File

@ -125,11 +125,6 @@ public class WmsTransferCompanyItem implements Serializable {
*/
private String ekgrp;
/**
* 转储数量
*/
private BigDecimal num;
/**
* 剩余数量
*/

View File

@ -2,7 +2,6 @@ package com.nflg.wms.repository.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.nflg.wms.common.pojo.qo.QCReceiptQO;
import com.nflg.wms.common.pojo.vo.QCReceiptVO;
import com.nflg.wms.common.pojo.vo.QCTaskVO;
@ -22,5 +21,5 @@ public interface WmsQcReceiveMapper extends BaseMapper<WmsQcReceive> {
List<QCTaskVO> getTasks(String orderNo);
IPage<QCReceiptVO> search(QCReceiptQO request, Page<Object> objectPage);
IPage<QCReceiptVO> search(QCReceiptQO request);
}

View File

@ -4,7 +4,6 @@ import cn.hutool.core.convert.Convert;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.nflg.wms.common.pojo.PageData;
import com.nflg.wms.common.pojo.qo.EnableMenuQO;
import com.nflg.wms.common.pojo.qo.MenuButtonAddQO;
@ -16,6 +15,7 @@ import com.nflg.wms.common.util.UserUtil;
import com.nflg.wms.repository.entity.MenuButton;
import com.nflg.wms.repository.mapper.MenuButtonMapper;
import com.nflg.wms.repository.service.IMenuButtonService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import java.time.LocalDateTime;
@ -37,8 +37,6 @@ public class MenuButtonServiceImpl extends ServiceImpl<MenuButtonMapper, MenuBut
IPage<MenuButton> page = lambdaQuery()
.eq(Objects.nonNull(request.getMenuId()), MenuButton::getMenuId, request.getMenuId())
.like(StrUtil.isNotBlank(request.getName()), MenuButton::getName, request.getName())
.orderByAsc(MenuButton::getSort)
.orderByAsc(MenuButton::getId)
.page(new Page<>(request.getPage(), request.getPageSize()));
return PageUtil.convert(page, d -> Convert.convert(MenuButtonVO.class, d));
}

View File

@ -69,8 +69,7 @@ public class MenuServiceImpl extends ServiceImpl<MenuMapper, Menu> implements IM
if (StrUtil.isNotBlank(request.getName())) {
queryWrapper.like(Menu::getName, request.getName());
}
queryWrapper.orderByAsc(Menu::getSort);
queryWrapper.orderByAsc(Menu::getId);
queryWrapper.orderByDesc(Menu::getSort);
List<Menu> list = baseMapper.selectList(queryWrapper);
//找出非根节点
List<Menu> roots = list.stream().filter(l -> Objects.equals(l.getParentId(), 0L)).collect(Collectors.toList());
@ -226,9 +225,7 @@ public class MenuServiceImpl extends ServiceImpl<MenuMapper, Menu> implements IM
IPage<Menu> page = new Page<>();
page.setCurrent(request.getPage());
page.setSize(request.getPageSize());
lambdaQuery()
.eq(Menu::getParentId, 0)
.orderByAsc(Menu::getSort)
lambdaQuery().eq(Menu::getParentId, 0)
.orderByAsc(Menu::getId)
.page(page);
List<MenuVO> datas = convert(page.getRecords());
@ -255,8 +252,7 @@ public class MenuServiceImpl extends ServiceImpl<MenuMapper, Menu> implements IM
private List<MenuVO> getChildren(Long parentId) {
List<MenuVO> datas = convert(lambdaQuery().eq(Menu::getParentId, parentId)
.orderByAsc(Menu::getSort)
.orderByAsc(Menu::getId)
.orderByDesc(Menu::getSort)
.list());
datas.forEach(d -> d.setChildren(getChildren(d.getId())));
return datas;
@ -272,8 +268,6 @@ public class MenuServiceImpl extends ServiceImpl<MenuMapper, Menu> implements IM
List<MenuButton> vos = menuButtonService.lambdaQuery()
.eq(MenuButton::getMenuId, menu.getId())
.eq(MenuButton::getEnable, true)
.orderByAsc(MenuButton::getSort)
.orderByAsc(MenuButton::getId)
.list();
menu.setChildren(vos.stream()
.map(d -> new MenuAuthorizeVO().setType(2).setId(d.getId()).setKey("button-"+d.getId()).setName(d.getName()).setSelected(buttonIsSelected(roleId, d.getId())))

View File

@ -1,7 +1,6 @@
package com.nflg.wms.repository.service.impl;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.nflg.wms.common.pojo.PageData;
import com.nflg.wms.common.pojo.qo.QCReceiptQO;
import com.nflg.wms.common.pojo.vo.POReceiptVO;
@ -33,7 +32,7 @@ public class WmsQcReceiveServiceImpl extends ServiceImpl<WmsQcReceiveMapper, Wms
@Override
public IPage<QCReceiptVO> search(QCReceiptQO request) {
return baseMapper.search(request, new Page<>(request.getPage(), request.getPageSize()));
return baseMapper.search(request);
}
}

View File

@ -22,32 +22,43 @@
<if test="request.inNum !=null and request.inNum !='' ">
and a.in_num like concat('%', #{request.inNum}, '%')
</if>
<if test="request.orderNo !=null and request.orderNo !='' ">
and b.note_num like concat('%', #{request.orderNo}, '%')
</if>
<if test="request.supplierNum !=null and request.supplierNum !='' ">
and b.supplier_num =#{request.supplierNum}
</if>
<if test="request.receiveStartDate !=null">
and a.create_time >= #{request.receiveStartDate}
</if>
<if test="request.receiveEndDate !=null">
and a.create_time &lt;= #{request.receiveEndDate}
</if>
<if test="request.deliveryStartDate !=null">
and b.delivery_note_date >=
#{request.deliveryStartDate}
#{request.deliveryStartDate, jdbcType=TIMESTAMP, javaType=java.time.LocalDate, typeHandler=org.apache.ibatis.type.LocalDateTypeHandler}
</if>
<if test="request.deliveryEndDate !=null">
and b.delivery_note_date &lt;=
#{request.deliveryEndDate}
#{request.deliveryEndDate, jdbcType=TIMESTAMP, javaType=java.time.LocalDate, typeHandler=org.apache.ibatis.type.LocalDateTypeHandler}
</if>
<if test="request.inStartDate !=null">
and a.update_time >= #{request.inStartDate}
</if>
<if test="request.inEndDate !=null">
and a.update_time &lt;= #{request.inEndDate}
</if>
</where>
order by a.create_time desc
</select>

View File

@ -42,26 +42,37 @@
left join user_supplier c on b.supplier_num = c.supplier_code
<where>
<if test="request.inNum !=null and request.inNum !='' ">
and a.in_no like concat('%', #{request.inNum}, '%')
and a.in_num like concat('%', #{request.inNum}, '%')
</if>
<if test="request.orderNo !=null and request.orderNo !='' ">
and b.note_num like concat('%', #{request.orderNo}, '%')
</if>
<if test="request.supplierNum !=null and request.supplierNum !='' ">
and b.supplier_num =#{request.supplierNum}
</if>
<if test="request.receiveStartDate !=null">
<if test="request.itemCode !=null and request.itemCode !='' ">
and EXISTS (select 1 from wms_srm_order_item where a.id=wms_srm_order_item.order_id and
wms_srm_order_item.item_code like concat('%', #{request.itemCode}, '%')
</if>
<if test="request.receiveStartDate !=null and request.receiveStartDate !='' ">
and a.create_time >= #{request.receiveStartDate}
</if>
<if test="request.receiveEndDate !=null">
<if test="request.receiveEndDate !=null and request.receiveEndDate !='' ">
and a.create_time &lt; #{request.receiveEndDate}
</if>
<if test="request.deliveryStartDate !=null">
and b.delivery_note_date >= #{request.deliveryStartDate}
<if test="request.deliveryStartDate !=null and request.deliveryStartDate !='' ">
and a.delivery_note_date >= #{request.deliveryStartDate}
</if>
<if test="request.deliveryEndDate !=null">
and b.delivery_note_date &lt; #{request.deliveryEndDate}
<if test="request.deliveryEndDate !=null and request.deliveryEndDate !='' ">
and a.delivery_note_date &lt; #{request.deliveryEndDate}
</if>
</where>
order by a.create_time desc
</select>

View File

@ -2,7 +2,7 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.nflg.wms.repository.mapper.WmsSrmOrderMapper">
<select id="search" resultType="com.nflg.wms.common.pojo.vo.SrmOrderVO">
select a.id, a.iu_code,a.note_num,a.purchase_group,a.waybill_num,a.supplier_num,a.create_time, a.delivery_note_date
select a.iu_code,a.note_num,a.purchase_group,a.waybill_num,a.supplier_num,a.create_time, a.delivery_note_date
,a.ou_code, a.is_completed,
b.supplier_name from wms_srm_order a left join user_supplier b on a.supplier_num=b.supplier_code

View File

@ -4,7 +4,6 @@ import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.util.IdUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.nflg.wms.common.pojo.qo.SRMOrderReceiveItemQO;
import com.nflg.wms.common.pojo.qo.SRMOrderReceiveQO;
import com.nflg.wms.common.pojo.qo.SRMQualityInspectionResult;
import com.nflg.wms.repository.entity.*;
@ -59,7 +58,10 @@ public class SRMController extends BaseController {
public Object receiveOrder(@RequestBody SRMOrderReceiveQO request) {
try {
WmsSrmOrder order = srmOrderService.lambdaQuery().eq(WmsSrmOrder::getNoteNum, request.getNoteNum()).one();
if (Objects.isNull(order)) {
if (Objects.nonNull(order)) {
// srmOrderService.removeById(order);
// srmOrderItemService.remove(new LambdaQueryWrapper<WmsSrmOrderItem>().eq(WmsSrmOrderItem::getOrderId, order.getId()));
} else {
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
LocalDateTime deliveryDate = LocalDateTime.parse(request.getDeliveryNoteDate(), formatter);
order = new WmsSrmOrder()
@ -72,41 +74,16 @@ public class SRMController extends BaseController {
.setPurchaseGroup(request.getPurchaseGroup())
.setOuCode(request.getOuCode())
.setDeliveryNoteDate(deliveryDate)
.setIsCompleted(false)
.setCreateTime(LocalDateTime.now());
srmOrderService.save(order);
}
//判断是否存在子集
if (CollectionUtil.isNotEmpty(request.getResultSet())) {
List<WmsSrmOrderItem> items = new ArrayList<>();
for (SRMOrderReceiveItemQO it : request.getResultSet()) {
WmsSrmOrderItem item = srmOrderItemService.lambdaQuery().eq(WmsSrmOrderItem::getLineNumber, it.getLineNumber())
.eq(WmsSrmOrderItem::getNoteNum, request.getNoteNum())
.one();
if (Objects.isNull(item) || item.getNoteNum().equals(null) || item.getNoteNum().equals("")) {
WmsSrmOrderItem updateItem = new WmsSrmOrderItem()
.setId(IdUtil.getSnowflakeNextId())
.setOrderId(order.getId())
.setLineNumber(it.getLineNumber())
.setPoNum(it.getPoNum())
.setPoLineNumber(it.getPoLineNumber())
.setItemCode(it.getItemCode())
.setItemName(it.getItemName())
.setOrderQty(it.getOrderQty())
.setUomCode(it.getUomCode())
.setDemandDate(it.getDemandDate())
.setNoteLineStatus(it.getNoteLineStatus())
.setOrderType(it.getOrderType())
.setDeliveryQty(it.getDeliveryQty())
.setIsQuality(it.getIsQuality())
.setNoteNum(request.getNoteNum())
.setReceiptQty(new BigDecimal(0));
items.add(updateItem);
}
}
if (CollectionUtil.isNotEmpty(items))
srmOrderItemService.saveBatch(items);
}
WmsSrmOrder finalOrder = order;
srmOrderItemService.saveBatch(request.getResultSet().stream().map(it -> {
WmsSrmOrderItem item = Convert.convert(WmsSrmOrderItem.class, it);
item.setOrderId(finalOrder.getId());
item.setReceiptQty(new BigDecimal(0));
return item;
}).toList());
return 0;
} catch (Exception ex) {
log.error("SRM送货单保存失败", ex);