coding:广告线索

fs-service/src/main/java/com/fs/newAdv/service/ILeadService.java

@@ -44,6 +44,13 @@ public interface ILeadService extends IService<Lead> {
      */
     void weChatAuthorizationLead(String traceId, String unionId, String maOpenId, String phone);
 
+    /**
+     * 小程序获取头像昵称线索处理
+     * @param traceId
+     * @param weiChatName
+     */
+    void weChatNameLead(String traceId, String weiChatName);
+
     /**
      * 小程序授权落地页访问线索处理
      * @param traceId

fs-service/src/main/java/com/fs/newAdv/service/impl/LeadServiceImpl.java

@@ -63,6 +63,7 @@ public class LeadServiceImpl extends ServiceImpl<LeadMapper, Lead> implements IL
     @Override
     @Async
     public void updateGroupAddMemberLead(String name, String chatId, String corpId, String unionid) {
+        log.info("用户加群线索信息:{} {} {} {}", name, chatId, corpId, unionid);
         LambdaQueryWrapper<Lead> last = new LambdaQueryWrapper<Lead>();
         if (StrUtil.isNotEmpty(unionid)) {
             last.eq(Lead::getUnionid, unionid);
@@ -111,6 +112,7 @@ public class LeadServiceImpl extends ServiceImpl<LeadMapper, Lead> implements IL
     }
 
     private void updateAddMemberLead(QwExternalContact qwExternalContact) {
+        log.info("用户加微线索信息:{}", qwExternalContact);
         LambdaQueryWrapper<Lead> last = new LambdaQueryWrapper<Lead>();
         if (StrUtil.isNotEmpty(qwExternalContact.getUnionid())) {
             last.eq(Lead::getUnionid, qwExternalContact.getUnionid());
@@ -142,26 +144,36 @@ public class LeadServiceImpl extends ServiceImpl<LeadMapper, Lead> implements IL
     @Override
     @Async
     public void weChatAuthorizationLead(String traceId, String unionId, String maOpenId, String phone) {
-        try {
-            log.info("用户微信授权线索信息:{}", traceId);
-            Lead byTraceId = this.getByTraceId(traceId);
-            if (byTraceId == null) {
-                return;
-            }
-            this.update(new LambdaUpdateWrapper<Lead>()
-                    .eq(Lead::getTraceId, traceId)
-                    .set(ObjectUtil.isNotEmpty(unionId), Lead::getUnionid, unionId)
-                    .set(ObjectUtil.isNotEmpty(phone), Lead::getPhone, phone)
-                    .set(ObjectUtil.isNotEmpty(maOpenId), Lead::getOpenid, maOpenId)
-                    .set(Lead::getMiniAuth, 1));
-            if (ObjectUtil.isNotEmpty(byTraceId.getLandingPageTs()) && byTraceId.getLandingPageTs().toLocalDate().isEqual(LocalDate.now())) {
-                // 微信授权且当日创建事件
-                log.info("用户微信授权线索事件回传:{}", traceId);
-                conversionEventPublisher.publishConversionEvent(traceId, SystemEventTypeEnum.AUTH_TODAY_CREATE);
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
+        log.info("用户微信授权线索信息:{} {} {} {}", traceId, unionId, phone, maOpenId);
+        Lead byTraceId = this.getByTraceId(traceId);
+        if (byTraceId == null) {
+            return;
+        }
+        this.update(new LambdaUpdateWrapper<Lead>()
+                .eq(Lead::getTraceId, traceId)
+                .set(ObjectUtil.isNotEmpty(unionId), Lead::getUnionid, unionId)
+                .set(ObjectUtil.isNotEmpty(phone), Lead::getPhone, phone)
+                .set(ObjectUtil.isNotEmpty(maOpenId), Lead::getOpenid, maOpenId)
+                .set(Lead::getMiniAuth, 1));
+        if (ObjectUtil.isNotEmpty(byTraceId.getLandingPageTs()) && byTraceId.getLandingPageTs().toLocalDate().isEqual(LocalDate.now())) {
+            // 微信授权且当日创建事件
+            log.info("用户微信授权线索事件回传:{}", traceId);
+            conversionEventPublisher.publishConversionEvent(traceId, SystemEventTypeEnum.AUTH_TODAY_CREATE);
+        }
+    }
+
+    @Override
+    @Async
+    public void weChatNameLead(String traceId, String weiChatName) {
+        log.info("用户微信昵称线索信息:{} {}", traceId, weiChatName);
+        Lead byTraceId = this.getByTraceId(traceId);
+        if (byTraceId == null) {
+            return;
         }
+        this.update(new LambdaUpdateWrapper<Lead>()
+                .eq(Lead::getTraceId, traceId)
+                .set(ObjectUtil.isNotEmpty(weiChatName), Lead::getWeiChatName, weiChatName)
+        );
     }
 
     @Override

fs-user-app/src/main/java/com/fs/app/controller/store/WxUserScrmController.java

@@ -252,6 +252,9 @@ public class WxUserScrmController extends AppBaseController {
             user.setAvatar(userInfo.getAvatarUrl());
             user.setIsWeixinAuth(1);
             userService.updateFsUser(user);
+
+            // 广告线索
+            leadService.weChatNameLead(param.getTraceId(), userInfo.getNickName());
             return R.ok();
         } catch (WxErrorException e) {
             e.printStackTrace();
@@ -287,12 +290,6 @@ public class WxUserScrmController extends AppBaseController {
             logger.info("session 得到：{}" , session);
             // 解密
             WxMaPhoneNumberInfo phoneNoInfo = wxService.getUserService().getPhoneNoInfo(session.getSessionKey(), param.getEncryptedData(), param.getIv());
-            try {
-                WxMaUserInfo userInfo = wxService.getUserService().getUserInfo(session.getSessionKey(), param.getRawData(), param.getIv());
-                logger.info("userInfo 获取：{}" , userInfo);
-            }catch (Exception e){
-                logger.info("获取用户信息失败！",e);
-            }
             FsUserScrm user=new FsUserScrm();
             logger.info("===========用户unionid:{}，用户openid:{}",session.getUnionid(),session.getOpenid());
             if (session.getUnionid()!=null){