修改nzj 数量

entity/entity.go

@@ -15,12 +15,13 @@ var (
 	JyDocMysql *mysql.Mysql
 	JyBiMysql  *mysql.Mysql
 	JyTidb     *mysql.Mysql
+	JyBiTidb   *mysql.Mysql
 	Mgo        *mongodb.MongodbSim
 	Es         *elastic.Elastic
 	AreaCode   = map[string]string{}
 )
 
-func InitMysql(n, x, y, z *mysql.Mysql) {
+func InitMysql(n, x, y, z, s *mysql.Mysql) {
 	JyMysql = &mysql.Mysql{
 		Address:      n.Address,
 		UserName:     n.UserName,
@@ -57,6 +58,15 @@ func InitMysql(n, x, y, z *mysql.Mysql) {
 		MaxIdleConns: z.MaxIdleConns,
 	}
 	JyTidb.Init()
+	JyBiTidb = &mysql.Mysql{
+		Address:      s.Address,
+		UserName:     s.UserName,
+		PassWord:     s.PassWord,
+		DBName:       s.DBName,
+		MaxOpenConns: s.MaxOpenConns,
+		MaxIdleConns: s.MaxIdleConns,
+	}
+	JyBiTidb.Init()
 	logx.Info("初始化mysql")
 }
 

rpc/biservice.go

@@ -26,7 +26,7 @@ func main() {
 	conf.MustLoad(*configFile, &c)
 	ctx := svc.NewServiceContext(c)
 	srv := server.NewBiServiceServer(ctx)
-	entity.InitMysql(c.Mysql.JianYu, c.Mysql.JyDoc, c.Mysql.Bi, c.Mysql.Tidb)
+	entity.InitMysql(c.Mysql.JianYu, c.Mysql.JyDoc, c.Mysql.Bi, c.Mysql.Tidb, c.Mysql.BiTidb)
 	entity.InitMongo(c.Mongo.Qfw.MongodbAddr, c.Mongo.Qfw.DbName, c.Mongo.Qfw.Size)
 	entity.InitEs(c.Es.Address, c.Es.DbSize)
 	entity.InitArea()

rpc/etc/biservice.yaml

@@ -34,6 +34,13 @@ Mysql:
     PassWord: "=PDT49#80Z!RVv52_z"
     MaxOpenConns: 5
     MaxIdleConns: 5
+  BiTidb:
+    DBName: Jianyu_subjectdb
+    Address: 192.168.3.217:4000
+    UserName: root
+    PassWord: "=PDT49#80Z!RVv52_z"
+    MaxOpenConns: 5
+    MaxIdleConns: 5
 Mongo:
   Qfw:
     MongodbAddr: 192.168.3.206:27080

rpc/internal/config/config.go

@@ -15,6 +15,7 @@ type Config struct {
 		JyDoc  *mysql.Mysql
 		Bi     *mysql.Mysql
 		Tidb   *mysql.Mysql
+		BiTidb *mysql.Mysql
 	}
 	Mongo struct {
 		Qfw struct {

service/yearEndReport.go

@@ -104,7 +104,7 @@ func MyDataAsset(this *biservice.MyDataAssetReq) *biservice.MyDataAssetResp {
 	followProjectCount = JyTidb.CountBySql(`select count(1) from follow_project_monitor where s_userid=?`, this.UserId)
 	claimCustomerCount = JyMysql.CountBySql(`select count(1) from entniche_user_customer where user_id=?`, this.EntUserId)
 	collectDocCount = JyDocMysql.CountBySql(`select count(1) from user_doc where userId=? and docCategory=2 and isDelete=0`, this.UserId)
-	claimNzjCount = JyBiMysql.CountBySql(`select count(1) from dwd_f_user_claim where user_id=? and status=0 and source_type=1`, this.NewUserId)
+	claimNzjCount = JyBiTidb.CountBySql(`select count(1) from dwd_f_user_claim where user_id=? and status=0 and source_type=1`, this.NewUserId)
 	return &biservice.MyDataAssetResp{
 		ErrorCode: 0,
 		Data: &biservice.MyDataAsset{