Skip to content

Commit f8ca797

Browse files
author
zengqiao
committed
删除无效的publish
1 parent ff78a9c commit f8ca797

File tree

1 file changed

+1
-5
lines changed
  • kafka-manager-extends/kafka-manager-bpm/src/main/java/com/xiaojukeji/kafka/manager/bpm/component

1 file changed

+1
-5
lines changed

kafka-manager-extends/kafka-manager-bpm/src/main/java/com/xiaojukeji/kafka/manager/bpm/component/LocalStorageService.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,6 @@
33
import com.xiaojukeji.kafka.manager.bpm.common.OrderStatusEnum;
44
import com.xiaojukeji.kafka.manager.common.entity.ResultStatus;
55
import com.xiaojukeji.kafka.manager.common.entity.pojo.OrderDO;
6-
import com.xiaojukeji.kafka.manager.common.events.OrderApplyEvent;
7-
import com.xiaojukeji.kafka.manager.common.utils.SpringTool;
86
import com.xiaojukeji.kafka.manager.common.utils.ValidateUtils;
97
import com.xiaojukeji.kafka.manager.dao.OrderDao;
108
import com.xiaojukeji.kafka.manager.service.utils.ConfigUtils;
@@ -36,8 +34,7 @@ public ResultStatus directSaveHandledOrder(OrderDO orderDO) {
3634
if (orderDao.directSaveHandledOrder(orderDO) <= 0) {
3735
return ResultStatus.MYSQL_ERROR;
3836
}
39-
// 无需进行通知
40-
// SpringTool.publish(new OrderApplyEvent(this, orderDO, configUtils.getIdc()));
37+
4138
return ResultStatus.SUCCESS;
4239
} catch (Exception e) {
4340
LOGGER.error("add order failed, orderDO:{}.", orderDO, e);
@@ -52,7 +49,6 @@ public boolean save(OrderDO orderDO) {
5249
return false;
5350
}
5451

55-
SpringTool.publish(new OrderApplyEvent(this, orderDO, configUtils.getIdc()));
5652
return true;
5753
} catch (Exception e) {
5854
LOGGER.error("add order failed, orderDO:{}.", orderDO, e);

0 commit comments

Comments
 (0)