@@ -230,8 +230,9 @@ private Collection<QuoteCb> createCbQuoteTimeFrame(final MyTimeFrame timeFrame1,
230
230
List <QuoteCb > quotes ) {
231
231
Date start = new Date ();
232
232
final SimpleDateFormat sdf = new SimpleDateFormat ("dd.MM.yyyy" );
233
- var result = isDay ? this .makeCbQuoteDay (quotes , timeFrame1 .begin (), timeFrame1 .end ())
234
- : this .makeCbQuoteHour (quotes , timeFrame1 .begin (), timeFrame1 .end ());
233
+ var result = this .makeCbQuoteDay (quotes , timeFrame1 .begin (), timeFrame1 .end ());
234
+ // var result = isDay ? this.makeCbQuoteDay(quotes, timeFrame1.begin(), timeFrame1.end())
235
+ // : this.makeCbQuoteHour(quotes, timeFrame1.begin(), timeFrame1.end());
235
236
LOG .info (String .format ("Calculate Coinbase %s Data for: " , isDay ? "Day" : "Hour" )
236
237
+ sdf .format (timeFrame1 .begin ().getTime ()) + " Time: " + (new Date ().getTime () - start .getTime ())
237
238
+ "ms" );
@@ -247,25 +248,33 @@ private void createCbIntervalAvg(boolean isDay) {
247
248
now .setTime (Date .from (LocalDate .now ().atStartOfDay ().atZone (ZoneId .systemDefault ()).toInstant ()));
248
249
final SimpleDateFormat sdf = new SimpleDateFormat ("dd.MM.yyyy" );
249
250
LOG .info ("isDay: {}, TimeFrame.Begin: {}, TimeFrame.End: {}, now: {}" , isDay , sdf .format (timeFrame .begin ().getTime ()), sdf .format (timeFrame .end ().getTime ()), sdf .format (now .getTime ()));
250
- this .createTimeFrames (timeFrame , now ).stream ()
251
+ this .createTimeFrames (timeFrame , now , isDay ).stream ()
251
252
.forEachOrdered (timeFrame1 -> this .processTimeFrame (timeFrame1 , isDay ));
252
253
var logStmt = String .format ("Prepared Coinbase %s Data Time:" , isDay ? "Daily" : "Hourly" );
253
254
LOG .info (this .serviceUtils .createAvgLogStatement (startAll , logStmt ));
254
255
}
255
256
256
- private List <MyTimeFrame > createTimeFrames (final MyTimeFrame timeFrame , final Calendar now ) {
257
+ private List <MyTimeFrame > createTimeFrames (final MyTimeFrame timeFrame , final Calendar now , final boolean isDay ) {
257
258
final var timeFrames = new ArrayList <MyTimeFrame >();
258
259
var begin = timeFrame .begin ();
259
260
var end = timeFrame .end ();
260
261
while (end .before (now )) {
262
+ begin = isDay ? nextDay (begin ) : nextHour (begin );
263
+ end = isDay ? nextDay (end ) : nextHour (begin );
261
264
var myTimeFrame = new MyTimeFrame (begin , end );
262
265
timeFrames .add (myTimeFrame );
263
- begin = nextDay (begin );
264
- end = nextDay (end );
265
266
}
266
267
return timeFrames ;
267
268
}
268
269
270
+ private Calendar nextHour (Calendar begin ) {
271
+ var begin1 = GregorianCalendar .getInstance ();
272
+ begin1 .setTime (begin .getTime ());
273
+ begin1 .add (Calendar .HOUR , 1 );
274
+ begin = begin1 ;
275
+ return begin ;
276
+ }
277
+
269
278
private Calendar nextDay (Calendar begin ) {
270
279
var begin1 = GregorianCalendar .getInstance ();
271
280
begin1 .setTime (begin .getTime ());
0 commit comments