|
@@ -6,6 +6,8 @@ import cn.hutool.core.map.MapUtil;
|
|
|
import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.fasterxml.jackson.databind.node.ObjectNode;
|
|
|
+import com.persagy.dc.basic.constant.DigitalMessageConstant;
|
|
|
+import com.persagy.dc.basic.utils.DigitalCommonUtils;
|
|
|
import com.persagy.dc.basic.utils.DigitalMessageHelper;
|
|
|
import com.persagy.dc.common.constant.ValidEnum;
|
|
|
import com.persagy.dc.common.model.entity.BaseEntity;
|
|
@@ -61,8 +63,12 @@ public class ObjectDigitalServiceImpl implements IObjectDigitalService {
|
|
|
}
|
|
|
validateOnSave(voList, false);
|
|
|
voList.forEach(vo -> {
|
|
|
+ // 生成ID
|
|
|
+ vo.setId(DigitalCommonUtils.fetchObjectId(vo.getProjectId(), vo.getObjType()));
|
|
|
// 新增
|
|
|
dao.insert(vo);
|
|
|
+ // 新增后消息
|
|
|
+ messageSender.sendMessage(DigitalMessageConstant.OPERATE_AFTER_INSERT, null, vo, false);
|
|
|
});
|
|
|
return voList;
|
|
|
}
|
|
@@ -84,6 +90,8 @@ public class ObjectDigitalServiceImpl implements IObjectDigitalService {
|
|
|
}
|
|
|
// 修改
|
|
|
dao.updateById(vo);
|
|
|
+ // 修改后消息
|
|
|
+ messageSender.sendMessage(DigitalMessageConstant.OPERATE_AFTER_UPDATE, dbVO, vo, false);
|
|
|
});
|
|
|
return voList;
|
|
|
}
|
|
@@ -142,6 +150,9 @@ public class ObjectDigitalServiceImpl implements IObjectDigitalService {
|
|
|
vo.setId(id);
|
|
|
vo.setValid(ValidEnum.FALSE.getType());
|
|
|
dao.updateById(vo);
|
|
|
+ // 删除后消息
|
|
|
+ dbVO.setValid(ValidEnum.FALSE.getType());
|
|
|
+ messageSender.sendMessage(DigitalMessageConstant.OPERATE_AFTER_DELETE, null, dbVO, false);
|
|
|
});
|
|
|
}
|
|
|
}
|