package com.gkhy.exam.noncoalmine.service.impl;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.alibaba.fastjson2.TypeReference;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.gkhy.exam.noncoalmine.entity.NcCert;
|
import com.gkhy.exam.noncoalmine.mapper.NcCertMapper;
|
import com.gkhy.exam.noncoalmine.model.query.NcCertQuery;
|
import com.gkhy.exam.noncoalmine.model.vo.ExamPlanExaminee;
|
import com.gkhy.exam.noncoalmine.model.vo.ExamPlanInfo;
|
import com.gkhy.exam.noncoalmine.model.vo.ReturnCertVO;
|
import com.gkhy.exam.noncoalmine.model.vo.ReturnVO;
|
import com.gkhy.exam.noncoalmine.service.NcCertService;
|
import com.ruoyi.common.enums.HttpMethod;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.common.signature.SignatureUtils;
|
import com.ruoyi.common.utils.StringUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.List;
|
|
/**
|
* (NcCert)表服务实现类
|
*
|
* @author makejava
|
* @since 2023-09-15 17:14:35
|
*/
|
@Service("ncCertService")
|
public class NcCertServiceImpl extends ServiceImpl<NcCertMapper, NcCert> implements NcCertService {
|
@Autowired
|
private NcCertMapper ncCertMapper;
|
|
@Override
|
public List<NcCert> getList(NcCertQuery query) {
|
List<NcCert> ncCerts = ncCertMapper.selectList(new LambdaQueryWrapper<NcCert>()
|
.eq(NcCert::getDelFlag, (byte) 0)
|
.like(StringUtils.isNotEmpty(query.getName()), NcCert::getName, query.getName())
|
.eq(StringUtils.isNotEmpty(query.getIdcardNum()),NcCert::getIdcardNum,query.getIdcardNum())
|
);
|
return ncCerts;
|
}
|
|
@Override
|
public void syncCert(NcCertQuery query) {
|
if(StringUtils.isEmpty(query.getIdcardNum())){
|
throw new ServiceException("身份证号不能为空");
|
}
|
query.setIdcardTypeCode("01");
|
String bodyParam = JSON.toJSONString(query);
|
|
String json = SignatureUtils.getObject(bodyParam, "/api/v1/cert/query", HttpMethod.POST);
|
ReturnVO<List<ReturnCertVO>> returnVo = JSONObject.parseObject(json, new TypeReference<ReturnVO<List<ReturnCertVO>>>() {});
|
if(returnVo.getCode() == null || returnVo.getCode() != 200){
|
throw new ServiceException("拉取数据异常");
|
}
|
if(returnVo.getData() == null){
|
throw new ServiceException("无数据可更新");
|
}
|
//同步数据
|
List<ReturnCertVO> returnCertVOList = returnVo.getData();
|
if(!CollectionUtils.isEmpty(returnCertVOList)){
|
for (ReturnCertVO returnCertVo : returnCertVOList) {
|
NcCert ncCert = new NcCert();
|
BeanUtils.copyProperties(returnCertVo,ncCert);
|
ncCert.setCertId(returnCertVo.getId());
|
ncCert.setId(null);
|
ncCert.setDelFlag((byte) 0);
|
if(!isExsit(returnCertVo.getId())){
|
baseMapper.insert(ncCert);
|
}
|
}
|
}
|
}
|
|
@Override
|
public List<NcCert> getByIdCard(String idCard) {
|
List<NcCert> ncCerts = baseMapper.selectList(new LambdaQueryWrapper<NcCert>().eq(NcCert::getDelFlag, (byte) 0)
|
.eq(NcCert::getIdcardNum, idCard));
|
return ncCerts;
|
}
|
private boolean isExsit(Long certId){
|
NcCert ncCert = baseMapper.selectOne(new LambdaQueryWrapper<NcCert>()
|
.eq(NcCert::getDelFlag, (byte) 0)
|
.eq(NcCert::getCertId, certId));
|
if (ncCert != null){
|
return true;
|
}
|
return false;
|
}
|
}
|
