소스 검색

feat:增加修改关键词保存日志

zhangxinlei1996 2 년 전
부모
커밋
c6a90567b2
2개의 변경된 파일8개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      jyBXSubscribe/api/init/db.go
  2. 7 0
      jyBXSubscribe/api/internal/logic/subscribeupdatelogic.go

+ 1 - 1
jyBXSubscribe/api/init/db.go

@@ -29,7 +29,7 @@ func MongoDBInit(em *entity.Mongo) {
 		}
 		MgoLog.InitPool()
 	}
-	if em.MgoLog.Address != "" {
+	if em.Main.Address != "" {
 		logx.Info("--初始化 mongodb log--")
 		Mgo = mongodb.MongodbSim{
 			MongodbAddr: em.Main.Address,

+ 7 - 0
jyBXSubscribe/api/internal/logic/subscribeupdatelogic.go

@@ -7,6 +7,7 @@ import (
 	"jyBXSubscribe/api/internal/svc"
 	"jyBXSubscribe/api/internal/types"
 	"jyBXSubscribe/rpc/model/service"
+	"time"
 
 	"app.yhyue.com/moapp/jybase/common"
 
@@ -83,6 +84,12 @@ func (l *SubscribeUpdateLogic) SubscribeUpdate(req *types.SubscribeUpdateReq) (r
 		resp.Err_code, resp.Err_msg = -1, "修改失败"
 		l.Error(fmt.Sprintf("%+v", req), resp.Err_msg)
 	} else {
+		it.MgoLog.Save("ovipjy_log", map[string]interface{}{
+			"userid":     req.UserId,
+			"o_vipjy":    req,
+			"createtime": time.Now().Unix(),
+			"type":       "o_vipjy",
+		})
 		resp.Data = map[string]interface{}{
 			"status": status,
 		}