@@ -216,14 +216,14 @@ func MultSave(this message.MultipleSaveMsgReq) (int64, string) {
if userIdArr[i] == "" {
continue
}
+ name := userNameArr[i]
wg.Add(1)
entity.SaveConcurrencyChan <- 1
- go func(v string) {
+ go func(v, userName string) {
defer func() {
<-entity.SaveConcurrencyChan
wg.Done()
}()
- userName := userNameArr[i]
//消息数组
c := entity.Mysql.Count("conversation", map[string]interface{}{"receive_id": v, "send_id": this.SendUserId})
sql3 := `INSERT INTO message(appid,receive_userid,receive_name,send_userid,send_name,title,content,msg_type,link,cite_id,createtime,isRead,isdel,msg_log_id,show_buoy,show_content) values ("%s",'%s','%s','%s','%s','%s','%s',%d,'%s',0,'%s',0,1,%d,%d,'%s');`
@@ -256,10 +256,8 @@ func MultSave(this message.MultipleSaveMsgReq) (int64, string) {
log.Println("存redis：", ok)
- }(userIdArr[i])
-
+ }(userIdArr[i], name)
wg.Wait()
return 0, ""
