下面列出了怎么用org.springframework.web.bind.annotation.RequestMapping的API类实例代码及写法,或者点击链接到github查看源代码。
/**
* 分页查询
*
* @return
* @throws Exception
*/
@SuppressWarnings("rawtypes")
@RequestMapping("list")
public Map<Object, Object> list(SysLogCriteria sysLogCriteria) throws Exception {
String sort = ServletRequestUtils.getStringParameter(request, "sort", "");
String order = ServletRequestUtils.getStringParameter(request, "order", "");
if (!isNotNullAndEmpty(sort)) {
sort = "logTime";
}
if (!isNotNullAndEmpty(order)) {
order = "desc";
}
PageBean pb = super.getPageBean(); // 获得分页对象
pb.setSort(sort);
pb.setSortOrder(order);
sysLogService.findByPage(pb, sysLogCriteria);
return super.setJsonPaginationMap(pb);
}
/**
* POST list all consumer groups for a specific cluster.
* This should require ADMIN role.
*/
@ResponseBody
@RequestMapping(path = "/cluster/{id}/consumer/remove", method = RequestMethod.POST, produces = "application/json")
public boolean removeConsumer(
@PathVariable final Long id,
@RequestBody final ConsumerRemoveRequest consumerRemoveRequest) {
// Retrieve cluster
final Cluster cluster = retrieveClusterById(consumerRemoveRequest.getClusterId());
try (final KafkaOperations operations = createOperationsClient(cluster)) {
return operations.removeConsumerGroup(consumerRemoveRequest.getConsumerId());
} catch (final Exception exception) {
throw new ApiException("ClusterNodes", exception);
}
}
/**
* Reset.
*
* @return the response entity
*/
@RequestMapping(value = "reset", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.GET, headers = "Accept=application/json")
@ResponseBody
public ResponseEntity<LogResponse> reset() {
final LoggerContext ctx = (LoggerContext) LogManager.getContext(false);
synchronized (ctx) {
// If the config location is null, it means we are using a non-standard path for
// the config file (for example log4j2-spring.xml. In this case the name of the configuration
// is usually the path to the configuration file. so we "fix" the path before reconfiguring
if (ctx.getConfigLocation() == null) {
ctx.setConfigLocation(Paths.get(ctx.getConfiguration().getName()).toUri());
}
ctx.reconfigure();
initInMemoryAppender();
}
return new ResponseEntity<>(listLoggers(ctx), HttpStatus.OK);
}
@RequestMapping(value = "/register", method = RequestMethod.POST)
public String register(Model model, @Valid UserRegistration userRegistration, BindingResult result) {
User user = userRegistration.getUser();
model.addAttribute("userRegistration", userRegistration);
model.addAttribute("currencies", currencyService.getCurrencies());
model.addAttribute("countries", countryService.getCountries());
int captcha1 = (int)(Math.random() * ((9 - 0) + 1));
int captcha2 = (int)(Math.random() * ((9 - 0) + 1));
int captchaAnswer = captcha1 + captcha2;
model.addAttribute("captcha1", captcha1);
model.addAttribute("captcha2", captcha2);
model.addAttribute("captchaAnswer", captchaAnswer);
if (result.hasErrors()) {
return "register";
}
userRegistration.applyUserRoles();
saveUser(user, userRegistration.getCompany(), userRegistration.getAddress());
authenticationService.authenticateUser(user);
emailGateway.userRegistration(user);
model.addAttribute("user", user);
return "registration/complete";
}
/**
* Same as submitRankingHedging but doesn't update the records.
*
* @throws IOException
* @throws ServletException
*
*/
@RequestMapping("/nextPrev")
@SuppressWarnings("unchecked")
public String nextPrev(HttpServletRequest request, HttpSession session) throws IOException, ServletException {
String sessionMapID = request.getParameter(PeerreviewConstants.ATTR_SESSION_MAP_ID);
request.setAttribute(PeerreviewConstants.ATTR_SESSION_MAP_ID, sessionMapID);
SessionMap<String, Object> sessionMap = (SessionMap<String, Object>) session.getAttribute(sessionMapID);
ToolAccessMode mode = (ToolAccessMode) sessionMap.get(AttributeNames.ATTR_MODE);
PeerreviewUser user = (PeerreviewUser) sessionMap.get(PeerreviewConstants.ATTR_USER);
Long toolSessionId = (Long) sessionMap.get(PeerreviewConstants.PARAM_TOOL_SESSION_ID);
Long criteriaId = WebUtil.readLongParam(request, "criteriaId");
RatingCriteria criteria = service.getCriteriaByCriteriaId(criteriaId);
request.setAttribute(PeerreviewConstants.ATTR_SESSION_MAP_ID, sessionMap.getSessionID());
request.setAttribute(AttributeNames.ATTR_MODE, mode);
request.setAttribute(PeerreviewConstants.PARAM_TOOL_SESSION_ID, toolSessionId);
Boolean next = WebUtil.readBooleanParam(request, "next");
// goto standard screen
return startRating(request, session, sessionMap, toolSessionId, user, mode, criteria, next);
}
@RequestMapping(value = "/api/preparations/{preparationId}/unlock", method = PUT, produces = APPLICATION_JSON_VALUE)
@ApiOperation(value = "Mark a preparation as unlocked by a user.",
notes = "Does not return any value, client may expect successful operation based on HTTP status code.")
@Timed
public void unlockPreparation(@PathVariable(value = "preparationId") @ApiParam(name = "preparationId",
value = "Preparation id.") final String preparationId) {
if (LOG.isDebugEnabled()) {
LOG.debug("Locking preparation #{}...", preparationId);
}
final HystrixCommand<Void> command = getCommand(PreparationUnlock.class, preparationId);
command.execute();
if (LOG.isDebugEnabled()) {
LOG.debug("Locked preparation #{}...", preparationId);
}
}
@RequestMapping(value = "/test2", method = RequestMethod.GET)
public List<User> test2() {
List<User> users = new ArrayList<>();
User user1 = new User();
user1.setId(1);
user1.setName("十一");
user1.setPassword("12121");
User user2 = new User();
user2.setId(2);
user2.setName("十二");
user2.setPassword("21212");
User user3 = new User();
user3.setId(3);
user3.setName("十三");
user3.setPassword("31313");
users.add(user1);
users.add(user2);
users.add(user3);
return users;
}
/**
* 所有的抓取任务列表
*
* @return
*/
@RequestMapping(value = "tasks", method = RequestMethod.GET)
public ModelAndView tasks(@RequestParam(required = false, defaultValue = "false") boolean showRunning) {
ModelAndView modelAndView = new ModelAndView("panel/commons/listTasks");
ResultListBundle<Task> listBundle;
if (!showRunning) {
listBundle = commonsSpiderService.getTaskList(true);
} else {
listBundle = commonsSpiderService.getTasksFilterByState(State.RUNNING, true);
}
ResultBundle<Long> runningTaskCount = commonsSpiderService.countByState(State.RUNNING);
modelAndView.addObject("resultBundle", listBundle);
modelAndView.addObject("runningTaskCount", runningTaskCount.getResult());
modelAndView.addObject("spiderInfoList", listBundle.getResultList().stream()
.map(task -> StringEscapeUtils.escapeHtml4(
gson.toJson(task.getExtraInfoByKey("spiderInfo")
))
).collect(Collectors.toList()));
return modelAndView;
}
/**
* API to enable disable rule or job
*
* @author NKrishn3
* @param ruleId - valid rule or job Id
* @param user - userId who performs the action
* @param action - valid action (disable/ enable)
* @return Success or Failure response
*/
@ApiOperation(httpMethod = "POST", value = "API to enable disable rule or job", response = Response.class, consumes = MediaType.APPLICATION_JSON_VALUE)
@RequestMapping(path = "/enable-disable", method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<Object> enableDisableRuleOrJob(@AuthenticationPrincipal Principal user,
@ApiParam(value = "provide valid rule id", required = false) @RequestParam(name = "ruleId", required = false) String ruleId,
@ApiParam(value = "provide valid job id", required = false) @RequestParam(name = "jobId", required = false) String jobId,
@ApiParam(value = "provide valid action", required = true) @RequestParam(name = "action", required = true) String action) {
try {
if (!StringUtils.isBlank(ruleId)) {
return ResponseUtils.buildSucessResponse(ruleService.enableDisableRule(ruleId, action, user.getName()));
} else if (!StringUtils.isBlank(jobId)) {
return ResponseUtils.buildSucessResponse(jobService.enableDisableJob(jobId, action, user.getName()));
} else {
return ResponseUtils.buildFailureResponse(new Exception(UNEXPECTED_ERROR_OCCURRED), JOBID_OR_RULEID_NOT_EMPTY);
}
} catch (Exception exception) {
log.error(UNEXPECTED_ERROR_OCCURRED, exception);
return ResponseUtils.buildFailureResponse(new Exception(UNEXPECTED_ERROR_OCCURRED), exception.getMessage());
}
}
@SuppressWarnings("unused")
@RequestMapping("/deleteConsoleUserByUserids")
@ResponseBody
public int deleteConsoleUserByUserids(HttpServletRequest request) {
long startTime = System.currentTimeMillis();
int nRows = 0;
String _sUserIds = request.getParameter("userIds");
String type = request.getParameter("type");
if (!StringUtils.isNull(_sUserIds)) {
nRows = consoleUserService.deleteConsoleUserUserIds(_sUserIds);
boolean flag = false; // define opear result
if (nRows != 0)
flag = true;
}
return nRows;
}
@RequestMapping (value = "/users/{userid}/cart/{cartid}/getcount",
method = RequestMethod.GET)
public int countProductsInCart(Principal principal,
@PathVariable (value = "userid") String userid,
@PathVariable (value = "cartid") String cartid)
throws ProductCartServiceException
{
User user = (User)((UsernamePasswordAuthenticationToken) principal).
getPrincipal();
fr.gael.dhus.service.ProductCartService productCartService =
ApplicationContextProvider.getBean(
fr.gael.dhus.service.ProductCartService.class);
try
{
return productCartService.countProductsInCart(user.getUUID());
}
catch (Exception e)
{
e.printStackTrace();
throw new ProductCartServiceException(e.getMessage());
}
}
@RequestMapping(value = {"/change_project.htm"})
public String changeProject(Model model) {
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
User user = (User) request.getSession().getAttribute(Attribute.SESSION_USER);
List<ProjectUser> projectUserList = indexService.selectProjectUserByUserCode(user.getCode());
request.getSession().setAttribute(Attribute.PROJECT_LIST, projectUserList);
String projectCode = request.getParameter("project_code");
if (!KobUtils.isEmpty(projectUserList)) {
for (ProjectUser projectUser : projectUserList) {
if (projectUser.getProjectCode().equals(projectCode)) {
request.getSession().setAttribute(Attribute.PROJECT_SELECTED, projectUser);
return welcome(model);
}
}
}
return welcome(model);
}
/**
* 添加slave节点
*
* @param appId
* @param masterInstanceId
* @param slaveHost
* @return
*/
@RequestMapping(value = "/addSlave")
public void addSlave(HttpServletRequest request, HttpServletResponse response, Model model, long appId,
int masterInstanceId, String slaveHost) {
AppUser appUser = getUserInfo(request);
logger.warn("user {} addSlave: appId:{},masterInstanceId:{},slaveHost:{}", appUser.getName(), appId, masterInstanceId, slaveHost);
boolean success = false;
if (appId > 0 && StringUtils.isNotBlank(slaveHost) && masterInstanceId > 0) {
try {
success = redisDeployCenter.addSlave(appId, masterInstanceId, slaveHost);
} catch (Exception e) {
logger.error(e.getMessage(), e);
}
}
logger.warn("user {} addSlave: appId:{},masterInstanceId:{},slaveHost:{} result is {}", appUser.getName(), appId, masterInstanceId, slaveHost, success);
write(response, String.valueOf(success == true ? SuccessEnum.SUCCESS.value() : SuccessEnum.FAIL.value()));
}
/**
* 申购
*
* @param productName
* @param orderAmount
* @param currentAmount
* @param response
*/
@RequestMapping(value = "/purchase", method = RequestMethod.GET)
public void puchase(@RequestParam String productName, @RequestParam BigDecimal orderAmount,
@RequestParam BigDecimal currentAmount, HttpServletResponse response) {
response.setHeader("Content-type", "text/html;charset=UTF-8");
try {
this.sysout(response, "购买商品:[" + new String(productName.getBytes("iso8859-1"), "utf-8") + "],订单金额:["
+ orderAmount + "],账户余额:[" + currentAmount + "]");
PurchaseContext context = new PurchaseContext();
context.setCurrentAmount(currentAmount);
context.setOrderAmount(orderAmount);
context.setProductName(new String(productName.getBytes("iso8859-1"), "utf-8"));
log.info(context.toString());
String activityId = purchaseService.puchase(context);
this.sysout(response, "业务活动ID:" + activityId);
List<String> list = tradeLog.getNewLog(activityId);
for (String an : list) {
this.sysout(response, an);
}
} catch (Exception e) {
log.error(e.getMessage(), e);
}
}
/**
* <p>
* The dispatch method that allows the teacher to view the status of the gate. It is expecting the caller passed in
* lesson id and gate activity id as http parameter. Otherwise, the utility method will generate some exception.
* </p>
*
* <p>
* Based on the lesson id and gate activity id, it sets up the gate form to show the waiting learners and the total
* waiting learners. Regarding schedule gate, it also shows the estimated gate opening time and gate closing time.
* </p>
*
* <b>Note:</b> gate form attribute <code>waitingLearners</code> got setup after the view is dispatch to ensure
* there won't be casting exception occur if the activity id is not a gate by chance.
*/
@RequestMapping("/viewGate")
public String viewGate(@ModelAttribute GateForm gateForm, HttpServletRequest request,
HttpServletResponse response) {
// if this is the initial call then activity id will be in the request, otherwise
// get it from the form (if being called from openGate.jsp
Long gateIdLong = WebUtil.readLongParam(request, AttributeNames.PARAM_ACTIVITY_ID, true);
if (gateIdLong == null) {
gateIdLong = gateForm.getActivityId();
}
long gateId = gateIdLong != null ? gateIdLong.longValue() : -1;
GateActivity gate = (GateActivity) monitoringService.getActivityById(gateId);
if (gate == null) {
throw new MonitoringServiceException("Gate activity missing. Activity id" + gateId);
}
gateForm.setActivityId(gateIdLong);
return findViewByGateType(gateForm, gate);
}
@RequestMapping(value="/update", method=RequestMethod.POST)
public @ResponseBody User update(
@RequestParam String username,
@RequestParam String firstName,
@RequestParam String lastName,
@RequestParam Integer role) {
Role existingRole = new Role();
existingRole.setRole(role);
User existingUser = new User();
existingUser.setUsername(username);
existingUser.setFirstName(firstName);
existingUser.setLastName(lastName);
existingUser.setRole(existingRole);
return service.update(existingUser);
}
/**
* 详情
* @return
*/
@RequestMapping(value="toDetail",method = RequestMethod.GET)
public void weixinTmessageSendLogDetail(@RequestParam(required = true, value = "id" ) String id,HttpServletResponse response,HttpServletRequest request)throws Exception{
VelocityContext velocityContext = new VelocityContext();
String viewName = "tmessage/back/weixinTmessageSendLog-detail.vm";
WeixinTmessageSendLog weixinTmessageSendLog = weixinTmessageSendLogService.queryById(id);
velocityContext.put("weixinTmessageSendLog",weixinTmessageSendLog);
ViewVelocity.view(request,response,viewName,velocityContext);
}
@RequestMapping(
method = GET,
value = "/project/all/subnets")
public Map getAllSubnetStates() {
Map result = new HashMap<String, Object>();
Map dataItems = this.subnetRedisRepository.findAllItems();
result.put("Count", dataItems.size());
result.put("Subnets", dataItems);
return result;
}
@RequestMapping(value = VirtualRouterConstant.VR_INIT, method = RequestMethod.POST)
private @ResponseBody
String init(HttpServletRequest req) {
HttpEntity<String> entity = restf.httpServletRequestToHttpEntity(req);
doInit(entity);
return null;
}
@ResponseBody
@RequestMapping(value = "/crossDataCenter")
@AuthIgnore
public Map<String, Object> crossDataCenter(@ModelAttribute("name") String name, HttpServletRequest request) {
Set<MediaSourceType> types = new HashSet<>();
if (name.toUpperCase().equals(MediaSourceType.ELASTICSEARCH.name())) {
types.add(MediaSourceType.ELASTICSEARCH);
} else if (name.toUpperCase().equals(MediaSourceType.HBASE.name())) {
types.add(MediaSourceType.HBASE);
} else if (name.toUpperCase().equals(MediaSourceType.HDFS.name())) {
types.add(MediaSourceType.HDFS);
} else if (name.toUpperCase().equals(MediaSourceType.MYSQL.name())) {
types.add(MediaSourceType.MYSQL);
} else if (name.toUpperCase().equals(MediaSourceType.SQLSERVER.name())) {
types.add(MediaSourceType.SQLSERVER);
} else if (name.toUpperCase().equals(MediaSourceType.POSTGRESQL.name())) {
types.add(MediaSourceType.POSTGRESQL);
} else if (name.toUpperCase().equals(MediaSourceType.SDDL.name())) {
types.add(MediaSourceType.SDDL);
} else if (name.toUpperCase().equals(MediaSourceType.ORACLE.name())){
types.add(MediaSourceType.ORACLE);
} else {
//忽略
}
List<MediaSourceInfo> mediaSourceList = mediaSourceService.getListByType(types);
Map<String, Object> map = new HashMap<>();
List<String> num = new ArrayList<>();
List<String> val = new ArrayList<>();
for (MediaSourceInfo info : mediaSourceList) {
num.add(info.getId() + "");
val.add(info.getName());
}
map.put("num", num);
map.put("val", val);
return map;
}
@PreAuthorize( "hasRole('ALL') or hasRole('F_SEND_EMAIL')" )
@RequestMapping( value = "/notification", method = RequestMethod.POST, produces = "application/json" )
public void sendEmailNotification( @RequestParam Set<String> recipients, @RequestParam String message,
@RequestParam ( defaultValue = "DHIS 2" ) String subject,
HttpServletResponse response, HttpServletRequest request ) throws WebMessageException
{
checkEmailSettings();
OutboundMessageResponse emailResponse = emailService.sendEmail( subject, message, recipients );
emailResponseHandler( emailResponse, request, response );
}
/**
* 查看我的通知-发送记录
*/
@RequestMapping(value = "viewRecordData")
@ResponseBody
public OaNotify viewRecordData(OaNotify oaNotify, Model model) {
if (StringUtils.isNotBlank(oaNotify.getId())){
oaNotify = oaNotifyService.getRecordList(oaNotify);
return oaNotify;
}
return null;
}
@RequestMapping(path = "/loginmaintain")
public String execute(@ModelAttribute LoginMaintainForm loginMaintainForm, HttpServletRequest request)
throws Exception {
loginMaintainForm.setNews(loadNews());
return "loginmaintain";
}
@ResponseBody
@RequestMapping("/test/aop/with/annotation")
@TokenRequired
public Map<String, Object> testAOPAnnotation(){
Map<String, Object> map = new LinkedHashMap<>();
map.put("result", "Aloha");
return map;
}
@RequestMapping("/initPedagogicalPlannerForm")
public String initPedagogicalPlannerForm(@ModelAttribute("pedagogicalPlannerForm") ScribePedagogicalPlannerForm pedagogicalPlannerForm,
HttpServletRequest request) {
Long toolContentID = WebUtil.readLongParam(request, AttributeNames.PARAM_TOOL_CONTENT_ID);
Scribe scribe = scribeService.getScribeByContentId(toolContentID);
pedagogicalPlannerForm.fillForm(scribe);
String contentFolderId = WebUtil.readStrParam(request, AttributeNames.PARAM_CONTENT_FOLDER_ID);
pedagogicalPlannerForm.setContentFolderID(contentFolderId);
return "pages/authoring/pedagogicalPlannerForm";
}
@RequestMapping(value = "/dictionary", method = GET, produces = APPLICATION_OCTET_STREAM_VALUE)
@ApiOperation(value = "Get current dictionary (as serialized object).")
@Timed
public StreamingResponseBody getDictionary() {
return outputStream -> {
// Serialize it to output
LOG.debug("Returning DQ dictionaries");
TdqCategories result = TdqCategoriesFactory.createFullTdqCategories();
try (ObjectOutputStream oos = new ObjectOutputStream(new GZIPOutputStream(outputStream))) {
oos.writeObject(result);
}
};
}
/**
* 客户结算-通过订单编号查询单个实体的已填所有信息
*/
@RequestMapping(value = "/selectCustomerBillClearByCode/{goodsBillCode}", method = RequestMethod.GET)
public CustomerBillClear selectCustomerBillClearByCode(@PathVariable("goodsBillCode") String goodsBillCode) {
CustomerBillClear customerBillClear = clearService.selectByBillCode(goodsBillCode);
System.out.println(customerBillClear);
return customerBillClear;
}
@RequestMapping(value = "/toUpdateHbaseTask")
public ModelAndView toUpdateHbaseTask(Long id) {
ModelAndView mav = new ModelAndView("task/hbaseTaskUpdate");
TaskInfo taskInfo = taskService.getTask(id);
Map<String, PluginWriterParameter> writerParameterMap = getWriterParameters();
taskInfo.getTaskWriterParameterObjs().forEach(i -> writerParameterMap.put(i.getPluginName(), i));
HBaseTaskModel hbaseTaskModel = new HBaseTaskModel(
new TaskModel.TaskBasicInfo(
id,
taskInfo.getTaskName(),
taskInfo.getTaskDesc(),
taskInfo.getTargetState(),
taskInfo.getGroupId()
),
writerParameterMap,
groupService.getAllGroups(),
TargetState.getAllStates(),
mediaService.getMediaSourcesByTypes(MediaSourceType.HBASE),
buildZkMediaSources(),
PluginWriterParameter.RetryMode.getAllModes(),
RdbmsWriterParameter.SyncMode.getAllModes(),
(HBaseReaderParameter) taskInfo.getTaskReaderParameterObj(),
CommitMode.getAllCommitModes(),
SerializeMode.getAllSerializeModes(),
PartitionMode.getAllPartitionModes(),
taskInfo.isLeaderTask() ? "1" : "0"
);
hbaseTaskModel.setCurrentWriters(taskInfo.getTaskWriterParameterObjs().stream().collect(Collectors.toMap(PluginWriterParameter::getPluginName, i -> "1")));
mav.addObject("taskModel", hbaseTaskModel);
return mav;
}
@PreAuthorize("hasAnyAuthority('TENANT_ADMIN', 'CUSTOMER_USER')")
@RequestMapping(value = "/asset/types", method = RequestMethod.GET)
@ResponseBody
public List<TenantAssetType> getAssetTypes() throws IoTPException {
try {
SecurityUser user = getCurrentUser();
TenantId tenantId = user.getTenantId();
ListenableFuture<List<TenantAssetType>> assetTypes = assetService.findAssetTypesByTenantId(tenantId);
return checkNotNull(assetTypes.get());
} catch (Exception e) {
throw handleException(e);
}
}
@RequestMapping(value = "/admin/latest-agent.status", method = {RequestMethod.HEAD, RequestMethod.GET})
public void checkAgentStatus(HttpServletResponse response) {
LOG.debug("Processing '/admin/latest-agent.status' request with values [{}:{}], [{}:{}], [{}:{}], [{}:{}]",
SystemEnvironment.AGENT_CONTENT_MD5_HEADER, agentChecksum,
SystemEnvironment.AGENT_LAUNCHER_CONTENT_MD5_HEADER, agentLauncherChecksum,
SystemEnvironment.AGENT_PLUGINS_ZIP_MD5_HEADER, pluginsZip.md5(),
SystemEnvironment.AGENT_TFS_SDK_MD5_HEADER, tfsSdkChecksum);
response.setHeader(SystemEnvironment.AGENT_CONTENT_MD5_HEADER, agentChecksum);
response.setHeader(SystemEnvironment.AGENT_LAUNCHER_CONTENT_MD5_HEADER, agentLauncherChecksum);
response.setHeader(SystemEnvironment.AGENT_PLUGINS_ZIP_MD5_HEADER, pluginsZip.md5());
response.setHeader(SystemEnvironment.AGENT_TFS_SDK_MD5_HEADER, tfsSdkChecksum);
response.setHeader(SystemEnvironment.AGENT_EXTRA_PROPERTIES_HEADER, getAgentExtraProperties());
setOtherHeaders(response);
}
如果文章对你有帮助,欢迎点击上方按钮打赏作者