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.Meeting;
|
import com.ruoyi.domain.ZInfoUser;
|
import com.ruoyi.domain.ZfLog;
|
import com.ruoyi.mapper.MeetingRatifyMapper;
|
import com.ruoyi.service.*;
|
import lombok.extern.slf4j.Slf4j;
|
import org.elasticsearch.action.update.UpdateRequest;
|
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.time.LocalDateTime;
|
import java.util.HashMap;
|
import java.util.List;
|
|
@Slf4j
|
@Service
|
public class MeetingRatifyServiceImpl extends ServiceImpl<MeetingRatifyMapper, Meeting> implements MeetingRatifyService {
|
|
@Resource
|
ZInfoUserService zInfoUserService;
|
|
@Resource
|
ZfLogService zfLogService;
|
|
@Resource
|
private EsService esSer;
|
|
@Resource
|
private RestHighLevelClient restHighLevelClient;
|
|
private LambdaQueryWrapper<Meeting> buildCondition(Meeting meeting) {
|
LambdaQueryWrapper<Meeting> lqw = new LambdaQueryWrapper<>();
|
// lqw.in(ZfDoctor::getFamilyId,familyIdList);
|
lqw.orderByDesc(Meeting::getId);
|
lqw.like(StringUtils.isNotEmpty(meeting.getPlace()), Meeting::getPlace, meeting.getPlace())
|
.like(StringUtils.isNotEmpty(meeting.getApplyApart()), Meeting::getApplyApart, meeting.getApplyApart());
|
// .like(Integer.valueOf(meeting.getApplyPerson())!=null, Meeting::getApplyPerson, meeting.getApplyPerson());
|
lqw.between(meeting.getHappenStartTime() != null && meeting.getHappenEndTime() != null, Meeting::getStartTime, meeting.getHappenStartTime(), meeting.getHappenEndTime());
|
|
return lqw;
|
}
|
|
|
@Override
|
public AjaxResult selectDataList(Meeting meeting, Integer pageNum, Integer pageSize) {
|
//要查自己家庭的
|
ZInfoUser myself = zInfoUserService.getMyself();
|
if(myself==null)
|
{
|
// System.out.println("ssssss");
|
return AjaxResult.success("您没加入到对应的家庭，请联系管理员");
|
}
|
Long familyId = myself.getFamilyId();
|
// //也要查别人授权的
|
// List<ZAuthority> authority = zAuthorityService.getAuthority();
|
// List<Long> idList = authority.stream().filter(auth -> auth.getAuthority().toString().equals(DOCTOR_LIST)).map(ZAuthority::getFid).collect(Collectors.toList());
|
// //加上自己家庭的id
|
// idList.add(familyId);
|
// String familyIds = listFamilyIds();
|
// String secondFamilyAuthority = listSecondFamilyIds();
|
LambdaQueryWrapper<Meeting> lqw = buildCondition(meeting);
|
|
|
Page<Meeting> meetingPage = new Page<>(pageNum, pageSize);
|
Page<Meeting> pageResult = page(meetingPage, lqw);
|
|
List<Meeting> beanRecords = pageResult.getRecords();//得到查询出来的数据
|
// System.out.println(beanRecords);
|
|
|
|
HashMap<String, Object> data = MapUtils.getResult(pageResult, beanRecords);
|
return AjaxResult.success(data); }
|
|
|
@Override
|
public AjaxResult updateData(Meeting meeting) {
|
|
ZfLog zfLog = new ZfLog();
|
zfLog.setUpdateTime(LocalDateTime.now());
|
zfLog.setModule("会议审批");
|
zfLog.setUpdater(zInfoUserService.getMyself().getNickName());
|
zfLogService.save(zfLog);
|
|
if (updateById(meeting)) {
|
//到数据库中查询对应的数据
|
Meeting dataById = getById(meeting.getId());
|
|
//先到es中查询到对应那条数据在es的id
|
EsModel esResult = esSer.findByCtId(dataById.getId().intValue(), "会议审批");
|
// System.out.println("====================================" + meeting);
|
if (esResult == null) {
|
return AjaxResult.success();
|
}
|
|
//操作es修改数据
|
EsModel newModel = new EsModel();
|
if (meeting.getStatu() != 0) {
|
newModel.setBy13(meeting.getStatu());
|
} else {
|
newModel.setBy13(dataById.getStatu());
|
}
|
|
UpdateRequest updateRequest = new UpdateRequest("allsearchdata", esResult.getId());
|
updateRequest.doc(
|
"by12", newModel.getBy13()
|
);
|
try {
|
restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);
|
} catch (IOException e) {
|
throw new RuntimeException(e);
|
}
|
|
return AjaxResult.success();
|
} else {
|
return AjaxResult.error();
|
}
|
}}
|
