From 1c592426db7393a5d891478be3e303563c038d30 Mon Sep 17 00:00:00 2001 From: zqy <2522236926@qq.com> Date: 星期五, 02 八月 2024 20:02:35 +0800 Subject: [PATCH] 分享 --- zhang-content/src/main/java/com/ruoyi/service/impl/ZfContactDownlServiceImpl.java | 141 ++++ zhang-content/src/main/java/com/ruoyi/service/impl/TravelSharServiceImpl.java | 50 + zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanDownloadServiceImpl.java | 143 ++++ zhang-content/src/main/java/com/ruoyi/service/impl/ZfEconomySharServiceImpl.java | 187 +++++ zhang-content/src/main/java/com/ruoyi/service/ZfEquipDownloadService.java | 13 zhang-content/src/main/java/com/ruoyi/service/ZfPetSharService.java | 28 zhang-content/src/main/java/com/ruoyi/service/impl/ZfContactShraServiceImpl.java | 190 +++++ zhang-content/src/main/java/com/ruoyi/service/impl/ZfEquipDownloadServiceImpl.java | 143 ++++ zhang-content/src/main/java/com/ruoyi/service/ZfEquipShareService.java | 28 zhang-content/src/main/java/com/ruoyi/service/impl/ZfEconomyDownlServiceImpl.java | 143 ++++ zhang-content/src/main/java/com/ruoyi/domain/ZfEquipment.java | 4 zhang-content/src/main/java/com/ruoyi/service/impl/ZfPetDownlServiceImpl.java | 4 zhang-content/src/main/java/com/ruoyi/domain/ZfCollection.java | 4 zhang-content/src/main/java/com/ruoyi/service/impl/ZfEquipShareServiceImpl.java | 190 +++++ zhang-content/src/main/java/com/ruoyi/domain/TravelDetail.java | 6 zhang-content/src/main/java/com/ruoyi/domain/ZfContact.java | 4 zhang-content/src/main/java/com/ruoyi/service/ZfCleanDownloadService.java | 13 zhang-content/src/main/java/com/ruoyi/domain/ZfPet.java | 5 zhang-content/src/main/java/com/ruoyi/service/ZfPetDownlService.java | 13 zhang-content/src/main/java/com/ruoyi/service/ZfEconomyDownlService.java | 13 zhang-content/src/main/java/com/ruoyi/service/impl/TravelDownServiceImpl.java | 4 zhang-content/src/main/java/com/ruoyi/domain/ZfClean.java | 5 zhang-content/src/main/java/com/ruoyi/domain/ZfPetNote.java | 4 zhang-content/src/main/java/com/ruoyi/service/ZfEconomyShaService.java | 28 zhang-content/src/main/java/com/ruoyi/service/ZfCollectionDownloadService.java | 13 zhang-content/src/main/java/com/ruoyi/domain/ZfEconomy.java | 5 zhang-content/src/main/java/com/ruoyi/domain/TravelCount.java | 4 zhang-content/src/main/java/com/ruoyi/service/ZfCleanShareService.java | 27 zhang-content/src/main/java/com/ruoyi/service/impl/ZfCollectionShaServiceImpl.java | 189 +++++ zhang-content/src/main/java/com/ruoyi/service/impl/ZfPetSharServiceImpl.java | 4 zhang-content/src/main/java/com/ruoyi/service/ZfContactShraService.java | 27 zhang-content/src/main/java/com/ruoyi/service/TravelDownlService.java | 14 zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanShareServiceImpl.java | 191 +++++ zhang-content/src/main/java/com/ruoyi/service/ZfCollectionShareService.java | 27 zhang-content/src/main/java/com/ruoyi/service/ZfContactDownlService.java | 13 zhang-content/src/main/java/com/ruoyi/service/impl/ZfCollectionDownlServiceImpl.java | 141 ++++ zhang-content/src/main/java/com/ruoyi/service/TravelSharService.java | 27 37 files changed, 2,045 insertions(+), 0 deletions(-) diff --git a/zhang-content/src/main/java/com/ruoyi/domain/TravelCount.java b/zhang-content/src/main/java/com/ruoyi/domain/TravelCount.java index c0b04c6..7300971 100644 --- a/zhang-content/src/main/java/com/ruoyi/domain/TravelCount.java +++ b/zhang-content/src/main/java/com/ruoyi/domain/TravelCount.java @@ -110,5 +110,9 @@ @JsonFormat(pattern = "yyyy-MM-dd") private Date createTime; + /** + * 鍒嗕韩浜篿d + */ + private Integer shareId; } diff --git a/zhang-content/src/main/java/com/ruoyi/domain/TravelDetail.java b/zhang-content/src/main/java/com/ruoyi/domain/TravelDetail.java index e2c01fc..6854e25 100644 --- a/zhang-content/src/main/java/com/ruoyi/domain/TravelDetail.java +++ b/zhang-content/src/main/java/com/ruoyi/domain/TravelDetail.java @@ -109,4 +109,10 @@ private Double otherCost; private String backInfo; + + /** + * 鍒嗕韩浜篿d + */ + private Integer shareId; + } diff --git a/zhang-content/src/main/java/com/ruoyi/domain/ZfClean.java b/zhang-content/src/main/java/com/ruoyi/domain/ZfClean.java index ed520e9..18f8ec0 100644 --- a/zhang-content/src/main/java/com/ruoyi/domain/ZfClean.java +++ b/zhang-content/src/main/java/com/ruoyi/domain/ZfClean.java @@ -110,4 +110,9 @@ @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") private Date happenTime; + /** + * 鍒嗕韩浜篿d + */ + private Integer shareId; + } diff --git a/zhang-content/src/main/java/com/ruoyi/domain/ZfCollection.java b/zhang-content/src/main/java/com/ruoyi/domain/ZfCollection.java index b4f7498..a2b347f 100644 --- a/zhang-content/src/main/java/com/ruoyi/domain/ZfCollection.java +++ b/zhang-content/src/main/java/com/ruoyi/domain/ZfCollection.java @@ -115,5 +115,9 @@ @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") private Date happenTime; + /** + * 鍒嗕韩浜篿d + */ + private Integer shareId; } diff --git a/zhang-content/src/main/java/com/ruoyi/domain/ZfContact.java b/zhang-content/src/main/java/com/ruoyi/domain/ZfContact.java index 4ea9d8b..a56bb56 100644 --- a/zhang-content/src/main/java/com/ruoyi/domain/ZfContact.java +++ b/zhang-content/src/main/java/com/ruoyi/domain/ZfContact.java @@ -127,5 +127,9 @@ @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") private Date happenTime; + /** + * 鍒嗕韩浜篿d + */ + private Integer shareId; } diff --git a/zhang-content/src/main/java/com/ruoyi/domain/ZfEconomy.java b/zhang-content/src/main/java/com/ruoyi/domain/ZfEconomy.java index 68a5159..4bc9ce8 100644 --- a/zhang-content/src/main/java/com/ruoyi/domain/ZfEconomy.java +++ b/zhang-content/src/main/java/com/ruoyi/domain/ZfEconomy.java @@ -109,4 +109,9 @@ @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") private Date happenTime; + /** + * 鍒嗕韩浜篿d + */ + private Integer shareId; + } diff --git a/zhang-content/src/main/java/com/ruoyi/domain/ZfEquipment.java b/zhang-content/src/main/java/com/ruoyi/domain/ZfEquipment.java index 8829bce..1d8cbaa 100644 --- a/zhang-content/src/main/java/com/ruoyi/domain/ZfEquipment.java +++ b/zhang-content/src/main/java/com/ruoyi/domain/ZfEquipment.java @@ -108,6 +108,10 @@ @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") private Date happenTime; + /** + * 鍒嗕韩浜篿d + */ + private Integer shareId; } diff --git a/zhang-content/src/main/java/com/ruoyi/domain/ZfPet.java b/zhang-content/src/main/java/com/ruoyi/domain/ZfPet.java index a7482ba..8dd4acf 100644 --- a/zhang-content/src/main/java/com/ruoyi/domain/ZfPet.java +++ b/zhang-content/src/main/java/com/ruoyi/domain/ZfPet.java @@ -154,5 +154,10 @@ @Excel(name = "鍑虹敓鏃ユ湡", dateFormat = "yyyy-MM-dd") private Date birthEnd; + /** + * 鍒嗕韩浜篿d + */ + private Integer shareId; + } diff --git a/zhang-content/src/main/java/com/ruoyi/domain/ZfPetNote.java b/zhang-content/src/main/java/com/ruoyi/domain/ZfPetNote.java index 2cd6bb7..c68453f 100644 --- a/zhang-content/src/main/java/com/ruoyi/domain/ZfPetNote.java +++ b/zhang-content/src/main/java/com/ruoyi/domain/ZfPetNote.java @@ -86,6 +86,10 @@ @JsonFormat(pattern = "yyyy-MM-dd") private Date remindEndTime; + /** + * 鍒嗕韩浜篿d + */ + private Integer shareId; diff --git a/zhang-content/src/main/java/com/ruoyi/service/TravelDownlService.java b/zhang-content/src/main/java/com/ruoyi/service/TravelDownlService.java new file mode 100644 index 0000000..b31d09f --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/TravelDownlService.java @@ -0,0 +1,14 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfShare; + +public interface TravelDownlService extends IService<ZfDownload> { + AjaxResult addData(ZfDownload zfDownload); + + AjaxResult deleteData(Long[] ids); + + AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo , Integer pageSize); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/TravelSharService.java b/zhang-content/src/main/java/com/ruoyi/service/TravelSharService.java new file mode 100644 index 0000000..e1d084d --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/TravelSharService.java @@ -0,0 +1,27 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ShareMore; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfProperty; +import com.ruoyi.domain.ZfShare; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +public interface TravelSharService extends IService<ZfShare> { + List<ZfShare> getAuthority(); + + AjaxResult saveZa(ShareMore shareMore); + + AjaxResult listByFidAid(ShareMore shareMore,Integer pageNo ,Integer pageSize); + + AjaxResult deleteZa(ShareMore shareMore); + + AjaxResult listByUserId(); + + AjaxResult listUserId(Integer pageNo ,Integer pageSize); + + Long getShareId(ZfDownload zfDownload); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfCleanDownloadService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfCleanDownloadService.java new file mode 100644 index 0000000..3915da0 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfCleanDownloadService.java @@ -0,0 +1,13 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ZfDownload; + +public interface ZfCleanDownloadService extends IService<ZfDownload> { + AjaxResult addData(ZfDownload zfDownload); + + AjaxResult deleteData(Long[] ids); + + AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo , Integer pageSize); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfCleanShareService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfCleanShareService.java new file mode 100644 index 0000000..82e5bd9 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfCleanShareService.java @@ -0,0 +1,27 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ShareMore; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfProperty; +import com.ruoyi.domain.ZfShare; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +public interface ZfCleanShareService extends IService<ZfShare> { + List<ZfShare> getAuthority(); + + AjaxResult saveZa(ShareMore shareMore); + + AjaxResult listByFidAid(ShareMore shareMore,Integer pageNo ,Integer pageSize); + + AjaxResult deleteZa(ShareMore shareMore); + + AjaxResult listByUserId(); + + AjaxResult listUserId(Integer pageNo ,Integer pageSize); + + Long getShareId(ZfDownload zfDownload); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfCollectionDownloadService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfCollectionDownloadService.java new file mode 100644 index 0000000..485d40a --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfCollectionDownloadService.java @@ -0,0 +1,13 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ZfDownload; + +public interface ZfCollectionDownloadService extends IService<ZfDownload> { + AjaxResult addData(ZfDownload zfDownload); + + AjaxResult deleteData(Long[] ids); + + AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo , Integer pageSize); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfCollectionShareService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfCollectionShareService.java new file mode 100644 index 0000000..246360a --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfCollectionShareService.java @@ -0,0 +1,27 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ShareMore; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfProperty; +import com.ruoyi.domain.ZfShare; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +public interface ZfCollectionShareService extends IService<ZfShare> { + List<ZfShare> getAuthority(); + + AjaxResult saveZa(ShareMore shareMore); + + AjaxResult listByFidAid(ShareMore shareMore,Integer pageNo ,Integer pageSize); + + AjaxResult deleteZa(ShareMore shareMore); + + AjaxResult listByUserId(); + + AjaxResult listUserId(Integer pageNo ,Integer pageSize); + + Long getShareId(ZfDownload zfDownload); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfContactDownlService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfContactDownlService.java new file mode 100644 index 0000000..b63521d --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfContactDownlService.java @@ -0,0 +1,13 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ZfDownload; + +public interface ZfContactDownlService extends IService<ZfDownload> { + AjaxResult addData(ZfDownload zfDownload); + + AjaxResult deleteData(Long[] ids); + + AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo , Integer pageSize); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfContactShraService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfContactShraService.java new file mode 100644 index 0000000..8718256 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfContactShraService.java @@ -0,0 +1,27 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ShareMore; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfProperty; +import com.ruoyi.domain.ZfShare; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +public interface ZfContactShraService extends IService<ZfShare> { + List<ZfShare> getAuthority(); + + AjaxResult saveZa(ShareMore shareMore); + + AjaxResult listByFidAid(ShareMore shareMore,Integer pageNo ,Integer pageSize); + + AjaxResult deleteZa(ShareMore shareMore); + + AjaxResult listByUserId(); + + AjaxResult listUserId(Integer pageNo ,Integer pageSize); + + Long getShareId(ZfDownload zfDownload); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfEconomyDownlService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfEconomyDownlService.java new file mode 100644 index 0000000..6d3e060 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfEconomyDownlService.java @@ -0,0 +1,13 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ZfDownload; + +public interface ZfEconomyDownlService extends IService<ZfDownload> { + AjaxResult addData(ZfDownload zfDownload); + + AjaxResult deleteData(Long[] ids); + + AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo , Integer pageSize); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfEconomyShaService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfEconomyShaService.java new file mode 100644 index 0000000..c7d2aae --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfEconomyShaService.java @@ -0,0 +1,28 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ShareMore; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfProperty; +import com.ruoyi.domain.ZfShare; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +public interface ZfEconomyShaService extends IService<ZfShare> { + + List<ZfShare> getAuthority(); + + AjaxResult saveZa(ShareMore shareMore); + + AjaxResult listByFidAid(ShareMore shareMore,Integer pageNo ,Integer pageSize); + + AjaxResult deleteZa(ShareMore shareMore); + + AjaxResult listByUserId(); + + AjaxResult listUserId(Integer pageNo ,Integer pageSize); + + Long getShareId(ZfDownload zfDownload); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfEquipDownloadService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfEquipDownloadService.java new file mode 100644 index 0000000..a7c1448 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfEquipDownloadService.java @@ -0,0 +1,13 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ZfDownload; + +public interface ZfEquipDownloadService extends IService<ZfDownload> { + AjaxResult addData(ZfDownload zfDownload); + + AjaxResult deleteData(Long[] ids); + + AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo , Integer pageSize); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfEquipShareService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfEquipShareService.java new file mode 100644 index 0000000..9ac1445 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfEquipShareService.java @@ -0,0 +1,28 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ShareMore; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfProperty; +import com.ruoyi.domain.ZfShare; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +public interface ZfEquipShareService extends IService<ZfShare> { + + List<ZfShare> getAuthority(); + + AjaxResult saveZa(ShareMore shareMore); + + AjaxResult listByFidAid(ShareMore shareMore,Integer pageNo ,Integer pageSize); + + AjaxResult deleteZa(ShareMore shareMore); + + AjaxResult listByUserId(); + + AjaxResult listUserId(Integer pageNo ,Integer pageSize); + + Long getShareId(ZfDownload zfDownload); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfPetDownlService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfPetDownlService.java new file mode 100644 index 0000000..075c76b --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfPetDownlService.java @@ -0,0 +1,13 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ZfDownload; + +public interface ZfPetDownlService extends IService<ZfDownload> { + AjaxResult addData(ZfDownload zfDownload); + + AjaxResult deleteData(Long[] ids); + + AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo , Integer pageSize); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfPetSharService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfPetSharService.java new file mode 100644 index 0000000..876d359 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/ZfPetSharService.java @@ -0,0 +1,28 @@ +package com.ruoyi.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ShareMore; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfProperty; +import com.ruoyi.domain.ZfShare; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +public interface ZfPetSharService extends IService<ZfShare> { + + List<ZfShare> getAuthority(); + + AjaxResult saveZa(ShareMore shareMore); + + AjaxResult listByFidAid(ShareMore shareMore,Integer pageNo ,Integer pageSize); + + AjaxResult deleteZa(ShareMore shareMore); + + AjaxResult listByUserId(); + + AjaxResult listUserId(Integer pageNo ,Integer pageSize); + + Long getShareId(ZfDownload zfDownload); +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/TravelDownServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/TravelDownServiceImpl.java new file mode 100644 index 0000000..7ef2a2c --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/TravelDownServiceImpl.java @@ -0,0 +1,4 @@ +package com.ruoyi.service.impl; + +public class TravelDownServiceImpl { +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/TravelSharServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/TravelSharServiceImpl.java new file mode 100644 index 0000000..d5a5ab0 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/TravelSharServiceImpl.java @@ -0,0 +1,50 @@ +package com.ruoyi.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.domain.ShareMore; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfProperty; +import com.ruoyi.domain.ZfShare; +import com.ruoyi.mapper.ZfShareMapper; +import com.ruoyi.service.TravelSharService; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +public class TravelSharServiceImpl extends ServiceImpl<ZfShareMapper,ZfShare> implements TravelSharService { + @Override + public List<ZfShare> getAuthority() { + return null; + } + + @Override + public AjaxResult saveZa(ShareMore shareMore) { + return null; + } + + @Override + public AjaxResult listByFidAid(ShareMore shareMore, Integer pageNo, Integer pageSize) { + return null; + } + + @Override + public AjaxResult deleteZa(ShareMore shareMore) { + return null; + } + + @Override + public AjaxResult listByUserId() { + return null; + } + + @Override + public AjaxResult listUserId(Integer pageNo, Integer pageSize) { + return null; + } + + @Override + public Long getShareId(ZfDownload zfDownload) { + return null; + } +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanDownloadServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanDownloadServiceImpl.java new file mode 100644 index 0000000..3efbb5e --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanDownloadServiceImpl.java @@ -0,0 +1,143 @@ +package com.ruoyi.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +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.utils.MapUtils; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.domain.ZInfoUser; +import com.ruoyi.domain.ZfClean; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfProperty; +import com.ruoyi.mapper.ZfDownloadMapper; +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.*; +import java.util.stream.Collectors; + +@Slf4j +@Service +public class ZfCleanDownloadServiceImpl extends ServiceImpl<ZfDownloadMapper,ZfDownload> implements ZfCleanDownloadService { + @Resource + EsService esService; + + @Resource + ZfCleanShareService zfCleanShareService; + + @Resource + ZfCleanService zfCleanService; + + + @Resource + ZInfoUserService zInfoUserService; + + @Resource + private RestHighLevelClient restHighLevelClient; + + private LambdaQueryWrapper<ZfDownload> buildCondition(ZfDownload zfDownload, Long userId) { + LambdaQueryWrapper<ZfDownload> lqw = new LambdaQueryWrapper<>(); + lqw.in(ZfDownload::getDownloadId,userId); + lqw.orderByDesc(ZfDownload::getDownloadId); + lqw.like(zfDownload.getDownloadId() != null, ZfDownload::getDownloadId, zfDownload.getDownloadId()) + .like(zfDownload.getDownloadContent() != null, ZfDownload::getDownloadContent, zfDownload.getDownloadContent()) + .eq( ZfDownload::getSysMenuId, zfDownload.getSysMenuId()); + return lqw; + } + private LambdaQueryWrapper<ZfDownload> uniqueCondition(ZfDownload zfDownload) { + LambdaQueryWrapper<ZfDownload> lqw = new LambdaQueryWrapper<>(); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfDownload.getDownloadId())), ZfDownload::getDownloadId, zfDownload.getDownloadId()) + .eq(StringUtils.isNotEmpty(String.valueOf(zfDownload.getDownloadContent())), ZfDownload::getDownloadContent, zfDownload.getDownloadContent()) + .eq(ZfDownload::getSysMenuId, zfDownload.getSysMenuId()); + return lqw; + } + + public Long getUserId() { + ZInfoUser myself = zInfoUserService.getMyself(); + return myself.getUserId(); + } + @Override + public AjaxResult addData(ZfDownload zfDownload) { + zfDownload.setDownloadId(getUserId()); + LambdaQueryWrapper<ZfDownload> lqw = uniqueCondition(zfDownload); + List<ZfDownload> list = list(lqw); + if (list.size() > 0) { + throw new RuntimeException("璇峰嬁閲嶅涓嬭浇鏁版嵁"); + } + +// zfDownload.setDownloadId(getUserId()); + zfDownload.setShareId(zfCleanShareService.getShareId(zfDownload)); + if (save(zfDownload)) { + EsModel esModel = new EsModel(); + Integer inte = zfDownload.getId().intValue(); + String uuid = UUID.randomUUID().toString().replace("-", ""); + esModel.setId(uuid); + esModel.setCtId(Long.valueOf(inte)); + esModel.setCtTableName("淇濇磥鏀剁撼"); + + esModel.setBy1(String.valueOf(zfDownload.getDownloadId())); + esModel.setBy2(String.valueOf(zfDownload.getDownloadContent())); + esModel.setBy3(String.valueOf(zfDownload.getShareId())); + //杩欓噷瀛樺偍鏌ヨ璇︽儏鐨勮矾寰� + esService.insertTable(esModel); + return AjaxResult.success(); + } else { + return AjaxResult.error(); + } + } + + @Override + public AjaxResult deleteData(Long[] ids) { + List<ZfDownload> zfDownloads = listByIds(Arrays.asList(ids)); + + if (zfCleanShareService.removeByIds(Arrays.asList(ids))) { + + //鍒犻櫎es涓殑鏁版嵁 + zfDownloads.stream().forEach(zfDoctorDownload -> { + EsModel esModel = esService.findByCtId(zfDoctorDownload.getId().intValue(), "淇濇磥鏀剁撼涓嬭浇"); + + if (esModel != null) { + DeleteRequest deleteRequest = new DeleteRequest("allsearchdata", esModel.getId()); + try { + restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT); + } catch (IOException e) { + throw new RuntimeException(e); + } + } + }); + return AjaxResult.success(); + } else { + return AjaxResult.error(); + } + } + + @Override + public AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo, Integer pageSize) { + ZInfoUser myself = zInfoUserService.getMyself(); + LambdaQueryWrapper<ZfDownload> lqw = buildCondition(zfDownload,myself.getUserId()); + List<ZfDownload> beanRecords = list(lqw); + List<ZfClean> bs = new ArrayList<>(); + for (ZfDownload a: beanRecords) { + if (zfCleanService.getById(a.getDownloadContent()) != null) { + ZfClean ds = zfCleanService.getById(a.getDownloadContent()); + ds.setShareId(a.getShareId().intValue()); + bs.add(ds); + } + } + List<ZfClean> record = bs.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (bs.size() -1) / pageSize +1; + + Page<ZfClean> zfEventPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfEventPage, record,bs.size()); + return AjaxResult.success(data); + } +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanShareServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanShareServiceImpl.java new file mode 100644 index 0000000..318b804 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanShareServiceImpl.java @@ -0,0 +1,191 @@ +package com.ruoyi.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +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.SysUser; +import com.ruoyi.common.utils.MapUtils; +import com.ruoyi.common.utils.SecurityUtils; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.domain.*; +import com.ruoyi.mapper.ZfShareMapper; +import com.ruoyi.service.*; +import org.springframework.stereotype.Service; +import org.springframework.web.multipart.MultipartFile; + +import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.stream.Collectors; + +@Service +public class ZfCleanShareServiceImpl extends ServiceImpl<ZfShareMapper,ZfShare> implements ZfCleanShareService { + @Resource + ZfCleanShareService zfCleanShareService; + + @Resource + ZfCleanService zfCleanService; + + @Resource + private ZInfoUserService zInfoUserService; + + private LambdaQueryWrapper<ZfShare> uniqueCondition(ZfShare zfShare) { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getShareId())), ZfShare::getShareId, zfShare.getShareId()); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getShareContent())), ZfShare::getShareContent, zfShare.getShareContent()); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getSysMenuId())), ZfShare::getSysMenuId, zfShare.getSysMenuId()); + return lqw; + } + + @Override + public List<ZfShare> getAuthority() { + SysUser user = SecurityUtils.getLoginUser().getUser(); + Long userId = user.getUserId(); + + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,userId); + + return list(lqw); + } + + public Long getUserId(){ + ZInfoUser myself = zInfoUserService.getMyself(); + return myself.getUserId(); + + } + + public void addData(ZfShare za) + { + LambdaQueryWrapper<ZfShare> lqw = uniqueCondition(za); + List<ZfShare> list = list(lqw); + + if(list.size()>0){ + throw new RuntimeException("璇峰嬁鍒嗕韩閲嶅鏁版嵁"); + } + else { + zfCleanShareService.save(za); + } + + } + + @Override + public AjaxResult saveZa(ShareMore shareMore) { + Long [] shareIds = shareMore.getShareIds(); + Long [] shareContents = shareMore.getShareContents(); + for (Long shareId : shareIds) { + for (Long shareContent : shareContents) { + ZfShare za = new ZfShare(); + za.setUserId(getUserId()); + za.setShareContent(shareContent); + za.setShareId(shareId); + za.setSysMenuId(2020L); + addData(za); + } + } + // Long [] + // if(bl) + return AjaxResult.success("鍒嗕韩鎴愬姛!"); + } + + @Override + public AjaxResult listByFidAid(ShareMore shareMore, Integer pageNo, Integer pageSize) { + Long [] shareIds = shareMore.getShareIds(); + List<ZfClean> beanRecord3 = new ArrayList<>(); + for (Long shareId : shareIds) { + { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,shareId) + .eq(ZfShare::getSysMenuId,shareMore.getSysMenuId()) + .eq(ZfShare::getUserId, getUserId()); + List<ZfShare> beanRecords = list(lqw); + for (ZfShare beanRecord : beanRecords ) { + beanRecord3.add(zfCleanService.getById(beanRecord.getShareContent())); + } + } + } + List<ZfClean> record = beanRecord3.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (beanRecord3.size() -1) / pageSize +1; + + Page<ZfClean> zfCleanPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfCleanPage, record,beanRecord3.size()); + + return AjaxResult.success(data); + } + + @Override + public AjaxResult deleteZa(ShareMore shareMore) { + Long [] shareIds = shareMore.getShareIds(); + Long [] shareContents = shareMore.getShareContents(); + for(Long shareId : shareIds) + for(Long shareContent: shareContents) + { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,shareId) + .eq(ZfShare::getShareContent, shareContent) + .eq(ZfShare::getSysMenuId, shareMore.getSysMenuId()) + .eq(ZfShare::getUserId, getUserId()); + + zfCleanShareService.remove(lqw); + // addData(za); + } + return AjaxResult.success("鏁版嵁鏀跺洖鎴愬姛!"); + } + + @Override + public AjaxResult listByUserId() { + HashMap<Long,List<ZfClean>> bs = new HashMap<>(); + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,getUserId()); + lqw.eq(ZfShare::getSysMenuId,2020L); + List<ZfShare> beanRecords = list(lqw); + List<ZfClean> b1 = new ArrayList<>(); + for (ZfShare beanRecord : beanRecords ) { + b1.add(zfCleanService.getById(beanRecord.getShareContent())); + bs.put(beanRecord.getUserId(),b1); + } +// log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", bs); + return AjaxResult.success(bs); + } + + @Override + public AjaxResult listUserId(Integer pageNo, Integer pageSize) { + List<ZfClean> bs = new ArrayList<>(); + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,getUserId()); + lqw.eq(ZfShare::getSysMenuId,2020L); + List<ZfShare> beanRecords = list(lqw); + for (ZfShare beanRecord : beanRecords ) { + ZfClean bs2 = zfCleanService.getById(beanRecord.getShareContent()); + bs2.setShareId(beanRecord.getUserId().intValue()); + bs.add(bs2); + } +// log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", bs); + List<ZfClean> record = bs.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (bs.size() -1) / pageSize +1; + + Page<ZfClean> zfCleanPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfCleanPage, record,bs.size()); + return AjaxResult.success(data); + } + + @Override + public Long getShareId(ZfDownload zfDownload) { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId, zfDownload.getDownloadId()) + .eq(ZfShare::getShareContent, zfDownload.getDownloadContent()) + .eq(ZfShare::getSysMenuId, zfDownload.getSysMenuId()); + List<ZfShare> beanRecords = list(lqw); + if (beanRecords.size() != 0){ + return beanRecords.get(0).getUserId(); + } + else { + return null; + } + } + + +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCollectionDownlServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCollectionDownlServiceImpl.java new file mode 100644 index 0000000..e8e6dd0 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCollectionDownlServiceImpl.java @@ -0,0 +1,141 @@ +package com.ruoyi.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +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.utils.MapUtils; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.domain.*; +import com.ruoyi.mapper.ZfDownloadMapper; +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.*; +import java.util.stream.Collectors; + +@Service +@Slf4j +public class ZfCollectionDownlServiceImpl extends ServiceImpl<ZfDownloadMapper, ZfDownload> implements ZfCollectionDownloadService { + @Resource + EsService esService; + + @Resource + ZfCollectionShareService zfCollectionShareService; + + @Resource + ZfCollectionService zfCollectionService; + + + @Resource + ZInfoUserService zInfoUserService; + + @Resource + private RestHighLevelClient restHighLevelClient; + + private LambdaQueryWrapper<ZfDownload> buildCondition(ZfDownload zfDownload, Long userId) { + LambdaQueryWrapper<ZfDownload> lqw = new LambdaQueryWrapper<>(); + lqw.in(ZfDownload::getDownloadId,userId); + lqw.orderByDesc(ZfDownload::getDownloadId); + lqw.like(zfDownload.getDownloadId() != null, ZfDownload::getDownloadId, zfDownload.getDownloadId()) + .like(zfDownload.getDownloadContent() != null, ZfDownload::getDownloadContent, zfDownload.getDownloadContent()) + .eq( ZfDownload::getSysMenuId, zfDownload.getSysMenuId()); + return lqw; + } + private LambdaQueryWrapper<ZfDownload> uniqueCondition(ZfDownload zfDownload) { + LambdaQueryWrapper<ZfDownload> lqw = new LambdaQueryWrapper<>(); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfDownload.getDownloadId())), ZfDownload::getDownloadId, zfDownload.getDownloadId()) + .eq(StringUtils.isNotEmpty(String.valueOf(zfDownload.getDownloadContent())), ZfDownload::getDownloadContent, zfDownload.getDownloadContent()) + .eq(ZfDownload::getSysMenuId, zfDownload.getSysMenuId()); + return lqw; + } + + public Long getUserId() { + ZInfoUser myself = zInfoUserService.getMyself(); + return myself.getUserId(); + } + @Override + public AjaxResult addData(ZfDownload zfDownload) { + zfDownload.setDownloadId(getUserId()); + LambdaQueryWrapper<ZfDownload> lqw = uniqueCondition(zfDownload); + List<ZfDownload> list = list(lqw); + if (list.size() > 0) { + throw new RuntimeException("璇峰嬁閲嶅涓嬭浇鏁版嵁"); + } + + zfDownload.setDownloadId(getUserId()); + zfDownload.setShareId(zfCollectionShareService.getShareId(zfDownload)); + if (save(zfDownload)) { + EsModel esModel = new EsModel(); + Integer inte = zfDownload.getId().intValue(); + String uuid = UUID.randomUUID().toString().replace("-", ""); + esModel.setId(uuid); + esModel.setCtId(Long.valueOf(inte)); + esModel.setCtTableName("鏀惰棌涓庤崳鑰�"); + + esModel.setBy1(String.valueOf(zfDownload.getDownloadId())); + esModel.setBy2(String.valueOf(zfDownload.getDownloadContent())); + esModel.setBy3(String.valueOf(zfDownload.getShareId())); + //杩欓噷瀛樺偍鏌ヨ璇︽儏鐨勮矾寰� + esService.insertTable(esModel); + return AjaxResult.success(); + } else { + return AjaxResult.error(); + } + } + + @Override + public AjaxResult deleteData(Long[] ids) { + List<ZfDownload> zfDownloads = listByIds(Arrays.asList(ids)); + + if (zfCollectionShareService.removeByIds(Arrays.asList(ids))) { + + //鍒犻櫎es涓殑鏁版嵁 + zfDownloads.stream().forEach(zfDoctorDownload -> { + EsModel esModel = esService.findByCtId(zfDoctorDownload.getId().intValue(), "鏀惰棌涓庤崳鑰�"); + + if (esModel != null) { + DeleteRequest deleteRequest = new DeleteRequest("allsearchdata", esModel.getId()); + try { + restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT); + } catch (IOException e) { + throw new RuntimeException(e); + } + } + }); + return AjaxResult.success(); + } else { + return AjaxResult.error(); + } + } + + @Override + public AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo, Integer pageSize) { + ZInfoUser myself = zInfoUserService.getMyself(); + LambdaQueryWrapper<ZfDownload> lqw = buildCondition(zfDownload,myself.getUserId()); + List<ZfDownload> beanRecords = list(lqw); + List<ZfCollection> bs = new ArrayList<>(); + for (ZfDownload a: beanRecords) { + if (zfCollectionService.getById(a.getDownloadContent()) != null) { + ZfCollection ds = zfCollectionService.getById(a.getDownloadContent()); + ds.setShareId(a.getShareId().intValue()); + bs.add(ds); + } + } + List<ZfCollection> record = bs.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (bs.size() -1) / pageSize +1; + + Page<ZfCollection> zfCollectionPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfCollectionPage, record,bs.size()); + return AjaxResult.success(data); + } +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCollectionShaServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCollectionShaServiceImpl.java new file mode 100644 index 0000000..6cadc6b --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCollectionShaServiceImpl.java @@ -0,0 +1,189 @@ +package com.ruoyi.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +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.SysUser; +import com.ruoyi.common.utils.MapUtils; +import com.ruoyi.common.utils.SecurityUtils; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.domain.*; +import com.ruoyi.mapper.ZfShareMapper; +import com.ruoyi.service.*; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.stream.Collectors; + +@Slf4j +@Service +public class ZfCollectionShaServiceImpl extends ServiceImpl<ZfShareMapper, ZfShare> implements ZfCollectionShareService { + + + @Resource + ZfCollectionService zfCollectionService; + + @Resource + private ZInfoUserService zInfoUserService; + + private LambdaQueryWrapper<ZfShare> uniqueCondition(ZfShare zfShare) { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getShareId())), ZfShare::getShareId, zfShare.getShareId()); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getShareContent())), ZfShare::getShareContent, zfShare.getShareContent()); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getSysMenuId())), ZfShare::getSysMenuId, zfShare.getSysMenuId()); + return lqw; + } + + @Override + public List<ZfShare> getAuthority() { + SysUser user = SecurityUtils.getLoginUser().getUser(); + Long userId = user.getUserId(); + + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,userId); + + return list(lqw); + } + + public Long getUserId(){ + ZInfoUser myself = zInfoUserService.getMyself(); + return myself.getUserId(); + + } + + 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); + } + + } + + @Override + public AjaxResult saveZa(ShareMore shareMore) { + Long [] shareIds = shareMore.getShareIds(); + Long [] shareContents = shareMore.getShareContents(); + for (Long shareId : shareIds) { + for (Long shareContent : shareContents) { + ZfShare za = new ZfShare(); + za.setUserId(getUserId()); + za.setShareContent(shareContent); + za.setShareId(shareId); + za.setSysMenuId(2018L); + addData(za); + } + } + // Long [] + // if(bl) + return AjaxResult.success("鍒嗕韩鎴愬姛!"); + } + + @Override + public AjaxResult listByFidAid(ShareMore shareMore, Integer pageNo, Integer pageSize) { + Long [] shareIds = shareMore.getShareIds(); + List<ZfCollection> beanRecord3 = new ArrayList<>(); + for (Long shareId : shareIds) { + { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,shareId) + .eq(ZfShare::getSysMenuId,shareMore.getSysMenuId()) + .eq(ZfShare::getUserId, getUserId()); + List<ZfShare> beanRecords = list(lqw); + for (ZfShare beanRecord : beanRecords ) { + beanRecord3.add(zfCollectionService.getById(beanRecord.getShareContent())); + } + } + } + List<ZfCollection> record = beanRecord3.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (beanRecord3.size() -1) / pageSize +1; + + Page<ZfCollection> zfCollectionPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfCollectionPage, record,beanRecord3.size()); + + return AjaxResult.success(data); + } + + @Override + public AjaxResult deleteZa(ShareMore shareMore) { + Long [] shareIds = shareMore.getShareIds(); + Long [] shareContents = shareMore.getShareContents(); + for(Long shareId : shareIds) + for(Long shareContent: shareContents) + { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,shareId) + .eq(ZfShare::getShareContent, shareContent) + .eq(ZfShare::getSysMenuId, shareMore.getSysMenuId()) + .eq(ZfShare::getUserId, getUserId()); + + remove(lqw); + // addData(za); + } + return AjaxResult.success("鏁版嵁鏀跺洖鎴愬姛!"); + } + + @Override + public AjaxResult listByUserId() { + HashMap<Long,List<ZfCollection>> bs = new HashMap<>(); + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,getUserId()); + lqw.eq(ZfShare::getSysMenuId,2018L); + List<ZfShare> beanRecords = list(lqw); + List<ZfCollection> b1 = new ArrayList<>(); + for (ZfShare beanRecord : beanRecords ) { + b1.add(zfCollectionService.getById(beanRecord.getShareContent())); + bs.put(beanRecord.getUserId(),b1); + } + log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", bs); + return AjaxResult.success(bs); + } + + @Override + public AjaxResult listUserId(Integer pageNo, Integer pageSize) { + List<ZfCollection> bs = new ArrayList<>(); + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,getUserId()); + lqw.eq(ZfShare::getSysMenuId,2018L); + List<ZfShare> beanRecords = list(lqw); + for (ZfShare beanRecord : beanRecords ) { + ZfCollection bs2 = zfCollectionService.getById(beanRecord.getShareContent()); + bs2.setShareId(beanRecord.getUserId().intValue()); + bs.add(bs2); + } + log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", bs); + List<ZfCollection> record = bs.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (bs.size() -1) / pageSize +1; + + Page<ZfCollection> zfCollectionPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfCollectionPage, record,bs.size()); + return AjaxResult.success(data); + } + + @Override + public Long getShareId(ZfDownload zfDownload) { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId, zfDownload.getDownloadId()) + .eq(ZfShare::getShareContent, zfDownload.getDownloadContent()) + .eq(ZfShare::getSysMenuId, zfDownload.getSysMenuId()); + List<ZfShare> beanRecords = list(lqw); + if (beanRecords.size() != 0){ + return beanRecords.get(0).getUserId(); + } + else { + return null; + } + } +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfContactDownlServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfContactDownlServiceImpl.java new file mode 100644 index 0000000..2355f1c --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfContactDownlServiceImpl.java @@ -0,0 +1,141 @@ +package com.ruoyi.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +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.utils.MapUtils; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.domain.*; +import com.ruoyi.mapper.ZfDownloadMapper; +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.*; +import java.util.stream.Collectors; + +@Service +@Slf4j +public class ZfContactDownlServiceImpl extends ServiceImpl<ZfDownloadMapper, ZfDownload> implements ZfContactDownlService { + @Resource + EsService esService; + + @Resource + ZfContactShraServiceImpl zfContactShraService; + + @Resource + ZfContactService zfContactService; + + + @Resource + ZInfoUserService zInfoUserService; + + @Resource + private RestHighLevelClient restHighLevelClient; + + private LambdaQueryWrapper<ZfDownload> buildCondition(ZfDownload zfDownload, Long userId) { + LambdaQueryWrapper<ZfDownload> lqw = new LambdaQueryWrapper<>(); + lqw.in(ZfDownload::getDownloadId,userId); + lqw.orderByDesc(ZfDownload::getDownloadId); + lqw.like(zfDownload.getDownloadId() != null, ZfDownload::getDownloadId, zfDownload.getDownloadId()) + .like(zfDownload.getDownloadContent() != null, ZfDownload::getDownloadContent, zfDownload.getDownloadContent()) + .eq( ZfDownload::getSysMenuId, zfDownload.getSysMenuId()); + return lqw; + } + private LambdaQueryWrapper<ZfDownload> uniqueCondition(ZfDownload zfDownload) { + LambdaQueryWrapper<ZfDownload> lqw = new LambdaQueryWrapper<>(); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfDownload.getDownloadId())), ZfDownload::getDownloadId, zfDownload.getDownloadId()) + .eq(StringUtils.isNotEmpty(String.valueOf(zfDownload.getDownloadContent())), ZfDownload::getDownloadContent, zfDownload.getDownloadContent()) + .eq(ZfDownload::getSysMenuId, zfDownload.getSysMenuId()); + return lqw; + } + + public Long getUserId() { + ZInfoUser myself = zInfoUserService.getMyself(); + return myself.getUserId(); + } + @Override + public AjaxResult addData(ZfDownload zfDownload) { + zfDownload.setDownloadId(getUserId()); + LambdaQueryWrapper<ZfDownload> lqw = uniqueCondition(zfDownload); + List<ZfDownload> list = list(lqw); + if (list.size() > 0) { + throw new RuntimeException("璇峰嬁閲嶅涓嬭浇鏁版嵁"); + } + + zfDownload.setDownloadId(getUserId()); + zfDownload.setShareId(zfContactShraService.getShareId(zfDownload)); + if (save(zfDownload)) { + EsModel esModel = new EsModel(); + Integer inte = zfDownload.getId().intValue(); + String uuid = UUID.randomUUID().toString().replace("-", ""); + esModel.setId(uuid); + esModel.setCtId(Long.valueOf(inte)); + esModel.setCtTableName("閫氳褰�"); + + esModel.setBy1(String.valueOf(zfDownload.getDownloadId())); + esModel.setBy2(String.valueOf(zfDownload.getDownloadContent())); + esModel.setBy3(String.valueOf(zfDownload.getShareId())); + //杩欓噷瀛樺偍鏌ヨ璇︽儏鐨勮矾寰� + esService.insertTable(esModel); + return AjaxResult.success(); + } else { + return AjaxResult.error(); + } + } + + @Override + public AjaxResult deleteData(Long[] ids) { + List<ZfDownload> zfDownloads = listByIds(Arrays.asList(ids)); + + if (zfContactShraService.removeByIds(Arrays.asList(ids))) { + + //鍒犻櫎es涓殑鏁版嵁 + zfDownloads.stream().forEach(zfDoctorDownload -> { + EsModel esModel = esService.findByCtId(zfDoctorDownload.getId().intValue(), "閫氳褰曚笅杞�"); + + if (esModel != null) { + DeleteRequest deleteRequest = new DeleteRequest("allsearchdata", esModel.getId()); + try { + restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT); + } catch (IOException e) { + throw new RuntimeException(e); + } + } + }); + return AjaxResult.success(); + } else { + return AjaxResult.error(); + } + } + + @Override + public AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo, Integer pageSize) { + ZInfoUser myself = zInfoUserService.getMyself(); + LambdaQueryWrapper<ZfDownload> lqw = buildCondition(zfDownload,myself.getUserId()); + List<ZfDownload> beanRecords = list(lqw); + List<ZfContact> bs = new ArrayList<>(); + for (ZfDownload a: beanRecords) { + if (zfContactService.getById(a.getDownloadContent()) != null) { + ZfContact ds = zfContactService.getById(a.getDownloadContent()); + ds.setShareId(a.getShareId().intValue()); + bs.add(ds); + } + } + List<ZfContact> record = bs.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (bs.size() -1) / pageSize +1; + + Page<ZfContact> zfContactPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfContactPage, record,bs.size()); + return AjaxResult.success(data); + } +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfContactShraServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfContactShraServiceImpl.java new file mode 100644 index 0000000..15d99fc --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfContactShraServiceImpl.java @@ -0,0 +1,190 @@ +package com.ruoyi.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +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.SysUser; +import com.ruoyi.common.utils.MapUtils; +import com.ruoyi.common.utils.SecurityUtils; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.domain.*; +import com.ruoyi.mapper.ZfShareMapper; +import com.ruoyi.service.ZInfoUserService; +import com.ruoyi.service.ZfCollectionService; +import com.ruoyi.service.ZfContactService; +import com.ruoyi.service.ZfContactShraService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.stream.Collectors; + +@Slf4j +@Service +public class ZfContactShraServiceImpl extends ServiceImpl<ZfShareMapper, ZfShare> implements ZfContactShraService { + @Resource + ZfContactService zfContactService; + + @Resource + private ZInfoUserService zInfoUserService; + + private LambdaQueryWrapper<ZfShare> uniqueCondition(ZfShare zfShare) { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getShareId())), ZfShare::getShareId, zfShare.getShareId()); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getShareContent())), ZfShare::getShareContent, zfShare.getShareContent()); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getSysMenuId())), ZfShare::getSysMenuId, zfShare.getSysMenuId()); + return lqw; + } + + @Override + public List<ZfShare> getAuthority() { + SysUser user = SecurityUtils.getLoginUser().getUser(); + Long userId = user.getUserId(); + + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,userId); + + return list(lqw); + } + + public Long getUserId(){ + ZInfoUser myself = zInfoUserService.getMyself(); + return myself.getUserId(); + + } + + 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); + } + + } + + @Override + public AjaxResult saveZa(ShareMore shareMore) { + Long [] shareIds = shareMore.getShareIds(); + Long [] shareContents = shareMore.getShareContents(); + for (Long shareId : shareIds) { + for (Long shareContent : shareContents) { + ZfShare za = new ZfShare(); + za.setUserId(getUserId()); + za.setShareContent(shareContent); + za.setShareId(shareId); + za.setSysMenuId(2021L); + addData(za); + } + } + // Long [] + // if(bl) + return AjaxResult.success("鍒嗕韩鎴愬姛!"); + } + + @Override + public AjaxResult listByFidAid(ShareMore shareMore, Integer pageNo, Integer pageSize) { + Long [] shareIds = shareMore.getShareIds(); + List<ZfContact> beanRecord3 = new ArrayList<>(); + for (Long shareId : shareIds) { + { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,shareId) + .eq(ZfShare::getSysMenuId,shareMore.getSysMenuId()) + .eq(ZfShare::getUserId, getUserId()); + List<ZfShare> beanRecords = list(lqw); + for (ZfShare beanRecord : beanRecords ) { + beanRecord3.add(zfContactService.getById(beanRecord.getShareContent())); + } + } + } + List<ZfContact> record = beanRecord3.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (beanRecord3.size() -1) / pageSize +1; + + Page<ZfContact> zfContactPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfContactPage, record,beanRecord3.size()); + + return AjaxResult.success(data); + } + + @Override + public AjaxResult deleteZa(ShareMore shareMore) { + Long [] shareIds = shareMore.getShareIds(); + Long [] shareContents = shareMore.getShareContents(); + for(Long shareId : shareIds) + for(Long shareContent: shareContents) + { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,shareId) + .eq(ZfShare::getShareContent, shareContent) + .eq(ZfShare::getSysMenuId, shareMore.getSysMenuId()) + .eq(ZfShare::getUserId, getUserId()); + + remove(lqw); + // addData(za); + } + return AjaxResult.success("鏁版嵁鏀跺洖鎴愬姛!"); + } + + @Override + public AjaxResult listByUserId() { + HashMap<Long,List<ZfContact>> bs = new HashMap<>(); + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,getUserId()); + lqw.eq(ZfShare::getSysMenuId,2021L); + List<ZfShare> beanRecords = list(lqw); + List<ZfContact> b1 = new ArrayList<>(); + for (ZfShare beanRecord : beanRecords ) { + b1.add(zfContactService.getById(beanRecord.getShareContent())); + bs.put(beanRecord.getUserId(),b1); + } + log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", bs); + return AjaxResult.success(bs); + } + + @Override + public AjaxResult listUserId(Integer pageNo, Integer pageSize) { + List<ZfContact> bs = new ArrayList<>(); + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,getUserId()); + lqw.eq(ZfShare::getSysMenuId,2021L); + List<ZfShare> beanRecords = list(lqw); + for (ZfShare beanRecord : beanRecords ) { + ZfContact bs2 = zfContactService.getById(beanRecord.getShareContent()); + bs2.setShareId(beanRecord.getUserId().intValue()); + bs.add(bs2); + } + log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", bs); + List<ZfContact> record = bs.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (bs.size() -1) / pageSize +1; + + Page<ZfContact> zfCollectionPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfCollectionPage, record,bs.size()); + return AjaxResult.success(data); + } + + @Override + public Long getShareId(ZfDownload zfDownload) { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId, zfDownload.getDownloadId()) + .eq(ZfShare::getShareContent, zfDownload.getDownloadContent()) + .eq(ZfShare::getSysMenuId, zfDownload.getSysMenuId()); + List<ZfShare> beanRecords = list(lqw); + if (beanRecords.size() != 0){ + return beanRecords.get(0).getUserId(); + } + else { + return null; + } + } +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEconomyDownlServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEconomyDownlServiceImpl.java new file mode 100644 index 0000000..e0ddf0e --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEconomyDownlServiceImpl.java @@ -0,0 +1,143 @@ +package com.ruoyi.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +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.utils.MapUtils; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.domain.ZInfoUser; +import com.ruoyi.domain.ZfContact; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfEconomy; +import com.ruoyi.mapper.ZfDownloadMapper; +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.*; +import java.util.stream.Collectors; + +@Service +@Slf4j +public class ZfEconomyDownlServiceImpl extends ServiceImpl<ZfDownloadMapper, ZfDownload> implements ZfEconomyDownlService { + @Resource + EsService esService; + + @Resource + ZfEconomyService zfEconomyService; + + @Resource + ZfEconomyShaService zfEconomyShaService; + + + @Resource + ZInfoUserService zInfoUserService; + + @Resource + private RestHighLevelClient restHighLevelClient; + + private LambdaQueryWrapper<ZfDownload> buildCondition(ZfDownload zfDownload, Long userId) { + LambdaQueryWrapper<ZfDownload> lqw = new LambdaQueryWrapper<>(); + lqw.in(ZfDownload::getDownloadId,userId); + lqw.orderByDesc(ZfDownload::getDownloadId); + lqw.like(zfDownload.getDownloadId() != null, ZfDownload::getDownloadId, zfDownload.getDownloadId()) + .like(zfDownload.getDownloadContent() != null, ZfDownload::getDownloadContent, zfDownload.getDownloadContent()) + .eq( ZfDownload::getSysMenuId, zfDownload.getSysMenuId()); + return lqw; + } + private LambdaQueryWrapper<ZfDownload> uniqueCondition(ZfDownload zfDownload) { + LambdaQueryWrapper<ZfDownload> lqw = new LambdaQueryWrapper<>(); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfDownload.getDownloadId())), ZfDownload::getDownloadId, zfDownload.getDownloadId()) + .eq(StringUtils.isNotEmpty(String.valueOf(zfDownload.getDownloadContent())), ZfDownload::getDownloadContent, zfDownload.getDownloadContent()) + .eq(ZfDownload::getSysMenuId, zfDownload.getSysMenuId()); + return lqw; + } + + public Long getUserId() { + ZInfoUser myself = zInfoUserService.getMyself(); + return myself.getUserId(); + } + @Override + public AjaxResult addData(ZfDownload zfDownload) { + zfDownload.setDownloadId(getUserId()); + LambdaQueryWrapper<ZfDownload> lqw = uniqueCondition(zfDownload); + List<ZfDownload> list = list(lqw); + if (list.size() > 0) { + throw new RuntimeException("璇峰嬁閲嶅涓嬭浇鏁版嵁"); + } + + zfDownload.setDownloadId(getUserId()); + zfDownload.setShareId(zfEconomyShaService.getShareId(zfDownload)); + if (save(zfDownload)) { + EsModel esModel = new EsModel(); + Integer inte = zfDownload.getId().intValue(); + String uuid = UUID.randomUUID().toString().replace("-", ""); + esModel.setId(uuid); + esModel.setCtId(Long.valueOf(inte)); + esModel.setCtTableName("瀹跺涵鏀舵敮鍙拌处"); + + esModel.setBy1(String.valueOf(zfDownload.getDownloadId())); + esModel.setBy2(String.valueOf(zfDownload.getDownloadContent())); + esModel.setBy3(String.valueOf(zfDownload.getShareId())); + //杩欓噷瀛樺偍鏌ヨ璇︽儏鐨勮矾寰� + esService.insertTable(esModel); + return AjaxResult.success(); + } else { + return AjaxResult.error(); + } + } + + @Override + public AjaxResult deleteData(Long[] ids) { + List<ZfDownload> zfDownloads = listByIds(Arrays.asList(ids)); + + if (zfEconomyShaService.removeByIds(Arrays.asList(ids))) { + + //鍒犻櫎es涓殑鏁版嵁 + zfDownloads.stream().forEach(zfDoctorDownload -> { + EsModel esModel = esService.findByCtId(zfDoctorDownload.getId().intValue(), "瀹跺涵鏀舵敮鍙拌处涓嬭浇"); + + if (esModel != null) { + DeleteRequest deleteRequest = new DeleteRequest("allsearchdata", esModel.getId()); + try { + restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT); + } catch (IOException e) { + throw new RuntimeException(e); + } + } + }); + return AjaxResult.success(); + } else { + return AjaxResult.error(); + } + } + + @Override + public AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo, Integer pageSize) { + ZInfoUser myself = zInfoUserService.getMyself(); + LambdaQueryWrapper<ZfDownload> lqw = buildCondition(zfDownload,myself.getUserId()); + List<ZfDownload> beanRecords = list(lqw); + List<ZfEconomy> bs = new ArrayList<>(); + for (ZfDownload a: beanRecords) { + if (zfEconomyService.getById(a.getDownloadContent()) != null) { + ZfEconomy ds = zfEconomyService.getById(a.getDownloadContent()); + ds.setShareId(a.getShareId().intValue()); + bs.add(ds); + } + } + List<ZfEconomy> record = bs.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (bs.size() -1) / pageSize +1; + + Page<ZfEconomy> zfEconomyPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfEconomyPage, record,bs.size()); + return AjaxResult.success(data); + } +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEconomySharServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEconomySharServiceImpl.java new file mode 100644 index 0000000..1ddc106 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEconomySharServiceImpl.java @@ -0,0 +1,187 @@ +package com.ruoyi.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +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.SysUser; +import com.ruoyi.common.utils.MapUtils; +import com.ruoyi.common.utils.SecurityUtils; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.domain.*; +import com.ruoyi.mapper.ZfShareMapper; +import com.ruoyi.service.*; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.stream.Collectors; + +@Slf4j +@Service +public class ZfEconomySharServiceImpl extends ServiceImpl<ZfShareMapper, ZfShare> implements ZfEconomyShaService { + @Resource + ZfEconomyService zfEconomyService; + + @Resource + private ZInfoUserService zInfoUserService; + + private LambdaQueryWrapper<ZfShare> uniqueCondition(ZfShare zfShare) { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getShareId())), ZfShare::getShareId, zfShare.getShareId()); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getShareContent())), ZfShare::getShareContent, zfShare.getShareContent()); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getSysMenuId())), ZfShare::getSysMenuId, zfShare.getSysMenuId()); + return lqw; + } + + @Override + public List<ZfShare> getAuthority() { + SysUser user = SecurityUtils.getLoginUser().getUser(); + Long userId = user.getUserId(); + + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,userId); + + return list(lqw); + } + + public Long getUserId(){ + ZInfoUser myself = zInfoUserService.getMyself(); + return myself.getUserId(); + + } + + 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); + } + + } + + @Override + public AjaxResult saveZa(ShareMore shareMore) { + Long [] shareIds = shareMore.getShareIds(); + Long [] shareContents = shareMore.getShareContents(); + for (Long shareId : shareIds) { + for (Long shareContent : shareContents) { + ZfShare za = new ZfShare(); + za.setUserId(getUserId()); + za.setShareContent(shareContent); + za.setShareId(shareId); + za.setSysMenuId(2023L); + addData(za); + } + } + // Long [] + // if(bl) + return AjaxResult.success("鍒嗕韩鎴愬姛!"); + } + + @Override + public AjaxResult listByFidAid(ShareMore shareMore, Integer pageNo, Integer pageSize) { + Long [] shareIds = shareMore.getShareIds(); + List<ZfEconomy> beanRecord3 = new ArrayList<>(); + for (Long shareId : shareIds) { + { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,shareId) + .eq(ZfShare::getSysMenuId,shareMore.getSysMenuId()) + .eq(ZfShare::getUserId, getUserId()); + List<ZfShare> beanRecords = list(lqw); + for (ZfShare beanRecord : beanRecords ) { + beanRecord3.add(zfEconomyService.getById(beanRecord.getShareContent())); + } + } + } + List<ZfEconomy> record = beanRecord3.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (beanRecord3.size() -1) / pageSize +1; + + Page<ZfEconomy> zfEconomyPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfEconomyPage, record,beanRecord3.size()); + + return AjaxResult.success(data); + } + + @Override + public AjaxResult deleteZa(ShareMore shareMore) { + Long [] shareIds = shareMore.getShareIds(); + Long [] shareContents = shareMore.getShareContents(); + for(Long shareId : shareIds) + for(Long shareContent: shareContents) + { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,shareId) + .eq(ZfShare::getShareContent, shareContent) + .eq(ZfShare::getSysMenuId, shareMore.getSysMenuId()) + .eq(ZfShare::getUserId, getUserId()); + + remove(lqw); + // addData(za); + } + return AjaxResult.success("鏁版嵁鏀跺洖鎴愬姛!"); + } + + @Override + public AjaxResult listByUserId() { + HashMap<Long,List<ZfEconomy>> bs = new HashMap<>(); + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,getUserId()); + lqw.eq(ZfShare::getSysMenuId,2023L); + List<ZfShare> beanRecords = list(lqw); + List<ZfEconomy> b1 = new ArrayList<>(); + for (ZfShare beanRecord : beanRecords ) { + b1.add(zfEconomyService.getById(beanRecord.getShareContent())); + bs.put(beanRecord.getUserId(),b1); + } + log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", bs); + return AjaxResult.success(bs); + } + + @Override + public AjaxResult listUserId(Integer pageNo, Integer pageSize) { + List<ZfEconomy> bs = new ArrayList<>(); + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,getUserId()); + lqw.eq(ZfShare::getSysMenuId,2023L); + List<ZfShare> beanRecords = list(lqw); + for (ZfShare beanRecord : beanRecords ) { + ZfEconomy bs2 = zfEconomyService.getById(beanRecord.getShareContent()); + bs2.setShareId(beanRecord.getUserId().intValue()); + bs.add(bs2); + } + log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", bs); + List<ZfEconomy> record = bs.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (bs.size() -1) / pageSize +1; + + Page<ZfEconomy> zfEconomyPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfEconomyPage, record,bs.size()); + return AjaxResult.success(data); + } + + @Override + public Long getShareId(ZfDownload zfDownload) { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId, zfDownload.getDownloadId()) + .eq(ZfShare::getShareContent, zfDownload.getDownloadContent()) + .eq(ZfShare::getSysMenuId, zfDownload.getSysMenuId()); + List<ZfShare> beanRecords = list(lqw); + if (beanRecords.size() != 0){ + return beanRecords.get(0).getUserId(); + } + else { + return null; + } + } +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEquipDownloadServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEquipDownloadServiceImpl.java new file mode 100644 index 0000000..abcbae7 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEquipDownloadServiceImpl.java @@ -0,0 +1,143 @@ +package com.ruoyi.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +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.utils.MapUtils; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.domain.ZInfoUser; +import com.ruoyi.domain.ZfDownload; +import com.ruoyi.domain.ZfEconomy; +import com.ruoyi.domain.ZfEquipment; +import com.ruoyi.mapper.ZfDownloadMapper; +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.*; +import java.util.stream.Collectors; + +@Slf4j +@Service +public class ZfEquipDownloadServiceImpl extends ServiceImpl<ZfDownloadMapper,ZfDownload> implements ZfEquipDownloadService { + @Resource + EsService esService; + + @Resource + ZfEquipShareServiceImpl zfEquipShareService; + + @Resource + ZfEquipmentService zfEquipmentService; + + + @Resource + ZInfoUserService zInfoUserService; + + @Resource + private RestHighLevelClient restHighLevelClient; + + private LambdaQueryWrapper<ZfDownload> buildCondition(ZfDownload zfDownload, Long userId) { + LambdaQueryWrapper<ZfDownload> lqw = new LambdaQueryWrapper<>(); + lqw.in(ZfDownload::getDownloadId,userId); + lqw.orderByDesc(ZfDownload::getDownloadId); + lqw.like(zfDownload.getDownloadId() != null, ZfDownload::getDownloadId, zfDownload.getDownloadId()) + .like(zfDownload.getDownloadContent() != null, ZfDownload::getDownloadContent, zfDownload.getDownloadContent()) + .eq( ZfDownload::getSysMenuId, zfDownload.getSysMenuId()); + return lqw; + } + private LambdaQueryWrapper<ZfDownload> uniqueCondition(ZfDownload zfDownload) { + LambdaQueryWrapper<ZfDownload> lqw = new LambdaQueryWrapper<>(); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfDownload.getDownloadId())), ZfDownload::getDownloadId, zfDownload.getDownloadId()) + .eq(StringUtils.isNotEmpty(String.valueOf(zfDownload.getDownloadContent())), ZfDownload::getDownloadContent, zfDownload.getDownloadContent()) + .eq(ZfDownload::getSysMenuId, zfDownload.getSysMenuId()); + return lqw; + } + + public Long getUserId() { + ZInfoUser myself = zInfoUserService.getMyself(); + return myself.getUserId(); + } + @Override + public AjaxResult addData(ZfDownload zfDownload) { + zfDownload.setDownloadId(getUserId()); + LambdaQueryWrapper<ZfDownload> lqw = uniqueCondition(zfDownload); + List<ZfDownload> list = list(lqw); + if (list.size() > 0) { + throw new RuntimeException("璇峰嬁閲嶅涓嬭浇鏁版嵁"); + } + + zfDownload.setDownloadId(getUserId()); + zfDownload.setShareId(zfEquipShareService.getShareId(zfDownload)); + if (save(zfDownload)) { + EsModel esModel = new EsModel(); + Integer inte = zfDownload.getId().intValue(); + String uuid = UUID.randomUUID().toString().replace("-", ""); + esModel.setId(uuid); + esModel.setCtId(Long.valueOf(inte)); + esModel.setCtTableName("瀹跺涵璁惧"); + + esModel.setBy1(String.valueOf(zfDownload.getDownloadId())); + esModel.setBy2(String.valueOf(zfDownload.getDownloadContent())); + esModel.setBy3(String.valueOf(zfDownload.getShareId())); + //杩欓噷瀛樺偍鏌ヨ璇︽儏鐨勮矾寰� + esService.insertTable(esModel); + return AjaxResult.success(); + } else { + return AjaxResult.error(); + } + } + + @Override + public AjaxResult deleteData(Long[] ids) { + List<ZfDownload> zfDownloads = listByIds(Arrays.asList(ids)); + + if (zfEquipShareService.removeByIds(Arrays.asList(ids))) { + + //鍒犻櫎es涓殑鏁版嵁 + zfDownloads.stream().forEach(zfDoctorDownload -> { + EsModel esModel = esService.findByCtId(zfDoctorDownload.getId().intValue(), "瀹跺涵璁惧涓嬭浇"); + + if (esModel != null) { + DeleteRequest deleteRequest = new DeleteRequest("allsearchdata", esModel.getId()); + try { + restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT); + } catch (IOException e) { + throw new RuntimeException(e); + } + } + }); + return AjaxResult.success(); + } else { + return AjaxResult.error(); + } + } + + @Override + public AjaxResult selectDoctorList(ZfDownload zfDownload, Integer pageNo, Integer pageSize) { + ZInfoUser myself = zInfoUserService.getMyself(); + LambdaQueryWrapper<ZfDownload> lqw = buildCondition(zfDownload,myself.getUserId()); + List<ZfDownload> beanRecords = list(lqw); + List<ZfEquipment> bs = new ArrayList<>(); + for (ZfDownload a: beanRecords) { + if (zfEquipmentService.getById(a.getDownloadContent()) != null) { + ZfEquipment ds = zfEquipmentService.getById(a.getDownloadContent()); + ds.setShareId(a.getShareId().intValue()); + bs.add(ds); + } + } + List<ZfEquipment> record = bs.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (bs.size() -1) / pageSize +1; + + Page<ZfEquipment> zfEquipmentPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfEquipmentPage, record,bs.size()); + return AjaxResult.success(data); + } +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEquipShareServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEquipShareServiceImpl.java new file mode 100644 index 0000000..ab87ba2 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEquipShareServiceImpl.java @@ -0,0 +1,190 @@ +package com.ruoyi.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +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.SysUser; +import com.ruoyi.common.utils.MapUtils; +import com.ruoyi.common.utils.SecurityUtils; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.domain.*; +import com.ruoyi.mapper.ZfShareMapper; +import com.ruoyi.service.ZInfoUserService; +import com.ruoyi.service.ZfEconomyService; +import com.ruoyi.service.ZfEquipShareService; +import com.ruoyi.service.ZfEquipmentService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.stream.Collectors; + +@Service +@Slf4j +public class ZfEquipShareServiceImpl extends ServiceImpl<ZfShareMapper, ZfShare> implements ZfEquipShareService { + @Resource + ZfEquipmentService zfEquipmentService; + + @Resource + private ZInfoUserService zInfoUserService; + + private LambdaQueryWrapper<ZfShare> uniqueCondition(ZfShare zfShare) { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getShareId())), ZfShare::getShareId, zfShare.getShareId()); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getShareContent())), ZfShare::getShareContent, zfShare.getShareContent()); + lqw.eq(StringUtils.isNotEmpty(String.valueOf(zfShare.getSysMenuId())), ZfShare::getSysMenuId, zfShare.getSysMenuId()); + return lqw; + } + + @Override + public List<ZfShare> getAuthority() { + SysUser user = SecurityUtils.getLoginUser().getUser(); + Long userId = user.getUserId(); + + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,userId); + + return list(lqw); + } + + public Long getUserId(){ + ZInfoUser myself = zInfoUserService.getMyself(); + return myself.getUserId(); + + } + + 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); + } + + } + + @Override + public AjaxResult saveZa(ShareMore shareMore) { + Long [] shareIds = shareMore.getShareIds(); + Long [] shareContents = shareMore.getShareContents(); + for (Long shareId : shareIds) { + for (Long shareContent : shareContents) { + ZfShare za = new ZfShare(); + za.setUserId(getUserId()); + za.setShareContent(shareContent); + za.setShareId(shareId); + za.setSysMenuId(2017L); + addData(za); + } + } + // Long [] + // if(bl) + return AjaxResult.success("鍒嗕韩鎴愬姛!"); + } + + @Override + public AjaxResult listByFidAid(ShareMore shareMore, Integer pageNo, Integer pageSize) { + Long [] shareIds = shareMore.getShareIds(); + List<ZfEquipment> beanRecord3 = new ArrayList<>(); + for (Long shareId : shareIds) { + { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,shareId) + .eq(ZfShare::getSysMenuId,shareMore.getSysMenuId()) + .eq(ZfShare::getUserId, getUserId()); + List<ZfShare> beanRecords = list(lqw); + for (ZfShare beanRecord : beanRecords ) { + beanRecord3.add(zfEquipmentService.getById(beanRecord.getShareContent())); + } + } + } + List<ZfEquipment> record = beanRecord3.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (beanRecord3.size() -1) / pageSize +1; + + Page<ZfEquipment> zfEquipmentPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfEquipmentPage, record,beanRecord3.size()); + + return AjaxResult.success(data); + } + + @Override + public AjaxResult deleteZa(ShareMore shareMore) { + Long [] shareIds = shareMore.getShareIds(); + Long [] shareContents = shareMore.getShareContents(); + for(Long shareId : shareIds) + for(Long shareContent: shareContents) + { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,shareId) + .eq(ZfShare::getShareContent, shareContent) + .eq(ZfShare::getSysMenuId, shareMore.getSysMenuId()) + .eq(ZfShare::getUserId, getUserId()); + + remove(lqw); + // addData(za); + } + return AjaxResult.success("鏁版嵁鏀跺洖鎴愬姛!"); + } + + @Override + public AjaxResult listByUserId() { + HashMap<Long,List<ZfEquipment>> bs = new HashMap<>(); + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,getUserId()); + lqw.eq(ZfShare::getSysMenuId,2017L); + List<ZfShare> beanRecords = list(lqw); + List<ZfEquipment> b1 = new ArrayList<>(); + for (ZfShare beanRecord : beanRecords ) { + b1.add(zfEquipmentService.getById(beanRecord.getShareContent())); + bs.put(beanRecord.getUserId(),b1); + } + log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", bs); + return AjaxResult.success(bs); + } + + @Override + public AjaxResult listUserId(Integer pageNo, Integer pageSize) { + List<ZfEquipment> bs = new ArrayList<>(); + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId,getUserId()); + lqw.eq(ZfShare::getSysMenuId,2017L); + List<ZfShare> beanRecords = list(lqw); + for (ZfShare beanRecord : beanRecords ) { + ZfEquipment bs2 = zfEquipmentService.getById(beanRecord.getShareContent()); + bs2.setShareId(beanRecord.getUserId().intValue()); + bs.add(bs2); + } + log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", bs); + List<ZfEquipment> record = bs.stream().skip((pageNo-1)*pageSize).limit(pageSize).collect(Collectors.toList()); + + int totalPage = (bs.size() -1) / pageSize +1; + + Page<ZfEquipment> zfEquipmentPage = new Page<>(pageNo, pageSize,totalPage); + HashMap<String, Object> data = MapUtils.getShareResult(zfEquipmentPage, record,bs.size()); + return AjaxResult.success(data); + } + + @Override + public Long getShareId(ZfDownload zfDownload) { + LambdaQueryWrapper<ZfShare> lqw = new LambdaQueryWrapper<>(); + lqw.eq(ZfShare::getShareId, zfDownload.getDownloadId()) + .eq(ZfShare::getShareContent, zfDownload.getDownloadContent()) + .eq(ZfShare::getSysMenuId, zfDownload.getSysMenuId()); + List<ZfShare> beanRecords = list(lqw); + if (beanRecords.size() != 0){ + return beanRecords.get(0).getUserId(); + } + else { + return null; + } + } +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfPetDownlServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfPetDownlServiceImpl.java new file mode 100644 index 0000000..53f4c04 --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfPetDownlServiceImpl.java @@ -0,0 +1,4 @@ +package com.ruoyi.service.impl; + +public class ZfPetDownlServiceImpl { +} diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfPetSharServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfPetSharServiceImpl.java new file mode 100644 index 0000000..c6ee98d --- /dev/null +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfPetSharServiceImpl.java @@ -0,0 +1,4 @@ +package com.ruoyi.service.impl; + +public class ZfPetSharServiceImpl { +} -- Gitblit v1.9.1