tijiao

rpc/integral.proto

@@ -4,7 +4,7 @@ package integral;
 
 message addReq {
   string userId = 1;
-  int64 countPoints = 2;
+  int countPoints = 2;
 }
 
 message addResp {
@@ -16,7 +16,7 @@ message checkReq {
 }
 
 message checkResp {
-  int64 countPoints = 1;
+  int countPoints = 1;
 }
 
 service Integral {

rpc/internal/logic/integraldetailedchecklogic.go

@@ -32,8 +32,8 @@ func (l *IntegralDetailedCheckLogic) IntegralDetailedCheck(in *integral.AddReq)
 	dat.UserId = in.UserId
 	dat.EndDate = "2021-03"
 	dat.AppId = 10000
-	dat.Page=1;
-	dat.PageSize=2;
+	dat.Page=1
+	dat.PageSize=2
 	data,count := integralService.IntegralDetailedCheck(dat)
 	fmt.Println(count,data)
 	return &integral.AddResp{}, nil

rpc/test/consume_test.go

@@ -21,7 +21,7 @@ import (
 //创建orm引擎
 func init() {
 	var  err  error
-	entity.Engine, err = xorm.NewEngine("mysql", "root:root@tcp(127.0.0.1:3306)/jyintegral?charset=utf8")
+	entity.Engine, err = xorm.NewEngine("mysql", "admin:123456@tcp(192.168.3.14:3306)/jyintegral?charset=utf8")
 	entity.Engine.ShowSQL(true)
 	if err != nil {
 		log.Fatal("数据库连接失败:", err)