diff --git a/BBWYB.Server.API/Controllers/DataRepairController.cs b/BBWYB.Server.API/Controllers/DataRepairController.cs
index 01df8b4..d758794 100644
--- a/BBWYB.Server.API/Controllers/DataRepairController.cs
+++ b/BBWYB.Server.API/Controllers/DataRepairController.cs
@@ -133,5 +133,11 @@ namespace BBWYB.Server.API.Controllers
         {
             dataRepairBusiness.ExportQTSpuAndJDSku();
         }
+
+        [HttpPost]
+        public void BelongBarginTeam()
+        {
+            dataRepairBusiness.BelongBarginTeam();
+        }
     }
 }
diff --git a/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs b/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs
index b9c9b8b..c9335a2 100644
--- a/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs
+++ b/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs
@@ -7,6 +7,8 @@ using BBWYB.Server.Model.Db;
 using BBWYB.Server.Model.Db.HY;
 using BBWYB.Server.Model.Dto;
 using FreeSql;
+using MySqlX.XDevAPI;
+using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
 using SDKAdapter;
 using SDKAdapter.OperationPlatform.Client;
@@ -15,6 +17,7 @@ using SDKAdapter.PurchasePlatform.Client;
 using SDKAdapter.PurchasePlatform.Models;
 using System.Data;
 using System.Reflection;
+using System.Text;
 using Yitter.IdGenerator;
 
 namespace BBWYB.Server.Business
@@ -1440,6 +1443,255 @@ namespace BBWYB.Server.Business
             var path = Path.Combine(Path.GetDirectoryName(Assembly.GetExecutingAssembly().Location), "ExportQTSpuAndJDSku.csv");
             System.IO.File.WriteAllLines(path, result, System.Text.Encoding.UTF8);
         }
+
+        public void BelongBarginTeam()
+        {
+            var lines = System.IO.File.ReadAllLines("C:\\Users\\pengcong\\Desktop\\供应商.csv", Encoding.UTF8).ToList();
+            lines.RemoveAt(0);
+
+            var purchaseRelations = lines.Select(x =>
+            {
+                var array = x.Split(",", StringSplitOptions.RemoveEmptyEntries);
+                var teamId = string.Empty;
+                var teamName = string.Empty;
+                if (array[3] == "陈默")
+                {
+                    teamId = "1760971589383360512";
+                    teamName = "1组";
+                }
+                else
+                {
+                    teamId = "1760971688964526080";
+                    teamName = "2组";
+                }
+                return new
+                {
+                    PurchaserName = array[0],
+                    TeamId = teamId,
+                    TeamName = teamName
+                };
+            });
+
+            var errorPurchaserList = new List<string>();
+            var errorSchemeList = new List<string>();
+            var errorSchemeGroupList = new List<string>();
+
+            var dbPurchaserList = fsql.Select<Purchaser>().ToList();
+            var dbPurchaseGroupList = fsql.Select<PurchaseSchemeGroup>().ToList();
+            var dbSchemeList = fsql.Select<PurchaseScheme>().ToList();
+            var dbSchemeProductList = fsql.Select<PurchaseSchemeProduct>().ToList();
+
+            var updatePurchaserList = new List<Purchaser>();
+            var updateSchemeList = new List<PurchaseScheme>();
+            var updateSchemeGroupList = new List<PurchaseSchemeGroup>();
+            var deletePsgIdList = new List<long>();
+
+            foreach (var purchaseRelation in purchaseRelations)
+            {
+                var dbPurchaser = dbPurchaserList.FirstOrDefault(p => p.Name == purchaseRelation.PurchaserName);
+                if (dbPurchaser == null)
+                {
+                    errorPurchaserList.Add($"未从数据表中找到供应商 {purchaseRelation}");
+                    continue;
+                }
+
+                if (dbPurchaser.BelongBargainTeamId != purchaseRelation.TeamId)
+                {
+                    dbPurchaser.BelongBargainTeamId = purchaseRelation.TeamId;
+                    dbPurchaser.BelongBargainTeamName = purchaseRelation.TeamName;
+                    dbPurchaser.BelongType = Enums.PurchaserBelongType.临时;
+                    updatePurchaserList.Add(dbPurchaser);
+                }
+            }
+
+            foreach (var purchaseRelation in purchaseRelations)
+            {
+                var dbPurchaser = dbPurchaserList.FirstOrDefault(p => p.Name == purchaseRelation.PurchaserName);
+                if (dbPurchaser == null)
+                    continue;
+
+                //查询使用了该采购商的采购方案
+                var usePurchaserSchemeIdList = dbSchemeProductList.Where(psp => psp.PurchaserId == dbPurchaser.Id)
+                                                                .Select(psp => psp.SkuPurchaseSchemeId)
+                                                                .Distinct()
+                                                                .ToList();
+                var usePurchaserSchemeList = dbSchemeList.Where(ps => usePurchaserSchemeIdList.Contains(ps.Id)).ToList();
+
+                foreach (var scheme in usePurchaserSchemeList)
+                {
+                    var pspList = dbSchemeProductList.Where(psp => psp.SkuPurchaseSchemeId == scheme.Id).ToList();
+                    if (pspList.Count() == 0)
+                        continue;
+                    var usePurchaserIdList = pspList.Select(psp => psp.PurchaserId).Distinct().ToList();
+                    var currentSchemePurchaserList = dbPurchaserList.Where(p => usePurchaserIdList.Contains(p.Id)).ToList();
+                    var currentSchemePurchaserBelongGroups = currentSchemePurchaserList.GroupBy(p => p.BelongBargainTeamId);
+                    if (currentSchemePurchaserBelongGroups.Count() > 1)
+                    {
+                        var sb = new StringBuilder($"采购方案{scheme.Id}使用了{currentSchemePurchaserBelongGroups.Count()}个不同归属的采购商 ");
+                        foreach (var belongGroup in currentSchemePurchaserBelongGroups)
+                        {
+                            var teamName = belongGroup.FirstOrDefault()?.BelongBargainTeamName;
+                            sb.Append($"{teamName}:{string.Join(",", belongGroup.Select(x => x.Name))},");
+                        }
+
+                        errorSchemeList.Add(sb.ToString());
+                    }
+                    else if (currentSchemePurchaserBelongGroups.Count() == 1)
+                    {
+                        var firstPurchaser = currentSchemePurchaserBelongGroups.FirstOrDefault()?.FirstOrDefault();
+                        if (scheme.BelongBargainTeamId != firstPurchaser.BelongBargainTeamId)
+                        {
+                            scheme.BelongBargainTeamId = firstPurchaser?.BelongBargainTeamId;
+                            scheme.BelongBargainTeamName = firstPurchaser?.BelongBargainTeamName;
+                            updateSchemeList.Add(scheme);
+                        }
+                    }
+                }
+            }
+
+            foreach (var psg in dbPurchaseGroupList)
+            {
+                var schemeList = dbSchemeList.Where(ps => ps.SchemeGroupId == psg.Id).ToList();
+                if (schemeList.Count() == 0)
+                {
+                    deletePsgIdList.Add(psg.Id);
+                    continue;
+                }
+
+                var currentPsgPurchaserBelongGroups = schemeList.GroupBy(ps => ps.BelongBargainTeamId);
+                if (currentPsgPurchaserBelongGroups.Count() > 1)
+                {
+                    var sb = new StringBuilder($"采购分组{psg.GroupName}使用了{currentPsgPurchaserBelongGroups.Count()}个不同归属的采购方案 ");
+                    foreach (var belongGroup in currentPsgPurchaserBelongGroups)
+                    {
+                        var teamName = belongGroup.FirstOrDefault()?.BelongBargainTeamName;
+                        sb.Append($"{teamName}:{string.Join(",", belongGroup.Select(x => x.Id))},");
+                    }
+                    errorSchemeGroupList.Add(sb.ToString());
+                }
+                else if (currentPsgPurchaserBelongGroups.Count() == 1)
+                {
+                    var firstScheme = schemeList[0];
+                    if (psg.BelongBargainTeamId != firstScheme.BelongBargainTeamId)
+                    {
+                        psg.BelongBargainTeamId = firstScheme.BelongBargainTeamId;
+                        updateSchemeGroupList.Add(psg);
+                    }
+                }
+            }
+
+            if (errorPurchaserList.Count() > 0 ||
+                errorSchemeList.Count() > 0 ||
+                errorSchemeGroupList.Count() > 0)
+            {
+                var msg = JsonConvert.SerializeObject(errorPurchaserList.Union(errorSchemeList).Union(errorSchemeGroupList));
+                throw new BusinessException(msg);
+            }
+
+            #region 更新采购商
+            {
+                var updateList = new List<IUpdate<Purchaser>>();
+                for (var i = 0; i < updatePurchaserList.Count(); i++)
+                {
+                    var purchaser = updatePurchaserList[i];
+                    var update = fsql.Update<Purchaser>(purchaser.Id)
+                                     .Set(p => p.BelongBargainTeamId, purchaser.BelongBargainTeamId)
+                                     .Set(p => p.BelongBargainTeamName, purchaser.BelongBargainTeamName);
+                    updateList.Add(update);
+                    if (updateList.Count() == 10)
+                    {
+                        fsql.Transaction(() =>
+                        {
+                            foreach (var _u in updateList)
+                                _u.ExecuteAffrows();
+                        });
+                        updateList.Clear();
+                        Console.WriteLine($"UpdatePurchaser {i + 1}/{updatePurchaserList.Count()}");
+                    }
+                }
+
+                if (updateList.Count() > 0)
+                {
+                    fsql.Transaction(() =>
+                    {
+                        foreach (var _u in updateList)
+                            _u.ExecuteAffrows();
+                    });
+                    updateList.Clear();
+                    Console.WriteLine($"LastUpdatePurchaser");
+                }
+            }
+            #endregion
+
+            #region 更新采购方案 
+            {
+                var updateList = new List<IUpdate<PurchaseScheme>>();
+                for (var i = 0; i < updateSchemeList.Count(); i++)
+                {
+                    var scheme = updateSchemeList[i];
+                    var update = fsql.Update<PurchaseScheme>(scheme.Id)
+                                     .Set(ps => ps.BelongBargainTeamId, scheme.BelongBargainTeamId)
+                                     .Set(ps => ps.BelongBargainTeamName, scheme.BelongBargainTeamName);
+                    updateList.Add(update);
+                    if (updateList.Count() == 10)
+                    {
+                        fsql.Transaction(() =>
+                        {
+                            foreach (var _u in updateList)
+                                _u.ExecuteAffrows();
+                        });
+                        updateList.Clear();
+                        Console.WriteLine($"UpdateScheme {i + 1}/{updateSchemeList.Count()}");
+                    }
+                }
+
+                if (updateList.Count() > 0)
+                {
+                    fsql.Transaction(() =>
+                    {
+                        foreach (var _u in updateList)
+                            _u.ExecuteAffrows();
+                    });
+                    updateList.Clear();
+                    Console.WriteLine($"LastUpdateScheme");
+                }
+            }
+            #endregion
+
+            #region 更新采购分组
+            {
+                var updateList = new List<IUpdate<PurchaseSchemeGroup>>();
+                for (var i = 0; i < updateSchemeGroupList.Count(); i++)
+                {
+                    var psg = updateSchemeGroupList[i];
+                    var update = fsql.Update<PurchaseSchemeGroup>(psg.Id)
+                                     .Set(g => g.BelongBargainTeamId, psg.BelongBargainTeamId);
+                    updateList.Add(update);
+                    if (updateList.Count() == 10)
+                    {
+                        fsql.Transaction(() =>
+                        {
+                            foreach (var _u in updateList)
+                                _u.ExecuteAffrows();
+                        });
+                        updateList.Clear();
+                        Console.WriteLine($"UpdateSchemeGroup {i + 1}/{updateSchemeGroupList.Count()}");
+                    }
+                }
+
+                if (updateList.Count() > 0)
+                {
+                    fsql.Transaction(() =>
+                    {
+                        foreach (var _u in updateList)
+                            _u.ExecuteAffrows();
+                    });
+                    updateList.Clear();
+                    Console.WriteLine($"LastUpdateSchemeGroup");
+                }
+            }
+            #endregion
+        }
     }
 }