Prechádzať zdrojové kódy

增加线下版本上传,查询

xiewenjie 3 rokov pred
rodič
commit
e7dd744707

+ 4 - 3
sxz-core/src/main/java/com/fdkk/sxz/webApi/controller/QueueController.java

@@ -27,6 +27,7 @@ import org.springframework.web.bind.annotation.RestController;
 
 import java.io.IOException;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * @author Xiewj
@@ -113,9 +114,9 @@ public class QueueController {
     @RequestMapping(value = "/getUploadInfo", method = RequestMethod.POST)
     @NoAuthentication
     @AroundLog(name = "获取上传任务状态")
-    public Result getUploadInfo(@RequestBody RequestQueue params) {
-
-        ModelUploadOfflineEntity modelUploadOfflineEntity = modelUploadOfflineService.findByName(params.getName());
+    public Result getUploadInfo(@RequestBody List<RequestQueue> params) {
+        List<String> names = params.stream().map(RequestQueue::getName).collect(Collectors.toList());
+        ModelUploadOfflineEntity modelUploadOfflineEntity = modelUploadOfflineService.findByName(names);
 
         return Result.success("成功", modelUploadOfflineEntity);
     }

+ 3 - 1
sxz-core/src/main/java/com/fdkk/sxz/webApi/service/IModelUploadOfflineService.java

@@ -3,12 +3,14 @@ package com.fdkk.sxz.webApi.service;
 import com.fdkk.sxz.base.IBaseService;
 import com.fdkk.sxz.entity.ModelUploadOfflineEntity;
 
+import java.util.List;
+
 /**
  * Created by Hb_zzZ on 2020/12/1.
  */
 public interface IModelUploadOfflineService extends IBaseService<ModelUploadOfflineEntity> {
 
-    ModelUploadOfflineEntity findByName(String name);
+    ModelUploadOfflineEntity findByName(List<String> name);
 
 
 }

+ 5 - 4
sxz-core/src/main/java/com/fdkk/sxz/webApi/service/impl/ModelUploadOfflineImpl.java

@@ -1,7 +1,6 @@
 package com.fdkk.sxz.webApi.service.impl;
 
 import cn.hutool.core.util.ObjectUtil;
-import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.fdkk.sxz.base.impl.BaseServiceImpl;
@@ -12,6 +11,8 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.List;
+
 /**
  * Created by Hb_zzZ on 2020/12/1.
  */
@@ -20,10 +21,10 @@ import org.springframework.transaction.annotation.Transactional;
 @Slf4j
 public class ModelUploadOfflineImpl extends BaseServiceImpl<IModelUploadOfflineMapper, ModelUploadOfflineEntity> implements IModelUploadOfflineService {
     @Override
-    public ModelUploadOfflineEntity findByName(String name) {
+    public ModelUploadOfflineEntity findByName(List<String> names) {
         LambdaQueryWrapper<ModelUploadOfflineEntity> wrapper = Wrappers.lambdaQuery();
-        if (ObjectUtil.isNotNull(name) && StrUtil.isNotEmpty(name)) {
-            wrapper.eq(ModelUploadOfflineEntity::getName, name);
+        if (ObjectUtil.isNotNull(names) && names.size() > 0) {
+            wrapper.in(ModelUploadOfflineEntity::getName, names);
         }
         return getOne(wrapper);
     }