|
@@ -7,6 +7,7 @@ import com.fdkankan.common.util.FileUtils;
|
|
import com.fdkankan.redis.util.RedisUtil;
|
|
import com.fdkankan.redis.util.RedisUtil;
|
|
import com.fdkankan.ucenter.common.RedisKeyUtil;
|
|
import com.fdkankan.ucenter.common.RedisKeyUtil;
|
|
import com.fdkankan.ucenter.common.StatisticsUtil;
|
|
import com.fdkankan.ucenter.common.StatisticsUtil;
|
|
|
|
+import com.fdkankan.ucenter.common.constants.NacosProperty;
|
|
import com.fdkankan.ucenter.common.utils.AuthLicenseUtil;
|
|
import com.fdkankan.ucenter.common.utils.AuthLicenseUtil;
|
|
import com.fdkankan.ucenter.constant.QrCodeFilePath;
|
|
import com.fdkankan.ucenter.constant.QrCodeFilePath;
|
|
import com.fdkankan.ucenter.service.*;
|
|
import com.fdkankan.ucenter.service.*;
|
|
@@ -39,6 +40,11 @@ public class TaskService {
|
|
|
|
|
|
@Scheduled(cron = "0 */10 * * * ?")
|
|
@Scheduled(cron = "0 */10 * * * ?")
|
|
public void delLoginQrCode(){
|
|
public void delLoginQrCode(){
|
|
|
|
+ if("local".equals(NacosProperty.uploadType)){
|
|
|
|
+ AuthLicenseUtil.checkAuthLicense();
|
|
|
|
+ this.updateSceneViewCount();
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
try {
|
|
try {
|
|
long startTime = new Date().getTime();
|
|
long startTime = new Date().getTime();
|
|
String qrCodePath = QrCodeFilePath.LOGIN_QR_CODE_PATH;
|
|
String qrCodePath = QrCodeFilePath.LOGIN_QR_CODE_PATH;
|
|
@@ -55,7 +61,6 @@ public class TaskService {
|
|
delFile(files2);
|
|
delFile(files2);
|
|
log.info("delLoginQrCode:结束定时清理本地登录二维码:耗时{}秒",(new Date().getTime() - startTime)/1000 );
|
|
log.info("delLoginQrCode:结束定时清理本地登录二维码:耗时{}秒",(new Date().getTime() - startTime)/1000 );
|
|
this.updateSceneViewCount();
|
|
this.updateSceneViewCount();
|
|
- AuthLicenseUtil.checkAuthLicense();
|
|
|
|
}catch (Exception e){
|
|
}catch (Exception e){
|
|
log.error("delLoginQrCode错误",e);
|
|
log.error("delLoginQrCode错误",e);
|
|
}
|
|
}
|
|
@@ -99,6 +104,9 @@ public class TaskService {
|
|
@Scheduled(cron = "0 0 12 * * ?")
|
|
@Scheduled(cron = "0 0 12 * * ?")
|
|
// @Scheduled(cron = "0 */30 * * * ?")
|
|
// @Scheduled(cron = "0 */30 * * * ?")
|
|
public void job11() {
|
|
public void job11() {
|
|
|
|
+ if("local".equals(NacosProperty.uploadType)){
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
log.info("每天12:00开始执行定时任务:短信提醒增值权益准备到期");
|
|
log.info("每天12:00开始执行定时任务:短信提醒增值权益准备到期");
|
|
try {
|
|
try {
|
|
userIncrementService.incrementExpireSendSms();
|
|
userIncrementService.incrementExpireSendSms();
|
|
@@ -112,6 +120,9 @@ public class TaskService {
|
|
|
|
|
|
@Scheduled(cron = "0 0 0 * * ?")
|
|
@Scheduled(cron = "0 0 0 * * ?")
|
|
public void job1() {
|
|
public void job1() {
|
|
|
|
+ if("local".equals(NacosProperty.uploadType)){
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
log.info("每天00:00开始执行定时任务:增值权益到期检查");
|
|
log.info("每天00:00开始执行定时任务:增值权益到期检查");
|
|
try {
|
|
try {
|
|
userIncrementService.incrementExpire();
|
|
userIncrementService.incrementExpire();
|
|
@@ -126,6 +137,9 @@ public class TaskService {
|
|
|
|
|
|
@Scheduled(cron = "0 0 1 * * ?")
|
|
@Scheduled(cron = "0 0 1 * * ?")
|
|
public void job2() {
|
|
public void job2() {
|
|
|
|
+ if("local".equals(NacosProperty.uploadType)){
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
log.info("每天01:00开始执行定时任务:更新收货状态");
|
|
log.info("每天01:00开始执行定时任务:更新收货状态");
|
|
try {
|
|
try {
|
|
//更新收货状态,发货后15天,默认用户已经收到货物
|
|
//更新收货状态,发货后15天,默认用户已经收到货物
|
|
@@ -140,6 +154,9 @@ public class TaskService {
|
|
ISceneStatisticsService sceneStatisticsService;
|
|
ISceneStatisticsService sceneStatisticsService;
|
|
@Scheduled(cron = "0 0 2 * * ?")
|
|
@Scheduled(cron = "0 0 2 * * ?")
|
|
public void job3() {
|
|
public void job3() {
|
|
|
|
+ if("local".equals(NacosProperty.uploadType)){
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
log.info("每天02:00开始执行定时任务:获取百度统计的数据入库");
|
|
log.info("每天02:00开始执行定时任务:获取百度统计的数据入库");
|
|
try {
|
|
try {
|
|
String dateStr = DateUtil.date2String(DateUtil.daysCalculate(new Date(), -1), DateUtil.YYYYMMDD_DATA_FORMAT);
|
|
String dateStr = DateUtil.date2String(DateUtil.daysCalculate(new Date(), -1), DateUtil.YYYYMMDD_DATA_FORMAT);
|