整合mq

sd-business/src/main/java/com/sd/business/service/order/impl/OrderServiceImpl.java

@@ -57,9 +57,13 @@ import com.sd.business.service.sku.SkuSpecService;
 import com.sd.business.service.statement.StatementOfAccountService;
 import com.sd.business.util.CodeEnum;
 import com.sd.framework.util.Assert;
+import com.sd.mq.config.ArtworkConfig;
+import com.sd.mq.entity.ArtworkMessage;
+import com.sd.mq.util.RabbitMqUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.io.File;
 import java.math.BigDecimal;
 import java.util.*;
 import java.util.function.Function;
@@ -600,6 +604,9 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, OrderInfo> implem
         // 更新附件
         ObsFileUtil.editFile(dto.getFileList(), dto.getId());
 
+        // 发送mq下载临时图稿
+        sendMq(dto);
+
     }
 
     @DSTransactional
@@ -1102,4 +1109,31 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, OrderInfo> implem
         inventoryService.unlockStorage(orderSkuList);
     }
 
+    private void sendMq(OrderInfoDto dto) {
+
+        List<OrderSkuDto> orderSkuList = dto.getOrderSkuList();
+
+        for (OrderSkuDto orderSkuDto : orderSkuList) {
+            String pathPrefix = "临时文件" + File.separator;
+
+            ArtworkMessage artworkMessage = new ArtworkMessage();
+            artworkMessage.setImgPath(pathPrefix + orderSkuDto.getBlueprint()
+                    .replace("https://os.winfaster.cn/sd/", "")
+                    .replace("test/", "")
+                    .replace("prod/", "")
+                    .replace("dev/", ""));
+            artworkMessage.setFilePath(pathPrefix + orderSkuDto.getProductionDocument()
+                    .replace("https://os.winfaster.cn/sd/", "")
+                    .replace("test/", "")
+                    .replace("prod/", "")
+                    .replace("dev/", ""));
+            artworkMessage.setImgUrl(orderSkuDto.getBlueprint());
+            artworkMessage.setFileUrl(orderSkuDto.getProductionDocument());
+            artworkMessage.setRetryCount(0);
+            artworkMessage.setType(1);
+
+            RabbitMqUtil.send(ArtworkConfig.DIRECT_EXCHANGE_NAME, ArtworkConfig.QUEUE_NAME, artworkMessage);
+        }
+    }
+
 }