消息队列

jyzb-biz/src/main/java/com/junmp/jyzb/controller/InventoryController.java

@@ -6,6 +6,7 @@ import com.junmp.jyzb.api.bean.query.InventorySumReq;
 import com.junmp.jyzb.entity.InventorySummary;
 import com.junmp.jyzb.service.InventoryService;
 import com.junmp.jyzb.service.InventorySummaryService;
+import com.junmp.jyzb.service.MQProductService;
 import com.junmp.jyzb.utils.ResponseResult;
 import com.junmp.v2.common.bean.request.ValidationApi;
 import com.junmp.v2.common.bean.response.ApiRes;
@@ -14,10 +15,7 @@ import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import java.util.Map;
@@ -31,7 +29,14 @@ public class InventoryController {
     public InventoryService inventoryService;
     @Resource
     public InventorySummaryService inventorySummaryService;
-
+    @Resource
+    public MQProductService mqProductService;
+    @GetMapping("/testMQ")
+    @ApiOperation("根据组织机构查询库存信息")
+    public ApiRes<Boolean> testMQ( ) {
+        String aa="";
+        return ApiRes.success(mqProductService.sendMessage());
+    }
     @PostMapping("/GetEquipmentInfo")
     @ApiOperation("根据组织机构查询库存信息")
     public ApiRes<PageResult<InventorySummary>> getEquipmentInfo(@RequestBody @Validated(ValidationApi.edit.class) InventorySumReq req) {