Pilot_KD_Parino_yuyubo/Pilot_KD_Parino/VRYF_FHTZDHXJL/UpdateAmount.cs

using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
using Kingdee.BOS.Core.DynamicForm.PlugIn;
using Kingdee.BOS.Util;
using Pilot_KD_Parino.SQL;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Kingdee.BOS.App.Data;
using System.Threading;

namespace Pilot_KD_Parino.VRYF_FHTZDHXJL
{
    [HotUpdate]
    [Description("核销记录单(发货通知单)--更新累计核销金额")]
    public class UpdateAmount : AbstractOperationServicePlugIn
    {
        public override void AfterExecuteOperationTransaction(AfterExecuteOperationTransaction e)
        {
            base.AfterExecuteOperationTransaction(e);
            foreach (var rows in e.SelectedRows)
            {
                var Billobj = rows.DataEntity;
                //获取销售订单核销金额数据
                string sql = string.Format(@"/*dialect*/ EXEC UpdateSalOrderAmount2 {0} ", Convert.ToString(Billobj["Id"]));
                //执行SQL                
                DBUtils.ExecuteDynamicObject(Context, sql);

                string sql1 = string.Format(@"/*dialect*/Select B.FBILLNO2,B.FALLAMOUNT2,FORGID,FCONTRACTNUMBER From VRYF_t_Cust100015 A
                JOIN VRYF_t_Cust_Entry100024 B
                on A.FID = B.FID Where A.FID = '{0}'", Billobj["Id"]);

                var sql1List = DBUtils.ExecuteDynamicObject(Context, sql1);

                foreach (var item in sql1List.ToList())
                {
                    decimal FALLAMOUNT = 0;

                    FALLAMOUNT = Convert.ToDecimal(item["FALLAMOUNT2"]);

                    string sql2 = string.Format($@"/*dialect*/Select B.FENTRYID,B.FRECADVANCEAMOUNT,ISNULL(B.F_ORDER,'') as 'F_ORDER',a.FID From 
                    T_SAL_ORDER A
                    JOIN
                    T_SAL_ORDERPLAN B
                    on A.FID = B.FID
                    Where A.F_contractnumber = '{item["FCONTRACTNUMBER"]}' and A.FSaleOrgId={item["FORGID"]}
                    Order by F_ORDER ,FENTRYID");

                    var sql2List = DBUtils.ExecuteDynamicObject(Context, sql2);

                    var fidList = sql2List.Select(t => t["FID"].ToString()).ToList().Distinct().ToList();
                    fidList.ForEach(t =>
                    {
                        string sql3 = $@"exec PR_ResetSALORDERPLAN_MBBA_yuyubo {t};";
                        DBUtils.ExecuteDynamicObject(Context, sql3);
                        Thread.Sleep(300);
                    });


                    ////如果只有一个直接赋值
                    //if (sql2List.Count == 1)
                    //{
                    //    string sql3 = string.Format(@"Update T_SAL_ORDERPLAN Set F_MBBA_Decimal_uky = {0} Where FENTRYID = {1};", FALLAMOUNT, sql2List[0]["FENTRYID"]);
                    //    DBUtils.ExecuteDynamicObject(Context, sql3);
                    //}
                    //if (sql2List.Count > 1)
                    //{
                    //    for (int i = 0; i < sql2List.Count; i++)
                    //    {
                    //        //判断核销顺序是否为空
                    //        //if (!string.IsNullOrWhiteSpace(sql2List[i]["F_ORDER"]?.ToString()))
                    //        //{
                    //        //判断核销金额是否大于按照排序对冲金额
                    //        decimal FRECADVANCEAMOUNT = Convert.ToDecimal(sql2List[i]["FRECADVANCEAMOUNT"]);
                    //        decimal F_MBBA_Decimal_uky = Convert.ToDecimal(sql2List[i]["F_MBBA_Decimal_uky"]);
                    //        if (FALLAMOUNT > 0 && F_MBBA_Decimal_uky < FRECADVANCEAMOUNT)
                    //        {
                    //            decimal fAmount = 0;
                    //            decimal chazhi = FRECADVANCEAMOUNT - F_MBBA_Decimal_uky;
                    //            //判断是否整条对冲
                    //            if (FALLAMOUNT - chazhi >= 0)
                    //            {
                    //                fAmount = chazhi;
                    //            }
                    //            else
                    //            {
                    //                fAmount = FALLAMOUNT;
                    //            }
                    //            string sql3 = string.Format(@"Update T_SAL_ORDERPLAN Set F_MBBA_Decimal_uky = ISNULL(F_MBBA_Decimal_uky,0)+{0} Where FENTRYID = '{1}';", fAmount, sql2List[i]["FENTRYID"]);
                    //            DBUtils.ExecuteDynamicObject(Context, sql3);
                    //            FALLAMOUNT = FALLAMOUNT - fAmount;
                    //        }

                    //        //}
                    //    }
                    //}
                }
            }
        }
    }
}