|
@@ -64,7 +64,9 @@ import static com.fs.course.utils.LinkUtil.generateRandomStringWithLock;
|
|
|
public class SopLogsTaskServiceImpl implements SopLogsTaskService {
|
|
|
|
|
|
|
|
|
- private static final String REAL_LINK_PREFIX = "https://h5.cdwjyyh.com/courseh5/pages/course/learning?course=";
|
|
|
+ private static final String REAL_LINK_PREFIX = "/courseH5/pages/course/learning?course=";
|
|
|
+ private static final String SHORT_LINK_PREFIX = "/courseH5/pages/course/learning?s=";
|
|
|
+
|
|
|
private static final String QWSOP_KEY_PREFIX = "qwsop:";
|
|
|
private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
|
|
private static final DateTimeFormatter DATE_TIME_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
|
@@ -152,7 +154,6 @@ public class SopLogsTaskServiceImpl implements SopLogsTaskService {
|
|
|
@PostConstruct
|
|
|
public void init() {
|
|
|
loadCourseConfig();
|
|
|
- loadDomainNames();
|
|
|
startConsumers();
|
|
|
}
|
|
|
|
|
@@ -171,14 +172,6 @@ public class SopLogsTaskServiceImpl implements SopLogsTaskService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private void loadDomainNames() {
|
|
|
- try {
|
|
|
- cachedDomainNames = fsCourseDomainNameMapper.selectAllDomainNames();
|
|
|
- log.info("Loaded {} domain names for short links.", cachedDomainNames.size());
|
|
|
- } catch (Exception e) {
|
|
|
- log.error("Failed to load domain names: {}", e.getMessage(), e);
|
|
|
- }
|
|
|
- }
|
|
|
|
|
|
|
|
|
private void startConsumers() {
|
|
@@ -230,17 +223,6 @@ public class SopLogsTaskServiceImpl implements SopLogsTaskService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- @Scheduled(fixedDelay = 60000) // 每60秒刷新一次
|
|
|
- public void refreshDomainNames() {
|
|
|
- synchronized(domainLock) {
|
|
|
- try {
|
|
|
- cachedDomainNames = fsCourseDomainNameMapper.selectAllDomainNames();
|
|
|
- log.info("Refreshed {} domain names for short links.", cachedDomainNames.size());
|
|
|
- } catch (Exception e) {
|
|
|
- log.error("Failed to refresh domain names: {}", e.getMessage(), e);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
|
|
|
|
|
|
@PreDestroy
|
|
@@ -1124,7 +1106,8 @@ public class SopLogsTaskServiceImpl implements SopLogsTaskService {
|
|
|
Date updateTime = Date.from(expireDateTime.atZone(ZoneId.systemDefault()).toInstant());
|
|
|
link.setUpdateTime(updateTime);
|
|
|
|
|
|
- String sortLink = "https://" + logVo.getDomain() + "/s/" + link.getLink();
|
|
|
+ //取销售绑定的二级域名
|
|
|
+ String sortLink = logVo.getDomain() + SHORT_LINK_PREFIX + link.getLink();
|
|
|
enqueueCourseLink(link);
|
|
|
return sortLink;
|
|
|
}
|