正在显示
2 个修改的文件
包含
45 行增加
和
2 行删除
lh-api/src/main/java/com/zhonglai/luhui/api/controller/user/UserTerminalGroupRelationController.java
| 1 | package com.zhonglai.luhui.api.controller.user; | 1 | package com.zhonglai.luhui.api.controller.user; |
| 2 | 2 | ||
| 3 | +import java.util.ArrayList; | ||
| 3 | import java.util.List; | 4 | import java.util.List; |
| 5 | +import java.util.Map; | ||
| 4 | import javax.servlet.http.HttpServletResponse; | 6 | import javax.servlet.http.HttpServletResponse; |
| 5 | 7 | ||
| 8 | +import com.alibaba.fastjson.JSON; | ||
| 9 | +import com.alibaba.fastjson.JSONObject; | ||
| 10 | +import com.ruoyi.common.utils.StringUtils; | ||
| 11 | +import com.ruoyi.common.utils.bean.BeanUtils; | ||
| 12 | +import com.ruoyi.system.service.PublicService; | ||
| 6 | import io.swagger.annotations.Api; | 13 | import io.swagger.annotations.Api; |
| 7 | import io.swagger.annotations.ApiOperation; | 14 | import io.swagger.annotations.ApiOperation; |
| 8 | import org.springframework.security.access.prepost.PreAuthorize; | 15 | import org.springframework.security.access.prepost.PreAuthorize; |
| @@ -38,6 +45,8 @@ public class UserTerminalGroupRelationController extends BaseController | @@ -38,6 +45,8 @@ public class UserTerminalGroupRelationController extends BaseController | ||
| 38 | @Autowired | 45 | @Autowired |
| 39 | private IUserTerminalGroupRelationService userTerminalGroupRelationService; | 46 | private IUserTerminalGroupRelationService userTerminalGroupRelationService; |
| 40 | 47 | ||
| 48 | + @Autowired | ||
| 49 | + private PublicService publicService; | ||
| 41 | /** | 50 | /** |
| 42 | * 查询终端分组关系列表 | 51 | * 查询终端分组关系列表 |
| 43 | */ | 52 | */ |
| @@ -52,6 +61,26 @@ public class UserTerminalGroupRelationController extends BaseController | @@ -52,6 +61,26 @@ public class UserTerminalGroupRelationController extends BaseController | ||
| 52 | return getDataTable(list); | 61 | return getDataTable(list); |
| 53 | } | 62 | } |
| 54 | 63 | ||
| 64 | + @ApiOperation("查询未分组终端") | ||
| 65 | + @PreAuthorize("@ss.hasPermi('user:UserTerminalGroupRelation:unGrouplist')") | ||
| 66 | + @GetMapping("/unGrouplist") | ||
| 67 | + public AjaxResult unGrouplist() | ||
| 68 | + { | ||
| 69 | + List<Map<String,Object>> list = publicService.getObjectListBySQL("SELECT * FROM `user_terminal_group_relation` WHERE user_info_id="+getUserId().intValue()+" AND iot_terminal_group_id IS NULL"); | ||
| 70 | + if(null != list && list.size() != 0) | ||
| 71 | + { | ||
| 72 | + List<UserTerminalGroupRelation> rlist = new ArrayList<>(); | ||
| 73 | + | ||
| 74 | + for (Map<String,Object> map:list) | ||
| 75 | + { | ||
| 76 | + UserTerminalGroupRelation userTerminalGroupRelation = JSON.parseObject(JSON.toJSONString(map),UserTerminalGroupRelation.class); | ||
| 77 | + rlist.add(userTerminalGroupRelation); | ||
| 78 | + } | ||
| 79 | + return AjaxResult.success(rlist); | ||
| 80 | + } | ||
| 81 | + return AjaxResult.success(""); | ||
| 82 | + } | ||
| 83 | + | ||
| 55 | /** | 84 | /** |
| 56 | * 导出终端分组关系列表 | 85 | * 导出终端分组关系列表 |
| 57 | */ | 86 | */ |
| @@ -86,7 +115,21 @@ public class UserTerminalGroupRelationController extends BaseController | @@ -86,7 +115,21 @@ public class UserTerminalGroupRelationController extends BaseController | ||
| 86 | @PostMapping | 115 | @PostMapping |
| 87 | public AjaxResult add(@RequestBody UserTerminalGroupRelation userTerminalGroupRelation) | 116 | public AjaxResult add(@RequestBody UserTerminalGroupRelation userTerminalGroupRelation) |
| 88 | { | 117 | { |
| 89 | - return toAjax(userTerminalGroupRelationService.insertUserTerminalGroupRelation(userTerminalGroupRelation)); | 118 | + String iotTerminalIds = userTerminalGroupRelation.getIot_terminal_id(); |
| 119 | + if(StringUtils.isEmpty(iotTerminalIds)) | ||
| 120 | + { | ||
| 121 | + return AjaxResult.error("终端id必填"); | ||
| 122 | + } | ||
| 123 | + List<UserTerminalGroupRelation> list = new ArrayList<>(); | ||
| 124 | + String[] is = iotTerminalIds.split(","); | ||
| 125 | + for(String iotTerminalId:is) | ||
| 126 | + { | ||
| 127 | + UserTerminalGroupRelation newuserTerminalGroupRelation = new UserTerminalGroupRelation(); | ||
| 128 | + BeanUtils.copyBeanProp(newuserTerminalGroupRelation,userTerminalGroupRelation); | ||
| 129 | + newuserTerminalGroupRelation.setIot_terminal_id(iotTerminalId); | ||
| 130 | + list.add(newuserTerminalGroupRelation); | ||
| 131 | + } | ||
| 132 | + return toAjax( publicService.insertAll(list)); | ||
| 90 | } | 133 | } |
| 91 | 134 | ||
| 92 | /** | 135 | /** |
| 1 | -# 项目相关配置 jhlt: # 名称 name: zhonglai # 版本 version: 3.8.2 # 版权年份 copyrightYear: 2022 # 实例演示开关 demoEnabled: true # 文件路径 示例( Windows配置D:/ruoyi/uploadPath,Linux配置 /home/ruoyi/uploadPath) profile: D:/ruoyi/uploadPath # 获取ip地址开关 addressEnabled: false # 验证码类型 math 数组计算 char 字符验证 captchaType: math # 开发环境配置 server: # 服务器的HTTP端口,默认为8080 port: 18080 servlet: # 应用的访问路径 context-path: / tomcat: # tomcat的URI编码 uri-encoding: UTF-8 # 连接数满后的排队数,默认为100 accept-count: 1000 threads: # tomcat最大线程数,默认为200 max: 800 # Tomcat启动初始化的线程数,默认值10 min-spare: 100 # 日志配置 logging: level: com.ruoyi: debug org.springframework: warn # Spring配置 spring: # 资源信息 messages: # 国际化资源文件路径 basename: i18n/messages profiles: active: druid # 文件上传 servlet: multipart: # 单个文件大小 max-file-size: 10MB # 设置总上传的文件大小 max-request-size: 20MB # 服务模块 devtools: restart: # 热部署开关 enabled: true # redis 配置 redis: # 地址 host: 47.112.163.61 # 端口,默认为6379 port: 9527 # 数据库索引 database: 1 # 密码 password: Luhui586 # 连接超时时间 timeout: 10s lettuce: pool: # 连接池中的最小空闲连接 min-idle: 0 # 连接池中的最大空闲连接 max-idle: 8 # 连接池的最大数据库连接数 max-active: 8 # #连接池最大阻塞等待时间(使用负值表示没有限制) max-wait: -1ms # token配置 token: # 令牌自定义标识 header: Authorization # 令牌密钥 secret: abcdefghijklmnopqrstuvwxyz # 令牌有效期(默认30分钟) expireTime: 1440 rediskey: lh-api # MyBatis配置 mybatis: # 搜索指定包别名 typeAliasesPackage: com.ruoyi.**.domain # 配置mapper的扫描,找到所有的mapper.xml映射文件 mapperLocations: classpath*:mapper/**/*Mapper.xml # 加载全局的配置文件 configLocation: classpath:mybatis/mybatis-config.xml # PageHelper分页插件 pagehelper: helperDialect: mysql supportMethodsArguments: true params: count=countSql # Swagger配置 swagger: # 是否开启swagger enabled: true # 请求前缀 pathMapping: /dev-api # 防止XSS攻击 xss: # 过滤开关 enabled: true # 排除链接(多个用逗号分隔) excludes: /system/notice # 匹配链接 urlPatterns: /system/*,/monitor/*,/tool/* mqtt: client: device_life: 180 sys: ## // 对于登录login 注册register 验证码captchaImage 允许匿名访问 antMatchers: /login/ApiLogin/* | ||
| 1 | +# 项目相关配置 jhlt: # 名称 name: zhonglai # 版本 version: 3.8.2 # 版权年份 copyrightYear: 2022 # 实例演示开关 demoEnabled: true # 文件路径 示例( Windows配置D:/ruoyi/uploadPath,Linux配置 /home/ruoyi/uploadPath) profile: D:/ruoyi/uploadPath # 获取ip地址开关 addressEnabled: false # 验证码类型 math 数组计算 char 字符验证 captchaType: math # 开发环境配置 server: # 服务器的HTTP端口,默认为8080 port: 18080 servlet: # 应用的访问路径 context-path: / tomcat: # tomcat的URI编码 uri-encoding: UTF-8 # 连接数满后的排队数,默认为100 accept-count: 1000 threads: # tomcat最大线程数,默认为200 max: 800 # Tomcat启动初始化的线程数,默认值10 min-spare: 100 # 日志配置 logging: level: com.ruoyi: debug org.springframework: warn # Spring配置 spring: # 资源信息 messages: # 国际化资源文件路径 basename: i18n/messages profiles: active: druid # 文件上传 servlet: multipart: # 单个文件大小 max-file-size: 10MB # 设置总上传的文件大小 max-request-size: 20MB # 服务模块 devtools: restart: # 热部署开关 enabled: true # redis 配置 redis: # 地址 host: 47.112.163.61 # 端口,默认为6379 port: 9527 # 数据库索引 database: 1 # 密码 password: Luhui586 # 连接超时时间 timeout: 10s lettuce: pool: # 连接池中的最小空闲连接 min-idle: 0 # 连接池中的最大空闲连接 max-idle: 8 # 连接池的最大数据库连接数 max-active: 8 # #连接池最大阻塞等待时间(使用负值表示没有限制) max-wait: -1ms # token配置 token: # 令牌自定义标识 header: Authorization # 令牌密钥 secret: abcdefghijklmnopqrstuvwxyz # 令牌有效期(默认30分钟) expireTime: 1440 rediskey: lh-api # MyBatis配置 mybatis: # 搜索指定包别名 typeAliasesPackage: com.ruoyi.**.domain # 配置mapper的扫描,找到所有的mapper.xml映射文件 mapperLocations: classpath*:mapper/**/*Mapper.xml # 加载全局的配置文件 configLocation: classpath:mybatis/mybatis-config.xml # PageHelper分页插件 pagehelper: helperDialect: mysql supportMethodsArguments: true params: count=countSql # Swagger配置 swagger: # 是否开启swagger enabled: true # 请求前缀 pathMapping: /dev-api # 防止XSS攻击 xss: # 过滤开关 enabled: true # 排除链接(多个用逗号分隔) excludes: /system/notice # 匹配链接 urlPatterns: /system/*,/monitor/*,/tool/* mqtt: client: device_life: 180 sys: ## // 对于登录login 注册register 验证码captchaImage 允许匿名访问 antMatchers: /login/ApiLogin/* # NameServer地址 rocketmq: name-server: 47.115.144.179:9876 # 默认的消息组 producer: group: deviceCommand send-message-timeout: 30000 send-topic: lh-api-test send-tags: 1 |
-
请 注册 或 登录 后发表评论