package cn.cslg.pas.service.business; import cn.cslg.pas.common.dto.PatentDTO; import cn.cslg.pas.common.dto.business.EventDTO; import cn.cslg.pas.common.dto.business.UpdateEventDTO; 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.Event; import cn.cslg.pas.domain.business.SystemDict; import cn.cslg.pas.domain.es.Patent; import cn.cslg.pas.exception.UnLoginException; 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.PatentMapper; import cn.cslg.pas.service.business.es.EsService; 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 PatentService extends ServiceImpl implements Business { @Autowired private EsService esService; @Override @Transactional(rollbackFor = Exception.class) public Object queryMessage(QueryRequest queryRequest) throws Exception { List patents = esService.esSearch(queryRequest.getGroupField(), queryRequest.getCurrent().intValue(), queryRequest.getSize().intValue(), null); Records records = new Records(); records.setCurrent(queryRequest.getCurrent()); records.setSize(queryRequest.getSize()); records.setData(patents); records.setTotal(patents.get(0).getTotal()); return records; } @Override @Transactional(rollbackFor = Exception.class) public Integer addMessage(Object object, List files) { return null; } @Override @Transactional(rollbackFor = Exception.class) public Object deleteMessage(List ids) throws IOException { return null; } /** * 更新事件接口 * * @param object * @param files * @return */ @Override @Transactional(rollbackFor = Exception.class) public Object updateMessage(Object object, List files) { return null; } /** * 查询事件分组信息 * * @param groupRequest * @return * @throws Exception */ @Transactional(rollbackFor = Exception.class) public Object getGroup(GroupRequest groupRequest,String tableName) throws Exception { Records records = new Records(); records.setCurrent(groupRequest.getCurrent()); return records; } @Override public Object addMessage(Object object) { return null; } @Override public Object updateMessage(Object object) { return null; } }