Browse Source

update

tags/v0
zhaohe 10 months ago
parent
commit
3706f7e461
  1. BIN
      app.db
  2. 4
      src/main/java/a8k/service/app/appctrl/mainflowctrl/action/SEQ3_APPLAY_RESOURCE.java
  3. 16
      src/main/java/a8k/service/app/appdata/ProjCfgMgrService.java
  4. 8
      src/main/java/a8k/service/app/appstate/ProjectProcessContextMgrService.java

BIN
app.db

4
src/main/java/a8k/service/app/appctrl/mainflowctrl/action/SEQ3_APPLAY_RESOURCE.java

@ -90,9 +90,7 @@ public class SEQ3_APPLAY_RESOURCE extends A8kStepAction {
Assert.isTrue(applyIncubatorPos,"applyIncubatorPos"); Assert.isTrue(applyIncubatorPos,"applyIncubatorPos");
logger.info("Tube:{} 申请资源成功", tube.getSampleId()); logger.info("Tube:{} 申请资源成功", tube.getSampleId());
boolean assProjInfoSuc = projectProcessContextMgrService.prepareProjInfoData(tube);
Assert.isTrue(assProjInfoSuc,"assProjInfoSuc");
projectProcessContextMgrService.prepareProjInfoData(tube);
//创建项目处理上下文 //创建项目处理上下文
projectProcessContextMgrService.prepareRecourseOK(); projectProcessContextMgrService.prepareRecourseOK();

16
src/main/java/a8k/service/app/appdata/ProjCfgMgrService.java

@ -1,6 +1,5 @@
package a8k.service.app.appdata; package a8k.service.app.appdata;
import a8k.service.db.A8kProjIdCardDBService; import a8k.service.db.A8kProjIdCardDBService;
import a8k.service.db.A8kProjInfoDBService; import a8k.service.db.A8kProjInfoDBService;
import a8k.service.db.A8kProjOptConfigDBService; import a8k.service.db.A8kProjOptConfigDBService;
@ -10,6 +9,7 @@ import a8k.utils.ProjBriefInfo;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.util.Assert;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
@ -25,7 +25,6 @@ public class ProjCfgMgrService {
@Resource @Resource
A8kProjOptConfigDBService a8kProjOptConfigDBService; A8kProjOptConfigDBService a8kProjOptConfigDBService;
public A8kProjCfg findByProjIndex(String lotid) { public A8kProjCfg findByProjIndex(String lotid) {
A8kProjCfg projCfg = new A8kProjCfg(); A8kProjCfg projCfg = new A8kProjCfg();
projCfg.idCardInfo = a8kProjIdCardDBService.getByLotId(lotid); projCfg.idCardInfo = a8kProjIdCardDBService.getByLotId(lotid);
@ -34,6 +33,17 @@ public class ProjCfgMgrService {
return projCfg; return projCfg;
} }
public A8kProjCfg findByProjIndexWithCheck(String lotid) {
A8kProjCfg projCfg = new A8kProjCfg();
projCfg.idCardInfo = a8kProjIdCardDBService.getByLotId(lotid);
projCfg.projectInfo = a8kProjInfoDBService.findByProjIndex(projCfg.idCardInfo.projIndex);
projCfg.projOptConfigList = a8kProjOptConfigDBService.findByProjIndex(projCfg.idCardInfo.projIndex);
Assert.isTrue(projCfg.idCardInfo != null, "ID卡信息不存在");
Assert.isTrue(projCfg.projectInfo != null, "项目信息不存在");
Assert.isTrue(projCfg.projOptConfigList != null, "项目配置信息不存在");
return projCfg;
}
public List<ProjBriefInfo> getProjBriefInfo(List<Integer> projIndex) { public List<ProjBriefInfo> getProjBriefInfo(List<Integer> projIndex) {
List<ProjBriefInfo> ret = new ArrayList<>(); List<ProjBriefInfo> ret = new ArrayList<>();
for (Integer index : projIndex) { for (Integer index : projIndex) {
@ -47,9 +57,9 @@ public class ProjCfgMgrService {
return ret; return ret;
} }
/** /**
* 通过项目索引获取流程 * 通过项目索引获取流程
*
* @param projIndex 项目索引 * @param projIndex 项目索引
* @return 流程 * @return 流程
*/ */

8
src/main/java/a8k/service/app/appstate/ProjectProcessContextMgrService.java

@ -289,16 +289,12 @@ public class ProjectProcessContextMgrService {
} }
synchronized public Boolean prepareProjInfoData(Tube tube) {
synchronized public void prepareProjInfoData(Tube tube) {
for (Integer projIndex : tube.getProjIndex()) { for (Integer projIndex : tube.getProjIndex()) {
ProjProcessContext cxt = getProjProcessContext(tube.getSampleId(), projIndex); ProjProcessContext cxt = getProjProcessContext(tube.getSampleId(), projIndex);
Assert.isTrue(cxt != null,"cxt != null"); Assert.isTrue(cxt != null,"cxt != null");
cxt.projCfg = projCfgMgrService.findByProjIndex(cxt.consumable.lotId);
if (cxt.projCfg == null) {
return false;
}
cxt.projCfg = projCfgMgrService.findByProjIndexWithCheck(cxt.consumable.lotId);
} }
return true;
} }
synchronized public void prepareRecourseOK() { synchronized public void prepareRecourseOK() {

Loading…
Cancel
Save