fix: 网元信息操作同步删除主机记录
This commit is contained in:
@@ -209,12 +209,19 @@ func (r *NeInfoImpl) Update(neInfo model.NeInfo) int64 {
|
|||||||
// DeleteByIds 批量删除信息
|
// DeleteByIds 批量删除信息
|
||||||
func (r *NeInfoImpl) DeleteByIds(infoIds []string) (int64, error) {
|
func (r *NeInfoImpl) DeleteByIds(infoIds []string) (int64, error) {
|
||||||
// 检查是否存在
|
// 检查是否存在
|
||||||
ids := r.neInfoRepository.SelectByIds(infoIds)
|
infos := r.neInfoRepository.SelectByIds(infoIds)
|
||||||
if len(ids) <= 0 {
|
if len(infos) <= 0 {
|
||||||
return 0, fmt.Errorf("neHostCmd.noData")
|
return 0, fmt.Errorf("neHostCmd.noData")
|
||||||
}
|
}
|
||||||
|
|
||||||
if len(ids) == len(infoIds) {
|
if len(infos) == len(infoIds) {
|
||||||
|
// 主机信息删除
|
||||||
|
for _, v := range infos {
|
||||||
|
if v.HostIDs != "" {
|
||||||
|
hostIds := strings.Split(v.HostIDs, ",")
|
||||||
|
r.neHostRepository.DeleteByIds(hostIds)
|
||||||
|
}
|
||||||
|
}
|
||||||
rows := r.neInfoRepository.DeleteByIds(infoIds)
|
rows := r.neInfoRepository.DeleteByIds(infoIds)
|
||||||
return rows, nil
|
return rows, nil
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user