yuyang/XH-Power-Cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

启动充电测试

Browse Source
This commit is contained in:
ZZ 2021-08-05 18:50:31 +08:00
parent a1db4383a0
commit 6d48e9c2c4
4 changed files with 28 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
xhpc-modules/xhpc-common/pom.xml
View File

@ -34,5 +34,9 @@
<artifactId>jackson-datatype-jsr310</artifactId> <artifactId>jackson-datatype-jsr310</artifactId>
<version>2.12.3</version> <version>2.12.3</version>
</dependency> </dependency>
<dependency>
<groupId>com.ruoyi</groupId>
<artifactId>ruoyi-common-security</artifactId>
</dependency>
</dependencies> </dependencies>
</project> </project>

2
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/PowerPileService.java
View File

@ -5,6 +5,7 @@ import com.xhpc.common.core.constant.ServiceNameConstants;
import com.xhpc.common.core.domain.R; import com.xhpc.common.core.domain.R;
import com.xhpc.common.data.down.StartChargingData; import com.xhpc.common.data.down.StartChargingData;
import com.xhpc.common.data.redis.CacheRateModel; import com.xhpc.common.data.redis.CacheRateModel;
import com.xhpc.common.security.annotation.PreAuthorize;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
@ -15,6 +16,7 @@ import java.util.Set;
@FeignClient(contextId = "powerPileService", value = ServiceNameConstants.PILE_SERVICE, fallbackFactory = PowerPileFallbackFactory.class) @FeignClient(contextId = "powerPileService", value = ServiceNameConstants.PILE_SERVICE, fallbackFactory = PowerPileFallbackFactory.class)
public interface PowerPileService { public interface PowerPileService {
@PreAuthorize(hasPermi = "user:privilege:add")
@PostMapping("/charging/start") @PostMapping("/charging/start")
R startCharging(@Validated @RequestBody StartChargingData startChargingData); R startCharging(@Validated @RequestBody StartChargingData startChargingData);

2
xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/data/down/StartChargingData.java
View File

@ -15,7 +15,7 @@ public class StartChargingData {
private Integer balance; //账户余额(精度:小数点后2位)=实际金额(元)×100 private Integer balance; //账户余额(精度:小数点后2位)=实际金额(元)×100
private String logicCardNo = "0000000000000000"; //逻辑卡号 private String logicCardNo = "0000000000000000"; //逻辑卡号
private String physicCardNo = "0000000000000000"; //物理卡号 private String physicCardNo = "0000000000000000"; //物理卡号
private String version; //协议版本号(0A) private String version = "0A"; //协议版本号(0A)
public String getOrderNo() { public String getOrderNo() {

36
xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/controller/TestController.java
View File

@ -1,30 +1,36 @@
package com.xhpc.pp.controller; package com.xhpc.pp.controller;
import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.exception.NacosException; import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingService; import com.xhpc.common.api.PowerPileService;
import com.alibaba.nacos.api.naming.pojo.Instance; import com.xhpc.common.core.domain.R;
import com.xhpc.common.core.utils.GetIpAndPort; import com.xhpc.common.data.down.StartChargingData;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@RestController @RestController
public class TestController { public class TestController {
@GetMapping("test") @Autowired
public String test() throws NacosException { private PowerPileService powerPileService;
String serverIp = "127.0.0.1"; @GetMapping("test/{ono}/{b}/{gid}")
int serverPort = 8848; public R test(@PathVariable String ono, @PathVariable int b, @PathVariable String gid) throws NacosException {
String serverAddr = serverIp + ":" + serverPort;
NamingService namingService = NacosFactory.createNamingService(serverAddr); // String serverIp = "127.0.0.1";
List<Instance> ppInstances = namingService.getAllInstances("xhpc-power-pile"); // int serverPort = 8848;
// String serverAddr = serverIp + ":" + serverPort;
// NamingService namingService = NacosFactory.createNamingService(serverAddr);
// List<Instance> ppInstances = namingService.getAllInstances("xhpc-power-pile");
// todo clean dead host pile cache // todo clean dead host pile cache
String ipAndPort = GetIpAndPort.getIpAndPort(); // String ipAndPort = GetIpAndPort.getIpAndPort();
return ipAndPort;
StartChargingData d = new StartChargingData();
d.setBalance(b); //300
d.setOrderNo(ono); //00000000000000000000000123456789
d.setGunId(gid); //02
return powerPileService.startCharging(d);
} }
} }