|
|
|
@ -58,10 +58,12 @@ public class StationTask implements ITask { |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public void run(String params) { |
|
|
|
log.info("StationTask run params: {}", params); |
|
|
|
getDayList(params).forEach(timePair -> { |
|
|
|
handleSequence(timePair); |
|
|
|
handleAgg(timePair); |
|
|
|
}); |
|
|
|
log.info("StationTask run end"); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
|