|
@@ -4,6 +4,7 @@ import (
|
|
|
"config"
|
|
|
"fmt"
|
|
|
"log"
|
|
|
+ . "mongodb"
|
|
|
qutil "qfw/util"
|
|
|
"qfw/util/jy"
|
|
|
"qfw/util/redis"
|
|
@@ -12,7 +13,7 @@ import (
|
|
|
)
|
|
|
|
|
|
// 默认消费
|
|
|
-func (this *UseBalanceStruct) defaultConsume() (r map[string]interface{}, m string) {
|
|
|
+func (this *UseBalanceStruct) defaultConsume() (r map[string]interface{}, m string, c int) {
|
|
|
r, rerr := this.UseBalance()
|
|
|
if rerr != nil {
|
|
|
m = fmt.Sprintf("消费异常:%s", rerr.Error())
|
|
@@ -21,7 +22,7 @@ func (this *UseBalanceStruct) defaultConsume() (r map[string]interface{}, m stri
|
|
|
}
|
|
|
|
|
|
//附件下载消费 fui:免费赠送已使用次数;pui:付费权限已使用次数
|
|
|
-func (this *UseBalanceStruct) fileConsume() (r map[string]interface{}, m string) {
|
|
|
+func (this *UseBalanceStruct) fileConsume() (r map[string]interface{}, m string, c int) {
|
|
|
_fileName := this.Remarks["fileName"].(string)
|
|
|
_id := this.Remarks["id"].(string)
|
|
|
BaseMsg := jy.GetBigVipUserBaseMsg(this.UserId, util.Mysql, util.MQFW)
|
|
@@ -43,8 +44,8 @@ func (this *UseBalanceStruct) fileConsume() (r map[string]interface{}, m string)
|
|
|
} else if BaseMsg.VipStatus > 0 {
|
|
|
isExists := false
|
|
|
//查询当月附件下载历史记录-如是已下载过的附件不再扣除次数
|
|
|
- if id := this.FindJyConsumePackRecord(); id != "" && this.Remarks["downUrl"] != nil {
|
|
|
- log.Println("id:", id)
|
|
|
+ id := this.FindJyConsumePackRecord()
|
|
|
+ if id != "" && this.Remarks["downUrl"] != nil {
|
|
|
if util.MQFW.UpdateById(jyCC, id, map[string]interface{}{
|
|
|
"$set": map[string]interface{}{
|
|
|
"l_updateDate": time.Now().Unix(),
|
|
@@ -98,6 +99,7 @@ func (this *UseBalanceStruct) fileConsume() (r map[string]interface{}, m string)
|
|
|
m = "获取附件异常"
|
|
|
}
|
|
|
} else {
|
|
|
+ c = -1
|
|
|
m = "该用户下载权限当前月已用完"
|
|
|
}
|
|
|
}
|
|
@@ -107,6 +109,7 @@ func (this *UseBalanceStruct) fileConsume() (r map[string]interface{}, m string)
|
|
|
//免费用户下载后取消下载权限
|
|
|
redis.PutKV(fmt.Sprintf(jy.PowerCacheFileKey, this.UserId), -1)
|
|
|
} else {
|
|
|
+ c = -1
|
|
|
m = "该用户没有下载权限"
|
|
|
}
|
|
|
}
|
|
@@ -133,7 +136,7 @@ func (this *UseBalanceStruct) FindJyConsumePackRecord() string {
|
|
|
} else {
|
|
|
log.Println("查询附件下载日志异常:", this.UserId)
|
|
|
}
|
|
|
- return qutil.ObjToString((*res)["_id"])
|
|
|
+ return BsonIdToSId((*res)["_id"])
|
|
|
}
|
|
|
|
|
|
//保存日志
|
|
@@ -184,13 +187,13 @@ func fileAttachRpc(fileName, id string) (r map[string]interface{}) {
|
|
|
}
|
|
|
|
|
|
//消费
|
|
|
-func JyConsumePack(userId, product, platform string, remarks map[string]interface{}) (r map[string]interface{}, m string) {
|
|
|
+func JyConsumePack(userId, product, platform string, remarks map[string]interface{}) (r map[string]interface{}, m string, c int) {
|
|
|
CStruct := InitUseBalance(userId, product, product, "", "", nil, remarks, 1, platform)
|
|
|
switch product {
|
|
|
case "附件下载包":
|
|
|
- r, m = CStruct.fileConsume()
|
|
|
+ r, m, c = CStruct.fileConsume()
|
|
|
default:
|
|
|
- r, m = CStruct.defaultConsume()
|
|
|
+ r, m, c = CStruct.defaultConsume()
|
|
|
}
|
|
|
return
|
|
|
}
|