zoujiajian 3 jaren geleden
bovenliggende
commit
5d0c9a5e0d

+ 13 - 7
netflix-service/src/main/java/com/cyksj/service/gzh/factory/EventMsgService.java

@@ -157,13 +157,19 @@ public class EventMsgService implements GzhMsgService {
 				String dsCode = gzhDto.getDsCode();
 				if (StrUtil.isNotBlank(dsCode)) {
 					dsCode = dsCode.trim();
-					UserDistributePopularize distributePopularize = distributePopularizeMapper.selectOne(Wrappers.lambdaQuery(UserDistributePopularize.class)
-							.eq(UserDistributePopularize::getCode, dsCode)
-							.select(UserDistributePopularize::getUserId, UserDistributePopularize::getId).last("limit 1"));
-					if (distributePopularize != null) {
-						log.info("渠道sharedId:{}设置固定推广链接PC扫码用户分销", distributePopularize.getUserId());
-						sharedId = distributePopularize.getUserId();
-						dsPopularizeId = distributePopularize.getId();
+					User sharedUser = userService.getOne(Wrappers.lambdaQuery(User.class)
+							.eq(User::getShowId, dsCode).last("limit 1"));
+					if (sharedUser != null) {
+						sharedId = sharedUser.getId();
+					} else {
+						UserDistributePopularize distributePopularize = distributePopularizeMapper.selectOne(Wrappers.lambdaQuery(UserDistributePopularize.class)
+								.eq(UserDistributePopularize::getCode, dsCode)
+								.select(UserDistributePopularize::getUserId, UserDistributePopularize::getId).last("limit 1"));
+						if (distributePopularize != null) {
+							log.info("渠道sharedId:{}设置固定推广链接PC扫码用户分销", distributePopularize.getUserId());
+							sharedId = distributePopularize.getUserId();
+							dsPopularizeId = distributePopularize.getId();
+						}
 					}
 				}
 				if (sharedId != null) {

+ 14 - 7
netflix-service/src/main/java/com/cyksj/service/user/impl/UserServiceImpl.java

@@ -101,13 +101,20 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements Us
 		}
 		Long dsPopularizeId = null;
 		if (StrUtil.isNotBlank(dsCode)) {
-			UserDistributePopularize distributePopularize = distributePopularizeMapper.selectOne(Wrappers.lambdaQuery(UserDistributePopularize.class)
-					.eq(UserDistributePopularize::getCode, dsCode)
-					.select(UserDistributePopularize::getUserId, UserDistributePopularize::getId).last("limit 1"));
-			if (distributePopularize != null) {
-				log.info("渠道sharedId:{}设置固定推广链接用户分销", distributePopularize.getUserId());
-				sharedId = distributePopularize.getUserId();
-				dsPopularizeId = distributePopularize.getId();
+			dsCode = dsCode.trim();
+			User sharedUser = getOne(Wrappers.lambdaQuery(User.class)
+					.eq(User::getShowId, dsCode).last("limit 1"));
+			if (sharedUser != null) {
+				sharedId = sharedUser.getId();
+			} else {
+				UserDistributePopularize distributePopularize = distributePopularizeMapper.selectOne(Wrappers.lambdaQuery(UserDistributePopularize.class)
+						.eq(UserDistributePopularize::getCode, dsCode)
+						.select(UserDistributePopularize::getUserId, UserDistributePopularize::getId).last("limit 1"));
+				if (distributePopularize != null) {
+					log.info("渠道sharedId:{}设置固定推广链接用户分销", distributePopularize.getUserId());
+					sharedId = distributePopularize.getUserId();
+					dsPopularizeId = distributePopularize.getId();
+				}
 			}
 		}
 		if (sharedId != null && isNewUser) {

+ 13 - 7
netflix-web/src/main/java/com/cyksj/web/controller/user/AuthorizationController.java

@@ -410,13 +410,19 @@ public class AuthorizationController {
         Long dsPopularizeId = null;
         if (StrUtil.isNotBlank(dsCode)) {
             dsCode = dsCode.trim();
-            UserDistributePopularize distributePopularize = distributePopularizeMapper.selectOne(Wrappers.lambdaQuery(UserDistributePopularize.class)
-                    .eq(UserDistributePopularize::getCode, dsCode)
-                    .select(UserDistributePopularize::getUserId, UserDistributePopularize::getId).last("limit 1"));
-            if (distributePopularize != null) {
-                log.info("渠道sharedId:{}设置固定推广链接PC用户分销", distributePopularize.getUserId());
-                sharedId = distributePopularize.getUserId();
-                dsPopularizeId = distributePopularize.getId();
+            User sharedUser = userService.getOne(Wrappers.lambdaQuery(User.class)
+                    .eq(User::getShowId, dsCode).last("limit 1"));
+            if (sharedUser != null) {
+                sharedId = sharedUser.getId();
+            } else {
+                UserDistributePopularize distributePopularize = distributePopularizeMapper.selectOne(Wrappers.lambdaQuery(UserDistributePopularize.class)
+                        .eq(UserDistributePopularize::getCode, dsCode)
+                        .select(UserDistributePopularize::getUserId, UserDistributePopularize::getId).last("limit 1"));
+                if (distributePopularize != null) {
+                    log.info("渠道sharedId:{}设置固定推广链接PC用户分销", distributePopularize.getUserId());
+                    sharedId = distributePopularize.getUserId();
+                    dsPopularizeId = distributePopularize.getId();
+                }
             }
         }
         if (user == null) {