integrated_traffic/src/main/java/com/zcloud/util/PLSUtil.java

package com.zcloud.util;

import com.alibaba.fastjson.JSONObject;
import com.zcloud.entity.PageData;
import com.zcloud.service.corp.CorpPlsInfoService;
import com.zcloud.service.system.UsersService;
import okhttp3.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;

import javax.annotation.PostConstruct;
import java.io.IOException;
import java.util.*;

@Component
public class PLSUtil {
    private static final Logger logger = LoggerFactory.getLogger(PLSUtil.class);

    private static CorpPlsInfoService corpplsinfoService;
    private static UsersService usersService;
    // 后台地址
    public static HashMap<String, String> BAKEADDR = new HashMap<>();
    private static RestTemplate restTemplate;

    public static JSONObject getPersonnelPositioningCount(String CORPINFO_ID, Integer currentPage, Integer showCount) throws Exception {
        HttpHeaders headers = new HttpHeaders();
        headers.set("Authorization", getToken(CORPINFO_ID));
        HttpEntity<JSONObject> httpEntity = new HttpEntity<>(headers);
        ResponseEntity<JSONObject> exchange = restTemplate.exchange(
                PLSUtil.BAKEADDR.get(CORPINFO_ID) + "/deploy/card/list?sortThePowerLevel=1&pageNum=" +
                        currentPage +
                        "&pageSize=" + showCount,
                HttpMethod.GET, httpEntity,
                JSONObject.class);
        return exchange.getBody();
    }

    @Autowired
    public void setCorpplsinfoService(CorpPlsInfoService corpplsinfoServicebean, UsersService usersServicebean, RestTemplate restTemplatebean) {
        corpplsinfoService = corpplsinfoServicebean;
        usersService = usersServicebean;
        restTemplate = restTemplatebean;
    }

    /**
     * @Description: 告警类型统计
     * @Author: dearLin
     * @Date: 2024/1/25/025 14:37
     * @Param: [java.lang.String, java.lang.Integer, java.lang.Integer] [keywords, currentPage, showCount]
     * @Return: com.alibaba.fastjson.JSONObject
     */
    public static JSONObject getAlarmTypeCount(String CORPINFO_ID) throws Exception {
        HttpHeaders headers = new HttpHeaders();
        headers.set("Authorization", getToken(CORPINFO_ID));
        HttpEntity<JSONObject> httpEntity = new HttpEntity<>(headers);
        ResponseEntity<JSONObject> exchange = restTemplate.exchange(
                PLSUtil.BAKEADDR.get(CORPINFO_ID) + "/region/alarm/alarmStatistics?type=day",
                HttpMethod.GET, httpEntity,
                JSONObject.class);
        return exchange.getBody();
    }


    /**
     * @Description: 添加摄像头
     * @Author: dearLin
     * @Date: 2024/1/25/025 14:37
     * @Param: [java.lang.String, java.lang.Integer, java.lang.Integer] [keywords, currentPage, showCount]
     * @Return: com.alibaba.fastjson.JSONObject
     */
    public static JSONObject saveCamera(String CORPINFO_ID, PageData camera) throws Exception {
        HttpHeaders headers = new HttpHeaders();
        headers.set("Authorization", getToken(CORPINFO_ID));
        headers.setContentType(org.springframework.http.MediaType.valueOf("application/json"));
        JSONObject uriVariables = new JSONObject();
        uriVariables.put("camNo", camera.getString("CODE"));
        uriVariables.put("camName", camera.getString("VIDEONAME"));
        uriVariables.put("camIp", "127.0.0.1");
        uriVariables.put("type", "0");
        uriVariables.put("port", "");
        uriVariables.put("camUserName", "1");
        uriVariables.put("camPassword", "1");
        uriVariables.put("lon", "");
        uriVariables.put("lat", "");
        uriVariables.put("alt", "");
        HttpEntity<JSONObject> httpEntity = new HttpEntity<>(uriVariables, headers);
//        HttpEntity<JSONObject> httpEntity = new HttpEntity<>(uriVariables,headers);
//        ResponseEntity<JSONObject> jsonObjectResponseEntity = restTemplate.postForEntity(PLSUtil.BAKEADDR.get(CORPINFO_ID) + "/device/camera",
//                httpEntity, JSONObject.class);


        ResponseEntity<JSONObject> exchange = restTemplate.exchange(PLSUtil.BAKEADDR.get(CORPINFO_ID) + "/device/camera",
                HttpMethod.POST,
                httpEntity,
                JSONObject.class);
        return exchange.getBody();
    }

    /**
     * @Description: 修改摄像头
     * @Author: dearLin
     * @Date: 2024/1/25/025 14:37
     * @Param: [java.lang.String, java.lang.Integer, java.lang.Integer] [keywords, currentPage, showCount]
     * @Return: com.alibaba.fastjson.JSONObject
     */
    public static JSONObject editCamera(String CORPINFO_ID, PageData camera) throws Exception {
        HttpHeaders headers = new HttpHeaders();
        headers.set("Authorization", getToken(CORPINFO_ID));
        headers.setContentType(org.springframework.http.MediaType.valueOf("application/json"));
        JSONObject uriVariables = new JSONObject();
        uriVariables.put("camNo", camera.getString("CODE"));
        uriVariables.put("camName", camera.getString("VIDEONAME"));
        uriVariables.put("camId", camera.getString("PLS_ID"));
        HttpEntity<JSONObject> httpEntity = new HttpEntity<>(uriVariables, headers);
        ResponseEntity<JSONObject> exchange = restTemplate.exchange(PLSUtil.BAKEADDR.get(CORPINFO_ID) + "/device/camera",
                HttpMethod.PUT, httpEntity,
                JSONObject.class, uriVariables);
        return exchange.getBody();
    }

    /**
     * @Description: 删除摄像头
     * @Author: dearLin
     * @Date: 2024/1/25/025 14:37
     * @Param: [java.lang.String, java.lang.Integer, java.lang.Integer] [keywords, currentPage, showCount]
     * @Return: com.alibaba.fastjson.JSONObject
     */
    public static JSONObject removeCamera(String CORPINFO_ID, PageData camera) throws Exception {
        HttpHeaders headers = new HttpHeaders();
        headers.set("Authorization", getToken(CORPINFO_ID));
        HttpEntity<JSONObject> httpEntity = new HttpEntity<>(headers);
        ResponseEntity<JSONObject> exchange = restTemplate.exchange(PLSUtil.BAKEADDR.get(CORPINFO_ID) + "/device/camera/" + Integer.parseInt(camera.getString("PLS_ID")), HttpMethod.DELETE, httpEntity, JSONObject.class);
        return exchange.getBody();
    }


    /**
     * @Description: 电子围栏列表
     * @Author: dearLin
     * @Date: 2024/1/25/025 14:37
     * @Param: [java.lang.String, java.lang.Integer, java.lang.Integer] [keywords, currentPage, showCount]
     * @Return: com.alibaba.fastjson.JSONObject
     */
    public static JSONObject getRyRegionList(String CORPINFO_ID, String keywords, Integer currentPage, Integer showCount) throws Exception {
        HttpHeaders headers = new HttpHeaders();

        headers.set("Authorization", getToken(CORPINFO_ID));
        HttpEntity<JSONObject> httpEntity = new HttpEntity<>(headers);
        ResponseEntity<JSONObject> exchange = restTemplate.exchange(PLSUtil.BAKEADDR.get(CORPINFO_ID) + "/region/region/list?pageNum=" +
                currentPage +
                "&pageSize=" + showCount +
                "&str=" + keywords + "&type=0", HttpMethod.GET, httpEntity, JSONObject.class);
        return exchange.getBody();
    }

    /**
     * @Description: 电子围栏详情
     * @Param: [java.lang.String, java.lang.Integer] [CORPINFO_ID, id]
     * @Return: com.alibaba.fastjson.JSONObject
     */
    public static JSONObject getRyRegionInfo(String CORPINFO_ID, int id) throws Exception {
        HttpHeaders headers = new HttpHeaders();

        headers.set("Authorization", getToken(CORPINFO_ID));
        HttpEntity<JSONObject> httpEntity = new HttpEntity<>(headers);
        ResponseEntity<JSONObject> exchange = restTemplate.exchange(PLSUtil.BAKEADDR.get(CORPINFO_ID) + "/region/region/" +
                id, HttpMethod.GET, httpEntity, JSONObject.class);
        return exchange.getBody();
    }

    /**
     * @Description:    当前在线人员实时位置信息
     * @Date: 2024/1/25/025 14:37
     * @Return: com.alibaba.fastjson.JSONObject
     */
    public static JSONObject getRealTimeList(String CORPINFO_ID) throws Exception {
        HttpHeaders headers = new HttpHeaders();

        headers.set("Authorization", getToken(CORPINFO_ID));
        HttpEntity<JSONObject> httpEntity = new HttpEntity<>(headers);
        ResponseEntity<JSONObject> exchange = restTemplate.exchange(PLSUtil.BAKEADDR.get(CORPINFO_ID) + "/api/prod-api/coordinate/realTime/data", HttpMethod.GET, httpEntity, JSONObject.class);
        return exchange.getBody();
    }

    /**
     * @Description: 根据定位卡号获取人是否再电子围栏里
     * @Author: dearLin
     * @Date: 2024/1/25/025 14:37
     * @Param: [java.lang.String, java.lang.Integer, java.lang.Integer] [keywords, currentPage, showCount]
     * @Return: com.alibaba.fastjson.JSONObject
     */
    public static Boolean determineWhetherThePersonIsInTheElectronicFence(String CORPINFO_ID, Integer PLS_ID, String ELECTRONIC_FENCE_ID) throws Exception {
        HttpHeaders headers = new HttpHeaders();
        headers.set("Authorization", getToken(CORPINFO_ID));
        HttpEntity<JSONObject> httpEntity = new HttpEntity<>(headers);
        ResponseEntity<Boolean> exchange = restTemplate.exchange(PLSUtil.BAKEADDR.get(CORPINFO_ID) + "/region/api/electronicFence/determineWhetherThePersonIsInTheElectronicFence2?psn=" +
                PLS_ID +
                "&id=" + ELECTRONIC_FENCE_ID, HttpMethod.GET, httpEntity, Boolean.class);
        return exchange.getBody();
    }


    @PostConstruct
    private void initBakeAddr() throws Exception {
        List<PageData> dataList = corpplsinfoService.listAll(new PageData());
        dataList.forEach(item -> {
            BAKEADDR.put(item.getString("CORPINFO_ID"), item.getString("POST_URL"));
        });
    }

    /**
     * @Description: 获取token
     * @Author: dearLin
     * @Date: 2024/1/24/024 9:59
     * @Param: [] []
     * @Return: java.lang.String
     */
    public static String getToken(String CORPINFO_ID) throws Exception {
        PageData pd = new PageData();
        pd.put("CORPINFO_ID", CORPINFO_ID);
        pd = corpplsinfoService.findById(pd);
        String token = pd.getString("TOKEN");
        String backAddr = pd.getString("POST_URL");
        String expireTime = pd.getString("EXPIRE_TIME");
        String userName = pd.getString("ACCOUNT");
        String passWord = pd.getString("PASSWORD");
        String loginUrl = pd.getString("POST_URL") + "/auth/login";
        if (token == null || expireTime == null || expireTime.trim().isEmpty() || DateUtil.compareDate(DateUtil.getTime(), expireTime)) {
            JSONObject loginPayload = new JSONObject();
            loginPayload.put("username", userName);
            loginPayload.put("password", passWord);
            loginPayload.put("isPresentationMode", "2");
            PageData response = sendPostHttpRequest(loginUrl, loginPayload.toJSONString(), null);
            if (response != null) {
                PageData valueData = JSONObject.parseObject(response.getString("data"), PageData.class);
                token = valueData.getString("access_token");
                String newExpireTime = DateUtil.getAfterHourDate("12");
                pd.put("TOKEN", token);
                pd.put("EXPIRE_TIME", newExpireTime);
                corpplsinfoService.edit(pd);
                return token;
            } else {
                System.out.println("登录失败");
            }
        }
        return token;
    }


    /**
     * @Description: 查询这个人的定位卡号是否存在
     * @Author: dearLin
     * @Date: 2024/1/24/024 10:00
     * @Param: [com.zcloud.entity.PageData] [user]
     * @Return: void
     */
    public static boolean hasCardNumber(PageData user) throws Exception {
        // 根据 定位卡号获取对应的人
        String url = BAKEADDR.get(Jurisdiction.getCORPINFO_ID()) + "/deploy/card/peopleDisplay/" + user.getString("CARDNO");
        PageData response = sendGetHttpRequest(url, null, getToken(Jurisdiction.getCORPINFO_ID()));
        if (response != null) {
            if (!"200".equals(response.getString("code"))) {
                return false;
            }
            List<PageData> dataList = JSONObject.parseArray(response.getString("data"), PageData.class);
            return dataList.isEmpty();
        }
        return false;
    }

    /**
     * @Description: 查询这个人的定位卡号是否存在
     * @Author: dearLin
     * @Date: 2024/1/24/024 10:00
     * @Param: [com.zcloud.entity.PageData] [user]
     * @Return: void
     */
    public static PageData getCardNumberPeople(PageData user) throws Exception {
        // 根据 定位卡号获取对应的人
        String url = BAKEADDR.get(Jurisdiction.getCORPINFO_ID()) + "/deploy/card/peopleDisplay/" + user.getString("CARDNO");
        PageData response = sendGetHttpRequest(url, null, getToken(Jurisdiction.getCORPINFO_ID()));
        if (response != null) {
            if (!"200".equals(response.getString("code"))) {
                return null;
            }
            List<PageData> dataList = JSONObject.parseArray(response.getString("data"), PageData.class);
            return dataList.size() > 0 ? dataList.get(0) : null;
        }
        return null;
    }

    /**
     * @Description: 把人新增到 人员定位系统
     * @Author: dearLin
     * @Date: 2024/1/24/024 10:00
     * @Param: [com.zcloud.entity.PageData] [user]
     * @Return: void
     */
    public static PageData saveUser(PageData user) throws Exception {
        String url = BAKEADDR.get(Jurisdiction.getCORPINFO_ID()) + "/deploy/psnmgt/insertPsnIfon";
        JSONObject loginPayload = new JSONObject();
        loginPayload.put("name", user.getString("NAME"));
        loginPayload.put("cardNo", user.getString("CARDNO"));
        loginPayload.put("empNo", "");
        loginPayload.put("sex", "");
        loginPayload.put("certType", "");
        loginPayload.put("certNo", "");
        loginPayload.put("office", "");
        loginPayload.put("staffType", "");
        loginPayload.put("phone", "");
        loginPayload.put("empId", "");
        loginPayload.put("age", "");
        loginPayload.put("addr", "");
        loginPayload.put("remark", "");
        loginPayload.put("enterpriseName", "");
        loginPayload.put("officeName", "");
        loginPayload.put("jobsName", "");
        loginPayload.put("deptName", "");
        loginPayload.put("deptId", "");
        loginPayload.put("avatar", "");
        return sendPostHttpRequest(url, loginPayload.toJSONString(), getToken(Jurisdiction.getCORPINFO_ID()));

    }

    /**
     * @Description: 把人新增到 人员定位系统
     * @Author: dearLin
     * @Date: 2024/1/24/024 10:00
     * @Param: [com.zcloud.entity.PageData] [user]
     * @Return: void
     */
    public static boolean editUser(PageData user) throws Exception {
        // 这个人没有卡号与人id的话
        if (!Tools.notEmpty(user.getString("PLS_ID"))) {
            PageData response = saveUser(user);
            if ("200".equals(response.getString("code"))) {
                user.put("PLS_ID", response.getString("data"));
                return true;
            }
            return false;
        }
        String url = BAKEADDR.get(Jurisdiction.getCORPINFO_ID()) + "/deploy/psnmgt/updPsnInfoById";
        JSONObject loginPayload = new JSONObject();
        loginPayload.put("name", user.getString("NAME"));
        loginPayload.put("psnId", user.getString("PLS_ID"));
        loginPayload.put("cardNo", user.getString("CARDNO"));
        loginPayload.put("empNo", "");
        loginPayload.put("sex", "");
        loginPayload.put("certType", "");
        loginPayload.put("certNo", "");
        loginPayload.put("office", "");
        loginPayload.put("staffType", "");
        loginPayload.put("phone", "");
        loginPayload.put("empId", "");
        loginPayload.put("age", "");
        loginPayload.put("addr", "");
        loginPayload.put("remark", "");
        loginPayload.put("enterpriseName", "");
        loginPayload.put("officeName", "");
        loginPayload.put("jobsName", "");
        loginPayload.put("deptName", "");
        loginPayload.put("deptId", "");
        loginPayload.put("avatar", "");
        PageData response = sendPostHttpRequest(url, loginPayload.toJSONString(), getToken(Jurisdiction.getCORPINFO_ID()));
        return "200".equals(response.getString("code"));
    }

    public static boolean removeUser(PageData user) throws Exception {
        String url = BAKEADDR.get(Jurisdiction.getCORPINFO_ID()) + "/deploy/psnmgt";
        PageData removeUser = usersService.findById(user);
        PageData response = sendDeleteHttpRequest(url, Long.parseLong(removeUser.getString("PLS_ID")), getToken(Jurisdiction.getCORPINFO_ID()));
        return "200".equals(response.getString("code"));
    }

    /**
     * 发送get类型请求
     *
     * @param url
     * @param queryParams
     * @param token
     * @return PageData
     * @throws IOException
     */

    private static PageData sendGetHttpRequest(String url, Map<String, String> queryParams, String token) throws IOException {
        OkHttpClient client = new OkHttpClient();

        HttpUrl.Builder httpBuilder = Objects.requireNonNull(HttpUrl.parse(url)).newBuilder();
        //封装请求参数
        if (queryParams != null) {
            for (Map.Entry<String, String> param : queryParams.entrySet()) {
                httpBuilder.addQueryParameter(param.getKey(), param.getValue());
            }
        }
        //设置请求的url
        Request.Builder requestBuilder = new Request.Builder()
                .url(httpBuilder.build());

        if (token != null && !token.isEmpty()) {
            requestBuilder.addHeader("Authorization", "Bearer " + token);
        }

        Request request = requestBuilder.build();
        Response execute = client.newCall(request).execute();
        if (execute.code() != 200) {
            logger.error("get请求失败，返回状态码：{},url:{}", execute.code(), url);
            throw new RuntimeException("get请求失败");
        }
        return JSONObject.parseObject(execute.body().string(), PageData.class);
        //发送请求并返回响应数据
    }


    /**
     * 发送post类型请求
     *
     * @param url
     * @param jsonPayload
     * @param token
     * @return
     * @throws IOException
     */
    private static PageData sendPostHttpRequest(String url, String jsonPayload, String token) throws IOException {
        OkHttpClient client = new OkHttpClient();
        MediaType JSON = MediaType.parse("application/json; charset=utf-8");
        RequestBody body = RequestBody.create(JSON, jsonPayload);
        Request.Builder builder = new Request.Builder() // 构建一个新的Request对象。
                .url(url)// 设置请求的URL。
                .post(body);// 设置请求的方法为POST，并设置请求体。
        //构建请求头
        if (token != null && !token.isEmpty()) {// 检查token是否存在且不为空。
            builder.addHeader("Authorization", "Bearer " + token);
        }

        // 构建请求
        Request request = builder.build();
        Response execute = client.newCall(request).execute();
        if (execute.code() != 200) {
            logger.error("post请求失败，返回状态码：{},url:{}", execute.code(), url);
            throw new RuntimeException("get请求失败");
        }
        PageData pageData = JSONObject.parseObject(execute.body().string(), PageData.class);
        if (!"200".equals(pageData.getString("code"))) {
            logger.error("post请求失败，返回值：{},url:{}", pageData.getString("msg"), url);
        }
        return pageData;
        //发起请求并响应数据
    }

    /**
     * 发送PUT类型请求
     *
     * @param url
     * @param jsonPayload
     * @param token
     * @return
     * @throws IOException
     */
    private static Response sendPutHttpRequest(String url, String jsonPayload, String token) throws IOException {
        OkHttpClient client = new OkHttpClient();
        MediaType JSON = MediaType.parse("application/json; charset=utf-8");
        RequestBody body = RequestBody.create(JSON, jsonPayload);
        Request.Builder builder = new Request.Builder()
                .url(url)
                .put(body);
        if (token != null && !token.isEmpty()) {
            builder.addHeader("Authorization", "Bearer " + token);
        }
        Request request = builder.build();

        return client.newCall(request).execute();
    }

    /**
     * 发送delete类型请求
     *
     * @param url
     * @param camIds
     * @param token
     * @return
     * @throws IOException
     */
    private static PageData sendDeleteHttpRequest(String url, Long camIds, String token) throws IOException {
        OkHttpClient client = new OkHttpClient();
        //将要删除的Id列表转换为逗号分隔的字符串
        //构建完整的url
        url = url + "/" + camIds;

        Request.Builder builderBuilder = new Request.Builder()
                .url(url)
                .delete();

        if (token != null && !token.isEmpty()) {
            builderBuilder.addHeader("Authorization", "Bearer " + token);
        }

        Request request = builderBuilder.build();
        Response execute = client.newCall(request).execute();
        if (execute.code() != 200) {
            logger.error("post请求失败，返回状态码：{},url:{}", execute.code(), url);
            throw new RuntimeException("get请求失败");
        }
        PageData pageData = JSONObject.parseObject(execute.body().string(), PageData.class);
        if (!"200".equals(pageData.getString("code"))) {
            logger.error("post请求失败，返回值：{},url:{}", pageData.getString("msg"), url);
        }
        return pageData;
    }

    /**
     * 获取区域内随机坐标点
     *
     * @param polygon [[lng,lat,alt],[lng,lat,alt],[lng,lat,alt],...]
     * @return [lng,lat,alt]
     * @throws IOException
     */
    public static List<String> getRandomPointInPolygon(List<List<Double>> polygon) {
        double minX = Double.POSITIVE_INFINITY;
        double minY = Double.POSITIVE_INFINITY;
        double maxX = Double.NEGATIVE_INFINITY;
        double maxY = Double.NEGATIVE_INFINITY;

        for (List<Double> point : polygon) {
            minX = Math.min(minX, point.get(0));
            minY = Math.min(minY, point.get(1));
            maxX = Math.max(maxX, point.get(0));
            maxY = Math.max(maxY, point.get(1));
        }

        Random rand = new Random();
        while (true) {
            Double x = minX + rand.nextDouble() * (maxX - minX);
            Double y = minY + rand.nextDouble() * (maxY - minY);

            if (pointInPolygon(polygon, x, y)) {
                List<String> point = Arrays.asList(x.toString(),y.toString(),polygon.get(0).get(2).toString());
                return point;
            }
        }
    }

    /**
     * 判断点是否在多边形内
     * @param polygon
     * @param lng
     * @param lat
     * @return
     */
    private static boolean pointInPolygon(List<List<Double>> polygon,double lng, double lat) {
        boolean inside = false;
        int n = polygon.size();
        for (int i = 0, j = n - 1; i < n; j = i++) {
            if (((polygon.get(i).get(1) > lat) != (polygon.get(j).get(1) > lat)) &&
                    (lng < (polygon.get(j).get(0) - polygon.get(i).get(0)) * (lat - polygon.get(i).get(1)) / (polygon.get(j).get(1) - polygon.get(i).get(1)) + polygon.get(i).get(0))) {
                inside = !inside;
            }
        }
        return inside;
    }
}