2

05.长园/CYG/SAL_OutStock/AutoPushLostOutStock2Pay.cs

@@ -0,0 +1,154 @@
+using Kingdee.BOS.App.Data;
+using Kingdee.BOS.App;
+using Kingdee.BOS;
+using Kingdee.BOS.Contracts;
+using Kingdee.BOS.Core.DynamicForm.Operation;
+using Kingdee.BOS.Core.DynamicForm;
+using Kingdee.BOS.Core.List;
+using Kingdee.BOS.Core.Metadata.ConvertElement.ServiceArgs;
+using Kingdee.BOS.Core.Metadata;
+using Kingdee.BOS.Core;
+using Kingdee.BOS.Log;
+using Kingdee.BOS.Orm.DataEntity;
+using Kingdee.BOS.Orm.Exceptions;
+using Kingdee.BOS.Orm;
+using Kingdee.BOS.Util;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel;
+using System.Data.SqlClient;
+using System.Linq;
+using System.Text;
+
+namespace CYG.SAL_OutStock
+{
+    [Description("自动下推"), HotUpdate]
+    public class AutoPushLostOutStock2Pay : IScheduleService
+    {
+        public void Run(Context ctx, Schedule schedule)
+        {
+            Logger.Info(schedule.Name, $"销售出库单自动下推应付单start...");
+            var succeedNum = 0;
+            var failNum = 0;
+            try
+            {
+                IConvertService service = ServiceHelper.GetService<IConvertService>();
+
+                //源单据标识
+                string sourceFormId = "SAL_OUTSTOCK";
+                //目标单据标识
+                string targetFormId = "AR_RECEIVABLE";
+                //目标单据类型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"].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
+                        {
+                            ConvertOperationResult convertResult = service.Push(ctx, pushArgs, option);
+
+                            DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray();
+
+                            FormMetadata destFormMetadata = ServiceHelper.GetService<IMetaDataService>().Load(ctx, targetFormId) as FormMetadata;
+
+                            IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(ctx, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
+
+                            string msg = string.Empty;
+
+                            if (saveResult.ValidationErrors != null && saveResult.ValidationErrors.Count > 0)
+                            {
+                                var errorInfo = string.Join(";", saveResult.ValidationErrors.Select(x => x.Message));
+
+                                throw new KDBusinessException("", "未知原因导致自动保存失败原因：" + errorInfo);
+                            }
+
+                            object[] pkArray = (from p in destObjs select p[0]).ToArray();
+                            //设置提交参数
+                            IOperationResult submitResult = ServiceHelper.GetService<ISubmitService>().Submit(ctx, destFormMetadata.BusinessInfo, pkArray, "Submit", OperateOption.Create());
+
+                            // 判断提交结果，如果失败，则内部会抛出错误，回滚代码
+                            if (submitResult.IsSuccess == false)
+                            {
+                                throw new KDBusinessException("", "未知原因导致自动提交失败！");
+                            }
+
+                            //设置审核参数
+                            IOperationResult auditResult = ServiceHelper.GetService<IAuditService>().Audit(ctx, destFormMetadata.BusinessInfo, pkArray, OperateOption.Create());
+                            // 判断提交结果，如果失败，则内部会抛出错误，回滚代码
+                            if (auditResult.IsSuccess == false)
+                            {
+                                throw new KDBusinessException("", "未知原因导致自动审核失败！");
+                            }
+
+                            succeedNum++;
+                            Logger.Info(schedule.Name, $"销售出库单:{list.Key},下推应付单:{saveResult.OperateResult[0].Number}成功！");
+                        }
+                        catch (OrmException ex)
+                        {
+                            failNum++;
+                            Logger.Error($"服务器插件：{schedule.Name}错误（Orm）", $"销售出库单:{list.Key}", ex);
+                        }
+                        catch (KDBusinessException ex)
+                        {
+                            failNum++;
+                            Logger.Error($"服务器插件：{schedule.Name}错误（KDB）", $"销售出库单:{list.Key}", ex);
+                        }
+                        catch (SqlException ex)
+                        {
+                            failNum++;
+                            Logger.Error($"服务器插件：{schedule.Name}错误（Sql）", $"销售出库单:{list.Key}", ex);
+                        }
+                        catch (Exception ex)
+                        {
+                            failNum++;
+                            Logger.Error($"服务器插件：{schedule.Name}", $"销售出库单:{list.Key}", ex);
+                        }
+                        finally
+                        {
+
+                        }
+                    }
+
+                }
+            }
+            catch (Exception ex)
+            {
+                Logger.Error($"服务器插件：{schedule.Name}", ex.Message, ex);
+            }
+            finally
+            {
+                Logger.Info(schedule.Name, $"成功{succeedNum}条,失败{failNum}条");
+                Logger.Info(schedule.Name, $"销售出库单自动下推应付单end...");
+            }
+        }
+
+
+
+        private DynamicObjectCollection GetDBData(Context ctx)
+        {
+            var unSql = $@"
+SELECT * from V_NOT_RECEIVABLE_OUTSTOCK
+";
+            var dbList = DBUtils.ExecuteDynamicObject(ctx, $"/*dialect*/{unSql}");
+
+            return dbList;
+        }
+    }
+}

05.长园/CYG/SAL_OutStock/SQLServer/SQLQuery4.sql

@@ -0,0 +1,5 @@
+
+UPDATE T_BD_MATERIAL SET F_CYG_CHECKBOX = 0  
+
+UPDATE A SET F_CYG_CHECKBOX = 1 FROM  T_BD_MATERIAL  A 
+INNER JOIN T_CB_PROACNTENTRY B ON A.FMATERIALID = B.FPRODUCTID

05.长园/CYG/SAL_OutStock/SQLServer/无关联应收单.sql

@@ -0,0 +1,27 @@
+IF EXISTS (SELECT * FROM sysobjects WHERE name='V_NOT_RECEIVABLE_OUTSTOCK')  --<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϊ<EFBFBD><EFBFBD>ͼ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
+    DROP VIEW V_NOT_RECEIVABLE_OUTSTOCK --<EFBFBD><EFBFBD>ͼ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
+GO
+CREATE VIEW V_NOT_RECEIVABLE_OUTSTOCK
+AS
+SELECT 
+	A.FID
+	,A.FBILLNO
+	,A.FSTOCKORGID
+	,AE.FENTRYID
+FROM
+	T_SAL_OUTSTOCK A  
+	LEFT JOIN T_SAL_OUTSTOCKENTRY AE ON A.FID = AE.FID
+	LEFT JOIN  (SELECT 
+		A.FID
+		,A.FBILLNO
+		,AE.FENTRYID
+		,BE.FORDERENTRYID
+		,BE_LK.FSID
+	FROM 
+		T_SAL_OUTSTOCK A 
+		LEFT JOIN T_SAL_OUTSTOCKENTRY AE ON A.FID = AE.FID
+		LEFT JOIN T_AR_RECEIVABLEENTRY_LK BE_LK ON BE_LK.FSBILLID = AE.FID AND BE_LK.FSID = AE.FENTRYID
+		LEFT JOIN T_AR_RECEIVABLEENTRY BE ON BE.FENTRYID = BE_LK.FENTRYID 
+	WHERE 
+		BE_LK.FSTABLENAME = 'T_SAL_OUTSTOCKENTRY' and FARNOTJOINQTY > 0) B ON A.FID = B.FID
+WHERE B.FID IS NULL and a.FDOCUMENTSTATUS ='C'

05.长园/CYG/SAL_OutStock/SQLServer/无关联应收单2-未关联应收数量.sql

@@ -0,0 +1,18 @@
+IF EXISTS (SELECT * FROM SYSOBJECTS WHERE NAME='V_NOT_RECEIVABLE_OUTSTOCK')  --<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϊ<EFBFBD><EFBFBD>ͼ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
+    DROP VIEW V_NOT_RECEIVABLE_OUTSTOCK --<EFBFBD><EFBFBD>ͼ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
+GO
+CREATE VIEW V_NOT_RECEIVABLE_OUTSTOCK
+AS
+SELECT 
+	A.FID
+	,A.FBILLNO
+	,AE.FENTRYID
+	,AE_R.FARNOTJOINQTY
+	,A.FDOCUMENTSTATUS
+FROM 
+	T_SAL_OUTSTOCK A 
+	LEFT JOIN T_SAL_OUTSTOCKENTRY AE ON A.FID = AE.FID
+	LEFT JOIN T_SAL_OUTSTOCKENTRY_R AE_R ON AE.FENTRYID = AE_R.FENTRYID
+WHERE 
+AE_R.FARNOTJOINQTY > 0 AND
+A.FDOCUMENTSTATUS ='C'

05.长园/CYG/SAL_OutStock/TestAutoPushPlugIn.cs

@@ -0,0 +1,168 @@
+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 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.App;
+using Kingdee.BOS.Core.DynamicForm;
+using Kingdee.BOS.Log;
+using Kingdee.BOS.Orm.Exceptions;
+using System.Data.SqlClient;
+
+namespace CYG.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, new Schedule
+                {
+                    Name =new LocaleValue("tbTestAutoP销售出库单自定下推Test")
+                });
+            }
+        }
+
+        public void Run(Context ctx, Schedule schedule)
+        {
+            Logger.Info(schedule.Name, $"销售出库单自动下推应付单start...");
+            var succeedNum = 0;
+            var failNum = 0;
+            try
+            {
+                IConvertService service = ServiceHelper.GetService<IConvertService>();
+
+                //源单据标识
+                string sourceFormId = "SAL_OUTSTOCK";
+                //目标单据标识
+                string targetFormId = "AR_RECEIVABLE";
+                //目标单据类型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"].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
+                        {
+                            //下推
+                            ConvertOperationResult convertResult = service.Push(ctx, pushArgs, option);
+
+                            //下推数据
+                            DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray();
+
+                            FormMetadata destFormMetadata = ServiceHelper.GetService<IMetaDataService>().Load(ctx, targetFormId) as FormMetadata;
+
+                            //保存
+                            IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(ctx, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
+
+                            string msg = string.Empty;
+
+                            if (saveResult.ValidationErrors != null && saveResult.ValidationErrors.Count > 0)
+                            {
+                                var errorInfo = string.Join(";", saveResult.ValidationErrors.Select(x => x.Message));
+
+                                throw new KDBusinessException("", "未知原因导致自动保存失败原因：" + errorInfo);
+                            }
+
+                            object[] pkArray = (from p in destObjs select p[0]).ToArray();
+                            //设置提交参数
+                            IOperationResult submitResult = ServiceHelper.GetService<ISubmitService>().Submit(ctx, destFormMetadata.BusinessInfo, pkArray, "Submit", OperateOption.Create());
+
+                            // 判断提交结果，如果失败，则内部会抛出错误，回滚代码
+                            if (submitResult.IsSuccess == false)
+                            {
+                                throw new KDBusinessException("", "未知原因导致自动提交失败！");
+                            }
+
+                            //设置审核参数
+                            IOperationResult auditResult = ServiceHelper.GetService<IAuditService>().Audit(ctx, destFormMetadata.BusinessInfo, pkArray, OperateOption.Create());
+                            // 判断提交结果，如果失败，则内部会抛出错误，回滚代码
+                            if (auditResult.IsSuccess == false)
+                            {
+                                throw new KDBusinessException("", "未知原因导致自动审核失败！");
+                            }
+
+                            succeedNum++;
+                            Logger.Info(schedule.Name, $"销售出库单:{list.Key},下推应付单:{saveResult.OperateResult[0].Number}成功！");
+                        }
+                        catch (OrmException ex)
+                        {
+                            failNum++;
+                            Logger.Error($"服务器插件：{schedule.Name}错误（Orm）", $"销售出库单:{list.Key}", ex);
+                        }
+                        catch (KDBusinessException ex)
+                        {
+                            failNum++;
+                            Logger.Error($"服务器插件：{schedule.Name}错误（KDB）", $"销售出库单:{list.Key}", ex);
+                        }
+                        catch (SqlException ex)
+                        {
+                            failNum++;
+                            Logger.Error($"服务器插件：{schedule.Name}错误（Sql）", $"销售出库单:{list.Key}", ex);
+                        }
+                        catch (Exception ex)
+                        {
+                            failNum++;
+                            Logger.Error($"服务器插件：{schedule.Name}", $"销售出库单:{list.Key}", ex);
+                        }
+                    }
+                }
+            }
+            catch (Exception ex)
+            {
+                Logger.Error($"服务器插件：{schedule.Name}", ex.Message, ex);
+            }
+            finally
+            {
+                Logger.Info(schedule.Name, $"成功{succeedNum}条,失败{failNum}条");
+                Logger.Info(schedule.Name, $"销售出库单自动下推应付单end...");
+            }
+        }
+
+
+
+        private DynamicObjectCollection GetDBData(Context ctx)
+        {
+            var unSql = $@"
+select * from V_NOT_RECEIVABLE_OUTSTOCK
+";
+            var dbList = DBUtils.ExecuteDynamicObject(ctx, $"/*dialect*/{unSql}");
+
+            return dbList;
+        }
+    }
+}