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

新增 宁夏平台controller

Browse Source
This commit is contained in:
Lemon
2024-05-30 09:38:29 +08:00
parent 40a929eebd
commit f08de6dd54
5 changed files with 148 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
jsowell-admin/src/main/java/com/jsowell/api/thirdparty/NingXiaController.java vendored
View File

@@ -4,6 +4,8 @@ import com.alibaba.fastjson2.JSON;
import com.jsowell.common.annotation.Anonymous;
import com.jsowell.common.enums.thirdparty.ThirdPartyReturnCodeEnum;
import com.jsowell.common.exception.BusinessException;
import com.jsowell.common.response.RestApiResponse;
import com.jsowell.pile.dto.PushRealTimeInfoDTO;
import com.jsowell.pile.dto.QueryOperatorInfoDTO;
import com.jsowell.pile.dto.QueryStationInfoDTO;
import com.jsowell.pile.thirdparty.CommonParamsDTO;
@@ -11,10 +13,7 @@ import com.jsowell.thirdparty.lianlian.common.CommonResult;
import com.jsowell.thirdparty.platform.service.ThirdPartyPlatformService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
import java.util.Map;
@@ -156,4 +155,57 @@ public class NingXiaController extends ThirdPartyBaseController {
}
/**
* 推送充电设备接口状态信息
* @param dto
* @return
*/
@PostMapping("/v1/supervise_notification_station_status")
public RestApiResponse<?> superviseNotificationStationStatus(@RequestBody PushRealTimeInfoDTO dto) {
RestApiResponse<?> response = null;
try {
String result = platformLogic.notificationStationStatus(dto);
response = new RestApiResponse<>(result);
} catch (Exception e) {
logger.error("宁夏平台推送充电设备接口状态信息 error", e);
return new RestApiResponse<>(e);
}
return response;
}
/**
* 推送充电状态信息
* @param dto
* @return
*/
@GetMapping("/v1/supervise_notification_equip_charge_status/{orderCode}")
public RestApiResponse<?> superviseNotificationEquipChargeStatus(@PathVariable("orderCode") String orderCode) {
RestApiResponse<?> response = null;
try {
String result = platformLogic.notificationEquipChargeStatus(orderCode);
response = new RestApiResponse<>(result);
} catch (Exception e) {
logger.error("宁夏平台推送充电状态信息 error", e);
return new RestApiResponse<>(e);
}
return response;
}
/**
* 推送充电站历史充电订单信息
* @param orderCode
* @return
*/
@GetMapping("/v1/supervise_notification_equip_charge_status/{orderCode}")
public RestApiResponse<?> notificationChargeOrderInfoHistory(@PathVariable("orderCode") String orderCode) {
RestApiResponse<?> response = null;
try {
String result = platformLogic.notificationChargeOrderInfoHistory(orderCode);
response = new RestApiResponse<>(result);
} catch (Exception e) {
logger.error("宁夏平台推送充电站历史充电订单信息 error", e);
return new RestApiResponse<>(e);
}
return response;
}
}

6
jsowell-admin/src/main/java/com/jsowell/api/thirdparty/QingHaiController.java vendored
View File

@@ -5,6 +5,7 @@ import com.alibaba.fastjson2.JSONObject;
import com.jsowell.common.annotation.Anonymous;
import com.jsowell.common.core.controller.BaseController;
import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
import com.jsowell.common.exception.BusinessException;
import com.jsowell.common.response.RestApiResponse;
import com.jsowell.common.util.JWTUtils;
import com.jsowell.pile.domain.ThirdPartyPlatformConfig;
@@ -56,8 +57,11 @@ public class QingHaiController extends BaseController {
Map<String, String> map = qingHaiPlatformServiceImpl.queryToken(dto);
logger.info("青海平台请求令牌 result:{}", JSON.toJSONString(map));
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
}catch (BusinessException e) {
logger.error("青海平台请求令牌 error:{}, {}", e.getCode(), e.getMessage());
return CommonResult.failed("获取token发生异常");
} catch (Exception e) {
logger.error("获取token接口 异常");
logger.error("青海平台请求令牌接口 异常");
return CommonResult.failed("获取token发生异常");
}
}

19
jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/common/CommonService.java vendored
View File

@@ -35,6 +35,7 @@ import com.jsowell.thirdparty.huawei.HuaweiServiceV2;
import com.jsowell.thirdparty.platform.service.impl.HaiNanPlatformServiceImpl;
import com.jsowell.thirdparty.huawei.HuaWeiService;
import com.jsowell.thirdparty.lianlian.service.LianLianService;
import com.jsowell.thirdparty.platform.service.impl.NinaXiaPlatformServiceImpl;
import com.jsowell.thirdparty.platform.service.impl.QingHaiPlatformServiceImpl;
import com.jsowell.thirdparty.platform.util.HttpRequestUtil;
import com.jsowell.thirdparty.lutongyunting.service.LTYTService;
@@ -116,6 +117,9 @@ public class CommonService {
@Autowired
private QingHaiPlatformServiceImpl qingHaiPlatformService;
@Autowired
private NinaXiaPlatformServiceImpl ninaXiaPlatformService;
@Autowired
private RedisCache redisCache;
@@ -366,6 +370,21 @@ public class CommonService {
}
}
}
if (StringUtils.equals(ThirdPlatformTypeEnum.NING_XIA_PLATFORM.getTypeCode(), thirdPartyType)) {
// 宁夏平台
dto.setThirdPartyType(ThirdPlatformTypeEnum.NING_XIA_PLATFORM.getTypeCode());
String result = ninaXiaPlatformService.notificationStationStatus(dto);
log.info("宁夏平台推送充电设备接口状态信息 result:{}", result);
if (StringUtils.equals(connectorStatus, "03")) {
// 充电状态, 查出订单信息
OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode);
if (orderInfo == null) {
return;
}
String result2 = ninaXiaPlatformService.notificationEquipChargeStatus(orderInfo.getOrderCode());
log.info("宁夏平台推送充电状态信息 result:{}", result2);
}
}
}
}

9
jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/ThirdPartyPlatformService.java vendored
View File

@@ -171,6 +171,15 @@ public interface ThirdPartyPlatformService extends InitializingBean {
throw new UnsupportedOperationException("This method is not yet implemented");
}
/**
* 过程信息查询 query_bms_info
* @param pileConnectorCode
* @return
*/
default Map<String, String> queryBmsInfo(String pileConnectorCode) {
throw new UnsupportedOperationException("This method is not yet implemented");
}
/**
* 查询业务策略信息结果
* 请求计费策略 request_equip_business_policy

59
jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/ShenZhenPlatformServiceImpl.java vendored
View File

@@ -552,6 +552,65 @@ public class ShenZhenPlatformServiceImpl implements ThirdPartyPlatformService {
return result;
}
@Override
public Map<String, String> queryBmsInfo(String pileConnectorCode) {
JSONObject jsonObject = new JSONObject();
// 根据枪口编号查询枪口信息
PileConnectorInfoVO connectorInfoVO = pileConnectorInfoService.getPileConnectorInfoByConnectorCode(pileConnectorCode);
if (!StringUtils.equals(PileConnectorDataBaseStatusEnum.OCCUPIED_CHARGING.getValue(), String.valueOf(connectorInfoVO.getStatus()))) {
// 不为充电中, BmsInfo 为空
jsonObject.put("BmsInfo", null);
}else {
// 充电中状态时，获取充电电池信息
// 获取正在充电的订单信息
List<OrderListVO> orderListVOS = orderBasicInfoService.selectChargingOrder(connectorInfoVO.getPileSn());
if (CollectionUtils.isEmpty(orderListVOS)) {
return null;
}
OrderListVO orderVO = orderListVOS.get(0);
// 获取充电电池信息
List<RealTimeMonitorData> chargingRealTimeData = orderBasicInfoService.getChargingRealTimeData(orderVO.getTransactionCode());
if (CollectionUtils.isEmpty(chargingRealTimeData)) {
return null;
}
RealTimeMonitorData data = chargingRealTimeData.get(0);
BMSInfo bmsInfo = BMSInfo.builder()
.vinCode(orderVO.getVinCode())
.bmsCode("")
.bmsVer("")
.connectorID(orderVO.getPileConnectorCode())
.maxChargeCurrent(new BigDecimal(""))
.maxChargeCellVoltage(new BigDecimal(""))
.maxTemp(0)
.ratedCapacity(0)
.tatalVoltage(new BigDecimal(data.getOutputVoltage()))
.totalCurrent(new BigDecimal(data.getOutputCurrent()))
.soc(Integer.parseInt(data.getSOC()))
.voltageH(new BigDecimal(""))
.voltageHNumIndex(0)
.temptureH(0)
.temptureHNumIndex(0)
.temptureL(0)
.temptureLNumIndex(0)
.currentCapacity(new BigDecimal(""))
.freshTime(DateUtils.getDateTime())
.startChargingTime(orderVO.getChargeStartTime())
.chargingSessionMin(Integer.parseInt(data.getSumChargingTime()) * 60)
.build();
jsonObject.put("BmsInfo", bmsInfo);
}
jsonObject.put("ConnectorID", pileConnectorCode);
jsonObject.put("Status", connectorInfoVO.getStatus());
ThirdPartySecretInfoVO shenZhenSecretInfo = getShenZhenSecretInfo();
Map<String, String> map = ThirdPartyPlatformUtils.generateResultMap(jsonObject, shenZhenSecretInfo);
return map;
}
/**
* 获取深圳平台相关密钥信息
* @return