package com.mes.controller;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.mes.entity.PlcAddress;
|
import com.mes.service.PlcAddressService;
|
import com.mes.vo.Result;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import io.swagger.annotations.ApiParam;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* PLC地址映射配置控制器
|
* 提供PLC地址映射配置的增删改查接口
|
*
|
* @author huang
|
* @date 2025/10/29
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("address-mapping")
|
@Api(tags = "PLC地址映射配置管理")
|
public class PlcAddressController {
|
|
@Resource
|
private PlcAddressService plcAddressService;
|
|
/**
|
* 获取所有PLC地址映射配置
|
*/
|
@GetMapping("/list")
|
@ApiOperation("获取所有PLC地址映射配置")
|
public Result<List<PlcAddress>> getAllMappings() {
|
try {
|
List<PlcAddress> mappings = plcAddressService.getAllMappings();
|
return Result.success(mappings);
|
} catch (Exception e) {
|
log.error("获取PLC地址映射配置列表失败", e);
|
return Result.error("获取PLC地址映射配置列表失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 分页获取PLC地址映射配置
|
*/
|
@GetMapping("/page")
|
@ApiOperation("分页获取PLC地址映射配置")
|
public Result<IPage<PlcAddress>> getMappingsByPage(
|
@ApiParam("页码，从1开始") @RequestParam(defaultValue = "1") int page,
|
@ApiParam("每页条数") @RequestParam(defaultValue = "10") int size,
|
@ApiParam("项目标识，支持模糊查询") @RequestParam(required = false) String projectId,
|
@ApiParam("PLC IP地址，支持模糊查询") @RequestParam(required = false) String plcIp) {
|
try {
|
IPage<PlcAddress> pageResult = plcAddressService.getMappingsByPage(page, size, projectId, plcIp);
|
return Result.success(pageResult);
|
} catch (Exception e) {
|
log.error("分页获取PLC地址映射配置失败", e);
|
return Result.error("分页获取PLC地址映射配置失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 根据ID获取PLC地址映射配置
|
*/
|
@GetMapping("/detail")
|
@ApiOperation("根据ID获取PLC地址映射配置")
|
public Result<PlcAddress> getMappingById(
|
@ApiParam("配置ID") @RequestParam Long id) {
|
try {
|
PlcAddress mapping = plcAddressService.getMappingById(id);
|
if (mapping != null) {
|
return Result.success(mapping);
|
} else {
|
return Result.error("未找到ID为 " + id + " 的PLC地址映射配置");
|
}
|
} catch (Exception e) {
|
log.error("获取PLC地址映射配置失败，ID: " + id, e);
|
return Result.error("获取PLC地址映射配置失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 根据项目标识获取PLC地址映射配置
|
*/
|
@GetMapping("/project")
|
@ApiOperation("根据项目标识获取PLC地址映射配置")
|
public Result<PlcAddress> getMappingByProjectId(
|
@ApiParam("项目标识") @RequestParam String projectId) {
|
try {
|
PlcAddress mapping = plcAddressService.getMappingByProjectId(projectId);
|
if (mapping != null) {
|
return Result.success(mapping);
|
} else {
|
return Result.error("未找到项目标识为 " + projectId + " 的PLC地址映射配置");
|
}
|
} catch (Exception e) {
|
log.error("获取PLC地址映射配置失败，项目标识: " + projectId, e);
|
return Result.error("获取PLC地址映射配置失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 根据项目ID获取项目配置（包含地址映射）
|
* 对应前端配置获取需求
|
*/
|
@GetMapping("/project/config")
|
@ApiOperation("根据项目ID获取项目配置（包含地址映射）")
|
public Result<Map<String, Object>> getProjectConfig(String projectId) {
|
try {
|
PlcAddress mapping = plcAddressService.getProjectConfig(projectId);
|
|
// 组装输出，仅基于数据库实体
|
Map<String, Object> result = new HashMap<>();
|
result.put("projectId", projectId);
|
result.put("dbArea", mapping != null ? mapping.getDbArea() : "DB1");
|
result.put("beginIndex", mapping != null ? mapping.getBeginIndex() : 0);
|
result.put("plcIp", mapping != null ? mapping.getPlcIp() : null);
|
result.put("plcType", mapping != null ? mapping.getPlcType() : null);
|
|
// 解析addressMapping JSON为Map
|
Map<String, Integer> addressMap = new HashMap<>();
|
if (mapping != null && mapping.getAddressMapping() != null && !mapping.getAddressMapping().trim().isEmpty()) {
|
try {
|
addressMap = new com.fasterxml.jackson.databind.ObjectMapper()
|
.readValue(mapping.getAddressMapping(), new com.fasterxml.jackson.core.type.TypeReference<Map<String, Integer>>() {});
|
} catch (Exception parseEx) {
|
log.warn("解析地址映射JSON失败: {}", mapping.getAddressMapping());
|
}
|
}
|
result.put("addressMapping", addressMap);
|
|
if (mapping != null) {
|
result.put("id", mapping.getId());
|
result.put("projectName", mapping.getProjectName());
|
result.put("remarks", mapping.getRemarks());
|
}
|
|
return Result.success(result);
|
} catch (Exception e) {
|
log.error("获取项目配置失败，项目标识: " + projectId, e);
|
return Result.error("获取项目配置失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 创建新的PLC地址映射配置
|
*/
|
@PostMapping
|
@ApiOperation("创建新的PLC地址映射配置")
|
public Result<PlcAddress> createMapping(
|
@ApiParam("PLC地址映射配置") @RequestBody PlcAddress mapping) {
|
try {
|
// 参数验证
|
if (mapping.getProjectId() == null || mapping.getProjectId().trim().isEmpty()) {
|
return Result.error("项目标识不能为空");
|
}
|
if (mapping.getDbArea() == null || mapping.getDbArea().trim().isEmpty()) {
|
return Result.error("DB块地址不能为空");
|
}
|
|
if (mapping.getBeginIndex() < 0) {
|
mapping.setBeginIndex(0); // 如果为负数，设置为默认起始索引0
|
}
|
|
PlcAddress created = plcAddressService.saveMapping(mapping);
|
log.info("创建PLC地址映射配置成功，ID: {}, 项目标识: {}", created.getId(), created.getProjectId());
|
return Result.success(created);
|
} catch (Exception e) {
|
log.error("创建PLC地址映射配置失败", e);
|
return Result.error("创建PLC地址映射配置失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 更新PLC地址映射配置
|
*/
|
@PutMapping("/update")
|
@ApiOperation("更新PLC地址映射配置")
|
public Result<PlcAddress> updateMapping(
|
@ApiParam("配置ID") @RequestParam Long id,
|
@ApiParam("更新的PLC地址映射配置") @RequestBody PlcAddress mapping) {
|
try {
|
// 参数验证
|
if (mapping.getProjectId() == null || mapping.getProjectId().trim().isEmpty()) {
|
return Result.error("项目标识不能为空");
|
}
|
if (mapping.getDbArea() == null || mapping.getDbArea().trim().isEmpty()) {
|
return Result.error("DB块地址不能为空");
|
}
|
|
mapping.setId(id);
|
PlcAddress updated = plcAddressService.updateMapping(mapping);
|
if (updated != null) {
|
log.info("更新PLC地址映射配置成功，ID: {}, 项目标识: {}", updated.getId(), updated.getProjectId());
|
return Result.success(updated);
|
} else {
|
return Result.error("未找到ID为 " + id + " 的PLC地址映射配置");
|
}
|
} catch (Exception e) {
|
log.error("更新PLC地址映射配置失败，ID: " + id, e);
|
return Result.error("更新PLC地址映射配置失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 根据项目ID更新配置
|
* 对应前端：updateConfig
|
*/
|
@PutMapping("/project/update")
|
@ApiOperation("根据项目ID更新配置")
|
public Result<PlcAddress> updateMappingByProjectId(
|
@ApiParam("项目标识") @RequestParam String projectId,
|
@ApiParam("更新的PLC地址映射配置") @RequestBody PlcAddress mapping) {
|
try {
|
// 参数验证
|
if (mapping.getDbArea() == null || mapping.getDbArea().trim().isEmpty()) {
|
return Result.error("DB块地址不能为空");
|
}
|
|
// 设置项目ID
|
mapping.setProjectId(projectId);
|
|
// 查找现有配置
|
PlcAddress existing = plcAddressService.getMappingByProjectId(projectId);
|
if (existing != null) {
|
// 更新现有配置
|
mapping.setId(existing.getId());
|
PlcAddress updated = plcAddressService.updateMapping(mapping);
|
log.info("根据项目ID更新PLC地址映射配置成功，项目标识: {}", projectId);
|
return Result.success(updated);
|
} else {
|
// 创建新配置
|
PlcAddress created = plcAddressService.saveMapping(mapping);
|
log.info("根据项目ID创建PLC地址映射配置成功，项目标识: {}", projectId);
|
return Result.success(created);
|
}
|
} catch (Exception e) {
|
log.error("根据项目ID更新PLC地址映射配置失败，项目标识: " + projectId, e);
|
return Result.error("更新配置失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 删除PLC地址映射配置
|
*/
|
@DeleteMapping("/delete")
|
@ApiOperation("删除PLC地址映射配置")
|
public Result<Void> deleteMapping(
|
@ApiParam("配置ID") @RequestParam Long id) {
|
try {
|
boolean deleted = plcAddressService.deleteMapping(id);
|
if (deleted) {
|
log.info("删除PLC地址映射配置成功，ID: {}", id);
|
return Result.success();
|
} else {
|
return Result.error("未找到ID为 " + id + " 的PLC地址映射配置");
|
}
|
} catch (Exception e) {
|
log.error("删除PLC地址映射配置失败，ID: " + id, e);
|
return Result.error("删除PLC地址映射配置失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 批量删除PLC地址映射配置
|
*/
|
@DeleteMapping("/batch")
|
@ApiOperation("批量删除PLC地址映射配置")
|
public Result<Void> deleteMappings(
|
@ApiParam("配置ID列表") @RequestBody List<Long> ids) {
|
try {
|
if (ids == null || ids.isEmpty()) {
|
return Result.error("ID列表不能为空");
|
}
|
|
int deletedCount = plcAddressService.deleteMappings(ids);
|
log.info("批量删除PLC地址映射配置成功，删除数量: {}, ID列表: {}", deletedCount, ids);
|
return Result.success();
|
} catch (Exception e) {
|
log.error("批量删除PLC地址映射配置失败，ID列表: " + ids, e);
|
return Result.error("批量删除PLC地址映射配置失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 测试PLC连接
|
*/
|
@PostMapping("/test-connection")
|
@ApiOperation("测试PLC连接")
|
public Result<String> testConnection(
|
@ApiParam("配置ID") @RequestParam Long id) {
|
try {
|
PlcAddress mapping = plcAddressService.getMappingById(id);
|
if (mapping == null) {
|
return Result.error("未找到ID为 " + id + " 的PLC地址映射配置");
|
}
|
|
boolean isConnected = plcAddressService.testConnection(mapping);
|
if (isConnected) {
|
String message = String.format("PLC连接测试成功 - 项目: %s, IP: %s, DB块: %s",
|
mapping.getProjectId(), mapping.getPlcIp(), mapping.getDbArea());
|
log.info(message);
|
return Result.success(message);
|
} else {
|
String message = String.format("PLC连接测试失败 - 项目: %s, IP: %s, DB块: %s",
|
mapping.getProjectId(), mapping.getPlcIp(), mapping.getDbArea());
|
log.warn(message);
|
return Result.error(message);
|
}
|
} catch (Exception e) {
|
log.error("PLC连接测试失败，ID: " + id, e);
|
return Result.error("PLC连接测试失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 重新加载配置文件中的地址映射
|
*/
|
@PostMapping("/reload-config")
|
@ApiOperation("重新加载配置文件中的地址映射")
|
public Result<String> reloadConfig() {
|
try {
|
plcAddressService.reloadConfigMappings();
|
String message = "配置文件中的PLC地址映射已重新加载";
|
log.info(message);
|
return Result.success(message);
|
} catch (Exception e) {
|
log.error("重新加载配置文件失败", e);
|
return Result.error("重新加载配置文件失败: " + e.getMessage());
|
}
|
}
|
}
|
