package jnpf.limsService.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import jnpf.base.service.SuperServiceImpl;
|
import jnpf.enums.LimsSampleEnum;
|
import jnpf.limsEntity.*;
|
import jnpf.limsMapper.LimsApplyTestMapper;
|
import jnpf.limsService.*;
|
import jnpf.util.DateUtil;
|
import jnpf.util.StringUtil;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.dao.EmptyResultDataAccessException;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.RequestBody;
|
|
import java.util.Comparator;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
@Service
|
public class LimsApplyTestServiceImpl extends SuperServiceImpl<LimsApplyTestMapper, LimsApplyTestEntity> implements LimsApplyTestService {
|
|
@Autowired
|
private LimsApplyTestItemService limsApplyTestItemService;
|
@Autowired
|
private LimsSampleInfoService limsSampleInfoService;
|
@Autowired
|
private LimsSamplingRecordService limsSamplingRecordService;
|
@Autowired
|
private LimsTestTaskService limsTestTaskService;
|
|
@Autowired
|
private JdbcTemplate jdbcTemplate;
|
|
/**
|
* 根据检验信息生成样品信息
|
* @param limsApplyTestEntity
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void createSampleInfo(LimsApplyTestEntity limsApplyTestEntity) {
|
|
LimsSampleInfoEntity limsSampleInfoEntity = new LimsSampleInfoEntity();
|
LimsSamplingRecordEntity limsSamplingRecordEntity = new LimsSamplingRecordEntity();
|
|
// 获取样品编号
|
String sampleCode = creatSampleCode();
|
limsApplyTestEntity.setSampleCode(sampleCode);
|
|
// 查询sampleId 是否有值 ，避免重复生成
|
String sampleId = limsApplyTestEntity.getSampleId();
|
if (StringUtil.isNotEmpty(sampleId)) {
|
limsSampleInfoEntity = limsSampleInfoService.getById(sampleId);
|
}
|
|
// 复制信息
|
BeanUtils.copyProperties(limsApplyTestEntity, limsSampleInfoEntity,"fId");
|
BeanUtils.copyProperties(limsApplyTestEntity, limsSamplingRecordEntity,"fId");
|
|
// 回写请检ID
|
limsSampleInfoEntity.setApplyId(limsApplyTestEntity.getId());
|
|
//获取对应流程信息
|
LimsSampleEnum sampleRecord = LimsSampleEnum.SAMPLE_RECORD;
|
// 请检已完成 状态为待取样
|
limsSampleInfoEntity.setSampleStatus(String.valueOf(sampleRecord.getCode()));
|
//limsSamplingRecordEntity.setApplyId(limsApplyTestEntity.getFId());
|
|
// 保存对应信息
|
limsSampleInfoService.save(limsSampleInfoEntity);
|
|
// 回写SampleId
|
limsSamplingRecordEntity.setSampleId(limsSampleInfoEntity.getId());
|
limsSamplingRecordService.save(limsSamplingRecordEntity);
|
|
// 请检已完成 回写SampleId
|
limsApplyTestEntity.setSampleId(limsSampleInfoEntity.getId());
|
limsApplyTestEntity.setApplyStatus("2");
|
this.updateById(limsApplyTestEntity);
|
|
// 生成对应的检验任务
|
LambdaQueryWrapper<LimsApplyTestItemEntity> itemQueryWrapper = new LambdaQueryWrapper<>();
|
itemQueryWrapper.eq(LimsApplyTestItemEntity::getFForeignId, limsApplyTestEntity.getId());
|
// 获取检验项目信息
|
List<LimsApplyTestItemEntity> itemList = limsApplyTestItemService.list(itemQueryWrapper);
|
// 赋值
|
List<LimsTestTaskEntity> taskEntityList = itemList.stream().map(item -> {
|
LimsTestTaskEntity limsTestTaskEntity = new LimsTestTaskEntity();
|
BeanUtils.copyProperties(item, limsTestTaskEntity, "id");
|
BeanUtils.copyProperties(limsApplyTestEntity, limsTestTaskEntity, "id");
|
limsTestTaskEntity.setCheckStatus(String.valueOf(sampleRecord.getItemCode()));
|
return limsTestTaskEntity;
|
}).collect(Collectors.toList());
|
|
// 将 null 值排在最后面
|
taskEntityList = taskEntityList.stream()
|
.sorted(Comparator.nullsLast(
|
Comparator.comparing(LimsTestTaskEntity::getItemSort)))
|
.collect(Collectors.toList());
|
|
// 保存信息
|
limsTestTaskService.saveBatch(taskEntityList);
|
}
|
|
public String creatSampleCode() {
|
String sql = "SELECT MAX(SAMPLE_CODE) FROM lims_sample_info";
|
|
String maxCode;
|
try {
|
maxCode = jdbcTemplate.queryForObject(sql, String.class);
|
} catch (EmptyResultDataAccessException e) {
|
maxCode = null;
|
}
|
|
// 获取年份
|
String year = DateUtil.getNow().split("-")[0];
|
|
if (StringUtil.isEmpty(maxCode)) {
|
maxCode = "SAMPLE-" + year + "-001";
|
} else {
|
// 判断是否为新的一年
|
if (year.equals(maxCode.split("-")[1])){
|
maxCode = "SAMPLE-" + year + "-" + String.format("%03d", Integer.parseInt(maxCode.split("-")[2] + 1));
|
} else {
|
maxCode = "SAMPLE-" + year + "-001";
|
}
|
}
|
return maxCode;
|
}
|
}
|
