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

package logic

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

	"app.yhyue.com/moapp/jyInfo/rpc/consumer/consumer"
	"app.yhyue.com/moapp/jyInfo/rpc/consumer/internal/svc"

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

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

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

// 信息审核状态查询
func (l *StatusQueryLogic) StatusQuery(in *consumer.StatusReq) (*consumer.StatusResp, error) {
	msgId := se.SE.DecodeString(in.MsgId) //信息id解密
	if in.Type == 3 {
		data := model.Mysql.FindOne("supply_info", map[string]interface{}{"id": msgId}, "", "")
		if len(*data) > 0 {
			var statusData consumer.StatusData
			statusData.Status = mc.InterfaceToStr((*data)["status"])
			statusData.Published = mc.InterfaceToStr((*data)["published"])
			return &consumer.StatusResp{
				ErrCode: 0,
				ErrMsg:  "",
				Data:    &statusData,
			}, nil
		}
	} else {
		data := model.Mysql.FindOne("information", map[string]interface{}{"id": msgId}, "", "")
		if len(*data) > 0 {
			var statusData consumer.StatusData
			statusData.Status = mc.InterfaceToStr((*data)["status"])
			statusData.Published = mc.InterfaceToStr((*data)["published"])
			return &consumer.StatusResp{
				ErrCode: 0,
				ErrMsg:  "",
				Data:    &statusData,
			}, nil
		}
	}
	return &consumer.StatusResp{
		ErrCode: -1,
		ErrMsg:  "无数据",
		Data:    nil,
	}, nil
}