animeic 1 年之前
父节点
当前提交
4c845b789b
共有 3 个文件被更改,包括 5 次插入5 次删除
  1. 3 3
      pay/bus/order.go
  2. 1 1
      pay/db/db.go
  3. 1 1
      pay/db/redis.go

+ 3 - 3
pay/bus/order.go

@@ -6,7 +6,6 @@ import (
 	"pay/db"
 	"pay/db/repo"
 	"pay/utils"
-	"strconv"
 	"time"
 
 	"github.com/nats-io/nats.go"
@@ -63,8 +62,9 @@ func getPayOrder(ctx context.Context, query map[string]interface{}) (order *pay.
 		CollectName: repo.CollectionOrder,
 		Query:       query,
 	}, &order)
-	amount, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", *order.RealAmount), 64)
-	order.RealAmount = &amount
+	if err != nil {
+		fmt.Println(err)
+	}
 	return
 }
 

+ 1 - 1
pay/db/db.go

@@ -39,7 +39,7 @@ var MongoInst *MongoDB = nil
 // 从config-service中获取配置,创建
 func NewConfigMongoDB(bus *comm.NatsBus) *MongoDB {
 
-	MongoInst, err := bus.NewMongoDBFromConfigDev("mongo")
+	MongoInst, err := bus.NewMongoDBFromConfig("mongo")
 	if err != nil {
 		panic(err)
 	}

+ 1 - 1
pay/db/redis.go

@@ -7,7 +7,7 @@ import (
 
 // 从config-service中获取配置,创建
 func NewConfigRedisClient(bus *comm.NatsBus) *redis.Client {
-	redisCli, err := bus.NewRedisFromConfigDev("redis")
+	redisCli, err := bus.NewRedisFromConfig("redis")
 	if err != nil {
 		panic(err)
 	}