package com.vci.server.cache;
|
|
import java.sql.Connection;
|
//import java.sql.Date;
|
import java.sql.PreparedStatement;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.sql.Timestamp;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import com.vci.common.log.ServerWithLog4j;
|
import com.vci.server.base.persistence.dao.BaseService;
|
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
|
import com.vci.server.cache.dao.impl.PLCacheRecordEntDaoImp;
|
import com.vci.server.cache.object.PLCacheRecordEnt;
|
|
public class PLCacheRecordService extends BaseService{
|
private static volatile PLCacheRecordService instance = null;
|
|
private Map<String, Long> mapObjTime = new HashMap<String, Long>();
|
|
private PLCacheRecordService(){
|
|
}
|
|
public static PLCacheRecordService getInstance(){
|
if(instance == null){
|
synchronized (PLCacheRecordService.class){
|
if (instance == null) {
|
instance = new PLCacheRecordService();
|
}
|
}
|
}
|
return instance;
|
}
|
|
/**
|
* 根据数据类型获取对应的详细信息
|
*
|
* @param plOId
|
* @return
|
* @throws Throwable
|
*/
|
public List<PLCacheRecordEnt> getCacheRecordByObjType(String objType) throws Throwable {
|
|
long timeNew = getDataBaseCurrtenttime();
|
|
// 解决线程安全的问题
|
synchronized (this) {
|
if (mapObjTime.containsKey(objType)) {
|
long timeOld = mapObjTime.get(objType);
|
|
if ((timeNew - timeOld) < 5000){
|
//ServerWithLog4j.logger.debug(String.format("====时间短暂，忽略【%s】缓存更新====", objType));
|
|
return new ArrayList<PLCacheRecordEnt>();
|
}
|
}
|
|
//ServerWithLog4j.logger.debug(String.format("====更新【%s】缓存====", objType));
|
|
PLCacheRecordEntDaoImp daoImpl = new PLCacheRecordEntDaoImp();
|
StringBuilder sql = new StringBuilder("select * from plcachetemp p");
|
if (objType != null && !objType.trim().equals("")) {
|
sql.append(" where p.PLOBJTYPE = '" + objType + "'");
|
}
|
List<PLCacheRecordEnt> loadAll = daoImpl.findEntites(sql.toString(), new Object[0], "", PLCacheRecordEnt.class);
|
|
mapObjTime.put(objType, timeNew);
|
return loadAll;
|
}
|
}
|
|
|
/**
|
* 根据数据类型获取对应的详细信息
|
*
|
* @param plOId
|
* @return
|
* @throws Throwable
|
*/
|
public List<PLCacheRecordEnt> getCacheRecordByObjType(String objType, long time) throws Throwable {
|
// 两次查询间隔小于5000ms，则不查询是否存在修改；
|
long timeNew = getDataBaseCurrtenttime();
|
|
synchronized (this) {
|
if (mapObjTime.containsKey(objType)) {
|
long timeOld = mapObjTime.get(objType);
|
|
if ((timeNew - timeOld) < 5000){
|
//ServerWithLog4j.logger.debug(String.format("====时间短暂，忽略【%s】缓存更新====", objType));
|
return new ArrayList<PLCacheRecordEnt>();
|
}
|
}
|
|
//ServerWithLog4j.logger.debug(String.format("====更新【%s】缓存====", objType));
|
|
PLCacheRecordEntDaoImp daoImpl = new PLCacheRecordEntDaoImp();
|
|
StringBuilder sql = new StringBuilder("select * from plcachetemp p where 1 =1 " +
|
"and p.PLOPERATETIME >= to_timestamp('" + new Timestamp(time) + "', 'yyyy-mm-dd hh24:mi:ss.ff')");
|
if (objType != null && !objType.trim().equals("")) {
|
sql.append(" and p.PLOBJTYPE = '" + objType + "'");
|
}
|
List<PLCacheRecordEnt> loadAll = daoImpl.findEntites(sql.toString(), new Object[0], "", PLCacheRecordEnt.class);
|
|
mapObjTime.put(objType, timeNew);
|
|
return loadAll;
|
}
|
}
|
|
public boolean clearCacheRecord() throws Throwable {
|
PLCacheRecordEntDaoImp daoImpl = new PLCacheRecordEntDaoImp();
|
String sql = "truncate table plcachetemp";
|
daoImpl.createSQLQuery(sql);
|
|
long timeNew = getDataBaseCurrtenttime();
|
|
synchronized (this) {
|
for (String key : mapObjTime.keySet()) {
|
mapObjTime.put(key, timeNew);
|
}
|
}
|
return true;
|
}
|
|
/**
|
* 删除指定类型下的数据
|
* @param objType
|
* @return
|
* @throws SQLException
|
*/
|
public boolean deleteHisTemp(String objType) throws SQLException {
|
boolean flag = false;
|
String sql = "delete from PLCACHETEMP where PLOBJTYPE = ? ";
|
Connection connection = HibernateSessionFactory.getSessionConnection();
|
PreparedStatement pst = connection.prepareStatement(sql);
|
pst.setString(1, objType);
|
pst.executeUpdate();
|
pst.close();
|
flag = true;
|
|
try {
|
long timeNew = getDataBaseCurrtenttime();
|
synchronized (this) {
|
mapObjTime.put(objType, timeNew);
|
}
|
} catch (Throwable e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
|
return flag;
|
}
|
|
public boolean deleteHisTempByIDs(String[] ids) throws SQLException {
|
boolean flag = false;
|
StringBuffer sb = new StringBuffer("delete from PLCACHETEMP where PLUID in(");
|
for (int i = 0; i < ids.length; i++) {
|
if (i != 0) {
|
sb.append(",");
|
}
|
sb.append("'").append(ids[i]).append("'");
|
}
|
sb.append(")");
|
//System.out.println(sb.toString());
|
Connection connection = HibernateSessionFactory.getSessionConnection();
|
PreparedStatement pst = connection.prepareStatement(sb.toString());
|
pst.executeUpdate();
|
pst.close();
|
flag = true;
|
return flag;
|
}
|
/**
|
* 获取数据库当前时间
|
*
|
* @param
|
* @return
|
* @throws Throwable
|
*/
|
public Long getDataBaseCurrtenttime() throws Throwable {
|
Long currenttime=null;
|
Timestamp tsTimestamp=null;
|
String sql = "select systimestamp from dual";
|
Connection connection = HibernateSessionFactory.getSessionConnection();
|
PreparedStatement pst = connection.prepareStatement(sql);
|
ResultSet res=pst.executeQuery();
|
if(res.next()){
|
tsTimestamp=res.getTimestamp("systimestamp");
|
}
|
currenttime=tsTimestamp.getTime();
|
if(null!=res){
|
res.close();
|
}
|
if(null!=pst){
|
pst.close();
|
}
|
return currenttime;
|
}
|
|
public void resetObjType(String objType) {
|
ServerWithLog4j.logger.debug(String.format("====重置【%s】缓存====", objType));
|
synchronized (this) {
|
mapObjTime.remove(objType);
|
}
|
}
|
}
|
