Compare commits
2 Commits
7f12421a86
...
d8f0f3e5c0
| Author | SHA1 | Date | |
|---|---|---|---|
| d8f0f3e5c0 | |||
| db2101087b |
@@ -1,6 +1,7 @@
|
|||||||
package com.jeelowcode.module.biz.job;
|
package com.jeelowcode.module.biz.job;
|
||||||
|
|
||||||
import cn.hutool.core.date.LocalDateTimeUtil;
|
import cn.hutool.core.date.LocalDateTimeUtil;
|
||||||
|
import cn.hutool.db.sql.SqlUtil;
|
||||||
import com.baomidou.dynamic.datasource.DynamicRoutingDataSource;
|
import com.baomidou.dynamic.datasource.DynamicRoutingDataSource;
|
||||||
import com.jeelowcode.module.biz.entity.AlibabaWorkOrder;
|
import com.jeelowcode.module.biz.entity.AlibabaWorkOrder;
|
||||||
import com.jeelowcode.module.biz.service.IAlibabaWorkOrderService;
|
import com.jeelowcode.module.biz.service.IAlibabaWorkOrderService;
|
||||||
@@ -62,6 +63,7 @@ public class AlibabaWorkOrderJob implements JobHandler {
|
|||||||
DataSource dataSource = dataSources.get(ALIBABA_DATASOURCE_NAME);
|
DataSource dataSource = dataSources.get(ALIBABA_DATASOURCE_NAME);
|
||||||
try (Connection connection = dataSource.getConnection();
|
try (Connection connection = dataSource.getConnection();
|
||||||
ResultSet resultSet = connection.createStatement().executeQuery(sqlBuilder.toString())) {
|
ResultSet resultSet = connection.createStatement().executeQuery(sqlBuilder.toString())) {
|
||||||
|
log.error(sqlBuilder.toString());
|
||||||
// 使用连接执行SQL并得到结果
|
// 使用连接执行SQL并得到结果
|
||||||
List<AlibabaWorkOrder> workOrderList = new ArrayList<>();
|
List<AlibabaWorkOrder> workOrderList = new ArrayList<>();
|
||||||
// 将resultSet解析成List<AlibabaWorkOrder> list
|
// 将resultSet解析成List<AlibabaWorkOrder> list
|
||||||
@@ -94,8 +96,8 @@ public class AlibabaWorkOrderJob implements JobHandler {
|
|||||||
|
|
||||||
// 解析得到的数据由服务存储到数据库
|
// 解析得到的数据由服务存储到数据库
|
||||||
int num = workOrderService.batchSaveWorkOrder(workOrderList);
|
int num = workOrderService.batchSaveWorkOrder(workOrderList);
|
||||||
log.info("同步阿里工单完成,共处理{}条数据", workOrderList.size());
|
log.error("同步阿里工单完成,共处理{}条数据", workOrderList.size());
|
||||||
log.info("同步阿里工单完成,共成功{}条数据", num);
|
log.error("同步阿里工单完成,共成功{}条数据", num);
|
||||||
return "同步阿里工单完成,共处理" + num + "条数据";
|
return "同步阿里工单完成,共处理" + num + "条数据";
|
||||||
} catch (SQLException e) {
|
} catch (SQLException e) {
|
||||||
log.error("执行SQL查询或解析ResultSet异常", e);
|
log.error("执行SQL查询或解析ResultSet异常", e);
|
||||||
@@ -508,7 +510,8 @@ public class AlibabaWorkOrderJob implements JobHandler {
|
|||||||
" ) " +
|
" ) " +
|
||||||
" )");
|
" )");
|
||||||
}
|
}
|
||||||
return sqlBuilder.toString();
|
|
||||||
|
return SqlUtil.formatSql(sqlBuilder.toString());
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user