feat:资源扣减

rpc/internal/entity/base_resource_use.go

@@ -54,13 +54,13 @@ func (b *base_resource_use) FindLastOne(appid, function_code string, user_id, en
 //新增扣减记录
 func (b *base_resource_use) Deduction(use_values []interface{}, detail_values [][]interface{}, update [][]interface{}) bool {
 	return Mysql_BaseService.ExecTx("新增扣减记录", func(tx *sql.Tx) bool {
-		v1, v2 := Mysql_BaseService.InsertBatchByTx(tx, "base_resource_use", []string{"appid", "ent_id", "user_id", "function_code", "add_count", "surplus_count", "deduction_count", "create_time"}, use_values)
+		v1, v2 := Mysql_BaseService.InsertBatchByTx(tx, "base_resource_use", []string{"appid", "ent_id", "user_id", "function_code", "add_count", "surplus_count", "deduct_count", "create_time"}, use_values)
 		array := []interface{}{}
 		for _, v := range detail_values {
 			array = append(array, v...)
 			array = append(array, v2)
 		}
-		v3, v4 := Mysql_BaseService.InsertBatchByTx(tx, "base_resource_use_detail", []string{"appid", "power_id", "surplus_count", "deduction_count", "create_time", "use_id"}, array)
+		v3, v4 := Mysql_BaseService.InsertBatchByTx(tx, "base_resource_use_detail", []string{"appid", "power_id", "surplus_count", "deduct_count", "create_time", "use_id"}, array)
 		ok := true
 		if len(update) > 0 {
 			ok = Mysql_BaseService.UpdateBathByTx(tx, "base_power", []string{"id", "surplus_count", "update_time"}, update) == int64(len(update))

test/resource.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"context"
+	"flag"
 	"log"
 
 	"bp.jydev.jianyu360.cn/BaseService/resourceCenter/rpc/pb"
@@ -18,8 +19,15 @@ var c = resource.NewResource(zrpc.MustNewClient(zrpc.RpcClientConf{
 }))
 
 func main() {
-	//PowerHandle()
-	CheckPower()
+	m := flag.Int("m", 0, "")
+	flag.Parse()
+	if *m == 1 {
+		PowerHandle()
+	} else if *m == 2 {
+		CheckPower()
+	} else if *m == 3 {
+		Deduction()
+	}
 }
 
 //开通或者取消用户/企业权益
@@ -47,5 +55,11 @@ func CheckPower() {
 
 //资源扣减
 func Deduction() {
-
+	r, err := c.Deduction(context.Background(), &pb.DeductionReq{
+		Appid:        "10000",
+		FunctionCode: "xxfb_gyxx_add",
+		EntId:        55,
+		Count:        1,
+	})
+	log.Println("----------", r.Status, err)
 }