2

Pilot_KD_Parino/Pilot_KD_Parino.csproj

@@ -333,6 +333,7 @@
     <Compile Include="QPHY_AutoWrire\SearchWriteRecord.cs" />
     <Compile Include="ReceivablesDetails\ReceivablesPlugIn.cs" />
     <Compile Include="Sal_Order\Bill.cs" />
+    <Compile Include="Sal_Order\PUR_ReceiveEntryStockId.cs" />
     <Compile Include="Sal_Order\PushSaleOutBillPlugIn.cs" />
     <Compile Include="Sal_Order\YJAuditPlugIn.cs" />
     <Compile Include="SQL\SqlManage_yuyubo.cs" />

Pilot_KD_Parino/Sal_Order/PUR_ReceiveEntryStockId.cs

@@ -0,0 +1,183 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Pilot_KD_Parino.Sal_Order
+{
+    //public class PUR_ReceiveEntryStockId
+    //{
+    //    /// <summary>
+    //    /// 
+    //    /// </summary>
+    //    public StockID StockID { get; set; }
+    //}
+
+    public class PUR_ReceiveEntryStockId
+    {
+        /// <summary>
+        /// 
+        /// </summary>
+        public string DirtyFlags { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public List<SnapshotsItem> Snapshots { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string FromDatabase { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int Id { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int msterID { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public List<MultiLanguageTextItem> MultiLanguageText { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public List<NameItem> Name { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string Number { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string IsOpenLocation { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string StockProperty { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string StockStatusType { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int DefStockStatusId_Id { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public DefStockStatusId DefStockStatusId { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string THIRDSTOCKNO { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string ThirdStockType { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string LocListFormatter { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public List<string> StockFlexItem { get; set; }
+    }
+
+
+    public class SnapshotsItem
+    {
+        /// <summary>
+        /// 
+        /// </summary>
+        public string TableName { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string Oids { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string OidType { get; set; }
+    }
+
+    public class MultiLanguageTextItem
+    {
+        /// <summary>
+        /// 
+        /// </summary>
+        public string DirtyFlags { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string FromDatabase { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int PkId { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int LocaleId { get; set; }
+        /// <summary>
+        /// 成品仓
+        /// </summary>
+        public string Name { get; set; }
+    }
+
+    public class NameItem
+    {
+        /// <summary>
+        /// 
+        /// </summary>
+        public int Key { get; set; }
+        /// <summary>
+        /// 成品仓
+        /// </summary>
+        public string Value { get; set; }
+    }
+
+  
+
+   
+    public class DefStockStatusId
+    {
+        /// <summary>
+        /// 
+        /// </summary>
+        public string DirtyFlags { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public List<SnapshotsItem> Snapshots { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string FromDatabase { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int Id { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int msterID { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string Number { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public List<MultiLanguageTextItem> MultiLanguageText { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public List<NameItem> Name { get; set; }
+    }
+
+ 
+
+}

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,11 +204,95 @@ 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<PUR_ReceiveEntryStockId> other3 = JsonHelper.ToObject<List<PUR_ReceiveEntryStockId>>(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;
@@ -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;
             }