优化

src/main/java/com/glxp/api/controller/collect/IoCollectOrderBackupController.java

@@ -57,20 +57,21 @@ public class IoCollectOrderBackupController extends BaseController {
 
         List<Long> workPlaceCodes = null;
         List<UserWorkResponse> 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<IoCollectOrderResponse> orderResponses = ioCollectOrderBackupService.filterList(collectOrderRequest);
         PageInfo<IoCollectOrderResponse> pageInfo = new PageInfo<>(orderResponses);

src/main/java/com/glxp/api/service/collect/IoCollectOrderBackupService.java

@@ -175,7 +175,7 @@ public class IoCollectOrderBackupService extends ServiceImpl<IoCollectOrderBacku
             if(StringUtils.isEmpty(collectOrderBizResponse.getFinishUdiCode())){
                 List<IoCollectCodeBackup> ioCollectCodeBackupList = ioCollectCodeBackMapper.selectList(new QueryWrapper<IoCollectCodeBackup>()
                         .eq("billNo",collectOrderBizRequest.getOrderIdFk())
-                        .eq("relId",collectOrderBiz.getId())
+                        .eq("relId",collectOrderBiz.getRelId())
                         .groupBy("code")
                 );
 

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<SysWorkplaceBus>().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());

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,9 +54,12 @@ public class AsyncIoCollectOrderUploadTask implements SchedulingConfigurer {
                 triggerContext -> {
                     ScheduledRequest scheduledRequest = new ScheduledRequest();
                     scheduledRequest.setCronName("ioCollectOrderUploadTask");
+                    ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest);
+                    String cron = null;
+
+                    if(scheduledEntity==null){
                         // 使用设置的轮询时间为准 这边进行转换
                         IoCollectSet ioCollectSet = collectSetService.getSet();
-                    String cron = null;
                         if (ioCollectSet != null
                                 && ioCollectSet.getStartUploadHour() != null
                                 && ioCollectSet.getStartUploadHour() > 0
@@ -72,6 +76,10 @@ public class AsyncIoCollectOrderUploadTask implements SchedulingConfigurer {
                         if (cron.isEmpty()) {
                             logger.error("cron is null");
                         }
+                    }else {
+                         cron = scheduledEntity != null ? scheduledEntity.getCron() : "0 */30 * * * ?";
+                    }
+
                     return new CronTrigger(cron).nextExecutionTime(triggerContext);
                 });
     }