diff --git a/ebike-orders/src/main/java/com/cdzy/orders/service/impl/UserOrdersServiceImpl.java b/ebike-orders/src/main/java/com/cdzy/orders/service/impl/UserOrdersServiceImpl.java index 67805070..c3cfa53b 100644 --- a/ebike-orders/src/main/java/com/cdzy/orders/service/impl/UserOrdersServiceImpl.java +++ b/ebike-orders/src/main/java/com/cdzy/orders/service/impl/UserOrdersServiceImpl.java @@ -2,7 +2,6 @@ package com.cdzy.orders.service.impl; import com.alibaba.fastjson2.JSONObject; import com.cdzy.common.enums.Code; -import com.cdzy.common.model.CoreResult; import com.cdzy.common.model.JsonResult; import com.cdzy.common.model.ResGPSDto; import com.cdzy.orders.component.EbikeCoreHandler; @@ -10,10 +9,13 @@ import com.cdzy.orders.enums.CmdCode; import com.cdzy.orders.enums.EbikeRegionInOperation; import com.cdzy.orders.enums.OrderStatus; import com.cdzy.orders.enums.OrderType; +import com.cdzy.orders.mapper.UserOrdersMapper; import com.cdzy.orders.model.dto.req.ReqBikeDto; import com.cdzy.orders.model.dto.req.ReqOrderDto; import com.cdzy.orders.model.dto.res.RedisPoint; import com.cdzy.orders.model.dto.res.RspBikeDto; +import com.cdzy.orders.model.entity.UserOrders; +import com.cdzy.orders.service.UserOrdersService; import com.cdzy.orders.uitls.RedisUtil; import com.cdzy.orders.uitls.TimeUtils; import com.ebike.feign.clients.MaintenanceFeignClient; @@ -24,9 +26,6 @@ import com.ebike.feign.model.rsp.FeignEbikeEcuInfo; import com.ebike.feign.model.rsp.FeignEbikeRegionDto; import com.mybatisflex.core.query.QueryWrapper; import com.mybatisflex.spring.service.impl.ServiceImpl; -import com.cdzy.orders.model.entity.UserOrders; -import com.cdzy.orders.mapper.UserOrdersMapper; -import com.cdzy.orders.service.UserOrdersService; import jakarta.annotation.Resource; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -121,6 +120,7 @@ public class UserOrdersServiceImpl extends ServiceImpl jsonResult = maintenanceFeignClient.getEbikeInfoByCode(orderDto.getBikeCode()); @@ -150,7 +150,13 @@ public class UserOrdersServiceImpl extends ServiceImpl stringCompletableFuture = ebikeCoreHandler.executeCommand(ecuInfo, CmdCode.LOCK, Long.valueOf(bikeInfoDto.getBikeId()), userId); + String response = stringCompletableFuture.join(); + JSONObject jsonObject = JSONObject.parseObject(response); + if (jsonObject.getInteger("code") != 0) { + throw new RuntimeException("关锁失败"); + } return userOrders.getOrderId(); }