| | |
|---|
| | | // 执行日志同步任务的方法 |
|---|
| | | public void executeTask(DictHosp dictHosp) { |
|---|
| | | // 获取锁，确保同一时间只有一个任务执行 |
|---|
| | | log.info("{}执行结果同步加锁前",JSONUtil.toJsonStr(dictHosp)); |
|---|
| | | ReentrantLock reentrantLock = getLock(dictHosp.getCode()); |
|---|
| | | boolean lock = reentrantLock.tryLock(); |
|---|
| | | try { |
|---|
| | | log.info("{}执行结果同步加锁后",JSONUtil.toJsonStr(dictHosp)); |
|---|
| | | log.info("{}执行结果同步", dictHosp.getCode()); |
|---|
| | | dataSourceConfig.addDataSource(dictHosp.getDbname()); |
|---|
| | | DataSourceContextHolder.setDataSourceKey(dictHosp.getDbname()); |
|---|
| | | String dsqkssj = configService.selectConfigByKey("dsqkssj"); |
|---|
| | | String dsqjssj = configService.selectConfigByKey("dsqjssj"); |
|---|
| | | boolean panduandangqianshijian = panduandangqianshijian(dsqkssj, dsqjssj); |
|---|
| | | |
|---|
| | | ReentrantLock reentrantLock = getLock(dictHosp.getCode()); |
|---|
| | | boolean lock = reentrantLock.tryLock(); |
|---|
| | | try { |
|---|
| | | if (!panduandangqianshijian) { |
|---|
| | | if (lock) { |
|---|
| | | log.info("任务开始执行时间 -> {}", dateTimeFormat.format(new Date())); |
|---|
