package com.battery.business.service;

import java.sql.Timestamp;
import java.sql.Statement;
import java.util.List;
import javax.sql.DataSource;
import com.ruoyi.common.exception.ServiceException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.support.GeneratedKeyHolder;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

/** 独立待办持久化，负责人限制始终使用登录用户 ID，不依赖姓名或管理员身份。 */
@Service
public class TodoService {
    private final JdbcTemplate jdbc;
    public TodoService(DataSource source) { jdbc = new JdbcTemplate(source); }
    public record Todo(long id, String content, long ownerId, String owner, String status,
            String creator, long createdAt, long operatedAt, String handleRemark) {}
    public record UserOption(long id, String name) {}
    private static final String COLUMNS = "select todo_id,content,owner_id,owner_name,status,creator_name,created_at_utc,operated_at_utc,handle_remark from t_todo";
    private static final RowMapper<Todo> ROW = (rs, index) -> new Todo(rs.getLong(1), rs.getString(2), rs.getLong(3), rs.getString(4),
            rs.getString(5), rs.getString(6), rs.getTimestamp(7).getTime(), rs.getTimestamp(8).getTime(), rs.getString(9));

    /** 返回当前负责人自己的全部待办；包括已处理项，不向创建人或管理员额外开放。 */
    public List<Todo> list(long ownerId) {
        return jdbc.query(COLUMNS + " where owner_id=? order by operated_at_utc desc,todo_id desc", ROW, ownerId);
    }

    /** 供新增表单选择启用用户，不要求用户管理模块权限。 */
    public List<UserOption> owners() {
        return jdbc.query("select user_id,coalesce(nullif(nick_name,''),user_name) from sys_user where status='0' and del_flag='0' order by user_id",
                (rs, index) -> new UserOption(rs.getLong(1), rs.getString(2)));
    }

    /** 新增后仅返回确认主键，分配给别人时不把该待办回传给非负责人。 */
    @Transactional
    public long create(String content, long ownerId, long creatorId, String creator) {
        String value = required(content, 200, "待办内容");
        var owner = owners().stream().filter(user -> user.id() == ownerId).findFirst()
                .orElseThrow(() -> new ServiceException("请选择启用的负责人"));
        var now = new Timestamp(System.currentTimeMillis());
        var key = new GeneratedKeyHolder();
        // 主键从本次 INSERT 的 JDBC 结果取得，不跨连接使用会话相关的 last_insert_id。
        jdbc.update(connection -> {
            var statement = connection.prepareStatement("insert into t_todo(content,owner_id,owner_name,creator_id,creator_name,status,created_at_utc,operated_at_utc,handle_remark) values(?,?,?,?,?,'待处理',?,?,'')", Statement.RETURN_GENERATED_KEYS);
            statement.setString(1, value); statement.setLong(2, owner.id()); statement.setString(3, owner.name());
            statement.setLong(4, creatorId); statement.setString(5, creator); statement.setTimestamp(6, now); statement.setTimestamp(7, now);
            return statement;
        }, key);
        return key.getKey().longValue();
    }

    /** 负责人只能将自己的待处理事项完成一次；写入条件同时校验身份和当前状态。 */
    public void handle(long id, long ownerId, String remark) {
        String value = required(remark, 500, "处理说明");
        if (jdbc.update("update t_todo set status='已处理',handle_remark=?,operated_at_utc=? where todo_id=? and owner_id=? and status='待处理'",
                value, new Timestamp(System.currentTimeMillis()), id, ownerId) != 1)
            throw new ServiceException("待办不存在、已处理或无权处理");
    }

    /** 按现有删除交互物理删除自己的待办，不涉及测试或异常事实。 */
    public void remove(long id, long ownerId) {
        if (jdbc.update("delete from t_todo where todo_id=? and owner_id=?", id, ownerId) != 1)
            throw new ServiceException("待办不存在或无权删除");
    }

    private String required(String text, int max, String name) {
        if (text == null || text.trim().isEmpty() || text.trim().length() > max)
            throw new ServiceException(name + "不能为空且长度不能超过" + max);
        return text.trim();
    }
}