package com.ld.igds.view.service;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.hibernate.Session;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import com.bstek.bdf2.core.orm.hibernate.HibernateDao;
|
import com.bstek.dorado.data.entity.EntityState;
|
import com.bstek.dorado.data.entity.EntityUtils;
|
import com.ld.igds.constant.RedisConst;
|
import com.ld.igds.models.Building;
|
import com.ld.igds.util.ContextUtil;
|
import com.ld.igds.util.RedisUtil;
|
|
/**
|
*
|
* @author jiazx
|
*
|
*/
|
@Component
|
public class BuildingService extends HibernateDao {
|
|
@Autowired
|
private RedisUtil redisUtil;
|
|
public List<Building> loadData(Map<String, Object> parameter) {
|
|
String hql = " from " + Building.class.getName()
|
+ " where companyId=:companyId ";
|
if (null == parameter) {
|
parameter = new HashMap<String, Object>();
|
}
|
|
String companyId = (String) parameter.get("companyId");
|
if (StringUtils.isEmpty(companyId)) {
|
companyId = ContextUtil.getCompanyId();
|
}
|
parameter.put("companyId", companyId);
|
|
String deptId = (String) parameter.get("deptId");
|
if(StringUtils.isNoneEmpty(deptId)){
|
hql += " and deptId=:deptId ";
|
parameter.put("deptId", deptId);
|
}
|
|
hql += " order by id + 0";
|
return this.query(hql, parameter);
|
}
|
|
public String saveOrUpdate(Building data) {
|
|
Session session = this.getSessionFactory().openSession();
|
try {
|
if(null == data.getDeptId()){
|
data.setDeptId(ContextUtil.subDeptId(null));
|
}
|
data.setCompanyId(ContextUtil.getCompanyId());
|
session.saveOrUpdate(data);
|
refreshCache(data.getCompanyId());
|
} finally {
|
session.flush();
|
session.close();
|
}
|
return null;
|
}
|
|
public String delData(Building data) {
|
Session session = this.getSessionFactory().openSession();
|
try {
|
session.delete(data);
|
} finally {
|
session.flush();
|
session.close();
|
}
|
return null;
|
}
|
|
public String saveAll(List<Building> items) {
|
Session session = this.getSessionFactory().openSession();
|
try {
|
EntityState state;
|
for (Building item : items) {
|
state = EntityUtils.getState(item);
|
if (state == EntityState.NEW) {
|
item.setCompanyId(ContextUtil.getCompanyId());
|
if(null == item.getDeptId()){
|
item.setDeptId(ContextUtil.subDeptId(null));
|
}
|
session.save(item);
|
}
|
if (state == EntityState.DELETED) {
|
session.delete(item);
|
}
|
if (state == EntityState.MODIFIED) {
|
session.update(item);
|
}
|
}
|
|
refreshCache(items.get(0).getCompanyId());
|
} finally {
|
session.flush();
|
session.close();
|
}
|
return "执行完成";
|
}
|
|
@SuppressWarnings("unchecked")
|
public List<Building> getCacheBuilding(String companyId,String deptId) {
|
if(StringUtils.isEmpty(companyId)){
|
companyId = ContextUtil.getCompanyId();
|
}
|
|
String key = RedisConst.buildKey(companyId, RedisConst.KEY_BUILDING_LIST);
|
|
List<Building> result = (List<Building>) redisUtil.get(key);
|
|
if (null == result) {
|
refreshCache(companyId);
|
|
return null;
|
}
|
|
if(null == deptId) return result;
|
|
return result.stream().filter(item -> item.getDeptId().equals(deptId))
|
.collect(Collectors.toList());
|
}
|
|
|
public void refreshCache(String companyId) {
|
Map<String, Object> parameter = new HashMap<String, Object>();
|
parameter.put("companyId", companyId);
|
List<Building> list = this.loadData(parameter);
|
|
redisUtil.set(RedisConst.buildKey(companyId, RedisConst.KEY_BUILDING_LIST),list);
|
}
|
}
|
