| | |
| | | stringBuffer.append(fromUserName); |
| | | agentProducer.sendMemberSubScanMsg(stringBuffer.toString()); |
| | | } |
| | | }else{ |
| | | /** |
| | | * 普通关注事件 |
| | | */ |
| | | agentProducer.sendMemberSubMsg(fromUserName); |
| | | } |
| | | /** |
| | | * 普通关注事件 |
| | | */ |
| | | agentProducer.sendMemberSubMsg(fromUserName); |
| | | } else if ("unsubscribe".equals(eventType)) { |
| | | log.info("取消关注事件:toUserName{}、fromUserName{}", toUserName, fromUserName); |
| | | //取消关注则退出商城 |
| | | MallMember mallMember = mallMemberMapper.selectMemberByOpenId(fromUserName); |
| | | redisUtils.del(AppContants.XCX_LOGIN_PREFIX + mallMember.getId()); |
| | | redisUtils.del(AppContants.XCX_LOGIN_PHONE_PREFIX + mallMember.getId()); |
| | | if(ObjectUtil.isNotEmpty(mallMember)){ |
| | | 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); |
| | | if(map.containsKey("EventKey")){ |
| | |
| | | agentProducer.sendMemberSubScanMsg(stringBuffer.toString()); |
| | | } |
| | | } |
| | | }else if ("VIEW".equals(eventType)) { |
| | | /** |
| | | * 普通关注事件 |
| | | */ |
| | | agentProducer.sendMemberSubMsg(fromUserName); |
| | | } |
| | | } |
| | | return result; |