修改定时任务输出日志

liweidong
ShiJiuZhou 6 days ago
parent 264d0ae8ef
commit 66ae64e721
  1. 5
      blade-ops/blade-job/src/main/java/org/springblade/job/processor/quality/TestPlanInCompleteProcessor.java
  2. 2
      blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/quality/feign/ITestPlanInCompleteTaskClient.java
  3. 4
      blade-service/blade-desk/src/main/java/org/springblade/desk/quality/feign/TestPlanInCompleteTaskClient.java
  4. 2
      blade-service/blade-desk/src/main/java/org/springblade/desk/quality/service/IPlanTestService.java
  5. 5
      blade-service/blade-desk/src/main/java/org/springblade/desk/quality/service/impl/PlanTestServiceImpl.java

@ -1,6 +1,7 @@
package org.springblade.job.processor.quality; package org.springblade.job.processor.quality;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springblade.desk.quality.feign.ITestPlanInCompleteTaskClient; import org.springblade.desk.quality.feign.ITestPlanInCompleteTaskClient;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import tech.powerjob.worker.core.processor.ProcessResult; import tech.powerjob.worker.core.processor.ProcessResult;
@ -13,6 +14,7 @@ import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
* @create 2026-04-22 14:00 * @create 2026-04-22 14:00
*/ */
@Component @Component
@Slf4j
public class TestPlanInCompleteProcessor implements BasicProcessor { public class TestPlanInCompleteProcessor implements BasicProcessor {
@Resource @Resource
@ -21,7 +23,8 @@ public class TestPlanInCompleteProcessor implements BasicProcessor {
@Override @Override
public ProcessResult process(TaskContext taskContext) throws Exception { public ProcessResult process(TaskContext taskContext) throws Exception {
client.testPlanIncomplete(); Integer count = client.testPlanIncomplete();
log.info("转试计划完成修改数量:{}", count);
return new ProcessResult(true); return new ProcessResult(true);
} }
} }

@ -22,5 +22,5 @@ public interface ITestPlanInCompleteTaskClient {
* 转试计划未完成 * 转试计划未完成
*/ */
@GetMapping(TEST_PLAN_INCOMPLETE) @GetMapping(TEST_PLAN_INCOMPLETE)
void testPlanIncomplete(); Integer testPlanIncomplete();
} }

@ -18,7 +18,7 @@ public class TestPlanInCompleteTaskClient implements ITestPlanInCompleteTaskClie
private IPlanTestService planTestService; private IPlanTestService planTestService;
@Override @Override
public void testPlanIncomplete() { public Integer testPlanIncomplete() {
planTestService.testPlanIncomplete(); return planTestService.testPlanIncomplete();
} }
} }

@ -75,5 +75,5 @@ public interface IPlanTestService extends BaseService<PlanTest> {
/** /**
* 转试计划未完成 * 转试计划未完成
*/ */
void testPlanIncomplete(); Integer testPlanIncomplete();
} }

@ -178,9 +178,10 @@ public class PlanTestServiceImpl extends BaseServiceImpl<PlanTestMapper, PlanTes
} }
@Override @Override
public void testPlanIncomplete() { public Integer testPlanIncomplete() {
List<PlanTest> planTestList = this.list(new LambdaQueryWrapper<PlanTest>() List<PlanTest> planTestList = this.list(new LambdaQueryWrapper<PlanTest>()
.isNull(PlanTest::getResult)); .isNull(PlanTest::getResult));
Integer count = 0;
if (planTestList != null && !planTestList.isEmpty()) { if (planTestList != null && !planTestList.isEmpty()) {
for (PlanTest prPlanTest : planTestList) { for (PlanTest prPlanTest : planTestList) {
List<WorkOrder> prWorkOrderList = workOrderMapper.selectList(new LambdaQueryWrapper<WorkOrder>() List<WorkOrder> prWorkOrderList = workOrderMapper.selectList(new LambdaQueryWrapper<WorkOrder>()
@ -206,8 +207,10 @@ public class PlanTestServiceImpl extends BaseServiceImpl<PlanTestMapper, PlanTes
} }
} }
this.updateById(prPlanTest); this.updateById(prPlanTest);
count ++;
} }
} }
} }
return count;
} }
} }

Loading…
Cancel
Save