package com.ruoyi.account.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.ruoyi.account.api.model.TAppUserWhitelist;
|
import com.ruoyi.account.api.model.TChargingCard;
|
import com.ruoyi.account.api.model.TVinManagement;
|
import com.ruoyi.account.mapper.TAppUserWhitelistMapper;
|
import com.ruoyi.account.mapper.TChargingCardMapper;
|
import com.ruoyi.account.mapper.TVinManagementMapper;
|
import com.ruoyi.account.service.FleetUnbindService;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
import java.util.Collections;
|
import java.util.List;
|
import java.util.Objects;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 车队解绑服务实现（内部链路：other 服务删除车队时触发，无管理端用户上下文）
|
* </p>
|
*
|
* @author mxcd
|
* @since 2026-09-29
|
*/
|
@Service
|
public class FleetUnbindServiceImpl implements FleetUnbindService {
|
|
@Resource
|
private TVinManagementMapper vinManagementMapper;
|
|
@Resource
|
private TChargingCardMapper chargingCardMapper;
|
|
@Resource
|
private TAppUserWhitelistMapper appUserWhitelistMapper;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int unbindByFleetIds(List<Integer> fleetIds) {
|
List<Integer> distinct = normalize(fleetIds);
|
if (distinct.isEmpty()) {
|
return 0;
|
}
|
LocalDateTime now = LocalDateTime.now();
|
int total = 0;
|
// 三表均在单事务内执行，任一失败整体回滚（调用方按失败中止车队删除，两侧数据保持一致）
|
// 显式 set null 清空车队归属（MyBatis-Plus 字段策略会忽略实体 null，需走 UpdateWrapper）
|
total += vinManagementMapper.update(null, new LambdaUpdateWrapper<TVinManagement>()
|
.in(TVinManagement::getFleetId, distinct)
|
.set(TVinManagement::getFleetId, null)
|
.set(TVinManagement::getUpdateTime, now));
|
total += chargingCardMapper.update(null, new LambdaUpdateWrapper<TChargingCard>()
|
.in(TChargingCard::getFleetId, distinct)
|
.set(TChargingCard::getFleetId, null)
|
.set(TChargingCard::getUpdateTime, now));
|
// 白名单实体无 updateTime 映射字段（表有 update_time 列），沿用现有解绑实现走 setSql
|
total += appUserWhitelistMapper.update(null, new LambdaUpdateWrapper<TAppUserWhitelist>()
|
.in(TAppUserWhitelist::getFleetId, distinct)
|
.set(TAppUserWhitelist::getFleetId, null)
|
.setSql("update_time = now()"));
|
return total;
|
}
|
|
private List<Integer> normalize(List<Integer> fleetIds) {
|
if (fleetIds == null || fleetIds.isEmpty()) {
|
return Collections.emptyList();
|
}
|
return fleetIds.stream().filter(Objects::nonNull).distinct().collect(Collectors.toList());
|
}
|
}
|
