添加假数据

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/SweetWechatMaoDengController.java

@@ -2,6 +2,7 @@ package com.liquidnet.service.sweet.controller;
 
 import com.liquidnet.commons.lang.util.StringUtil;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.sweet.service.impl.SweetTestImpl;
 import com.liquidnet.service.sweet.service.impl.SweetWechatMaoDengServiceImpl;
 import com.liquidnet.service.sweet.utils.QueueUtils;
 import com.liquidnet.service.sweet.utils.WechatUsersRedisUtils;
@@ -28,6 +29,8 @@ public class SweetWechatMaoDengController {
     QueueUtils queueUtils;
     @Autowired
     private SweetWechatMaoDengServiceImpl sweetWechatMaoDengService;
+    @Autowired
+    private SweetTestImpl sweetTestImpl;
 
 
     @GetMapping("/backData")
@@ -36,6 +39,7 @@ public class SweetWechatMaoDengController {
 
 
         SweetMaoDengVo sweetMaoDeng = redisUtils.getSweetMaoDengTransfer(userId);
+        if (sweetMaoDeng!=null){
         String textMsg = sweetMaoDeng.getTextMsg();
         String image = sweetMaoDeng.getPicUrl();
         if (StringUtil.isEmpty(textMsg) && StringUtil.isEmpty(image)) {
@@ -44,6 +48,8 @@ public class SweetWechatMaoDengController {
 
         return ResponseDto.success(sweetMaoDeng);
         }
+        return ResponseDto.failure("获取信息失败");
+    }
 
     @PostMapping("/backData")
     @ApiOperation("存生成的图")
@@ -55,4 +61,28 @@ public class SweetWechatMaoDengController {
                                      @RequestParam(value = "imgUrl",required = false)String imgUrl){
         return sweetWechatMaoDengService.addBuilderImg(userId,imgUrl);
     }
+
+    @GetMapping("sensitiveText")
+    @ApiOperation("入库测试-文本")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "query", dataType = "String", name = "fromUser", value = "fromUser"),
+            @ApiImplicitParam(type = "query", dataType = "String", name = "maoContent", value = "maoContent"),
+    })
+    public ResponseDto<Boolean> insertText(String fromUser,String maoContent){
+        sweetTestImpl.insertToText(fromUser,maoContent);
+
+        return ResponseDto.failure();
+    }
+
+    @GetMapping("sensitiveImg")
+    @ApiOperation("入库测试-图片")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "query", dataType = "String", name = "fromUser", value = "fromUser"),
+            @ApiImplicitParam(type = "query", dataType = "String", name = "picUrl", value = "picUrl")
+    })
+    public ResponseDto<Boolean> insertImg(String fromUser,String picUrl){
+        sweetTestImpl.insertToImg(fromUser,picUrl);
+        return ResponseDto.failure();
+    }
+
 }

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

@@ -18,6 +18,7 @@ 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;
 
@@ -45,7 +46,6 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
         String fromUser = wxMessage.getFromUser();//用户id
         String picUrl = wxMessage.getPicUrl();//图片url
         String maoId = IDGenerator.nextSnowId();
-
         //图片非法判断
         //此处判断不需要用户登录，所以使用时间代替
         String currentUid = DateUtil.now().getTime()+"";
@@ -63,25 +63,33 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
         if (StringUtil.isNotEmpty(i)){
             //活动已开启  持久化  redis
             SweetMaoDengVo sweetMaoDeng = redisUtils.getSweetMaoDengTransfer(fromUser);
-
+            WxMpXmlOutTextMessage build =null;
             if (sweetMaoDeng != null){
                 String textMsg = sweetMaoDeng.getTextMsg();
                 sweetMaoDengVo.setTextMsg(textMsg);
-
+                // 获取微信用户信息
+                WxMpUser wxMpUser = wxMpService.getUserService().userInfo(wxMessage.getFromUser());
+                String nickname = wxMpUser.getNickname();
+                build = WxMpXmlOutMessage.TEXT().content("你好，"+nickname+"   点击下方小程序卡片\n" +
+                        "查看你的猫咪隐藏音乐技能。\n" +
+                        "（小程序卡片，点击进入活动）\n")
+                        .fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser())
+                        .build();
                 // 发送活动小程序卡片
                 WxMpKefuMessage message = WxMpKefuMessage.MINIPROGRAMPAGE()
                         .appId(maConfigure.getWxMaAppid(4))
                         .pagePath("/pages/index?nickname=".concat(textMsg))
                         .thumbMediaId("ov08q51In7bXX6tXv7FewxFNN0G78n-pPRsbi3LZbPE")
-                        .title("查看你的猫咪隐藏音乐技能。")
+                        .title("在猫登天空，每一只猫咪都有自己的隐藏音乐技能！")
                         .toUser(wxMessage.getFromUser())
                         .build();
                 wxMpService.getKefuService().sendKefuMessage(message);
+
             }
             //获取过期时间
             long expire = redisUtil.getExpire(REDIS_KEY_SWEET_WECHAT_MAODENG_OPEN_POSTER + fromUser);
             redisUtils.setSweetMaoDengTransfer(sweetMaoDengVo,expire);
-            return null;
+            return build;
         }
        return null;
     }

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

+package com.liquidnet.service.sweet.service.impl;
+
+import com.liquidnet.common.cache.redis.util.RedisUtil;
+import com.liquidnet.common.third.shumei.util.ShumeiUtil;
+import com.liquidnet.commons.lang.util.DateUtil;
+import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.commons.lang.util.StringUtil;
+import com.liquidnet.service.base.ResponseDto;
+
+import com.liquidnet.service.sweet.utils.QueueUtils;
+import com.liquidnet.service.sweet.utils.WechatUsersRedisUtils;
+import com.liquidnet.service.sweet.vo.SweetMaoDengVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+
+import static com.liquidnet.service.sweet.constant.SweetConstant.REDIS_KEY_SWEET_WECHAT_MAODENG_OPEN_POSTER;
+
+@Service
+public class SweetTestImpl {
+    @Autowired
+    private ShumeiUtil shumeiUtil;
+    @Autowired
+    private WechatUsersRedisUtils redisUtils;
+    @Autowired
+    QueueUtils queueUtils;
+    @Autowired
+    private RedisUtil redisUtil;
+
+    /**
+     * 文字
+     */
+    public ResponseDto insertToText(String fromUser,String maoContent){
+        SweetMaoDengVo sweetMaoDengVo = SweetMaoDengVo.getNew();
+        sweetMaoDengVo.setUserId(fromUser);
+        sweetMaoDengVo.setTextMsg(maoContent);
+
+        String maoId = IDGenerator.nextSnowId();
+        //敏感词判断
+        //此处判断不需要用户登录，所以使用时间代替
+        String currentUid = DateUtil.now().getTime()+"";
+        if (!shumeiUtil.checkText(currentUid, maoContent)) {
+            //文字敏感 提示，发送文本消息
+            return ResponseDto.failure("文字非法");
+        }
+        if(maoContent.equals("猫登天空")){
+            redisUtils.setSweetMaoDengOpen(fromUser,10*60);
+            return null;
+        }
+        String i = redisUtils.getSweetMaoDengOpen(fromUser);
+
+        //是否参加了活动
+        if (StringUtil.isNotEmpty(i)) {
+
+            SweetMaoDengVo sweetMaoDeng = redisUtils.getSweetMaoDengTransfer(fromUser);
+            /*String maoIdText =null;
+            if (sweetMaoDeng != null){
+                maoIdText= sweetMaoDeng.getMaoId();
+            }*/
+
+            if (sweetMaoDeng != null) {
+                String picUrl = sweetMaoDeng.getPicUrl();
+                sweetMaoDengVo.setPicUrl(picUrl);
+               /* maoId=sweetMaoDeng.getMaoId();
+                sweetMaoDengVo.setMaoId(maoId);
+                String s="";
+                //更新mysql
+                LinkedList<String> sqls = CollectionUtil.linkedListString();
+                LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+                sqls.add(SqlMapping.get("sweet_wechat_maodeng.text.update"));
+                sqlsDataA.add(new Object[]{maoContent,fromUser,maoId});
+                queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_MAODENG_TEXT_INSERT.getKey(), SqlMapping.gets(sqls, sqlsDataA));*/
+            }/*else {
+
+                sweetMaoDengVo.setMaoId(maoId);
+                LinkedList<String> sqls = CollectionUtil.linkedListString();
+                LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+                sqls.add(SqlMapping.get("sweet_wechat_maodeng.insert"));
+                String s="";
+                sqlsDataA.add(new Object[]{maoId, fromUser, maoContent, null,null});
+                queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_MAODENG_TEXT_INSERT.getKey(), SqlMapping.gets(sqls, sqlsDataA));
+            }*/
+            //获取过期时间
+            long expire = redisUtil.getExpire(REDIS_KEY_SWEET_WECHAT_MAODENG_OPEN_POSTER + fromUser);
+            redisUtils.setSweetMaoDengTransfer(sweetMaoDengVo,expire);
+        }
+        return null;
+    }
+
+
+    /**
+     * 图片
+     */
+    public ResponseDto insertToImg(String fromUser,String picUrl){
+        String maoId = IDGenerator.nextSnowId();
+        //图片非法判断
+        //此处判断不需要用户登录，所以使用时间代替
+        String currentUid = DateUtil.now().getTime()+"";
+        if (!shumeiUtil.checkImage(currentUid, picUrl)) {
+            //图片非法 提示，发送文本消息
+            return ResponseDto.failure("非法的图片");
+        }
+        SweetMaoDengVo sweetMaoDengVo = SweetMaoDengVo.getNew();
+        sweetMaoDengVo.setUserId(fromUser);
+        sweetMaoDengVo.setPicUrl(picUrl);
+        String i = redisUtils.getSweetMaoDengOpen(fromUser);
+        if (StringUtil.isNotEmpty(i)){
+            //活动已开启  持久化  redis
+            //判断是否第一次参加活动
+            SweetMaoDengVo sweetMaoDeng = redisUtils.getSweetMaoDengTransfer(fromUser);
+
+           /* String maoIdText =null;
+            if (sweetMaoDeng != null){
+                maoIdText= sweetMaoDeng.getMaoId();
+            }*/
+           if (sweetMaoDeng != null){
+                String textMsg = sweetMaoDeng.getTextMsg();
+                sweetMaoDengVo.setTextMsg(textMsg);
+
+
+              /* String s="";
+                //更新mysql
+                LinkedList<String> sqls = CollectionUtil.linkedListString();
+                LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+                sqls.add(SqlMapping.get("sweet_wechat_maodeng.img.update"));
+                sqlsDataA.add(new Object[]{picUrl,fromUser,maoId});
+                queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_MAODENG_TEXT_INSERT.getKey(), SqlMapping.gets(sqls, sqlsDataA));*/
+            }/*else {
+               sweetMaoDengVo.setMaoId(maoId);
+              *//* //redis队列入库
+               LinkedList<String> sqls = CollectionUtil.linkedListString();
+               LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+               sqls.add(SqlMapping.get("sweet_wechat_maodeng.insert"));
+               sqlsDataA.add(new Object[]{maoId, fromUser, null, picUrl,null});
+               queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_MAODENG_TEXT_INSERT.getKey(), SqlMapping.gets(sqls, sqlsDataA));
+               String s="";*//*
+           }*/
+            //获取过期时间
+            long expire = redisUtil.getExpire(REDIS_KEY_SWEET_WECHAT_MAODENG_OPEN_POSTER + fromUser);
+            redisUtils.setSweetMaoDengTransfer(sweetMaoDengVo,expire);
+
+        }
+        return null;
+    }
+
+}