自建单发送图稿到mq

sd-business/src/main/java/com/sd/business/flow/OrderFlow.java

@@ -8,16 +8,21 @@ import com.ruoyi.common.core.domain.BasePo;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.sd.business.entity.order.dto.OrderFlowExampleDto;
 import com.sd.business.entity.order.dto.OrderInfoDto;
+import com.sd.business.entity.order.dto.OrderSkuDto;
 import com.sd.business.entity.order.enums.OrderStatusEnum;
 import com.sd.business.entity.order.po.OrderFlowExample;
 import com.sd.business.entity.order.po.OrderInfo;
 import com.sd.business.service.order.OrderFlowExampleService;
 import com.sd.business.service.order.OrderService;
 import com.sd.business.service.production.ProductionWorkOrderService;
+import com.sd.mq.config.ArtworkConfig;
+import com.sd.mq.entity.TempArtworkMessage;
+import com.sd.mq.util.RabbitMqUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.Date;
+import java.util.List;
 
 /**
  * 发起采购流程
@@ -88,6 +93,8 @@ public class OrderFlow extends FlowDelegate {
                 .set(BasePo::getUpdateTime, new Date())
                 .set(BasePo::getUpdateUser, SecurityUtils.getUserId()));
 
+        sendMq(dto);
+
     }
 
     @Override
@@ -127,4 +134,23 @@ public class OrderFlow extends FlowDelegate {
         returnToOriginator(flowId, businessId, flowStatus);
     }
 
+
+    private void sendMq(OrderInfoDto dto) {
+
+        List<OrderSkuDto> orderSkuList = dto.getOrderSkuList();
+
+        for (OrderSkuDto orderSkuDto : orderSkuList) {
+
+            if (orderSkuDto.getArtworkLibraryId() == null || orderSkuDto.getArtworkLibraryId() == 0L) {
+                continue;
+            }
+
+            TempArtworkMessage tempArtworkMessage = new TempArtworkMessage();
+            tempArtworkMessage.setImgUrl(orderSkuDto.getBlueprint());
+            tempArtworkMessage.setFileUrl(orderSkuDto.getProductionDocument());
+
+            RabbitMqUtil.send(ArtworkConfig.DIRECT_EXCHANGE_NAME, ArtworkConfig.TEMP_ARTWORK_QUEUE_NAME, tempArtworkMessage);
+        }
+    }
+
 }

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

@@ -1116,7 +1116,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, OrderInfo> implem
 
         for (OrderSkuDto orderSkuDto : orderSkuList) {
 
-            if (orderSkuDto.getArtworkLibraryId() != null && orderSkuDto.getArtworkLibraryId() == 0L) {
+            if (orderSkuDto.getArtworkLibraryId() == null || orderSkuDto.getArtworkLibraryId() == 0L) {
                 continue;
             }
 

sd-business/src/main/java/com/sd/business/service/production/impl/ProductionWorkOrderServiceImpl.java

@@ -177,23 +177,22 @@ public class ProductionWorkOrderServiceImpl extends ServiceImpl<ProductionWorkOr
             if (artworkLibraryId != null && artworkLibraryId != 0) {
                 ArtworkLibrary artworkLibrary = artworkLibraryMap.get(artworkLibraryId);
                 if (artworkLibrary != null) {
-                    workOrderDetail.setImgPath(artworkLibrary.getArtworkName() + "\\" + artworkLibrary.getImgName());
-                    workOrderDetail.setFilePath(artworkLibrary.getArtworkName() + "\\" + artworkLibrary.getFileName());
+                    workOrderDetail.setImgPath("artwork\\" + artworkLibrary.getArtworkName() + "\\" + artworkLibrary.getImgName());
+                    workOrderDetail.setFilePath("artwork\\" + artworkLibrary.getArtworkName() + "\\" + artworkLibrary.getFileName());
                 }
             }
 
             if (StrUtil.isAllBlank(workOrderDetail.getImgPath(), workOrderDetail.getFilePath())) {
-                workOrderDetail.setImgPath(orderSku.getBlueprint().replace("https://os.winfaster.cn/sd/", "")
+                workOrderDetail.setImgPath("tempArtwork\\" + orderSku.getBlueprint().replace("https://os.winfaster.cn/sd/", "")
                         .replace("test/", "")
                         .replace("prod/", "")
                         .replace("dev/", ""));
-                workOrderDetail.setFilePath(orderSku.getProductionDocument().replace("https://os.winfaster.cn/sd/", "")
+                workOrderDetail.setFilePath("tempArtwork\\" + orderSku.getProductionDocument().replace("https://os.winfaster.cn/sd/", "")
                         .replace("test/", "")
                         .replace("prod/", "")
                         .replace("dev/", ""));
             }
 
-
             SkuSpec skuSpec = skuSpecMap.get(item.getSkuSpecId());
 
             workOrderDetail.setLength(skuSpec.getLength());