diff --git a/src/main/java/com/muyu/system/controller/BuyInterface.java b/src/main/java/com/muyu/system/controller/BuyInterface.java
index ff9f8e5..0606580 100644
--- a/src/main/java/com/muyu/system/controller/BuyInterface.java
+++ b/src/main/java/com/muyu/system/controller/BuyInterface.java
@@ -2,6 +2,7 @@ package com.muyu.system.controller;
 
 import com.muyu.common.core.domain.Result;
 import com.muyu.system.domain.Connector;
+import com.muyu.system.domain.ConnectorUser;
 import com.muyu.system.service.BuyService;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -24,8 +25,13 @@ public class BuyInterface {
     @Autowired
     private BuyService buyService;
 
+    /**
+     * 购买API接口
+     * @param connectorUser
+     * @return
+     */
     @PostMapping("/doBuyInterface")
-    public Result doBuyInterface(@RequestBody Connector connector){
-        return buyService.doBuyInterface(connector);
+    public Result doBuyInterface(@RequestBody ConnectorUser connectorUser){
+        return buyService.doBuyInterface(connectorUser);
     }
 }
diff --git a/src/main/java/com/muyu/system/domain/ConnectorUser.java b/src/main/java/com/muyu/system/domain/ConnectorUser.java
new file mode 100644
index 0000000..f8d1937
--- /dev/null
+++ b/src/main/java/com/muyu/system/domain/ConnectorUser.java
@@ -0,0 +1,42 @@
+package com.muyu.system.domain;
+
+import lombok.Data;
+
+/**
+ * @Author：chaiyapeng
+ * @Package：com.muyu.system.domain
+ * @Project：cloud-system
+ * @name：ConnectorUser
+ * @Date：2024/9/2 10:00
+ */
+@Data
+public class ConnectorUser {
+    /**
+     * id
+     */
+    private Integer connectorUserId;
+    /**
+     * 用户ID
+     */
+    private Long userId;
+    /**
+     * 接口id
+     */
+    private Integer connectorId;
+    /**
+     * 剩余次数
+     */
+    private Integer connectorResidueDegree;
+    /**
+     * 购买次数
+     */
+    private Integer connectorFrequency;
+    /**
+     * 接口名称
+     */
+    private String connectorName;
+    /**
+     * 用户名称
+     */
+    private String userName;
+}
diff --git a/src/main/java/com/muyu/system/mapper/BuyMapper.java b/src/main/java/com/muyu/system/mapper/BuyMapper.java
index 2ad0812..50fa01e 100644
--- a/src/main/java/com/muyu/system/mapper/BuyMapper.java
+++ b/src/main/java/com/muyu/system/mapper/BuyMapper.java
@@ -2,6 +2,7 @@ package com.muyu.system.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.muyu.system.domain.Connector;
+import com.muyu.system.domain.ConnectorUser;
 
 /**
  * @Author：chaiyapeng
@@ -12,5 +13,9 @@ import com.muyu.system.domain.Connector;
  * 购买接口
  */
 public interface BuyMapper extends BaseMapper<Connector> {
-    Integer doBuyInterface(Connector connector);
+    Integer doBuyInterface(ConnectorUser connectorUser);
+
+    ConnectorUser selectConnectorUser(ConnectorUser connectorUserr);
+
+    Integer addConnectorUser(ConnectorUser connectorUser);
 }
diff --git a/src/main/java/com/muyu/system/service/BuyService.java b/src/main/java/com/muyu/system/service/BuyService.java
index 623aa76..3c6d3e2 100644
--- a/src/main/java/com/muyu/system/service/BuyService.java
+++ b/src/main/java/com/muyu/system/service/BuyService.java
@@ -3,6 +3,7 @@ package com.muyu.system.service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.muyu.common.core.domain.Result;
 import com.muyu.system.domain.Connector;
+import com.muyu.system.domain.ConnectorUser;
 
 /**
  * @Author：chaiyapeng
@@ -13,5 +14,5 @@ import com.muyu.system.domain.Connector;
  * 购买接口
  */
 public interface BuyService extends IService<Connector> {
-    Result doBuyInterface(Connector connector);
+    Result doBuyInterface(ConnectorUser connectorUser);
 }
diff --git a/src/main/java/com/muyu/system/service/impl/BuyServiceImpl.java b/src/main/java/com/muyu/system/service/impl/BuyServiceImpl.java
index 0364938..3929bc2 100644
--- a/src/main/java/com/muyu/system/service/impl/BuyServiceImpl.java
+++ b/src/main/java/com/muyu/system/service/impl/BuyServiceImpl.java
@@ -2,7 +2,10 @@ package com.muyu.system.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.muyu.common.core.domain.Result;
+import com.muyu.common.security.utils.SecurityUtils;
+import com.muyu.common.system.domain.LoginUser;
 import com.muyu.system.domain.Connector;
+import com.muyu.system.domain.ConnectorUser;
 import com.muyu.system.mapper.BuyMapper;
 import com.muyu.system.service.BuyService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -23,8 +26,22 @@ public class BuyServiceImpl extends ServiceImpl<BuyMapper, Connector> implements
     @Resource
     private BuyMapper buyMapper;
     @Override
-    public Result doBuyInterface(Connector connector) {
-        Integer i = buyMapper.doBuyInterface(connector);
+    public Result doBuyInterface(ConnectorUser connectorUser) {
+//        //获取当前用户名
+//        String username = SecurityUtils.getUsername();
+        //获取当前用户ID
+        Long userId = SecurityUtils.getUserId();
+//        //获取当前的用户信息
+//        LoginUser loginUser = SecurityUtils.getLoginUser();
+        ConnectorUser connectorUser1 = buyMapper.selectConnectorUser(connectorUser);
+        if (connectorUser1==null){
+            Integer i = buyMapper.addConnectorUser(connectorUser);
+            if (i>0){
+                buyMapper.doBuyInterface(connectorUser);
+            }
+        }
+        connectorUser.setUserId(userId);
+        Integer i = buyMapper.doBuyInterface(connectorUser);
         if (i>0){
             return Result.success(i,"购买成功");
         }
diff --git a/src/main/resources/mapper/system/BuyMapper.xml b/src/main/resources/mapper/system/BuyMapper.xml
index 82fbbf9..d77bc27 100644
--- a/src/main/resources/mapper/system/BuyMapper.xml
+++ b/src/main/resources/mapper/system/BuyMapper.xml
@@ -3,9 +3,29 @@
         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.muyu.system.mapper.BuyMapper">
+    <insert id="addConnectorUser">
+        INSERT INTO `three-groups`.`connector_user`
+            (`connector_user_id`, `user_id`, `connector_id`, `connector_residue_degree`, `connector_frequency`)
+        VALUES (0,#{userId}, #{connectorId}, 0, 0)
+
+    </insert>
 
 
     <update id="doBuyInterface">
-        update connector set connector_residue_degree=connector_residue_degree+#{connectorFrequency},connector_frequency=connector_frequency+#{connectorFrequency} where connector_id=#{connectorId}
+        update connector_user set connector_residue_degree=connector_residue_degree+#{connectorFrequency},connector_frequency=connector_frequency+#{connectorFrequency} where connector_id=#{connectorId} and user_id=#{userId}
     </update>
+    <select id="selectConnectorUser" resultType="com.muyu.system.domain.ConnectorUser">
+        SELECT
+            connector_user.connector_user_id,
+            connector_user.connector_residue_degree,
+            connector_user.connector_frequency,
+            sys_user.user_name,
+            connector.connector_name
+        FROM
+            connector_user
+                LEFT JOIN sys_user ON connector_user.user_id = sys_user.user_id
+                LEFT JOIN connector ON connector_user.connector_id = connector.connector_id
+        WHERE
+            connector.connector_name=#{connectorName}
+    </select>
 </mapper>