package cn.ksource.web.facade.impl;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import cn.ksource.beans.AC_ROLE;
|
import cn.ksource.beans.GG_ZZJG;
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.dao.SqlParameter;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.JsonUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.core.web.TreeNode;
|
import cn.ksource.web.facade.XtpzFacade;
|
import cn.ksource.web.service.UserService;
|
|
@Service("xtpzFacade")
|
public class XtpzFacadeImpl implements XtpzFacade {
|
|
@Resource(name="baseDao")
|
private BaseDao baseDao;
|
|
@Autowired
|
private UserService userService;
|
|
public void insertSingleZb(String row_id,String column_id,String value,int type){
|
String delSql = "DELETE FROM REPORT_EXCEPTION WHERE ROW_ID=:ROW_ID and COLUMN_ID=:COLUMN_ID";
|
String sql = "INSERT INTO REPORT_EXCEPTION(ID,ROW_ID,COLUMN_ID,INPUT_VALUE,TYPE) " +
|
"VALUES(:ID,:ROW_ID,:COLUMN_ID,:INPUT_VALUE,:TYPE)";
|
SqlParameter param = new SqlParameter("ID",StringUtil.getUUID());
|
param.addValue("ROW_ID", row_id).addValue("COLUMN_ID",column_id).addValue("INPUT_VALUE", value)
|
.addValue("TYPE", type);
|
|
baseDao.execute(delSql, param);
|
baseDao.execute(sql, param);
|
}
|
|
public Map getZBYCMap(){
|
String sql = "select * from REPORT_EXCEPTION";
|
List<Map> list = baseDao.queryForList(sql);
|
Map map = new HashMap();
|
for (Map tem : list) {
|
map.put(tem.get("ROW_ID")+"_"+tem.get("COLUMN_ID"), tem.get("INPUT_VALUE"));
|
}
|
return map;
|
}
|
|
public String getAllJsListForJson(){
|
List<Map> list = baseDao.queryForList("SELECT * FROM AC_ROLE ORDER BY SXH ASC");
|
return JsonUtil.list2Json(list);
|
}
|
|
public int delRole(String roleid) {
|
updateRolePermission(roleid);
|
new AC_ROLE(roleid).deleteById();
|
return 1;
|
}
|
|
@Override
|
public List<Map> getQxList(String roleid) {
|
String sql = "SELECT ID,GNMC,TYPE,SXH,SMALL_IMAGE,SJBH FROM GG_XTGN ORDER BY TYPE ASC,SXH ASC";
|
Map roleMap = new HashMap();
|
if (StringUtils.isNotBlank(roleid)) {
|
List<Map> roleQxList = baseDao.queryForList("SELECT GNBH FROM AC_ROLE_QX WHERE JSBH =:jsbh",new SqlParameter("jsbh",roleid));
|
for (Map map2 : roleQxList) {
|
roleMap.put(map2.get("GNBH"), "");
|
}
|
}
|
|
List<Map> xtgnList = baseDao.queryForList(sql, new SqlParameter());
|
|
List<Map> resultList = new LinkedList<Map>();
|
|
Map<String, Map> yjgnCache = new HashMap<String, Map>();
|
Map<String, Map> ejgnCache = new HashMap<String, Map>();
|
Map<String, Map> sjgnCache = new HashMap<String, Map>();
|
|
for (Map map : xtgnList) {
|
|
if (roleMap.containsKey(map.get("ID"))) {
|
map.put("CHECKED", true);
|
}
|
|
//一级功能
|
if (map.get("TYPE").toString().equalsIgnoreCase("1")) {
|
yjgnCache.put(map.get("ID").toString(), map);
|
List<Map> ejgnList = new LinkedList<Map>();
|
map.put("GNLIST", ejgnList);
|
resultList.add(map);
|
continue;
|
}
|
if (map.get("TYPE").toString().equalsIgnoreCase("2")) {
|
Map yjgnMap = yjgnCache.get(map.get("SJBH").toString());
|
List<Map> list = (List<Map>)yjgnMap.get("GNLIST");
|
map.put("GNLIST", new LinkedList<Map>());
|
list.add(map);
|
|
ejgnCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
if (map.get("TYPE").toString().equalsIgnoreCase("3")) {
|
Map ejgnMap = ejgnCache.get(map.get("SJBH").toString());
|
List<Map> list = (List<Map>)ejgnMap.get("GNLIST");
|
map.put("GNLIST", new LinkedList<Map>());
|
list.add(map);
|
sjgnCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
if (map.get("TYPE").toString().equalsIgnoreCase("4")) {
|
Map sjgnMap = sjgnCache.get(map.get("SJBH").toString());
|
List<Map> list = (List<Map>)sjgnMap.get("GNLIST");
|
list.add(map);
|
}
|
}
|
return resultList;
|
}
|
|
public void doQxInRoleSubmit(String[] yjgnbhs,String[] ejgnbhs,String[] sjgnbhs,String[] sijgnbhs,String roleid){
|
baseDao.execute("delete from AC_ROLE_QX where JSBH=:JSBH", new SqlParameter("JSBH",roleid));
|
List<SqlParameter> paramList = new ArrayList<SqlParameter>();
|
String sql = "INSERT INTO AC_ROLE_QX (ID,JSBH,GNBH) VALUES(:ID,:JSBH,:GNBH)";
|
if (yjgnbhs != null) {
|
for (String gnbh : yjgnbhs) {
|
paramList.add(new SqlParameter("ID",StringUtil.getUUID())
|
.addValue("JSBH", roleid)
|
.addValue("GNBH", gnbh)
|
);
|
}
|
}
|
if (ejgnbhs != null) {
|
for (String gnbh : ejgnbhs) {
|
paramList.add(new SqlParameter("ID",StringUtil.getUUID())
|
.addValue("JSBH", roleid)
|
.addValue("GNBH", gnbh)
|
);
|
}
|
}
|
if (sjgnbhs != null) {
|
for (String gnbh : sjgnbhs) {
|
paramList.add(new SqlParameter("ID",StringUtil.getUUID())
|
.addValue("JSBH", roleid)
|
.addValue("GNBH", gnbh)
|
);
|
}
|
}
|
if (sijgnbhs != null) {
|
for (String gnbh : sijgnbhs) {
|
paramList.add(new SqlParameter("ID",StringUtil.getUUID())
|
.addValue("JSBH", roleid)
|
.addValue("GNBH", gnbh)
|
);
|
}
|
}
|
baseDao.executeBatch(sql, paramList);
|
|
updateRolePermission(roleid);
|
|
|
|
}
|
|
private void updateRolePermission(String roleid) {
|
List<Map> list = baseDao.queryForList("SELECT * FROM AC_USER_REF_ROLE WHERE JSBH=:roleid",new SqlParameter("roleid",roleid));
|
for (Map map : list) {
|
String userid = map.get("YHBH").toString();
|
/*userService.updateUserPermission(userid);*/
|
}
|
}
|
|
@Override
|
public Map getUserInRole(String roleid) {
|
|
//所有用户
|
String userSql = "SELECT ID,ZSXM,SSBMBH FROM GG_USER WHERE ZT=1 ORDER BY BMPX ASC";
|
List<Map> allUserList = baseDao.queryForList(userSql);
|
|
Map roleMap = new HashMap();
|
if (StringUtils.isNotBlank(roleid)) {
|
List<Map> roleQxList = baseDao.queryForList("SELECT YHBH FROM AC_USER_REF_ROLE WHERE JSBH =:jsbh",new SqlParameter("jsbh",roleid));
|
for (Map map2 : roleQxList) {
|
roleMap.put(map2.get("YHBH"), "");
|
}
|
}
|
|
|
//如果人员在角色中，则增加CHECKED属性
|
for (Map map3 : allUserList) {
|
if (roleMap.containsKey(map3.get("ID"))) {
|
map3.put("CHECKED", true);
|
}
|
}
|
|
|
//所有部门
|
String sql = "SELECT * FROM GG_ZZJG ORDER BY CENGJ ASC,SXH ASC";
|
List<Map> bmList = baseDao.queryForList(sql, new SqlParameter());
|
|
List<Map> resultList = new LinkedList<Map>();
|
|
Map<String, Map> yjbmCache = new HashMap<String, Map>();
|
Map<String, Map> ejbmCache = new HashMap<String, Map>();
|
Map<String, Map> sjbmCache = new HashMap<String, Map>();
|
|
for (Map map : bmList) {
|
|
List<Map> userList = new LinkedList<Map>();
|
map.put("USERLIST", userList);
|
for (Map userMap : allUserList) {
|
if (userMap.get("SSBMBH").toString().equalsIgnoreCase(map.get("ID").toString())) {
|
userList.add(userMap);
|
}
|
}
|
|
//一级功能
|
if (map.get("CENGJ").toString().equalsIgnoreCase("1")) {
|
yjbmCache.put(map.get("ID").toString(), map);
|
List<Map> ejbmList = new LinkedList<Map>();
|
map.put("BMLIST", ejbmList);
|
resultList.add(map);
|
continue;
|
}
|
if (map.get("CENGJ").toString().equalsIgnoreCase("2")) {
|
Map yjbmMap = yjbmCache.get(map.get("SJBH").toString());
|
List<Map> list = (List<Map>)yjbmMap.get("BMLIST");
|
map.put("BMLIST", new LinkedList<Map>());
|
list.add(map);
|
|
ejbmCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
if (map.get("CENGJ").toString().equalsIgnoreCase("3")) {
|
Map ejbmMap = ejbmCache.get(map.get("SJBH").toString());
|
List<Map> list = (List<Map>)ejbmMap.get("BMLIST");
|
map.put("BMLIST", new LinkedList<Map>());
|
list.add(map);
|
sjbmCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
if (map.get("CENGJ").toString().equalsIgnoreCase("4")) {
|
Map sjbmMap = sjbmCache.get(map.get("SJBH").toString());
|
List<Map> list = (List<Map>)sjbmMap.get("BMLIST");
|
list.add(map);
|
}
|
}
|
|
Map resultMap = new HashMap();
|
resultMap.put("BMLIST", resultList);
|
return resultMap;
|
}
|
|
public void doUserInRoleSubmit(String[] userids,String roleid){
|
baseDao.execute("DELETE FROM AC_USER_REF_ROLE WHERE JSBH =:JSBH", new SqlParameter("JSBH",roleid));
|
if (userids != null && userids.length > 0) {
|
String sql = "insert into AC_USER_REF_ROLE(ID,JSBH,YHBH) VALUES(:ID,:JSBH,:YHBH)";
|
List<SqlParameter> paramList = new ArrayList<SqlParameter>();
|
for (String userid : userids) {
|
paramList.add(new SqlParameter("ID",StringUtil.getUUID())
|
.addValue("JSBH", roleid)
|
.addValue("YHBH", userid)
|
);
|
}
|
baseDao.executeBatch(sql, paramList);
|
|
/*for (String userid : userids) {
|
userService.updateUserPermission(userid);
|
}*/
|
|
}
|
}
|
|
public boolean delBm(String bmbh){
|
String sql = "SELECT COUNT(*) FROM GG_USER WHERE ZT=1 ANd SSBMBH=:bmbh";
|
int count = baseDao.queryForInteger(sql,new SqlParameter("bmbh",bmbh));
|
if (count > 0) {
|
return false;
|
}
|
new GG_ZZJG(bmbh).setZt(2).update();
|
return true;
|
}
|
|
@Override
|
public List<Map> getBmList(String sjbh) {
|
|
String sql = "SELECT * FROM GG_ZZJG WHERE ZT=1 ";
|
|
if (StringUtils.isNotBlank(sjbh) && !sjbh.toString().equalsIgnoreCase("0")) {
|
sql += " AND SJBH=:sjbh ";
|
} else {
|
sql += " AND SJBH IS NULL ";
|
}
|
|
sql += " ORDER BY SXH ASC ";
|
|
List<Map> list = baseDao.queryForList(sql,new SqlParameter("sjbh",sjbh));
|
|
return list;
|
}
|
|
@Override
|
public TreeNode getBmTree() {
|
TreeNode root = new TreeNode("0","组织架构");
|
|
String sql = "SELECT * FROM GG_ZZJG WHERE ZT=1 ORDER BY CENGJ ASC,SXH ASC";
|
List<Map> xtgnList = baseDao.queryForList(sql, new SqlParameter());
|
Map<String, TreeNode> yjgnCache = new HashMap<String, TreeNode>();
|
Map<String, TreeNode> ejgnCache = new HashMap<String, TreeNode>();
|
Map<String, TreeNode> sjgnCache = new HashMap<String, TreeNode>();
|
|
for (Map map : xtgnList) {
|
//一级功能
|
if (map.get("CENGJ").toString().equalsIgnoreCase("1")) {
|
TreeNode yjTree = new TreeNode(map.get("ID").toString(),map.get("JGMC").toString());
|
root.addChild(yjTree);
|
yjgnCache.put(ConvertUtil.obj2Str(map.get("ID")), yjTree);
|
continue;
|
}
|
if (map.get("CENGJ").toString().equalsIgnoreCase("2")) {
|
TreeNode ejTree = new TreeNode(map.get("ID").toString(),map.get("JGMC").toString());
|
|
yjgnCache.get(ConvertUtil.obj2Str(map.get("SJBH"))).addChild(ejTree);
|
ejgnCache.put(ConvertUtil.obj2Str(map.get("ID")), ejTree);
|
continue;
|
}
|
if (map.get("CENGJ").toString().equalsIgnoreCase("3")) {
|
TreeNode sjTree = new TreeNode(map.get("ID").toString(),map.get("JGMC").toString());
|
ejgnCache.get(ConvertUtil.obj2Str(map.get("SJBH"))).addChild(sjTree);
|
sjgnCache.put(map.get("ID").toString(), sjTree);
|
}
|
/*if (map.get("CENGJ").toString().equalsIgnoreCase("4")) {
|
TreeNode sijTree = new TreeNode(map.get("ID").toString(),map.get("JGMC").toString());
|
sjgnCache.get(ConvertUtil.obj2Str(map.get("SJBH"))).addChild(sijTree);
|
}*/
|
}
|
|
return root;
|
}
|
|
}
|
