Cookies_Github_mirror/AquaDX
4
0
Fork 1
mirror of https://github.com/MewoLab/AquaDX.git synced 2026-02-04 23:57:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

[api] Add more ongeki feature

Browse Source
This commit is contained in:
samnyan
2020-03-21 23:07:54 +09:00
parent ee7b68356d
commit 913244c2b5
6 changed files with 150 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
README.md
View File

@@ -54,6 +54,11 @@ And DIVA screenshot will be save in data folder.
### Changelog:
v0.0.11a:
[api] Add more ongeki feature
v0.0.11: **[This will do database update]**
[ongeki] Add support to ongeki plus

2
pom.xml
View File

@@ -10,7 +10,7 @@
</parent>
<groupId>icu.samnya</groupId>
<artifactId>aqua</artifactId>
<version>0.0.11-RELEASE</version>
<version>0.0.11a-RELEASE</version>
<name>Aqua Server</name>
<description>A multipurpose game server</description>

145
src/main/java/icu/samnyan/aqua/api/controller/sega/game/ongeki/ApiOngekiPlayerDataController.java
View File

@@ -1,6 +1,7 @@
package icu.samnyan.aqua.api.controller.sega.game.ongeki;
import com.fasterxml.jackson.core.type.TypeReference;
import icu.samnyan.aqua.api.model.MessageResponse;
import icu.samnyan.aqua.api.model.ReducedPageResponse;
import icu.samnyan.aqua.api.model.resp.sega.ongeki.ProfileResp;
import icu.samnyan.aqua.api.util.ApiMapper;
@@ -11,10 +12,15 @@ import icu.samnyan.aqua.sega.ongeki.model.userdata.*;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List;
import java.util.Map;
import java.util.Optional;
/**
* @author samnyan (privateamusement@protonmail.com)
@@ -25,6 +31,8 @@ public class ApiOngekiPlayerDataController {
private final ApiMapper mapper;
private static DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.0");
private final UserActivityRepository userActivityRepository;
private final UserCardRepository userCardRepository;
private final UserCharacterRepository userCharacterRepository;
@@ -91,22 +99,86 @@ public class ApiOngekiPlayerDataController {
public ReducedPageResponse<UserCard> getCard(@RequestParam Integer aimeId,
@RequestParam(required = false, defaultValue = "0") int page,
@RequestParam(required = false, defaultValue = "10") int size) {
Page<UserCard> cards = userCardRepository.findByUser_Card_ExtId(aimeId, PageRequest.of(page,size));
Page<UserCard> cards = userCardRepository.findByUser_Card_ExtId(aimeId, PageRequest.of(page,size, Sort.Direction.DESC, "id"));
return new ReducedPageResponse<>(cards.getContent(), cards.getPageable().getPageNumber(), cards.getTotalPages(), cards.getTotalElements());
}
@PostMapping("insert")
public UserCard insertCard(@RequestBody Map<String, Object> request) {
/**
* Force insert a card. This will use to create a new card or update a currently existed card star level.
* @param request Map of aimeId and cardId
* @return result UserCard or error message
*/
@PostMapping("card")
public ResponseEntity<Object> insertCard(@RequestBody Map<String, Object> request) {
UserData profile = userDataRepository.findByCard_ExtId((Integer) request.get("aimeId")).orElseThrow();
Integer cardId = (Integer) request.get("cardId");
Optional<UserCard> userCardOptional = userCardRepository.findByUserAndCardId(profile, cardId);
if(userCardOptional.isPresent()) {
UserCard card = userCardOptional.get();
if(card.getDigitalStock() < 5) {
card.setDigitalStock(card.getDigitalStock() + 1);
return ResponseEntity.ok(userCardRepository.save(card));
} else {
// If digital stock is larger than 5, check if this card is N card.
Optional<GameCard> gameCard = gameCardRepository.findById((long) card.getCardId());
if(gameCard.isPresent()) {
if(gameCard.get().getRarity().equals("N")) {
card.setDigitalStock(card.getDigitalStock() + 1);
return ResponseEntity.ok(userCardRepository.save(card));
} else {
return ResponseEntity.status(HttpStatus.UNPROCESSABLE_ENTITY).body(new MessageResponse("This card has reached max limit."));
}
} else {
return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR)
.body(new MessageResponse("Card info not found on server, not allow to edit with api, please make edit to database directly."));
}
}
}
GameCard card = gameCardRepository.findById(cardId.longValue()).orElseThrow();
return userCardRepository.save(new UserCard(
profile,
cardId,
card.getSkillId()
return ResponseEntity.ok(
userCardRepository.save(
new UserCard(
profile,
cardId,
card.getSkillId(),
LocalDateTime.now().format(df))
));
}
@PostMapping("card/{cardId}/kaika")
public ResponseEntity<Object> kaikaCard(@RequestParam Integer aimeId, @PathVariable Integer cardId) {
Optional<UserCard> userCardOptional = userCardRepository.findByUser_Card_ExtIdAndCardId(aimeId, cardId);
if(userCardOptional.isEmpty()) {
return ResponseEntity.status(HttpStatus.NOT_FOUND).body(new MessageResponse("Card not found."));
} else {
UserCard card = userCardOptional.get();
if(!card.getKaikaDate().equals("0000-00-00 00:00:00.0")) {
return ResponseEntity.status(HttpStatus.UNPROCESSABLE_ENTITY).body(new MessageResponse("No, you have done this before."));
} else {
card.setKaikaDate(LocalDateTime.now().format(df));
card.setPrintCount(card.getPrintCount() + 1);
return ResponseEntity.ok(userCardRepository.save(card));
}
}
}
@PostMapping("card/{cardId}/choKaika")
public ResponseEntity<Object> choKaikaCard(@RequestParam Integer aimeId, @PathVariable Integer cardId) {
Optional<UserCard> userCardOptional = userCardRepository.findByUser_Card_ExtIdAndCardId(aimeId, cardId);
if(userCardOptional.isEmpty()) {
return ResponseEntity.status(HttpStatus.NOT_FOUND).body(new MessageResponse("Card not found."));
} else {
UserCard card = userCardOptional.get();
if(!card.getChoKaikaDate().equals("0000-00-00 00:00:00.0")) {
return ResponseEntity.status(HttpStatus.UNPROCESSABLE_ENTITY).body(new MessageResponse("No, you have done this before."));
} else {
card.setChoKaikaDate(LocalDateTime.now().format(df));
card.setPrintCount(card.getPrintCount() + 1);
return ResponseEntity.ok(userCardRepository.save(card));
}
}
}
@GetMapping("character")
public ReducedPageResponse<UserCharacter> getCharacter(@RequestParam Integer aimeId,
@RequestParam(required = false, defaultValue = "0") int page,
@@ -115,6 +187,40 @@ public class ApiOngekiPlayerDataController {
return new ReducedPageResponse<>(characters.getContent(), characters.getPageable().getPageNumber(), characters.getTotalPages(), characters.getTotalElements());
}
@GetMapping("activity")
public List<UserActivity> getActivities(@RequestParam Integer aimeId) {
return userActivityRepository.findByUser_Card_ExtId(aimeId);
}
@PostMapping("activity")
public ResponseEntity<Object> updateActivities(@RequestBody Map<String, Object> request) {
UserData profile = userDataRepository.findByCard_ExtId((Integer) request.get("aimeId")).orElseThrow();
Integer activityId = (Integer) request.get("id");
Integer kind = (Integer) request.get("kind");
Integer sortNumber = (Integer) request.get("sortNumber");
Integer param1 = (Integer) request.get("param1");
Integer param2 = (Integer) request.get("param2");
Integer param3 = (Integer) request.get("param3");
Integer param4 = (Integer) request.get("param4");
Optional<UserActivity> userActivityOptional = userActivityRepository.findByUserAndKindAndActivityId(profile, kind, activityId);
UserActivity userActivity;
if(userActivityOptional.isPresent()) {
userActivity = userActivityOptional.get();
} else {
userActivity = new UserActivity(profile);
userActivity.setActivityId(activityId);
userActivity.setKind(kind);
userActivity.setSortNumber(sortNumber);
}
userActivity.setParam1(param1);
userActivity.setParam2(param2);
userActivity.setParam3(param3);
userActivity.setParam4(param4);
return ResponseEntity.ok(userActivityRepository.save(userActivity));
}
@GetMapping("item")
public ReducedPageResponse<UserItem> getItem(@RequestParam Integer aimeId,
@RequestParam(required = false, defaultValue = "0") int page,
@@ -123,6 +229,31 @@ public class ApiOngekiPlayerDataController {
return new ReducedPageResponse<>(items.getContent(), items.getPageable().getPageNumber(), items.getTotalPages(), items.getTotalElements());
}
@PostMapping("item")
public ResponseEntity<Object> updateItem(@RequestBody Map<String, Object> request) {
UserData profile = userDataRepository.findByCard_ExtId((Integer) request.get("aimeId")).orElseThrow();
Integer itemKind = (Integer) request.get("itemKind");
Integer itemId = (Integer) request.get("itemId");
int stock = 1;
if(request.containsKey("stock")) {
stock = (Integer) request.get("stock");
}
Optional<UserItem> userItemOptional = userItemRepository.findByUserAndItemKindAndItemId(profile, itemKind, itemId);
UserItem userItem;
if(userItemOptional.isPresent()) {
userItem = userItemOptional.get();
} else {
userItem = new UserItem(profile);
userItem.setItemId(itemId);
userItem.setItemKind(itemKind);
}
userItem.setStock(stock);
userItem.setValid(true);
return ResponseEntity.ok(userItemRepository.save(userItem));
}
@GetMapping("recent")
public ReducedPageResponse<UserPlaylog> getRecent(@RequestParam Integer aimeId,
@RequestParam(required = false, defaultValue = "0") int page,

2
src/main/java/icu/samnyan/aqua/sega/ongeki/dao/userdata/UserActivityRepository.java
View File

@@ -16,4 +16,6 @@ public interface UserActivityRepository extends JpaRepository<UserActivity, Long
Optional<UserActivity> findByUserAndKindAndActivityId(UserData userData, int kind, int activityId);
List<UserActivity> findByUser_Card_ExtIdAndKindOrderBySortNumberDesc(int userId, int kind);
List<UserActivity> findByUser_Card_ExtId(int userId);
}

2
src/main/java/icu/samnyan/aqua/sega/ongeki/dao/userdata/UserCardRepository.java
View File

@@ -17,4 +17,6 @@ public interface UserCardRepository extends JpaRepository<UserCard, Long> {
Optional<UserCard> findByUserAndCardId(UserData userData, int cardId);
Page<UserCard> findByUser_Card_ExtId(int userId, Pageable page);
Optional<UserCard> findByUser_Card_ExtIdAndCardId(int aimeId, int cardId);
}

3
src/main/java/icu/samnyan/aqua/sega/ongeki/model/userdata/UserCard.java
View File

@@ -65,9 +65,10 @@ public class UserCard implements Serializable {
this.user = userData;
}
public UserCard(UserData userData, int cardId, int skillId) {
public UserCard(UserData userData, int cardId, int skillId, String created) {
this.user = userData;
this.cardId = cardId;
this.skillId = skillId;
this.created = created;
}
}