fix:bug

sunpengfei

2025-06-12 edbf9166fc8857f192adade7e15d8f7d52de4b91

 LifePayment/LifePayment.Application/Sync/SyncService.cs

@@ -498,39 +498,39 @@
                }
            }

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

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

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