From ef85d920a9b6dcab50fab454e7bfc86a5f16064e Mon Sep 17 00:00:00 2001 From: "autumn.g@foxmail.com" Date: Wed, 1 Nov 2023 17:03:48 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E5=85=85=E7=94=B5=E7=AB=99=E9=80=9A?= =?UTF-8?q?=E4=BF=A1=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pile/service/IPileMsgRecordService.java | 3 ++ .../impl/PileMsgRecordServiceImpl.java | 46 +++++++++++++++++++ 2 files changed, 49 insertions(+) diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/IPileMsgRecordService.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/IPileMsgRecordService.java index 31b43e810..1a7536f4a 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/IPileMsgRecordService.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/IPileMsgRecordService.java @@ -1,6 +1,7 @@ package com.jsowell.pile.service; import com.jsowell.common.core.page.PageResponse; +import com.jsowell.pile.domain.PileMsgRecord; import com.jsowell.pile.dto.QueryPileDTO; public interface IPileMsgRecordService { @@ -21,4 +22,6 @@ public interface IPileMsgRecordService { * 查询充电桩通信日志 分页 */ PageResponse getPileFeedList(QueryPileDTO dto); + + String generateDescription(PileMsgRecord pileMsgRecord); } diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileMsgRecordServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileMsgRecordServiceImpl.java index 9d17f04cb..7fdb2f3b6 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileMsgRecordServiceImpl.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileMsgRecordServiceImpl.java @@ -1,5 +1,6 @@ package com.jsowell.pile.service.impl; +import com.alibaba.fastjson2.JSONObject; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.jsowell.common.core.domain.ykc.YKCFrameTypeCode; @@ -82,4 +83,49 @@ public class PileMsgRecordServiceImpl implements IPileMsgRecordService { .build(); return pageResponse; } + + /** + * 生成展示在后管的描述 + * @param pileMsgRecord + * @return + */ + @Override + public String generateDescription(PileMsgRecord pileMsgRecord) { + String result = null; + + String frameType = YKCUtils.frameType2Str(pileMsgRecord.getFrameType().getBytes()); + String jsonMsg = pileMsgRecord.getJsonMsg(); + switch (frameType) { + case "0x01" : + result = loginMsg(jsonMsg); + break; + case "0x31" : + result = loginMsg(jsonMsg); + break; + default: + + } + + return result; + } + + private String loginMsg(String jsonMsg) { + JSONObject jsonObject = JSONObject.parseObject(jsonMsg); + String iccid = jsonObject.getString("iccid"); + String programVersion = jsonObject.getString("programVersion"); + Integer connectorNum = jsonObject.getInteger("connectorNum"); + String internetConnection = jsonObject.getString("internetConnection"); + String pileType = jsonObject.getString("pileType"); + return "SIM卡号:" + iccid + ", " + + "设备程序版本:" + programVersion + ", " + + "桩类型:" + pileType + ", " + + "枪数量:" + connectorNum + ", " + + "网络链接类型:" + internetConnection; + } + + private String requestStartChargingMsg(String jsonMsg) { + JSONObject jsonObject = JSONObject.parseObject(jsonMsg); + jsonObject.getString(""); + return null; + } }