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 { 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 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 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 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 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 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 c3ChargingBoList = c3mChargingMapper.listC3mChargingDto(c3ChargingParam.getKeyword()); 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())); } }