This commit is contained in:
parent
532093f872
commit
e3c6a17a8f
1 changed files with 2 additions and 2 deletions
|
|
@ -4,7 +4,7 @@ import java.io.IOException;
|
|||
import java.nio.charset.StandardCharsets;
|
||||
import java.nio.file.Files;
|
||||
import java.nio.file.Path;
|
||||
import java.time.LocalTime;
|
||||
import java.time.LocalDateTime;
|
||||
import java.time.format.DateTimeFormatter;
|
||||
import java.util.Collection;
|
||||
import java.util.Optional;
|
||||
|
|
@ -119,7 +119,7 @@ public class TaskListener extends QueueConsumer implements InitializingBean {
|
|||
Collection<OrderCurrency> orders = imdgQueryService.getClccOrderCurrencyIds();
|
||||
String content = orderCurrencyTriExportService.exportToTri(orders);
|
||||
Path fileName = storagePath.resolve(String.format("KS_TS_ORDERS_%s.tri",
|
||||
LocalTime.now().format(formatter)));
|
||||
LocalDateTime.now().format(formatter)));
|
||||
Files.writeString(fileName, content, StandardCharsets.UTF_8);
|
||||
kafkaSender.sendRequestToQueue(Consts.SDOR_FIX_TASK, req.getRequestPayload());
|
||||
} catch (IOException e) {
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue