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 eca05bd..ddb9a66 100644 --- a/src/main/java/com/muyu/system/service/impl/BuyServiceImpl.java +++ b/src/main/java/com/muyu/system/service/impl/BuyServiceImpl.java @@ -6,6 +6,7 @@ import com.muyu.common.security.utils.SecurityUtils; import com.muyu.common.system.domain.LoginUser; import com.muyu.common.system.domain.SysUser; import com.muyu.system.domain.Connector; +import com.muyu.system.domain.ConnectorLog; import com.muyu.system.domain.ConnectorUser; import com.muyu.system.mapper.BuyMapper; import com.muyu.system.service.BuyService; @@ -44,6 +45,11 @@ public class BuyServiceImpl extends ServiceImpl implements if (i>0){ user.setUserBalance(user.getUserBalance()-connectorUser.getConnectorFrequency()*connectorUser.getConnectorPrice()); buyMapper.buyPrice(user); + ConnectorLog connectorLog = new ConnectorLog(); + connectorLog.setDataName(connectorUser.getConnectorName()); + connectorLog.setAmount(connectorUser.getConnectorPrice()); + // 插入购买记录 + buyMapper.insertPurchaseRecord(connectorLog); return Result.success(i,"购买成功"); } ConnectorUser connectorUser1 = buyMapper.selectConnectorUser(connectorUser); @@ -53,6 +59,11 @@ public class BuyServiceImpl extends ServiceImpl implements user.setUserBalance(user.getUserBalance()-connectorUser.getConnectorFrequency()*connectorUser.getConnectorPrice()); buyMapper.buyPrice(user); buyMapper.doBuyInterface(connectorUser); + ConnectorLog connectorLog = new ConnectorLog(); + connectorLog.setDataName(connectorUser.getConnectorName()); + connectorLog.setAmount(connectorUser.getConnectorPrice()); + // 插入购买记录 + buyMapper.insertPurchaseRecord(connectorLog); return Result.success(i,"购买成功"); } }