|
|
@@ -632,6 +632,13 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
}
|
|
|
if (!putBoxes.isEmpty()) {
|
|
|
for (PutBox item : putBoxes) {
|
|
|
+ long count = 0;
|
|
|
+ if (ObjectUtils.isNotNull(item.getCode())){
|
|
|
+ count = itemsListJC.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber()) &&
|
|
|
+ !item.getCode().contains(e.getBoxCode())).count();
|
|
|
+ }else {
|
|
|
+ count = itemsListJC.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber())).count();
|
|
|
+ }
|
|
|
if (ObjectUtils.isNotNull(item.getCode())) {
|
|
|
for (BoxDynamicsRecordItems e : itemsListJC) {
|
|
|
if (e.getContainerNumber().equals(item.getContainerNumber()) && ObjectUtils.isNotNull(item.getCode())
|
|
|
@@ -645,7 +652,6 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
item.setCode(itemsListJC.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber()))
|
|
|
.map(BoxDynamicsRecordItems::getBoxCode).collect(Collectors.joining(",")));
|
|
|
}
|
|
|
- long count = itemsListJC.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber())).count();
|
|
|
if ("0".equals(item.getWhetherManuallyCreate())) {
|
|
|
item.setTotalNum(item.getTotalNum() + Integer.parseInt(count + ""));
|
|
|
item.setRemainingNum(item.getRemainingNum() + Integer.parseInt(count + ""));
|
|
|
@@ -659,6 +665,13 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
if (!tradingBoxes.isEmpty()) {
|
|
|
TradingBox tradingBox = tradingBoxes.stream().filter(e -> e.getId().equals(item.getSrcId())).findFirst().orElse(null);
|
|
|
if (tradingBox != null) {
|
|
|
+ long count1 = 0;
|
|
|
+ if (ObjectUtils.isNotNull(tradingBox.getCode())){
|
|
|
+ count1 = itemsListJC.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber()) &&
|
|
|
+ !tradingBox.getCode().contains(e.getBoxCode())).count();
|
|
|
+ }else {
|
|
|
+ count1 = itemsListJC.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber())).count();
|
|
|
+ }
|
|
|
if (ObjectUtils.isNotNull(item.getCode())) {
|
|
|
for (BoxDynamicsRecordItems e : itemsListJC) {
|
|
|
if (e.getContainerNumber().equals(item.getContainerNumber()) && ObjectUtils.isNotNull(tradingBox.getCode())
|
|
|
@@ -673,8 +686,8 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
.map(BoxDynamicsRecordItems::getBoxCode).collect(Collectors.joining(",")));
|
|
|
}
|
|
|
if ("OW(拿)".contains(item.getBusType())) {
|
|
|
- tradingBox.setSuitcaseNum(tradingBox.getSuitcaseNum() + Integer.parseInt(count + ""));
|
|
|
- tradingBox.setNotSuitcaseNum(tradingBox.getBoxNumber() - item.getSuitcaseNum());
|
|
|
+ tradingBox.setSuitcaseNum(tradingBox.getSuitcaseNum() + Integer.parseInt(count1 + ""));
|
|
|
+ tradingBox.setNotSuitcaseNum(tradingBox.getBoxNumber() - tradingBox.getSuitcaseNum());
|
|
|
}
|
|
|
tradingBoxMapper.updateById(tradingBox);
|
|
|
}
|
|
|
@@ -1408,9 +1421,6 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
if (!archives.getTypeName().equals(item.getBoxType())) {
|
|
|
throw new RuntimeException("箱号:" + item.getBoxCode() + "与箱档案中箱型不符");
|
|
|
}
|
|
|
- if ("使用中".equals(archives.getStatus())) {
|
|
|
- throw new RuntimeException("箱号:" + item.getBoxCode() + "状态为使用中");
|
|
|
- }
|
|
|
archives.setBoxStatus(item.getBoxStatus());
|
|
|
archives.setUpdateTime(new Date());
|
|
|
archives.setUpdateUser(AuthUtil.getUserId());
|
|
|
@@ -1462,11 +1472,11 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
//放箱号明细数据处理
|
|
|
PutBoxItems putBoxItem;
|
|
|
if (!putBoxItemsList.isEmpty()) {
|
|
|
- putBoxItem = putBoxItemsList.stream().filter(e -> e.getBoxCode().equals(item.getBoxCode()))
|
|
|
+ putBoxItem = putBoxItemsList.stream().filter(e -> e.getBoxCode().equals(item.getBoxCode()) &&
|
|
|
+ e.getPid().equals(putBox.getId()))
|
|
|
.findFirst().orElse(null);
|
|
|
if (putBoxItem != null) {
|
|
|
putBoxItem.setPid(putBox.getId());
|
|
|
- putBoxItem.setMblno(item.getMblno());
|
|
|
putBoxItem.setBoxDynamics("调箱进场");
|
|
|
putBoxItem.setStatus("待使用");
|
|
|
putBoxItem.setPolCyId(item.getStationId());
|
|
|
@@ -1475,6 +1485,7 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
putBoxItem.setPolCyEname(item.getPortEname());
|
|
|
putBoxItem.setPolPickUpDate(item.getApproachExitDate());
|
|
|
putBoxItem.setPolPreAppearanceDate(item.getApproachExitDate());
|
|
|
+ putBoxItem.setMblno(putBox.getSrcNo());
|
|
|
putBoxItem.setBoxStatus(item.getBoxStatus());
|
|
|
} else {
|
|
|
putBoxItem = new PutBoxItems();
|
|
|
@@ -1488,7 +1499,6 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
putBoxItem.setBoxCode(item.getBoxCode());
|
|
|
putBoxItem.setBoxType(item.getBoxType());
|
|
|
putBoxItem.setBoxClass(putBox.getBusType());
|
|
|
- putBoxItem.setMblno(item.getMblno());
|
|
|
putBoxItem.setBoxDynamics("调箱进场");
|
|
|
putBoxItem.setPolCyId(item.getStationId());
|
|
|
putBoxItem.setPolCyCode(item.getStationCode());
|
|
|
@@ -1496,6 +1506,7 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
putBoxItem.setPolCyEname(item.getPortEname());
|
|
|
putBoxItem.setPolPickUpDate(item.getApproachExitDate());
|
|
|
putBoxItem.setPolPreAppearanceDate(item.getApproachExitDate());
|
|
|
+ putBoxItem.setMblno(putBox.getSrcNo());
|
|
|
}
|
|
|
} else {
|
|
|
putBoxItem = new PutBoxItems();
|
|
|
@@ -1509,7 +1520,7 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
putBoxItem.setContainerNumber(item.getContainerNumber());
|
|
|
putBoxItem.setBoxCode(item.getBoxCode());
|
|
|
putBoxItem.setBoxType(item.getBoxType());
|
|
|
- putBoxItem.setMblno(item.getMblno());
|
|
|
+ putBoxItem.setMblno(putBox.getSrcNo());
|
|
|
putBoxItem.setBoxDynamics("调箱进场");
|
|
|
putBoxItem.setPolCyId(item.getStationId());
|
|
|
putBoxItem.setPolCyCode(item.getStationCode());
|
|
|
@@ -1540,9 +1551,8 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
tradingBoxItem = tradingBoxItemList.stream().filter(e -> e.getCode().equals(item.getBoxCode()))
|
|
|
.findFirst().orElse(null);
|
|
|
if (tradingBoxItem != null) {
|
|
|
-// throw new RemoteException("箱号:" + item.getBoxCode() + "在放箱号:" + item.getContainerNumber() + "单据中已存在,不能重复导入");
|
|
|
tradingBoxItem.setPid(tradingBox.getId());
|
|
|
- tradingBoxItem.setMblno(item.getMblno());
|
|
|
+ tradingBoxItem.setMblno(putBox.getSrcNo());
|
|
|
tradingBoxItem.setBoxDynamics("调箱进场");
|
|
|
tradingBoxItem.setPortId(item.getPortId());
|
|
|
tradingBoxItem.setPortCode(item.getPortCode());
|
|
|
@@ -1580,7 +1590,7 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
tradingBoxItem.setPid(tradingBox.getId());
|
|
|
tradingBoxItem.setContainerNumber(item.getContainerNumber());
|
|
|
tradingBoxItem.setCode(item.getBoxCode());
|
|
|
- tradingBoxItem.setMblno(item.getMblno());
|
|
|
+ tradingBoxItem.setMblno(putBox.getSrcNo());
|
|
|
tradingBoxItem.setBoxDynamics("调箱进场");
|
|
|
tradingBoxItem.setBoxType(item.getBoxType());
|
|
|
tradingBoxItem.setPortId(item.getPortId());
|
|
|
@@ -1620,7 +1630,7 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
tradingBoxItem.setPid(tradingBox.getId());
|
|
|
tradingBoxItem.setContainerNumber(item.getContainerNumber());
|
|
|
tradingBoxItem.setCode(item.getBoxCode());
|
|
|
- tradingBoxItem.setMblno(item.getMblno());
|
|
|
+ tradingBoxItem.setMblno(putBox.getSrcNo());
|
|
|
tradingBoxItem.setBoxDynamics("调箱进场");
|
|
|
tradingBoxItem.setBoxType(item.getBoxType());
|
|
|
tradingBoxItem.setPortId(item.getPortId());
|
|
|
@@ -1663,6 +1673,13 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
}
|
|
|
if (!putBoxes.isEmpty()) {
|
|
|
for (PutBox item : putBoxes) {
|
|
|
+ long count = 0;
|
|
|
+ if (ObjectUtils.isNotNull(item.getCode())){
|
|
|
+ count = itemsListZJ.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber()) &&
|
|
|
+ !item.getCode().contains(e.getBoxCode())).count();
|
|
|
+ }else {
|
|
|
+ count = itemsListZJ.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber())).count();
|
|
|
+ }
|
|
|
if (ObjectUtils.isNotNull(item.getCode())) {
|
|
|
for (BoxDynamicsRecordItems e : itemsListZJ) {
|
|
|
if (e.getContainerNumber().equals(item.getContainerNumber()) && ObjectUtils.isNotNull(item.getCode())
|
|
|
@@ -1676,9 +1693,26 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
item.setCode(itemsListZJ.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber()))
|
|
|
.map(BoxDynamicsRecordItems::getBoxCode).collect(Collectors.joining(",")));
|
|
|
}
|
|
|
+ if ("0".equals(item.getWhetherManuallyCreate())) {
|
|
|
+ item.setTotalNum(item.getTotalNum() + Integer.parseInt(count + ""));
|
|
|
+ item.setRemainingNum(item.getRemainingNum() + Integer.parseInt(count + ""));
|
|
|
+ item.setStorageNum(item.getStorageNum() + Integer.parseInt(count + ""));
|
|
|
+ }
|
|
|
+ if ("OW(拿)".equals(item.getBusType())) {
|
|
|
+ item.setSuitcaseNum(item.getSuitcaseNum() + Integer.parseInt(count + ""));
|
|
|
+ item.setNotSuitcaseNum(item.getTotalNum() - item.getSuitcaseNum());
|
|
|
+ item.setStorageNum(item.getStorageNum() + Integer.parseInt(count + ""));
|
|
|
+ }
|
|
|
if (!tradingBoxes.isEmpty()) {
|
|
|
TradingBox tradingBox = tradingBoxes.stream().filter(e -> e.getId().equals(item.getSrcId())).findFirst().orElse(null);
|
|
|
if (tradingBox != null) {
|
|
|
+ long count1 = 0;
|
|
|
+ if (ObjectUtils.isNotNull(tradingBox.getCode())){
|
|
|
+ count1 = itemsListJC.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber()) &&
|
|
|
+ !tradingBox.getCode().contains(e.getBoxCode())).count();
|
|
|
+ }else {
|
|
|
+ count1 = itemsListJC.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber())).count();
|
|
|
+ }
|
|
|
if (ObjectUtils.isNotNull(item.getCode())) {
|
|
|
for (BoxDynamicsRecordItems e : itemsListZJ) {
|
|
|
if (e.getContainerNumber().equals(item.getContainerNumber()) && ObjectUtils.isNotNull(tradingBox.getCode())
|
|
|
@@ -1692,6 +1726,10 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
tradingBox.setCode(itemsListZJ.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber()))
|
|
|
.map(BoxDynamicsRecordItems::getBoxCode).collect(Collectors.joining(",")));
|
|
|
}
|
|
|
+ if ("OW(拿)".contains(item.getBusType())) {
|
|
|
+ tradingBox.setSuitcaseNum(tradingBox.getSuitcaseNum() + Integer.parseInt(count1 + ""));
|
|
|
+ tradingBox.setNotSuitcaseNum(tradingBox.getBoxNumber() - tradingBox.getSuitcaseNum());
|
|
|
+ }
|
|
|
tradingBoxMapper.updateById(tradingBox);
|
|
|
}
|
|
|
}
|
|
|
@@ -1978,7 +2016,7 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
.findFirst().orElse(null);
|
|
|
if (tradingBoxItem != null) {
|
|
|
tradingBoxItem.setPid(tradingBox.getId());
|
|
|
- tradingBoxItem.setBoxDynamics("空箱出场");
|
|
|
+ tradingBoxItem.setBoxDynamics("调箱出场");
|
|
|
tradingBoxItem.setPortId(item.getPortId());
|
|
|
tradingBoxItem.setPortCode(item.getPortCode());
|
|
|
tradingBoxItem.setPortCname(item.getPortCname());
|
|
|
@@ -2099,6 +2137,26 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
item.setCode(itemsListZD.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber()))
|
|
|
.map(BoxDynamicsRecordItems::getBoxCode).collect(Collectors.joining(",")));
|
|
|
}
|
|
|
+ long count = itemsListZD.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber())).count();
|
|
|
+ if ("OW(拿)".equals(item.getBusType())) {
|
|
|
+ item.setStorageNum(item.getStorageNum() - Integer.parseInt(count + ""));
|
|
|
+ if (item.getStorageNum() < 0) {
|
|
|
+ throw new RuntimeException("放箱号:" + item.getContainerNumber() + "剩余场地盘存小于本次导入箱数");
|
|
|
+ }
|
|
|
+ } else if ("OW(放)".equals(item.getBusType())) {
|
|
|
+ item.setThisSuitcaseNum(Integer.parseInt(count + ""));
|
|
|
+ item.setSuitcaseNum(item.getSuitcaseNum() + Integer.parseInt(count + ""));
|
|
|
+ item.setNotSuitcaseNum(item.getTotalNum() - item.getSuitcaseNum());
|
|
|
+ if (item.getNotSuitcaseNum() < 0) {
|
|
|
+ throw new RuntimeException("放箱号:" + item.getContainerNumber() + "剩余未提箱小于本次导入箱数");
|
|
|
+ }
|
|
|
+ item.setRemainingNum(item.getRemainingNum() - Integer.parseInt(count + ""));
|
|
|
+ } else {
|
|
|
+ item.setStorageNum(item.getStorageNum() - Integer.parseInt(count + ""));
|
|
|
+ if (item.getStorageNum() < 0) {
|
|
|
+ throw new RuntimeException("放箱号:" + item.getContainerNumber() + "剩余场地盘存小于本次导入箱数");
|
|
|
+ }
|
|
|
+ }
|
|
|
putBoxList1.add(item);
|
|
|
if (!tradingBoxes.isEmpty()) {
|
|
|
TradingBox tradingBox = tradingBoxes.stream().filter(e -> e.getId().equals(item.getSrcId())).findFirst().orElse(null);
|
|
|
@@ -2116,6 +2174,15 @@ public class BoxDynamicsRecordServiceImpl extends ServiceImpl<BoxDynamicsRecordM
|
|
|
tradingBox.setCode(itemsListZD.stream().filter(e -> e.getContainerNumber().equals(item.getContainerNumber()))
|
|
|
.map(BoxDynamicsRecordItems::getBoxCode).collect(Collectors.joining(",")));
|
|
|
}
|
|
|
+ if ("OW(放)".equals(item.getBusType())) {
|
|
|
+ item.setSuitcaseNum(item.getSuitcaseNum() + Integer.parseInt(count + ""));
|
|
|
+ item.setNotSuitcaseNum(item.getTotalNum() - item.getSuitcaseNum());
|
|
|
+ if (item.getNotSuitcaseNum() < 0) {
|
|
|
+ throw new RuntimeException("放箱号:" + item.getContainerNumber() + "剩余未提箱小于本次导入箱数");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ tradingBox.setActualBoxNumber(tradingBox.getActualBoxNumber() - Integer.parseInt(count + ""));
|
|
|
+ tradingBox.setRemainingBoxNumber(tradingBox.getBoxNumber() - tradingBox.getActualBoxNumber());
|
|
|
tradingBoxMapper.updateById(tradingBox);
|
|
|
}
|
|
|
}
|