From c560fc99409ba6db544ce81f036a146145af8fac Mon Sep 17 00:00:00 2001 From: zhengyf Date: Wed, 30 Apr 2025 15:18:53 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=BD=E7=9F=A5=EF=BC=9A1=E3=80=81=E6=96=B0?= =?UTF-8?q?=E5=A2=9EOFS=E8=B0=83=E6=95=B4=E5=85=A5=E5=BA=93(=E6=97=A0?= =?UTF-8?q?=E6=BA=90=E4=BB=B6=E5=85=A5=E5=BA=93)--->U8C=E7=BA=A2=E5=AD=97?= =?UTF-8?q?=E5=85=B6=E5=AE=83=E5=87=BA=E5=BA=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../adjust/AdjustInWYJPluginInitializer.java | 564 ++++++++++++++++++ .../plugin/lets/spring/spring-lets-plugin.xml | 3 + .../lets/plugin/transfer/TransferTest.java | 17 +- 3 files changed, 583 insertions(+), 1 deletion(-) create mode 100644 buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/adjust/AdjustInWYJPluginInitializer.java diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/adjust/AdjustInWYJPluginInitializer.java b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/adjust/AdjustInWYJPluginInitializer.java new file mode 100644 index 00000000..00a6a0b9 --- /dev/null +++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/adjust/AdjustInWYJPluginInitializer.java @@ -0,0 +1,564 @@ +package com.hzya.frame.plugin.lets.plugin.adjust; + +import cn.hutool.core.date.DateField; +import cn.hutool.core.date.DateUtil; +import cn.hutool.core.lang.Assert; +import cn.hutool.json.JSONUtil; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.hzya.frame.base.PluginBaseEntity; +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.ofsvo.QueryOfsAdjustOrderRequestVO; +import com.hzya.frame.plugin.lets.ofsvo.QueryOfsSoSaleOutVo; +import com.hzya.frame.plugin.lets.ofsvo.QueryOfsStockinOrderRequestVO; +import com.hzya.frame.plugin.lets.u8cdto.GeneralBillVO_4ADto; +import com.hzya.frame.plugin.lets.u8cdto.GeneralBillVO_4IDto; +import com.hzya.frame.plugin.lets.u8cdto.ReusltStrDto; +import com.hzya.frame.plugin.lets.util.OfsStandardUtil; +import com.hzya.frame.plugin.lets.util.PushDataByU8cUtil; +import com.hzya.frame.plugin.lets.util.QueryU8CEntityUtil; +import com.hzya.frame.plugin.lets.util.SaveOrUpdateBusinessLogUtil; +import com.hzya.frame.plugin.lets.util.pushData.Attribute; +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.dto.InterfaceParamDto; +import com.hzya.frame.ttxofs.dto.ofsTransferOrderSearch.OFSAdjustOrderSearchResponse; +import com.hzya.frame.ttxofs.dto.passivestorage.PassiveStorageResponse; +import com.hzya.frame.ttxofs.dto.stock.StockinOrderSearchResponse; +import com.hzya.frame.ttxofs.dto.stock.StockoutOrderSearchResponse; +import com.hzya.frame.ttxofs.service.OfsUnifiedService; +import com.hzya.frame.web.entity.BaseResult; +import com.hzya.frame.web.entity.JsonResultEntity; +import org.apache.commons.lang3.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; + +import java.util.ArrayList; +import java.util.Date; +import java.util.List; +import java.util.concurrent.locks.ReentrantLock; + +/** + * OFS调整入库(无源件入库)--->U8C红字其它出库 + * 接收（U8_RECEIPT_TYPE）：无源件入库 + * U8入库类型（U8_RECEIPT_TYPE） + * U8_RECEIPT_TYPE 0107 无源件入库 + *

+ * 1、调整单备注字段 对应无源入库单 + * 2、根据无源入库单查询是否有售后单号，有售后单号则过滤。 + */ + +public class AdjustInWYJPluginInitializer extends PluginBaseEntity { + Logger logger = LoggerFactory.getLogger(AdjustInWYJPluginInitializer.class); + + private static final ReentrantLock LOCK = new ReentrantLock(true); + + @Override + public void initialize() { + logger.info(getPluginLabel() + "執行初始化方法initialize()"); + } + + @Override + public void destroy() { + logger.info(getPluginLabel() + "執行銷毀方法destroy()"); + } + + @Override + public String getPluginId() { + return "adjust.AdjustInPluginInitializer"; + } + + @Override + public String getPluginName() { + return "丽知：OFS调整入库(无源件入库)--->U8C红字其它出库"; + } + + @Override + public String getPluginLabel() { + return "丽知：OFS调整入库(无源件入库)--->U8C红字其它出库"; + } + + @Override + public String getPluginType() { + return "1"; + } + + @Autowired + private IIntegrationTaskLivingDetailsDao iIntegrationTaskLivingDetailsDao; + @Autowired + private PushDataByU8cUtil pushDataByU8cUtil; + @Autowired + private PushU8CByApiCode pushU8CByApiCode; + @Autowired + private SaveOrUpdateBusinessLogUtil saveOrUpdateBusinessLogUtil; + + @Autowired + private OfsUnifiedService ofsUnifiedService; + + @Autowired + private IBdRdclDao iBdRdclDao; + @Autowired + private QueryU8CEntityUtil queryU8CEntityUtil; + + @Override + public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception { + try { + logger.info("调用：" + getPluginName() + "-插件"); + String prod = "prod"; + String param = String.valueOf(requestJson.get("param")); + if (requestJson != null && ProfilesActiveConstant.TYPE_DATE.equals(requestJson.get("type"))) { + //按日期 + if (param != null && !"".equals(param)) { + String[] split = param.split("/"); + if (!(split.length == 2)) { + Assert.state(false, "时间格式传递不正确"); + } + Assert.notNull(split[0], "开始时间不能为空"); + Assert.notNull(split[1], "结束时间不能为空"); + start(split[0], split[1]); + } + } else if (requestJson != null && ProfilesActiveConstant.TYPE_VBILLCODE.equals(requestJson.get("type"))) { + //按单号 + if (param != null && !"".equals(param)) { + start(param); + } + } else if (ProfilesActiveConstant.TYPE_DETAIL_ERROR.equals(requestJson.get("type"))) { + String integrationTaskLivingDetails = (String) requestJson.get("integration_task_living_details_id"); + IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = saveOrUpdateBusinessLogUtil.queryIntegrationTaskLivingDetailsEntity(integrationTaskLivingDetails); + start(integrationTaskLivingDetailsEntity.getRootAppPk()); + } else if (ProfilesActiveConstant.LETS_PROFILES_ACTIVE.equals(prod)) { + //默认 + start(); + } + } catch (Exception e) { + e.printStackTrace(); + logger.error("executeBusiness方法抛出异常", e); + } + return BaseResult.getSuccessMessageEntity("插件执行成功"); + } + + + /** + * 默认推送 + */ + public void start() { + try { + //获取当前时间 + Date currentDate = new Date(); + Date startTime = DateUtil.offset(currentDate, DateField.MINUTE, -10); + Date endTime = DateUtil.offset(currentDate, DateField.MINUTE, -2); + String startTimeStr = DateUtil.format(startTime, "yyyy-MM-dd HH:mm:ss"); + String endTimeStr = DateUtil.format(endTime, "yyyy-MM-dd HH:mm:ss"); + + QueryOfsStockinOrderRequestVO queryOfsStockinOrderRequestVO = new QueryOfsStockinOrderRequestVO(); + queryOfsStockinOrderRequestVO.setClosedAt_start(startTimeStr); + queryOfsStockinOrderRequestVO.setClosedAt_end(endTimeStr); + List stockinOrders = queryOfsStockinOrder(queryOfsStockinOrderRequestVO); + + if (stockinOrders == null || stockinOrders.size() == 0) { + return; + } + //过滤类型，tmdofs调整单类型在调整单藏着，不在调整入库单直接展示 + List filterTypeOrders = filterTypeAndReturn(stockinOrders); + if (filterTypeOrders == null || filterTypeOrders.size() == 0) { + return; + } + //过滤日志 + List filterStockinOrders = filterData(filterTypeOrders); + if (filterStockinOrders.size() == 0) { + return; + } + + //推送 + implement(filterStockinOrders); + + + } catch (Exception e) { + logger.error("丽知：OFS调整入库(无源件入库)--->U8C红字其它出库,start()方法报错：", e); + } + } + + + /** + * 按单号 + */ + public void start(String stockinNo) { + try { + + QueryOfsStockinOrderRequestVO queryOfsStockinOrderRequestVO = new QueryOfsStockinOrderRequestVO(); + queryOfsStockinOrderRequestVO.setCode(stockinNo); + List stockinOrders = queryOfsStockinOrder(queryOfsStockinOrderRequestVO); + if (stockinOrders.size() == 0) { + Assert.state(false, "丽知：OFS调整入库(无源件入库)--->U8C红字其它出库：{}，未查询到调整出库单", stockinNo); + } + + //过滤类型，tmdofs调整单类型在调整单藏着，不在调整入库单直接展示 + List filterTypeOrders = filterTypeAndReturn(stockinOrders); + if (filterTypeOrders == null || filterTypeOrders.size() == 0) { + Assert.state(false, "丽知：OFS调整入库(无源件入库)--->U8C红字其它出库：{}，入库单类型不是[无源件入库]或存在售后单号被过滤", stockinNo); + } + + + //过滤日志 + List filterStockinOrders = filterData(filterTypeOrders); + if (filterStockinOrders.size() == 0) { + Assert.state(false, "丽知：OFS调整入库(无源件入库)--->U8C红字其它出库：{}，该调整出库单已被推送成功，请勿重新推送", stockinNo); + } + + //推送 + implement(filterStockinOrders); + + } catch (Exception e) { + logger.error("丽知：OFS调整入库(无源件入库)--->U8C红字其它出库,start(String goodsName)方法报错：", e); + } + + } + + /** + * 按时间区间 + */ + public void start(String startTime, String endTime) { + try { + Date business_start = DateUtil.parse(startTime); + Date business_end = DateUtil.parse(endTime); + String start = DateUtil.format(business_start, "yyyy-MM-dd") + " 00:00:00"; + String end = DateUtil.format(business_end, "yyyy-MM-dd") + " 23:59:59"; + + QueryOfsStockinOrderRequestVO queryOfsStockinOrderRequestVO = new QueryOfsStockinOrderRequestVO(); + queryOfsStockinOrderRequestVO.setClosedAt_start(start); + queryOfsStockinOrderRequestVO.setClosedAt_end(end); + List stockinOrders = queryOfsStockinOrder(queryOfsStockinOrderRequestVO); + + if (stockinOrders.size() == 0) { + Assert.state(false, "丽知：OFS调整入库(无源件入库)--->U8C红字其它出库根据日期期间[开始时间]-[结束时间]：{}-{}，未查询到调整入库单[入库完成]", startTime, endTime); + } + + //过滤类型，tmdofs调整单类型在调整单藏着，不在调整入库单直接展示 + List filterTypeOrders = filterTypeAndReturn(stockinOrders); + if (filterTypeOrders == null || filterTypeOrders.size() == 0) { + Assert.state(false, "丽知：OFS调整入库(无源件入库)--->U8C红字其它出库根据日期期间[开始时间]-[结束时间]：{}-{}，该调期间整入库单[入库完成]，未查询到无源件入库类型", startTime, endTime); + } + + //过滤日志 + List filterStockinOrders = filterData(filterTypeOrders); + if (filterStockinOrders.size() == 0) { + Assert.state(false, "丽知：OFS调整入库(无源件入库)--->U8C红字其它出库根据日期期间[开始时间]-[结束时间]：{}-{}，该调期间整入库单[入库完成]已被推送成功，请勿重新推送", startTime, endTime); + } + + //推送 + implement(filterStockinOrders); + + + } catch (Exception e) { + logger.error("丽知：OFS调整入库(无源件入库)--->U8C红字其它出库,start(String startTime, String endTime)方法报错：", e); + } + } + + + /** + * 查询调整单单据类型只接收无源 0107 无源件入库 + */ + private List filterTypeAndReturn(List stockinOrders) throws Exception { + List filterTypes = new ArrayList<>(); + for (StockinOrderSearchResponse.StockinOrder stockinOrder : stockinOrders) { + StockinOrderSearchResponse.StockinOrder.StockinH ofsHeader = stockinOrder.getHeader(); + try { + List ofsAdjustOrders = queryOfsAdjustOrders(ofsHeader.getRefOrderCode()); + if (ofsAdjustOrders.size() != 1) { + Assert.state(false, "根据调整入库单号：{}，查询调整单：{}，失败。不存在或不唯一。", ofsHeader.getCode(), ofsHeader.getRefOrderCode()); + } + String u8ReceiptType = ofsAdjustOrders.get(0).getHeader().getU8ReceiptType();//调整单类型 + String remark = ofsAdjustOrders.get(0).getHeader().getRemark(); + System.out.println(remark); + List datas = queryOfsNoSourceStockinOrder(remark); + //没查到无源入库单存到错误中 + if (datas == null) { + Assert.state(false, "根据调整单备注：{}，未查询到无源入库单。", remark); + } + if (datas.size() != 1) { + Assert.state(false, "根据调整单备注：{}，查询到无源入库单不唯一。", remark); + + } + if (datas.get(0).getHeader().getReturnOrderCode() != null) { + continue; + } + + if ("0107".equals(u8ReceiptType)) { + filterTypes.add(stockinOrder); + } + } catch (Exception e) { + e.printStackTrace(); + String ErrMessage = e.getMessage(); + //失败 + IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); + integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_N); + integrationTaskLivingDetailsEntity.setRootAppNewData("调整单：" + ofsHeader.getCode()); + integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage); + integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); + integrationTaskLivingDetailsEntity.setBusinessDate(ofsHeader.getClosedAt()); + integrationTaskLivingDetailsEntity.setRootAppPk(ofsHeader.getCode()); + integrationTaskLivingDetailsEntity.setRootAppBill(ofsHeader.getId()); + integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); + saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); + } + } + return filterTypes; + } + + /** + * 过滤成功日志 + * 过滤"NMNS"\"YNS"\"HJ" + */ + public List filterData(List stockinOrders) { + List filterStockinOrders = new ArrayList<>(); + for (StockinOrderSearchResponse.StockinOrder stockinOrder : stockinOrders) { + StockinOrderSearchResponse.StockinOrder.StockinH header = stockinOrder.getHeader(); + String filterCompanyStr = queryU8CEntityUtil.queryBdDefDocByListPk(); + if (filterCompanyStr.contains(header.getCompanyCode().trim())) { + continue; + } + String rootAppPk = header.getCode(); + boolean isExis = true; + IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); + integrationTaskLivingDetailsEntity.setRootAppPk(rootAppPk); + integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y); + integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); + List integrationTaskLivingDetailsEntities = iIntegrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity); + if (integrationTaskLivingDetailsEntities == null || integrationTaskLivingDetailsEntities.size() == 0) { + isExis = false; + } + if (!isExis) { + filterStockinOrders.add(stockinOrder); + } + } + return filterStockinOrders; + } + + + /** + * 推送u8c红丝其他出库单 固收发类别固定0107 + */ + public void implement(List filterStockinOrders) { + for (StockinOrderSearchResponse.StockinOrder StockinOrder : filterStockinOrders) { + String mapStr = ""; + String create = ""; + String modify = ""; + String response = ""; + String ofsCode = ""; + String ofsId = ""; + try { + StockinOrderSearchResponse.StockinOrder.StockinH ofsHeader = StockinOrder.getHeader(); + //其他出库单 + GeneralBillVO_4IDto generalBillVO_4I = new GeneralBillVO_4IDto(); + //主表 + GeneralBillVO_4IDto.Parentvo parentvo = new GeneralBillVO_4IDto.Parentvo(); + //ofs订单号，自定义项19 + ofsId = ofsHeader.getId(); + ofsCode = ofsHeader.getCode(); + parentvo.setVuserdef19(ofsCode); + + //pk_corp--公司 + String corpCode = queryU8CEntityUtil.queryBdDefDocByPkDefDocList(ofsHeader.getCompanyCode()); + parentvo.setPk_corp(corpCode); + //pk_calbody--库存组织PK + parentvo.setPk_calbody(corpCode); + //cwarehouseid--仓库 + parentvo.setCwarehouseid(ofsHeader.getFacilityCode()); + //vnote--备注 + parentvo.setVnote(ofsHeader.getNote()); + //dbilldate--单据日期--oms入库时间 + create = ofsHeader.getCreated(); + modify = ofsHeader.getLastUpdated(); + parentvo.setDbilldate(StringUtils.substring(modify, 0, 10)); + //coperatorid--制单人 + parentvo.setCoperatorid("tbadmin"); + //审核时间dauditdate + parentvo.setDauditdate(StringUtils.substring(modify, 0, 10)); + //cdispatcherid--收发类别 + parentvo.setCdispatcherid("0107"); + + //子表 + List childrenvo = new ArrayList<>(); + for (StockinOrderSearchResponse.StockinOrder.StockinB ofsDetail : StockinOrder.getDetails()) { + GeneralBillVO_4IDto.Childrenvo children = new GeneralBillVO_4IDto.Childrenvo(); + //dbizdate业务日期 + children.setDbizdate(modify); + //存货档案id + children.setCinventoryid(ofsDetail.getSkuCode()); + //nshouldinnum--应出数量 + children.setNshouldoutnum(String.valueOf(ofsDetail.getRequestQty())); + //nintnum--实入数量,20241106妮妮姐私聊：可以改成实收是0你就不传这条明细 明细里就不传这个 + if (ofsDetail.getReceivedQty() == null || "0".equals(ofsDetail.getReceivedQty())) { + continue; + } + children.setNoutnum(String.valueOf(ofsDetail.getReceivedQty())); + childrenvo.add(children); + } + generalBillVO_4I.setParentvo(parentvo); + generalBillVO_4I.setChildrenvo(childrenvo); + String dataJson = JSONUtil.toJsonStr(generalBillVO_4I); + mapStr = "{\"GeneralBillVO_4I\":[" + dataJson + "]}"; + ZTResult ztResult = pushU8CByApiCode.pushByCode(OverallConstant.getOverAllValue("otheroutqzCode"), mapStr); + //两层判断,一层中台转发,一层u8c返回 + if ("false".equals(ztResult.getFlag())) { + //转发失败 + response = JSONUtil.toJsonStr(ztResult.getAttribute()); + Assert.state(false, "丽知：OFS调整入库(无源件入库)--->U8C红字其它出库.中台转发失败,失败原因:{}", ztResult.getAttribute()); + } + Attribute attribute = ztResult.getAttribute(); + + boolean isSuccess = false; + String vbillcode = ""; + String vbillId = ""; + if ("success".equals(attribute.getStatus())) { + isSuccess = true; + String data = attribute.getData(); + GeneralBillVO_4IDto resGeneralBillVO = resultDataHandle(data); + vbillcode = resGeneralBillVO.getParentvo().getVbillcode(); + vbillId = resGeneralBillVO.getParentvo().getCgeneralhid(); + } + if (!isSuccess) { + Assert.state(false, "丽知：OFS调整入库(无源件入库)--->U8C红字其它出库 失败 接口返回结果：{} 接口入参:{}", attribute.getErrormsg(), mapStr); + } + //成功 + IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); + integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y); + integrationTaskLivingDetailsEntity.setRootAppNewData(mapStr); + integrationTaskLivingDetailsEntity.setNewTransmitInfo(attribute.getData()); + integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); + integrationTaskLivingDetailsEntity.setBusinessDate(modify); + integrationTaskLivingDetailsEntity.setRootAppPk(ofsCode); + integrationTaskLivingDetailsEntity.setRootAppBill(ofsCode); + integrationTaskLivingDetailsEntity.setNewSystemNumber(corpCode + "_" + vbillcode);//u8c其他出库单号 + integrationTaskLivingDetailsEntity.setNewSystemPrimary(vbillId);//u8c其他出库单号 + integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); + saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); + + + } catch (Exception e) { + e.printStackTrace(); + logger.error("推送U8C，丽知：OFS调整入库(无源件入库)--->U8C红字其它出库失败，失败原因：" + e); + + ReusltStrDto reusltStrDto = JSON.parseObject(response, ReusltStrDto.class); + String ErrMessage = ""; + + if (reusltStrDto != null) { + ErrMessage = reusltStrDto.getErrormsg(); + } else { + ErrMessage = e.getMessage(); + } + + //失败 + IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); + integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_N); + integrationTaskLivingDetailsEntity.setRootAppNewData(mapStr); + integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage); + integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); + integrationTaskLivingDetailsEntity.setBusinessDate(modify); + integrationTaskLivingDetailsEntity.setRootAppPk(ofsCode); + integrationTaskLivingDetailsEntity.setRootAppBill(ofsCode); + integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); + saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); + } + } + } + + + public List queryOfsStockinOrder(QueryOfsStockinOrderRequestVO queryOfsStockinOrderRequestVO) throws Exception { + Long pageNo = 1L; + List all = new ArrayList<>(); + + + InterfaceParamDto interfaceParamDto = new InterfaceParamDto(); + interfaceParamDto.setApi("ofs.receipt.search"); + queryOfsStockinOrderRequestVO.setInternalInstructionType("ADJUST");//入库单类型 SALES销售 EXCHANGE换货 REISSUE补发RETURN销退 PURCHASE采购 PURCHASE_RETURN采退 TRANSFER调拨 WORK_ORDER加工 OTHER其他 ADJUST调整 EXCHANGE换货 + queryOfsStockinOrderRequestVO.setClientCode("LETS"); + queryOfsStockinOrderRequestVO.setStatus("900");//状态 500待同步 510已同步 700收货中 900入库完成 911作废 100订单池 200暂挂 400待合单 410待出库单出库 + queryOfsStockinOrderRequestVO.setPageNo(pageNo); + queryOfsStockinOrderRequestVO.setPageSize(500L); + interfaceParamDto.setData(JSON.toJSONString(queryOfsStockinOrderRequestVO)); + StockinOrderSearchResponse stockinOrderSearchResponse = (StockinOrderSearchResponse) ofsUnifiedService.unified(interfaceParamDto); + if (stockinOrderSearchResponse.getData() == null || stockinOrderSearchResponse.getData().size() == 0) { + return null; + } + + all.addAll(stockinOrderSearchResponse.getData()); + int count = stockinOrderSearchResponse.getData().size(); + while (count >= 500) {//>=500,可能还有下一页。 + //还有下一页 + pageNo++; + queryOfsStockinOrderRequestVO.setPageNo(pageNo); + interfaceParamDto.setData(JSON.toJSONString(queryOfsStockinOrderRequestVO)); + StockinOrderSearchResponse stockinOrderSearchResponse1 = (StockinOrderSearchResponse) ofsUnifiedService.unified(interfaceParamDto); + + all.addAll(stockinOrderSearchResponse1.getData()); + + count = stockinOrderSearchResponse1.getData().size(); + } + return all; + } + + + private GeneralBillVO_4IDto resultDataHandle(String resultData) { + try { + if (resultData != null && !"".equals(resultData)) { + if (resultData.contains("[")) { + resultData = resultData.substring(1, resultData.length() - 1); + } + return JSON.parseObject(resultData, GeneralBillVO_4IDto.class); + } + } catch (Exception e) { + e.printStackTrace(); + logger.error("解析返回参数失败的错误", e); + //如果解析失败，记录原因，但是不能影响结果的记录 + } + return null; + } + + /** + * ofs调整单查询 + * ofs.adjustOrder.search + */ + public List 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); + List data = ofsAdjustOrderSearchResponse.getData(); + return data; + } + + @Autowired + private OfsStandardUtil ofsStandardUtil; + + /** + * ofs无源入库单查询 + */ + public List queryOfsNoSourceStockinOrder(String remark) throws Exception { + QueryOfsSoSaleOutVo queryOfsSoSaleOutVo = new QueryOfsSoSaleOutVo(); + queryOfsSoSaleOutVo.setReceiptCode(remark); + queryOfsSoSaleOutVo.setClientCode("LETS"); + queryOfsSoSaleOutVo.setPageNo(1L); + queryOfsSoSaleOutVo.setPageSize(50L); + InterfaceParamDto interfaceParamDto = new InterfaceParamDto(); + interfaceParamDto.setApi("ofs.passive.order.search"); + interfaceParamDto.setData(JSON.toJSONString(queryOfsSoSaleOutVo)); + PassiveStorageResponse res = (PassiveStorageResponse) ofsUnifiedService.unified(interfaceParamDto); + if (res.getData() == null || res.getData().size() == 0) { + return null; + } + List data = res.getData(); + return data; + } +} diff --git a/buildpackage/src/main/resources/cfgHome/plugin/lets/spring/spring-lets-plugin.xml b/buildpackage/src/main/resources/cfgHome/plugin/lets/spring/spring-lets-plugin.xml index a556a057..72e20a5b 100644 --- a/buildpackage/src/main/resources/cfgHome/plugin/lets/spring/spring-lets-plugin.xml +++ b/buildpackage/src/main/resources/cfgHome/plugin/lets/spring/spring-lets-plugin.xml @@ -54,4 +54,7 @@ + + + diff --git a/buildpackage/src/test/java/com/hzya/frame/plugin/lets/plugin/transfer/TransferTest.java b/buildpackage/src/test/java/com/hzya/frame/plugin/lets/plugin/transfer/TransferTest.java index a2d7987e..bcb2db39 100644 --- a/buildpackage/src/test/java/com/hzya/frame/plugin/lets/plugin/transfer/TransferTest.java +++ b/buildpackage/src/test/java/com/hzya/frame/plugin/lets/plugin/transfer/TransferTest.java @@ -171,7 +171,7 @@ public class TransferTest { @Test public void t90(){ - refundOnlyPluginInitializerToC.start("LETS-RO2025011100008183"); + refundOnlyPluginInitializerToC.start("LETS-RO2025042100005959"); } @Test public void t91(){ @@ -189,4 +189,19 @@ public class TransferTest { } ////////////////////////////////////////////////////////////////////////////////////dingtalk + + + + ////////////////////////////////////////////////////////////////////////////////////调整入库单（无源件） + @Autowired + private AdjustInWYJPluginInitializer adjustInWYJPluginInitializer; + @Test + public void t1200(){ + adjustInWYJPluginInitializer.start("LETS-RE2025040200003009");//无售后 +// adjustInWYJPluginInitializer.start("LETS-RE2025042100001235");//有售后 + } + + ////////////////////////////////////////////////////////////////////////////////////调整入库单（无源件） + + }