赠送积分更新状态

xiaoyong931011

2023-07-27 b12c793840ad2b1cb24e02d83702729204a9d86b

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

@@ -1,7 +1,11 @@
package cc.mrbird.febs.pay.util;

import cc.mrbird.febs.common.utils.AppContants;
import cc.mrbird.febs.common.utils.LoginUserUtil;
import cc.mrbird.febs.common.utils.MallUtils;
import cc.mrbird.febs.common.utils.RedisUtils;
import cc.mrbird.febs.mall.entity.MallMember;
import cc.mrbird.febs.mall.mapper.MallMemberMapper;
import cc.mrbird.febs.rabbit.producter.AgentProducer;
import cn.hutool.core.io.FileUtil;
import cn.hutool.core.text.StrFormatter;
@@ -49,6 +53,10 @@

    @Autowired
    RestTemplate restTemplate;


    @Autowired
    MallMemberMapper mallMemberMapper;

    private static Logger log = LoggerFactory.getLogger(WechatEventUtil.class);

@@ -104,8 +112,10 @@
                     */
                    String eventKey = map.get("EventKey");
                    if(StrUtil.isNotEmpty(eventKey)){
                        stringBuffer.append(eventKey);
                        stringBuffer.append("-");

                        String[] eventKeyStr = StrUtil.split(eventKey, "_");
                        stringBuffer.append(eventKeyStr[1]);
                        stringBuffer.append("@");
                        stringBuffer.append(fromUserName);
                        agentProducer.sendMemberSubScanMsg(stringBuffer.toString());
                    }
@@ -116,6 +126,10 @@
                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());
            }else if ("SCAN".equals(eventType)) {
                log.info("扫码关注事件：toUserName{}、fromUserName{}", toUserName, fromUserName);
                if(map.containsKey("EventKey")){
@@ -125,7 +139,8 @@
                     */
                    String eventKey = map.get("EventKey");
                    if(StrUtil.isNotEmpty(eventKey)){
                        stringBuffer.append(eventKey);
                        String[] eventKeyStr = StrUtil.split(eventKey, "_");
                        stringBuffer.append(eventKeyStr[1]);
                        stringBuffer.append("@");
                        stringBuffer.append(fromUserName);
                        agentProducer.sendMemberSubScanMsg(stringBuffer.toString());