From 645da5e4e48dd94b760ea4dcbf80e22bf2a3f33c Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期六, 11 一月 2025 17:20:08 +0800
Subject: [PATCH] #添加播种站点功能

---
 zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WaveManagentServiceImpl.java |   53 +++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 53 insertions(+), 0 deletions(-)

diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WaveManagentServiceImpl.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WaveManagentServiceImpl.java
index 004a0a9..17653bd 100644
--- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WaveManagentServiceImpl.java
+++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WaveManagentServiceImpl.java
@@ -1,8 +1,17 @@
 package com.zy.asrs.wms.apis.wcs.services.Impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.zy.asrs.framework.common.R;
+import com.zy.asrs.framework.exception.CoolException;
+import com.zy.asrs.wms.apis.wcs.entity.domain.WaveTaskDetl;
 import com.zy.asrs.wms.apis.wcs.entity.response.SowSeeds;
 import com.zy.asrs.wms.apis.wcs.services.WaveManagentService;
+import com.zy.asrs.wms.asrs.entity.Task;
+import com.zy.asrs.wms.asrs.entity.dto.LargeScreenTaskDto;
+import com.zy.asrs.wms.asrs.entity.enums.TaskStsType;
+import com.zy.asrs.wms.asrs.entity.param.WaveSeedReviewParam;
+import com.zy.asrs.wms.asrs.mapper.TaskMapper;
+import com.zy.asrs.wms.asrs.service.TaskService;
 import com.zy.asrs.wms.asrs.service.WaveSeedService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -14,9 +23,53 @@
     @Autowired
     private WaveSeedService waveSeedService;
 
+    @Autowired
+    private TaskService taskService;
+
+    @Autowired
+    private TaskMapper taskMapper;
+
     @Override
     public R getSowSeeds() {
         List<SowSeeds> waveSeeds = waveSeedService.selectSeedsList();
         return R.ok(waveSeeds);
     }
+
+    @Override
+    public R reviewSeeds(WaveSeedReviewParam reviewParam) {
+         waveSeedService.waveSeedReview(reviewParam);
+         return R.ok("鎾澶嶆牳鎴愬姛");
+    }
+
+    @Override
+    public int removeSowSeed(Long id) {
+        if (id == null) {
+            throw new CoolException("鎾ID涓嶈兘涓虹┖锛侊紒");
+        }
+        return waveSeedService.removeSowById(id);
+
+    }
+
+    @Override
+    public R getTask() {
+         List<LargeScreenTaskDto> taskDtos =  taskMapper.getTaskIntegrateByTaskNo(new LambdaQueryWrapper<Task>().eq(Task::getTaskSts, TaskStsType.WAVE_SEED.id));
+        return R.ok(taskDtos);
+    }
+
+    @Override
+    public R getTaskDetl(String taskNo) {
+        List<WaveTaskDetl> taskDetls = taskMapper.getTaskDetlByTaskNo(taskNo);
+        return R.ok(taskDetls);
+    }
+
+    /**
+     * 鑾峰彇闈炴眹鎬绘槑缁嗘暟鎹�
+     * @param taskNo
+     * @return
+     */
+    @Override
+    public R getTaskDetlQutify(String taskNo) {
+        List<WaveTaskDetl> taskDetls = taskMapper.getTaskDetlQutify(taskNo);
+        return R.ok(taskDetls);
+    }
 }

--
Gitblit v1.9.1