package com.zhitan.airconditioner.service.impl;

import java.util.Date;
import java.util.List;

import com.alibaba.fastjson2.JSONObject;
import com.zhitan.airconditioner.domain.AirConditioner;
import com.zhitan.airconditioner.domain.AirConditionerLog;
import com.zhitan.airconditioner.mapper.AirConditionerLogMapper;
import com.zhitan.airconditioner.mapper.AirConditionerMapper;
import com.zhitan.airconditioner.service.IAirConditionerService;
import com.zhitan.common.utils.DateUtils;
import com.zhitan.common.utils.SecurityUtils;
import com.zhitan.framework.mqtt.MqttClientUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * 空调控制器Service业务层处理
 * 
 * @author zhitan
 */
@Service
public class AirConditionerServiceImpl implements IAirConditionerService
{
    @Autowired
    private AirConditionerMapper airConditionerMapper;
    
    @Autowired
    private AirConditionerLogMapper airConditionerLogMapper;
    
    @Autowired
    private MqttClientUtil mqttClientUtil;

    /**
     * 查询空调控制器列表
     * 
     * @param airConditioner 空调控制器信息
     * @return 空调控制器集合
     */
    @Override
    public List<AirConditioner> selectAirConditionerList(AirConditioner airConditioner)
    {
        return airConditionerMapper.selectAirConditionerList(airConditioner);
    }

    /**
     * 查询空调控制器信息
     * 
     * @param id 空调控制器ID
     * @return 空调控制器信息
     */
    @Override
    public AirConditioner selectAirConditionerById(Long id)
    {
        return airConditionerMapper.selectAirConditionerById(id);
    }
    
    /**
     * 根据控制器ID查询空调控制器信息
     * 
     * @param controllerId 控制器ID
     * @return 空调控制器信息
     */
    @Override
    public AirConditioner selectAirConditionerByControllerId(String controllerId)
    {
        return airConditionerMapper.selectAirConditionerByControllerId(controllerId);
    }

    /**
     * 新增空调控制器
     * 
     * @param airConditioner 空调控制器信息
     * @return 结果
     */
    @Override
    public int insertAirConditioner(AirConditioner airConditioner)
    {
        airConditioner.setCreateTime(DateUtils.getNowDate());
        airConditioner.setCreateBy(SecurityUtils.getUsername());
        return airConditionerMapper.insertAirConditioner(airConditioner);
    }

    /**
     * 修改空调控制器
     * 
     * @param airConditioner 空调控制器信息
     * @return 结果
     */
    @Override
    public int updateAirConditioner(AirConditioner airConditioner)
    {
        airConditioner.setUpdateTime(DateUtils.getNowDate());
        airConditioner.setUpdateBy(SecurityUtils.getUsername());
        return airConditionerMapper.updateAirConditioner(airConditioner);
    }

    /**
     * 批量删除空调控制器
     * 
     * @param ids 需要删除的空调控制器ID
     * @return 结果
     */
    @Override
    public int deleteAirConditionerByIds(Long[] ids)
    {
        return airConditionerMapper.deleteAirConditionerByIds(ids);
    }

    /**
     * 删除空调控制器信息
     * 
     * @param id 空调控制器ID
     * @return 结果
     */
    @Override
    public int deleteAirConditionerById(Long id)
    {
        return airConditionerMapper.deleteAirConditionerById(id);
    }
    
    /**
     * 控制空调开关机
     * 
     * @param id 空调ID
     * @param mode 控制模式（0制冷 1制热 2关机）
     * @param operateType 操作类型（0手动 1自动）
     * @return 结果
     */
    @Override
    public boolean controlAirConditioner(Long id, String mode, String operateType)
    {
        try {
            // 查询空调信息
            AirConditioner airConditioner = airConditionerMapper.selectAirConditionerById(id);
            if (airConditioner == null) {
                return false;
            }

            String msg = "{\n" +
                    "  \"rw_prot\": {\n" +
                    "    \"Ver\": \"1.0.1\",\n" +
                    "    \"dir\": \"down\",\n" +
                    "    \"id\": \"00601925021000024737\",\n" +
                    "    \"r_data\": [\n" +
                    "      {\"name\":\"hum\"},\n" +
                    "      {\"name\":\"tmp\"},\n" +
                    "      {\n" +
                    "        \"name\": \"cold\"\n" +
                    "      },\n" +
                    "      {\n" +
                    "        \"name\": \"hot\"\n" +
                    "      },\n" +
                    "      {\n" +
                    "        \"name\": \"off\"\n" +
                    "      }\n" +
                    "    ],\n" +
                    "    \"w_data\": [\n" +
                    "      {\n" +
                    "        \"name\": \"cold\",\n" +
                    "        \"value\": \"0\"\n" +
                    "      },\n" +
                    "      {\n" +
                    "        \"name\": \"hot\",\n" +
                    "        \"value\": \"0\"\n" +
                    "      },\n" +
                    "      {\n" +
                    "        \"name\": \"off\",\n" +
                    "        \"value\": \"0\"\n" +
                    "      }\n" +
                    "    ]\n" +
                    "  }\n" +
                    "}";
            // 将字符串转json
            JSONObject jsonObject = JSONObject.parseObject(msg);
            JSONObject rwProt = jsonObject.getJSONObject("rw_prot");
            rwProt.put("id", airConditioner.getControllerId());
            if ("0".equals(mode)) {
                rwProt.getJSONArray("w_data").getJSONObject(0).put("value", "1");
            } else if ("1".equals(mode)) {
                rwProt.getJSONArray("w_data").getJSONObject(1).put("value", "1");
            } else if ("2".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);
            
            // 记录操作日志
            AirConditionerLog log = new AirConditionerLog();
            log.setAirConditionerId(id);
            log.setAirConditionerName(airConditioner.getName());
            log.setOperateType(operateType);
            log.setOperateMode(mode);
            log.setOperateTime(new Date());
            log.setOperateResult("1"); // 成功
            log.setOperateMsg("操作成功");
            log.setCreateTime(DateUtils.getNowDate());
            if ("1".equals(operateType)) {
                log.setCreateBy("系统");
            } else {
                log.setCreateBy(SecurityUtils.getUsername());
            }
            airConditionerLogMapper.insertAirConditionerLog(log);
            
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }
}