毕业设计&课设-基于Java的Epic Games后端系统-虚幻引擎4.zip

package com.tokenplay.ue4.www.controllers; import java.io.IOException; import java.time.LocalDateTime; import java.time.OffsetDateTime; import java.util.*; import java.util.stream.Collectors; import javax.servlet.http.HttpServletRequest; import javax.transaction.Transactional; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import io.vavr.control.Either; import com.tokenplay.ue4.model.db.tables.records.*; import com.tokenplay.ue4.www.api.*; import com.tokenplay.ue4.www.exception.UserNotFoundException; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.tuple.Pair; import org.apache.commons.lang3.tuple.Triple; import org.apache.logging.log4j.util.Strings; import org.jooq.DSLContext; import org.jooq.Record; import org.jooq.Result; import org.jooq.tools.json.JSONObject; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpStatus; import org.springframework.http.MediaType; import org.springframework.http.ResponseEntity; import org.springframework.retry.annotation.Backoff; import org.springframework.retry.annotation.Retryable; import org.springframework.stereotype.Controller; import org.springframework.transaction.interceptor.TransactionAspectSupport; import org.springframework.web.bind.annotation.ModelAttribute; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.ResponseStatus; import com.hazelcast.core.HazelcastInstance; import lombok.Data; import lombok.EqualsAndHashCode; import lombok.extern.slf4j.Slf4j; import com.tokenplay.ue4.configuration.HazelCastConfiguration; import com.tokenplay.ue4.logic.TaskManager; import com.tokenplay.ue4.model.db.tables.Tue4ServerAuthorised; import com.tokenplay.ue4.model.db.tables.pojos.PaintScheme; import com.tokenplay.ue4.model.db.tables.pojos.Server; import com.tokenplay.ue4.model.repositories.ServersDB; import com.tokenplay.ue4.steam.client.SteamApiClient; import com.tokenplay.ue4.steam.client.types.ApiException; import com.tokenplay.ue4.steam.client.types.api.AuthenticateUserTicketRS; import com.tokenplay.ue4.steam.client.types.api.CheckAppOwnershipRS; import com.tokenplay.ue4.steam.client.types.api.SteamApiSessionResponse; import com.tokenplay.ue4.utils.BCrypt; import com.tokenplay.ue4.www.caching.LiveServer; import static io.vavr.control.Either.left; import static io.vavr.control.Either.right; import static org.springframework.util.StringUtils.isEmpty; @Data @EqualsAndHashCode(callSuper = false) @Slf4j @Controller @Transactional public class GameAPI extends CommonAPI { private static final String DEVELOPMENT_KEYWORD = "serv6271@coolxeons"; public static final int NUM_RETRIES = 3; @Autowired DSLContext jooq; @Autowired HazelcastInstance hazelcast; @Autowired(required = false) SteamApiClient steamApiClient; @ResponseBody @RequestMapping(value = "/leave_server", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.POST) @Retryable(backoff = @Backoff(delay = 500)) public JSONResponse leaveServer(@RequestParam(value = "pil_token") String token, @RequestParam(value = "srv_id") String id, @RequestParam( value = "quit", defaultValue = "false") boolean quitting) { log.debug("Leave requested for token {} at server {}, quitting: {}", token, id, quitting); JSONResponse response = new JSONResponse(); try { PilotRecord pilot = TaskManager.leaveServer(getDataProvider(), token, id); // If we are quitting, clean the pilot token as well if (pilot == null) { log.error("An unknown pilot with token {} tried to leave server {} or quit {}", token, id, quitting); response.setError("Pilot session invalid"); } else if (quitting) { getPilots().clean(pilot); log.info("Pilot {} quit game", pilot.getPilCallsign()); } } catch (Exception e) { log.info("Error while {} was leaving server {}:{}", new Object[] { token, id}, e); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); response.setError("Error leaving server"); } return response; } @ResponseBody @RequestMapping(value = "/gi/{token}/rest/isdeveloper", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.GET) @Retryable(backoff = @Backoff(delay = 500)) public JSONResponse isDeveloper(@PathVariable(value = "token") String token) { JSONResponse response = new JSONResponse(); try { Pair<PilotRecord, UsersRecord> pair = getPilots().findPilotAndUser(token); UsersRecord user = null; if (pair != null) { user = pair.getRight(); } if (getUsers().isDeveloper(user)) { response.setSuccess(true); } } catch (Exception e) { response.setError("Error finding developer."); } return response; } @ResponseBody @RequestMapping(value = "/gi/rest/users/ext/{ext_service_id}/{ext_service_user_id}", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.GET) @Retryable(backoff = @Backoff(delay = 500)) public JSONResponse getUserByExternalServiceId(@PathVariable(value = "ext_service_user_id") String extServiceUserId, @PathVariable( value = "ext_service_id") String extServiceId, @RequestParam(value = "token") String token) { JSONResponse response = new JSONResponse(); try { if (isAuthorized(token)) { ExternalService service = ExternalService.getEnum(extServiceId); switch (service) { case STEAM: Either<UserNotFoundException, JSONResponse> stuff = toUserResponse(getPilots().findBySteamId(extServiceUserId)); if (stuff.isRight()) { response = stuff.get(); response.setSuccess(true); } else { response.setSuccess(true); log.info("Failed to find user for external service ID " + extServiceUserId); } break; default: String msg = "Unhandled external service " + extServiceId; log.warn(msg); response.setError(msg); } } else { String msg = "Not authenticated"; log.warn(msg); response.setError(msg); } } catch (IllegalArgumentException iae) { String message = "Unknown external service ID: " + extServiceId; log.error(message); response.setError(message); } catch (Exception e) { String message = "Exception when finding user by external service ID " + extServiceUserId + " for service " + extServiceId; log.error(message, e); response.setError(message); } return response; } @ResponseBody @RequestMapping(value = "/gi/rest/users/{user_id}", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.GET) @Retryable(backoff = @Backoff(delay = 500)) public JSONResponse getUserByUserId(@PathVariable(value = "user_id") String userId, @RequestParam(value = "token") String token) {