|
@@ -39,6 +39,7 @@ import static com.winhc.data.push.common.Constant.*;
|
|
import static com.winhc.data.push.constant.BaseParam.*;
|
|
import static com.winhc.data.push.constant.BaseParam.*;
|
|
import static com.winhc.data.push.utils.BaseUtils.getObjectId;
|
|
import static com.winhc.data.push.utils.BaseUtils.getObjectId;
|
|
import static com.winhc.data.push.utils.BaseUtils.getPrcessDate;
|
|
import static com.winhc.data.push.utils.BaseUtils.getPrcessDate;
|
|
|
|
+import static com.winhc.data.push.utils.DateUtils.getPrcessDateV2;
|
|
import static com.winhc.data.push.utils.OssUtils.listKeys;
|
|
import static com.winhc.data.push.utils.OssUtils.listKeys;
|
|
import static com.winhc.data.push.utils.TransToExcelNewCompany.dataPathPrefix;
|
|
import static com.winhc.data.push.utils.TransToExcelNewCompany.dataPathPrefix;
|
|
import static com.winhc.data.push.utils.TransToExcelNewCompany.run;
|
|
import static com.winhc.data.push.utils.TransToExcelNewCompany.run;
|
|
@@ -330,7 +331,7 @@ public class SynDataServiceImpl implements SynDataService {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public void saveObject(String ds, String targetBucketName, String ossPre) {
|
|
public void saveObject(String ds, String targetBucketName, String ossPre) {
|
|
- String prcessDate = getPrcessDate(ds);
|
|
|
|
|
|
+ String prcessDate = getPrcessDateV2(ds,7);
|
|
String pre = ossPre + "/" + prcessDate + "/";
|
|
String pre = ossPre + "/" + prcessDate + "/";
|
|
List<String> keys = listKeys(targetBucketName, pre);
|
|
List<String> keys = listKeys(targetBucketName, pre);
|
|
List<String> filters_keys = keys.stream()
|
|
List<String> filters_keys = keys.stream()
|