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/consumerinfo"
	"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 *consumerinfo.StatusReq) (*consumerinfo.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 consumerinfo.StatusData
			statusData.Status = 1
			if published == 2 {
				statusData.Status = 2
			} else if status == -2 || status == -1 {
				statusData.Status = 3
			}

			statusData.Published = mc.Int64All((*data)["published"])
			return &consumerinfo.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 consumerinfo.StatusData
			statusData.Status = 1
			if published == 2 {
				statusData.Status = 2
			} else if status == -2 || status == -1 {
				statusData.Status = 3
			}
			statusData.Published = mc.Int64All((*data)["published"])
			return &consumerinfo.StatusResp{
				ErrCode: 0,
				ErrMsg:  "",
				Data:    &statusData,
			}, nil
		}
	}
	return &consumerinfo.StatusResp{
		ErrCode: -1,
		ErrMsg:  "无数据",
		Data:    nil,
	}, nil
}