基于Java语言的爱心助学志愿服务平台设计源码

package com.sicau.recruit.service.impl; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.IdWorker; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.sicau.commonUtils.utils.ESUtil; import com.sicau.commonUtils.utils.JwtUtil; import com.sicau.commonUtils.utils.PageUtil; import com.sicau.commonUtils.vo.PageVO; import com.sicau.commonUtils.vo.RecruitmentInnerDetailVO; import com.sicau.commonUtils.vo.UserInnerVO; import com.sicau.recruit.client.UserClient; import com.sicau.recruit.entity.enums.recruitment.PostStatusEnum; import com.sicau.recruit.entity.enums.recruitment.RecruitStatusEnum; import com.sicau.recruit.entity.params.recruitment.RecruitmentFrontPageParams; import com.sicau.recruit.entity.params.recruitment.RecruitmentPageParams; import com.sicau.recruit.entity.params.recruitment.RecruitmentPostParams; import com.sicau.recruit.entity.params.recruitment.RecruitmentUpdateParams; import com.sicau.recruit.entity.po.RecruitmentContent; import com.sicau.recruit.entity.po.TeachingSupport; import com.sicau.recruit.entity.vo.recrutitment.RecruitmentDocumentVO; import com.sicau.recruit.entity.vo.recrutitment.RecruitmentFrontDetailVO; import com.sicau.recruit.entity.vo.recrutitment.RecruitmentFrontPageVO; import com.sicau.recruit.entity.vo.recrutitment.RecruitmentPageVO; import com.sicau.recruit.mapper.RecruitmentContentMapper; import com.sicau.recruit.mapper.TeachingSupportMapper; import com.sicau.recruit.service.TeachingSupportService; import com.sicau.serviceBase.CodeEnum; import com.sicau.serviceBase.exceptionHandler.GlobalRunTimeException; import org.elasticsearch.action.delete.DeleteRequest; import org.elasticsearch.action.delete.DeleteResponse; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.search.SearchRequest; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.update.UpdateRequest; import org.elasticsearch.action.update.UpdateResponse; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.common.text.Text; import org.elasticsearch.common.unit.TimeValue; import org.elasticsearch.common.xcontent.XContentType; import org.elasticsearch.index.query.MatchPhraseQueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.index.query.TermQueryBuilder; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.SearchHits; import org.elasticsearch.search.builder.SearchSourceBuilder; import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder; import org.elasticsearch.search.fetch.subphase.highlight.HighlightField; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.ObjectUtils; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.io.IOException; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; /** * <p> * 服务实现类 * </p> * * @author jay * @since 2022-02-26 */ @Service public class TeachingSupportServiceImpl extends ServiceImpl<TeachingSupportMapper, TeachingSupport> implements TeachingSupportService { @Resource private TeachingSupportMapper teachingSupportMapper; @Resource private RecruitmentContentMapper recruitmentContentMapper; @Autowired private UserClient userClient; @Autowired private RestHighLevelClient restHighLevelClient; @Override public void postSupport(RecruitmentPostParams recruitmentPostParams, HttpServletRequest request) { TeachingSupport teachingSupport = new TeachingSupport(); BeanUtils.copyProperties(recruitmentPostParams,teachingSupport); teachingSupport.setPostStatus(PostStatusEnum.REVIEWING.type); teachingSupport.setCreator(JwtUtil.getMemberIdByJwtToken(request)); RecruitmentContent recruitmentContent = new RecruitmentContent(); BeanUtils.copyProperties(recruitmentPostParams,recruitmentContent); long id = IdWorker.getId(); QueryWrapper<TeachingSupport> queryWrapper = new QueryWrapper<TeachingSupport>() .eq("teaching_support_title", recruitmentPostParams.getTeachingSupportTitle()); teachingSupport.setId(id); recruitmentContent.setId(id); if (0 != teachingSupportMapper.selectCount(queryWrapper)){ throw new GlobalRunTimeException(CodeEnum.FAIL.getType(), "标题重复,请重新输入"); } //将数据存储到ES中 try { IndexRequest indexRequest = new IndexRequest("teaching_support"); RecruitmentDocumentVO recruitmentDocumentVO = new RecruitmentDocumentVO(); BeanUtils.copyProperties(recruitmentPostParams,recruitmentDocumentVO); recruitmentDocumentVO.setId(String.valueOf(id)); recruitmentDocumentVO.setCreateTime(new Date()); indexRequest.timeout(TimeValue.timeValueMillis(1000)); indexRequest.id(String.valueOf(id)); indexRequest.source(JSON.toJSONString(recruitmentDocumentVO), XContentType.JSON); restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT); restHighLevelClient.close(); } catch (IOException e) { e.printStackTrace(); } if (0 == teachingSupportMapper.insert(teachingSupport)){ throw new GlobalRunTimeException(CodeEnum.FAIL.getType(),"添加招募信息失败"); } recruitmentContentMapper.insert(recruitmentContent); } @Override public void deleteSupportAndContentById(Long id) { try { DeleteRequest request = new DeleteRequest("teaching_support", id.toString()); request.timeout("1s"); restHighLevelClient.delete(request, RequestOptions.DEFAULT); } catch (IOException e) { e.printStackTrace(); } int result1 = teachingSupportMapper.deleteById(id); int result2 = recruitmentContentMapper.deleteById(id); if (result1 == 0 || result2 == 0) { throw new GlobalRunTimeException(CodeEnum.FAIL.getType(),"删除异常，请重试"); } } @Override public void updateSupportById(RecruitmentUpdateParams recruitmentUpdateParams) { TeachingSupport teachingSupport = new TeachingSupport(); BeanUtils.copyProperties(recruitmentUpdateParams,teachingSupport); RecruitmentContent recruitmentContent = new RecruitmentContent(); BeanUtils.copyProperties(recruitmentUpdateParams,recruitmentContent); int result1 = teachingSupportMapper.updateById(teachingSupport); int result2 = recruitmentContentMapper.updateById(recruitmentContent); try { UpdateRequest request = new UpdateRequest("teaching_support", recruitmentUpdateParams.getId().toString()); RecruitmentDocumentVO recruitmentDocumentVO = new RecruitmentDocumentVO(); BeanUtils.copyProperties(recruitmentUpdateParams,recruitmentDocumentVO); recruitmentDocumentVO.setId(recruitmentUpdateParams.getId().toString()); recruitmentDocumentVO.setCreateTime(new Date()); request.doc(JSON.toJSONString(recruitmentDocumentVO),XContentType.JSON); restHighLevelClient.update(request, RequestOptions.DEFAULT); } catch (IOException e) { e.printStackTrace(); } if (result1 == 0 || result2 == 0) { throw new GlobalRunTimeException(CodeEnum.FAIL.ge