yuyubo/Pilot_KD_Parino_yuyubo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

111

Browse Source
This commit is contained in:
余宇波 2025-04-29 19:37:04 +08:00
parent af5743fb96
commit 196be8875a
5 changed files with 425 additions and 257 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
Pilot_KD_Parino/Common/BOSCommon.cs Normal file
View File

@ -0,0 +1,53 @@
using Kingdee.BOS;
using Kingdee.BOS.Core.Metadata.FieldElement;
using Kingdee.BOS.Orm;
using Kingdee.BOS.Orm.DataEntity;
using Kingdee.BOS.Orm.Metadata.DataEntity;
using Kingdee.BOS.Util;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Pilot_KD_Parino.Common
{
public static class BOSCommon
{
/// <summary>
/// 给基础资料赋值
/// </summary>
/// <param name="ctx"></param>
/// <param name="field"></param>
/// <param name="data"></param>
/// <param name="value"></param>
public static void SetBaseDataFieldValue(Context ctx, BaseDataField field, DynamicObject data, object value)
{
long result = 0L;
long.TryParse(value.ToString(), out result);
if ((value.ToString().Length > 1) || (result > 0L))
{
DynamicObject newValue = LoadReferenceData(ctx, field.RefFormDynamicObjectType, value);
field.DynamicProperty.SetValue(data, newValue);
field.RefIDDynamicProperty.SetValue(data, value);
}
else
{
field.DynamicProperty.SetValue(data, null);
field.RefIDDynamicProperty.SetValue(data, 0);
}
}
public static DynamicObject LoadReferenceData(Context ctx, DynamicObjectType dt, object pkValue)
{
if (pkValue.IsEmptyPrimaryKey())
{
return null;
}
OperateOption option = OperateOption.Create();
option.SetThrowExceptionWhenNotFind(false);
return Kingdee.BOS.ServiceHelper.BusinessDataServiceHelper.LoadSingle(ctx, pkValue, dt, option);
}
}
}

3
Pilot_KD_Parino/Pilot_KD_Parino.csproj
View File

@ -310,6 +310,7 @@
</Reference> </Reference>
</ItemGroup> </ItemGroup>
<ItemGroup> <ItemGroup>
<Compile Include="Common\BOSCommon.cs" />
<Compile Include="Common\CombinaAddClass1.cs" /> <Compile Include="Common\CombinaAddClass1.cs" />
<Compile Include="Common\CombinaClass.cs" /> <Compile Include="Common\CombinaClass.cs" />
<Compile Include="Common\CombinationGenerator_yuyubo.cs" /> <Compile Include="Common\CombinationGenerator_yuyubo.cs" />
@ -333,9 +334,9 @@
<Compile Include="QPHY_AutoWrire\SearchWriteRecord.cs" /> <Compile Include="QPHY_AutoWrire\SearchWriteRecord.cs" />
<Compile Include="ReceivablesDetails\ReceivablesPlugIn.cs" /> <Compile Include="ReceivablesDetails\ReceivablesPlugIn.cs" />
<Compile Include="Sal_Order\Bill.cs" /> <Compile Include="Sal_Order\Bill.cs" />
<Compile Include="Sal_Order\PUR_ReceiveEntryStockId.cs" />
<Compile Include="Sal_Order\PushSaleBillPlugIn.cs" /> <Compile Include="Sal_Order\PushSaleBillPlugIn.cs" />
<Compile Include="Sal_Order\PushSaleOutBillPlugIn.cs" /> <Compile Include="Sal_Order\PushSaleOutBillPlugIn.cs" />
<Compile Include="Sal_Order\SupplierClass.cs" />
<Compile Include="Sal_Order\YJAuditPlugIn.cs" /> <Compile Include="Sal_Order\YJAuditPlugIn.cs" />
<Compile Include="SQL\SqlManage_yuyubo.cs" /> <Compile Include="SQL\SqlManage_yuyubo.cs" />
<Compile Include="SQL\SqlManage.cs" /> <Compile Include="SQL\SqlManage.cs" />

465
Pilot_KD_Parino/Sal_Order/PushSaleBillPlugIn.cs
View File

@ -1,28 +1,23 @@
using DevExpress.Xpo.DB.Helpers; using Kingdee.BOS;
using FarPoint.Excel;
using Kingdee.BOS;
using Kingdee.BOS.App; using Kingdee.BOS.App;
using Kingdee.BOS.App.Data;
using Kingdee.BOS.Contracts; using Kingdee.BOS.Contracts;
using Kingdee.BOS.Core.DynamicForm; using Kingdee.BOS.Core.DynamicForm;
using Kingdee.BOS.Core.DynamicForm.Operation; using Kingdee.BOS.Core.DynamicForm.Operation;
using Kingdee.BOS.Core.DynamicForm.PlugIn; using Kingdee.BOS.Core.DynamicForm.PlugIn;
using Kingdee.BOS.Core.DynamicForm.PlugIn.Args; using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
using Kingdee.BOS.Core.List; using Kingdee.BOS.Core.List;
using Kingdee.BOS.Core.List.PlugIn;
using Kingdee.BOS.Core.Metadata; using Kingdee.BOS.Core.Metadata;
using Kingdee.BOS.Core.Metadata.ConvertElement; using Kingdee.BOS.Core.Metadata.ConvertElement;
using Kingdee.BOS.Core.Metadata.ConvertElement.ServiceArgs; using Kingdee.BOS.Core.Metadata.ConvertElement.ServiceArgs;
using Kingdee.BOS.Core.Metadata.FormElement; using Kingdee.BOS.Core.Metadata.FieldElement;
using Kingdee.BOS.Core.Metadata.Util;
using Kingdee.BOS.Log; using Kingdee.BOS.Log;
using Kingdee.BOS.Orm; using Kingdee.BOS.Orm;
using Kingdee.BOS.Orm.DataEntity; using Kingdee.BOS.Orm.DataEntity;
using Kingdee.BOS.ServiceHelper; using Kingdee.BOS.ServiceHelper;
using Kingdee.BOS.Util; using Kingdee.BOS.Util;
using Newtonsoft.Json.Linq;
using Pilot_KD_Parino.Common; using Pilot_KD_Parino.Common;
using System; using System;
using System.Collections.Generic;
using System.ComponentModel; using System.ComponentModel;
using System.Data; using System.Data;
using System.Linq; using System.Linq;
@ -39,6 +34,14 @@ namespace Pilot_KD_Parino.Sal_Order
//this.View.ShowMessage("669977"); //this.View.ShowMessage("669977");
if (e.BarItemKey.Equals("tbSaleBill333", StringComparison.OrdinalIgnoreCase))
{
var FEntity = this.View.Model.DataObject;
var json = JsonUtil.Serialize(FEntity);
Logger.Error("采购订单信息", json, new Exception());
//var id = FEntity["id"];
//string formid = FEntity["FFormId"].ToString();
}
if (e.BarItemKey.Equals("tbSaleBill222", StringComparison.OrdinalIgnoreCase)) if (e.BarItemKey.Equals("tbSaleBill222", StringComparison.OrdinalIgnoreCase))
{ {
var FEntity = this.View.Model.DataObject; var FEntity = this.View.Model.DataObject;
@ -49,96 +52,48 @@ namespace Pilot_KD_Parino.Sal_Order
int stockId = 0; int stockId = 0;
IOperationResult result = Invoke("SAL_SaleOrder", "PUR_PurchaseOrder", id.ToString(), "7cd93c259999489c97798063f2f7bd70", ref stockId); //IOperationResult result = Invoke("SAL_SaleOrder", "d124a6be-5f97-4d1f-b5fd-e20e53e0ed2a", id.ToString(), "83d822ca3e374b4ab01e5dd46a0062bd", ref stockId);
IOperationResult result = Invoke("SAL_SaleOrder", "PUR_PurchaseOrder", id.ToString(), "83d822ca3e374b4ab01e5dd46a0062bd", ref stockId, FEntity, null);
var sheet = result.SuccessDataEnity.FirstOrDefault(); var sheet = result.SuccessDataEnity.FirstOrDefault();
string jsonsheet = JsonHelper.ToJson(sheet); string id2 = sheet["id"].ToString();
//Logger.Error("推送采购入库单",jsonsheet,null);
if (sheet != null)
{
result = Invoke("PUR_ReceiveBill", "STK_InStock", sheet["id"].ToString(), "a1ff32276cd9469dad3bf2494366fa4f", ref stockId);
result = Invoke("PUR_PurchaseOrder", "SAL_SaleOrder", id2, "5eaf7dde-df05-4c11-accd-3a175f117968", ref stockId, sheet, FEntity);
//sheet = result.SuccessDataEnity.FirstOrDefault(); //sheet = result.SuccessDataEnity.FirstOrDefault();
//result = Invoke("PUR_ReceiveBill", "STK_InStock", sheet["id"].ToString(), "a1ff32276cd9469dad3bf2494366fa4f"); //result = Invoke("SAL_DELIVERYNOTICE", "SAL_OUTSTOCK", sheet["id"].ToString(), "ad0779a4685a43a08f08d2e42d7bf3e9", ref stockId);
}
//找到最开始的销售订单
for (int kk = 0; kk < 6 && tablename.ToUpper() != "T_SAL_ORDERENTRY"; 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("没有上查关联的跨组织的采购订单");
return;
}
else
{
tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
}
tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
}
if (tablename.ToUpper() != "T_SAL_ORDERENTRY")
{
throw new KDBusinessException("", "推送销售发货通知单失败,没有上查关联的跨组织的销售订单：" + tablename);
}
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("跨组织下推订单完成"); this.View.ShowMessage("跨组织下推订单完成");
//this.View.ShowMessage("就是这个按钮"+ id);
//ListSelectedRowCollection rows =new ListSelectedRowCollection();
//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("生成对应系列的分布式调出单完成！！！");
//}
} }
} }
/// <summary>
private IOperationResult Invoke(string source, string target, string tempFid, string sargetBillTypeId, ref int stockId) ///
/// </summary>
/// <param name="source"></param>
/// <param name="target"></param>
/// <param name="tempFid"></param>
/// <param name="sargetBillTypeId"></param>
/// <param name="stockId"></param>
/// <param name="FEntity">本次操作页面的对象</param>
/// <param name="FEntity2">最开始的销售单对象</param>
/// <returns></returns>
private IOperationResult Invoke(string source, string target, string tempFid, string sargetBillTypeId, ref int stockId, DynamicObject FEntity, DynamicObject FEntity2)
{ {
try try
{ {
IOperationResult result = new OperationResult(); IOperationResult result = new OperationResult();
//获取单据转换规则 //获取单据转换规则
ConvertRuleElement ruleElement = ServiceHelper.GetService<IConvertService>().GetConvertRules(this.Context, source, target).FirstOrDefault(); ConvertRuleElement ruleElement;
if (target == "PUR_PurchaseOrder")
{
var ruleMetaData = ConvertServiceHelper.GetConvertRule(this.Context, "d124a6be-5f97-4d1f-b5fd-e20e53e0ed2a");
ruleElement = ruleMetaData.Rule;
}
else
ruleElement = ServiceHelper.GetService<IConvertService>().GetConvertRules(this.Context, source, target).FirstOrDefault();
//如下代码 直接通过查询数据库获取单据转换源单数据 //如下代码 直接通过查询数据库获取单据转换源单数据
ListSelectedRowCollection rows = new ListSelectedRowCollection(); ListSelectedRowCollection rows = new ListSelectedRowCollection();
int i = 0; int i = 0;
@ -150,8 +105,7 @@ namespace Pilot_KD_Parino.Sal_Order
//转换生成目标单 //转换生成目标单
ConvertOperationResult convertResult = ServiceHelper.GetService<IConvertService>().Push(this.Context, pushArgs); ConvertOperationResult convertResult = ServiceHelper.GetService<IConvertService>().Push(this.Context, pushArgs);
////合并转换操作结果
//result.MergeResult(convertResult);
////目标单据数据集合 ////目标单据数据集合
DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray(); DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray();
@ -159,6 +113,166 @@ namespace Pilot_KD_Parino.Sal_Order
var sdsas = JsonHelper.ToJson(destObjs); var sdsas = JsonHelper.ToJson(destObjs);
Logger.Error("目标单据数据集合", sdsas, new Exception()); Logger.Error("目标单据数据集合", sdsas, new Exception());
int temStockId = stockId; int temStockId = stockId;
//采购订单 1 采购类型=02 生产物资采购 供应商=珠海兴诺能源技术有限公司
string SupplierId_Id = "";
string number = "";
string name = "";
if (target == "PUR_PurchaseOrder")
{
var beiHuoName1 = FEntity["F_SaleOrgId"] as DynamicObject;
string SaleOrgId_Id = FEntity["SaleOrgId_Id"].ToString();
if (beiHuoName1 != null)
{
var beiHuoName2 = beiHuoName1["MultiLanguageText"] as DynamicObjectCollection;
if (beiHuoName2 != null && beiHuoName2.Count() > 0)
{
var beiHuoName3 = beiHuoName2[0]["Name"].ToString();
string sqltemp1 = $@"/*dialect*/ SELECT FUseOrgId,a.FNUMBER,b.FNAME,a.FSUPPLIERID FROM T_BD_SUPPLIER a
LEFT JOIN T_BD_SUPPLIER_L b ON a.FSUPPLIERID=b.FSUPPLIERID
WHERE FUseOrgId={SaleOrgId_Id} AND FNAME LIKE '%{beiHuoName3}%' ";
var supplierList = DBServiceHelper.ExecuteDynamicObject(this.Context, sqltemp1, null, null, CommandType.Text, null);
if (supplierList != null && supplierList.Count > 0)
{
var orderSheet = destObjs[0];
DynamicObject supplierObj = null;//.Select(t => t["FSUPPLIERID"].ToString())
if (beiHuoName3 == "珠海兴诺")
{
supplierObj = supplierList.Where(t => t["FNAME"].ToString() == "珠海兴诺能源技术有限公司").FirstOrDefault();
}
if (beiHuoName3 == "珠海派诺")
{
supplierObj = supplierList.Where(t => t["FNAME"].ToString() == "珠海派诺科技股份有限公司").FirstOrDefault();
}
else
{
supplierObj = supplierList.FirstOrDefault();
}
SupplierId_Id = supplierObj["FSUPPLIERID"].ToString();
orderSheet["SupplierId_Id"] = SupplierId_Id;
number = supplierObj["FNUMBER"].ToString();
name = supplierObj["FNAME"].ToString();
SupplierClass supplier = new SupplierClass();
supplier.Id = int.Parse(SupplierId_Id);
supplier.Number = number;
supplier.UseOrgId_Id = int.Parse(SaleOrgId_Id);
//string json2= JsonHelper.ToJson(supplier);
//采购类型
/**
* SELECT * FROM dbo.T_BAS_ASSISTANTDATAENTRY_l
WHERE FENTRYID IN ( SELECT FENTRYID FROM dbo.T_BAS_ASSISTANTDATAENTRY
WHERE fid='6736e9ea1d1dcb')
*/
orderSheet["F_Procurementtype_Id"] = "6736ea151d1dcf"; //采购类型
//明细价税合计 AllAmount_LC 税率 TaxRate POOrderEntry
var detailList = (orderSheet["POOrderEntry"] as DynamicObjectCollection).ToList();
var saleDetailList = (FEntity["SaleOrderEntry"] as DynamicObjectCollection).ToList();
if (detailList != null && detailList.Count > 0)
{
detailList.ForEach(t =>
{
var dasda = t["Qty"].ToString();
decimal qty = decimal.Parse(dasda);
var tempOne = saleDetailList.Where(h => h["MaterialId_Id"].ToString() == t["MaterialId_Id"].ToString()
&& decimal.Parse(h["Qty"].ToString()) == qty).FirstOrDefault();
if (tempOne != null)
{
t["Price"] = tempOne["Price"];
t["AllAmount_LC"] = tempOne["AllAmount_LC"];
t["AllAmount"] = tempOne["AllAmount"];
t["TaxPrice"] = tempOne["TaxPrice"];
t["TaxRate"] = tempOne["TaxRate"];
t["TaxAmount"] = tempOne["TaxAmount"];
t["Amount"] = tempOne["Amount"];
}
});
}
//this.View.ShowMessage($@"{beiHuoName3}备货组织跨组织下推订单完成");
}
else
{
throw new KDBusinessException("", $@"{beiHuoName3}备货组织没有对应的同名供应商,无法跨组织推送采购订单");
}
}
else
{
throw new KDBusinessException("", $@"备货组织没有值");
}
}
else
throw new KDBusinessException("", "推送跨组织采购订单必须选择备货组织");
}
if (target == "SAL_SaleOrder")
{
//客户，销售员，是否海外
var beiHuoName1 = FEntity2["SaleOrgId"] as DynamicObject;
string SaleOrgId_Id = FEntity2["SaleOrgId_Id"].ToString();
if (beiHuoName1 != null)
{
//通过上游销售单的销售组织找到对应的客户
var beiHuoName2 = beiHuoName1["MultiLanguageText"] as DynamicObjectCollection;
if (beiHuoName2 != null && beiHuoName2.Count() > 0)
{
var beiHuoName3 = beiHuoName2[0]["Name"].ToString();
var orderSheet = destObjs[0];
orderSheet["SaleOrgId_Id"] = SaleOrgId_Id;
orderSheet["F_SFHW"] = "2";
SupplierId_Id = orderSheet["SaleOrgId_Id"].ToString();
string sqltemp1 = $@"/*dialect*/ SELECT FUseOrgId,a.FNUMBER,b.FNAME,a.FCUSTID FROM T_BD_CUSTOMER a
LEFT JOIN T_BD_CUSTOMER_L b ON a.FCUSTID=b.FCUSTID
WHERE FUseOrgId={SupplierId_Id} AND FNAME LIKE '%{beiHuoName3}%' ";
var keHuList = DBServiceHelper.ExecuteDynamicObject(this.Context, sqltemp1, null, null, CommandType.Text, null);
if (keHuList != null && keHuList.Count > 0)
{
DynamicObject supplierObj = null;//.Select(t => t["FSUPPLIERID"].ToString())
if (beiHuoName3 == "珠海兴诺")
{
supplierObj = keHuList.Where(t => t["FNAME"].ToString() == "珠海兴诺国际能源有限公司").FirstOrDefault();
}
if (beiHuoName3 == "珠海派诺")
{
supplierObj = keHuList.Where(t => t["FNAME"].ToString() == "珠海派诺科技股份有限公司").FirstOrDefault();
}
else
{
supplierObj = keHuList.FirstOrDefault();
}
SupplierId_Id = supplierObj["FCUSTID"].ToString();
orderSheet["CustId_Id"] = SupplierId_Id;
number = supplierObj["FNUMBER"].ToString();
name = supplierObj["FNAME"].ToString();
}
}
}//F_SFHW
}
if (target == "PUR_ReceiveBill")//收料通知单,强制没有配置仓库的物料进成品仓库 if (target == "PUR_ReceiveBill")//收料通知单,强制没有配置仓库的物料进成品仓库
{ {
//var sheet = destObjs.FirstOrDefault(); PUR_ReceiveEntry //var sheet = destObjs.FirstOrDefault(); PUR_ReceiveEntry
@ -167,7 +281,8 @@ namespace Pilot_KD_Parino.Sal_Order
if (temStockId == 0) if (temStockId == 0)
{ {
string sql2 = $@"/*dialect*/ SELECT FUseOrgId,fname, a.FSTOCKID,FForbidStatus,FDocumentStatus FROM T_BD_STOCK a 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 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"]}"; 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); var stockList = DBServiceHelper.ExecuteDynamicObject(this.Context, sql2, null, null, CommandType.Text, null);
@ -239,55 +354,33 @@ namespace Pilot_KD_Parino.Sal_Order
} }
//根据实际情况，处理目标单据数据
//destObjs[0]["Date"] = Convert.ToDateTime(sDate);
//DynamicObjectCollection col_FEntityDetail;
//var sdsas = JsonHelper.ToJson(destObjs);
//Logger.Error("目标单据数据集合", sdsas, new Exception());
//this.View.ShowMessage("好了好了，就是这个按钮");
//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; FormMetadata destFormMetadata = ServiceHelper.GetService<IMetaDataService>().Load(this.Context, target) as FormMetadata;
//sdsas = JsonHelper.ToJson(destObjs);
//Logger.Error("目标单据数据集合3", sdsas, new Exception());
//destFormMetadata.BusinessInfo.Entrys.ForEach(t => );
if (target == "PUR_PurchaseOrder")
{
destObjs[0]["SupplierId"] = BusinessDataServiceHelper.LoadSingle(this.Context, SupplierId_Id, (destFormMetadata.BusinessInfo.GetField("FSupplierId") as BaseDataField).RefFormDynamicObjectType);
}
if (target == "SAL_SaleOrder")
{
destObjs[0]["SaleOrgId"] = BusinessDataServiceHelper.LoadSingle(this.Context, FEntity2["SaleOrgId_Id"].ToString(), (destFormMetadata.BusinessInfo.GetField("FSaleOrgId") as BaseDataField).RefFormDynamicObjectType);
destObjs[0]["CustId"] = BusinessDataServiceHelper.LoadSingle(this.Context, SupplierId_Id, (destFormMetadata.BusinessInfo.GetField("FCustId") as BaseDataField).RefFormDynamicObjectType);
}
//Logger.Error("目标单据数据集合3", sdsas, new Exception());
IOperationResult saveResult2 = BusinessDataServiceHelper.Draft(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
//var ddd = (from p in destObjs select p[0]).ToArray();
//var ddd = saveResult2.SuccessDataEnity.Select(t => t).ToArray();
//sdsas = JsonHelper.ToJson(ddd);
//Logger.Error("目标单据数据集合4", sdsas, new Exception());
////保存目标单据 ////保存目标单据
IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create()); IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
////合并保存操作结果 ////合并保存操作结果
@ -334,123 +427,7 @@ namespace Pilot_KD_Parino.Sal_Order
} }
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);
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();
//根据实际情况，处理目标单据数据
//destObjs[0]["Date"] = Convert.ToDateTime(sDate);
DynamicObjectCollection col_FEntityDetail;
var sdsas= JsonHelper.ToJson(destObjs);
Logger.Error("目标单据数据集合", sdsas, new Exception ());
this.View.ShowMessage("好了好了，就是这个按钮");
//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))
{
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);
}
return result;
//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;
}
}
} }
} }

2
Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs
View File

@ -92,9 +92,7 @@ namespace Pilot_KD_Parino.Sal_Order
} }
if (tablename.ToUpper() != "T_PUR_POORDERENTRY") if (tablename.ToUpper() != "T_PUR_POORDERENTRY")
{ {
throw new KDBusinessException("", "没有上查关联的跨组织的采购订单：" + tablename); throw new KDBusinessException("", "没有上查关联的跨组织的采购订单：" + tablename);
} }
int stockId = 0; int stockId = 0;

139
Pilot_KD_Parino/Sal_Order/SupplierClass.cs Normal file
View File

@ -0,0 +1,139 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Pilot_KD_Parino.Sal_Order
{
public class SupplierClass
{
/// <summary>
///
/// </summary>
public string DirtyFlags { get; set; }
/// <summary>
///
/// </summary>
public string FromDatabase { get; set; }
/// <summary>
///
/// </summary>
public int Id { get; set; }
/// <summary>
///
/// </summary>
public int msterID { get; set; }
/// <summary>
///
/// </summary>
public List<MultiLanguageTextItem> MultiLanguageText { get; set; }
/// <summary>
///
/// </summary>
public List<NameItem> Name { get; set; }
/// <summary>
///
/// </summary>
public string Number { get; set; }
/// <summary>
///
/// </summary>
public int UseOrgId_Id { get; set; }
/// <summary>
///
/// </summary>
public UseOrgId UseOrgId { get; set; }
}
public class MultiLanguageTextItem
{
/// <summary>
///
/// </summary>
public string DirtyFlags { get; set; }
/// <summary>
///
/// </summary>
public string FromDatabase { get; set; }
/// <summary>
///
/// </summary>
public int PkId { get; set; }
/// <summary>
///
/// </summary>
public int LocaleId { get; set; }
/// <summary>
/// 珠海兴诺能源技术有限公司
/// </summary>
public string Name { get; set; }
}
public class NameItem
{
/// <summary>
///
/// </summary>
public int Key { get; set; }
/// <summary>
/// 珠海兴诺能源技术有限公司
/// </summary>
public string Value { get; set; }
}
public class SnapshotsItem
{
/// <summary>
///
/// </summary>
public string TableName { get; set; }
/// <summary>
///
/// </summary>
public string Oids { get; set; }
/// <summary>
///
/// </summary>
public string OidType { get; set; }
}
public class UseOrgId
{
/// <summary>
///
/// </summary>
public string DirtyFlags { get; set; }
/// <summary>
///
/// </summary>
public List<SnapshotsItem> Snapshots { get; set; }
/// <summary>
///
/// </summary>
public string FromDatabase { get; set; }
/// <summary>
///
/// </summary>
public int Id { get; set; }
/// <summary>
///
/// </summary>
public string Number { get; set; }
/// <summary>
///
/// </summary>
public List<MultiLanguageTextItem> MultiLanguageText { get; set; }
/// <summary>
///
/// </summary>
public List<NameItem> Name { get; set; }
}
}