jyInfo/rpc/manager/internal/logic/infoonekeyactionlogic.go

package logic

import (
	MI "app.yhyue.com/moapp/jyInfo/rpc/manager/init"
	"app.yhyue.com/moapp/jyInfo/rpc/manager/internal/svc"
	"app.yhyue.com/moapp/jyInfo/rpc/manager/type/manager"
	"app.yhyue.com/moapp/jyInfo/rpc/model"
	es "app.yhyue.com/moapp/jyInfo/rpc/model/es"
	"app.yhyue.com/moapp/jyInfo/rpc/util"
	mc "app.yhyue.com/moapp/jybase/common"
	se "app.yhyue.com/moapp/jybase/encrypt"
	"app.yhyue.com/moapp/jybase/redis"
	"context"
	"fmt"
	"github.com/zeromicro/go-zero/core/logx"
	"time"
)

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

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

// 管理后台一键操作 1：管理后台一键敏感词过滤；2：管理后台一键发布；3管理后台一键删除；
func (l *InfoOneKeyActionLogic) InfoOneKeyAction(in *manager.OneKeyActionReq) (*manager.InfoResp, error) {
	var resp = &manager.InfoResp{}
	if in.UserId != "" && MI.MUserIdMap[in.UserId] {
		msgId := se.SE.DecodeString(in.MsgId)
		var tname = mc.If(in.MsgType == "3", "supply_info", "information").(string)
		data := model.Mysql.SelectBySql(`SELECT a.title,a.detail,a.attach FROM ? a WHERE a.id = ? AND a.type = ?`, tname, msgId, in.MsgType)
		if len(*data) > 0 {
			res := (*data)[0]
			switch in.Type {
			case 1: //一键敏感词过滤
				appendInfo := make(map[string]interface{})
				if res["title"] != nil {
					appendInfo["title"] = mc.InterfaceToStr(res["title"])
				}
				if res["detail"] != nil {
					appendInfo["detail"] = mc.InterfaceToStr(res["detail"])
				}
				if res["attach"] != nil && mc.InterfaceToStr(res["attach"]) != "{}" {
					appendInfo["attach"] = mc.StringToMap(mc.InterfaceToStr(res["attach"]))
				}
				nsq, err := util.NewNsqInfo(model.NsqConfig.Ip, model.NsqConfig.Topic, msgId, "1", mc.InterfaceToStr(in.MsgType), false, appendInfo)
				if err != nil || nsq.NsqPushInfo() != nil {
					resp.ErrCode = -1
					resp.ErrMsg = fmt.Sprintf("nsq 发布异常：%s", res["id"])
					logx.Info(resp.ErrMsg)
				}
			case 2: //一键信息发布
				query := map[string]interface{}{
					"id":     msgId,
					"app_id": in.AppId,
				}
				switch in.MsgType {
				case "3": //供应信息生成索引
					upData := make(map[string]interface{})
					upData["publish_time"] = time.Now().Format("2006-01-02 15:04:05")
					upData["published"] = 2
					entNameKye := fmt.Sprintf("userEntName_%s_%s_%d", mc.InterfaceToStr(res["user_id"]), in.MsgId, in.MsgType)
					entName := redis.GetStr("other", entNameKye)
					supInfo := make(map[string]interface{})
					supInfo["id"] = msgId
					supInfo["title"] = res["title"]
					supInfo["detail"] = res["detail"]
					supInfo["province"] = res["province"]
					supInfo["city"] = res["city"]
					if !es.SaveSupplyInfo(entName, supInfo) {
						resp.ErrCode = -1
						resp.ErrMsg = "信息发布调用失败"
					}
					if !model.Mysql.Update(tname, query, map[string]interface{}{
						"publish_time": time.Now().Format("2006-01-02 15:04:05"),
						"published":    2,
					}) {
						resp.ErrCode = -1
						resp.ErrMsg = resp.ErrMsg + "更新信息失败"
					}
				case "1", "2": //招标信息，采购信息
					//nsq发布信息
					nsq, err := util.NewNsqInfo(model.NsqConfig.Ip, model.NsqConfig.Topic, msgId, "2", mc.InterfaceToStr(in.MsgType), false, res)
					if err != nil || nsq.NsqPushInfo() != nil {
						resp.ErrCode = -1
						resp.ErrMsg = "调用nsq失败"
					}
					if !model.Mysql.Update(tname, query, map[string]interface{}{
						"status": 4,
					}) {
						resp.ErrCode = -1
						resp.ErrMsg = resp.ErrMsg + "更新信息失败"
					}
				}
			case 3: //一键删除
				query := map[string]interface{}{
					"id":     msgId,
					"app_id": in.AppId,
				}
				if data := model.Mysql.FindOne(tname, query, "", ""); data != nil && len(*data) > 0 {
					update := map[string]interface{}{"is_del": -1}
					if !model.Mysql.Update(tname, query, update) {
						resp.ErrCode = -1
						resp.ErrMsg = resp.ErrMsg + "更新信息失败"
					}
				}
				switch in.MsgType {
				case "3": //删除供应信息索引
					if mc.IntAll(res["published"]) == 2 {
						if !es.DelSupplyInfo(mc.InterfaceToStr(msgId)) {
							resp.ErrCode = -1
							resp.ErrMsg = "es删除供应信息失败"
						}
					}
				case "1", "2": //删除 招标信息，采购信息 索引
					if mc.IntAll(res["published"]) == 2 {
						//如果是已经正常发布的信息 同步调用nsq删除
						nsq, err := util.NewNsqInfo(model.NsqConfig.Ip, model.NsqConfig.Topic, msgId, "3", in.MsgType, false, res)
						if err != nil || nsq.NsqPushInfo() != nil {
							resp.ErrCode = -1
							resp.ErrMsg = "nsq回调删除，同步删除信息失败"
						}
					}
				}
			}
		}
	}
	return resp, nil
}