jyInfo/rpc/common/internal/logic/statemethodlogic.go

package logic

import (
	"app.yhyue.com/moapp/jyInfo/rpc/model"
	"app.yhyue.com/moapp/jyInfo/rpc/util"
	"context"

	"log"
	"time"

	"app.yhyue.com/moapp/jyInfo/rpc/common/commoninfo"
	"app.yhyue.com/moapp/jyInfo/rpc/common/internal/svc"

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

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

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

//数据组 rpc回调 修改信息发布状态
func (l *StateMethodLogic) StateMethod(in *commoninfo.StateRequest) (*commoninfo.StateResponse, error) {
	var (
		resp commoninfo.StateResponse
	)
	log.Println("信息发布回调StateMethod", in)
	query := make(map[string]interface{})
	query["id"] = in.Id
	upData := make(map[string]interface{})
	upData["published"] = 2
	upData["publish_id"] = in.PublishId
	upData["publish_time"] = time.Now().Format("2006-01-02 15:04:05")
	data := model.Mysql.FindOne("information", query, "", "")
	if data == nil || len(*data) < 1 {
		log.Println("nsq回调发布状态,获取信息失败", in.Id)
		resp.ErrCode = -1
		resp.ErrMsg = "nsq回调发布状态,获取信息失败"
		return &resp, nil
	}
	//处理对于发布删除冲突问题，在回调发布后查看是否已删除，如已删除在回调删除nsq 未删除继续正常发布流程
	if mc.IntAll((*data)["is_de"]) == -1 {
		nsq, err := util.NewNsqInfo(model.NsqConfig.Ip, model.NsqConfig.Topic, mc.InterfaceToStr((*data)["id"]), "3", mc.InterfaceToStr((*data)["type"]), false, upData)
		if err != nil || nsq.NsqPushInfo() != nil {
			log.Println("信息已删除，同步删除信息失败", model.NsqConfig, upData)
			resp.ErrCode = -1
			resp.ErrMsg = "信息已删除，同步删除信息失败"
		}
		return &resp, nil
	}
	if !model.Mysql.Update("information", query, upData) {
		log.Println("nsq回调发布状态,更新信息状态失败", query, upData)
		resp.ErrCode = -1
		resp.ErrMsg = "nsq回调发布状态,更新信息状态失败"
	}
	return &resp, nil
}