清理import

修改数据库位置
This commit is contained in:
easonzhu 2025-01-28 22:03:38 +08:00
parent 2dbcb0652c
commit f7140c39ed
43 changed files with 20 additions and 122 deletions

View File

@ -8,8 +8,6 @@ import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import java.io.File;
@ComponentScan("com.upchina")
@SpringBootApplication
@EnableCaching

View File

@ -1,52 +0,0 @@
package com.upchina.app.schedule;
import com.upchina.app.service.OrderSyncService;
import com.upchina.common.config.cache.CacheKey;
import com.upchina.common.service.CacheService;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.concurrent.TimeUnit;
@Component
public class AppTask {
@Resource
private CacheService cacheService;
@Resource
private OrderSyncService orderSyncService;
/**
* 拉取云端视频转码状态
*/
@Scheduled(cron = "${cron.syncAppOrderRecent}")
public void syncAppOrder() {
cacheService.lock(CacheKey.LockKey.SYNC_APP_ORDER,
0, TimeUnit.SECONDS,
4, TimeUnit.MINUTES,
() -> {
LocalDateTime now = LocalDateTime.now();
LocalDateTime startTime = now.plusDays(-1);
orderSyncService.syncAppOrder(startTime, now);
}
);
}
@Scheduled(cron = "${cron.syncAppOrderHistory}")
public void saveWatchSeconds() {
cacheService.lock(CacheKey.LockKey.SYNC_APP_ORDER,
0, TimeUnit.SECONDS,
4, TimeUnit.MINUTES,
() -> {
LocalDateTime now = LocalDateTime.now();
LocalDateTime startTime = now.plusDays(-7);
LocalDateTime endTime = now.plusDays(-1);
orderSyncService.syncAppOrder(startTime, endTime);
}
);
}
}

View File

@ -1,15 +1,9 @@
package com.upchina.app.service;
import cn.hutool.core.util.StrUtil;
import com.hazelcast.org.apache.calcite.util.Holder;
import com.upchina.common.util.LoggerUtil;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;
@Service
public class CouponService {

View File

@ -2,7 +2,6 @@ package com.upchina.app.vo;
import java.io.Serializable;
import java.util.List;
import java.util.stream.Collectors;
public class LiveListVO implements Serializable {

View File

@ -6,7 +6,6 @@ import com.baomidou.mybatisplus.core.injector.AbstractMethod;
import com.baomidou.mybatisplus.core.metadata.TableFieldInfo;
import com.baomidou.mybatisplus.core.metadata.TableInfo;
import com.baomidou.mybatisplus.core.metadata.TableInfoHelper;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.sql.SqlScriptUtils;
import org.apache.ibatis.executor.keygen.Jdbc3KeyGenerator;
import org.apache.ibatis.executor.keygen.KeyGenerator;

View File

@ -17,7 +17,6 @@ import com.upchina.common.vo.FrontUserVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.util.StringUtils;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

View File

@ -1,9 +1,9 @@
package com.upchina.common.entity;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import cn.hutool.core.util.StrUtil;
import com.upchina.common.constant.ScheduleLogResult;
import java.io.Serializable;

View File

@ -6,7 +6,6 @@ import com.baomidou.mybatisplus.generator.AutoGenerator;
import com.baomidou.mybatisplus.generator.config.*;
import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;
import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine;
import org.apache.commons.lang3.StringUtils;
import java.util.Scanner;

View File

@ -1,7 +1,7 @@
package com.upchina.common.interceptor;
import com.hazelcast.map.IMap;
import cn.hutool.core.util.StrUtil;
import com.hazelcast.map.IMap;
import com.upchina.common.constant.IsOrNot;
import com.upchina.common.filter.AuthFilter;
import com.upchina.common.handler.BizException;

View File

@ -29,7 +29,6 @@ import com.upchina.rbac.service.UserService;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;
import javax.annotation.Resource;
import java.util.Arrays;

View File

@ -35,7 +35,6 @@ import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;
import javax.annotation.Resource;
import java.time.LocalDateTime;

View File

@ -33,7 +33,6 @@ import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;
import javax.annotation.Resource;
import java.time.LocalDateTime;

View File

@ -1,8 +1,8 @@
package com.upchina.common.service;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import cn.hutool.core.util.StrUtil;
import com.upchina.common.entity.ScheduleLog;
import com.upchina.common.handler.BizException;
import com.upchina.common.mapper.ScheduleLogMapper;

View File

@ -18,7 +18,6 @@ import org.ahocorasick.trie.Emit;
import org.ahocorasick.trie.Trie;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;

View File

@ -1,11 +1,11 @@
package com.upchina.common.service;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.hazelcast.core.HazelcastInstance;
import cn.hutool.core.util.StrUtil;
import com.upchina.advisor.service.AdvisorInfoService;
import com.upchina.common.constant.IsActive;
import com.upchina.common.constant.ProductType;

View File

@ -1,7 +1,7 @@
package com.upchina.common.util;
import com.google.common.base.Charsets;
import cn.hutool.core.util.StrUtil;
import com.google.common.base.Charsets;
import org.springframework.util.DigestUtils;
import javax.crypto.Mac;

View File

@ -1,7 +1,6 @@
package com.upchina.common.util;
import cn.hutool.core.util.StrUtil;
import org.apache.commons.lang3.StringUtils;
public class HideUtils {

View File

@ -3,7 +3,6 @@ package com.upchina.common.util;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
import org.slf4j.MDC;
import org.springframework.util.StringUtils;
import java.util.Date;

View File

@ -1,9 +1,5 @@
package com.upchina.common.vo;
import cn.hutool.core.util.StrUtil;
import com.upchina.video.service.admin.AdminVideoCustomerService;
import org.springframework.util.StringUtils;
public class FrontUserVO {
private String userId;

View File

@ -42,7 +42,6 @@ import com.upchina.video.constant.VideoStatus;
import com.upchina.video.constant.VideoUserType;
import com.upchina.video.service.app.AppVideoInfoService;
import com.upchina.video.vo.info.VideoDetailAppVO;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

View File

@ -44,7 +44,6 @@ import com.upchina.video.entity.CloudMediaEntity;
import com.upchina.video.query.info.AppLimitQuery;
import com.upchina.video.service.app.AppVideoInfoService;
import com.upchina.video.service.common.VideoCloudService;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.exception.ExceptionUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.dao.DuplicateKeyException;

View File

@ -1,9 +1,6 @@
package com.upchina.rbac.service;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.hazelcast.core.HazelcastInstance;
@ -28,7 +25,10 @@ import com.upchina.rbac.entity.UserDept;
import com.upchina.rbac.entity.UserLogin;
import com.upchina.rbac.mapper.UserDeptMapper;
import com.upchina.rbac.mapper.UserLoginMapper;
import com.upchina.rbac.query.*;
import com.upchina.rbac.query.ChangeMobileQuery;
import com.upchina.rbac.query.ListRoleByUserIdQuery;
import com.upchina.rbac.query.LoginDeptQuery;
import com.upchina.rbac.query.LoginQuery;
import com.upchina.rbac.vo.*;
import com.upchina.video.constant.VideoUserType;
import com.wf.captcha.SpecCaptcha;

View File

@ -1,10 +1,10 @@
package com.upchina.rbac.service;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.hazelcast.core.HazelcastInstance;
import cn.hutool.core.util.StrUtil;
import com.upchina.advisor.entity.AdvisorInfo;
import com.upchina.common.constant.IsActive;
import com.upchina.common.handler.BizException;

View File

@ -1,8 +1,8 @@
package com.upchina.rbac.service;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import cn.hutool.core.util.StrUtil;
import com.upchina.common.handler.BizException;
import com.upchina.common.query.OnlyIdQuery;
import com.upchina.common.result.ResponseStatus;

View File

@ -1,10 +1,10 @@
package com.upchina.rbac.service;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.hazelcast.core.HazelcastInstance;
import cn.hutool.core.util.StrUtil;
import com.upchina.common.handler.BizException;
import com.upchina.common.query.KeywordPageQuery;
import com.upchina.common.query.OnlyIdQuery;

View File

@ -1,10 +1,10 @@
package com.upchina.rbac.service;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.hazelcast.core.HazelcastInstance;
import cn.hutool.core.util.StrUtil;
import com.upchina.common.config.cache.CacheKey;
import com.upchina.common.handler.BizException;
import com.upchina.common.query.OnlyIdQuery;

View File

@ -8,7 +8,6 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.google.common.base.Functions;
import com.google.common.collect.ImmutableList;
import com.hazelcast.core.HazelcastInstance;
import cn.hutool.core.util.StrUtil;
import com.upchina.advisor.entity.AdvisorBasic;
import com.upchina.advisor.entity.AdvisorInfo;
import com.upchina.advisor.mapper.AdvisorInfoMapper;

View File

@ -1,7 +1,7 @@
package com.upchina.rbac.vo;
import com.google.common.collect.Lists;
import cn.hutool.core.util.StrUtil;
import com.google.common.collect.Lists;
import java.util.HashMap;
import java.util.List;

View File

@ -1,8 +1,8 @@
package com.upchina.video.helper;
import cn.hutool.core.util.PhoneUtil;
import com.google.common.collect.ImmutableSet;
import cn.hutool.core.util.StrUtil;
import com.google.common.collect.ImmutableSet;
import com.upchina.video.constant.VideoLiveStatus;
import com.upchina.video.constant.VideoStatus;

View File

@ -1,7 +1,5 @@
package com.upchina.video.query.customer;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.LocalDateTimeUtil;
import com.upchina.common.vo.FrontUserVO;
import com.upchina.video.constant.VideoNotifyType;
import com.upchina.video.entity.VideoBehaviorNotify;

View File

@ -13,7 +13,6 @@ import com.upchina.video.query.mix.LiveMixQuery;
import com.upchina.video.query.push.LivePushQuery;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import org.springframework.util.StringUtils;
import javax.validation.constraints.Max;
import javax.validation.constraints.Min;

View File

@ -2,7 +2,6 @@ package com.upchina.video.query.info;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.core.util.StrUtil;
import com.upchina.video.constant.VideoOperateType;
import com.upchina.video.constant.VideoPlayType;
import com.upchina.video.constant.VideoStatus;

View File

@ -7,9 +7,7 @@ import com.upchina.common.config.cache.CacheKey;
import com.upchina.common.util.LoggerUtil;
import com.upchina.common.util.WebServerInfo;
import org.apache.commons.lang3.exception.ExceptionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.web.context.WebServerApplicationContext;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;

View File

@ -34,7 +34,6 @@ import com.upchina.video.vo.column.CountStatisticsVO;
import com.upchina.video.vo.column.VideoColumnListVO;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;
import javax.annotation.Resource;
import java.sql.Timestamp;

View File

@ -9,7 +9,6 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.google.common.collect.Sets;
import com.google.common.collect.Table;
import cn.hutool.core.util.StrUtil;
import com.upchina.advisor.service.AdvisorInfoService;
import com.upchina.advisor.vo.AdvisorBasicVO;
import com.upchina.common.config.cache.CacheKey;

View File

@ -1,9 +1,9 @@
package com.upchina.video.service.admin;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import cn.hutool.core.util.StrUtil;
import com.upchina.common.handler.BizException;
import com.upchina.common.result.ResponseStatus;
import com.upchina.video.constant.VideoTransStatus;

View File

@ -5,7 +5,6 @@ import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import cn.hutool.core.util.StrUtil;
import com.upchina.advisor.entity.AdvisorBasic;
import com.upchina.advisor.service.AdvisorInfoService;
import com.upchina.advisor.vo.AdvisorBasicVO;

View File

@ -9,7 +9,6 @@ import com.google.common.collect.ImmutableList;
import com.google.common.collect.Table;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.map.IMap;
import cn.hutool.core.util.StrUtil;
import com.upchina.advisor.entity.AdvisorBasic;
import com.upchina.advisor.service.AdvisorInfoService;
import com.upchina.advisor.vo.AdvisorBasicVO;

View File

@ -2,7 +2,6 @@ package com.upchina.video.service.app;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.core.util.StrUtil;
import com.upchina.advisor.service.AdvisorInfoService;
import com.upchina.advisor.vo.AdvisorBasicVO;
import com.upchina.common.config.cache.CacheKey;

View File

@ -11,7 +11,6 @@ import com.auth0.jwt.exceptions.JWTCreationException;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Sets;
import cn.hutool.core.util.StrUtil;
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
import com.tencentcloudapi.live.v20180801.LiveClient;
import com.tencentcloudapi.live.v20180801.models.*;

View File

@ -1,11 +1,11 @@
package com.upchina.video.service.common;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.google.common.collect.Table;
import cn.hutool.core.util.StrUtil;
import com.upchina.common.config.cache.CacheKey;
import com.upchina.common.constant.IsOrNot;
import com.upchina.common.constant.ProductType;

View File

@ -15,20 +15,9 @@ hazelcast:
serverPort: 5709 #自己作为缓存服务器监听的端口号
taf:
servant:
atgGameServant: ATGSTC.ATGGameServer.ATGGameObj@tcp -h 172.16.8.146 -t 60000 -p 19321
dataTransServant: ATGSTC.DataTransServer.DataTransObj@tcp -h 172.16.11.237 -t 20000 -p 27500
userLoginServant: ATGSTC.UserLoginServer.UserLoginObj@tcp -h 172.16.8.146 -t 60000 -p 13936
featureServant: HQSys.FeatureServer.FeatureObj@tcp -h 118.178.30.136 -t 60000 -p 8888
basicHqServant: HQSys.MarketDataServer.BasicHqObj@tcp -h 118.178.30.136 -t 60000 -p 8888
orderServant: DemoVideoDev.OrderSystemServer.OrderSystemObj@tcp -h 172.16.8.102 -t 20000 -p 12126 -e 0
crmServant: CRM.LoginServer.LoginObj@tcp -h 172.16.8.125 -t 60000 -p 8888 # 生产tcp -h 118.178.30.136 -t 60000 -p 8888
crmAuthServant: CRM.CRMWebLoginServer.WebLoginObj@tcp -h 172.16.8.124 -t 600000 -p 13367
baseOrderStatServant: Base.BaseOrderStat.StatObj@tcp -h 172.16.8.252 -t 600000 -p 28048
advisorServant: DemoVideoDev.AdvisorServer.AdvisorObj@tcp -h 127.0.0.1 -t 60000 -p 45600
scheduledEnable: true
cron:
sortPortfolioCron: "0 */5 * * * ?"
saveViewCount: "0 0/20 * * * ?" #从cache刷新观点互动数量到DB
saveVideoCount: "10 * * * * ?" #从cache刷新视频播放量到DB 每分钟的第10s执行
refreshTranscodeStatus: "2 3/5 * * * ?" #从腾讯云拉取录播上传视频信息更新到DB
updateLiveStatus: "3 1 * * * ?" #更新视频录播状态
@ -39,8 +28,6 @@ cron:
collectLastWeek: "0 30 3 * * ?" #统计一周内的数据
collectLivingVideo: "0 * * * * ?" #每分钟统计已开始但未结束的视频直播数据
collectRecentEndVideo: "8 */5 * * * ?" #每5分钟统计已结束48小时以内的视频直播数据
syncAppOrderRecent: "30 */1 * * * ?" # 每5分钟同步app订单数据
syncAppOrderHistory: "40 2 * * * ?" #每5分钟同步app历史订单数据
user:
admin:
roles: 1,3,4,5 #管理员角色id用逗号隔开

View File

@ -33,9 +33,9 @@ spring:
datasource:
master:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://172.16.8.64:3306/video_demo_wx?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMT%2B8
username: root
password: 123456
url: jdbc:mysql://47.96.178.171:3306/advisor_video?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMT%2B8
username: eason
password: mysql2025easonzhu
mvc:
pathmatch:
matching-strategy: ant_path_matcher #Springfox 使用的路径匹配是基于AntPathMatcher的而Spring Boot 2.6.X使用的是PathPatternMatcher。