| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204 |
- package proto
- import (
- "bet24.com/log"
- "bet24.com/servers/micros/common"
- "context"
- )
- // 发放筹码
- func GiveChip(userId, amount, logType int, sourceName, remark, ipAddress string) int {
- xclient := getClient()
- //defer xclient.Close()
- args := &Request_GiveReduceMoney{
- UserId: userId,
- Amount: amount,
- LogType: logType,
- SourceName: sourceName,
- Remark: remark,
- IpAddress: ipAddress,
- }
- reply := &Response_GiveReduceMoney{}
- err := xclient.Call(context.Background(), "GiveChip", args, reply)
- if err != nil {
- log.Debug("money failed to call: %v", err)
- common.GetClientPool().RemoveClient(ServiceName)
- return 0
- }
- return reply.Gold
- }
- // 扣减筹码
- func ReduceChip(userId, amount, logType int, sourceName, remark, ipAddress string) int {
- xclient := getClient()
- //defer xclient.Close()
- args := &Request_GiveReduceMoney{
- UserId: userId,
- Amount: amount,
- LogType: logType,
- SourceName: sourceName,
- Remark: remark,
- IpAddress: ipAddress,
- }
- reply := &Response_GiveReduceMoney{}
- err := xclient.Call(context.Background(), "ReduceChip", args, reply)
- if err != nil {
- log.Debug("money failed to call: %v", err)
- common.GetClientPool().RemoveClient(ServiceName)
- return reply.RetCode
- }
- return reply.RetCode
- }
- func GetUserChip(userId int) (bool, int) {
- xclient := getClient()
- //defer xclient.Close()
- args := &Request_base{
- UserId: userId,
- }
- reply := &Response_GetMoney{}
- err := xclient.Call(context.Background(), "GetUserChip", args, reply)
- if err != nil {
- log.Debug("money failed to call: %v", err)
- common.GetClientPool().RemoveClient(ServiceName)
- return reply.Success, reply.Gold
- }
- return reply.Success, reply.Gold
- }
- // 金币日志
- func UserChipLog(userId int, beginTime, endTime string, pageIndex, pageSize int) (int, []*CashInfo) {
- xclient := getClient()
- //defer xclient.Close()
- args := &Request_CashLog{
- UserId: userId,
- BeginTime: beginTime,
- EndTime: endTime,
- PageIndex: pageIndex,
- PageSize: pageSize,
- }
- reply := &Response_CashLog{}
- err := xclient.Call(context.Background(), "UserChipLog", args, reply)
- if err != nil {
- log.Debug("money failed to call: %v", err)
- common.GetClientPool().RemoveClient(ServiceName)
- return reply.RecordCount, reply.List
- }
- return reply.RecordCount, reply.List
- }
- func ChipBankTransfer(userId, toUserId, amount int, ipAddress string) *Response_Transfer {
- xclient := getClient()
- //defer xclient.Close()
- args := &Request_Transfer{
- UserId: userId,
- ToUserId: toUserId,
- Amount: amount,
- IpAddress: ipAddress,
- }
- reply := &Response_Transfer{}
- err := xclient.Call(context.Background(), "ChipBankTransfer", args, reply)
- if err != nil {
- log.Debug("money failed to call: %v", err)
- common.GetClientPool().RemoveClient(ServiceName)
- return nil
- }
- return reply
- }
- func GetTransferCfg() *TransferCfg {
- xclient := getClient()
- //defer xclient.Close()
- args := &Request{}
- reply := &Response_GetTransferCfg{}
- err := xclient.Call(context.Background(), "GetTransferCfg", args, reply)
- if err != nil {
- log.Debug("money failed to call: %v", err)
- common.GetClientPool().RemoveClient(ServiceName)
- return nil
- }
- return reply.Info
- }
- // 赠送日志
- func ChipTransferLog(userId int) []*TransferInfo {
- xclient := getClient()
- //defer xclient.Close()
- args := &Request_base{
- UserId: userId,
- }
- reply := &Response_GoldTransferLog{}
- err := xclient.Call(context.Background(), "ChipTransferLog", args, reply)
- if err != nil {
- log.Debug("money failed to call: %v", err)
- common.GetClientPool().RemoveClient(ServiceName)
- return nil
- }
- return reply.List
- }
- // 获取银行信息
- func GetBankInfo(userId int) *BankInfo {
- xclient := getClient()
- //defer xclient.Close()
- args := &Request_base{
- UserId: userId,
- }
- reply := &Response_GetBankInfo{}
- err := xclient.Call(context.Background(), "GetBankInfo", args, reply)
- if err != nil {
- log.Debug("money failed to call: %v", err)
- common.GetClientPool().RemoveClient(ServiceName)
- return nil
- }
- return reply.Info
- }
- // 保存银行信息
- func SaveBankInfo(userId int, realName, bankName, bankCode, bankCard, mobile string) bool {
- xclient := getClient()
- //defer xclient.Close()
- args := &Request_SaveBankInfo{
- UserId: userId,
- RealName: realName,
- BankName: bankName,
- BankCode: bankCode,
- BankCard: bankCard,
- Mobile: mobile,
- }
- reply := &Response_SaveBankInfo{}
- err := xclient.Call(context.Background(), "SaveBankInfo", args, reply)
- if err != nil {
- log.Debug("money failed to call: %v", err)
- common.GetClientPool().RemoveClient(ServiceName)
- return false
- }
- return reply.Success
- }
|