package com.java110.fee.api.z2;

import com.alibaba.fastjson.JSONObject;
import com.java110.dto.importData.HouseMailRecord;
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;

/**
 * 房屋邮寄记录信息接口
 * 适配 house_mail_record 表
 * @author dev
 * @date 2025-12-24
 */
@RestController
@RequestMapping(value = "/houseMailRecord")
public class HouseMailRecordApi {

    @Autowired
    protected SqlSessionTemplate sqlSessionTemplate;

    /**
     * 保存单条房屋邮寄记录信息
     *
     * @param reqJson 请求参数
     * @return 响应结果
     * @serviceCode /houseMailRecord/saveHouseMailRecordInfo
     * @path /app/houseMailRecord/saveHouseMailRecordInfo
     */
    @RequestMapping(value = "/saveHouseMailRecord", method = RequestMethod.POST)
    public ResponseEntity<String> saveHouseMailRecordInfo(@RequestBody JSONObject reqJson) {
        // 核心参数校验
        Assert.hasKeyAndValue(reqJson, "ownerId", "请求报文中未包含业主编号ownerId");
        Assert.hasKeyAndValue(reqJson, "houseId", "请求报文中未包含房屋编号houseId");
        Assert.hasKeyAndValue(reqJson, "sendDate", "请求报文中未包含寄出日期sendDate");

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

        // 调用Mapper保存方法
        int insert = sqlSessionTemplate.insert("houseMailRecordServiceDaoImpl.saveHouseMailRecordInfo",
                BeanConvertUtil.beanCovertMap(record));

        // 构造响应结果
        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 请求参数（包含houseMailRecordList数组）
     * @return 响应结果
     * @serviceCode /houseMailRecord/saveHouseMailRecords
     * @path /app/houseMailRecord/saveHouseMailRecords
     */
    @RequestMapping(value = "/saveHouseMailRecords", method = RequestMethod.POST)
    public ResponseEntity<String> saveHouseMailRecords(@RequestBody JSONObject reqJson) {
        Assert.hasKeyAndValue(reqJson, "houseMailRecordList", "请求报文中未包含批量数据列表houseMailRecordList");

        // 转换批量数据
        List<HouseMailRecord> recordList = BeanConvertUtil.covertBeanList(
                reqJson.getJSONArray("houseMailRecordList"), HouseMailRecord.class);

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

        // 批量插入
        int insert = sqlSessionTemplate.insert("houseMailRecordServiceDaoImpl.saveHouseMailRecords", 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 /houseMailRecord/updateHouseMailRecordInfo
     * @path /app/houseMailRecord/updateHouseMailRecordInfo
     */
    @RequestMapping(value = "/updateHouseMailRecordInfo", method = RequestMethod.POST)
    public ResponseEntity<String> updateHouseMailRecordInfo(@RequestBody JSONObject reqJson) {
        // 主键校验（id 或 ownerId+houseId 二选一）
        boolean hasId = reqJson.containsKey("id") && reqJson.getString("id") != null && !reqJson.getString("id").isEmpty();
        boolean hasOwnerAndHouseId = reqJson.containsKey("ownerId") && !reqJson.getString("ownerId").isEmpty()
                && reqJson.containsKey("houseId") && !reqJson.getString("houseId").isEmpty();
        Assert.isTrue(hasId || hasOwnerAndHouseId, "请求报文中需包含主键ID，或同时包含业主编号和房屋编号");

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

        // 调用Mapper修改方法
        int update = sqlSessionTemplate.update("houseMailRecordServiceDaoImpl.updateHouseMailRecordInfo",
                BeanConvertUtil.beanCovertMap(record));

        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 /houseMailRecord/deleteHouseMailRecordInfo
     * @path /app/houseMailRecord/deleteHouseMailRecordInfo
     */
    @RequestMapping(value = "/deleteHouseMailRecordInfo", method = RequestMethod.POST)
    public ResponseEntity<String> deleteHouseMailRecordInfo(@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("houseId") && !reqJson.getString("houseId").isEmpty();
        Assert.isTrue(hasFilter, "请求报文中需包含id/ownerId/houseId至少一个筛选条件");

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

        // 调用Mapper删除方法
        int delete = sqlSessionTemplate.delete("houseMailRecordServiceDaoImpl.deleteHouseMailRecordInfo",
                BeanConvertUtil.beanCovertMap(record));

        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 houseId         房屋编号（可选）
     * @param sendDate        寄出日期（可选）
     * @param mailNo          邮寄单号（可选）
     * @param mailResult      邮寄结果（可选）
     * @param startSendDate   寄出日期开始范围（可选）
     * @param endSendDate     寄出日期结束范围（可选）
     * @return 响应结果
     * @serviceCode /houseMailRecord/queryHouseMailRecordInfo
     * @path /app/houseMailRecord/queryHouseMailRecordInfo
     */
    @RequestMapping(value = "/queryHouseMailRecordInfo", method = RequestMethod.GET)
    public ResponseEntity<String> queryHouseMailRecordInfo(
            @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 = "houseId", required = false) String houseId,
            @RequestParam(value = "sendDate", required = false) String sendDate,
            @RequestParam(value = "mailNo", required = false) String mailNo,
            @RequestParam(value = "mailResult", required = false) String mailResult,
            @RequestParam(value = "startSendDate", required = false) String startSendDate,
            @RequestParam(value = "endSendDate", required = false) String endSendDate) {

        // 封装查询参数
        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("houseId", houseId);
        param.put("sendDate", sendDate);
        param.put("mailNo", mailNo);
        param.put("mailResult", mailResult);
        param.put("startSendDate", startSendDate);
        param.put("endSendDate", endSendDate);

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

        // 查询总数
        Map<String, Object> countMap = sqlSessionTemplate.selectOne(
                "houseMailRecordServiceDaoImpl.queryHouseMailRecordsCount", 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, HouseMailRecord.class));

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

    /**
     * 查询房屋邮寄记录统计信息
     *
     * @param ownerId         业主编号（可选）
     * @param houseId         房屋编号（可选）
     * @param startSendDate   寄出日期开始范围（可选）
     * @param endSendDate     寄出日期结束范围（可选）
     * @return 响应结果
     * @serviceCode /houseMailRecord/queryHouseMailRecordStatistics
     * @path /app/houseMailRecord/queryHouseMailRecordStatistics
     */
    @RequestMapping(value = "/queryHouseMailRecordStatistics", method = RequestMethod.GET)
    public ResponseEntity<String> queryHouseMailRecordStatistics(
            @RequestParam(value = "ownerId", required = false) String ownerId,
            @RequestParam(value = "houseId", required = false) String houseId,
            @RequestParam(value = "startSendDate", required = false) String startSendDate,
            @RequestParam(value = "endSendDate", required = false) String endSendDate) {

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

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

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

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

    /**
     * 按邮寄结果分组统计房屋邮寄记录
     *
     * @param ownerId         业主编号（可选）
     * @param houseId         房屋编号（可选）
     * @param startSendDate   寄出日期开始范围（可选）
     * @param endSendDate     寄出日期结束范围（可选）
     * @return 响应结果
     * @serviceCode /houseMailRecord/queryHouseMailRecordByMailResult
     * @path /app/houseMailRecord/queryHouseMailRecordByMailResult
     */
    @RequestMapping(value = "/queryHouseMailRecordByMailResult", method = RequestMethod.GET)
    public ResponseEntity<String> queryHouseMailRecordByMailResult(
            @RequestParam(value = "ownerId", required = false) String ownerId,
            @RequestParam(value = "houseId", required = false) String houseId,
            @RequestParam(value = "startSendDate", required = false) String startSendDate,
            @RequestParam(value = "endSendDate", required = false) String endSendDate) {

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

        // 分组统计查询
        List<Map<String, Object>> resultList = sqlSessionTemplate.selectList(
                "houseMailRecordServiceDaoImpl.queryHouseMailRecordByMailResult", param);

        JSONObject resJson = new JSONObject();
        resJson.put("code", "0000");
        resJson.put("msg", "按邮寄结果分组统计房屋邮寄记录成功");
        resJson.put("data", resultList);

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

    /**
     * 按年月维度统计邮寄费用
     *
     * @param startSendDate   寄出日期开始范围（可选）
     * @param endSendDate     寄出日期结束范围（可选）
     * @return 响应结果
     * @serviceCode /houseMailRecord/queryHouseMailRecordByMonth
     * @path /app/houseMailRecord/queryHouseMailRecordByMonth
     */
    @RequestMapping(value = "/queryHouseMailRecordByMonth", method = RequestMethod.GET)
    public ResponseEntity<String> queryHouseMailRecordByMonth(
            @RequestParam(value = "startSendDate", required = false) String startSendDate,
            @RequestParam(value = "endSendDate", required = false) String endSendDate) {

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

        // 按年月统计查询
        List<Map<String, Object>> resultList = sqlSessionTemplate.selectList(
                "houseMailRecordServiceDaoImpl.queryHouseMailRecordByMonth", 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 houseId         房屋编号（可选）
     * @param startSendDate   寄出日期开始范围（可选）
     * @param endSendDate     寄出日期结束范围（可选）
     * @return 响应结果
     * @serviceCode /houseMailRecord/queryUnfinishedMailRecords
     * @path /app/houseMailRecord/queryUnfinishedMailRecords
     */
    @RequestMapping(value = "/queryUnfinishedMailRecords", method = RequestMethod.GET)
    public ResponseEntity<String> queryUnfinishedMailRecords(
            @RequestParam(value = "page", defaultValue = "1") int page,
            @RequestParam(value = "row", defaultValue = "10") int row,
            @RequestParam(value = "ownerId", required = false) String ownerId,
            @RequestParam(value = "houseId", required = false) String houseId,
            @RequestParam(value = "startSendDate", required = false) String startSendDate,
            @RequestParam(value = "endSendDate", required = false) String endSendDate) {

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

        // 查询未完成记录
        List<Map<String, Object>> list = sqlSessionTemplate.selectList(
                "houseMailRecordServiceDaoImpl.queryUnfinishedMailRecords", 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());
    }
}