为盘库增加消息推送

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/BussinessInventoryServiceImpl.java

@@ -3,6 +3,7 @@ package com.junmp.jyzb.service.impl;
 
 import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.druid.sql.dialect.oracle.ast.stmt.OracleCreateTableStatement;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
@@ -21,6 +22,7 @@ import com.junmp.jyzb.api.bean.req.UpdateStocktakeReq;
 import com.junmp.jyzb.api.bean.req.UploadInventoryReq;
 import com.junmp.jyzb.api.exception.enums.EquipmentExceptionEnum;
 import com.junmp.jyzb.api.exception.enums.InventoryExceptionEnum;
+import com.junmp.jyzb.cache.JYZBRedisCache;
 import com.junmp.jyzb.entity.*;
 import com.junmp.jyzb.mapper.BussinessInventoryDetailMapper;
 import com.junmp.jyzb.mapper.BussinessInventoryMapper;
@@ -37,6 +39,8 @@ import com.junmp.v2.dict.entity.SysDict;
 import com.junmp.v2.dict.entity.SysDictItem;
 import com.junmp.v2.dict.service.SysDictItemService;
 import com.junmp.v2.dict.service.SysDictService;
+import com.junmp.v2.message.api.MessageApi;
+import com.junmp.v2.message.api.bean.req.MessageSendReq;
 import com.junmp.v2.sys.api.OrganizationServiceApi;
 import com.sun.org.apache.xpath.internal.operations.Bool;
 import org.flowable.engine.TaskService;
@@ -77,6 +81,10 @@ public class BussinessInventoryServiceImpl extends ServiceImpl<BussinessInventor
     @Resource
     private PubOrgService orgService;
     @Resource
+    private JYZBRedisCache redisCache;
+    @Resource
+    private MessageApi messageApi;
+    @Resource
     private WarehouseInventoryService warehouseInventoryService;
     @Resource
     private OrderNumService orderNumService;
@@ -121,7 +129,15 @@ public class BussinessInventoryServiceImpl extends ServiceImpl<BussinessInventor
 
             updateById(BI);
 
+            String objJson= redisCache.get(BI.getProcessId());
+            redisCache.remove(BI.getProcessId());
+            List<MessageSendReq> msgs= JSONObject.parseArray(objJson,MessageSendReq.class);
+            msgs.forEach(msg->
+                    {
+                        messageApi.sendMessage(msg);
+                    }
 
+            );
             return BI.getId();
         }
         else