接口 优化

src/main/java/com/ikonke/konkeaialibabamcp/service/cdc/CdcHttpUtils.java

@@ -77,6 +77,7 @@ public class CdcHttpUtils {
 				CDCTokenCache.put(bySn.getSn(),jsonObject.getJSONObject("data").toString());
 				return userEntity;
 			}else{
+				log.error("【{}】获取用户信息失败:{}",bySn.getSn(),body);
 				return null;
 			}
 		}
@@ -91,7 +92,7 @@ public class CdcHttpUtils {
 		log.info("【{}】建发get请求：url：{}",sn,url);
 		CDCToken bySn = tokenService.findBySn(sn);
 		UserEntity userEntity = getOwner(bySn);
-		if(userEntity==null || userEntity.roomInfo== null){
+		if(userEntity==null || userEntity.getRoomInfo() == null){
 			log.info("【{}】获取用户信息失败",sn);
 			return null;
 		}

src/main/java/com/ikonke/konkeaialibabamcp/utils/KonkeIotUtils.java

@@ -30,6 +30,7 @@ import java.awt.*;
 import java.time.LocalDateTime;
 import java.util.*;
 import java.util.List;
+import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 
 @Slf4j
@@ -79,6 +80,28 @@ public class KonkeIotUtils {
 				throw new StatefulException(-20, "参数不能为空");
 			}
 			List<String> devIdList = List.of(devIds.split(","));
+
+			// 异步执行设备操作，不阻塞主线程
+//			CompletableFuture.runAsync(() -> {
+//				try {
+//					for(String devId : devIdList){
+//						if (getDeviceOnline(ccuName, devId)) {
+//							log.warn("设备已离线: {}", devId);
+//							continue;
+//						}
+//						SynDevice byId = sycDeviceService.findById(ccuName, devId);
+//						if(byId==null){
+//							continue;
+//						}
+//						this.optDeviceOpen(ccuName,devId,byId.getOperateId());
+//					}
+//					log.info("批量开启设备操作完成");
+//				} catch (Exception e) {
+//					log.error("异步执行设备开启操作失败", e);
+//				}
+//			});
+
+			// 异步执行？
 			for(String devId : devIdList){
 				if (getDeviceOnline(ccuName, devId)) {
 					throw new StatefulException(-30, "设备已离线");

建发/MCP对接.md

+## 工具列表
+
+> SSE模式访问：[https://mcp.cndmega.com/sse](https://mcp.cndmega.com/sse)
+
+### 访客管理工具
+
+#### createVisitorInvitation
+创建访客邀请，生成访客记录。
+
+**参数：**
+- `visitor_name` (必需): 访客姓名
+- `visitor_phone` (必需): 访客手机号码
+- `person_num` (必需): 人数
+- `visitor_start_date` (必需): 访问开始时间 (格式: yyyy-MM-dd HH:mm:ss)
+- `visitor_end_date` (必需): 访问结束时间 (格式: yyyy-MM-dd HH:mm:ss)
+
+**注意：** 社区代码、房间ID、房间名称、楼栋ID等通用参数将从请求头自动获取
+
+#### getVisitorInvitationList
+查看业主的访客记录列表。
+
+**参数：**
+- `pageNum` (可选): 页码，默认为1
+- `pageSize` (可选): 每页数量，默认为20
+
+**注意：** 社区代码等通用参数将从请求头自动获取
+
+### 智慧会所工具
+
+#### getClubList
+查看当前所有的智慧会所。
+
+**注意：** 社区ID和房间ID等通用参数将从请求头自动获取
+
+#### getClubDetail
+查看指定智慧会所的信息，包含开放时间和地址。
+
+**参数：**
+- `clubId` (必需): 会所ID
+
+**注意：** 社区ID和房间ID等通用参数将从请求头自动获取
+
+#### createClubAppointment
+预约智慧会所。
+
+**参数：**
+- `clubId` (必需): 会所ID
+- `date` (必需): 预约日期 (格式: yyyy-MM-dd)
+- `startTime` (必需): 时段开始时间 (格式: HH:mm:ss)
+- `endTime` (必需): 时段结束时间 (格式: HH:mm:ss)
+
+**注意：** 社区ID和房间ID等通用参数将从请求头自动获取
+
+#### getClubAppointmentList
+获取智慧会所预约订单列表。
+
+**参数：**
+- `datetimeStartTime` (可选): 查询开始时间 (格式: YYYY-MM-DD HH:MM:SS)
+- `datetimeEndTime` (可选): 查询结束时间 (格式: YYYY-MM-DD HH:MM:SS)
+
+**注意：** 社区ID和房间ID等通用参数将从请求头自动获取
+
+#### getClubSchedule
+查询会所可预定时间表。
+
+**参数：**
+- `clubId` (必需): 会所ID
+- `date` (必需): 查询日期
+
+**注意：** 社区ID和房间ID等通用参数将从请求头自动获取
+
+### 机器人服务工具
+
+#### createRobotAppointment
+预约机器人上门服务（垃圾代收）。
+
+**注意：** 楼栋ID和房间ID等通用参数将从请求头自动获取
+
+#### getRobotAppointmentList
+查询机器人预约记录（垃圾代收）。
+
+**参数：**
+- `pageNum` (可选): 页码，默认为1
+- `pageSize` (可选): 每页数量，默认为20
+
+**注意：** 社区ID等通用参数将从请求头自动获取
+
+### 垃圾代收工具
+
+#### createRobotAppointment
+创建垃圾代收订单。
+
+**注意：** 楼栋ID和房间ID等通用参数将从请求头自动获取
+
+#### getRobotAppointmentList
+查询垃圾代收订单列表。
+
+**参数：**
+- `pageNum` (可选): 页码，默认为1
+- `pageSize` (可选): 每页数量，默认为20
+
+**注意：** 社区ID等通用参数将从请求头自动获取
+
+### 工单服务工具
+
+#### createWorkOrder
+创建工单。
+
+**参数：**
+- `description` (必需): 问题描述
+
+**注意：** 社区ID等通用参数将从请求头自动获取，默认创建"问题整改"类型工单
+
+#### getWorkOrderList
+查询工单列表。
+
+**参数：**
+- `pageNum` (可选): 页码，默认为1
+- `pageSize` (可选): 每页数量，默认为20
+
+**注意：** 社区ID等通用参数将从请求头自动获取
\ No newline at end of file