修改roll房

models/roll.go

@@ -325,6 +325,26 @@ func DelRollInfoById(id int) error {
 	return nil
 }
 
+// 删除非活跃roll房
+func del_unactive_roll_info(id int) error {
+	pool := utils.GetAccountRedisPool()
+	if pool == nil {
+		return fmt.Errorf("get redis pool fail")
+	}
+	rd := pool.Get()
+	defer rd.Close()
+
+	pKey := get_roll_key(id)
+	_, err := rd.Do("del", pKey)
+	if err != nil {
+		log.Println(err)
+		return err
+	}
+	rd.Do("srem", ROLL_MAIN_KEY, id)
+
+	return nil
+}
+
 // 获取roll房信息信息
 func GetRollInfoById(id int) (hf *RollInfo) {
 	riMutex.Lock()
@@ -354,6 +374,7 @@ func GetRollInfoList() RollInfoArray {
 	for _, v := range rollList {
 		if v.AwardTime > currTime {
 			_rollList = append(_rollList, v)
+			del_unactive_roll_info(v.Id)
 		}
 	}
 	rollList = _rollList