diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/order/ordertemp/OrderTempSyncService.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/order/ordertemp/OrderTempSyncService.java index 3dca7ab..1568eca 100644 --- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/order/ordertemp/OrderTempSyncService.java +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/order/ordertemp/OrderTempSyncService.java @@ -171,12 +171,6 @@ public class OrderTempSyncService { } }); - // 数据库修改成功后,再将数据下发 - if (ret) { - SyncTaskService.me.send(synctask); - SyncTaskService.me.send(synctaskincrement); - } - return ret ? Result.success(order) : Result.failed("取消失败"); } } diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/prepaydetail/PrepayDetailSyncService.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/prepaydetail/PrepayDetailSyncService.java index 6a04b45..e966bd4 100644 --- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/prepaydetail/PrepayDetailSyncService.java +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/prepaydetail/PrepayDetailSyncService.java @@ -195,11 +195,6 @@ public class PrepayDetailSyncService extends BaseSyncService { } }); - // 数据库修改成功后,再将数据下发 - if (ret) { - SyncTaskService.me.send(synctask); - } - return ret ? Result.success(true) : Result.failed(false, "更新失败"); } catch (Exception e) { log.error(e.getMessage(), e); diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/refunddetail/RefundDetailSyncService.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/refunddetail/RefundDetailSyncService.java index fd5a8af..e74cde1 100644 --- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/refunddetail/RefundDetailSyncService.java +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/refunddetail/RefundDetailSyncService.java @@ -290,11 +290,6 @@ public class RefundDetailSyncService extends BaseSyncService { } }); - // 数据库修改成功后,再将数据下发 - if (ret) { - SyncTaskService.me.send(synctask); - } - return ret ? Result.object(model) : Result.failed(false, "更新失败"); } catch (Exception e) { log.error(e.getMessage(), e); diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/synctask/SyncTaskService.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/synctask/SyncTaskService.java index 048d1ed..a0e3fca 100644 --- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/synctask/SyncTaskService.java +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/synctask/SyncTaskService.java @@ -126,9 +126,10 @@ public class SyncTaskService { boolean ret = model.save(); - if (ret) { - send(model); - } + // 2020-10-10 创建的任务不能立马就发出,要事务完成后发出,避免事务回滚 +// if (ret) { +// send(model); +// } return ret; // 有插入的,还是需要返回插入状态