diff --git a/src/main.rs b/src/main.rs index a6845a6..f763dd6 100644 --- a/src/main.rs +++ b/src/main.rs @@ -235,6 +235,12 @@ async fn shop(req: HttpRequest) -> HttpResponse { router::shop::shop(req) } #[post("/api/shop/buy")] async fn shop_buy(req: HttpRequest, body: String) -> HttpResponse { router::shop::buy(req, body) } +#[get("/api/exchange")] +async fn exchange(req: HttpRequest) -> HttpResponse { router::exchange::exchange(req) } + +#[post("/api/exchange")] +async fn exchange_post(req: HttpRequest, body: String) -> HttpResponse { router::exchange::exchange_post(req, body) } + #[post("/api/webui/login")] async fn webui_login(req: HttpRequest, body: String) -> HttpResponse { router::webui::login(req, body) } @@ -288,6 +294,8 @@ async fn main() -> std::io::Result<()> { println!("Request: {}", req.path()); srv.call(req) }) + .service(exchange_post) + .service(exchange) .service(serial_code) .service(shop) .service(shop_buy) diff --git a/src/router.rs b/src/router.rs index eb1db87..b579b9d 100644 --- a/src/router.rs +++ b/src/router.rs @@ -22,3 +22,4 @@ pub mod card; pub mod shop; pub mod webui; pub mod clear_rate; +pub mod exchange; diff --git a/src/router/exchange.rs b/src/router/exchange.rs new file mode 100644 index 0000000..cba90bd --- /dev/null +++ b/src/router/exchange.rs @@ -0,0 +1,70 @@ +use crate::encryption; +use json::{JsonValue, object}; +use crate::router::global; +use crate::router::userdata; +use actix_web::{HttpResponse, HttpRequest}; +use lazy_static::lazy_static; + +lazy_static! { + static ref EXCHANGE_LIST: JsonValue = { + let mut info = object!{}; + let items = json::parse(include_str!("json/exchange_item.json")).unwrap(); + for (_i, data) in items.members().enumerate() { + info[data["id"].to_string()] = data.clone(); + } + info + }; + static ref EXCHANGE_REWARD: JsonValue = { + let mut info = object!{}; + let items = json::parse(include_str!("json/exchange_item_reward.json")).unwrap(); + for (_i, data) in items.members().enumerate() { + info[data["id"].to_string()] = data.clone(); + } + info + }; +} + +pub fn exchange(_req: HttpRequest) -> HttpResponse { + let resp = object!{ + "code": 0, + "server_time": global::timestamp(), + "data": {"exchange_list":[]} + }; + global::send(resp) +} + +pub fn exchange_post(req: HttpRequest, body: String) -> HttpResponse { + let key = global::get_login(req.headers(), &body); + let body = json::parse(&encryption::decrypt_packet(&body).unwrap()).unwrap(); + let mut user = userdata::get_acc(&key); + + let item = &EXCHANGE_LIST[body["master_exchange_item_id"].to_string()]; + + if item["consumeType"].as_i32().unwrap() == 4 { + global::use_item(item["value"].as_i64().unwrap(), item["amount"].as_i64().unwrap() * body["count"].as_i64().unwrap(), &mut user); + } else { + println!("Unknown consume type {}", item["consumeType"]); + } + + let mut gift = EXCHANGE_REWARD[item["masterExchangeItemRewardId"].to_string()].clone(); + gift["reward_type"] = gift["type"].clone(); + gift["amount"] = (gift["amount"].as_i64().unwrap() * body["count"].as_i64().unwrap()).into(); + global::give_gift(&gift, &mut user); + + userdata::save_acc(&key, user.clone()); + + let resp = object!{ + "code": 0, + "server_time": global::timestamp(), + "data": { + "exchange": body, + "updated_value_list": { + "card_list": user["card_list"].clone(), + "item_list": user["item_list"].clone(), + "point_list": user["point_list"].clone() + }, + "clear_mission_ids": [] + } + }; + global::send(resp) +} diff --git a/src/router/lottery/mod.rs b/src/router/lottery/mod.rs index 3c22fb2..6e84714 100644 --- a/src/router/lottery/mod.rs +++ b/src/router/lottery/mod.rs @@ -213,6 +213,7 @@ pub fn lottery_post(req: HttpRequest, body: String) -> HttpResponse { } lottery_list.push(to_push).unwrap(); } + global::give_gift_basic(3, 15540034, 10, &mut user); } else if lottery_type == 2 { for (_i, data) in cardstogive.members().enumerate() { let info = get_card(data["master_lottery_item_id"].to_string(), data["master_lottery_item_number"].to_string());