hbjzws 1 year ago
parent
commit
6c2868f3ed

+ 6 - 2
src/main/java/com/charging/chargingparking/service/impl/ParkingChannelServiceImpl.java

@@ -82,7 +82,10 @@ public class ParkingChannelServiceImpl extends ServiceImpl<ParkingChannelMapper,
             parkingChannel.setIpAddr(receiveDeviceDTO.getIpaddr());
             parkingChannel.setIpAddr(receiveDeviceDTO.getIpaddr());
             updateById(parkingChannel);
             updateById(parkingChannel);
         }
         }
-
+        if("d86f5987-ec8dc901".equals(parkingChannel.getChannelCode())){
+            log.warn("receiveDeviceInfo荆鹏院子停车场入口2-----荆鹏停车场入口1");
+            parkingChannel = getById("1");
+        }
 
 
         //设备序列号写入redis用来判断设备是否在线
         //设备序列号写入redis用来判断设备是否在线
         saveToRedis(parkingChannel);
         saveToRedis(parkingChannel);
@@ -91,9 +94,10 @@ public class ParkingChannelServiceImpl extends ServiceImpl<ParkingChannelMapper,
         //区别处理入口与出口通道逻辑
         //区别处理入口与出口通道逻辑
         JSONObject jsonObject = channelHandle(parkingChannel);
         JSONObject jsonObject = channelHandle(parkingChannel);
 
 
+        ParkingChannel finalParkingChannel = parkingChannel;
         CompletableFuture.runAsync(() -> {
         CompletableFuture.runAsync(() -> {
             //车辆进场修改停车场剩余车位
             //车辆进场修改停车场剩余车位
-            parkingInfoService.updateSurplusParkingNumber(jsonObject, parkingChannel);
+            parkingInfoService.updateSurplusParkingNumber(jsonObject, finalParkingChannel);
         });
         });