|
|
@@ -36,7 +36,10 @@ import java.math.RoundingMode;
|
|
|
import java.nio.file.Files;
|
|
|
import java.nio.file.Path;
|
|
|
import java.nio.file.Paths;
|
|
|
+import java.text.SimpleDateFormat;
|
|
|
import java.time.LocalDateTime;
|
|
|
+import java.time.format.DateTimeFormatter;
|
|
|
+import java.util.Date;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.List;
|
|
|
import java.util.stream.Collectors;
|
|
|
@@ -57,7 +60,7 @@ public class InsExcelTaskAsyncServiceImpl extends ServiceImpl<InsExcelTaskAsyncM
|
|
|
|
|
|
@Async
|
|
|
@Override
|
|
|
- public void importasync(List<OrdersDataExcel> resultSubOrder, HashMap<String, String> dateMapByType) {
|
|
|
+ public void importasync(List<OrdersDataExcel> resultSubOrder, HashMap<String, String> dateMapByType,String beginDate,String endDate) {
|
|
|
InsExcelTaskEntity insExcelTaskEntity = new InsExcelTaskEntity();
|
|
|
String taskId = String.valueOf(new SnowFlakeUtil().nextId());
|
|
|
insExcelTaskEntity.setId(taskId);
|
|
|
@@ -66,6 +69,15 @@ public class InsExcelTaskAsyncServiceImpl extends ServiceImpl<InsExcelTaskAsyncM
|
|
|
insExcelTaskEntity.setCreateTime(LocalDateTime.now());
|
|
|
insExcelTaskEntity.setCreatedAt(LocalDateTime.now());
|
|
|
insExcelTaskEntity.setType("1");
|
|
|
+ // 定义时间格式的常量
|
|
|
+ DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
|
|
+ // 构建开始时间
|
|
|
+ LocalDateTime startTime = LocalDateTime.parse(beginDate + " 00:00:00", formatter);
|
|
|
+ insExcelTaskEntity.setStartTime(startTime);
|
|
|
+ // 构建结束时间
|
|
|
+ LocalDateTime endTime = LocalDateTime.parse(endDate + " " + LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm:ss")), formatter);
|
|
|
+ insExcelTaskEntity.setEndTime(endTime);
|
|
|
+
|
|
|
baseMapper.insert(insExcelTaskEntity);
|
|
|
|
|
|
if (!resultSubOrder.isEmpty()) {
|
|
|
@@ -107,7 +119,8 @@ public class InsExcelTaskAsyncServiceImpl extends ServiceImpl<InsExcelTaskAsyncM
|
|
|
|
|
|
@Override
|
|
|
@Async
|
|
|
- public void importasyncBigOrder(List<BigOrderUploadDto> list,String userId) {
|
|
|
+ public void importasyncBigOrder(List<BigOrderUploadDto> list,String userId,String beginDate,String endDate) {
|
|
|
+
|
|
|
InsExcelTaskEntity insExcelTaskEntity = new InsExcelTaskEntity();
|
|
|
String taskId = String.valueOf(new SnowFlakeUtil().nextId());
|
|
|
insExcelTaskEntity.setId(taskId);
|
|
|
@@ -115,6 +128,15 @@ public class InsExcelTaskAsyncServiceImpl extends ServiceImpl<InsExcelTaskAsyncM
|
|
|
insExcelTaskEntity.setUserId(userId);
|
|
|
insExcelTaskEntity.setCreateTime(LocalDateTime.now());
|
|
|
insExcelTaskEntity.setCreatedAt(LocalDateTime.now());
|
|
|
+ // 定义时间格式的常量
|
|
|
+ DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
|
|
+ // 构建开始时间
|
|
|
+ LocalDateTime startTime = LocalDateTime.parse(beginDate + " 00:00:00", formatter);
|
|
|
+ insExcelTaskEntity.setStartTime(startTime);
|
|
|
+ // 构建结束时间
|
|
|
+ LocalDateTime endTime = LocalDateTime.parse(endDate + " " + LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm:ss")), formatter);
|
|
|
+ insExcelTaskEntity.setEndTime(endTime);
|
|
|
+
|
|
|
insExcelTaskEntity.setType("0");
|
|
|
baseMapper.insert(insExcelTaskEntity);
|
|
|
|
|
|
@@ -150,6 +172,11 @@ public class InsExcelTaskAsyncServiceImpl extends ServiceImpl<InsExcelTaskAsyncM
|
|
|
baseMapper.updateById(insExcelTaskEntity1);
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ *
|
|
|
+ * @param insExcelTaskDto
|
|
|
+ * @return 控制台导出任务分页
|
|
|
+ */
|
|
|
@Override
|
|
|
public BasePageResult<InsExcelTaskEntity> queryPage(InsExcelTaskDto insExcelTaskDto) {
|
|
|
Page<InsExcelTaskEntity> page = new Page<>(insExcelTaskDto.getPageNum(), insExcelTaskDto.getPageSize());
|