From d3c73d48fc94466a2c0e7b4b480ed95495f4d212 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 11:47:28 +0800
Subject: [PATCH] 1

---
 .../purchase/tiktok_store/store_sku2.go       | 28 +++++++++++++------
 1 file changed, 20 insertions(+), 8 deletions(-)

diff --git a/business/partner/purchase/tiktok_store/store_sku2.go b/business/partner/purchase/tiktok_store/store_sku2.go
index 4e7b86574..a08edec50 100644
--- a/business/partner/purchase/tiktok_store/store_sku2.go
+++ b/business/partner/purchase/tiktok_store/store_sku2.go
@@ -9,6 +9,7 @@ import (
 	sku_syncStock_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/sku_syncStock/request"
 	tiktokShop "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/tiktok_api"
 	"git.rosy.net.cn/baseapi/utils"
+	"git.rosy.net.cn/jx-callback/business/jxstore/cms"
 	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
 	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
 	"git.rosy.net.cn/jx-callback/business/model"
@@ -467,19 +468,13 @@ func GetProductAuditList(vendorOrgCode string) map[string]string {
 			}
 
 		}
-		if len(ddIDList) == 0 {
-			ddIDList = append(ddIDList, "")
-			updateCategory[utils.Int64ToStr(3583974659122702090)] = "99999"
-		}
-		globals.SugarLogger.Debugf("====================ddIDList %s", utils.Format4Output(ddIDList, false))
+
 		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 {
-			globals.SugarLogger.Debugf("======skuList %s", utils.Format4Output(v, false))
 			item := &model.SkuVendorCategoryMap{
 				ModelIDCULD: model.ModelIDCULD{
 					CreatedAt:    time.Now(),
@@ -491,10 +486,27 @@ func GetProductAuditList(vendorOrgCode string) map[string]string {
 				VendorID:         model.VendorIDDD,
 				VendorCategoryID: updateCategory[v.DdId],
 			}
-			if err := dao.CreateOrUpdate(db, item); err != nil {
+			vendorCatgory, err := cms.GetVendorCategoriesByName(14, updateCategory[v.DdId])
+			if err != nil {
 				globals.SugarLogger.Debugf("====================err2 %s", err)
 				return nil
 			}
+			item.VendorCategoryID = vendorCatgory.VendorCategoryID
+			skuVendorCategoryMap := &model.SkuVendorCategoryMap{}
+			if err := dao.GetRow(db, skuVendorCategoryMap, `SELECT * FROM sku_vendor_category_map WHERE name_id = ? AND vendor_id = ? AND deleted_at = ?`, []interface{}{v.NameId, model.VendorIDDD, utils.DefaultTimeValue}); err != nil {
+				globals.SugarLogger.Debugf("====================err3 %s", err)
+				return nil
+			}
+			if skuVendorCategoryMap != nil && skuVendorCategoryMap.ID > 0 {
+				if _, err := dao.UpdateEntity(db, skuVendorCategoryMap, "VendorCategoryID"); err != nil {
+					globals.SugarLogger.Debugf("====================err4 %s", err)
+				}
+			} else {
+				if err := dao.CreateEntity(db, item); err != nil {
+					globals.SugarLogger.Debugf("====================err5 %s", err)
+				}
+			}
+
 		}
 		break
 		//if page*pageSize < total {