|
|
@@ -136,6 +136,49 @@ func (c *CreditRpc) InCreadit(param *qrpc.CreditData, replay *int) error {
|
|
|
}
|
|
|
lock.Unlock()
|
|
|
//
|
|
|
+ case "c":
|
|
|
+ lock := GetMutex(param.Uid)
|
|
|
+ lock.Lock()
|
|
|
+ if param.Code == "c1" { //交易
|
|
|
+ objid := param.OtherParam["objid"]
|
|
|
+ if objid != nil {
|
|
|
+ key := param.Code + "_" + param.Uid + "_" + objid.(string)
|
|
|
+ if redis.Get(consts.RedisDB, key) == nil {
|
|
|
+ creditDoc["i_score"] = Score[param.Code]
|
|
|
+ creditDoc["s_objid"] = objid.(string)
|
|
|
+ newDoc := map[string]interface{}{
|
|
|
+ "s_uid": objid.(string),
|
|
|
+ "s_code": param.Code,
|
|
|
+ "i_type": 1,
|
|
|
+ "s_sourceid": param.Uid,
|
|
|
+ "l_date": time.Now().Unix(),
|
|
|
+ "i_score": Score[param.Code],
|
|
|
+ }
|
|
|
+ creditlog.AddLog(creditDoc)
|
|
|
+ creditlog.AddLog(newDoc)
|
|
|
+ redis.Put(consts.RedisDB, key, true, GetSubSecond(1))
|
|
|
+ *replay = 1
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else if param.Code == "c2" { //评价
|
|
|
+ objid := param.OtherParam["serviceid"] //服务商id
|
|
|
+ if objid != nil {
|
|
|
+ key := param.Code + "_" + param.Uid + "_" + objid.(string)
|
|
|
+ if redis.Get(consts.RedisDB, key) == nil {
|
|
|
+ creditDoc["i_score"] = Score[param.Code]
|
|
|
+ creditDoc["o_param"] = param.OtherParam
|
|
|
+ creditlog.AddLog(creditDoc)
|
|
|
+ redis.Put(consts.RedisDB, key, true, GetSubSecond(1))
|
|
|
+ *replay = 1
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ creditDoc["i_score"] = Score[param.Code]
|
|
|
+ creditDoc["o_param"] = param.OtherParam
|
|
|
+ creditlog.AddLog(creditDoc)
|
|
|
+ *replay = 1
|
|
|
+ }
|
|
|
+ lock.Unlock()
|
|
|
default: //定时任务
|
|
|
sc := util.If(param.Num > 0, param.Num, Score[param.Code]).(int)
|
|
|
if sc > 0 {
|
