Commit 2936c2ae by guominglei

修改参数类型

parent e5df24b8
...@@ -722,7 +722,7 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -722,7 +722,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
if (null != unstartflowStatisticData){ if (null != unstartflowStatisticData){
flowStatisticData.setUnstart(flowStatisticData.getUnstart() + unstartflowStatisticData.getUnstart()); flowStatisticData.setUnstart(flowStatisticData.getUnstart() + unstartflowStatisticData.getUnstart());
} }
StatisticData nodeStatisticData = jobTaskRunLogMapper.findStatusByStartAndEndTime(startTime, endTime, flowIdList); StatisticData nodeStatisticData = jobTaskRunLogMapper.findStatusByStartAndEndTime(new Date(startTime), new Date(endTime), flowIdList);
StatisticData unstartNodeStatisticData = waitingTaskMapper.findStatusByStartAndEndTime(flowIdList); StatisticData unstartNodeStatisticData = waitingTaskMapper.findStatusByStartAndEndTime(flowIdList);
if (null != unstartNodeStatisticData){ if (null != unstartNodeStatisticData){
nodeStatisticData.setUnstart(nodeStatisticData.getUnstart() + unstartNodeStatisticData.getUnstart()); nodeStatisticData.setUnstart(nodeStatisticData.getUnstart() + unstartNodeStatisticData.getUnstart());
...@@ -820,7 +820,7 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -820,7 +820,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
} }
} }
StatisticData nodeStatisticData = jobTaskRunLogMapper.findStatusByStartAndEndTime(startTime, endTime, flowIdList); StatisticData nodeStatisticData = jobTaskRunLogMapper.findStatusByStartAndEndTime(new Date(startTime), new Date(endTime), flowIdList);
StatisticData unstartNodeStatisticData = waitingTaskMapper.findStatusByStartAndEndTime(flowIdList); StatisticData unstartNodeStatisticData = waitingTaskMapper.findStatusByStartAndEndTime(flowIdList);
if (null != unstartNodeStatisticData){ if (null != unstartNodeStatisticData){
nodeStatisticData.setUnstart(nodeStatisticData.getUnstart() + unstartNodeStatisticData.getUnstart()); nodeStatisticData.setUnstart(nodeStatisticData.getUnstart() + unstartNodeStatisticData.getUnstart());
......
...@@ -6,6 +6,7 @@ import com.byit.model.JobTaskRunLogWithBLOBs; ...@@ -6,6 +6,7 @@ import com.byit.model.JobTaskRunLogWithBLOBs;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List; import java.util.List;
/** /**
...@@ -119,8 +120,8 @@ public interface JobTaskRunLogMapper { ...@@ -119,8 +120,8 @@ public interface JobTaskRunLogMapper {
* @param flowIdList * @param flowIdList
* @return * @return
*/ */
StatisticData findStatusByStartAndEndTime(@Param("startTime")Long startTime, StatisticData findStatusByStartAndEndTime(@Param("startTime")Date startTime,
@Param("endTime")Long endTime, @Param("endTime")Date endTime,
@Param("flowIdList")List<Integer> flowIdList); @Param("flowIdList")List<Integer> flowIdList);
StatisticData findStatisticDataByRunIdAndFlowId(@Param("runId")String runId, @Param("flowId")Integer flowId); StatisticData findStatisticDataByRunIdAndFlowId(@Param("runId")String runId, @Param("flowId")Integer flowId);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment