修改bug

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/SweetWechatMaoDengServiceImpl.java

@@ -30,30 +30,31 @@ public class SweetWechatMaoDengServiceImpl {
     @Autowired
     WechatMaConfigure maConfigure;
 
-    public ResponseDto addBuilderImg(String userId, String imgUrl) {
+    public ResponseDto addBuilderImg(String userId,String imgUrl){
         LocalDateTime localDateTime = DateUtil.asLocalDateTime(DateUtil.now()); //生成创建时间
         try {
             log.error("[userId] = {}", userId);
             log.error("[imgUrl] = {}", imgUrl);
+
         String maoId = IDGenerator.nextSnowId();
         SweetWechatUsersVo wechatUsers = redisUtils.getSweetWechatUsersOfUnionId(userId, 1);
         if (null == wechatUsers) {
             return ResponseDto.failure("请求失败");
         }
         SweetMaoDengVo sweetMaoDeng = redisUtils.getSweetMaoDeng(wechatUsers.getOpenId());
-            if (sweetMaoDeng != null) {
+        if (sweetMaoDeng != null){
             sweetMaoDeng.setImgUrl(imgUrl);
         }
         String textMsg = sweetMaoDeng.getTextMsg();
         String picUrl = sweetMaoDeng.getPicUrl();
         sweetMaoDeng.setCreatedAt(localDateTime);
         redisUtils.setSweetMaoDeng(sweetMaoDeng);
-            if (StringUtil.isNotEmpty(textMsg) && StringUtil.isNotEmpty(picUrl)) {
+        if (StringUtil.isNotEmpty(textMsg) && StringUtil.isNotEmpty(picUrl)){
             //redis队列入库
             LinkedList<String> sqls = CollectionUtil.linkedListString();
             LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
             sqls.add(SqlMapping.get("sweet_wechat_maodeng.insert"));
-                sqlsDataA.add(new Object[]{maoId, userId, textMsg, picUrl, imgUrl,localDateTime});
+            sqlsDataA.add(new Object[]{maoId, userId, textMsg, picUrl,imgUrl,localDateTime});
             queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_MAODENG_TEXT_INSERT.getKey(), SqlMapping.gets(sqls, sqlsDataA));
             return ResponseDto.failure("请求成功");
         }