王 垚
2021-11-12 0ce538e3c3dc01153ce1bfc2d75276881206c222
src/BLL/Demo.BillView/PRD/Pro_MaterialRequisitionAuditDayPlan.cs
@@ -13,16 +13,16 @@
using Kingdee.BOS.ServiceHelper;
using Kingdee.K3.SCM.App;
namespace Demo.DynamicForm.PRD
namespace Demo.BillView.PRD
{
    /// <summary>
    /// 插件示例:引入销售出库单,建立与销售订单的关联
    /// 插件示例:日计划用料清单下推后,建立生产领料单与生产用料清单关联关系
    /// </summary>
    /// <remarks>
    /// 要求:
    /// 1. 需要引入单据体的源单类型、源单编号字段
    /// 2. 本插件挂在销售出库单的保存操作上
    /// 出库关联销售订单
    /// 2. 本插件挂在生产领料单的保存操作上
    /// 生产领料单与生产用料清单关联
    /// </remarks>
    [Description("日计划用料清单下推后,建立生产领料单与生产用料清单关联关系")]
    [HotUpdate]
@@ -59,18 +59,16 @@
                            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["PPBOMBILLNO"].ToString();
                        FPPBOMFENTRYID = entryRow["PPBomEntryId"].ToString();
                    }
                    catch (Exception)
                    {
                    }
                    srcFormId = "PRD_PPBOM";
                    srcSrcBillNo = entryRow["PPBOMBILLNO"].ToString();
                    FPPBOMFENTRYID = entryRow["PPBomEntryId"].ToString();
                    if (string.IsNullOrWhiteSpace(srcFormId)
                        || string.IsNullOrWhiteSpace(srcSrcBillNo)
                        )
@@ -142,7 +140,7 @@
                }
            }
            // 为新建的源单关联信息,设置内码
            IDBService dbService = ServiceHelper.GetService<IDBService>();
            IDBService dbService = Kingdee.K3.SCM.App.ServiceHelper.GetService<IDBService>();
            dbService.AutoSetPrimaryKey(this.Context, allNewLinkRows.ToArray(), linkEntry.DynamicObjectType);
        }
        /// <summary>
@@ -152,24 +150,28 @@
        public override void AfterExecuteOperationTransaction(AfterExecuteOperationTransaction e)
        {
            base.AfterExecuteOperationTransaction(e);
            if (FentryIdList.Count == 0)
                return;
            string FentryId = string.Join(",", FentryIdList.ToArray());
            List<string> sqlList = new List<string>();
            string sql = string.Format(@"/*dialect*/
    update a set FBASEACTUALQTY = b.FBASEACTUALQTY
   from T_PRD_PICKMTRLDATA_LK a
   join T_PRD_PICKMTRLDATA b on a.FENTRYID = b.FENTRYID
   where a.FSTABLENAME = 'T_PRD_PPBOMENTRY' and a.FENTRYID in ({0})", FentryId);
            update a set FSTOCKAPPQTY = FAPPQTY,FSTOCKACTUALQTY=FACTUALQTY
             from T_PRD_PICKMTRLDATA a
             where  a.FENTRYID in ({0})", FentryId);
            sqlList.Add(sql);
            sql = string.Format(@"/*dialect*/
   update T_PRD_PICKMTRLDATA set
   FSrcBillType = 'PRD_PPBOM',
   FSRCENTRYID=FPPBomEntryId,
   FSrcBillNo=FPPBOMBILLNO
   where FENTRYID in ({0})
update a set
FSrcBillType='PRD_PPBOM',
FSrcBillNo = b.FPPBOMBILLNO,
FSRCINTERID =FHPPBomInterID,
FSRCENTRYID = FHPPBomEntryID,
FSRCENTRYSEQ =FPPBOMFSEQINT
from T_PRD_PICKMTRLDATA a
join Sc_DayPlanPPBomBillSub b on a.FDAYPLANFENTRYID = b.FEntryID
where a.FEntryID in ({0})
    ", FentryId);
            sqlList.Add(sql);
            DBServiceHelper.ExecuteBatch(Context, sqlList);
            //DBServiceHelper.Execute(Context, sql);
        }
        /// <summary>
        /// 加载相关的销售订单数据
@@ -178,7 +180,7 @@
        /// <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";
            // 指定需要加载的销售订单字段
@@ -230,7 +232,7 @@
        /// <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;
        }
@@ -245,11 +247,11 @@
            //剩余领料数量 
            decimal remainQty = DBServiceHelper.ExecuteScalar<decimal>(Context, $"select FMustQty -isnull(FSelPickedQty,0) from  T_PRD_PPBOMENTRY t1  left join  T_PRD_PPBOMENTRY_Q t2 on t1.FENTRYID = t2.FENTRYID where t1.FENTRYID={toRow["PPBomEntryId"]?.ToString()}", 0);
            linkRow["FlowId"] = srcRow["BFLowId_Id"];
            linkRow["FlowLineId"] = 0;
            linkRow["FlowLineId"] = 5;
            linkRow["RuleId"] = "PRD_PPBOM2PICKMTRL_NORMAL";
            linkRow["SBillId"] = ((DynamicObject)srcRow.Parent)[0];
            linkRow["STableId"] = ((DynamicObject)srcRow.Parent)[0];
            linkRow["SId"] = srcRow[0];
            linkRow["SId"] = toRow["PPBomEntryId"];
            linkRow["BaseActualQtyOld"] = remainQty;
            linkRow["BaseActualQty"] = toRow["ACTUALQTY"]; //基本单位实发数量