| | |
|---|
| | | TChargingPile chargingPile = chargingPileService.getOne(new LambdaQueryWrapper<TChargingPile>() |
|---|
| | | .eq(TChargingPile::getCode, code).eq(TChargingPile::getDelFlag, 0)); |
|---|
| | | if(null != chargingPile){ |
|---|
| | | if(chargingPile.getStatus() == 1){ |
|---|
| | | //充电桩正常，返回异常，处理充电桩状态和添加故障记录 |
|---|
| | | if(chargingPile.getStatus() == 1 && 1 == status){ |
|---|
| | | TFaultMessage faultMessage = faultMessageService.getOne(new LambdaQueryWrapper<TFaultMessage>().eq(TFaultMessage::getChargingPileId, chargingPile.getId()) |
|---|
| | | .eq(TFaultMessage::getStatus, 2).eq(TFaultMessage::getDelFlag, 0).isNull(TFaultMessage::getEndTime)); |
|---|
| | | if(null == faultMessage){ |
|---|
| | |
|---|
| | | one.setEndTime(LocalDateTime.now()); |
|---|
| | | faultMessageService.updateById(one); |
|---|
| | | } |
|---|
| | | |
|---|
| | | chargingPile.setStatus(0 == status ? 1 : 3); |
|---|
| | | chargingPileService.updateById(chargingPile); |
|---|
| | | } |
|---|
| | | if(0 == status){ |
|---|
| | | redisService.getCacheMap("charging_pile_online").put(code, System.currentTimeMillis()); |
|---|
| | | Map<String, Object> charging_pile_online = redisService.getCacheMap("charging_pile_online"); |
|---|
| | | charging_pile_online.put(code, System.currentTimeMillis()); |
|---|
| | | redisService.setCacheMap("charging_pile_online", charging_pile_online); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
