105 lines
4.7 KiB
C#
105 lines
4.7 KiB
C#
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);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
} |