jyInfo/rpc/consumer/internal/logic/inforelatedlogic.go

package logic

import (
	se "app.yhyue.com/moapp/jybase/encrypt"
	"context"
	"jyInfo/rpc/model"

	"jyInfo/rpc/consumer/consumer"
	"jyInfo/rpc/consumer/internal/svc"

	mc "app.yhyue.com/moapp/jybase/common"
	"github.com/zeromicro/go-zero/core/logx"
)

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

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

// 关联公告
func (l *InfoRelatedLogic) InfoRelated(in *consumer.UserIdReq) (*consumer.InfoRelatedResp, error) {
	// todo: add your logic here and delete this line
	var (
		quryname string
		resq     consumer.InfoRelatedResp
	)
	quryname = ` and type=` + mc.InterfaceToStr(in.MsqType)
	if in.Match != "" {
		quryname = ` and title LIKE '%` + in.Match + `%' `
	}

	allData := model.Mysql.SelectBySql(`SELECT id,title from information WHERE user_id="` + in.UserId + `" and published=2 and is_del=1` + quryname + ` order by create_time desc limit 50`)
	if allData == nil || len(*allData) == 0 {
		return &resq, nil
	}
	for _, v := range *allData {
		var data consumer.InfoData
		data.Id = se.SE.EncodeString(mc.InterfaceToStr(v["id"])) //关联信息加密
		data.Title = mc.InterfaceToStr(v["title"])
		resq.Data = append(resq.Data, &data)
	}
	return &resq, nil
}