mirror of
https://github.com/didi/KnowStreaming.git
synced 2025-12-24 11:52:08 +08:00
Compare commits
1 Commits
v3.0.0-bet
...
v2.0.0
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f8ca797f16 |
@@ -3,8 +3,6 @@ package com.xiaojukeji.kafka.manager.bpm.component;
|
|||||||
import com.xiaojukeji.kafka.manager.bpm.common.OrderStatusEnum;
|
import com.xiaojukeji.kafka.manager.bpm.common.OrderStatusEnum;
|
||||||
import com.xiaojukeji.kafka.manager.common.entity.ResultStatus;
|
import com.xiaojukeji.kafka.manager.common.entity.ResultStatus;
|
||||||
import com.xiaojukeji.kafka.manager.common.entity.pojo.OrderDO;
|
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.common.utils.ValidateUtils;
|
||||||
import com.xiaojukeji.kafka.manager.dao.OrderDao;
|
import com.xiaojukeji.kafka.manager.dao.OrderDao;
|
||||||
import com.xiaojukeji.kafka.manager.service.utils.ConfigUtils;
|
import com.xiaojukeji.kafka.manager.service.utils.ConfigUtils;
|
||||||
@@ -36,8 +34,7 @@ public class LocalStorageService extends AbstractOrderStorageService {
|
|||||||
if (orderDao.directSaveHandledOrder(orderDO) <= 0) {
|
if (orderDao.directSaveHandledOrder(orderDO) <= 0) {
|
||||||
return ResultStatus.MYSQL_ERROR;
|
return ResultStatus.MYSQL_ERROR;
|
||||||
}
|
}
|
||||||
// 无需进行通知
|
|
||||||
// SpringTool.publish(new OrderApplyEvent(this, orderDO, configUtils.getIdc()));
|
|
||||||
return ResultStatus.SUCCESS;
|
return ResultStatus.SUCCESS;
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
LOGGER.error("add order failed, orderDO:{}.", orderDO, e);
|
LOGGER.error("add order failed, orderDO:{}.", orderDO, e);
|
||||||
@@ -52,7 +49,6 @@ public class LocalStorageService extends AbstractOrderStorageService {
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
SpringTool.publish(new OrderApplyEvent(this, orderDO, configUtils.getIdc()));
|
|
||||||
return true;
|
return true;
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
LOGGER.error("add order failed, orderDO:{}.", orderDO, e);
|
LOGGER.error("add order failed, orderDO:{}.", orderDO, e);
|
||||||
|
|||||||
Reference in New Issue
Block a user