|
@@ -41,7 +41,9 @@ public class AdqAdIncomeServiceImpl implements IAdqAdIncomeService {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
public void getAdqAdIncome(String startDt, String endDt, String appId, Long appletId, Integer page, Integer isLog, Long errId, Integer isSend) {
|
|
public void getAdqAdIncome(String startDt, String endDt, String appId, Long appletId, Integer page, Integer isLog, Long errId, Integer isSend) {
|
|
|
- getAdqAdIncomeCover(startDt, endDt, appId, appletId, page, isLog, errId, isSend);
|
|
|
|
|
|
|
+ if (page == 1) {
|
|
|
|
|
+ getAdqAdIncomeCover(startDt, endDt, appId, appletId, page, isLog, errId, isSend);
|
|
|
|
|
+ }
|
|
|
try {
|
|
try {
|
|
|
String url = "https://api.weixin.qq.com/publisher/stat";
|
|
String url = "https://api.weixin.qq.com/publisher/stat";
|
|
|
Object tokenObj = redis2Template_db5.opsForValue().get("wechat-applet-access-token-key-" + appletId);
|
|
Object tokenObj = redis2Template_db5.opsForValue().get("wechat-applet-access-token-key-" + appletId);
|
|
@@ -101,7 +103,7 @@ public class AdqAdIncomeServiceImpl implements IAdqAdIncomeService {
|
|
|
if (totalPage > page) {
|
|
if (totalPage > page) {
|
|
|
getAdqAdIncome(startDt, endDt, appId, appletId, page + 1, isLog, errId, isSend);
|
|
getAdqAdIncome(startDt, endDt, appId, appletId, page + 1, isLog, errId, isSend);
|
|
|
} else {
|
|
} else {
|
|
|
- log.info("微小广告细分数据拉取完成,app_id:{} {}~{} page:{}。", appId, startDt, endDt,page);
|
|
|
|
|
|
|
+ log.info("微小广告细分数据拉取完成,app_id:{} {}~{} page:{}。", appId, startDt, endDt, page);
|
|
|
if (errId != null) {
|
|
if (errId != null) {
|
|
|
adqErrorLogMapper.deleteInfoByErrorId(errId);
|
|
adqErrorLogMapper.deleteInfoByErrorId(errId);
|
|
|
}
|
|
}
|
|
@@ -176,9 +178,9 @@ public class AdqAdIncomeServiceImpl implements IAdqAdIncomeService {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
if (totalPage > page) {
|
|
if (totalPage > page) {
|
|
|
- getAdqAdIncome(startDt, endDt, appId, appletId, page + 1, isLog, errId, isSend);
|
|
|
|
|
|
|
+ getAdqAdIncomeCover(startDt, endDt, appId, appletId, page + 1, isLog, errId, isSend);
|
|
|
} else {
|
|
} else {
|
|
|
- log.info("微小广告封面广告数据拉取完成,app_id:{} {}~{} page:{}。", appId, startDt, endDt,page);
|
|
|
|
|
|
|
+ log.info("微小广告封面广告数据拉取完成,app_id:{} {}~{} page:{}。", appId, startDt, endDt, page);
|
|
|
if (errId != null) {
|
|
if (errId != null) {
|
|
|
adqErrorLogMapper.deleteInfoByErrorId(errId);
|
|
adqErrorLogMapper.deleteInfoByErrorId(errId);
|
|
|
}
|
|
}
|