CRM退款匹配调整

data-base/base-sync-crm-refund/src/main/java/com/bailuntec/Application.java

@@ -4,6 +4,7 @@ import com.alibaba.druid.pool.DruidDataSource;
 import com.bailuntec.job.CrmRefundSyncJob;
 import com.bailuntec.job.RefundLinkOrderJob;
 import com.bailuntec.listener.CrmRefundSyncJobListener;
+import com.bailuntec.listener.RefundLinkJobListener;
 import com.bailuntec.utils.PropertiesUtil;
 import com.dangdang.ddframe.job.config.JobCoreConfiguration;
 import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
@@ -27,7 +28,7 @@ public class Application {
     private static final String EVENT_RDB_STORAGE_PASSWORD = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_PASSWORD");
     public static void main(String[] args) {
         new JobScheduler(createRegistryCenter(), createJobConfiguration(),createJobEventConfiguration(), new CrmRefundSyncJobListener()).init();
-        new JobScheduler(createRegistryCenter(), createJobConfiguration1()).init();
+        new JobScheduler(createRegistryCenter(), createJobConfiguration1(),createJobEventConfiguration(), new RefundLinkJobListener()).init();
     }
 
     private static CoordinatorRegistryCenter createRegistryCenter() {

data-base/base-sync-crm-refund/src/main/java/com/bailuntec/job/RefundLinkOrderJob.java

@@ -88,11 +88,8 @@ public class RefundLinkOrderJob extends PointJob {
                             }
                         }
                     }
-                    SessionUtil.getSession().commit();
                 } catch (Exception e) {
-                    e.printStackTrace();
-                    SessionUtil.getSession().rollback();
-                    throw new RuntimeException("Mybatis操作DB失败");
+                    throw new RuntimeException("Mybatis操作DB失败", e);
                 } finally {
                     SessionUtil.closeSession();
                 }

data-base/base-sync-crm-refund/src/main/java/com/bailuntec/listener/RefundLinkJobListener.java

+package com.bailuntec.listener;
+
+import com.dangdang.ddframe.job.executor.ShardingContexts;
+import com.dangdang.ddframe.job.lite.api.listener.ElasticJobListener;
+
+public class RefundLinkJobListener implements ElasticJobListener {
+    @Override
+    public void beforeJobExecuted(ShardingContexts shardingContexts) {
+
+    }
+
+    @Override
+    public void afterJobExecuted(ShardingContexts shardingContexts) {
+
+    }
+}