| | |
| | | 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<>(); |
| | |
| | | za.setShareId(shareId); |
| | | za.setSysMenuId(2056L); |
| | | addData(za); |
| | | |
| | | TravelDetail travelDetail = new TravelDetail(); |
| | | travelDetail.setCid(za.getShareContent()); |
| | | |
| | | List<TravelDetail> travelDetails = travelDetailService.getDataByCid(za.getShareContent(),travelDetail); |
| | | if (travelDetails.size() != 0) { |
| | | for (TravelDetail travelDetail1 : travelDetails) { |
| | | za.setId(za.getId() + 1); |
| | | za.setSysMenuId(2055L); |
| | | za.setShareContent(travelDetail1.getId()); |
| | | System.out.println(za); |
| | | save(za); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | // Long [] |
| | |
| | | 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; |
| | | } |
| | | } |
| | | } |