模版消息

models/tables/report_send_ths_detail/create.go

@@ -4,7 +4,7 @@ import "hongze/hongze_yb/global"
 
 //新增报告发送给同花顺的记录
 func AddReportSendThsDetail(item *ReportSendThsDetail) (lastId int, err error) {
-	err = global.MYSQL["rddp"].Create(item).Error
+	err = global.DEFAULT_MYSQL.Create(item).Error
 	lastId = item.SendId
 	return
 }

models/tables/report_send_ths_detail/update.go

@@ -6,7 +6,7 @@ import (
 
 //修改报告发送给同花顺的记录状态
 func ModifyReportSendThsDetailStatus(sendId int, status int8, remark string) (err error) {
-	err = global.MYSQL["rddp"].Model(ReportSendThsDetail{}).Where("send_id = ? ", sendId).Updates(ReportSendThsDetail{
+	err = global.DEFAULT_MYSQL.Model(ReportSendThsDetail{}).Where("send_id = ? ", sendId).Updates(ReportSendThsDetail{
 		Status:     status,
 		Remark:     remark,
 	}).Error

services/wechat/template_msg.go

@@ -284,6 +284,46 @@ func SendVoiceBroadcastWxMsg(broadcastId int, sectionName, broadcastName string)
 	if wxAppPath != "" {
 		sendMap["miniprogram"] = map[string]interface{}{"appid": WxYbAppId, "pagepath": wxAppPath}
 	}
-	err = SendMultiTemplateMsg(sendMap, openIdList, wxAppPath, utils.TEMPLATE_MSG_YB_VOICE_BROADCAST)
+	err = SendMultiTemplateMsgNoReturn(sendMap, openIdList, wxAppPath, utils.TEMPLATE_MSG_YB_VOICE_BROADCAST)
+	return
+}
+
+// SendMultiTemplateMsg 推送模板消息至多个用户中间出错不返回
+func SendMultiTemplateMsgNoReturn(sendMap map[string]interface{}, items []*OpenIdList, resource string, sendType int) (err error) {
+	ws := GetWxChat()
+	accessToken, err := ws.GetAccessToken()
+	if err != nil {
+		return
+	}
+	for _, item := range items {
+		sendMap["touser"] = item.OpenId
+		data, e := json.Marshal(sendMap)
+		if e != nil {
+			err = e
+			return
+		}
+		ts := &TemplateMsgSendClient{
+			AccessToken: accessToken,
+			Data:        data,
+		}
+		result, e := ts.SendMsg()
+		if result == nil {
+			return
+		}
+		// 推送消息记录
+		{
+			go func(v *OpenIdList) {
+				sendStatus := 1
+				if e != nil {
+					sendStatus = 0
+				}
+				resultJson, _ := json.Marshal(result)
+				_ = AddUserTemplateRecord(v.UserId, sendStatus, sendType, v.OpenId, resource, string(data), string(resultJson))
+			}(item)
+		}
+		if e != nil {
+			err = e
+		}
+	}
 	return
 }