From 27bb38334ab26bdb111bbd110838c91b8ab08783 Mon Sep 17 00:00:00 2001 From: ZZ Date: Tue, 15 Feb 2022 11:07:05 +0800 Subject: [PATCH] pk whole no substr --- sql/v2.1.sql | 4 ++++ .../src/main/java/com/xhpc/pp/server/RateModelTask.java | 4 ++-- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/sql/v2.1.sql b/sql/v2.1.sql index f63f9df7..8d58bb7e 100644 --- a/sql/v2.1.sql +++ b/sql/v2.1.sql @@ -596,3 +596,7 @@ ALTER TABLE `ry-cloud`.`t_iccard_info` ALTER TABLE `xhpc_statistics_station` ADD COLUMN `source` INT(4) NULL COMMENT '订单来源（0 C端用户 1 流量方用户 2社区用户 3B端用户）' AFTER `tenant_id`; + +ALTER TABLE `xhpc_operator` + CHANGE COLUMN `corp_no` `corp_no` VARCHAR(30) NULL COMMENT '运营商代码,用于桩编号前缀,如80836代表翔桦' AFTER `name`, + ADD UNIQUE INDEX `corp_no` (`corp_no`); diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/RateModelTask.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/RateModelTask.java index 0cb0e72c..2daad923 100644 --- a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/RateModelTask.java +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/RateModelTask.java @@ -42,9 +42,9 @@ public class RateModelTask { } } if (!charging) { - ClientHandler handler = getHandler(pk.substring(5)); + ClientHandler handler = getHandler(pk); if (handler != null && handler.isOpen()) { - String rsmsg = RateModelRequestLogic.translate(pk.substring(5), rateModelIdStation, "0058"); + String rsmsg = RateModelRequestLogic.translate(pk, rateModelIdStation, "0058"); try { handler.sendClientBinary(HexUtils.toBytes(rsmsg)); log.info("pile[{}] rate model[{}] sent ⚪", pk, rateModelIdPile);