|
|
@ -24,15 +24,14 @@ public class CustomQueryTask {
|
|
|
|
private PmtCustomReportMapper pmtCustomReportMapper;
|
|
|
|
private PmtCustomReportMapper pmtCustomReportMapper;
|
|
|
|
|
|
|
|
|
|
|
|
@Scheduled(cron = "0 0/10 * * * *")
|
|
|
|
@Scheduled(cron = "0 0/10 * * * *")
|
|
|
|
public void customReportQuery(){
|
|
|
|
public void customReportQuery() {
|
|
|
|
List<JSONObject> reports = pmtCustomReportMapper.findCustomReportNotScucess();
|
|
|
|
List<JSONObject> reports = pmtCustomReportMapper.findCustomReportNotScucess();
|
|
|
|
if(!reports.isEmpty()){
|
|
|
|
reports.forEach(report -> {
|
|
|
|
for (JSONObject report:reports) {
|
|
|
|
try {
|
|
|
|
//Alipay直接返回成功与否,Wechat返回的结果较多,成功提交至海关后状态才会变为success,因此只有Wechat需要定时查询报关单状态
|
|
|
|
customSupport.queryCustomResult(report.getString("report_id"));
|
|
|
|
if(report.getString("channel").equals("Wechat")){
|
|
|
|
} catch (Exception e) {
|
|
|
|
customSupport.queryCustomResult(report.getString("report_id"));
|
|
|
|
//donothing
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|