package com.hbbh.adapter.manager.impl;
|
|
|
import com.alibaba.fastjson.JSON;
|
import com.google.common.collect.Lists;
|
import com.hbbh.adapter.covert.PointConvert;
|
import com.hbbh.adapter.pojo.Point;
|
import com.hbbh.adapter.utils.SearchConditionUtil;
|
import com.rtdb.enums.DataSort;
|
import com.rtdb.model.*;
|
import com.rtdb.service.impl.BaseImpl;
|
import com.rtdb.service.impl.ServerImpl;
|
import com.rtdb.service.impl.ServerImplPool;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Value;
|
|
import java.util.List;
|
|
@Deprecated
|
public class DataSourceManager
|
//implements DataSource
|
{
|
private static final Logger log = LoggerFactory.getLogger(Class.class);
|
|
|
@Value("${golden.ip}")
|
private String _ip;
|
@Value("${golden.port}")
|
private int _port;
|
@Value("${golden.username}")
|
private String _username;
|
@Value("${golden.password}")
|
private String _password;
|
|
@Value("${golden.poolSize}")
|
private int _poolSize;
|
@Value("${golden.maxSize}")
|
private int _maxSize;
|
|
|
private static ServerImplPool pool;
|
private static ServerImpl server;
|
|
|
static {
|
pool = new ServerImplPool("47.92.145.232",
|
6327,
|
"sa",
|
"golden",
|
5,
|
10);
|
try {
|
server = pool.getServerImpl();
|
} catch (Exception e) {
|
log.error("实时数据库,建立单连接失败！");
|
e.printStackTrace();
|
}
|
}
|
|
/* public ServerImpl server {
|
try {
|
ServerImpl serverImpl = server.server;
|
return serverImpl;
|
} catch (Exception e) {
|
log.error("实时数据库,建立单连接失败！");
|
e.printStackTrace();
|
}
|
return null;
|
}*/
|
|
/**
|
* 格式批量获取标签点最小信息
|
*
|
* @return
|
* @throws Exception
|
*/
|
public List<MinPoint> findPoints(String target) throws Exception {
|
String[] tableTags = new String[1];
|
tableTags[0] = target;
|
BaseImpl base = new BaseImpl(server);
|
List<MinPoint> points = base.findPoints(tableTags);
|
|
log.info(JSON.toJSONString(points));
|
return points;
|
}
|
|
/**
|
* @param pointIds 标签点id数组
|
* @return
|
* @throws Exception
|
*/
|
public List<FullPoint> selectFullPoint(int[] pointIds) throws Exception {
|
BaseImpl base = new BaseImpl(server);
|
|
Entity<FullPoint> pointsProperties = base.getPointsProperties(pointIds);
|
List<FullPoint> list = pointsProperties.getList();
|
return list;
|
}
|
|
|
public FullPoint findFullPoint(int id) throws Exception {
|
BaseImpl base = new BaseImpl(server);
|
int[] pointIds = new int[1];
|
pointIds[0] = id;
|
Entity<FullPoint> pointsProperties = base.getPointsProperties(pointIds);
|
List<FullPoint> list = pointsProperties.getList();
|
return list.get(0);
|
}
|
|
|
/**
|
* TODO:
|
* 获取表信息
|
*
|
* @return
|
* @throws Exception
|
*/
|
public List<Table> findTableInfo() throws Exception {
|
List<Table> results = Lists.newArrayList();
|
|
BaseImpl base = new BaseImpl(server);
|
int[] tableIds = base.getTableIds();
|
int tableId = tableIds[0];
|
|
return results;
|
}
|
|
|
public int getCount() throws Exception {
|
BaseImpl base = new BaseImpl(server);
|
|
//TODO:写死 暂时第一个
|
int[] tableIds = base.getTableIds();
|
int tableId = tableIds[0];
|
int pointSize = base.getTableRealSizeById(tableId);
|
return pointSize;
|
}
|
|
/**
|
* 获取单个表的所有测量点信息
|
*
|
* @return
|
* @throws Exception
|
*/
|
public List<Point> selectEntity() throws Exception {
|
int count = getCount();
|
BaseImpl base = new BaseImpl(server);
|
|
int[] pointIds = base.search(SearchConditionUtil.getSearchCondition(),
|
count,
|
DataSort.SORT_BY_ID);
|
List<FullPoint> fullPoints = selectFullPoint(pointIds);
|
|
List<Point> results = PointConvert.fullpointsToPointEntity(fullPoints);
|
return results;
|
}
|
|
|
public void execute() throws Exception {
|
List<Point> points = selectEntity();
|
for (Point point : points) {
|
//goldenDao.saveAndFlush(point);
|
}
|
|
}
|
|
|
}
|
