调试

ms-biz/src/main/java/com/ms/api/common/TaskBaseService.java

@@ -40,7 +40,7 @@ public abstract class TaskBaseService implements TaskHandler {
             if(isPoolFull()){ return;}
             execute();
         }catch (Throwable e){
-            //e.printStackTrace();
+            e.printStackTrace();
             log.info("任务执行失败 : ",e.getMessage());
         }
     }
@@ -53,7 +53,7 @@ public abstract class TaskBaseService implements TaskHandler {
             execute();
             transactionManager.commit(status);
         }catch (Throwable e){
-            //e.printStackTrace();
+            e.printStackTrace();
             log.info("任务执行失败 : ",e.getMessage());
             transactionManager.rollback(status);
         }

ms-biz/src/main/java/com/ms/api/service/MaterialAuditStatusBufferService.java

@@ -30,5 +30,5 @@ public interface MaterialAuditStatusBufferService  {
 
     List<MaterialAuditStatusBuffer> selectTimeoutBuffer(int limit);
 
-    int deleteBatchByMaterialId(List<Integer> failMaterialIds);
+    int deleteBatchByMaterialId(List<String> failMaterialIds);
 }

ms-biz/src/main/java/com/ms/api/service/MaterialBizAuditStatusLogService.java

@@ -29,7 +29,7 @@ public interface MaterialBizAuditStatusLogService  {
 
     int updateMaterialBizAuditStatusLog(MaterialBizAuditStatusLog materialBizAuditStatusLog);
 
-    int updateBatchByMaterialIds(MaterialBizAuditStatusLog materialBizAuditStatusLog, List<Integer> failMaterialIds);
+    int updateBatchByMaterialIds(MaterialBizAuditStatusLog materialBizAuditStatusLog, List<String> failMaterialIds);
 
     List<MaterialBizAuditStatusLog> getMaterialBizAuditStatusLogByMaterialIds(List<String> materialIds);
 

ms-biz/src/main/java/com/ms/api/service/impl/MaterialAuditStatusBufferServiceImpl.java

@@ -70,7 +70,7 @@ public class MaterialAuditStatusBufferServiceImpl implements MaterialAuditStatus
     }
 
     @Override
-    public int deleteBatchByMaterialId(List<Integer> failMaterialIds) {
+    public int deleteBatchByMaterialId(List<String> failMaterialIds) {
         return materialAuditStatusBufferMapper.deleteBatchByMaterialId(failMaterialIds);
     }
 

ms-biz/src/main/java/com/ms/api/service/impl/MaterialBizAuditStatusLogServiceImpl.java

@@ -74,7 +74,7 @@ public class MaterialBizAuditStatusLogServiceImpl implements MaterialBizAuditSta
     }
 
     @Override
-    public int updateBatchByMaterialIds(MaterialBizAuditStatusLog materialBizAuditStatusLog, List<Integer> failMaterialIds) {
+    public int updateBatchByMaterialIds(MaterialBizAuditStatusLog materialBizAuditStatusLog, List<String> failMaterialIds) {
         return materialBizAuditStatusLogMapper.updateBatchByMaterialIds(materialBizAuditStatusLog, failMaterialIds);
     }
 

ms-biz/src/main/java/com/ms/api/task/CheckAuditStatusTimeoutTaskService.java

@@ -19,6 +19,7 @@ import java.util.Arrays;
 import java.util.Date;
 import java.util.List;
 import java.util.concurrent.Executor;
+import java.util.stream.Collectors;
 
 /**
  * 检查素材的buffer是否有过期或者重试超过20次的
@@ -82,7 +83,7 @@ public class CheckAuditStatusTimeoutTaskService extends TaskBaseService {
                 break;
             }
 
-            List<Integer> failMaterialIds = Arrays.asList(timeOutBuffers.stream().map(MaterialAuditStatusBuffer::getMaterialId).toArray(Integer[]::new));
+            List<String> failMaterialIds = timeOutBuffers.stream().map(MaterialAuditStatusBuffer::getMaterialId).collect(Collectors.toList());
             try {
                 MaterialBizAuditStatusLog materialBizAuditStatusLog = new MaterialBizAuditStatusLog();
                 materialBizAuditStatusLog.setStatus(StatusConst.fail);

ms-biz/src/main/java/com/ms/api/task/MoveMaterialAuditProcessTaskService.java

@@ -243,7 +243,7 @@ public class MoveMaterialAuditProcessTaskService extends TaskBaseService {
         String materialId = queueMsg.getMaterialId();
         long shopId = queueMsg.getShopId();
         MaterialBizAuditStatusLog mLog = materialBizAuditStatusLogService.getShopMaterialBizAuditStatusLog(shopId, (new StrObjMap() {{
-            put("material_id", materialId);
+            put("materialId", materialId);
         }}));
         if (!mLog.getStatus().equals(StatusConst.wait)) {
             return;

ms-dal/src/main/java/com/ms/dal/mapper/MaterialAuditStatusBufferMapper.java

@@ -32,5 +32,5 @@ public interface MaterialAuditStatusBufferMapper {
 
     List<MaterialAuditStatusBuffer> selectTimeoutBuffer(int limit);
 
-    int deleteBatchByMaterialId(List<Integer> failMaterialIds);
+    int deleteBatchByMaterialId(List<String> failMaterialIds);
 }

ms-dal/src/main/java/com/ms/dal/mapper/MaterialBizAuditStatusLogMapper.java

@@ -30,7 +30,7 @@ public interface MaterialBizAuditStatusLogMapper {
 
     int updateByPrimaryKeySelectiveByMaterialId(MaterialBizAuditStatusLog materialBizAuditStatusLog);
 
-    int updateBatchByMaterialIds(MaterialBizAuditStatusLog materialBizAuditStatusLog, List<Integer> failMaterialIds);
+    int updateBatchByMaterialIds(MaterialBizAuditStatusLog materialBizAuditStatusLog, List<String> failMaterialIds);
 
     List<MaterialBizAuditStatusLog> getMaterialBizAuditStatusLogByMaterialIds(List<String> materialIds);