package jnpf.limsService.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import jnpf.audit.sdk.annotation.AuditLog;
|
import jnpf.base.service.SuperServiceImpl;
|
import jnpf.exception.DataException;
|
import jnpf.limsEntity.LimsShebeiYiqiJiliangEntity;
|
import jnpf.limsEntity.LimsShebeiYiqiXinxiEntity;
|
import jnpf.limsEntity.LimsShebeiYiqiYanzhengEntity;
|
import jnpf.limsMapper.LimsShebeiYiqiJiliangMapper;
|
import jnpf.limsMapper.LimsShebeiYiqiXinxiMapper;
|
import jnpf.limsMapper.LimsShebeiYiqiYanzhengMapper;
|
import jnpf.limsService.LimsShebeiYiqiXinxiService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.LinkedHashSet;
|
import java.util.List;
|
import java.util.Set;
|
|
@Service
|
public class LimsShebeiYiqiXinxiServiceImpl
|
extends SuperServiceImpl<LimsShebeiYiqiXinxiMapper, LimsShebeiYiqiXinxiEntity>
|
implements LimsShebeiYiqiXinxiService {
|
|
private static final String BIZ_STATUS_YIBAOFEI = "yibaofei";
|
private static final String XINGNENG_ZHUANGTAI_ZHUNYONG = "zhunyong";
|
@Autowired
|
private LimsShebeiYiqiYanzhengMapper limsShebeiYiqiYanzhengMapper;
|
|
@Autowired
|
private LimsShebeiYiqiJiliangMapper limsShebeiYiqiJiliangMapper;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@AuditLog(action = "SCRAP", label = "仪器报废", bizType = "SHEBEI_YIQI",
|
bizCodeExpr = "#yiqiId", bizCodeRequired = false, targetTable = "lims_shebei_yiqi_xinxi",
|
targetIdExpr = "#yiqiId", diff = true, entityClass = LimsShebeiYiqiXinxiEntity.class)
|
public void baofei(String yiqiId) throws DataException {
|
String id = trimToEmpty(yiqiId);
|
if (id.isEmpty()) {
|
throw new DataException("仪器ID(yiqi_id)不能为空");
|
}
|
|
LimsShebeiYiqiXinxiEntity yiqi = this.getById(id);
|
if (yiqi == null) {
|
throw new DataException("仪器信息不存在：" + id);
|
}
|
|
LimsShebeiYiqiXinxiEntity update = new LimsShebeiYiqiXinxiEntity();
|
update.setId(id);
|
update.setBizStatus(BIZ_STATUS_YIBAOFEI);
|
if (!this.updateById(update)) {
|
throw new DataException("仪器报废失败，请刷新后重试");
|
}
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@AuditLog(action = "ENABLE", label = "仪器批量启用", bizType = "SHEBEI_YIQI",
|
bizCodeExpr = "", bizCodeRequired = false, targetTable = "lims_shebei_yiqi_xinxi",
|
targetIdExpr = "#yiqiIds[0]", diff = true,
|
entityClass = LimsShebeiYiqiXinxiEntity.class)
|
public int qiyong(List<String> yiqiIds) throws DataException {
|
List<String> ids = normalizeIds(yiqiIds);
|
if (ids.isEmpty()) {
|
throw new DataException("仪器ID列表(yiqi_ids)不能为空");
|
}
|
|
LimsShebeiYiqiXinxiEntity update = new LimsShebeiYiqiXinxiEntity();
|
update.setXingnengZhuangtai(XINGNENG_ZHUANGTAI_ZHUNYONG);
|
LambdaUpdateWrapper<LimsShebeiYiqiXinxiEntity> wrapper = new LambdaUpdateWrapper<>();
|
wrapper.in(LimsShebeiYiqiXinxiEntity::getId, ids);
|
int updated = this.baseMapper.update(update, wrapper);
|
if (updated <= 0) {
|
throw new DataException("未找到可启用的仪器信息");
|
}
|
return updated;
|
}
|
|
@Override
|
public void checkTodayJiaoyan(String yiqiId, LocalDateTime jiaoyanShijian) throws DataException {
|
String id = trimToEmpty(yiqiId);
|
if (id.isEmpty()) {
|
throw new DataException("仪器ID(yiqi_id)不能为空");
|
}
|
if (jiaoyanShijian == null) {
|
throw new DataException("校准时间(jiaoyan_shijian)不能为空");
|
}
|
|
LocalDateTime startTime = jiaoyanShijian.toLocalDate().atStartOfDay();
|
LocalDateTime endTime = startTime.plusDays(1);
|
if (this.baseMapper.existsTodayJiaoyan(id, startTime, endTime)) {
|
throw new DataException("该仪器设备今日已校准过，不需要重复校准！");
|
}
|
}
|
|
@Override
|
public void checkShiyong(String yiqiId) throws DataException {
|
String id = trimToEmpty(yiqiId);
|
if (id.isEmpty()) {
|
throw new DataException("仪器ID(yiqi_id)不能为空");
|
}
|
|
LocalDateTime startTime = LocalDate.now().atStartOfDay();
|
LocalDateTime endTime = startTime.plusDays(1);
|
if (this.baseMapper.requiresTodayJiaoyan(id, startTime, endTime)) {
|
throw new DataException("该仪器设备今日需要校准，请进行日常校准！");
|
}
|
if (this.baseMapper.existsUsingYiqi(id)) {
|
throw new DataException("该仪器设备正在使用，请稍后！");
|
}
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@AuditLog(action = "VERIFY_CONFIRM", label = "确认仪器验证", bizType = "SHEBEI_YIQI",
|
bizCodeExpr = "#yanzhengId", bizCodeRequired = false, targetTable = "lims_shebei_yiqi_xinxi",
|
targetIdExpr = "T(jnpf.limsService.support.LimsAuditTargetIds).yiqiByVerification(#yanzhengId)",
|
diff = true, entityClass = LimsShebeiYiqiXinxiEntity.class)
|
public void confirmYanzheng(String yanzhengId) throws DataException {
|
String id = trimToEmpty(yanzhengId);
|
if (id.isEmpty()) {
|
throw new DataException("仪器验证ID(yanzheng_id)不能为空");
|
}
|
|
LimsShebeiYiqiYanzhengEntity yanzheng = limsShebeiYiqiYanzhengMapper.selectById(id);
|
if (yanzheng == null) {
|
throw new DataException("仪器验证记录不存在：" + id);
|
}
|
|
LimsShebeiYiqiXinxiEntity update = new LimsShebeiYiqiXinxiEntity();
|
update.setShangciYanzhengShijian(yanzheng.getShangciYanzhengShijian());
|
update.setXiaciYanzhengShijian(yanzheng.getXiaciYanzhengShijian());
|
update.setYanzhengZhouqi(yanzheng.getYanzhengZhouqi());
|
update.setYanzhengShijianDanwei(yanzheng.getYanzhengShijianDanwei());
|
update.setTiqianTixingShijian(yanzheng.getTiqianTixingShijian());
|
update.setTixingShijianDanwei(yanzheng.getTixingShijianDanwei());
|
update.setYanzhengTixingRiqi(yanzheng.getYanzhengTixingRiqi());
|
updateYiqiXinxi(yanzheng.getYiqiId(), update, id, "仪器验证记录");
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
@AuditLog(action = "MEASURE_CONFIRM", label = "确认仪器计量", bizType = "SHEBEI_YIQI",
|
bizCodeExpr = "#jiliangId", bizCodeRequired = false, targetTable = "lims_shebei_yiqi_xinxi",
|
targetIdExpr = "T(jnpf.limsService.support.LimsAuditTargetIds).yiqiByMeasurement(#jiliangId)",
|
diff = true, entityClass = LimsShebeiYiqiXinxiEntity.class)
|
public void confirmJiliang(String jiliangId) throws DataException {
|
String id = trimToEmpty(jiliangId);
|
if (id.isEmpty()) {
|
throw new DataException("仪器计量ID(jiliang_id)不能为空");
|
}
|
|
LimsShebeiYiqiJiliangEntity jiliang = limsShebeiYiqiJiliangMapper.selectById(id);
|
if (jiliang == null) {
|
throw new DataException("仪器计量记录不存在：" + id);
|
}
|
|
LimsShebeiYiqiXinxiEntity update = new LimsShebeiYiqiXinxiEntity();
|
update.setShangciJiliangShijian(jiliang.getShangciJiliangShijian());
|
update.setXiaciJiliangShijian(jiliang.getXiaciJiliangShijian());
|
update.setJiliangZhouqi(jiliang.getJiliangZhouqi());
|
update.setJiliangShijianDanwei(jiliang.getJiliangShijianDanwei());
|
update.setTiqianTixingShijian(jiliang.getTiqianTixingShijian());
|
update.setTixingShijianDanwei(jiliang.getTixingShijianDanwei());
|
update.setJiliangTixingRiqi(jiliang.getJiliangTixingRiqi());
|
updateYiqiXinxi(jiliang.getYiqiId(), update, id, "仪器计量记录");
|
}
|
|
private void updateYiqiXinxi(String yiqiId, LimsShebeiYiqiXinxiEntity update,
|
String recordId, String recordDescription) throws DataException {
|
yiqiId = trimToEmpty(yiqiId);
|
if (yiqiId.isEmpty()) {
|
throw new DataException(recordDescription + "未关联仪器(yiqi_id)：" + recordId);
|
}
|
if (this.getById(yiqiId) == null) {
|
throw new DataException("关联仪器信息不存在：" + yiqiId);
|
}
|
|
update.setId(yiqiId);
|
if (!this.updateById(update)) {
|
throw new DataException(recordDescription + "同步仪器信息失败，请刷新后重试");
|
}
|
}
|
|
private List<String> normalizeIds(List<String> yiqiIds) {
|
Set<String> ids = new LinkedHashSet<>();
|
if (yiqiIds == null) {
|
return new ArrayList<>(ids);
|
}
|
for (String yiqiId : yiqiIds) {
|
String id = trimToEmpty(yiqiId);
|
if (!id.isEmpty()) {
|
ids.add(id);
|
}
|
}
|
return new ArrayList<>(ids);
|
}
|
|
private String trimToEmpty(String value) {
|
return value == null ? "" : value.trim();
|
}
|
|
}
|
