Merge branch 'hotfix/v1.5.36.5' into hotfix/v1.5.36.2

clueSync/autoTask.go

@@ -629,7 +629,12 @@ func ClueToDxTask() {
 			if data != nil && len(*data) > 0 {
 				log.Println("企业下员工数：", gconv.Int(val["ent_id"]), len(*data))
 				for _, vv := range *data {
-					childIds = append(childIds, gconv.String(vv["userid"]))
+					//判断员工是否有大会员权益
+					count := TiDb.CountBySql("SELECT COUNT(1) FROM dwd_f_data_equity_info WHERE (product_type = '大会员' or product_type='企业商机管理') AND equity_status = 1 AND user_type = 2 AND user_role = 1 AND uid = ?", gconv.String(vv["uid"]))
+					log.Println("用户是否有权益", gconv.String(vv["uid"]), count)
+					if count > 0 {
+						childIds = append(childIds, gconv.String(vv["userid"]))
+					}
 				}
 			}
 		}

clueSync/main.go

@@ -258,6 +258,8 @@ func main() {
 		select {}
 	} else if *mode == 2 {
 		LabelToClue()
+	} else if *mode == 3 {
+		ClueToDxTask()
 	} else {
 		users()
 		saleLeads()