diff --git a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/controller/admin/InterphoneOpenController.java b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/controller/admin/InterphoneOpenController.java new file mode 100644 index 0000000..44a65d0 --- /dev/null +++ b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/controller/admin/InterphoneOpenController.java @@ -0,0 +1,245 @@ +package cn.iocoder.yudao.module.interphone.controller.admin; + +import cn.iocoder.yudao.framework.common.pojo.CommonResult; +import cn.iocoder.yudao.module.interphone.service.InterphoneApiService; +import io.swagger.v3.oas.annotations.Operation; +import io.swagger.v3.oas.annotations.Parameter; +import io.swagger.v3.oas.annotations.Parameters; +import io.swagger.v3.oas.annotations.tags.Tag; +import jakarta.annotation.Resource; +import jakarta.annotation.security.PermitAll; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; + +import java.util.Map; + +import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success; + +@Tag(name = "开放接口 - 对讲平台代理") +@RestController +@RequestMapping("/interphone/open-api") +@Validated +public class InterphoneOpenController { + + @Resource + private InterphoneApiService interphoneApiService; + + @GetMapping("/profile/agent") + @Operation(summary = "获取代理商个人信息") + @PermitAll + public CommonResult getAgentProfile() { + return success(interphoneApiService.getAgentProfile()); + } + + @GetMapping("/agent/list") + @Operation(summary = "查询代理商列表") + @Parameters({ + @Parameter(name = "pageNo", description = "页码", required = true), + @Parameter(name = "pageSize", description = "每页数量", required = true), + @Parameter(name = "name", description = "代理商名称") + }) + @PermitAll + public CommonResult getAgentList(@RequestParam("pageNo") Integer pageNo, + @RequestParam("pageSize") Integer pageSize, + @RequestParam(value = "name", required = false) String name) { + return success(interphoneApiService.getAgentList(pageNo, pageSize, name)); + } + + @GetMapping("/agent/detail") + @Operation(summary = "查询代理商详情") + @Parameter(name = "id", description = "代理商 ID", required = true) + @PermitAll + public CommonResult getAgentDetail(@RequestParam("id") String id) { + return success(interphoneApiService.getAgentDetail(id)); + } + + @GetMapping("/profile/faststats") + @Operation(summary = "查询代理商单位群组用户统计") + @PermitAll + public CommonResult getFastStats() { + return success(interphoneApiService.getFastStats()); + } + + @GetMapping("/group/getGroupName") + @Operation(summary = "查询群组名称") + @Parameter(name = "orgId", description = "单位 ID", required = true) + @PermitAll + public CommonResult getGroupName(@RequestParam("orgId") String orgId) { + return success(interphoneApiService.getGroupName(orgId)); + } + + @GetMapping("/terminal/querySubordinateUser") + @Operation(summary = "查询下级用户") + @Parameters({ + @Parameter(name = "pageNo", description = "页码", required = true), + @Parameter(name = "pageSize", description = "每页数量", required = true), + @Parameter(name = "agentId", description = "代理商 ID"), + @Parameter(name = "orgId", description = "单位 ID"), + @Parameter(name = "groupId", description = "群组 ID"), + @Parameter(name = "userName", description = "用户名称"), + @Parameter(name = "account", description = "账号") + }) + @PermitAll + public CommonResult querySubordinateUser(@RequestParam("pageNo") Integer pageNo, + @RequestParam("pageSize") Integer pageSize, + @RequestParam(value = "agentId", required = false) String agentId, + @RequestParam(value = "orgId", required = false) String orgId, + @RequestParam(value = "groupId", required = false) String groupId, + @RequestParam(value = "userName", required = false) String userName, + @RequestParam(value = "account", required = false) String account) { + return success(interphoneApiService.querySubordinateUser(pageNo, pageSize, agentId, orgId, groupId, userName, account)); + } + + @GetMapping("/agent/orgs") + @Operation(summary = "查询单位列表") + @Parameters({ + @Parameter(name = "pageNo", description = "页码", required = true), + @Parameter(name = "pageSize", description = "每页数量", required = true), + @Parameter(name = "name", description = "单位名称") + }) + @PermitAll + public CommonResult getAgentOrgs(@RequestParam("pageNo") Integer pageNo, + @RequestParam("pageSize") Integer pageSize, + @RequestParam(value = "name", required = false) String name) { + return success(interphoneApiService.getAgentOrgs(pageNo, pageSize, name)); + } + + @GetMapping("/group/list") + @Operation(summary = "查询群组列表") + @Parameters({ + @Parameter(name = "pageNo", description = "页码", required = true), + @Parameter(name = "pageSize", description = "每页数量", required = true), + @Parameter(name = "name", description = "群组名称"), + @Parameter(name = "orgname", description = "单位名称") + }) + @PermitAll + public CommonResult getGroupList(@RequestParam("pageNo") Integer pageNo, + @RequestParam("pageSize") Integer pageSize, + @RequestParam(value = "name", required = false) String name, + @RequestParam(value = "orgname", required = false) String orgName) { + return success(interphoneApiService.getGroupList(pageNo, pageSize, name, orgName)); + } + + @PostMapping("/group/add") + @Operation(summary = "新增群组") + @PermitAll + public CommonResult addGroup(@RequestBody String requestBody) { + return success(interphoneApiService.addGroup(requestBody)); + } + + @GetMapping("/group/detail") + @Operation(summary = "查询群组详情") + @Parameter(name = "id", description = "群组 ID", required = true) + @PermitAll + public CommonResult getGroupDetail(@RequestParam("id") String id) { + return success(interphoneApiService.getGroupDetail(id)); + } + + @PostMapping("/group/updateGroup") + @Operation(summary = "编辑群组") + @PermitAll + public CommonResult updateGroup(@RequestBody String requestBody) { + return success(interphoneApiService.updateGroup(requestBody)); + } + + @PostMapping("/group/delete") + @Operation(summary = "删除群组") + @PermitAll + public CommonResult deleteGroup(@RequestBody String requestBody) { + return success(interphoneApiService.deleteGroup(requestBody)); + } + + @GetMapping("/group/members") + @Operation(summary = "获取群组成员") + @Parameter(name = "id", description = "群组 ID", required = true) + @PermitAll + public CommonResult getGroupMembers(@RequestParam("id") String id) { + return success(interphoneApiService.getGroupMembers(id)); + } + + @PostMapping("/group/members/add") + @Operation(summary = "添加群组成员") + @PermitAll + public CommonResult addGroupMembers(@RequestBody String requestBody) { + return success(interphoneApiService.addGroupMembers(requestBody)); + } + + @PostMapping("/group/members/remove") + @Operation(summary = "移除群组成员") + @PermitAll + public CommonResult removeGroupMembers(@RequestBody String requestBody) { + return success(interphoneApiService.removeGroupMembers(requestBody)); + } + + @GetMapping("/jsp/queryGroupByUId") + @Operation(summary = "查询用户群组") + @PermitAll + public CommonResult queryGroupByUid(@RequestParam Map queryParams) { + return success(interphoneApiService.queryGroupByUid(queryParams)); + } + + @PostMapping("/terminal/batch") + @Operation(summary = "创建对讲用户") + @PermitAll + public CommonResult createTerminalUsers(@RequestBody String requestBody) { + return success(interphoneApiService.createTerminalUsers(requestBody)); + } + + @GetMapping("/terminal/list") + @Operation(summary = "查询对讲用户列表") + @Parameters({ + @Parameter(name = "pageNo", description = "页码", required = true), + @Parameter(name = "pageSize", description = "每页数量", required = true), + @Parameter(name = "org_id", description = "单位 ID"), + @Parameter(name = "groupId", description = "群组 ID"), + @Parameter(name = "name", description = "用户名称") + }) + @PermitAll + public CommonResult getTerminalList(@RequestParam("pageNo") Integer pageNo, + @RequestParam("pageSize") Integer pageSize, + @RequestParam(value = "org_id", required = false) String orgId, + @RequestParam(value = "groupId", required = false) String groupId, + @RequestParam(value = "name", required = false) String name) { + return success(interphoneApiService.getTerminalList(pageNo, pageSize, orgId, groupId, name)); + } + + @GetMapping("/terminal/detail") + @Operation(summary = "查询对讲用户详情") + @PermitAll + public CommonResult getTerminalDetail(@RequestParam Map queryParams) { + return success(interphoneApiService.getTerminalDetail(queryParams)); + } + + @PostMapping("/terminal/updateUser") + @Operation(summary = "修改对讲用户信息") + @PermitAll + public CommonResult updateTerminalUser(@RequestBody String requestBody) { + return success(interphoneApiService.updateTerminalUser(requestBody)); + } + + @PostMapping("/terminal/deleteUser") + @Operation(summary = "删除对讲用户") + @PermitAll + public CommonResult deleteTerminalUser(@RequestBody String requestBody) { + return success(interphoneApiService.deleteTerminalUser(requestBody)); + } + + @GetMapping("/terminal/userOnlineStatus") + @Operation(summary = "查询对讲用户在线状态") + @PermitAll + public CommonResult getTerminalUserOnlineStatus(@RequestParam Map queryParams) { + return success(interphoneApiService.getTerminalUserOnlineStatus(queryParams)); + } + + @GetMapping("/record/list") + @Operation(summary = "查询录音列表") + @PermitAll + public CommonResult getRecordList(@RequestParam Map queryParams) { + return success(interphoneApiService.getRecordList(queryParams)); + } +} diff --git a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/core/ApiClient.java b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/core/ApiClient.java index 52c6602..44ca447 100644 --- a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/core/ApiClient.java +++ b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/core/ApiClient.java @@ -66,19 +66,22 @@ public class ApiClient { } private ApiResponse doExecute(ApiRequest apiRequest) throws IOException { - String url = QueryStringBuilder.build( + String rawUrl = QueryStringBuilder.build( properties.getApiUrl(), apiRequest.getPath(), apiRequest.getQueryParams() ); - Request.Builder builder = new Request.Builder().url(url); + HttpUrl.Builder urlBuilder = Objects.requireNonNull(HttpUrl.parse(rawUrl), "无效请求地址").newBuilder(); if (apiRequest.isNeedToken()) { Author author = tokenManager.getAuthor(); - builder.url(url + "?access_token=" + author.getAccessToken() + "&openid=" + author.getOpenId()); + urlBuilder.addQueryParameter("access_token", author.getAccessToken()); + urlBuilder.addQueryParameter("openid", author.getOpenId()); } + Request.Builder builder = new Request.Builder().url(urlBuilder.build()); + if (apiRequest.getHeaders() != null) { for (Map.Entry entry : apiRequest.getHeaders().entrySet()) { builder.header(entry.getKey(), entry.getValue()); @@ -113,4 +116,4 @@ public class ApiClient { } return RetryDecision.noRetry(); } -} \ No newline at end of file +} diff --git a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/core/ApiRequest.java b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/core/ApiRequest.java index 75891d9..08e5dd9 100644 --- a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/core/ApiRequest.java +++ b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/core/ApiRequest.java @@ -1,10 +1,13 @@ package cn.iocoder.yudao.module.interphone.core; +import lombok.Getter; + import java.util.HashMap; import java.util.Map; +@Getter public class ApiRequest { private HttpMethod method; @@ -15,50 +18,26 @@ public class ApiRequest { private boolean needToken = true; - public HttpMethod getMethod() { - return method; - } - public void setMethod(HttpMethod method) { this.method = method; } - public String getPath() { - return path; - } - public void setPath(String path) { this.path = path; } - public Map getQueryParams() { - return queryParams; - } - public void setQueryParams(Map queryParams) { this.queryParams = queryParams; } - public Map getHeaders() { - return headers; - } - public void setHeaders(Map headers) { this.headers = headers; } - public String getJsonBody() { - return jsonBody; - } - public void setJsonBody(String jsonBody) { this.jsonBody = jsonBody; } - public boolean isNeedToken() { - return needToken; - } - public void setNeedToken(boolean needToken) { this.needToken = needToken; } diff --git a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/demo/DemoRemoteClient.java b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/demo/DemoRemoteClient.java deleted file mode 100644 index c014f87..0000000 --- a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/demo/DemoRemoteClient.java +++ /dev/null @@ -1,28 +0,0 @@ -package cn.iocoder.yudao.module.interphone.demo; - - -import cn.iocoder.yudao.module.interphone.core.ApiClient; -import cn.iocoder.yudao.module.interphone.core.ApiRequest; -import cn.iocoder.yudao.module.interphone.core.ApiResponse; -import org.springframework.stereotype.Component; - -import java.util.HashMap; -import java.util.Map; - -@Component -public class DemoRemoteClient { - - private final ApiClient apiClient; - - public DemoRemoteClient(ApiClient apiClient) { - this.apiClient = apiClient; - } - - public String getUserInfo() { - - ApiRequest request = ApiRequest.get("/profile/agent"); - ApiResponse response = apiClient.execute(request); - return response.getBody(); - } - -} diff --git a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/retry/TokenExpiredRetryHandler.java b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/retry/TokenExpiredRetryHandler.java index d85afbe..30dd696 100644 --- a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/retry/TokenExpiredRetryHandler.java +++ b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/retry/TokenExpiredRetryHandler.java @@ -29,7 +29,7 @@ public class TokenExpiredRetryHandler implements RetryHandler { // 方式2：业务码判断 String body = response.getBody(); if (body != null && - (body.contains("\"code\":40101") || body.contains("token expired") || body.contains("登录过期"))) { + (body.contains("\"code\":40102") || body.contains("token expired") || body.contains("登录过期"))) { tokenManager.forceRefreshToken(); return RetryDecision.retryAfterTokenRefresh(); } diff --git a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/service/InterphoneApiService.java b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/service/InterphoneApiService.java new file mode 100644 index 0000000..7651c45 --- /dev/null +++ b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/service/InterphoneApiService.java @@ -0,0 +1,53 @@ +package cn.iocoder.yudao.module.interphone.service; + +import java.util.Map; + +public interface InterphoneApiService { + + String getAgentProfile(); + + String getAgentList(Integer pageNo, Integer pageSize, String name); + + String getAgentDetail(String id); + + String getFastStats(); + + String getGroupName(String orgId); + + String querySubordinateUser(Integer pageNo, Integer pageSize, String agentId, String orgId, + String groupId, String userName, String account); + + String getAgentOrgs(Integer pageNo, Integer pageSize, String name); + + String getGroupList(Integer pageNo, Integer pageSize, String name, String orgName); + + String addGroup(String requestBody); + + String getGroupDetail(String id); + + String updateGroup(String requestBody); + + String deleteGroup(String requestBody); + + String getGroupMembers(String id); + + String addGroupMembers(String requestBody); + + String removeGroupMembers(String requestBody); + + String queryGroupByUid(Map queryParams); + + String createTerminalUsers(String requestBody); + + String getTerminalList(Integer pageNo, Integer pageSize, String orgId, String groupId, String name); + + String getTerminalDetail(Map queryParams); + + String updateTerminalUser(String requestBody); + + String deleteTerminalUser(String requestBody); + + String getTerminalUserOnlineStatus(Map queryParams); + + String getRecordList(Map queryParams); +} diff --git a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/service/apidoc.md b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/service/apidoc.md new file mode 100644 index 0000000..9961fde --- /dev/null +++ b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/service/apidoc.md @@ -0,0 +1,470 @@ +# 管理平台 API 文档 + +Base URL + +```text +https://chat.zdhlcn.com:9443/api +``` + +--- + +# 通用返回格式 + +```json +{ + "code": 20001, + "msg": "OK", + "data": {}, + "count": 0 +} +``` + +--- + +# 1 用户信息 + +--- + +# 1.1 个人信息 - 代理商 + +### 接口 + +``` +GET /v1/profile/agent +``` + +### 参数 + +| 参数 | 类型 | 必填 | 说明 | +| ------------ | ------ | -- | ---- | +| access_token | String | 是 | 登录凭证 | +| openid | String | 是 | 用户ID | + +--- + +### 返回示例 + +```json +{ + "code":20001, + "msg":"OK", + "data":{ + "loginname":"broadtest", + "usertype":0, + "agentinfo":{ + "id":"efad38ced1bb4ac0bf97665041db752a", + "name":"测试平台", + "contact":"测试测试", + "country_id":86, + "blance":939 + } + } +} +``` + +--- + +# 2 代理商管理 + +--- + +# 2.1 代理商查询 + +``` +GET /v1/agent/list +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ------------ | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | +| pageNo | int | 是 | +| pageSize | int | 是 | +| name | string | 否 | + +--- + +# 2.2 查询代理商详情 + +``` +GET /v1/agent/detail +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ------------ | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | +| id | String | 是 | + +--- + +# 2.3 查询代理商单位群组用户数 + +``` +GET /v1/profile/faststats +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ------------ | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | + +--- + +### 返回示例 + +```json +{ + "agent_count":232, + "org_count":107, + "group_count":107, + "user_count":488 +} +``` + +--- + +# 3 群组相关 + +--- + +# 3.1 查询群组名称 + +``` +GET /v1/group/getGroupName +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ------------ | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | +| orgId | String | 是 | + +--- + +# 3.2 查询下级用户 + +``` +GET /v1/terminal/querySubordinateUser +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ------------ | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | +| pageNo | int | 是 | +| pageSize | int | 是 | +| agentId | String | 否 | +| orgId | String | 否 | +| groupId | String | 否 | +| userName | String | 否 | +| account | String | 否 | + +--- + +# 4 单位管理 + +--- + +# 4.1 单位查询 + +``` +GET /v1/agent/orgs +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ------------ | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | +| pageNo | int | 是 | +| pageSize | int | 是 | +| name | string | 否 | + +--- + +# 5 群组管理 + +--- + +# 5.1 群组查询 + +``` +GET /v1/group/list +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ------------ | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | +| pageNo | int | 是 | +| pageSize | int | 是 | +| name | string | 否 | +| orgname | string | 否 | + +--- + +# 5.2 添加群组 + +``` +POST /v1/group/add +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ---------------------- | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | +| orgId | String | 是 | +| cgName | String | 是 | +| cg_speech_limit_second | int | 是 | +| remarks | String | 否 | + +--- + +# 5.3 群组详情 + +``` +GET /v1/group/detail +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ------------ | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | +| id | String | 是 | + +--- + +# 5.4 编辑群组 + +``` +POST /v1/group/updateGroup +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ---------------------- | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | +| id | String | 是 | +| cgName | String | 是 | +| cg_speech_limit_second | int | 是 | +| remarks | String | 是 | + +--- + +# 5.5 删除群组 + +``` +POST /v1/group/delete +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ------------ | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | +| id | String | 是 | + +--- + +# 6 群组成员 + +--- + +# 6.1 获取群组成员 + +``` +GET /v1/group/members +``` + +### 参数 + +| 参数 | 类型 | 必填 | +| ------------ | ------ | -- | +| access_token | String | 是 | +| openid | String | 是 | +| id | String | 是 | + +--- + +# 6.2 添加群组成员 + +``` +POST /v1/group/members/add +``` + +### 示例 + +```json +{ + "id":"groupId", + "members":[ + { + "id":"userUuid", + "user_id":5583024, + "priorities":1 + } + ] +} +``` + +--- + +# 6.3 移除群组成员 + +``` +POST /v1/group/members/remove +``` + +--- + +# 6.4 获取用户群组 + +``` +GET /v1/jsp/queryGroupByUId +``` + +--- + +# 7 对讲用户 + +--- + +# 7.1 创建用户 + +``` +POST /v1/terminal/batch +``` + +### 示例 + +```json +{ + "orgId":"uuid", + "groups":[{"id":"groupId"}], + "prefix":"test", + "accounts":["imei1","imei2"], + "cardTypes":[0,2] +} +``` + +--- + +# 7.2 用户查询 + +``` +GET /v1/terminal/list +``` + +### 参数 + +| 参数 | 类型 | +| -------- | ------ | +| pageNo | int | +| pageSize | int | +| org_id | String | +| groupId | String | +| name | String | + +--- + +# 7.3 用户详情 + +``` +GET /v1/terminal/detail +``` + +--- + +# 7.4 修改用户信息 + +``` +POST /v1/terminal/updateUser +``` + +--- + +# 7.5 删除用户 + +``` +POST /v1/terminal/deleteUser +``` + +--- + +# 7.6 查询用户在线状态 + +``` +GET /v1/terminal/userOnlineStatus +``` + +--- + +# 8 录音 + +--- + +# 8.1 查询录音 + +``` +GET /v1/record/list +``` + +--- + +# 接口模块结构 + +``` +用户 +├─ 个人信息 + +代理商 +├─ 查询 +├─ 详情 +├─ 统计 + +单位 +├─ 查询 + +群组 +├─ 查询 +├─ 创建 +├─ 编辑 +├─ 删除 + +群组成员 +├─ 获取 +├─ 添加 +├─ 删除 + +对讲用户 +├─ 创建 +├─ 查询 +├─ 详情 +├─ 修改 +├─ 删除 +├─ 在线状态 + +录音 +├─ 查询 +``` diff --git a/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/service/impl/InterphoneApiServiceImpl.java b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/service/impl/InterphoneApiServiceImpl.java new file mode 100644 index 0000000..d0fac1c --- /dev/null +++ b/cc-admin-master/yudao-module-interphone/src/main/java/cn/iocoder/yudao/module/interphone/service/impl/InterphoneApiServiceImpl.java @@ -0,0 +1,207 @@ +package cn.iocoder.yudao.module.interphone.service.impl; + +import cn.hutool.core.util.StrUtil; +import cn.iocoder.yudao.module.interphone.core.ApiClient; +import cn.iocoder.yudao.module.interphone.core.ApiRequest; +import cn.iocoder.yudao.module.interphone.core.ApiResponse; +import cn.iocoder.yudao.module.interphone.service.InterphoneApiService; +import org.springframework.stereotype.Service; +import org.springframework.validation.annotation.Validated; + +import java.util.LinkedHashMap; +import java.util.Map; + +@Service +@Validated +public class InterphoneApiServiceImpl implements InterphoneApiService { + + private final ApiClient apiClient; + + public InterphoneApiServiceImpl(ApiClient apiClient) { + this.apiClient = apiClient; + } + + @Override + public String getAgentProfile() { + return executeGet("/profile/agent"); + } + + @Override + public String getAgentList(Integer pageNo, Integer pageSize, String name) { + Map queryParams = new LinkedHashMap<>(); + putIfNotNull(queryParams, "pageNo", pageNo); + putIfNotNull(queryParams, "pageSize", pageSize); + putIfHasText(queryParams, "name", name); + return executeGet("/agent/list", queryParams); + } + + @Override + public String getAgentDetail(String id) { + return executeGet("/agent/detail", Map.of("id", id)); + } + + @Override + public String getFastStats() { + return executeGet("/profile/faststats"); + } + + @Override + public String getGroupName(String orgId) { + return executeGet("/group/getGroupName", Map.of("orgId", orgId)); + } + + @Override + public String querySubordinateUser(Integer pageNo, Integer pageSize, String agentId, String orgId, + String groupId, String userName, String account) { + Map queryParams = new LinkedHashMap<>(); + putIfNotNull(queryParams, "pageNo", pageNo); + putIfNotNull(queryParams, "pageSize", pageSize); + putIfHasText(queryParams, "agentId", agentId); + putIfHasText(queryParams, "orgId", orgId); + putIfHasText(queryParams, "groupId", groupId); + putIfHasText(queryParams, "userName", userName); + putIfHasText(queryParams, "account", account); + return executeGet("/terminal/querySubordinateUser", queryParams); + } + + @Override + public String getAgentOrgs(Integer pageNo, Integer pageSize, String name) { + Map queryParams = new LinkedHashMap<>(); + putIfNotNull(queryParams, "pageNo", pageNo); + putIfNotNull(queryParams, "pageSize", pageSize); + putIfHasText(queryParams, "name", name); + return executeGet("/agent/orgs", queryParams); + } + + @Override + public String getGroupList(Integer pageNo, Integer pageSize, String name, String orgName) { + Map queryParams = new LinkedHashMap<>(); + putIfNotNull(queryParams, "pageNo", pageNo); + putIfNotNull(queryParams, "pageSize", pageSize); + putIfHasText(queryParams, "name", name); + putIfHasText(queryParams, "orgname", orgName); + return executeGet("/group/list", queryParams); + } + + @Override + public String addGroup(String requestBody) { + return executePost("/group/add", requestBody); + } + + @Override + public String getGroupDetail(String id) { + return executeGet("/group/detail", Map.of("id", id)); + } + + @Override + public String updateGroup(String requestBody) { + return executePost("/group/updateGroup", requestBody); + } + + @Override + public String deleteGroup(String requestBody) { + return executePost("/group/delete", requestBody); + } + + @Override + public String getGroupMembers(String id) { + return executeGet("/group/members", Map.of("id", id)); + } + + @Override + public String addGroupMembers(String requestBody) { + return executePost("/group/members/add", requestBody); + } + + @Override + public String removeGroupMembers(String requestBody) { + return executePost("/group/members/remove", requestBody); + } + + @Override + public String queryGroupByUid(Map queryParams) { + return executeGet("/jsp/queryGroupByUId", queryParams); + } + + @Override + public String createTerminalUsers(String requestBody) { + return executePost("/terminal/batch", requestBody); + } + + @Override + public String getTerminalList(Integer pageNo, Integer pageSize, String orgId, String groupId, String name) { + Map queryParams = new LinkedHashMap<>(); + putIfNotNull(queryParams, "pageNo", pageNo); + putIfNotNull(queryParams, "pageSize", pageSize); + putIfHasText(queryParams, "org_id", orgId); + putIfHasText(queryParams, "groupId", groupId); + putIfHasText(queryParams, "name", name); + return executeGet("/terminal/list", queryParams); + } + + @Override + public String getTerminalDetail(Map queryParams) { + return executeGet("/terminal/detail", queryParams); + } + + @Override + public String updateTerminalUser(String requestBody) { + return executePost("/terminal/updateUser", requestBody); + } + + @Override + public String deleteTerminalUser(String requestBody) { + return executePost("/terminal/deleteUser", requestBody); + } + + @Override + public String getTerminalUserOnlineStatus(Map queryParams) { + return executeGet("/terminal/userOnlineStatus", queryParams); + } + + @Override + public String getRecordList(Map queryParams) { + return executeGet("/record/list", queryParams); + } + + private String executeGet(String path) { + return executeGet(path, null); + } + + private String executeGet(String path, Map queryParams) { + ApiRequest request = ApiRequest.get(path, sanitizeQueryParams(queryParams)); + ApiResponse response = apiClient.execute(request); + return response.getBody(); + } + + private String executePost(String path, String requestBody) { + ApiRequest request = ApiRequest.postJson(path, StrUtil.emptyToDefault(requestBody, "")); + ApiResponse response = apiClient.execute(request); + return response.getBody(); + } + + private Map sanitizeQueryParams(Map queryParams) { + if (queryParams == null || queryParams.isEmpty()) { + return null; + } + Map sanitized = new LinkedHashMap<>(); + queryParams.forEach((key, value) -> { + if (value != null) { + sanitized.put(key, value); + } + }); + return sanitized.isEmpty() ? null : sanitized; + } + + private void putIfHasText(Map queryParams, String key, String value) { + if (StrUtil.isNotBlank(value)) { + queryParams.put(key, value); + } + } + + private void putIfNotNull(Map queryParams, String key, Object value) { + if (value != null) { + queryParams.put(key, String.valueOf(value)); + } + } +} diff --git a/cc-admin-master/yudao-server/src/main/resources/logback-spring.xml b/cc-admin-master/yudao-server/src/main/resources/logback-spring.xml new file mode 100644 index 0000000..b1b9f3f --- /dev/null +++ b/cc-admin-master/yudao-server/src/main/resources/logback-spring.xml @@ -0,0 +1,76 @@ + + + + + + + + + + 　　　　　 + + + ${PATTERN_DEFAULT} + + + + + + + + + + ${PATTERN_DEFAULT} + + + + ${LOG_FILE} + + + ${LOGBACK_ROLLINGPOLICY_FILE_NAME_PATTERN:-${LOG_FILE}.%d{yyyy-MM-dd}.%i.gz} + + ${LOGBACK_ROLLINGPOLICY_CLEAN_HISTORY_ON_START:-false} + + ${LOGBACK_ROLLINGPOLICY_MAX_FILE_SIZE:-10MB} + + ${LOGBACK_ROLLINGPOLICY_TOTAL_SIZE_CAP:-0} + + ${LOGBACK_ROLLINGPOLICY_MAX_HISTORY:-30} + + + + + + 0 + + 256 + + + + + + + + ${PATTERN_DEFAULT} + + + + + + + + + + + + + + + + + + + + + +