|
@@ -11,6 +11,8 @@ import com.fjhx.item.entity.product.po.ProductInfo;
|
|
|
import com.fjhx.item.service.product.ProductInfoService;
|
|
|
import com.fjhx.wms.entity.stock.dto.StockWaitDto;
|
|
|
import com.fjhx.wms.entity.stock.dto.StockWaitSelectDto;
|
|
|
+import com.fjhx.wms.entity.stock.emums.JournalType;
|
|
|
+import com.fjhx.wms.entity.stock.emums.StockWaitType;
|
|
|
import com.fjhx.wms.entity.stock.po.*;
|
|
|
import com.fjhx.wms.entity.stock.vo.StockWaitDetailsVo;
|
|
|
import com.fjhx.wms.entity.stock.vo.StockWaitVo;
|
|
@@ -88,7 +90,7 @@ public class StockWaitServiceImpl extends ServiceImpl<StockWaitMapper, StockWait
|
|
|
//过滤入库/出库
|
|
|
wrapper.eq(StockWait::getType, dto.getType());
|
|
|
wrapper.eq(StockWait::getBusinessCode, dto.getKeyword());
|
|
|
- wrapper.eq(StockWait::getStatus,dto.getStatus());
|
|
|
+ wrapper.eq(StockWait::getStatus, dto.getStatus());
|
|
|
Page<StockWaitVo> page = this.baseMapper.getPage(dto.getPage(), wrapper);
|
|
|
|
|
|
List<StockWaitVo> records = page.getRecords();
|
|
@@ -152,7 +154,7 @@ public class StockWaitServiceImpl extends ServiceImpl<StockWaitMapper, StockWait
|
|
|
Map<Long, ProductInfo> productInfoMap = productInfos.stream().collect(Collectors.toMap(ProductInfo::getId, Function.identity()));
|
|
|
for (StockWaitDetailsVo stockWaitDetails : stockWaitDetailsVos) {
|
|
|
ProductInfo productInfo = productInfoMap.get(stockWaitDetails.getProductId());
|
|
|
- if(ObjectUtil.isEmpty(productInfo)){
|
|
|
+ if (ObjectUtil.isEmpty(productInfo)) {
|
|
|
continue;
|
|
|
}
|
|
|
stockWaitDetails.setProductName(productInfo.getName());
|
|
@@ -178,8 +180,25 @@ public class StockWaitServiceImpl extends ServiceImpl<StockWaitMapper, StockWait
|
|
|
StockWait byId = getById(stockWaitDetails.getStockWaitId());
|
|
|
//创建出入库记录
|
|
|
StockJournal stockJournal = new StockJournal();
|
|
|
- stockJournal.setType(byId.getType() == 1 ? 4 : 5);
|
|
|
- stockJournal.setCode(byId.getType()==1? CodeEnum.SIN_CODE.getCode() : CodeEnum.SOUT_CODE.getCode());
|
|
|
+ stockJournal.setOpType(byId.getType());
|
|
|
+ //根据待入库业务类型创建待出入库记录
|
|
|
+ Integer businessType = stockWaitDto.getBusinessType();
|
|
|
+ if (StockWaitType.BORDER_OF_LINE_IN.getDetailType().equals(businessType)) {
|
|
|
+ //线边回仓库
|
|
|
+ stockJournal.setType(JournalType.BORDER_OF_LINE_IN.getDetailType());
|
|
|
+ } else if (StockWaitType.COMPLETION_IN.getDetailType().equals(businessType)) {
|
|
|
+ //完工入库
|
|
|
+ stockJournal.setType(JournalType.COMPLETION_IN.getDetailType());
|
|
|
+ } else if (StockWaitType.PURCHASE_ARRIVAL_IN.getDetailType().equals(businessType)) {
|
|
|
+ //采购到货
|
|
|
+ stockJournal.setType(JournalType.PURCHASE_ARRIVAL_IN.getDetailType());
|
|
|
+ } else if (StockWaitType.BACK_OUT.getDetailType().equals(businessType)) {
|
|
|
+ //退货出货
|
|
|
+ stockJournal.setType(JournalType.BACK_OUT.getDetailType());
|
|
|
+ } else {
|
|
|
+ throw new ServiceException("未知待入库业务类型");
|
|
|
+ }
|
|
|
+ stockJournal.setCode(byId.getType() == 1 ? CodeEnum.SIN_CODE.getCode() : CodeEnum.SOUT_CODE.getCode());
|
|
|
stockJournal.setWarehouseId(stockWaitDto.getWarehouseId());
|
|
|
stockJournal.setBusinessId(byId.getId());
|
|
|
//保存出入库记录
|
|
@@ -228,9 +247,9 @@ public class StockWaitServiceImpl extends ServiceImpl<StockWaitMapper, StockWait
|
|
|
stockWaitDetailsService.updateBatchById(stockWaitDetails);
|
|
|
//修改待入库状态
|
|
|
StockWait stockWait = getById(stockWaitDto.getId());
|
|
|
- if(statusFlag==stockWaitDetails.size()){
|
|
|
+ if (statusFlag == stockWaitDetails.size()) {
|
|
|
stockWait.setStatus(2);//入库完成
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
stockWait.setStatus(1);//部分入库
|
|
|
}
|
|
|
updateById(stockWait);
|
|
@@ -238,7 +257,7 @@ public class StockWaitServiceImpl extends ServiceImpl<StockWaitMapper, StockWait
|
|
|
//创建出入库记录
|
|
|
StockJournal stockJournal = new StockJournal();
|
|
|
stockJournal.setType(stockWaitDto.getType() == 1 ? 4 : 5);
|
|
|
- stockJournal.setCode(stockWait.getType()==1?CodeEnum.SIN_CODE.getCode() : CodeEnum.SOUT_CODE.getCode());
|
|
|
+ stockJournal.setCode(stockWait.getType() == 1 ? CodeEnum.SIN_CODE.getCode() : CodeEnum.SOUT_CODE.getCode());
|
|
|
stockJournal.setWarehouseId(stockWaitDto.getWarehouseId());
|
|
|
stockJournal.setBusinessId(stockWaitDto.getId());
|
|
|
//保存出入库记录
|