zqy
5 天以前 b02beccf4567068cb47a3f1181a00039456c872d
zhang-content/src/main/java/com/ruoyi/service/impl/TravelCountDownServiceImpl.java
@@ -37,6 +37,9 @@
    @Resource
    TravelCountService travelCountService;
    @Resource
    TravelDetailService travelDetailService;
    @Resource
    ZInfoUserService zInfoUserService;
@@ -82,13 +85,29 @@
            String uuid = UUID.randomUUID().toString().replace("-", "");
            esModel.setId(uuid);
            esModel.setCtId(Long.valueOf(inte));
            esModel.setCtTableName("通讯录");
            esModel.setCtTableName("旅游");
            esModel.setBy1(String.valueOf(zfDownload.getDownloadId()));
            esModel.setBy2(String.valueOf(zfDownload.getDownloadContent()));
            esModel.setBy3(String.valueOf(zfDownload.getShareId()));
            //这里存储查询详情的路径
            esService.insertTable(esModel);
            TravelDetail travelDetail = new TravelDetail();
            travelDetail.setCid(zfDownload.getDownloadContent());
            List<TravelDetail> travelDetails = travelDetailService.getDataByCid(zfDownload.getDownloadContent(),travelDetail);
            System.out.println("cgftfygmjh267/"+travelDetails.size());
            if (travelDetails.size() != 0){
            for (TravelDetail travelDetail1:travelDetails) {
                zfDownload.setId(zfDownload.getId()+1);
                zfDownload.setSysMenuId(2055L);
                zfDownload.setDownloadContent(travelDetail1.getId());
                System.out.println(zfDownload);
                save(zfDownload);
            }}
            return AjaxResult.success();
        } else {
            return AjaxResult.error();
@@ -96,14 +115,29 @@
    }
    @Override
    public AjaxResult deleteData(Long[] ids) {
        List<ZfDownload> zfDownloads = listByIds(Arrays.asList(ids));
    public Boolean deleteData(Long[] ids) {
        List<Long> id = new ArrayList<>();
        if (travelCountService.removeByIds(Arrays.asList(ids))) {
        LambdaQueryWrapper<ZfDownload> lqw = new LambdaQueryWrapper<>();
        lqw.in(ids != null, ZfDownload::getDownloadContent,  ids)
                .eq(ZfDownload::getSysMenuId, 2056L);
        List<ZfDownload> zfDownloads = list(lqw);
        System.out.println(zfDownloads);
        if (zfDownloads.size() == 0){
            return true;
        }
        for (ZfDownload zfDownload: zfDownloads) {
            id.add(zfDownload.getId());
        }
        System.out.println(id);
        if (removeByIds(id)) {
            //删除es中的数据
            zfDownloads.stream().forEach(zfDoctorDownload -> {
                EsModel esModel = esService.findByCtId(zfDoctorDownload.getId().intValue(), "通讯录下载");
                EsModel esModel = esService.findByCtId(zfDoctorDownload.getId().intValue(), "旅游统计表下载删除");
                if (esModel != null) {
                    DeleteRequest deleteRequest = new DeleteRequest("allsearchdata", esModel.getId());
@@ -114,9 +148,9 @@
                    }
                }
            });
            return AjaxResult.success();
            return true;
        } else {
            return AjaxResult.error();
            return false;
        }
    }