Java 类org.springframework.web.bind.annotation.CookieValue 实例源码
项目:SkillWill
文件:OAuthMock.java
@RequestMapping(path = "/oauthmock", method = RequestMethod.GET)
public ResponseEntity<String> getOAuthMock(@CookieValue("_oauth2_proxy") String oAuthToken) {
if (StringUtils.isEmpty(mockOAuth) || !mockOAuth.equals("true")) {
return new ResponseEntity<>(new StatusJSON("mocking disabled").getJSON().toString(), HttpStatus.LOCKED);
}
if (userRepository.findByMail(sessionService.extractMail(oAuthToken)) != null) {
return new ResponseEntity<>(new StatusJSON("ok").getJSON().toString(), HttpStatus.ACCEPTED);
}
return new ResponseEntity<>(new StatusJSON("forbidden").getJSON().toString(), HttpStatus.FORBIDDEN);
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.PROVIDERS_BASE + "/schema", method = RequestMethod.GET,
headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public String getRelationships(
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws NoSuchProviderException, NoSuchSessionException {
GenerateSchema drawer = new GenerateSchema();
List<Class<? extends Item>> items = new ArrayList<>();
if (rateLimiter.tryAcquire()) {
Reflections reflections = new Reflections("com");
Set<Class<? extends Item>> subTypes = reflections.getSubTypesOf(Item.class);
for (Class<? extends Item> class1 : subTypes) {
items.add(class1);
}
}
Session session = modelValidator.validateSession(sessionId, response);
return drawer.process(stitcher, items, session.getProviders().keySet());
}
项目:xm-uaa
文件:SocialController.java
@GetMapping("/signup")
public RedirectView signUp(WebRequest webRequest,
@CookieValue(name = "NG_TRANSLATE_LANG_KEY", required = false, defaultValue = "\"en\"") String langKey) {
String providerId = null;
try {
Connection<?> connection = providerSignInUtils.getConnectionFromSession(webRequest);
providerId = connection.getKey().getProviderId();
socialService.createSocialUser(connection, langKey.replace("\"", ""));
return redirect(URIBuilder
.fromUri(TenantUtil.getApplicationUrl() + "/social-register/"
+ connection.getKey().getProviderId())
.queryParam("success", "true").build().toString());
} catch (Exception e) {
log.error("Exception creating social user: ", e);
return redirectOnError(providerId);
}
}
项目:lemon
文件:DiskController.java
/**
* 详情.
*/
@RequestMapping("disk-view")
public String view(
@RequestParam("id") Long id,
@CookieValue(value = "share", required = false) String sharePassword,
Model model) {
DiskShare diskShare = diskShareManager.get(id);
if ("private".equals(diskShare.getShareType())) {
if (!diskShare.getSharePassword().equals(sharePassword)) {
return "disk/disk-code";
}
}
model.addAttribute("diskShare", diskShare);
return "disk/disk-view";
}
项目:SkillWill
文件:SessionController.java
@ApiOperation(value = "session/user", nickname = "get session user", notes = "get session user")
@ApiResponses({
@ApiResponse(code = 200, message = "Success"),
@ApiResponse(code = 401, message = "Unauthorized"),
@ApiResponse(code = 500, message = "Failure")
})
@ApiImplicitParams({
@ApiImplicitParam(name = "search", value = "Name to search", paramType = "query"),
@ApiImplicitParam(name = "exclude_hidden", value = "Do not return hidden skills", paramType = "query", defaultValue = "true"),
@ApiImplicitParam(name = "count", value = "Limit the number of skills to find", paramType = "query"),
})
@RequestMapping(path = "/session/user", method = RequestMethod.GET)
public ResponseEntity<String> getCurrentUser(@CookieValue("_oauth2_proxy") String oAuthToken) {
logger.debug("Getting user from session {}", oAuthToken);
User user = sessionService.getUserByToken(oAuthToken);
if (user == null) {
return new ResponseEntity<>(new StatusJSON("no current session").toString(), HttpStatus.UNAUTHORIZED);
}
return new ResponseEntity<>(user.toJSON().toString(), HttpStatus.OK);
}
项目:HelloShiftLeft
文件:AdminController.java
@RequestMapping(value = "/admin/printSecrets", method = RequestMethod.GET)
public String doGetPrintSecrets(@CookieValue(value = "auth", defaultValue = "notset") String auth, HttpServletResponse response, HttpServletRequest request) throws Exception {
if (request.getSession().getAttribute("auth") == null) {
return fail;
}
String authToken = request.getSession().getAttribute("auth").toString();
if(!isAdmin(authToken)) {
return fail;
}
ClassPathResource cpr = new ClassPathResource("static/calculations.csv");
try {
byte[] bdata = FileCopyUtils.copyToByteArray(cpr.getInputStream());
response.getOutputStream().println(new String(bdata, StandardCharsets.UTF_8));
return null;
} catch (IOException ex) {
ex.printStackTrace();
// redirect to /
return fail;
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.PROVIDERS_BASE, method = RequestMethod.GET, headers = ApiConfig.API_HEADERS,
produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public ProviderList getProviders(
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) {
if (rateLimiter.tryAcquire()) {
sessionManager.getSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Get all providers");
}
ProviderList providerList = new ProviderList();
providerList.getProviders().addAll(adapterManager.getProviders());
return providerList;
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.PROVIDERS_BASE + "/{providerType}", method = RequestMethod.GET,
headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public ProviderList getProviders(@PathVariable final String providerType,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) {
if (rateLimiter.tryAcquire()) {
if (providerType == null || StringUtils.isBlank(providerType) || providerType.equals("null")) {
throw new BadRequestException("Empty provider type parameter");
}
sessionManager.getSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Get all providers for type " + providerType);
}
ProviderList providerList = new ProviderList();
providerList.getProviders().addAll(adapterManager.getProviders(providerType));
return providerList;
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.PROVIDERS_BASE + "/{providerType}/{providerId}", method = RequestMethod.GET,
headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public Provider getProvider(@PathVariable final String providerType, @PathVariable final String providerId,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws NoSuchProviderException {
if (rateLimiter.tryAcquire()) {
sessionManager.getSession(sessionId, response);
modelValidator.validateProviderType(providerType);
modelValidator.validateProviderId(providerId);
if (LOG.isDebugEnabled()) {
LOG.debug("Get provider " + providerType + Provider.PROV_SEPARATOR + providerId);
}
return getProvider(providerType, providerId);
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.PATTERNS_BASE, method = RequestMethod.GET, headers = ApiConfig.API_HEADERS,
produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public PatternDefinitionList getPatterns(
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws NoSuchSessionException {
if (rateLimiter.tryAcquire()) {
Session session = modelValidator.validateSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Get all patterns for all providers");
}
synchronized (session) {
PatternDefinitionList patternDefinitionList = new PatternDefinitionList();
List<PatternDefinition> patterns = patternDefinitionList.getPatterns();
patterns.addAll(tapestryManager.getAllPatterns());
return patternDefinitionList;
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.PATTERNS_BASE + "/{patternId}", method = RequestMethod.GET,
headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public PatternDefinition getPattern(@PathVariable final String patternId,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response)
throws InterruptedException, NoSuchSessionException, NoSuchPatternException {
if (rateLimiter.tryAcquire()) {
if (StringUtils.isBlank(patternId)) {
throw new BadRequestException("Empty pattern id parameter");
}
Session session = modelValidator.validateSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Get pattern with id: " + patternId);
}
synchronized (session) {
PatternDefinition patternDefinition = tapestryManager.getPattern(patternId);
return patternDefinition;
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.TAPESTRY_BASE + "/{tapestryId}", method = RequestMethod.GET,
headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public TapestryDefinition getTapestryDefinition(@PathVariable final String tapestryId,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws NoSuchSessionException, NoSuchTapestryDefinitionException {
if (rateLimiter.tryAcquire()) {
Session session = modelValidator.validateSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Get tapestry definition with id: " + tapestryId);
}
synchronized (session) {
modelValidator.validateTapestryDefinition(tapestryId);
TapestryDefinition tapestryDefinition = tapestryManager.getTapestryDefinition(session);
// querying with any tapestryId would work as well as the tapestryManager works
// based on session, not id.
return tapestryDefinition;
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.TAPESTRY_BASE, method = RequestMethod.GET, headers = ApiConfig.API_HEADERS,
produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public TapestryDefinitionList getTapestryDefinitions(
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws NoSuchSessionException {
if (rateLimiter.tryAcquire()) {
Session session = modelValidator.validateSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Get all tapestry definitions");
}
synchronized (session) {
// Ultimately, this needs to be changed based on user rather than session.
TapestryDefinition tapestryDefinition = tapestryManager.getTapestryDefinition(session);
ArrayList<TapestryDefinition> tapestryDefinitions = new ArrayList<>(1);
if (tapestryDefinition != null) {
tapestryDefinitions.add(tapestryDefinition);
}
return new TapestryDefinitionList(tapestryDefinitions);
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.TAPESTRY_BASE + "/{tapestryId}", method = RequestMethod.DELETE,
headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public void deleteTapestryDefinition(@PathVariable final String tapestryId,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws NoSuchSessionException, NoSuchTapestryDefinitionException {
if (rateLimiter.tryAcquire()) {
Session session = modelValidator.validateSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Delete tapestry definition with id: " + tapestryId);
}
synchronized (session) {
modelValidator.validateTapestryDefinition(tapestryId);
// Ultimately, this needs to be a specific tapestry not based on sesssion.
tapestryManager.clearTapestryDefinition(session);
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.TAPESTRY_BASE, method = RequestMethod.DELETE, headers = ApiConfig.API_HEADERS,
produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public void deleteTapestryDefinitions(
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws NoSuchSessionException {
if (rateLimiter.tryAcquire()) {
Session session = modelValidator.validateSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Delete all tapestry definitions");
}
synchronized (session) {
// Ultimately, this needs to invoke a method in tapestry manager to remove all
// tapestries rather than the only one bound with a session.
tapestryManager.clearTapestryDefinition(session);
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.ACTION_RESULTS_BASE + "/{actionResultId}", method = RequestMethod.GET,
headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public ActionResult getActionResult(@PathVariable final String actionResultId,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws InvalidActionSpecificationException, NoSuchProviderException,
NoSuchSessionException, NoSuchItemTypeException {
if (rateLimiter.tryAcquire()) {
if (actionResultId == null) {
throw new BadRequestException("actionResultId cannot be null");
}
UUID uuid = UUID.fromString(actionResultId);
Session session = modelValidator.validateSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Lookup action result " + actionResultId + " for session " + sessionId);
}
synchronized (session) {
if (LOG.isDebugEnabled()) {
LOG.debug("Assigned session " + session.getId());
}
ActionResult actionResult = actionManager.getActionResult(session, uuid);
return actionResult;
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.ITEM_TYPE + "/{providerType}/{providerId}", method = RequestMethod.GET,
headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public ItemTypeList getItemTypes(@PathVariable final String providerType, @PathVariable final String providerId,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws NoSuchProviderException {
if (rateLimiter.tryAcquire()) {
sessionManager.getSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Get all itemTypes for a provider");
}
modelValidator.validateProviderType(providerType);
modelValidator.validateProviderId(providerId);
Provider provider = getProvider(providerType, providerId);
return new ItemTypeList(new HashSet<>(itemTypeManager.getItemTypes(provider)));
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.ITEM_TYPE + "/{providerType}", method = RequestMethod.GET,
headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public ItemTypeList getItemTypes(@PathVariable final String providerType,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) {
if (rateLimiter.tryAcquire()) {
modelValidator.validateProviderType(providerType);
sessionManager.getSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Get all itemTypes for a provider type");
}
return new ItemTypeList(new HashSet<>(itemTypeManager.getItemTypes(providerType)));
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:HeatSeeking
文件:AuthController.java
/**
* 用户注册接口,根据实体传入参数
*
* @param auth
* @return
*/
@RequestMapping("/register.do")
@CrossOrigin
public FrontEndResponse register(@CookieValue(value = "token", defaultValue = "empty") String token,
AuthenticationEntity auth, HttpServletResponse response, HttpServletRequest request) {
/*新增用户,新增token,返回用户名*/
Map map = authService.register(auth);
if ((boolean) map.get("success")) {
Cookie responseCookie = new Cookie("token", (String) map.get("token"));
responseCookie.setPath("/");
responseCookie.setMaxAge(20 * 60);
response.addCookie(responseCookie);
AuthenticationEntity authenticationEntityDB = (AuthenticationEntity) map.get("auth");
return new FrontEndResponse(true, authenticationEntityDB.getUserName());
} else {
return new FrontEndResponse(false, "Email已存在");
}
}
项目:mojito
文件:ReactAppController.java
@RequestMapping({
"/",
"/login",
"repositories",
"project-requests",
"workbench",
"settings"
})
@ResponseBody
ModelAndView getIndex(HttpServletRequest httpServletRequest, @CookieValue(value = "locale", required = false, defaultValue = "en") String localeCookieValue) throws MalformedURLException, IOException {
ModelAndView index = new ModelAndView("index");
index.addObject("locale", getValidLocaleFromCookie(localeCookieValue));
index.addObject("csrfToken", csrfTokenController.getCsrfToken(httpServletRequest));
index.addObject("username", getUsername());
index.addObject("contextPath", contextPath);
return index;
}
项目:pollistics
文件:PollController.java
@PostMapping(value = "/polls/vote/{slug}")
public String voteOptions(@CookieValue(value = "pollistics-voted", defaultValue = "") String originalCookie, @PathVariable String slug, HttpServletRequest request, HttpServletResponse response, RedirectAttributes redirectAttrs) throws UnsupportedEncodingException {
String encodedSlug = URLEncoder.encode(slug, "UTF-8");
Poll p = pollService.getPoll(slug);
// already voted
if (originalCookie.contains(slug)) {
redirectAttrs.addFlashAttribute("message", "You already voted for this poll");
redirectAttrs.addFlashAttribute("message_type", "error");
response.setStatus(403);
return "redirect:/" + encodedSlug + "/results";
} else {
response.addCookie(CookieBuilder.getVotedCookie(originalCookie, slug));
String option = request.getParameter("option");
pollService.voteOption(p, option);
return "redirect:/" + encodedSlug + "/results";
}
}
项目:ds4p
文件:AdminController.java
/**
* Admin Home Page.
*
* NOTE: THIS FUNCTION IS A TEMPORARY FUNCTION TO DISPLAY THE ADMIN HOME PAGE
* IT MUST BE MODIFIED BEFORE IT IS INTEGREATED WITH THE BACK-END CODE
*
* @param model the model
* @param request the request
* @param recentVisits the recent visits
* @return the string
*/
@RequestMapping(value = "adminHome.html")
public String adminHome(Model model, HttpServletRequest request,
@CookieValue(value = "recent_visit", required = false) List<String> recentVisits) {
List<RecentPatientDto> recentPatientDtos=new ArrayList<RecentPatientDto>();
if(recentVisits!=null)
recentPatientDtos=patientService.findRecentPatientDtosById(recentVisits);
String notify = request.getParameter("notify");
BasicPatientAccountDto basicPatientAccountDto = new BasicPatientAccountDto();
model.addAttribute("notifyevent", notify);
model.addAttribute(basicPatientAccountDto);
model.addAttribute("recentVisits", recentPatientDtos);
return "views/Administrator/adminHome";
}
项目:ds4p
文件:AdminController.java
/**
* Admin Patient View Page.
*
* NOTE: THIS FUNCTION IS A TEMPORARY FUNCTION TO DISPLAY THE ADMIN PATIENT VIEW PAGE.
* IT MUST BE MODIFIED BEFORE IT IS INTEGREATED WITH THE BACK-END CODE
*
* @param model the model
* @param request the request
* @param response the response
* @param recentVisits the recent visits
* @return the string
*/
@RequestMapping(value = "adminPatientView.html")
public String adminPatientView(Model model, HttpServletRequest request, HttpServletResponse response,
@CookieValue(value = "recent_visit", required = false) List<String> recentVisits) {
if(request.getParameter("id")!=null){
response.addCookie(new Cookie("recent_visit", buildRecentPatientsCookie(recentVisits,request.getParameter("id"))));
long patientId=Long.parseLong(request.getParameter("id"));
PatientProfileDto patientProfileDto=patientService.findPatient((long) patientId);
List<ConsentListDto> consentListDto=consentService.findAllConsentsDtoByPatient((long) patientId);
model.addAttribute("patientProfileDto", patientProfileDto);
model.addAttribute("consentListDto", consentListDto);
populateLookupCodes(model);
return "views/Administrator/adminPatientView";
}else{
return "redirect:/Administrator/adminHome.html";
}
}
项目:runningdinner
文件:AdminController.java
@RequestMapping(value = RequestMappings.SEND_DINNERROUTES_MAIL, method = RequestMethod.GET)
public String showSendDinnerRoutesForm(
HttpServletRequest request,
@PathVariable(RequestMappings.ADMIN_URL_UUID_MARKER) String uuid,
@CookieValue(value = MailServerSettingsTransformer.MAILSERVER_SETTINGS_COOKIE_NAME, required = false) String mailServerSettings,
Model model, RedirectAttributes redirectAttributes, Locale locale) {
adminValidator.validateUuid(uuid);
SendDinnerRoutesModel sendDinnerRoutesModel = SendDinnerRoutesModel.createWithDefaultMessageTemplate(messages, locale);
mailServerSettingsTransformer.enrichModelWithMailServerSettings(uuid, sendDinnerRoutesModel, mailServerSettings);
bindCommonMailAttributesAndLoadTeamDisplayMap(model, sendDinnerRoutesModel, uuid,
communicationService.findLastDinnerRouteMailReport(uuid));
Map<String, String> teamDisplayMap = sendDinnerRoutesModel.getEntityDisplayMap();
if (teamDisplayMap.size() == 0) {
LOGGER.warn("Tried to call send dinner route mails for dinner {} without any existing teams", uuid);
return generateStatusPageRedirect(RequestMappings.ADMIN_OVERVIEW, uuid, redirectAttributes, new SimpleStatusMessage(
SimpleStatusMessage.WARN_STATUS, messages.getMessage("error.no.teams", null, locale)));
}
// Select all Teams:
sendDinnerRoutesModel.setSelectedEntities(new ArrayList<String>(teamDisplayMap.keySet()));
return getFullViewName("sendDinnerRoutesForm");
}
项目:runningdinner
文件:AdminController.java
@RequestMapping(value = RequestMappings.SEND_PARTICIPANT_MAILS, method = RequestMethod.GET)
public String showSendParticipantsForm(
HttpServletRequest request,
@PathVariable(RequestMappings.ADMIN_URL_UUID_MARKER) String uuid,
@CookieValue(value = MailServerSettingsTransformer.MAILSERVER_SETTINGS_COOKIE_NAME, required = false) String mailServerSettings,
Model model, RedirectAttributes redirectAttributes, Locale locale) {
adminValidator.validateUuid(uuid);
BaseSendMailsModel sendMailsModel = new BaseSendMailsModel();
mailServerSettingsTransformer.enrichModelWithMailServerSettings(uuid, sendMailsModel, mailServerSettings);
sendMailsModel.setMessage(messages.getMessage("message.template.participants", null, locale));
bindAndSetupParticipantMailAttributes(model, sendMailsModel, uuid, locale);
Map<String, String> participantDisplayMap = sendMailsModel.getEntityDisplayMap();
if (participantDisplayMap.size() == 0) {
LOGGER.warn("Tried to call send participant mails for dinner {} without any existing participants", uuid);
return generateStatusPageRedirect(RequestMappings.ADMIN_OVERVIEW, uuid, redirectAttributes, new SimpleStatusMessage(
SimpleStatusMessage.WARN_STATUS, messages.getMessage("error.no.participants", null, locale)));
}
// Select all participants:
sendMailsModel.setSelectedEntities(new ArrayList<String>(participantDisplayMap.keySet()));
return getFullViewName("sendParticipantsForm");
}
项目:Weikong
文件:OrderController.java
@ResponseBody
@RequestMapping("/add")
public Object createOrder(@CookieValue(value="cart", required= false, defaultValue="") String cart , @RequestParam("addressId") Long addressId , @RequestParam("deliverTime") String deliverTime) throws Exception {
Result<Object> result = new Result<Object>();
RequestData data = requestContextHolder.getRequestData();
@SuppressWarnings("unchecked")
Map<Long, Integer> map = new ObjectMapper().readValue(cart, Map.class);
if(map == null || map.size() == 0)
throw new ServiceException(ConstantsError.InvalidArguemnt);
List<ProductVO> list = productService.getProductList(data.getUserId(), new ArrayList<Long>(map.keySet()));
if(list == null || list.size() == 0)
throw new ServiceException(ConstantsError.InvalidArguemnt);
StringBuilder sb = new StringBuilder();
Long totalPrice = 0L;
for(int i = 0 ; i < list.size() ; i++) {
ProductVO p = list.get(i);
int num = map.get(String.valueOf(p.getId()));
totalPrice += (p.getPrice()*num);
sb.append(p.getTitle()).append("(").append(num).append(p.getUnit()).append(")").append(",");
}
sb.deleteCharAt(sb.length()-1);
orderService.addOrder(data.getUserId() , data.getOpenId() , addressId , sb.toString(), deliverTime , totalPrice);
return result;
}
项目:proctor-demo
文件:DemoController.java
@RequestMapping(value = "/change-definition", method = { RequestMethod.GET, RequestMethod.POST })
public String changeDefinition(@Nonnull final HttpServletResponse response,
@Nullable @CookieValue(required = false, value = TEST_DEFINITION_URL_COOKIE) String testDefnUrlCookie,
@Nullable @RequestParam(required = false, value = TEST_DEFINITION_URL_PARAM) String testDefnUrlParam) {
final String definitionUrl;
if (!Strings.isNullOrEmpty(testDefnUrlParam)) {
definitionUrl = testDefnUrlParam;
response.addCookie(createCookie(TEST_DEFINITION_URL_COOKIE, definitionUrl, Integer.MAX_VALUE));
} else {
definitionUrl = DefinitionManager.DEFAULT_DEFINITION;
if (testDefnUrlCookie != null) {
// clear cookie
response.addCookie(createCookie(TEST_DEFINITION_URL_COOKIE, "", -1));
}
}
definitionManager.load(definitionUrl, true);
return "redirect:/";
}
项目:incubator-servicecomb-java-chassis
文件:SpringmvcSwaggerGeneratorContext.java
@Override
protected void initParameterAnnotationMgr() {
super.initParameterAnnotationMgr();
parameterAnnotationMgr.register(CookieValue.class, new CookieValueAnnotationProcessor());
parameterAnnotationMgr.register(PathVariable.class, new PathVariableAnnotationProcessor());
parameterAnnotationMgr.register(RequestBody.class, new RequestBodyAnnotationProcessor());
parameterAnnotationMgr.register(RequestHeader.class, new RequestHeaderAnnotationProcessor());
parameterAnnotationMgr.register(RequestParam.class, new RequestParamAnnotationProcessor());
parameterAnnotationMgr.register(RequestAttribute.class, new RequestAttributeAnnotationProcessor());
parameterAnnotationMgr.register(RequestPart.class, new RequestPartAnnotationProcessor());
}
项目:karate
文件:HeadersController.java
@GetMapping("/{token:.+}")
public ResponseEntity validateToken(@CookieValue("time") String time,
@RequestHeader("Authorization") String[] authorization, @PathVariable String token,
@RequestParam String url) {
String temp = tokens.get(token);
String auth = authorization[0];
if (auth.equals("dummy")) {
auth = authorization[1];
}
if (temp.equals(time) && auth.equals(token + time + url)) {
return ResponseEntity.ok().build();
} else {
return ResponseEntity.badRequest().build();
}
}
项目:dataProvider
文件:UtilController.java
@RequestMapping(value={"", "/", "tasks"})
public String index(@CookieValue(value = "host", defaultValue = "") String host, @CookieValue(value = "slacktoken", defaultValue = "") String slacktoken, Model model) throws SchedulerException {
ecs.storeFromCoockies(host, slacktoken);
if (ecs.getConfiguration().getHost() == null) {
model.addAttribute("message", "The receiving endpoint needs to be configured.");
} else {
model.addAttribute("message", null);
}
model.addAttribute("tasks", jobUtility.getTasks());
return "tasks";
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.PROVIDERS_BASE + "/{providerType}/{providerId}", method = RequestMethod.POST,
headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public PatternDefinitionList logProvider(@PathVariable final String providerType,
@PathVariable final String providerId, @RequestParam final String operation,
@RequestBody(required = false) final Credentials creds,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws NoSuchProviderException, SessionAlreadyExistsException,
NoSuchSessionException, UserAlreadyConnectedException, NoSuchUserException {
if (rateLimiter.tryAcquire()) {
if (StringUtils.isBlank(providerType)) {
throw new BadRequestException("Empty provider type parameter");
}
if (StringUtils.isBlank(providerId)) {
throw new BadRequestException("Empty provider id parameter");
}
if (StringUtils.isBlank(operation)) {
throw new BadRequestException("Empty operation parameter");
}
Provider provider = getProvider(providerType, providerId);
if (provider == null) {
throw new NoSuchProviderException(providerType, providerId);
}
Session session = sessionManager.getSessionWithSessionId(sessionId, response);
synchronized (session) {
return handleLogOperation(provider, session, operation, creds, response);
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.TAPESTRY_BASE, method = RequestMethod.POST, headers = ApiConfig.API_HEADERS,
produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public TapestryDefinition createTapestryDefinition(@RequestBody final TapestryDefinition tapestryDefinition,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response)
throws NoSuchSessionException, NoSuchTapestryDefinitionException, NoSuchAggregationException,
NoSuchQueryDefinitionException, LogicalIdAlreadyExistsException, OperationException,
NoSuchThreadDefinitionException, InvalidQueryInputException, InvalidQueryParametersException,
NoSuchItemTypeException, ItemPropertyNotFound, RelationPropertyNotFound, ThreadDeletedByDynAdapterUnload {
if (rateLimiter.tryAcquire()) {
Session session = modelValidator.validateSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Create tapestry definition " + tapestryDefinition + " with session " + sessionId);
}
synchronized (session) {
modelValidator.validateTapestryDefinition(tapestryDefinition, true);
return setOrUpdateTapestryDefinition(session, tapestryDefinition);
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.TAPESTRY_BASE + "/{tapestryId}/threads/{threadId}/results",
method = RequestMethod.GET, headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public QueryResult getQueryResult(@PathVariable final String tapestryId, @PathVariable final String threadId,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws NoSuchSessionException, NoSuchThreadDefinitionException,
NoSuchTapestryDefinitionException, NoSuchQueryDefinitionException, NoSuchAggregationException,
LogicalIdAlreadyExistsException, InvalidQueryInputException, OperationException, ItemPropertyNotFound,
RelationPropertyNotFound, ThreadDeletedByDynAdapterUnload, NoSuchItemTypeException,
InvalidQueryParametersException, AccessExpiredException, JsonProcessingException, NoSuchProviderException {
if (rateLimiter.tryAcquire()) {
Session session = modelValidator.validateSessionAndAccess(sessionId, response, tapestryId, threadId);
if (LOG.isDebugEnabled()) {
LOG.debug("Query a thread with tapestryId: " + tapestryId + " and threadId: " + threadId
+ " with session ID " + sessionId);
}
synchronized (session) {
modelValidator.validateTapestryDefinition(tapestryId);
modelValidator.validateThreadDefinition(threadId);
return queryManager.getThread(session, threadId, false);
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.TAPESTRY_BASE + "/{tapestryId}/threads/results", method = RequestMethod.POST,
headers = ApiConfig.API_HEADERS, produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public QueryResultList getQueryResults(@PathVariable final String tapestryId,
@RequestBody final List<String> threadIds,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response)
throws NoSuchSessionException, NoSuchThreadDefinitionException, NoSuchTapestryDefinitionException,
NoSuchQueryDefinitionException, NoSuchAggregationException, LogicalIdAlreadyExistsException,
InvalidQueryInputException, OperationException, ItemPropertyNotFound, RelationPropertyNotFound,
ThreadDeletedByDynAdapterUnload, AccessExpiredException, JsonProcessingException, NoSuchProviderException {
if (rateLimiter.tryAcquire()) {
Session session = modelValidator.validateSessionAndAccess(sessionId, response, tapestryId);
if (LOG.isDebugEnabled()) {
LOG.debug("Query a set of threads with tapestryId " + tapestryId + " and threadIds in: "
+ threadIds.toString() + " with session ID " + sessionId);
}
synchronized (session) {
modelValidator.validateTapestryDefinition(tapestryId);
List<QueryResult> queryResults = new ArrayList<>(threadIds.size());
for (String threadId : threadIds) {
queryResults.add(queryManager.getThread(session, threadId, false));
}
return new QueryResultList(queryResults);
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.ACTIONS_BASE, method = RequestMethod.POST, headers = ApiConfig.API_HEADERS,
produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public ActionResult doAction(@RequestBody final Action action,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) throws InvalidActionSpecificationException, NoSuchProviderException,
NoSuchSessionException, NoSuchItemTypeException {
if (rateLimiter.tryAcquire()) {
if (action == null) {
throw new BadRequestException("Action object cannot be null");
}
Session session = modelValidator.validateSession(sessionId, response);
if (LOG.isDebugEnabled()) {
LOG.debug("Execute action " + action + " for session " + sessionId);
}
synchronized (session) {
if (LOG.isDebugEnabled()) {
LOG.debug("Assigned session " + session.getId());
}
ActionResult actionResult = actionManager.doAction(session, action);
return actionResult;
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.ITEM_TYPE, method = RequestMethod.GET, headers = ApiConfig.API_HEADERS,
produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public ItemTypeList getItemTypes(
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
@RequestParam(value = "current", required = false) final boolean current,
final HttpServletResponse response) throws NoSuchSessionException {
if (rateLimiter.tryAcquire()) {
if (LOG.isDebugEnabled()) {
LOG.debug("Get all itemTypes for all provider types");
}
Set<ItemType> itemTypes = new HashSet<>();
ItemTypeList itemTypeList = new ItemTypeList();
Session session = modelValidator.validateSession(sessionId, response);
synchronized (session) {
if (current) {
for (Provider provider : session.getProviders().keySet()) {
try {
itemTypes.addAll(itemTypeManager.getItemTypes(provider));
} catch (NoSuchProviderException e) {
}
}
} else {
itemTypes.addAll(itemTypeManager.getItemTypes());
}
itemTypeList.setItemTypes(itemTypes);
return itemTypeList;
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:loom
文件:LoomServiceImpl.java
@Override
@RequestMapping(value = ApiConfig.OPERATION, method = RequestMethod.GET, headers = ApiConfig.API_HEADERS,
produces = {ApiConfig.API_PRODUCES})
@ResponseBody
public OperationList getOperations(@RequestParam(value = "itemType", required = false) final String itemType,
@RequestParam(value = "providerType", required = false) final String providerType,
@RequestParam(value = "declaredBy", required = false) final String declaredBy,
@CookieValue(value = SessionManager.SESSION_COOKIE, required = false) final String sessionId,
final HttpServletResponse response) {
if (rateLimiter.tryAcquire()) {
sessionManager.getSession(sessionId, response);
if (!StringUtils.isBlank(providerType) && declaredBy == null && itemType == null) {
return getOperationsOperateOn(providerType);
} else if (providerType == null && !StringUtils.isBlank(declaredBy) && itemType == null) {
return getOperationsDeclaredBy(declaredBy);
} else if (!StringUtils.isBlank(itemType) && providerType == null && declaredBy == null) {
return getOperationsByItemType(itemType);
} else if (itemType == null && providerType == null && declaredBy == null) {
return getOperationsOperateOn(PROVIDER_ANY);
} else {
throw new BadRequestException(
"A request parameter required, either providerType or declaredBy or itemType");
}
} else {
throw new ApiThrottlingException("Exceeded max number of requests per second");
}
}
项目:school-website
文件:UserController.java
/**
* Logout common result.
* 注意一、修改、删除Cookie时,新建的Cookie除value、maxAge之外的所有属性
* 例如name、path、domain等,都要与原Cookie完全一样。否则,浏览器将视为两个不同的Cookie不予覆盖,导致修改、删除失败。
*
* @param cookie the cookie
* @param session the session
* @param response the response
* @return the common result
*/
@ResponseBody
@RequestMapping("/logout.do")
public CommonResult logout(@CookieValue("JSESSIONID") Cookie cookie, HttpSession session, HttpServletResponse response) {
if (!isEmpty(cookie)) {
cookie.setValue(null);
cookie.setMaxAge(0);
cookie.setPath("/");
response.addCookie(cookie);
}
session.invalidate();
return new CommonResult("注销成功",true);
}
项目:HeatSeeking
文件:AuthController.java
/**
* 验证用户是否登录,获取用户权限;
*
* @param token
* @param account
* @param password
* @param response
* @return
*/
@RequestMapping("/loginWithToken.do")
@CrossOrigin
public FrontEndResponse authentication(@CookieValue(value = "token", defaultValue = "empty") String token,
String account, String password, HttpServletResponse response) {
TokenEntity tokenEntity = authService.isTokenValid(token);
if (!token.equals("empty") && tokenEntity != null) {
AuthenticationEntity authenticationEntity = authService.findOne(tokenEntity.getUserId());
authService.updateTokenValidTime(tokenEntity);
return new FrontEndResponse(true, authenticationEntity.getUserName());
} else {
return new FrontEndResponse(false, "token 不存在或已超期,请使用账户密码登录");
}
}
项目:spring4-understanding
文件:Portlet20AnnotationControllerTests.java
@RequestMapping("EDIT")
@RenderMapping
public void myHandle(@RequestParam("param1") String p1, @RequestParam("param2") int p2,
@RequestHeader("header1") long h1, @CookieValue("cookie1") Cookie c1,
RenderResponse response) throws IOException {
response.getWriter().write("test-" + p1 + "-" + p2 + "-" + h1 + "-" + c1.getValue());
}