产品代码上传

王 垚

2021-11-12 0ce538e3c3dc01153ce1bfc2d75276881206c222

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

@@ -13,20 +13,20 @@
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("送货计划单插件关联提料计划单")]
    [Description("日计划用料清单下推后，建立生产领料单与生产用料清单关联关系")]
    [HotUpdate]
    public class Pro_TlPushAudit : AbstractOperationServicePlugIn
    public class Pro_MaterialRequisitionAuditDayPlan : AbstractOperationServicePlugIn
    {
        public override void OnPreparePropertys(PreparePropertysEventArgs e)
        {
@@ -37,16 +37,19 @@
            e.FieldKeys.Add("FTreeEntity_FEntryID");
            e.FieldKeys.Add("FBillNo");
            e.FieldKeys.Add("FBFLowId");
            e.FieldKeys.Add("FHQty");
            e.FieldKeys.Add("FHMaterID");
            e.FieldKeys.Add("FMaterialId");
            e.FieldKeys.Add("FBaseUnitQty");
            e.FieldKeys.Add("FBaseJoinQty");
        }
        private const string POFormId = "paez_PODemandPlan";
        private const string POFormId = "PRD_PPBOM";
        public List<string> FentryIdList = new List<string>();

        public override void BeforeExecuteOperationTransaction(BeforeExecuteOperationTransaction e)
        {
            base.BeforeExecuteOperationTransaction(e);
            HashSet<string> poBillNos = new HashSet<string>();
            Entity entity = this.BusinessInfo.GetEntity("FDetailEntity");//获取明细信息
            Entity linkEntry = this.BusinessInfo.GetEntity("FDetailEntity_Link");
            Entity entity = this.BusinessInfo.GetEntity("FEntity");//获取明细信息
            Entity linkEntry = this.BusinessInfo.GetEntity("FEntity_Link");
            Field fldSrcFormId = this.BusinessInfo.GetField("FSrcBillType");
            Field fldSrcBillNo = this.BusinessInfo.GetField("FSrcBillNo");
            // 对单据体进行循环，取关联的源单编号
@@ -56,20 +59,16 @@
                            as DynamicObjectCollection;
                foreach (var entryRow in entryRows)
                {
                    //生产用料清单为空时
                    if (Convert.ToString(entryRow["FDayPlanBillNo"]) == "")
                        continue;
                    string srcFormId = "";
                    string srcSrcBillNo = "";
                    try
                    {
                        srcFormId = "paez_PODemandPlan";
                        srcSrcBillNo = entryRow["FTLOrderNo"].ToString();
                        //srcSrcBillNo = entryRow["FTLentryId"].ToString();
                        //srcSrcBillNo = entryRow["FTLId"].ToString();
                        //srcSrcBillNo = DBServiceHelper.ExecuteScalar<string>(Context, $" select distinct FPPBOMBILLNO from T_PUR_RECEIVEENTRY_LK where FSRCBILLNO = '{srcSrcBillNo}' ", srcSrcBillNo);
                    string FPPBOMFENTRYID = "";
                    srcFormId = "PRD_PPBOM";
                    srcSrcBillNo = entryRow["PPBOMBILLNO"].ToString();
                    FPPBOMFENTRYID = entryRow["PPBomEntryId"].ToString();

                    }
                    catch (Exception)
                    {
                    }
                    if (string.IsNullOrWhiteSpace(srcFormId)
                        || string.IsNullOrWhiteSpace(srcSrcBillNo)
                        )
@@ -101,9 +100,13 @@
                            as DynamicObjectCollection;
                foreach (var entryRow in entryRows)
                {
                    //string srcSrcBillNo = fldSrcBillNo.DynamicProperty.GetValue<string>(entryRow);
                    string srcFormId = "paez_PODemandPlan";
                    string srcSrcBillNo = entryRow["FTLOrderNo"].ToString();
                    string srcFormId = "";
                    string srcSrcBillNo = "";
                    string FPPBOMFENTRYID = "";

                    srcFormId = "PRD_PPBOM";
                    srcSrcBillNo = entryRow["PPBOMBILLNO"].ToString();
                    FPPBOMFENTRYID = entryRow["PPBomEntryId"].ToString();

                    if (string.IsNullOrWhiteSpace(srcFormId)
                        || string.IsNullOrWhiteSpace(srcSrcBillNo)
@@ -122,9 +125,13 @@
                    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;
                    linkRows.Clear();
                    //linkRows.Clear();
                    DynamicObject linkRow = new DynamicObject(linkEntry.DynamicObjectType);
                    linkRow["STableName"] = srcTableNumber;
                    this.FillLinkRow(srcRow, entryRow, linkRow);
@@ -133,10 +140,39 @@
                }
            }
            // 为新建的源单关联信息，设置内码
            IDBService dbService = ServiceHelper.GetService<IDBService>();
            IDBService dbService = Kingdee.K3.SCM.App.ServiceHelper.GetService<IDBService>();
            dbService.AutoSetPrimaryKey(this.Context, allNewLinkRows.ToArray(), linkEntry.DynamicObjectType);
        }

        /// <summary>
        /// 新增操作后 sql更新数量 以及 源单信息表
        /// </summary>
        /// <param name="e"></param>
        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 FSTOCKAPPQTY = FAPPQTY,FSTOCKACTUALQTY=FACTUALQTY
             from T_PRD_PICKMTRLDATA a
             where  a.FENTRYID in ({0})", FentryId);
            sqlList.Add(sql);
            sql = string.Format(@"/*dialect*/
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);
        }
        /// <summary>
        /// 加载相关的销售订单数据
        /// </summary>
@@ -144,18 +180,20 @@
        /// <returns></returns>
        private DynamicObject[] LoadPurchaseOrder(HashSet<string> poBillNos)
        {
            IViewService viewService = ServiceHelper.GetService<IViewService>();
            string formId = "paez_PODemandPlan";
            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("FEntity_FEntryID"));     // 单据体主键
            fields.Add(new SelectorItemInfo("FTreeEntity_FEntryID"));     // 单据体主键
            fields.Add(new SelectorItemInfo("FBillNo"));    // 单据编号
            //fields.Add(new SelectorItemInfo("FBFLowId"));    // 业务流程
            fields.Add(new SelectorItemInfo("FHMaterID"));    // 物料
            fields.Add(new SelectorItemInfo("FHQty"));           // 基本单位数量
            //fields.Add(new SelectorItemInfo("FBFLOWID"));           //  
            fields.Add(new SelectorItemInfo("FBFLowId"));    // 业务流程
            fields.Add(new SelectorItemInfo("FMaterialId"));    // 物料
            fields.Add(new SelectorItemInfo("FMaterialID2"));    // 物料
            fields.Add(new SelectorItemInfo("FBASENEEDQTY"));           // 基本单位数量
            fields.Add(new SelectorItemInfo("FBASEPICKEDQTY"));           // 基本单位关联数量
            fields.Add(new SelectorItemInfo("FBFLOWID"));           //  

            // 指定过滤条件
            string filter = string.Format(" FBillNo IN ('{0}') ", string.Join("','", poBillNos));
@@ -176,10 +214,10 @@
            {
                string billNo = Convert.ToString(poObj["BillNo"]);
                Dictionary<string, DynamicObject> dctOneBill = new Dictionary<string, DynamicObject>();
                DynamicObjectCollection entryRows = poObj["FEntity"] as DynamicObjectCollection;
                DynamicObjectCollection entryRows = poObj["PPBomEntry"] as DynamicObjectCollection;
                foreach (var entryRow in entryRows)
                {
                    DynamicObject materialObj = entryRow["FHMaterID"] as DynamicObject;
                    DynamicObject materialObj = entryRow["MaterialId"] as DynamicObject;
                    if (materialObj == null) continue;
                    string materialNumber = Convert.ToString(materialObj["number"]);
                    dctOneBill[materialNumber] = entryRow;
@@ -194,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;
        }
@@ -206,16 +244,17 @@
        /// <param name="linkRow">关联行</param>
        private void FillLinkRow(DynamicObject srcRow, DynamicObject toRow, DynamicObject linkRow)
        {
            //linkRow["FlowId"] = srcRow["BFLowId_Id"];
            linkRow["FlowLineId"] = 0;
            linkRow["RuleId"] = Guid.NewGuid().ToString();
            //剩余领料数量 
            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"] = 5;
            linkRow["RuleId"] = "PRD_PPBOM2PICKMTRL_NORMAL";
            linkRow["SBillId"] = ((DynamicObject)srcRow.Parent)[0];
            linkRow["SId"] = srcRow[0];
            // 原始携带量
            decimal baseUnitQty = Convert.ToDecimal(srcRow["FHQty"]);//用料清单单位数量
            decimal joinUnitQty = Convert.ToDecimal(srcRow["FHQty"]);//用料清单单位领料数量
            linkRow["BASEUNITQTY"] = baseUnitQty;
            linkRow["STOCKBASEQTY"] = baseUnitQty; //基本单位实发数量
            linkRow["STableId"] = ((DynamicObject)srcRow.Parent)[0];
            linkRow["SId"] = toRow["PPBomEntryId"];
            linkRow["BaseActualQtyOld"] = remainQty;
            linkRow["BaseActualQty"] = toRow["ACTUALQTY"]; //基本单位实发数量

        }

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