Commit 4e7d8d15 by 赵剑炜

修改取消盘点后消息推送的具体内容

parent 43e846c4
...@@ -7,6 +7,7 @@ import java.util.List; ...@@ -7,6 +7,7 @@ import java.util.List;
@Data @Data
public class MQDto { public class MQDto {
private String api; private String api;
private String orderState;
private Integer type; private Integer type;
private List<String> idList; private List<String> idList;
private String message; private String message;
......
...@@ -904,6 +904,11 @@ public class BussinessInventoryServiceImpl extends ServiceImpl<BussinessInventor ...@@ -904,6 +904,11 @@ public class BussinessInventoryServiceImpl extends ServiceImpl<BussinessInventor
warehouse.setIsLocked(0); warehouse.setIsLocked(0);
warehouseService.updateById(warehouse); warehouseService.updateById(warehouse);
this.updateById(BI); this.updateById(BI);
MQDto mqDto = new MQDto();
mqDto.setOrderState("finished");
mqDto.setApi("BussinessInventoryFinish");
mqDto.setOrderId(BI.getId());
MQ.SendMsg("orderExchange", BI.getOrgId().toString(),mqDto);
} }
else//废除单据 req.getState().equals(1) else//废除单据 req.getState().equals(1)
{ {
...@@ -913,11 +918,14 @@ public class BussinessInventoryServiceImpl extends ServiceImpl<BussinessInventor ...@@ -913,11 +918,14 @@ public class BussinessInventoryServiceImpl extends ServiceImpl<BussinessInventor
BI.setInventoryState("cancel"); BI.setInventoryState("cancel");
BI.setUpdateTime(DateTimeUtil.getCurrentDateTime()); BI.setUpdateTime(DateTimeUtil.getCurrentDateTime());
this.updateById(BI); this.updateById(BI);
MQDto mqDto = new MQDto();
mqDto.setOrderState("cancel");
mqDto.setApi("BussinessInventoryFinish");
mqDto.setOrderId(BI.getId());
MQ.SendMsg("orderExchange", BI.getOrgId().toString(),mqDto);
} }
MQDto mqDto = new MQDto();
mqDto.setApi("BussinessInventoryFinish");
mqDto.setOrderId(BI.getId());
MQ.SendMsg("orderExchange", BI.getOrgId().toString(),mqDto);
String Msg="盘库单:【"+BI.getOrderNum()+"】已结束,仓库:"+BI.getWarehouseName()+",该仓库已解锁"; String Msg="盘库单:【"+BI.getOrderNum()+"】已结束,仓库:"+BI.getWarehouseName()+",该仓库已解锁";
sendAsyncReminder(BI,Msg,"Inventory/pass");//异步推送消息 sendAsyncReminder(BI,Msg,"Inventory/pass");//异步推送消息
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论