package com.sandu.ximon.admin.service;
|
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.github.pagehelper.PageHelper;
|
import com.sandu.common.execption.BusinessException;
|
import com.sandu.common.object.BaseConditionVO;
|
import com.sandu.common.service.impl.BaseServiceImpl;
|
import com.sandu.ximon.admin.config.C3mRedisConfig;
|
import com.sandu.ximon.admin.manager.iot.frame.A5Frame;
|
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5C3HeartbeatReportInnerFrame;
|
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5C3OperationReportInnerFrame;
|
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5C3QueryReportInnerFrame;
|
import com.sandu.ximon.admin.manager.iot.frame.inner.request.*;
|
import com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonFrame;
|
import com.sandu.ximon.admin.manager.iot.rrpc.enums.A5OrderEnum;
|
import com.sandu.ximon.admin.manager.iot.rrpc.enums.C3mRedisConstant;
|
import com.sandu.ximon.admin.manager.iot.rrpc.mainboard.MainBoardInvokeSyncService;
|
import com.sandu.ximon.admin.param.C3ChargingAddParam;
|
import com.sandu.ximon.admin.param.C3ChargingParam;
|
import com.sandu.ximon.admin.utils.LogUtils;
|
import com.sandu.ximon.admin.utils.RedisUtils;
|
import com.sandu.ximon.dao.bo.C3ChargingBo;
|
import com.sandu.ximon.dao.domain.C3mCharging;
|
import com.sandu.ximon.dao.domain.C3mChargingCharge;
|
import com.sandu.ximon.dao.domain.PoleBinding;
|
import com.sandu.ximon.dao.mapper.C3mChargingMapper;
|
import lombok.AllArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Set;
|
|
/**
|
* @author ZZQ
|
* C3充电桩
|
* @date 2022/3/4 9:58
|
*/
|
@Service
|
@Slf4j
|
@AllArgsConstructor
|
public class C3ChargingService extends BaseServiceImpl<C3mChargingMapper, C3mCharging> {
|
private C3mChargingMapper c3mChargingMapper;
|
private final C3mChargingChargeService c3mChargingChargeService;
|
private final PoleBindingService bindingService;
|
private final PoleService poleService;
|
|
/**
|
* 保存上报C3充电设备心跳数据
|
*
|
* @return 是否成功
|
*/
|
public boolean updateReportState(String deviceName, String c3Mac, String statusBit, String deviceTemperature) {
|
C3mCharging one = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getPoleDevicesCode, deviceName));
|
if (one != null) {
|
// one.setStatusBit(Integer.valueOf(statusBit));
|
one.setDeviceTemperature(deviceTemperature);
|
one.setPoleDevicesCode(deviceName);
|
one.setC3Mac(c3Mac);
|
|
// List<C3mChargingCharge> list = c3mChargingChargeService.list(Wrappers.lambdaQuery(C3mChargingCharge.class).eq(C3mChargingCharge::getC3Id, one.getC3Id()));
|
// if (list.size() == 0) {//费率表中没有此充电桩数据时 添加默认费率
|
// c3mChargingChargeService.initCharge((one.getC3Id()).intValue());
|
// }
|
return updateById(one);
|
} else {
|
return false;
|
}
|
}
|
|
/**
|
* 保存上报C3充电设备心跳数据
|
*
|
* @return 是否成功
|
*/
|
public boolean saveReporEquipment(String deviceName, String mcuUdid, String c3Mac) {
|
C3mCharging one = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getMcuUdid, mcuUdid));
|
boolean flag;
|
if (one == null) {
|
//将设备信息添加到充电桩设备表
|
C3mCharging c3mCharging = new C3mCharging();
|
c3mCharging.setMcuUdid(mcuUdid);
|
c3mCharging.setPoleDevicesCode(deviceName);
|
c3mCharging.setC3Mac(c3Mac);
|
flag = save(c3mCharging);
|
//设置费率
|
C3mCharging c3mCharging1 = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getMcuUdid, mcuUdid));
|
List<C3mChargingCharge> list = c3mChargingChargeService.list(Wrappers.lambdaQuery(C3mChargingCharge.class).eq(C3mChargingCharge::getC3Id, c3mCharging1.getC3Id()));
|
if (list.size() == 0) {//费率表中没有此充电桩数据时 添加默认费率
|
c3mChargingChargeService.initCharge((c3mCharging1.getC3Id()).intValue());
|
}
|
|
} else {
|
//将设备信息添加到充电桩设备表
|
one.setPoleDevicesCode(deviceName);
|
one.setC3Mac(c3Mac);
|
flag = updateById(one);
|
//设置费率
|
C3mCharging c3mCharging1 = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getMcuUdid, mcuUdid));
|
List<C3mChargingCharge> list = c3mChargingChargeService.list(Wrappers.lambdaQuery(C3mChargingCharge.class).eq(C3mChargingCharge::getC3Id, c3mCharging1.getC3Id()));
|
if (list.size() == 0) {//费率表中没有此充电桩数据时 添加默认费率
|
c3mChargingChargeService.initCharge((c3mCharging1.getC3Id()).intValue());
|
}
|
}
|
//同步时间戳
|
String date = new SimpleDateFormat("yyMMddHHmmss").format(new Date());
|
String s = SetCalendar(c3Mac, Integer.parseInt(date.substring(0, 2)), Integer.parseInt(date.substring(2, 4)),
|
Integer.parseInt(date.substring(4, 6)), Integer.parseInt(date.substring(6, 8)),
|
Integer.parseInt(date.substring(8, 10)), Integer.parseInt(date.substring(10, 12)));
|
if (!"操作成功".equals(s)) {
|
LogUtils.error("发送设置C3时间同步失败!");
|
return false;
|
}
|
|
/** 跳包时间同步
|
* 设置时间规则：充电时为1倍，非充电状态为1.5倍时间
|
*/
|
Set<String> keys = RedisUtils.getBean().keys(C3mRedisConstant.C3_STATUS.getCode() + "*");
|
|
C3mRedisConfig.reFlushTime(keys.size());
|
String time1 = SetHeartbeatPacketTimeCharging(c3Mac, C3mRedisConfig.parseInt(C3mRedisConfig.HEART_BEAT_TIME) * 2, false);
|
LogUtils.error("C3空闲心跳包时间同步响应结果：" + time1);
|
String time2 = SetHeartbeatPacketTimeCharging(c3Mac, C3mRedisConfig.parseInt(C3mRedisConfig.HEART_BEAT_TIME), true);
|
LogUtils.error("C3充电时心跳包时间同步响应结果：" + time2);
|
|
|
/**
|
* 获取心跳包，判断在线
|
*/
|
A5C3HeartbeatReportInnerFrame.HeartBeatDataPackage aPackage = ReadTheHeartbeatPackage(c3Mac);
|
if (aPackage == null) {
|
LogUtils.error("读取心跳包为空");
|
return false;
|
}
|
RedisUtils redisUtils = RedisUtils.getBean();
|
redisUtils.set(
|
C3mRedisConstant.C3_STATUS.getCode() + c3Mac,
|
JSON.toJSONString(aPackage),
|
C3mRedisConfig.OUTLINE_TIME
|
);
|
|
/**
|
* finally、同步结束
|
*/
|
String end = EndOfTheSynchronization(c3Mac);
|
if (!"操作成功".equals(end)) {
|
LogUtils.error("C3同步结束响应结果" + end);
|
return false;
|
}
|
return flag;
|
}
|
|
/**
|
* 查询C3充电桩设备列表
|
*
|
* @return
|
*/
|
public List<C3ChargingBo> getC3ChargingListByKeyword(BaseConditionVO baseConditionVO, C3ChargingParam c3ChargingParam) {
|
PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
|
if (c3ChargingParam == null) {
|
c3ChargingParam = new C3ChargingParam();
|
}
|
|
//关键字去除空格
|
if (c3ChargingParam.getKeyword() != null) {
|
c3ChargingParam.setKeyword(c3ChargingParam.getKeyword().trim());
|
}
|
|
List<C3ChargingBo> c3ChargingBoList = c3mChargingMapper.listC3mChargingDto(c3ChargingParam.getKeyword());
|
for (C3ChargingBo one : c3ChargingBoList) {
|
String s = RedisUtils.getBean().get(C3mRedisConstant.C3_STATUS.getCode() + one.getC3Mac());
|
if(s != null){
|
one.setStatusBit(1);
|
}else{
|
one.setStatusBit(0);
|
}
|
|
}
|
return c3ChargingBoList;
|
}
|
|
/**
|
* 开始充电
|
*
|
* @param c3Mac
|
* @param chargingCapacity
|
* @param chargeAmount
|
*/
|
public String startCharging(String c3Mac, Integer chargingCapacity, Double chargeAmount) {
|
C3StartChargingReqInnerFrame c3StartChargingReqInnerFrame =
|
new C3StartChargingReqInnerFrame(c3Mac, chargingCapacity, chargeAmount);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), c3StartChargingReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
System.out.println(commonFrame + " -----commonFrame");
|
|
|
// String functionCode = commonFrame.getPayload().substring(2, 4);
|
// if (C3ChargingEnum.StartCharging.getCode().equals(functionCode)) {}
|
|
|
A5C3OperationReportInnerFrame operationReportInnerFrame = new A5C3OperationReportInnerFrame().transformFrame(commonFrame.getPayload());
|
|
if (operationReportInnerFrame.isValidate()) {
|
return operationReportInnerFrame.getState();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 结束充电
|
*
|
* @param c3Mac
|
*/
|
public String finishCharging(String c3Mac) {
|
C3FinishChargingReqInnerFrame c3FinishChargingReqInnerFrame =
|
new C3FinishChargingReqInnerFrame(c3Mac);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), c3FinishChargingReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3OperationReportInnerFrame operationReportInnerFrame = new A5C3OperationReportInnerFrame().transformFrame(commonFrame.getPayload());
|
|
if (operationReportInnerFrame.isValidate()) {
|
return operationReportInnerFrame.getState();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
|
/**
|
* 同步结束
|
*
|
* @param c3Mac
|
*/
|
public String EndOfTheSynchronization(String c3Mac) {
|
C3EndOfTheSynchronizationReqInnerFrame c3EndOfTheSynchronizationReqInnerFrame =
|
new C3EndOfTheSynchronizationReqInnerFrame(c3Mac);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), c3EndOfTheSynchronizationReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3OperationReportInnerFrame operationReportInnerFrame = new A5C3OperationReportInnerFrame().transformFrame(commonFrame.getPayload());
|
|
if (operationReportInnerFrame.isValidate()) {
|
return operationReportInnerFrame.getState();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 二维码
|
*
|
* @param c3Mac
|
*/
|
public String QrCode(String c3Mac, String qrCodeData) {
|
C3QrCodeReqInnerFrame c3QrCodeReqInnerFrame = new C3QrCodeReqInnerFrame(c3Mac, qrCodeData);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), c3QrCodeReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3OperationReportInnerFrame operationReportInnerFrame = new A5C3OperationReportInnerFrame().transformFrame(commonFrame.getPayload());
|
|
if (operationReportInnerFrame.isValidate()) {
|
return operationReportInnerFrame.getState();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 查询版本
|
*
|
* @param c3Mac
|
*/
|
public String QueryVersion(String c3Mac) {
|
C3QueryVersionReqInnerFrame c3QueryVersionReqInnerFrame =
|
new C3QueryVersionReqInnerFrame(c3Mac);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), c3QueryVersionReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3QueryReportInnerFrame a5C3QueryReportInnerFrame = new A5C3QueryReportInnerFrame().transformFrame(commonFrame.getPayload());
|
|
if (a5C3QueryReportInnerFrame.isValidate()) {
|
return a5C3QueryReportInnerFrame.getVersion();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 查询心跳包间隔时间
|
*
|
* @param c3Mac
|
*/
|
public String QueryIntervalTime(String c3Mac) {
|
C3QueryIntervalTimeReqInnerFrame c3QueryIntervalTimeReqInnerFrame =
|
new C3QueryIntervalTimeReqInnerFrame(c3Mac);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), c3QueryIntervalTimeReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3QueryReportInnerFrame queryReportInnerFrame = new A5C3QueryReportInnerFrame().transformFrame(commonFrame.getPayload());
|
|
if (queryReportInnerFrame.isValidate()) {
|
return queryReportInnerFrame.getIntervalTime();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 查询电压/电流常数
|
*
|
* @param c3Mac
|
*/
|
public String QueryConstant(String c3Mac) {
|
C3QueryConstantReqInnerFrame c3QueryConstantReqInnerFrame =
|
new C3QueryConstantReqInnerFrame(c3Mac);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), c3QueryConstantReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3QueryReportInnerFrame queryReportInnerFrame = new A5C3QueryReportInnerFrame().transformFrame(commonFrame.getPayload());
|
|
if (queryReportInnerFrame.isValidate()) {
|
return queryReportInnerFrame.getConstant();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 查询地址
|
*
|
* @param c3Mac
|
*/
|
public String QueryAddress(String c3Mac) {
|
C3QueryAddressReqInnerFrame c3QueryAddressReqInnerFrame =
|
new C3QueryAddressReqInnerFrame(c3Mac);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), c3QueryAddressReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3QueryReportInnerFrame queryReportInnerFrame = new A5C3QueryReportInnerFrame().transformFrame(commonFrame.getPayload());
|
|
if (queryReportInnerFrame.isValidate()) {
|
return queryReportInnerFrame.getAddress();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 查询故障码
|
*
|
* @param c3Mac
|
*/
|
public String QueryFaultCode(String c3Mac) {
|
C3QueryFaultCodeReqInnerFrame c3QueryFaultCodeReqInnerFrame =
|
new C3QueryFaultCodeReqInnerFrame(c3Mac);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), c3QueryFaultCodeReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3QueryReportInnerFrame queryReportInnerFrame = new A5C3QueryReportInnerFrame().transformFrame(commonFrame.getPayload());
|
|
if (queryReportInnerFrame.isValidate()) {
|
return queryReportInnerFrame.getFaultCode();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 读心跳包
|
*
|
* @param c3Mac
|
*/
|
public A5C3HeartbeatReportInnerFrame.HeartBeatDataPackage ReadTheHeartbeatPackage(String c3Mac) {
|
C3ReadTheHeartbeatPackageReqInnerFrame readTheHeartbeatPackageReqInnerFrame =
|
new C3ReadTheHeartbeatPackageReqInnerFrame(c3Mac);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), readTheHeartbeatPackageReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3HeartbeatReportInnerFrame heartbeatReportInnerFrame = new A5C3HeartbeatReportInnerFrame().transformFrame(commonFrame.getPayload());
|
if (heartbeatReportInnerFrame.isValidate()) {
|
return heartbeatReportInnerFrame.getHeartBeatDataPackage();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 设置心跳包间隔时间(秒）-充电状态时/非充电状态时
|
*
|
* @param c3Mac
|
* @param setTime
|
* @return
|
*/
|
public String SetHeartbeatPacketTimeCharging(String c3Mac, int setTime, boolean flag) {
|
if (setTime <= 0) {
|
throw new BusinessException("设置的心跳包间隔时间错误！");
|
}
|
C3SetHeartbeatPacketTimeReqInnerFrame setHeartbeatPacketTimeChargingReqInnerFrame =
|
new C3SetHeartbeatPacketTimeReqInnerFrame(c3Mac, setTime, flag);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), setHeartbeatPacketTimeChargingReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3OperationReportInnerFrame operationReportInnerFrame = new A5C3OperationReportInnerFrame().transformFrame(commonFrame.getPayload());
|
if (operationReportInnerFrame.isValidate()) {
|
return operationReportInnerFrame.getState();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 设置电压/电流常数(各一字节)(默认值0xBC64)
|
*
|
* @param c3Mac
|
* @param constant
|
* @return
|
*/
|
public String SetConstant(String c3Mac, String constant) {
|
|
C3SetConstantReqInnerFrame setConstantReqInnerFrame =
|
new C3SetConstantReqInnerFrame(c3Mac, constant);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), setConstantReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3OperationReportInnerFrame operationReportInnerFrame = new A5C3OperationReportInnerFrame().transformFrame(commonFrame.getPayload());
|
if (operationReportInnerFrame.isValidate()) {
|
return operationReportInnerFrame.getState();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 设置地址
|
*
|
* @param c3Mac
|
* @param address
|
* @return
|
*/
|
public String SetAddress(String c3Mac, String address) {
|
if (address == null || address.length() != 8) {
|
throw new BusinessException("地址信息错误！");
|
}
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3MAC地址不存在");
|
}
|
|
if (getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, address)) != null) {
|
throw new BusinessException("新的地址信息已存在！");
|
}
|
|
C3SetAddressReqInnerFrame setAddressReqInnerFrame =
|
new C3SetAddressReqInnerFrame(c3Mac, address);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), setAddressReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3OperationReportInnerFrame operationReportInnerFrame = new A5C3OperationReportInnerFrame().transformFrame(commonFrame.getPayload());
|
if (operationReportInnerFrame.isValidate()) {
|
if ("操作成功".equals(operationReportInnerFrame.getState())) {
|
//修改成功需要更改数据库数据
|
C3mCharging one = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
one.setC3Mac(address);
|
updateById(one);
|
}
|
return operationReportInnerFrame.getState();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 设置日历（同心跳包中的6字节日期时间）
|
*
|
* @param c3Mac
|
* @return
|
*/
|
public String SetCalendar(String c3Mac, int year, int month, int day, int hour, int min, int sec) {
|
|
|
C3SetCalendarReqInnerFrame setCalendarReqInnerFrame =
|
new C3SetCalendarReqInnerFrame(c3Mac, year, month, day, hour, min, sec);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), setCalendarReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3OperationReportInnerFrame operationReportInnerFrame = new A5C3OperationReportInnerFrame().transformFrame(commonFrame.getPayload());
|
if (operationReportInnerFrame.isValidate()) {
|
return operationReportInnerFrame.getState();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 故障码上报清除
|
*
|
* @param c3Mac
|
* @return
|
*/
|
public String ClearedFaultCode(String c3Mac) {
|
|
|
C3ClearedFaultCodeReqInnerFrame clearedFaultCodeReqInnerFrame =
|
new C3ClearedFaultCodeReqInnerFrame(c3Mac);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), clearedFaultCodeReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3OperationReportInnerFrame operationReportInnerFrame = new A5C3OperationReportInnerFrame().transformFrame(commonFrame.getPayload());
|
if (operationReportInnerFrame.isValidate()) {
|
return operationReportInnerFrame.getState();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 恢复出厂值
|
*
|
* @param c3Mac
|
* @return
|
*/
|
public String RestoreFactoryValue(String c3Mac) {
|
|
|
C3RestoreFactoryValueReqInnerFrame restoreFactoryValueReqInnerFrame =
|
new C3RestoreFactoryValueReqInnerFrame(c3Mac);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), restoreFactoryValueReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3OperationReportInnerFrame operationReportInnerFrame = new A5C3OperationReportInnerFrame().transformFrame(commonFrame.getPayload());
|
if (operationReportInnerFrame.isValidate()) {
|
return operationReportInnerFrame.getState();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
/**
|
* 软重启
|
*
|
* @param c3Mac
|
*/
|
public String restartCharging(String c3Mac) {
|
C3RestartChargingReqInnerFrame c3RestartChargingReqInnerFrame =
|
new C3RestartChargingReqInnerFrame(c3Mac);
|
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_C3_DATA.getCode(), c3RestartChargingReqInnerFrame);
|
System.out.println(a5Frame + " -----a5Frame");
|
|
C3mCharging c3mCharging = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3Mac));
|
if (c3mCharging == null) {
|
throw new BusinessException("C3充电桩硬件mcu_udid不存在");
|
}
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(c3mCharging.getPoleDevicesCode(), a5Frame);
|
// CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC("32313243305008ff1a06ffff", a5Frame);
|
|
System.out.println(commonFrame + " -----commonFrame");
|
|
A5C3OperationReportInnerFrame operationReportInnerFrame = new A5C3OperationReportInnerFrame().transformFrame(commonFrame.getPayload());
|
|
if (operationReportInnerFrame.isValidate()) {
|
return operationReportInnerFrame.getState();
|
} else {
|
throw new BusinessException("数据校验错误，请重新请求");
|
}
|
}
|
|
public boolean addC3Charging(C3ChargingAddParam c3ChargingAddParam) {
|
C3mCharging one = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getMcuUdid, c3ChargingAddParam.getMcuUdid()));
|
if (one != null) {
|
throw new BusinessException("硬件设备已存在！");
|
}
|
|
if (c3ChargingAddParam.getC3Name() == null || c3ChargingAddParam.getMcuUdid() == null) {
|
throw new BusinessException("添加C3充电桩设备出错！");
|
}
|
C3mCharging c3mCharging = new C3mCharging();
|
c3mCharging.setMcuUdid(c3ChargingAddParam.getMcuUdid());
|
if (c3ChargingAddParam.getC3Name() != null) {
|
c3mCharging.setC3Name(c3ChargingAddParam.getC3Name());
|
}
|
c3mCharging.setC3Mac(c3ChargingAddParam.getC3Mac());
|
return save(c3mCharging);
|
}
|
|
public boolean updateC3ChargingName(C3ChargingAddParam c3ChargingAddParam) {
|
C3mCharging one = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Id, c3ChargingAddParam.getC3Id()));
|
if (one == null) {
|
throw new BusinessException("硬件设备不存在！");
|
}
|
|
if (c3ChargingAddParam.getC3Id() == null || c3ChargingAddParam.getC3Name() == null) {
|
throw new BusinessException("添加C3充电桩设备出错！");
|
}
|
C3mCharging c3mCharging = new C3mCharging();
|
c3mCharging.setC3Id(c3ChargingAddParam.getC3Id());
|
c3mCharging.setC3Name(c3ChargingAddParam.getC3Name());
|
return updateById(c3mCharging);
|
}
|
|
public C3mCharging getC3mByPoleId(Long poleId) {
|
PoleBinding one = bindingService.getOne(Wrappers.lambdaQuery(PoleBinding.class).eq(PoleBinding::getDeviceType, 2).eq(PoleBinding::getPoleId, poleId));
|
if (one == null) {
|
throw new BusinessException("未找到绑定关系");
|
}
|
return getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, one.getDeviceCode()));
|
}
|
|
|
}
|
