jyPoints/redisResource/config/purchaseBalance.go

package config

import (
	"context"
	"fmt"
	"log"
	"sync"
	"time"

	"app.yhyue.com/moapp/jyResourcesCenter/rpc/resourcesCenterclient"
)

type PurchaseBalance struct{}

var Purchase *PurchaseBalance
var allGiven = map[string]int64{}
var allGivenLock = &sync.Mutex{}

// 资源新增
// 查询数据有没有新增过
func (this *PurchaseBalance) PurchaseUserBalance(inteReq resourcesCenterclient.Resources) {
	key := fmt.Sprintf("%s_%s_%s_%d", inteReq.UserId, inteReq.ResourceType, inteReq.EndTime, inteReq.Model)
	allGivenLock.Lock()
	if allGiven[key] > 0 {
		return
	}
	allGiven[key] = time.Now().Unix()
	allGivenLock.Unlock()
	//判断资源之前有没有新增
	_resp, err := ResourcesRpc.PurchaseUserBalance(context.Background(), &inteReq)
	if err != nil {
		log.Println("BalanceCheck error:", err)
	}
	log.Println(inteReq.UserId, _resp)
}