From 52547d3a329dcde5b8f5cfd3caa146b33ce8aed5 Mon Sep 17 00:00:00 2001
From: huangjiajun <582604932@qq.com>
Date: Thu, 27 Mar 2025 16:27:16 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/svc/platform/svc_guide_order_list.go      | 11 +++++-----
 app/task/init.go                              | 11 +++++-----
 app/task/md/cron_key.go                       |  1 +
 .../svc_tik_tok_local_life_order_settle.go    | 20 +++++++++++-------
 app/task/task_tik_tok_chanxuan_settle.go      | 21 +++++++++++++++++++
 5 files changed, 45 insertions(+), 19 deletions(-)
 create mode 100644 app/task/task_tik_tok_chanxuan_settle.go

diff --git a/app/svc/platform/svc_guide_order_list.go b/app/svc/platform/svc_guide_order_list.go
index 10b635a..5418711 100644
--- a/app/svc/platform/svc_guide_order_list.go
+++ b/app/svc/platform/svc_guide_order_list.go
@@ -13,12 +13,11 @@ func GuideOrderList(c *gin.Context, args map[string]string) ([]map[string]string
 	list, total := db.GetGuideOrderListTotal(args)
 	var data = make([]map[string]string, 0)
 	platformMap := map[string]string{
-		"tikTok_life": "抖音本地生活",
-		"csjp":        "穿山甲抖音",
-		"csjp_live":   "穿山甲抖音直播商品",
-		"kuaishou":    "快手",
-		"vip":         "唯品会",
-
+		"tikTok_life":   "抖音本地生活",
+		"csjp":          "穿山甲抖音",
+		"csjp_live":     "穿山甲抖音直播商品",
+		"kuaishou":      "快手",
+		"vip":           "唯品会",
 		"kuaishou_live": "快手直播商品",
 		"meituan":       "美团",
 		"own_ele":       "饿了么",
diff --git a/app/task/init.go b/app/task/init.go
index af3b2a6..42481d0 100644
--- a/app/task/init.go
+++ b/app/task/init.go
@@ -93,11 +93,12 @@ func initTasks() {
 	jobs[taskMd.ZhimengCronCinema5bmsOrder] = taskCinema5bmsOrder             //
 	jobs[taskMd.ZhimengCronCinema5bmsYesterOrder] = taskCinema5bmsYesterOrder //
 
-	jobs[taskMd.ZhimengCronTikTokCsjp] = taskTikTokCsjp                   //
-	jobs[taskMd.ZhimengCronTikTokCsjpActivity] = taskTikTokCsjpActivity   //
-	jobs[taskMd.ZhimengCronTikTokCsjpLive] = taskTikTokCsjpLive           //
-	jobs[taskMd.ZhimengCronTikTokChanxuan] = taskTikTokCsjpChanxuan       //
-	jobs[taskMd.ZhimengCronTikTokChanxuanPay] = taskTikTokCsjpChanxuanPay //
+	jobs[taskMd.ZhimengCronTikTokCsjp] = taskTikTokCsjp                         //
+	jobs[taskMd.ZhimengCronTikTokCsjpActivity] = taskTikTokCsjpActivity         //
+	jobs[taskMd.ZhimengCronTikTokCsjpLive] = taskTikTokCsjpLive                 //
+	jobs[taskMd.ZhimengCronTikTokChanxuan] = taskTikTokCsjpChanxuan             //
+	jobs[taskMd.ZhimengCronTikTokChanxuanSettle] = taskTikTokCsjpChanxuanSettle //
+	jobs[taskMd.ZhimengCronTikTokChanxuanPay] = taskTikTokCsjpChanxuanPay       //
 
 	jobs[taskMd.ZhimengCronTikTokTask] = taskTikTokTask                             //
 	jobs[taskMd.ZhimengCronTikTokTaskRelate] = taskTikTokTaskRelate                 //
diff --git a/app/task/md/cron_key.go b/app/task/md/cron_key.go
index a6cc845..b0435b4 100644
--- a/app/task/md/cron_key.go
+++ b/app/task/md/cron_key.go
@@ -5,6 +5,7 @@ const (
 	ZhimengCronTikTokCsjp                      = "zhimeng_cron_tik_tok_csjp"
 	ZhimengCronTikTokChanxuan                  = "zhimeng_cron_tik_tok_chanxuan"
 	ZhimengCronTikTokChanxuanPay               = "zhimeng_cron_tik_tok_chanxuan_pay"
+	ZhimengCronTikTokChanxuanSettle            = "zhimeng_cron_tik_tok_chanxuan_settle"
 	ZhimengCronCinema5bms                      = "zhimeng_cron_cinema5bms"
 	ZhimengCronPLayletBihaiOrder               = "zhimeng_cron_playlet_bihai_order"
 	ZhimengCronCinema5bmsOrder                 = "zhimeng_cron_cinema5bms_order"
diff --git a/app/task/svc/svc_tik_tok_local_life_order_settle.go b/app/task/svc/svc_tik_tok_local_life_order_settle.go
index a4e2115..8372ea6 100644
--- a/app/task/svc/svc_tik_tok_local_life_order_settle.go
+++ b/app/task/svc/svc_tik_tok_local_life_order_settle.go
@@ -32,10 +32,12 @@ func TikTokLocalLifeOrderSettle() {
 	}
 	fmt.Println(utils.SerializeStr(order))
 	platformMap := map[string]string{
-		"tikTok_life":   "抖音本地生活",
-		"csjp":          "穿山甲抖音",
-		"csjp_live":     "穿山甲抖音直播商品",
-		"kuaishou":      "快手",
+		"tikTok_life": "抖音本地生活",
+		"csjp":        "穿山甲抖音",
+		"csjp_live":   "穿山甲抖音直播商品",
+		"kuaishou":    "快手",
+		"vip":         "唯品会",
+
 		"kuaishou_live": "快手直播商品",
 		"meituan":       "美团",
 		"own_ele":       "饿了么",
@@ -138,10 +140,12 @@ func ChanxuanOrderSettle() {
 	}
 	fmt.Println(utils.SerializeStr(order))
 	platformMap := map[string]string{
-		"tikTok_life":   "抖音本地生活",
-		"csjp":          "穿山甲抖音",
-		"csjp_live":     "穿山甲抖音直播商品",
-		"kuaishou":      "快手",
+		"tikTok_life": "抖音本地生活",
+		"csjp":        "穿山甲抖音",
+		"csjp_live":   "穿山甲抖音直播商品",
+		"kuaishou":    "快手",
+		"vip":         "唯品会",
+
 		"kuaishou_live": "快手直播商品",
 		"meituan":       "美团",
 		"own_ele":       "饿了么",
diff --git a/app/task/task_tik_tok_chanxuan_settle.go b/app/task/task_tik_tok_chanxuan_settle.go
new file mode 100644
index 0000000..5c4c0a7
--- /dev/null
+++ b/app/task/task_tik_tok_chanxuan_settle.go
@@ -0,0 +1,21 @@
+package task
+
+import (
+	"applet/app/task/svc"
+	"math/rand"
+	"time"
+)
+
+func taskTikTokCsjpChanxuanSettle() {
+	for {
+		if len(ch) > workerNum {
+			time.Sleep(time.Millisecond * time.Duration(rand.Intn(1000)))
+		} else {
+			goto START
+		}
+	}
+START:
+	ch <- 1
+	svc.TikTokChanxuan(2)
+	<-ch
+}