Compare commits
2 Commits
31d94d6234
...
bf10ad0b6f
| Author | SHA1 | Date |
|---|---|---|
|
|
bf10ad0b6f | |
|
|
95bc4cf20c |
|
|
@ -2,10 +2,14 @@ package com.zcloud.eightwork.command.query;
|
||||||
|
|
||||||
import com.alibaba.cola.dto.PageResponse;
|
import com.alibaba.cola.dto.PageResponse;
|
||||||
import com.zcloud.eightwork.command.convertor.MeasuresLogsCoConvertor;
|
import com.zcloud.eightwork.command.convertor.MeasuresLogsCoConvertor;
|
||||||
|
import com.zcloud.eightwork.domain.gateway.TaskLogGateway;
|
||||||
|
import com.zcloud.eightwork.domain.model.TaskLogE;
|
||||||
import com.zcloud.eightwork.dto.MeasuresLogsPageQry;
|
import com.zcloud.eightwork.dto.MeasuresLogsPageQry;
|
||||||
import com.zcloud.eightwork.dto.clientobject.MeasuresLogsCO;
|
import com.zcloud.eightwork.dto.clientobject.MeasuresLogsCO;
|
||||||
import com.zcloud.eightwork.persistence.dataobject.MeasuresLogsDO;
|
import com.zcloud.eightwork.persistence.dataobject.MeasuresLogsDO;
|
||||||
|
import com.zcloud.eightwork.persistence.dataobject.TaskLogDO;
|
||||||
import com.zcloud.eightwork.persistence.repository.MeasuresLogsRepository;
|
import com.zcloud.eightwork.persistence.repository.MeasuresLogsRepository;
|
||||||
|
import com.zcloud.eightwork.persistence.repository.TaskLogRepository;
|
||||||
import com.zcloud.gbscommon.utils.PageQueryHelper;
|
import com.zcloud.gbscommon.utils.PageQueryHelper;
|
||||||
import lombok.AllArgsConstructor;
|
import lombok.AllArgsConstructor;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
|
@ -25,6 +29,7 @@ import java.util.Map;
|
||||||
public class MeasuresLogsQueryExe {
|
public class MeasuresLogsQueryExe {
|
||||||
private final MeasuresLogsRepository measuresLogsRepository;
|
private final MeasuresLogsRepository measuresLogsRepository;
|
||||||
private final MeasuresLogsCoConvertor measuresLogsCoConvertor;
|
private final MeasuresLogsCoConvertor measuresLogsCoConvertor;
|
||||||
|
private final TaskLogRepository taskLogRepository;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 根据id查询
|
* 根据id查询
|
||||||
|
|
@ -48,7 +53,14 @@ public class MeasuresLogsQueryExe {
|
||||||
}
|
}
|
||||||
|
|
||||||
public List<MeasuresLogsCO> listAll(String workId) {
|
public List<MeasuresLogsCO> listAll(String workId) {
|
||||||
return measuresLogsCoConvertor.converDOsToCOs(measuresLogsRepository.listAll(workId));
|
List<MeasuresLogsCO> measuresLogsCOS = measuresLogsCoConvertor.converDOsToCOs(measuresLogsRepository.listAll(workId));
|
||||||
|
List<TaskLogDO> logs = taskLogRepository.listAllByWorkId(workId);
|
||||||
|
measuresLogsCOS.stream().forEach(measuresLogsCO -> {
|
||||||
|
logs.stream().filter(taskLogDO -> taskLogDO.getTaskLogId().equals(measuresLogsCO.getTaskLogId())).findFirst().ifPresent(taskLogDO -> {
|
||||||
|
measuresLogsCO.setStepName(taskLogDO.getStepName());
|
||||||
|
});
|
||||||
|
});
|
||||||
|
return measuresLogsCOS;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,19 @@
|
||||||
|
package com.zcloud.eightwork.dto;
|
||||||
|
|
||||||
|
import io.swagger.annotations.ApiModelProperty;
|
||||||
|
import lombok.Data;
|
||||||
|
|
||||||
|
import javax.validation.constraints.NotBlank;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 作业任务查询 Qry
|
||||||
|
*
|
||||||
|
* @author fangjiakai
|
||||||
|
* @date 2026-03-18
|
||||||
|
*/
|
||||||
|
@Data
|
||||||
|
public class EightworkTaskQry {
|
||||||
|
@ApiModelProperty(value = "作业类型", required = true)
|
||||||
|
@NotBlank(message = "作业类型不能为空")
|
||||||
|
private String workType;
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,21 @@
|
||||||
|
package com.zcloud.eightwork.dto.clientobject;
|
||||||
|
|
||||||
|
import com.alibaba.cola.dto.ClientObject;
|
||||||
|
import io.swagger.annotations.ApiModelProperty;
|
||||||
|
import lombok.Data;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 作业任务级别 CO
|
||||||
|
* 只包含任务名称和作业级别
|
||||||
|
*
|
||||||
|
* @author fangjiakai
|
||||||
|
* @date 2026-03-18
|
||||||
|
*/
|
||||||
|
@Data
|
||||||
|
public class EightworkTaskLevelCO extends ClientObject {
|
||||||
|
@ApiModelProperty(value = "任务名称")
|
||||||
|
private String taskName;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "作业级别")
|
||||||
|
private String workLevel;
|
||||||
|
}
|
||||||
|
|
@ -19,6 +19,9 @@ public class MeasuresLogsCO extends ClientObject {
|
||||||
//作业类型
|
//作业类型
|
||||||
@ApiModelProperty(value = "作业类型")
|
@ApiModelProperty(value = "作业类型")
|
||||||
private String workType;
|
private String workType;
|
||||||
|
//填写步骤名
|
||||||
|
@ApiModelProperty(value = "填写步骤名")
|
||||||
|
private String stepName;
|
||||||
//防护措施
|
//防护措施
|
||||||
@ApiModelProperty(value = "防护措施")
|
@ApiModelProperty(value = "防护措施")
|
||||||
private String content;
|
private String content;
|
||||||
|
|
@ -34,6 +37,9 @@ public class MeasuresLogsCO extends ClientObject {
|
||||||
//答案 &&分割
|
//答案 &&分割
|
||||||
@ApiModelProperty(value = "答案 &&分割")
|
@ApiModelProperty(value = "答案 &&分割")
|
||||||
private String answer;
|
private String answer;
|
||||||
|
//是否合格1是2否
|
||||||
|
@ApiModelProperty(value = "是否合格1是2否")
|
||||||
|
private Integer status;
|
||||||
//签字
|
//签字
|
||||||
@ApiModelProperty(value = "签字")
|
@ApiModelProperty(value = "签字")
|
||||||
private String signPath;
|
private String signPath;
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,22 @@
|
||||||
|
package com.zcloud.eightwork.dto.clientobject;
|
||||||
|
|
||||||
|
import com.alibaba.cola.dto.ClientObject;
|
||||||
|
import io.swagger.annotations.ApiModelProperty;
|
||||||
|
import lombok.Data;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 任务流程分组结果
|
||||||
|
*
|
||||||
|
* @author fangjiakai
|
||||||
|
* @date 2026-03-13
|
||||||
|
*/
|
||||||
|
@Data
|
||||||
|
public class TaskFlowGroupCO extends ClientObject {
|
||||||
|
@ApiModelProperty(value = "组别名称")
|
||||||
|
private String groupName;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "该组别的步骤列表")
|
||||||
|
private List<TaskFlowCO> steps;
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,23 @@
|
||||||
|
package com.zcloud.eightwork.domain.model;
|
||||||
|
|
||||||
|
import lombok.Data;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 作业任务级别 E
|
||||||
|
* 只包含任务名称和作业级别
|
||||||
|
*
|
||||||
|
* @author fangjiakai
|
||||||
|
* @date 2026-03-18
|
||||||
|
*/
|
||||||
|
@Data
|
||||||
|
public class EightworkTaskLevelE {
|
||||||
|
/**
|
||||||
|
* 任务名称
|
||||||
|
*/
|
||||||
|
private String taskName;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 作业级别
|
||||||
|
*/
|
||||||
|
private String workLevel;
|
||||||
|
}
|
||||||
|
|
@ -13,6 +13,8 @@ import lombok.Data;
|
||||||
public class MeasuresLogsE extends BaseE {
|
public class MeasuresLogsE extends BaseE {
|
||||||
//作业类型
|
//作业类型
|
||||||
private String workType;
|
private String workType;
|
||||||
|
//填写步骤名
|
||||||
|
private String stepName;
|
||||||
//防护措施
|
//防护措施
|
||||||
private String content;
|
private String content;
|
||||||
//问题 &&分割
|
//问题 &&分割
|
||||||
|
|
@ -23,6 +25,8 @@ public class MeasuresLogsE extends BaseE {
|
||||||
private String taskLogId;
|
private String taskLogId;
|
||||||
//答案 &&分割
|
//答案 &&分割
|
||||||
private String answer;
|
private String answer;
|
||||||
|
//是否合格1是2否
|
||||||
|
private Integer status;
|
||||||
//签字
|
//签字
|
||||||
private String signPath;
|
private String signPath;
|
||||||
//排序
|
//排序
|
||||||
|
|
|
||||||
|
|
@ -22,6 +22,9 @@ public class MeasuresLogsDO extends BaseDO {
|
||||||
//作业类型
|
//作业类型
|
||||||
@ApiModelProperty(value = "作业类型")
|
@ApiModelProperty(value = "作业类型")
|
||||||
private String workType;
|
private String workType;
|
||||||
|
//填写步骤名
|
||||||
|
@ApiModelProperty(value = "填写步骤名")
|
||||||
|
private String stepName;
|
||||||
//防护措施
|
//防护措施
|
||||||
@ApiModelProperty(value = "防护措施")
|
@ApiModelProperty(value = "防护措施")
|
||||||
private String content;
|
private String content;
|
||||||
|
|
@ -37,6 +40,9 @@ public class MeasuresLogsDO extends BaseDO {
|
||||||
//答案 &&分割
|
//答案 &&分割
|
||||||
@ApiModelProperty(value = "答案 &&分割")
|
@ApiModelProperty(value = "答案 &&分割")
|
||||||
private String answer;
|
private String answer;
|
||||||
|
//是否合格1是2否
|
||||||
|
@ApiModelProperty(value = "是否合格1是2否")
|
||||||
|
private Integer status;
|
||||||
//签字
|
//签字
|
||||||
@ApiModelProperty(value = "签字")
|
@ApiModelProperty(value = "签字")
|
||||||
private String signPath;
|
private String signPath;
|
||||||
|
|
|
||||||
|
|
@ -45,7 +45,6 @@ public class TaskLogRepositoryImpl extends BaseRepositoryImpl<TaskLogMapper, Tas
|
||||||
public List<TaskLogDO> listAllByWorkId(String workId) {
|
public List<TaskLogDO> listAllByWorkId(String workId) {
|
||||||
return list(new LambdaQueryWrapper<TaskLogDO>()
|
return list(new LambdaQueryWrapper<TaskLogDO>()
|
||||||
.eq(TaskLogDO::getWorkId, workId)
|
.eq(TaskLogDO::getWorkId, workId)
|
||||||
.ne(TaskLogDO::getStatus,-1)
|
|
||||||
.orderByAsc(TaskLogDO::getStepOrder)
|
.orderByAsc(TaskLogDO::getStepOrder)
|
||||||
.orderByAsc(TaskLogDO::getCreateTime));
|
.orderByAsc(TaskLogDO::getCreateTime));
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue