Browse Source

mq消息结果

lyhzzz 2 years ago
parent
commit
3e075ae5bd

+ 1 - 0
src/main/java/com/fdkankan/manage/mq/param/ManageToSaleParam.java

@@ -1,5 +1,6 @@
 package com.fdkankan.manage.mq.param;
 
+import com.alibaba.fastjson.JSONObject;
 import com.fdkankan.manage.entity.SysUser;
 import lombok.AllArgsConstructor;
 import lombok.Data;

+ 1 - 1
src/main/java/com/fdkankan/manage/service/impl/SysUserServiceImpl.java

@@ -111,7 +111,7 @@ public class SysUserServiceImpl extends ServiceImpl<ISysUserMapper, SysUser> imp
             }
         }
         if(sysUser.getId() != null){
-            rabbitMqProducer.sendByWorkQueue(MqQueueUtil.manageToSaleQueue,new ManageToSaleParam(MqQueueUtil.updateUserCommand,sysUser));
+            rabbitMqProducer.sendByWorkQueue(MqQueueUtil.manageToSaleQueue,JSONObject.toJSONString(new ManageToSaleParam(MqQueueUtil.updateUserCommand,sysUser)));
         }
         this.saveOrUpdate(sysUser);
     }