|
@@ -85,7 +85,7 @@ public class PushMessageDataJob {
|
|
if (mysqlCount == 0) {
|
|
if (mysqlCount == 0) {
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
- String pt = DateUtil.getDateString(startTime.getTime());
|
|
|
|
|
|
+ String pt = DateUtil.getDateString(startTime.getTime(), "yyyyMMdd");
|
|
String sql = String.format("SELECT count(*) FROM push_message_callback WHERE pt = %s;", pt);
|
|
String sql = String.format("SELECT count(*) FROM push_message_callback WHERE pt = %s;", pt);
|
|
List<Record> recordList = odpsManager.query(sql);
|
|
List<Record> recordList = odpsManager.query(sql);
|
|
if (CollectionUtils.isEmpty(recordList)) {
|
|
if (CollectionUtils.isEmpty(recordList)) {
|