批量操作失败告警

 package com.yohoufo.order.service.impl.processor;
 
+import com.yohoufo.common.alarm.CommonAlarmEventPublisher;
 import com.yohoufo.common.utils.DateUtil;
 import com.yohoufo.dal.order.SellerTaskMapper;
 import com.yohoufo.dal.order.model.SellerTask;
@@ -48,6 +49,12 @@ public class SellerTaskProcessor {
 
     private SellerTaskResult doProcess(SellerTaskDTO sbpDto) {
         ISellerTaskHandler handler = sbpDto.getTaskHandler();
-        return handler.handle(sbpDto);
+        SellerTaskResult taskResult =  handler.handle(sbpDto);
+        if (taskResult == null || taskResult.failCnt > 0) {
+            //任务失败或者有部分失败
+            CommonAlarmEventPublisher.publish("seller batch operation fail", "ufo.seller.batchTask",
+                    "uid=" + sbpDto.getUid() + ",taskId=" + sbpDto.getTaskId() + ",taskType=" + sbpDto.getTaskType());
+        }
+        return taskResult;
     }
 }