| | |
|---|
| | | UploadRealTimeMonitoringDataQuery query = new UploadRealTimeMonitoringDataQuery(); |
|---|
| | | BeanUtils.copyProperties(uploadRealTimeMonitoringData, query); |
|---|
| | | chargingOrderClient.chargeMonitoring(query); |
|---|
| | | GetChargingGunByCode code = new GetChargingGunByCode(); |
|---|
| | | code.setCharging_pile_code(uploadRealTimeMonitoringDataMessage.getCharging_pile_code()); |
|---|
| | | code.setCharging_gun_code(uploadRealTimeMonitoringDataMessage.getCharging_gun_code()); |
|---|
| | | TChargingGun chargingGun = chargingGunClient.getChargingGunByCode(code).getData(); |
|---|
| | | if(Objects.nonNull(chargingGun)){ |
|---|
| | | // 存储状态信息 |
|---|
| | | TFaultMessage faultMessage = new TFaultMessage(); |
|---|
| | | if(uploadRealTimeMonitoringDataMessage.getCharging_gun_status().equals(0) || uploadRealTimeMonitoringDataMessage.getCharging_gun_status().equals(1)){ |
|---|
| | | faultMessage.setSiteId(chargingGun.getSiteId()); |
|---|
| | | faultMessage.setChargingPileId(chargingGun.getChargingPileId()); |
|---|
| | | faultMessage.setChargingGunId(chargingGun.getId()); |
|---|
| | | switch (uploadRealTimeMonitoringDataMessage.getCharging_gun_status()){ |
|---|
| | | case 0: |
|---|
| | | faultMessage.setStatus(1); |
|---|
| | | chargingGun.setStatus(1); |
|---|
| | | break; |
|---|
| | | case 1: |
|---|
| | | faultMessage.setStatus(2); |
|---|
| | | chargingGun.setStatus(7); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | faultMessage.setDownTime(LocalDateTime.now()); |
|---|
| | | faultMessageClient.createFaultMessage(faultMessage); |
|---|
| | | }else { |
|---|
| | | switch (uploadRealTimeMonitoringDataMessage.getCharging_gun_status()){ |
|---|
| | | case 2: |
|---|
| | | chargingGun.setStatus(2); |
|---|
| | | break; |
|---|
| | | case 3: |
|---|
| | | chargingGun.setStatus(4); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | // 空闲 充电 查询是否该设备之前存在离线记录或者故障记录 |
|---|
| | | faultMessage = faultMessageClient.getFaultMessageByGunId(chargingGun.getId()).getData(); |
|---|
| | | if(Objects.nonNull(faultMessage)){ |
|---|
| | | faultMessage.setEndTime(LocalDateTime.now()); |
|---|
| | | faultMessageClient.updateFaultMessage(faultMessage); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | chargingGunClient.updateChargingGunById(chargingGun); |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
