修改bug

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/MaoDengImageHandler.java

@@ -18,14 +18,11 @@ import me.chanjar.weixin.mp.bean.kefu.WxMpKefuMessage;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlOutTextMessage;
-import me.chanjar.weixin.mp.bean.result.WxMpUser;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.util.Map;
 
-import static com.liquidnet.service.sweet.constant.SweetConstant.REDIS_KEY_SWEET_WECHAT_MAODENG_OPEN_POSTER;
-
 @Component
 @Slf4j
 public class MaoDengImageHandler implements WxMpMessageHandler {

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

@@ -27,14 +27,12 @@ public class SweetWechatMaoDengServiceImpl {
 
     public ResponseDto addBuilderImg(String userId,String imgUrl){
         String maoId = IDGenerator.nextSnowId();
-        SweetMaoDengVo sweetMaoDeng = redisUtils.getSweetMaoDengTransfer(userId);
+        SweetMaoDengVo sweetMaoDeng = redisUtils.getSweetMaoDeng(userId);
         if (sweetMaoDeng != null){
             sweetMaoDeng.setImgUrl(imgUrl);
         }
         String textMsg = sweetMaoDeng.getTextMsg();
         String picUrl = sweetMaoDeng.getPicUrl();
-        sweetMaoDeng.setImgUrl(imgUrl);
-        sweetMaoDeng.setMaoId(maoId);
         redisUtils.setSweetMaoDeng(sweetMaoDeng);
         if (StringUtil.isNotEmpty(textMsg) && StringUtil.isNotEmpty(picUrl)){
             //redis队列入库
@@ -43,8 +41,9 @@ public class SweetWechatMaoDengServiceImpl {
             sqls.add(SqlMapping.get("sweet_wechat_maodeng.insert"));
             sqlsDataA.add(new Object[]{maoId, userId, textMsg, picUrl,imgUrl});
             queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_MAODENG_TEXT_INSERT.getKey(), SqlMapping.gets(sqls, sqlsDataA));
+            return ResponseDto.failure("请求成功");
         }
 
-        return ResponseDto.success();
+        return ResponseDto.failure("请求失败");
     }
 }