|
@@ -47,14 +47,12 @@ import org.springblade.salesPart.order.mapper.OrderItemsMapper;
|
|
|
import org.springblade.salesPart.order.mapper.OrderMapper;
|
|
import org.springblade.salesPart.order.mapper.OrderMapper;
|
|
|
import org.springblade.salesPart.order.service.IOrderService;
|
|
import org.springblade.salesPart.order.service.IOrderService;
|
|
|
import org.springblade.salesPart.payMethod.PayService;
|
|
import org.springblade.salesPart.payMethod.PayService;
|
|
|
-import org.springblade.salesPart.payment.mapper.PaymentMapper;
|
|
|
|
|
-import org.springblade.salesPart.productLaunch.mapper.ProductLaunchMapper;
|
|
|
|
|
|
|
+import org.springblade.salesPart.productLaunch.service.IProductLaunchService;
|
|
|
import org.springblade.salesPart.settlement.mapper.SettlementMapper;
|
|
import org.springblade.salesPart.settlement.mapper.SettlementMapper;
|
|
|
import org.springblade.salesPart.settlement.service.ISettlementItemsService;
|
|
import org.springblade.salesPart.settlement.service.ISettlementItemsService;
|
|
|
-import org.springblade.salesPart.settlement.service.ISettlementService;
|
|
|
|
|
import org.springblade.salesPart.ship.mapper.ShipItemsMapper;
|
|
import org.springblade.salesPart.ship.mapper.ShipItemsMapper;
|
|
|
import org.springblade.salesPart.ship.mapper.ShipMapper;
|
|
import org.springblade.salesPart.ship.mapper.ShipMapper;
|
|
|
-import org.springblade.salesPart.stock.mapper.StockDescMapper;
|
|
|
|
|
|
|
+import org.springblade.salesPart.stock.service.IStockDescService;
|
|
|
import org.springblade.salesPart.storage.mapper.StorageDescMapper;
|
|
import org.springblade.salesPart.storage.mapper.StorageDescMapper;
|
|
|
import org.springblade.salesPart.vo.OrderStatistics;
|
|
import org.springblade.salesPart.vo.OrderStatistics;
|
|
|
import org.springblade.salesPart.vo.OrderVO;
|
|
import org.springblade.salesPart.vo.OrderVO;
|
|
@@ -98,8 +96,8 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, PjOrder> implemen
|
|
|
private final ShipItemsMapper shipItemsMapper;
|
|
private final ShipItemsMapper shipItemsMapper;
|
|
|
private final CorpsDescMapper corpsDescMapper;
|
|
private final CorpsDescMapper corpsDescMapper;
|
|
|
private final StorageDescMapper storageDescMapper;
|
|
private final StorageDescMapper storageDescMapper;
|
|
|
- private final StockDescMapper stockDescMapper;
|
|
|
|
|
- private final ProductLaunchMapper productLaunchMapper;
|
|
|
|
|
|
|
+ private final IStockDescService stockDescService;
|
|
|
|
|
+ private final IProductLaunchService productLaunchService;
|
|
|
private final GoodsDescMapper goodsDescMapper;
|
|
private final GoodsDescMapper goodsDescMapper;
|
|
|
private final ISysClient sysClient;
|
|
private final ISysClient sysClient;
|
|
|
private final HistoryMapper historyMapper;
|
|
private final HistoryMapper historyMapper;
|
|
@@ -200,6 +198,17 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, PjOrder> implemen
|
|
|
return page.setRecords(baseMapper.collectionStatistics(page, order));
|
|
return page.setRecords(baseMapper.collectionStatistics(page, order));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 自定义分页
|
|
|
|
|
+ *
|
|
|
|
|
+ * @param order
|
|
|
|
|
+ * @return
|
|
|
|
|
+ */
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public List<OrderStatistics> collectionStatisticsList(OrderVO order) {
|
|
|
|
|
+ return baseMapper.collectionStatisticsList(order);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
@Override
|
|
@Override
|
|
|
public List<PjOrder> salesman(PjOrder order) {
|
|
public List<PjOrder> salesman(PjOrder order) {
|
|
|
return baseMapper.salesman(order);
|
|
return baseMapper.salesman(order);
|
|
@@ -359,7 +368,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, PjOrder> implemen
|
|
|
} else {
|
|
} else {
|
|
|
lambdaQueryWrapper.and(i -> i.eq(PjStockDesc::getDot, "").or().isNull(PjStockDesc::getDot));
|
|
lambdaQueryWrapper.and(i -> i.eq(PjStockDesc::getDot, "").or().isNull(PjStockDesc::getDot));
|
|
|
}
|
|
}
|
|
|
- PjStockDesc stockDesc = stockDescMapper.selectOne(lambdaQueryWrapper);
|
|
|
|
|
|
|
+ PjStockDesc stockDesc = stockDescService.getOne(lambdaQueryWrapper);
|
|
|
if (ObjectUtil.isNotEmpty(stockDesc)) {
|
|
if (ObjectUtil.isNotEmpty(stockDesc)) {
|
|
|
item.setCostprie(item.getGoodsNum().multiply(stockDesc.getInventoryCostPrice()));
|
|
item.setCostprie(item.getGoodsNum().multiply(stockDesc.getInventoryCostPrice()));
|
|
|
} else {
|
|
} else {
|
|
@@ -373,7 +382,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, PjOrder> implemen
|
|
|
.eq(PjProductLaunch::getGoodsId, item.getGoodsId())
|
|
.eq(PjProductLaunch::getGoodsId, item.getGoodsId())
|
|
|
.eq(PjProductLaunch::getSalesCompanyId, order.getSalesCompanyId())
|
|
.eq(PjProductLaunch::getSalesCompanyId, order.getSalesCompanyId())
|
|
|
.eq(PjProductLaunch::getSourceCompanyId, order.getSharedCompanyId());
|
|
.eq(PjProductLaunch::getSourceCompanyId, order.getSharedCompanyId());
|
|
|
- PjProductLaunch productLaunch = productLaunchMapper.selectOne(lambdaQueryWrapper);
|
|
|
|
|
|
|
+ PjProductLaunch productLaunch = productLaunchService.getOne(lambdaQueryWrapper);
|
|
|
if (ObjectUtils.isNotNull(productLaunch)) {
|
|
if (ObjectUtils.isNotNull(productLaunch)) {
|
|
|
item.setCostprie(item.getGoodsNum().multiply(productLaunch.getShareCost()));
|
|
item.setCostprie(item.getGoodsNum().multiply(productLaunch.getShareCost()));
|
|
|
} else {
|
|
} else {
|
|
@@ -564,14 +573,14 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, PjOrder> implemen
|
|
|
.eq(PjProductLaunch::getIsDeleted, 0)
|
|
.eq(PjProductLaunch::getIsDeleted, 0)
|
|
|
.and(i -> i.eq(PjProductLaunch::getSalesCompanyId, pjOrder.getSalesCompanyId()).or().in(PjProductLaunch::getSourceCompanyId, pjOrder.getSalesCompanyId()))
|
|
.and(i -> i.eq(PjProductLaunch::getSalesCompanyId, pjOrder.getSalesCompanyId()).or().in(PjProductLaunch::getSourceCompanyId, pjOrder.getSalesCompanyId()))
|
|
|
.eq(PjProductLaunch::getGoodsId, e.getGoodsId());
|
|
.eq(PjProductLaunch::getGoodsId, e.getGoodsId());
|
|
|
- List<PjProductLaunch> launchList = productLaunchMapper.selectList(queryWrapper);
|
|
|
|
|
|
|
+ List<PjProductLaunch> launchList = productLaunchService.list(queryWrapper);
|
|
|
if (ObjectUtil.isNotEmpty(launchList)) {
|
|
if (ObjectUtil.isNotEmpty(launchList)) {
|
|
|
launchList.forEach(productLaunch -> {
|
|
launchList.forEach(productLaunch -> {
|
|
|
productLaunch.setInventory(productLaunch.getInventory().subtract(e.getGoodsNum()));
|
|
productLaunch.setInventory(productLaunch.getInventory().subtract(e.getGoodsNum()));
|
|
|
productLaunch.setVersion(productLaunch.getVersion());
|
|
productLaunch.setVersion(productLaunch.getVersion());
|
|
|
- int count = productLaunchMapper.updateById(productLaunch);
|
|
|
|
|
- if (count == 0) {
|
|
|
|
|
- throw new RuntimeException(productLaunch.getCname() + "该产品上架库存正在操作,请稍后刷新在进行操作!");
|
|
|
|
|
|
|
+ R res = productLaunchService.updateByIdNew(productLaunch);
|
|
|
|
|
+ if (!res.isSuccess()) {
|
|
|
|
|
+ throw new RuntimeException(res.getMsg());
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|
|
@@ -664,14 +673,14 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, PjOrder> implemen
|
|
|
.eq(PjProductLaunch::getIsDeleted, 0)
|
|
.eq(PjProductLaunch::getIsDeleted, 0)
|
|
|
.and(i -> i.eq(PjProductLaunch::getSalesCompanyId, pjOrder.getSalesCompanyId()).or().in(PjProductLaunch::getSourceCompanyId, pjOrder.getSalesCompanyId()))
|
|
.and(i -> i.eq(PjProductLaunch::getSalesCompanyId, pjOrder.getSalesCompanyId()).or().in(PjProductLaunch::getSourceCompanyId, pjOrder.getSalesCompanyId()))
|
|
|
.eq(PjProductLaunch::getGoodsId, e.getGoodsId());
|
|
.eq(PjProductLaunch::getGoodsId, e.getGoodsId());
|
|
|
- List<PjProductLaunch> launchList = productLaunchMapper.selectList(queryWrapper);
|
|
|
|
|
|
|
+ List<PjProductLaunch> launchList = productLaunchService.list(queryWrapper);
|
|
|
if (ObjectUtil.isNotEmpty(launchList)) {
|
|
if (ObjectUtil.isNotEmpty(launchList)) {
|
|
|
launchList.forEach(productLaunch -> {
|
|
launchList.forEach(productLaunch -> {
|
|
|
productLaunch.setInventory(productLaunch.getInventory().add(e.getGoodsNum()));
|
|
productLaunch.setInventory(productLaunch.getInventory().add(e.getGoodsNum()));
|
|
|
productLaunch.setVersion(productLaunch.getVersion());
|
|
productLaunch.setVersion(productLaunch.getVersion());
|
|
|
- int count = productLaunchMapper.updateById(productLaunch);
|
|
|
|
|
- if (count == 0) {
|
|
|
|
|
- throw new RuntimeException(productLaunch.getCname() + "该产品上架库存正在操作,请稍后刷新在进行操作!");
|
|
|
|
|
|
|
+ R res = productLaunchService.updateByIdNew(productLaunch);
|
|
|
|
|
+ if (!res.isSuccess()) {
|
|
|
|
|
+ throw new RuntimeException(res.getMsg());
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|
|
@@ -1008,16 +1017,16 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, PjOrder> implemen
|
|
|
|
|
|
|
|
/** ----------------------修改上架库存---------------------- */
|
|
/** ----------------------修改上架库存---------------------- */
|
|
|
//查询所有该商品的库存
|
|
//查询所有该商品的库存
|
|
|
- LambdaQueryWrapper<PjStockDesc> lambdaQueryWrapperList = new LambdaQueryWrapper<>();
|
|
|
|
|
|
|
+ /*LambdaQueryWrapper<PjStockDesc> lambdaQueryWrapperList = new LambdaQueryWrapper<>();
|
|
|
lambdaQueryWrapperList.eq(PjStockDesc::getTenantId, AuthUtil.getTenantId())
|
|
lambdaQueryWrapperList.eq(PjStockDesc::getTenantId, AuthUtil.getTenantId())
|
|
|
.eq(PjStockDesc::getIsDeleted, 0)
|
|
.eq(PjStockDesc::getIsDeleted, 0)
|
|
|
.eq(PjStockDesc::getSalesCompanyId, order.getSalesCompanyId())
|
|
.eq(PjStockDesc::getSalesCompanyId, order.getSalesCompanyId())
|
|
|
.eq(PjStockDesc::getGoodsId, goodsDesc.getId());
|
|
.eq(PjStockDesc::getGoodsId, goodsDesc.getId());
|
|
|
- List<PjStockDesc> stockDescList = stockDescMapper.selectList(lambdaQueryWrapperList);
|
|
|
|
|
|
|
+ List<PjStockDesc> stockDescList = stockDescService.list(lambdaQueryWrapperList);
|
|
|
|
|
|
|
|
//库存总数量
|
|
//库存总数量
|
|
|
BigDecimal balanceQuantity = stockDescList.stream().map(PjStockDesc::getBalanceQuantity).filter(Objects::nonNull).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
BigDecimal balanceQuantity = stockDescList.stream().map(PjStockDesc::getBalanceQuantity).filter(Objects::nonNull).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
-
|
|
|
|
|
|
|
+*/
|
|
|
//查询所有上架商品
|
|
//查询所有上架商品
|
|
|
LambdaQueryWrapper<PjProductLaunch> productLaunchQueryWrapper = new LambdaQueryWrapper<>();
|
|
LambdaQueryWrapper<PjProductLaunch> productLaunchQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
productLaunchQueryWrapper.eq(PjProductLaunch::getTenantId, AuthUtil.getTenantId())
|
|
productLaunchQueryWrapper.eq(PjProductLaunch::getTenantId, AuthUtil.getTenantId())
|
|
@@ -1025,12 +1034,15 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, PjOrder> implemen
|
|
|
.eq(PjProductLaunch::getSalesCompanyId, order.getSalesCompanyId())
|
|
.eq(PjProductLaunch::getSalesCompanyId, order.getSalesCompanyId())
|
|
|
.and(i -> i.eq(PjProductLaunch::getSalesCompanyId, order.getSalesCompanyId()).or().in(PjProductLaunch::getSourceCompanyId, order.getSalesCompanyId()))
|
|
.and(i -> i.eq(PjProductLaunch::getSalesCompanyId, order.getSalesCompanyId()).or().in(PjProductLaunch::getSourceCompanyId, order.getSalesCompanyId()))
|
|
|
.eq(PjProductLaunch::getGoodsId, goodsDesc.getId());
|
|
.eq(PjProductLaunch::getGoodsId, goodsDesc.getId());
|
|
|
- List<PjProductLaunch> productLaunch = productLaunchMapper.selectList(productLaunchQueryWrapper);
|
|
|
|
|
|
|
+ List<PjProductLaunch> productLaunch = productLaunchService.list(productLaunchQueryWrapper);
|
|
|
//修改上架数量
|
|
//修改上架数量
|
|
|
if (ObjectUtil.isNotEmpty(productLaunch)) {
|
|
if (ObjectUtil.isNotEmpty(productLaunch)) {
|
|
|
productLaunch.forEach(e -> {
|
|
productLaunch.forEach(e -> {
|
|
|
e.setInventory(e.getInventory().add(item.getGoodsNum()));
|
|
e.setInventory(e.getInventory().add(item.getGoodsNum()));
|
|
|
- productLaunchMapper.updateById(e);
|
|
|
|
|
|
|
+ R res = productLaunchService.updateByIdNew(e);
|
|
|
|
|
+ if (!res.isSuccess()) {
|
|
|
|
|
+ throw new RuntimeException(res.getMsg());
|
|
|
|
|
+ }
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|
|
|
|
|
|