package com.gk.firework.Service.ServiceImpl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gk.firework.Domain.EnterpriseFeed;
import com.gk.firework.Domain.EnterpriseResource;
import com.gk.firework.Domain.Exception.BusinessException;
import com.gk.firework.Domain.UserInfo;
import com.gk.firework.Domain.Utils.*;
import com.gk.firework.Domain.Utils.Properties;
import com.gk.firework.Domain.Vo.EnterpriseFeedVo;
import com.gk.firework.Mapper.EnterpriseFeedMapper;
import com.gk.firework.Service.EnterpriseFeedService;
import com.gk.firework.Service.EnterpriseResourceService;
import com.gk.firework.Service.ExcelExportService;
import com.gk.firework.Service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import java.io.*;
import java.text.SimpleDateFormat;
import java.util.*;

@Service("enterpriseFeedService")
public class EnterpriseFeedServiceImpl extends ServiceImpl<EnterpriseFeedMapper, EnterpriseFeed> implements EnterpriseFeedService {

    @Autowired
    private EnterpriseFeedMapper enterpriseFeedMapper;
    @Autowired
    private ExcelExportService excelExportService;
    @Autowired
    private EnterpriseResourceService enterpriseResourceService;
    @Autowired
    private UserService userService;


    /**
    * @Description: 查询自检
    * @date 2021/5/13 18:44
    */
    @Override
    public IPage selectPages(Page<EnterpriseFeed> page, Long id, UserInfo user) {
        Map<String, Object> params = new HashMap<>();
        params.put("tabletype", Constants.FEED);
        params.put("id", id);
        List<EnterpriseFeed> list = enterpriseFeedMapper.selectPages(page, params);
        return page.setRecords(list);
    }

    /**
    * @Description: 新增自检
    * @date 2021/5/13 18:44
    */
    @Override
    @Transactional
    public void addFeed(EnterpriseFeedVo enterpriseFeedVo, UserInfo user) {

        if (enterpriseFeedVo.getEnterpriseid() == null) {
            throw new BusinessException("缺少企业关键数据");
        }

        enterpriseFeedVo.setValidflag(true);
        enterpriseFeedVo.setCreatetime(new Date());
        enterpriseFeedVo.setCreateby(user.getId());
        enterpriseFeedVo.setCreatebyname(user.getUsername());
        this.save(enterpriseFeedVo);

        List<EnterpriseResource> adds = null;
        MultipartFile[] files = enterpriseFeedVo.getFile();
        try {
            if (files != null && files.length > 0) {
                adds = new ArrayList<>();
                Date now = new Date();
                for (MultipartFile file : files) {
                    String name = UploadUtil.uploadFile(file, Properties.enterprisePath);
                    EnterpriseResource er = new EnterpriseResource();
                    er.setTabletype(Constants.FEED);
                    er.setFilename(file.getOriginalFilename());
                    er.setUrl(Properties.enterprise + name);
                    er.setCreatetime(now);
                    er.setCreateby(user.getId());
                    er.setCreatebyname(user.getUsername());
                    er.setBelongid(enterpriseFeedVo.getId());
                    er.setValidflag(true);
                    adds.add(er);
                }
                //执行
                enterpriseResourceService.saveBatch(adds);
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new BusinessException("上传失败，请联系管理员");
        }

    }

    /**
    * @Description: 导入反馈
    * @date 2021/5/13 18:52
    */
    @Override
    public void importFeed(MultipartFile file, UserInfo user,Long enterpriseId) {
        if (file == null || file.getSize() == 0) {
            throw new BusinessException("上传文件或者请求出现问题");
        }

        if(!FileOptUtils.isDirExists(Properties.filePath)){
            throw new BusinessException("发生错误或不为目录");
        }
        if (enterpriseId == null) {
            throw new BusinessException("缺少企业关键数据");
        }

        SimpleDateFormat sdf = new SimpleDateFormat( "yyyyMMddHHmmssSSS" );
        String fileSave = Properties.enterprisePath + user.getUsername() +"_feed_" + sdf.format(new Date()) +".xlsx";

        try {
            file.transferTo(new File(fileSave));
            InputStream in = new FileInputStream(fileSave);
            String name = file.getOriginalFilename();
            assert name != null;
            Boolean isExcel2007 = name.substring(name.lastIndexOf(".") + 1).endsWith("xlsx");
            excelExportService.importFeedExcel(in, user, isExcel2007,enterpriseId);
        } catch (FileNotFoundException e) {
            e.printStackTrace();
            throw new BusinessException("找不到文件");
        } catch (IOException e) {
            e.printStackTrace();
            throw new BusinessException("发生错误,请联系管理员");
        }
    }


    /**
    * @Description: 导出反馈
    * @date 2021/5/14 11:11
    */
    @Override
    public List<Map> exportFeed(Map filter, UserInfo user) {
        UserInfo userInfo = userService.getById(user.getId());
        Map<String, Object> params = new HashMap<>();
        //监管部门 根据 地区看所有
        params.put("province", userInfo.getProvince());
        params.put("city", userInfo.getCity());
        params.put("district", userInfo.getArea());
        params.put("street", userInfo.getTown());
        params.put("committee", userInfo.getCommunity());
        //企业用户
        params.put("enterprisenumber", userInfo.getCompanynumber());

        //过滤条件
        { //企业类型
            params.put("safetySupervision", filter.get("safetysupervision"));
            //经济类型
            params.put("economicIndustry", filter.get("economicindustry"));
            //许可证有效|过期
            params.put("valid", filter.get("valid"));
            //地区
            params.put("filterProvince", filter.get("province"));
            params.put("filterCity", filter.get("city"));
            params.put("filterDistrict", filter.get("district"));
            params.put("filterStreet", filter.get("street"));
            params.put("filterCommittee", filter.get("committee"));
            //企业名称
            params.put("enterprisename", filter.get("enterprisename"));

        }
        return enterpriseFeedMapper.selectExportFeed(params);
    }

    @Override
    public List<Map> exportFeedById(Long id) {
        if (id == null) {
            throw new BusinessException("参数传递为空");
        }
        return enterpriseFeedMapper.selectExportFeedById(id);
    }

}