package com.panzhihua.service_community.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.Comparator;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.panzhihua.common.model.dtos.vaccines.EnrollUserByAppDTO;
|
import com.panzhihua.common.model.dtos.vaccines.VaccinesEnrollByAdminDTO;
|
import com.panzhihua.common.model.dtos.vaccines.VaccinesEnrollByAppDTO;
|
import com.panzhihua.common.model.dtos.vaccines.VaccinesEnrollUserByAppDTO;
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.common.model.vos.vaccines.VaccinesEnrollByAdminVO;
|
import com.panzhihua.common.model.vos.vaccines.VaccinesEnrollUserByAppVO;
|
import com.panzhihua.common.utlis.IdCard;
|
import com.panzhihua.common.utlis.StringUtils;
|
import com.panzhihua.service_community.dao.ComMngVaccinesDAO;
|
import com.panzhihua.service_community.dao.ComMngVaccinesEnrollRecordDAO;
|
import com.panzhihua.service_community.model.dos.ComMngVaccinesDO;
|
import com.panzhihua.service_community.model.dos.ComMngVaccinesEnrollRecordDO;
|
import com.panzhihua.service_community.service.ComMngVaccinesEnrollRecordService;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
/**
|
* @auther lyq
|
* @create 2021-05-19 14:17:53
|
* @describe 疫苗报名记录表服务实现类
|
*/
|
@Slf4j
|
@Service
|
public class ComMngVaccinesEnrollRecordServiceImpl
|
extends ServiceImpl<ComMngVaccinesEnrollRecordDAO, ComMngVaccinesEnrollRecordDO>
|
implements ComMngVaccinesEnrollRecordService {
|
|
@Resource
|
private ComMngVaccinesDAO comMngVaccinesDAO;
|
|
/**
|
* 小程序-疫苗类型对应家庭成员接种列表
|
*
|
* @return 疫苗类型对应家庭成员接种列表
|
*/
|
@Override
|
public R getVaccinesUserListByApp(VaccinesEnrollUserByAppDTO enrollUserByAppDTO) {
|
// 查询当前用户的家庭成员列表
|
List<VaccinesEnrollUserByAppVO> userLists = new ArrayList<>();
|
// 将自己的信息组装进家庭成员列表中
|
VaccinesEnrollUserByAppVO ownUser = this.baseMapper.getSysUser(enrollUserByAppDTO.getUserId());
|
if (ownUser != null) {
|
ownUser.setIsUser(1);
|
// 计算年龄
|
ownUser.setAge(IdCard.IdNOToAge(ownUser.getIdCard()));
|
userLists.add(ownUser);
|
}
|
List<VaccinesEnrollUserByAppVO> userList = this.baseMapper.getFamilyUserList(enrollUserByAppDTO.getUserId());
|
if (!userList.isEmpty()) {
|
userLists.addAll(userList);
|
}
|
|
if (!userLists.isEmpty()) {
|
userLists.forEach(user -> {
|
if (user.getIsUser() == null) {
|
user.setIsUser(2);
|
}
|
if (StringUtils.isEmpty(user.getJob())) {
|
user.setJob("暂无");
|
}
|
// 查询当前用户是否已经报名
|
ComMngVaccinesEnrollRecordDO enrollRecordDO =
|
this.baseMapper.selectOne(new QueryWrapper<ComMngVaccinesEnrollRecordDO>().lambda()
|
.eq(ComMngVaccinesEnrollRecordDO::getFamilyUserId, user.getUserId())
|
.eq(ComMngVaccinesEnrollRecordDO::getType, enrollUserByAppDTO.getVaccinesId())
|
.eq(ComMngVaccinesEnrollRecordDO::getFamilyUserType, user.getIsUser()));
|
if (enrollRecordDO != null) {
|
user.setIsEnroll(VaccinesEnrollUserByAppVO.isEnroll.yes);
|
} else {
|
user.setIsEnroll(VaccinesEnrollUserByAppVO.isEnroll.no);
|
}
|
});
|
}
|
|
List<VaccinesEnrollUserByAppVO> newUserLists = userLists.stream()
|
.sorted(Comparator.comparing(VaccinesEnrollUserByAppVO::getIsEnroll).reversed()
|
.thenComparing(Comparator.comparing(VaccinesEnrollUserByAppVO::getCreateAt).reversed()))
|
.collect(Collectors.toList());
|
return R.ok(newUserLists);
|
}
|
|
/**
|
* 用户疫苗报名
|
*
|
* @param enrollByAppDTO
|
* 请求参数
|
* @return 报名结果
|
*/
|
@Override
|
public R VaccinesEnrollByApp(VaccinesEnrollByAppDTO enrollByAppDTO) {
|
// 查询疫苗信息
|
ComMngVaccinesDO vaccinesDO = comMngVaccinesDAO.selectById(enrollByAppDTO.getVaccinesId());
|
if (vaccinesDO == null) {
|
return R.fail("未找到到疫苗信息");
|
}
|
List<ComMngVaccinesEnrollRecordDO> vaccinesEnrollRecordDOList = new ArrayList<>();
|
if (!enrollByAppDTO.getEnrollUserList().isEmpty()) {
|
for (EnrollUserByAppDTO userByAppDTO : enrollByAppDTO.getEnrollUserList()) {
|
ComMngVaccinesEnrollRecordDO enrollRecordDO =
|
this.baseMapper.selectOne(new QueryWrapper<ComMngVaccinesEnrollRecordDO>().lambda()
|
.eq(ComMngVaccinesEnrollRecordDO::getFamilyUserType, userByAppDTO.getIsUser())
|
.eq(ComMngVaccinesEnrollRecordDO::getFamilyUserId, userByAppDTO.getUserId())
|
.eq(ComMngVaccinesEnrollRecordDO::getUserId, enrollByAppDTO.getUserId())
|
.eq(ComMngVaccinesEnrollRecordDO::getType, enrollByAppDTO.getVaccinesId()));
|
if (enrollRecordDO != null) {
|
continue;
|
}
|
// 报名疫苗填充对象
|
ComMngVaccinesEnrollRecordDO vaccinesEnrollRecordDO = new ComMngVaccinesEnrollRecordDO();
|
if (userByAppDTO.getIsUser().equals(EnrollUserByAppDTO.isUser.yes)) {
|
// 如果是自己就查询自己的信息
|
VaccinesEnrollUserByAppVO enrollUserByAppVO =
|
this.baseMapper.getSysUser(enrollByAppDTO.getUserId());
|
if (enrollUserByAppVO != null) {
|
vaccinesEnrollRecordDO.setName(enrollUserByAppVO.getName());
|
vaccinesEnrollRecordDO.setIdCard(enrollUserByAppVO.getIdCard());
|
vaccinesEnrollRecordDO.setAge(enrollUserByAppVO.getAge());
|
vaccinesEnrollRecordDO.setPhone(enrollUserByAppVO.getPhone());
|
vaccinesEnrollRecordDO.setSex(IdCard.sex(enrollUserByAppVO.getIdCard()));
|
}
|
vaccinesEnrollRecordDO.setFamilyUserType(ComMngVaccinesEnrollRecordDO.familyUserType.mini);
|
} else {
|
VaccinesEnrollUserByAppVO enrollUserByAppVO =
|
this.baseMapper.getFamilyUser(userByAppDTO.getUserId());
|
if (enrollUserByAppVO != null) {
|
vaccinesEnrollRecordDO.setName(enrollUserByAppVO.getName());
|
vaccinesEnrollRecordDO.setIdCard(enrollUserByAppVO.getIdCard());
|
vaccinesEnrollRecordDO.setAge(enrollUserByAppVO.getAge());
|
vaccinesEnrollRecordDO.setPhone(enrollUserByAppVO.getPhone());
|
vaccinesEnrollRecordDO.setSex(IdCard.sex(enrollUserByAppVO.getIdCard()));
|
}
|
}
|
vaccinesEnrollRecordDO.setUserId(enrollByAppDTO.getUserId());
|
vaccinesEnrollRecordDO.setFamilyUserId(userByAppDTO.getUserId());
|
vaccinesEnrollRecordDO.setType(enrollByAppDTO.getVaccinesId());
|
vaccinesEnrollRecordDO.setCommunityId(enrollByAppDTO.getCommunityId());
|
vaccinesEnrollRecordDOList.add(vaccinesEnrollRecordDO);
|
}
|
}
|
if (!vaccinesEnrollRecordDOList.isEmpty()) {
|
this.saveBatch(vaccinesEnrollRecordDOList);
|
}
|
return R.ok();
|
}
|
|
/**
|
* 查询疫苗登记列表
|
*
|
* @param vaccinesByAdminDTO
|
* 请求参数
|
* @return 登记列表
|
*/
|
@Override
|
public R getVaccinesEnrollListByAdmin(VaccinesEnrollByAdminDTO vaccinesByAdminDTO) {
|
IPage<VaccinesEnrollByAdminVO> enrollByAdminVOIPage = this.baseMapper.getVaccinesEnrollListByAdmin(
|
new Page<VaccinesEnrollByAdminVO>(vaccinesByAdminDTO.getPageNum(), vaccinesByAdminDTO.getPageSize()),
|
vaccinesByAdminDTO);
|
if (!enrollByAdminVOIPage.getRecords().isEmpty()) {
|
for (VaccinesEnrollByAdminVO enroll : enrollByAdminVOIPage.getRecords()) {
|
if (enroll.getIdCard().length() != 18) {
|
enroll.setSex(3);
|
} else {
|
enroll.setSex(IdCard.sex(enroll.getIdCard()));
|
}
|
}
|
}
|
return R.ok(enrollByAdminVOIPage);
|
}
|
|
/**
|
* 根据条件导出疫苗登记记录
|
*
|
* @param vaccinesByAdminDTO
|
* 请求参数
|
* @return 导出登记列表
|
*/
|
@Override
|
public R exportVaccinesEnrollListByAdmin(VaccinesEnrollByAdminDTO vaccinesByAdminDTO) {
|
return R.ok(this.baseMapper.exportVaccinesEnrollListByAdmin(vaccinesByAdminDTO));
|
}
|
}
|
