package com.java110.fee.api;

import com.alibaba.fastjson.JSONObject;
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;

/**
 * 对方收款单位接口
 * 适配 payee_receiveInfo 表
 * @author dev
 * @date 2025-12-24
 */
@RestController
@RequestMapping(value = "/payeeReceiveInfo")
public class PayeeReceiveInfoApi {

    @Autowired
    protected SqlSessionTemplate sqlSessionTemplate;

    /**
     * 保存对方收款单位信息
     *
     * @param reqJson 请求参数
     * @return 响应结果
     * @serviceCode /payeeReceiveInfo/savePayeeReceiveInfo
     * @path /app/payeeReceiveInfo/savePayeeReceiveInfo
     */
    @RequestMapping(value = "/savePayeeReceiveInfo", method = RequestMethod.POST)
    public ResponseEntity<String> savePayeeReceiveInfo(@RequestBody JSONObject reqJson) {
        // 核心参数校验（可根据业务补充必传校验）
        Assert.hasKeyAndValue(reqJson, "ownerId", "请求报文中未包含业主编号ownerId");

        // 转换为POJO
        PayeeReceiveInfoPo po = BeanConvertUtil.covertBean(reqJson, PayeeReceiveInfoPo.class);

        // 调用Mapper保存方法
        int insert = sqlSessionTemplate.insert("payeeReceiveInfoServiceDaoImpl.savePayeeReceiveInfo",
                BeanConvertUtil.beanCovertMap(po));

        // 构造响应结果
        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());
    }

    public ResponseEntity<String> savePayeeReceiveInfo(PayeeReceiveInfoPo po) {
        // 调用Mapper保存方法
        int insert = sqlSessionTemplate.insert("payeeReceiveInfoServiceDaoImpl.savePayeeReceiveInfo",
                BeanConvertUtil.beanCovertMap(po));

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

        // 转换批量数据
        List<PayeeReceiveInfoPo> poList = BeanConvertUtil.covertBeanList(
                reqJson.getJSONArray("payeeReceiveInfoList"), PayeeReceiveInfoPo.class);

        Map<String, Object> param = BeanConvertUtil.beanCovertMap(reqJson);
        param.put("payeeReceiveInfoList", poList);

        // 批量插入
        int insert = sqlSessionTemplate.insert("payeeReceiveInfoServiceDaoImpl.batchSavePayeeReceiveInfo", 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 /payeeReceiveInfo/updatePayeeReceiveInfo
     * @path /app/payeeReceiveInfo/updatePayeeReceiveInfo
     */
    @RequestMapping(value = "/updatePayeeReceiveInfo", method = RequestMethod.POST)
    public ResponseEntity<String> updatePayeeReceiveInfo(@RequestBody JSONObject reqJson) {
        // 主键校验
        Assert.hasKeyAndValue(reqJson, "id", "请求报文中未包含主键ID");

        PayeeReceiveInfoPo po = BeanConvertUtil.covertBean(reqJson, PayeeReceiveInfoPo.class);

        // 调用Mapper修改方法
        int update = sqlSessionTemplate.update("payeeReceiveInfoServiceDaoImpl.updatePayeeReceiveInfo",
                BeanConvertUtil.beanCovertMap(po));

        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 /payeeReceiveInfo/deletePayeeReceiveInfo
     * @path /app/payeeReceiveInfo/deletePayeeReceiveInfo
     */
    @RequestMapping(value = "/deletePayeeReceiveInfo", method = RequestMethod.POST)
    public ResponseEntity<String> deletePayeeReceiveInfo(@RequestBody JSONObject reqJson) {
        // 必要参数校验
        Assert.hasKeyAndValue(reqJson, "id", "主键ID不能为空");

        PayeeReceiveInfoPo po = BeanConvertUtil.covertBean(reqJson, PayeeReceiveInfoPo.class);

        // 调用Mapper删除方法
        int delete = sqlSessionTemplate.delete("payeeReceiveInfoServiceDaoImpl.deletePayeeReceiveInfo",
                BeanConvertUtil.beanCovertMap(po));

        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 ownerId            业主编号（必传）
     * @param page                页码（默认1）
     * @param row                 每页条数（默认10）
     * @param id                  主键ID（可选）
     * @param roomId             房屋Id（可选）
     * @return 响应结果
     * @serviceCode /payeeReceiveInfo/queryPayeeReceiveInfo
     * @path /app/payeeReceiveInfo/queryPayeeReceiveInfo
     */
    @RequestMapping(value = "/queryPayeeReceiveInfo", method = RequestMethod.GET)
    public ResponseEntity<String> queryPayeeReceiveInfo(
            @RequestParam(value = "ownerId") String ownerId,
            @RequestParam(value = "page", defaultValue = "1") int page,
            @RequestParam(value = "row", defaultValue = "10") int row,
            @RequestParam(value = "id", required = false) String id,
            @RequestParam(value = "roomId", required = false) String roomId) {

        // 封装查询参数
        PayeeReceiveInfoPo queryPo = new PayeeReceiveInfoPo();
        queryPo.setOwnerId(ownerId);
        queryPo.setPage((page - 1) * row); // 转换为MySQL分页偏移量
        queryPo.setRow(row);

        if (id != null && !id.isEmpty()) {
            queryPo.setId(Integer.parseInt(id));
        }
        if (roomId != null && !roomId.isEmpty()) {
            queryPo.setRoomId(roomId);
        }

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

        // 查询总数
        Object total = ((HashMap) sqlSessionTemplate.selectOne(
                "payeeReceiveInfoServiceDaoImpl.queryPayeeReceiveInfoCount",
                BeanConvertUtil.beanCovertMap(queryPo))).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", list);

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

    /**
     * 根据ID查询单条对方收款单位信息
     *
     * @param id 主键ID
     * @return 响应结果
     * @serviceCode /payeeReceiveInfo/getPayeeReceiveInfoById
     * @path /app/payeeReceiveInfo/getPayeeReceiveInfoById
     */
    @RequestMapping(value = "/getPayeeReceiveInfoById", method = RequestMethod.GET)
    public ResponseEntity<String> getPayeeReceiveInfoById(@RequestParam(value = "id") Integer id) {
        // 主键校验
        Assert.notNull(id, "主键ID不能为空");

        PayeeReceiveInfoPo queryPo = new PayeeReceiveInfoPo();
        queryPo.setId(id);

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

        JSONObject resJson = new JSONObject();
        if (result != null) {
            resJson.put("code", "0000");
            resJson.put("msg", "查询对方收款单位信息成功");
            resJson.put("data", result);
        } else {
            resJson.put("code", "0001");
            resJson.put("msg", "未找到对应对方收款单位记录");
        }

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

    /**
     * 根据ownerId查询对方收款单位信息
     *
     * @param ownerId 业主编号
     * @return 响应结果
     * @serviceCode /payeeReceiveInfo/getPayeeReceiveInfoByOwnerId
     * @path /app/payeeReceiveInfo/getPayeeReceiveInfoByOwnerId
     */
    @RequestMapping(value = "/getPayeeReceiveInfoByOwnerId", method = RequestMethod.GET)
    public ResponseEntity<String> getPayeeReceiveInfoByOwnerId(@RequestParam(value = "ownerId") String ownerId) {
        Assert.notNull(ownerId, "业主编号ownerId不能为空");

        PayeeReceiveInfoPo queryPo = new PayeeReceiveInfoPo();
        queryPo.setOwnerId(ownerId);

        List<Map<String, Object>> result = sqlSessionTemplate.selectList(
                "payeeReceiveInfoServiceDaoImpl.getPayeeReceiveInfo",
                BeanConvertUtil.beanCovertMap(queryPo));

        JSONObject resJson = new JSONObject();
        resJson.put("code", "0000");
        resJson.put("msg", "查询对方收款单位信息成功");
        resJson.put("data", result);

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

    /**
     * 统计对方收款单位信息
     *
     * @param ownerId            业主编号（可选）
     * @param roomId             房屋Id（可选）
     * @param startCreateTime     开始创建时间（可选，格式：yyyy-MM-dd HH:mm:ss）
     * @param endCreateTime       结束创建时间（可选）
     * @return 响应结果
     * @serviceCode /payeeReceiveInfo/queryPayeeReceiveInfoStatistics
     * @path /app/payeeReceiveInfo/queryPayeeReceiveInfoStatistics
     */
    @RequestMapping(value = "/queryPayeeReceiveInfoStatistics", method = RequestMethod.GET)
    public ResponseEntity<String> queryPayeeReceiveInfoStatistics(
            @RequestParam(value = "ownerId", required = false) String ownerId,
            @RequestParam(value = "roomId", required = false) String roomId,
            @RequestParam(value = "startCreateTime", required = false) String startCreateTime,
            @RequestParam(value = "endCreateTime", required = false) String endCreateTime) {

        PayeeReceiveInfoPo queryPo = new PayeeReceiveInfoPo();
        queryPo.setOwnerId(ownerId);
        queryPo.setRoomId(roomId);
        queryPo.setStartCreateTime(startCreateTime);
        queryPo.setEndCreateTime(endCreateTime);

        // 统计查询
        Map<String, Object> statistics = sqlSessionTemplate.selectOne(
                "payeeReceiveInfoServiceDaoImpl.queryPayeeReceiveInfoStatistics",
                BeanConvertUtil.beanCovertMap(queryPo));

        JSONObject resJson = new JSONObject();
        resJson.put("code", "0000");
        resJson.put("msg", "统计对方收款单位信息成功");
        resJson.put("data", statistics);

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

    /**
     * 配套POJO类（内部类形式，也可抽离为独立类）
     */
    public static class PayeeReceiveInfoPo {
        private Integer id;
        private String callerName;
        private String contactInfo;
        private String payeeInfo;
        private String invoiceNo;
        private String invoiceDate;
        private String receiptNo;
        private String receiptDate;
        private String receiptNote;
        private String receiptNoteDate;
        private String imageFile;
        private String ourCompanyReceiveDate;
        private String attachmentFile;
        private String createTime;
        private String updateTime;
        private String ownerId;
        private String roomId;
        // 分页参数
        private int page;
        private int row;
        // 统计时间范围参数
        private String startCreateTime;
        private String endCreateTime;

        // Getter & Setter
        public Integer getId() {
            return id;
        }

        public void setId(Integer id) {
            this.id = id;
        }

        public String getCallerName() {
            return callerName;
        }

        public void setCallerName(String callerName) {
            this.callerName = callerName;
        }

        public String getContactInfo() {
            return contactInfo;
        }

        public void setContactInfo(String contactInfo) {
            this.contactInfo = contactInfo;
        }

        public String getPayeeInfo() {
            return payeeInfo;
        }

        public void setPayeeInfo(String payeeInfo) {
            this.payeeInfo = payeeInfo;
        }

        public String getInvoiceNo() {
            return invoiceNo;
        }

        public void setInvoiceNo(String invoiceNo) {
            this.invoiceNo = invoiceNo;
        }

        public String getInvoiceDate() {
            return invoiceDate;
        }

        public void setInvoiceDate(String invoiceDate) {
            this.invoiceDate = invoiceDate;
        }

        public String getReceiptNo() {
            return receiptNo;
        }

        public void setReceiptNo(String receiptNo) {
            this.receiptNo = receiptNo;
        }

        public String getReceiptDate() {
            return receiptDate;
        }

        public void setReceiptDate(String receiptDate) {
            this.receiptDate = receiptDate;
        }

        public String getReceiptNote() {
            return receiptNote;
        }

        public void setReceiptNote(String receiptNote) {
            this.receiptNote = receiptNote;
        }

        public String getReceiptNoteDate() {
            return receiptNoteDate;
        }

        public void setReceiptNoteDate(String receiptNoteDate) {
            this.receiptNoteDate = receiptNoteDate;
        }

        public String getImageFile() {
            return imageFile;
        }

        public void setImageFile(String imageFile) {
            this.imageFile = imageFile;
        }

        public String getOurCompanyReceiveDate() {
            return ourCompanyReceiveDate;
        }

        public void setOurCompanyReceiveDate(String ourCompanyReceiveDate) {
            this.ourCompanyReceiveDate = ourCompanyReceiveDate;
        }

        public String getAttachmentFile() {
            return attachmentFile;
        }

        public void setAttachmentFile(String attachmentFile) {
            this.attachmentFile = attachmentFile;
        }

        public String getCreateTime() {
            return createTime;
        }

        public void setCreateTime(String createTime) {
            this.createTime = createTime;
        }

        public String getUpdateTime() {
            return updateTime;
        }

        public void setUpdateTime(String updateTime) {
            this.updateTime = updateTime;
        }

        public String getOwnerId() {
            return ownerId;
        }

        public void setOwnerId(String ownerId) {
            this.ownerId = ownerId;
        }

        public String getRoomId() {
            return roomId;
        }

        public void setRoomId(String roomId) {
            this.roomId = roomId;
        }

        public int getPage() {
            return page;
        }

        public void setPage(int page) {
            this.page = page;
        }

        public int getRow() {
            return row;
        }

        public void setRow(int row) {
            this.row = row;
        }

        public String getStartCreateTime() {
            return startCreateTime;
        }

        public void setStartCreateTime(String startCreateTime) {
            this.startCreateTime = startCreateTime;
        }

        public String getEndCreateTime() {
            return endCreateTime;
        }

        public void setEndCreateTime(String endCreateTime) {
            this.endCreateTime = endCreateTime;
        }
    }
}