Merge branch 'test-transfer' into develop

* test-transfer:
  未处理的不删除错误记录，同步数据

kxs-transfer/src/main/java/com/kxs/transfer/api/task/taskJob.java

@@ -86,14 +86,20 @@ public class taskJob {
                 //仓库担保记录
                 if ("StoreHouseAmountPromiss".equals(kxsDtsErrorLog.getTableName())) {
                     kxsWarehouseService.changeCreditData(JSON.parseObject(kxsDtsErrorLog.getContent(), DMLData.class));
+                    //删除本条记录
+                    kxsDtsErrorLogService.removeById(kxsDtsErrorLog.getId());
                 }
                 //商品订单同步
                 if ("Orders".equals(kxsDtsErrorLog.getTableName())) {
                     kxsShopOrderService.changeData(JSON.parseObject(kxsDtsErrorLog.getContent(), DMLData.class));
+                    //删除本条记录
+                    kxsDtsErrorLogService.removeById(kxsDtsErrorLog.getId());
                 }
                 //商品订单详情
                 if ("OrderProduct".equals(kxsDtsErrorLog.getTableName())) {
                     kxsShopOrderService.changeInfoData(JSON.parseObject(kxsDtsErrorLog.getContent(), DMLData.class));
+                    //删除本条记录
+                    kxsDtsErrorLogService.removeById(kxsDtsErrorLog.getId());
                 }
 
 
@@ -103,8 +109,7 @@ public class taskJob {
 
 
 
-                //删除本条记录
-                kxsDtsErrorLogService.removeById(kxsDtsErrorLog.getId());
+
             } catch (Exception e) {
                 log.error("重复消费新增数据的队列消费失败",e);
             }