rpc.go 632 B

123456789101112131415161718192021222324252627
  1. package coin
  2. import (
  3. "context"
  4. "fmt"
  5. coinclient "go-common/app/service/main/coin/api"
  6. "go-common/library/log"
  7. "time"
  8. )
  9. // AddCoin ModifyCoins with grpc client
  10. func (d *Dao) AddCoin(c context.Context, mid, aid int64, coin float64, ip string) (err error) {
  11. arg := &coinclient.ModifyCoinsReq{
  12. Mid: mid,
  13. Count: coin,
  14. Reason: fmt.Sprintf("删除稿件av%d,扣硬币", aid),
  15. IP: ip,
  16. Operator: "main.archive.creative",
  17. CheckZero: 1,
  18. Ts: time.Now().Unix(),
  19. }
  20. _, err = d.coinClient.ModifyCoins(c, arg)
  21. if err != nil {
  22. log.Error("ModifyCoins arg(%+v), err(%+v)", arg, err)
  23. }
  24. return
  25. }