移除部分事务
Showing
3 changed files
with
0 additions
and
5 deletions
| ... | @@ -23,7 +23,6 @@ public class AutoBindAppProcessor { | ... | @@ -23,7 +23,6 @@ public class AutoBindAppProcessor { |
| 23 | @Value("${entity.appId}") | 23 | @Value("${entity.appId}") |
| 24 | private Long APP_ID; | 24 | private Long APP_ID; |
| 25 | 25 | ||
| 26 | @Transactional(rollbackFor = Exception.class) | ||
| 27 | public void execute() { | 26 | public void execute() { |
| 28 | Connection connection = null; | 27 | Connection connection = null; |
| 29 | try { | 28 | try { | ... | ... |
| ... | @@ -23,7 +23,6 @@ public class AutoBindServiceProcessor { | ... | @@ -23,7 +23,6 @@ public class AutoBindServiceProcessor { |
| 23 | @Value("${entity.serviceId}") | 23 | @Value("${entity.serviceId}") |
| 24 | private Long SERVICE_ID; | 24 | private Long SERVICE_ID; |
| 25 | 25 | ||
| 26 | @Transactional(rollbackFor = Exception.class) | ||
| 27 | public void execute() { | 26 | public void execute() { |
| 28 | Connection connection = null; | 27 | Connection connection = null; |
| 29 | try { | 28 | try { | ... | ... |
| ... | @@ -21,7 +21,6 @@ public class AutoOnlineProcessor { | ... | @@ -21,7 +21,6 @@ public class AutoOnlineProcessor { |
| 21 | @Value("${entity.difference}") | 21 | @Value("${entity.difference}") |
| 22 | private Long DIFFERENCE; | 22 | private Long DIFFERENCE; |
| 23 | 23 | ||
| 24 | @Transactional(rollbackFor = Exception.class) | ||
| 25 | public void execute() { | 24 | public void execute() { |
| 26 | Connection connection = null; | 25 | Connection connection = null; |
| 27 | String today = DateUtil.today(); | 26 | String today = DateUtil.today(); |
| ... | @@ -34,8 +33,6 @@ public class AutoOnlineProcessor { | ... | @@ -34,8 +33,6 @@ public class AutoOnlineProcessor { |
| 34 | "where xm.`status` = '000' and xm.file_status = '001' and xm.create_time >= ? and xcsc.id is null " + | 33 | "where xm.`status` = '000' and xm.file_status = '001' and xm.create_time >= ? and xcsc.id is null " + |
| 35 | ") as a ) ", DateUtil.now()); | 34 | ") as a ) ", DateUtil.now()); |
| 36 | dbUtil.doExecute(connection, sql, today); | 35 | dbUtil.doExecute(connection, sql, today); |
| 37 | // 提交事务 | ||
| 38 | dbUtil.commitTransaction(connection); | ||
| 39 | 36 | ||
| 40 | } catch (Exception ex) { | 37 | } catch (Exception ex) { |
| 41 | ex.printStackTrace(); | 38 | ex.printStackTrace(); | ... | ... |
-
Please register or sign in to post a comment