using Castle.Core.Logging;
using Dapper;
using LifePayment.Application.Contracts;
using LifePayment.Application.Contracts.Sync;
using LifePayment.Domain.LifePay;
using LifePayment.Domain.Models;
using Microsoft.EntityFrameworkCore.Metadata.Internal;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Logging;
using Nest;
using NPOI.SS.Formula.Functions;
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Volo.Abp.Application.Services;
using Volo.Abp.Domain.Repositories;
using ZeroD.Util;
using ZeroD.Util.Fadd;

namespace LifePayment.Application.Sync
{
    public class SyncService : ApplicationService, ISyncService
    {
        private readonly ILogger<SyncService> logger;
        private readonly IConfiguration configuration;

        public SyncService(
            ILogger<SyncService> logger,
            IConfiguration configuration)
        {
            this.logger = logger;
            this.configuration = configuration;
        }

        private async Task<List<T>> GetListDataAsync<T>(string connName, string tableName)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                var data = await conn.QueryAsync<T>(@$"
                    SELECT * FROM [{tableName}]
                ");
                return data.ToList();
            }
        }

        private async Task<int> InsertLifePayChannles(string connName, SyncLifePayChannles item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    INSERT INTO LifePayChannles (
                        Id, ChannlesName, ChannlesNum, ChannlesRate, ChannlesRakeRate, 
                        ChannlesType, SwitchType, Status, CreationTime, CreatorId, 
                        LastModificationTime, LastModifierId, IsDeleted, DeleterId, 
                        DeletionTime
                    ) VALUES (
                        @Id, @ChannlesName, @ChannlesNum, @ChannlesRate, @ChannlesRakeRate, 
                        @ChannlesType, @SwitchType, @Status, @CreationTime, @CreatorId, 
                        @LastModificationTime, @LastModifierId, @IsDeleted, @DeleterId, 
                        @DeletionTime
                    )
                ", item);
            }
        }

        private async Task<int> InsertLifePayUser(string connName, SyncLifePayUser item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    INSERT INTO LifePayUser (
                        Id, PhoneNumber, OpenId, LastLoginTime, CreationTime, 
                        CreatorId, LastModificationTime, LastModifierId, IsDeleted, 
                        DeleterId, DeletionTime, UnionId, CreationChannleNum, 
                        LastLoginChannleNum, Name
                    ) VALUES (
                        @Id, @PhoneNumber, @OpenId, @LastLoginTime, @CreationTime, 
                        @CreatorId, @LastModificationTime, @LastModifierId, @IsDeleted, 
                        @DeleterId, @DeletionTime, @UnionId, @CreationChannleNum, 
                        @LastLoginChannleNum, @Name
                    )
                ", item);
            }
        }

        private async Task<int> InsertLifePayOrder(string connName, SyncLifePayOrder item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    INSERT INTO LifePayOrder (
                        Id, UserId, CreationTime, CreatorId, LastModificationTime, 
                        LastModifierId, IsDeleted, DeleterId, DeletionTime, 
                        ExtraProperties, ConcurrencyStamp, PhoneNumber, LifePayType, 
                        LifePayOrderType, OrderNo, RechargeAmount, DiscountAmount, 
                        PayAmount, PayTime, PayStatus, OutOrderNo, LifePayOrderStatus, 
                        FinishTime, RefundCredentialsImgUrl, OrderParamDetailJsonStr, 
                        OutRequestNo, ACOOLYOrderNo, RefundApplyRemark, 
                        RefundCheckRemark, RefundTime, RefundCheckUserId, ChannelId, 
                        RefundApplyTime, PlatformDeductionAmount, ACOOLYStatus, 
                        ActualRechargeAmount, LifePayRefundStatus, RefundPrice, 
                        RefundOrderNo, ElecBillUrl, RefundElecBillUrl, 
                        ActualReceivedAmount, PlatformRate, ChannleRate, 
                        ChannlesRakeRate, PremiumRate
                    ) VALUES (
                        @Id, @UserId, @CreationTime, @CreatorId, @LastModificationTime, 
                        @LastModifierId, @IsDeleted, @DeleterId, @DeletionTime, 
                        @ExtraProperties, @ConcurrencyStamp, @PhoneNumber, @LifePayType, 
                        @LifePayOrderType, @OrderNo, @RechargeAmount, @DiscountAmount, 
                        @PayAmount, @PayTime, @PayStatus, @OutOrderNo, @LifePayOrderStatus, 
                        @FinishTime, @RefundCredentialsImgUrl, @OrderParamDetailJsonStr, 
                        @OutRequestNo, @ACOOLYOrderNo, @RefundApplyRemark, 
                        @RefundCheckRemark, @RefundTime, @RefundCheckUserId, @ChannelId, 
                        @RefundApplyTime, @PlatformDeductionAmount, @ACOOLYStatus, 
                        @ActualRechargeAmount, @LifePayRefundStatus, @RefundPrice, 
                        @RefundOrderNo, @ElecBillUrl, @RefundElecBillUrl, 
                        @ActualReceivedAmount, @PlatformRate, @ChannleRate, 
                        @ChannlesRakeRate, @PremiumRate
                    )
                ", item);
            }
        }

        private async Task<int> InsertLifePayChannlesRake(string connName, SyncLifePayChannlesRake item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    INSERT INTO LifePayChannlesRake (
                        Id, UserId, CreationTime, CreatorId, LastModificationTime, 
                        LastModifierId, IsDeleted, DeleterId, DeletionTime, 
                        ExtraProperties, FinishTime, OrderNo, PayAmount, 
                        ChannlesRakeRate, ChannlesRakePrice, ChannelId
                    ) VALUES (
                        @Id, @UserId, @CreationTime, @CreatorId, @LastModificationTime, 
                        @LastModifierId, @IsDeleted, @DeleterId, @DeletionTime, 
                        @ExtraProperties, @FinishTime, @OrderNo, @PayAmount, 
                        @ChannlesRakeRate, @ChannlesRakePrice, @ChannelId
                    )
                ", item);
            }
        }

        private async Task<int> InsertLifePayConsumption(string connName, SyncLifePayConsumption item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    INSERT INTO LifePayConsumption (
                        Id, UserId, CreationTime, CreatorId, LastModificationTime, 
                        LastModifierId, IsDeleted, DeleterId, DeletionTime, 
                        ExtraProperties, OrderNo, AcoolyOrderNo, Amount, 
                        ACOOLYStatus, FrozenStatus, Flow, DeductionAmount, 
                        FinishTime, ChannelId, FrozenAmount
                    ) VALUES (
                        @Id, @UserId, @CreationTime, @CreatorId, @LastModificationTime, 
                        @LastModifierId, @IsDeleted, @DeleterId, @DeletionTime, 
                        @ExtraProperties, @OrderNo, @AcoolyOrderNo, @Amount, 
                        @ACOOLYStatus, @FrozenStatus, @Flow, @DeductionAmount, 
                        @FinishTime, @ChannelId, @FrozenAmount
                    )
                ", item);
            }
        }

        private async Task<int> InsertLifePayExpensesReceipts(string connName, SyncLifePayExpensesReceipts item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    INSERT INTO LifePayExpensesReceipts (
                        Id, UserId, CreationTime, CreatorId, LastModificationTime, 
                        LastModifierId, IsDeleted, DeleterId, DeletionTime, 
                        ExtraProperties, OrderNo, OutOrderNo, LifePayType, 
                        Amount, ExpensesReceiptsType, FinishTime
                    ) VALUES (
                        @Id, @UserId, @CreationTime, @CreatorId, @LastModificationTime, 
                        @LastModifierId, @IsDeleted, @DeleterId, @DeletionTime, 
                        @ExtraProperties, @OrderNo, @OutOrderNo, @LifePayType, 
                        @Amount, @ExpensesReceiptsType, @FinishTime
                    )
                ", item);
            }
        }

        private async Task<int> UpdateLifePayChannles(string connName, SyncLifePayChannles item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    UPDATE LifePayChannles
                    SET 
                        ChannlesName = @ChannlesName,
                        ChannlesNum = @ChannlesNum,
                        ChannlesRate = @ChannlesRate,
                        ChannlesRakeRate = @ChannlesRakeRate,
                        ChannlesType = @ChannlesType,
                        SwitchType = @SwitchType,
                        Status = @Status,
                        CreationTime = @CreationTime,
                        CreatorId = @CreatorId,
                        LastModificationTime = @LastModificationTime,
                        LastModifierId = @LastModifierId,
                        IsDeleted = @IsDeleted,
                        DeleterId = @DeleterId,
                        DeletionTime = @DeletionTime
                    WHERE Id = @Id
                ", item);
            }
        }

        private async Task<int> UpdateLifePayUser(string connName, SyncLifePayUser item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    UPDATE LifePayUser
                    SET 
                        PhoneNumber = @PhoneNumber,
                        OpenId = @OpenId,
                        LastLoginTime = @LastLoginTime,
                        CreationTime = @CreationTime,
                        CreatorId = @CreatorId,
                        LastModificationTime = @LastModificationTime,
                        LastModifierId = @LastModifierId,
                        IsDeleted = @IsDeleted,
                        DeleterId = @DeleterId,
                        DeletionTime = @DeletionTime,
                        UnionId = @UnionId,
                        CreationChannleNum = @CreationChannleNum,
                        LastLoginChannleNum = @LastLoginChannleNum,
                        Name = @Name
                    WHERE Id = @Id
                ", item);
            }
        }

        private async Task<int> UpdateLifePayOrder(string connName, SyncLifePayOrder item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    UPDATE LifePayOrder
                    SET 
                        UserId = @UserId,
                        CreationTime = @CreationTime,
                        CreatorId = @CreatorId,
                        LastModificationTime = @LastModificationTime,
                        LastModifierId = @LastModifierId,
                        IsDeleted = @IsDeleted,
                        DeleterId = @DeleterId,
                        DeletionTime = @DeletionTime,
                        ExtraProperties = @ExtraProperties,
                        ConcurrencyStamp = @ConcurrencyStamp,
                        PhoneNumber = @PhoneNumber,
                        LifePayType = @LifePayType,
                        LifePayOrderType = @LifePayOrderType,
                        OrderNo = @OrderNo,
                        RechargeAmount = @RechargeAmount,
                        DiscountAmount = @DiscountAmount,
                        PayAmount = @PayAmount,
                        PayTime = @PayTime,
                        PayStatus = @PayStatus,
                        OutOrderNo = @OutOrderNo,
                        LifePayOrderStatus = @LifePayOrderStatus,
                        FinishTime = @FinishTime,
                        RefundCredentialsImgUrl = @RefundCredentialsImgUrl,
                        OrderParamDetailJsonStr = @OrderParamDetailJsonStr,
                        OutRequestNo = @OutRequestNo,
                        ACOOLYOrderNo = @ACOOLYOrderNo,
                        RefundApplyRemark = @RefundApplyRemark,
                        RefundCheckRemark = @RefundCheckRemark,
                        RefundTime = @RefundTime,
                        RefundCheckUserId = @RefundCheckUserId,
                        ChannelId = @ChannelId,
                        RefundApplyTime = @RefundApplyTime,
                        PlatformDeductionAmount = @PlatformDeductionAmount,
                        ACOOLYStatus = @ACOOLYStatus,
                        ActualRechargeAmount = @ActualRechargeAmount,
                        LifePayRefundStatus = @LifePayRefundStatus,
                        RefundPrice = @RefundPrice,
                        RefundOrderNo = @RefundOrderNo,
                        ElecBillUrl = @ElecBillUrl,
                        RefundElecBillUrl = @RefundElecBillUrl,
                        ActualReceivedAmount = @ActualReceivedAmount,
                        PlatformRate = @PlatformRate,
                        ChannleRate = @ChannleRate,
                        ChannlesRakeRate = @ChannlesRakeRate,
                        PremiumRate = @PremiumRate
                    WHERE Id = @Id
                ", item);
            }
        }

        private async Task<int> UpdateLifePayChannlesRake(string connName, SyncLifePayChannlesRake item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    UPDATE LifePayChannlesRake
                    SET 
                        UserId = @UserId,
                        CreationTime = @CreationTime,
                        CreatorId = @CreatorId,
                        LastModificationTime = @LastModificationTime,
                        LastModifierId = @LastModifierId,
                        IsDeleted = @IsDeleted,
                        DeleterId = @DeleterId,
                        DeletionTime = @DeletionTime,
                        ExtraProperties = @ExtraProperties,
                        FinishTime = @FinishTime,
                        OrderNo = @OrderNo,
                        PayAmount = @PayAmount,
                        ChannlesRakeRate = @ChannlesRakeRate,
                        ChannlesRakePrice = @ChannlesRakePrice,
                        ChannelId = @ChannelId
                    WHERE Id = @Id
                ", item);
            }
        }

        private async Task<int> UpdateLifePayConsumption(string connName, SyncLifePayConsumption item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    UPDATE LifePayConsumption
                    SET 
                        UserId = @UserId,
                        CreationTime = @CreationTime,
                        CreatorId = @CreatorId,
                        LastModificationTime = @LastModificationTime,
                        LastModifierId = @LastModifierId,
                        IsDeleted = @IsDeleted,
                        DeleterId = @DeleterId,
                        DeletionTime = @DeletionTime,
                        ExtraProperties = @ExtraProperties,
                        OrderNo = @OrderNo,
                        AcoolyOrderNo = @AcoolyOrderNo,
                        Amount = @Amount,
                        ACOOLYStatus = @ACOOLYStatus,
                        FrozenStatus = @FrozenStatus,
                        Flow = @Flow,
                        DeductionAmount = @DeductionAmount,
                        FinishTime = @FinishTime,
                        ChannelId = @ChannelId,
                        FrozenAmount = @FrozenAmount
                    WHERE Id = @Id
                ", item);
            }
        }

        private async Task<int> UpdateLifePayExpensesReceipts(string connName, SyncLifePayExpensesReceipts item)
        {
            var connString = configuration.GetConnectionString(connName);
            using (var conn = new SqlConnection(connString))
            {
                return await conn.ExecuteAsync(@"
                    UPDATE LifePayExpensesReceipts
                    SET 
                        UserId = @UserId,
                        CreationTime = @CreationTime,
                        CreatorId = @CreatorId,
                        LastModificationTime = @LastModificationTime,
                        LastModifierId = @LastModifierId,
                        IsDeleted = @IsDeleted,
                        DeleterId = @DeleterId,
                        DeletionTime = @DeletionTime,
                        ExtraProperties = @ExtraProperties,
                        OrderNo = @OrderNo,
                        OutOrderNo = @OutOrderNo,
                        LifePayType = @LifePayType,
                        Amount = @Amount,
                        ExpensesReceiptsType = @ExpensesReceiptsType,
                        FinishTime = @FinishTime
                    WHERE Id = @Id
                ", item);
            }
        }

        /// <summary>
        /// 同步测试订单数据
        /// </summary>
        /// <returns></returns>
        public async Task<List<string>> SyncFromTest()
        {
            var messages = new List<string>();
            var sourceConnName = "SyncLifePaymentServices";
            var targetConnName = "LifePaymentServices";

            var sourceLifePayChannlesList = await GetListDataAsync<SyncLifePayChannles>(sourceConnName, "LifePayChannles");
            var sourceLifePayUserList = await GetListDataAsync<SyncLifePayUser>(sourceConnName, "LifePayUser");
            var sourceLifePayOrderList = await GetListDataAsync<SyncLifePayOrder>(sourceConnName, "LifePayOrder");
            var sourceLifePayChannlesRakeList = await GetListDataAsync<SyncLifePayChannlesRake>(sourceConnName, "LifePayChannlesRake");
            var sourceLifePayConsumptionList = await GetListDataAsync<SyncLifePayConsumption>(sourceConnName, "LifePayConsumption");
            var sourceLifePayExpensesReceiptsList = await GetListDataAsync<SyncLifePayExpensesReceipts>(sourceConnName, "LifePayExpensesReceipts");

            var targetLifePayChannlesList = await GetListDataAsync<SyncLifePayChannles>(targetConnName, "LifePayChannles");
            var targetLifePayUserList = await GetListDataAsync<SyncLifePayUser>(targetConnName, "LifePayUser");
            var targetLifePayOrderList = await GetListDataAsync<SyncLifePayOrder>(targetConnName, "LifePayOrder");
            var targetLifePayChannlesRakeList = await GetListDataAsync<SyncLifePayChannlesRake>(targetConnName, "LifePayChannlesRake");
            var targetLifePayConsumptionList = await GetListDataAsync<SyncLifePayConsumption>(targetConnName, "LifePayConsumption");
            var targetLifePayExpensesReceiptsList = await GetListDataAsync<SyncLifePayExpensesReceipts>(targetConnName, "LifePayExpensesReceipts");

            var dicUserIds = new Dictionary<Guid?, Guid?>();
            var dicChannleIds = new Dictionary<Guid?, Guid?>();
            var count = 0;
            logger.LogInformation($"准备同步{sourceLifePayUserList.Count}个用户数据");
            foreach (var sourceLifePayUser in sourceLifePayUserList)
            {
                count++;
                logger.LogInformation($"正在同步第{count}个用户：{sourceLifePayUser.PhoneNumber}--------------------------------------------------------------------");

                try
                {
                    var targetLifePayUser = targetLifePayUserList.FirstOrDefault(it => it.PhoneNumber == sourceLifePayUser.PhoneNumber);
                    if (targetLifePayUser == null)
                    {
                        logger.LogInformation("未匹配相同手机号");
                        targetLifePayUser = targetLifePayUserList.FirstOrDefault(it => it.Id == sourceLifePayUser.Id);
                    }

                    if (targetLifePayUser == null)
                    {
                        targetLifePayUser = new SyncLifePayUser();
                        ObjectMapper.Map(sourceLifePayUser, targetLifePayUser);
                        await InsertLifePayUser(targetConnName, targetLifePayUser);
                        dicUserIds.Add(sourceLifePayUser.Id, targetLifePayUser.Id);
                        logger.LogInformation("未匹配相同Id，已插入用户");
                    }
                    else
                    {
                        var updateTargetLifePayUser = new SyncLifePayUser();
                        ObjectMapper.Map(sourceLifePayUser, updateTargetLifePayUser);
                        updateTargetLifePayUser.Id = targetLifePayUser.Id;
                        await UpdateLifePayUser(targetConnName, updateTargetLifePayUser);
                        targetLifePayUser = updateTargetLifePayUser;
                        dicUserIds.Add(sourceLifePayUser.Id, targetLifePayUser.Id);
                        logger.LogInformation("已更新用户");
                    }
                }
                catch (Exception ex)
                {
                    messages.Add($"未能同步用户（{sourceLifePayUser.PhoneNumber}）发生服务器异常：{ex.Message}");
                    continue;
                }
            }

            foreach (var sourceLifePayChannles in sourceLifePayChannlesList)
            {
                try
                {
                    var targetLifePayChannles = targetLifePayChannlesList.FirstOrDefault(it => it.ChannlesNum == sourceLifePayChannles.ChannlesNum);
                    if (targetLifePayChannles == null)
                    {
                        logger.LogInformation("未匹配相同编号");
                        targetLifePayChannles = targetLifePayChannlesList.FirstOrDefault(it => it.Id == sourceLifePayChannles.Id);
                    }

                    if (targetLifePayChannles == null)
                    {
                        targetLifePayChannles = new SyncLifePayChannles();
                        ObjectMapper.Map(sourceLifePayChannles, targetLifePayChannles);
                        await InsertLifePayChannles(targetConnName, targetLifePayChannles);
                        dicChannleIds.Add(sourceLifePayChannles.Id, targetLifePayChannles.Id);
                        logger.LogInformation($"已插入渠道：{targetLifePayChannles.ChannlesName}");
                    }
                    else
                    {
                        var updateTargetLifePayChannles = new SyncLifePayChannles();
                        ObjectMapper.Map(sourceLifePayChannles, updateTargetLifePayChannles);
                        updateTargetLifePayChannles.Id = targetLifePayChannles.Id;
                        await UpdateLifePayChannles(targetConnName, updateTargetLifePayChannles);
                        targetLifePayChannles = updateTargetLifePayChannles;
                        dicChannleIds.Add(sourceLifePayChannles.Id, targetLifePayChannles.Id);
                        logger.LogInformation($"已更新渠道：{targetLifePayChannles.ChannlesName}");
                    }
                }
                catch (Exception ex)
                {
                    messages.Add($"未能同步渠道（{sourceLifePayChannles.ChannlesName}）发生服务器异常：{ex.Message}");
                    continue;
                }
            }

            foreach (var sourceLifePayChannlesRake in sourceLifePayChannlesRakeList)
            {
                try
                {
                    var targetLifePayChannlesRake = targetLifePayChannlesRakeList.FirstOrDefault(it => it.Id == sourceLifePayChannlesRake.Id);
                    if (targetLifePayChannlesRake == null)
                    {
                        targetLifePayChannlesRake = new SyncLifePayChannlesRake();
                        ObjectMapper.Map(sourceLifePayChannlesRake, targetLifePayChannlesRake);
                        if (sourceLifePayChannlesRake.UserId.HasValue)
                        {
                            targetLifePayChannlesRake.UserId = dicUserIds[sourceLifePayChannlesRake.UserId];
                        }

                        await InsertLifePayChannlesRake(targetConnName, targetLifePayChannlesRake);
                        logger.LogInformation($"已插入分佣：{targetLifePayChannlesRake.OrderNo}");
                    }
                    else
                    {
                        targetLifePayChannlesRake = new SyncLifePayChannlesRake();
                        ObjectMapper.Map(sourceLifePayChannlesRake, targetLifePayChannlesRake);
                        if (sourceLifePayChannlesRake.UserId.HasValue)
                        {
                            targetLifePayChannlesRake.UserId = dicUserIds[sourceLifePayChannlesRake.UserId];
                        }

                        await UpdateLifePayChannlesRake(targetConnName, targetLifePayChannlesRake);
                        logger.LogInformation($"已更新分佣：{targetLifePayChannlesRake.OrderNo}");
                    }
                }
                catch (Exception ex)
                {
                    messages.Add($"未能同步分佣（{sourceLifePayChannlesRake.OrderNo}）发生服务器异常：{ex.Message}");
                    continue;
                }
            }

            foreach (var sourceLifePayChannlesRake in sourceLifePayChannlesRakeList)
            {
                try
                {
                    var targetLifePayChannlesRake = targetLifePayChannlesRakeList.FirstOrDefault(it => it.Id == sourceLifePayChannlesRake.Id);
                    if (targetLifePayChannlesRake == null)
                    {
                        targetLifePayChannlesRake = new SyncLifePayChannlesRake();
                        ObjectMapper.Map(sourceLifePayChannlesRake, targetLifePayChannlesRake);
                        if (sourceLifePayChannlesRake.UserId.HasValue)
                        {
                            targetLifePayChannlesRake.UserId = dicUserIds[sourceLifePayChannlesRake.UserId];
                        }

                        await InsertLifePayChannlesRake(targetConnName, targetLifePayChannlesRake);
                        logger.LogInformation($"已插入分佣：{targetLifePayChannlesRake.OrderNo}");
                    }
                    else
                    {
                        targetLifePayChannlesRake = new SyncLifePayChannlesRake();
                        ObjectMapper.Map(sourceLifePayChannlesRake, targetLifePayChannlesRake);
                        if (sourceLifePayChannlesRake.UserId.HasValue)
                        {
                            targetLifePayChannlesRake.UserId = dicUserIds[sourceLifePayChannlesRake.UserId];
                        }

                        await UpdateLifePayChannlesRake(targetConnName, targetLifePayChannlesRake);
                        logger.LogInformation($"已更新分佣：{targetLifePayChannlesRake.OrderNo}");
                    }
                }
                catch (Exception ex)
                {
                    messages.Add($"未能同步分佣（{sourceLifePayChannlesRake.OrderNo}）发生服务器异常：{ex.Message}");
                    continue;
                }
            }

            foreach (var sourceLifePayConsumption in sourceLifePayConsumptionList)
            {
                try
                {
                    var targetLifePayConsumption = targetLifePayConsumptionList.FirstOrDefault(it => it.Id == sourceLifePayConsumption.Id);
                    if (targetLifePayConsumption == null)
                    {
                        targetLifePayConsumption = new SyncLifePayConsumption();
                        ObjectMapper.Map(sourceLifePayConsumption, targetLifePayConsumption);
                        if (sourceLifePayConsumption.UserId.HasValue)
                        {
                            targetLifePayConsumption.UserId = dicUserIds[sourceLifePayConsumption.UserId];
                        }

                        await InsertLifePayConsumption(targetConnName, targetLifePayConsumption);
                        logger.LogInformation($"已插入消费流水：{targetLifePayConsumption.OrderNo}");
                    }
                    else
                    {
                        targetLifePayConsumption = new SyncLifePayConsumption();
                        ObjectMapper.Map(sourceLifePayConsumption, targetLifePayConsumption);
                        if (sourceLifePayConsumption.UserId.HasValue)
                        {
                            targetLifePayConsumption.UserId = dicUserIds[sourceLifePayConsumption.UserId];
                        }

                        await UpdateLifePayConsumption(targetConnName, targetLifePayConsumption);
                        logger.LogInformation($"已更新消费流水：{targetLifePayConsumption.OrderNo}");
                    }
                }
                catch (Exception ex)
                {
                    messages.Add($"未能同步消费流水（{sourceLifePayConsumption.OrderNo}）发生服务器异常：{ex.Message}");
                    continue;
                }
            }

            foreach (var sourceLifePayExpensesReceipts in sourceLifePayExpensesReceiptsList)
            {
                try
                {
                    if (sourceLifePayExpensesReceipts.FinishTime == DateTime.MinValue)
                    {
                        sourceLifePayExpensesReceipts.FinishTime = null;
                    }

                    var targetLifePayExpensesReceipts = targetLifePayExpensesReceiptsList.FirstOrDefault(it => it.Id == sourceLifePayExpensesReceipts.Id);
                    if (targetLifePayExpensesReceipts == null)
                    {
                        targetLifePayExpensesReceipts = new SyncLifePayExpensesReceipts();
                        ObjectMapper.Map(sourceLifePayExpensesReceipts, targetLifePayExpensesReceipts);
                        if (sourceLifePayExpensesReceipts.UserId.HasValue)
                        {
                            targetLifePayExpensesReceipts.UserId = dicUserIds[sourceLifePayExpensesReceipts.UserId];
                        }

                        await InsertLifePayExpensesReceipts(targetConnName, targetLifePayExpensesReceipts);
                        logger.LogInformation($"已插入收支流水：{targetLifePayExpensesReceipts.OrderNo}");
                    }
                    else
                    {
                        targetLifePayExpensesReceipts = new SyncLifePayExpensesReceipts();
                        ObjectMapper.Map(sourceLifePayExpensesReceipts, targetLifePayExpensesReceipts);
                        if (sourceLifePayExpensesReceipts.UserId.HasValue)
                        {
                            targetLifePayExpensesReceipts.UserId = dicUserIds[sourceLifePayExpensesReceipts.UserId];
                        }

                        await UpdateLifePayExpensesReceipts(targetConnName, targetLifePayExpensesReceipts);
                        logger.LogInformation($"已更新收支流水：{targetLifePayExpensesReceipts.OrderNo}");
                    }
                }
                catch (Exception ex)
                {
                    messages.Add($"未能同步收支流水（{sourceLifePayExpensesReceipts.OrderNo}）发生服务器异常：{ex.Message}");
                    continue;
                }
            }

            return messages;
        }
    }
}