更新

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":       "饿了么",

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                 //

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"

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":       "饿了么",

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
+}