Merge branch 'master' of http://8.136.199.33:3000/hongze/hongze_cygx into debug

models/wx_template_msg.go

@@ -13,9 +13,10 @@ type SendTemplateResponse struct {
 }
 
 type OpenIdList struct {
-	OpenId string
-	UserId int
-	Mobile string `description:"手机号"`
+	OpenId    string
+	UserId    int
+	Mobile    string `description:"手机号"`
+	CompanyId int    `description:"手机号"`
 }
 
 func GetOpenIdList() (items []*OpenIdList, err error) {

models/wx_user.go

@@ -685,6 +685,14 @@ func GetWxUserisMakerByCompanyIds(companyIds []int) (items []*WxUser, err error)
 	return
 }
 
+// GetWxUserListByCompanyId 根据公司ID获取公司下面所有用户
+func GetWxUserListByCompanyId(companyId int) (items []*WxUser, err error) {
+	o := orm.NewOrmUsingDB("weekly_report")
+	sql := `SELECT user_id,mobile FROM wx_user  WHERE company_id = ?  `
+	_, err = o.Raw(sql, companyId).QueryRows(&items)
+	return
+}
+
 // GetWxUserNumByCompanyIds 根据公司ID获取所有决策人ID
 func GetWxUserNumByCompanyIds(companyIds []int) (items []*WxUserNumGroup, err error) {
 	lenArr := len(companyIds)

services/article.go

@@ -1045,6 +1045,9 @@ func DoArticleOnenIdWxTemplateMsg(articleId int) {
 
 	var mobileArr []string
 	for _, v := range openidPowerListMobile {
+		if v.CompanyId == utils.JMCJ_COMPANY_ID {
+			continue //需求池 1043：深圳进门财经科技股份有限公司下所有的账号，所有活动的新增修改都做推送，所有的报告的新增修改都不做推送。
+		}
 		mobileArr = append(mobileArr, v.Mobile)
 	}
 	openidPowerList, err := models.GetWxOpenIdByMobileSliceList(mobileArr)

services/cygx_yanxuan_special.go

@@ -54,6 +54,9 @@ func SendWxMsgSpecialFollow(specialId int) (err error) {
 	mobile := ``
 
 	for _, v := range userList {
+		if v.CompanyId == utils.JMCJ_COMPANY_ID {
+			continue //需求池 1043：深圳进门财经科技股份有限公司下所有的账号，所有活动的新增修改都做推送，所有的报告的新增修改都不做推送。
+		}
 		mobile += v.Mobile + ","
 	}
 

services/wx_category_template_msg.go

@@ -913,6 +913,9 @@ func SendWxCategoryMsgSpecialFollow(specialId int) (err error) {
 
 	var mobiles []string
 	for _, v := range userList {
+		if v.CompanyId == utils.JMCJ_COMPANY_ID {
+			continue //需求池 1043：深圳进门财经科技股份有限公司下所有的账号，所有活动的新增修改都做推送，所有的报告的新增修改都不做推送。
+		}
 		if v.Mobile != "" {
 			mobiles = append(mobiles, v.Mobile)
 		}

services/wx_user.go

@@ -1565,3 +1565,23 @@ func GetWxUserEndDate(user *models.WxUserItem) (isShowTerminateButton bool, endD
 	}
 	return
 }
+
+// 获取某一个公司下所有用户的手机号
+func GetUserMobileByComapnyId(comppanyId int) (mobileArr []string) {
+	var err error
+	defer func() {
+		if err != nil {
+			fmt.Println(err)
+			go utils.SendAlarmMsg(fmt.Sprint("获取某一个公司下所有用户的手机号 失败 comppanyId", comppanyId, "err", err.Error()), 2)
+		}
+	}()
+	listUser, e := models.GetWxUserListByCompanyId(comppanyId)
+	if e != nil {
+		err = errors.New("GetWxUserListByCompanyId" + e.Error())
+		return
+	}
+	for _, v := range listUser {
+		mobileArr = append(mobileArr, v.Mobile)
+	}
+	return
+}

utils/constants.go

@@ -226,7 +226,8 @@ const (
 )
 
 const (
-	GAO_YI_ZI_CHAN_COMPANY_ID = 5285 // 高毅资产ID
+	GAO_YI_ZI_CHAN_COMPANY_ID = 5285  // 高毅资产ID
+	JMCJ_COMPANY_ID           = 19642 // 深圳进门财经科技股份有限公司ID
 )
 
 // 模板消息地址路由2