diff --git a/src/main/java/com/glxp/api/controller/collect/IoCollectOrderBackupController.java b/src/main/java/com/glxp/api/controller/collect/IoCollectOrderBackupController.java index 9464684a4..43a3df753 100644 --- a/src/main/java/com/glxp/api/controller/collect/IoCollectOrderBackupController.java +++ b/src/main/java/com/glxp/api/controller/collect/IoCollectOrderBackupController.java @@ -57,20 +57,21 @@ public class IoCollectOrderBackupController extends BaseController { List workPlaceCodes = null; List page; - if (collectOrderRequest.getWorkPlaceCode() == null) { - Long userId = getUserId(); - BasicCollectUserRequest request = new BasicCollectUserRequest(); - request.setPage(1); - request.setLimit(100); - request.setUserId(userId.toString()); - page = basicCollectUserService.filterList(request); - if (page != null) { - workPlaceCodes = page.stream() - .map(UserWorkResponse::getWorkplaceId) - .collect(Collectors.toList()); - } - collectOrderRequest.setWorkPlaceCodes(workPlaceCodes); - } + // 上传医保不做登录权限限制 +// if (collectOrderRequest.getWorkPlaceCode() == null) { +// Long userId = getUserId(); +// BasicCollectUserRequest request = new BasicCollectUserRequest(); +// request.setPage(1); +// request.setLimit(100); +// request.setUserId(userId.toString()); +// page = basicCollectUserService.filterList(request); +// if (page != null) { +// workPlaceCodes = page.stream() +// .map(UserWorkResponse::getWorkplaceId) +// .collect(Collectors.toList()); +// } +// collectOrderRequest.setWorkPlaceCodes(workPlaceCodes); +// } log.error("collectOrderRequest"+collectOrderRequest); List orderResponses = ioCollectOrderBackupService.filterList(collectOrderRequest); PageInfo pageInfo = new PageInfo<>(orderResponses); diff --git a/src/main/java/com/glxp/api/service/collect/IoCollectOrderBackupService.java b/src/main/java/com/glxp/api/service/collect/IoCollectOrderBackupService.java index 06aec55a6..a0447e7ac 100644 --- a/src/main/java/com/glxp/api/service/collect/IoCollectOrderBackupService.java +++ b/src/main/java/com/glxp/api/service/collect/IoCollectOrderBackupService.java @@ -175,7 +175,7 @@ public class IoCollectOrderBackupService extends ServiceImpl ioCollectCodeBackupList = ioCollectCodeBackMapper.selectList(new QueryWrapper() .eq("billNo",collectOrderBizRequest.getOrderIdFk()) - .eq("relId",collectOrderBiz.getId()) + .eq("relId",collectOrderBiz.getRelId()) .groupBy("code") ); diff --git a/src/main/java/com/glxp/api/task/AsyncIoCollectOrderFinishTask.java b/src/main/java/com/glxp/api/task/AsyncIoCollectOrderFinishTask.java index a55161bb3..e2abff453 100644 --- a/src/main/java/com/glxp/api/task/AsyncIoCollectOrderFinishTask.java +++ b/src/main/java/com/glxp/api/task/AsyncIoCollectOrderFinishTask.java @@ -108,7 +108,7 @@ public class AsyncIoCollectOrderFinishTask implements SchedulingConfigurer { if (CollUtil.isNotEmpty(ioCollectSetBustypes)) { sysWorkplaceBus = sysWorkplaceBusService.getOne(new LambdaQueryWrapper().eq(SysWorkplaceBus::getBusTypeCode, sysWorkplaceDocumentEntity.getDocumentTypeCode()).last("limit 1")); } - if (sysWorkplaceBus == null) break; + if (sysWorkplaceBus == null) continue; collectOrderRequest.setWorkPlaceCode(sysWorkplaceBus.getWorkplaceCode()); collectOrderRequest.setBusType(sysWorkplaceBus.getBusTypeCode()); collectOrderRequest.setBillNo(collectOrder.getBillNo()); diff --git a/src/main/java/com/glxp/api/task/AsyncIoCollectOrderUploadTask.java b/src/main/java/com/glxp/api/task/AsyncIoCollectOrderUploadTask.java index fc8f31678..ca5dae9bf 100644 --- a/src/main/java/com/glxp/api/task/AsyncIoCollectOrderUploadTask.java +++ b/src/main/java/com/glxp/api/task/AsyncIoCollectOrderUploadTask.java @@ -8,6 +8,7 @@ import com.glxp.api.dao.schedule.ScheduledDao; import com.glxp.api.entity.auth.AuthAdmin; import com.glxp.api.entity.collect.IoCollectSet; import com.glxp.api.entity.collect.IoCollectSetBustype; +import com.glxp.api.entity.system.ScheduledEntity; import com.glxp.api.req.collect.CollectOrderRequest; import com.glxp.api.req.system.ScheduledRequest; import com.glxp.api.res.collect.IoCollectOrderResponse; @@ -53,25 +54,32 @@ public class AsyncIoCollectOrderUploadTask implements SchedulingConfigurer { triggerContext -> { ScheduledRequest scheduledRequest = new ScheduledRequest(); scheduledRequest.setCronName("ioCollectOrderUploadTask"); - // 使用设置的轮询时间为准 这边进行转换 - IoCollectSet ioCollectSet = collectSetService.getSet(); + ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest); String cron = null; - if (ioCollectSet != null - && ioCollectSet.getStartUploadHour() != null - && ioCollectSet.getStartUploadHour() > 0 - ) { - if (ioCollectSet.getStartUploadHour() <= 24) { - cron = "0 0 */" + ioCollectSet.getStartUploadHour() + " * * ? "; + if(scheduledEntity==null){ + // 使用设置的轮询时间为准 这边进行转换 + IoCollectSet ioCollectSet = collectSetService.getSet(); + if (ioCollectSet != null + && ioCollectSet.getStartUploadHour() != null + && ioCollectSet.getStartUploadHour() > 0 + ) { + if (ioCollectSet.getStartUploadHour() <= 24) { + cron = "0 0 */" + ioCollectSet.getStartUploadHour() + " * * ? "; + + } + } else { + cron = "0 0 0 */1 * ?"; } - } else { - cron = "0 0 0 */1 * ?"; - } - logger.info("已完成单据自动上传轮询设置cron表达式===" + cron); + logger.info("已完成单据自动上传轮询设置cron表达式===" + cron); - if (cron.isEmpty()) { - logger.error("cron is null"); + if (cron.isEmpty()) { + logger.error("cron is null"); + } + }else { + cron = scheduledEntity != null ? scheduledEntity.getCron() : "0 */30 * * * ?"; } + return new CronTrigger(cron).nextExecutionTime(triggerContext); }); }