新增 绑定停车平台接口

jsowell-admin/src/main/java/com/jsowell/web/controller/pile/PileStationInfoController.java

@@ -1,5 +1,6 @@
 package com.jsowell.web.controller.pile;
 
+import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
 import com.jsowell.common.annotation.Log;
 import com.jsowell.common.core.controller.BaseController;
@@ -19,7 +20,9 @@ import com.jsowell.pile.dto.FastCreateStationDTO;
 import com.jsowell.pile.dto.LianLianPushStationInfoDTO;
 import com.jsowell.pile.dto.QueryStationDTO;
 import com.jsowell.pile.dto.amap.EditAmapFlagDTO;
+import com.jsowell.pile.dto.lutongyunting.BindParkingPlatformDTO;
 import com.jsowell.pile.service.IPileStationInfoService;
+import com.jsowell.pile.service.IThirdPartyParkingConfigService;
 import com.jsowell.pile.service.IThirdPartyStationRelationService;
 import com.jsowell.pile.service.IThirdPartySettingInfoService;
 import com.jsowell.pile.vo.web.PileStationVO;
@@ -56,6 +59,9 @@ public class PileStationInfoController extends BaseController {
 	@Autowired
 	private IThirdPartyStationRelationService thirdPartyStationRelationService;
 
+	@Autowired
+	private IThirdPartyParkingConfigService parkingConfigService;
+
 
 	/**
 	 * 查询充电站信息列表NEW
@@ -280,4 +286,43 @@ public class PileStationInfoController extends BaseController {
 		return response;
 	}
 
+	/**
+	 * 绑定停车平台（停车充电下发优惠券）
+	 * @param dto
+	 * @return
+	 */
+	@PostMapping("/bindParkingPlatform")
+	public RestApiResponse<?> bindParkingPlatform(BindParkingPlatformDTO dto) {
+		logger.info("绑定停车平台 params:{}", JSON.toJSONString(dto));
+		RestApiResponse<?> response = null;
+		try {
+			pileStationInfoService.bindParkingPlatform(dto);
+		}catch (BusinessException e) {
+			logger.error("绑定停车平台 error,", e);
+			response = new RestApiResponse<>(e.getCode(), e.getMessage());
+		} catch (Exception e) {
+			logger.error("绑定停车平台 error", e);
+			response = new RestApiResponse<>(e);
+		}
+		logger.info("绑定停车平台 result:{}", response);
+		return response;
+	}
+
+	/**
+	 * 获取停车平台列表
+	 * @return
+	 */
+	@GetMapping("/getParkingInfoList")
+	public RestApiResponse<?> getParkingInfoList() {
+		logger.info("获取停车平台列表");
+		RestApiResponse<?> response = null;
+		try {
+			
+		} catch (Exception e) {
+			logger.error("获取停车平台列表 error,", e);
+			response = new RestApiResponse<>(e);
+		}
+		logger.info("获取停车平台列表 result:{}", response);
+		return response;
+	}
 }

jsowell-common/src/main/java/com/jsowell/common/enums/ykc/ReturnCodeEnum.java

@@ -118,6 +118,8 @@ public enum ReturnCodeEnum {
 
 	CODE_QUERY_WECHAT_APP_ID_IS_NULL("00100056", "未查询到商户的微信小程序id"),
 
+	CODE_QUERY_PARKING_INFO_IS_NULL("00100057", "未查到停车平台信息"),
+
 	/* 个人桩 start */
 
 	CODE_PILE_HAS_BEEN_BINDING_ERROR("00400001", "此桩已被绑定，请联系管理员！"),

jsowell-pile/src/main/java/com/jsowell/pile/dto/lutongyunting/BindParkingPlatformDTO.java

@@ -0,0 +1,16 @@
+package com.jsowell.pile.dto.lutongyunting;
+
+import lombok.Data;
+
+/**
+ * 绑定停车平台DTO
+ *
+ * @author Lemon
+ * @Date 2023/8/25 13:34
+ */
+@Data
+public class BindParkingPlatformDTO {
+    private String stationId;
+
+    private String parkingId;
+}

jsowell-pile/src/main/java/com/jsowell/pile/mapper/PileStationInfoMapper.java

@@ -88,4 +88,10 @@ public interface PileStationInfoMapper {
 	 * @return
 	 */
     List<String> getIdsByDeptId(String deptId);
+
+	/**
+	 * 修改绑定停车平台
+	 * @param stationId
+	 */
+	int updateParkingPlatform(@Param("parkingId") String parkingId, @Param("stationId") String stationId);
 }

jsowell-pile/src/main/java/com/jsowell/pile/mapper/ThirdpartyParkingConfigMapper.java

@@ -1,6 +1,8 @@
 package com.jsowell.pile.mapper;
 
+import com.jsowell.pile.domain.ThirdPartyPlatformConfig;
 import com.jsowell.pile.domain.ThirdpartyParkingConfig;
+import org.springframework.stereotype.Repository;
 
 /**
  * TODO
@@ -8,6 +10,7 @@ import com.jsowell.pile.domain.ThirdpartyParkingConfig;
  * @Date 2023/8/24 16:50
  * @author  Lemon 
  */
+@Repository
 public interface ThirdpartyParkingConfigMapper {
     /**
      * delete by primary key

jsowell-pile/src/main/java/com/jsowell/pile/service/IPileStationInfoService.java

@@ -4,6 +4,7 @@ import com.jsowell.common.core.page.PageResponse;
 import com.jsowell.pile.domain.PileStationInfo;
 import com.jsowell.pile.dto.FastCreateStationDTO;
 import com.jsowell.pile.dto.QueryStationDTO;
+import com.jsowell.pile.dto.lutongyunting.BindParkingPlatformDTO;
 import com.jsowell.pile.vo.web.PileStationVO;
 
 import java.util.List;
@@ -105,4 +106,10 @@ public interface IPileStationInfoService {
 	 * @return
 	 */
 	List<String> getIdsByDeptId(String deptId);
+
+	/**
+	 * 绑定停车系统平台
+	 * @param dto
+	 */
+	int bindParkingPlatform(BindParkingPlatformDTO dto);
 }

jsowell-pile/src/main/java/com/jsowell/pile/service/IThirdPartyParkingConfigService.java

@@ -0,0 +1,53 @@
+package com.jsowell.pile.service;
+
+import com.jsowell.pile.domain.ThirdpartyParkingConfig;
+
+/**
+ * 第三方停车平台Service
+ *
+ * @author Lemon
+ * @Date 2023/8/25 13:42
+ */
+public interface IThirdPartyParkingConfigService {
+    /**
+     * delete by primary key
+     * @param id primaryKey
+     * @return deleteCount
+     */
+    int deleteByPrimaryKey(Integer id);
+
+    /**
+     * insert record to table
+     * @param record the record
+     * @return insert count
+     */
+    int insert(ThirdpartyParkingConfig record);
+
+    /**
+     * insert record to table selective
+     * @param record the record
+     * @return insert count
+     */
+    int insertSelective(ThirdpartyParkingConfig record);
+
+    /**
+     * select by primary key
+     * @param id primary key
+     * @return object by primary key
+     */
+    ThirdpartyParkingConfig selectByPrimaryKey(Integer id);
+
+    /**
+     * update record selective
+     * @param record the updated record
+     * @return update count
+     */
+    int updateByPrimaryKeySelective(ThirdpartyParkingConfig record);
+
+    /**
+     * update record
+     * @param record the updated record
+     * @return update count
+     */
+    int updateByPrimaryKey(ThirdpartyParkingConfig record);
+}

jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileStationInfoServiceImpl.java

@@ -9,6 +9,8 @@ import com.jsowell.common.core.domain.entity.SysUser;
 import com.jsowell.common.core.domain.vo.AuthorizedDeptVO;
 import com.jsowell.common.core.page.PageResponse;
 import com.jsowell.common.core.redis.RedisCache;
+import com.jsowell.common.enums.ykc.ReturnCodeEnum;
+import com.jsowell.common.exception.BusinessException;
 import com.jsowell.common.util.DateUtils;
 import com.jsowell.common.util.DistanceUtils;
 import com.jsowell.common.util.SecurityUtils;
@@ -16,8 +18,11 @@ import com.jsowell.common.util.StringUtils;
 import com.jsowell.common.util.ip.AddressUtils;
 import com.jsowell.pile.domain.PileBasicInfo;
 import com.jsowell.pile.domain.PileStationInfo;
+import com.jsowell.pile.domain.ThirdPartyPlatformConfig;
+import com.jsowell.pile.domain.ThirdpartyParkingConfig;
 import com.jsowell.pile.dto.FastCreateStationDTO;
 import com.jsowell.pile.dto.QueryStationDTO;
+import com.jsowell.pile.dto.lutongyunting.BindParkingPlatformDTO;
 import com.jsowell.pile.mapper.PileStationInfoMapper;
 import com.jsowell.pile.service.*;
 import com.jsowell.pile.vo.base.MerchantInfoVO;
@@ -73,6 +78,8 @@ public class PileStationInfoServiceImpl implements IPileStationInfoService {
 	@Autowired
 	private SysUserService userService;
 
+	@Autowired
+	private IThirdPartyParkingConfigService parkingConfigService;
 
 
 	/**
@@ -486,5 +493,25 @@ public class PileStationInfoServiceImpl implements IPileStationInfoService {
         return pileStationInfoMapper.getIdsByDeptId(deptId);
     }
 
+	/**
+	 * 绑定停车系统平台
+	 * @param dto
+	 */
+    @Override
+    public int bindParkingPlatform(BindParkingPlatformDTO dto) {
+		String parkingId = dto.getParkingId();
+		String stationId = dto.getStationId();
+		// 先根据停车系统平台查询一下是否有数据
+		ThirdpartyParkingConfig basicInfo = parkingConfigService.selectByPrimaryKey(Integer.parseInt(parkingId));
+		if (basicInfo == null) {
+			throw new BusinessException(ReturnCodeEnum.CODE_QUERY_PARKING_INFO_IS_NULL);
+		}
+		// 先删除缓存
+		String redisKey = CacheConstants.SELECT_PILE_STATION_INFO_BY_ID + stationId;
+		redisCache.deleteObject(redisKey);
+		// 再将站点信息表中绑定上parkingId
+        return pileStationInfoMapper.updateParkingPlatform(parkingId, stationId);
+    }
+
 }
 

jsowell-pile/src/main/java/com/jsowell/pile/service/impl/ThirdPartyParkingConfigServiceImpl.java

@@ -0,0 +1,52 @@
+package com.jsowell.pile.service.impl;
+
+import com.jsowell.pile.domain.ThirdpartyParkingConfig;
+import com.jsowell.pile.mapper.ThirdpartyParkingConfigMapper;
+import com.jsowell.pile.service.IThirdPartyParkingConfigService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * TODO
+ *
+ * @author Lemon
+ * @Date 2023/8/25 13:43
+ */
+@Service
+public class ThirdPartyParkingConfigServiceImpl implements IThirdPartyParkingConfigService {
+
+    @Autowired
+    private ThirdpartyParkingConfigMapper thirdpartyParkingConfigMapper;
+
+
+    @Override
+    public int deleteByPrimaryKey(Integer id) {
+        return thirdpartyParkingConfigMapper.deleteByPrimaryKey(id);
+    }
+
+    @Override
+    public int insert(ThirdpartyParkingConfig record) {
+        return thirdpartyParkingConfigMapper.insert(record);
+    }
+
+    @Override
+    public int insertSelective(ThirdpartyParkingConfig record) {
+        return thirdpartyParkingConfigMapper.insertSelective(record);
+    }
+
+    @Override
+    public ThirdpartyParkingConfig selectByPrimaryKey(Integer id) {
+        return thirdpartyParkingConfigMapper.selectByPrimaryKey(id);
+    }
+
+    @Override
+    public int updateByPrimaryKeySelective(ThirdpartyParkingConfig record) {
+        return thirdpartyParkingConfigMapper.updateByPrimaryKeySelective(record);
+    }
+
+    @Override
+    public int updateByPrimaryKey(ThirdpartyParkingConfig record) {
+        return thirdpartyParkingConfigMapper.updateByPrimaryKey(record);
+    }
+
+}

jsowell-pile/src/main/resources/mapper/pile/PileStationInfoMapper.xml

@@ -421,4 +421,13 @@
         where
             dept_id = #{deptId,jdbcType=VARCHAR}
     </select>
+
+    <update id="updateParkingPlatform">
+        update
+            pile_station_info
+        set
+            parking_id = #{parkingId,jdbcType=VARCHAR}
+        where
+            id = #{stationId,jdbcType=VARCHAR}
+    </update>
 </mapper>

jsowell-pile/src/main/resources/mapper/pile/ThirdpartyParkingConfigMapper.xml

@@ -16,11 +16,22 @@
         <result column="update_by" jdbcType="VARCHAR" property="updateBy"/>
         <result column="del_flag" jdbcType="VARCHAR" property="delFlag"/>
     </resultMap>
+
     <sql id="Base_Column_List">
         <!--@mbg.generated-->
-    id, parking_name, app_id, secret_key, parking_merchant_id, coupon_id, create_time, 
+        id,
-    create_by, update_time, update_by, del_flag
+        parking_name,
+        app_id,
+        secret_key,
+        parking_merchant_id,
+        coupon_id,
+        create_time,
+        create_by,
+        update_time,
+        update_by,
+        del_flag
     </sql>
+
     <select id="selectByPrimaryKey" parameterType="java.lang.Integer" resultMap="BaseResultMap">
         <!--@mbg.generated-->
         select
@@ -28,11 +39,14 @@
         from thirdparty_parking_config
         where id = #{id,jdbcType=INTEGER}
     </select>
+
     <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer">
         <!--@mbg.generated-->
-    delete from thirdparty_parking_config
+        delete
+        from thirdparty_parking_config
         where id = #{id,jdbcType=INTEGER}
     </delete>
+
     <insert id="insert" parameterType="com.jsowell.pile.domain.ThirdpartyParkingConfig">
         <!--@mbg.generated-->
         insert into thirdparty_parking_config (id, parking_name, app_id,
@@ -44,6 +58,7 @@
                 #{createTime,jdbcType=TIMESTAMP}, #{createBy,jdbcType=VARCHAR}, #{updateTime,jdbcType=TIMESTAMP},
                 #{updateBy,jdbcType=VARCHAR}, #{delFlag,jdbcType=VARCHAR})
     </insert>
+
     <insert id="insertSelective" parameterType="com.jsowell.pile.domain.ThirdpartyParkingConfig">
         <!--@mbg.generated-->
         insert into thirdparty_parking_config
@@ -118,6 +133,7 @@
             </if>
         </trim>
     </insert>
+
     <update id="updateByPrimaryKeySelective" parameterType="com.jsowell.pile.domain.ThirdpartyParkingConfig">
         <!--@mbg.generated-->
         update thirdparty_parking_config
@@ -155,6 +171,7 @@
         </set>
         where id = #{id,jdbcType=INTEGER}
     </update>
+
     <update id="updateByPrimaryKey" parameterType="com.jsowell.pile.domain.ThirdpartyParkingConfig">
         <!--@mbg.generated-->
         update thirdparty_parking_config

jsowell-ui/src/api/pile/station.js

@@ -130,6 +130,7 @@ export function updateSettingByStationId(data) {
 //   })
 // }
 
+// 推送充电站信息到联联平台
 export function pushStationInfo(data) {
   return request({
     url: "/pile/station/pushStationInfo",
@@ -138,3 +139,12 @@ export function pushStationInfo(data) {
   })
 }
 
+// 绑定停车平台
+export function bindParkingPlatform(data) {
+  return request({
+    url: '/pile/station/bindParkingPlatform',
+    method: 'post',
+    data: data,
+  })
+}
+