|
|
@@ -36,7 +36,7 @@ public class PnsDataSyncTask {
|
|
|
@Autowired
|
|
|
private BaseDao baseDao;
|
|
|
|
|
|
- @Scheduled(cron = "0 0/1 * * * ?")
|
|
|
+ @Scheduled(cron = "0 0/5 * * * ?")
|
|
|
public void UploadSaleData(){
|
|
|
logger.info("Sale Upload Start---");
|
|
|
List<PNSSendData> saleUploads = getSaleDataUpload();
|
|
|
@@ -64,7 +64,6 @@ public class PnsDataSyncTask {
|
|
|
pageReq.put("current_data_count", String.valueOf(pageSize));
|
|
|
pageReq.put("detail", JSONArray.toJSONString(saleUploads.subList(i*pageSize, (i+1)*pageSize),SerializerFeature.WriteMapNullValue));
|
|
|
}
|
|
|
- logger.info("{}",pageReq.toString());
|
|
|
try {
|
|
|
HttpUtil.Response response = HttpUtil.sendPostRequest(pnsConfig.getRoute(), reqHeader, pageReq.toString());
|
|
|
logger.info("{}, statusCode{},{}",response.getResponseText(), response.getStatusCode(), response.getStatusCode() == HttpStatus.OK.value());
|
|
|
@@ -72,10 +71,7 @@ public class PnsDataSyncTask {
|
|
|
String data = response.getResponseText();
|
|
|
logger.info("{}", StringUtils.hasText(data));
|
|
|
if (StringUtils.hasText(data)) {
|
|
|
- logger.info("{}", FlexJsonUtil.fromJson(data));
|
|
|
- logger.info("{}", FlexJsonUtil.fromJson(data).get("result"));
|
|
|
PNSSendResp resp = FlexJsonUtil.fromJson(String.valueOf(FlexJsonUtil.fromJson(data).get("result")), PNSSendResp.class);
|
|
|
- logger.info("{},{}",resp,resp.getSuccess());
|
|
|
if(resp.getSuccess()) {
|
|
|
logger.info("Sale Upload success Size {}", i);
|
|
|
pageReq.put("if_batch_no",resp.getIf_batch_no());
|