提交代码

schedule/src/main/java/com/hfkj/schedule/GasSchedule.java

@@ -0,0 +1,27 @@
+package com.hfkj.schedule;
+
+import com.hfkj.channel.gas.newlink.NewLinkGasService;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+
+/**
+ * @className: GasSchedule
+ * @author: HuRui
+ * @date: 2024/7/15
+ **/
+@Component
+public class GasSchedule {
+    @Resource
+    private NewLinkGasService newLinkGasService;
+    @Scheduled(cron = "5 0 0 * * ?")   // 每日凌晨00:00:5执行一次
+    public void GasSchedule() {
+        try {
+            newLinkGasService.refresh();
+        } catch (Exception e) {
+            System.out.println("能链【团油】油站获取失败！！！");
+        }
+    }
+}

service/src/main/java/com/hfkj/dao/BsGasOilPriceMapperExt.java

@@ -16,6 +16,7 @@ import java.util.Map;
 public interface BsGasOilPriceMapperExt {
     @Select({" select b.* from bs_merchant a, bs_gas_oil_price b " +
             "  where a.id = b.mer_id " +
+            "  and a.source_type = 1 " +
             "  and a.`status` = 1 " +
             "  and a.province_code = #{regionId} " +
             "  and b.oil_no = #{oilNo} "})