Răsfoiți Sursa

fix:超级订阅升级续费支付成功清除缓存移除协程

fuwencai 2 ani în urmă
părinte
comite
758efcc04f
1 a modificat fișierele cu 14 adăugiri și 14 ștergeri
  1. 14 14
      src/jfw/modules/subscribepay/src/entity/subscribeVip.go

+ 14 - 14
src/jfw/modules/subscribepay/src/entity/subscribeVip.go

@@ -354,17 +354,17 @@ func (this *vipSubscribeStruct) StartSubVip(userId string, vmsg VipSimpleMsg, st
 		bson.M{"$set": set}) {
 		return false
 	}
-	go func() {
-		util.MergeKws(userId, positionType, entId, entUserId) //初始化vip订阅关键词
-		redis.Del("other", "p1_indexMessage_"+userId)         //清除redis中vip状态
-		positionId := util.MongoIdToPositionId(userId)
-		jy.ClearBigVipUserPower(positionId)
-		config.Middleground.UserCenter.WorkDesktopClearUserInfo(pb.WorkDesktopClearUserInfoReq{
-			PositionId: positionId,
-			AppId:      "10000",
-		})
-		config.Middleground.PowerCheckCenter.DelCheckRedis("10000", qutil.Int64All(positionId))
-	}()
+
+	util.MergeKws(userId, positionType, entId, entUserId) //初始化vip订阅关键词
+	redis.Del("other", "p1_indexMessage_"+userId)         //清除redis中vip状态
+	positionId := util.MongoIdToPositionId(userId)
+	jy.ClearBigVipUserPower(positionId)
+	config.Middleground.UserCenter.WorkDesktopClearUserInfo(pb.WorkDesktopClearUserInfoReq{
+		PositionId: positionId,
+		AppId:      "10000",
+	})
+	config.Middleground.PowerCheckCenter.DelCheckRedis("10000", qutil.Int64All(positionId))
+
 	return true
 }
 
@@ -465,12 +465,12 @@ func (this *vipSubscribeStruct) UpgradeSubVip(userId string, vmsg VipSimpleMsg,
 		return false
 	} else {
 		positionId := util.MongoIdToPositionId(userId)
-		go jy.ClearBigVipUserPower(positionId)
-		go config.Middleground.UserCenter.WorkDesktopClearUserInfo(pb.WorkDesktopClearUserInfoReq{
+		jy.ClearBigVipUserPower(positionId)
+		config.Middleground.UserCenter.WorkDesktopClearUserInfo(pb.WorkDesktopClearUserInfoReq{
 			PositionId: positionId,
 			AppId:      "10000",
 		})
-		go config.Middleground.PowerCheckCenter.DelCheckRedis("10000", qutil.Int64All(positionId))
+		config.Middleground.PowerCheckCenter.DelCheckRedis("10000", qutil.Int64All(positionId))
 		return true
 	}
 }