MessageCenter/rpc/internal/config/config.go

package config

import (
	"github.com/zeromicro/go-zero/zrpc"
)

type Config struct {
	zrpc.RpcServerConf
	DataSource *mysqlConfig // 手动代码
	BaseSource *mysqlConfig // 手动代码
	WebRpcPort int
	//Mysql           string
	RedisAddr       string `json:"RedisAddr"`
	Mongodb         *mgoConf
	Bidding         *mgoConf
	SurvivalTime    int
	SaveConcurrency int       // 消息保存并发数
	WxWebdomain     string    `json:"WxWebdomain"`
	WxTmplConfig    WxTmplMsg `json:"WxTmplConfig"`
	PushGrpcServer  string    `json:"PushGrpcServer"`
	Mail            []struct {
		Addr string `json:"addr"`
		Port int    `json:"port"`
		Pwd  string `json:"pwd"`
		User string `json:"user"`
	} `json:"mail"`
	Registedate       int64
	TidbEng           string  `json:"Tidb"`
	ClassSearchList   []int64 `json:"ClassSearchList"` // 需要按照messageclass 查询的groupId
	Clickhouse        *CHouseConfig
	GlobMsgLoadTime   string `json:"GlobMsgLoadTime"`
	FreeIntelTime     string `json:"FreeIntelTime"`
	PayIntelTime      string `json:"PayIntelTime"`
	FreePushNumber    int    `json:"FreePushNumber"`
	PayPushNumber     int    `json:"PayPushNumber"`
	EquityInfoMsgType int64  `json:"EquityInfoMsgType"` // 营销权益消息需要特殊处理的消息类型
	NewUserMsgTitle   string `json:"NewUserMsgTitle"`
	IsFilterActive    bool   `json:"IsFilterActive"`
	RedisFailureTime  int    `json:"RedisFailureTime"` //用户消息缓存失效时间
	ThreadCount       int    `json:"ThreadCount"`      //线程锁，配置15个，用户hash取锁
	MsgLogLimit       int    `json:"MsgLogLimit"`      //加载消息记录条数
}

type CHouseConfig struct {
	Addr         string
	UserName     string
	Password     string
	DbName       string
	MaxIdleConns int
	MaxOpenConns int
}

type mysqlConfig struct {
	DbName       string
	Address      string
	UserName     string
	PassWord     string
	MaxOpenConns int
	MaxIdleConns int
}

type mgoConf struct {
	Address         string
	Size            int
	DbName          string
	ReplSet         string
	UserName        string
	Password        string
	Collection      string
	Collection_back string
}

var ConfigJson Config

type WxTmplMsg struct {
	RpcAddr     string `json:"rpcAddr"`
	CloseNotice string `json:"closeNotice"`
	Limit       struct {
		Total       int64 `json:"total"`
		OneDayLimit int64 `json:"oneDayLimit"`
		DuringMine  int   `json:"duringMine"`
		Alert       struct {
			Nums   []int64  `json:"nums"`
			ToMail []string `json:"toMail"`
			CcMail []string `json:"ccMail"`
		} `json:"alert"`
	} `json:"limit"`
}