package com.battery.business.report;

import com.alibaba.fastjson2.JSON;
import com.ruoyi.common.exception.ServiceException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
import javax.sql.DataSource;
import java.sql.Timestamp;
import java.util.List;

/** 对比模板独立存储；模板更新不访问或回写报表版本。 */
@Repository
public class CompareFieldTemplateRepository {
    private final JdbcTemplate jdbc;
    public CompareFieldTemplateRepository(DataSource dataSource) { jdbc = new JdbcTemplate(dataSource); }
    public record Template(long id, String name, String type, List<CompareField> fields, String creator, long updatedAt) {}
    private List<CompareField> fields(String json) { return JSON.parseArray(json, CompareField.class); }

    /** 返回该类全部模板，不按创建人过滤；字段数组次序即展示次序。 */
    public List<Template> list() {
        return jdbc.query("select template_id,template_name,template_type,fields_json,creator_name,updated_at_utc from t_compare_report_field_template where template_type='compare' order by template_name,template_id",
            (rs, i) -> new Template(rs.getLong(1), rs.getString(2), rs.getString(3), fields(rs.getString(4)), rs.getString(5), rs.getTimestamp(6).getTime()));
    }

    /** 保存已验证的结构；同类同名模板须由用户明确选择更新，不隐式覆盖。 */
    public long insert(String name, List<CompareField> fields, long userId, String userName) {
        try {
            var key = new org.springframework.jdbc.support.GeneratedKeyHolder();
            jdbc.update(connection -> {
                var statement = connection.prepareStatement("insert into t_compare_report_field_template(template_name,template_type,fields_json,creator_id,creator_name,created_at_utc,updated_at_utc) values(?,'compare',?,?,?,?,?)", java.sql.Statement.RETURN_GENERATED_KEYS);
                statement.setString(1, name); statement.setString(2, JSON.toJSONString(fields));
                statement.setLong(3, userId); statement.setString(4, userName);
                var now = new Timestamp(System.currentTimeMillis());
                statement.setTimestamp(5, now); statement.setTimestamp(6, now);
                return statement;
            }, key);
            return key.getKey().longValue();
        } catch (org.springframework.dao.DuplicateKeyException e) { throw new ServiceException("模板名称已存在"); }
    }

    /** 授权编辑只替换模板结构，不改变既有报表或模板创建人。 */
    public void update(long id, String name, List<CompareField> fields) {
        try {
            if (jdbc.update("update t_compare_report_field_template set template_name=?,fields_json=?,updated_at_utc=? where template_id=? and template_type='compare'",
                    name, JSON.toJSONString(fields), new Timestamp(System.currentTimeMillis()), id) == 0)
                throw new ServiceException("字段模板不存在");
        } catch (org.springframework.dao.DuplicateKeyException e) { throw new ServiceException("模板名称已存在"); }
    }
}