Merge branch 'master' of http://8.130.121.29:3000/yuyubo/Pilot_KD_Parino_yuyubo

Gatedge.K3.Pilot.PlugIn/BOSPlugIn/AR_SalesVATInvoice/ServicePlugIn/AfterSave.cs

@@ -0,0 +1,105 @@
+using Kingdee.BOS;
+using Kingdee.BOS.Core.DynamicForm.PlugIn;
+using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
+using Kingdee.BOS.Log;
+using Kingdee.BOS.Orm;
+using Kingdee.BOS.Orm.DataEntity;
+using Kingdee.BOS.ServiceHelper;
+using Kingdee.BOS.Util;
+using System;
+using System.ComponentModel;
+using System.Dynamic;
+
+namespace Gatedge.K3.Pilot.PlugIn.BOSPlugIn.AR_SalesVATInvoice.ServicePlugIn
+{
+    [HotUpdate, Description("销售增值税专用发票_保存后事件")]
+    public class AfterSave : AbstractOperationServicePlugIn
+    {
+        public override void OnPreparePropertys(PreparePropertysEventArgs e)
+        {
+            base.OnPreparePropertys(e);
+            // 根据日志中的实际实体属性名来添加
+            e.FieldKeys.Add("FIDD");
+            e.FieldKeys.Add("FSEQQ");
+            e.FieldKeys.Add("SRCBILLTYPEID");  // 实体属性名（没有F前缀）
+            e.FieldKeys.Add("SRCBILLNO");      // 实体属性名（没有F前缀）
+            e.FieldKeys.Add("FSEQ");
+        }
+
+        public override void AfterExecuteOperationTransaction(AfterExecuteOperationTransaction e)
+        {
+            base.AfterExecuteOperationTransaction(e);
+
+            foreach (var dataEntity in e.DataEntitys)
+            {
+                var billObj = dataEntity as DynamicObject;
+                if (billObj == null)
+                    continue;
+
+                // 获取单据体
+                var entrys = billObj["SALESICENTRY"] as DynamicObjectCollection;
+                if (entrys == null || entrys.Count == 0)
+                    continue;
+
+                foreach (var entry in entrys)
+                {
+                    // 使用 Id 获取主键值
+                    var entryId = Convert.ToInt64(entry.GetPrimaryKeyValue());
+                    var fidd = entry["FIDD"];
+                    var fiddValue = fidd == null ? 0 : Convert.ToInt64(fidd);
+
+                    if (fiddValue > 0)
+                    {
+                        // FIDD > 0 时，判断是否需要回写
+                        var srcBillNo = entry["SRCBILLNO"]?.ToString() ?? "";
+
+                        // 判断条件：FIDD != 当前行ID 且 源单编号为空
+                        if (fiddValue != entryId && string.IsNullOrWhiteSpace(srcBillNo))
+                        {
+                            // 查询源单据体信息（FID = fiddValue的明细行）
+                            // 这里使用数据库字段名（带F前缀）
+                            var sql = $@"/*dialect*/
+SELECT FSRCBILLTYPEID, FSRCBILLNO, FSEQ
+FROM T_IV_SALESICENTRY
+WHERE FENTRYID = {fiddValue}";
+                            Logger.Error("销售增值税专用发票", sql, new Exception());
+                            Logger.Error("销售增值税专用发票", "78", new Exception());
+                            var result = DBServiceHelper.ExecuteDynamicObject(this.Context, sql);
+                            if (result == null || result.Count == 0)
+                                continue;
+
+                            var srcData = result[0];
+                            // 注意：SQL查询返回的是数据库字段名（带F前缀）
+                            var srcBillTypeId = srcData["FSRCBILLTYPEID"]?.ToString() ?? "";
+                            var srcBillNoValue = srcData["FSRCBILLNO"]?.ToString() ?? "";
+
+                            // 回写当前单据体：源单类型、源单编号
+                            // 这里使用数据库字段名（带F前缀）
+                            var updateSql = $@"/*dialect*/
+UPDATE T_IV_SALESICENTRY 
+SET FSRCBILLTYPEID = '{srcBillTypeId.Replace("'", "''")}', 
+    FSRCBILLNO = '{srcBillNoValue.Replace("'", "''")}'
+WHERE FENTRYID = {entryId}";
+                            Logger.Error("销售增值税专用发票", updateSql, new Exception());
+                            Logger.Error("销售增值税专用发票", "78", new Exception());
+                            DBServiceHelper.Execute(this.Context, updateSql);
+                        }
+                    }
+                    else
+                    {
+                        // FIDD <= 0 时，把当前行FID赋值给FIDD，同时把FSEQ赋值给FSEQQ
+                        var seq = entry["FSEQ"]?.ToString() ?? "0";
+                        var updateSql = $@"/*dialect*/
+UPDATE T_IV_SALESICENTRY 
+SET FIDD = {entryId},
+    FSEQQ = '{seq.Replace("'", "''")}'
+WHERE FENTRYID = {entryId}";
+                        Logger.Error("销售增值税专用发票", updateSql, new Exception());
+                        Logger.Error("销售增值税专用发票", "78", new Exception());
+                        DBServiceHelper.Execute(this.Context, updateSql);
+                    }
+                }
+            }
+        }
+    }
+}