PAS/src/main/java/cn/cslg/pas/service/business/ReportProjectService.java

package cn.cslg.pas.service.business;

import cn.cslg.pas.common.dto.business.PatentProjectDTO;
import cn.cslg.pas.common.model.cronModel.*;
import cn.cslg.pas.common.model.request.GroupRequest;
import cn.cslg.pas.common.model.request.QueryRequest;
import cn.cslg.pas.common.model.request.StringRequest;
import cn.cslg.pas.common.utils.CacheUtils;
import cn.cslg.pas.common.utils.LoginUtils;
import cn.cslg.pas.common.vo.business.EventCountVO;
import cn.cslg.pas.common.vo.business.EventVO;
import cn.cslg.pas.domain.business.AssoEventFile;
import cn.cslg.pas.domain.business.PatentProject;
import cn.cslg.pas.domain.business.ReportProject;
import cn.cslg.pas.domain.business.SystemDict;
import cn.cslg.pas.exception.XiaoShiException;
import cn.cslg.pas.factorys.businessFactory.Business;
import cn.cslg.pas.factorys.reGroupFactory.QueryGroupFactory;
import cn.cslg.pas.factorys.reGroupFactory.QueryGroupImp;
import cn.cslg.pas.mapper.AssoProjectEventMapper;
import cn.cslg.pas.mapper.EventMapper;
import cn.cslg.pas.mapper.PatentProjectMapper;
import cn.cslg.pas.mapper.ReportProjectMapper;
import cn.cslg.pas.service.common.FileManagerService;
import cn.cslg.pas.service.permissions.PermissionService;
import cn.cslg.pas.service.query.FormatQueryService;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
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.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

@Service
@Slf4j
public class ReportProjectService extends ServiceImpl<ReportProjectMapper,ReportProject> implements Business {
    @Autowired
    private EventMapper eventMapper;

    @Autowired
    private FormatQueryService formatQueryService;

    @Autowired
    private FileManagerService fileManagerService;

    @Autowired
    private AssoEventFileService assoEventFileService;

    @Autowired
    private QueryGroupFactory queryGroupFactory;

    @Autowired
    private PermissionService permissionService;

    @Autowired
    private SystemDictService systemDictService;

    @Autowired
    private AssoProjectEventMapper assoProjectEventMapper;

    @Autowired
    private CacheUtils cacheUtils;
    @Autowired
    private LoginUtils loginUtils;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Object queryMessage(QueryRequest queryRequest) throws Exception {

       List<String> sqls = formatQueryService.reSqls(queryRequest,"event");
        //根据sql查询事件信息
        List<EventVO> eventVOS = eventMapper.getEvent(sqls.get(0),sqls.get(1),sqls.get(2));

        //查询总数
        Long total = eventMapper.getEventCount(sqls.get(0));

        //装载事件信息
        this.loadEvent(eventVOS);
        Records records = new Records();
        records.setCurrent(queryRequest.getCurrent());
        records.setSize(queryRequest.getSize());
        records.setData(eventVOS);
        records.setTotal(total);
        return records;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Integer addMessage(Object object, List<MultipartFile> files) {

        return null;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Object deleteMessage(List<Integer> ids) throws IOException {
        //根据事件id删除事件和文件关联
        LambdaQueryWrapper<AssoEventFile> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.in(AssoEventFile::getEventId, ids);
        List<AssoEventFile> assoEventFiles = assoEventFileService.list(queryWrapper);
        List<String> guids = assoEventFiles.stream().map(AssoEventFile::getFileGuid).collect(Collectors.toList());
        // 根据guid删除文件
        if (guids.size() != 0) {
            fileManagerService.deleteFileFromFMS(guids);
        }
        //删除事件和文件关联表
        assoEventFiles.remove(queryWrapper);
        //根据事件id删除事件
        this.removeBatchByIds(ids);
        return ids;
    }

    /**
     * 更新事件接口
     *
     * @param object
     * @param files
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public Object updateMessage(Object object, List<MultipartFile> files) {

       return null;
        }
    /**
     * 查询事件分组信息
     *
     * @param groupRequest
     * @return
     * @throws Exception
     */
    @Transactional(rollbackFor = Exception.class)
    public Object getGroup(GroupRequest groupRequest,String tableName) throws Exception {
        StringRequest stringRequest =new StringRequest();
        BeanUtils.copyProperties(groupRequest,stringRequest);
        List<String> sqls = formatQueryService.reSqls(stringRequest,tableName);
        //格式化 分组
        GroupConfig groupConfig=null;
        if (groupRequest.getGroupBy() != null) {
            String json = CommonService.readJsonFile(tableName+".json");
            List<GroupConfig> groupConfigs = JSON.parseArray(json, GroupConfig.class);
            groupConfig = groupConfigs.stream().filter(item -> groupRequest.getGroupBy().equals(item.getField())).findFirst().orElse(null);
            if (groupConfig == null) {
                throw new XiaoShiException("未找到配置");
            }
        }

        //返回分组数据
        QueryGroupImp queryGroupImp = queryGroupFactory.getClass(groupConfig.getGroupClass());
        ReGroupDataVO  reGroupDataVO = queryGroupImp.getGroup(sqls, tableName, groupConfig.getSqlField());

        //装载数据
        GroupVO groupVO = new GroupVO();
        groupVO.setField(groupRequest.getGroupBy());
        groupVO.setValues(reGroupDataVO.getValues());
        Records records = new Records();
        records.setCurrent(groupRequest.getCurrent());
        records.setSize(groupRequest.getSize());
        records.setData(groupVO);
        records.setTotal(reGroupDataVO.getTotal());
        return records;
    }

    @Override
    public Object addMessage(Object object) {
        PatentProjectDTO patentProjectDTO =(PatentProjectDTO)object;

        return null;
    }

    @Override
    public Object updateMessage(Object object) {
        return null;
    }

    /**
     * 装载事件返回类
     *
     * @param eventVOs
     */
    private void loadEvent(List<EventVO> eventVOs) throws IOException {
        List<String> createIds = new ArrayList<>();
        List<Integer> clientIds = new ArrayList<>();
        List<Integer> ids = new ArrayList<>();
        List<EventCountVO> eventCountVOS = new ArrayList<>();
        //获得所有文件的guid
        eventVOs.forEach(
                item -> {
                    if (item.getClientId() != null) {
                        clientIds.add(item.getClientId());
                    }

                    if (item.getCreateId() != null) {
                        createIds.add(item.getCreateId());
                    }
                    if (item.getId() != null) {
                        ids.add(item.getId());
                    }
                }
        );

        List<Personnel> personnels = new ArrayList<>();
        List<Client> clients = new ArrayList<>();
        List<String> guids = new ArrayList<>();
        List<SystemFile> systemFiles = new ArrayList<>();
        List<AssoEventFile> assoEventFiles = new ArrayList<>();

        if (ids.size() != 0) {
            //根据事件id获得事件文件关联表
            LambdaQueryWrapper<AssoEventFile> queryWrapper = new LambdaQueryWrapper<>();
            queryWrapper.in(AssoEventFile::getEventId, ids);
            assoEventFiles = assoEventFileService.list(queryWrapper);
            guids = assoEventFiles.stream().map(AssoEventFile::getFileGuid).collect(Collectors.toList());


            //根据事件id分组查询事件关联专题库或报告数量
            eventCountVOS = assoProjectEventMapper.getEventProjectCount(ids);
        }

        //查询创建人名称
        if (createIds.size() != 0) {
            String res = permissionService.getPersonnelByIdsFromPCS(createIds);
            JSONObject jsonObject = JSONObject.parseObject(res);
            personnels = JSONObject.parseArray(jsonObject.getString("data"), Personnel.class);
        }

        //查询客户名称
        if (clientIds.size() != 0) {
            String res = permissionService.getClientByIdsFromPCS(clientIds);
            JSONObject jsonObject = JSONObject.parseObject(res);
            clients = JSONObject.parseArray(jsonObject.getString("data"), Client.class);
        }

        //查询文件
        if (guids.size() != 0) {
            String res = fileManagerService.getSystemFileFromFMS(guids);
            JSONObject jsonObject = JSONObject.parseObject(res);
            systemFiles = JSONObject.parseArray(jsonObject.getString("data"), SystemFile.class);
        }

        //查询关联报告或专题库

        //查询应用场景
        List<SystemDict> systemDictList = systemDictService.getSystemDictListByType(Arrays.asList("ENTERPRISE_APPLICATION_SCENARIO"));

        //查询专题库数量

        //装载信息
        for (EventVO eventVO : eventVOs) {
            //装载人员信息
            Personnel personnel = personnels.stream().filter(item -> item.getId().equals(eventVO.getCreateId())).findFirst().orElse(null);
            if (personnel != null) {
                eventVO.setCreateName(personnel.getPersonnelName());
            }

            //装载客户信息
            Client client = clients.stream().filter(item -> item.getId().equals(eventVO.getClientId())).findFirst().orElse(null);
            if (client != null) {
                eventVO.setClientName(client.getName());
            }

            //装载场景
            SystemDict systemDict = systemDictList.stream().filter(item -> item.getValue().equals(eventVO.getScenarioId().toString())).findFirst().orElse(null);
            if (systemDict != null) {
                eventVO.setScenarioName(systemDict.getLabel());
            }

            //装载文件信息
            List<AssoEventFile> assoEventFileTemp = assoEventFiles.stream().filter(item -> item.getEventId().equals(eventVO.getId())).collect(Collectors.toList());
            if (assoEventFileTemp.size() != 0) {
                List<String> guidTemp = assoEventFileTemp.stream().map(AssoEventFile::getFileGuid).collect(Collectors.toList());
                if (guidTemp.size() != 0) {
                    List<SystemFile> systemFileTemp = systemFiles.stream().filter(item -> guidTemp.contains(item.getGuid())).collect(Collectors.toList());
                    if (systemFileTemp.size() != 0) {
                        eventVO.setSystemFileList(systemFileTemp);
                    }
                }
            }


            //装载专题库或报告数量
            if (eventCountVOS.size() != 0) {
                //专题库数量
                EventCountVO eventCountVO1 = eventCountVOS.stream().filter(item ->
                        item.getEventId().equals(eventVO.getId()) && item.getProjectType().equals(1)).findFirst().orElse(null);

                //报告数量
                EventCountVO eventCountVO2 = eventCountVOS.stream().filter(item ->
                        item.getEventId().equals(eventVO.getId()) && item.getProjectType().equals(2)).findFirst().orElse(null);

                //设置专题库数量
                if (eventCountVO1 != null) {
                    eventVO.setPatentProjectNum(eventCountVO1.getProjectCount());
                } else {
                    eventVO.setPatentProjectNum(0);
                }

                //设置报告数量
                if (eventCountVO2 != null) {
                    eventVO.setReportProjectNum(eventCountVO2.getProjectCount());
                } else {
                    eventVO.setReportProjectNum(0);
                }

            } else {
                eventVO.setReportProjectNum(0);
                eventVO.setPatentProjectNum(0);
            }
        }


    }


}