From 91c2b2c831f7ab60957161314010330f61e65d6f Mon Sep 17 00:00:00 2001
From: yuyubo <1870149533@qq.com>
Date: Wed, 23 Apr 2025 19:57:13 +0800
Subject: [PATCH] 22
---
Pilot_KD_Parino/Pilot_KD_Parino.csproj | 1 +
.../Sal_Order/PushSaleOutBillPlugIn.cs | 157 ++++++++++++++++--
2 files changed, 147 insertions(+), 11 deletions(-)
diff --git a/Pilot_KD_Parino/Pilot_KD_Parino.csproj b/Pilot_KD_Parino/Pilot_KD_Parino.csproj
index 722ccf9..5c71130 100644
--- a/Pilot_KD_Parino/Pilot_KD_Parino.csproj
+++ b/Pilot_KD_Parino/Pilot_KD_Parino.csproj
@@ -333,6 +333,7 @@
+
diff --git a/Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs b/Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs
index 1fb67a4..f88c278 100644
--- a/Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs
+++ b/Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs
@@ -1,4 +1,6 @@
-using Kingdee.BOS;
+using DevExpress.Xpo.DB.Helpers;
+using FarPoint.Excel;
+using Kingdee.BOS;
using Kingdee.BOS.App;
using Kingdee.BOS.App.Data;
using Kingdee.BOS.Contracts;
@@ -54,6 +56,7 @@ namespace Pilot_KD_Parino.Sal_Order
}
int tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
string tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
+ //找到采购订单
for (int kk = 0; kk < 6 && tablename.ToUpper() != "T_PUR_POORDERENTRY"; kk++)
{
////发货通知单
@@ -89,13 +92,61 @@ namespace Pilot_KD_Parino.Sal_Order
}
if (tablename.ToUpper() != "T_PUR_POORDERENTRY")
{
- this.View.ShowMessage("没有上查关联的跨组织的采购订单 " + tablename);
- return;
+
+ throw new KDBusinessException("", "没有上查关联的跨组织的采购订单：" + tablename);
+
}
- IOperationResult result = Invoke("PUR_PurchaseOrder", "PUR_ReceiveBill", tempFid.ToString(), "7cd93c259999489c97798063f2f7bd70");
+
+ int stockId = 0;
+ IOperationResult result = Invoke("PUR_PurchaseOrder", "PUR_ReceiveBill", tempFid.ToString(), "7cd93c259999489c97798063f2f7bd70", ref stockId);
+
+ var sheet = result.SuccessDataEnity.FirstOrDefault();
+ string jsonsheet = JsonHelper.ToJson(sheet);
+ //Logger.Error("推送采购入库单",jsonsheet,null);
+ if (sheet != null)
+ {
+
+ result = Invoke("PUR_ReceiveBill", "STK_InStock", sheet["id"].ToString(), "a1ff32276cd9469dad3bf2494366fa4f", ref stockId);
+ //sheet = result.SuccessDataEnity.FirstOrDefault();
+ //result = Invoke("PUR_ReceiveBill", "STK_InStock", sheet["id"].ToString(), "a1ff32276cd9469dad3bf2494366fa4f");
+ }
+ //找到最开始的销售订单
+ for (int kk = 0; kk < 6 && tablename.ToUpper() != "T_SAL_ORDERENTRY"; kk++)
+ {
+ ////发货通知单
+ tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
+ string tempTable = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
+ getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID FROM dbo.{tempTable}_lk
+ WHERE FENTRYID IN ( SELECT FENTRYID FROM {tempTable} WHERE FID = {tempFid})";
+ dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
+ if (dt == null || dt.Count == 0)
+ {
+
+ this.View.ShowMessage("没有上查关联的跨组织的采购订单");
+ return;
+ }
+ else
+ {
+ tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
+
+ }
+ tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
+ }
+ if (tablename.ToUpper() != "T_SAL_ORDERENTRY")
+ {
+
+ throw new KDBusinessException("", "推送销售发货通知单失败,没有上查关联的跨组织的销售订单：" + tablename);
+
+ }
+
+ result = Invoke("SAL_SaleOrder", "SAL_DELIVERYNOTICE", tempFid.ToString(), "193822715afc48aa9fa6d6beca7700ab", ref stockId);
+ sheet = result.SuccessDataEnity.FirstOrDefault();
+ result = Invoke("SAL_DELIVERYNOTICE", "SAL_OUTSTOCK", sheet["id"].ToString(), "ad0779a4685a43a08f08d2e42d7bf3e9", ref stockId);
+
+ this.View.ShowMessage("跨组织下推订单完成");
//this.View.ShowMessage("就是这个按钮"+ id);
@@ -129,7 +180,7 @@ namespace Pilot_KD_Parino.Sal_Order
}
- private IOperationResult Invoke(string source, string target, string tempFid, string sargetBillTypeId)
+ private IOperationResult Invoke(string source, string target, string tempFid, string sargetBillTypeId, ref int stockId)
{
try
{
@@ -153,13 +204,97 @@ namespace Pilot_KD_Parino.Sal_Order
////目标单据数据集合
DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray();
- //根据实际情况，处理目标单据数据
- //destObjs[0]["Date"] = Convert.ToDateTime(sDate);
- DynamicObjectCollection col_FEntityDetail;
+
var sdsas = JsonHelper.ToJson(destObjs);
Logger.Error("目标单据数据集合", sdsas, new Exception());
+ int temStockId = stockId;
+ if (target == "PUR_ReceiveBill")//收料通知单,强制没有配置仓库的物料进成品仓库
+ {
+ //var sheet = destObjs.FirstOrDefault(); PUR_ReceiveEntry
+ string pur = ("PUR_ReceiveEntry");
+ var stocks3 = destObjs[0];
+
+ if (temStockId == 0)
+ {
+ string sql2 = $@"/*dialect*/ SELECT FUseOrgId,fname, a.FSTOCKID,FForbidStatus,FDocumentStatus FROM T_BD_STOCK a
+ LEFT JOIN T_BD_STOCK_L b ON a.FSTOCKID=b.FSTOCKID
+ WHERE fname like '%成品仓%' AND FForbidStatus='A' AND FDocumentStatus='C' AND FUseOrgId={stocks3["StockOrgId_Id"]}";
+ var stockList = DBServiceHelper.ExecuteDynamicObject(this.Context, sql2, null, null, CommandType.Text, null);
+ if (stockList == null || stockList.Count == 0)
+ {
+ throw new KDBusinessException("", "所涉及的跨组织单位没有配置成品仓");
+ }
+
+
+ temStockId = stockList.Select(t => int.Parse(t["FSTOCKID"].ToString())).FirstOrDefault();
+ stockId = temStockId;
+ }
+ var stocks333 = stocks3[pur];
+ var stocks = stocks333 as DynamicObjectCollection;
+ var stock0 = stocks.ToList();
+
+ stock0.ForEach(t =>
+ {
+ t["StockID_Id"] = temStockId;
+ });
+
+
+
+ //if (stock0.Count > 0)
+ //{
+ // var others= stocks.Where(t => int.Parse(t["StockID_Id"].ToString()) != 0).ToList();
+ // if (others.Count == 0)
+ // {
+ // throw new KDBusinessException("", "上查关联的跨组织的采购订单明细全部没有配置仓库" );
+ // }
+ // var other2 = others.Select(t => t["StockId"]).ToList();
+ // var json1 = JsonHelper.ToJson(other2);
+ // List other3 = JsonHelper.ToObject>(json1);
+ // var other4 = other3.Where(t => t.Name.FirstOrDefault().Value.Contains("成品仓")).ToList();
+
+ // if (other4.Count > 0)
+ // {
+ // stockId = other4.Select(t => t.Id).FirstOrDefault();
+ // }
+ // else
+ // {
+ // stockId = other3.Select(t => t.Id).FirstOrDefault();
+ // }
+
+
+ // stock0.ForEach(t =>
+ // {
+ // t["StockID_Id"] = stockId;
+ // });
+ //}
+ }
+
+
+ if (target == "SAL_DELIVERYNOTICE")//采购入库单,强制没有配置仓库的物料进成品仓库
+ {
+ //throw new KDBusinessException("","还没开发好");
+ //var sheet = destObjs.FirstOrDefault(); PUR_ReceiveEntry
+ string pur = ("SAL_DELIVERYNOTICEENTRY");
+ var stocks3 = destObjs[0];
+ var stocks333 = stocks3[pur];
+ var stocks = stocks333 as DynamicObjectCollection;
+ var stock0 = stocks.ToList();
+ stock0.ForEach(t =>
+ {
+ t["StockID_Id"] = temStockId;
+ });
+
+
+
+ }
+
+ //根据实际情况，处理目标单据数据
+ //destObjs[0]["Date"] = Convert.ToDateTime(sDate);
+ //DynamicObjectCollection col_FEntityDetail;
+ //var sdsas = JsonHelper.ToJson(destObjs);
+ //Logger.Error("目标单据数据集合", sdsas, new Exception());
//this.View.ShowMessage("好了好了，就是这个按钮");
-
+
//return result;
////if (target == "SAL_OUTSTOCK")//销售出库
////{
@@ -217,7 +352,7 @@ namespace Pilot_KD_Parino.Sal_Order
//this.View.ShowErrMessage("调用下推, 导致自动保存失败 原因：" + saveResult.ValidationErrors[0].Message.ToString());
throw new KDBusinessException("", "未知原因导致自动保存失败原因：" + errorInfo);
}
-
+ result = saveResult;
//this.View.ShowMessage("1");
// 取到需要自动提交、审核的单据内码
object[] pkArray = (from p in destObjs select p[0]).ToArray();
@@ -242,7 +377,7 @@ namespace Pilot_KD_Parino.Sal_Order
}
catch (Exception ex)
{
- Logger.Error("同步报关信息时", "同步报关信息时 error:" + ex.Message + ex.StackTrace, ex);
+ Logger.Error("跨组织下推订单报错", "跨组织下推订单报错 error:" + ex.Message + ex.StackTrace, ex);
throw ex;
}