会员完善

src/main/java/com/charging/chargingparking/constant/ParkingConstant.java

@@ -8,4 +8,10 @@ public class ParkingConstant {
 
 
     public static final String RESPONSEKEY = "Response_AlarmInfoPlate";
+
+    public static final String OK = "ok";
+
+    public static final String OUTMESSAGE = "一路顺风";
+
+    public static final String INMESSAGE = "欢迎光临";
 }

src/main/java/com/charging/chargingparking/dto/ResponseAlarmInfoPlate.java

@@ -12,4 +12,6 @@ public class ResponseAlarmInfoPlate {
     private String info;
 
     private Integer plateid;
+
+    private String content;
 }

src/main/java/com/charging/chargingparking/scheduled/ParkingMemberTask.java

@@ -0,0 +1,78 @@
+package com.charging.chargingparking.scheduled;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.charging.chargingparking.entity.ParkingMember;
+import com.charging.chargingparking.entity.ParkingRecord;
+import com.charging.chargingparking.service.ParkingMemberService;
+import com.charging.chargingparking.service.ParkingRecordService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @author 墨鱼_mo
+ * @date 2022/6/6 0006 下午 2:04
+ */
+@Component
+@Slf4j
+@Transactional
+public class ParkingMemberTask {
+
+    @Autowired
+    private ParkingRecordService parkingRecordService;
+
+    @Autowired
+    private ParkingMemberService parkingMemberService;
+
+    //每日删掉不在停车场的过期会员
+    @Scheduled(cron = "0 59 23 ? * *")
+    public  void run() {
+        try{
+
+            QueryWrapper<ParkingMember> parkingMemberQueryWrapper = new QueryWrapper<>();
+            parkingMemberQueryWrapper.eq("cloud_del_flag",false);
+            parkingMemberQueryWrapper.lt("member_end_time",new Date());
+            List<ParkingMember> parkingMemberList = parkingMemberService.list(parkingMemberQueryWrapper);
+            if (parkingMemberList.size()>0){
+                for (ParkingMember parkingMember : parkingMemberList){
+                    try{
+                        QueryWrapper<ParkingRecord> parkingRecordQueryWrapper = new QueryWrapper<>();
+                        parkingRecordQueryWrapper.eq("car_num",parkingMember.getMemberCarNum());
+                        parkingRecordQueryWrapper.eq("park_id",parkingMember.getParkId());
+                        parkingRecordQueryWrapper.orderByDesc("create_time");
+                        parkingRecordQueryWrapper.last("LIMIT 1");
+                        ParkingRecord parkingRecord = parkingRecordService.getOne(parkingRecordQueryWrapper);
+                        if (parkingRecord == null){
+                            parkingMember.setCloudDelFlag(true);
+                            parkingMember.setUpdateTime(new Date());
+                            parkingMemberService.updateById(parkingMember);
+                        }else {
+                            if (parkingRecord.getOutParkingTime()!=null && "1".equals(parkingRecord.getReleaseStatus())){
+                                parkingMember.setCloudDelFlag(true);
+                                parkingMember.setUpdateTime(new Date());
+                                parkingMemberService.updateById(parkingMember);
+                            }
+                        }
+                    }catch (Exception ex){
+
+                    }
+
+
+                }
+            }
+
+
+        }catch (Exception ex){
+            log.error(ex.getMessage(),ex);
+        }
+
+
+
+
+    }
+}

src/main/java/com/charging/chargingparking/service/impl/ParkingChannelServiceImpl.java

@@ -89,7 +89,8 @@ public class ParkingChannelServiceImpl extends ServiceImpl<ParkingChannelMapper,
                 parkingRecord.setReleaseStatus("1");
                 parkingRecordService.updateById(parkingRecord);
                 ResponseAlarmInfoPlate responseAlarmInfoPlate = new ResponseAlarmInfoPlate();
-                responseAlarmInfoPlate.setInfo("ok");
+                responseAlarmInfoPlate.setInfo(ParkingConstant.OK);
+                responseAlarmInfoPlate.setContent(ParkingConstant.OUTMESSAGE);
                 map.put(ParkingConstant.RESPONSEKEY, responseAlarmInfoPlate);
                 return map;
             }

src/main/java/com/charging/chargingparking/service/impl/ParkingRecordServiceImpl.java

@@ -113,8 +113,9 @@ public class ParkingRecordServiceImpl extends ServiceImpl<ParkingRecordMapper, P
                 save(parkingRecord);
 
 
-                responseAlarmInfoPlate.setInfo("ok");
+                responseAlarmInfoPlate.setInfo(ParkingConstant.OK);
                 responseAlarmInfoPlate.setPlateid(parkingRecord.getPlateId());
+                responseAlarmInfoPlate.setContent(ParkingConstant.INMESSAGE);
                 map.put(ParkingConstant.RESPONSEKEY,responseAlarmInfoPlate);
                 return map;
             }
@@ -164,6 +165,7 @@ public class ParkingRecordServiceImpl extends ServiceImpl<ParkingRecordMapper, P
 
                 responseAlarmInfoPlate.setInfo("ok");
                 responseAlarmInfoPlate.setPlateid(parkingRecord.getPlateId());
+                responseAlarmInfoPlate.setContent(ParkingConstant.OUTMESSAGE);
                 map.put(ParkingConstant.RESPONSEKEY,responseAlarmInfoPlate);
                 return map;
             }