package cn.huge.module.casebook.controller.web;

import cn.huge.base.common.utils.ReturnFailUtils;
import cn.huge.base.common.utils.ReturnSucUtils;
import cn.huge.base.config.CurrentUser;
import cn.huge.module.casebook.domain.dto.CaseBookPageDTO;
import cn.huge.module.casebook.domain.po.CasebookInfo;
import cn.huge.module.casebook.service.CasebookInfoService;
import cn.huge.module.client.api.impl.CustClientImpl;
import cn.huge.module.cust.dto.CtUserDTO;
import cn.huge.module.mediate.constant.CaseBaseConsts;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.google.common.collect.Maps;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import java.util.stream.Stream;

/**
 * @title: dyh_casebook_info接口api-web端
 * @description: dyh_casebook_info接口api-web端
 * @company: hugeinfo
 * @author: liyj
 * @time: 2024-10-26 12:31:22
 * @version: 1.0.0
 */
@Slf4j
@RestController
@RequestMapping("/api/web/caseBook")
public class CaseBookWebController {

    @Autowired(required = false)
    private HttpServletRequest request;

    @Autowired
    private CasebookInfoService casebookInfoService;
    @Autowired
    private CustClientImpl custClient;

    /**
     * 案件导入-导入草稿
     * @url {ctx}/api/web/caseBook/pageImportDraft
     * @param page 页码
     * @param size 每页数量
     * @param sortType 排序方式（1：正序；2：倒序）
     * @return Object
     */
    @GetMapping("/pageImportDraft")
    public Object pageImportDraft(@RequestParam(value = "page") int page, @RequestParam(value = "size") int size
            , @RequestParam(value = "sortType") int sortType, @CurrentUser String userId) {
        try {
            // 查询条件
            Map<String, Object> terms = Maps.newHashMap();
            // 导入时间区间
            String importStart = request.getParameter("importStart");
            String importEnd = request.getParameter("importEnd");
            if(StringUtils.isNotBlank(importStart) && StringUtils.isNotBlank(importEnd)) {
                terms.put("importStart", importStart);
                terms.put("importEnd", importEnd);
            }
            // 纠纷发生时间区间
            String occurStart = request.getParameter("occurStart");
            String occurEnd = request.getParameter("occurEnd");
            if(StringUtils.isNotBlank(occurStart) && StringUtils.isNotBlank(occurEnd)) {
                terms.put("occurStart", occurStart);
                terms.put("occurEnd", occurEnd);
            }
            // 申请方
            String plaintiffs = request.getParameter("plaintiffs");
            if (StringUtils.isNotBlank(plaintiffs)){
                terms.put("plaintiffs", plaintiffs);
            }
            // 被申请方
            String defendants = request.getParameter("defendants");
            if (StringUtils.isNotBlank(defendants)){
                terms.put("defendants", defendants);
            }
            // 调解员
            String mediator = request.getParameter("mediator");
            if (StringUtils.isNotBlank(mediator)){
                terms.put("mediator", mediator);
            }
            // 化解结果
            String mediResult = request.getParameter("mediResult");
            if (StringUtils.isNotBlank(mediResult)){
                terms.put("mediResult", mediResult);
            }
            // 纠纷类型
            String caseType = request.getParameter("caseType");
            if (StringUtils.isNotBlank(caseType)){
                terms.put("caseType", caseType);
            }
            // 协助调解员
            String assistMediator = request.getParameter("assistMediator");
            if (StringUtils.isNotBlank(assistMediator)){
                terms.put("assistMediator", assistMediator);
            }
            CtUserDTO loginUser = custClient.clientGetUserAll(userId);
            terms.put("inputUnitId", loginUser.getUnitId());
            // 排序
            Sort sort = null;
            if(sortType == 1) {
                sort = Sort.by(Sort.Direction.DESC, "t1.create_time");
            }
            if (sortType == 1){
                sort = Sort.by(Sort.Direction.ASC, "t1.create_time");
            }
            PageRequest pageRequest = PageRequest.of(page-1, size, sort);
            Page<CaseBookPageDTO> caseBookPageDTOPage = casebookInfoService.pageImportDraft(pageRequest, terms);
            return ReturnSucUtils.getRepInfo(caseBookPageDTOPage);
        } catch (Exception e) {
            log.error("[CaseBookWebController.pageImportDraft]请求失败，异常信息："+e, e);
            return ReturnFailUtils.getRepInfo();
        }
    }

    /**
    * 案件导入-导入成功
    * @url {ctx}/api/web/caseBook/pageImportSuc
    * @param page 页码
    * @param size 每页数量
    * @param sortType 排序方式（1：正序；2：倒序）
    * @return Object
    */
    @GetMapping("/pageImportSuc")
    public Object pageImportSuc(@RequestParam(value = "page") int page, @RequestParam(value = "size") int size
            , @RequestParam(value = "sortType") int sortType, @CurrentUser String userId) {
        try {
            // 查询条件
            Map<String, Object> terms = Maps.newHashMap();
            // 转入时间区间
            String importStart = request.getParameter("importStart");
            String importEnd = request.getParameter("importEnd");
            if(StringUtils.isNotBlank(importStart) && StringUtils.isNotBlank(importEnd)) {
                terms.put("importStart", importStart);
                terms.put("importEnd", importEnd);
            }
            // 纠纷发生时间区间
            String occurStart = request.getParameter("occurStart");
            String occurEnd = request.getParameter("occurEnd");
            if(StringUtils.isNotBlank(occurStart) && StringUtils.isNotBlank(occurEnd)) {
                terms.put("occurStart", occurStart);
                terms.put("occurEnd", occurEnd);
            }
            // 申请方
            String plaintiffs = request.getParameter("plaintiffs");
            if (StringUtils.isNotBlank(plaintiffs)){
                terms.put("plaintiffs", plaintiffs);
            }
            // 被申请方
            String defendants = request.getParameter("defendants");
            if (StringUtils.isNotBlank(defendants)){
                terms.put("defendants", defendants);
            }
            // 调解员
            String mediator = request.getParameter("mediator");
            if (StringUtils.isNotBlank(mediator)){
                terms.put("mediator", mediator);
            }
            // 化解结果
            String mediResult = request.getParameter("mediResult");
            if (StringUtils.isNotBlank(mediResult)){
                terms.put("mediResult", mediResult);
            }
            // 纠纷类型
            String caseType = request.getParameter("caseType");
            if (StringUtils.isNotBlank(caseType)){
                terms.put("caseType", caseType);
            }
            // 协助调解员
            String assistMediator = request.getParameter("assistMediator");
            if (StringUtils.isNotBlank(assistMediator)){
                terms.put("assistMediator", assistMediator);
            }
            CtUserDTO loginUser = custClient.clientGetUserAll(userId);
            terms.put("inputUnitId", loginUser.getUnitId());
            // 排序
            Sort sort = null;
            if(sortType == 1) {
                sort = Sort.by(Sort.Direction.DESC, "t1.create_time");
            }
            if (sortType == 1){
                sort = Sort.by(Sort.Direction.ASC, "t1.create_time");
            }
            PageRequest pageRequest = PageRequest.of(page-1, size, sort);
            Page<CaseBookPageDTO> caseBookPageDTOPage = casebookInfoService.pageImportSuc(pageRequest, terms);
            return ReturnSucUtils.getRepInfo(caseBookPageDTOPage);
        } catch (Exception e) {
            log.error("[CaseBookWebController.pageImportSuc]请求失败，异常信息："+e, e);
            return ReturnFailUtils.getRepInfo();
        }
    }

    /**
    * 案件导入-导入操作
    * @url {ctx}/api/web/caseBook/inputCaseByExcel
    * @return Object
    */
    @GetMapping("/inputCaseByExcel")
    public Object inputCaseByExcel(@RequestParam(value = "fileId") String fileId, @CurrentUser String userId) {
        try {
            return casebookInfoService.inputCaseByExcel(fileId, userId, request);
        } catch (Exception e) {
            return ReturnFailUtils.getRepInfo();
        }
    }

    /**
    * 案件导入-删除草稿
    * @url {ctx}/api/web/caseBook/deleteDraft
    * @return Object
    */
    @PostMapping("/deleteDraft")
    public Object deleteDraft(@RequestBody List<String> idList, @CurrentUser String userId) {
        try {
            casebookInfoService.deleteDraft(idList);
            return ReturnSucUtils.getRepInfo();
        } catch (Exception e) {
            return ReturnFailUtils.getRepInfo();
        }
    }

    /**
    * 案件导入-草稿转入正式案件
    * @url {ctx}/api/web/caseBook/importToCase
    * @return Object
    */
    @PostMapping("/importToCase")
    public Object importToCase(@RequestBody List<String> idList, @CurrentUser String userId) {
        try {
            casebookInfoService.importToCase(idList, userId);
            return ReturnSucUtils.getRepInfo();
        } catch (Exception e) {
            return ReturnFailUtils.getRepInfo();
        }
    }

    /**
     * 案件导入-全部草稿转入正式案件
     * @url {ctx}/api/web/caseBook/importToCaseAll
     * @return Object
     */
    @GetMapping("/importToCaseAll")
    public Object importToCaseAll(@CurrentUser String userId) {
        try {
            // 查询条件
            Map<String, Object> terms = Maps.newHashMap();
            // 导入时间区间
            String importStart = request.getParameter("importStart");
            String importEnd = request.getParameter("importEnd");
            if(StringUtils.isNotBlank(importStart) && StringUtils.isNotBlank(importEnd)) {
                terms.put("importStart", importStart);
                terms.put("importEnd", importEnd);
            }
            // 纠纷发生时间区间
            String occurStart = request.getParameter("occurStart");
            String occurEnd = request.getParameter("occurEnd");
            if(StringUtils.isNotBlank(occurStart) && StringUtils.isNotBlank(occurEnd)) {
                terms.put("occurStart", occurStart);
                terms.put("occurEnd", occurEnd);
            }
            // 申请方
            String plaintiffs = request.getParameter("plaintiffs");
            if (StringUtils.isNotBlank(plaintiffs)){
                terms.put("plaintiffs", plaintiffs);
            }
            // 被申请方
            String defendants = request.getParameter("defendants");
            if (StringUtils.isNotBlank(defendants)){
                terms.put("defendants", defendants);
            }
            // 调解员
            String mediator = request.getParameter("mediator");
            if (StringUtils.isNotBlank(mediator)){
                terms.put("mediator", mediator);
            }
            // 化解结果
            String mediResult = request.getParameter("mediResult");
            if (StringUtils.isNotBlank(mediResult)){
                terms.put("mediResult", mediResult);
            }
            // 纠纷类型
            String caseType = request.getParameter("caseType");
            if (StringUtils.isNotBlank(caseType)){
                terms.put("caseType", caseType);
            }
            // 协助调解员
            String assistMediator = request.getParameter("assistMediator");
            if (StringUtils.isNotBlank(assistMediator)){
                terms.put("assistMediator", assistMediator);
            }
            CtUserDTO loginUser = custClient.clientGetUserAll(userId);
            terms.put("inputUnitId", loginUser.getUnitId());
            // 查询
            casebookInfoService.importToCaseAll(terms, userId);
            return ReturnSucUtils.getRepInfo();
        } catch (Exception e) {
            log.error("[CaseBookWebController.importToCaseAll]请求失败，异常信息："+e, e);
            return ReturnFailUtils.getRepInfo();
        }
    }

}