update

pay/api/router.go

@@ -23,6 +23,7 @@ func RegRouters(svc *Service) {
 
 	// 其他测试
 	payGroup.GET("/print", PrintParam)
+	payGroup.GET("/getIp", GetIp)
 }
 
 func Logger() gin.HandlerFunc {

pay/api/test.go

@@ -11,3 +11,8 @@ func PrintParam(c *gin.Context, apictx *ApiSession) (interface{}, error) {
 	// return utils.IntToDecimal(1)
 	return time.Now(), nil
 }
+func GetIp(c *gin.Context, apictx *ApiSession) (interface{}, error) {
+
+	// return utils.IntToDecimal(1)
+	return c.RemoteIP(), nil
+}

pay/assettest.log

@@ -44,3 +44,4 @@
 {"level":"info","timestamp":"2023-07-07 14:36:21","message":"[初始化支付客户端]","service_name":"assettest"}
 {"level":"info","timestamp":"2023-07-07 14:47:56","message":"[初始化支付客户端]","service_name":"assettest"}
 {"level":"info","timestamp":"2023-07-07 15:30:44","message":"[初始化支付客户端]","service_name":"assettest"}
+{"level":"info","timestamp":"2023-07-10 16:41:37","message":"[初始化支付客户端]","service_name":"assettest"}

pay/bus/nats.go

@@ -19,9 +19,14 @@ func NewNatsBus(app *conf.AppConf) *comm.NatsBus {
 		PayPointList(),
 		PayPointDetail(),
 		GetPointAmount(),
+
 		PayOrderCreate(),
 		PayOrderDetail(),
 		PayOrderUpdate(),
+
+		PayRefundCreate(),
+		PayRefundUpdate(),
+		PayRefundDetail(),
 	})
 	NatsCenter = bus
 	return NatsCenter

pay/bus/refund.go

@@ -63,6 +63,22 @@ func getPayRefund(ctx context.Context, query map[string]interface{}) (refund *pa
 	return
 }
 
+// 更新退款
+func PayRefundUpdate() *comm.NatsMsgReplyer {
+	refund := pay.ReFund{}
+	utils.ConsoleFormat(pay.PayRefundUpdateApi)
+	return &comm.NatsMsgReplyer{
+		Subject: pay.PayRefundUpdateApi,
+		Entity:  func() interface{} { return &refund },
+		Cb2: func(_ *nats.Msg, entity interface{}) (interface{}, error) {
+			refund := entity.(*pay.ReFund)
+			ctx := context.Background()
+			res, err := updateRefund(ctx, refund)
+			return res, err
+		},
+	}
+}
+
 func updateRefund(ctx context.Context, refund *pay.ReFund) (result *mongo.UpdateResult, err error) {
 	refund.UpdateTime = time.Now()
 	result, err = repo.RepoUpdateSetDoc(&repo.RepoSession{Ctx: ctx, Client: db.GMongoDb}, repo.CollectionRefund, refund.Id.Hex(), &refund)

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)
 	}