yuyubo/Pilot_KD_Parino_yuyubo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
993ae2e08d55d9f4ec7d4bcd08b66a2d33187e51
Pilot_KD_Parino_yuyubo/Pilot_KD_Parino/Sal_Order/SalDeliveryNoticeAudit.cs

457 lines
24 KiB
C#
Raw Normal View History

11
2025-07-15 19:51:01 +08:00
using Castle.Core.Internal;
using Kingdee.BOS;
666
2025-05-14 12:29:38 +08:00
using Kingdee.BOS.App;
using Kingdee.BOS.Contracts;
1
2025-07-23 16:52:09 +08:00
using Kingdee.BOS.Core.Bill;
using Kingdee.BOS.Core;
666
2025-05-14 12:29:38 +08:00
using Kingdee.BOS.Core.DynamicForm;
using Kingdee.BOS.Core.DynamicForm.Operation;
using Kingdee.BOS.Core.DynamicForm.PlugIn;
using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
1
2025-07-23 16:52:09 +08:00
using Kingdee.BOS.Core.Interaction;
666
2025-05-14 12:29:38 +08:00
using Kingdee.BOS.Core.List;
using Kingdee.BOS.Core.Metadata;
using Kingdee.BOS.Core.Metadata.ConvertElement;
using Kingdee.BOS.Core.Metadata.ConvertElement.ServiceArgs;
1
2025-07-23 16:52:09 +08:00
using Kingdee.BOS.Core.Metadata.FormElement;
666
2025-05-14 12:29:38 +08:00
using Kingdee.BOS.Log;
using Kingdee.BOS.Orm;
using Kingdee.BOS.Orm.DataEntity;
using Kingdee.BOS.ServiceHelper;
using Kingdee.BOS.Util;
11
2025-06-17 20:21:32 +08:00
using Pilot_KD_Parino.Common;
666
2025-05-14 12:29:38 +08:00
using System;
11
2025-07-15 19:51:01 +08:00
using System.Collections.Generic;
666
2025-05-14 12:29:38 +08:00
using System.ComponentModel;
using System.Data;
using System.Linq;
1
2025-07-23 16:52:09 +08:00
using Kingdee.BOS.Core.Metadata.EntityElement;
using Kingdee.K3.SCM.Common.BusinessEntity.Sales;
666
2025-05-14 12:29:38 +08:00
namespace Pilot_KD_Parino.Sal_Order
{
[Description("A组织的发货通知单自动推B组织的发货通知单服务插件"), HotUpdate]
public class SalDeliveryNoticeAudit : AbstractOperationServicePlugIn
{
11
2025-06-17 20:21:32 +08:00
string ADDRESS = "";
string date = "";
11
2025-06-17 20:39:31 +08:00
string fid = "0";
11
2025-07-15 19:51:01 +08:00
DynamicObject sheet = null;
666
2025-05-14 12:29:38 +08:00
public override void AfterExecuteOperationTransaction(AfterExecuteOperationTransaction e)
{
//throw new KDBusinessException("", "至少进来了");
base.AfterExecuteOperationTransaction(e);
foreach (var rows in e.SelectedRows)
{
var Billobj = rows.DataEntity;
11
2025-07-15 19:51:01 +08:00
sheet = Billobj;
var sdsas = JsonHelper.ToJson(Billobj);
Logger.Error("目标单据数据集合", sdsas, new Exception());
666
2025-05-14 12:29:38 +08:00
string id = Convert.ToString(Billobj["Id"]);
11
2025-06-17 20:39:31 +08:00
fid = id;
11
2025-06-17 20:21:32 +08:00
string addressSql = $@"/*dialect*/SELECT F_Shippingaddress, FDate FROM dbo.T_SAL_DELIVERYNOTICE WHERE fid={id}";
var dan = DBServiceHelper.ExecuteDynamicObject(this.Context, addressSql);
ADDRESS = dan.Select(t => t["F_Shippingaddress"]).FirstOrDefault()?.ToString();
date = dan.Select(t => t["FDate"]).FirstOrDefault()?.ToString();
666
2025-05-14 12:29:38 +08:00
//发货通知单找到源头销售订单
string getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID FROM T_SAL_DELIVERYNOTICEENTRY_LK
WHERE FENTRYID IN ( SELECT FENTRYID FROM dbo.T_SAL_DELIVERYNOTICEENTRY WHERE FID = {id})";
var dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
if (dt == null || dt.Count == 0)
{
//throw new KDBusinessException("", "没有找到源头销售订单：" );
return;
}
int tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
string tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
//销售订单找到跨组织的销售订单
getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID,FENTRYID FROM T_SAL_ORDERENTRY_LK
WHERE FSBILLID = {tempFid} and FSTABLENAME='T_SAL_ORDERENTRY' ";
dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
//throw new KDBusinessException("", "1:" + getSourceSql);
string fentryid = "";
if (dt == null || dt.Count == 0)
{
//如果不是小公司的订单，是珠海派诺--珠海兴诺的订单，则按 销售订单--采购申请单--采购订单--兴诺的销售订单 逻辑找订单
//采购申请单
getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID,FENTRYID FROM T_PUR_ReqEntry_LK
WHERE FSBILLID = {tempFid} and FSTABLENAME='T_SAL_ORDERENTRY' ";
dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
111
2025-09-01 11:57:43 +08:00
11
2025-07-28 20:22:12 +08:00
if (dt == null || dt.Count == 0 || dt.Count>1)
666
2025-05-14 12:29:38 +08:00
{
222
2025-05-15 19:42:19 +08:00
//throw new KDBusinessException("", "没有找到跨组织的采购申请单:" + getSourceSql);
666
2025-05-14 12:29:38 +08:00
return;
}
else
{
111
2025-09-01 11:57:43 +08:00
var FSBILLIDList = dt.Select(t => t["FSBILLID"].ToString()).Distinct().ToList();
if (FSBILLIDList.Count > 1)
{
return;
}
666
2025-05-14 12:29:38 +08:00
//采购订单
tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
fentryid = dt.Select(t => t["FENTRYID"]).FirstOrDefault().ToString();
getSourceSql = $@"/*dialect*/ SELECT FID FROM T_PUR_ReqEntry WHERE FENTRYID ={fentryid}";
dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
tempFid = int.Parse(dt.FirstOrDefault()["FID"].ToString());
getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID,FENTRYID FROM t_PUR_POOrderEntry_LK
WHERE FSBILLID = {tempFid} and FSTABLENAME='T_PUR_ReqEntry' ";
dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
111
2025-09-01 11:57:43 +08:00
if (dt == null || dt.Count == 0)
666
2025-05-14 12:29:38 +08:00
{
222
2025-05-15 19:42:19 +08:00
//throw new KDBusinessException("", "没有找到跨组织的采购订单:" + getSourceSql);
666
2025-05-14 12:29:38 +08:00
return;
}
else
{
111
2025-09-01 11:57:43 +08:00
var FSBILLIDList2 = dt.Select(t => t["FSBILLID"].ToString()).Distinct().ToList();
if (FSBILLIDList2.Count > 1)
{
return;
}
666
2025-05-14 12:29:38 +08:00
//兴诺的销售订单
tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
fentryid = dt.Select(t => t["FENTRYID"]).FirstOrDefault().ToString();
getSourceSql = $@"/*dialect*/ SELECT FID FROM t_PUR_POOrderEntry WHERE FENTRYID ={fentryid}";
dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
tempFid = int.Parse(dt.FirstOrDefault()["FID"].ToString());
getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID,FENTRYID FROM T_SAL_ORDERENTRY_LK
WHERE FSBILLID = {tempFid} and FSTABLENAME='t_PUR_POOrderEntry' ";
dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
11
2025-07-28 20:22:12 +08:00
if (dt == null || dt.Count == 0 || dt.Count > 1)
666
2025-05-14 12:29:38 +08:00
{
222
2025-05-15 19:42:19 +08:00
//throw new KDBusinessException("", "没有找到跨组织的销售订单:" + getSourceSql);
666
2025-05-14 12:29:38 +08:00
return;
}
}
}
//throw new KDBusinessException("", "没有找到跨组织的销售订单:"+ getSourceSql);
}
tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
fentryid = dt.Select(t => t["FENTRYID"]).FirstOrDefault().ToString();
//找到跨组织的销售订单主键ID
getSourceSql = $@"/*dialect*/ SELECT FID FROM T_SAL_ORDERENTRY WHERE FENTRYID ={fentryid}";
dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
//throw new KDBusinessException("", "2:" + getSourceSql);
if (dt == null || dt.Count == 0)
{
//throw new KDBusinessException("", "没有找到跨组织的销售订单明细");
return;
}
else
{
tempFid = int.Parse(dt.FirstOrDefault()["FID"].ToString());
int stockId = 0;
var result = Invoke("SAL_SaleOrder", "SAL_DELIVERYNOTICE", tempFid.ToString(), "193822715afc48aa9fa6d6beca7700ab", ref stockId);
}
//throw new KDBusinessException("", "3:" + getSourceSql);
}
}
11
2025-07-15 19:51:01 +08:00
private IOperationResult Invoke(string source, string target, string tempFid, string sargetBillTypeId,ref int stockId)
666
2025-05-14 12:29:38 +08:00
{
try
{
IOperationResult result = new OperationResult();
1
2025-08-28 19:23:07 +08:00
//获取单据转换规则
ConvertRuleElement ruleElement;
var ruleElementList = ServiceHelper.GetService<IConvertService>().GetConvertRules(this.Context, source, target).ToList();
var akdos = JsonHelper.ToJson(ruleElementList);
Logger.Error("获取单据转换规则", akdos, new Exception());
666
2025-05-14 12:29:38 +08:00
1
2025-08-28 19:23:07 +08:00
ruleElement = ruleElementList.Where(t => t.OriginKey == "9090ab67-7255-4a33-a457-a70fa2d90536").FirstOrDefault();
//var ruleMetaData = ConvertServiceHelper.GetConvertRule(this.Context, "9090ab67-7255-4a33-a457-a70fa2d90536");
//ruleElement = ruleMetaData.Rule;
//如下代码 直接通过查询数据库获取单据转换源单数据 9090ab67-7255-4a33-a457-a70fa2d90536
666
2025-05-14 12:29:38 +08:00
ListSelectedRowCollection rows = new ListSelectedRowCollection();
int i = 0;
ListSelectedRow row = new ListSelectedRow(tempFid, string.Empty, i++, source);
rows.Add(row);
PushArgs pushArgs = new PushArgs(ruleElement, rows.ToArray());
pushArgs.TargetBillTypeId = sargetBillTypeId;//单据类型
//转换生成目标单
ConvertOperationResult convertResult = ServiceHelper.GetService<IConvertService>().Push(this.Context, pushArgs);
////合并转换操作结果
//result.MergeResult(convertResult);
////目标单据数据集合
DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray();
11
2025-06-17 20:21:32 +08:00
666
2025-05-14 12:29:38 +08:00
//var sdsas = JsonHelper.ToJson(destObjs);
//Logger.Error("目标单据数据集合", sdsas, new Exception());
////目标单元数据
FormMetadata destFormMetadata = ServiceHelper.GetService<IMetaDataService>().Load(this.Context, target) as FormMetadata;
////保存目标单据
IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
11
2025-06-17 20:21:32 +08:00
if (target == "SAL_DELIVERYNOTICE")
{
var stocks3 = destObjs[0];
var sdsas = JsonHelper.ToJson(stocks3);
Logger.Error("跨组织的发货通知单", sdsas, new Exception());
if (ADDRESS != "")
{
11
2025-06-17 20:39:31 +08:00
string addressSql = $@"/*dialect*/update T_SAL_DELIVERYNOTICE set F_Shippingaddress=bb.F_Shippingaddress
from (select F_Shippingaddress from dbo.T_SAL_DELIVERYNOTICE bb where fid={fid}) bb
WHERE T_SAL_DELIVERYNOTICE.fid={stocks3["Id"]} ";
11
2025-06-17 20:21:32 +08:00
DBServiceHelper.ExecuteDynamicObject(this.Context, addressSql);
}
if (date != "")
{
11
2025-06-17 20:39:31 +08:00
string addressSql = $@"/*dialect*/update T_SAL_DELIVERYNOTICE set FDate='{date}' WHERE fid={stocks3["Id"]}";
11
2025-07-15 19:51:01 +08:00
11
2025-06-17 20:21:32 +08:00
DBServiceHelper.ExecuteDynamicObject(this.Context, addressSql);
}
11
2025-07-15 19:51:01 +08:00
var itemList = sheet["SAL_DELIVERYNOTICEENTRY"] as DynamicObjectCollection;
var newItemlist = stocks3["SAL_DELIVERYNOTICEENTRY"] as DynamicObjectCollection;
Dictionary<string, decimal> MaterialCode = new Dictionary<string, decimal>();
foreach (var item in itemList)
{
var Material = item["MaterialID"] as DynamicObject;
if (Material != null)
{
string code2 = (Material["Number"].ToString());
decimal qty = decimal.Parse(item["Qty"].ToString());
if (!MaterialCode.ContainsKey(code2))
{
MaterialCode.Add(code2, qty);
}
else
MaterialCode[code2] = MaterialCode[code2] + qty;
}
}
List<DynamicObject> deleteItem = new List<DynamicObject>();
foreach (var item in newItemlist)
{
var Material = item["MaterialID"] as DynamicObject;
if (Material != null)
{
string code2 = (Material["Number"].ToString());
decimal qty = decimal.Parse(item["Qty"].ToString());
if (MaterialCode.ContainsKey(code2))
{
if (MaterialCode[code2] != qty)
{
item["Qty"] = MaterialCode[code2];
1
2025-07-23 16:52:09 +08:00
item["BaseOutMaxQty"] = MaterialCode[code2];
item["BaseOutMinQty"] = MaterialCode[code2];
item["RemainOutQty"] = MaterialCode[code2];
item["OutMaxQty"] = MaterialCode[code2];
item["OutMinQty"] = MaterialCode[code2];
11
2025-07-15 19:51:01 +08:00
}
}
else
{
deleteItem.Add(item);
}
}
}
if (deleteItem.Count > 0)
{
deleteItem.ForEach(t =>
{
newItemlist.Remove(t);
});
1
2025-07-23 16:52:09 +08:00
//saveResult = ServiceHelper.GetService<ISaveService>().Save(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
11
2025-07-15 19:51:01 +08:00
}
1
2025-07-23 16:52:09 +08:00
saveResult = ServiceHelper.GetService<ISaveService>().Save(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
//调用Qty字段值更新服务
InvokeFieldUpdate(Convert.ToString(stocks3["Id"]));
//插入自动生成记录
string insertSql = $@"/*dialect*/INSERT INTO zz_zTuiSongLog
(Fid,FromType,TargetType,TFid,Creater,CreateTime)
VALUES
({fid},'SAL_DELIVERYNOTICE','SAL_DELIVERYNOTICE',{Convert.ToString(stocks3["Id"])},'{this.Context.UserName}','{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}')";
DBServiceHelper.Execute(this.Context, insertSql);
;
11
2025-06-17 20:21:32 +08:00
}
666
2025-05-14 12:29:38 +08:00
////合并保存操作结果
//result.MergeResult(saveResult);
//根据操作结果构造返回结果
if ((saveResult.ValidationErrors != null && saveResult.ValidationErrors.Count > 0))
//|| (result.OperateResult != null && result.OperateResult.Count > 0))
{
var errorInfo = string.Join(";", saveResult.ValidationErrors.Select(x => x.Message));
//this.View.ShowErrMessage("调用下推, 导致自动保存失败 原因：" + errorInfo);
//result.IsSuccess = false;
//this.View.ShowErrMessage("调用下推, 导致自动保存失败 原因：" + saveResult.ValidationErrors[0].Message.ToString());
throw new KDBusinessException("", "未知原因导致自动保存失败原因：" + errorInfo);
}
result = saveResult;
//this.View.ShowMessage("1");
// 取到需要自动提交、审核的单据内码
object[] pkArray = (from p in destObjs select p[0]).ToArray();
//设置提交参数
IOperationResult submitResult = ServiceHelper.GetService<ISubmitService>().Submit(this.Context, destFormMetadata.BusinessInfo, pkArray, "Submit", OperateOption.Create());
// 判断提交结果，如果失败，则内部会抛出错误，回滚代码
if (submitResult.IsSuccess == false)
{
throw new KDBusinessException("", "未知原因导致自动提交失败！");
}
//设置审核参数
IOperationResult auditResult = ServiceHelper.GetService<IAuditService>().Audit(this.Context, destFormMetadata.BusinessInfo, pkArray, OperateOption.Create());
// 判断提交结果，如果失败，则内部会抛出错误，回滚代码
if (auditResult.IsSuccess == false)
{
throw new KDBusinessException("", "未知原因导致自动审核失败！");
}
//显示下推后的单据
//ShowPushResult("k0f9e182dbc5247fcabc9479ddb300fa3", convertResult, destObjs);
return result;
}
catch (Exception ex)
{
Logger.Error("跨组织下推订单报错", "跨组织下推订单报错 error:" + ex.Message + ex.StackTrace, ex);
throw ex;
}
}
1
2025-07-23 16:52:09 +08:00
/// <summary>
/// 调用字段值更新服务
/// </summary>
/// <param name="FID"></param>
private void InvokeFieldUpdate(string FID)
{
// 构建一个IBillView实例，通过此实例，可以方便的填写补卡申请单各属性
IBillView billView = this.CreateBillView("SAL_DELIVERYNOTICE");
// 加载一个发货通知单
((IBillViewService)billView).LoadData();
// 触发插件的OnLoad事件：
// 组织控制基类插件，在OnLoad事件中，对主业务组织改变是否提示选项进行初始化。
// 如果不触发OnLoad事件，会导致主业务组织赋值不成功
DynamicFormViewPlugInProxy eventProxy = billView.GetService<DynamicFormViewPlugInProxy>();
eventProxy.FireOnLoad();
ModifyBill(billView, FID);
int Rowcount = billView.Model.GetEntryRowCount("FEntity");
for (int j = 0; j < Rowcount; j++)
{
billView.InvokeFieldUpdateService("FQty", j);
billView.UpdateView("FEntity");
}
// 保存补卡申请单
OperateOption saveOption = OperateOption.Create();
this.SaveBill(billView, saveOption);
}
public IBillView CreateBillView(string FKEY)
{
// 读取商品类型的元数据
FormMetadata meta = MetaDataServiceHelper.Load(this.Context, FKEY) as FormMetadata;
Form form = meta.BusinessInfo.GetForm();
// 创建用于引入数据的单据view
Type type = Type.GetType("Kingdee.BOS.Web.Import.ImportBillView,Kingdee.BOS.Web");
var billView = (IDynamicFormViewService)Activator.CreateInstance(type);
// 开始初始化billView：
// 创建视图加载参数对象，指定各种参数，如FormId, 视图(LayoutId)等
BillOpenParameter openParam = this.CreateOpenParameter(meta);
// 动态领域模型服务提供类，通过此类，构建MVC实例
var provider = form.GetFormServiceProvider();
billView.Initialize(openParam, provider);
return billView as IBillView;
}
private BillOpenParameter CreateOpenParameter(FormMetadata meta)
{
Form form = meta.BusinessInfo.GetForm();
// 指定FormId, LayoutId
BillOpenParameter openParam = new BillOpenParameter(form.Id, meta.GetLayoutInfo().Id);
// 数据库上下文
openParam.Context = this.Context;
// 本单据模型使用的MVC框架
openParam.ServiceName = form.FormServiceName;
// 随机产生一个不重复的PageId，作为视图的标识
openParam.PageId = Guid.NewGuid().ToString();
// 元数据
openParam.FormMetaData = meta;
// 界面状态：新增 (修改、查看)
openParam.Status = OperationStatus.ADDNEW;
// 单据主键：本案例演示新建商品类型，不需要设置主键
openParam.PkValue = null;
// 界面创建目的：普通无特殊目的 （为工作流、为下推、为复制等）
openParam.CreateFrom = CreateFrom.Default;
// 基础资料分组维度：基础资料允许添加多个分组字段，每个分组字段会有一个分组维度
// 具体分组维度Id，请参阅 form.FormGroups 属性
openParam.GroupId = "";
// 基础资料分组：如果需要为新建的基础资料指定所在分组，请设置此属性
openParam.ParentId = 0;
// 单据类型
openParam.DefaultBillTypeId = "";
// 业务流程
openParam.DefaultBusinessFlowId = "";
// 主业务组织改变时，不用弹出提示界面
openParam.SetCustomParameter("ShowConfirmDialogWhenChangeOrg", false);
// 插件
List<AbstractDynamicFormPlugIn> plugs = form.CreateFormPlugIns();
openParam.SetCustomParameter(FormConst.PlugIns, plugs);
PreOpenFormEventArgs args = new PreOpenFormEventArgs(this.Context, openParam);
foreach (var plug in plugs)
{// 触发插件PreOpenForm事件，供插件确认是否允许打开界面
plug.PreOpenForm(args);
}
if (args.Cancel == true)
{// 插件不允许打开界面
// 本案例不理会插件的诉求，继续....
}
// 返回
return openParam;
}
public void SaveBill(IBillView billView, OperateOption saveOption)
{
saveOption.SetIgnoreInteractionFlag(true);
//获取发货通知单表单结构
Form form = billView.BillBusinessInfo.GetForm();
if (form.FormIdDynamicProperty != null)
{
form.FormIdDynamicProperty.SetValue(billView.Model.DataObject, form.Id);
}
// 调用保存操作
IOperationResult saveResult = BusinessDataServiceHelper.Save(
this.Context,
billView.BillBusinessInfo,
billView.Model.DataObject,
saveOption, "Save");
billView.CommitNetworkCtrl();
billView.Close();
}
/// <summary>
/// 修改单据
/// </summary>
/// <param name="billView"></param>
/// <param name="pkValue"></param>
private void ModifyBill(IBillView billView, string pkValue)
{
billView.OpenParameter.Status = OperationStatus.EDIT;
billView.OpenParameter.CreateFrom = CreateFrom.Default;
billView.OpenParameter.PkValue = pkValue;
billView.OpenParameter.DefaultBillTypeId = string.Empty;
((IDynamicFormViewService)billView).LoadData();
}
666
2025-05-14 12:29:38 +08:00
}
}
Reference in New Issue Copy Permalink