修改roll房

controllers/roll.go

@@ -32,6 +32,7 @@ func (c *RollController) Get() {
 
 	action := c.GetString("action")
 	if action == "update" {
+		models.InitRollInfo()
 		c.Data["json"] = &map[string]interface{}{"status": true}
 		c.ServeJSON()
 		return

models/roll.go

@@ -40,6 +40,10 @@ type RollCondition struct {
 	Name         string
 }
 
+type RES_ROLL struct {
+	Code int `json:"code"` // 错误码
+}
+
 type RollConditionArray []*RollCondition
 
 var conditionList RollConditionArray
@@ -89,6 +93,8 @@ func InitRollInfo() {
 	rd := pool.Get()
 	defer rd.Close()
 
+	rollList = RollInfoArray{}
+
 	result, _ := redis.Values(rd.Do("smembers", ROLL_MAIN_KEY))
 	for _, v := range result {
 		id := utils.StringToInt(string(v.([]byte)))
@@ -205,6 +211,7 @@ func AddRollInfo(hf *RollInfo) error {
 	rollList = append(rollList, hf)
 	riMutex.Unlock()
 
+	SendGameAddRoll(hf.Id)
 	return nil
 }
 
@@ -267,6 +274,8 @@ func UpdateRollInfo(hf *RollInfo) error {
 	}
 	riMutex.Unlock()
 
+	SendGameUpdateRoll(hf.Id)
+
 	return nil
 }
 
@@ -321,6 +330,7 @@ func DelRollInfoById(id int) error {
 			rollList = append(rollList[:i], rollList[ii:]...)
 		}
 	}
+	SendGameDeleteRoll(id)
 
 	return nil
 }
@@ -342,6 +352,8 @@ func del_unactive_roll_info(id int) error {
 	}
 	rd.Do("srem", ROLL_MAIN_KEY, id)
 
+	SendGameDeleteRoll(id)
+
 	return nil
 }
 
@@ -374,6 +386,7 @@ func GetRollInfoList() RollInfoArray {
 	for _, v := range rollList {
 		if v.AwardTime > currTime {
 			_rollList = append(_rollList, v)
+		} else {
 			del_unactive_roll_info(v.Id)
 		}
 	}
@@ -384,3 +397,87 @@ func GetRollInfoList() RollInfoArray {
 func GetRollConditionList() RollConditionArray {
 	return conditionList
 }
+
+// 游戏服 - 新增
+func SendGameAddRoll(id int) error {
+	params := make(map[string]interface{})
+	params["name"] = "gm_add_roll"
+	data := make(map[string]interface{})
+	data["id"] = id
+	params["data"] = data
+
+	body, _ := json.Marshal(params)
+	host := utils.GetKeyConf("gameservers", "web")
+	sign := utils.Strtomd5(string(body) + utils.GetKeyConf("app", "gameKey"))
+	url := "http://" + host + "/json?sign=" + sign
+	buff, err := utils.SendAndRecvHTTP("POST", url, string(body))
+	if err != nil {
+		return err
+	}
+
+	var res RES_ROLL
+	err = json.Unmarshal(buff, &res)
+	if err != nil {
+		return err
+	}
+	if res.Code != 200 {
+		return fmt.Errorf("code:%d", res.Code)
+	}
+	return nil
+}
+
+// 游戏服 - 更新
+func SendGameUpdateRoll(id int) error {
+	params := make(map[string]interface{})
+	params["name"] = "gm_update_roll"
+	data := make(map[string]interface{})
+	data["id"] = id
+	params["data"] = data
+
+	body, _ := json.Marshal(params)
+	host := utils.GetKeyConf("gameservers", "web")
+	sign := utils.Strtomd5(string(body) + utils.GetKeyConf("app", "gameKey"))
+	url := "http://" + host + "/json?sign=" + sign
+	buff, err := utils.SendAndRecvHTTP("POST", url, string(body))
+	if err != nil {
+		return err
+	}
+
+	var res RES_ROLL
+	err = json.Unmarshal(buff, &res)
+	if err != nil {
+		return err
+	}
+	if res.Code != 200 {
+		return fmt.Errorf("code:%d", res.Code)
+	}
+	return nil
+}
+
+// 游戏服 - 更新
+func SendGameDeleteRoll(id int) error {
+	params := make(map[string]interface{})
+	params["name"] = "gm_del_roll"
+	data := make(map[string]interface{})
+	data["id"] = id
+	params["data"] = data
+
+	body, _ := json.Marshal(params)
+	host := utils.GetKeyConf("gameservers", "web")
+	sign := utils.Strtomd5(string(body) + utils.GetKeyConf("app", "gameKey"))
+	url := "http://" + host + "/json?sign=" + sign
+	buff, err := utils.SendAndRecvHTTP("POST", url, string(body))
+	if err != nil {
+		return err
+	}
+
+	var res RES_ROLL
+	err = json.Unmarshal(buff, &res)
+	if err != nil {
+		return err
+	}
+	if res.Code != 200 {
+		return fmt.Errorf("code:%d", res.Code)
+	}
+	return nil
+}