smartfuel_Lite/FuelCloud/Fuel.Application/Service/TransactionsService.cs

using Fuel.Core.Transactions.Dto;
using Microsoft.AspNetCore.Http;
using Newtonsoft.Json;
using FuelServer.Core.Entity;
using System.Linq.Expressions;
using Fuel.Core.Models;
using System.Net;
using Fuel.Payment.Service.Pay;
using DFS.Core.Abstractions.View;
using Fuel.Core;
using System;
using System.Transactions;
using Fuel.Core.WechatServer;
using Fuel.Core.Nozzle.Dto;
using Fuel.Application.MqttService;
using Org.BouncyCastle.Asn1.X509;
using Jayrock.Json;
using Fuel.Core.Transactions;
using Microsoft.Extensions.DependencyInjection;
using static Fuel.Core.WechatServer.WeChatService;
using System.Linq.Dynamic.Core;
using System.Text.Json;
using Org.BouncyCastle.Asn1.Ocsp;


namespace Fuel.Application.Service
{
    public class TransactionsService : ITransactionsService
    {
        private readonly EntityHelper _entityHelper;
        private readonly IHttpContextAccessor _httpContextAccessor;
        private readonly IPayService _payService;
        public readonly IFreeSql _fsql;
        private readonly IMqttClientService _mqttService;
        private readonly IServiceScopeFactory _serviceScopeFactory;
        static NLog.Logger logger = NLog.LogManager.LoadConfiguration("nlog.xml").GetLogger("Main");

        public TransactionsService(EntityHelper entityHelper, IHttpContextAccessor httpContextAccessor, IPayService payService, IFreeSql fsql, IMqttClientService mqttService, IServiceScopeFactory serviceScopeFactory)
        {
            _entityHelper = entityHelper;
            _httpContextAccessor = httpContextAccessor;
            _payService = payService;
            _fsql = fsql;
            _mqttService = mqttService;
            _serviceScopeFactory = serviceScopeFactory;
        }

        /// <summary>
        /// 创建订单
        /// </summary>
        /// <param name="uploadTransactions"></param>
        /// <returns></returns>
        public async Task<ServiceResponse> CreateTransactions(UploadTransactions uploadTransactions)
        {
            Guid Buid = HttpRequestReader.GetCurrentBuId(); //站点id
            var site = _fsql.Select<businessunitinfo>().Where(_ => _.Buid == Buid).First();
            if (site == null)
            {
                return ServiceResponse.Error("站点信息查询为空 buid: " + Buid);
            }
            string key = string.Empty;
            var _product = await _entityHelper.GetEntitiesAsync<product>(_ => _.Buid == Buid && _.ProductName == uploadTransactions.Product);
            if (_product.Count() <= 0)
            {
                return ServiceResponse.Error("油品查询失败，油品名称：" + uploadTransactions.Product);
            }
            var _nozzle = await _entityHelper.GetEntitiesAsync<nozzle>(_ => _.Buid == Buid && _.ExternalGunNumber == uploadTransactions.ExternalGunNumber);
            if (_nozzle.Count() <= 0)
            {
                return ServiceResponse.Error("油枪查询失败，油枪名称：" + uploadTransactions.ExternalGunNumber);
            }
            if (site.PaymentMode == 1)//预支付
            {
                key = uploadTransactions.ExternalGunNumber + ":" +
                         uploadTransactions.OriginalAmount + ":" +
                         uploadTransactions.Qty + ":" +
                         uploadTransactions.MiniProgramID + ":" +
                         Buid.ToString();
                string WachatID = HttpRequestReader.GetWachatID(); //用户
                var userSession = WechatUserSessionRepo.GetUserSession(WachatID.ToString());
                if (userSession == null)
                {
                    return ServiceResponse.Error(HttpStatusCode.NonAuthoritativeInformation, "未找到用户！");
                }
                var user = _fsql.Select<miniprogramusers>().Where(_ => _.OpenId == userSession.openid).First();


                if (uploadTransactions.OriginalAmount != null)
                {
                    decimal decimalValue = uploadTransactions.OriginalAmount.HasValue ? uploadTransactions.OriginalAmount.Value : 0m;
                    decimal ProductPrice = _product.First().ProductPrice.HasValue ? _product.First().ProductPrice.Value : 0m;
                    decimal qty = decimalValue / ProductPrice;
                    uploadTransactions.Qty = qty;
                    //订单金额不能小于2元、订单金额不能大于9900元
                    if (uploadTransactions.OriginalAmount < 2 || uploadTransactions.OriginalAmount > 9900)
                    {
                        return ServiceResponse.Error(HttpStatusCode.NonAuthoritativeInformation, "订单金额不能小于2元、订单金额不能大于9900元");
                    }
                }
                else if (uploadTransactions.Qty != null)
                {
                    decimal decimalValue = uploadTransactions.Qty.HasValue ? uploadTransactions.Qty.Value : 0m;
                    decimal ProductPrice = _product.First().ProductPrice.HasValue ? _product.First().ProductPrice.Value : 0m;
                    decimal OriginalAmount = decimalValue * ProductPrice;
                    uploadTransactions.OriginalAmount = OriginalAmount;
                    if (uploadTransactions.Qty < 1 || OriginalAmount > 9900)
                    {
                        return ServiceResponse.Error(HttpStatusCode.NonAuthoritativeInformation, "升数不能小于1升，订单升数乘单价不能大于9900元");
                    }
                }
                else if (uploadTransactions.OriginalAmount == null && uploadTransactions.Qty == null)
                {
                    return ServiceResponse.Error("金额与升数为空");
                }

                uploadTransactions.MiniProgramID = user.Id;
            }
            else//后支付
            {
                key = uploadTransactions.ExternalGunNumber + ":" +
                       uploadTransactions.OriginalAmount + ":" +
                       uploadTransactions.Qty + ":" +
                       uploadTransactions.MiniProgramID + ":" +
                       uploadTransactions.FuelItemTransactionEndTime + ":" +
                        uploadTransactions.TransactionNumber + ":" +
                       Buid.ToString();
            }
            transactions output = await GetRedisTransactions(uploadTransactions, key);
            if (output != null)
            {
                return ServiceResponse.Ok(output);
            }
          
            var trx = uploadTransactions.ToTransactions(uploadTransactions, Buid, _product.FirstOrDefault(), _nozzle.FirstOrDefault(), site.PaymentMode);
            //int affectedRows = _fsql.Insert<transactions>().AppendData(trx).ExecuteAffrows();
            // var affectedRows = _fsql.Insert<transactions>().AppendData(trx).ExecuteInserted();
            var id = _fsql.Insert(trx).ExecuteIdentity();
            if (id > 0)
            {
                var insertedTransaction = _fsql.Select<transactions>()
                    .Where(t => t.Id == id)
                    .First();
                string jsonString = JsonConvert.SerializeObject(insertedTransaction);

                RedisHelper.SetAsync(key, jsonString, 600);
                return ServiceResponse.Ok(insertedTransaction);
            }
            else
            {
                return ServiceResponse.Error("订单信息插入失败");
            }
        }
        /// <summary>
        /// 后支付查询
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ServiceResponse> GetTransactionsAsync(RequestModel input)
        {
            Guid Buid = HttpRequestReader.GetCurrentBuId(); //站点id
            var site = _fsql.Select<businessunitinfo>().Where(_ => _.Buid == Buid).First();
            var _nozzle = _fsql.Select<nozzle>().Where(_ => _.Buid == Buid).ToList();//根据油枪id查询外部枪号
            var user = _fsql.Select<miniprogramusers>().Where(_ => _.Buid == Buid).ToList();
            var paytype = _fsql.Select<paytype>().ToList();
            Expression<Func<transactions, bool>> where = p => p.Buid == Buid;
            //查油枪
            if (input.filter.NozzleID != "")
            {
                long.TryParse(input.filter.NozzleID, out long NozzleID);
                var nozzle = _nozzle.Where(_ => _.ExternalGunNumber == NozzleID).First();//根据油枪id查询外部枪号
                where = CombineExpressions(where, p => p.NozzleId == nozzle.Id);
            }
            //查油品
            if (input.filter.ProductName != "")
            {
                where = CombineExpressions(where, p => p.ProductName == input.filter.ProductName);
            }
            //查站点
            if (input.filter.siteName != "")
            {

                where = CombineExpressions(where, p => p.Buid == site.Buid);
            }
            //查用户
            if (input.filter.username != "")
            {
                var userid = user.Where(_ => _.UserName == input.filter.username).First();
                where = CombineExpressions(where, p => p.MiniProgramID == userid.Id);
            }
            //查加油时间
            if (input.filter.TransactionTime != null)
            {
                where = CombineExpressions(where, p => p.TransactionTime >= input.filter.TransactionTime[0]  && p.TransactionTime <= input.filter.TransactionTime[1]);
            }
            //查支付模式
            if (input.filter.OrderType != "")
            {
                transactionsORDERTYPE OrderType = transactionsORDERTYPE.Postpayment;
                if (input.filter.OrderType == "0")
                {
                    OrderType = transactionsORDERTYPE.Postpayment;
                }
                else if (input.filter.OrderType == "1")
                {
                    OrderType = transactionsORDERTYPE.Prepayment;
                }
                where = CombineExpressions(where, p => p.OrderType == OrderType);
            }
            //查支付状态
            if (input.filter.OrderStatus != "")
            {
                transactionsORDERSTATUS OrderStatus = transactionsORDERSTATUS.Paid;
                if (input.filter.OrderStatus == "0")
                {
                    OrderStatus = transactionsORDERSTATUS.Unpaid;
                }
                else if (input.filter.OrderStatus == "1")
                {
                    OrderStatus = transactionsORDERSTATUS.Paid;
                }
                else if (input.filter.OrderStatus == "2")
                {
                    OrderStatus = transactionsORDERSTATUS.Paying;
                }
                else if (input.filter.OrderStatus == "3")
                {
                    OrderStatus = transactionsORDERSTATUS.CardPayment;
                }
                else if (input.filter.OrderStatus == "4")
                {
                    OrderStatus = transactionsORDERSTATUS.Completed;
                }
                else if (input.filter.OrderStatus == "5")
                {
                    OrderStatus = transactionsORDERSTATUS.Cancelled;
                }
                where = CombineExpressions(where, p => p.OrderStatus == OrderStatus);
            }
            var result = _fsql.Select<transactions>().Where(where).Count(out var total).Page(input.currentPage,input.pageSize).ToList();
            result = result.OrderByDescending(_ => _.TransactionTime).ToList();
            List<TransactionsList> list = new List<TransactionsList>();
            foreach (var item in result)
            {
                //  var nozzle = _nozzle.Where(_ => _.Id == item.NozzleId)?.First();//根据油枪id查询外部枪号
                var nozzle = _nozzle.FirstOrDefault(_ => _.Id == item.NozzleId);//根据油枪id查询外部枪号
             
              
                var pay = paytype.FirstOrDefault(_ => _.Id == item.PaymentMethod)?.Name;
                TransactionsList transactions = new TransactionsList();
                transactions.TransactionNumber = item.TransactionNumber;
                transactions.SiteName = site.Name;
                transactions.NozzleProductName = item.NozzleId + " | " + item.ProductName;
                transactions.ActualPaymentAmount = string.IsNullOrEmpty(item.ActualPaymentAmount.ToString()) ?  null : item.ActualPaymentAmount.ToString() + "元";
                transactions.TransactionTime = item.TransactionTime?.ToString("yyyy-MM-dd hh:mm:ss");
                transactions.OrderStatus = GetChineseStatus(item.OrderStatus);
                transactions.RefundAmount = string.IsNullOrEmpty(item.RefundAmount.ToString()) ? null : item.RefundAmount.ToString() + "元";
                transactions.OrderType = item.OrderType == transactionsORDERTYPE.Prepayment ? "预支付":"后支付";
                if (item.MiniProgramID != null)
                {
                    var userid = user.Where(_ => _.Id == item.MiniProgramID).FirstOrDefault();
                    transactions.UserName = userid?.UserName;
                    string UserPhoneNumber = user.Where(_ => _.Id == item.MiniProgramID).FirstOrDefault()?.UserPhoneNumber;
                    if (!string.IsNullOrEmpty(UserPhoneNumber))
                    {
                        transactions.UserPhoneNumber = HideMiddleDigits(UserPhoneNumber,3,4);
                    }
                }
                transactions.PriceQty = item.Price + " | " + item.Qty;
                transactions.PaymentMethod = pay;
               
                list.Add(transactions);
            }

            return ServiceResponse.Ok(new { list, total });
        }
        /// <summary>
        /// 预支付查询
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ServiceResponse> GetPrepaymentTransactionsAsync(RequestModel input)
        {
            Guid Buid = HttpRequestReader.GetCurrentBuId(); //站点id
            var site = _fsql.Select<businessunitinfo>().Where(_ => _.Buid == Buid).First();
            var _nozzle = _fsql.Select<nozzle>().Where(_ => _.Buid == Buid).ToList();//根据油枪id查询外部枪号
            var user = _fsql.Select<miniprogramusers>().Where(_ => _.Buid == Buid).ToList();
            var paytype = _fsql.Select<paytype>().ToList();
            Expression<Func<transactions, bool>> where = p => p.Buid == Buid;
            //查油枪
            if (input.filter.NozzleID != "")
            {
                long.TryParse(input.filter.NozzleID, out long NozzleID);
                var nozzle = _nozzle.Where(_ => _.ExternalGunNumber == NozzleID).First();//根据油枪id查询外部枪号
                where = CombineExpressions(where, p => p.NozzleId == nozzle.Id);
            }
            //查油品
            if (input.filter.ProductName != "")
            {
                where = CombineExpressions(where, p => p.ProductName == input.filter.ProductName);
            }
            //查站点
            if (input.filter.siteName != "")
            {

                where = CombineExpressions(where, p => p.Buid == site.Buid);
            }
            //查用户
            if (input.filter.username != "")
            {
                var userid = user.Where(_ => _.UserName == input.filter.username).First();
                where = CombineExpressions(where, p => p.MiniProgramID == userid.Id);
            }
            //查加油时间
            if (input.filter.TransactionTime != null)
            {
                where = CombineExpressions(where, p => p.TransactionTime >= input.filter.TransactionTime[0] && p.TransactionTime <= input.filter.TransactionTime[1]);
            }
            //查支付模式
            if (input.filter.OrderType != "")
            {
                transactionsORDERTYPE OrderType = transactionsORDERTYPE.Postpayment;
                if (input.filter.OrderType == "0")
                {
                    OrderType = transactionsORDERTYPE.Postpayment;
                }
                else if (input.filter.OrderType == "1")
                {
                    OrderType = transactionsORDERTYPE.Prepayment;
                }
                where = CombineExpressions(where, p => p.OrderType == OrderType);
            }
            //查支付状态
            if (input.filter.OrderStatus != "")
            {
                transactionsORDERSTATUS OrderStatus = transactionsORDERSTATUS.Paid;
                if (input.filter.OrderStatus == "0")
                {
                    OrderStatus = transactionsORDERSTATUS.Unpaid;
                }
                else if (input.filter.OrderStatus == "1")
                {
                    OrderStatus = transactionsORDERSTATUS.Paid;
                }
                else if (input.filter.OrderStatus == "2")
                {
                    OrderStatus = transactionsORDERSTATUS.Paying;
                }
                else if (input.filter.OrderStatus == "3")
                {
                    OrderStatus = transactionsORDERSTATUS.CardPayment;
                }
                else if (input.filter.OrderStatus == "4")
                {
                    OrderStatus = transactionsORDERSTATUS.Completed;
                }
                else if (input.filter.OrderStatus == "5")
                {
                    OrderStatus = transactionsORDERSTATUS.Cancelled;
                }
                where = CombineExpressions(where, p => p.OrderStatus == OrderStatus);
            }
            var result = _fsql.Select<transactions>().Where(where).Count(out var total).Page(input.currentPage, input.pageSize).ToList();
            result = result.OrderByDescending(_ => _.TransactionTime).ToList();
            List<PrepaymentTransactionsList> list = new List<PrepaymentTransactionsList>();
            foreach (var item in result)
            {
                //  var nozzle = _nozzle.Where(_ => _.Id == item.NozzleId)?.First();//根据油枪id查询外部枪号
                var nozzle = _nozzle.FirstOrDefault(_ => _.Id == item.NozzleId);//根据油枪id查询外部枪号


                var pay = paytype.FirstOrDefault(_ => _.Id == item.PaymentMethod)?.Name;
                PrepaymentTransactionsList transactions = new PrepaymentTransactionsList();
                transactions.TransactionNumber = item.TransactionNumber;
                transactions.SiteName = site.Name;
                transactions.NozzleProductName = item.NozzleId + " | " + item.ProductName;
                transactions.ActualPaymentAmount = string.IsNullOrEmpty(item.ActualPaymentAmount.ToString()) ? null : item.ActualPaymentAmount.ToString() + "元";
                transactions.TransactionTime = item.TransactionTime?.ToString("yyyy-MM-dd hh:mm:ss");
                transactions.OrderStatus = GetChineseStatus(item.OrderStatus);
                transactions.RefundAmount = string.IsNullOrEmpty(item.RefundAmount.ToString()) ? null : item.RefundAmount.ToString() + "元";
                transactions.OrderType = item.OrderType == transactionsORDERTYPE.Prepayment ? "预支付" : "后支付";
                if (item.MiniProgramID != null)
                {
                    var userid = user.Where(_ => _.Id == item.MiniProgramID).FirstOrDefault();
                    transactions.UserName = userid?.UserName;
                    string UserPhoneNumber = user.Where(_ => _.Id == item.MiniProgramID).FirstOrDefault()?.UserPhoneNumber;
                    if (!string.IsNullOrEmpty(UserPhoneNumber))
                    {
                        transactions.UserPhoneNumber = HideMiddleDigits(UserPhoneNumber, 3, 4);
                    }
                }
                transactions.PriceQty = item.Price + " | " + item.Qty;
                transactions.PaymentMethod = pay;
                transactions.authorizationStatus = GetAuthorizationStatus(item.authorizationStatus);
                transactions.RefundStatus = GetRefundStatus(item.RefundStatus);
                list.Add(transactions);
            }

            return ServiceResponse.Ok(new { list, total });
        }
        /// <summary>
        /// 小程序查询未支付订单
        /// </summary>
        /// <returns></returns>
        public async Task<ServiceResponse> GetMiniProgramTransactionsUnpaidAsync(TransactionsInput input)
        {
            Guid Buid = HttpRequestReader.GetCurrentBuId(); //站点id
            Expression<Func<transactions, bool>> where = p => p.Buid == Buid;
            string WachatID = HttpRequestReader.GetWachatID(); //用户
            var userSession = WechatUserSessionRepo.GetUserSession(WachatID.ToString());
            if (userSession == null)
            {
                return ServiceResponse.Error(HttpStatusCode.NonAuthoritativeInformation, "未找到用户！");
            }
            DateTime dayBeforeTime = DateTime.Now.AddDays(-1);
            var user = _fsql.Select<miniprogramusers>().Where(_ => _.OpenId == userSession.openid).First();
            where = CombineExpressions(where, p => p.MiniProgramID == user.Id && p.OrderStatus == transactionsORDERSTATUS.Unpaid && p.TransactionTime >= dayBeforeTime);
            var result = await _entityHelper.GetEntitiesAsync<transactions>(where);
            result = result.OrderByDescending(x => x.CreateTime).ToList();
            return ServiceResponse.Ok(result);
        }

        /// <summary>
        /// 小程序用户根据抢号查询未支付订单
        /// </summary>
        /// <returns></returns>
        public async Task<ServiceResponse> GetMiniProgramTransactionsUnpaidNozzleAsync(long NozzleId)
        {
            Guid Buid = HttpRequestReader.GetCurrentBuId(); //站点id
            Expression<Func<transactions, bool>> where = p => p.Buid == Buid;
            string WachatID = HttpRequestReader.GetWachatID(); //用户
            var userSession = WechatUserSessionRepo.GetUserSession(WachatID.ToString());
            if (userSession == null)
            {
                return ServiceResponse.Error(HttpStatusCode.NonAuthoritativeInformation, "未找到用户！");
            }
            DateTime dayBeforeTime = DateTime.Now.AddDays(-1);
            var _nozzle = _fsql.Select<nozzle>().Where(_ => _.Id == NozzleId).First();//根据油枪id查询外部枪号
            where = CombineExpressions(where, p => p.NozzleId == _nozzle.ExternalGunNumber && p.OrderStatus == transactionsORDERSTATUS.Unpaid && p.TransactionTime >= dayBeforeTime);
            var result = await _entityHelper.GetEntitiesAsync<transactions>(where);
            result = result.OrderByDescending(x => x.CreateTime).ToList();
            return ServiceResponse.Ok(result);
        }
        /// <summary>
        /// 小程序查询已支付订单
        /// </summary>
        /// <returns></returns>
        public async Task<ServiceResponse> GetMiniProgramTransactionsPaidAsync(TransactionsInput input)
        {
            Guid Buid = HttpRequestReader.GetCurrentBuId(); //站点id
            Expression<Func<transactions, bool>> where = p => p.Buid == Buid;
            string WachatID = HttpRequestReader.GetWachatID(); //用户
            var userSession = WechatUserSessionRepo.GetUserSession(WachatID.ToString());
            if (userSession == null)
            {
                return ServiceResponse.Error(HttpStatusCode.NonAuthoritativeInformation, "未找到用户！");
            }
            var user = _fsql.Select<miniprogramusers>().Where(_ => _.OpenId == userSession.openid).First();
            where = CombineExpressions(where, p => p.MiniProgramID == user.Id && p.OrderStatus == transactionsORDERSTATUS.Paid);
            var result = await _entityHelper.GetEntitiesAsync<transactions>(where);
            return ServiceResponse.Ok(result);
        }
        /// <summary>
        /// 小程序查询已支付订单
        /// </summary>
        /// <returns></returns>
        public async Task<ServiceResponse> WXFindOrders(DateTime? dateTime, int pageNum, int lineCount)
        {
            Guid Buid = HttpRequestReader.GetCurrentBuId(); //站点id
            Expression<Func<transactions, bool>> where = p => p.Buid == Buid;
            string WachatID = HttpRequestReader.GetWachatID(); //用户
            var userSession = WechatUserSessionRepo.GetUserSession(WachatID.ToString());
            if (userSession == null)
            {
                return ServiceResponse.Error(HttpStatusCode.NonAuthoritativeInformation, "未找到用户！");
            }
            var user = _fsql.Select<miniprogramusers>().Where(_ => _.OpenId == userSession.openid).First();
            DateTime time = dateTime != null ? (DateTime)dateTime : DateTime.Now;
            var select = _fsql.Select<transactions>().Where(_ => _.MiniProgramID == user.Id
            && (_.TransactionTime >= DateTime.Now.AddDays(-30) && _.TransactionTime <= time));
            var list = await select.Page(pageNum, lineCount).OrderByDescending(_ => _.TransactionTime).ToListAsync();

            return ServiceResponse.Ok(list);
        }
        /// <summary>
        /// 提交支付
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ServiceResponse> CommitPayment(int trxId, string AuthCode)
        {
            bool paymentOK = false;
            var trx = _entityHelper.GetEntitiesAsync<transactions>(_ => _.Id == trxId).Result.FirstOrDefault();
            if (trx == null)
            {
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "未查询到订单！");
            }
            var paytype = _entityHelper.GetEntitiesAsync<paytype>(_ => _.Id == trx.PaymentMethod).Result.FirstOrDefault();
            string billNumber = SequenceNumber.Next();//订单编号
            trx.TransactionNumber = billNumber;
            decimal payDueAmount = (decimal)trx.OriginalAmount;
            string Channel = paytype.Channel;
            var serviceResult = await _payService.PerformElectronicProcess(AuthCode, payDueAmount, billNumber);
            Payment.Core.Models.ElectronicOrderProcessResultModel payResult = (Payment.Core.Models.ElectronicOrderProcessResultModel)serviceResult.Data;
            if (!serviceResult.IsSuccessful() || payResult.ResultCode == "PAY_ERROR")
            {
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "支付失败");
            }
            trx.ActualPaymentAmount = payDueAmount;//实际支付金额
            trx.ResultCode = payResult?.ResultCode;//支付成功应该为0
            trx.ErrorDetail = payResult?.ErrorDetail;
            _entityHelper.UpdateAsync(trx);
            return ServiceResponse.Ok(trx);
        }
        /// <summary>
        /// 查询redis订单缓存
        /// </summary>
        /// <returns></returns>
        public async Task<transactions> GetRedisTransactions(UploadTransactions uploadTransactions, string key)
        {
            Guid Buid = HttpRequestReader.GetCurrentBuId(); //站点id
            var respond = RedisHelper.GetAsync(key).Result;
            if (respond == null)
            {
                return null;
            }
            transactions transactions = JsonConvert.DeserializeObject<transactions>(respond);
            var trx = _entityHelper.GetEntitiesAsync<transactions>(_ => _.Id == transactions.Id).Result.FirstOrDefault();
            if (trx == null || trx.OrderStatus != transactionsORDERSTATUS.Unpaid)
            {
                return null;
            }
            return transactions;
        }
        // 辅助方法：组合两个表达式
        private static Expression<Func<T, bool>> CombineExpressions<T>(Expression<Func<T, bool>> expr1, Expression<Func<T, bool>> expr2)
        {
            ParameterExpression param = expr1.Parameters[0];
            Expression body = Expression.AndAlso(expr1.Body, Expression.Invoke(expr2, param));
            return Expression.Lambda<Func<T, bool>>(body, param);
        }
        /// <summary>
        /// 退款
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ServiceResponse> RefundTrx(int trxId,
            decimal? OriginalQty = null)
        {
            Guid Buid = HttpRequestReader.GetCurrentBuId(); //站点id
            var businessunitinfo = _entityHelper.GetEntitiesAsync<businessunitinfo>(_ => _.Buid == Buid).Result.FirstOrDefault();
            if (businessunitinfo == null)
            {
                logger.Debug($"RefundTrx，退款失败，站点为空，Buid={Buid} ，trxId={trxId}");
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "站点为空");
            }
            string[] parts = businessunitinfo.GpsCoordinates.Split(',');
           // if (parts.Length == 2 &&
           //double.TryParse(parts[0], out double latitude2) &&
           //double.TryParse(parts[1], out double longitude2))
           // {

           // }
           // else
           // {
           //     return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "站点经纬度获取失败");
           // }
           // //计算调用方和油站的距离，超过距离判定为恶意请求
           // double distance = DistanceCalculator.CalculateDistance(longitude, latitude, longitude2, latitude2);
           // if (distance > 5)
           // {
           //     return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "该请求大于油站地址5公里");
           // }

            var trx = _entityHelper.GetEntitiesAsync<transactions>(_ => _.Id == trxId).Result.FirstOrDefault();
            if (trx == null)
            {
                logger.Debug($"退款失败，未查询到订单，Buid={Buid} ，trxId={trxId}");
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "未查询到订单！");
            }
            else if (trx.RefundStatus == RefundStatus.FullyRefunded)
            {
                logger.Debug($"该订单已退款，未查询到订单，Buid={Buid} ，trxId={trxId}");
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "该订单已退款");
            }
            else if (trx.RefundStatus == RefundStatus.PartiallyRefunded)
            {
                logger.Debug($"该订单已部分退款，Buid={Buid} ，trxId={trxId}");
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "该订单已部分退款");
            }
            else if (trx.OrderStatus == transactionsORDERSTATUS.Unpaid)
            {
                logger.Debug($"该订单已退款，该订单未支付，Buid={Buid} ，trxId={trxId}");
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "该订单未支付");
            }
            //获取单价
            decimal? ProductPrice = _entityHelper.GetEntitiesAsync<product>(_ => _.Id == trx.ProductId).Result.FirstOrDefault().ProductPrice;
            if (ProductPrice == null)
            {
                logger.Debug($"该订单已退款，单价获取失败，Buid={Buid} ，trxId={trxId}");
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "单价获取失败");
            }
            //计算退款金额
            //decimal RefundAmount = (decimal)trx.ActualPaymentAmount;
            decimal RefundAmount = 0.0M;
            if (businessunitinfo.PaymentMode == 0)//后支付
            {
                logger.Debug($"后支付模式无法退款！，Buid={Buid} ，trxId={trxId}");
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "后支付模式无法退款!");
                // RefundAmount = (decimal)((trx.Qty - trx.OriginalQty) * ProductPrice.Value);
            }
            else if (businessunitinfo.PaymentMode == 1)//预支付
            {
                decimal volume = OriginalQty ?? 0m;
                RefundAmount = (decimal)((trx.Qty - volume) * trx.Price);
                //RefundAmount = (decimal)((trx.Qty - OriginalQty) * ProductPrice.Value);
            }
            if (RefundAmount <= 0.0M)
            {
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "该笔单无需退款");
            }
            //退款
            var serviceResult = await _payService.ReturnProcess(RefundAmount, (decimal)trx.ActualPaymentAmount, "WX_SCAN", trx.BillNumber);
            Payment.Core.Models.ElectronicOrderProcessResultModel payResult = (Payment.Core.Models.ElectronicOrderProcessResultModel)serviceResult.Data;
            if (!serviceResult.IsSuccessful() || payResult.ResultCode == "PAY_ERROR")
            {
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "退款失败");
            }
            if (RefundAmount == (decimal)trx.ActualPaymentAmount)
            {
                trx.RefundStatus = RefundStatus.FullyRefunded;//全额退款
            }
            else
            {
                trx.RefundStatus = RefundStatus.PartiallyRefunded;//部分退款
            }
            trx.OrderStatus = transactionsORDERSTATUS.Cancelled;
            trx.RefundAmount = RefundAmount;
            int affectedRows = _fsql.Update<transactions>().SetSource(trx).ExecuteAffrows();
            var user = _fsql.Select<miniprogramusers>().Where(_ => _.Id == trx.MiniProgramID).First();
            string jsonString = JsonConvert.SerializeObject(trx);
            await _mqttService.SubscribeAsync("refund/" + Buid);
            await Task.Delay(2000);
            var sendjson = new { data = jsonString, UserName = user.UserName, UserPhoneNumber = user.UserPhoneNumber };
            await _mqttService.PublishAsync("refund/" + Buid, JsonConvert.SerializeObject(sendjson));
            return ServiceResponse.Ok(trx);
        }
        public async Task<ServiceResponse> UnifiedOrder(int trxId)
        {
            Guid Buid = HttpRequestReader.GetCurrentBuId(); //站点id
            try
            {
                logger.Debug("UnifiedOrder  start++");

                string WachatID = HttpRequestReader.GetWachatID(); //用户
                var userSession = WechatUserSessionRepo.GetUserSession(WachatID.ToString());
                if (userSession == null)
                {
                    return ServiceResponse.Error(HttpStatusCode.NonAuthoritativeInformation, "未找到用户！");
                }
                //var userSession = new WechatUserSessionResponse() { buId = "12345678-9abc-def0-1234-56789abcdef0", openid = "o8pFb5cWH1KkBDvGls2X7yMiFkGA" };
                var site = _fsql.Select<businessunitinfo>().Where(_ => _.Buid == Buid).First();
                var weChatService = new WeChatService(site.Appid, site.Secret);
                var user = _fsql.Select<miniprogramusers>().Where(_ => _.OpenId == userSession.openid).First();
                var trx = _entityHelper.GetEntitiesAsync<transactions>(_ => _.Id == trxId).Result.FirstOrDefault();
                if (trx == null)
                {
                    logger.Debug($"统一下单，Buid={Buid} ，trxId={trxId}，未查询到订单");
                    return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "未查询到订单！");
                }
                logger.Debug($"统一下单开始，Buid={Buid} ，trxId={trxId}");
                var serviceResult = await _payService.UnifiedOrder(trx.OriginalAmount.Value, "WX_SCAN", userSession.openid);
                var dataProperties = serviceResult.Data.GetType().GetProperty("UnifiedOrderResult");
                if (!serviceResult.IsSuccessful() || dataProperties == null)
                {
                    logger.Debug($"统一下单失败，Buid={Buid} ，trxId={trxId}" );
                    return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "统一下单失败");
                }


                //小程序支付完后，云端需要通过订单编号去支付平台查询支付状态，以便更新订单信息
                _ = Task.Delay(1500).ContinueWith(async _ =>
                {
                    using (var scope = _serviceScopeFactory.CreateScope())
                    {
                        var scopedMqttService = scope.ServiceProvider.GetRequiredService<IMqttClientService>();
                        var dataProperties = serviceResult.Data.GetType().GetProperty("eOrder");
                        var orderModel = (Fuel.Payment.Core.Models.ElectronicOrderModel)dataProperties.GetValue(serviceResult.Data);
                        var genericResponse = await _payService.QueryOrder(orderModel);
                        logger.Debug($"统一下单，Buid={Buid} ，trxId={trxId}，genericResponse.Data={genericResponse.Data}");
                        if (genericResponse.IsSuccessful() && orderModel.TradeStatus == Fuel.Payment.Core.Models.TradeStatus.SUCCESS)
                        {
                            trx.OrderStatus = transactionsORDERSTATUS.Paid;//将订单状态更改成已支付
                            trx.MiniProgramID = user.Id;
                            trx.BillNumber = orderModel.BillNumber;
                            trx.BillNumberBase62 = NumericBase62Converter.Encode(orderModel.BillNumber);
                            trx.ActualPaymentAmount = trx.OriginalAmount;
                            trx.PaymentMethod = 2;//2 :微信支付
                            try
                            {
                                await scopedMqttService.SubscribeAsync("paid/" + Buid);
                                string jsonString = JsonConvert.SerializeObject(trx);
                                await Task.Delay(2000);
                                var sendjson = new { data = jsonString, UserName = user.UserName, UserPhoneNumber = user.UserPhoneNumber };
                                logger.Debug($"统一下单，Buid={Buid} ，trxId={trxId}，订单推送fcc  sendjson={System.Text.Json.JsonSerializer.Serialize(sendjson)}");
                                //支付完成将订单信息推送到fcc
                                 scopedMqttService.PublishAsync("paid/" + Buid, JsonConvert.SerializeObject(sendjson));

                            }
                            catch (Exception ex)
                            {
                                logger.Debug($"统一下单，Buid={Buid} ，trxId={trxId}，异常："+ ex.Message);
                            }
                            logger.Debug($"统一下单，Buid={Buid} ，trxId={trxId}，更新订单信息");
                            int affectedRows = _fsql.Update<transactions>().SetSource(trx).ExecuteAffrows();
                            logger.Debug($"统一下单，Buid={Buid} ，trxId={trxId}，更新状态" + affectedRows);
                            //SendMessage(trx,Buid);
                        }
                    }
                });
                var unifiedOrderResult = dataProperties.GetValue(serviceResult.Data);
                var options = new JsonSerializerOptions
                {
                    IgnoreReadOnlyProperties = true // 忽略只读属性
                };
                string serializedUnifiedOrderResult = System.Text.Json.JsonSerializer.Serialize(unifiedOrderResult, options);
                logger.Debug($"统一下单，Buid={Buid} ，trxId={trxId}， 支付信息 " + serializedUnifiedOrderResult);
                return ServiceResponse.Ok(unifiedOrderResult);
            }
            catch (Exception ex)
            {
                logger.Debug($"统一下单，Buid={Buid} ，trxId={trxId}，Exception：" +ex.Message);
                return ServiceResponse.Error(ex.Message);
            }
        }
        public async Task<ServiceResponse> Redeem(int trxId, decimal OriginalQty, decimal FuelItemPumpTotalizerVolume)
        {
            var trx = _entityHelper.GetEntitiesAsync<transactions>(_ => _.Id == trxId).Result.FirstOrDefault();
            if (trx == null)
            {
                return ServiceResponse.Error(HttpStatusCode.NotAcceptable, "未查询到订单！");
            }
            var refund = await RefundTrx(trxId, OriginalQty);
             trx = _entityHelper.GetEntitiesAsync<transactions>(_ => _.Id == trxId).Result.FirstOrDefault();
            trx.OriginalQty = OriginalQty;
            trx.FuelItemPumpTotalizerVolume = FuelItemPumpTotalizerVolume;
            if (refund.IsSuccessful() || refund.StatusCode == HttpStatusCode.NotAcceptable)
            {
                trx.OrderStatus = transactionsORDERSTATUS.Completed;
            }
            int affectedRows = _fsql.Update<transactions>().SetSource(trx).ExecuteAffrows();
            return ServiceResponse.Ok(trx);
        }
        /// <summary>
        /// 微信发送模板消息
        /// </summary>
        /// <returns></returns>
        public async Task SendMessage(int trxId, string orderType)
        {
            var data = new Dictionary<string, object>();//动态字段

            Guid Buid = HttpRequestReader.GetCurrentBuId(); //站点id
            var trx = _entityHelper.GetEntitiesAsync<transactions>(_ => _.Id == trxId).Result.FirstOrDefault();
            var site = _fsql.Select<businessunitinfo>().Where(_ => _.Buid == Buid).First();
            var weChatService = new WeChatService(site.Appid, site.Secret);
            string WachatID = HttpRequestReader.GetWachatID(); //用户
                                                               //var userSession = WechatUserSessionRepo.GetUserSession(WachatID.ToString());
                                                               //if (userSession == null)
                                                               //{
                                                               //}
                                                               //var user = _fsql.Select<miniprogramusers>().Where(_ => _.OpenId == userSession.openid).First();

            var user = _fsql.Select<miniprogramusers>().Where(_ => _.OpenId == WachatID).First();
            var template = _fsql.Select<configuration>().Where(_ => _.Buid == Buid && _.Type == 2 && _.Name == "小程序通知模板").First();
            if (template == null)
            {
                //模板获取失败
                return;
            }

            //将金额小数改成俩位
            if (trx.ActualPaymentAmount.HasValue)
            {
                decimal roundedValue = Math.Round(trx.ActualPaymentAmount.Value, 2, MidpointRounding.AwayFromZero);
                trx.ActualPaymentAmount = roundedValue;
            }
           // var BillNumber = EncodeBillNumber(trx.BillNumber);
            var config = JsonConvert.DeserializeObject<TemplateConfig>(template.Value);
            var dataDict = new Dictionary<string, object>();
            var dynamicData = new Dictionary<string, object>
            {
                { "orderType", orderType},
               { "BillNumber", trx.BillNumberBase62 },//trx.BillNumber
                { "ProductName_Qty", trx.ProductName + " & " + trx.Qty + "L"},
                { "ActualPaymentAmount",trx.ActualPaymentAmount.ToString() + "元" },
                { "TransactionTime", ToFormattedString(trx.TransactionTime) }
            };


            foreach (var mapping in config.DataMappings)
            {
                string dataFieldName = mapping.Key;
                string targetFieldName = mapping.Value;

                if (dynamicData.TryGetValue(dataFieldName, out object value))
                {
                    dataDict.Add(targetFieldName, new { value = value });
                }
            }
            // 准备要发送的模板消息内容
            var templateMessage = new WeChatService.TemplateMessage
            {
                ToUser = user.OpenId,
                TemplateId = config.TemplateId,
                Page = "pages/historyOrder/historyOrder",
                Data = dataDict
            };
            //var templateMessage = new WeChatService.TemplateMessage
            //{
            //    ToUser = user.OpenId,
            //    TemplateId = "V0tl-4n-5hwNZc4SrEttvrmawAyM-SB0pQWZNwp54Ks",
            //    Page = "pages/historyOrder/historyOrder",
            //    Data = new
            //    {
            //        short_thing10 = new { value = orderType },
            //        character_string11 = new { value = trx.BillNumber },
            //        thing12 = new { value = trx.ProductName + " | " + trx.Qty + "L"},
            //        amount13 = new { value = trx.ActualPaymentAmount },
            //        time14 = new { value = ToFormattedString(trx.TransactionTime) },
            //    }
            //};
            weChatService.SendTemplateMessage(templateMessage);
        }
        public string ToFormattedString(DateTime? dateTime)
        {
            if (dateTime.HasValue)
            {
                return dateTime.Value.ToString("yyyy-MM-dd HH:mm:ss");
            }
            else
            {
                return null;
            }
        }
        public static string GetAuthorizationStatus(AuthorizationStatus status)
        {
            switch (status)
            {
                case AuthorizationStatus.Unauthorized:
                    return "未授权";
                case AuthorizationStatus.Authorized:
                    return "已授权";
                case AuthorizationStatus.WaitAuthorization:
                    return "等待授权";
                case AuthorizationStatus.FillingUp:
                    return "加油中";
                default:
                    throw new ArgumentOutOfRangeException(nameof(status), status, null);
            }
        }
        public static string GetRefundStatus(RefundStatus status)
        {
            switch (status)
            {
                case RefundStatus.NotRefunded:
                    return "无退款";
                case RefundStatus.FullyRefunded:
                    return "订单全额退款";
                case RefundStatus.PartiallyRefunded:
                    return "订单部分退款";
                default:
                    throw new ArgumentOutOfRangeException(nameof(status), status, null);
            }
        }

        public static string GetChineseStatus(transactionsORDERSTATUS status)
        {
            switch (status)
            {
                case transactionsORDERSTATUS.Unpaid:
                    return "订单未支付";
                case transactionsORDERSTATUS.Paid:
                    return "订单已支付";
                case transactionsORDERSTATUS.Paying:
                    return "订单正在支付中";
                case transactionsORDERSTATUS.CardPayment:
                    return "订单通过卡支付";
                case transactionsORDERSTATUS.Completed:
                    return "订单已完成";
                case transactionsORDERSTATUS.Cancelled:
                    return "已退款";
                default:
                    throw new ArgumentOutOfRangeException(nameof(status), status, null);
            }
        }
        /// <summary>
        /// 隐藏手机号中间的几位数字
        /// </summary>
        /// <param name="phoneNumber">原始手机号</param>
        /// <param name="startIndex">开始隐藏的位置</param>
        /// <param name="length">需要隐藏的字符长度</param>
        /// <returns>处理后的手机号</returns>
        public static string HideMiddleDigits(string phoneNumber, int startIndex, int length)
        {
            if (string.IsNullOrEmpty(phoneNumber) || startIndex + length > phoneNumber.Length)
            {
                return phoneNumber; // 如果输入无效，则返回原始手机号
            }

            string visiblePartStart = phoneNumber.Substring(0, startIndex); // 手机号前部分
            string hiddenPart = new string('*', length); // 中间隐藏部分
            string visiblePartEnd = phoneNumber.Substring(startIndex + length); // 手机号后部分

            return visiblePartStart + hiddenPart + visiblePartEnd;
        }
    }
}