perf: 优化表名缺失时的入库处理

dev
huangfeng 3 months ago
parent 688c702af9
commit 35c0444512

@ -13,7 +13,7 @@ public interface RptparamindexRepository extends JpaRepository<Rptparamindex, St
List<Rptparamindex> findAllByEqmid(Integer eqmid);
List<Rptparamindex> findAllByEqmidInAndColnameIsNotNull(List<Integer> eqmidList);
List<Rptparamindex> findAllByEqmidInAndColnameIsNotNullAndTablenameIsNotNull(List<Integer> eqmidList);
List<Rptparamindex> findAllByParamindexStartingWith(String param);

@ -295,6 +295,12 @@ public class DataServiceImpl implements DataService {
@Override
public void insertData(String tableName, Integer devId, String time, String colname, String value) {
if (StringUtils.isBlank(tableName)) {
return;
}
if (StringUtils.isBlank(colname)) {
return;
}
String devField = DataTable.getDevidField(tableName);
String timeField = this.getTimeField(tableName);
String sqlFrom = " FROM " + tableName;

@ -85,7 +85,7 @@ public class Client61850Task {
return;
}
List<Rptparamindex> rptList = rptparamindexRepository.findAllByEqmidInAndColnameIsNotNull(eqmidList);
List<Rptparamindex> rptList = rptparamindexRepository.findAllByEqmidInAndColnameIsNotNullAndTablenameIsNotNull(eqmidList);
List<IedDlConfig> dlList = dlConfigRepository.findByDevIdIn(eqmidList);
if (CollectionUtils.isEmpty(rptList) && CollectionUtils.isEmpty(dlList)) {
return;

Loading…
Cancel
Save