| | |
|---|
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
|---|
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|---|
| | | import com.ruoyi.common.core.domain.AjaxResult; |
|---|
| | | import com.ruoyi.common.core.domain.entity.EsModel; |
|---|
| | | import com.ruoyi.common.core.domain.entity.SysUser; |
|---|
| | | import com.ruoyi.common.utils.MapUtils; |
|---|
| | | import com.ruoyi.common.utils.SecurityUtils; |
|---|
| | |
|---|
| | | import com.ruoyi.mapper.ZfShareMapper; |
|---|
| | | import com.ruoyi.service.*; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.elasticsearch.action.delete.DeleteRequest; |
|---|
| | | import org.elasticsearch.client.RequestOptions; |
|---|
| | | import org.elasticsearch.client.RestHighLevelClient; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.io.IOException; |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | TravelDetailService travelDetailService; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private RestHighLevelClient restHighLevelClient; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | EsService esService; |
|---|
| | | |
|---|
| | | private LambdaQueryWrapper<ZfShare> uniqueCondition(ZfShare zfShare) { |
|---|
| | | LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); |
|---|
| | |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Boolean deleteByContentId(Long[] ids) { |
|---|
| | | List<Long> id = new ArrayList<>(); |
|---|
| | | |
|---|
| | | LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); |
|---|
| | | lqw.in(ids != null, ZfShare::getShareContent, ids) |
|---|
| | | .eq(ZfShare::getSysMenuId, 2056L); |
|---|
| | | |
|---|
| | | List<ZfShare> zfShares = list(lqw); |
|---|
| | | if (zfShares.size() == 0) { |
|---|
| | | return true; |
|---|
| | | } |
|---|
| | | for (ZfShare zfShare : zfShares) { |
|---|
| | | id.add(zfShare.getId()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | System.out.println(id); |
|---|
| | | if (removeByIds(id)) { |
|---|
| | | //删除es中的数据 |
|---|
| | | zfShares.forEach(zfDoctorDownload -> { |
|---|
| | | EsModel esModel = esService.findByCtId(zfDoctorDownload.getId().intValue(), "旅游统计表分享删除"); |
|---|
| | | if (esModel != null) { |
|---|
| | | DeleteRequest deleteRequest = new DeleteRequest("allsearchdata", esModel.getId()); |
|---|
| | | System.out.println(deleteRequest); |
|---|
| | | try { |
|---|
| | | restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT); |
|---|
| | | } catch (IOException e) { |
|---|
| | | throw new RuntimeException(e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | return true; |
|---|
| | | } else { |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
