ufo / yohoufo-fore · Commits

Go to a project

Authored by mali
Commit 7a0121a3882499171f15b8a20d7f8cb2d2aaf39f 1 parent 5a56da65

删除测试代码

Inline Side-by-side
Showing 2 changed files with 2 additions and 10 deletions
... ... @@ -24,7 +24,7 @@ public class UfoInfluxdbEventHandler implements IEventHandler<UfoInfluxdbEvent>
@Override
@Subscribe
public void handle(UfoInfluxdbEvent event) {
logger.info("method UfoInfluxdbEventHandler onApplicationEvent, event", event);
logger.info("method UfoInfluxdbEventHandler onApplicationEvent, event is {}", event);
if (Objects.isNull(event) || Objects.isNull(event.getUfoInfluxdbVo())) {
return;
... ... @@ -36,7 +36,7 @@ public class UfoInfluxdbEventHandler implements IEventHandler<UfoInfluxdbEvent>
eventReporter.report(database, ufoInfluxdbVo.getMeasurement(), ufoInfluxdbVo.getTags(), ufoInfluxdbVo.getFields());
logger.info("method UfoInfluxdbEventHandler onApplicationEvent end, event", event);
logger.info("method UfoInfluxdbEventHandler onApplicationEvent end, event is {}", event);
}
private void complete(UfoInfluxdbVo ufoInfluxdbVo) {
... ...
... ... @@ -5,13 +5,8 @@ import com.yohobuy.ufo.model.order.common.TabType;
import com.yohobuy.ufo.model.order.req.*;
import com.yohobuy.ufo.model.order.resp.*;
import com.yohoufo.common.ApiResponse;
import com.yohoufo.common.alarm.EventBusPublisher;
import com.yohoufo.common.alarm.UfoInfluxdbEvent;
import com.yohoufo.common.alarm.UfoInfluxdbVo;
import com.yohoufo.common.annotation.IgnoreSession;
import com.yohoufo.common.annotation.IgnoreSignature;
import com.yohoufo.common.constant.InfluxdbFieldEnum;
import com.yohoufo.common.constant.InfluxdbMeasurementEnum;
import com.yohoufo.common.exception.GatewayException;
import com.yohoufo.dal.order.model.SellerOrder;
import com.yohoufo.order.model.request.OrderListRequest;
... ... @@ -96,9 +91,6 @@ public class SellerOrderController {
@RequestParam(name="address_id")String address_id,
@RequestParam(name="num", defaultValue = "1", required = false)int num,
@RequestParam(name="skupType", defaultValue = DEFAULT_SKUP_TYPE, required = false) Integer skupType) throws GatewayException {
EventBusPublisher.publishEvent(new UfoInfluxdbEvent(new UfoInfluxdbVo.Builder().setMeasurement(InfluxdbMeasurementEnum.MEASUREMENT_ORDER_CANCEL)
.addInitField(InfluxdbFieldEnum.FIELD_COUNT).build())); // 统计取消订单的次数
SellerOrderSubmitReq req = SellerOrderSubmitReq.builder()
.uid(uid)
.storageId(storage_id)
... ...