This commit is contained in:
ZZ 2022-03-25 16:21:59 +08:00
parent 88c7918752
commit dba9a9551d
5 changed files with 16 additions and 13 deletions

View File

@ -74,8 +74,6 @@
<dependency> <dependency>
<groupId>com.ruoyi</groupId> <groupId>com.ruoyi</groupId>
<artifactId>xhpc-common</artifactId> <artifactId>xhpc-common</artifactId>
<version>3.0.0</version>
<scope>compile</scope>
</dependency> </dependency>
<dependency> <dependency>

View File

@ -19,8 +19,8 @@ public class Calc {
test("-1 + 2", 1); test("-1 + 2", 1);
test("2 * (3 * (4 + 5)) / 9 / 6", 1); test("2 * (3 * (4 + 5)) / 9 / 6", 1);
test("max(1, 2 + 3)", 5); // test("max(1, 2 + 3)", 5);
test("min(3 - 1, 1)", 1); // test("min(3 - 1, 1)", 1);
Map<String, Object> map = new HashMap<>(); Map<String, Object> map = new HashMap<>();
map.put("totalPower", new BigDecimal("400000.000000")); map.put("totalPower", new BigDecimal("400000.000000"));
@ -32,6 +32,14 @@ public class Calc {
Expression expression = parser.parseExpression(ruleExpression); Expression expression = parser.parseExpression(ruleExpression);
String rs = expression.getValue(stdContext, String.class); String rs = expression.getValue(stdContext, String.class);
System.out.println(rs); System.out.println(rs);
ruleExpression = "#totalPower + 500000";
expression = parser.parseExpression(ruleExpression);
rs = expression.getValue(stdContext, String.class);
System.out.println(rs);
ruleExpression = "#totalPower * 0.03";
expression = parser.parseExpression(ruleExpression);
rs = expression.getValue(stdContext, String.class);
System.out.println(rs);
} }
private static void test(String s, double x) { private static void test(String s, double x) {

View File

@ -313,7 +313,7 @@ public class XhpcChargeOrderServiceImpl extends BaseService implements IXhpcChar
}catch (Exception e){ }catch (Exception e){
e.printStackTrace(); e.printStackTrace();
} }
return AjaxResult.error(UserTypeUtil.LOGIN_TYPE, "重新登录"); return AjaxResult.error(UserTypeUtil.LOGIN_TYPE, "确认设备网络状况正常和枪正确插好后重新尝试");
} }
@Override @Override

View File

@ -234,11 +234,6 @@ public class ChargingController {
String pileNo = startChargingData.getPileNo(); String pileNo = startChargingData.getPileNo();
ClientHandler handler = ChargingPileServer.getHandler(pileNo); ClientHandler handler = ChargingPileServer.getHandler(pileNo);
if (handler == null) { if (handler == null) {
try {
handler.closeConnection();
} catch (Exception e) {
log.error("invalid conn [{}]", handler.getName());
}
return R.fail("充电桩没有连接到上次注册的服务器,请稍后再试一次"); return R.fail("充电桩没有连接到上次注册的服务器,请稍后再试一次");
} else if (!handler.isOpen()) { } else if (!handler.isOpen()) {
log.error("[{}]({}) connection lost", handler.getName(), pileNo); log.error("[{}]({}) connection lost", handler.getName(), pileNo);

View File

@ -135,10 +135,12 @@ public class ChargingPileServer {
pileNo = pileNo.substring(pileNo.length() - 14); pileNo = pileNo.substring(pileNo.length() - 14);
} }
ClientHandler handler = handlerMap.get(pileNo); ClientHandler handler = handlerMap.get(pileNo);
if (handler == null || !handler.isOpen()) { if (handler == null) {
return;
}
if (!handler.isOpen()) {
log.error("send message failed. [{}]({}) connection lost", handler.getName(), pileNo); log.error("send message failed. [{}]({}) connection lost", handler.getName(), pileNo);
removeHandler(pileNo); removeHandler(pileNo);
return;
} }
try { try {
handler.sendClientBinary(msg); handler.sendClientBinary(msg);