zhouwentao
/
demo-kafka
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

updates

Browse Source 
RMS访客机接口
main
周文涛 2 years ago
parent 9127574316
commit f2e70b9378
13 changed files with 1569 additions and 0 deletions
Show Stats Download Patch File Download Diff File

121
src/main/java/com/example/zxweb/common/constant/enums/IotApiPathsEnum.java
Unescape View File

@ -0,0 +1,121 @@
package com.example.zxweb.common.constant.enums;
/**
* @Description: IOT设备API接口路径
* @author: ZhouWenTao
* @date: 2023/9/8 12:05
*/
public enum IotApiPathsEnum {
/**
* 获取单个设备信息 GET,query
*/
get_devices("/devices", "获取单个设备信息"),
/**
* 获取设备列表 GET,query
*/
get_devices_list("/devices/list", "获取设备列表"),
/**
* 向设备发送消息 POST,body
*/
post_devices_datastreams("/devices/datastreams", "向设备发送消息"),
/**
* 查询设备历史数据 GET
*/
get_devices_datastreams("/devices/datastreams", "查询设备历史数据"),
/**
* 查询消息是否下达到设备 GET
*/
get_devices_datastreams_state("/devices/datastreams/state", "查询消息是否下达到设备"),
/**
* 查询事件历史数据 GET
*/
get_devices_events("/devices/events", "查询事件历史数据"),
/**
* 向设备发送方法 POST,body
*/
post_devices_methods("/devices/methods", "向设备发送方法"),
/**
* 查询方法历史数据 GET
*/
get_devices_methods("/devices/methods", "查询方法历史数据"),
;
/**
* 地址
*/
String path;
/**
* 描述
*/
String text;
public String getPath() {
return path;
}
public void setPath(String path) {
this.path = path;
}
public String getText(){
return text;
}
public void setText(String text) {
this.text = text;
}
/**
* 构造器
*
* @param path 地址
* @param text 描述
*/
IotApiPathsEnum(String path, String text) {
this.path = path;
this.text = text;
}
/**
* 根据描述匹配
*
* @param path 请求地址
* @return String 描述
*/
public static String getTextByPath(String path){
for (IotApiPathsEnum e : IotApiPathsEnum.values()) {
if (path.startsWith(e.getPath())) {
return e.getText();
}
}
return null;
}
/**
* 根据路径描述获取路径
* @param text 描述
* @return
*/
public static String getPathByText(String text){
for (IotApiPathsEnum e : IotApiPathsEnum.values()) {
if (text.startsWith(e.getText())) {
return e.getPath();
}
}
return null;
}
}

92
src/main/java/com/example/zxweb/common/constant/enums/RmsApiEnum.java
Unescape View File

@ -0,0 +1,92 @@
package com.example.zxweb.common.constant.enums;
/**
* @Description: IOT设备API接口路径
* @author: ZhouWenTao
* @date: 2023/9/8 13:05
*/
public enum RmsApiEnum {
//https://docs.qq.com/doc/DVWxxY0hOdkxYaEJH
/**
* 系统登陆
* 本接口用于系统启用token验证功能调用，登陆成功即可，其它接口无须传token值，token1小时有效，账号和密码可联系技术人员获取。
*/
post_auth_login("/rms/auth/login","系统登陆"),
/**
* 访客查询
* 本接口用于访客信息查询，查询出访客登记的所有信息，建议查询条件为当天时间+状态查询，不易跨月，多天的频繁调用，对服务压力大，查询结果为倒序排序。
*/
post_fkterminal_findAccessRecord("/rms/fkterminal/findAccessRecord","访客查询"),
;
/**
* 接口地址
*/
String api;
/**
* 描述
*/
String text;
public String getApi() {
return api;
}
public void setApi(String api) {
this.api = api;
}
public String getText(){
return text;
}
public void setText(String text) {
this.text = text;
}
/**
* 构造器
*
* @param api 地址
* @param text 描述
*/
RmsApiEnum(String api, String text) {
this.api = api;
this.text = text;
}
/**
* 根据 接口地址 匹配
*
* @param api 接口地址
* @return String 描述
*/
public static String getTextByApi(String api){
for (RmsApiEnum e : RmsApiEnum.values()) {
if (api.startsWith(e.getApi())) {
return e.getText();
}
}
return null;
}
/**
* 根据 描述 匹配
* @param text 描述
* @return
*/
public static String getApiByText(String text){
for (RmsApiEnum e : RmsApiEnum.values()) {
if (text.startsWith(e.getText())) {
return e.getApi();
}
}
return null;
}
}

40
src/main/java/com/example/zxweb/controller/IotController.java
Unescape View File

@ -0,0 +1,40 @@
package com.example.zxweb.controller;
import com.example.zxweb.common.api.vo.Result;
import com.example.zxweb.common.constant.enums.IotApiPathsEnum;
import com.example.zxweb.utils.AssertUtils;
import com.example.zxweb.utils.IotUtils;
import com.example.zxweb.utils.RestUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.LinkedHashMap;
import java.util.Map;
/**
* @Description
* @Author ZhouWenTao
* @Date 2023/9/8 11:43
*/
@RestController
@RequestMapping("/iot")
@Slf4j
@Api(tags = "设备管理")
public class IotController {
@ApiOperation(value = "获取单个设备信息")
@GetMapping(value = "/devices")
public Result<?> devices(@RequestParam(value = "serial",defaultValue = "")String serial,@RequestParam(value = "productId",defaultValue = "")String productId){
AssertUtils.notEmpty(serial,"请输入-[serial]");AssertUtils.notEmpty(productId,"请输入-[productId]");
Map<String,Object> queryData=new LinkedHashMap<>();
queryData.put("serial",serial);
queryData.put("productId",productId);
//请求数据
return Result.OK(IotUtils.getApi(IotApiPathsEnum.getPathByText("获取单个设备信息"),queryData));
}
}

57
src/main/java/com/example/zxweb/controller/RmsController.java
Unescape View File

@ -0,0 +1,57 @@
package com.example.zxweb.controller;
import com.alibaba.fastjson.JSONObject;
import com.example.zxweb.common.api.vo.Result;
import com.example.zxweb.common.constant.enums.IotApiPathsEnum;
import com.example.zxweb.utils.AssertUtils;
import com.example.zxweb.utils.IotUtils;
import com.example.zxweb.utils.RmsUtils;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;
import java.util.LinkedHashMap;
import java.util.Map;
/**
* @Description 访客机
* @Author ZhouWenTao
* @Date 2023/9/8 13:16
*/
@RestController
@RequestMapping("/rms")
@Slf4j
@Api(tags = "访客机")
public class RmsController {
@ApiOperation(value = "访客查询")
@PostMapping(value = "/fkterminal/findAccessRecord")
public Result<?> fkterminalFindAccessRecord(@RequestBody JSONObject requestBody){
JSONObject responseBody = RmsUtils.fkterminalFindAccessRecord(requestBody);
responseBody.remove("msg");
responseBody.remove("code");
responseBody.remove("success");
return Result.OK(responseBody);
}
@ApiOperation(value = "访客预约")
@PostMapping(value = "/sync/orderrecord")
public Result<?> syncOrderrecord(@RequestBody JSONObject requestBody){
JSONObject responseBody = RmsUtils.syncOrderrecord(requestBody);
responseBody.remove("msg");
responseBody.remove("code");
responseBody.remove("success");
return Result.OK(responseBody);
}
@ApiOperation(value = "访客注销")
@PostMapping(value = "/fkterminal/recoverCard")
public Result<?> fkterminalRecoverCard(@RequestBody JSONObject requestBody){
JSONObject responseBody = RmsUtils.fkterminalRecoverCard(requestBody);
responseBody.remove("msg");
responseBody.remove("code");
responseBody.remove("success");
return Result.OK(responseBody);
}
}

24
src/main/java/com/example/zxweb/exception/Business401Exception.java
Unescape View File

@ -0,0 +1,24 @@
package com.example.zxweb.exception;
/**
* @Description: bussiness自定义401异常
* @Author ZhouWenTao
* @Date 2023/9/8 11:46
*/
public class Business401Exception extends RuntimeException {
private static final long serialVersionUID = 1L;
public Business401Exception(String message){
super(message);
}
public Business401Exception(Throwable cause)
{
super(cause);
}
public Business401Exception(String message, Throwable cause)
{
super(message,cause);
}
}

24
src/main/java/com/example/zxweb/exception/BusinessException.java
Unescape View File

@ -0,0 +1,24 @@
package com.example.zxweb.exception;
/**
* @Description: 自定义异常
* @Author ZhouWenTao
* @Date 2023/9/8 11:46
*/
public class BusinessException extends RuntimeException {
private static final long serialVersionUID = 1L;
public BusinessException(String message){
super(message);
}
public BusinessException(Throwable cause)
{
super(cause);
}
public BusinessException(String message, Throwable cause)
{
super(message,cause);
}
}

130
src/main/java/com/example/zxweb/exception/BusinessExceptionHandler.java
Unescape View File

@ -0,0 +1,130 @@
package com.example.zxweb.exception;
import com.example.zxweb.common.api.vo.Result;
import lombok.extern.slf4j.Slf4j;
import org.springframework.dao.DataIntegrityViolationException;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.http.HttpStatus;
import org.springframework.web.HttpRequestMethodNotSupportedException;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import org.springframework.web.multipart.MaxUploadSizeExceededException;
import org.springframework.web.servlet.NoHandlerFoundException;
/**
* 异常处理器
* @Description
* @Author ZhouWenTao
* @Date 2023/9/8 11:46
*/
@RestControllerAdvice
@Slf4j
public class BusinessExceptionHandler {
/**
* 处理自定义异常
*/
@ExceptionHandler(BusinessException.class)
public Result<?> handleBusinessException(BusinessException e){
log.error(e.getMessage(), e);
return Result.error(e.getMessage());
}
/**
* 处理自定义微服务异常
*/
/*@ExceptionHandler(JeecgCloudException.class)
public Result<?> handleJeecgCloudException(JeecgCloudException e){
log.error(e.getMessage(), e);
return Result.error(e.getMessage());
}*/
/**
* 处理自定义异常
*/
@ExceptionHandler(Business401Exception.class)
@ResponseStatus(HttpStatus.UNAUTHORIZED)
public Result<?> handleJeecgBoot401Exception(Business401Exception e){
log.error(e.getMessage(), e);
return new Result(401,e.getMessage());
}
@ExceptionHandler(NoHandlerFoundException.class)
public Result<?> handlerNoFoundException(Exception e) {
log.error(e.getMessage(), e);
return Result.error(404, "路径不存在，请检查路径是否正确");
}
@ExceptionHandler(DuplicateKeyException.class)
public Result<?> handleDuplicateKeyException(DuplicateKeyException e){
log.error(e.getMessage(), e);
return Result.error("数据库中已存在该记录");
}
/*@ExceptionHandler({UnauthorizedException.class, AuthorizationException.class})
public Result<?> handleAuthorizationException(AuthorizationException e){
log.error(e.getMessage(), e);
return Result.noauth("没有权限，请联系管理员授权");
}*/
/*@ExceptionHandler(Exception.class)
public Result<?> handleException(Exception e){
log.error(e.getMessage(), e);
//update-begin---author:zyf ---date:20220411 for：处理Sentinel限流自定义异常
Throwable throwable = e.getCause();
SentinelErrorInfoEnum errorInfoEnum = SentinelErrorInfoEnum.getErrorByException(throwable);
if (ObjectUtil.isNotEmpty(errorInfoEnum)) {
return Result.error(errorInfoEnum.getError());
}
//update-end---author:zyf ---date:20220411 for：处理Sentinel限流自定义异常
return Result.error("操作失败，"+e.getMessage());
}*/
/**
* @Author 政辉
* @param e
* @return
*/
@ExceptionHandler(HttpRequestMethodNotSupportedException.class)
public Result<?> httpRequestMethodNotSupportedException(HttpRequestMethodNotSupportedException e){
StringBuffer sb = new StringBuffer();
sb.append("不支持");
sb.append(e.getMethod());
sb.append("请求方法，");
sb.append("支持以下");
String [] methods = e.getSupportedMethods();
if(methods!=null){
for(String str:methods){
sb.append(str);
sb.append("、");
}
}
log.error(sb.toString(), e);
//return Result.error("没有权限，请联系管理员授权");
return Result.error(405,sb.toString());
}
/**
* spring默认上传大小100MB 超出大小捕获异常MaxUploadSizeExceededException
*/
@ExceptionHandler(MaxUploadSizeExceededException.class)
public Result<?> handleMaxUploadSizeExceededException(MaxUploadSizeExceededException e) {
log.error(e.getMessage(), e);
return Result.error("文件大小超出10MB限制, 请压缩或降低文件质量! ");
}
@ExceptionHandler(DataIntegrityViolationException.class)
public Result<?> handleDataIntegrityViolationException(DataIntegrityViolationException e) {
log.error(e.getMessage(), e);
//【issues/3624】数据库执行异常handleDataIntegrityViolationException提示有误 #3624
return Result.error("执行数据库异常,违反了完整性例如：违反惟一约束、违反非空限制、字段内容超出长度等");
}
/*@ExceptionHandler(PoolException.class)
public Result<?> handlePoolException(PoolException e) {
log.error(e.getMessage(), e);
return Result.error("Redis 连接异常!");
}*/
}

87
src/main/java/com/example/zxweb/utils/AssertUtils.java
Unescape View File

@ -0,0 +1,87 @@
package com.example.zxweb.utils;
import com.example.zxweb.exception.BusinessException;
import org.apache.commons.lang.StringUtils;
import java.util.List;
/**
* @Description 变量校验工具
* @Author ZhouWenTao
* @Date 2023/6/26 19:14
*/
public abstract class AssertUtils {
/**
* 判断真假值
* @param flag
* @param message
*/
public static void isTrue(boolean flag, String message) {
if (!flag) {
throw new BusinessException(message);
}
}
/**
* true时拦截
* @param flag
* @param message
*/
public static void notTrue(boolean flag, String message) {
if (flag) {
throw new BusinessException(message);
}
}
public static void notNull(Object object, String message) {
if (object == null) {
throw new BusinessException(message);
}
}
public static void isEmpty(String str, String message) {
if (StringUtils.isNotBlank(str)) {
throw new BusinessException(message);
}
}
public static void notEmpty(String str, String message) {
if (StringUtils.isBlank(str)) {
throw new BusinessException(message);
}
}
/**
* 校验Array 不可为空/不可空数据
* @param list
* @param message
*/
public static void hasSize(List list,String message){
if (list==null || list.size()==0) {
throw new BusinessException(message);
}
}
/**
* 校验Array 不可为空/不可空数据
* @param list
* @param message
*/
public static void hasSize(Object[] list,String message){
if (list==null || list.length==0) {
throw new BusinessException(message);
}
}
/**
* 判断字符串长度
* @param o 判读对象
* @param len 字符串长度，不可超过
* @param message 异常提示
*/
public static void checkLength(Object o,Integer len,String message){
notNull(o,"<"+message+">判断之前参数不可空!");
if (o.toString().length()>len) {
throw new BusinessException(message);
}
}
}

31
src/main/java/com/example/zxweb/utils/IotUtils.java
Unescape View File

@ -0,0 +1,31 @@
package com.example.zxweb.utils;
import com.alibaba.fastjson.JSONObject;
import com.example.zxweb.common.constant.enums.IotApiPathsEnum;
import org.springframework.stereotype.Component;
import java.util.Map;
/**
* @Description ios 设备请求工具
* @Author ZhouWenTao
* @Date 2023/9/8 11:59
*/
@Component
public class IotUtils {
//请求服务地址
private static final String API_PREFIX = "https://10.0.10.153:2443/api/iot/v1";
public static JSONObject getApi(String apiUrl,Map<String,Object> queryData) {
StringBuilder sb=new StringBuilder();
int i=0;
for (String field : queryData.keySet()) {
String value = (String) queryData.get(field);
sb.append(i==0?"?":"&");
sb.append(field).append("=").append(value);
i++;
}
JSONObject jsonObject = RestUtil.get(API_PREFIX+apiUrl + sb);
return jsonObject;
}
}

320
src/main/java/com/example/zxweb/utils/RestUtil.java
Unescape View File

@ -0,0 +1,320 @@
package com.example.zxweb.utils;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.http.*;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.http.converter.StringHttpMessageConverter;
import org.springframework.web.client.RestTemplate;
import java.nio.charset.StandardCharsets;
import java.util.Base64;
import java.util.Iterator;
import java.util.Map;
/**
* 调用 Restful 接口 Util
*
* @author sunjianlei
*/
@Slf4j
public class RestUtil {
private static String domain = null;
private static String path = null;
/*private static String getDomain() {
if (domain == null) {
domain = SpringContextUtils.getDomain();
// issues/2959
// 微服务版集成企业微信单点登录
// 因为微服务版没有端口号，导致 SpringContextUtils.getDomain() 方法获取的域名的端口号变成了:-1所以出问题了，只需要把这个-1给去掉就可以了。
String port=":-1";
if (domain.endsWith(port)) {
domain = domain.substring(0, domain.length() - 3);
}
}
return domain;
}
private static String getPath() {
if (path == null) {
path = SpringContextUtils.getApplicationContext().getEnvironment().getProperty("server.servlet.context-path");
}
return oConvertUtils.getString(path);
}
public static String getBaseUrl() {
String basepath = getDomain() + getPath();
log.info(" RestUtil.getBaseUrl: " + basepath);
return basepath;
}*/
/**
* RestAPI 调用器
*/
private static RestTemplate RT;
static {
SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
requestFactory.setConnectTimeout(30*1000);
requestFactory.setReadTimeout(30*1000);
RT = new RestTemplate(requestFactory);
// 解决乱码问题
RT.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
}
public static RestTemplate getRestTemplate() {
return RT;
}
/**
* 发送 get 请求
*/
public static JSONObject get(String url) {
return getNative(url, null, null).getBody();
}
/**
* 发送 get 请求
*/
public static JSONObject get(String url, JSONObject variables) {
return getNative(url, variables, null).getBody();
}
/**
* 发送 get 请求
*/
public static JSONObject get(String url, JSONObject variables, JSONObject params) {
return getNative(url, variables, params).getBody();
}
/**
* 发送 get 请求，返回原生 ResponseEntity 对象
*/
public static ResponseEntity<JSONObject> getNative(String url, JSONObject variables, JSONObject params) {
return request(url, HttpMethod.GET, variables, params,null);
}
/**
* 发送 Post 请求
*/
public static JSONObject post(String url) {
return postNative(url, null, null,null).getBody();
}
/**
* 发送 Post 请求
*/
public static JSONObject post(String url, JSONObject params,JSONObject headers) {
return postNative(url, null, params,headers).getBody();
}
/**
* 发送 Post 请求
*/
public static JSONObject post(String url, JSONObject variables, JSONObject params,JSONObject headers) {
return postNative(url, variables, params,headers).getBody();
}
/**
* 发送 POST 请求，返回原生 ResponseEntity 对象
*/
public static ResponseEntity<JSONObject> postNative(String url, JSONObject variables, JSONObject params,JSONObject headers) {
return request(url, HttpMethod.POST, variables, params,headers);
}
/**
* 发送 put 请求
*/
public static JSONObject put(String url) {
return putNative(url, null, null,null).getBody();
}
/**
* 发送 put 请求
*/
public static JSONObject put(String url, JSONObject params) {
return putNative(url, null, params,null).getBody();
}
/**
* 发送 put 请求
*/
public static JSONObject put(String url, JSONObject variables, JSONObject params,JSONObject headers) {
return putNative(url, variables, params,headers).getBody();
}
/**
* 发送 put 请求，返回原生 ResponseEntity 对象
*/
public static ResponseEntity<JSONObject> putNative(String url, JSONObject variables, JSONObject params,JSONObject headers) {
return request(url, HttpMethod.PUT, variables, params,headers);
}
/**
* 发送 delete 请求
*/
public static JSONObject delete(String url) {
return deleteNative(url, null, null).getBody();
}
/**
* 发送 delete 请求
*/
public static JSONObject delete(String url, JSONObject variables, JSONObject params) {
return deleteNative(url, variables, params).getBody();
}
/**
* 发送 delete 请求，返回原生 ResponseEntity 对象
*/
public static ResponseEntity<JSONObject> deleteNative(String url, JSONObject variables, JSONObject params) {
return request(url, HttpMethod.DELETE, null, variables, params, JSONObject.class);
}
/**
* 发送请求
*/
public static ResponseEntity<JSONObject> request(String url, HttpMethod method, JSONObject variables, JSONObject params,JSONObject header) {
HttpHeaders headers=null;
if (header==null) {
headers = getHeaderApplicationJson();
}else{
headers= new HttpHeaders();
for (String s : header.keySet()) {
/*if ("Authorization".equals(s)) {
JSONObject jsonObject = header.getJSONObject(s);
String username = jsonObject.getString("username");
String password = jsonObject.getString("password");
String auth = username + ":" + password;
String encodedAuth = Base64.getEncoder().encodeToString(auth.getBytes(StandardCharsets.UTF_8));
headers.add(org.apache.hc.core5.http.HttpHeaders.AUTHORIZATION,"Basic " + encodedAuth);
continue;
}*/
headers.add(s,header.getString(s));
}
}
return request(url, method, headers, variables, params, JSONObject.class);
}
/**
* 发送请求
*
* @param url 请求地址
* @param method 请求方式
* @param headers 请求头 可空
* @param variables 请求url参数 可空
* @param params 请求body参数 可空
* @param responseType 返回类型
* @return ResponseEntity<responseType>
*/
public static <T> ResponseEntity<T> request(String url, HttpMethod method, HttpHeaders headers, JSONObject variables, Object params, Class<T> responseType) {
log.info(" RestUtil --- request --- url = "+ url);
if (StringUtils.isEmpty(url)) {
throw new RuntimeException("url 不能为空");
}
if (method == null) {
throw new RuntimeException("method 不能为空");
}
if (headers == null) {
headers = new HttpHeaders();
}
// 请求体
String body = "";
if (params != null) {
if (params instanceof JSONObject) {
body = ((JSONObject) params).toJSONString();
} else {
body = params.toString();
}
}
// 拼接 url 参数
if (variables != null && !variables.isEmpty()) {
url += ("?" + asUrlVariables(variables));
}
/*
try {
SslUtils.ignoreSsl();
} catch (Exception e) {
e.printStackTrace();
}*/
// 发送请求
HttpEntity<String> request = new HttpEntity<>(body, headers);
//回调接口
if (url.contains("callback")) {
SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
requestFactory.setConnectTimeout(30000);
requestFactory.setReadTimeout(30000);
RT = new RestTemplate(requestFactory);
}else{
SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
requestFactory.setConnectTimeout(300 *1000);
requestFactory.setReadTimeout(300* 1000);
RT = new RestTemplate(requestFactory);
}
// 解决乱码问题
RT.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
return RT.exchange(url, method, request, responseType);
}
/**
* 获取JSON请求头
*/
public static HttpHeaders getHeaderApplicationJson() {
return getHeader(MediaType.APPLICATION_JSON_UTF8_VALUE);
}
/**
* 获取请求头
*/
public static HttpHeaders getHeader(String mediaType) {
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.parseMediaType(mediaType));
headers.add("Accept", mediaType);
return headers;
}
/**
* 将 JSONObject 转为 a=1&b=2&c=3...&n=n 的形式
*/
public static String asUrlVariables(JSONObject variables) {
Map<String, Object> source = variables.getInnerMap();
Iterator<String> it = source.keySet().iterator();
StringBuilder urlVariables = new StringBuilder();
while (it.hasNext()) {
String key = it.next();
String value = "";
Object object = source.get(key);
if (object != null) {
if (!StringUtils.isEmpty(object.toString())) {
value = object.toString();
}
}
urlVariables.append("&").append(key).append("=").append(value);
}
// 去掉第一个&
return urlVariables.substring(1);
}
/*public static JSONObject postTest(String httpUrl,JSONObject requestBodyJson){
RestTemplate restTemplate = null;
try {
restTemplate = new RestTemplate(RestTemplateConfig.generateHttpRequestFactory());
} catch (NoSuchAlgorithmException e) {
e.printStackTrace();
} catch (KeyManagementException e) {
e.printStackTrace();
} catch (KeyStoreException e) {
e.printStackTrace();
}
String result = HttpUtil.post(httpUrl, requestBodyJson.toJSONString());
//打开建立连接
log.debug("post_responseBody:");
log.debug(result);
//获取返回结果
return JSONObject.parseObject(result);
}*/
}

104
src/main/java/com/example/zxweb/utils/RmsUtils.java
Unescape View File

@ -0,0 +1,104 @@
package com.example.zxweb.utils;
import com.alibaba.fastjson.JSONObject;
import com.example.zxweb.common.constant.enums.RmsApiEnum;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import springfox.documentation.spring.web.json.Json;
/**
* @Description 访客机工具类
* @Author ZhouWenTao
* @Date 2023/9/8 13:18
*/
@Component
@Slf4j
public class RmsUtils {
private static String TOKEN;
private static JSONObject header=new JSONObject();
static {
//请求头
header=new JSONObject();
header.put("AppCode","42142fd0jkbf4515853b7fcec64748f6");
header.put("devid","68EDA45C54F3");
//获取TOKEN
//getToken();
//header.put("TOKEN",TOKEN);
}
public static void getToken() {
JSONObject requestBody = JSONObject.parseObject("{\"email\":\"admin\", \"pswd\":\"cf79ae6addba60ad018347359bd144d2\"}");
JSONObject responseBody = RestUtil.post(RmsApiEnum.getApiByText("系统登陆"), requestBody, header);
AssertUtils.notNull(responseBody,"获取TOKEN失败");
String code = responseBody.getString("code");
String msg = responseBody.getString("msg");
AssertUtils.isTrue("0".equals(code),"获取TOKEN出错:"+msg);
JSONObject content = responseBody.getJSONObject("content");
TOKEN = content.getString("token");
}
/**
* 访客查询
* 本接口用于访客信息查询，查询出访客登记的所有信息，建议查询条件为当天时间+状态查询，不易跨月，多天的频繁调用，对服务压力大，查询结果为倒序排序。
* @param requestBody {"starttime":"2022-11-09","status":"0","num":1,"pageNum":1,"endtime":"2022-11-09"}
* @return {"code":0,"msg":"成功","pagecount":2,"pageNum":1,"content":[{"id":85,"rcode":"1486300085","parentid":null,"vid":88,"visitor":{"id":88,"name":"王麻子","sex":"男","nation":"汉","birthday":null,"idnum":"a543546aef4bdd46ac957554f3c4f8cd222498dd2c2d56d1a9e5939469930619","idnumAdd":"123456123456","idnumCipher":"04e08e6ebddced2dd94b588e039096a2111f8be98f9eb79e365a3443c697d699ac9f08b892821e2b3b4e22b54203084b4e111329918b810c2fc480637c830e2fe909a7b4e75c18c91da3a163441ea36123ca105526b68c11e570e6869bc4c6121825f116905de9107c1d7832b7","photo":null,"sitePhoto":null,"issuing":null,"validitydatestart":null,"validitydateend":null,"phone":"84537d95e88ce687e4efab251a746c7318dbe7cc2f6cecbb0840ce4889e7a2a5","phoneAdd":"13900074111","phoneCipher":"04d176b602a7ad1c6b9784adc7adef54e90c7e771f04aba9ca66c3cf3abfa0cc6163203fb4c1017381a7ccc6a396150af3070efa193cfc22d128294bc58a52705077cbba29dc322072e95815d5ed19e92ee7b2f2c0470e4e15ae0eb15fa8540df61b07dfd4a1256955bbd019","startTime":null,"endTime":null,"pinYin":"wmz","syncId":null,"companyCode":null,"isbindfinger":0,"isbindface":0,"wltPhoto":null,"tabTime":null,"uploadTime":null,"isVip":0,"sheetSize":null,"idphoto":null},"uid":20653,"user":{"id":20653,"nickname":"张三","userpinyin":null,"email":"abc10110","pswd":null,"terminalpswd":null,"createTime":null,"lastLoginTime":null,"status":1,"sex":1,"nation":null,"nations":null,"birthday":null,"address":null,"idNum":"1304331989111111","photo":"\\image\\idpic\\1304331989111111_20221108143849677.png","issuing":null,"validityDateStart":null,"validityDateEnd":null,"phone":"13931021490","dep":null,"depID":1049,"depSyncId":null,"depName":null,"telephone":"010123456","ecardNum":"12345678","ecardEndTime":"2042-11-30 00:00:00","pinYin":null,"syncId":"abc10110","companyNum":null,"sta":null,"imIP":null,"imTime":null,"entranceGuards":null,"isbindface":null,"visitable":null,"tabTime":null,"uploadTime":null,"idphoto":null,"plateNo":null,"plateTime":null,"plateIssue":null},"dept":{"id":1049,"value":"子级部门1","pinyin":"zjbm1","parentId":null,"syncId":"abc123","syncParentId":null,"companyNum":null,"sta":null,"visitable":null,"sortnum":null,"tabTime":null,"uploadTime":null},"createtime":"2022-11-09 13:44:46","starttime":"2022-11-09 13:44:00","endtime":"2022-11-09 23:59:00","logofftime":null,"status":0,"reasons":"访问","unit":"公司名称","num":1,"type":0,"isprintvoucher":0,"ispullcard":1,"cardtype":0,"cardnum":"1234512345","sitephoto":null,"headphoto":null,"vCar":{"id":180,"cardnum":"京A99999","cardcolor":null,"num":null,"arid":85,"companyCode":null,"tabTime":null,"uploadTime":null},"drList":[],"trList":[],"isUpload":0,"pageNum":null,"yyID":null,"companyCode":"000000","terminalCode":"1000002","terminalManagerId":1038,"zhuxiaoManagerId":null,"tabTime":"2022-11-09 13:44:46","uploadTime":null,"syncId":null,"tiwen":35.0,"terminalManagerName":null,"zhuxiaoManagerName":null,"zhuxiaoTerminalCode":null,"channels":"","comment":"","xckStatus":0,"xckvisitedArea":null,"xckPhone":null,"xckUpdateTime":null,"xckPhoto":null,"jkbPhoto":null,"healthStatus":null,"lastRNATime":null,"lastRNAResult":null,"travelStatus":null,"tel":null,"vcar":{"id":180,"cardnum":"京A99999","cardcolor":null,"num":null,"arid":85,"companyCode":null,"tabTime":null,"uploadTime":null}}],"success":true}
*/
public static JSONObject fkterminalFindAccessRecord(JSONObject requestBody){
String starttime = requestBody.getString("starttime");//开始时间*
String status = requestBody.getString("status");//状态：-1超时未注销、0登记中、1已注销3预约
String pageNum = requestBody.getString("pageNum");//页数
String num = requestBody.getString("num");//查询条数
String endtime = requestBody.getString("endtime");//结束时间*
AssertUtils.notEmpty(starttime,"请输入开始时间-[starttime]");
AssertUtils.notEmpty(endtime,"请输入结束时间-[endtime]");
JSONObject responseBody = RestUtil.post(RmsApiEnum.getApiByText("访客查询"), requestBody, header);
AssertUtils.notNull(responseBody,"请求失败");
Integer code = responseBody.getInteger("code");
AssertUtils.isTrue(0==code,"请求异常:"+responseBody.getString("msg"));
return responseBody;
}
/**
* 访客预约
* @param requestBody {"reason":"拜访","synId":"abc10110","visitorBeginTime":"2022-11-08 10:00:00","visitorEndTime":"2022-11-08 18:00:00","visitorCmp":"访客部","visitorIdNum":"1234567890123","visitorName":"访客","visitorPhone":"1300000000"}
* @return {"code":0,"msg":"预约成功","pagecount":null,"pageNum":null,"content":null,"success":true}
*/
public static JSONObject syncOrderrecord(JSONObject requestBody){
String reason = requestBody.getString("reason");//状态
String synId = requestBody.getString("synId");//被访人ID*
String visitorBeginTime = requestBody.getString("visitorBeginTime");//来访时间 yyyy-MM-dd HH:mm:ss yyyy*
String visitorEndTime = requestBody.getString("visitorEndTime");//结束时间 yyyy-MM-dd HH:mm:ss*
String visitorCmp = requestBody.getString("visitorCmp");//访客单位
String visitorIdNum = requestBody.getString("visitorIdNum");//访客证件号码*
String visitorName = requestBody.getString("visitorName");//访客姓名*
String visitorPhone = requestBody.getString("visitorPhone");//访客手机号
AssertUtils.notEmpty(synId,"请输入被访客ID-[synId]");
AssertUtils.notEmpty(visitorBeginTime,"请输入来访时间-[visitorBeginTime]");
AssertUtils.notEmpty(visitorEndTime,"请输入结束时间-[visitorEndTime]");
AssertUtils.notEmpty(visitorIdNum,"请输入访客证件号-[visitorIdNum]");
AssertUtils.notEmpty(visitorName,"请输入访客姓名-[visitorName]");
JSONObject responseBody = RestUtil.post(RmsApiEnum.getApiByText("访客预约"), requestBody, header);
AssertUtils.notNull(responseBody,"请求接口异常");
Integer code = responseBody.getInteger("code");
AssertUtils.isTrue(code==0,"请求访客预约接口异常:"+requestBody.getOrDefault("msg",""));
return responseBody;
}
/**
* 访客注销
* 本接口用于主动调用访客系统注销，针对于发卡用户使用，比如：访客登记发放门禁卡，出门注销时可调用此接口
* @param requestBody {"cardNum":"1234567888"}
* @return {"code":0,"msg":"成功","pagecount":null,"pageNum":null,"content":null,"success":true}
*/
public static JSONObject fkterminalRecoverCard(JSONObject requestBody) {
String cardNum = requestBody.getString("cardNum");
AssertUtils.notEmpty(cardNum,"清输入访客证件号-[cardNum]");
JSONObject responseBody = RestUtil.post(RmsApiEnum.getApiByText("访客注销"), requestBody, header);
AssertUtils.notNull(responseBody,"请求失败");
Integer code = responseBody.getInteger("code");
AssertUtils.isTrue(0==code,"请求异常:"+responseBody.getString("msg"));
return responseBody;
}
}

29
src/main/java/com/example/zxweb/vo/QueryDevicesVO.java
Unescape View File

@ -0,0 +1,29 @@
package com.example.zxweb.vo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;
import java.io.Serializable;
/**
* @Description
* @Author ZhouWenTao
* @Date 2023/9/8 11:46
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@ApiModel(value="获取单个设备信息入参", description="获取单个设备信息入参")
public class QueryDevicesVO implements Serializable {
@ApiModelProperty(value = "设备序列号")
public String serial;
@ApiModelProperty(value = "产品序列号")
public String productId;
}

510
word/swagger-inone-api.json
Unescape View File

@ -0,0 +1,510 @@
{
"swagger": "2.0",
"info": {
"version": "v1",
"title": "设备管理"
},
"tags": [],
"basePath": "",
"paths": {
"/api/iot/v1/devices": {
"get": {
"summary": "获取单个设备信息",
"description": "",
"parameters": [{
"name": "serial",
"in": "query",
"description": "设备序列号",
"required": true,
"type": "string"
},
{
"in": "query",
"name": "productId",
"description": "产品序列号",
"required": false,
"type": "string"
}],
"responses": {
"200": {
"description": "成功"
},
"400": {
"description": "失败，请求不合法"
},
"422": {
"description": "失败，请求参数不合法"
},
"444": {
"description": "失败，出现了业务错误"
}
}
}
},
"/api/iot/v1/devices/list": {
"get": {
"summary": "获取设备列表",
"description": "",
"parameters": [{
"name": "serial",
"in": "query",
"description": "产品序列号",
"required": true,
"type": "string"
},
{
"in": "query",
"name": "modelCode",
"description": "设备类型",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "authority",
"description": "设备属性",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "pageSize",
"description": "分页大小",
"required": false,
"type": "integer",
"format": "int32"
},
{
"in": "query",
"name": "pageNo",
"description": "分页序号",
"required": false,
"type": "integer",
"format": "int32"
},
{
"in": "query",
"name": "startTime",
"description": "开始时间",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "endTime",
"description": "结束时间",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "sort",
"description": "排序",
"required": false,
"type": "string"
}],
"responses": {
"200": {
"description": "成功"
},
"400": {
"description": "失败，请求不合法"
},
"422": {
"description": "失败，请求参数不合法"
},
"444": {
"description": "失败，出现了业务错误"
}
}
}
},
"/api/iot/v1/devices/datastreams": {
"post": {
"summary": "向设备发送消息",
"description": "",
"parameters": [{
"in": "body",
"name": "body",
"required": false,
"schema": {
"type": "object",
"required": ["dataStreamInfo"],
"properties": {
"dataStreamInfo": {
"type": "object",
"required": ["productId",
"serial",
"dataStreams"],
"properties": {
"productId": {
"type": "string",
"description": "产品序列号"
},
"serial": {
"type": "string",
"description": "设备序列号"
},
"dataStreams": {
"type": "array",
"items": {
"type": "object",
"required": ["streamName",
"streamValue"],
"properties": {
"streamName": {
"type": "string",
"description": "数据流名称"
},
"streamValue": {
"type": "string",
"description": "数据流值"
}
}
}
}
}
}
}
}
}],
"responses": {
"201": {
"description": "成功"
},
"400": {
"description": "失败，请求不合法"
},
"422": {
"description": "失败，请求参数不合法"
},
"444": {
"description": "失败，出现了业务错误"
}
}
},
"get": {
"summary": "查询设备历史数据",
"description": "",
"parameters": [{
"in": "query",
"name": "serial",
"description": "设备序列号",
"required": true,
"type": "string"
},
{
"in": "query",
"name": "dataStreamName",
"description": "数据流能力名称",
"required": true,
"type": "string"
},
{
"in": "query",
"name": "productId",
"description": "产品序列号",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "pageSize",
"description": "分页大小",
"required": false,
"type": "integer",
"format": "int32"
},
{
"in": "query",
"name": "pageNo",
"description": "分页序列号",
"required": false,
"type": "integer",
"format": "int32"
},
{
"in": "query",
"name": "startTime",
"description": "开始时间",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "endTime",
"description": "结束时间",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "sort",
"description": "排序",
"required": false,
"type": "string"
}],
"responses": {
"200": {
"description": "成功"
},
"400": {
"description": "失败，请求不合法"
},
"422": {
"description": "失败，请求参数不合法"
},
"444": {
"description": "失败，出现了业务错误"
}
}
}
},
"/api/iot/v1/devices/datastreams/state": {
"get": {
"summary": "查询消息是否下达到设备",
"description": "",
"parameters": [{
"in": "query",
"name": "serial",
"description": "设备序列号",
"required": true,
"type": "string"
},
{
"in": "query",
"name": "streamCinId",
"description": "能力实例序列号",
"required": true,
"type": "string"
},
{
"in": "query",
"name": "productId",
"description": "产品序列号",
"required": false,
"type": "string"
}],
"responses": {
"200": {
"description": "成功"
},
"400": {
"description": "失败，请求不合法"
},
"422": {
"description": "失败，请求参数不合法"
},
"444": {
"description": "失败，出现了业务错误"
}
}
}
},
"/api/iot/v1/devices/events": {
"get": {
"summary": "查询事件历史数据",
"description": "",
"parameters": [{
"in": "query",
"name": "serial",
"description": "设备序列号",
"required": true,
"type": "string"
},
{
"in": "query",
"name": "dataStreamName",
"description": "数据流能力名称",
"required": true,
"type": "string"
},
{
"in": "query",
"name": "productId",
"description": "产品序列号",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "pageSize",
"description": "分页大小",
"required": false,
"type": "integer",
"format": "int32"
},
{
"in": "query",
"name": "pageNo",
"description": "分页序列号",
"required": false,
"type": "integer",
"format": "int32"
},
{
"in": "query",
"name": "startTime",
"description": "开始时间",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "endTime",
"description": "结束时间",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "sort",
"description": "排序",
"required": false,
"type": "string"
}],
"responses": {
"200": {
"description": "成功"
},
"400": {
"description": "失败，请求不合法"
},
"422": {
"description": "失败，请求参数不合法"
},
"444": {
"description": "失败，出现了业务错误"
}
}
}
},
"/api/iot/v1/devices/methods": {
"post": {
"summary": "向设备发送方法",
"description": "",
"parameters": [{
"in": "body",
"name": "body",
"required": false,
"schema": {
"type": "object",
"required": ["serial",
"methodName",
"inputData"],
"properties": {
"serial": {
"type": "string",
"description": "设备序列号"
},
"productId": {
"type": "string",
"description": "产品序列号"
},
"methodName": {
"type": "string",
"description": "方法名称"
},
"inputData": {
"type": "object",
"description": "方法参数"
}
}
}
}],
"responses": {
"201": {
"description": "success"
},
"400": {
"description": "error, request is invalid."
},
"422": {
"description": "error, request parameter is invalid."
},
"444": {
"description": "error, exception occurred."
}
}
},
"get": {
"summary": "查询方法历史数据",
"description": "",
"parameters": [{
"in": "query",
"name": "serial",
"description": "设备序列号",
"required": true,
"type": "string"
},
{
"in": "query",
"name": "methodName",
"description": "方法名称",
"required": true,
"type": "string"
},
{
"in": "query",
"name": "productId",
"description": "产品序列号",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "pageSize",
"description": "分页大小",
"required": false,
"type": "integer",
"format": "int32"
},
{
"in": "query",
"name": "pageNo",
"description": "分页序列号",
"required": false,
"type": "integer",
"format": "int32"
},
{
"in": "query",
"name": "startTime",
"description": "开始时间",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "endTime",
"description": "结束时间",
"required": false,
"type": "string"
},
{
"in": "query",
"name": "sort",
"description": "排序",
"required": false,
"type": "string"
}],
"responses": {
"200": {
"description": "成功"
},
"400": {
"description": "失败，请求不合法"
},
"422": {
"description": "失败，请求参数不合法"
},
"444": {
"description": "失败，出现了业务错误"
}
}
}
}
},
"definitions": {}
}
Write Preview
Loading…
Cancel
Save