.

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("取消失败");
     }
 }

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);

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);

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) {
+        // 2020-10-10 创建的任务不能立马就发出，要事务完成后发出，避免事务回滚
-            send(model);
+//        if (ret) {
-        }
+//            send(model);
+//        }
 
         return ret; // 有插入的，还是需要返回插入状态