MessageCenter/rpc/internal/logic/appletterpushlogic.go

package logic

import (
	"app.yhyue.com/moapp/MessageCenter/entity"
	"app.yhyue.com/moapp/MessageCenter/rpc/internal/common"
	"app.yhyue.com/moapp/MessageCenter/rpc/internal/svc"
	"app.yhyue.com/moapp/MessageCenter/rpc/type/message"
	qutil "app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/go-xweb/log"
	"context"
	"fmt"
	"strings"

	"github.com/zeromicro/go-zero/core/logx"
)

type AppLetterPushLogic struct {
	ctx    context.Context
	svcCtx *svc.ServiceContext
	logx.Logger
}

func NewAppLetterPushLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AppLetterPushLogic {
	return &AppLetterPushLogic{
		ctx:    ctx,
		svcCtx: svcCtx,
		Logger: logx.WithContext(ctx),
	}
}

// 发送剑鱼微信模版消息
func (l *AppLetterPushLogic) AppLetterPush(in *message.WxTmplMsgRequest) (*message.SendMsgResponse, error) {
	var userArr []string
	log.Println("app私信push推送内容===", in)
	userArr = strings.Split(in.PositionIds, ",")
	pushConfig, err := common.GetWxTmplConfig(in.MessageClass)
	if err != nil {
		return &message.SendMsgResponse{
			Total:   0,
			Message: err.Error(),
		}, nil
	}

	for _, uId := range userArr {
		if uId == "" {
			continue
		}
		query := make(map[string]interface{})
		uInfo := entity.Mysql.SelectBySql("SELECT user_id FROM base_service.base_position WHERE id = ? ", uId)
		if uInfo != nil && len(*uInfo) > 0 {
			if baseUserId := qutil.Int64All((*uInfo)[0]["user_id"]); baseUserId != 0 {
				query["base_user_id"] = baseUserId
			}
		}
		if len(query) > 0 {
			userData := make(map[string]interface{})
			rData, _ := entity.MQFW.FindOneByField("user", query, fmt.Sprintf(`{"_id":1,"s_appversion":1,"s_nmae":1,"s_nmae":1,"s_jpushid":1,"s_opushid":1,"s_m_openid":1,"o_pushset.%s.i_apppush":1}`, pushConfig.Switch))
			if rData != nil && len(*rData) > 0 {
				userData = *rData
			}

			if err = common.AppPushMsg(userData, pushConfig.Switch, in.Url, in.Title, in.Detail); err != nil {
				return &message.SendMsgResponse{
					Total: 1,
				}, err
			}
		}
	}
	return &message.SendMsgResponse{
		Total: 1,
	}, nil
}