开年活动

clueSync/jobutil.go

@@ -1863,6 +1863,8 @@ func sendEmailIfSuccessful(err error, fileName, detailName, dir string) {
 		log.Println("send mail success", fileName, email)
 	}
 }
+
+// 邀请用户处理
 func inviteUser() {
 	log.Println("邀请用户处理开始")
 	//判断节假日
@@ -1902,3 +1904,43 @@ func inviteUser() {
 	}
 	log.Println("邀请用户处理结束")
 }
+
+// 开年活动
+func nextYearActivit() {
+	log.Println("开年活动处理开始")
+	//判断节假日
+	runOk := getRunOk()
+	if !runOk {
+		log.Println("不是工作日，任务暂停")
+		return
+	}
+	rebindTimeEnd := cfg.InviteTime
+	sql := fmt.Sprintf(`select * from user_statistics where createTime > "%s" order by  createTime asc`, rebindTimeEnd)
+	data := BiService.SelectBySql(sql)
+	if data != nil && *data != nil && len(*data) > 0 {
+		for _, v := range *data {
+			rebindTimeEnd = common.ObjToString(v["createTime"])
+			event := gconv.Int64(v["event"])
+			switch event {
+			case 1:
+				v["sourceCode"] = "736"
+			case 2:
+				v["sourceCode"] = "737"
+			case 3:
+				v["sourceCode"] = "738"
+			}
+			v["user_id"] = gconv.String(v["userId"])
+			ok1, ok2, _ := FormatData(v, "invite")
+			if !ok1 {
+				log.Println("线索卡点", "invite", v, rebindTimeEnd)
+			} else {
+				if !ok2 {
+					log.Println("用户分配已达上限", "invite", v, rebindTimeEnd)
+				}
+			}
+		}
+		cfg.InviteTime = rebindTimeEnd
+		common.WriteSysConfig(&cfg)
+	}
+	log.Println("邀请用户处理结束")
+}