获取token和数据传输代码开发

base-common/src/main/java/com/ozs/common/constant/CacheConstants.java

@@ -12,6 +12,11 @@ public class CacheConstants
      */
     public static final String LOGIN_TOKEN_KEY = "login_tokens:";
 
+    /**
+     * 地址灾害 redis key
+     */
+    public static final String GEOHAZARDMONITOR_LOGIN_TOKEN_KEY = "geoHazardMonitor_login_tokens:";
+
     /**
      * 验证码 redis key
      */

base-common/src/main/java/com/ozs/common/constant/Constants.java

@@ -84,6 +84,11 @@ public class Constants
      */
     public static final String LOGIN_USER_KEY = "login_user_key";
 
+    /**
+     * 地址灾害令牌前缀
+     */  
+    public static final String GEOHAZARDMONITOR_KEY = "GeoHazardMonitor_key";
+
     /**
      * 用户ID
      */

base-common/src/main/java/com/ozs/common/core/domain/Result.java

@@ -0,0 +1,186 @@
+package com.ozs.common.core.domain;
+
+import com.ozs.common.constant.HttpStatus;
+import com.ozs.common.utils.StringUtils;
+
+import java.util.HashMap;
+
+/**
+ * 地址灾害操作消息提醒
+ *
+ * @author ruoyi
+ */
+public class Result extends HashMap<String, Object>
+{
+    private static final long serialVersionUID = 1L;
+
+    /** 状态码 */
+    public static final String CODE_TAG = "resultCode";
+
+    /** 返回内容 */
+    public static final String MSG_TAG = "message";
+
+    /** 数据对象 */
+    public static final String DATA_TAG = "data";
+
+    /**
+     * 初始化一个新创建的 AjaxResult 对象，使其表示一个空消息。
+     */
+    public Result()
+    {
+    }
+
+    /**
+     * 初始化一个新创建的 AjaxResult 对象
+     *
+     * @param resultCode 状态码
+     * @param message 返回内容
+     */
+    public Result(int resultCode, String message)
+    {
+        super.put(CODE_TAG, resultCode);
+        super.put(MSG_TAG, message);
+    }
+
+    /**
+     * 初始化一个新创建的 AjaxResult 对象
+     *
+     * @param resultCode 状态码
+     * @param message 返回内容
+     * @param data 数据对象
+     */
+    public Result(int resultCode, String message, Object data)
+    {
+        super.put(CODE_TAG, resultCode);
+        super.put(MSG_TAG, message);
+        if (StringUtils.isNotNull(data))
+        {
+            super.put(DATA_TAG, data);
+        }
+    }
+
+    /**
+     * 返回成功消息
+     *
+     * @return 成功消息
+     */
+    public static Result success()
+    {
+        return Result.success("操作成功");
+    }
+
+    /**
+     * 返回成功数据
+     *
+     * @return 成功消息
+     */
+    public static Result success(Object data)
+    {
+        return Result.success("操作成功", data);
+    }
+
+    /**
+     * 返回成功消息
+     *
+     * @param message 返回内容
+     * @return 成功消息
+     */
+    public static Result success(String message)
+    {
+        return Result.success(message, null);
+    }
+
+    /**
+     * 返回成功消息
+     *
+     * @param message 返回内容
+     * @param data 数据对象
+     * @return 成功消息
+     */
+    public static Result success(String message, Object data)
+    {
+        return new Result(HttpStatus.SUCCESS, message, data);
+    }
+
+    /**
+     * 返回警告消息
+     *
+     * @param message 返回内容
+     * @return 警告消息
+     */
+    public static Result warn(String message)
+    {
+        return Result.warn(message, null);
+    }
+
+    /**
+     * 返回警告消息
+     *
+     * @param msg 返回内容
+     * @param data 数据对象
+     * @return 警告消息
+     */
+    public static Result warn(String msg, Object data)
+    {
+        return new Result(HttpStatus.WARN, msg, data);
+    }
+
+    /**
+     * 返回错误消息
+     *
+     * @return 错误消息
+     */
+    public static Result error()
+    {
+        return Result.error("操作失败");
+    }
+
+    /**
+     * 返回错误消息
+     *
+     * @param message 返回内容
+     * @return 错误消息
+     */
+    public static Result error(String message)
+    {
+        return Result.error(message, null);
+    }
+
+    /**
+     * 返回错误消息
+     *
+     * @param message 返回内容
+     * @param data 数据对象
+     * @return 错误消息
+     */
+    public static Result error(String message, Object data)
+    {
+        return new Result(HttpStatus.ERROR, message, data);
+    }
+
+    /**
+     * 返回错误消息
+     *
+     * @param resultCode 状态码
+     * @param message 返回内容
+     * @return 错误消息
+     */
+    public static Result error(int resultCode, String message)
+    {
+        return new Result(resultCode, message, null);
+    }
+
+    /**
+     * 方便链式调用
+     *
+     * @param key 键
+     * @param value 值
+     * @return 数据对象
+     */
+    @Override
+    public Result put(String key, Object value)
+    {
+        super.put(key, value);
+        return this;
+    }
+}

base-common/src/main/java/com/ozs/common/utils/MinioUtils.java

@@ -1,19 +1,17 @@
 package com.ozs.common.utils;
 
-import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+
+import com.ozs.common.core.domain.AjaxResult;
 import io.minio.MinioClient;
 import io.minio.PutObjectArgs;
 import io.swagger.annotations.ApiImplicitParam;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.poi.ss.usermodel.DateUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.multipart.MultipartFile;
-
-import javax.annotation.PostConstruct;
 import java.io.InputStream;
 import java.util.HashMap;
 import java.util.Map;
@@ -21,16 +19,20 @@ import java.util.Map;
 @Slf4j
 @Component
 public class MinioUtils {
-    @Value("${minio.endpoint}")
+
+    @Value(value = "${minio.endpoint}")
     private String endpoint;
-    @Value("${minio.accessKey}")
+
+    @Value(value = "${minio.accessKey}")
     private String accessKey;
-    @Value("${minio.secretKey}")
+
+    @Value(value = "${minio.secretKey}")
     private String secretKey;
-    @Value("${minio.bucketName}")
+
+    @Value(value = "${minio.bucketName}")
     private String bucketName;
     
-
+    
 
     /**
      * 上传
@@ -48,6 +50,8 @@ public class MinioUtils {
         //添加自定义/用户元数据
         Map<String, String> userMetadata = new HashMap<>(10);
         userMetadata.put("My-Project", "Project One");
+
+
         MinioClient minioClient =
                 MinioClient.builder()
                         .endpoint(endpoint)
@@ -62,5 +66,6 @@ public class MinioUtils {
                         .userMetadata(userMetadata)
                         .build());
         imgInputStream.close();
+
     }
 }

base-framework/src/main/java/com/ozs/framework/web/service/TokenService.java

@@ -1,5 +1,6 @@
 package com.ozs.framework.web.service;
 
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
@@ -77,6 +78,33 @@ public class TokenService
         return null;
     }
 
+    /**
+     * 地址灾害获取token信息
+     *
+     * @return 用户信息
+     */
+    public String getGeoHazardMonitorToken(HttpServletRequest request)
+    {
+        // 获取请求携带的令牌
+        String token = getGeoToken(request);
+        if (StringUtils.isNotEmpty(token))
+        {
+            try
+            {
+                Claims claims = parseToken(token);
+                // 解析对应的权限
+                String uuid = (String) claims.get(Constants.GEOHAZARDMONITOR_KEY);
+                String userKey = getGeoHazardMonitorTokenKey(uuid);
+                String tokens = redisCache.getCacheObject(userKey);
+                return tokens;
+            }
+            catch (Exception e)
+            {
+            }
+        }
+        return null;
+    }
+
     /**
      * 设置用户身份信息
      */
@@ -118,6 +146,23 @@ public class TokenService
         return createToken(claims);
     }
 
+    /**
+     * 地址灾害创建令牌
+     *
+     * @return
+     */
+    public ArrayList<String> createGeoHazardMonitorToken() {
+        ArrayList<String> parameter = new ArrayList<>();
+        String token = IdUtils.fastUUID();
+        String tokenKey = getGeoHazardMonitorTokenKey(token);
+        parameter.add(String.valueOf(System.currentTimeMillis() + expireTime * MILLIS_MINUTE));
+        redisCache.setCacheObject(tokenKey, token, expireTime, TimeUnit.MINUTES);
+        Map<String, Object> claims = new HashMap<>();
+        claims.put(Constants.GEOHAZARDMONITOR_KEY, token);
+        parameter.add(createToken(claims));
+        return parameter;
+    }
+
     /**
      * 验证令牌有效期，相差不足20分钟，自动刷新缓存
      *
@@ -219,8 +264,29 @@ public class TokenService
         return token;
     }
 
+    /**
+     * 获取请求token
+     *
+     * @param request
+     * @return token
+     */
+    private String getGeoToken(HttpServletRequest request)
+    {
+        String token = request.getHeader("token");
+        if (StringUtils.isNotEmpty(token) && token.startsWith(Constants.TOKEN_PREFIX))
+        {
+            token = token.replace(Constants.TOKEN_PREFIX, "");
+        }
+        return token;
+    }
+
     private String getTokenKey(String uuid)
     {
         return CacheConstants.LOGIN_TOKEN_KEY + uuid;
     }
+
+    private String getGeoHazardMonitorTokenKey(String uuid)
+    {   
+        return CacheConstants.GEOHAZARDMONITOR_LOGIN_TOKEN_KEY + uuid;
+    }
 }

base-system/src/main/java/com/ozs/system/domain/vo/ReqMsgAlarmVo.java

@@ -0,0 +1,53 @@
+package com.ozs.system.domain.vo;
+
+import com.ozs.common.core.domain.entity.SysDept;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author Administrator
+ * 报警信息请求参数
+ */
+@Data
+public class ReqMsgAlarmVo implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /** 主键ID */
+    private Long alarmId;
+
+    /** 报警时间 */
+    private String alarmTime;
+
+    /** 相机编码 */
+    private Long alarmCamera;
+
+    /** 报警里程位置 */
+    private String alarmMile;
+
+    /** 报警内容 */
+    private String content;
+
+    /** 报警置信度（百分比） */
+    private String alarmConfidence;
+
+    /** 报警行别 */
+    private Integer lineDir;
+
+    /** 报警病害类型（目前只有1泥石流，后续可扩展使用） */
+    private Integer alarmType;
+
+    /** 报警病害属性（可以给出泥石流的框定范围） */
+    private String alarmArrr;
+
+    private String files;
+
+    /** 报警图片地址 */
+    private String imageUrl;
+
+    /** 报警是否解除 1已解除2未解除 */
+    private Integer isLock;
+}

base-system/src/main/java/com/ozs/system/domain/vo/RespGeoHazardMonitorVo.java

@@ -0,0 +1,27 @@
+package com.ozs.system.domain.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 地址灾害获取token返回参数
+ * @author Administrator
+ */
+@Data
+public class RespGeoHazardMonitorVo implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+    /**
+     * 访问令牌
+     */
+    private String accessToken;
+    /**
+     * 过期时间，单位秒
+     */
+    private Long expiresIn;
+    /**
+     * 令牌类型
+     */
+    private String  tokenType;
+}

base-system/src/main/java/com/ozs/system/domain/vo/RespMsgAlarmVo.java

@@ -0,0 +1,27 @@
+package com.ozs.system.domain.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author Administrator
+ * 报警信息请求参数
+ */
+@Data
+public class RespMsgAlarmVo implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /** 主键ID */
+    private Long alarmId;
+
+    /** 报警解除时间 */
+    private String cancelTime;
+
+    /** 相机编码 */
+    private Long alarmCamera;
+    
+    /** 报警是否解除 1已解除2未解除 */
+    private Integer isCancel;
+}