| | |
| | | import com.vincent.rsf.server.api.entity.dto.PoItemsDto; |
| | | import com.vincent.rsf.server.api.service.ReceiveMsgService; |
| | | import com.vincent.rsf.server.api.service.ReportMsgService; |
| | | import com.vincent.rsf.server.common.utils.DateUtils; |
| | | import com.vincent.rsf.server.manager.controller.params.AsnOrderAndItemsParams; |
| | | import com.vincent.rsf.server.manager.controller.params.BatchUpdateParam; |
| | | import com.vincent.rsf.server.manager.entity.*; |
| | |
| | | * @time 2025/3/7 08:02 |
| | | */ |
| | | @Service("asnOrderService") |
| | | public class AsnOrderServiceImpl extends ServiceImpl<AsnOrderMapper, AsnOrder> implements AsnOrderService { |
| | | public class AsnOrderServiceImpl extends ServiceImpl<AsnOrderMapper, WkOrder> implements AsnOrderService { |
| | | |
| | | @Autowired |
| | | private ReceiveMsgService receiveMsgService; |
| | |
| | | private PurchaseItemService purchaseItemService; |
| | | |
| | | @Override |
| | | public boolean notifyInspect(List<AsnOrder> orders) { |
| | | public boolean notifyInspect(List<WkOrder> orders) { |
| | | if (orders.isEmpty()) { |
| | | throw new CoolException("上报参数不能为空!!"); |
| | | } |
| | | Set<Long> asnIds = orders.stream().map(AsnOrder::getId).collect(Collectors.toSet()); |
| | | Set<Long> asnIds = orders.stream().map(WkOrder::getId).collect(Collectors.toSet()); |
| | | if (asnIds.isEmpty()) { |
| | | throw new CoolException("ASN单据不能为空!!"); |
| | | } |
| | |
| | | } |
| | | |
| | | @Override |
| | | public List<AsnOrder> getListByMatnr(Map<String, String> params) { |
| | | public List<WkOrder> getListByMatnr(Map<String, String> params) { |
| | | if (Objects.isNull(params)) { |
| | | throw new CoolException("查询条件不能为空!!"); |
| | | } |
| | |
| | | if (Objects.isNull(params.getOrders())) { |
| | | throw new CoolException("主单信息不能为空"); |
| | | } |
| | | AsnOrder orders = params.getOrders(); |
| | | WkOrder orders = params.getOrders(); |
| | | if (Objects.isNull(orders)) { |
| | | throw new CoolException("单据不能为空!!"); |
| | | } |
| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public R updateOrderItem(AsnOrderAndItemsParams params, Long loginUserId) throws Exception { |
| | | AsnOrder orders = params.getOrders(); |
| | | WkOrder orders = params.getOrders(); |
| | | if (Objects.isNull(orders)) { |
| | | throw new CoolException("主单信息不能为空!!"); |
| | | } |
| | |
| | | */ |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void svaeOrUpdateOrderItem(AsnOrderAndItemsParams params, Long loginUserId) throws Exception { |
| | | AsnOrder orders = params.getOrders(); |
| | | WkOrder orders = params.getOrders(); |
| | | params.getItems().forEach(item -> { |
| | | item.put("asnId", orders.getId()); |
| | | item.put("asnCode", orders.getCode()); |
| | |
| | | */ |
| | | @Override |
| | | public boolean batchUpdate(BatchUpdateParam params, Long userId) { |
| | | AsnOrder order = params.getOrder(); |
| | | WkOrder order = params.getOrder(); |
| | | if (Objects.isNull(order)) { |
| | | throw new CoolException("修改参数不能为空!!"); |
| | | } |
| | | return this.update(new LambdaUpdateWrapper<AsnOrder>() |
| | | .in(AsnOrder::getId, params.getIds()) |
| | | .set(!Objects.isNull(order.getRleStatus()), AsnOrder::getRleStatus, order.getRleStatus()) |
| | | .set(!Objects.isNull(order.getNtyStatus()), AsnOrder::getNtyStatus, order.getNtyStatus()) |
| | | .set(!Objects.isNull(order.getStatus()), AsnOrder::getStatus, order.getStatus()) |
| | | .set(!Objects.isNull(order.getWkType()), AsnOrder::getWkType, order.getWkType()) |
| | | .set(!Objects.isNull(order.getExceStatus()), AsnOrder::getExceStatus, order.getExceStatus()) |
| | | .set(AsnOrder::getUpdateBy, userId)); |
| | | return this.update(new LambdaUpdateWrapper<WkOrder>() |
| | | .in(WkOrder::getId, params.getIds()) |
| | | .set(!Objects.isNull(order.getRleStatus()), WkOrder::getRleStatus, order.getRleStatus()) |
| | | .set(!Objects.isNull(order.getNtyStatus()), WkOrder::getNtyStatus, order.getNtyStatus()) |
| | | .set(!Objects.isNull(order.getStatus()), WkOrder::getStatus, order.getStatus()) |
| | | .set(!Objects.isNull(order.getWkType()), WkOrder::getWkType, order.getWkType()) |
| | | .set(!Objects.isNull(order.getExceStatus()), WkOrder::getExceStatus, order.getExceStatus()) |
| | | .set(WkOrder::getUpdateBy, userId)); |
| | | } |
| | | |
| | | /** |
| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public R completeOrder(Long id, Long loginUserId) { |
| | | AsnOrder asnOrder = this.getById(id); |
| | | if (Objects.isNull(asnOrder)) { |
| | | WkOrder wkOrder = this.getById(id); |
| | | if (Objects.isNull(wkOrder)) { |
| | | throw new CoolException("单据不存在!!"); |
| | | } |
| | | //一键加入历史档 |
| | | try { |
| | | operateOrderLogs(asnOrder); |
| | | operateOrderLogs(wkOrder); |
| | | } catch (Exception e) { |
| | | throw new CoolException("收货完成失败!!"); |
| | | } |
| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public R closeOrder(Long id) { |
| | | AsnOrder order = this.getById(id); |
| | | WkOrder order = this.getById(id); |
| | | if (Objects.isNull(order)) { |
| | | throw new CoolException("单据不存在!!"); |
| | | } |
| | |
| | | if (Objects.isNull(purchase)) { |
| | | throw new CoolException("PO单据不存在!!"); |
| | | } |
| | | AsnOrder order = new AsnOrder(); |
| | | WkOrder order = new WkOrder(); |
| | | //根据编码规则生成ASN单号 |
| | | String code = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_ASN_ORDER, purchase); |
| | | order.setCode(code) |
| | |
| | | } |
| | | } |
| | | |
| | | if (!this.remove(new LambdaQueryWrapper<AsnOrder>() |
| | | .in(AsnOrder::getId, ids) |
| | | .eq(AsnOrder::getExceStatus, AsnExceStatus.ASN_EXCE_STATUS_UN_EXCE.val))) { |
| | | if (!this.remove(new LambdaQueryWrapper<WkOrder>() |
| | | .in(WkOrder::getId, ids) |
| | | .eq(WkOrder::getExceStatus, AsnExceStatus.ASN_EXCE_STATUS_UN_EXCE.val))) { |
| | | throw new CoolException("任务中单据不可删除!!"); |
| | | } |
| | | |
| | |
| | | * @time 2025/3/19 19:53 |
| | | */ |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public synchronized void operateOrderLogs(AsnOrder asrder) throws Exception { |
| | | public synchronized void operateOrderLogs(WkOrder asrder) throws Exception { |
| | | if (Objects.isNull(asrder) || Objects.isNull(asrder.getId())) { |
| | | throw new CoolException("参数不能为空!!"); |
| | | } |
| | |
| | | // if (Objects.isNull(asrder.getAnfme()) || asrder.getAnfme().compareTo(0.00) == 0) { |
| | | // throw new CoolException("收货数量不能为零!!"); |
| | | // } |
| | | AsnOrder order = this.getById(asrder.getId()); |
| | | WkOrder order = this.getById(asrder.getId()); |
| | | AsnOrderLog orderLog = new AsnOrderLog(); |
| | | // order.setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val); |
| | | BeanUtils.copyProperties(order, orderLog); |