diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/transfer/TransferInPluginInitializer_bak20250303.java b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/transfer/TransferInPluginInitializer_bak20250303.java new file mode 100644 index 00000000..71bad2c4 --- /dev/null +++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/transfer/TransferInPluginInitializer_bak20250303.java @@ -0,0 +1,545 @@ +//package com.hzya.frame.plugin.lets.plugin.transfer; +// +//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.IIcGeneralBDao; +//import com.hzya.frame.plugin.lets.dao.IIcGeneralHDao; +//import com.hzya.frame.plugin.lets.dao.IToBillDao; +//import com.hzya.frame.plugin.lets.entity.IcGeneralBEntity; +//import com.hzya.frame.plugin.lets.entity.IcGeneralHEntity; +//import com.hzya.frame.plugin.lets.entity.ToBillEntity; +//import com.hzya.frame.plugin.lets.ofsvo.QueryOfsStockinOrderRequestVO; +//import com.hzya.frame.plugin.lets.u8cdto.GeneralBillVO; +//import com.hzya.frame.plugin.lets.u8cdto.ReusltStrDto; +//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.stock.StockinOrderSearchResponse; +//import com.hzya.frame.ttxofs.service.OfsUnifiedService; +//import com.hzya.frame.web.entity.BaseResult; +//import com.hzya.frame.web.entity.JsonResultEntity; +//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; +// +///** +// * 丽知:OFS调拨入库订单--->U8C调拨入库订单 +// */ +//public class TransferInPluginInitializer_bak20250303 extends PluginBaseEntity { +// Logger logger = LoggerFactory.getLogger(TransferInPluginInitializer_bak20250303.class); +// +// private static final Object OBJECT_LOCK = new Object(); +// +// @Override +// public void initialize() { +// logger.info(getPluginLabel() + "執行初始化方法initialize()"); +// } +// +// @Override +// public void destroy() { +// logger.info(getPluginLabel() + "執行銷毀方法destroy()"); +// } +// +// @Override +// public String getPluginId() { +// return "transfer.TransferInPluginInitializer"; +// } +// +// @Override +// public String getPluginName() { +// return "丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联U8C调拨出库单)"; +// } +// +// @Override +// public String getPluginLabel() { +// return "丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联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 IToBillDao toBillDao; +// +// @Autowired +// private IIcGeneralHDao icGeneralHDao; +// @Autowired +// private IIcGeneralBDao icGeneralBDao; +// +// @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 { +// synchronized (OBJECT_LOCK) { +// +// //获取当前时间 +// 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); +// //状态 500待同步 510已同步 700收货中 900入库完成 911作废 100订单池 200暂挂 400待合单 410待出库单出库 +// queryOfsStockinOrderRequestVO.setStatus("900"); +// List transferInOrder = queryOfsStockinOrder(queryOfsStockinOrderRequestVO); +// +// if (transferInOrder == null || transferInOrder.size() == 0) { +// return; +// } +// //过滤日志 +// List filterTransferInOrders = filterData(transferInOrder); +// if (filterTransferInOrders.size() == 0) { +// return; +// } +// implement(filterTransferInOrders); +// } +// +// +// } catch (Exception e) { +// logger.error("丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联U8C调拨出库单),start()方法报错:", e); +// } +// } +// +// /** +// * 按单号 +// */ +// public void start(String stockinNo) { +// try { +// synchronized (OBJECT_LOCK) { +// +// QueryOfsStockinOrderRequestVO queryOfsStockinOrderRequestVO = new QueryOfsStockinOrderRequestVO(); +// queryOfsStockinOrderRequestVO.setCode(stockinNo); +// //状态 500待同步 510已同步 700收货中 900入库完成 911作废 100订单池 200暂挂 400待合单 410待出库单出库 +// queryOfsStockinOrderRequestVO.setStatus("900"); +// List transferInOrder = queryOfsStockinOrder(queryOfsStockinOrderRequestVO); +// +// if (transferInOrder == null || transferInOrder.size() == 0) { +// Assert.state(false, "丽知:OFS调拨入库--->U8C调拨入库根据单据号[入库完成]:{},未查询到调拨入库单", stockinNo); +// } +// //过滤日志 +// List filterTransferInOrders = filterData(transferInOrder); +// if (filterTransferInOrders.size() == 0) { +// Assert.state(false, "丽知:OFS调拨入库--->U8C调拨入库根据单据号[入库完成]:{},该调拨入库单已被推送成功,请勿重新推送", stockinNo); +// } +// implement(filterTransferInOrders); +// } +// +// } catch (Exception e) { +// logger.error("丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联U8C调拨出库单),start(String goodsName)方法报错:", e); +// } +// +// } +// +// /** +// * 按时间区间 +// */ +// public void start(String startTime, String endTime) { +// try { +// synchronized (OBJECT_LOCK) { +// +// 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); +// //状态 500待同步 510已同步 700收货中 900入库完成 911作废 100订单池 200暂挂 400待合单 410待出库单出库 +// queryOfsStockinOrderRequestVO.setStatus("900"); +// List transferInOrder = queryOfsStockinOrder(queryOfsStockinOrderRequestVO); +// +// if (transferInOrder == null || transferInOrder.size() == 0) { +// Assert.state(false, "丽知:OFS调拨入库订单--->U8C调拨入库订单根据日期期间[开始时间]-[结束时间]:{}-{},未查询到调拨入库单[入库完成]", startTime, endTime); +// } +// //过滤日志 +// List filterTransferInOrders = filterData(transferInOrder); +// if (filterTransferInOrders.size() == 0) { +// Assert.state(false, "丽知:OFS调拨入库订单--->U8C调拨入库订单根据日期期间[开始时间]-[结束时间]:{}-{},该调期调拨入库单[入库完成]已被推送成功,请勿重新推送", startTime, endTime); +// } +// implement(filterTransferInOrders); +// } +// +// +// } catch (Exception e) { +// logger.error("丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联U8C调拨出库单),start(String startTime, String endTime)方法报错:", e); +// } +// } +// +// /** +// * 过滤成功日志 +// * +// * @return +// */ +// public List filterData(List stockinOrders) { +// List filterStockinOrders = new ArrayList<>(); +// for (StockinOrderSearchResponse.StockinOrder stockinOrder : stockinOrders) { +// StockinOrderSearchResponse.StockinOrder.StockinH header = stockinOrder.getHeader(); +// //过滤"NMNS"\"YNS"\"HJ" +// if("NMNS".equals(header.getCompanyCode())||"YNS".equals(header.getCompanyCode())||"HJ".equals(header.getCompanyCode())){ +// 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; +// } +// +// /** +// * ofs调拨入库推送u8c调拨入库,关联调拨订单。 +// *

+// * 根据ofs调拨订单,可以查询到u8c调拨订单 +// * u8c调拨出库单子表的来源单据号vsourcebillcode(调拨订单号) +// * +// * @param filterTransferInOrders +// */ +// public void implement(List filterTransferInOrders) { +// for (StockinOrderSearchResponse.StockinOrder transferInOrders : filterTransferInOrders) { +// String mapStr = ""; +// String format = ""; +// String response = ""; +// String ofsCode = ""; +// try { +// StockinOrderSearchResponse.StockinOrder.StockinH ofsTransferHeader = transferInOrders.getHeader(); +// +// //ofs调拨订单号 +// String ofsSourceOrderCode = ofsTransferHeader.getSourceOrderCode(); +// //ofs调拨入库单单号 +// ofsCode = ofsTransferHeader.getCode(); +// //ofs最后修改时间,调入时间 +// format = ofsTransferHeader.getLastUpdated(); +// +// GeneralBillVO generalBillVO = new GeneralBillVO(); +// //主表 +// GeneralBillVO.Parentvo parentvo = new GeneralBillVO.Parentvo(); +// //coperatorid 制单人 +// parentvo.setCoperatorid("tbadmin"); +// //cwarehouseid 仓库 +// parentvo.setCwarehouseid(ofsTransferHeader.getFacilityCode()); +// //pk_calbody 库存组织 +// String corpCode = queryU8CEntityUtil.queryBdDefDocByPkDefDocList(ofsTransferHeader.getCompanyCode()); +// parentvo.setPk_calbody(corpCode); +// //pk_corp 公司 +// parentvo.setPk_corp(corpCode); +// //pk_defdoc19 自定义项19(ofs调拨订单号) +// parentvo.setVuserdef19(ofsSourceOrderCode); +// //dbilldate 单据日期 +// parentvo.setDbilldate(format.substring(0, 10)); +// +// //U8C调拨订单信息 +//// List toBillEntityList = queryToBillByPkVdefdoc19(ofsSourceOrderCode); +// //U8C调拨出库单主表信息 +// List icGeneralHEntityList = queryIcGeneralHByVdef19(ofsSourceOrderCode); +// if (icGeneralHEntityList == null) { +// Assert.state(false, "在U8C内根据OFS调拨订单号(vdefdoc19):{},没有查询到调拨出库单,请检查。", ofsSourceOrderCode); +// } +// if (icGeneralHEntityList.size() > 1) { +// Assert.state(false, "在U8C内根据OFS调拨订单号(vdefdoc19):{},查询到调拨出库单不唯一,请检查。", ofsSourceOrderCode); +// } +// IcGeneralHEntity icGeneralHEntity = icGeneralHEntityList.get(0); +// +// //U8C调拨出库单子表信息 +// List icGeneralBEntityList = queryIcGeneralBByCgeneralhid(icGeneralHEntity.getCgeneralhid()); +// if (icGeneralBEntityList == null) { +// Assert.state(false, "在U8C内根据U8C调拨出库单主表主键:{},调拨出库单单号:{},未查询到调拨出库单子表信息,请检查。", icGeneralHEntity.getCgeneralhid(), icGeneralHEntity.getVbillcode()); +// } +// +// List ChildrenList = new ArrayList<>(); +// int i = 1; +// for (StockinOrderSearchResponse.StockinOrder.StockinB ofsTransferDetail : transferInOrders.getDetails()) { +// GeneralBillVO.Childrenvo childrenvo = new GeneralBillVO.Childrenvo(); +// +// //cinventoryid 存货 +// childrenvo.setCinventoryid(ofsTransferDetail.getSkuCode()); +// //ninnum 实收数量 +// childrenvo.setNinnum(ofsTransferDetail.getReceivedQty()); +// //csourcetype 来源单据类型编码 +// childrenvo.setCsourcetype("4Y"); +// //vsourcebillcode 来源单据号 +// childrenvo.setVsourcebillcode(icGeneralHEntity.getVbillcode()); +// +// +// for (IcGeneralBEntity icGeneralBEntity : icGeneralBEntityList) { +// //根据存货+行号匹配 +// if (ofsTransferDetail.getRefOrderDetailId().equals(icGeneralBEntity.getVuserdef20().trim()) && ofsTransferDetail.getSkuCode().equals(icGeneralBEntity.getCinvbascode())) { +// //crowno 行号 +// childrenvo.setCrowno(i++ + "0"); +// //ofs来源单据行行号 +// childrenvo.setVuserdef20(ofsTransferDetail.getRefOrderDetailId()); +// //vsourcerowno 来源单据行号 +// childrenvo.setVsourcerowno(icGeneralBEntity.getCrowno()); +// break; +// } +// } +// ChildrenList.add(childrenvo); +// } +// generalBillVO.setParentvo(parentvo); +// generalBillVO.setChildrenvo(ChildrenList); +// +// mapStr = "{\"GeneralBillVO\":[" + JSONUtil.toJsonStr(generalBillVO) + "]}"; +// ZTResult ztResult = pushU8CByApiCode.pushByCode(OverallConstant.getOverAllValue("approveInqzCode"), mapStr); +// //两层判断,一层中台转发,一层u8c返回 +// if ("false".equals(ztResult.getFlag())) { +// //转发失败 +// response = JSONUtil.toJsonStr(ztResult.getAttribute()); +// Assert.state(false, "丽知:OFS调拨入库订单--->U8C调拨入库订单.中台转发失败,失败原因:{}", response); +// } +// Attribute attribute = ztResult.getAttribute(); +// boolean isSuccess = false; +// String vbillcode = ""; +// if ("success".equals(attribute.getStatus())) { +// isSuccess = true; +// String data = attribute.getData(); +// GeneralBillVO generalBill = resultDataHandle(data); +// vbillcode = generalBill.getParentvo().getVbillcode(); +// } +// if (!isSuccess) { +// Assert.state(false, "推送U8C--> 丽知:OFS调拨入库订单--->U8C调拨入库订单 失败 接口返回结果:{} 接口入参:{}", response, mapStr); +// } +// +// //成功 +// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); +// integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y); +// integrationTaskLivingDetailsEntity.setRootAppNewData(mapStr); +// integrationTaskLivingDetailsEntity.setNewTransmitInfo(response); +// integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); +// integrationTaskLivingDetailsEntity.setBusinessDate(format); +// integrationTaskLivingDetailsEntity.setRootAppPk(ofsCode); +// integrationTaskLivingDetailsEntity.setRootAppBill(ofsCode); +// integrationTaskLivingDetailsEntity.setNewSystemNumber(corpCode+"_"+vbillcode); +// integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); +// saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); +// +// } catch (Exception e) { +// e.printStackTrace(); +// logger.error("推送U8C,丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联U8C调拨出库单)失败,失败原因:" + e); +// ReusltStrDto reusltStrDto = JSON.parseObject(response, ReusltStrDto.class); +// String ErrMessage = null; +// if (reusltStrDto != null) { +// ErrMessage = "推送U8C,丽知:OFS调拨入库订单--->U8C调拨入库订单,失败原因:" + 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(format); +// integrationTaskLivingDetailsEntity.setRootAppPk(ofsCode); +// integrationTaskLivingDetailsEntity.setRootAppBill(ofsCode); +// integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); +// saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); +// } +// } +// +// } +// +// private GeneralBillVO resultDataHandle(String resultData) { +// try { +// if (resultData != null && !"".equals(resultData)) { +// if (resultData.contains("[")) { +// resultData = resultData.substring(1, resultData.length() - 1); +// } +// return JSON.parseObject(resultData, GeneralBillVO.class); +// } +// } catch (Exception e) { +// e.printStackTrace(); +// logger.error("解析返回参数失败的错误", e); +// //如果解析失败,记录原因,但是不能影响结果的记录 +// } +// return null; +// } +// +// +// /** +// * 查询ofs调拨入库单 +// * +// * @param queryOfsStockinOrderRequestVO +// * @return +// * @throws Exception +// */ +// 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("TRANSFER");//入库单类型 SALES销售 EXCHANGE换货 REISSUE补发RETURN销退 PURCHASE采购 PURCHASE_RETURN采退 TRANSFER调拨 WORK_ORDER加工 OTHER其他 ADJUST调整 EXCHANGE换货 +// queryOfsStockinOrderRequestVO.setClientCode("LETS"); +// 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; +// } +// +// /** +// * 根据单号查询调拨单 to_bill 单据主表 单据 +// * +// * @param vcode +// */ +// public List queryToBillByVCode(String vcode) { +// ToBillEntity toBillEntity = new ToBillEntity(); +// toBillEntity.setVcode(vcode); +// toBillEntity.setCbilltype("5X"); +// List toBillEntityList = toBillDao.queryToBillEntity(toBillEntity); +// return toBillEntityList; +// } +// +// /** +// * 根据自定义项19(ofs调拨订单单号),查询u8c调拨订单 +// * +// * @param pkDefdoc19 +// * @return +// */ +// public List queryToBillByPkVdefdoc19(String pkDefdoc19) { +// ToBillEntity toBillEntity = new ToBillEntity(); +// toBillEntity.setPkDefdoc19(pkDefdoc19); +// toBillEntity.setCbilltype("5X"); +// toBillEntity.setDataSourceCode(ProfilesActiveConstant.LETS_DATE_SOURCE); +// List toBillEntityList = toBillDao.query(toBillEntity); +// return toBillEntityList; +// } +// +// /** +// * 根据调拨出库单主表自定义项19(ofs调拨订单号)查询调拨出库单主表 +// */ +// public List queryIcGeneralHByVdef19(String pkDefdoc19) { +// IcGeneralHEntity icGeneralHEntity = new IcGeneralHEntity(); +// icGeneralHEntity.setDr(0); +// icGeneralHEntity.setCbilltypecode("4Y"); +// icGeneralHEntity.setVuserdef19(pkDefdoc19); +// icGeneralHEntity.setDataSourceCode(ProfilesActiveConstant.LETS_DATE_SOURCE); +// List icGeneralHEntityList = icGeneralHDao.query(icGeneralHEntity); +// if (icGeneralHEntityList == null || icGeneralHEntityList.size() == 0) { +// return null; +// } +// return icGeneralHEntityList; +// } +// +// /** +// * 根据调拨出库单主表主键,查询调拨出库单子表 +// */ +// public List queryIcGeneralBByCgeneralhid(String cgeneralhid) { +//// IcGeneralBEntity icGeneralBEntity = new IcGeneralBEntity(); +//// icGeneralBEntity.setDr(0); +//// icGeneralBEntity.setCgeneralhid(cgeneralhid); +//// icGeneralBEntity.setDataSourceCode(ProfilesActiveConstant.LETS_DATE_SOURCE); +// List icGeneralBEntityList = icGeneralBDao.queryAndCinvbasCode(cgeneralhid); +// if (icGeneralBEntityList == null || icGeneralBEntityList.size() == 0) { +// return null; +// } +// return icGeneralBEntityList; +// } +// +//} diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/transfer/TransferInPluginInitializer_pk.java b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/transfer/TransferInPluginInitializer_pk.java new file mode 100644 index 00000000..a6591420 --- /dev/null +++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/transfer/TransferInPluginInitializer_pk.java @@ -0,0 +1,557 @@ +//package com.hzya.frame.plugin.lets.plugin.transfer; +// +//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.IIcGeneralBDao; +//import com.hzya.frame.plugin.lets.dao.IIcGeneralHDao; +//import com.hzya.frame.plugin.lets.dao.IToBillDao; +//import com.hzya.frame.plugin.lets.entity.*; +//import com.hzya.frame.plugin.lets.ofsvo.QueryOfsStockinOrderRequestVO; +//import com.hzya.frame.plugin.lets.u8cdto.GeneralBillVO; +//import com.hzya.frame.plugin.lets.u8cdto.ReusltStrDto; +//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.stock.StockinOrderSearchResponse; +//import com.hzya.frame.ttxofs.service.OfsUnifiedService; +//import com.hzya.frame.web.entity.BaseResult; +//import com.hzya.frame.web.entity.JsonResultEntity; +//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; +// +///** +// * 丽知:OFS调拨入库订单--->U8C调拨入库订单 +// */ +//public class TransferInPluginInitializer_pk extends PluginBaseEntity { +// Logger logger = LoggerFactory.getLogger(TransferInPluginInitializer_pk.class); +// +// private static final Object OBJECT_LOCK = new Object(); +// +// @Override +// public void initialize() { +// logger.info(getPluginLabel() + "執行初始化方法initialize()"); +// } +// +// @Override +// public void destroy() { +// logger.info(getPluginLabel() + "執行銷毀方法destroy()"); +// } +// +// @Override +// public String getPluginId() { +// return "transfer.TransferInPluginInitializer"; +// } +// +// @Override +// public String getPluginName() { +// return "丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联U8C调拨出库单)"; +// } +// +// @Override +// public String getPluginLabel() { +// return "丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联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 IToBillDao toBillDao; +// +// @Autowired +// private IIcGeneralHDao icGeneralHDao; +// @Autowired +// private IIcGeneralBDao icGeneralBDao; +// +// @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 { +// synchronized (OBJECT_LOCK) { +// +// //获取当前时间 +// 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); +// //状态 500待同步 510已同步 700收货中 900入库完成 911作废 100订单池 200暂挂 400待合单 410待出库单出库 +// queryOfsStockinOrderRequestVO.setStatus("900"); +// List transferInOrder = queryOfsStockinOrder(queryOfsStockinOrderRequestVO); +// +// if (transferInOrder == null || transferInOrder.size() == 0) { +// return; +// } +// //过滤日志 +// List filterTransferInOrders = filterData(transferInOrder); +// if (filterTransferInOrders.size() == 0) { +// return; +// } +// implement(filterTransferInOrders); +// } +// +// +// } catch (Exception e) { +// logger.error("丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联U8C调拨出库单),start()方法报错:", e); +// } +// } +// +// /** +// * 按单号 +// */ +// public void start(String stockinNo) { +// try { +// synchronized (OBJECT_LOCK) { +// +// QueryOfsStockinOrderRequestVO queryOfsStockinOrderRequestVO = new QueryOfsStockinOrderRequestVO(); +// queryOfsStockinOrderRequestVO.setCode(stockinNo); +// //状态 500待同步 510已同步 700收货中 900入库完成 911作废 100订单池 200暂挂 400待合单 410待出库单出库 +// queryOfsStockinOrderRequestVO.setStatus("900"); +// List transferInOrder = queryOfsStockinOrder(queryOfsStockinOrderRequestVO); +// +// if (transferInOrder == null || transferInOrder.size() == 0) { +// Assert.state(false, "丽知:OFS调拨入库--->U8C调拨入库根据单据号[入库完成]:{},未查询到调拨入库单", stockinNo); +// } +// //过滤日志 +// List filterTransferInOrders = filterData(transferInOrder); +// if (filterTransferInOrders.size() == 0) { +// Assert.state(false, "丽知:OFS调拨入库--->U8C调拨入库根据单据号[入库完成]:{},该调拨入库单已被推送成功,请勿重新推送", stockinNo); +// } +// implement(filterTransferInOrders); +// } +// +// } catch (Exception e) { +// logger.error("丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联U8C调拨出库单),start(String goodsName)方法报错:", e); +// } +// +// } +// +// /** +// * 按时间区间 +// */ +// public void start(String startTime, String endTime) { +// try { +// synchronized (OBJECT_LOCK) { +// +// 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); +// //状态 500待同步 510已同步 700收货中 900入库完成 911作废 100订单池 200暂挂 400待合单 410待出库单出库 +// queryOfsStockinOrderRequestVO.setStatus("900"); +// List transferInOrder = queryOfsStockinOrder(queryOfsStockinOrderRequestVO); +// +// if (transferInOrder == null || transferInOrder.size() == 0) { +// Assert.state(false, "丽知:OFS调拨入库订单--->U8C调拨入库订单根据日期期间[开始时间]-[结束时间]:{}-{},未查询到调拨入库单[入库完成]", startTime, endTime); +// } +// //过滤日志 +// List filterTransferInOrders = filterData(transferInOrder); +// if (filterTransferInOrders.size() == 0) { +// Assert.state(false, "丽知:OFS调拨入库订单--->U8C调拨入库订单根据日期期间[开始时间]-[结束时间]:{}-{},该调期调拨入库单[入库完成]已被推送成功,请勿重新推送", startTime, endTime); +// } +// implement(filterTransferInOrders); +// } +// +// +// } catch (Exception e) { +// logger.error("丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联U8C调拨出库单),start(String startTime, String endTime)方法报错:", e); +// } +// } +// +// /** +// * 过滤成功日志 +// * +// * @return +// */ +// public List filterData(List stockinOrders) { +// List filterStockinOrders = new ArrayList<>(); +// for (StockinOrderSearchResponse.StockinOrder stockinOrder : stockinOrders) { +// StockinOrderSearchResponse.StockinOrder.StockinH header = stockinOrder.getHeader(); +// //过滤"NMNS"\"YNS"\"HJ" +// if ("NMNS".equals(header.getCompanyCode()) || "YNS".equals(header.getCompanyCode()) || "HJ".equals(header.getCompanyCode())) { +// 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; +// } +// +// /** +// * ofs调拨入库推送u8c调拨入库,关联调拨订单。 +// *

+// * 根据ofs调拨订单,可以查询到u8c调拨订单 +// * u8c调拨出库单子表的来源单据号vsourcebillcode(调拨订单号) +// * +// * @param filterTransferInOrders +// */ +// public void implement(List filterTransferInOrders) { +// for (StockinOrderSearchResponse.StockinOrder transferInOrders : filterTransferInOrders) { +// String mapStr = ""; +// String format = ""; +// String response = ""; +// String ofsCode = ""; +// try { +// StockinOrderSearchResponse.StockinOrder.StockinH ofsTransferHeader = transferInOrders.getHeader(); +// +// //ofs调拨订单号 +// String ofsSourceOrderCode = ofsTransferHeader.getSourceOrderCode(); +// //ofs调拨入库单单号 +// ofsCode = ofsTransferHeader.getCode(); +// //ofs最后修改时间,调入时间 +// format = ofsTransferHeader.getLastUpdated(); +// +// GeneralBillVO generalBillVO = new GeneralBillVO(); +// //主表 +// GeneralBillVO.Parentvo parentvo = new GeneralBillVO.Parentvo(); +// //coperatorid 制单人 +//// parentvo.setCoperatorid("tbadmin");//code +// parentvo.setCoperatorid(OverallConstant.getOverAllValue("u8cApiZdrPK"));//pk +// +// //pk_calbody 库存组织 +// String corpCode = queryU8CEntityUtil.queryBdDefDocByPkDefDocList(ofsTransferHeader.getCompanyCode()); +//// parentvo.setPk_calbody(corpCode);//code +// BdCorpEntity bdCorpEntity = queryU8CEntityUtil.queryBdCorpByUnitCode(corpCode); +// if (bdCorpEntity == null) { +// Assert.state(false, "根据公司编码:{},未查询到公司,请检查。", corpCode); +// } +// parentvo.setPk_calbody(bdCorpEntity.getPkCorp());//pk +// //pk_corp 公司 +//// parentvo.setPk_corp(corpCode);//code +// parentvo.setPk_corp(bdCorpEntity.getPkCorp());//pk +// +// //cwarehouseid 仓库 +//// parentvo.setCwarehouseid(ofsTransferHeader.getFacilityCode());//code +// BdStordocEntity bdStordocEntity = queryU8CEntityUtil.queryBdStordocByCodeAndPkCorp(ofsTransferHeader.getFacilityCode(), bdCorpEntity.getPkCorp()); +// if (bdStordocEntity == null) { +// Assert.state(false, "根据公司编码:{},公司主键:{},仓库编码:{},未查询到仓库,请检查。", corpCode, bdCorpEntity.getPkCorp(), ofsTransferHeader.getFacilityCode()); +// } +// parentvo.setCwarehouseid(bdStordocEntity.getPkStordoc());//pk +// +// //pk_defdoc19 自定义项19(ofs调拨订单号) +// parentvo.setVuserdef19(ofsSourceOrderCode); +// //dbilldate 单据日期 +// parentvo.setDbilldate(format); +// +// //U8C调拨订单信息 +//// List toBillEntityList = queryToBillByPkVdefdoc19(ofsSourceOrderCode); +// //U8C调拨出库单主表信息 +// List icGeneralHEntityList = queryIcGeneralHByVdef19(ofsSourceOrderCode); +// if (icGeneralHEntityList == null) { +// Assert.state(false, "在U8C内根据OFS调拨订单号(vdefdoc19):{},没有查询到调拨出库单,请检查。", ofsSourceOrderCode); +// } +// if (icGeneralHEntityList.size() > 1) { +// Assert.state(false, "在U8C内根据OFS调拨订单号(vdefdoc19):{},查询到调拨出库单不唯一,请检查。", ofsSourceOrderCode); +// } +// IcGeneralHEntity icGeneralHEntity = icGeneralHEntityList.get(0); +// +// //U8C调拨出库单子表信息 +// List icGeneralBEntityList = queryIcGeneralBByCgeneralhid(icGeneralHEntity.getCgeneralhid()); +// if (icGeneralBEntityList == null) { +// Assert.state(false, "在U8C内根据U8C调拨出库单主表主键:{},调拨出库单单号:{},未查询到调拨出库单子表信息,请检查。", icGeneralHEntity.getCgeneralhid(), icGeneralHEntity.getVbillcode()); +// } +// +// List ChildrenList = new ArrayList<>(); +// int i = 1; +// for (StockinOrderSearchResponse.StockinOrder.StockinB ofsTransferDetail : transferInOrders.getDetails()) { +// GeneralBillVO.Childrenvo childrenvo = new GeneralBillVO.Childrenvo(); +// +// //cinventoryid 存货 +// childrenvo.setCinventoryid(ofsTransferDetail.getSkuCode()); +// //ninnum 实收数量 +// childrenvo.setNinnum(ofsTransferDetail.getReceivedQty()); +// //csourcetype 来源单据类型编码 +// childrenvo.setCsourcetype("4Y"); +// //vsourcebillcode 来源单据号 +// childrenvo.setVsourcebillcode(icGeneralHEntity.getVbillcode()); +// +// +// for (IcGeneralBEntity icGeneralBEntity : icGeneralBEntityList) { +// //根据存货+行号匹配 +// if (ofsTransferDetail.getRefOrderDetailId().equals(icGeneralBEntity.getVuserdef20().trim()) && ofsTransferDetail.getSkuCode().equals(icGeneralBEntity.getCinvbascode())) { +// //crowno 行号 +// childrenvo.setCrowno(i++ + "0"); +// //ofs来源单据行行号 +// childrenvo.setVuserdef20(ofsTransferDetail.getRefOrderDetailId()); +// //vsourcerowno 来源单据行号 +// childrenvo.setVsourcerowno(icGeneralBEntity.getCrowno()); +// break; +// } +// } +// ChildrenList.add(childrenvo); +// } +// generalBillVO.setParentvo(parentvo); +// generalBillVO.setChildrenvo(ChildrenList); +// +// mapStr = "{\"GeneralBillVO\":[" + JSONUtil.toJsonStr(generalBillVO) + "]}"; +// ZTResult ztResult = pushU8CByApiCode.pushByCode(OverallConstant.getOverAllValue("approveInqzCode"), mapStr); +// //两层判断,一层中台转发,一层u8c返回 +// if ("false".equals(ztResult.getFlag())) { +// //转发失败 +// response = JSONUtil.toJsonStr(ztResult.getAttribute()); +// Assert.state(false, "丽知:OFS调拨入库订单--->U8C调拨入库订单.中台转发失败,失败原因:{}", response); +// } +// Attribute attribute = ztResult.getAttribute(); +// boolean isSuccess = false; +// String vbillcode = ""; +// if ("success".equals(attribute.getStatus())) { +// isSuccess = true; +// String data = attribute.getData(); +// GeneralBillVO generalBill = resultDataHandle(data); +// vbillcode = generalBill.getParentvo().getVbillcode(); +// } +// if (!isSuccess) { +// Assert.state(false, "推送U8C--> 丽知:OFS调拨入库订单--->U8C调拨入库订单 失败 接口返回结果:{} 接口入参:{}", response, mapStr); +// } +// +// //成功 +// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); +// integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y); +// integrationTaskLivingDetailsEntity.setRootAppNewData(mapStr); +// integrationTaskLivingDetailsEntity.setNewTransmitInfo(response); +// integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); +// integrationTaskLivingDetailsEntity.setBusinessDate(format); +// integrationTaskLivingDetailsEntity.setRootAppPk(ofsCode); +// integrationTaskLivingDetailsEntity.setRootAppBill(ofsCode); +// integrationTaskLivingDetailsEntity.setNewSystemNumber(corpCode + "_" + vbillcode); +// integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); +// saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); +// +// } catch (Exception e) { +// e.printStackTrace(); +// logger.error("推送U8C,丽知:OFS调拨入库订单--->U8C调拨入库订单(保存签字,关联U8C调拨出库单)失败,失败原因:" + e); +// ReusltStrDto reusltStrDto = JSON.parseObject(response, ReusltStrDto.class); +// String ErrMessage = null; +// if (reusltStrDto != null) { +// ErrMessage = "推送U8C,丽知:OFS调拨入库订单--->U8C调拨入库订单,失败原因:" + 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(format); +// integrationTaskLivingDetailsEntity.setRootAppPk(ofsCode); +// integrationTaskLivingDetailsEntity.setRootAppBill(ofsCode); +// integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); +// saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); +// } +// } +// +// } +// +// private GeneralBillVO resultDataHandle(String resultData) { +// try { +// if (resultData != null && !"".equals(resultData)) { +// if (resultData.contains("[")) { +// resultData = resultData.substring(1, resultData.length() - 1); +// } +// return JSON.parseObject(resultData, GeneralBillVO.class); +// } +// } catch (Exception e) { +// e.printStackTrace(); +// logger.error("解析返回参数失败的错误", e); +// //如果解析失败,记录原因,但是不能影响结果的记录 +// } +// return null; +// } +// +// +// /** +// * 查询ofs调拨入库单 +// * +// * @param queryOfsStockinOrderRequestVO +// * @return +// * @throws Exception +// */ +// 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("TRANSFER");//入库单类型 SALES销售 EXCHANGE换货 REISSUE补发RETURN销退 PURCHASE采购 PURCHASE_RETURN采退 TRANSFER调拨 WORK_ORDER加工 OTHER其他 ADJUST调整 EXCHANGE换货 +// queryOfsStockinOrderRequestVO.setClientCode("LETS"); +// 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; +// } +// +// /** +// * 根据单号查询调拨单 to_bill 单据主表 单据 +// * +// * @param vcode +// */ +// public List queryToBillByVCode(String vcode) { +// ToBillEntity toBillEntity = new ToBillEntity(); +// toBillEntity.setVcode(vcode); +// toBillEntity.setCbilltype("5X"); +// List toBillEntityList = toBillDao.queryToBillEntity(toBillEntity); +// return toBillEntityList; +// } +// +// /** +// * 根据自定义项19(ofs调拨订单单号),查询u8c调拨订单 +// * +// * @param pkDefdoc19 +// * @return +// */ +// public List queryToBillByPkVdefdoc19(String pkDefdoc19) { +// ToBillEntity toBillEntity = new ToBillEntity(); +// toBillEntity.setPkDefdoc19(pkDefdoc19); +// toBillEntity.setCbilltype("5X"); +// toBillEntity.setDataSourceCode(ProfilesActiveConstant.LETS_DATE_SOURCE); +// List toBillEntityList = toBillDao.query(toBillEntity); +// return toBillEntityList; +// } +// +// /** +// * 根据调拨出库单主表自定义项19(ofs调拨订单号)查询调拨出库单主表 +// */ +// public List queryIcGeneralHByVdef19(String pkDefdoc19) { +// IcGeneralHEntity icGeneralHEntity = new IcGeneralHEntity(); +// icGeneralHEntity.setDr(0); +// icGeneralHEntity.setCbilltypecode("4Y"); +// icGeneralHEntity.setVuserdef19(pkDefdoc19); +// icGeneralHEntity.setDataSourceCode(ProfilesActiveConstant.LETS_DATE_SOURCE); +// List icGeneralHEntityList = icGeneralHDao.query(icGeneralHEntity); +// if (icGeneralHEntityList == null || icGeneralHEntityList.size() == 0) { +// return null; +// } +// return icGeneralHEntityList; +// } +// +// /** +// * 根据调拨出库单主表主键,查询调拨出库单子表 +// */ +// public List queryIcGeneralBByCgeneralhid(String cgeneralhid) { +//// IcGeneralBEntity icGeneralBEntity = new IcGeneralBEntity(); +//// icGeneralBEntity.setDr(0); +//// icGeneralBEntity.setCgeneralhid(cgeneralhid); +//// icGeneralBEntity.setDataSourceCode(ProfilesActiveConstant.LETS_DATE_SOURCE); +// List icGeneralBEntityList = icGeneralBDao.queryAndCinvbasCode(cgeneralhid); +// if (icGeneralBEntityList == null || icGeneralBEntityList.size() == 0) { +// return null; +// } +// return icGeneralBEntityList; +// } +// +//}