|
|
@@ -266,5 +266,79 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
|
|
|
//修改库存信息待定
|
|
|
return R.data(order);
|
|
|
}
|
|
|
+ @Override
|
|
|
+ @Transactional
|
|
|
+ public R createMarket(Order order) {
|
|
|
+ Order selectById = baseMapper.selectById(order.getId());
|
|
|
+ if (selectById == null){
|
|
|
+ throw new RuntimeException("找不到询价单信息");
|
|
|
+ }
|
|
|
+ //保存订单主表信息
|
|
|
+ //获取系统编号
|
|
|
+ R billNo = serialClient.getBillNo(order.getBillType());
|
|
|
+ if (billNo.getCode() != 200){
|
|
|
+ TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
|
|
+ throw new RuntimeException("生成系统编号失败");
|
|
|
+ }
|
|
|
+ selectById.setSrcId(order.getId());
|
|
|
+ selectById.setSrcOrderNo(selectById.getSysNo());
|
|
|
+ selectById.setId(null);
|
|
|
+ selectById.setSysNo((String) billNo.getData());
|
|
|
+ selectById.setTenantId(SecureUtil.getTenantId());
|
|
|
+ selectById.setCreateTime(new Date());
|
|
|
+ selectById.setCreateUser(SecureUtil.getUserId());
|
|
|
+ selectById.setUpdateUser(null);
|
|
|
+ selectById.setUpdateTime(null);
|
|
|
+ selectById.setOrderStatus("录入");
|
|
|
+ selectById.setIfEnquiry(null);
|
|
|
+ selectById.setIfShipping(null);
|
|
|
+ selectById.setIfInvoice("否");
|
|
|
+ selectById.setBillType(order.getBillType());
|
|
|
+ selectById.setTradeType(order.getTradeType());
|
|
|
+ if (order.getBusinesDate() == null){
|
|
|
+ selectById.setBusinesDate(new Date());
|
|
|
+ }
|
|
|
+ baseMapper.insert(selectById);
|
|
|
+ //保存订单费用明细
|
|
|
+ List<OrderFees> orderFeesList = orderFeesService.list(new QueryWrapper<OrderFees>().eq("pid", order.getId()).eq("is_deleted", 0));
|
|
|
+ if (CollectionUtils.isNotEmpty(orderFeesList)){
|
|
|
+ orderFeesList.stream().forEach(fee ->{
|
|
|
+ fee.setPid(selectById.getId());
|
|
|
+ fee.setId(null);
|
|
|
+ fee.setCreateTime(new Date());
|
|
|
+ fee.setCreateUser(SecureUtil.getUserId());
|
|
|
+ fee.setUpdateTime(null);
|
|
|
+ fee.setUpdateUser(null);
|
|
|
+ orderFeesService.save(fee);
|
|
|
+ });
|
|
|
+ }
|
|
|
+ //保存订单明细
|
|
|
+ List<OrderItems> orderItemsList = orderItemsService.list(new QueryWrapper<OrderItems>().eq("pid", order.getId()).eq("is_deleted", 0));
|
|
|
+ if (CollectionUtils.isNotEmpty(orderItemsList)){
|
|
|
+ orderItemsList.stream().forEach(item ->{
|
|
|
+ item.setPid(selectById.getId());
|
|
|
+ item.setId(null);
|
|
|
+ item.setCreateTime(new Date());
|
|
|
+ item.setCreateUser(SecureUtil.getUserId());
|
|
|
+ item.setUpdateTime(null);
|
|
|
+ item.setUpdateUser(null);
|
|
|
+ orderItemsService.save(item);
|
|
|
+ });
|
|
|
+ }
|
|
|
+ //保存订单文件信息
|
|
|
+ List<OrderFiles> orderFilesList = orderFilesService.list(new QueryWrapper<OrderFiles>().eq("pid", order.getId()).eq("is_deleted", 0));
|
|
|
+ if (CollectionUtils.isNotEmpty(orderFilesList)){
|
|
|
+ orderFilesList.stream().forEach(file ->{
|
|
|
+ file.setPid(selectById.getId());
|
|
|
+ file.setId(null);
|
|
|
+ file.setCreateTime(new Date());
|
|
|
+ file.setCreateUser(SecureUtil.getUserId());
|
|
|
+ file.setUpdateTime(null);
|
|
|
+ file.setUpdateUser(null);
|
|
|
+ orderFilesService.save(file);
|
|
|
+ });
|
|
|
+ }
|
|
|
+ return R.data(order);
|
|
|
+ }
|
|
|
|
|
|
}
|