From 2ca5680816d64b566dae213d0499bb8441e48be2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= <zouzongnan1995@icloud.com>
Date: Mon, 21 Nov 2022 10:40:03 +0800
Subject: [PATCH] 1

---
 .../purchase/tiktok_store/store_sku2.go       | 50 +++++++++++++++++--
 1 file changed, 47 insertions(+), 3 deletions(-)

diff --git a/business/partner/purchase/tiktok_store/store_sku2.go b/business/partner/purchase/tiktok_store/store_sku2.go
index ec2d715db..6cacb08f7 100644
--- a/business/partner/purchase/tiktok_store/store_sku2.go
+++ b/business/partner/purchase/tiktok_store/store_sku2.go
@@ -18,6 +18,7 @@ import (
 	"git.rosy.net.cn/jx-callback/globals"
 	"regexp"
 	"strings"
+	"time"
 )
 
 const (
@@ -437,11 +438,18 @@ func (p *PurchaseHandler) UpdateStoreSkusSpecTag(ctx *jxcontext.Context, vendorO
 
 func GetProductAuditList(vendorOrgCode string) map[string]string {
 	var page int64 = 1
-	var pageSize int64 = 100
+	var pageSize int64 = 1
 
-	updateCategory := make(map[string]string, 0) // 修改分类的Map
+	updateCategory := make(map[string]string, 100) // 修改分类的Map
+	ddIDList := make([]string, 0, 100)
+	skuList := make([]struct {
+		DdID   string `json:"dd_id"`
+		ID     int    `json:"id"`
+		NameId int    `json:"name_id"`
+	}, 0, 100)
+	db := dao.GetDB()
 	for {
-		data, err := getAPI(vendorOrgCode, 0, "").GetProductAuditList(page, pageSize, 2)
+		data, _, err := getAPI(vendorOrgCode, 0, "").GetProductAuditList(page, pageSize, 2)
 		if err != nil || len(data) == 0 {
 			break
 		}
@@ -452,11 +460,47 @@ func GetProductAuditList(vendorOrgCode string) map[string]string {
 					list2 := strings.Split(list[1], `”`)
 					categoryNameList := strings.Split(list2[0], "/")
 					updateCategory[utils.Int64ToStr(v.ProductId)] = categoryNameList[len(categoryNameList)-1]
+					ddIDList = append(ddIDList, utils.Int64ToStr(v.ProductId))
 				}
 			}
 
 		}
+
+		sql := " SELECT b.dd_id,s.id,s.name_id FROM store_sku_bind b INNER JOIN sku s ON b.sku_id = s.id AND s.deleted_at = ? WHERE b.dd_id IN (" + dao.GenQuestionMarks(len(ddIDList)) + ") AND b.deleted_at = ?"
+		params := []interface{}{utils.DefaultTimeValue, ddIDList, utils.DefaultTimeValue}
+		if err := dao.GetRows(db, &skuList, sql, params...); err != nil {
+			globals.SugarLogger.Debugf("====================err1 %s", err)
+			return nil
+		}
+		for _, v := range skuList {
+			item := &model.SkuVendorCategoryMap{
+				ModelIDCULD: model.ModelIDCULD{
+					CreatedAt:    time.Now(),
+					UpdatedAt:    time.Now(),
+					DeletedAt:    time.Now(),
+					LastOperator: "18981810340",
+				},
+				NameID:           v.NameId,
+				VendorID:         model.VendorIDDD,
+				VendorCategoryID: updateCategory[v.DdID],
+			}
+			if err := dao.CreateOrUpdate(db, item); err != nil {
+				globals.SugarLogger.Debugf("====================err2 %s", err)
+				return nil
+			}
+		}
+
 		break
+		//if page*pageSize < total {
+		//	page++
+		//}
+		//updateCategory = make(map[string]string, 100) // 修改分类的Map
+		//ddIDList = make([]string, 0, 100)
+		//skuList = make([]struct {
+		//	DdID   string `json:"dd_id"`
+		//	ID     int    `json:"id"`
+		//	NameId int    `json:"name_id"`
+		//}, 0, 100)
 	}
 	return updateCategory
 }