修改

src/main/java/com/free/controller/TransferApplyController.java

@@ -76,7 +76,8 @@ public class TransferApplyController {
     }
     TransferApply data = new TransferApply();
     data.setApply_time(LocalDateTime.now());
-    data.setUser_id(body.getUser_id().toString());
+    data.setUser_id(body.getUser_id());
+    data.setIs_close(TransferApplyNotClose);
     this.service.save(data);
     QueryWrapper qw = new QueryWrapper<>();
     qw.eq("id", data.getId());

src/main/java/com/free/entity/TransferApply.java

@@ -46,7 +46,7 @@ public class TransferApply extends BaseEntity {
   @ApiModelProperty("是否接通转人工")
   private String is_agree;
 
-  @Column(comment = "是否结束", defaultValue = "1")
+  @Column(comment = "是否结束")
   @TableField(value = "is_close")
   @ApiModelProperty("是否结束")
   private int is_close;

src/main/java/com/free/mq/MqService.java

@@ -87,8 +87,8 @@ public class MqService {
    * @param apply
    */
   public void sendMsgToApplicant(TransferApply apply) {
-    String ex = MqListeners.exName;
-    String routerKey = MqListeners.queueName + "." + apply.getUser_id();
+    String ex = MqListeners.userExName;
+    String routerKey = MqListeners.userQueue + "." + apply.getUser_id();
     Map map = new HashMap<>();
     Map data = Utils.objectToMap(apply);
     map.put("data", data);