Merge branch 'edb/frequency_notice' into debug

models/wechat.go

@@ -78,8 +78,7 @@ func GetWxToken() (item *WxAccessToken, err error) {
 	}
 	fmt.Println("result", string(result))
 	//必须要初始化该变量，要不然下面会报错
-	item = &WxAccessToken{}
-	err = json.Unmarshal(result, item)
+	err = json.Unmarshal(result, &item)
 	if err != nil {
 		utils.FileLog.Info(fmt.Sprintf("GetWxToken Unmarshal Err: %s ,%s", string(result), err.Error()))
 		return

services/task.go

@@ -255,6 +255,7 @@ func AddEdbTask(cont context.Context) (err error) {
 	//失败列表
 	failList := make([]string, 0)
 
+	wxUser, _ := models.GetWxUserByMobile("17634786714")
 	//task.globalTaskManager.adminTaskList
 	for _, edb := range list {
 		tmpEdb := edb            //指标信息
@@ -390,9 +391,9 @@ func AddEdbTask(cont context.Context) (err error) {
 						return
 					}
 				}
-				if utils.RunMode == "debug" {
+				if utils.RunMode == "debug" && wxUser != nil {
 					//tmpEdb.UserId = 44078 //测试环境的话，发送邮箱给颜鹏
-					tmpEdb.UserId = 51655 //测试环境的话，发送邮箱给嘉豪
+					tmpEdb.UserId = int(wxUser.UserId) //测试环境的话，发送邮箱给嘉豪
 
 				}