ds8-solution-pro/ds-wms-service/DS.WMS.Core/TaskInteraction/Method/FeeBillTaskService.cs

using DS.Module.Core;
using DS.WMS.Core.Fee.Entity;
using DS.WMS.Core.Flow.Dtos;
using DS.WMS.Core.Op.Entity;
using DS.WMS.Core.TaskInteraction.Dtos;
using DS.WMS.Core.TaskInteraction.Interface;

namespace DS.WMS.Core.TaskInteraction.Method
{
    /// <summary>
    /// 费用整票审核任务
    /// </summary>
    public class FeeBillTaskService : TaskService, IFeeBillTaskService
    {
        /// <summary>
        /// 初始化
        /// </summary>
        /// <param name="provider"></param>
        public FeeBillTaskService(IServiceProvider provider) : base(provider)
        {
        }

        /// <summary>
        /// 批量创建
        /// </summary>
        /// <param name="request"></param>
        /// <param name="useTransaction"></param>
        /// <returns></returns>
        public override Task<DataResult> CreateMultipleTaskAsync(TaskCreationRequest request, bool useTransaction = true)
        {
            return Task.FromResult(DataResult.Failed("不支持批量提交整票审核任务"));
        }

        /// <summary>
        /// 回调更新
        /// </summary>
        /// <param name="callback"></param>
        /// <returns></returns>
        public override async Task UpdateBusinessAsync(FlowCallback callback)
        {
            var auditType = callback.AuditType;
            if (auditType != TaskBaseTypeEnum.BILL_RECV_AUDIT && auditType != TaskBaseTypeEnum.BILL_PAY_AUDIT)
                return;

            var biz = await TenantDb.Queryable<BusinessFeeStatus>().Where(x => x.BusinessId == callback.BusinessId && x.BusinessType == callback.BusinessType)
                    .Select(x => new BusinessFeeStatus
                    {
                        Id = x.Id,
                        BusinessId = x.BusinessId,
                        BusinessType = x.BusinessType,
                        BillAuditStatus = x.BillAuditStatus,
                        BillFeeStatusTime = x.BillFeeStatusTime
                    }).FirstAsync();
            if (biz == null)
                return;

            long userId = long.Parse(User.UserId);
            DateTime dtNow = DateTime.Now;
            await TenantDb.Ado.BeginTranAsync();
            try
            {
                if (auditType == TaskBaseTypeEnum.BILL_RECV_AUDIT)
                {
                    if (callback.FlowStatus == FlowStatusEnum.Approve)
                    {
                        biz.BillAuditStatus = BillAuditStatus.RecvPassed;
                    }
                    else if (callback.FlowStatus == FlowStatusEnum.Reject)
                    {
                        biz.BillAuditStatus = BillAuditStatus.RecvRejected;
                        await TenantDb.Updateable<FeeRecord>()
                        .SetColumns(x => x.FeeStatus == FeeStatus.RejectSubmission)
                        .SetColumns(x => x.AuditBy == userId)
                        .SetColumns(x => x.AuditOperator == User.UserName)
                        .SetColumns(x => x.AuditDate == dtNow)
                        .Where(x => x.BusinessId == biz.BusinessId && x.BusinessType == biz.BusinessType && x.FeeStatus == FeeStatus.AuditSubmitted)
                        .ExecuteCommandAsync();
                    }

                    biz.BillFeeStatusTime = dtNow;
                    await TenantDb.Updateable(biz).UpdateColumns(x => new
                    {
                        x.BillAuditStatus,
                        x.BillFeeStatusTime
                    }).ExecuteCommandAsync();
                }
                else if (auditType == TaskBaseTypeEnum.BILL_PAY_AUDIT)
                {
                    FeeStatus status = FeeStatus.RejectSubmission;
                    if (callback.FlowStatus == FlowStatusEnum.Approve)
                    {
                        biz.BillAuditStatus = BillAuditStatus.PayPassed;
                        biz.ARFeeStatus = biz.APFeeStatus = BillFeeStatus.AuditPassed;
                        status = FeeStatus.AuditPassed;
                    }
                    else if (callback.FlowStatus == FlowStatusEnum.Reject)
                    {
                        biz.BillAuditStatus = BillAuditStatus.PayRejected;
                        biz.ARFeeStatus = biz.APFeeStatus = BillFeeStatus.RejectSubmission;
                        status = FeeStatus.RejectSubmission;
                    }

                    biz.BillFeeStatusTime = dtNow;
                    await TenantDb.Updateable(biz).UpdateColumns(x => new
                    {
                        x.BillAuditStatus,
                        x.BillFeeStatusTime,
                        x.ARFeeStatus,
                        x.APFeeStatus
                    }).ExecuteCommandAsync();

                    await TenantDb.Updateable<FeeRecord>()
                        .SetColumns(x => x.FeeStatus == status)
                        .SetColumns(x => x.AuditBy == userId)
                        .SetColumns(x => x.AuditOperator == User.UserName)
                        .SetColumns(x => x.AuditDate == dtNow)
                        .Where(x => x.BusinessId == biz.BusinessId && x.BusinessType == biz.BusinessType && x.FeeStatus == FeeStatus.AuditSubmitted)
                        .ExecuteCommandAsync();
                }

                await base.UpdateBusinessAsync(callback);
                await TenantDb.Ado.CommitTranAsync();
            }
            catch (Exception ex)
            {
                await TenantDb.Ado.RollbackTranAsync();
                await ex.LogAsync(Db);
                throw;
            }
        }
    }
}