Selaa lähdekoodia

增加上传需求

Xiewj 3 vuotta sitten
vanhempi
commit
91af8644b2

+ 14 - 11
sxz-core/src/main/java/com/fdkk/sxz/webApi/controller/ManagerController.java

@@ -615,19 +615,22 @@ public class ManagerController extends BaseController {
     @NoAuthentication
     @AroundLog(name = "新增模型数据")
     public Result addModelDetail(@RequestBody RequestRenovationPartsDetailManager param) throws Exception {
-        if (param.getModelUploadId() == null) {
-            return Result.failure(CodeConstant.FAILURE_CODE_3001, CodeConstant.FAILURE_MSG_3001);
-        }
+        Message message = MessageBuilder.withPayload(param).build();
+        if (param.getQueryType()!=null&&param.getQueryType()==3){
+            rabbitTemplate.convertAndSend(TopicRabbitConfig.TOPICE, TopicRabbitConfig.ADDMODEL, message);
+        }else {
+            if (param.getModelUploadId() == null) {
+                return Result.failure(CodeConstant.FAILURE_CODE_3001, CodeConstant.FAILURE_MSG_3001);
+            }
 
-        ModelUploadEntity modelUploadEntity = modelUploadService.findById(param.getModelUploadId());
-        if (modelUploadEntity == null) {
-            return Result.failure(CodeConstant.FAILURE_CODE_4009, CodeConstant.FAILURE_MSG_4009);
+            ModelUploadEntity modelUploadEntity = modelUploadService.findById(param.getModelUploadId());
+            if (modelUploadEntity == null) {
+                return Result.failure(CodeConstant.FAILURE_CODE_4009, CodeConstant.FAILURE_MSG_4009);
+            }
+            rabbitTemplate.convertAndSend(TopicRabbitConfig.TOPICE, TopicRabbitConfig.ADDMODEL, message);
+            modelUploadEntity.setAddStatus(1);
+            modelUploadService.updateById(modelUploadEntity);
         }
-
-        Message message = MessageBuilder.withPayload(param).build();
-        rabbitTemplate.convertAndSend(TopicRabbitConfig.TOPICE, TopicRabbitConfig.ADDMODEL, message);
-        modelUploadEntity.setAddStatus(1);
-        modelUploadService.updateById(modelUploadEntity);
         //响应过快,前端未刷新
         return success();
     }