This commit is contained in:
Lemon
2026-07-20 15:41:30 +08:00
14 changed files with 191 additions and 84 deletions

View File

@@ -120,13 +120,14 @@ public interface AdapayMemberAccountMapper {
AdapayMemberAccount selectByMemberId(String memberId);
/**
* 通过运营商id删除账户信息
* @param merchantId
*/
void deleteAccountByMerchantId(String merchantId);
int deleteCurrentAccount(@Param("id") Integer id,
@Param("merchantId") String merchantId,
@Param("adapayMemberId") String adapayMemberId);
void clearSettleAccountByMerchantId(String merchantId);
int clearCurrentSettleAccount(@Param("id") Integer id,
@Param("merchantId") String merchantId,
@Param("adapayMemberId") String adapayMemberId,
@Param("settleAccountId") String settleAccountId);
/**
* 根据运营商id查询最近一条的信息

View File

@@ -35,4 +35,6 @@ public interface StationSplitConfigMapper {
* @return
*/
List<SplitConfigStationVO> queryStationList(String adapayMemberId);
int countActiveByAdapayMemberId(String adapayMemberId);
}

View File

@@ -111,12 +111,11 @@ public interface AdapayMemberAccountService {
String selectMerchantNameByAdapayMemberId(String adapayMemberId);
/**
* 根据运营商id删除记录
* @param merchantId
* 精确逻辑删除当前有效账户,避免并发开户时误删新记录
*/
void deleteAccountByMerchantId(String merchantId);
int deleteCurrentAccount(Integer id, String merchantId, String adapayMemberId);
void clearSettleAccountByMerchantId(String merchantId);
int clearCurrentSettleAccount(Integer id, String merchantId, String adapayMemberId, String settleAccountId);
/**
* 根据运营商Id查询最近一条的信息

View File

@@ -59,4 +59,6 @@ public interface StationSplitConfigService {
* @return
*/
Map<String,List<SplitConfigStationVO>> queryStationList(SplitConfigStationDTO splitConfigStationDTO);
int countActiveByAdapayMemberId(String adapayMemberId);
}

View File

@@ -270,15 +270,21 @@ public class AdapayMemberAccountServiceImpl implements AdapayMemberAccountServic
}
@Override
public void deleteAccountByMerchantId(String merchantId) {
adapayMemberAccountMapper.deleteAccountByMerchantId(merchantId);
redisCache.deleteObject(CacheConstants.ADAPAY_MEMBER_ACCOUNT + merchantId);
public int deleteCurrentAccount(Integer id, String merchantId, String adapayMemberId) {
int result = adapayMemberAccountMapper.deleteCurrentAccount(id, merchantId, adapayMemberId);
if (result > 0) {
redisCache.deleteObject(CacheConstants.ADAPAY_MEMBER_ACCOUNT + merchantId);
}
return result;
}
@Override
public void clearSettleAccountByMerchantId(String merchantId) {
adapayMemberAccountMapper.clearSettleAccountByMerchantId(merchantId);
redisCache.deleteObject(CacheConstants.ADAPAY_MEMBER_ACCOUNT + merchantId);
public int clearCurrentSettleAccount(Integer id, String merchantId, String adapayMemberId, String settleAccountId) {
int result = adapayMemberAccountMapper.clearCurrentSettleAccount(id, merchantId, adapayMemberId, settleAccountId);
if (result > 0) {
redisCache.deleteObject(CacheConstants.ADAPAY_MEMBER_ACCOUNT + merchantId);
}
return result;
}
/**

View File

@@ -316,4 +316,9 @@ public class StationSplitConfigServiceImpl implements StationSplitConfigService{
return stationMap;
}
@Override
public int countActiveByAdapayMemberId(String adapayMemberId) {
return stationSplitConfigMapper.countActiveByAdapayMemberId(adapayMemberId);
}
}