resource.go 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. package main
  2. import (
  3. "context"
  4. "flag"
  5. "log"
  6. "bp.jydev.jianyu360.cn/BaseService/resourceCenter/rpc/pb"
  7. "bp.jydev.jianyu360.cn/BaseService/resourceCenter/rpc/resource"
  8. "github.com/zeromicro/go-zero/core/discov"
  9. "github.com/zeromicro/go-zero/zrpc"
  10. )
  11. var c resource.Resource
  12. func main12() {
  13. m := flag.Int("m", 0, "")
  14. flag.Parse()
  15. c = resource.NewResource(zrpc.MustNewClient(zrpc.RpcClientConf{
  16. Etcd: discov.EtcdConf{
  17. Hosts: []string{"192.168.3.149:2379"},
  18. Key: "resource.rpc",
  19. },
  20. }))
  21. *m = 5
  22. if *m == -1 {
  23. CancelPowerHandle()
  24. } else if *m == 1 {
  25. OpenPowerHandle()
  26. } else if *m == 2 {
  27. CheckPower()
  28. } else if *m == 3 {
  29. Deduction()
  30. } else if *m == 4 {
  31. ReEmpower()
  32. } else if *m == 5 {
  33. HasPowers()
  34. }
  35. }
  36. //开通或者取消用户/企业权益
  37. func OpenPowerHandle() {
  38. r, err := c.PowerHandle(context.Background(), &pb.PowerReq{
  39. Appid: "10000",
  40. GoodsCode: "xxfb_gyxx",
  41. EntId: 55,
  42. Type: 1,
  43. })
  44. log.Println("----------", r.Status, err)
  45. }
  46. //开通或者取消用户/企业权益
  47. func CancelPowerHandle() {
  48. r, err := c.PowerHandle(context.Background(), &pb.PowerReq{
  49. Appid: "10000",
  50. GoodsCode: "xxfb_gyxx",
  51. EntId: 55,
  52. Type: -1,
  53. })
  54. log.Println("----------", r.Status, err)
  55. }
  56. //检查用户/企业权益
  57. func CheckPower() {
  58. r, err := c.CheckPower(context.Background(), &pb.CheckPowerReq{
  59. Appid: "10000",
  60. FunctionCode: "znsj_kf_use",
  61. EntAccountId: 12664,
  62. EntId: 1023,
  63. EntUserId: 1308,
  64. })
  65. log.Println("----------", r.Status, err)
  66. }
  67. //资源扣减
  68. func Deduction() {
  69. r, err := c.Deduction(context.Background(), &pb.DeductionReq{
  70. Appid: "10000",
  71. FunctionCode: "xxfb_gyxx_add",
  72. AccountId: 0,
  73. Count: 1,
  74. })
  75. log.Println("----------", r.Status, err)
  76. }
  77. //资源扣减
  78. func ReEmpower() {
  79. r, err := c.ReEmpower(context.Background(), &pb.EmpowerReq{
  80. Appid: "10000",
  81. FunctionCode: "znsj_kf_use",
  82. EntId: 14184,
  83. EntUserId: []int64{4271},
  84. })
  85. log.Println("----------", r.Status, err)
  86. }
  87. //获取权益
  88. func HasPowers() {
  89. r, err := c.Haspowers(context.Background(), &pb.HaspowersReq{
  90. Appid: "10000",
  91. AccountId: 12664,
  92. EntAccountId: 205,
  93. EntId: 1023,
  94. EntUserId: 1308,
  95. })
  96. log.Println("----------", r.Powers, err)
  97. }