Develop/GateDge2023_ljy
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

g

Browse Source
This commit is contained in:
PastSaid
2023-12-20 22:26:30 +08:00
parent fe71b6365c
commit 4a98ba6946
15 changed files with 975 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

74
CY.SAL_OUTSTOCK/AutoPushLostOutStock2Pay.cs
View File

@@ -18,6 +18,9 @@ using Kingdee.BOS.Orm.DataEntity;
using Kingdee.BOS.Core.BusinessFlow.ServiceArgs;
using Kingdee.BOS.Core.Metadata;
using Kingdee.BOS.App.Core.ScheduleService;
using Kingdee.BOS.App;
using Kingdee.BOS.Core.DynamicForm;
using Kingdee.BOS.Log;
namespace CY.SAL_OUTSTOCK
{
@@ -26,62 +29,79 @@ namespace CY.SAL_OUTSTOCK
{
public void Run(Context ctx, Schedule schedule)
{
Logger.Info(schedule.Name, $"销售出库单自动下推应付单start...");
var succeedNum = 0;
var failNum = 0;
try
{
IConvertService service = Kingdee.BOS.App.ServiceHelper.GetService<IConvertService>();
IConvertService service = ServiceHelper.GetService<IConvertService>();
//源单据标识
string sourceFormId = "SAL_OUTSTOCK";
//目标单据标识
string targetFormId = "AR_RECEIVABLE";
//var rules = service.GetConvertRules(ctx, sourceFormId, targetFormId);
//目标单据类型id-标准应收单
string targetBillTypeId = "180ecd4afd5d44b5be78a6efe4a7e041";
//转换规则
string convertRuleId = "AR_OutStockToReceivableMap"; //销售出库单下推应付单
var ruleMeta = service.GetConvertRule(ctx, convertRuleId);
var rule = ruleMeta.Rule;
var dbList = GetDBData(ctx);
if (dbList != null && dbList.Any())
{
var groupbyList = dbList.GroupBy(x => x["FBILLNO"]);
StringBuilder stringBuilder = new StringBuilder();
var groupbyList = dbList.GroupBy(x => x["FBILLNO"].ToString());
Logger.Info(schedule.Name, $"找到{groupbyList.Count()}条数据");
foreach (var list in groupbyList)
{
List<ListSelectedRow> selectedRows = list.Select(x => new ListSelectedRow(x["FID"].ToString(), x["FENTRYID"].ToString(), 0, sourceFormId)).ToList();
PushArgs pushArgs = new PushArgs(rule, selectedRows.ToArray());//下推入口参数
pushArgs.TargetBillTypeId = targetBillTypeId;
OperateOption option = OperateOption.Create();//选项参数
try
{
List<ListSelectedRow> selectedRows = list.Select(x => new ListSelectedRow(x["FID"].ToString(), x["FENTRYID"].ToString(), 0, sourceFormId)).ToList();
ConvertOperationResult convertResult = service.Push(ctx, pushArgs, option);
PushArgs pushArgs = new PushArgs(rule, selectedRows.ToArray());//下推入口参数
DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray();
OperateOption option = OperateOption.Create();//选项参数
FormMetadata destFormMetadata = ServiceHelper.GetService<IMetaDataService>().Load(ctx, targetFormId) as FormMetadata;
ConvertOperationResult result = service.Push(ctx, pushArgs, option);
IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(ctx, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
if (saveResult.ValidationErrors != null && saveResult.ValidationErrors.Count > 0)
{
var errorInfo = string.Join(";", saveResult.ValidationErrors.Select(x => x.Message));
throw new KDBusinessException("", "未知原因导致自动保存失败原因：" + errorInfo);
}
else
{
succeedNum++;
Logger.Info(schedule.Name, $"销售出库单:{list.Key}下推应付单:{saveResult.OperateResult[0].Number}成功！");
}
}
catch (Exception ex)
catch (KDBusinessException ex)
{
stringBuilder.AppendLine($"单据:{list.Key}下推失败");
failNum++;
Logger.Error($"服务器插件：{schedule.Name}", $"销售出库单:{list.Key}", ex);
}
}
if (stringBuilder.IsNullOrEmpty())
throw new Exception(stringBuilder.ToString());
}
}
catch (Exception ex)
{
ScheduleMsgDal _msgDal = new ScheduleMsgDal();
ScheduleMsg msg = new ScheduleMsg();
msg.MsgDetail = ex.Message;
msg.HappenTime = DateTime.Now;
msg.MsgType = 5;// 1 成功 5异常，
msg.ScheduleTypeId = schedule.ScheduleTypeId;
_msgDal.InsertScheduleMsg(ctx, msg);
Logger.Error($"服务器插件：{schedule.Name}", ex.Message, ex);
}
finally
{
Logger.Info(schedule.Name, $"成功{succeedNum}条,失败{failNum}条");
Logger.Info(schedule.Name, $"销售出库单自动下推应付单end...");
}
}

5
CY.SAL_OUTSTOCK/CY.SAL_OUTSTOCK.csproj
View File

@@ -49,6 +49,10 @@
<Reference Include="Kingdee.BOS.DataEntity">
<HintPath>..\..\..\..\..\Program Files (x86)\Kingdee\K3Cloud\WebSite\bin\Kingdee.BOS.DataEntity.dll</HintPath>
</Reference>
<Reference Include="Kingdee.BOS.ServiceHelper, Version=8.1.571.1, Culture=neutral, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
<HintPath>..\..\..\..\..\Program Files (x86)\Kingdee\K3Cloud\WebSite\bin\Kingdee.BOS.ServiceHelper.dll</HintPath>
</Reference>
<Reference Include="Kingdee.K3.BD.Contracts">
<HintPath>..\..\..\..\..\Program Files (x86)\Kingdee\K3Cloud\WebSite\bin\Kingdee.K3.BD.Contracts.dll</HintPath>
</Reference>
@@ -64,6 +68,7 @@
<ItemGroup>
<Compile Include="AutoPushLostOutStock2Pay.cs" />
<Compile Include="Properties\AssemblyInfo.cs" />
<Compile Include="TestAutoPushPlugIn.cs" />
</ItemGroup>
<ItemGroup>
<Content Include="SQLServer\无关联应收单.sql" />

195
CY.SAL_OUTSTOCK/PushSaleOutBillPlugIn.cs Normal file
View File

@@ -0,0 +1,195 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Kingdee.BOS;
using Kingdee.BOS.Core.Bill.PlugIn;
using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
using Kingdee.BOS.Core.List;
using Kingdee.BOS.Core.List.PlugIn;
using Kingdee.BOS.ServiceHelper;
using Kingdee.BOS.Util;
using Kingdee.BOS.WebApi.FormService;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System.ComponentModel;
using Kingdee.BOS.Core.DynamicForm;
using Kingdee.BOS.App;
using Kingdee.BOS.Contracts;
using Kingdee.BOS.Core.Metadata;
using Kingdee.BOS.Core.DynamicForm.Operation;
using Kingdee.BOS.Orm.DataEntity;
using Kingdee.BOS.Core.Metadata.ConvertElement.ServiceArgs;
using Kingdee.BOS.Core.Metadata.ConvertElement;
using Kingdee.BOS.Orm;
using Kingdee.BOS.App.Data;
using System.Data;
using Kingdee.BOS.Log;
using Kingdee.BOS.Core.Metadata.FieldElement;
namespace KD.K3.QQSD.PlugIn
{
[Description("批量下推生成销售出库单插件")]
public class PushSaleOutBillPlugIn : AbstractListPlugIn
{
long sScrId = 0;
string sScrBillNo = "";
public override void BarItemClick(BarItemClickEventArgs e)
{
base.BarItemClick(e);
long sOutId = 0;//珠海分布式调出单单号内码
string sOutBillNo = "";//珠海分布式调出单单号
bool flag = true;
string sBillNo = "";
long sEntryId = 0;
long slevel = 2;
long sId = 0;
if (e.BarItemKey == "tbPushSalOut")//批量下推调拨
{
ListSelectedRowCollection rows = this.ListView.SelectedRowsInfo;
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("生成对应系列的分布式调出单完成！！！");
}
}
}
private IOperationResult Invoke(string source, string target, string getSourceSql, 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;
using (IDataReader reader = DBUtils.ExecuteReader(this.Context, getSourceSql))
{
while (reader.Read())
{
ListSelectedRow row = new ListSelectedRow(reader["FID"].ToString(), 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;
//////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);
}
//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
CY.SAL_OUTSTOCK/SQLServer/无关联应收单.sql
View File

@@ -8,7 +8,6 @@ SELECT
,A.FBILLNO
,A.FSTOCKORGID
,AE.FENTRYID
,B.FID
FROM
T_SAL_OUTSTOCK A
LEFT JOIN T_SAL_OUTSTOCKENTRY AE ON A.FID = AE.FID

125
CY.SAL_OUTSTOCK/TestAutoPushPlugIn.cs Normal file
View File

@@ -0,0 +1,125 @@
using Kingdee.BOS.App.Core.ScheduleService;
using Kingdee.BOS.App.Data;
using Kingdee.BOS.Contracts;
using Kingdee.BOS.Core.DynamicForm.Operation;
using Kingdee.BOS.Core.List;
using Kingdee.BOS.Core.Metadata.ConvertElement.ServiceArgs;
using Kingdee.BOS.Core;
using Kingdee.BOS.Orm.DataEntity;
using Kingdee.BOS.Orm;
using Kingdee.BOS.Util;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Kingdee.BOS;
using System.ComponentModel;
using Kingdee.BOS.Core.List.PlugIn;
using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
using Kingdee.BOS.Core.Metadata;
using Kingdee.BOS.ServiceHelper;
using Kingdee.BOS.Core.Metadata.FieldElement;
using Kingdee.BOS.App;
using Kingdee.BOS.Core.DynamicForm;
namespace CY.SAL_OUTSTOCK
{
[Description("测试自动下推功能"), HotUpdate]
public class TestAutoPushPlugIn : AbstractListPlugIn
{
public override void BarItemClick(BarItemClickEventArgs e)
{
base.BarItemClick(e);
if (e.BarItemKey.Equals("tbTestAutoP"))
{
Run(this.Context);
}
}
public void Run(Context ctx)
{
try
{
IConvertService service = Kingdee.BOS.App.ServiceHelper.GetService<IConvertService>();
string sourceFormId = "SAL_OUTSTOCK";
string targetFormId = "AR_RECEIVABLE";
string targetBillTypeId = "180ecd4afd5d44b5be78a6efe4a7e041";
//var rules = service.GetConvertRules(ctx, sourceFormId, targetFormId);
string convertRuleId = "AR_OutStockToReceivableMap"; //销售出库单下推应付单
var ruleMeta = service.GetConvertRule(ctx, convertRuleId);
var rule = ruleMeta.Rule;
var dbList = GetDBData(ctx);
if (dbList != null && dbList.Any())
{
var groupbyList = dbList.GroupBy(x => x["FBILLNO"]);
StringBuilder stringBuilder = new StringBuilder();
foreach (var list in groupbyList)
{
var pkid = dbList.Select(x => x["FID"]).ToArray();
List<ListSelectedRow> selectedRows = list.Select(x => new ListSelectedRow(x["FID"].ToString(), x["FENTRYID"].ToString(), 0, sourceFormId)).ToList();
PushArgs pushArgs = new PushArgs(rule, selectedRows.ToArray());//下推入口参数
pushArgs.TargetBillTypeId = targetBillTypeId;
OperateOption option = OperateOption.Create();//选项参数
try
{
ConvertOperationResult convertResult = service.Push(ctx, pushArgs, option);
DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray();
FormMetadata destFormMetadata = ServiceHelper.GetService<IMetaDataService>().Load(this.Context, targetFormId) as FormMetadata;
IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
if ((saveResult.ValidationErrors != null && saveResult.ValidationErrors.Count > 0))
{
var errorInfo = string.Join(";", saveResult.ValidationErrors.Select(x => x.Message));
throw new KDBusinessException("", "未知原因导致自动保存失败原因：" + errorInfo);
}
}
catch (KDBusinessException ex)
{
stringBuilder.AppendLine($"单据:{list.Key}{ex.GetErrorInfo()}");
}
}
if (!stringBuilder.IsNullOrEmpty())
throw new Exception(stringBuilder.ToString());
}
}
catch (Exception ex)
{
//ScheduleMsgDal _msgDal = new ScheduleMsgDal();
//ScheduleMsg msg = new ScheduleMsg();
//msg.MsgDetail = ex.Message;
//msg.HappenTime = DateTime.Now;
//msg.MsgType = 5;// 1 成功 5异常，
//msg.ScheduleTypeId = schedule.ScheduleTypeId;
//_msgDal.InsertScheduleMsg(ctx, msg);
}
}
private DynamicObjectCollection GetDBData(Context ctx)
{
var unSql = $@"
select * from V_NOT_RECEIVABLE_OUTSTOCK
";
var dbList = DBUtils.ExecuteDynamicObject(ctx, $"/*dialect*/{unSql}");
return dbList;
}
}
}