package com.java110.fee.api;

import com.alibaba.fastjson.JSONObject;
import com.java110.dto.importData.OwnerCollectionDto;
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_collection 表
 * @author dev
 * @date 2025-12-24
 */
@RestController
@RequestMapping(value = "/ownerCollection")
public class OwnerCollectionApi {

    @Autowired
    protected SqlSessionTemplate sqlSessionTemplate;

    /**
     * 保存业主催缴信息
     *
     * @param reqJson 请求参数
     * @return 响应结果
     * @serviceCode /ownerCollection/saveOwnerCollection
     * @path /app/ownerCollection/saveOwnerCollection
     */
    @RequestMapping(value = "/saveOwnerCollection", method = RequestMethod.POST)
    public ResponseEntity<String> saveOwnerCollection(@RequestBody JSONObject reqJson) {
        // 核心参数校验（可根据业务补充必要的非空校验）
        Assert.hasKeyAndValue(reqJson, "ownerId", "请求报文中未包含业主ID");
        Assert.hasKeyAndValue(reqJson, "roomId", "请求报文中未包含房间ID");

        // 转换为DTO
        OwnerCollectionDto dto = BeanConvertUtil.covertBean(reqJson, OwnerCollectionDto.class);
        // 补充默认时间（可根据业务调整，比如取当前时间）
        if (dto.getCreateTime() == null || dto.getCreateTime().isEmpty()) {
            dto.setCreateTime(String.valueOf(System.currentTimeMillis()));
        }
        dto.setUpdateTime(dto.getCreateTime());

        // 调用Mapper保存方法
        int insert = sqlSessionTemplate.insert("ownerV1ServiceDaoImpl.saveOwnerCollection",
                BeanConvertUtil.beanCovertMap(dto));

        // 构造响应结果
        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 dto 业主催缴DTO
     * @return 响应结果
     */
    public ResponseEntity<String> saveOwnerCollection(OwnerCollectionDto dto) {
        // 补充默认时间
        if (dto.getCreateTime() == null || dto.getCreateTime().isEmpty()) {
            dto.setCreateTime(String.valueOf(System.currentTimeMillis()));
        }
        dto.setUpdateTime(dto.getCreateTime());

        int insert = sqlSessionTemplate.insert("ownerV1ServiceDaoImpl.saveOwnerCollection",
                BeanConvertUtil.beanCovertMap(dto));

        // 构造响应结果
        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 请求参数
     * @return 响应结果
     * @serviceCode /ownerCollection/updateOwnerCollection
     * @path /app/ownerCollection/updateOwnerCollection
     */
    @RequestMapping(value = "/updateOwnerCollection", method = RequestMethod.POST)
    public ResponseEntity<String> updateOwnerCollection(@RequestBody JSONObject reqJson) {
        // 主键校验
        Assert.hasKey(reqJson, "collectionId", "请求报文中未包含催缴信息主键ID");

        OwnerCollectionDto dto = BeanConvertUtil.covertBean(reqJson, OwnerCollectionDto.class);
        // 补充更新时间
        dto.setUpdateTime(String.valueOf(System.currentTimeMillis()));

        // 调用Mapper修改方法
        int update = sqlSessionTemplate.update("ownerV1ServiceDaoImpl.updateOwnerCollection",
                BeanConvertUtil.beanCovertMap(dto));

        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 collectionId       催缴信息ID（可选）
     * @param ownerId            业主ID（可选）
     * @param roomId             房间ID（可选）
     * @param collectionStartDate 催缴开始日期（可选）
     * @param collectionEndDate   催缴结束日期（可选）
     * @param page               页码（默认1）
     * @param row                每页条数（默认10）
     * @return 响应结果
     * @serviceCode /ownerCollection/queryOwnerCollection
     * @path /app/ownerCollection/queryOwnerCollection
     */
    @RequestMapping(value = "/queryOwnerCollection", method = RequestMethod.GET)
    public ResponseEntity<String> queryOwnerCollection(
            @RequestParam(value = "collectionId", required = false) String collectionId,
            @RequestParam(value = "ownerId", required = false) String ownerId,
            @RequestParam(value = "roomId", required = false) String roomId,
            @RequestParam(value = "collectionStartDate", required = false) String collectionStartDate,
            @RequestParam(value = "collectionEndDate", required = false) String collectionEndDate,
            @RequestParam(value = "page", defaultValue = "1") int page,
            @RequestParam(value = "row", defaultValue = "10") int row) {

        // 封装查询参数
        OwnerCollectionDto queryDto = new OwnerCollectionDto();
        queryDto.setCollectionId(collectionId);
        queryDto.setOwnerId(ownerId);
        queryDto.setRoomId(roomId);
        queryDto.setCollectionStartDate(collectionStartDate);
        queryDto.setCollectionEndDate(collectionEndDate);
        queryDto.setCreateTime(null); // 排除默认时间干扰
        queryDto.setUpdateTime(null);
        queryDto.setPage((page - 1) * row); // 计算分页起始位置
        queryDto.setRow(row);

        // 查询列表数据
        List<Map<String, Object>> list = sqlSessionTemplate.selectList(
                "ownerV1ServiceDaoImpl.getOwnerCollection",
                BeanConvertUtil.beanCovertMap(queryDto));

        List<OwnerCollectionDto> ownerCollections = BeanConvertUtil.covertBeanList(list, OwnerCollectionDto.class);

        // 查询总数
        Object total = ((HashMap) sqlSessionTemplate.selectOne(
                "ownerV1ServiceDaoImpl.queryOwnerCollectionCount",
                BeanConvertUtil.beanCovertMap(queryDto))).get("count");

        // 构造分页响应
        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", ownerCollections);

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

    /**
     * 根据ID查询单条业主催缴信息
     *
     * @param collectionId 催缴信息主键ID
     * @return 响应结果
     * @serviceCode /ownerCollection/getOwnerCollectionById
     * @path /app/ownerCollection/getOwnerCollectionById
     */
    @RequestMapping(value = "/getOwnerCollectionById", method = RequestMethod.GET)
    public ResponseEntity<String> getOwnerCollectionById(@RequestParam(value = "collectionId") String collectionId) {
        // 主键校验
        Assert.hasLength(collectionId, "催缴信息主键ID不能为空");

        OwnerCollectionDto queryDto = new OwnerCollectionDto();
        queryDto.setCollectionId(collectionId);

        // 查询单条数据
        Map<String, Object> result = sqlSessionTemplate.selectOne(
                "ownerV1ServiceDaoImpl.getOwnerCollection",
                BeanConvertUtil.beanCovertMap(queryDto));

        JSONObject resJson = new JSONObject();
        if (result != null) {
            OwnerCollectionDto ownerCollection = BeanConvertUtil.covertBean(result, OwnerCollectionDto.class);
            resJson.put("code", "0000");
            resJson.put("msg", "查询业主催缴信息成功");
            resJson.put("data", ownerCollection);
        } else {
            resJson.put("code", "0001");
            resJson.put("msg", "未找到对应业主催缴记录");
        }

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

    /**
     * 根据业主ID查询业主催缴信息
     *
     * @param ownerId 业主ID
     * @return 响应结果
     * @serviceCode /ownerCollection/getOwnerCollectionByOwnerId
     * @path /app/ownerCollection/getOwnerCollectionByOwnerId
     */
    @RequestMapping(value = "/getOwnerCollectionByOwnerId", method = RequestMethod.GET)
    public ResponseEntity<String> getOwnerCollectionByOwnerId(@RequestParam(value = "ownerId") String ownerId) {
        Assert.hasLength(ownerId, "业主ID不能为空");

        OwnerCollectionDto queryDto = new OwnerCollectionDto();
        queryDto.setOwnerId(ownerId);

        List<Map<String, Object>> result = sqlSessionTemplate.selectList(
                "ownerV1ServiceDaoImpl.getOwnerCollection",
                BeanConvertUtil.beanCovertMap(queryDto));

        JSONObject resJson = new JSONObject();
        resJson.put("code", "0000");
        resJson.put("msg", "查询业主催缴信息成功");
        resJson.put("data", result);

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