package com.java110.fee.api.z2;

import com.alibaba.fastjson.JSONObject;
import com.java110.dto.importData.OwnerPropertySurvey;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import org.mybatis.spring.SqlSessionTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 业主房屋产调记录表信息接口
 * 适配 owner_property_survey 表
 * @author dev
 * @date 2025-12-24
 */
@RestController
@RequestMapping(value = "/ownerPropertySurvey")
public class OwnerPropertySurveyApi {

    @Autowired
    protected SqlSessionTemplate sqlSessionTemplate;

    /**
     * 保存单条业主房屋产调记录信息
     *
     * @param reqJson 请求参数
     * @return 响应结果
     * @serviceCode /ownerPropertySurvey/saveOwnerPropertySurveyInfo
     * @path /app/ownerPropertySurvey/saveOwnerPropertySurveyInfo
     */
    @RequestMapping(value = "/saveOwnerPropertySurvey", method = RequestMethod.POST)
    public ResponseEntity<String> saveOwnerPropertySurveyInfo(@RequestBody JSONObject reqJson) {
        // 核心参数校验（业主ID、房屋ID为非空字段）
        Assert.hasKeyAndValue(reqJson, "ownerId", "请求报文中未包含业主编号ownerId");
        Assert.hasKeyAndValue(reqJson, "roomId", "请求报文中未包含房屋编号roomId");

        // 转换为实体类
        OwnerPropertySurvey survey = BeanConvertUtil.covertBean(reqJson, OwnerPropertySurvey.class);

        // 调用Mapper保存方法
        int insert = sqlSessionTemplate.insert("ownerPropertySurveyServiceDaoImpl.saveOwnerPropertySurveyInfo",
                BeanConvertUtil.beanCovertMap(survey));

        // 构造响应结果
        JSONObject resJson = new JSONObject();
        if (insert > 0) {
            resJson.put("code", "0000");
            resJson.put("msg", "保存业主房屋产调记录信息成功");
        } else {
            resJson.put("code", "0001");
            resJson.put("msg", "保存业主房屋产调记录信息失败");
        }
        resJson.put("count", insert);
        return ResponseEntity.ok(resJson.toJSONString());
    }

    /**
     * 批量保存业主房屋产调记录信息
     *
     * @param reqJson 请求参数（包含ownerPropertySurveyList数组）
     * @return 响应结果
     * @serviceCode /ownerPropertySurvey/saveOwnerPropertySurveys
     * @path /app/ownerPropertySurvey/saveOwnerPropertySurveys
     */
    @RequestMapping(value = "/saveOwnerPropertySurveys", method = RequestMethod.POST)
    public ResponseEntity<String> saveOwnerPropertySurveys(@RequestBody JSONObject reqJson) {
        Assert.hasKeyAndValue(reqJson, "ownerPropertySurveyList", "请求报文中未包含批量数据列表ownerPropertySurveyList");

        // 转换批量数据
        List<OwnerPropertySurvey> surveyList = BeanConvertUtil.covertBeanList(
                reqJson.getJSONArray("ownerPropertySurveyList"), OwnerPropertySurvey.class);

        Map<String, Object> param = new HashMap<>();
        param.put("ownerPropertySurveyPos", surveyList);

        // 批量插入
        int insert = sqlSessionTemplate.insert("ownerPropertySurveyServiceDaoImpl.saveOwnerPropertySurveys", param);

        JSONObject resJson = new JSONObject();
        resJson.put("code", "0000");
        resJson.put("msg", "批量保存业主房屋产调记录信息成功");
        resJson.put("count", insert);
        return ResponseEntity.ok(resJson.toJSONString());
    }

    /**
     * 修改业主房屋产调记录信息
     *
     * @param reqJson 请求参数
     * @return 响应结果
     * @serviceCode /ownerPropertySurvey/updateOwnerPropertySurveyInfo
     * @path /app/ownerPropertySurvey/updateOwnerPropertySurveyInfo
     */
    @RequestMapping(value = "/updateOwnerPropertySurveyInfo", method = RequestMethod.POST)
    public ResponseEntity<String> updateOwnerPropertySurveyInfo(@RequestBody JSONObject reqJson) {
        // 主键校验（id 或 ownerId+roomId 二选一）
        boolean hasId = reqJson.containsKey("id") && reqJson.getString("id") != null && !reqJson.getString("id").isEmpty();
        boolean hasOwnerAndRoomId = reqJson.containsKey("ownerId") && !reqJson.getString("ownerId").isEmpty()
                && reqJson.containsKey("roomId") && !reqJson.getString("roomId").isEmpty();
        Assert.isTrue(hasId || hasOwnerAndRoomId, "请求报文中需包含主键ID，或同时包含业主编号和房屋编号");

        // 转换为实体类
        OwnerPropertySurvey survey = BeanConvertUtil.covertBean(reqJson, OwnerPropertySurvey.class);

        // 调用Mapper修改方法
        int update = sqlSessionTemplate.update("ownerPropertySurveyServiceDaoImpl.updateOwnerPropertySurveyInfo",
                BeanConvertUtil.beanCovertMap(survey));

        JSONObject resJson = new JSONObject();
        if (update > 0) {
            resJson.put("code", "0000");
            resJson.put("msg", "修改业主房屋产调记录信息成功");
        } else {
            resJson.put("code", "0001");
            resJson.put("msg", "修改业主房屋产调记录信息失败，未找到对应记录");
        }
        resJson.put("count", update);
        return ResponseEntity.ok(resJson.toJSONString());
    }

    /**
     * 删除业主房屋产调记录信息
     *
     * @param reqJson 请求参数
     * @return 响应结果
     * @serviceCode /ownerPropertySurvey/deleteOwnerPropertySurveyInfo
     * @path /app/ownerPropertySurvey/deleteOwnerPropertySurveyInfo
     */
    @RequestMapping(value = "/deleteOwnerPropertySurveyInfo", method = RequestMethod.POST)
    public ResponseEntity<String> deleteOwnerPropertySurveyInfo(@RequestBody JSONObject reqJson) {
        // 必要参数校验（至少包含一个筛选条件）
        boolean hasFilter = reqJson.containsKey("id") && reqJson.getString("id") != null && !reqJson.getString("id").isEmpty()
                || reqJson.containsKey("ownerId") && !reqJson.getString("ownerId").isEmpty()
                || reqJson.containsKey("roomId") && !reqJson.getString("roomId").isEmpty();
        Assert.isTrue(hasFilter, "请求报文中需包含id/ownerId/roomId至少一个筛选条件");

        // 转换为实体类
        OwnerPropertySurvey survey = BeanConvertUtil.covertBean(reqJson, OwnerPropertySurvey.class);

        // 调用Mapper删除方法
        int delete = sqlSessionTemplate.delete("ownerPropertySurveyServiceDaoImpl.deleteOwnerPropertySurveyInfo",
                BeanConvertUtil.beanCovertMap(survey));

        JSONObject resJson = new JSONObject();
        if (delete > 0) {
            resJson.put("code", "0000");
            resJson.put("msg", "删除业主房屋产调记录信息成功");
        } else {
            resJson.put("code", "0001");
            resJson.put("msg", "删除业主房屋产调记录信息失败，未找到对应记录");
        }
        resJson.put("count", delete);
        return ResponseEntity.ok(resJson.toJSONString());
    }

    /**
     * 分页查询业主房屋产调记录信息列表
     *
     * @param page                    页码（默认1）
     * @param row                     每页条数（默认10）
     * @param id                      主键ID（可选）
     * @param ownerId                 业主编号（可选）
     * @param roomId                  房屋编号（可选）
     * @param surveyWarrantApplyDate  调查令申请日期（可选）
     * @param propertySurveyDate      产调日期（可选）
     * @param name                    业主姓名（可选）
     * @param startPropertySurveyDate 产调日期开始范围（可选）
     * @param endPropertySurveyDate   产调日期结束范围（可选）
     * @return 响应结果
     * @serviceCode /ownerPropertySurvey/queryOwnerPropertySurveyInfo
     * @path /app/ownerPropertySurvey/queryOwnerPropertySurveyInfo
     */
    @RequestMapping(value = "/queryOwnerPropertySurveyInfo", method = RequestMethod.GET)
    public ResponseEntity<String> queryOwnerPropertySurveyInfo(
            @RequestParam(value = "page", defaultValue = "1") int page,
            @RequestParam(value = "row", defaultValue = "10") int row,
            @RequestParam(value = "id", required = false) String id,
            @RequestParam(value = "ownerId", required = false) String ownerId,
            @RequestParam(value = "roomId", required = false) String roomId,
            @RequestParam(value = "surveyWarrantApplyDate", required = false) String surveyWarrantApplyDate,
            @RequestParam(value = "propertySurveyDate", required = false) String propertySurveyDate,
            @RequestParam(value = "name", required = false) String name,
            @RequestParam(value = "startPropertySurveyDate", required = false) String startPropertySurveyDate,
            @RequestParam(value = "endPropertySurveyDate", required = false) String endPropertySurveyDate) {

        // 封装查询参数
        Map<String, Object> param = new HashMap<>();
        param.put("page", (page - 1) * row); // 转换为MySQL分页偏移量
        param.put("row", row);
        param.put("id", id);
        param.put("ownerId", ownerId);
        param.put("roomId", roomId);
        param.put("surveyWarrantApplyDate", surveyWarrantApplyDate);
        param.put("propertySurveyDate", propertySurveyDate);
        param.put("name", name);
        param.put("startPropertySurveyDate", startPropertySurveyDate);
        param.put("endPropertySurveyDate", endPropertySurveyDate);

        // 查询列表数据
        List<Map<String, Object>> list = sqlSessionTemplate.selectList(
                "ownerPropertySurveyServiceDaoImpl.getOwnerPropertySurveyInfo", param);

        // 查询总数
        Map<String, Object> countMap = sqlSessionTemplate.selectOne(
                "ownerPropertySurveyServiceDaoImpl.queryOwnerPropertySurveysCount", param);
        int total = countMap != null ? Integer.parseInt(countMap.get("count").toString()) : 0;

        // 构造分页响应
        JSONObject resJson = new JSONObject();
        resJson.put("code", "0000");
        resJson.put("msg", "查询业主房屋产调记录信息成功");
        resJson.put("page", page);
        resJson.put("row", row);
        resJson.put("total", total);
        resJson.put("data", BeanConvertUtil.covertBeanList(list, OwnerPropertySurvey.class));

        return ResponseEntity.ok(resJson.toJSONString());
    }

    /**
     * 查询业主房屋产调记录统计信息
     *
     * @param ownerId                 业主编号（可选）
     * @param roomId                  房屋编号（可选）
     * @param startPropertySurveyDate 产调日期开始范围（可选）
     * @param endPropertySurveyDate   产调日期结束范围（可选）
     * @return 响应结果
     * @serviceCode /ownerPropertySurvey/queryOwnerPropertySurveyStatistics
     * @path /app/ownerPropertySurvey/queryOwnerPropertySurveyStatistics
     */
    @RequestMapping(value = "/queryOwnerPropertySurveyStatistics", method = RequestMethod.GET)
    public ResponseEntity<String> queryOwnerPropertySurveyStatistics(
            @RequestParam(value = "ownerId", required = false) String ownerId,
            @RequestParam(value = "roomId", required = false) String roomId,
            @RequestParam(value = "startPropertySurveyDate", required = false) String startPropertySurveyDate,
            @RequestParam(value = "endPropertySurveyDate", required = false) String endPropertySurveyDate) {

        // 封装查询参数
        Map<String, Object> param = new HashMap<>();
        param.put("ownerId", ownerId);
        param.put("roomId", roomId);
        param.put("startPropertySurveyDate", startPropertySurveyDate);
        param.put("endPropertySurveyDate", endPropertySurveyDate);

        // 统计查询
        Map<String, Object> statistics = sqlSessionTemplate.selectOne(
                "ownerPropertySurveyServiceDaoImpl.queryOwnerPropertySurveyStatistics", param);

        JSONObject resJson = new JSONObject();
        resJson.put("code", "0000");
        resJson.put("msg", "统计业主房屋产调记录信息成功");
        resJson.put("data", statistics);

        return ResponseEntity.ok(resJson.toJSONString());
    }

    /**
     * 按产调日期年月维度统计业主房屋产调记录
     *
     * @param startPropertySurveyDate 产调日期开始范围（可选）
     * @param endPropertySurveyDate   产调日期结束范围（可选）
     * @return 响应结果
     * @serviceCode /ownerPropertySurvey/queryOwnerPropertySurveyByMonth
     * @path /app/ownerPropertySurvey/queryOwnerPropertySurveyByMonth
     */
    @RequestMapping(value = "/queryOwnerPropertySurveyByMonth", method = RequestMethod.GET)
    public ResponseEntity<String> queryOwnerPropertySurveyByMonth(
            @RequestParam(value = "startPropertySurveyDate", required = false) String startPropertySurveyDate,
            @RequestParam(value = "endPropertySurveyDate", required = false) String endPropertySurveyDate) {

        // 封装查询参数
        Map<String, Object> param = new HashMap<>();
        param.put("startPropertySurveyDate", startPropertySurveyDate);
        param.put("endPropertySurveyDate", endPropertySurveyDate);

        // 按年月统计查询
        List<Map<String, Object>> resultList = sqlSessionTemplate.selectList(
                "ownerPropertySurveyServiceDaoImpl.queryOwnerPropertySurveyByMonth", param);

        JSONObject resJson = new JSONObject();
        resJson.put("code", "0000");
        resJson.put("msg", "按年月维度统计业主房屋产调记录成功");
        resJson.put("data", resultList);

        return ResponseEntity.ok(resJson.toJSONString());
    }

    /**
     * 查询未完成产调的记录（产调日期为空）
     *
     * @param page                    页码（默认1）
     * @param row                     每页条数（默认10）
     * @param ownerId                 业主编号（可选）
     * @param roomId                  房屋编号（可选）
     * @param startSurveyWarrantDate  调查令申请日期开始范围（可选）
     * @param endSurveyWarrantDate    调查令申请日期结束范围（可选）
     * @return 响应结果
     * @serviceCode /ownerPropertySurvey/queryUnfinishedPropertySurveys
     * @path /app/ownerPropertySurvey/queryUnfinishedPropertySurveys
     */
    @RequestMapping(value = "/queryUnfinishedPropertySurveys", method = RequestMethod.GET)
    public ResponseEntity<String> queryUnfinishedPropertySurveys(
            @RequestParam(value = "page", defaultValue = "1") int page,
            @RequestParam(value = "row", defaultValue = "10") int row,
            @RequestParam(value = "ownerId", required = false) String ownerId,
            @RequestParam(value = "roomId", required = false) String roomId,
            @RequestParam(value = "startSurveyWarrantDate", required = false) String startSurveyWarrantDate,
            @RequestParam(value = "endSurveyWarrantDate", required = false) String endSurveyWarrantDate) {

        // 封装查询参数
        Map<String, Object> param = new HashMap<>();
        param.put("page", (page - 1) * row);
        param.put("row", row);
        param.put("ownerId", ownerId);
        param.put("roomId", roomId);
        param.put("startSurveyWarrantDate", startSurveyWarrantDate);
        param.put("endSurveyWarrantDate", endSurveyWarrantDate);

        // 查询未完成记录
        List<Map<String, Object>> list = sqlSessionTemplate.selectList(
                "ownerPropertySurveyServiceDaoImpl.queryUnfinishedPropertySurveys", param);

        JSONObject resJson = new JSONObject();
        resJson.put("code", "0000");
        resJson.put("msg", "查询未完成产调记录成功");
        resJson.put("page", page);
        resJson.put("row", row);
        resJson.put("total", list.size()); // 如需精准总数可新增count方法，此处简化
        resJson.put("data", list);

        return ResponseEntity.ok(resJson.toJSONString());
    }
}