配置

clueSync/config.json

@@ -1,28 +1 @@
-{
-  "lastOrderId": 261915,
-  "lastOrderClueId": "2025-05-16 10:05:24",
-  "lastUserId": "2025-04-15 15:20:01",
-  "lastXcxUserId": "2025-04-17 15:03:03",
-  "lastId": "67f8808952d21982ca5970cb",
-  "lastOrderTime": "2025-04-21 10:41:30",
-  "lastUserTime": "2025-04-21 13:30:02",
-  "lastSubscribeId": "67fcb9c1cdf0004e40e69cba",
-  "lastMessageTime": "2025-04-02 10:21:06",
-  "lastkcTime": "2025-05-17 15:18:00",
-  "lastEverythingTime": "2024-11-20 13:40:21",
-  "lastEventRegTime": "2024-11-20 13:40:21",
-  "lastReadClueTime": "2025-03-25 14:43:42",
-  "bigSaleTime": 1747293636,
-  "bigOrderTime": "2025-04-29 15:18:31",
-  "marketSaleTime": 1745218148,
-  "advisoryCommitteeTime": 1745216244,
-  "selectionDepartmentTime": 1745216244,
-  "allocationTime": "2024-11-20 13:40:21",
-  "allocationRatio": 2,
-  "activeTime": "2025-04-14 22:00:00",
-  "rebindTime": "2025-04-09 11:11:56",
-  "inviteTime": "2025-04-21 00:00:00",
-  "activityTime": "2025-04-03 16:59:23",
-  "lastKcChangeTime": "2025-04-14 15:00:27.000",
-  "lastMessageButtonTime": "2025-05-28 16:59:23"
-}
+{"lastOrderId":263043,"lastOrderClueId":"2025-05-16 10:05:24","lastUserId":"2025-04-15 15:20:01","lastXcxUserId":"2025-04-17 15:03:03","lastId":"67f8808952d21982ca5970cb","lastOrderTime":"2025-04-21 10:41:30","lastUserTime":"2025-04-21 13:30:02","lastSubscribeId":"67fcb9c1cdf0004e40e69cba","lastMessageTime":"2025-04-02 10:21:06","lastMessageButtonTime":"2025-05-28 16:59:23","lastkcTime":"2025-05-17 15:18:00","lastEverythingTime":"2024-11-20 13:40:21","lastEventRegTime":"2024-11-20 13:40:21","lastReadClueTime":"2025-03-25 14:43:42","bigSaleTime":1747293636,"bigOrderTime":"2025-04-29 15:18:31","marketSaleTime":1745218148,"advisoryCommitteeTime":1745216244,"selectionDepartmentTime":1745216244,"allocationTime":"2024-11-20 13:40:21","allocationRatio":2,"activeTime":"2025-04-14 22:00:00","rebindTime":"2025-04-09 11:11:56","inviteTime":"2025-04-21 00:00:00","activityTime":"2025-04-03 16:59:23","lastKcChangeTime":"2025-04-14 15:00:27.000"}

clueSync/lable.json

@@ -0,0 +1,124 @@
+{
+  "ConditionConfig": [
+    {
+      "topName": "公海中电销历史标记用户",
+      "subName": "访问标讯历史意向用户",
+      "conditionArr": [
+        {
+          "code": "7day_article_gte_7",
+          "fool": true
+        },
+        {
+          "code": "telemarketing_intended_30_day",
+          "fool": true
+        },
+        {
+          "code": "telemarketing_follow_7_day",
+          "fool": false
+        },
+        {
+          "code": "telemarketing_listen_7_day",
+          "fool": false
+        }
+      ]
+    },{
+      "topName": "公海中电销历史标记用户",
+      "subName": "访问标讯历史意向用户",
+      "conditionArr": [
+        {
+          "code": "7day_article_gte_7",
+          "fool": true
+        },
+        {
+          "code": "telemarketing_highIntended_30_day",
+          "fool": true
+        },
+        {
+          "code": "telemarketing_follow_7_day",
+          "fool": false
+        },
+        {
+          "code": "telemarketing_listen_7_day",
+          "fool": false
+        }
+      ]
+    },{
+      "topName": "公海中电销历史标记用户",
+      "subName": "访问标讯历史意向用户",
+      "conditionArr": [
+        {
+          "code": "7day_article_gte_7",
+          "fool": true
+        },
+        {
+          "code": "telemarketing_beSigned_30_day",
+          "fool": true
+        },
+        {
+          "code": "telemarketing_follow_7_day",
+          "fool": false
+        },
+        {
+          "code": "telemarketing_listen_7_day",
+          "fool": false
+        }
+      ]
+    },{
+      "topName": "公海中电销历史标记用户",
+      "subName": "点击留资弹框的历史接通用户",
+      "conditionArr": [
+        {
+          "code": "click_saleLeads_gte_1_7day",
+          "fool": true
+        },
+        {
+          "code": "telemarketing_hasCall_30_day",
+          "fool": true
+        },
+        {
+          "code": "telemarketing_follow_7_day",
+          "fool": false
+        },
+        {
+          "code": "telemarketing_listen_7_day",
+          "fool": false
+        }
+      ]
+    },{
+      "topName": "公海中电销历史标记用户",
+      "subName": "访问标讯的近期未建联用户",
+      "conditionArr": [
+        {
+          "code": "7day_article_gte_10",
+          "fool": true
+        },
+        {
+          "code": "telemarketing_follow_7_day",
+          "fool": false
+        },
+        {
+          "code": "telemarketing_listen_7_day",
+          "fool": false
+        }
+      ]
+    },
+    {
+      "topName": "公海中电销历史标记用户",
+      "subName": "访问标讯的近期未建联用户",
+      "conditionArr": [
+        {
+          "code": "buryPoint_share_7_day_gte2",
+          "fool": true
+        },
+        {
+          "code": "telemarketing_follow_7_day",
+          "fool": false
+        },
+        {
+          "code": "telemarketing_listen_7_day",
+          "fool": false
+        }
+      ]
+    }
+  ]
+}

doFreeClueSign/job/job.go

@@ -87,7 +87,7 @@ func (jm *JobManager) LoadAgainSubUser() {
 // @Description 过滤订单 筛选活动注册用户
 // @Date 2024/11/18
 func loadOrder() {
-	sql := `SELECT id, filter, order_code, product_type, user_id, user_phone, vip_starttime, vip_endtime FROM dataexport_order WHERE id > ? AND order_status = 1 ORDER BY id ASC`
+	sql := `SELECT id, filter, order_code, product_type, user_id, user_phone FROM dataexport_order WHERE id > ? AND order_status = 1 ORDER BY id ASC`
 	res, err := g.DB("jianyu").Query(ctx, sql, LastId)
 	if err == nil && !res.IsEmpty() {
 		for _, m := range res.List() {
@@ -131,7 +131,7 @@ func loadOrder() {
 }
 
 func LoadOrderOther() {
-	sql := `SELECT id, filter, order_code, product_type, user_id, user_phone, vip_starttime, vip_endtime FROM dataexport_order WHERE vip_endtime > ? AND vip_endtime < ? AND order_status = 1 AND (filter LIKE '%邀请好友成功%' OR filter LIKE '%被邀请注册成功%' OR filter LIKE '%2024年新用户注册赠送7天超级订阅%') ORDER BY id ASC`
+	sql := `SELECT id, filter, order_code, product_type, user_id, user_phone FROM dataexport_order WHERE vip_endtime > ? AND vip_endtime < ? AND order_status = 1 AND (filter LIKE '%邀请好友成功%' OR filter LIKE '%被邀请注册成功%' OR filter LIKE '%2024年新用户注册赠送7天超级订阅%') ORDER BY id ASC`
 	sql1 := `SELECT count(1) FROM dataexport_order WHERE vip_endtime > ? AND vip_endtime < ? AND order_status = 1 AND (filter LIKE '%邀请好友成功%' OR filter LIKE '%被邀请注册成功%' OR filter LIKE '%2024年新用户注册赠送7天超级订阅%')`
 	sql2 := `SELECT id, vip_endtime FROM jianyu.dataexport_order WHERE (product_type = 'VIP订阅' OR product_type = '大会员') AND id > ? AND user_id = ? AND order_status = 1`
 	now := time.Now().Format(time.DateTime)
@@ -164,7 +164,7 @@ func verifyDate(v int64) bool {
 // @Date 2024/11/19
 func LoadOrderHis() {
 	g.Log().Infof(ctx, "LoadOrderHis start")
-	sql := `SELECT id, filter, order_code, product_type, user_id, user_phone, vip_starttime, vip_endtime FROM dataexport_order WHERE id <= ? AND order_status = 1 AND filter LIKE '%邀请好友成功%' ORDER BY id DESC`
+	sql := `SELECT id, filter, order_code, product_type, user_id, user_phone FROM dataexport_order WHERE id <= ? AND order_status = 1 AND filter LIKE '%邀请好友成功%' ORDER BY id DESC`
 	res, err := g.DB("jianyu").Query(ctx, sql, LastId)
 	if err == nil && !res.IsEmpty() {
 		for _, m := range res.List() {