Переглянути джерело

fix(service): 修正策略费查询中使用的站点ID

- 将策略费查询条件中的站点ID由传入参数改为主键ID
- 确保平台和企业策略费查询语句中使用stationInfo.getId()

fix(charging): 启用充电站信息与价格策略同步任务

- 取消注释充电站信息同步定时任务的@Scheduled注解
- 取消注释充电桩价格策略同步定时任务的@Scheduled注解
- 确保定时任务按计划每15分钟和每10分钟执行
SheepHy 2 тижнів тому
батько
коміт
881f48cb7a

+ 2 - 2
src/main/java/com/zsElectric/boot/business/service/impl/AppletHomeServiceImpl.java

@@ -472,7 +472,7 @@ public class AppletHomeServiceImpl implements AppletHomeService {
         Map<Integer, PolicyFee> platformPriceMap = new HashMap<>();
         List<PolicyFee> platformPolicyFeeList = policyFeeMapper.selectList(
                 new LambdaQueryWrapper<PolicyFee>()
-                        .eq(PolicyFee::getStationInfoId, stationId)
+                        .eq(PolicyFee::getStationInfoId, stationInfo.getId())  // 使用主键ID
                         .eq(PolicyFee::getSalesType, 0) // 0-平台
                         .eq(PolicyFee::getIsDeleted, 0)
         );
@@ -487,7 +487,7 @@ public class AppletHomeServiceImpl implements AppletHomeService {
         if (firmId != null) {
             List<PolicyFee> policyFeeList = policyFeeMapper.selectList(
                     new LambdaQueryWrapper<PolicyFee>()
-                            .eq(PolicyFee::getStationInfoId, stationId)
+                            .eq(PolicyFee::getStationInfoId, stationInfo.getId())  // 使用主键ID
                             .eq(PolicyFee::getSalesType, 1) // 1-企业
                             .eq(PolicyFee::getFirmId, firmId)
                             .eq(PolicyFee::getIsDeleted, 0)

+ 2 - 2
src/main/java/com/zsElectric/boot/charging/quartz/ChargingJob.java

@@ -45,7 +45,7 @@ public class ChargingJob {
      * 同步充电站信息
      * 每5分钟执行一次,从第三方接口获取充电站信息并存储到数据库
      */
-//    @Scheduled(cron = "0 0/15 * * * ?")
+    @Scheduled(cron = "0 0/15 * * * ?")
     public void syncStationsInfo() {
         log.info("开始执行充电站信息同步定时任务");
 
@@ -82,7 +82,7 @@ public class ChargingJob {
      * 每10分钟执行一次,查询所有充电桩的价格策略并存储到数据库
      * cron表达式: 0 10 * * * ? 表示每10分钟执行
      */
-//    @Scheduled(cron = "0 */10 * * * ?")
+    @Scheduled(cron = "0 */10 * * * ?")
     public void syncEquipmentPricePolicy() {
         // 检查任务是否正在执行,防止并发
         if (isPricePolicySyncRunning) {