赠送积分更新状态

xiaoyong931011

2023-08-15 84c7afc62bb1eb6f5d80d2d9928d0d11a1ffbdda

 src/main/java/cc/mrbird/febs/pay/util/WechatEventUtil.java

@@ -129,9 +129,19 @@
                log.info("取消关注事件：toUserName{}、fromUserName{}", toUserName, fromUserName);
                //取消关注则退出商城
                MallMember mallMember = mallMemberMapper.selectMemberByOpenId(fromUserName);
                mallMember.setSubStatus(MallMember.SUB_STATUS_DISABLED);
                mallMemberMapper.updateById(mallMember);
                if(ObjectUtil.isNotEmpty(mallMember)){
                    String redisKey = AppContants.XCX_LOGIN_PREFIX + mallMember.getId();
                    String existToken = redisUtils.getString(redisKey);
                    if (StrUtil.isNotBlank(existToken)) {
                        Object o = redisUtils.get(existToken);
                        if (ObjectUtil.isNotEmpty(o)) {
                            redisUtils.del(existToken);
                        }
                    }
                    redisUtils.del(existToken);
                    redisUtils.del(AppContants.XCX_LOGIN_PREFIX + mallMember.getId());
                    redisUtils.del(AppContants.XCX_LOGIN_PHONE_PREFIX + mallMember.getId());
                }
            }else if ("SCAN".equals(eventType)) {
                log.info("扫码关注事件：toUserName{}、fromUserName{}", toUserName, fromUserName);
@@ -142,8 +152,9 @@
                     */
                    String eventKey = map.get("EventKey");
                    if(StrUtil.isNotEmpty(eventKey)){
                        String[] eventKeyStr = StrUtil.split(eventKey, "_");
                        stringBuffer.append(eventKeyStr[1]);
//                        String[] eventKeyStr = StrUtil.split(eventKey, "_");
//                        stringBuffer.append(eventKeyStr[1]);
                        stringBuffer.append(eventKey);
                        stringBuffer.append("@");
                        stringBuffer.append(fromUserName);
                        agentProducer.sendMemberSubScanMsg(stringBuffer.toString());