no message

models/activity_signup_detail.go

@@ -201,3 +201,26 @@ func UpdateActivitySignupDetailMultiMobileAndUserId(items []*CygxActivitySignupD
 	}
 	return
 }
+
+// UpdateActivitySignupDetailMulti 批量修改用户报名信息且报名的人
+func UpdateActivitySignupDetailMultiUserId(items []*CygxActivitySignupDetail) (err error) {
+	o := orm.NewOrm()
+	p, err := o.Raw(` UPDATE cygx_activity_signup_detail SET 
+							user_id = ?
+							WHERE mobile = ?  `).Prepare()
+	if err != nil {
+		return
+	}
+	defer func() {
+		_ = p.Close() // 别忘记关闭 statement
+	}()
+	for _, v := range items {
+		_, err = p.Exec(
+			v.UserId,
+			v.Mobile)
+		if err != nil {
+			return
+		}
+	}
+	return
+}

services/init12.8.go

@@ -232,3 +232,46 @@ func inituser() {
 		}
 	}
 }
+
+func initbug111() {
+	var condition string
+	var pars []interface{}
+	condition = " AND company_id = 5593  AND  mobile  != '' GROUP BY mobile  ORDER BY mobile DESC  LIMIT 0,5000 "
+	signUpDetailList, err := models.GetSignupDetailList(condition, pars)
+	if err != nil && err.Error() != utils.ErrNoRow() {
+		fmt.Println(err)
+		return
+	}
+
+	var mobiles []string
+	for _, v := range signUpDetailList {
+		mobiles = append(mobiles, v.Mobile)
+	}
+
+	listUser, e := models.GetWxUserByMobiles(mobiles)
+	if e != nil {
+		fmt.Println(e)
+		return
+	}
+
+	mapMobile := make(map[string]int)
+	var itemsUpdate []*models.CygxActivitySignupDetail
+	for _, v := range listUser {
+		if v.Mobile == "" {
+			continue
+		}
+		mapMobile[v.Mobile] = v.UserId
+		var itemDetail = new(models.CygxActivitySignupDetail)
+		itemDetail.Mobile = v.Mobile
+		itemDetail.UserId = v.UserId
+		itemsUpdate = append(itemsUpdate, itemDetail)
+	}
+	fmt.Println(len(itemsUpdate))
+
+	err = models.UpdateActivitySignupDetailMultiUserId(itemsUpdate)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+
+}