调整盘点消息推送

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

@@ -429,7 +429,7 @@ public class BussinessInventoryServiceImpl extends ServiceImpl<BussinessInventor
         }
         warehouseService.updateById(warehouse);
         String msg="盘库单:【"+bi.getOrderNum()+"】正在进行盘点，仓库:"+bi.getWarehouseName()+",该仓库已锁定，请勿执行记账操作";
-        sendAsyncReminder(bi,msg);
+        sendAsyncReminder(bi,msg,"systemInvMsg");
         if (bi!=null)
         {
             bi.setInventoryState("running");
@@ -919,12 +919,12 @@ public class BussinessInventoryServiceImpl extends ServiceImpl<BussinessInventor
         mqDto.setOrderId(BI.getId());
         MQ.SendMsg("orderExchange", BI.getOrgId().toString(),mqDto);
         String Msg="盘库单:【"+BI.getOrderNum()+"】已结束，仓库:"+BI.getWarehouseName()+",该仓库已解锁";
-        sendAsyncReminder(BI,Msg);//异步推送消息
+        sendAsyncReminder(BI,Msg,"pass");//异步推送消息
 
         return true;
     }
     @Async
-    public void sendAsyncReminder(BussinessInventory BI,String Msg) {
+    public void sendAsyncReminder(BussinessInventory BI,String Msg,String type) {
         //盘点进行中，需要为所有人员推送信息
         MessageSendReq sendReq = new MessageSendReq();
         List<Long> uniqueOrgIDsList = new ArrayList<>();
@@ -936,7 +936,7 @@ public class BussinessInventoryServiceImpl extends ServiceImpl<BussinessInventor
                 .collect(Collectors.joining(","));
         sendReq.setReceiveUserIds(userIds);
         sendReq.setMsgTitle("盘点提醒");
-        sendReq.setBizType("systemInvMsg");
+        sendReq.setBizType(type);
         sendReq.setBizId(Long.valueOf(BI.getId()));
         sendReq.setSendUserId(String.valueOf(1000));
         sendReq.setMsgContent(Msg);