diff --git a/kafka-manager-extends/kafka-manager-bpm/src/main/java/com/xiaojukeji/kafka/manager/bpm/component/LocalStorageService.java b/kafka-manager-extends/kafka-manager-bpm/src/main/java/com/xiaojukeji/kafka/manager/bpm/component/LocalStorageService.java index 4b010dc9798461dd9f2e211dd103e771f70ea664..87176596efe7fde1f150b5f702224d3550ea57be 100644 --- a/kafka-manager-extends/kafka-manager-bpm/src/main/java/com/xiaojukeji/kafka/manager/bpm/component/LocalStorageService.java +++ b/kafka-manager-extends/kafka-manager-bpm/src/main/java/com/xiaojukeji/kafka/manager/bpm/component/LocalStorageService.java @@ -3,8 +3,6 @@ package com.xiaojukeji.kafka.manager.bpm.component; import com.xiaojukeji.kafka.manager.bpm.common.OrderStatusEnum; import com.xiaojukeji.kafka.manager.common.entity.ResultStatus; import com.xiaojukeji.kafka.manager.common.entity.pojo.OrderDO; -import com.xiaojukeji.kafka.manager.common.events.OrderApplyEvent; -import com.xiaojukeji.kafka.manager.common.utils.SpringTool; import com.xiaojukeji.kafka.manager.common.utils.ValidateUtils; import com.xiaojukeji.kafka.manager.dao.OrderDao; import com.xiaojukeji.kafka.manager.service.utils.ConfigUtils; @@ -36,8 +34,7 @@ public class LocalStorageService extends AbstractOrderStorageService { if (orderDao.directSaveHandledOrder(orderDO) <= 0) { return ResultStatus.MYSQL_ERROR; } -// 无需进行通知 -// SpringTool.publish(new OrderApplyEvent(this, orderDO, configUtils.getIdc())); + return ResultStatus.SUCCESS; } catch (Exception e) { LOGGER.error("add order failed, orderDO:{}.", orderDO, e); @@ -52,7 +49,6 @@ public class LocalStorageService extends AbstractOrderStorageService { return false; } - SpringTool.publish(new OrderApplyEvent(this, orderDO, configUtils.getIdc())); return true; } catch (Exception e) { LOGGER.error("add order failed, orderDO:{}.", orderDO, e);