From b91fdc439ca1ba0b98409de0f1c0edf6fd626ee9 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: Fri, 21 Jul 2023 14:16:35 +0800
Subject: [PATCH] 增加app一键报警
---
src/main/java/com/ard/alarm/apponekey/service/impl/ArdAlarmApponekeyServiceImpl.java | 111 +++++
src/main/java/com/ard/utils/hiksdk/util/minio/MinioUtils.java | 7
src/main/java/com/ard/utils/uuid/IdUtils.java | 50 ++
src/main/java/com/ard/alarm/apponekey/controller/ArdAlarmApponekeyController.java | 40 ++
src/main/java/com/ard/utils/http/HttpStatus.java | 95 ++++
src/main/java/com/ard/utils/http/AjaxResult.java | 204 ++++++++++
src/main/java/com/ard/alarm/apponekey/service/IArdAlarmApponekeyService.java | 61 +++
src/main/java/com/ard/alarm/apponekey/mapper/ArdAlarmApponekeyMapper.java | 63 +++
src/main/java/com/ard/alarm/apponekey/domain/ArdAlarmApponekey.java | 40 ++
src/main/java/com/ard/utils/uuid/UUID.java | 485 ++++++++++++++++++++++++
10 files changed, 1,154 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/ard/alarm/apponekey/controller/ArdAlarmApponekeyController.java b/src/main/java/com/ard/alarm/apponekey/controller/ArdAlarmApponekeyController.java
new file mode 100644
index 0000000..eb9295d
--- /dev/null
+++ b/src/main/java/com/ard/alarm/apponekey/controller/ArdAlarmApponekeyController.java
@@ -0,0 +1,40 @@
+package com.ard.alarm.apponekey.controller;
+
+import com.ard.utils.hiksdk.util.minio.MinioUtils;
+import com.ard.utils.http.AjaxResult;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import com.ard.alarm.apponekey.domain.ArdAlarmApponekey;
+import com.ard.alarm.apponekey.service.IArdAlarmApponekeyService;
+import org.springframework.web.multipart.MultipartFile;
+
+
+/**
+ * app一键报警Controller
+ *
+ * @author ard
+ * @date 2023-07-21
+ */
+@RestController
+@RequestMapping("/alarm/apponekey")
+public class ArdAlarmApponekeyController {
+ @Autowired
+ private IArdAlarmApponekeyService ardAlarmApponekeyService;
+
+
+ /**
+ * 新增app一键报警
+ */
+ @PostMapping
+ public AjaxResult add(String userId,String name, Double longitude,Double latitude,Double altitude,MultipartFile file) {
+ String url = MinioUtils.putObjectAndGetUrl("record", file);
+ ArdAlarmApponekey ardAlarmApponekey =new ArdAlarmApponekey();
+ ardAlarmApponekey.setUserId(userId);
+ ardAlarmApponekey.setName(name);
+ ardAlarmApponekey.setLongitude(longitude);
+ ardAlarmApponekey.setLatitude(latitude);
+ ardAlarmApponekey.setAltitude(altitude);
+ ardAlarmApponekey.setRecordUrl(url);
+ return AjaxResult.success(ardAlarmApponekeyService.insertArdAlarmApponekey(ardAlarmApponekey));
+ }
+}
diff --git a/src/main/java/com/ard/alarm/apponekey/domain/ArdAlarmApponekey.java b/src/main/java/com/ard/alarm/apponekey/domain/ArdAlarmApponekey.java
new file mode 100644
index 0000000..2e85fc7
--- /dev/null
+++ b/src/main/java/com/ard/alarm/apponekey/domain/ArdAlarmApponekey.java
@@ -0,0 +1,40 @@
+package com.ard.alarm.apponekey.domain;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import java.util.Date;
+
+/**
+ * app一键报警对象 ard_alarm_apponekey
+ *
+ * @author ard
+ * @date 2023-07-21
+ */
+@Data
+public class ArdAlarmApponekey
+{
+ private static final long serialVersionUID = 1L;
+
+ /** ID */
+ private String id;
+
+ /** app用户ID */
+ private String userId;
+ /** app用户姓名 */
+ private String name;
+ /** 经度 */
+ private Double longitude;
+
+ /** 纬度 */
+ private Double latitude;
+
+ /** 高层 */
+ private Double altitude;
+
+ /** 录像url */
+ private String recordUrl;
+
+ /** 接收创建时间 */
+ @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+ private Date createTime;
+}
diff --git a/src/main/java/com/ard/alarm/apponekey/mapper/ArdAlarmApponekeyMapper.java b/src/main/java/com/ard/alarm/apponekey/mapper/ArdAlarmApponekeyMapper.java
new file mode 100644
index 0000000..beb1681
--- /dev/null
+++ b/src/main/java/com/ard/alarm/apponekey/mapper/ArdAlarmApponekeyMapper.java
@@ -0,0 +1,63 @@
+package com.ard.alarm.apponekey.mapper;
+
+import java.util.List;
+import com.ard.alarm.apponekey.domain.ArdAlarmApponekey;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * app一键报警Mapper接口
+ *
+ * @author ard
+ * @date 2023-07-21
+ */
+@Mapper
+public interface ArdAlarmApponekeyMapper
+{
+ /**
+ * 查询app一键报警
+ *
+ * @param id app一键报警主键
+ * @return app一键报警
+ */
+ public ArdAlarmApponekey selectArdAlarmApponekeyById(String id);
+
+ /**
+ * 查询app一键报警列表
+ *
+ * @param ardAlarmApponekey app一键报警
+ * @return app一键报警集合
+ */
+ public List<ArdAlarmApponekey> selectArdAlarmApponekeyList(ArdAlarmApponekey ardAlarmApponekey);
+
+ /**
+ * 新增app一键报警
+ *
+ * @param ardAlarmApponekey app一键报警
+ * @return 结果
+ */
+ public int insertArdAlarmApponekey(ArdAlarmApponekey ardAlarmApponekey);
+
+ /**
+ * 修改app一键报警
+ *
+ * @param ardAlarmApponekey app一键报警
+ * @return 结果
+ */
+ public int updateArdAlarmApponekey(ArdAlarmApponekey ardAlarmApponekey);
+
+ /**
+ * 删除app一键报警
+ *
+ * @param id app一键报警主键
+ * @return 结果
+ */
+ public int deleteArdAlarmApponekeyById(String id);
+
+ /**
+ * 批量删除app一键报警
+ *
+ * @param ids 需要删除的数据主键集合
+ * @return 结果
+ */
+ public int deleteArdAlarmApponekeyByIds(String[] ids);
+}
diff --git a/src/main/java/com/ard/alarm/apponekey/service/IArdAlarmApponekeyService.java b/src/main/java/com/ard/alarm/apponekey/service/IArdAlarmApponekeyService.java
new file mode 100644
index 0000000..6d69469
--- /dev/null
+++ b/src/main/java/com/ard/alarm/apponekey/service/IArdAlarmApponekeyService.java
@@ -0,0 +1,61 @@
+package com.ard.alarm.apponekey.service;
+
+import java.util.List;
+import com.ard.alarm.apponekey.domain.ArdAlarmApponekey;
+
+/**
+ * app一键报警Service接口
+ *
+ * @author ard
+ * @date 2023-07-21
+ */
+public interface IArdAlarmApponekeyService
+{
+ /**
+ * 查询app一键报警
+ *
+ * @param id app一键报警主键
+ * @return app一键报警
+ */
+ public ArdAlarmApponekey selectArdAlarmApponekeyById(String id);
+
+ /**
+ * 查询app一键报警列表
+ *
+ * @param ardAlarmApponekey app一键报警
+ * @return app一键报警集合
+ */
+ public List<ArdAlarmApponekey> selectArdAlarmApponekeyList(ArdAlarmApponekey ardAlarmApponekey);
+
+ /**
+ * 新增app一键报警
+ *
+ * @param ardAlarmApponekey app一键报警
+ * @return 结果
+ */
+ public int insertArdAlarmApponekey(ArdAlarmApponekey ardAlarmApponekey);
+
+ /**
+ * 修改app一键报警
+ *
+ * @param ardAlarmApponekey app一键报警
+ * @return 结果
+ */
+ public int updateArdAlarmApponekey(ArdAlarmApponekey ardAlarmApponekey);
+
+ /**
+ * 批量删除app一键报警
+ *
+ * @param ids 需要删除的app一键报警主键集合
+ * @return 结果
+ */
+ public int deleteArdAlarmApponekeyByIds(String[] ids);
+
+ /**
+ * 删除app一键报警信息
+ *
+ * @param id app一键报警主键
+ * @return 结果
+ */
+ public int deleteArdAlarmApponekeyById(String id);
+}
diff --git a/src/main/java/com/ard/alarm/apponekey/service/impl/ArdAlarmApponekeyServiceImpl.java b/src/main/java/com/ard/alarm/apponekey/service/impl/ArdAlarmApponekeyServiceImpl.java
new file mode 100644
index 0000000..213eb9f
--- /dev/null
+++ b/src/main/java/com/ard/alarm/apponekey/service/impl/ArdAlarmApponekeyServiceImpl.java
@@ -0,0 +1,111 @@
+package com.ard.alarm.apponekey.service.impl;
+
+import java.util.Date;
+import java.util.List;
+
+import com.alibaba.fastjson2.JSON;
+import com.ard.utils.mqtt.MqttConsumer;
+import com.ard.utils.uuid.IdUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import com.ard.alarm.apponekey.mapper.ArdAlarmApponekeyMapper;
+import com.ard.alarm.apponekey.domain.ArdAlarmApponekey;
+import com.ard.alarm.apponekey.service.IArdAlarmApponekeyService;
+
+import javax.annotation.Resource;
+
+import static jdk.nashorn.internal.runtime.regexp.joni.Config.log;
+
+/**
+ * app一键报警Service业务层处理
+ *
+ * @author ard
+ * @date 2023-07-21
+ */
+@Service
+@Slf4j(topic = "apponekey")
+public class ArdAlarmApponekeyServiceImpl implements IArdAlarmApponekeyService {
+ @Resource
+ private ArdAlarmApponekeyMapper ardAlarmApponekeyMapper;
+
+ /**
+ * 查询app一键报警
+ *
+ * @param id app一键报警主键
+ * @return app一键报警
+ */
+ @Override
+ public ArdAlarmApponekey selectArdAlarmApponekeyById(String id) {
+ return ardAlarmApponekeyMapper.selectArdAlarmApponekeyById(id);
+ }
+
+ /**
+ * 查询app一键报警列表
+ *
+ * @param ardAlarmApponekey app一键报警
+ * @return app一键报警
+ */
+ @Override
+ public List<ArdAlarmApponekey> selectArdAlarmApponekeyList(ArdAlarmApponekey ardAlarmApponekey) {
+ return ardAlarmApponekeyMapper.selectArdAlarmApponekeyList(ardAlarmApponekey);
+ }
+
+ /**
+ * 新增app一键报警
+ *
+ * @param ardAlarmApponekey app一键报警
+ * @return 结果
+ */
+ @Override
+ public int insertArdAlarmApponekey(ArdAlarmApponekey ardAlarmApponekey) {
+ try {
+ ardAlarmApponekey.setId(IdUtils.fastSimpleUUID());
+ ardAlarmApponekey.setCreateTime(new Date());
+ printLog(ardAlarmApponekey);
+ MqttConsumer.publish(2, false, "apponekey", JSON.toJSONString(ardAlarmApponekey));
+ return 1;
+ } catch (Exception ex) {
+ log.error("一键报警处理异常:" + ex.getMessage());
+ return 0;
+ }
+ }
+
+ private void printLog(ArdAlarmApponekey ardAlarmApponekey) {
+ log.info("收到数据:" + "【ID】" + ardAlarmApponekey.getId() + "【userId】" + ardAlarmApponekey.getUserId()
+ + "【经度】" + ardAlarmApponekey.getLongitude() + "【纬度】" + ardAlarmApponekey.getLatitude()
+ + "【高层】" + ardAlarmApponekey.getAltitude() + "【创建时间】" + ardAlarmApponekey.getCreateTime());
+ }
+
+ /**
+ * 修改app一键报警
+ *
+ * @param ardAlarmApponekey app一键报警
+ * @return 结果
+ */
+ @Override
+ public int updateArdAlarmApponekey(ArdAlarmApponekey ardAlarmApponekey) {
+ return ardAlarmApponekeyMapper.updateArdAlarmApponekey(ardAlarmApponekey);
+ }
+
+ /**
+ * 批量删除app一键报警
+ *
+ * @param ids 需要删除的app一键报警主键
+ * @return 结果
+ */
+ @Override
+ public int deleteArdAlarmApponekeyByIds(String[] ids) {
+ return ardAlarmApponekeyMapper.deleteArdAlarmApponekeyByIds(ids);
+ }
+
+ /**
+ * 删除app一键报警信息
+ *
+ * @param id app一键报警主键
+ * @return 结果
+ */
+ @Override
+ public int deleteArdAlarmApponekeyById(String id) {
+ return ardAlarmApponekeyMapper.deleteArdAlarmApponekeyById(id);
+ }
+}
diff --git a/src/main/java/com/ard/utils/hiksdk/util/minio/MinioUtils.java b/src/main/java/com/ard/utils/hiksdk/util/minio/MinioUtils.java
index a21ee68..0e600e0 100644
--- a/src/main/java/com/ard/utils/hiksdk/util/minio/MinioUtils.java
+++ b/src/main/java/com/ard/utils/hiksdk/util/minio/MinioUtils.java
@@ -154,7 +154,7 @@
//文件名
String originalFilename = file.getOriginalFilename();
//新的文件名
- String fileName = UUID.randomUUID().toString().replace("-", "") + originalFilename;
+ String fileName = UUID.randomUUID().toString().replace("-", "") +"_"+ originalFilename;
try {
InputStream inputStream = file.getInputStream();
/*上传对象*/
@@ -170,10 +170,13 @@
/*获取url*/
GetPresignedObjectUrlArgs getPresignedObjectUrlArgs = GetPresignedObjectUrlArgs
.builder()
+ .method(Method.GET)
.bucket(bucketName)
.object(fileName)
.build();
- return MinioClientSingleton.getMinioClient().getPresignedObjectUrl(getPresignedObjectUrlArgs);
+ String presignedObjectUrl = MinioClientSingleton.getMinioClient().getPresignedObjectUrl(getPresignedObjectUrlArgs);
+ String ObjectUrl = presignedObjectUrl.substring(0, presignedObjectUrl.indexOf("?"));
+ return ObjectUrl;
} catch (Exception ex) {
log.error("上传对象返回url异常：" + ex.getMessage());
}
diff --git a/src/main/java/com/ard/utils/http/AjaxResult.java b/src/main/java/com/ard/utils/http/AjaxResult.java
new file mode 100644
index 0000000..f2d1beb
--- /dev/null
+++ b/src/main/java/com/ard/utils/http/AjaxResult.java
@@ -0,0 +1,204 @@
+package com.ard.utils.http;
+
+import java.util.HashMap;
+
+/**
+ * 操作消息提醒
+ *
+ * @author ruoyi
+ */
+public class AjaxResult extends HashMap<String, Object>
+{
+ private static final long serialVersionUID = 1L;
+
+ /** 状态码 */
+ public static final String CODE_TAG = "code";
+
+ /** 返回内容 */
+ public static final String MSG_TAG = "msg";
+
+ /** 数据对象 */
+ public static final String DATA_TAG = "data";
+
+ /**
+ * 初始化一个新创建的 AjaxResult 对象，使其表示一个空消息。
+ */
+ public AjaxResult()
+ {
+ }
+
+ /**
+ * 初始化一个新创建的 AjaxResult 对象
+ *
+ * @param code 状态码
+ * @param msg 返回内容
+ */
+ public AjaxResult(int code, String msg)
+ {
+ super.put(CODE_TAG, code);
+ super.put(MSG_TAG, msg);
+ }
+
+ /**
+ * 初始化一个新创建的 AjaxResult 对象
+ *
+ * @param code 状态码
+ * @param msg 返回内容
+ * @param data 数据对象
+ */
+ public AjaxResult(int code, String msg, Object data)
+ {
+ super.put(CODE_TAG, code);
+ super.put(MSG_TAG, msg);
+ if (data!=null)
+ {
+ super.put(DATA_TAG, data);
+ }
+ }
+
+ /**
+ * 返回成功消息
+ *
+ * @return 成功消息
+ */
+ public static AjaxResult success()
+ {
+ return AjaxResult.success("操作成功");
+ }
+
+ /**
+ * 返回成功数据
+ *
+ * @return 成功消息
+ */
+ public static AjaxResult success(Object data)
+ {
+ return AjaxResult.success("操作成功", data);
+ }
+
+ /**
+ * 返回成功消息
+ *
+ * @param msg 返回内容
+ * @return 成功消息
+ */
+ public static AjaxResult success(String msg)
+ {
+ return AjaxResult.success(msg, null);
+ }
+
+ /**
+ * 返回成功消息
+ *
+ * @param msg 返回内容
+ * @param data 数据对象
+ * @return 成功消息
+ */
+ public static AjaxResult success(String msg, Object data)
+ {
+ return new AjaxResult(HttpStatus.SUCCESS, msg, data);
+ }
+
+ /**
+ * 返回警告消息
+ *
+ * @param msg 返回内容
+ * @return 警告消息
+ */
+ public static AjaxResult warn(String msg)
+ {
+ return AjaxResult.warn(msg, null);
+ }
+
+ /**
+ * 返回警告消息
+ *
+ * @param msg 返回内容
+ * @param data 数据对象
+ * @return 警告消息
+ */
+ public static AjaxResult warn(String msg, Object data)
+ {
+ return new AjaxResult(HttpStatus.WARN, msg, data);
+ }
+
+ /**
+ * 返回错误消息
+ *
+ * @return 错误消息
+ */
+ public static AjaxResult error()
+ {
+ return AjaxResult.error("操作失败");
+ }
+
+ /**
+ * 返回错误消息
+ *
+ * @param msg 返回内容
+ * @return 错误消息
+ */
+ public static AjaxResult error(String msg)
+ {
+ return AjaxResult.error(msg, null);
+ }
+
+ /**
+ * 返回错误消息
+ *
+ * @param msg 返回内容
+ * @param data 数据对象
+ * @return 错误消息
+ */
+ public static AjaxResult error(String msg, Object data)
+ {
+ return new AjaxResult(HttpStatus.ERROR, msg, data);
+ }
+
+ /**
+ * 返回错误消息
+ *
+ * @param code 状态码
+ * @param msg 返回内容
+ * @return 错误消息
+ */
+ public static AjaxResult error(int code, String msg)
+ {
+ return new AjaxResult(code, msg, null);
+ }
+
+ /**
+ * 方便链式调用
+ *
+ * @param key 键
+ * @param value 值
+ * @return 数据对象
+ */
+ @Override
+ public AjaxResult put(String key, Object value)
+ {
+ super.put(key, value);
+ return this;
+ }
+ /**
+ * 响应返回结果
+ *
+ * @param rows 影响行数
+ * @return 操作结果
+ */
+ public static AjaxResult toAjax(int rows)
+ {
+ return rows > 0 ? AjaxResult.success() : AjaxResult.error();
+ }
+ /**
+ * 响应返回结果
+ *
+ * @param result 结果
+ * @return 操作结果
+ */
+ public static AjaxResult toAjax(boolean result)
+ {
+ return result ? success() : error();
+ }
+}
+
diff --git a/src/main/java/com/ard/utils/http/HttpStatus.java b/src/main/java/com/ard/utils/http/HttpStatus.java
new file mode 100644
index 0000000..cafc54c
--- /dev/null
+++ b/src/main/java/com/ard/utils/http/HttpStatus.java
@@ -0,0 +1,95 @@
+package com.ard.utils.http;
+
+/**
+ * 返回状态码
+ *
+ * @author ruoyi
+ */
+public class HttpStatus
+{
+ /**
+ * 操作成功
+ */
+ public static final int SUCCESS = 200;
+
+ /**
+ * 对象创建成功
+ */
+ public static final int CREATED = 201;
+
+ /**
+ * 请求已经被接受
+ */
+ public static final int ACCEPTED = 202;
+
+ /**
+ * 操作已经执行成功，但是没有返回数据
+ */
+ public static final int NO_CONTENT = 204;
+
+ /**
+ * 资源已被移除
+ */
+ public static final int MOVED_PERM = 301;
+
+ /**
+ * 重定向
+ */
+ public static final int SEE_OTHER = 303;
+
+ /**
+ * 资源没有被修改
+ */
+ public static final int NOT_MODIFIED = 304;
+
+ /**
+ * 参数列表错误（缺少，格式不匹配）
+ */
+ public static final int BAD_REQUEST = 400;
+
+ /**
+ * 未授权
+ */
+ public static final int UNAUTHORIZED = 401;
+
+ /**
+ * 访问受限，授权过期
+ */
+ public static final int FORBIDDEN = 403;
+
+ /**
+ * 资源，服务未找到
+ */
+ public static final int NOT_FOUND = 404;
+
+ /**
+ * 不允许的http方法
+ */
+ public static final int BAD_METHOD = 405;
+
+ /**
+ * 资源冲突，或者资源被锁
+ */
+ public static final int CONFLICT = 409;
+
+ /**
+ * 不支持的数据，媒体类型
+ */
+ public static final int UNSUPPORTED_TYPE = 415;
+
+ /**
+ * 系统内部错误
+ */
+ public static final int ERROR = 500;
+
+ /**
+ * 接口未实现
+ */
+ public static final int NOT_IMPLEMENTED = 501;
+
+ /**
+ * 系统警告消息
+ */
+ public static final int WARN = 601;
+}
+
diff --git a/src/main/java/com/ard/utils/uuid/IdUtils.java b/src/main/java/com/ard/utils/uuid/IdUtils.java
new file mode 100644
index 0000000..7c708ae
--- /dev/null
+++ b/src/main/java/com/ard/utils/uuid/IdUtils.java
@@ -0,0 +1,50 @@
+package com.ard.utils.uuid;
+
+
+/**
+ * ID生成器工具类
+ *
+ * @author ruoyi
+ */
+public class IdUtils
+{
+ /**
+ * 获取随机UUID
+ *
+ * @return 随机UUID
+ */
+ public static String randomUUID()
+ {
+ return UUID.randomUUID().toString();
+ }
+
+ /**
+ * 简化的UUID，去掉了横线
+ *
+ * @return 简化的UUID，去掉了横线
+ */
+ public static String simpleUUID()
+ {
+ return UUID.randomUUID().toString(true);
+ }
+
+ /**
+ * 获取随机UUID，使用性能更好的ThreadLocalRandom生成UUID
+ *
+ * @return 随机UUID
+ */
+ public static String fastUUID()
+ {
+ return UUID.fastUUID().toString();
+ }
+
+ /**
+ * 简化的UUID，去掉了横线，使用性能更好的ThreadLocalRandom生成UUID
+ *
+ * @return 简化的UUID，去掉了横线
+ */
+ public static String fastSimpleUUID()
+ {
+ return UUID.fastUUID().toString(true);
+ }
+}
diff --git a/src/main/java/com/ard/utils/uuid/UUID.java b/src/main/java/com/ard/utils/uuid/UUID.java
new file mode 100644
index 0000000..bffe30b
--- /dev/null
+++ b/src/main/java/com/ard/utils/uuid/UUID.java
@@ -0,0 +1,485 @@
+package com.ard.utils.uuid;
+
+import com.sun.xml.internal.ws.util.UtilException;
+
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+import java.security.SecureRandom;
+import java.util.Random;
+import java.util.concurrent.ThreadLocalRandom;
+
+/**
+ * 提供通用唯一识别码（universally unique identifier）（UUID）实现
+ *
+ * @author ruoyi
+ */
+public final class UUID implements java.io.Serializable, Comparable<UUID>
+{
+ private static final long serialVersionUID = -1185015143654744140L;
+
+ /**
+ * SecureRandom 的单例
+ *
+ */
+ private static class Holder
+ {
+ static final SecureRandom numberGenerator = getSecureRandom();
+ }
+
+ /** 此UUID的最高64有效位 */
+ private final long mostSigBits;
+
+ /** 此UUID的最低64有效位 */
+ private final long leastSigBits;
+
+ /**
+ * 私有构造
+ *
+ * @param data 数据
+ */
+ private UUID(byte[] data)
+ {
+ long msb = 0;
+ long lsb = 0;
+ assert data.length == 16 : "data must be 16 bytes in length";
+ for (int i = 0; i < 8; i++)
+ {
+ msb = (msb << 8) | (data[i] & 0xff);
+ }
+ for (int i = 8; i < 16; i++)
+ {
+ lsb = (lsb << 8) | (data[i] & 0xff);
+ }
+ this.mostSigBits = msb;
+ this.leastSigBits = lsb;
+ }
+
+ /**
+ * 使用指定的数据构造新的 UUID。
+ *
+ * @param mostSigBits 用于 {@code UUID} 的最高有效 64 位
+ * @param leastSigBits 用于 {@code UUID} 的最低有效 64 位
+ */
+ public UUID(long mostSigBits, long leastSigBits)
+ {
+ this.mostSigBits = mostSigBits;
+ this.leastSigBits = leastSigBits;
+ }
+
+ /**
+ * 获取类型 4（伪随机生成的）UUID 的静态工厂。 使用加密的本地线程伪随机数生成器生成该 UUID。
+ *
+ * @return 随机生成的 {@code UUID}
+ */
+ public static UUID fastUUID()
+ {
+ return randomUUID(false);
+ }
+
+ /**
+ * 获取类型 4（伪随机生成的）UUID 的静态工厂。 使用加密的强伪随机数生成器生成该 UUID。
+ *
+ * @return 随机生成的 {@code UUID}
+ */
+ public static UUID randomUUID()
+ {
+ return randomUUID(true);
+ }
+
+ /**
+ * 获取类型 4（伪随机生成的）UUID 的静态工厂。 使用加密的强伪随机数生成器生成该 UUID。
+ *
+ * @param isSecure 是否使用{@link SecureRandom}如果是可以获得更安全的随机码，否则可以得到更好的性能
+ * @return 随机生成的 {@code UUID}
+ */
+ public static UUID randomUUID(boolean isSecure)
+ {
+ final Random ng = isSecure ? Holder.numberGenerator : getRandom();
+
+ byte[] randomBytes = new byte[16];
+ ng.nextBytes(randomBytes);
+ randomBytes[6] &= 0x0f; /* clear version */
+ randomBytes[6] |= 0x40; /* set to version 4 */
+ randomBytes[8] &= 0x3f; /* clear variant */
+ randomBytes[8] |= 0x80; /* set to IETF variant */
+ return new UUID(randomBytes);
+ }
+
+ /**
+ * 根据指定的字节数组获取类型 3（基于名称的）UUID 的静态工厂。
+ *
+ * @param name 用于构造 UUID 的字节数组。
+ *
+ * @return 根据指定数组生成的 {@code UUID}
+ */
+ public static UUID nameUUIDFromBytes(byte[] name)
+ {
+ MessageDigest md;
+ try
+ {
+ md = MessageDigest.getInstance("MD5");
+ }
+ catch (NoSuchAlgorithmException nsae)
+ {
+ throw new InternalError("MD5 not supported");
+ }
+ byte[] md5Bytes = md.digest(name);
+ md5Bytes[6] &= 0x0f; /* clear version */
+ md5Bytes[6] |= 0x30; /* set to version 3 */
+ md5Bytes[8] &= 0x3f; /* clear variant */
+ md5Bytes[8] |= 0x80; /* set to IETF variant */
+ return new UUID(md5Bytes);
+ }
+
+ /**
+ * 根据 {@link #toString()} 方法中描述的字符串标准表示形式创建{@code UUID}。
+ *
+ * @param name 指定 {@code UUID} 字符串
+ * @return 具有指定值的 {@code UUID}
+ * @throws IllegalArgumentException 如果 name 与 {@link #toString} 中描述的字符串表示形式不符抛出此异常
+ *
+ */
+ public static UUID fromString(String name)
+ {
+ String[] components = name.split("-");
+ if (components.length != 5)
+ {
+ throw new IllegalArgumentException("Invalid UUID string: " + name);
+ }
+ for (int i = 0; i < 5; i++)
+ {
+ components[i] = "0x" + components[i];
+ }
+
+ long mostSigBits = Long.decode(components[0]).longValue();
+ mostSigBits <<= 16;
+ mostSigBits |= Long.decode(components[1]).longValue();
+ mostSigBits <<= 16;
+ mostSigBits |= Long.decode(components[2]).longValue();
+
+ long leastSigBits = Long.decode(components[3]).longValue();
+ leastSigBits <<= 48;
+ leastSigBits |= Long.decode(components[4]).longValue();
+
+ return new UUID(mostSigBits, leastSigBits);
+ }
+
+ /**
+ * 返回此 UUID 的 128 位值中的最低有效 64 位。
+ *
+ * @return 此 UUID 的 128 位值中的最低有效 64 位。
+ */
+ public long getLeastSignificantBits()
+ {
+ return leastSigBits;
+ }
+
+ /**
+ * 返回此 UUID 的 128 位值中的最高有效 64 位。
+ *
+ * @return 此 UUID 的 128 位值中最高有效 64 位。
+ */
+ public long getMostSignificantBits()
+ {
+ return mostSigBits;
+ }
+
+ /**
+ * 与此 {@code UUID} 相关联的版本号. 版本号描述此 {@code UUID} 是如何生成的。
+ * <p>
+ * 版本号具有以下含意:
+ * <ul>
+ * <li>1 基于时间的 UUID
+ * <li>2 DCE 安全 UUID
+ * <li>3 基于名称的 UUID
+ * <li>4 随机生成的 UUID
+ * </ul>
+ *
+ * @return 此 {@code UUID} 的版本号
+ */
+ public int version()
+ {
+ // Version is bits masked by 0x000000000000F000 in MS long
+ return (int) ((mostSigBits >> 12) & 0x0f);
+ }
+
+ /**
+ * 与此 {@code UUID} 相关联的变体号。变体号描述 {@code UUID} 的布局。
+ * <p>
+ * 变体号具有以下含意：
+ * <ul>
+ * <li>0 为 NCS 向后兼容保留
+ * <li>2 <a href="http://www.ietf.org/rfc/rfc4122.txt">IETF RFC 4122</a>(Leach-Salz), 用于此类
+ * <li>6 保留，微软向后兼容
+ * <li>7 保留供以后定义使用
+ * </ul>
+ *
+ * @return 此 {@code UUID} 相关联的变体号
+ */
+ public int variant()
+ {
+ // This field is composed of a varying number of bits.
+ // 0 - - Reserved for NCS backward compatibility
+ // 1 0 - The IETF aka Leach-Salz variant (used by this class)
+ // 1 1 0 Reserved, Microsoft backward compatibility
+ // 1 1 1 Reserved for future definition.
+ return (int) ((leastSigBits >>> (64 - (leastSigBits >>> 62))) & (leastSigBits >> 63));
+ }
+
+ /**
+ * 与此 UUID 相关联的时间戳值。
+ *
+ * <p>
+ * 60 位的时间戳值根据此 {@code UUID} 的 time_low、time_mid 和 time_hi 字段构造。<br>
+ * 所得到的时间戳以 100 毫微秒为单位，从 UTC（通用协调时间） 1582 年 10 月 15 日零时开始。
+ *
+ * <p>
+ * 时间戳值仅在在基于时间的 UUID（其 version 类型为 1）中才有意义。<br>
+ * 如果此 {@code UUID} 不是基于时间的 UUID，则此方法抛出 UnsupportedOperationException。
+ *
+ * @throws UnsupportedOperationException 如果此 {@code UUID} 不是 version 为 1 的 UUID。
+ */
+ public long timestamp() throws UnsupportedOperationException
+ {
+ checkTimeBase();
+ return (mostSigBits & 0x0FFFL) << 48//
+ | ((mostSigBits >> 16) & 0x0FFFFL) << 32//
+ | mostSigBits >>> 32;
+ }
+
+ /**
+ * 与此 UUID 相关联的时钟序列值。
+ *
+ * <p>
+ * 14 位的时钟序列值根据此 UUID 的 clock_seq 字段构造。clock_seq 字段用于保证在基于时间的 UUID 中的时间唯一性。
+ * <p>
+ * {@code clockSequence} 值仅在基于时间的 UUID（其 version 类型为 1）中才有意义。 如果此 UUID 不是基于时间的 UUID，则此方法抛出
+ * UnsupportedOperationException。
+ *
+ * @return 此 {@code UUID} 的时钟序列
+ *
+ * @throws UnsupportedOperationException 如果此 UUID 的 version 不为 1
+ */
+ public int clockSequence() throws UnsupportedOperationException
+ {
+ checkTimeBase();
+ return (int) ((leastSigBits & 0x3FFF000000000000L) >>> 48);
+ }
+
+ /**
+ * 与此 UUID 相关的节点值。
+ *
+ * <p>
+ * 48 位的节点值根据此 UUID 的 node 字段构造。此字段旨在用于保存机器的 IEEE 802 地址，该地址用于生成此 UUID 以保证空间唯一性。
+ * <p>
+ * 节点值仅在基于时间的 UUID（其 version 类型为 1）中才有意义。<br>
+ * 如果此 UUID 不是基于时间的 UUID，则此方法抛出 UnsupportedOperationException。
+ *
+ * @return 此 {@code UUID} 的节点值
+ *
+ * @throws UnsupportedOperationException 如果此 UUID 的 version 不为 1
+ */
+ public long node() throws UnsupportedOperationException
+ {
+ checkTimeBase();
+ return leastSigBits & 0x0000FFFFFFFFFFFFL;
+ }
+
+ /**
+ * 返回此{@code UUID} 的字符串表现形式。
+ *
+ * <p>
+ * UUID 的字符串表示形式由此 BNF 描述：
+ *
+ * <pre>
+ * {@code
+ * UUID = <time_low>-<time_mid>-<time_high_and_version>-<variant_and_sequence>-<node>
+ * time_low = 4*<hexOctet>
+ * time_mid = 2*<hexOctet>
+ * time_high_and_version = 2*<hexOctet>
+ * variant_and_sequence = 2*<hexOctet>
+ * node = 6*<hexOctet>
+ * hexOctet = <hexDigit><hexDigit>
+ * hexDigit = [0-9a-fA-F]
+ * }
+ * </pre>
+ *
+ * </blockquote>
+ *
+ * @return 此{@code UUID} 的字符串表现形式
+ * @see #toString(boolean)
+ */
+ @Override
+ public String toString()
+ {
+ return toString(false);
+ }
+
+ /**
+ * 返回此{@code UUID} 的字符串表现形式。
+ *
+ * <p>
+ * UUID 的字符串表示形式由此 BNF 描述：
+ *
+ * <pre>
+ * {@code
+ * UUID = <time_low>-<time_mid>-<time_high_and_version>-<variant_and_sequence>-<node>
+ * time_low = 4*<hexOctet>
+ * time_mid = 2*<hexOctet>
+ * time_high_and_version = 2*<hexOctet>
+ * variant_and_sequence = 2*<hexOctet>
+ * node = 6*<hexOctet>
+ * hexOctet = <hexDigit><hexDigit>
+ * hexDigit = [0-9a-fA-F]
+ * }
+ * </pre>
+ *
+ * </blockquote>
+ *
+ * @param isSimple 是否简单模式，简单模式为不带'-'的UUID字符串
+ * @return 此{@code UUID} 的字符串表现形式
+ */
+ public String toString(boolean isSimple)
+ {
+ final StringBuilder builder = new StringBuilder(isSimple ? 32 : 36);
+ // time_low
+ builder.append(digits(mostSigBits >> 32, 8));
+ if (!isSimple)
+ {
+ builder.append('-');
+ }
+ // time_mid
+ builder.append(digits(mostSigBits >> 16, 4));
+ if (!isSimple)
+ {
+ builder.append('-');
+ }
+ // time_high_and_version
+ builder.append(digits(mostSigBits, 4));
+ if (!isSimple)
+ {
+ builder.append('-');
+ }
+ // variant_and_sequence
+ builder.append(digits(leastSigBits >> 48, 4));
+ if (!isSimple)
+ {
+ builder.append('-');
+ }
+ // node
+ builder.append(digits(leastSigBits, 12));
+
+ return builder.toString();
+ }
+
+ /**
+ * 返回此 UUID 的哈希码。
+ *
+ * @return UUID 的哈希码值。
+ */
+ @Override
+ public int hashCode()
+ {
+ long hilo = mostSigBits ^ leastSigBits;
+ return ((int) (hilo >> 32)) ^ (int) hilo;
+ }
+
+ /**
+ * 将此对象与指定对象比较。
+ * <p>
+ * 当且仅当参数不为 {@code null}、而是一个 UUID 对象、具有与此 UUID 相同的 varriant、包含相同的值（每一位均相同）时，结果才为 {@code true}。
+ *
+ * @param obj 要与之比较的对象
+ *
+ * @return 如果对象相同，则返回 {@code true}；否则返回 {@code false}
+ */
+ @Override
+ public boolean equals(Object obj)
+ {
+ if ((null == obj) || (obj.getClass() != UUID.class))
+ {
+ return false;
+ }
+ UUID id = (UUID) obj;
+ return (mostSigBits == id.mostSigBits && leastSigBits == id.leastSigBits);
+ }
+
+ // Comparison Operations
+
+ /**
+ * 将此 UUID 与指定的 UUID 比较。
+ *
+ * <p>
+ * 如果两个 UUID 不同，且第一个 UUID 的最高有效字段大于第二个 UUID 的对应字段，则第一个 UUID 大于第二个 UUID。
+ *
+ * @param val 与此 UUID 比较的 UUID
+ *
+ * @return 在此 UUID 小于、等于或大于 val 时，分别返回 -1、0 或 1。
+ *
+ */
+ @Override
+ public int compareTo(UUID val)
+ {
+ // The ordering is intentionally set up so that the UUIDs
+ // can simply be numerically compared as two numbers
+ return (this.mostSigBits < val.mostSigBits ? -1 : //
+ (this.mostSigBits > val.mostSigBits ? 1 : //
+ (this.leastSigBits < val.leastSigBits ? -1 : //
+ (this.leastSigBits > val.leastSigBits ? 1 : //
+ 0))));
+ }
+
+ // -------------------------------------------------------------------------------------------------------------------
+ // Private method start
+ /**
+ * 返回指定数字对应的hex值
+ *
+ * @param val 值
+ * @param digits 位
+ * @return 值
+ */
+ private static String digits(long val, int digits)
+ {
+ long hi = 1L << (digits * 4);
+ return Long.toHexString(hi | (val & (hi - 1))).substring(1);
+ }
+
+ /**
+ * 检查是否为time-based版本UUID
+ */
+ private void checkTimeBase()
+ {
+ if (version() != 1)
+ {
+ throw new UnsupportedOperationException("Not a time-based UUID");
+ }
+ }
+
+ /**
+ * 获取{@link SecureRandom}，类提供加密的强随机数生成器 (RNG)
+ *
+ * @return {@link SecureRandom}
+ */
+ public static SecureRandom getSecureRandom()
+ {
+ try
+ {
+ return SecureRandom.getInstance("SHA1PRNG");
+ }
+ catch (NoSuchAlgorithmException e)
+ {
+ throw new UtilException(e);
+ }
+ }
+
+ /**
+ * 获取随机数生成器对象<br>
+ * ThreadLocalRandom是JDK 7之后提供并发产生随机数，能够解决多个线程发生的竞争争夺。
+ *
+ * @return {@link ThreadLocalRandom}
+ */
+ public static ThreadLocalRandom getRandom()
+ {
+ return ThreadLocalRandom.current();
+ }
+}
--
Gitblit v1.9.3