feat: 提交

services/activity/task/task.go

@@ -124,6 +124,10 @@ func (this *Task) Task() {
 		}
 		mail := gconv.String((*userMsg)["s_myemail"])
 		openid := gconv.String((*userMsg)["s_m_openid"])
+		phone := gconv.String((*userMsg)["s_phone"])
+		if phone == "" {
+			phone = gconv.String((*userMsg)["s_m_phone"])
+		}
 		if !isNew {
 			//邮箱是否绑定
 			if mail != "" {
@@ -160,6 +164,22 @@ func (this *Task) Task() {
 					},
 				})
 			}
+			if phone != "" {
+				dataM[model.FollowWx].Status = 1
+				dataM[model.FollowWx].FinishTime = now
+				activity.Task(&model.Message{
+					E_code:   "task",
+					E_userId: mgoUserId,
+					E_time:   time.Now().Unix(),
+					E_app:    "jyweb_node2",
+					E_body: map[string]interface{}{
+						"code":       1007, //首次订阅
+						"types":      "bindPhone",
+						"baseUserId": baseUserId,
+						"positionId": positionId,
+					},
+				})
+			}
 		}
 		//判断是否已经创建任务
 		integralTaskData := db.Tidb.SelectBySql(`select * from integral_task where user_id =? limit 1`, baseUserId)