2021与蓝度共同重构项目,服务端
liuhaonan
2022-03-18 794ae298001fb0b06d7ae8d5b72b02350d340289
ximon-admin/src/main/java/com/sandu/ximon/admin/service/C3ChargingService.java
@@ -17,6 +17,7 @@
import com.sandu.ximon.admin.manager.iot.rrpc.mainboard.MainBoardInvokeSyncService;
import com.sandu.ximon.admin.utils.RedisUtils;
import com.sandu.ximon.dao.domain.C3mCharging;
import com.sandu.ximon.dao.domain.C3mChargingCharge;
import com.sandu.ximon.dao.mapper.C3mChargingMapper;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -34,6 +35,8 @@
@AllArgsConstructor
public class C3ChargingService extends BaseServiceImpl<C3mChargingMapper, C3mCharging> {
    private final C3mChargingChargeService c3mChargingChargeService;
    /**
     * 保存上报C3充电设备心跳数据
     *
@@ -41,6 +44,10 @@
     */
    public boolean saveReportData(String deviceName, A5C3HeartbeatReportInnerFrame.HeartBeatDataPackage heartBeatDataPackage) {
        C3mCharging one = getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getMcuUdid, deviceName));
        List<C3mChargingCharge> list = c3mChargingChargeService.list(Wrappers.lambdaQuery(C3mChargingCharge.class).eq(C3mChargingCharge::getC3Id, one.getC3Id()));
        if(list.size()==0){//费率表中没有此充电桩数据时  添加默认费率
            c3mChargingChargeService.initCharge((one.getC3Id()).intValue());
        }
        if (one == null) {
            //将设备信息添加到充电桩设备表