package com.ruoyi.http.service.impl;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.ruoyi.common.utils.http.HttpUtils;
import com.ruoyi.http.config.TqdianbiaoConfig;
import com.ruoyi.http.mapper.TqdianbiaoMeterMapper;
import com.ruoyi.http.pojo.TqdianbiaoMeter;
import com.ruoyi.http.service.TqdianbiaoMeterSyncService;
import com.ruoyi.http.service.TqdianbiaoSyncLogService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import java.time.LocalDateTime;

@Service
@Slf4j
@RequiredArgsConstructor
public class TqdianbiaoMeterSyncServiceImpl implements TqdianbiaoMeterSyncService {

    private final TqdianbiaoConfig config;
    private final TqdianbiaoMeterMapper meterMapper;
    private final TqdianbiaoSyncLogService syncLogService;

    @Override
    public int syncMeters() {
        String syncType = "meter";
        try {
            String url = config.getBaseUrl() + "/Api/Meter";
            String param = "auth=" + config.getAuth();
            String raw = HttpUtils.sendGet(url, param);
            JSONArray list = parseList(raw);
            LocalDateTime now = LocalDateTime.now();
            int count = 0;
            for (int i = 0; i < list.size(); i++) {
                JSONObject item = list.getJSONObject(i);
                if (!"0".equals(String.valueOf(item.get("device_type")))) {
                    continue;
                }
                Long meterId = item.getLong("id");
                if (meterId == null) {
                    continue;
                }
                TqdianbiaoMeter entity = meterMapper.selectOne(
                        Wrappers.<TqdianbiaoMeter>lambdaQuery()
                                .eq(TqdianbiaoMeter::getMeterId, meterId)
                                .last("LIMIT 1"));
                boolean isNew = entity == null;
                if (isNew) {
                    entity = new TqdianbiaoMeter();
                    entity.setMeterId(meterId);
                    entity.setSource("sync");
                }
                String savedName = entity.getMeterName();
                String savedAddress = entity.getAddress();
                String savedDesc = entity.getDescription();
                String savedRelay = entity.getRelayState();

                entity.setCollectorId(item.getString("cid"));
                entity.setCollectorNo(item.getString("collectorid"));
                entity.setMeterType(item.getString("type"));
                entity.setCsq(item.getInteger("csq"));
                entity.setRate(item.getInteger("rate"));
                entity.setSyncTime(now);

                if (isNew) {
                    entity.setAddress(item.getString("address"));
                    entity.setRelayState(item.getString("relay_state"));
                    entity.setDescription(item.getString("description"));
                    entity.setMeterName(StringUtils.hasText(savedName) ? savedName : item.getString("address"));
                } else {
                    entity.setMeterName(savedName);
                    entity.setAddress(savedAddress);
                    entity.setDescription(savedDesc);
                    entity.setRelayState(savedRelay);
                }
                if (entity.getId() == null) {
                    meterMapper.insert(entity);
                } else {
                    meterMapper.updateById(entity);
                }
                count++;
            }
            syncLogService.logSuccess(syncType, null, null, count);
            return count;
        } catch (Exception e) {
            log.error("电表同步失败", e);
            syncLogService.logFailure(syncType, null, null, e.getMessage());
            throw e;
        }
    }

    private JSONArray parseList(String raw) {
        Object parsed = JSON.parse(raw);
        if (parsed instanceof JSONArray) {
            return (JSONArray) parsed;
        }
        JSONObject root = (JSONObject) parsed;
        if (root.getIntValue("status") != 1) {
            throw new IllegalStateException("电表接口返回异常: " + raw);
        }
        Object data = root.get("data");
        if (data instanceof JSONArray) {
            return (JSONArray) data;
        }
        return new JSONArray();
    }
}