| | |
| | | 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 |
| | | TravelCountSharService travelCountSharService; |
| | | |
| | | @Resource |
| | | private RestHighLevelClient restHighLevelClient; |
| | | |
| | | @Resource |
| | | EsService esService; |
| | | |
| | | private LambdaQueryWrapper<ZfShare> uniqueCondition(ZfShare zfShare) { |
| | | LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); |
| | |
| | | |
| | | } |
| | | |
| | | public void addData(ZfShare za) |
| | | { |
| | | LambdaQueryWrapper<ZfShare> lqw = uniqueCondition(za); |
| | | List<ZfShare> list = list(lqw); |
| | | |
| | | if(list.size()>0){ |
| | | throw new RuntimeException("请勿分享重复数据"); |
| | | } |
| | | else { |
| | | save(za); |
| | | } |
| | | |
| | | } |
| | | // public void addData(ZfShare za) |
| | | // { |
| | | // LambdaQueryWrapper<ZfShare> lqw = uniqueCondition(za); |
| | | // List<ZfShare> list = list(lqw); |
| | | // |
| | | // if(list.size()>0){ |
| | | // throw new RuntimeException("请勿分享重复数据"); |
| | | // } |
| | | // else { |
| | | // |
| | | // } |
| | | // |
| | | // } |
| | | |
| | | @Override |
| | | public AjaxResult saveZa(ShareMore shareMore) { |
| | |
| | | za.setShareContent(shareContent); |
| | | za.setShareId(shareId); |
| | | za.setSysMenuId(2055L); |
| | | addData(za); |
| | | TravelDetail travelDetail =travelDetailService.getById(za.getShareContent()); |
| | | Long id = travelDetail.getCid(); |
| | | if (id != null){ |
| | | za.setId(za.getId()+1); |
| | | za.setSysMenuId(2056L); |
| | | za.setShareContent(id); |
| | | List<ZfShare> travelCount = list(uniqueCondition(za)); |
| | | System.out.println("nmfiwwugn419526/"+za); |
| | | System.out.println(travelCount); |
| | | if (travelCount.size() == 0){ |
| | | addData(za); |
| | | }} |
| | | save(za); |
| | | // TravelDetail travelDetail =travelDetailService.getById(za.getShareContent()); |
| | | // Long id = travelDetail.getCid(); |
| | | // if (id != null){ |
| | | // za.setId(za.getId()+1); |
| | | // za.setSysMenuId(2056L); |
| | | // za.setShareContent(id); |
| | | // List<ZfShare> travelCount = list(uniqueCondition(za)); |
| | | // System.out.println("nmfiwwugn419526/"+za); |
| | | // System.out.println(travelCount); |
| | | // if (travelCount.size() == 0){ |
| | | // addData(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, 2055L); |
| | | |
| | | 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; |
| | | } |
| | | } |
| | | } |