nothing

王 垚

2021-07-28 50b5c72ca7fe4db72a4a10fe378ca95bffb1e736

 src/BLL/Demo.BillView/PRD/Pro_DayPlanPushZJDB.cs

@@ -16,13 +16,13 @@
namespace Demo.DynamicForm.PRD
{
    /// <summary>
    /// 插件示例：引入销售出库单，建立与销售订单的关联
    /// 日计划用料清单下推后，建立直接调拨单与日计划用料清单关联关系
    /// </summary>
    /// <remarks>
    /// 要求：
    /// 1. 需要引入单据体的源单类型、源单编号字段
    /// 2. 本插件挂在销售出库单的保存操作上
    /// 出库关联销售订单
    /// 2. 本插件挂在直接调拨单的保存操作上
    /// 直接调拨单关联日计划用料清单
    /// </remarks>
    [Description("日计划用料清单下推后，建立直接调拨单与生产用料清单关联关系")]
    [HotUpdate]
@@ -42,6 +42,7 @@
            e.FieldKeys.Add("FBaseJoinQty");
        }
        private const string POFormId = "PRD_PPBOM";
        public List<string> FentryIdList = new List<string>();
        public override void BeforeExecuteOperationTransaction(BeforeExecuteOperationTransaction e)
        {
            base.BeforeExecuteOperationTransaction(e);
@@ -57,15 +58,18 @@
                            as DynamicObjectCollection;
                foreach (var entryRow in entryRows)
                {
                    //生产用料清单为空时
                    if (Convert.ToString(entryRow["FDayPlanBillNo"]) == "")
                        continue;
                    string srcFormId = "";
                    string srcSrcBillNo = "";
                    string FPPBOMFENTRYID = "";
                    try
                    {
                        srcFormId = "PRD_PPBOM";
                        srcSrcBillNo = entryRow["FPPBOMBILLNO"].ToString();
                        string FPPBOMFID = entryRow["FPPOMFID"].ToString();
                        FPPBOMFENTRYID = entryRow["FPPBOMFENTRYID"].ToString();
                        srcSrcBillNo = entryRow["FPPBOMBILLNO"]?.ToString();
                        string FPPBOMFID = entryRow["FPPOMFID"]?.ToString();
                        FPPBOMFENTRYID = entryRow["FPPBOMFENTRYID"]?.ToString();
                    }
                    catch (Exception)
                    {
@@ -102,9 +106,9 @@
                foreach (var entryRow in entryRows)
                {
                    string srcFormId = "PRD_PPBOM";
                    string srcSrcBillNo = entryRow["FPPBOMBILLNO"].ToString();
                    string FPPBOMFID = entryRow["FPPOMFID"].ToString();
                    string FPPBOMFENTRYID = entryRow["FPPBOMFENTRYID"].ToString();
                    string srcSrcBillNo = entryRow["FPPBOMBILLNO"]?.ToString();
                    string FPPBOMFID = entryRow["FPPOMFID"]?.ToString();
                    string FPPBOMFENTRYID = entryRow["FPPBOMFENTRYID"]?.ToString();

                    if (string.IsNullOrWhiteSpace(srcFormId)
                        || string.IsNullOrWhiteSpace(srcSrcBillNo)
@@ -123,6 +127,10 @@
                    bool Ret = SourceVerification(Convert.ToString(entryRow["Id"]));
                    if (!Ret) continue;

                    //记录源单ID 用于更新
                    if (!FentryIdList.Contains(entryRow["Id"]?.ToString()))
                        FentryIdList.Add(entryRow["Id"]?.ToString());

                    DynamicObjectCollection linkRows = linkEntry.DynamicProperty.GetValue(entryRow)
                            as DynamicObjectCollection;
                    DynamicObject linkRow = new DynamicObject(linkEntry.DynamicObjectType);
@@ -133,21 +141,55 @@
                }
            }
            // 为新建的源单关联信息，设置内码
            IDBService dbService = ServiceHelper.GetService<IDBService>();
            IDBService dbService = Kingdee.K3.SCM.App.ServiceHelper.GetService<IDBService>();
            dbService.AutoSetPrimaryKey(this.Context, allNewLinkRows.ToArray(), linkEntry.DynamicObjectType);
        }

        /// <summary>
        /// 加载相关的销售订单数据
        /// 保存操作关联关系写入完成后 更改源单信息
        /// </summary>
        /// <param name="e"></param>
        public override void AfterExecuteOperationTransaction(AfterExecuteOperationTransaction e)
        {
            base.AfterExecuteOperationTransaction(e);
            //更改LK表信息 以及 源单关联信息
            List<string> sqlList = new List<string>();
            string sql = "";
            if (FentryIdList.Count > 0)
            {
                string FentryId = string.Join(",", FentryIdList.ToArray());
   //             sql = string.Format(@"/*dialect*/
   //update a set FBASEQTY = FQTY
   //from T_STK_STKTRANSFERINENTRY_LK a
   //join T_STK_STKTRANSFERINENTRY b on a.FENTRYID = b.FENTRYID
   //where 
   //--a.FSTABLENAME = 'T_PRD_PPBOMENTRY' and
   //a.FENTRYID in ({0})", FentryId);
   //             sqlList.Add(sql);
                sql = string.Format(@"/*dialect*/update T_STK_STKTRANSFERINENTRY_R 
   set FSrcBillTypeId = 'PRD_PPBOM',FSRCBILLNO=b.FPPBOMBILLNO
   ,FTRANSRESERVELINK=1
   from T_STK_STKTRANSFERINENTRY_R a 
   join T_STK_STKTRANSFERINENTRY b on a.FENTRYID=b.FENTRYID
   where a.FENTRYID in({0})", FentryId);
                sqlList.Add(sql);
                DBServiceHelper.ExecuteBatch(Context, sqlList);
            }
           
        }


        /// <summary>
        /// 加载相关的生产用料清单信息
        /// </summary>
        /// <param name="poBillNos"></param>
        /// <returns></returns>
        private DynamicObject[] LoadPurchaseOrder(HashSet<string> poBillNos)
        {
            IViewService viewService = ServiceHelper.GetService<IViewService>();
            IViewService viewService = Kingdee.K3.SCM.App.ServiceHelper.GetService<IViewService>();
            string formId = "PRD_PPBOM";

            // 指定需要加载的销售订单字段
            // 指定需要加载的用料清单字段
            List<SelectorItemInfo> fields = new List<SelectorItemInfo>();
            fields.Add(new SelectorItemInfo("FID"));        // 单据主键
            fields.Add(new SelectorItemInfo("FTreeEntity_FEntryID"));     // 单据体主键
@@ -156,8 +198,9 @@
            fields.Add(new SelectorItemInfo("FMaterialId"));    // 物料
            fields.Add(new SelectorItemInfo("FMaterialID2"));    // 物料
            fields.Add(new SelectorItemInfo("FBASENEEDQTY"));           // 基本单位数量
            fields.Add(new SelectorItemInfo("FBASEPICKEDQTY"));           // 基本单位关联数量
            fields.Add(new SelectorItemInfo("FBASEPICKEDQTY"));           //  
            fields.Add(new SelectorItemInfo("FBFLOWID"));           //  
            fields.Add(new SelectorItemInfo("FSelTranslateQty"));           //  

            // 指定过滤条件
            string filter = string.Format(" FBillNo IN ('{0}') ", string.Join("','", poBillNos));
@@ -166,7 +209,7 @@
            return objs;
        }
        /// <summary>
        /// 把销售订单单据体行构建为字典：Dictionary(单据编号, Dictionary(物料编码, 源单行));
        /// 把用料清单单据体行构建为字典：Dictionary(单据编号, Dictionary(物料编码, 源单行));
        /// </summary>
        /// <param name="poObjs"></param>
        /// <returns></returns>
@@ -191,12 +234,12 @@
            return dctAllBills;
        }
        /// <summary>
        /// 获取销售订单关联主实体表格编码
        /// 获取用料清单关联主实体表格编码
        /// </summary>
        /// <returns></returns>
        private string GetPOEntryTableNumber()
        {
            IBusinessFlowService bfMetaService = ServiceHelper.GetService<IBusinessFlowService>();
            IBusinessFlowService bfMetaService = Kingdee.K3.SCM.App.ServiceHelper.GetService<IBusinessFlowService>();
            var tableDefine = bfMetaService.LoadTableDefine(this.Context, POFormId, "FEntity");
            return tableDefine.TableNumber;
        }
@@ -209,15 +252,18 @@
        private void FillLinkRow(DynamicObject srcRow, DynamicObject toRow, DynamicObject linkRow)
        {
            //剩余调拨数量 
            decimal remainQty = DBServiceHelper.ExecuteScalar<decimal>(Context, $"select FMustQty -isnull(FSELTRANSLATEQTY,0) from  T_PRD_PPBOMENTRY t1  left join  T_PRD_PPBOMENTRY_Q t2 on t1.FENTRYID = t2.FENTRYID where t1.FENTRYID={toRow["FPPBOMFENTRYID"]?.ToString()}",0);
            decimal remainQty = DBServiceHelper.ExecuteScalar<decimal>(Context, $"select FMustQty -isnull(FSELTRANSLATEQTY,0) from  T_PRD_PPBOMENTRY t1  left join  T_PRD_PPBOMENTRY_Q t2 on t1.FENTRYID = t2.FENTRYID where t1.FENTRYID={toRow["FPPBOMFENTRYID"]?.ToString()}", 0);
            linkRow["FlowId"] = srcRow["BFLowId_Id"];
            linkRow["FlowLineId"] = 0;
            linkRow["FlowLineId"] = 13;
            linkRow["RuleId"] = "PRD_PPBOM-STK_TransferDirect";
            linkRow["SBillId"] = ((DynamicObject)srcRow.Parent)[0];
            linkRow["SId"] = srcRow[0];
            // 原始携带量
            linkRow["BaseQtyOld"] = remainQty;//剩余调拨数量
            linkRow["BaseQty"] = remainQty-Convert.ToDecimal(toRow["QTY"]); //本次需要调拨数量
            linkRow["BaseQty"] = toRow["QTY"]; //本次需要调拨数量
            linkRow["SALBASEQTY"] = toRow["QTY"]; //本次需要调拨数量


        }

        /// <summary>
@@ -226,7 +272,7 @@
        /// <returns></returns>
        public bool SourceVerification(string FTID)
        {
            string sql = $" select count(*) from T_BF_INSTANCEENTRY where FSTABLENAME= 'T_PRD_PPBOMENTRY' and FTID = '{FTID}'";
            string sql = $" select count(*) from T_BF_INSTANCEENTRY where FSTABLENAME= 'T_PRD_PPBOMENTRY' and FTTABLENAME = 'T_STK_STKTRANSFERINENTRY' and FTID = '{FTID}'";
            int count = DBServiceHelper.ExecuteScalar<int>(Context, sql, 0);
            if (count == 0)
                return true;