diff --git a/business/jxstore/cms/user2.go b/business/jxstore/cms/user2.go index 17580de2b..8e596c364 100644 --- a/business/jxstore/cms/user2.go +++ b/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 }