diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/mapper/XhpcInternetUserMapper.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/mapper/XhpcInternetUserMapper.java new file mode 100644 index 00000000..e0c52d32 --- /dev/null +++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/mapper/XhpcInternetUserMapper.java @@ -0,0 +1,13 @@ +package com.xhpc.order.mapper; + +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +/** + * @Author HongYun on 2021/11/4 + */ +@Mapper +public interface XhpcInternetUserMapper { + + int selectByOperatorIdEvcs(@Param("operatorIdEvcs") String operatorIdEvcs); +} diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcChargeOrderServiceImpl.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcChargeOrderServiceImpl.java index 204f5538..f15e2391 100644 --- a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcChargeOrderServiceImpl.java +++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcChargeOrderServiceImpl.java @@ -12,6 +12,7 @@ import com.xhpc.common.redis.service.RedisService; import com.xhpc.order.domain.XhpcChargeOrder; import com.xhpc.order.domain.XhpcOrderRedisRecord; import com.xhpc.order.mapper.XhpcChargeOrderMapper; +import com.xhpc.order.mapper.XhpcInternetUserMapper; import com.xhpc.order.service.IXhpcChargeOrderService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -348,6 +349,9 @@ public class XhpcChargeOrderServiceImpl implements IXhpcChargeOrderService { return xhpcChargeOrderMapper.getXhpcChargeOrderStatus(status, source); } + @Autowired + private XhpcInternetUserMapper xhpcInternetUserMapper; + @Override @Transactional public R startUpBy3rd(String internetSerialNumber, String driverId, Integer chargingAmt, String plateNum, Integer status, String connectorId) { @@ -364,6 +368,11 @@ public class XhpcChargeOrderServiceImpl implements IXhpcChargeOrderService { return r; } + int resTime = xhpcInternetUserMapper.selectByOperatorIdEvcs(internetSerialNumber.substring(0, 9)); + if (resTime == 0) { + r.setCode(500); + return r; + } StartChargingData startChargingData = new StartChargingData(); //500000 equals 500 yuan diff --git a/xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcInternetUser.xml b/xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcInternetUser.xml new file mode 100644 index 00000000..971775fd --- /dev/null +++ b/xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcInternetUser.xml @@ -0,0 +1,16 @@ + + + + + + +