no message

models/activity_special_signup.go

@@ -57,3 +57,11 @@ func GetActivityListSpecialAll(activityId int) (items []*CygxActivitySpecialSign
 	_, err = o.Raw(sql, activityId).QueryRows(&items)
 	return
 }
+
+//列表
+func GetActivityListSpecialGroupyMobile() (items []*CygxActivitySpecialSignup, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT *  FROM cygx_activity_special_signup   GROUP BY mobile`
+	_, err = o.Raw(sql).QueryRows(&items)
+	return
+}

services/activity_special.go

@@ -0,0 +1,40 @@
+package services
+
+import (
+	"fmt"
+	"hongze/hongze_cygx/models"
+	"strconv"
+
+	"hongze/hongze_cygx/utils"
+)
+
+func init() {
+	UpdateCygxActivitySpecialSignupNum()
+}
+
+//修改活动状态至进行中
+func UpdateCygxActivitySpecialSignupNum() (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println()
+			fmt.Println(err)
+			go utils.SendAlarmMsg("修改活动状态至进行中失败"+err.Error(), 2)
+			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "修改活动状态至进行中失败 ErrMsg:"+err.Error(), utils.EmailSendToUsers)
+		}
+	}()
+
+	listSpecial, err := models.GetActivityListSpecialGroupyMobile()
+	if err != nil {
+		return err
+	}
+	var mobiles string
+	var companyIds string
+
+	for _, v := range listSpecial {
+		mobiles += "'" + v.Mobile + "'" + ","
+		companyIds += strconv.Itoa(v.CompanyId) + ","
+	}
+	fmt.Println(mobiles)
+	fmt.Println(companyIds)
+	return
+}