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

丽知：新增调整单。

This commit is contained in:
zhengyf 2024-08-24 23:16:04 +08:00
parent ca95709867
commit b169b6bcb8
4 changed files with 134 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
buildpackage/src/main/java/com/hzya/frame/plugin/lets/ofsvo/QueryOfsAdjustOrderRequestVO.java Normal file
View File

@ -0,0 +1,32 @@
package com.hzya.frame.plugin.lets.ofsvo;
import lombok.Data;
/**
* ofs调整单查询
*/
@Data
public class QueryOfsAdjustOrderRequestVO{
/** 开始时间 */
private String created_start;
/** 结束时间 */
private String created_end;
/** 组织 */
private String clientCode;
/** 调拨订单 */
private String code;
/** 状态 */
private String status;
/** 订单类型 */
private String internalOrderType;
/** 上位系统订单号 */
private String sourceOrderCode;
/** 货主 */
private String companyCode;
/** 库存地点 */
private String facilityCode;
/** 分页页数 */
private Long pageNo;
/** 每页条数 1-500,默认50 */
private Long pageSize;
}

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

@ -11,6 +11,7 @@ import com.hzya.frame.plugin.lets.constant.OverallConstant;
import com.hzya.frame.plugin.lets.constant.ProfilesActiveConstant;
import com.hzya.frame.plugin.lets.dao.IBdRdclDao;
import com.hzya.frame.plugin.lets.entity.BdRdclEntity;
import com.hzya.frame.plugin.lets.ofsvo.QueryOfsAdjustOrderRequestVO;
import com.hzya.frame.plugin.lets.ofsvo.QueryOfsStockinOrderRequestVO;
import com.hzya.frame.plugin.lets.ofsvo.QueryOfsStockoutOrderRequestVO;
import com.hzya.frame.plugin.lets.u8cdto.GeneralBillVO_4ADto;
@ -23,7 +24,9 @@ import com.hzya.frame.plugin.lets.util.pushData.PushU8CByApiCode;
import com.hzya.frame.plugin.lets.util.pushData.ZTResult;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.dao.IIntegrationTaskLivingDetailsDao;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.entity.IntegrationTaskLivingDetailsEntity;
import com.hzya.frame.ttxofs.basics.ReturnMessageBasics;
import com.hzya.frame.ttxofs.dto.InterfaceParamDto;
import com.hzya.frame.ttxofs.dto.ofsTransferOrderSearch.OFSAdjustOrderSearchResponse;
import com.hzya.frame.ttxofs.dto.ofssaleorderoutsearch.DetailsDto;
import com.hzya.frame.ttxofs.dto.ofssaleorderoutsearch.HeaderDetailsDto;
import com.hzya.frame.ttxofs.dto.ofssaleorderoutsearch.HeaderDto;
@ -365,13 +368,13 @@ public class AdjustOutPluginInitializer extends PluginBaseEntity {
vbillcode = resGeneralBillVO.getParentvo().getVbillcode();
}
if (!isSuccess) {
Assert.state(false, "推送U8C--> 丽知：OFS调整出库--->U8C其它出库 失败 接口返回结果：{} 接口入参:{}", response, mapStr);
Assert.state(false, "推送U8C--> 丽知：OFS调整出库--->U8C其它出库 失败 接口返回结果：{} 接口入参:{}", attribute.getErrormsg(), mapStr);
}
//成功
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y);
integrationTaskLivingDetailsEntity.setRootAppNewData(mapStr);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(response);
integrationTaskLivingDetailsEntity.setNewTransmitInfo(attribute.getData());
integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(format);
integrationTaskLivingDetailsEntity.setRootAppPk(ofsCode);
@ -473,4 +476,25 @@ public class AdjustOutPluginInitializer extends PluginBaseEntity {
}
return null;
}
/**
* ofs调整单查询
* ofs. adjustOrder.search
*/
public void queryOfsAdjustOrders(String ofsAdjustCode) throws Exception {
QueryOfsAdjustOrderRequestVO queryOfsAdjustOrderRequestVO = new QueryOfsAdjustOrderRequestVO();
queryOfsAdjustOrderRequestVO.setClientCode("LETS");
queryOfsAdjustOrderRequestVO.setCode(ofsAdjustCode);
queryOfsAdjustOrderRequestVO.setPageNo(1L);
queryOfsAdjustOrderRequestVO.setPageSize(500L);
InterfaceParamDto interfaceParamDto = new InterfaceParamDto();
interfaceParamDto.setApi("ofs.adjustOrder.search");
interfaceParamDto.setData(JSON.toJSONString(queryOfsAdjustOrderRequestVO));
OFSAdjustOrderSearchResponse ofsAdjustOrderSearchResponse =(OFSAdjustOrderSearchResponse) ofsUnifiedService.unified(interfaceParamDto);
System.out.println(ofsAdjustOrderSearchResponse);
}
}

2
service/src/main/java/com/hzya/frame/ttxofs/basics/ApiDtoCacheMap.java
View File

@ -4,6 +4,7 @@ import com.hzya.frame.ttxofs.dto.ofsBaseSearch.OFSSKUClassSearchResponse;
import com.hzya.frame.ttxofs.dto.ofsBaseSearch.OFSSKUSearchResponse;
import com.hzya.frame.ttxofs.dto.ofsBaseSearch.OfsShopReturnMessageDto;
import com.hzya.frame.ttxofs.dto.ofsBaseSearch.OfsSupplierReturnMessageDto;
import com.hzya.frame.ttxofs.dto.ofsTransferOrderSearch.OFSAdjustOrderSearchResponse;
import com.hzya.frame.ttxofs.dto.ofsTransferOrderSearch.OFSTranseferOrderSearchResponse;
import com.hzya.frame.ttxofs.dto.ofspoorder.OfsPoOrderBean;
import com.hzya.frame.ttxofs.dto.ofssaleorderoutsearch.SaleOutReturnMessageDto;
@ -43,5 +44,6 @@ public class ApiDtoCacheMap {
apiDtoCacheMap.put("ofs.returnOrder.search", new RerturnGoodsOrderSearchJsonRootBean());//售后订单
apiDtoCacheMap.put("ofs.purchaseOrder.search", new OfsPoOrderBean());//采购订单
apiDtoCacheMap.put("ofs.adjustOrder.search", new OFSAdjustOrderSearchResponse());//调整单
}
}

74
service/src/main/java/com/hzya/frame/ttxofs/dto/ofsTransferOrderSearch/OFSAdjustOrderSearchResponse.java Normal file
View File

@ -0,0 +1,74 @@
package com.hzya.frame.ttxofs.dto.ofsTransferOrderSearch;
import com.hzya.frame.ttxofs.basics.ReturnMessageBasics;
import lombok.Data;
import java.util.Date;
import java.util.List;
@Data
public class OFSAdjustOrderSearchResponse extends ReturnMessageBasics {
private List<OFSAdjustOrder> data;
@Data
public class OFSAdjustOrder{
private OFSAdjustH header;
private List<OFSAdjustB> details;
@Data
public class OFSAdjustH{
private String id;
private String clientCode;
private String companyCode;
private String facilityCode;
private String code;
private String adjustType;
private String status;
private String totalLines;
private String totalQty;
private String quantityUM;
private String totalWeight;
private String totalVolume;
private String totalVolumeWeight;
private String weightUM;
private String volumeUM;
private String errorCode;
private String errorDesc;
private String StringernalOrderType;
private String bizChannel;
private String created;
private String createdBy;
private String lastUpdated;
private String lastUpdatedBy;
private String remark;
private String sourcePlatformCode;
}
@Data
public class OFSAdjustB{
/** id */
private String id;
private String clientCode;
private String companyCode;
private String facilityCode;
private String adjustOrderId;
private String adjustOrderCode;
private String skuCode;
private String skuName;
private String inventorySts;
private String totalWeight;
private String totalVolume;
private String weightUM;
private String volumeUM;
private String requestQty;
private String hasAdjustQty;
private String waitAdjustQty;
private String created;
private String createdBy;
private String lastUpdated;
private String lastUpdatedBy;
private String totalVolumeWeight;
private String quantityUM;
}
}
}