autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-05-10 21:10:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

update 电单车协议

Browse Source
This commit is contained in:
Guoqs
2024-09-04 13:48:39 +08:00
parent c0366f7c1b
commit efe869d79b
2 changed files with 8 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
jsowell-admin/src/main/java/com/jsowell/api/uniapp/customer/PileController.java
View File

@@ -119,7 +119,7 @@ public class PileController extends BaseController {
*/ */
@PostMapping("/selectConnectorListByParams") @PostMapping("/selectConnectorListByParams")
public RestApiResponse<?> selectConnectorListByParams(HttpServletRequest request, @RequestBody QueryConnectorListDTO dto) { public RestApiResponse<?> selectConnectorListByParams(HttpServletRequest request, @RequestBody QueryConnectorListDTO dto) {
logger.info("查询充电枪口列表 params:{}", JSON.toJSONString(dto)); logger.debug("查询充电枪口列表 params:{}", JSON.toJSONString(dto));
RestApiResponse<?> response = null; RestApiResponse<?> response = null;
try { try {
PageResponse pageResponse = pileConnectorInfoService.getUniAppConnectorInfoListByParams(dto); PageResponse pageResponse = pileConnectorInfoService.getUniAppConnectorInfoListByParams(dto);
@@ -128,7 +128,7 @@ public class PileController extends BaseController {
logger.error("查询充电枪口列表异常", e); logger.error("查询充电枪口列表异常", e);
response = new RestApiResponse<>(ReturnCodeEnum.CODE_GET_CONNECTOR_INFO_BY_STATION_ID_ERROR); response = new RestApiResponse<>(ReturnCodeEnum.CODE_GET_CONNECTOR_INFO_BY_STATION_ID_ERROR);
} }
logger.info("查询充电枪口列表 result:{}", response); logger.debug("查询充电枪口列表 result:{}", response);
return response; return response;
} }
@@ -141,15 +141,8 @@ public class PileController extends BaseController {
*/ */
@PostMapping("/selectStationConnectorList") @PostMapping("/selectStationConnectorList")
public RestApiResponse<?> selectStationConnectorList(HttpServletRequest request, @RequestBody QueryConnectorListDTO dto) { public RestApiResponse<?> selectStationConnectorList(HttpServletRequest request, @RequestBody QueryConnectorListDTO dto) {
logger.info("查询充电枪口列表 params:{}", JSON.toJSONString(dto)); logger.debug("查询充电枪口列表 params:{}", JSON.toJSONString(dto));
RestApiResponse<?> response = null; RestApiResponse<?> response = null;
// try {
// // 查询对接第三方平台的枪口状态
// selectThirdPartyConnectorStatus(dto);
// } catch (Exception e) {
// logger.error("修改对接第三方平台的枪口状态 error");
// }
try { try {
PageResponse pageResponse = pileConnectorInfoService.selectStationConnectorList(dto); PageResponse pageResponse = pileConnectorInfoService.selectStationConnectorList(dto);
response = new RestApiResponse<>(pageResponse); response = new RestApiResponse<>(pageResponse);
@@ -157,7 +150,7 @@ public class PileController extends BaseController {
logger.error("查询充电枪口列表异常", e); logger.error("查询充电枪口列表异常", e);
response = new RestApiResponse<>(ReturnCodeEnum.CODE_GET_CONNECTOR_INFO_BY_STATION_ID_ERROR); response = new RestApiResponse<>(ReturnCodeEnum.CODE_GET_CONNECTOR_INFO_BY_STATION_ID_ERROR);
} }
logger.info("查询充电枪口列表 result:{}", response); logger.debug("查询充电枪口列表, params:{}, result:{}", JSON.toJSONString(dto), response);
return response; return response;
} }

5
jsowell-netty/src/main/java/com/jsowell/netty/handler/electricbicycles/SettlementUploadHandler.java
View File

@@ -1,6 +1,7 @@
package com.jsowell.netty.handler.electricbicycles; package com.jsowell.netty.handler.electricbicycles;
import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSON;
import com.jsowell.common.constant.Constants;
import com.jsowell.common.core.domain.ebike.EBikeDataProtocol; import com.jsowell.common.core.domain.ebike.EBikeDataProtocol;
import com.jsowell.common.util.YKCUtils; import com.jsowell.common.util.YKCUtils;
import com.jsowell.netty.factory.EBikeOperateFactory; import com.jsowell.netty.factory.EBikeOperateFactory;
@@ -40,7 +41,9 @@ public class SettlementUploadHandler extends AbstractEBikeHandler {
saveLastTimeAndCheckChannel(message.getPhysicalId() + "", ctx); saveLastTimeAndCheckChannel(message.getPhysicalId() + "", ctx);
EBikeMessageCmd03.SettlementInfo settlementInfo = message.getSettlementInfo(); EBikeMessageCmd03.SettlementInfo settlementInfo = message.getSettlementInfo();
log.info("结算消费信息上传:{}", JSON.toJSONString(message)); log.info("结算消费信息上传:{}", JSON.toJSONString(message));
return null;
// 返回结果
return getResult(dataProtocol, Constants.zeroByteArray);
} }
} }