pref:导出退款订单新增平台订单号

sunpengfei

2025-06-12 8cffc2cde22edfa1378f5d0e7b9780aa31c6e8ba

 LifePayment/LifePayment.Application/Sync/SyncService.cs

@@ -482,13 +482,13 @@
                    }
                    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}");
                        //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)
@@ -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;
                }
            }