package com.yeshi.fanli.job;
|
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.yeshi.fanli.entity.AppVersionInfo;
|
import com.yeshi.fanli.entity.SystemEnum;
|
import com.yeshi.fanli.entity.common.Config;
|
import com.yeshi.fanli.entity.pdd.UserPDDAuthRecord;
|
import com.yeshi.fanli.entity.system.ConfigKeyEnum;
|
import com.yeshi.fanli.service.inter.config.AppVersionService;
|
import com.yeshi.fanli.service.inter.config.ConfigService;
|
import com.yeshi.fanli.service.inter.pdd.PDDAuthService;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;
|
import org.springframework.stereotype.Component;
|
import org.yeshi.utils.AppMarketUtil;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 拼多多授权验证
|
*/
|
@Component
|
public class PDDAuthValidJob {
|
|
@Resource
|
private PDDAuthService pddAuthService;
|
|
@Resource
|
private ConfigService configService;
|
|
@XxlJob("pdd-validAuthResult")
|
public ReturnT<String> validAuthResult(String param) throws Exception {
|
|
Date minCreateTime = new Date(System.currentTimeMillis() - 1000 * 60 * 60L * 24);
|
Long uid = null;
|
if (!StringUtil.isNullOrEmpty(param)) {
|
uid = Long.parseLong(param);
|
}
|
|
if (uid != null) {
|
UserPDDAuthRecord record = pddAuthService.getLatestRecordByUid(uid);
|
if (record != null && !record.getSuccess()) {
|
boolean auth = PinDuoDuoApiUtil.isAuth(record.getPid(), record.getCustomParams());
|
if (auth) {
|
pddAuthService.authSuccess(record.getId());
|
}
|
}
|
} else {
|
List<UserPDDAuthRecord> list = pddAuthService.listNeedValidRecord(minCreateTime, 1, 100);
|
if (list != null) {
|
for (UserPDDAuthRecord record : list) {
|
boolean auth = PinDuoDuoApiUtil.isAuth(record.getPid(), record.getCustomParams());
|
if (auth) {
|
pddAuthService.authSuccess(record.getId());
|
}
|
}
|
}
|
}
|
return ReturnT.SUCCESS;
|
}
|
|
|
}
|
