修改添加消息通知

rs-website/rs-website-server/src/main/java/com/upyuns/platform/rs/website/job/WebsiteScheduleTask.java

@@ -6,16 +6,14 @@ import cn.hutool.json.JSONUtil;
 import com.upyuns.platform.rs.datacenter.fegin.DatacenterFeign;
 import com.upyuns.platform.rs.datacenter.pojo.ImageDataVO;
 import com.upyuns.platform.rs.gtdata.GtDataRestClient;
-import com.upyuns.platform.rs.website.biz.ImageInfoRelationBiz;
-import com.upyuns.platform.rs.website.biz.IndustryApplicationInfoBiz;
-import com.upyuns.platform.rs.website.biz.OrderInfoBiz;
-import com.upyuns.platform.rs.website.biz.OrderItemBiz;
+import com.upyuns.platform.rs.website.biz.*;
 import com.upyuns.platform.rs.website.dto.order.OldeliveryJson;
 import com.upyuns.platform.rs.website.entity.ImageInfoRelation;
 import com.upyuns.platform.rs.website.entity.IndustryApplicationInfo;
 import com.upyuns.platform.rs.website.entity.OrderInfo;
 import com.upyuns.platform.rs.website.entity.OrderItem;
 import com.upyuns.platform.rs.website.type.ItemTypeEnum;
+import com.upyuns.platform.rs.website.type.NoticeTypeEnum;
 import com.upyuns.platform.rs.website.type.OrderStatusEnum;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -48,6 +46,9 @@ public class WebsiteScheduleTask {
     @Autowired
     IndustryApplicationInfoBiz industryApplicationInfoBiz;
 
+    @Autowired
+    NoticeInfoBiz noticeInfoBiz;
+
     @Autowired
     DatacenterFeign datacenterFeign;
 
@@ -126,6 +127,9 @@ public class WebsiteScheduleTask {
                 setStatus(OrderStatusEnum.ORDER_RECEIVED.getType());
                 setOldeliveryJson(JSONUtil.toJsonStr(jsons));
             }});
+
+            //添加通知信息
+            noticeInfoBiz.addObj("订单" + orderInfo.getOrderNo() + "已交付，请查看下载", NoticeTypeEnum.ORDER_INFO.getType(), orderInfo.getUserId(), String.valueOf(orderInfo.getOrderId()));
         });
     }
 }
\ No newline at end of file