1

src/main/java/com/fdkankan/sale/mq/consumer/ManageToSaleConsumer.java

@@ -31,9 +31,7 @@ public class ManageToSaleConsumer {
             String messageId = message.getMessageProperties().getMessageId();
             String msg = new String(message.getBody(), StandardCharsets.UTF_8);
             log.info("接受结果mq--messageId:{},msg:{}",messageId,msg);
-            msg = msg.substring(1, msg.length() - 1);
 
-            msg = StringEscapeUtils.unescapeJava(msg);
             ManageToSaleParam param = JSONObject.parseObject(msg, ManageToSaleParam.class);
             String command = param.getCommand();
             switch (command){

src/main/java/com/fdkankan/sale/service/impl/SysUserServiceImpl.java

@@ -268,9 +268,13 @@ public class SysUserServiceImpl extends ServiceImpl<ISysUserMapper, SysUser> imp
 
     @Override
     public void updateByDb2(SysUser data) {
-        LambdaUpdateWrapper<SysUser> wrapper = new LambdaUpdateWrapper<>();
-        wrapper.eq(SysUser::getManageId,data.getId());
-        wrapper.set(SysUser::getNickName,data.getNickName());
-        this.update(wrapper);
+        if(data!=null){
+            LambdaUpdateWrapper<SysUser> wrapper = new LambdaUpdateWrapper<>();
+            wrapper.eq(SysUser::getManageId,data.getId());
+            if(StringUtils.isNotBlank(data.getNickName())){
+                wrapper.set(SysUser::getNickName,data.getNickName());
+            }
+            this.update(wrapper);
+        }
     }
 }