生活缴费api
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhengyiming
2025-04-16 5a09f64b974521e25ef07c0691361ba5d71e919b 
 LifePayment/LifePayment.Application/LifePay/LifePayService.cs


@@ -160,7 +160,7 @@


    /// <returns></returns>


    public async Task<List<LifePayRateListOutput>> GetRate()


    {


        return await _lifePayRateRepository.Where(x => x.IsDeleted == false).Select(x => new LifePayRateListOutput() { Id = x.Id, Rate = x.Rate, RateType = x.RateType })


        return await _lifePayRateRepository.Select(x => new LifePayRateListOutput() { Id = x.Id, Rate = x.Rate, RateType = x.RateType })


                                           .ToListAsync();


    }




@@ -170,7 +170,7 @@


    /// <returns></returns>


    public async Task<ChannelRateOutput> GetChannelRate(ChannelsBaseInput input)


    {


        return _lifePayChannlesRep.Where(x => x.IsDeleted == false && x.ChannlesNum == input.CheckChannelId).Select(x => new ChannelRateOutput() { ChannlesRate = x.ChannlesRate })


        return _lifePayChannlesRep.Where(x => x.ChannlesNum == input.CheckChannelId).Select(x => new ChannelRateOutput() { ChannlesRate = x.ChannlesRate })


                                           .FirstOrDefault();


    }




@@ -180,7 +180,7 @@


    /// <returns></returns>


    public async Task<List<LifePayPremiumListOutput>> GetPremium()


    {


        return await _lifePayPremiumRepository.Where(x => x.IsDeleted == false).Select(x => new LifePayPremiumListOutput() { Id = x.Id, Rate = x.Rate, PremiumType = x.PremiumType })


        return await _lifePayPremiumRepository.Select(x => new LifePayPremiumListOutput() { Id = x.Id, Rate = x.Rate, PremiumType = x.PremiumType })


                                           .ToListAsync();


    }




@@ -190,7 +190,7 @@


    /// <returns></returns>


    public async Task<List<LifePayIntroInfoOutput>> GetIntroInfo(LifePayOrderTypeEnum lifePayType)


    {


        return await _lifePayIntroInfoRepository.Where(x => x.IsDeleted == false && x.LifePayType == lifePayType).OrderBy(x => x.Sequence)


        return await _lifePayIntroInfoRepository.Where(x => x.LifePayType == lifePayType).OrderBy(x => x.Sequence)


            .Select(x => new LifePayIntroInfoOutput() { Type = x.Type, ContentSummary = x.ContentSummary, Content = x.Content, LifePayType = x.LifePayType, Path = x.Path, Sequence = x.Sequence })


                                           .ToListAsync();


    }


@@ -202,7 +202,7 @@


    /// <returns></returns>


    public async Task<PageOutput<UserListOutput>> GetUserPage(QueryUserPageInput input)


    {


        return await _channelFilter.GetChannelLifePayUserFilter(_lifePayUserRepository).Where(x => x.IsDeleted == false)


        return await _channelFilter.GetChannelLifePayUserFilter(_lifePayUserRepository)


            .WhereIf(!string.IsNullOrEmpty(input.QueryCondition), x => x.PhoneNumber.Contains(input.QueryCondition) || x.Name.Contains(input.QueryCondition))


            .WhereIf(input.CreationTimeBegin.HasValue, x => x.CreationTime >= input.CreationTimeBegin)


            .WhereIf(input.CreationTimeEnd.HasValue, x => x.CreationTime <= input.CreationTimeEnd)


@@ -280,16 +280,16 @@


                                DiscountAmount = a.DiscountAmount ?? 0,


                                FinishTime = a.FinishTime,


                                Id = a.Id,


                                LifePayOrderStatus = a.LifePayOrderStatus?? 0,


                                LifePayOrderStatus = a.LifePayOrderStatus ?? 0,


                                LifePayOrderType = a.LifePayOrderType,


                                LifePayType = a.LifePayType,


                                OrderNo = a.OrderNo,


                                PayAmount = a.PayAmount ?? 0,


                                PhoneNumber = a.PhoneNumber,


                                RechargeAmount = a.RechargeAmount??0,


                                RechargeAmount = a.RechargeAmount ?? 0,


                                UserId = a.UserId,


                                OutOrderNo = a.OutOrderNo,


                                PayStatus = a.PayStatus?? 0,


                                PayStatus = a.PayStatus ?? 0,


                                PayTime = a.PayTime,


                                ACOOLYOrderNo = a.ACOOLYOrderNo,


                                RefundCredentialsImgUrl = a.RefundCredentialsImgUrl.GetOssPath(),


@@ -300,6 +300,7 @@


                                RefundTime = a.RefundTime,


                                ChannelName = b.ChannlesName,


                                ActualRechargeAmount = a.RechargeAmount,


                                ActualReceivedAmount = a.ActualReceivedAmount,


                                PlatformDeductionAmount = a.PlatformDeductionAmount,


                                ACOOLYStatus = a.ACOOLYStatus,


                                LifePayRefundStatus = a.LifePayRefundStatus,


@@ -328,7 +329,7 @@


                                            .WhereIf(input.ACOOLYStatus.HasValue, x => x.ACOOLYStatus == input.ACOOLYStatus.Value)


                                            .WhereIf(input.LifePayOrderType.HasValue, x => x.LifePayOrderType == input.LifePayOrderType.Value)


                                            .WhereIf(input.UserId.HasValue, x => x.UserId == input.UserId.Value)


                                            .WhereIf(input.KeyWords.IsNotNullOrEmpty(), x => x.PhoneNumber.Contains(input.KeyWords) || x.RefundOrderNo.Contains(input.KeyWords) || x.OutOrderNo.Contains(input.KeyWords) || x.ACOOLYOrderNo.Contains(input.KeyWords))


                                            .WhereIf(input.KeyWords.IsNotNullOrEmpty(), x => x.PhoneNumber.Contains(input.KeyWords) || x.RefundOrderNo.Contains(input.KeyWords) || x.OutOrderNo.Contains(input.KeyWords) || x.ACOOLYOrderNo.Contains(input.KeyWords) || x.OrderNo.Contains(input.KeyWords))


                            join b in _lifePayChannlesRep on a.ChannelId equals b.ChannlesNum into temp


                            from b in temp.DefaultIfEmpty()


                            select new LifePayOrderListOutput


@@ -388,8 +389,9 @@


            ACOOLYStatus = x.ACOOLYStatus,


            RefundApplyRemark = x.RefundApplyRemark,


            RechargeAmount = x.RechargeAmount,


            ActualReceivedAmount = x.ActualReceivedAmount.ToString("F2"),


            ActualReceivedAmount = (x.ActualReceivedAmount ?? 0).ToString("F2"),


            LifePayRefundStatus = x.LifePayRefundStatus,


            OrderNo = x.OrderNo,




        }).OrderByDescending(r => r.CreationTime).ToListAsync();


        var i = 0;


@@ -467,7 +469,7 @@


        var order = await _lifePayOrderRepository.Where(x => x.OrderNo == orderNo).FirstOrDefaultAsync();


        var platformRate = await _lifePayRateRepository.FirstOrDefaultAsync(r => r.RateType == LifePayRateTypeEnum.供应商折扣价);


        var channle = await _lifePayChannlesRep.FirstOrDefaultAsync(r => r.ChannlesNum == order.ChannelId);


        var premium = await _lifePayPremiumRepository.Where(x => x.IsDeleted == false && x.PremiumType == order.LifePayType).FirstOrDefaultAsync();


        var premium = await _lifePayPremiumRepository.Where(x => x.PremiumType == order.LifePayType).FirstOrDefaultAsync();


        CheckExtensions.IfTrueThrowUserFriendlyException(order == null, "订单不存在");


        var user = await _lifePayUserRepository.FirstOrDefaultAsync(x => x.Id == order.UserId);




@@ -566,7 +568,7 @@


                                                        DiscountAmount = x.DiscountAmount ?? 0,


                                                        FinishTime = x.FinishTime,


                                                        Id = x.Id,


                                                        LifePayOrderStatus = x.LifePayOrderStatus?? 0 ,


                                                        LifePayOrderStatus = x.LifePayOrderStatus ?? 0,


                                                        LifePayOrderType = x.LifePayOrderType,


                                                        LifePayType = x.LifePayType,


                                                        OrderNo = x.OrderNo,


@@ -607,9 +609,9 @@


        return await GetLifePayChannlesListFilter().GetPageResult(input.PageModel);


    }




    public async Task<List<CreateEditPayChannelsInput>> GetLifePayChannlesAllList()


    public async Task<List<CreateEditPayChannelsInput>> GetLifePayChannlesAllList(QueryLifePayChannlesInput input)


    {


        return await GetLifePayChannlesListFilter().Where(x => x.Status == LifePayChannelsStatsEnum.启用).ToListAsync();


        return await GetLifePayChannlesListFilter().WhereIf(input.Status.HasValue, x => x.Status == input.Status).ToListAsync();


    }




    public async Task<CreateEditPayChannelsInput> GetLifePayChannlesDto(Guid id)


@@ -669,7 +671,7 @@


            return new PageOutput<UserAccountOutput>();


        }




        var result = await _lifePayAccount.Where(x => x.UserId == input.UserId && x.IsDeleted == false)


        var result = await _lifePayAccount.Where(x => x.UserId == input.UserId)


                                            .WhereIf(input.LifePayOrderType.HasValue, x => x.LifePayType == input.LifePayOrderType)


                                            .OrderByDescending(x => x.CreationTime)


                                            .Select(x =>


@@ -696,7 +698,7 @@


            return new List<UserAccountOutput>();


        }




        var result = await _lifePayAccount.Where(x => x.UserId == input.UserId && x.IsDeleted == false)


        var result = await _lifePayAccount.Where(x => x.UserId == input.UserId)


                                            .WhereIf(input.LifePayOrderType.HasValue, x => x.LifePayType == input.LifePayOrderType)


                                            .OrderByDescending(x => x.CreationTime)


                                            .Select(x =>


@@ -907,7 +909,7 @@


        return await _wxPayApi.WxPayTradeQuery(outTradeNo);


    }




  






    #endregion




@@ -929,14 +931,11 @@


        var channle = await GetLifePayChannlesDtoByNum(input.ChannelId);


        CheckExtensions.IfTrueThrowUserFriendlyException(channle == null, "渠道不存在");




        var repeatOrder = await _lifePayOrderRepository.Where(x => x.LifePayOrderType == LifePayOrderTypeEnum.PhoneOrder 


        var repeatOrder = await _lifePayOrderRepository.Where(x => x.LifePayOrderType == LifePayOrderTypeEnum.PhoneOrder


        && x.PayStatus == LifePayStatusEnum.已支付


        && x.LifePayOrderStatus == LifePayOrderStatusEnum.充值中


        && x.OrderParamDetailJsonStr.Contains(input.ProductData.Phone)).ToListAsync();


         CheckExtensions.IfTrueThrowUserFriendlyException(repeatOrder.Count() > 0, "您有同户号订单正在充值中，请勿重复充值");




        //var rate = await GetRate();


        //CheckExtensions.IfTrueThrowUserFriendlyException(rate.IsNullOrEmpty(), "未配置折扣");


        && x.OrderParamDetailJsonStr.Contains(input.ProductData.Phone)).AnyAsync();


        CheckExtensions.IfTrueThrowUserFriendlyException(repeatOrder, "您有同户号订单正在充值中，请勿重复充值");




        var rate = await GetLifePayRate(channle, LifePayRateTypeEnum.默认话费折扣);




@@ -963,7 +962,6 @@


            PlatformDeductionAmount = amount.RechargeAmount * platformRate.Rate / 100,


            ChannleRate = rate,


            ChannlesRakeRate = channle.ChannlesRakeRate,


            //ChannlesRakePrice = amount.RechargeAmount * (channle.ChannlesRate - platformRate.Rate) / 100 * channle.ChannlesRakeRate / 100


        };




        await CreateLifePayOrder(orderInput);


@@ -989,12 +987,10 @@


        CheckExtensions.IfTrueThrowUserFriendlyException(channle == null, "渠道不存在");


        CheckExtensions.IfTrueThrowUserFriendlyException(channle.Status == LifePayChannelsStatsEnum.禁用, "渠道已被禁用");




        //var rate = await GetRate();


        //CheckExtensions.IfTrueThrowUserFriendlyException(rate.IsNullOrEmpty(), "未配置折扣");


        var repeatOrder = await _lifePayOrderRepository.Where(x => x.LifePayOrderType == LifePayOrderTypeEnum.ElectricOrder && x.PayStatus == LifePayStatusEnum.已支付


         && x.LifePayOrderStatus == LifePayOrderStatusEnum.充值中 && x.OrderParamDetailJsonStr.Contains(input.ProductData.ElectricType)


         && x.OrderParamDetailJsonStr.Contains(input.ProductData.ElectricAccount)).ToListAsync();


        CheckExtensions.IfTrueThrowUserFriendlyException(repeatOrder.Count() > 0, "您有同户号订单正在充值中，请勿重复充值");


         && x.OrderParamDetailJsonStr.Contains(input.ProductData.ElectricAccount)).AnyAsync();


        CheckExtensions.IfTrueThrowUserFriendlyException(repeatOrder, "您有同户号订单正在充值中，请勿重复充值");






        var rate = await GetLifePayRate(channle, LifePayRateTypeEnum.默认电费折扣);


@@ -1006,7 +1002,6 @@


            OrderNo = channle.ChannlesNum + CreateOrderNo(),


            LifePayOrderStatus = LifePayOrderStatusEnum.充值中,


            LifePayOrderType = LifePayOrderTypeEnum.ElectricOrder,


            // LifePayType = input.LifePayType,


            OrderParamDetailJsonStr = JsonConvert.SerializeObject(input.ProductData),


            UserId = user.Id,


            PayStatus = LifePayStatusEnum.未支付,


@@ -1016,6 +1011,7 @@


            RechargeAmount = amount.RechargeAmount,


            ChannelId = channle.ChannlesNum,


            PlatformRate = platformRate.Rate,


            PlatformDeductionAmount = amount.RechargeAmount * platformRate.Rate / 100,


            ChannleRate = rate,


            ChannlesRakeRate = channle.ChannlesRakeRate,


        };


@@ -1043,12 +1039,10 @@


        CheckExtensions.IfTrueThrowUserFriendlyException(channle == null, "渠道不存在");


        CheckExtensions.IfTrueThrowUserFriendlyException(channle.Status == LifePayChannelsStatsEnum.禁用, "渠道已被禁用");




        //var rate = await GetRate();


        //CheckExtensions.IfTrueThrowUserFriendlyException(rate.IsNullOrEmpty(), "未配置折扣");


        var repeatOrder = await _lifePayOrderRepository.Where(x => x.LifePayOrderType == LifePayOrderTypeEnum.GasOrder && x.PayStatus == LifePayStatusEnum.已支付


        && x.LifePayOrderStatus == LifePayOrderStatusEnum.充值中 && x.OrderParamDetailJsonStr.Contains(input.ProductData.GasOrgType)


        && x.OrderParamDetailJsonStr.Contains(input.ProductData.GasAccount)).ToListAsync();


        CheckExtensions.IfTrueThrowUserFriendlyException(repeatOrder.Count() > 0, "您有同户号订单正在充值中，请勿重复充值");


        && x.OrderParamDetailJsonStr.Contains(input.ProductData.GasAccount)).AnyAsync();


        CheckExtensions.IfTrueThrowUserFriendlyException(repeatOrder, "您有同户号订单正在充值中，请勿重复充值");






        var rate = await GetLifePayRate(channle, LifePayRateTypeEnum.默认燃气折扣);


@@ -1072,6 +1066,7 @@


            RechargeAmount = amount.RechargeAmount,


            ChannelId = channle.ChannlesNum,


            PlatformRate = platformRate.Rate,


            PlatformDeductionAmount = amount.RechargeAmount * platformRate.Rate / 100,


            ChannleRate = rate,


            ChannlesRakeRate = channle.ChannlesRakeRate,


        };


@@ -1388,12 +1383,13 @@


        var order = await _lifePayOrderRepository.Where(x => x.OrderNo == orderNo).FirstOrDefaultAsync();


        CheckExtensions.IfTrueThrowUserFriendlyException(order == null, "订单不存在");




        if (order.LifePayOrderStatus >= LifePayOrderStatusEnum.已完成)


        if (order.LifePayOrderStatus == LifePayOrderStatusEnum.已完成)


        {


            return;


        }




        order.PlatformDeductionAmount = payAmount;


        // order.PlatformDeductionAmount = payAmount;




        if (acoolyOrderNo.IsNotNullOrEmpty())


        {


            order.ACOOLYOrderNo = acoolyOrderNo;


@@ -1416,6 +1412,7 @@




        if (order.LifePayOrderStatus == LifePayOrderStatusEnum.已完成)


        {


            ///结算渠道佣金


            /// 毛利


            var grossProfit = order.RechargeAmount * (order.ChannleRate - order.PlatformRate) / 100;


            /// 渠道佣金  （(充值面额 * 渠道折扣比例)-(充值面额 * 平台折扣比例)）* 佣金比例


@@ -1425,9 +1422,9 @@


                LifePayChannlesRake lifePayChannlesRake = new LifePayChannlesRake()


                {


                    OrderNo = order.OrderNo,


                    PayAmount = order.PayAmount.Value,


                    ChannlesRakeRate = order.ChannlesRakeRate.Value,


                    ChannlesRakePrice = channlesRakePrice.Value,


                    PayAmount = order.RechargeAmount ?? 0,


                    ChannlesRakeRate = order.ChannlesRakeRate ?? 0,


                    ChannlesRakePrice = channlesRakePrice ?? 0,


                    FinishTime = order.FinishTime.Value,


                    ChannelId = order.ChannelId,


                };


@@ -1614,9 +1611,9 @@


            var userAccount = await _lifePayAccount.Where(x => x.UserId == input.UserId && x.Id == input.Id)


                                            .FirstOrDefaultAsync();


            CheckExtensions.IfTrueThrowUserFriendlyException(userAccount == null, "户号不存在");


            var repeatAccountContent = await _lifePayAccount.Where(x => x.UserId == input.UserId && x.LifePayType == input.LifePayType && x.Content == input.Content && x.Id != input.Id && x.IsDeleted == false)


                                            .FirstOrDefaultAsync();


            CheckExtensions.IfTrueThrowUserFriendlyException(repeatAccountContent != null, "户号已存在");


            var repeatAccountContent = await _lifePayAccount.Where(x => x.UserId == input.UserId && x.LifePayType == input.LifePayType && x.Content == input.Content && x.Id != input.Id)


                                            .AnyAsync();


            CheckExtensions.IfTrueThrowUserFriendlyException(repeatAccountContent, "户号已存在");




            userAccount.LifePayType = input.LifePayType;


            userAccount.Content = input.Content;


@@ -1629,8 +1626,8 @@


        else


        {


            var repeatAccountContent = await _lifePayAccount.Where(x => x.UserId == input.UserId && x.LifePayType == input.LifePayType && x.Content == input.Content && x.IsDeleted == false)


                                            .FirstOrDefaultAsync();


            CheckExtensions.IfTrueThrowUserFriendlyException(repeatAccountContent != null, "户号已存在");


                                            .AnyAsync();


            CheckExtensions.IfTrueThrowUserFriendlyException(repeatAccountContent, "户号已存在");


            var userAccount = new LifePayAccount


            {


                Id = Guid.NewGuid(),


@@ -1673,17 +1670,6 @@


        userAccount.DeletionTime = DateTime.Now;


        userAccount.IsDeleted = true;




        /// 清除户号对应的用户姓名


        if (userAccount.LifePayType == LifePayOrderTypeEnum.PhoneOrder || userAccount.LifePayType == LifePayOrderTypeEnum.ElectricOrder)


        {


            var user = await _lifePayUserRepository.Where(r => r.Id == userAccount.UserId && !r.IsDeleted).FirstOrDefaultAsync();


            CheckExtensions.IfTrueThrowUserFriendlyException(user == null, "用户不存在");


            var extraProperties = JsonConvert.DeserializeObject<Model_UserAccountExtraProperties>(userAccount.ExtraProperties);


            if (!string.IsNullOrEmpty(extraProperties.Name) && extraProperties.Phone == user.PhoneNumber)


            {


                user.Name = string.Empty;


            }


        }


        return Constant.SUCCESS;


    }




@@ -1717,8 +1703,7 @@


            await _lifePayOrderRepository.UpdateAsync(order);




            #region 记录日志




            await LifePayOrderHistory("退款驳回", "退款", order.Id, (int)OperateHistoryTypeEnum.LifePayRefund);


            await LifePayOrderHistory("退款驳回", "退款驳回", order.Id, (int)OperateHistoryTypeEnum.LifePayRefund);


            #endregion


        }


        else


@@ -2268,7 +2253,7 @@


        CheckExtensions.IfTrueThrowUserFriendlyException(order.LifePayType.HasValue, "当前订单已选择支付类型");




        order.LifePayType = lifePayType;


        var premium = await _lifePayPremiumRepository.Where(x => x.IsDeleted == false && x.PremiumType == order.LifePayType).FirstOrDefaultAsync();


        var premium = await _lifePayPremiumRepository.Where(x => x.PremiumType == order.LifePayType).FirstOrDefaultAsync();


        order.PremiumRate = premium == null ? 0 : premium.Rate;


        await _lifePayOrderRepository.UpdateAsync(order);




@@ -2287,12 +2272,12 @@


            default:


                break;


        }


        




        return new SetPayTypeReturn()


        {


            Desc = desc,


            OrderNo = order.OrderNo,


            PayAmount = order.PayAmount.HasValue? order.PayAmount.Value : 0,


            PayAmount = order.PayAmount.HasValue ? order.PayAmount.Value : 0,


            LifePayType = lifePayType,


        };


    }