package com.yuanchu.mom.service.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.deepoove.poi.XWPFTemplate;
import com.deepoove.poi.config.Configure;
import com.deepoove.poi.data.Pictures;
import com.yuanchu.mom.common.GetLook;
import com.yuanchu.mom.dto.InternalImplementDto;
import com.yuanchu.mom.exception.ErrorException;
import com.yuanchu.mom.mapper.InternalImplementMapper;
import com.yuanchu.mom.mapper.UserMapper;
import com.yuanchu.mom.pojo.InternalImplement;
import com.yuanchu.mom.pojo.InternalImplementDetail;
import com.yuanchu.mom.pojo.User;
import com.yuanchu.mom.service.InternalImplementDetailService;
import com.yuanchu.mom.service.InternalImplementService;
import com.yuanchu.mom.util.HackLoopTableRenderPolicy;
import com.yuanchu.mom.util.XWPFDocumentUtils;
import com.yuanchu.mom.utils.DateImageUtil;
import com.yuanchu.mom.utils.QueryWrappers;
import lombok.AllArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URLEncoder;
import java.time.LocalDateTime;
import java.util.HashMap;
import java.util.List;

/**
 * 内审实施计划
 *
 * @author zhuo
 * @since 2024-11-11
 */
@Service
@Transactional(rollbackFor = Exception.class)
public class InternalImplementServiceImpl extends ServiceImpl<InternalImplementMapper, InternalImplement> implements InternalImplementService {

    @Resource
    private InternalImplementDetailService internalImplementDetailService;
    @Resource
    private GetLook getLook;
    @Resource
    private UserMapper userMapper;
    @Value("${file.path}")
    private String imgUrl;

    /**
     * 内审实施计划分页查询
     * @param page
     * @param internalImplement
     * @return
     */
    @Override
    public IPage<InternalImplementDto> pageInternalImplement(Page page, InternalImplement internalImplement) {
        return baseMapper.pageInternalImplement(page, QueryWrappers.queryWrappers(internalImplement));
    }

    /**
     * 内审实施计划新增
     * @param internalImplement
     * @return
     */
    @Override
    public boolean addInternalImplement(InternalImplementDto internalImplement) {
        Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId");
        // 添加编制人
        User user = userMapper.selectById(userId);
        internalImplement.setWriteTime(LocalDateTime.now());
        internalImplement.setWriteUserId(user.getId());
        internalImplement.setWriteUserName(user.getName());

        baseMapper.insert(internalImplement);
        // 新增详情
        for (InternalImplementDetail internalImplementDetail : internalImplement.getImplementDetailList()) {
            internalImplementDetail.setImplementId(internalImplement.getImplementId());
        }
        internalImplementDetailService.saveBatch(internalImplement.getImplementDetailList());
        return true;
    }

    /**
     * 内审实施计划修改
     * @param internalImplement
     * @return
     */
    @Override
    public boolean updateInternalImplement(InternalImplementDto internalImplement) {
        baseMapper.updateById(internalImplement);

        // 删除之前的详情
        internalImplementDetailService.remove(Wrappers.<InternalImplementDetail>lambdaQuery()
                .eq(InternalImplementDetail::getImplementId, internalImplement.getImplementId()));

        // 新增详情
        for (InternalImplementDetail internalImplementDetail : internalImplement.getImplementDetailList()) {
            internalImplementDetail.setImplementId(internalImplement.getImplementId());
        }
        internalImplementDetailService.saveBatch(internalImplement.getImplementDetailList());

        return true;
    }

    /**
     * 内审实施计划删除
     * @param implementId
     * @return
     */
    @Override
    public boolean delInternalImplement(Integer implementId) {
        internalImplementDetailService.remove(Wrappers.<InternalImplementDetail>lambdaQuery()
                .eq(InternalImplementDetail::getImplementId, implementId));
        baseMapper.deleteById(implementId);
        return true;
    }

    /**
     * 内审实施计划查看详情
     * @param implementId
     * @return
     */
    @Override
    public InternalImplementDto getInternalImplementOne(Integer implementId) {
        InternalImplement internalImplement = baseMapper.selectById(implementId);
        InternalImplementDto internalImplementDto = new InternalImplementDto();
        BeanUtils.copyProperties(internalImplement, internalImplementDto);

        // 查询详细信息
        internalImplementDto.setImplementDetailList(internalImplementDetailService.list(Wrappers.<InternalImplementDetail>lambdaQuery()
                .eq(InternalImplementDetail::getImplementId, implementId)));
        return internalImplementDto;
    }

    /**
     * 内审实施计划批准
     * @param internalImplement
     * @return
     */
    @Override
    public boolean ratifyInternalImplement(InternalImplementDto internalImplement) {
        Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId");
        User user = userMapper.selectById(userId);
        baseMapper.update(null, Wrappers.<InternalImplement>lambdaUpdate()
                .eq(InternalImplement::getImplementId, internalImplement.getImplementId())
                .set(InternalImplement::getRatifyUserId, userId)
                .set(InternalImplement::getRatifyUserName, user.getName())
                .set(InternalImplement::getRatifyRemark, internalImplement.getRatifyRemark())
                .set(InternalImplement::getRatifyStatus, internalImplement.getRatifyStatus())
                .set(InternalImplement::getRatifyTime, LocalDateTime.now())
        );
        return true;
    }

    /**
     * 导出内审实施计划
     * @param implementId
     * @param response
     */
    @Override
    public void exportInternalImplement(Integer implementId, HttpServletResponse response) {
        InternalImplement internalImplement = baseMapper.selectById(implementId);

        //获取提交人的签名地址
        String writeUrl = userMapper.selectById(internalImplement.getWriteUserId()).getSignatureUrl();
        if (StringUtils.isBlank(writeUrl)) {
            throw new ErrorException("找不到检验人的签名");
        }

        //获取批准人的签名地址
        String ratifyUrl = null;
        if (internalImplement.getRatifyUserId() != null) {
            ratifyUrl = userMapper.selectById(internalImplement.getRatifyUserId()).getSignatureUrl();
            if (StringUtils.isBlank(ratifyUrl)) {
                throw new ErrorException("找不到批准人的签名");
            }
        }

        // 查询详情
        List<InternalImplementDetail> detailList = internalImplementDetailService.list(Wrappers.<InternalImplementDetail>lambdaQuery()
                .eq(InternalImplementDetail::getImplementId, implementId));

        int index = 1;
        for (InternalImplementDetail detail : detailList) {
            detail.setIndex(index);
            index++;
        }

        // 获取路径
        InputStream inputStream = this.getClass().getResourceAsStream("/static/internal-implement.docx");
        String finalRatifyUrl = ratifyUrl;
        Configure configure = Configure.builder()
                .bind("implementDetailList", new HackLoopTableRenderPolicy())
                .build();
        XWPFTemplate template = XWPFTemplate.compile(inputStream, configure).render(
                new HashMap<String, Object>() {{
                    put("implement", internalImplement);
                    put("implementDetailList", detailList);
                    put("writeUrl", StringUtils.isNotBlank(writeUrl) ? Pictures.ofLocal(imgUrl + "/" + writeUrl).create() : null);
                    put("ratifyUrl", StringUtils.isNotBlank(finalRatifyUrl) ? Pictures.ofLocal(imgUrl + "/" + finalRatifyUrl).create() : null);
                    put("writeDateUrl", internalImplement.getWriteTime() != null ?
                            Pictures.ofStream(DateImageUtil.createDateImage(internalImplement.getWriteTime())).create() : null);
                    put("ratifyDateUrl", internalImplement.getRatifyTime() != null ?
                            Pictures.ofStream(DateImageUtil.createDateImage(internalImplement.getRatifyTime())).create() : null);
                }});

        try {
            response.setContentType("application/msword");
            String fileName = URLEncoder.encode(
                    internalImplement.getPurposes(), "UTF-8");
            response.setHeader("Content-disposition",
                    "attachment;filename=" + fileName + ".docx");
            OutputStream os = response.getOutputStream();
            template.write(os);
            os.flush();
            os.close();
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException("导出失败");
        }

    }
}