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

534 lines
28 KiB
C#
Raw Normal View History

22
2025-04-23 19:57:13 +08:00
using DevExpress.Xpo.DB.Helpers;
using FarPoint.Excel;
using Kingdee.BOS;
1
2025-04-18 13:42:20 +08:00
using Kingdee.BOS.App;
using Kingdee.BOS.App.Data;
using Kingdee.BOS.Contracts;
using Kingdee.BOS.Core.DynamicForm;
using Kingdee.BOS.Core.DynamicForm.Operation;
22
2025-04-19 14:44:32 +08:00
using Kingdee.BOS.Core.DynamicForm.PlugIn;
1
2025-04-18 13:42:20 +08:00
using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
using Kingdee.BOS.Core.List;
using Kingdee.BOS.Core.List.PlugIn;
using Kingdee.BOS.Core.Metadata;
using Kingdee.BOS.Core.Metadata.ConvertElement;
using Kingdee.BOS.Core.Metadata.ConvertElement.ServiceArgs;
333
2025-04-22 19:17:14 +08:00
using Kingdee.BOS.Core.Metadata.FormElement;
1
2025-04-18 13:42:20 +08:00
using Kingdee.BOS.Log;
using Kingdee.BOS.Orm;
using Kingdee.BOS.Orm.DataEntity;
using Kingdee.BOS.ServiceHelper;
22
2025-04-19 17:25:24 +08:00
using Kingdee.BOS.Util;
1
2025-04-22 11:34:03 +08:00
using Newtonsoft.Json.Linq;
using Pilot_KD_Parino.Common;
1
2025-04-18 13:42:20 +08:00
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Linq;
namespace Pilot_KD_Parino.Sal_Order
{
22
2025-04-19 17:25:24 +08:00
[Description("下推生成销售出库单及联动生成其他单的插件"), HotUpdate]
22
2025-04-19 14:44:32 +08:00
public class PushSaleOutBillPlugIn : AbstractDynamicFormPlugIn // AbstractListPlugIn
1
2025-04-18 13:42:20 +08:00
{
long sScrId = 0;
string sScrBillNo = "";
22
2025-04-19 17:25:24 +08:00
public override void AfterBarItemClick(AfterBarItemClickEventArgs e)
1
2025-04-18 13:42:20 +08:00
{
22
2025-04-19 17:25:24 +08:00
base.AfterBarItemClick(e);
333
2025-04-22 19:17:14 +08:00
22
2025-04-19 17:25:24 +08:00
//this.View.ShowMessage("669977");
22
2025-04-19 14:44:32 +08:00
22
2025-04-19 17:25:24 +08:00
if (e.BarItemKey.Equals("tbPushSalOut111", StringComparison.OrdinalIgnoreCase))
{
333
2025-04-22 19:17:14 +08:00
var FEntity = this.View.Model.DataObject;
22
2025-04-19 17:25:24 +08:00
var id = FEntity["id"];
333
2025-04-22 19:17:14 +08:00
string formid = FEntity["FFormId"].ToString();
//var detailList = (FEntity["SAL_DELIVERYNOTICEENTRY"]);
22
2025-04-19 17:25:24 +08:00
333
2025-04-22 19:17:14 +08:00
//发货通知单或者发货出库单
string getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID FROM dbo.T_{formid}ENTRY_LK
WHERE FENTRYID IN ( SELECT FENTRYID FROM dbo.T_{formid}ENTRY WHERE FID = {id})";
var dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
if (dt == null || dt.Count == 0)
{
this.View.ShowMessage("没有上查关联的发货通知单");
}
int tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
string tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
232
2025-05-07 20:08:40 +08:00
int xiaoFid = 0;
22
2025-04-23 19:57:13 +08:00
//找到采购订单
333
2025-04-22 19:17:14 +08:00
for (int kk = 0; kk < 6 && tablename.ToUpper() != "T_PUR_POORDERENTRY"; kk++)
{
////发货通知单
tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
string tempTable = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID FROM dbo.{tempTable}_lk
WHERE FENTRYID IN ( SELECT FENTRYID FROM {tempTable} WHERE FID = {tempFid})";
//dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
//if (dt == null || dt.Count == 0)
//{
// this.View.ShowMessage("没有上查关联的销售单");
//}
////共享的采购订单
//tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
//tempTable = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
//getSourceSql = $@"/*dialect*/ SELECT FSTABLENAME,FSBILLID FROM dbo.{tempTable}_lk
// WHERE FENTRYID IN ( SELECT FENTRYID FROM {tempTable} WHERE FID = {tempFid})";
dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
22
2025-04-19 17:25:24 +08:00
333
2025-04-22 19:17:14 +08:00
if (dt == null || dt.Count == 0)
{
232
2025-05-07 20:08:40 +08:00
//this.View.ShowMessage("没有上查关联的跨组织的采购订单");
333
2025-04-22 19:17:14 +08:00
return;
}
else
{
tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
232
2025-05-07 20:08:40 +08:00
tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
333
2025-04-22 19:17:14 +08:00
}
232
2025-05-07 20:08:40 +08:00
333
2025-04-22 19:17:14 +08:00
}
if (tablename.ToUpper() != "T_PUR_POORDERENTRY")
232
2025-05-07 20:08:40 +08:00
{
getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID,FENTRYID FROM dbo.T_PUR_POORDERENTRY_LK
WHERE FSBILLID= {tempFid}";
dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
if (dt == null || dt.Count == 0)
{
throw new KDBusinessException("", "没有上查关联的跨组织的采购订单：" + tablename);
}
else
{
xiaoFid = tempFid;
//tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
//tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
var FENTRYIDList = dt.Select(t => int.Parse(t["FENTRYID"].ToString())).ToList();
string ids = string.Join(",", FENTRYIDList);
getSourceSql = $@"/*dialect*/ SELECT FID FROM T_PUR_POORDERENTRY WHERE FENTRYID IN({ids})";
dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
if (dt == null || dt.Count == 0)
{
throw new KDBusinessException("", "没有上查关联的跨组织的采购订单：" + tablename);
}
else
{
tempFid =int.Parse( dt.FirstOrDefault()["FID"].ToString());
}
}
1
2025-04-22 11:34:03 +08:00
}
22
2025-04-23 19:57:13 +08:00
int stockId = 0;
IOperationResult result = Invoke("PUR_PurchaseOrder", "PUR_ReceiveBill", tempFid.ToString(), "7cd93c259999489c97798063f2f7bd70", ref stockId);
333
2025-04-22 19:17:14 +08:00
22
2025-04-23 19:57:13 +08:00
var sheet = result.SuccessDataEnity.FirstOrDefault();
string jsonsheet = JsonHelper.ToJson(sheet);
//Logger.Error("推送采购入库单",jsonsheet,null);
if (sheet != null)
{
result = Invoke("PUR_ReceiveBill", "STK_InStock", sheet["id"].ToString(), "a1ff32276cd9469dad3bf2494366fa4f", ref stockId);
//sheet = result.SuccessDataEnity.FirstOrDefault();
//result = Invoke("PUR_ReceiveBill", "STK_InStock", sheet["id"].ToString(), "a1ff32276cd9469dad3bf2494366fa4f");
}
333
2025-04-22 19:17:14 +08:00
22
2025-04-23 19:57:13 +08:00
//找到最开始的销售订单
232
2025-05-07 20:08:40 +08:00
for (int kk = 0; kk < 6 && tablename.ToUpper() != "T_SAL_ORDERENTRY" && xiaoFid==0; kk++)
22
2025-04-23 19:57:13 +08:00
{
////发货通知单
tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
string tempTable = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID FROM dbo.{tempTable}_lk
WHERE FENTRYID IN ( SELECT FENTRYID FROM {tempTable} WHERE FID = {tempFid})";
dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);
333
2025-04-22 19:17:14 +08:00
22
2025-04-23 19:57:13 +08:00
if (dt == null || dt.Count == 0)
{
this.View.ShowMessage("没有上查关联的跨组织的采购订单");
return;
}
else
{
tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
}
tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
}
232
2025-05-07 20:08:40 +08:00
if (tablename.ToUpper() != "T_SAL_ORDERENTRY" && xiaoFid == 0)
22
2025-04-23 19:57:13 +08:00
{
throw new KDBusinessException("", "推送销售发货通知单失败,没有上查关联的跨组织的销售订单：" + tablename);
}
232
2025-05-07 20:08:40 +08:00
if (xiaoFid > 0)
tempFid = xiaoFid;
22
2025-04-23 19:57:13 +08:00
result = Invoke("SAL_SaleOrder", "SAL_DELIVERYNOTICE", tempFid.ToString(), "193822715afc48aa9fa6d6beca7700ab", ref stockId);
sheet = result.SuccessDataEnity.FirstOrDefault();
result = Invoke("SAL_DELIVERYNOTICE", "SAL_OUTSTOCK", sheet["id"].ToString(), "ad0779a4685a43a08f08d2e42d7bf3e9", ref stockId);
this.View.ShowMessage("跨组织下推订单完成");
1
2025-04-22 11:34:03 +08:00
//this.View.ShowMessage("就是这个按钮"+ id);
22
2025-04-19 17:25:24 +08:00
1
2025-04-22 11:34:03 +08:00
//ListSelectedRowCollection rows =new ListSelectedRowCollection();
22
2025-04-19 17:25:24 +08:00
//List<string> pkIds = new List<string>();
//List<object> pkEntryIds = new List<object>();
//if (rows.Count <= 0)
//{
// this.View.ShowMessage("请选择对应的发货通知单！！！");
// return;
//}
//foreach (var row in rows)
//{
// sBillNo = row.BillNo.ToString();//发货通知单号
// sId = Convert.ToInt64(row.PrimaryKeyValue);//发货通知单ID
// sEntryId = Convert.ToInt64(row.EntryPrimaryKeyValue);//发货通知单ID
// string sSql = "select FID from T_SAL_DELIVERYNOTICEENTRY where FID= " + sId + " and FENTRYID= " + sEntryId + " and abs(FBaseUnitQty) > abs(FBASEJOINOUTQTY) ";
// sSql = String.Format(@"/*dialect*/" + sSql);
// var dt = DBServiceHelper.ExecuteDynamicObject(this.Context, sSql);
// if (dt.Count > 0)
// {
// string getSourceSql = "select FID from T_SAL_DELIVERYNOTICE where FBILLNO='" + sBillNo + "'";
// IOperationResult result = Invoke("SAL_DELIVERYNOTICE", "SAL_OUTSTOCK", getSourceSql, "ad0779a4685a43a08f08d2e42d7bf3e9");
// }
//}//进入下一个循环生成下一个系列的分布式调出单
//if (flag)
//{
// this.View.ShowMessage("生成对应系列的分布式调出单完成！！！");
//}
}
1
2025-04-18 13:42:20 +08:00
}
333
2025-04-22 19:17:14 +08:00
22
2025-04-23 19:57:13 +08:00
private IOperationResult Invoke(string source, string target, string tempFid, string sargetBillTypeId, ref int stockId)
1
2025-04-18 13:42:20 +08:00
{
try
{
IOperationResult result = new OperationResult();
//获取单据转换规则
ConvertRuleElement ruleElement = ServiceHelper.GetService<IConvertService>().GetConvertRules(this.Context, source, target).FirstOrDefault();
//如下代码 直接通过查询数据库获取单据转换源单数据
ListSelectedRowCollection rows = new ListSelectedRowCollection();
int i = 0;
333
2025-04-22 19:17:14 +08:00
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();
22
2025-04-23 19:57:13 +08:00
333
2025-04-22 19:17:14 +08:00
var sdsas = JsonHelper.ToJson(destObjs);
Logger.Error("目标单据数据集合", sdsas, new Exception());
22
2025-04-23 19:57:13 +08:00
int temStockId = stockId;
if (target == "PUR_ReceiveBill")//收料通知单,强制没有配置仓库的物料进成品仓库
{
//var sheet = destObjs.FirstOrDefault(); PUR_ReceiveEntry
string pur = ("PUR_ReceiveEntry");
var stocks3 = destObjs[0];
if (temStockId == 0)
{
string sql2 = $@"/*dialect*/ SELECT FUseOrgId,fname, a.FSTOCKID,FForbidStatus,FDocumentStatus FROM T_BD_STOCK a
LEFT JOIN T_BD_STOCK_L b ON a.FSTOCKID=b.FSTOCKID
WHERE fname like '%成品仓%' AND FForbidStatus='A' AND FDocumentStatus='C' AND FUseOrgId={stocks3["StockOrgId_Id"]}";
var stockList = DBServiceHelper.ExecuteDynamicObject(this.Context, sql2, null, null, CommandType.Text, null);
if (stockList == null || stockList.Count == 0)
{
throw new KDBusinessException("", "所涉及的跨组织单位没有配置成品仓");
}
temStockId = stockList.Select(t => int.Parse(t["FSTOCKID"].ToString())).FirstOrDefault();
stockId = temStockId;
}
var stocks333 = stocks3[pur];
var stocks = stocks333 as DynamicObjectCollection;
var stock0 = stocks.ToList();
stock0.ForEach(t =>
{
t["StockID_Id"] = temStockId;
});
//if (stock0.Count > 0)
//{
// var others= stocks.Where(t => int.Parse(t["StockID_Id"].ToString()) != 0).ToList();
// if (others.Count == 0)
// {
// throw new KDBusinessException("", "上查关联的跨组织的采购订单明细全部没有配置仓库" );
// }
// var other2 = others.Select(t => t["StockId"]).ToList();
// var json1 = JsonHelper.ToJson(other2);
// List<PUR_ReceiveEntryStockId> other3 = JsonHelper.ToObject<List<PUR_ReceiveEntryStockId>>(json1);
// var other4 = other3.Where(t => t.Name.FirstOrDefault().Value.Contains("成品仓")).ToList();
// if (other4.Count > 0)
// {
// stockId = other4.Select(t => t.Id).FirstOrDefault();
// }
// else
// {
// stockId = other3.Select(t => t.Id).FirstOrDefault();
// }
// stock0.ForEach(t =>
// {
// t["StockID_Id"] = stockId;
// });
//}
}
if (target == "SAL_DELIVERYNOTICE")//采购入库单,强制没有配置仓库的物料进成品仓库
{
//throw new KDBusinessException("","还没开发好");
//var sheet = destObjs.FirstOrDefault(); PUR_ReceiveEntry
string pur = ("SAL_DELIVERYNOTICEENTRY");
var stocks3 = destObjs[0];
var stocks333 = stocks3[pur];
var stocks = stocks333 as DynamicObjectCollection;
var stock0 = stocks.ToList();
stock0.ForEach(t =>
{
t["StockID_Id"] = temStockId;
});
}
//根据实际情况，处理目标单据数据
//destObjs[0]["Date"] = Convert.ToDateTime(sDate);
//DynamicObjectCollection col_FEntityDetail;
//var sdsas = JsonHelper.ToJson(destObjs);
//Logger.Error("目标单据数据集合", sdsas, new Exception());
333
2025-04-22 19:17:14 +08:00
//this.View.ShowMessage("好了好了，就是这个按钮");
22
2025-04-23 19:57:13 +08:00
333
2025-04-22 19:17:14 +08:00
//return result;
////if (target == "SAL_OUTSTOCK")//销售出库
////{
//col_FEntityDetail = destObjs[0]["SAL_OUTSTOCKENTRY"] as DynamicObjectCollection;
////}
////else
////{//销售退货
//// col_FEntityDetail = destObjs[0]["SAL_RETURNSTOCKENTRY"] as DynamicObjectCollection;
////}
//#region
//long sStockOrgID = 0;
//sStockOrgID = Convert.ToInt64(destObjs[0]["StockOrgId_Id"]);
//foreach (var item in col_FEntityDetail)
//{
// //item["KeeperID_Id"] = item["OwnerID_Id"];//保管者
// string sStockSql = "select FOrgStockId from v_BusinessOrgId where FORGID= " + sStockOrgID + " ";
// sStockSql = String.Format(@"/*dialect*/" + sStockSql);
// var dt = DBServiceHelper.ExecuteDynamicObject(this.Context, sStockSql);
// //if (dt.Count > 0 && Convert.ToInt64(dt[0]["FOrgStockId"]) != 0)
// if (dt.Count > 0)
// {
// //var targetBillMeta = ServiceHelper.GetService<IMetaDataService>().Load(this.Context, target) as FormMetadata;
// //BusinessInfo info = targetBillMeta.BusinessInfo;
// //BaseDataField stockFld = info.GetField("FStockId") as BaseDataField;
// //long stockId = Convert.ToInt64(dt[0]["FOrgStockId"]);
// //IViewService viewService = ServiceHelper.GetService<IViewService>();
// //DynamicObject[] stockObjs = viewService.LoadFromCache(this.Context, new object[] { stockId }, stockFld.RefFormDynamicObjectType);
// //stockFld.RefIDDynamicProperty.SetValue(item, stockId);
// //stockFld.DynamicProperty.SetValue(item, stockObjs[0]);
// item["StockID_Id"] = Convert.ToInt64(dt[0]["FOrgStockId"]);
// }
//}
//#endregion
////目标单元数据
FormMetadata destFormMetadata = ServiceHelper.GetService<IMetaDataService>().Load(this.Context, target) as FormMetadata;
////保存目标单据
IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
////合并保存操作结果
//result.MergeResult(saveResult);
//根据操作结果构造返回结果
if ((saveResult.ValidationErrors != null && saveResult.ValidationErrors.Count > 0))
//|| (result.OperateResult != null && result.OperateResult.Count > 0))
1
2025-04-18 13:42:20 +08:00
{
333
2025-04-22 19:17:14 +08:00
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);
}
22
2025-04-23 19:57:13 +08:00
result = saveResult;
333
2025-04-22 19:17:14 +08:00
//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("", "未知原因导致自动提交失败！");
1
2025-04-18 13:42:20 +08:00
}
333
2025-04-22 19:17:14 +08:00
//设置审核参数
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)
{
22
2025-04-23 19:57:13 +08:00
Logger.Error("跨组织下推订单报错", "跨组织下推订单报错 error:" + ex.Message + ex.StackTrace, ex);
333
2025-04-22 19:17:14 +08:00
throw ex;
}
}
private IOperationResult Invoke2(string source, string target, string tempFid, string sargetBillTypeId)
{
try
{
IOperationResult result = new OperationResult();
//获取单据转换规则
ConvertRuleElement ruleElement = ServiceHelper.GetService<IConvertService>().GetConvertRules(this.Context, source, target).FirstOrDefault();
//如下代码 直接通过查询数据库获取单据转换源单数据
ListSelectedRowCollection rows = new ListSelectedRowCollection();
int i = 0;
ListSelectedRow row = new ListSelectedRow(tempFid, string.Empty, i++, source);
rows.Add(row);
1
2025-04-18 13:42:20 +08:00
PushArgs pushArgs = new PushArgs(ruleElement, rows.ToArray());
pushArgs.TargetBillTypeId = sargetBillTypeId;//单据类型
//转换生成目标单
ConvertOperationResult convertResult = ServiceHelper.GetService<IConvertService>().Push(this.Context, pushArgs);
1
2025-04-22 11:34:03 +08:00
1
2025-04-18 13:42:20 +08:00
////合并转换操作结果
//result.MergeResult(convertResult);
////目标单据数据集合
DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray();
//根据实际情况，处理目标单据数据
//destObjs[0]["Date"] = Convert.ToDateTime(sDate);
DynamicObjectCollection col_FEntityDetail;
1
2025-04-22 11:34:03 +08:00
var sdsas= JsonHelper.ToJson(destObjs);
Logger.Error("目标单据数据集合", sdsas, new Exception ());
this.View.ShowMessage("好了好了，就是这个按钮");
//return result;
1
2025-04-18 13:42:20 +08:00
////if (target == "SAL_OUTSTOCK")//销售出库
////{
//col_FEntityDetail = destObjs[0]["SAL_OUTSTOCKENTRY"] as DynamicObjectCollection;
////}
////else
////{//销售退货
//// col_FEntityDetail = destObjs[0]["SAL_RETURNSTOCKENTRY"] as DynamicObjectCollection;
////}
//#region
//long sStockOrgID = 0;
//sStockOrgID = Convert.ToInt64(destObjs[0]["StockOrgId_Id"]);
//foreach (var item in col_FEntityDetail)
//{
// //item["KeeperID_Id"] = item["OwnerID_Id"];//保管者
// string sStockSql = "select FOrgStockId from v_BusinessOrgId where FORGID= " + sStockOrgID + " ";
// sStockSql = String.Format(@"/*dialect*/" + sStockSql);
// var dt = DBServiceHelper.ExecuteDynamicObject(this.Context, sStockSql);
// //if (dt.Count > 0 && Convert.ToInt64(dt[0]["FOrgStockId"]) != 0)
// if (dt.Count > 0)
// {
// //var targetBillMeta = ServiceHelper.GetService<IMetaDataService>().Load(this.Context, target) as FormMetadata;
// //BusinessInfo info = targetBillMeta.BusinessInfo;
// //BaseDataField stockFld = info.GetField("FStockId") as BaseDataField;
// //long stockId = Convert.ToInt64(dt[0]["FOrgStockId"]);
// //IViewService viewService = ServiceHelper.GetService<IViewService>();
// //DynamicObject[] stockObjs = viewService.LoadFromCache(this.Context, new object[] { stockId }, stockFld.RefFormDynamicObjectType);
// //stockFld.RefIDDynamicProperty.SetValue(item, stockId);
// //stockFld.DynamicProperty.SetValue(item, stockObjs[0]);
// item["StockID_Id"] = Convert.ToInt64(dt[0]["FOrgStockId"]);
// }
//}
//#endregion
////目标单元数据
FormMetadata destFormMetadata = ServiceHelper.GetService<IMetaDataService>().Load(this.Context, target) as FormMetadata;
////保存目标单据
IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
////合并保存操作结果
//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);
}
1
2025-04-22 11:34:03 +08:00
return result;
1
2025-04-18 13:42:20 +08:00
//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;
}
}
}
}
Reference in New Issue Copy Permalink