package jnpf.limsController;
|
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import jnpf.exception.DataException;
|
import jnpf.limsEntity.BizStatus;
|
import jnpf.limsEntity.LimsQingyandanEntity;
|
import jnpf.limsEntity.LimsSignEntity;
|
import jnpf.limsEntity.LimsSignUsageTarget;
|
import jnpf.limsEntity.SignOpType;
|
import jnpf.limsService.LimsQingyandanService;
|
import jnpf.limsService.LimsSignService;
|
import jnpf.util.R;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.Collections;
|
import java.util.Map;
|
|
@Slf4j
|
@Tag(name = "lims请验单接口", description = "请验单提交 / 撤回 / 废弃 / 编辑")
|
@RestController
|
@RequestMapping("/lims/biz")
|
public class LimsQingyandanController {
|
|
@Autowired
|
private LimsQingyandanService limsQingyandanService;
|
@Autowired
|
private LimsSignService limsSignService;
|
|
/**
|
* 成品请验单提交 -> 复制数据到取样表
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@Operation(summary = "成品请验单提交")
|
@PostMapping("/qingyandan/submit")
|
public R<String> qingyandanSubmit(@RequestBody LimsQingyandanEntity formData) {
|
LimsQingyandanEntity qingyandan = limsQingyandanService.findByFormData(formData);
|
if (qingyandan == null) {
|
return R.error("请验单数据不存在");
|
}
|
|
BizStatus currentStatus = BizStatus.fromCode(qingyandan.getBizStatus());
|
if (currentStatus != BizStatus.CREATED && currentStatus != BizStatus.CANCELLED
|
&& currentStatus != BizStatus.REJECTED) {
|
return R.error("当前状态[" + currentStatus.getLabel() + "]不允许提交");
|
}
|
|
LimsSignEntity sign;
|
try {
|
sign = requireQingyandanSign(qingyandan, formData, SignOpType.QINGYANDAN_SUBMIT);
|
} catch (DataException e) {
|
return R.error(e.getMessage());
|
}
|
limsQingyandanService.submit(qingyandan);
|
claimQingyandanSignUsageOnly(sign, SignOpType.QINGYANDAN_SUBMIT, qingyandan);
|
return R.success("提交成功");
|
}
|
|
/**
|
* 请验单操作：撤回 / 废弃
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@Operation(summary = "请验单操作（撤回/废弃）")
|
@PostMapping("/qingyandan/action")
|
public R<String> qingyandanAction(@RequestBody Map<String, String> params) {
|
if (params == null) {
|
return R.error("请求参数不能为空");
|
}
|
String action = params.get("action");
|
String liushuihao = params.get("jianyan_liushuihao");
|
|
if (liushuihao == null || liushuihao.isEmpty()) {
|
return R.error("检验流水号不能为空");
|
}
|
|
LimsQingyandanEntity qingyandan = limsQingyandanService.findByLiushuihao(liushuihao);
|
if (qingyandan == null) {
|
return R.error("请验单数据不存在");
|
}
|
|
BizStatus currentStatus = BizStatus.fromCode(qingyandan.getBizStatus());
|
|
switch (action) {
|
case "cancel":
|
if (currentStatus != BizStatus.CONFIRMED) {
|
return R.error("只有已提交状态的请验单才能撤回");
|
}
|
LimsSignEntity cancelSign;
|
try {
|
cancelSign = requireQingyandanActionSign(
|
qingyandan, params, SignOpType.QINGYANDAN_CANCEL);
|
} catch (DataException e) {
|
return R.error(e.getMessage());
|
}
|
if (!limsQingyandanService.cancel(qingyandan)) {
|
return R.error("请验单状态已变更，撤回未生效");
|
}
|
recordQingyandanSignUsage(
|
cancelSign, SignOpType.QINGYANDAN_CANCEL, qingyandan);
|
return R.success("撤回成功");
|
|
case "delete":
|
if (currentStatus != BizStatus.CREATED && currentStatus != BizStatus.CANCELLED
|
&& currentStatus != BizStatus.REJECTED) {
|
return R.error("只有已创建或已撤回状态的请验单才能废弃");
|
}
|
limsQingyandanService.delete(qingyandan);
|
return R.success("废弃成功");
|
|
default:
|
return R.error("不支持的操作: " + action);
|
}
|
}
|
|
/**
|
* 请验单编辑
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@Operation(summary = "请验单编辑")
|
@PostMapping("/qingyandan/edit")
|
public R<String> qingyandanEdit(@RequestBody LimsQingyandanEntity formData) {
|
LimsQingyandanEntity qingyandan = limsQingyandanService.findByFormData(formData);
|
if (qingyandan == null) {
|
return R.error("请验单数据不存在");
|
}
|
|
BizStatus currentStatus = BizStatus.fromCode(qingyandan.getBizStatus());
|
if (currentStatus != BizStatus.CREATED && currentStatus != BizStatus.CANCELLED
|
&& currentStatus != BizStatus.REJECTED) {
|
return R.error("当前状态[" + currentStatus.getLabel() + "]不允许编辑");
|
}
|
|
LimsSignEntity sign;
|
try {
|
sign = requireQingyandanSign(qingyandan, formData, SignOpType.QINGYANDAN_SUBMIT);
|
} catch (DataException e) {
|
return R.error(e.getMessage());
|
}
|
limsQingyandanService.edit(qingyandan, formData);
|
claimQingyandanSignUsageOnly(sign, SignOpType.QINGYANDAN_SUBMIT, qingyandan);
|
return R.success("编辑成功");
|
}
|
|
private LimsSignEntity requireQingyandanSign(LimsQingyandanEntity persisted,
|
LimsQingyandanEntity request,
|
SignOpType opType) {
|
String signId = request == null ? null : request.getBizSign();
|
if (signId == null || signId.trim().isEmpty()) {
|
throw new DataException("请添加电子签名");
|
}
|
signId = signId.trim();
|
persisted.setBizSign(signId);
|
if (request != null) {
|
request.setBizSign(signId);
|
}
|
return limsSignService.requireValidSign(
|
signId, opType, persisted.getJianyanLiushuihao());
|
}
|
|
private LimsSignEntity requireQingyandanActionSign(LimsQingyandanEntity persisted,
|
Map<String, String> params,
|
SignOpType opType) {
|
String signId = params.get("biz_sign");
|
if (signId == null || signId.trim().isEmpty()) {
|
signId = params.get("id");
|
}
|
if (signId == null || signId.trim().isEmpty()) {
|
throw new DataException("请添加电子签名");
|
}
|
return limsSignService.requireValidSign(
|
signId.trim(), opType, persisted.getJianyanLiushuihao());
|
}
|
|
/**
|
* 认领签名并记一条 {@code SIGN_USED}。
|
*
|
* <p>🔴 <b>只剩撤回（{@code QINGYANDAN_CANCEL}）走这条路，一字未动</b>：撤回是列表按钮场景，
|
* 层 0 根本不覆盖（实测撤回只产生层 2 + 层 3 两条事件，没有层 0 伴随事件）。
|
* 一旦让它也改走只认领，那次签名就彻底没有任何记录。
|
*
|
* <p>提交 / 编辑改走 {@link #claimQingyandanSignUsageOnly}——见那里的说明。
|
*/
|
private void recordQingyandanSignUsage(LimsSignEntity sign,
|
SignOpType opType,
|
LimsQingyandanEntity qingyandan) {
|
limsSignService.recordSignUsage(sign, opType,
|
Collections.singletonList(qingyandan.getId()),
|
Collections.singletonList(qingyandanUsageTarget(qingyandan)));
|
}
|
|
/**
|
* 只做签名的原子认领，<b>不发 {@code SIGN_USED} 事件</b>（2026-07-31，D8）。
|
*
|
* <p>提交 / 编辑走的是在线表单路径：表单保存本身已经产生层 0 事件，层 0 会据表单里的
|
* {@code biz_sign} 字段补写一条签名事件；这里再发一条 {@code SIGN_USED} 就是同一次签名两条证据。
|
*
|
* <p><b>认领没有被删</b>：它是「签名单次消费」的防重放护栏（ed4d908），
|
* 去掉等于同一个签名可以反复使用。本次改动只是把「认领」和「发事件」拆开。
|
*/
|
private void claimQingyandanSignUsageOnly(LimsSignEntity sign,
|
SignOpType opType,
|
LimsQingyandanEntity qingyandan) {
|
limsSignService.claimSignUsageOnly(sign, opType,
|
Collections.singletonList(qingyandan.getId()),
|
Collections.singletonList(qingyandanUsageTarget(qingyandan)));
|
}
|
|
private LimsSignUsageTarget qingyandanUsageTarget(LimsQingyandanEntity qingyandan) {
|
return LimsSignUsageTarget.builder()
|
.targetTable("lims_qingyandan")
|
.targetId(qingyandan.getId())
|
.bizType("QINGYANDAN")
|
.bizModule("LIMS-请验单")
|
.bizCode(qingyandan.getJianyanLiushuihao())
|
.build();
|
}
|
}
|
