|
@@ -24,32 +24,25 @@ public class NodeLandServiceImpl implements NodeLandService {
|
|
|
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public boolean createNodeLand(String nodeId, String geomDbId) {
|
|
|
+ public void createNodeLand(String nodeId, String geomDbId) {
|
|
|
try {
|
|
|
if (nodeId == null || nodeId.trim().isEmpty()) {
|
|
|
logger.warn("创建节点地块关联失败:nodeId不能为空");
|
|
|
- return false;
|
|
|
+ throw new IllegalArgumentException("nodeId不能为空");
|
|
|
}
|
|
|
|
|
|
if (geomDbId == null || geomDbId.trim().isEmpty()) {
|
|
|
logger.warn("创建节点地块关联失败:geomDbId不能为空");
|
|
|
- return false;
|
|
|
+ throw new IllegalArgumentException("geomDbId不能为空");
|
|
|
}
|
|
|
|
|
|
// 先删除该nodeId的所有关联记录
|
|
|
- int deletedCount = nodeLandMapper.deleteByNodeId(nodeId);
|
|
|
- logger.info("删除了 {} 条已存在的节点地块关联记录,nodeId: {}", deletedCount, nodeId);
|
|
|
+ nodeLandMapper.deleteByNodeId(nodeId);
|
|
|
+ logger.info("删除已存在的节点地块关联记录,nodeId: {}", nodeId);
|
|
|
|
|
|
// 创建新的关联记录
|
|
|
- int result = nodeLandMapper.insertByNodeIdAndGeomDbId(nodeId, geomDbId);
|
|
|
-
|
|
|
- if (result > 0) {
|
|
|
- logger.info("成功创建节点地块关联记录,nodeId: {}, geomDbId: {}", nodeId, geomDbId);
|
|
|
- return true;
|
|
|
- } else {
|
|
|
- logger.warn("创建节点地块关联记录失败,nodeId: {}, geomDbId: {}", nodeId, geomDbId);
|
|
|
- return false;
|
|
|
- }
|
|
|
+ nodeLandMapper.insertByNodeIdAndGeomDbId(nodeId, geomDbId);
|
|
|
+ logger.info("成功创建节点地块关联记录,nodeId: {}, geomDbId: {}", nodeId, geomDbId);
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.error("创建节点地块关联记录异常,nodeId: {}, geomDbId: {}", nodeId, geomDbId, e);
|
|
@@ -76,20 +69,19 @@ public class NodeLandServiceImpl implements NodeLandService {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public int deleteByNodeId(String nodeId) {
|
|
|
+ public void deleteByNodeId(String nodeId) {
|
|
|
try {
|
|
|
if (nodeId == null || nodeId.trim().isEmpty()) {
|
|
|
logger.warn("删除节点地块关联失败:nodeId不能为空");
|
|
|
- return 0;
|
|
|
+ throw new IllegalArgumentException("nodeId不能为空");
|
|
|
}
|
|
|
-
|
|
|
- int deletedCount = nodeLandMapper.deleteByNodeId(nodeId);
|
|
|
- logger.info("删除了 {} 条节点地块关联记录,nodeId: {}", deletedCount, nodeId);
|
|
|
- return deletedCount;
|
|
|
-
|
|
|
+
|
|
|
+ nodeLandMapper.deleteByNodeId(nodeId);
|
|
|
+ logger.info("删除节点地块关联记录,nodeId: {}", nodeId);
|
|
|
+
|
|
|
} catch (Exception e) {
|
|
|
logger.error("删除节点地块关联记录异常,nodeId: {}", nodeId, e);
|
|
|
- return 0;
|
|
|
+ throw e;
|
|
|
}
|
|
|
}
|
|
|
}
|