|
|
@@ -35,7 +35,8 @@ public class LingxingTask {
|
|
|
@Autowired
|
|
|
private BaseDao baseDao;
|
|
|
//定时注解 @cron
|
|
|
- @Scheduled(cron = "0 0 1 * * ?")
|
|
|
+ //@Scheduled(cron = "0 0 1 * * ?")
|
|
|
+ @Scheduled(cron = "0 0/5 * * * ?")
|
|
|
public void getSellerOrders(){
|
|
|
logger.info("同步领星订单-开始");
|
|
|
Date date = new Date();
|
|
|
@@ -45,6 +46,8 @@ public class LingxingTask {
|
|
|
//final CountDownLatch countDownLatch = new CountDownLatch(appSet.size());
|
|
|
try {
|
|
|
appSet.stream().forEach(appId -> {
|
|
|
+ baseDao.execute("insert into MESSAGELOGLX (MLL_ID,MLL_DATE,MLL_CONTENT,MLL_RESULT,MLL_APPID) " +
|
|
|
+ "values(MESSAGELOGLX_SEQ.nextval,sysdate,'测试','测试','" + appId + "')");
|
|
|
lingxingService.getSellerOrders(appId);
|
|
|
});
|
|
|
//countDownLatch.await();
|
|
|
@@ -52,7 +55,7 @@ public class LingxingTask {
|
|
|
e.printStackTrace();
|
|
|
}*/
|
|
|
catch (Exception e){
|
|
|
- System.out.println( e.getMessage());;
|
|
|
+ System.out.println( e.getMessage());
|
|
|
}
|
|
|
}
|
|
|
logger.info("同步领星订单-结束:用时"+((System.currentTimeMillis()-date.getTime())/1000));
|