Browse Source

Merge remote-tracking branch 'origin/master'

wzq 18 hours ago
parent
commit
8f5bb53a91

+ 1 - 1
src/main/java/com/zsElectric/boot/business/model/entity/PolicyFee.java

@@ -32,7 +32,7 @@ public class PolicyFee implements Serializable {
     /**
      * 主键ID
      */
-    @TableId(type = IdType.ASSIGN_ID)
+    @TableId(type = IdType.AUTO)
     private Long id;
 
     /**

+ 3 - 0
src/main/java/com/zsElectric/boot/business/model/query/StationInfoQuery.java

@@ -35,4 +35,7 @@ public class StationInfoQuery extends BasePageQuery {
      */
     @Schema(description = "纬度")
     private BigDecimal latitude;
+
+    @Schema(description = "用户ID")
+    private Long userId;
 }

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

@@ -32,16 +32,14 @@ public class AppletHomeServiceImpl implements AppletHomeService {
 
     @Override
     public IPage<StationInfoVO> getStationInfoPage(StationInfoQuery queryParams) {
-        // 获取当前登录用户ID
-        Long userId = SecurityUtils.getUserId();
         
         // 查询用户是否为企业用户,获取企业ID
         Long firmId = null;
         boolean isFirmUser = false;
-        if (userId != null) {
+        if (queryParams.getUserId() != null) {
             UserFirm userFirm = userFirmMapper.selectOne(
                     new LambdaQueryWrapper<UserFirm>()
-                            .eq(UserFirm::getUserId, userId)
+                            .eq(UserFirm::getUserId, queryParams.getUserId())
                             .last("LIMIT 1")
             );
             if (userFirm != null) {

+ 6 - 6
src/main/resources/mapper/business/ThirdPartyStationInfoMapper.xml

@@ -187,8 +187,8 @@
                     END
                 FROM third_party_policy_info tppi
                 INNER JOIN third_party_equipment_price_policy tpepp ON tppi.price_policy_id = tpepp.id AND tpepp.is_deleted = 0
-                INNER JOIN third_party_equipment_info tpei2 ON tpepp.equipment_id = tpei2.equipment_id AND tpei2.is_deleted = 0
-                WHERE tpei2.station_id = tpsi.station_id
+                INNER JOIN third_party_connector_info tpci2 ON tpepp.connector_id = tpci2.connector_id AND tpci2.is_deleted = 0
+                WHERE tpci2.station_id = tpsi.station_id
                     AND tppi.is_deleted = 0
                     AND tppi.start_time &lt;= #{currentTime}
                 ORDER BY tppi.start_time DESC
@@ -205,8 +205,8 @@
                 FROM c_policy_fee pf
                 INNER JOIN third_party_policy_info tppi ON pf.start_time = tppi.start_time
                 INNER JOIN third_party_equipment_price_policy tpepp ON tppi.price_policy_id = tpepp.id AND tpepp.is_deleted = 0
-                INNER JOIN third_party_equipment_info tpei3 ON tpepp.equipment_id = tpei3.equipment_id AND tpei3.is_deleted = 0
-                WHERE tpei3.station_id = tpsi.station_id
+                INNER JOIN third_party_connector_info tpci3 ON tpepp.connector_id = tpci3.connector_id AND tpci3.is_deleted = 0
+                WHERE tpci3.station_id = tpsi.station_id
                     AND pf.station_info_id = tpsi.id
                     AND pf.sales_type = 0
                     AND pf.is_deleted = 0
@@ -227,8 +227,8 @@
                 FROM c_policy_fee pf
                 INNER JOIN third_party_policy_info tppi ON pf.start_time = tppi.start_time
                 INNER JOIN third_party_equipment_price_policy tpepp ON tppi.price_policy_id = tpepp.id AND tpepp.is_deleted = 0
-                INNER JOIN third_party_equipment_info tpei4 ON tpepp.equipment_id = tpei4.equipment_id AND tpei4.is_deleted = 0
-                WHERE tpei4.station_id = tpsi.station_id
+                INNER JOIN third_party_connector_info tpci4 ON tpepp.connector_id = tpci4.connector_id AND tpci4.is_deleted = 0
+                WHERE tpci4.station_id = tpsi.station_id
                     AND pf.station_info_id = tpsi.id
                     AND pf.sales_type = 1
                     AND pf.firm_id = #{firmId}