org.apache.commons.lang.time.DateUtils#addHours ( )源码实例Demo

下面列出了org.apache.commons.lang.time.DateUtils#addHours ( ) 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

源代码1 项目: datawave   文件: BaseQueryMetricHandler.java
public QueryMetricsSummaryHtmlResponse processQueryMetricsHtmlSummary(List<T> queryMetrics) throws IOException {
    
    QueryMetricsSummaryHtmlResponse summary = new QueryMetricsSummaryHtmlResponse();
    Date now = new Date();
    Date hour1 = DateUtils.addHours(now, -1);
    Date hour6 = DateUtils.addHours(now, -6);
    Date hour12 = DateUtils.addHours(now, -12);
    Date day1 = DateUtils.addDays(now, -1);
    Date day7 = DateUtils.addDays(now, -7);
    Date day30 = DateUtils.addDays(now, -30);
    Date day60 = DateUtils.addDays(now, -60);
    Date day90 = DateUtils.addDays(now, -90);
    
    for (T metric : queryMetrics) {
        try {
            binSummary(metric, summary, hour1, hour6, hour12, day1, day7, day30, day60, day90);
        } catch (Exception e1) {
            log.error(e1.getMessage());
        }
    }
    
    return summary;
}
 
源代码2 项目: datawave   文件: BaseQueryMetricHandler.java
public QueryMetricsSummaryResponse processQueryMetricsSummary(List<T> queryMetrics) throws IOException {
    
    QueryMetricsSummaryResponse summary = new QueryMetricsSummaryResponse();
    Date now = new Date();
    Date hour1 = DateUtils.addHours(now, -1);
    Date hour6 = DateUtils.addHours(now, -6);
    Date hour12 = DateUtils.addHours(now, -12);
    Date day1 = DateUtils.addDays(now, -1);
    Date day7 = DateUtils.addDays(now, -7);
    Date day30 = DateUtils.addDays(now, -30);
    Date day60 = DateUtils.addDays(now, -60);
    Date day90 = DateUtils.addDays(now, -90);
    
    for (T metric : queryMetrics) {
        try {
            binSummary(metric, summary, hour1, hour6, hour12, day1, day7, day30, day60, day90);
        } catch (Exception e1) {
            log.error(e1.getMessage());
        }
    }
    
    return summary;
}
 
源代码3 项目: ambari-logsearch   文件: ManageStartEndTime.java
@Override
public synchronized void run() {
  synchronized (ManageStartEndTime.class) {
    startDate = DateUtils.addSeconds(startDate, UPDATE_TIME_IN_SECONDS);
    endDate = DateUtils.addHours(startDate, 1);
  }
}
 
源代码4 项目: api-layer   文件: AuthenticationServiceTest.java
@Test
public void shouldParseJwtTokenAsQueryResponse() {
    String jwtToken = authService.createJwtToken(USER, DOMAIN, LTPA);

    String dateNow = new Date().toString().substring(0, 16);
    QueryResponse parsedToken = authService.parseJwtToken(jwtToken);

    assertEquals("org.zowe.apiml.security.common.token.QueryResponse", parsedToken.getClass().getTypeName());
    assertEquals(DOMAIN, parsedToken.getDomain());
    assertEquals(USER, parsedToken.getUserId());
    assertEquals(parsedToken.getCreation().toString().substring(0, 16), dateNow);
    Date toBeExpired = DateUtils.addHours(parsedToken.getCreation(), 24);
    assertEquals(parsedToken.getExpiration(), toBeExpired);
}
 
源代码5 项目: ambari-logsearch   文件: ManageStartEndTime.java
private ManageStartEndTime() {
  endDate = new Date();
  startDate = DateUtils.addHours(endDate, -1);
}
 
源代码6 项目: Mycat2   文件: MysqlMethodInvocationHandler.java
private SQLExpr invokeAddDate(SQLMethodInvokeExpr expr, boolean negative) throws SQLNonTransientException {
    List<SQLExpr> parameters = expr.getParameters();
    if (parameters.size() != 2) {
        throwSyntaxError(expr);
    }
    SQLExpr p1 = parameters.get(0);
    SQLExpr p2 = parameters.get(1);
    if (p1 instanceof SQLMethodInvokeExpr) {
        p1 = doInvoke((SQLMethodInvokeExpr) p1);
    }
    if (p1 instanceof SQLCharExpr) {
        String time = ((SQLCharExpr) p1).getText();
        Integer delta = null;
        String unit = null;
        if (p2 instanceof SQLIntegerExpr) {
            delta = (Integer) ((SQLIntegerExpr) p2).getNumber();
            unit = "DAY";
        } else if (p2 instanceof MySqlIntervalExpr) {
            SQLIntegerExpr value = (SQLIntegerExpr) ((MySqlIntervalExpr) p2).getValue();
            delta = (Integer) value.getNumber();
            unit = ((MySqlIntervalExpr) p2).getUnit().name();
        } else {
            throwSyntaxError(p2);
        }
        try {
            Date date = DateUtils.parseDate(time, SUPPORT_PATTERNS);
            Date result;
            delta = negative ? -delta : delta;
            if ("MONTH".equals(unit)) {
                result = DateUtils.addMonths(date, delta);
            } else if ("DAY".equals(unit)) {
                result = DateUtils.addDays(date, delta);
            } else if ("HOUR".equals(unit)) {
                result = DateUtils.addHours(date, delta);
            } else if ("MINUTE".equals(unit)) {
                result = DateUtils.addMinutes(date, delta);
            } else if ("SECOND".equals(unit)) {
                result = DateUtils.addSeconds(date, delta);
            } else {
                return null;
            }
            String ret = DateFormatUtils.format(result, "yyyy-MM-dd HH:mm:ss");
            return new SQLIdentifierExpr(ret);
        } catch (ParseException e) {
            LOGGER.error("",e);
        }
    }
    return null;
}
 
源代码7 项目: scava   文件: GremlinAdapter.java
private List<GraphTraversal<Vertex, Vertex>> getFramedValuesByDuration(Duration duration, Date currentTime) throws MetricException {
	List<GraphTraversal<Vertex, Vertex>> verticesList = new ArrayList<>();

	for (int i = 0; i < duration.getCount(); i++) {

		Date timeSliceBegin = DateUtils.addHours(currentTime, (-i * duration.getDuration()));
		Date timeSliceEnd = DateUtils.addHours(currentTime, (-i * duration.getDuration()) - duration.getDuration());

		GraphTraversal<Vertex, Vertex> vertexList = graphTraversalSource.V().where(__.has("TimeStamp", P.lte(timeSliceBegin))).where(__.has("TimeStamp", P.gte(timeSliceEnd))).order()
				.by("TimeStamp", Order.incr);

		verticesList.add(vertexList);

	}

	return verticesList;
}
 
源代码8 项目: mmall20180107   文件: OrderServiceImpl.java
public void closeOrder(int hour){

        Date closeTime = DateUtils.addHours(new Date(),-hour);

        List<Order> orderList = orderMapper.selectUnPayOrder(Const.OrderStatusEnum.NO_PAY.getCode(),DateTimeUtil.dateToStr(closeTime));

        for(Order order:orderList){

            List<OrderItem> orderItemList = orderItemMapper.selectByOrderNo(order.getOrderNo());

            for(OrderItem orderItem:orderItemList){

                Integer stock = productMapper.selectStockByProductId(orderItem.getProductId());

                if(stock==null){
                    continue;
                }

                Product product = new Product();
                product.setId(orderItem.getProductId());
                product.setStock(stock+orderItem.getQuantity());

                productMapper.updateByPrimaryKeySelective(product);

            }


        }






    }