Merge remote-tracking branch 'origin/develop' into develop
# Conflicts: # nflg-wms-admin/src/main/java/com/nflg/wms/admin/controller/NormalQMController.java
This commit is contained in:
commit
adf80b96e6
|
|
@ -76,7 +76,6 @@ public class NormalQMController extends BaseController {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取SRM推送过来的质检单信息
|
* 获取SRM推送过来的质检单信息
|
||||||
*
|
|
||||||
* @param request
|
* @param request
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
|
|
@ -88,7 +87,6 @@ public class NormalQMController extends BaseController {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 导出质检单
|
* 导出质检单
|
||||||
*
|
|
||||||
* @param request 查询条件
|
* @param request 查询条件
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
|
|
@ -102,7 +100,6 @@ public class NormalQMController extends BaseController {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 质检物料上架任务(PDA)
|
* 质检物料上架任务(PDA)
|
||||||
*
|
|
||||||
* @param orderNo 送货单号或任务单号
|
* @param orderNo 送货单号或任务单号
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
|
|
@ -115,7 +112,6 @@ public class NormalQMController extends BaseController {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 质检物料上架物料详情
|
* 质检物料上架物料详情
|
||||||
*
|
|
||||||
* @param taskId 任务ID
|
* @param taskId 任务ID
|
||||||
**/
|
**/
|
||||||
@GetMapping("PDA/task/item")
|
@GetMapping("PDA/task/item")
|
||||||
|
|
@ -127,7 +123,6 @@ public class NormalQMController extends BaseController {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 质检物料上架任务确认
|
* 质检物料上架任务确认
|
||||||
*
|
|
||||||
* @param request
|
* @param request
|
||||||
**/
|
**/
|
||||||
@Transactional
|
@Transactional
|
||||||
|
|
@ -152,13 +147,17 @@ public class NormalQMController extends BaseController {
|
||||||
|
|
||||||
List<String> qrCodes = CollectionUtil.unionAll(
|
List<String> qrCodes = CollectionUtil.unionAll(
|
||||||
request.stream()
|
request.stream()
|
||||||
|
.filter(Objects::nonNull)
|
||||||
.map(QCReceiveTaskConfirmQO::getReceiveItems)
|
.map(QCReceiveTaskConfirmQO::getReceiveItems)
|
||||||
.flatMap(List::stream)
|
.flatMap(List::stream)
|
||||||
|
.filter(Objects::nonNull)
|
||||||
.map(InCostCenterBackSubmitItemQRQO::getQrCode)
|
.map(InCostCenterBackSubmitItemQRQO::getQrCode)
|
||||||
.toList()
|
.toList()
|
||||||
, request.stream()
|
, request.stream()
|
||||||
|
.filter(Objects::nonNull)
|
||||||
.map(QCReceiveTaskConfirmQO::getRejectItems)
|
.map(QCReceiveTaskConfirmQO::getRejectItems)
|
||||||
.flatMap(List::stream)
|
.flatMap(List::stream)
|
||||||
|
.filter(Objects::nonNull)
|
||||||
.map(InCostCenterBackSubmitItemQRQO::getQrCode)
|
.map(InCostCenterBackSubmitItemQRQO::getQrCode)
|
||||||
.toList()
|
.toList()
|
||||||
);
|
);
|
||||||
|
|
@ -369,7 +368,6 @@ public class NormalQMController extends BaseController {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 无码质检任务上架确认
|
* 无码质检任务上架确认
|
||||||
*
|
|
||||||
* @param request 任务ID
|
* @param request 任务ID
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
|
|
|
||||||
|
|
@ -118,6 +118,7 @@ public class NormalPGIControllerService {
|
||||||
* 该方法首先根据订单编号查询订单主表信息,若不存在则返回 null;
|
* 该方法首先根据订单编号查询订单主表信息,若不存在则返回 null;
|
||||||
* 若存在,则进一步查询订单行项目列表,并结合 SAP 系统同步物料相关信息,
|
* 若存在,则进一步查询订单行项目列表,并结合 SAP 系统同步物料相关信息,
|
||||||
* 最终组装成 PDAOrderVO 对象返回。
|
* 最终组装成 PDAOrderVO 对象返回。
|
||||||
|
*
|
||||||
* @param orderNo 订单编号,用于查询订单主表和子表数据
|
* @param orderNo 订单编号,用于查询订单主表和子表数据
|
||||||
* @return PDAOrderVO 包含订单头信息和行项目信息的视图对象;若未找到对应订单则返回 null
|
* @return PDAOrderVO 包含订单头信息和行项目信息的视图对象;若未找到对应订单则返回 null
|
||||||
* @throws Exception 查询或业务处理过程中可能抛出的异常
|
* @throws Exception 查询或业务处理过程中可能抛出的异常
|
||||||
|
|
@ -479,6 +480,7 @@ public class NormalPGIControllerService {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 将检验物料信息推送到SRM系统
|
* 将检验物料信息推送到SRM系统
|
||||||
|
*
|
||||||
* @param request SRM检验输入数据传输对象,包含需要推送的检验物料信息
|
* @param request SRM检验输入数据传输对象,包含需要推送的检验物料信息
|
||||||
*/
|
*/
|
||||||
private void pushInspectionMaterialsToSRM(SRMInspectionInputDTO request) {
|
private void pushInspectionMaterialsToSRM(SRMInspectionInputDTO request) {
|
||||||
|
|
@ -515,6 +517,7 @@ public class NormalPGIControllerService {
|
||||||
* <p>
|
* <p>
|
||||||
* 该方法首先尝试从Redis缓存中获取SRM Token,如果缓存中不存在或为空,
|
* 该方法首先尝试从Redis缓存中获取SRM Token,如果缓存中不存在或为空,
|
||||||
* 则通过OAuth认证接口重新获取Token并存入Redis缓存50分钟。
|
* 则通过OAuth认证接口重新获取Token并存入Redis缓存50分钟。
|
||||||
|
*
|
||||||
* @return SRM系统认证Token字符串
|
* @return SRM系统认证Token字符串
|
||||||
*/
|
*/
|
||||||
private String GetSRMToken() {
|
private String GetSRMToken() {
|
||||||
|
|
@ -618,38 +621,38 @@ public class NormalPGIControllerService {
|
||||||
}
|
}
|
||||||
|
|
||||||
//编码管理
|
//编码管理
|
||||||
if (CollectionUtil.isNotEmpty(dto.getQrCodes())) {
|
// if (CollectionUtil.isNotEmpty(dto.getQrCodes())) {
|
||||||
//同步箱码信息到物料码中
|
// //同步箱码信息到物料码中
|
||||||
List<WmsQrCodeMaster> parents = dto.getQrCodes()
|
// List<WmsQrCodeMaster> parents = dto.getQrCodes()
|
||||||
.stream()
|
// .stream()
|
||||||
.filter(qrCode -> qrCode.getPackagingType() == 1)
|
// .filter(qrCode -> qrCode.getPackagingType() == 1)
|
||||||
.toList();
|
// .toList();
|
||||||
if (CollectionUtil.isNotEmpty(parents)) {
|
// if (CollectionUtil.isNotEmpty(parents)) {
|
||||||
List<WmsQrCodeMaster> children = qrCodeMasterService.lambdaQuery()
|
// List<WmsQrCodeMaster> children = qrCodeMasterService.lambdaQuery()
|
||||||
.in(WmsQrCodeMaster::getParentBarcodeId, parents
|
// .in(WmsQrCodeMaster::getParentBarcodeId, parents
|
||||||
.stream()
|
// .stream()
|
||||||
.map(WmsQrCodeMaster::getId)
|
// .map(WmsQrCodeMaster::getId)
|
||||||
.toList()
|
// .toList()
|
||||||
)
|
// )
|
||||||
.list();
|
// .list();
|
||||||
parents.forEach(p -> {
|
// parents.forEach(p -> {
|
||||||
children.stream()
|
// children.stream()
|
||||||
.filter(c -> c.getParentBarcodeId().equals(p.getId()))
|
// .filter(c -> c.getParentBarcodeId().equals(p.getId()))
|
||||||
.forEach(c -> {
|
// .forEach(c -> {
|
||||||
c.setProcessStage(p.getProcessStage());
|
// c.setProcessStage(p.getProcessStage());
|
||||||
c.setLastScanBy(UserUtil.getUserId());
|
// c.setLastScanBy(UserUtil.getUserId());
|
||||||
c.setLastScanByname(UserUtil.getUserName());
|
// c.setLastScanByname(UserUtil.getUserName());
|
||||||
c.setLastScanTime(LocalDateTime.now());
|
// c.setLastScanTime(LocalDateTime.now());
|
||||||
c.setFactoryCode(p.getFactoryCode());
|
// c.setFactoryCode(p.getFactoryCode());
|
||||||
c.setStorageLocation(p.getStorageLocation());
|
// c.setStorageLocation(p.getStorageLocation());
|
||||||
c.setBinLocation(p.getBinLocation());
|
// c.setBinLocation(p.getBinLocation());
|
||||||
c.setReceiptItemId(p.getReceiptItemId());
|
// c.setReceiptItemId(p.getReceiptItemId());
|
||||||
});
|
// });
|
||||||
});
|
// });
|
||||||
dto.getQrCodes().addAll(children);
|
// dto.getQrCodes().addAll(children);
|
||||||
}
|
// }
|
||||||
qrCodeMasterService.updateBarCode(dto.getQrCodes());
|
qrCodeMasterService.updateBarCode(dto.getQrCodes());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue