hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

丽知：过滤0107和0207 无源头件类型

This commit is contained in:
zhengyf 2025-01-12 14:26:02 +08:00
parent 111280c203
commit 46080c7e3b
2 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/adjust/AdjustInPluginInitializer.java
View File

@ -46,7 +46,6 @@ import java.util.concurrent.locks.ReentrantLock;
* 排除（U8_RECEIPT_TYPE）：组装入库 * 排除（U8_RECEIPT_TYPE）：组装入库
* U8入库类型（U8_RECEIPT_TYPE） * U8入库类型（U8_RECEIPT_TYPE）
* U8_RECEIPT_TYPE 0106 组装入库 * U8_RECEIPT_TYPE 0106 组装入库
*
*/ */
public class AdjustInPluginInitializer extends PluginBaseEntity { public class AdjustInPluginInitializer extends PluginBaseEntity {
@ -156,7 +155,7 @@ public class AdjustInPluginInitializer extends PluginBaseEntity {
queryOfsStockinOrderRequestVO.setClosedAt_end(endTimeStr); queryOfsStockinOrderRequestVO.setClosedAt_end(endTimeStr);
List<StockinOrderSearchResponse.StockinOrder> stockinOrders = queryOfsStockinOrder(queryOfsStockinOrderRequestVO); List<StockinOrderSearchResponse.StockinOrder> stockinOrders = queryOfsStockinOrder(queryOfsStockinOrderRequestVO);
if (stockinOrders==null||stockinOrders.size() == 0) { if (stockinOrders == null || stockinOrders.size() == 0) {
return; return;
} }
//过滤日志 //过滤日志
@ -246,7 +245,7 @@ public class AdjustInPluginInitializer extends PluginBaseEntity {
for (StockinOrderSearchResponse.StockinOrder stockinOrder : stockinOrders) { for (StockinOrderSearchResponse.StockinOrder stockinOrder : stockinOrders) {
StockinOrderSearchResponse.StockinOrder.StockinH header = stockinOrder.getHeader(); StockinOrderSearchResponse.StockinOrder.StockinH header = stockinOrder.getHeader();
//过滤"NMNS"\"YNS"\"HJ" //过滤"NMNS"\"YNS"\"HJ"
if("NMNS".equals(header.getCompanyCode())||"YNS".equals(header.getCompanyCode())||"HJ".equals(header.getCompanyCode())){ if ("NMNS".equals(header.getCompanyCode()) || "YNS".equals(header.getCompanyCode()) || "HJ".equals(header.getCompanyCode())) {
continue; continue;
} }
String rootAppPk = header.getCode(); String rootAppPk = header.getCode();
@ -319,10 +318,10 @@ public class AdjustInPluginInitializer extends PluginBaseEntity {
Assert.state(false, "根据调整入库单号：{}，查询调整单：{}，失败。不存在或不唯一。", ofsCode, ofsHeader.getRefOrderCode()); Assert.state(false, "根据调整入库单号：{}，查询调整单：{}，失败。不存在或不唯一。", ofsCode, ofsHeader.getRefOrderCode());
} }
String u8ReceiptType = ofsAdjustOrders.get(0).getHeader().getU8ReceiptType(); String u8ReceiptType = ofsAdjustOrders.get(0).getHeader().getU8ReceiptType();
if(u8ReceiptType==null){ if (u8ReceiptType == null) {
Assert.state(false,"调整单：{}，收发类别（入库类别）为空，请维护。",ofsAdjustOrders.get(0).getHeader().getCode()); Assert.state(false, "调整单：{}，收发类别（入库类别）为空，请维护。", ofsAdjustOrders.get(0).getHeader().getCode());
} }
if("0106".equals(u8ReceiptType)){//20240910：排除组装入库，单独做一个插件 if ("0106".equals(u8ReceiptType) || "0107".equals(u8ReceiptType)) {//20240910：排除组装入库，单独做一个插件，20250112：无源件不接
continue; continue;
} }
// BdRdclEntity bdRdclEntity = new BdRdclEntity(); // BdRdclEntity bdRdclEntity = new BdRdclEntity();
@ -351,7 +350,7 @@ public class AdjustInPluginInitializer extends PluginBaseEntity {
children.setNshouldinnum(String.valueOf(ofsDetail.getRequestQty())); children.setNshouldinnum(String.valueOf(ofsDetail.getRequestQty()));
//nintnum--实入数量,20241106妮妮姐私聊：可以改成实收是0你就不传这条明细 明细里就不传这个 //nintnum--实入数量,20241106妮妮姐私聊：可以改成实收是0你就不传这条明细 明细里就不传这个
if(ofsDetail.getReceivedQty()==null||"0".equals(ofsDetail.getReceivedQty())){ if (ofsDetail.getReceivedQty() == null || "0".equals(ofsDetail.getReceivedQty())) {
continue; continue;
} }
children.setNinnum(String.valueOf(ofsDetail.getReceivedQty())); children.setNinnum(String.valueOf(ofsDetail.getReceivedQty()));
@ -398,7 +397,7 @@ public class AdjustInPluginInitializer extends PluginBaseEntity {
integrationTaskLivingDetailsEntity.setRootAppPk(ofsCode); integrationTaskLivingDetailsEntity.setRootAppPk(ofsCode);
integrationTaskLivingDetailsEntity.setRootAppBill(ofsCode); integrationTaskLivingDetailsEntity.setRootAppBill(ofsCode);
integrationTaskLivingDetailsEntity.setNewSystemPrimary(vbillId); integrationTaskLivingDetailsEntity.setNewSystemPrimary(vbillId);
integrationTaskLivingDetailsEntity.setNewSystemNumber(corpCode+"_"+vbillcode); integrationTaskLivingDetailsEntity.setNewSystemNumber(corpCode + "_" + vbillcode);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
@ -407,12 +406,12 @@ public class AdjustInPluginInitializer extends PluginBaseEntity {
logger.error("推送U8C，丽知：OFS调整入库--->U8C其它入库失败，失败原因：" + e); logger.error("推送U8C，丽知：OFS调整入库--->U8C其它入库失败，失败原因：" + e);
ReusltStrDto reusltStrDto = JSON.parseObject(response, ReusltStrDto.class); ReusltStrDto reusltStrDto = JSON.parseObject(response, ReusltStrDto.class);
String ErrMessage=""; String ErrMessage = "";
if (reusltStrDto != null) { if (reusltStrDto != null) {
ErrMessage = "推送U8C，丽知：OFS调整入库--->U8C其它入库失败，失败原因：" + reusltStrDto.getErrormsg(); ErrMessage = "推送U8C，丽知：OFS调整入库--->U8C其它入库失败，失败原因：" + reusltStrDto.getErrormsg();
}else { } else {
ErrMessage=e.getMessage(); ErrMessage = e.getMessage();
} }
//失败 //失败

2
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/adjust/AdjustOutPluginInitializer.java
View File

@ -322,7 +322,7 @@ public class AdjustOutPluginInitializer extends PluginBaseEntity {
if(u8ShipmentType==null){ if(u8ShipmentType==null){
Assert.state(false,"调整单：{}，收发类别（出库类别）为空，请维护。",ofsAdjustOrders.get(0).getHeader().getCode()); Assert.state(false,"调整单：{}，收发类别（出库类别）为空，请维护。",ofsAdjustOrders.get(0).getHeader().getCode());
} }
if("0206".equals(u8ShipmentType)){//20240910：排除组装出库，不做处理 if("0206".equals(u8ShipmentType) || "0207".equals(u8ShipmentType)){//20240910：排除组装出库，不做处理。20250112：无源件不做处理
continue; continue;
} }