同步数据删除机具和金额记录

kxs-transfer/src/main/java/com/kxs/transfer/api/service/user/impl/KxsPartnerServiceImpl.java

@@ -138,6 +138,10 @@ public class KxsPartnerServiceImpl extends ServiceImpl<KxsPartnerMapper, KxsPart
 
         //操作类型
         OperationType operation = dmlData.getOperation();
+        if(operation.equals(OperationType.DELETE)){
+            baseMapper.deleteById(id);
+            return;
+        }
         for (String field : changeFieldList) {
 
             switch (field) {

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

@@ -81,7 +81,7 @@ public class taskJob {
     @Scheduled(fixedDelay = 1000 * 60 * 5)
 //    @Scheduled(fixedDelay = 1000 * 5)
     public void tradeRepeatEntry(){
-        List<KxsDtsErrorLog> list = kxsDtsErrorLogService.list(Wrappers.<KxsDtsErrorLog>lambdaQuery().eq(KxsDtsErrorLog::getOperation, OperationType.INSERT).last("limit 100"));
+        List<KxsDtsErrorLog> list = kxsDtsErrorLogService.list(Wrappers.<KxsDtsErrorLog>lambdaQuery().in(KxsDtsErrorLog::getOperation, OperationType.INSERT, OperationType.DELETE).last("limit 100"));
 
         for (KxsDtsErrorLog kxsDtsErrorLog : list) {
             try {
@@ -109,7 +109,10 @@ public class taskJob {
                     //删除本条记录
                     kxsDtsErrorLogService.removeById(kxsDtsErrorLog.getId());
                 }
-
+                //合伙人账户余额变动记录表
+                if ("AmountRecordNew".equals(kxsDtsErrorLog.getTableName()) ) {
+                    kxsPartnerService.changeAccountLogData(JSON.parseObject(kxsDtsErrorLog.getContent(), DMLData.class));
+                }