aa

business/jxstore/cms/user2.go

@@ -4,7 +4,6 @@ import (
 	"errors"
 	"fmt"
 	"git.rosy.net.cn/baseapi/platformapi/qywxapi"
-	"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
 	beego "github.com/astaxie/beego/server/web"
 	"sort"
 	"strings"
@@ -1252,6 +1251,7 @@ func SendQywxPeopleCount(ctx *jxcontext.Context) (err error) {
 			}
 		}
 		//最后找出已有门店电话不在已有群组里的发消息
+		userMobileMap := make(map[string][]*model.Store)
 		for _, v := range mobiles {
 			store := &model.Store{}
 			sql := `
@@ -1282,19 +1282,47 @@ func SendQywxPeopleCount(ctx *jxcontext.Context) (err error) {
 							}
 						}
 					}
-					noticeMsg := fmt.Sprintf("您有负责的商家还未加入相应的[%s]沟通群，门店ID :[%d]，门店名：[%s]，商家电话：[%s,%s]", list[1].(string), store.ID, store.Name, store.Tel1, store.Tel2)
+					//noticeMsg := fmt.Sprintf("您有负责的商家还未加入相应的[%s]沟通群，门店ID :[%d]，门店名：[%s]，商家电话：[%s,%s]", list[1].(string), store.ID, store.Name, store.Tel1, store.Tel2)
 					user2, err := dao.GetUserByID(db, "mobile", store.MarketManPhone)
 					if err == nil {
 						userIDMap[user2.UserID] = user2.UserID
 						for _, v := range userIDMap {
-							if api.DingDingAPI.GetToken() != "" {
-								ddmsg.SendUserMessage(dingdingapi.MsgTyeText, v, "您有商家还未加入企业微信群", noticeMsg)
-							}
+							userMobileMap[v] = append(userMobileMap[v], store)
+							//if api.DingDingAPI.GetToken() != "" {
+							//ddmsg.SendUserMessage(dingdingapi.MsgTyeText, v, "您有商家还未加入企业微信群", noticeMsg)
+							//}
 						}
 					}
 				}
 			}
 		}
+		//一次发太多了，尝试分组发
+		groupList := []string{}
+		groupListAll := [][]string{}
+		for k, v := range userMobileMap {
+			msg := fmt.Sprintf("您有负责的商家还未加入相应的[%s]沟通群，门店信息 :", list[1].(string))
+			for i := 0; i < len(v); i++ {
+				if (i+1)%25 != 0 {
+					msg += utils.Int2Str(v[i].ID) + "，" + v[i].Name + "，商家电话：" + v[i].Tel1 + "，" + v[i].Tel2
+				} else {
+					groupList = append(groupList, k, msg)
+					groupListAll = append(groupListAll, groupList)
+					groupList = []string{}
+					msg = fmt.Sprintf("您有负责的商家还未加入相应的[%s]沟通群，门店信息 :", list[1].(string))
+					msg += utils.Int2Str(v[i].ID) + "，" + v[i].Name + "，商家电话：" + v[i].Tel1 + "，" + v[i].Tel2
+				}
+				if i == len(v)-1 {
+					groupList = append(groupList, k, msg)
+					groupListAll = append(groupListAll, groupList)
+				}
+			}
+		}
+		fmt.Println("groupListAll 11111111111111111111111111111111111111111111111111", groupListAll)
+		//for _, v := range groupListAll {
+		//	if api.DingDingAPI.GetToken() != "" {
+		//		ddmsg.SendUserMessage(dingdingapi.MsgTyeText, v[0], "您有商家还未加入企业微信群", v[1])
+		//	}
+		//}
 	}
 	return err
 }