feat(空调控制): 实现空调控制功能并优化 SVG 数据加载- 新增 AirCondConstants 类，定义空调控制常量 - 修改 AirCo...

baoshiwei

2025-06-30 e8a7beb5455d0c9f50f93004b600dd2781ad6bfd

 zhitan-airconditioner/src/main/java/com/zhitan/airconditioner/service/impl/AirConditionerServiceImpl.java

@@ -4,6 +4,7 @@
import java.util.List;

import com.alibaba.fastjson2.JSONObject;
import com.zhitan.airconditioner.common.AirCondConstants;
import com.zhitan.airconditioner.domain.AirConditioner;
import com.zhitan.airconditioner.domain.AirConditionerLog;
import com.zhitan.airconditioner.mapper.AirConditionerLogMapper;
@@ -12,6 +13,8 @@
import com.zhitan.common.utils.DateUtils;
import com.zhitan.common.utils.SecurityUtils;
import com.zhitan.framework.mqtt.MqttClientUtil;
import com.zhitan.realtimedata.domain.TagValue;
import com.zhitan.realtimedata.service.RealtimeDatabaseService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@@ -31,6 +34,9 @@
    
    @Autowired
    private MqttClientUtil mqttClientUtil;

    @Autowired
    private RealtimeDatabaseService realtimeDatabaseService;

    /**
     * 查询空调控制器列表
@@ -176,19 +182,18 @@
            JSONObject jsonObject = JSONObject.parseObject(msg);
            JSONObject rwProt = jsonObject.getJSONObject("rw_prot");
            rwProt.put("id", airConditioner.getControllerId());
            if ("0".equals(mode)) {
            if (AirCondConstants.COOL_OPEN.equals(mode)) {
                rwProt.getJSONArray("w_data").getJSONObject(0).put("value", "1");
            } else if ("1".equals(mode)) {
            } else if (AirCondConstants.HOT_OPEN.equals(mode)) {
                rwProt.getJSONArray("w_data").getJSONObject(1).put("value", "1");
            } else if ("2".equals(mode)) {
            } else if (AirCondConstants.OFF.equals(mode)) {
                rwProt.getJSONArray("w_data").getJSONObject(2).put("value", "1");
            }
            // 构建MQTT消息
            String topic = "lanbao/nygl/sevice/kt1/down";
            String message = jsonObject.toJSONString();
            
            // 发送MQTT消息
            mqttClientUtil.sendMessage(topic, message, 2);
            mqttClientUtil.sendMessage(AirCondConstants.SEND_COMMAND_TOPIC, message, 2);
            
            // 记录操作日志
            AirConditionerLog log = new AirConditionerLog();