package com.ruoyi.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
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.SecurityUtils;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.domain.*;
|
import com.ruoyi.mapper.ZfApplicationMapper;
|
import com.ruoyi.service.*;
|
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.*;
|
|
|
@Service
|
public class ZfApplicationServiceImpl extends ServiceImpl<ZfApplicationMapper, ZfApplication> implements ZfApplicationService {
|
|
@Resource
|
ZInfoUserService zInfoUserService;
|
|
|
@Resource
|
EsService esService;
|
|
@Resource
|
private RestHighLevelClient restHighLevelClient;
|
|
|
|
|
|
@Override
|
public AjaxResult selectDoctorList(ZfApplication zfApplication, Integer pageNum, Integer pageSize,Integer roleId) {
|
|
//要查自己家庭的
|
ZInfoUser myself = zInfoUserService.getMyself();
|
System.out.println("[[[[[[[[["+myself);
|
if (myself !=null) {
|
System.out.println("iiiiiii"+myself.getClanId());
|
zfApplication.setClanId(myself.getClanId());
|
if (roleId != 1) zfApplication.setApplicant(myself.getSysId().intValue());
|
}
|
|
|
LambdaQueryWrapper<ZfApplication> lqw = buildCondition(zfApplication);
|
Page<ZfApplication> zfDoctorPage = new Page<>(pageNum, pageSize);
|
Page<ZfApplication> pageResult = page(zfDoctorPage, lqw);
|
List<ZfApplication> beanRecords = pageResult.getRecords();//得到查询出来的数据
|
|
HashMap<String, Object> data = MapUtils.getResult(pageResult, beanRecords);
|
return AjaxResult.success(data);
|
}
|
|
@Override
|
public List<ZfApplication> selectByCondition(ZfApplication zfApplication) {
|
LambdaQueryWrapper<ZfApplication> lambdaQueryWrapper = buildCondition(zfApplication);
|
List<ZfApplication> beanRecords = list(lambdaQueryWrapper);
|
return beanRecords;
|
}
|
|
@Override
|
public List<ZfApplication> selectByIds(Long[] ids) {
|
List<ZfApplication> list = new ArrayList<>();
|
if (ids.length != 0)
|
list = listByIds(Arrays.asList(ids));
|
else
|
list = list();
|
return list;
|
}
|
|
|
|
@Override
|
public AjaxResult addData(ZfApplication zfApplication) {
|
ZInfoUser myself = zInfoUserService.getMyself();
|
|
Long userId = SecurityUtils.getUserId();
|
|
if (myself !=null) {
|
zfApplication.setClanId(myself.getClanId());
|
}
|
|
Date currentDate = new Date();
|
|
zfApplication.setApplicant(userId.intValue());
|
zfApplication.setStatus("0");
|
zfApplication.setCreateTime(currentDate);
|
if (save(zfApplication)) {
|
EsModel esModel = new EsModel();
|
Integer inte = zfApplication.getId();
|
String uuid = UUID.randomUUID().toString().replace("-", "");
|
esModel.setId(uuid);
|
esModel.setCtId(Long.valueOf(inte));
|
esModel.setCtTableName("申请表");
|
esModel.setBy2(zfApplication.getApplyReason());
|
//这里存储查询详情的路径
|
esService.insertTable(esModel);
|
return AjaxResult.success();
|
} else {
|
return AjaxResult.error();
|
}
|
}
|
|
|
|
@Override
|
public AjaxResult deleteData(Long[] ids) {
|
|
List<ZfApplication> zfDoctors = listByIds(Arrays.asList(ids));
|
|
if (this.removeByIds(Arrays.asList(ids))) {
|
|
//删除es中的数据
|
zfDoctors.stream().forEach(zfDoctor -> {
|
EsModel esModel = esService.findByCtId(zfDoctor.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 setStatus(ZfApplication zfApplication)
|
{
|
Date currentDate = new Date();
|
System.out.println("[[[[[[["+zfApplication);
|
|
LambdaUpdateWrapper<ZfApplication> lqw = new LambdaUpdateWrapper();
|
lqw
|
.eq(ZfApplication::getId,zfApplication.getId())
|
.set(ZfApplication::getStatus,zfApplication.getStatus())
|
.set(ZfApplication::getCreateTime, currentDate);
|
|
|
boolean isUpdated = this.update(lqw); // 使用Service执行更新
|
|
if (isUpdated) {
|
if (zfApplication.getStatus().equals("1"))
|
return AjaxResult.success("已经给该用户延长试用时间");
|
else return AjaxResult.success("已驳回该用户的申请");
|
} else {
|
return AjaxResult.error("更新失败，请检查数据");
|
}
|
}
|
|
|
private LambdaQueryWrapper<ZfApplication> uniqueCondition(ZfApplication zfApplication) {
|
LambdaQueryWrapper<ZfApplication> lqw = new LambdaQueryWrapper<>();
|
lqw.eq(zfApplication.getApplicant() != null,ZfApplication::getApplicant, zfApplication.getApplicant())
|
.eq(StringUtils.isNotEmpty(zfApplication.getApplyReason()), ZfApplication::getApplyReason, zfApplication.getApplyReason())
|
.eq(zfApplication.getStatus() != null, ZfApplication::getStatus, zfApplication.getStatus())
|
.eq(zfApplication.getClanId() != null, ZfApplication::getClanId, zfApplication.getClanId())
|
.eq(zfApplication.getApplyDay() != null, ZfApplication::getApplyDay, zfApplication.getApplyDay());
|
return lqw;
|
}
|
|
private LambdaQueryWrapper<ZfApplication> buildCondition(ZfApplication zfApplication) {
|
LambdaQueryWrapper<ZfApplication> lqw = new LambdaQueryWrapper<>();
|
lqw.orderByDesc(ZfApplication::getCreateTime);
|
lqw.like(zfApplication.getApplicant() !=null,ZfApplication::getApplicant, zfApplication.getApplicant())
|
.like(StringUtils.isNotEmpty(zfApplication.getApplyReason()), ZfApplication::getApplyReason, zfApplication.getApplyReason())
|
.like(zfApplication.getStatus() != null, ZfApplication::getStatus, zfApplication.getStatus())
|
.like(zfApplication.getClanId() != null, ZfApplication::getClanId, zfApplication.getClanId())
|
.like(zfApplication.getApplyDay() != null, ZfApplication::getApplyDay, zfApplication.getApplyDay())
|
.like(zfApplication.getId() != null, ZfApplication::getId, zfApplication.getId())
|
;
|
|
return lqw;
|
}
|
}
|
