Merge branch 'dev/v1.2.6_zxl' of moapp/message into feature/v1.2.6

services/activity/task/task.go

@@ -98,6 +98,7 @@ func (this *Task) Task() {
 			}
 		}
 		userMsg, ok := db.Mgo.FindById("user", mgoUserId, `{"s_m_openid":1,"l_registedate":1,"s_m_phone":1,"s_phone":1,"s_myemail":1,"s_nickname":1,"s_headimageurl":1,"s_password":1,"s_company":1,"s_unionid":1,"o_jy":1,"o_vipjy":1,"o_member_jy":1,"i_app_login_task":1}`)
+		log.Println("===>", userMsg)
 		if userMsg == nil || len(*userMsg) == 0 || !ok {
 			return nil, fmt.Errorf("未查询到用户")
 		}
@@ -130,7 +131,7 @@ func (this *Task) Task() {
 				dataM[model.BindMail].FinishTime = now
 				activity.Task(&model.Message{
 					E_code:   "task",
-					E_userId: userId,
+					E_userId: mgoUserId,
 					E_time:   time.Now().Unix(),
 					E_app:    "jyweb_node2",
 					E_body: map[string]interface{}{
@@ -148,7 +149,7 @@ func (this *Task) Task() {
 				dataM[model.FollowWx].FinishTime = now
 				activity.Task(&model.Message{
 					E_code:   "task",
-					E_userId: userId,
+					E_userId: mgoUserId,
 					E_time:   time.Now().Unix(),
 					E_app:    "jyweb_node2",
 					E_body: map[string]interface{}{