1001684平台端社群统计新增统计数据

pcloud-service-book/src/main/java/com/pcloud/book/group/biz/BookGroupBiz.java

@@ -281,6 +281,11 @@ public interface BookGroupBiz {
     OwnAltQrcodeInfoDTO getOwnAltQrcodeInfoDTOByClassifyId(Long wechatUserId, Long classifyId);
 
     /**
+     * 根据群二维码id获取个人二维码信息
+     */
+    OwnAltQrcodeInfoDTO getOwnAltQrcodeInfoDTOByQrcodeId(Long wechatUserId, Long qrcodeId);
+
+    /**
      * 获取暗号状态
      */
     Integer getCipherState(String cipher);

pcloud-service-book/src/main/java/com/pcloud/book/group/biz/impl/BookGroupBizImpl.java

@@ -28,6 +28,7 @@ import com.pcloud.book.group.biz.BookGroupClassifyBiz;
 import com.pcloud.book.group.dao.*;
 import com.pcloud.book.group.dto.*;
 import com.pcloud.book.group.entity.BookGroup;
+import com.pcloud.book.group.entity.GroupQrcode;
 import com.pcloud.book.group.entity.JoinGroupCipher;
 import com.pcloud.book.group.entity.TempletRelevance;
 import com.pcloud.book.group.enums.LargTempletEnum;
@@ -192,6 +193,8 @@ public class BookGroupBizImpl implements BookGroupBiz {
     private BookConsr bookConsr;
     @Autowired
     private GroupQrcodeBiz groupQrcodeBiz;
+    @Autowired
+    private GroupQrcodeDao groupQrcodeDao;
 
 
 
@@ -1254,6 +1257,76 @@ public class BookGroupBizImpl implements BookGroupBiz {
         return ownAltQrcodeInfoDTO;
     }
 
+    @Transactional(rollbackFor = Exception.class)
+    @ParamLog("根据分类id获取个人二维码信息")
+    @Override
+    public OwnAltQrcodeInfoDTO getOwnAltQrcodeInfoDTOByQrcodeId(Long wechatUserId, Long qrcodeId) {
+        OwnAltQrcodeInfoDTO ownAltQrcodeInfoDTO = new OwnAltQrcodeInfoDTO();
+        GroupQrcode groupQrcode = groupQrcodeDao.getById(qrcodeId);
+        Long classifyId = groupQrcode.getClassifyId();
+
+        //根据分类id查询社群码信息
+        ClassifyDTO classifyDTO = bookGroupClassifyDao.getById(classifyId);
+        if (classifyDTO == null) {
+            throw new BookBizException(BookBizException.PARAM_IS_ERROR, "没有该分类");
+        }
+        Long bookId = classifyDTO.getBookId();
+        Map<String, Object> paramMap = Maps.newHashMap();
+        paramMap.put("bookId", bookId);
+        paramMap.put("adviserId", classifyDTO.getCreateUser());
+        paramMap.put("channelId", classifyDTO.getChannelId());
+        BookDto bookDto = bookDao.getById(paramMap);
+        Long templetId = bookDto.getTempletId();
+        //根据分类id获取大类
+        TempletRelevance templetRelevance = templetRelevanceDao.getByTempletId(templetId);
+        LOGGER.info("根据分类id获取大类templetRelevance" + templetRelevance.toString());
+        Integer largeTemplet = templetRelevance.getLargeTemplet();
+        SelfRobotDTO selfRobotDTO = wechatGroupConsr.getAvailableRobot(wechatUserId, largeTemplet, classifyId);
+        if (selfRobotDTO == null) {
+            throw new BookBizException(BookBizException.PARAM_IS_ERROR, "未找到机器人!");
+        }
+        ownAltQrcodeInfoDTO.setAltHeadUrl(selfRobotDTO.getHeadPic());
+        ownAltQrcodeInfoDTO.setAltId(selfRobotDTO.getWxId());
+        ownAltQrcodeInfoDTO.setAltNickName(selfRobotDTO.getNickName());
+        ownAltQrcodeInfoDTO.setAltQrcodeUrl(selfRobotDTO.getQrcodeUrl());
+        ownAltQrcodeInfoDTO.setAltHeadUrl(selfRobotDTO.getHeadPic());
+        //获取之前是否有没有使用的暗号
+        JoinGroupCipher joinGroupCipher = joinGroupCipherDao.getByWechatUserIdAndQrcodeId(wechatUserId, qrcodeId);
+        String cipher;
+        if (joinGroupCipher != null) {
+            cipher = joinGroupCipher.getCipher();
+            //避免之前通过社群码入群
+            if (!cipher.contains("RAYS_PCLOUD_")){
+                cipher = UUIDUitl.generateShort();
+                //查重，如果有重复，再次生成
+                JoinGroupCipher joinGroupCipherHas = joinGroupCipherDao.getByCipher(cipher);
+                if (joinGroupCipherHas != null) {
+                    cipher = UUIDUitl.generateShort();
+                }
+                //更新
+                joinGroupCipherDao.updateCipher(joinGroupCipher.getId(), cipher);
+            }
+        } else {
+            //新增暗号
+            cipher = UUIDUitl.generateShort();
+            //查重，如果有重复，再次生成
+            JoinGroupCipher joinGroupCipherHas = joinGroupCipherDao.getByCipher(cipher);
+            if (joinGroupCipherHas != null) {
+                cipher = UUIDUitl.generateShort();
+            }
+            cipher = "RAYS_PCLOUD_" + cipher;
+            JoinGroupCipher joinGroupCipherNew = new JoinGroupCipher();
+            joinGroupCipherNew.setCipher(cipher);
+            joinGroupCipherNew.setWechatUserId(wechatUserId);
+            joinGroupCipherNew.setClassifyId(classifyId);
+            joinGroupCipherNew.setAltId(selfRobotDTO.getWxId());
+            joinGroupCipherNew.setQrcodeId(qrcodeId);
+            joinGroupCipherDao.insert(joinGroupCipherNew);
+        }
+        ownAltQrcodeInfoDTO.setCipher(cipher);
+        return ownAltQrcodeInfoDTO;
+    }
+
     @ParamLog("获取暗号状态")
     @Override
     public Integer getCipherState(String cipher) {

pcloud-service-book/src/main/java/com/pcloud/book/group/dao/JoinGroupCipherDao.java

@@ -27,4 +27,8 @@ public interface JoinGroupCipherDao extends BaseDao<JoinGroupCipher> {
      * @return
      */
     BigDecimal getPayPrice(String wxId, Long qrcodeId);
+
+    JoinGroupCipher getByWechatUserIdAndQrcodeId(Long wechatUserId, Long qrcodeId);
+
+    void updateCipher(Long id, String cipher);
 }

pcloud-service-book/src/main/java/com/pcloud/book/group/dao/impl/JoinGroupCipherDaoImpl.java

@@ -69,4 +69,20 @@ public class JoinGroupCipherDaoImpl extends BaseDaoImpl<JoinGroupCipher> impleme
         map.put("qrcodeId", qrcodeId);
         return getSessionTemplate().selectOne(getStatement("getPayPrice"), map);
     }
+
+    @Override
+    public JoinGroupCipher getByWechatUserIdAndQrcodeId(Long wechatUserId, Long qrcodeId) {
+        Map<String,Object> map=new HashMap<>();
+        map.put("wechatUserId",wechatUserId);
+        map.put("qrcodeId",qrcodeId);
+        return this.getSqlSession().selectOne(this.getStatement("getByWechatUserIdAndQrcodeId"), map);
+    }
+
+    @Override
+    public void updateCipher(Long id, String cipher) {
+        Map<String, Object> map = new HashMap<>();
+        map.put("id", id);
+        map.put("cipher", cipher);
+        getSessionTemplate().update(getStatement("updateCipher"), map);
+    }
 }

pcloud-service-book/src/main/java/com/pcloud/book/group/facade/BookGroupFacade.java

@@ -295,6 +295,13 @@ public interface BookGroupFacade {
             @RequestParam("classifyId") Long classifyId
     ) throws BizException, PermissionException, JsonParseException;
 
+    @ApiOperation("根据分类id获取个人二维码")
+    @GetMapping("getOwnAltQrcodeInfoDTOByQrcodeId")
+    ResponseDto<?> getOwnAltQrcodeInfoDTOByQrcodeId(
+            @CookieValue("userInfo") String userInfo,
+            @RequestParam("qrcodeId") Long qrcodeId
+    ) throws BizException, PermissionException, JsonParseException;
+
     @ApiOperation("获取所有的大类")
     @GetMapping("getAllLargeTemplet")
     ResponseDto<?> getAllLargeTemplet(

pcloud-service-book/src/main/java/com/pcloud/book/group/facade/impl/BookGroupFacadeImpl.java

@@ -424,6 +424,20 @@ public class BookGroupFacadeImpl implements BookGroupFacade {
         return new ResponseDto<>(bookGroupBiz.getOwnAltQrcodeInfoDTOByClassifyId(wechatUserId, classifyId));
     }
 
+    @ApiOperation("根据群二维码id获取个人二维码")
+    @GetMapping("getOwnAltQrcodeInfoDTOByQrcodeId")
+    @Override
+    public ResponseDto<?> getOwnAltQrcodeInfoDTOByQrcodeId(
+            @CookieValue("userInfo") String userInfo,
+            @RequestParam("qrcodeId") Long qrcodeId
+    ) throws BizException, PermissionException, JsonParseException {
+        Long wechatUserId = Cookie.getId(userInfo, Cookie._WECHAT_USER_ID);
+        if (qrcodeId == null) {
+            throw new BookBizException(BookBizException.PARAM_IS_ERROR, "分类不能为空！");
+        }
+        return new ResponseDto<>(bookGroupBiz.getOwnAltQrcodeInfoDTOByQrcodeId(wechatUserId, qrcodeId));
+    }
+
     @ApiOperation("获取所有的大类")
     @GetMapping("getAllLargeTemplet")
     @Override

pcloud-service-book/src/main/resources/mapper/group/JoinGroupCipher.xml

@@ -102,4 +102,18 @@
         AND c.wx_id = #{wxId}
     </select>
 
+    <!--根据用户id和群id获取基本信息-->
+    <select id="getByWechatUserIdAndQrcodeId" parameterType="map" resultMap="BaseResultMap">
+        select <include refid="Base_Column_List"/> from join_group_cipher
+        where wechat_user_id=#{wechatUserId} and
+        qrcode_id=#{qrcode_id}
+    </select>
+
+    <!--更新暗号-->
+    <update id="updateCipher" parameterType="map" >
+        update join_group_cipher set
+        cipher=#{cipher}
+        where id=#{id}
+    </update>
+
 </mapper>
\ No newline at end of file