`
y806839048
  • 浏览: 1121559 次
  • 性别: Icon_minigender_1
  • 来自: 上海
文章分类
社区版块
存档分类
最新评论

rest 调用有参数接口

    博客分类:
  • rest
 
阅读更多
//有参数rest,调用客户端   OperateLogServiceImpl.java

  public ResultModel<List<OperateLogVO>> getOperateLogList(OperateLogFilter filter, int page, int rows, String sortName, String sortType) {
        String requestUrl = ConfigFileLoad.getConfContent("NFVO_IP") + "/rest/operlogs/";
        final List<OperateLogVO> voList = new ArrayList<OperateLogVO>();
        // HttpClientGetRequest request = new HttpClientGetRequest(requestUrl);
        HttpRestClientRequest request = new HttpRestClientRequest(requestUrl);
        request.addParam("pageSize", rows);
        request.addParam("pageNum", page);
        if (StringUtils.isNotBlank(filter.getOperateType())) {
            request.addParam("operateType", filter.getOperateType());
        }
        if (!"-1".equals(filter.getSubsystem())) {
            request.addParam("subsystem", filter.getSubsystem());
        }
        if (StringUtils.isNotBlank(filter.getEventId())) {
            request.addParam("eventId", filter.getEventId());
        }
        if (StringUtils.isNotBlank(filter.getsDate())) {
            request.addParam("startTime", filter.getsDate());
        }

        if (StringUtils.isNotBlank(filter.geteDate())) {
            request.addParam("endTime", filter.geteDate());
        }

        if ("eventIdSort".equals(sortName)) {
            sortName = "event_id";
        } else if ("operateTypeSort".equals(sortName)) {
            sortName = "operate_type";
        } else if ("timestampSort".equals(sortName)) {
            sortName = "create_time";
        }
        if (StringUtils.isNotBlank(sortName)) {
            request.addParam("orderField", sortName);
            request.addParam("orderType", sortType);
        } else {
            request.addParam("orderField", "create_time");
            request.addParam("orderType", "1");
        }

        String response = request.postRequest();
        JSONObject resObj = JSONObject.parseObject(response);// .fromObject(response);
        JSONObject jsonObj = resObj.getJSONObject("result");
        JSONArray jsArray = jsonObj.getJSONArray("operationLogList");
        int totalSize = DataType.getAsInt(jsonObj.get("size"));
        OperateLogVO vo;
        JSONObject jso;
        for (int i = 0; i < jsArray.size(); i++) {
            jso = jsArray.getJSONObject(i);
            vo = new OperateLogVO();
            vo.setId("1");
            vo.setUserId(jso.getString("userId"));
            vo.setEventId(jso.getString("eventId"));
            vo.setOperateType(jso.getString("operateType"));
            vo.setRequestContent(jso.getString("requestContent"));
            vo.setRequestStatus(jso.getString("responseStatus"));
            vo.setSubsystem(jso.getString("subsystem"));
            vo.setTimestamp(jso.getString("createTime"));
            vo.setResponseContent(jso.getString("responseContent"));
            voList.add(vo);
        }

        ResultModel<List<OperateLogVO>> result = null;

        result = new ResultModel<List<OperateLogVO>>(voList);
        result.setResult(Constants.RESULT_FLAG.SUCCESS.number());
        result.setTotalSize(totalSize);
        result.setCurrentPageNum(page);
        result.setPageSize(rows);
        result.setStartRowNo(CommonUtil.getStartRowNo(page, rows));
        result.setTotalPageNum(totalSize % rows == 0 ? totalSize / rows : (totalSize / rows) + 1);

        return result;
    }




@POST
    @Path("/operlogs")
    @Produces(ContentType.APPLICATION_JSON_UTF_8)
    @Consumes(ContentType.APPLICATION_JSON_UTF_8)
    public OperationLogPageResult find(@QueryParam("userId") String userId,
////////////////////////////////直接将参数转化成变量
    @QueryParam("eventId") String eventId,
    @QueryParam("subsystem") String subsystem,
    @QueryParam("operateType") String operateType,
    @QueryParam("startTime") String startTime,
    @QueryParam("endTime") String endTime,
    @QueryParam("pageSize") String pageSize,
    @QueryParam("pageNum") String pageNum,
    @QueryParam("orderField") String orderField,
    @QueryParam("orderType") String orderType) throws ManoException
    {
        try
        {
        OperLogQuery operlogQuery = new OperLogQuery();
        operlogQuery.setStartTime(startTime);
        operlogQuery.setEndTime(endTime);
        operlogQuery.setEventId(eventId);
        operlogQuery.setOperateType(operateType);
        operlogQuery.setOrderField(orderField);
        operlogQuery.setOrderType(orderType);
        operlogQuery.setSubsystem(subsystem);
        operlogQuery.setUserId(userId);
       
        OperationLogPageResult result = new OperationLogPageResult();
        int size = operationLogLS.countAll(operlogQuery);
        result.setSize(size);
       
        if(!StringUtils.isEmpty(pageSize))
        {
        int pageSizeInt = Integer.parseInt(pageSize);
            operlogQuery.setStartNum((Integer.parseInt(pageNum) - 1) * pageSizeInt);
            operlogQuery.setPageSize(pageSizeInt);
        }

            List<OperationLog> operationLogList = operationLogLS.selectPage(operlogQuery);

            result.setOperationLogList(operationLogList);
           
            return result;
        }
        catch (Exception ex)
        {
            LOG.error(ex.getMessage(), ex);
            throw new ManoException(ex);
        }
    }

========================================================



//有参数二======================:

OperateLogServiceImpl.java
@Override
    public String saveOperateLog(String operateType, String requestContent, String responstatus, String responseContent) {
        String ret = "";
        try {
            logger.info("开始记录日志");
            String url = ConfigFileLoad.getConfContent("NFVO_IP") + "/rest/logs/generation";
            // url = "http://172.16.25.138:9090/nfvo/rest/logs/generation";
            HttpRestClientRequest hr = new HttpRestClientRequest(url);
            hr.addParam("Event-Id", UUID.randomUUID().toString());
            hr.addParam("User-Id", formatStr(CommonUtil.getUserId()));
            hr.addParam("Operate-Type", formatStr(operateType));
            hr.addParam("Request-Content", formatStr(requestContent));
            hr.addParam("Response-Status", formatStr(responstatus));
            hr.addParam("Response-Content", formatStr(responseContent));
            hr.addParam("Subsystem", "GUI");
            ret = hr.postRequest();
        } catch (Exception e) {
            logger.info("记录日志失败" + ret);
            e.printStackTrace();
        }
        return ret;
    }





@Service("NsdService")
public class NsdServiceImpl implements INsdService {
  private static void addOperateLog() {
        String url = "http://172.16.25.138:9090/nfvo/rest/logs/generation";
        HttpRestClientRequest hr = new HttpRestClientRequest(url);



OperationLogRest

///上文的带参数的接口调动,mybatise的应用
@POST
    @Path("logs/generation")
    @Produces(ContentType.APPLICATION_JSON_UTF_8)
    @Consumes(ContentType.APPLICATION_JSON_UTF_8)
    public long saveOperationLog(@Context HttpServletRequest request) throws ManoException
    {
        try
        {
            OperationLog operationLog = new OperationLog();
            operationLog.setEventId(request.getParameter("Event-Id"));
            operationLog.setOperateType(request.getParameter("Operate-Type"));
            operationLog.setRequestContent(request.getParameter("Request-Content"));
            operationLog.setSubsystem(request.getParameter("Subsystem"));
            operationLog.setUserId(request.getParameter("User-Id"));
            operationLog.setResponseContent(request.getParameter("Response-Content"));
            operationLog.setResponseStatus(request.getParameter("Response-Status"));
            operationLogLS.insertOne(operationLog);
            return operationLog.getId();
        }
        catch (Exception ex)
        {
            LOG.error(ex.getMessage(), ex);
            throw new ManoException(ex);
        }
    }



================================================
有参数调用三
//一个path一段   WebTarget webTarget = client.target(vimRestRootUrl).path(VDU_URL).path(vduUUID).path("detail");

@Override
public TenantNetwork queryTenantNetwork(String uuid) {

if(StringUtils.isEmpty(uuid))
{
return null;
}

Client client = getClient();
WebTarget webTarget = client.target(vimRestRootUrl)
.path("vlinks_internal/" + uuid + "/detail");
Invocation.Builder invocationBuilder = webTarget.request(ContentType.APPLICATION_JSON_UTF_8);

TenantNetworkQueryResp resp = invocationBuilder.get(TenantNetworkQueryResp.class);

if(!resp.getRetCode().equals("ok"))
{
if(RestResultCode.ITEM_NOT_FOUND.equals(resp.getRetCode()))
{
logger.error(resp.getRetCode() + ":" + resp.getMsg());
return null;
}
else
{
throw new ManoException(resp.getRetCode(), resp.getMsg());
}
}

return resp.getResult();
}





@GET
@Path("vlinks_internal/{vlink_uuid}/detail")//{vlink_uuid}
这个变量直接通过前方传过的地址位置对应接收
@Produces(ContentType.APPLICATION_JSON_UTF_8)
@Consumes(MediaType.TEXT_PLAIN)
//这里的这个之所以会设置成变量有path中决定生成
public Network findNetworkById(
@PathParam("vlink_uuid") String vlinkUUID(直接用),@HeaderParam("X-Auth-Token") String token) throws ManoException {

logger.info("findNetworkById-X-Auth-Token="+token);
logger.info("findNetworkById-vlinkUUID="+vlinkUUID);

if ((null == vlinkUUID) || (vlinkUUID.trim().equalsIgnoreCase(""))) {
throw new ManoException(ExceptionCode.PARAM_NEEDED_IS_NULL);
}

try {

return networkService.findNetworkById(vlinkUUID,token);

} catch (ManoException ex) {
throw ex;
}  catch (Exception ex)
{
logger.error("findNetworkById-ex = " + ex);
throw new ManoException(ExceptionCode.FIND_VLINK_INTERNAL_FAILED, ex);
}



}
分享到:
评论

相关推荐

    Java 调用Http Rest接口 例子说明

    #### 三、Java调用REST接口的方法 ##### 3.1 使用Apache HttpClient库 Apache HttpClient是一个用于Java开发者的高效、最新的HTTP客户端库,可以用来构建HTTP客户端应用,包括简单的GET请求以及复杂的POST请求。 ...

    泛微 9.0 rest接口调用说明

    泛微9.0 REST接口调用是一个用于与泛微协同办公系统进行交互的重要技术,它允许开发者通过HTTP请求来执行各种操作,如注册、获取访问令牌、创建流程以及实现单点登录。下面是这些知识点的详细说明: 1. **注册接口*...

    动态发布rest接口及服务调用

    调用者根据REST接口的URL、HTTP方法和可能需要的参数,发送请求并接收响应。例如,使用Jersey的`Client`和`WebTarget`可以这样调用接口: ```java Client client = ClientBuilder.newClient(); WebTarget target = ...

    数据抽取-Kettl动态参数调用HTTP、POST接口

    动态参数调用HTTP、POST接口在各种场景下都有应用,如: - 实时数据同步:从API获取最新的数据。 - 事件触发的ETL:当某个事件发生时,通过POST发送数据到分析平台。 - 自动化报告:定期调用接口获取报告数据,然后...

    Java 调用Http Rest接口 例子说明2

    #### 三、Java实现HTTP REST调用 本文提供的代码示例基于Apache HttpClient库实现,该库提供了丰富的API来处理HTTP请求和响应。 ##### 3.1 GET请求示例 ```java public static String getHttp(String url) { ...

    存储REST接口调用使用说明及范例-xiaoqiang1

    然而,在技术支持过程中,仍然有很多用户需要在特定的场合下,通过调用Azure REST接口来实现某部分业务的需求。 二、Azure Storage Services REST API Reference Azure 官方文档中提供了Storage Services REST API...

    java REST接口测试 测试小例子

    在这个"java REST接口测试 测试小例子"中,我们将探讨如何在Java环境下进行REST接口的调用以及测试。 首先,`Test.java`文件很可能是包含测试代码的主类。在Java中,我们通常使用JUnit框架进行单元测试,不过这个...

    再谈kettle两种循环之-调用http分页接口循环获取数据

    这在需要多次调用同一接口获取大量分页数据时非常有用。 描述中提到的变量运用是Kettle中动态配置的重要组成部分。在处理HTTP分页接口时,我们可以设置全局变量来存储页码、每页大小等参数,然后在循环中动态更新...

    kettle rest 接口 请求实例

    保存token的方法有很多种,可以将其写入到Kettle的变量或参数中,也可以存储在一个单独的文件中。当需要进行API调用时,Kettle作业或转换可以从这些位置读取并使用该token。为了保持安全性,应当确保存储token的地方...

    致远OA开发REST远程接口实现发送表单

    1. **API配置**:首先,你需要在致远OA的后台管理系统中配置REST接口,设定接口的URL、请求方法(POST、GET等)、参数类型等信息。这一步骤确保了外部系统可以通过这些接口与OA系统进行通信。 2. **构建请求参数**...

    安卓调用webservice接口

    总之,调用WebService接口是Android开发中的重要环节,理解并熟练掌握SOAP和RESTful API的调用方法,以及相关的数据解析、错误处理、权限申请和性能优化,将有助于你构建高效、稳定的Android应用。随着技术的发展,...

    patch_NC65restful接口_20180629_dingyh5.zip

    在实际应用中,开发者应当仔细阅读接口文档,理解每个接口的功能和使用限制,以确保接口的正确调用,避免出现错误或冲突。 总之,NC65的RESTful接口为开发者提供了一种高效、标准的方式来访问和操作系统资源,...

    H3C CAS REST API接口

    H3C CAS的REST API设计简洁,易于理解和使用,使得开发者可以使用常见的编程语言如Python、Java、JavaScript等来调用这些接口,实现自动化管理任务。 在使用H3C CAS REST API时,首先需要了解API的基本结构和请求...

    Jquery调用Rest

    在上面的代码中,`url`参数指定了REST服务的地址,`type`参数设定了请求类型。`success`和`error`回调函数分别处理成功和失败的情况。 除了`$.ajax()`, jQuery还提供了更简单的`$.get()`和`$.post()`方法,它们是对...

    REST接口测试工具(postman)

    2. **参数管理**:在请求构造器中,用户可以添加查询参数、路径参数、表单数据或JSON数据,方便测试接口的输入数据处理。 3. **集合**:Postman的集合功能允许将相关请求组织在一起,形成一个测试套件,便于管理和...

    SAP ABAP 通用接口日志&amp;restful 动态调用FM

    在ABAP中,你可以通过定义和实现特定的日志类来创建自定义的日志机制,这些类通常会记录接口调用的输入参数、返回值、异常以及执行时间等信息。 接下来,我们转向RESTful动态调用Function Module(FM)。REST...

    vue 调用 RESTful风格接口操作

    本篇文章将详细介绍如何在Vue项目中调用RESTful风格的接口。 REST(Representational State Transfer)是一种软件架构风格,用于设计网络应用程序。它强调通过HTTP方法(GET、POST、PUT、DELETE)来对应不同的操作...

    myService_purpose1sv_cxf调用axis2的接口服务_接口服务_

    3. **调用服务方法**:通过生成的服务代理类实例,我们可以调用Axis2接口服务中的具体方法,传递参数并接收响应。 4. **处理结果**:收到服务响应后,根据业务需求进行数据解析和后续操作。 5. **异常处理**:添加...

    CAS restful接口调用

    ### CAS Restful接口调用详解 #### 一、CAS简介 CAS(Central Authentication Service)是一种开源的单点登录协议和服务实现。它旨在减轻单一Web应用的登录流程,并为多个服务提供一个集中式的认证机制。CAS支持...

Global site tag (gtag.js) - Google Analytics