package jnpf.limsController;

import com.alibaba.fastjson.JSONObject;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.slf4j.Slf4j;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.Collections;
import java.util.List;
import java.util.Map;

/**
 * 工作流表配置测试数据查询。
 *
 * <p>该 Controller 仅用于验证前端配置页面，保持只读，不影响现有业务接口。</p>
 */
@Slf4j
@Tag(name = "工作流表配置测试", description = "按流程查询发起表单关联的数据表")
@RestController
@RequestMapping("/custom/workflow-table-config")
public class WorkflowTableConfigTestController {

    private static final String DEFAULT_FLOW_ID = "864125763559883717";

    private final JdbcTemplate jdbcTemplate;

    public WorkflowTableConfigTestController(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    @Operation(summary = "查询流程表配置")
    @GetMapping
    public JSONObject list(@RequestParam(value = "flowId", required = false) String flowId) {
        String queryFlowId = StringUtils.hasText(flowId) ? flowId.trim() : DEFAULT_FLOW_ID;
        JSONObject result = new JSONObject();
        result.put("code", 200);
        result.put("msg", "查询成功");

        try {
            String sql = "SELECT n.f_form_id AS \"formId\", "
                    + "v.f_full_name AS \"formName\", "
                    + "item.value ->> 'typeId' AS \"tableType\", "
                    + "item.value ->> 'table' AS \"tableName\", "
                    + "item.value ->> 'tableName' AS \"tableDisplayName\" "
                    + "FROM public.workflow_node n "
                    + "JOIN public.base_visual_release v ON v.f_id = n.f_form_id "
                    + "CROSS JOIN LATERAL jsonb_array_elements("
                    + "CASE WHEN v.f_tables_data IS NULL OR btrim(v.f_tables_data) = '' "
                    + "THEN '[]'::jsonb ELSE v.f_tables_data::jsonb END) AS item(value) "
                    + "WHERE n.f_flow_id = ? AND n.f_node_type = 'start' "
                    + "AND item.value ->> 'typeId' = '1'";

            List<Map<String, Object>> rows = jdbcTemplate.queryForList(sql, queryFlowId);
            result.put("data", rows == null ? Collections.emptyList() : rows);
            return result;
        } catch (Exception ex) {
            log.error("查询流程表配置失败，flowId={}", queryFlowId, ex);
            result.put("code", 500);
            result.put("msg", "查询失败：" + ex.getMessage());
            result.put("data", Collections.emptyList());
            return result;
        }
    }
}