违停信息数据同步

src/main/java/com/sky/ioc/controller/life/ParkingController.java

@@ -1,6 +1,7 @@
 package com.sky.ioc.controller.life;
 
 import com.sky.ioc.entity.params.IocParam;
+import com.sky.ioc.service.Parking.IllegalParkingService;
 import com.sky.ioc.service.Parking.ParkService;
 import com.sky.ioc.service.Parking.ParkingService;
 import com.sky.ioc.tool.ReturnMsg;
@@ -36,6 +37,9 @@ public class ParkingController {
     @Autowired
     ParkService parkService;
 
+    @Autowired
+    IllegalParkingService illegalParkingService;
+
 
     @ApiOperation("查询智慧生活中智慧停车的核心指标")
     @PostMapping("getCoreIndicators")
@@ -90,7 +94,7 @@ public class ParkingController {
     @PostMapping("getParkingData")
     public ReturnMsg  getParkingData(){
 //        dateType   1.周，2.月，3.年
-        return parkService.getParkData();
+        return illegalParkingService.getIllegalParkingData();
     }
 
 

src/main/java/com/sky/ioc/entity/domain/parking/IllegalParking.java

@@ -0,0 +1,32 @@
+package com.sky.ioc.entity.domain.parking;
+
+import lombok.Data;
+
+@Data
+public class IllegalParking {
+
+    private  Integer id;
+
+    /**拥有者ID*/
+    private Integer userId;
+    /**拥有者*/
+    private String people;
+
+    /**单位ID*/
+    private String companyId;
+
+    /**单位名称*/
+    private String company;
+    /**车牌号*/
+    private String licencePlate;
+    /**违停时间*/
+    private String illegalTime;
+    /**离开时间*/
+    private String managerTime;
+
+    /**违规原因*/
+    private String illegalReason;
+
+
+
+}

src/main/java/com/sky/ioc/entity/params/IocParam.java

@@ -31,12 +31,7 @@ public class IocParam {
     /**
      * 分页数
      */
-    private Integer pageSize =10;
-
-    /**
-     * 分页数
-     */
-    private Integer page =1;
+    private Integer limit =5;
 
     /**
      * 日期范围

src/main/java/com/sky/ioc/mapper/IllegalParkingMapper.java

@@ -0,0 +1,9 @@
+package com.sky.ioc.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sky.ioc.entity.domain.parking.IllegalParking;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface IllegalParkingMapper extends BaseMapper<IllegalParking> {
+}

src/main/java/com/sky/ioc/service/Parking/IllegalParkingService.java

@@ -0,0 +1,8 @@
+package com.sky.ioc.service.Parking;
+
+import com.sky.ioc.tool.ReturnMsg;
+
+public interface IllegalParkingService {
+
+    ReturnMsg getIllegalParkingData();
+}

src/main/java/com/sky/ioc/service/Parking/ParkService.java

@@ -5,4 +5,7 @@ import com.sky.ioc.tool.ReturnMsg;
 public interface ParkService {
 
     ReturnMsg getParkData();
+
+
+
 }

src/main/java/com/sky/ioc/service/Parking/impl/IllegalParkingServiceImpl.java

@@ -0,0 +1,86 @@
+package com.sky.ioc.service.Parking.impl;
+
+import com.sky.ioc.entity.domain.parking.IllegalParking;
+import com.sky.ioc.entity.domain.parking.Parking;
+import com.sky.ioc.mapper.IllegalParkingMapper;
+import com.sky.ioc.mapper.job.TokenMapper;
+import com.sky.ioc.service.Parking.IllegalParkingService;
+import com.sky.ioc.tool.ReturnMsg;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
+import java.util.Map;
+import java.util.concurrent.ThreadLocalRandom;
+
+@Service
+@Slf4j
+public class IllegalParkingServiceImpl implements IllegalParkingService {
+
+
+    @Autowired
+    TokenMapper tokenMapper;
+
+    @Value("${sky.dataIp}")
+    private String dataIp;
+
+    @Autowired
+    IllegalParkingMapper illegalParkingMapper;
+
+    final static  String ILLEGAL_PARKING_URL="%s/api/parking/PARKING/illegalParking/list";
+    @Override
+    public ReturnMsg getIllegalParkingData() {
+        String url =   String.format(ILLEGAL_PARKING_URL,"http://"+dataIp)+"??pageNum=1&pageSize=1000";
+        Map<String,String> tokenMap = tokenMapper.getNewToken();
+        String token ="Bearer eyJhbGciOiJIUzUxMiJ9.eyJ1c2VyX2lkIjoxLCJ1c2VyX2tleSI6IjUwZTU1NTRkLWJjYzYtNGRhMS1iZDUxLWFhNTc3YzU4YTFiNCIsInVzZXJuYW1lIjoiYWRtaW4ifQ.X10VPYJfeeRTka7OtqNPOGMpL4QkW3fR_TfCKXCmO-yXbIIrr_40fcwiVnpXfYVENo_BvXWEACRd-Y6nXsbkog";
+        if(tokenMap!=null){
+            token = "Bearer "+tokenMap.get("token");
+        }
+        // 创建一个请求头对象
+        HttpHeaders httpHeaders = new HttpHeaders();
+        // 设置参数
+        httpHeaders.set("authorization", token);
+        // 创建一个响应体对象
+        HttpEntity<String> httpEntity = new HttpEntity(httpHeaders);
+        // 3.创建RestTemplate
+        RestTemplate restTemplate = new RestTemplate();
+        // 发送GET请求
+        ResponseEntity<Map> responseEntity = restTemplate.exchange(url, HttpMethod.GET, httpEntity, Map.class);
+        // 获取响应对象里的 body 对象
+        Map<String, Object> body = responseEntity.getBody();
+        // 获取状态码
+        Integer code = (Integer)body.get("code");
+        // 获取响应信息
+        String message = (String)body.get("msg");
+        if(code==200){
+            ThreadLocalRandom random = ThreadLocalRandom.current();
+            ArrayList list = (ArrayList) body.get("rows");
+            if(list!=null&&list.size()>0){
+                illegalParkingMapper.delete(null);
+                for (int i=0;i<list.size();i++){
+                    LinkedHashMap json = (LinkedHashMap) list.get(i);
+                    IllegalParking illegalParking = new IllegalParking();
+                    illegalParking.setId((Integer) json.get("id"));
+                    illegalParking.setLicencePlate(String.valueOf(json.get("illegalCardnumber")));
+                    illegalParking.setIllegalTime(String.valueOf(json.get("illegalTime")));
+                    illegalParking.setManagerTime(String.valueOf(json.get("managerTime")));
+                    illegalParking.setIllegalReason(String.valueOf(json.get("illegalReason")));
+                    illegalParkingMapper.insert(illegalParking);
+                }
+            }
+            return ReturnMsg.ok();
+
+        }else{
+            log.info("获取违停数据："+message);
+            return  ReturnMsg.fail(message);
+        }
+    }
+}