This commit is contained in:
linfso 2024-06-18 00:19:15 +08:00
parent bc924cd3ee
commit ea833287db
2 changed files with 52 additions and 24 deletions

View File

@ -425,10 +425,14 @@ public class EmisCommonController extends EmisBaseController
} }
@RequestMapping("/autoDoSendSmsTest") /**
public AjaxResult autoDoSendSmsTest(){ * 短信发送触发
String lockKey="autoDoSendSmsTest"; * @return
log.error("autoDoSendSmsTest start"); */
@RequestMapping("/autoDoSendSmsTrigger")
public AjaxResult autoDoSendSmsTrigger(){
String lockKey="autoDoSendSmsTrigger";
log.error("autoDoSendSmsTrigger start");
// 加锁查询 // 加锁查询
redissonService.lock(lockKey,300); redissonService.lock(lockKey,300);
@ -436,13 +440,37 @@ public class EmisCommonController extends EmisBaseController
emisBaseService.autoDoSmsSend(); emisBaseService.autoDoSmsSend();
}catch(Exception ex){ }catch(Exception ex){
ex.printStackTrace(); ex.printStackTrace();
log.error("autoDoSendSmsTest exception:"+ex.getMessage()); log.error("autoDoSendSmsTrigger exception:"+ex.getMessage());
} }
log.error("autoDoSendSmsTest end"); log.error("autoDoSendSmsTrigger end");
redissonService.unlock(lockKey); redissonService.unlock(lockKey);
return AjaxResult.success("发送成功"); return AjaxResult.success("发送成功");
} }
/**
* 物流轨迹采集触发
* @return
*/
@RequestMapping("/autoDoQueryTransferInfoTrigger")
public AjaxResult autoDoQueryTransferInfoTrigger(){
String lockKey="autoDoQueryTransferInfoTrigger";
log.error("autoDoQueryTransferInfoTrigger start");
// 加锁查询
redissonService.lock(lockKey,300);
try{
emisBaseService.doTransferTraceUpdate();
}catch(Exception ex){
ex.printStackTrace();
log.error("autoDoQueryTransferInfoTrigger exception:"+ex.getMessage());
}
log.error("autoDoQueryTransferInfoTrigger end");
redissonService.unlock(lockKey);
return AjaxResult.success("发送成功");
}
} }

View File

@ -35,24 +35,24 @@ public class LogisticTask {
/** /**
* 自动查询转件物流信息 * 自动查询转件物流信息
*/ */
@Async // @Async
@Scheduled(fixedRate = 1000L * 60 * 5) // @Scheduled(fixedRate = 1000L * 60 * 5)
public void autoDoQueryTransferInfo() { // public void autoDoQueryTransferInfo() {
String lockKey="autoDoQueryTransferInfo"; // String lockKey="autoDoQueryTransferInfo";
log.error("autoDoQueryTransferInfo start"); // log.error("autoDoQueryTransferInfo start");
//
// 加锁查询 // // 加锁查询
redissonService.lock(lockKey,300); // redissonService.lock(lockKey,300);
try{ // try{
emisBaseService.doTransferTraceUpdate(); // emisBaseService.doTransferTraceUpdate();
}catch(Exception ex){ // }catch(Exception ex){
ex.printStackTrace(); // ex.printStackTrace();
log.error("autoDoQueryTransferInfo exception:"+ex.getMessage()); // log.error("autoDoQueryTransferInfo exception:"+ex.getMessage());
} // }
log.error("autoDoQueryTransferInfo end"); // log.error("autoDoQueryTransferInfo end");
//
redissonService.unlock(lockKey); // redissonService.unlock(lockKey);
} // }
/** /**