导入拳探类目数据

BBWYB.Server.API/Controllers/DataRepairController.cs

@@ -96,5 +96,9 @@ namespace BBWYB.Server.API.Controllers
         {
             dataRepairBusiness.RepairPurchaseSchemeLastPurchasePrice();
         }
+
+        [HttpPost]
+        public void SyncProductCategory()
+        { dataRepairBusiness.SyncProductCategory(); }
     }
 }

BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs

@@ -958,5 +958,49 @@ namespace BBWYB.Server.Business
             }
             Console.WriteLine(schemeGroups.Count());
         }
+
+        public void SyncProductCategory()
+        {
+            List<PurchaserExtendedInfo> insertList = new List<PurchaserExtendedInfo>();
+            List<long> deletePurchaserExtendedIdList = new List<long>();
+
+            var dbCategoryList = fsql.Select<PurchaserExtendedInfo>()
+                                     .Where(x => x.Type == Enums.PurchaserBasicInfoType.主营类目)
+                                     .ToList();
+
+            var client = opPlatformClientFactory.GetClient(AdapterEnums.PlatformType.拳探);
+            var request = new OP_QueryProductCategoryRequest()
+            {
+                PageIndex = 1,
+                PageSize = 50,
+                AppKey = "BBWYB2023022501",
+                AppSecret = "3a1521deccc6819d61788a0d6baae49e9",
+                AppToken = "9"
+            };
+
+            var qtCategoryList = new List<OP_ProductCategoryResponse>();
+            var response = client.GetProductCategoryList(request);
+            if (response.Items != null)
+                qtCategoryList.AddRange(response.Items);
+
+
+            //找出新增的类目
+            var newCategoryList = qtCategoryList.Where(c => !dbCategoryList.Any(dc => dc.Id == long.Parse(c.CategoryId))).ToList();
+            if (newCategoryList.Count() > 0)
+            {
+                insertList.AddRange(newCategoryList.Select(c => new PurchaserExtendedInfo()
+                {
+                    Id = long.Parse(c.CategoryId),
+                    Name = c.CategoryName,
+                    CreateTime = DateTime.Now,
+                    Type = Enums.PurchaserBasicInfoType.主营类目
+                }).ToList());
+            }
+
+            fsql.Insert(insertList).ExecuteAffrows();
+
+            //找出接口丢失的类目
+
+        }
     }
 }

BBWYB.Server.Business/Purchaser/PurchaserBusiness.cs

@@ -22,7 +22,7 @@ namespace BBWYB.Server.Business
         public ListResponse<PurchaserExtendedInfoResponse> QueryPurchaserCategoryList(QueryPurchaserExtendedRequest request)
         {
             var list = fsql.Select<PurchaserExtendedInfo>()
-                           .Where(x => x.Type == request.Type)
+                           .WhereIf(request.Type != null, x => x.Type == request.Type)
                            .WhereIf(!string.IsNullOrEmpty(request.Keywords), x => x.Name.Contains(request.Keywords))
                            .Count(out var count)
                            .ToList<PurchaserExtendedInfoResponse>();

BBWYB.Server.Model/Dto/Request/Purchaser/QueryPurchaserExtendedRequest.cs

@@ -2,7 +2,7 @@
 {
     public class QueryPurchaserExtendedRequest
     {
-        public Enums.PurchaserBasicInfoType Type { get; set; }
+        public Enums.PurchaserBasicInfoType? Type { get; set; }
 
         /// <summary>
         /// 不传关键字默认查所有

BBWYB.Server.Model/Enums.cs

@@ -332,7 +332,7 @@
         }
 
         /// <summary>
-        /// 厂家经营模式
+        /// 厂家经营模式 贸易 = 0, 厂家 = 1
         /// </summary>
         public enum ManagmentMode
         {

QuanTan.SDK/Client/Supplier/QuanTan_Supplier_ProductClient.cs

@@ -1,5 +1,6 @@
 using BBWYB.Common.Http;
 using QuanTan.SDK.Model;
+using QuanTan.SDK.Models;
 using QuanTan.SDK.Models.Supplier;
 
 namespace QuanTan.SDK.Client.Supplier
@@ -24,5 +25,10 @@ namespace QuanTan.SDK.Client.Supplier
         {
             return SendRequest<object>("api/platform/supply/product/price/change", request, appId, appSecret);
         }
+
+        public QuanTanResponse<QuanTanListResponse<QuanTan_Supplier_ProductCategoryResponse>> GetProductCategoryList(QuanTan_Supplier_SearchProductCategoryRequest request, string appId, string appSecret)
+        {
+            return SendRequest<QuanTanListResponse<QuanTan_Supplier_ProductCategoryResponse>>("api/platform/supply/category/list", request, appId, appSecret);
+        }
     }
 }

QuanTan.SDK/Models/Supplier/Request/Product/QuanTan_Supplier_SearchProductCategoryRequest.cs

@@ -0,0 +1,13 @@
+namespace QuanTan.SDK.Models.Supplier
+{
+    public class QuanTan_Supplier_SearchProductCategoryRequest
+    {
+        public string storeId { get; set; }
+
+        public string categoryIds { get; set; }
+
+        public int pageSize { get; set; } = 20;
+
+        public int page { get; set; } = 1;
+    }
+}

QuanTan.SDK/Models/Supplier/Response/Product/QuanTan_Supplier_ProductCategoryResponse.cs

@@ -0,0 +1,9 @@
+namespace QuanTan.SDK.Models.Supplier
+{
+    public class QuanTan_Supplier_ProductCategoryResponse
+    {
+        public string CategoryId { get; set; }
+
+        public string CategoryName { get; set; }
+    }
+}

SDKAdapter/OperationPlatform/Client/Base/OP_PlatformClient.cs

@@ -56,5 +56,10 @@ namespace SDKAdapter.OperationPlatform.Client
         {
             throw new NotImplementedException();
         }
+
+        public virtual OP_ListResponse<OP_ProductCategoryResponse> GetProductCategoryList(OP_QueryProductCategoryRequest request)
+        {
+            throw new NotImplementedException();
+        }
     }
 }

SDKAdapter/OperationPlatform/Client/Impl/OP_QuanTanClient.cs

@@ -242,5 +242,23 @@ namespace SDKAdapter.OperationPlatform.Client
             if (qtResponse.Status != 200)
                 throw new BusinessException(qtResponse.Message);
         }
+
+        public override OP_ListResponse<OP_ProductCategoryResponse> GetProductCategoryList(OP_QueryProductCategoryRequest request)
+        {
+            var qtResponse = supplier_ProductClient.GetProductCategoryList(new QuanTan_Supplier_SearchProductCategoryRequest()
+            {
+                page = request.PageIndex,
+                pageSize = request.PageSize
+            }, request.AppKey, request.AppSecret);
+            return new OP_ListResponse<OP_ProductCategoryResponse>()
+            {
+                Count = qtResponse.Data.Count,
+                Items = qtResponse.Data.List != null && qtResponse.Data.List.Count() > 0 ? qtResponse.Data.List.Select(x => new OP_ProductCategoryResponse()
+                {
+                    CategoryId = x.CategoryId,
+                    CategoryName = x.CategoryName,
+                }).ToList() : null
+            };
+        }
     }
 }

SDKAdapter/OperationPlatform/Models/Request/Product/OP_QueryProductCategoryRequest.cs

@@ -0,0 +1,9 @@
+namespace SDKAdapter.OperationPlatform.Models
+{
+    public class OP_QueryProductCategoryRequest: BasePlatformRequest
+    {
+        public int PageIndex { get; set; }
+
+        public int PageSize { get; set; }
+    }
+}

SDKAdapter/OperationPlatform/Models/Response/OP_ListResponse.cs

@@ -0,0 +1,9 @@
+namespace SDKAdapter.OperationPlatform.Models
+{
+    public class OP_ListResponse<T> where T:class
+    {
+        public long Count { get; set; }
+
+        public List<T> Items { get; set; }
+    }
+}

SDKAdapter/OperationPlatform/Models/Response/Product/OP_ProductCategoryResponse.cs

@@ -0,0 +1,9 @@
+namespace SDKAdapter.OperationPlatform.Models
+{
+    public class OP_ProductCategoryResponse
+    {
+        public string CategoryId { get; set; }
+
+        public string CategoryName { get; set; }
+    }
+}