修改代码

.gitignore

@@ -101,3 +101,7 @@ Thumbs.db
 /jyzb-mq/jyzb-mq-producer/target/maven-archiver/pom.properties
 /jyzb-biz/jyzb-biz.iml
 /jyzb-biz/src/main/java/com/junmp/jyzb/config/rabbitMQ/RabbitmqConfig.java
+/jyzb-boot/src/main/resources/application.yml
+/jyzb-boot/src/main/resources/application-local.yml
+/jyzb-boot/src/main/resources/application.yml
+/jyzb-boot/src/main/resources/application-local.yml

jyzb-api/src/main/java/com/junmp/jyzb/api/bean/req/DetailListReq.java

@@ -2,8 +2,10 @@ package com.junmp.jyzb.api.bean.req;
 
 import lombok.Data;
 
+import java.io.Serializable;
+
 @Data
-public class DetailListReq {
+public class DetailListReq implements Serializable {
     /**
      * 类型
      */

jyzb-biz/pom.xml

@@ -98,5 +98,10 @@
             <groupId>com.junmp.v2</groupId>
             <artifactId>message-boot-starter</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+        </dependency>
     </dependencies>
 </project>

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

@@ -63,7 +63,7 @@ public class OrderController {
     //内部处理，任务单状态直接设置成finished 添加到数据并且直接推送到消息队列中去
     @PostMapping("/AddFinishOrder")
     @ApiOperation("新增已完成的任务单")
-    public ApiRes<String> AddFinishOrder(@RequestBody UpdateOrderReq req) throws JsonProcessingException {
+    public ApiRes<String> AddFinishOrder(@RequestBody UpdateOrderReq req)  {
         req.setExamineState("finished");
         return ApiRes.success(orderService.AddFinishOrder(req));
     }

jyzb-biz/src/main/java/com/junmp/jyzb/entity/MessageWrapper.java

@@ -5,9 +5,33 @@ import lombok.*;
 import java.io.Serializable;
 
 @Data
-@AllArgsConstructor
-@NoArgsConstructor
 public class MessageWrapper implements Serializable {
     private Object object;
     private String type;
+
+    public MessageWrapper() {
+    }
+
+    public MessageWrapper(Object object, String type) {
+        this.object = object;
+        this.type = type;
+    }
+
+    // getter和setter方法
+
+    public Object getObject() {
+        return object;
+    }
+
+    public void setObject(Object object) {
+        this.object = object;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
 }

jyzb-biz/src/main/java/com/junmp/jyzb/service/OrderService.java

@@ -16,7 +16,7 @@ import java.util.Map;
 
 public interface OrderService extends IService<OrderMain> {
     String AddOrder(UpdateOrderReq req);
-    String AddFinishOrder(UpdateOrderReq req) throws JsonProcessingException;
+    String AddFinishOrder(UpdateOrderReq req);
 
 
     Boolean updateOrder(UpdateOrderReq req);

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

@@ -73,7 +73,7 @@ public class OrderServiceImpl  extends ServiceImpl<OrderMainMapper, OrderMain> i
 
     @Transactional(rollbackFor = Exception.class)
     @Override
-    public String AddFinishOrder(UpdateOrderReq req) throws JsonProcessingException {
+    public String AddFinishOrder(UpdateOrderReq req) {
         OrderMain order = new OrderMain();
         BeanPlusUtil.copyProperties(req, order);
         //保存
@@ -113,7 +113,7 @@ public class OrderServiceImpl  extends ServiceImpl<OrderMainMapper, OrderMain> i
             Exchange exchange = new DirectExchange(exchangeName, true, false);
             rabbitAdmin.declareQueue(queue);
             rabbitAdmin.declareExchange(exchange);
-            rabbitAdmin.declareBinding(BindingBuilder.bind(queue).to(exchange).with(req.getStartOrgId()).noargs());
+            rabbitAdmin.declareBinding(BindingBuilder.bind(queue).to(exchange).with(req.getEndOrgId()).noargs());
             rabbitTemplate.convertAndSend(exchangeName, req.getEndOrgId(), req);
 
         }

jyzb-boot/pom.xml

@@ -110,10 +110,6 @@
             <groupId>org.springframework.integration</groupId>
             <artifactId>spring-integration-mqtt</artifactId>
         </dependency>
-        <dependency>
-            <groupId>com.fasterxml.jackson.core</groupId>
-            <artifactId>jackson-databind</artifactId>
-        </dependency>
     </dependencies>
 
     <build>

jyzb-boot/src/main/resources/application-local.yml

@@ -26,9 +26,9 @@ knife4j:
 spring:
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver
-    url: jdbc:mysql://192.168.3.128:3306/db_jyzb?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=CTT&nullCatalogMeansCurrent=true
-    username: junmp
-    password: 123456
+    url: jdbc:mysql://127.0.0.1:3306/junmp?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=CTT&nullCatalogMeansCurrent=true
+    username: root
+    password: vkeline
 
   redis:
     #host: 192.168.3.188

jyzb-boot/src/main/resources/application.yml

@@ -12,10 +12,10 @@ spring:
   application:
     name: jyzb-app
   rabbitmq:
-      host: 192.168.3.188
+      host: 127.0.0.1
       port: 5672
-      username: root
-      password: 123456
+      username: guest
+      password: guest
       listener:
         simple:
           acknowledge-mode: MANUAL

pom.xml

@@ -295,12 +295,6 @@
                 <artifactId>ws-api</artifactId>
                 <version>${junmp.v2.version}</version>
             </dependency>
-            <!--字符串转对象-->
-            <dependency>
-                <groupId>com.fasterxml.jackson.core</groupId>
-                <artifactId>jackson-databind</artifactId>
-                <version>2.12.5</version>
-            </dependency>
         </dependencies>
 
     </dependencyManagement>