-
Notifications
You must be signed in to change notification settings - Fork 176
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
ce63b75
commit ad0d5b3
Showing
12 changed files
with
370 additions
and
23 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,164 @@ | ||
| package com.misec.task; | ||
|
|
||
|
|
||
| import com.google.gson.JsonArray; | ||
| import com.google.gson.JsonElement; | ||
| import com.google.gson.JsonObject; | ||
| import com.misec.apiquery.ApiList; | ||
| import com.misec.apiquery.OftenApi; | ||
| import com.misec.config.Config; | ||
| import com.misec.login.Verify; | ||
| import com.misec.utils.HttpUtil; | ||
| import com.oldwu.log.OldwuLog; | ||
| import lombok.extern.log4j.Log4j2; | ||
|
|
||
| import java.net.URLEncoder; | ||
| import java.text.SimpleDateFormat; | ||
| import java.util.Date; | ||
| import java.util.Random; | ||
|
|
||
| /** | ||
| * @author junzhou | ||
| */ | ||
| @Log4j2 | ||
| public class MatchGame implements Task { | ||
|
|
||
| @Override | ||
| public void run() { | ||
|
|
||
| if (OftenApi.getCoinBalance() < Config.getInstance().getMinimumNumberOfCoins()) { | ||
| OldwuLog.log(Config.getInstance().getMinimumNumberOfCoins() + "个硬币都没有，参加你\uD83D\uDC34预测呢？任务结束"); | ||
| log.info("{}个硬币都没有，参加什么预测呢？任务结束", Config.getInstance().getMinimumNumberOfCoins()); | ||
| return; | ||
| } | ||
| JsonObject resultJson = queryContestQuestion(getTime(), 1, 50); | ||
| JsonObject jsonObject = resultJson.get("data").getAsJsonObject(); | ||
| if (resultJson.get("code").getAsInt() == 0) { | ||
| JsonArray list = jsonObject.get("list").getAsJsonArray(); | ||
| JsonObject pageinfo = jsonObject.get("page").getAsJsonObject(); | ||
| if (pageinfo.get("total").getAsInt() == 0) { | ||
| log.info("今日无赛事或者本日赛事已经截止预测"); | ||
| OldwuLog.log("今日无赛事或者本日赛事已经截止预测"); | ||
| return; | ||
| } | ||
| if (list != null) { | ||
| int coinNumber = Config.getInstance().getPredictNumberOfCoins(); | ||
| int contestId; | ||
| String contestName; | ||
| int questionId; | ||
| String questionTitle; | ||
| int teamId; | ||
| String teamName; | ||
| int seasonId; | ||
| String seasonName; | ||
|
|
||
| for (JsonElement listinfo : list) { | ||
| log.info("-----预测开始-----"); | ||
| OldwuLog.log("-----预测开始-----"); | ||
| JsonObject contestJson = listinfo.getAsJsonObject().getAsJsonObject("contest"); | ||
| JsonObject questionJson = listinfo.getAsJsonObject().getAsJsonArray("questions") | ||
| .get(0).getAsJsonObject(); | ||
| contestId = contestJson.get("id").getAsInt(); | ||
| contestName = contestJson.get("game_stage").getAsString(); | ||
| questionId = questionJson.get("id").getAsInt(); | ||
| questionTitle = questionJson.get("title").getAsString(); | ||
| seasonId = contestJson.get("season").getAsJsonObject() | ||
| .get("id").getAsInt(); | ||
| seasonName = contestJson.get("season").getAsJsonObject() | ||
| .get("title").getAsString(); | ||
|
|
||
| log.info(seasonName + " " + contestName + ":" + questionTitle); | ||
| OldwuLog.log(seasonName + " " + contestName + ":" + questionTitle); | ||
|
|
||
| if (questionJson.get("is_guess").getAsInt() == 1) { | ||
| log.info("此问题已经参与过预测了，无需再次预测"); | ||
| OldwuLog.log("此问题已经参与过预测了，无需再次预测"); | ||
| continue; | ||
| } | ||
|
|
||
| JsonObject teamA = questionJson.get("details").getAsJsonArray().get(0).getAsJsonObject(); | ||
| JsonObject teamB = questionJson.get("details").getAsJsonArray().get(1).getAsJsonObject(); | ||
|
|
||
| log.info("当前赔率为: {}:{}", teamA.get("odds").getAsDouble(), teamB.get("odds").getAsDouble()); | ||
| OldwuLog.log("当前赔率为: " + teamA.get("odds").getAsDouble() + ":" + teamB.get("odds").getAsDouble()); | ||
|
|
||
| if (teamA.get("odds").getAsDouble() >= teamB.get("odds").getAsDouble()) { | ||
| teamId = teamB.get("detail_id").getAsInt(); | ||
| teamName = teamB.get("option").getAsString(); | ||
| } else { | ||
| teamId = teamA.get("detail_id").getAsInt(); | ||
| teamName = teamA.get("option").getAsString(); | ||
| } | ||
|
|
||
| log.info("拟预测的队伍是:{},预测硬币数为:{}", teamName, coinNumber); | ||
| OldwuLog.log("拟预测的队伍是:" + teamName + ",预测硬币数为:" + coinNumber); | ||
| doPrediction(contestId, questionId, teamId, coinNumber); | ||
| try { | ||
| taskSuspend(); | ||
| } catch (InterruptedException e) { | ||
| e.printStackTrace(); | ||
| } | ||
| } | ||
| } | ||
| } else { | ||
| log.info("获取赛事信息失败"); | ||
| OldwuLog.error("获取赛事信息失败"); | ||
| } | ||
|
|
||
| } | ||
|
|
||
| private void taskSuspend() throws InterruptedException { | ||
| Random random = new Random(); | ||
| int sleepTime = (int) ((random.nextDouble() + 0.5) * 3000); | ||
| log.info("-----随机暂停{}ms-----\n", sleepTime); | ||
| Thread.sleep(sleepTime); | ||
| } | ||
|
|
||
| private JsonObject queryContestQuestion(String today, int pn, int ps) { | ||
|
|
||
| String gid = ""; | ||
| String sids = ""; | ||
| String urlParam = "?pn=" + pn + | ||
| "&ps=" + ps | ||
| + "&gid=" + gid | ||
| + "&sids=" + sids | ||
| + "&stime=" + today + URLEncoder.encode(" 00:00:00") | ||
| + "&etime=" + today + URLEncoder.encode(" 23:59:59") | ||
| + "&pn=" + pn | ||
| + "&ps=" + ps | ||
| + "&stime=" + today + "+00:00:00" | ||
| + "&etime=" + today + "+23:59:59"; | ||
| return HttpUtil.doGet(ApiList.queryQuestions + urlParam); | ||
| } | ||
|
|
||
| private void doPrediction(int oid, int main_id, int detail_id, int count) { | ||
| String requestbody = "oid=" + oid + | ||
| "&main_id=" + main_id | ||
| + "&detail_id=" + detail_id | ||
| + "&count=" + count | ||
| + "&is_fav=0" | ||
| + "&csrf=" + Verify.getInstance().getBiliJct(); | ||
|
|
||
| JsonObject result = HttpUtil.doPost(ApiList.doAdd, requestbody); | ||
|
|
||
| if (result.get("code").getAsInt() != 0) { | ||
| log.info(result.get("message").getAsString()); | ||
| OldwuLog.log(result.get("message").getAsString()); | ||
| } else { | ||
| log.info("预测成功"); | ||
| OldwuLog.log("预测成功"); | ||
| } | ||
|
|
||
| } | ||
|
|
||
| private String getTime() { | ||
| Date d = new Date(); | ||
| SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); | ||
| return sdf.format(d); | ||
| } | ||
|
|
||
| @Override | ||
| public String getName() { | ||
| return "赛事预测"; | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.