fix:修复问题

liutao_branch
HuangHuiKang 2 weeks ago
parent 060ad5338e
commit dbbcf82a26

@ -70,17 +70,17 @@ public class ErpProductController {
@Operation(summary = "更新产品") @Operation(summary = "更新产品")
@PreAuthorize("@ss.hasPermission('erp:product:update')") @PreAuthorize("@ss.hasPermission('erp:product:update')")
public CommonResult<Boolean> updateProduct(@Valid @RequestBody ProductSaveReqVO updateReqVO) { public CommonResult<Boolean> updateProduct(@Valid @RequestBody ProductSaveReqVO updateReqVO) {
ErpProductPageReqVO productPageReqVO = new ErpProductPageReqVO(); // ErpProductPageReqVO productPageReqVO = new ErpProductPageReqVO();
productPageReqVO.setName(updateReqVO.getName()); // productPageReqVO.setName(updateReqVO.getName());
productPageReqVO.setStandard(updateReqVO.getStandard()); // productPageReqVO.setStandard(updateReqVO.getStandard());
if (productMapper.selectProductExist(productPageReqVO)) { // if (productMapper.selectProductExist(productPageReqVO)) {
return error(400,"名称+规格不能重复"); // return error(400,"名称+规格不能重复");
} // }
productPageReqVO = new ErpProductPageReqVO(); // productPageReqVO = new ErpProductPageReqVO();
productPageReqVO.setCode(updateReqVO.getBarCode()); // productPageReqVO.setCode(updateReqVO.getBarCode());
if (!productMapper.selectProductCodeExist(productPageReqVO).getList().isEmpty()) { // if (!productMapper.selectProductCodeExist(productPageReqVO).getList().isEmpty()) {
return error(400,"编码不能重复"); // return error(400,"编码不能重复");
} // }
productService.updateProduct(updateReqVO); productService.updateProduct(updateReqVO);
return success(true); return success(true);
} }

@ -1161,11 +1161,14 @@ public class TDengineService {
* @return Map<String,Object> * @return Map<String,Object>
*/ */
@DS("tdengine") @DS("tdengine")
public List<Map<String, Object>> newSelectLatestData(Long deviceId, String startTime, String endTime, int limit) { public List<Map<String, Object>> newSelectLatestData(Long deviceId, String startTime, String endTime, Integer limit) {
if (deviceId == null || limit <= 0) { if (deviceId == null ) {
return Collections.emptyList(); return Collections.emptyList();
} }
// 默认限制条数(防止全表扫描)
int safeLimit = limit == null ? 100 : limit;
String tableName = "besure_server.d_" + deviceId; String tableName = "besure_server.d_" + deviceId;
StringBuilder sqlBuilder = new StringBuilder(); StringBuilder sqlBuilder = new StringBuilder();
@ -1179,7 +1182,7 @@ public class TDengineService {
} }
sqlBuilder.append(" ORDER BY ts DESC "); // 按时间倒序 sqlBuilder.append(" ORDER BY ts DESC "); // 按时间倒序
sqlBuilder.append(" LIMIT ").append(limit); // 限制条数 sqlBuilder.append(" LIMIT ").append(safeLimit); // 限制条数
String sql = sqlBuilder.toString(); String sql = sqlBuilder.toString();

@ -184,7 +184,7 @@ import static cn.iocoder.yudao.module.iot.enums.ErrorCodeConstants.*;
try { try {
// 获取最新10条设备数据 // 获取最新10条设备数据
List<Map<String, Object>> deviceDataList = List<Map<String, Object>> deviceDataList =
tdengineService.newSelectLatestData(deviceId, collectionStartTime, collectionEndTime, 10); tdengineService.newSelectLatestData(deviceId, collectionStartTime, collectionEndTime, null);
// 查找 modelId 对应的 attributeCode // 查找 modelId 对应的 attributeCode
DeviceContactModelDO modelDO = deviceContactModelMapper.selectById(modelId); DeviceContactModelDO modelDO = deviceContactModelMapper.selectById(modelId);

Loading…
Cancel
Save