手机号采集

jydocs-back/servers/stdDoc.go

@@ -88,7 +88,6 @@ func (stdDoc *StdDoc) Detail() {
 func (stdDoc *StdDoc) GetDoc(sign string) {
 	userId := common.ObjToString(stdDoc.GetSession("userId"))
 	rData, errMsg := func() (interface{}, error) {
-		log.Println(sign)
 		docId := stdDoc.GetString("docId")
 		if docId == "" {
 			return nil, fmt.Errorf("参数异常")

jydocs-back/servers/userDoc.go

@@ -88,6 +88,7 @@ func (userDoc *UserDoc) DocBuy() {
 	userId := common.ObjToString(userDoc.GetSession("userId"))
 	rData, errMsg := func() (interface{}, error) {
 		docId := userDoc.GetString("docId")
+		phone := userDoc.GetString("phone")
 		if docId == "" {
 			return nil, fmt.Errorf("参数异常")
 		}
@@ -128,6 +129,18 @@ func (userDoc *UserDoc) DocBuy() {
 		if err != nil {
 			return nil, err
 		}
+		//手机号采集
+		go func() {
+			if phone != "" {
+				public.MQFW.Save("user_msg", map[string]interface{}{
+					"s_userId":     userId,
+					"s_phone":      phone,
+					"i_phoneCheck": -1, //未验证
+					"i_time":       time.Now().Unix(),
+					"s_source":     "jydoc",
+				})
+			}
+		}()
 		return map[string]interface{}{
 			"code":    docId,
 			"balance": userPoint - docPoint,