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/consumerclient" "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 *consumerclient.StatusReq) (*consumerclient.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 { status := mc.IntAll((*data)["status"]) published := mc.IntAll((*data)["published"]) var statusData consumerclient.StatusData statusData.Status = "1" if published == 2 { statusData.Status = "2" } else if status == -2 || status == -1 { statusData.Status = "3" } statusData.Published = mc.InterfaceToStr((*data)["published"]) return &consumerclient.StatusResp{ ErrCode: 0, ErrMsg: "", Data: &statusData, }, nil } } else { data := model.Mysql.FindOne("information", map[string]interface{}{"id": msgId}, "", "") if len(*data) > 0 { status := mc.IntAll((*data)["status"]) published := mc.IntAll((*data)["published"]) var statusData consumerclient.StatusData statusData.Status = "1" if published == 2 { statusData.Status = "2" } else if status == -2 || status == -1 { statusData.Status = "3" } statusData.Published = mc.InterfaceToStr((*data)["published"]) return &consumerclient.StatusResp{ ErrCode: 0, ErrMsg: "", Data: &statusData, }, nil } } return &consumerclient.StatusResp{ ErrCode: -1, ErrMsg: "无数据", Data: nil, }, nil }