package com.chinagas.modules.schsf.controller;

import cn.hutool.core.bean.BeanUtil;
import com.alibaba.excel.EasyExcel;
import com.alibaba.excel.util.MapUtils;
import com.alibaba.excel.util.StringUtils;
import com.alibaba.fastjson2.JSON;
import com.chinagas.common.core.domain.AjaxResult;
import com.chinagas.common.core.web.controller.BaseController;
import com.chinagas.common.core.web.page.TableDataInfo;
import com.chinagas.common.log.annotation.Log;
import com.chinagas.common.log.enums.BusinessType;
import com.chinagas.common.security.annotation.RequirePermission;
import com.chinagas.common.security.enums.Logical;
import com.chinagas.modules.schsf.domain.McVisit;
import com.chinagas.modules.schsf.domain.McVisitAndIgnition;
import com.chinagas.modules.schsf.domain.dto.ChargedListDto;
import com.chinagas.modules.schsf.domain.dto.NodeUsersDto;
import com.chinagas.modules.schsf.domain.dto.VisitListDto;
import com.chinagas.modules.schsf.domain.vo.McVisitAuditVo;
import com.chinagas.modules.schsf.domain.vo.McVisitModificationVo;
import com.chinagas.modules.schsf.domain.vo.McVisitVo;
import com.chinagas.modules.schsf.enums.YesNoEnums;
import com.chinagas.modules.schsf.service.IMcVisitService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;


/**
 * 拜访工单Controller
 *
 * @author cw
 * @date 2024-05-30
 */
@Slf4j
@RestController
@RequestMapping("/mcVisit")
public class McVisitController extends BaseController {
    @Autowired
    private IMcVisitService mcVisitService;

    /**
     * 查询拜访工单列表
     */
    @RequirePermission("schsf:mcVisit:list")
    @GetMapping("/list")
    public TableDataInfo list(McVisitVo mcVisitVo) {
        startPage();
        List<McVisit> list = mcVisitService.selectMcVisitList(mcVisitVo);
        return getDataTable(list);
    }

    /**
     * 查看节点处理人
     *
     * @param id
     * @return
     */
    @RequirePermission(value = {"schsf:mcVisit:statusNodeUserList", "schsf:mcVisit:list"}, logical = Logical.OR)
    @GetMapping("/statusNodeUserList/{id}")
    public AjaxResult statusNodeUserList(@PathVariable("id") Long id) {
        startPage();
        List<NodeUsersDto> list = mcVisitService.selectStatusNodeUserList(id);
        return AjaxResult.success(list);
    }

    /**
     * 获取拜访工单详细信息
     */
    @Log(title = "拜访工单-获取拜访工单详细信息", businessType = BusinessType.OTHER)
    @RequirePermission(value = {"schsf:mcVisit:details", "schsf:mcVisit:list"}, logical = Logical.OR)
    @GetMapping(value = "details/{id}")
    public AjaxResult getInfo(@PathVariable("id") Long id) {
        return AjaxResult.success(mcVisitService.selectMcVisitById(id));
    }

    /**
     * 新增拜访工单
     */
    @RequirePermission("schsf:mcVisit:add")
    @Log(title = "拜访工单-新增拜访工单", businessType = BusinessType.INSERT)
    @PostMapping("/add")
    public AjaxResult add(@RequestBody McVisit mcVisit) {
        AjaxResult paramValidate = getMcVisitValidate(mcVisit);
        if (paramValidate != null) return paramValidate;
        mcVisit.setId(null);
        return toAjax(mcVisitService.insertMcVisit(mcVisit));
    }

    private AjaxResult getMcVisitValidate(McVisit mcVisit) {
        if (StringUtils.isEmpty(mcVisit.getHasDm()) || !mcVisit.getHasDm().equals(YesNoEnums.Y.getName())) {
            //非决策人信息
            mcVisit.setHasDm("N");
            mcVisit.setDmAge(null);
            mcVisit.setDmIncomeSrc(null);
            mcVisit.setDmPhone(null);
        }
        if (StringUtils.isEmpty(mcVisit.getIsCharged()) || !mcVisit.getIsCharged().equals(YesNoEnums.Y.getName())) {
            //不是收费
            mcVisit.setUserCode(null);
            mcVisit.setUserIdCard(null);
            mcVisit.setInvoiceNo(null);
            mcVisit.setChargeAmt(null);
            mcVisit.setPaymentMeth(null);
            mcVisit.setChargeType(null);
        }
        if (StringUtils.isEmpty(mcVisit.getIsVisited()) || !mcVisit.getIsVisited().equals(YesNoEnums.Y.getName())) {
            //不是拜访
            mcVisit.setIsIntent(null);
            mcVisit.setHouseCondition(null);
            mcVisit.setCurrentCookingEnergy(null);
            mcVisit.setCurrentHeatingEnergy(null);
            mcVisit.setFamilyMembers(null);
            mcVisit.setFridgeStatus(null);
            mcVisit.setAcStatus(null);
            mcVisit.setTvStatus(null);
            mcVisit.setWasherStatus(null);
            mcVisit.setWaterHeaterStatus(null);
            mcVisit.setPvSystemStatus(null);
        }
        if (StringUtils.isEmpty(mcVisit.getIsCharged()) && StringUtils.isEmpty(mcVisit.getIsVisited())) {
            return AjaxResult.error("是否拜访 与 是否收费 不可同时为空");
        }
        if (BeanUtil.isEmpty(mcVisit)) {
            return AjaxResult.error("参数不可为空");
        }
        if (mcVisit.getFiscalYear() == null) {
            return AjaxResult.error("财年不可为空");
        }
        if (StringUtils.isEmpty(mcVisit.getRegionName()) ||
                StringUtils.isEmpty(mcVisit.getGroupName()) ||
                StringUtils.isEmpty(mcVisit.getCompanyName()) ||
                StringUtils.isEmpty(mcVisit.getCompanyCode())) {
            return AjaxResult.error("请选择项目公司");
        }
        if (mcVisit.getEntryTime() == null) {
            return AjaxResult.error("请选择拜访时间");
        }
        if (StringUtils.isEmpty(mcVisit.getUserName())) {
            return AjaxResult.error("请选择拜访客户");
        }
        if (StringUtils.isEmpty(mcVisit.getUserPhone())) {
            return AjaxResult.error("请输入拜访客户手机号");
        }

        if (
                (StringUtils.isEmpty(mcVisit.getIsCharged()) && StringUtils.isEmpty(mcVisit.getIsVisited())) ||
                        (mcVisit.getIsCharged().equals(YesNoEnums.N) && mcVisit.getIsVisited().equals(YesNoEnums.N))
        ) {
            return AjaxResult.error("参数错误");
        }
        return null;
    }

    /**
     * 修改拜访工单
     */
    @RequirePermission("schsf:mcVisit:edit")
    @Log(title = "拜访工单-修改拜访工单", businessType = BusinessType.UPDATE)
    @PostMapping("/edit")
    public AjaxResult edit(@RequestBody McVisit mcVisit) throws CloneNotSupportedException {
        AjaxResult paramValidate = getMcVisitValidate(mcVisit);
        if (paramValidate != null) return paramValidate;
        return toAjax(mcVisitService.updateMcVisit(mcVisit));
    }


    /**
     * 发布-一级审核
     * status : Y :通过    N ：驳回
     */
    @RequirePermission("schsf:mcVisit:ticket_submitAuditOne")
    @Log(title = "拜访工单-发布-一级审核", businessType = BusinessType.UPDATE)
    @PostMapping("/ticket/submitAuditOne")
    public AjaxResult ticketSubmitAuditOne(@Validated @RequestBody McVisitAuditVo mcVisitAuditVo) throws CloneNotSupportedException {
        log.info("拜访工单-发布-一级审核，参数对象:{}", mcVisitAuditVo);
        mcVisitAuditVo.setType("1");
        mcVisitService.SubmitAudit(mcVisitAuditVo);
        return AjaxResult.success();
    }

    /**
     * 发布-二级审核
     * status : Y :通过    N ：驳回
     */
    @RequirePermission("schsf:mcVisit:ticket_submitAuditTwo")
    @Log(title = "拜访工单-发布-二级审核", businessType = BusinessType.UPDATE)
    @PostMapping("/ticket/submitAuditTwo")
    public AjaxResult ticketsubmitAuditTwo(@Validated @RequestBody McVisitAuditVo mcVisitAuditVo) throws CloneNotSupportedException {
        log.info("拜访工单-发布-二级审核，参数对象:{}", mcVisitAuditVo);
        mcVisitAuditVo.setType("2");
        mcVisitService.SubmitAudit(mcVisitAuditVo);
        return AjaxResult.success();
    }


    /**
     * 异动-一级审核
     * status : Y :通过    N ：驳回
     */
    @RequirePermission("schsf:mcVisit:modification_submitAuditOne")
    @Log(title = "拜访工单-异动-一级审核", businessType = BusinessType.UPDATE)
    @PostMapping("/modification/submitAuditOne")
    public AjaxResult modificationSubmitAuditOne(@Validated @RequestBody McVisitAuditVo mcVisitAuditVo) throws Exception {
        log.info("拜访工单-异动-一级审核，参数对象:{}", mcVisitAuditVo);
        mcVisitAuditVo.setType("3");
        mcVisitService.SubmitAudit(mcVisitAuditVo);
        return AjaxResult.success();
    }

    /**
     * 异动-二级审核
     * status : Y :通过    N ：驳回
     */
    @RequirePermission("schsf:mcVisit:modification_submitAuditTwo")
    @Log(title = "拜访工单-异动-二级审核", businessType = BusinessType.UPDATE)
    @PostMapping("/modification/submitAuditTwo")
    public AjaxResult modificationSubmitAuditTwo(@Validated @RequestBody McVisitAuditVo mcVisitAuditVo) throws CloneNotSupportedException {
        log.info("拜访工单-异动-二级审核，参数对象:{}", mcVisitAuditVo);
        mcVisitAuditVo.setType("4");
        mcVisitService.SubmitAudit(mcVisitAuditVo);
        return AjaxResult.success();
    }


    /**
     * 发起异动
     *
     * @param mcVisit
     * @return
     * @throws CloneNotSupportedException
     */
    @RequirePermission("schsf:mcVisit:modification")
    @Log(title = "拜访工单-发起异动", businessType = BusinessType.UPDATE)
    @PostMapping("/modification")
    public AjaxResult modification(@Validated @RequestBody McVisitModificationVo mcVisitModificationVo) throws CloneNotSupportedException {
        log.info("拜访工单-发起异动，参数对象:{}", mcVisitModificationVo);
        return toAjax(mcVisitService.updateMcVisitModification(mcVisitModificationVo));
    }

    /**
     * 作废工作单
     *
     * @param mcVisit
     * @return
     * @throws CloneNotSupportedException
     */
    @RequirePermission("schsf:mcVisit:cancel")
    @Log(title = "拜访工单-作废工作单", businessType = BusinessType.DELETE)
    @PostMapping("/cancel")
    public AjaxResult cancel(@RequestBody McVisit mcVisit) throws CloneNotSupportedException {
        return toAjax(mcVisitService.updateMcVisitCancel(mcVisit.getId(), mcVisit.getRemark()));
    }


    /**
     * 查询当前财年
     *
     * @return
     */
    @GetMapping(value = "getCurrentFiscalYear")
    public AjaxResult getCurrentFiscalYear() {
        return AjaxResult.success(mcVisitService.getCurrentFiscalYear());
    }


    /**
     * 拜访报表
     *
     * @param mcVisitVo
     * @return
     */
    @RequirePermission("schsf:mcVisit:visitList")
    @GetMapping("/visitList")
    public TableDataInfo visitList(McVisitVo mcVisitVo) {
        startPage();
        List<String> ticketTypeList = new ArrayList<String>();
        ticketTypeList.add("1");
        ticketTypeList.add("3");
        mcVisitVo.setTicketTypeList(ticketTypeList);
        mcVisitVo.setDefFlag("0");
//        mcVisitVo.setStatusCode("APPROVED");
        List<McVisitAndIgnition> list = mcVisitService.selectMcVisitAndIgnitionList(mcVisitVo);
        return getDataTable(list);
    }


    /**
     * 收费报表
     *
     * @param mcVisitVo
     * @return
     */
    @RequirePermission("schsf:mcVisit:chargedList")
    @GetMapping("/chargedList")
    public TableDataInfo chargedList(McVisitVo mcVisitVo) {
        startPage();
        List<String> ticketTypeList = new ArrayList<String>();
        ticketTypeList.add("2");
        ticketTypeList.add("3");
        mcVisitVo.setTicketTypeList(ticketTypeList);
        mcVisitVo.setDefFlag("0");
//        mcVisitVo.setStatusCode("APPROVED");
        List<McVisitAndIgnition> list = mcVisitService.selectMcVisitAndIgnitionList(mcVisitVo);
        return getDataTable(list);
    }

    /**
     * 拜访报表-导出
     *
     * @param mcVisitVo
     * @return
     */
    @RequirePermission("schsf:mcVisit:visitListExport")
    @PostMapping("/visitListExport")
    public void visitListExport(@RequestBody McVisitVo mcVisitVo, HttpServletResponse response) throws IOException {
        List<String> ticketTypeList = new ArrayList<String>();
        ticketTypeList.add("1");
        ticketTypeList.add("3");
        mcVisitVo.setTicketTypeList(ticketTypeList);
        mcVisitVo.setDefFlag("0");
//        mcVisitVo.setStatusCode("APPROVED");
        List<McVisitAndIgnition> data = mcVisitService.selectMcVisitAndIgnitionList(mcVisitVo);
        List<VisitListDto> list = new ArrayList<VisitListDto>();
        for (McVisitAndIgnition datum : data) {
            VisitListDto visitListDto = new VisitListDto(
                    datum.getEntryTime(),
                    datum.getBillingPersonName(),
                    datum.getJobNature(),
                    datum.getCompanyName(),
                    datum.getUserProvince(),
                    datum.getUserCity(),
                    datum.getUserDistrict(),
                    datum.getUserStreet(),
                    datum.getVlgOrCmty(),
                    datum.getUserDetailedAddress(),
                    datum.getUserName(),
                    datum.getUserPhone(),
                    datum.getIsIntent(),
                    datum.getHouseCondition(),
                    datum.getCurrentCookingEnergy(),
                    datum.getCurrentHeatingEnergy(),
                    datum.getFamilyMembers(),
                    datum.getFridgeStatus(),
                    datum.getAcStatus(),
                    datum.getTvStatus(),
                    datum.getWasherStatus(),
                    datum.getWaterHeaterStatus(),
                    datum.getPvSystemStatus(),
                    StringUtils.isNotBlank(datum.getHasDm()) && datum.getHasDm().equals("Y") ? "是" : "否",
                    datum.getDmAge(),
                    datum.getDmIncomeSrc(),
                    datum.getDmPhone(),
                    datum.getRemark(),
                    datum.getUpdateTime()
            );
            list.add(visitListDto);
        }
        try {
            response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
            response.setCharacterEncoding("utf-8");
            // 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系
            String fileName = URLEncoder.encode("拜访报表", "UTF-8").replaceAll("\\+", "%20");
            response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + fileName + ".xlsx");
            // 这里需要设置不关闭流
            EasyExcel.write(response.getOutputStream(), VisitListDto.class).autoCloseStream(Boolean.FALSE).sheet("客户信息列表").doWrite(list);
        } catch (Exception e) {
            // 重置response
            e.printStackTrace();
            response.reset();
            response.setContentType("application/json");
            response.setCharacterEncoding("utf-8");
            Map<String, String> map = MapUtils.newHashMap();
            map.put("status", "failure");
            map.put("message", "下载文件失败" + e.getMessage());
            response.getWriter().println(JSON.toJSONString(map));
        }
    }


    /**
     * 收费报表-导出
     *
     * @param mcVisitVo
     * @return
     */
    @RequirePermission("schsf:mcVisit:chargedListExport")
    @PostMapping("/chargedListExport")
    public void chargedListExport(@RequestBody McVisitVo mcVisitVo, HttpServletResponse response) throws IOException {
        List<String> ticketTypeList = new ArrayList<String>();
        ticketTypeList.add("2");
        ticketTypeList.add("3");
        mcVisitVo.setTicketTypeList(ticketTypeList);
        mcVisitVo.setDefFlag("0");
//        mcVisitVo.setStatusCode("APPROVED");
        List<McVisitAndIgnition> data = mcVisitService.selectMcVisitAndIgnitionList(mcVisitVo);
        List<ChargedListDto> list = new ArrayList<ChargedListDto>();
        for (McVisitAndIgnition datum : data) {
            String chargeType="其他";
            if (StringUtils.isEmpty(datum.getChargeType())){
                chargeType="其他";
            }else  if (datum.getChargeType().equals("1")){
                chargeType="定金";
            }else  if (datum.getChargeType().equals("2")){
                chargeType="全款";
            }else  if (datum.getChargeType().equals("4")){
                chargeType="分期";
            }




            ChargedListDto chargedListDto = new ChargedListDto(
                    datum.getEntryTime(),
                    datum.getBillingPersonName(),
                    datum.getJobNature(),
                    datum.getCompanyName(),
                    datum.getUserProvince(),
                    datum.getUserCity(),
                    datum.getUserDistrict(),
                    datum.getUserStreet(),
                    datum.getVlgOrCmty(),
                    datum.getUserDetailedAddress(),
                    datum.getUserName(),
                    datum.getUserPhone(),
                    datum.getUserIdCard(),
                    datum.getInvoiceNo(),
                    datum.getChargeAmt(),
                    datum.getPaymentMeth(),
                    chargeType,
                    StringUtils.isEmpty(datum.getIgnCnfStatusCode())?"-":datum.getIgnCnfStatusCode().equals("Y")?"是":"否",
                    datum.getIgnTime(),
                    datum.getnIgnRsn(),
                    datum.getUpdateTime()
            );
            list.add(chargedListDto);
        }
        try {
            response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
            response.setCharacterEncoding("utf-8");
            // 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系
            String fileName = URLEncoder.encode("拜访报表", "UTF-8").replaceAll("\\+", "%20");
            response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + fileName + ".xlsx");
            // 这里需要设置不关闭流
            EasyExcel.write(response.getOutputStream(), ChargedListDto.class).autoCloseStream(Boolean.FALSE).sheet("客户信息列表").doWrite(list);
        } catch (Exception e) {
            // 重置response
            e.printStackTrace();
            response.reset();
            response.setContentType("application/json");
            response.setCharacterEncoding("utf-8");
            Map<String, String> map = MapUtils.newHashMap();
            map.put("status", "failure");
            map.put("message", "下载文件失败" + e.getMessage());
            response.getWriter().println(JSON.toJSONString(map));
        }
    }

}