feat(cyl):新增接口 向以天为维度的企业气瓶统计表刷入数据，支持指定时间及企业appid

amos-boot-system-tzs/amos-boot-module-cylinder/amos-boot-module-cylinder-api/src/main/java/com/yeejoin/amos/boot/module/cylinder/flc/api/service/ICylinderInfoService.java

@@ -45,7 +45,9 @@ public interface ICylinderInfoService {
 
 	void fillingCheckDataSynHandler();
 
-    void fillingRecordDataSynHandler();
+	void oneDayEnterpriseCylinderDataRefreshTask(String day, String appId);
+
+	void fillingRecordDataSynHandler();
 
     void synFillingUnloadUnitData();
 

amos-boot-system-tzs/amos-boot-module-cylinder/amos-boot-module-cylinder-biz/src/main/java/com/yeejoin/amos/boot/module/cylinder/flc/biz/controller/CylinderInfoController.java

@@ -1337,13 +1337,24 @@ public class CylinderInfoController extends BaseController {
 	}
 
 	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
-	@ApiOperation(httpMethod = "GET", value = "主动向以天为维度的企业气瓶统计表中刷入当前时间前30天的数据")
+	@ApiOperation(httpMethod = "GET", value = "先清除表数据，再主动向以天为维度的企业气瓶统计表中刷入当前时间前30天的数据")
 	@GetMapping(value = "/thirtyDayEnterpriseCylinderDataRefreshTask")
 	public ResponseModel<Object> thirtyDayEnterpriseCylinderDataRefreshTask() {
 		cylinderInfoServiceImpl.fillingRecordDataSynHandler();
 		return ResponseHelper.buildResponse("ok");
 	}
 
+	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+	@ApiOperation(httpMethod = "GET", value = "以天为维度的企业气瓶统计表中刷入某天的数据，" +
+			"支持传参：1、某天day（必填）：刷入时间，例如2024-06-07；2、企业appId(非必填，如果不填则刷入所有企业的day数据):刷入企业的appId")
+	@GetMapping(value = "/oneDayEnterpriseCylinderDataRefreshTask")
+	public ResponseModel<Object> oneDayEnterpriseCylinderDataRefreshTask(
+			@RequestParam(value = "day",required = true) String day,
+			@RequestParam(value = "appId",required = false) String appId) {
+		cylinderInfoServiceImpl.oneDayEnterpriseCylinderDataRefreshTask(day, appId);
+		return ResponseHelper.buildResponse("ok");
+	}
+
 	/**
 	 * 地市气瓶,气站信息统计
 	 *

amos-boot-system-tzs/amos-boot-module-cylinder/amos-boot-module-cylinder-biz/src/main/java/com/yeejoin/amos/boot/module/cylinder/flc/biz/service/impl/CylinderInfoServiceImpl.java

@@ -806,21 +806,50 @@ public class CylinderInfoServiceImpl extends BaseService<CylinderInfoDto, Cylind
         cylinderFillingCheckDataUnitDto.setAppId(cylinderUnit.getAppId());
     }
 
-
     @Override
-    public void fillingRecordDataSynHandler() {
-        // 清空数据
-        cylinderFillingRecordStatisticsUnitDayServiceImpl.remove(new LambdaQueryWrapper<>());
-        countByUnit(cylinderUnit -> {
-            // 当前企业前31天数据填充
+    public void oneDayEnterpriseCylinderDataRefreshTask(String day, String appId) {
+        try {
+            SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
+            Date date = formatter.parse(day);
             Calendar calendar = Calendar.getInstance();
-            for (int i = 0; i <= 30; i++) {
+            calendar.setTime(date);
+            if (ValidationUtil.isEmpty(appId)) {// 刷入所有企业数据
+                CompletableFuture.runAsync(() -> countByUnit(cylinderUnit -> {
+                    CylinderFillingRecordStatisticsUnitDayDto unitDay = new CylinderFillingRecordStatisticsUnitDayDto();
+                    calcCylinderFillingCheckDataUnitDataWithDay(cylinderUnit, calendar, unitDay);
+                    cylinderFillingRecordStatisticsUnitDayServiceImpl.createWithModel(unitDay);
+                }));
+            } else {// 刷入指定企业数据
+                CylinderUnit targetUnit = cylinderUnitServiceImpl.list().stream()
+                        .filter(unit -> unit.getAppId().equals(appId))
+                        .findFirst()
+                        .orElseThrow(() -> new NoSuchElementException("没有对应appid的企业"));
                 CylinderFillingRecordStatisticsUnitDayDto unitDay = new CylinderFillingRecordStatisticsUnitDayDto();
-                calendar.add(Calendar.DAY_OF_MONTH, -1);
-                calcCylinderFillingCheckDataUnitDataWithDay(cylinderUnit,calendar,unitDay);
+                calcCylinderFillingCheckDataUnitDataWithDay(targetUnit, calendar, unitDay);
                 cylinderFillingRecordStatisticsUnitDayServiceImpl.createWithModel(unitDay);
             }
-        });
+        } catch (ParseException e) {
+            log.error("日期解析错误", e);
+        } catch (NoSuchElementException e) {
+            log.error("未找到指定appid的企业", e);
+        } catch (Exception e) {
+            log.error("刷新企业气瓶数据任务出错", e);
+        }
+    }
+
+
+    @Override
+    public void fillingRecordDataSynHandler() {
+        CompletableFuture.runAsync(() -> cylinderFillingRecordStatisticsUnitDayServiceImpl.remove(new LambdaQueryWrapper<>()))
+                .thenRunAsync(() -> countByUnit(cylinderUnit -> {
+                    Calendar calendar = Calendar.getInstance();
+                    for (int i = 0; i <= 30; i++) {
+                        CylinderFillingRecordStatisticsUnitDayDto unitDay = new CylinderFillingRecordStatisticsUnitDayDto();
+                        calendar.add(Calendar.DAY_OF_MONTH, -1);
+                        calcCylinderFillingCheckDataUnitDataWithDay(cylinderUnit, calendar, unitDay);
+                        cylinderFillingRecordStatisticsUnitDayServiceImpl.createWithModel(unitDay);
+                    }
+                }));
     }
 
     /**