package cn.ksource.web.service.sl;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.dao.SqlParameter;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.web.service.sl.sla.NoticeUser;
|
import cn.ksource.web.service.sl.sla.SLAEntity;
|
import cn.ksource.web.service.sl.sla.SLALevel;
|
|
@Service("slaProjectService")
|
public class SlaProjectServiceImpl implements SlaProjectService {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
|
@Override
|
public Map queryProjectSeviceList(String customerId,String sl) {
|
|
|
|
|
String selectSql = "SELECT A.* FROM SC_SERVCE_CATEGORY A,SC_SERVCE_CATEGORY_CUSTOMER B WHERE A.ID = B.CATEGORY_ID AND A.STATE = 1 AND B.CUSTOMER_ID = :customerId AND B.STATE = 1 ORDER BY A.LEVEL,A.SERIAL ";
|
|
List<Map> categoryList = baseDao.queryForList(selectSql,new SqlParameter("customerId", customerId));
|
|
|
|
Map slMap = new HashMap();
|
if(StringUtil.notEmpty(sl)) {
|
String[] sls = sl.split(",");
|
for(String s : sls) {
|
slMap.put(s, s);
|
}
|
}
|
|
|
|
Map result = new HashMap();
|
|
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 : categoryList) {
|
|
//一级树
|
if (map.get("LEVEL").toString().equalsIgnoreCase("1")) {
|
yjgnCache.put(map.get("ID").toString(), map);
|
List<Map> ejgnList = new LinkedList<Map>();
|
map.put("ejTree", ejgnList);
|
resultList.add(map);
|
continue;
|
}
|
//二级树
|
if (map.get("LEVEL").toString().equalsIgnoreCase("2")) {
|
Map yjgnMap = yjgnCache.get(map.get("P_ID").toString());
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
map.put("sjTree", new LinkedList<Map>());
|
list.add(map);
|
|
ejgnCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
//三级树
|
if (map.get("LEVEL").toString().equalsIgnoreCase("3")) {
|
if(null!=map.get("P_ID")){
|
|
if(slMap.containsKey(map.get("ID"))) {
|
slMap.put(map.get("ID"), map.get("CATEGORY_NAME"));
|
map.put("check", 1);
|
} else {
|
map.put("check", 2);
|
}
|
|
Map ejgnMap = ejgnCache.get(map.get("P_ID").toString());
|
List<Map> list = (List<Map>)ejgnMap.get("sjTree");
|
list.add(map);
|
}
|
}
|
}
|
for (Map map : resultList) {
|
List<Map> ejlist = (List<Map>)map.get("ejTree");
|
if(ejlist != null){
|
if(ejlist.size() == 0){
|
map.put("nodata", 0);
|
}else{
|
int count = 0;
|
for(Map map1 :ejlist){
|
List<Map> sjlist = (List<Map>)map1.get("sjTree");
|
if(sjlist != null){
|
if(sjlist.size() == 0){
|
map1.put("nodata", 0);
|
}else{
|
map1.put("nodata", 1);
|
count = 1;
|
}
|
}else{
|
map1.put("nodata", 0);
|
}
|
}
|
if(count == 0){
|
map.put("nodata", 0);
|
}else{
|
map.put("nodata", 1);
|
}
|
}
|
}else{
|
map.put("nodata", 0);
|
}
|
|
}
|
Map resultMap = new HashMap();
|
resultMap.put("categoryList", resultList);
|
resultMap.put("slMap", slMap);
|
return resultMap;
|
}
|
|
@Override
|
public String queryLevel(String priority_id, String influence_id,String customerId) {
|
|
String selectSql = "SELECT LEVEL_ID FROM SC_SLA_LEVEL_CONFIG WHERE INFLUENCE_ID = :influence_id AND PRIORITY_ID = :priority_id AND CUSTOMER_ID = :customerId";
|
Map paramMap = new HashMap();
|
paramMap.put("influence_id", influence_id);
|
paramMap.put("priority_id", priority_id);
|
paramMap.put("customerId", customerId);
|
String levelId = baseDao.queryForString(selectSql,paramMap);
|
return levelId;
|
}
|
|
@Override
|
public SLAEntity getLevelMsg(String customerId, String cateId) {
|
SLAEntity slaEntity = new SLAEntity();
|
|
slaEntity = querySelfProject(customerId,cateId);
|
return slaEntity;
|
}
|
|
/**
|
* 查询自有项目服务信息
|
* @param
|
* @param customerId
|
* @param
|
* @param cateId
|
* @return
|
*/
|
private SLAEntity querySelfProject(String customerId,String cateId) {
|
SLAEntity slaEntity = new SLAEntity(customerId,cateId);
|
//查询服务人员信息
|
//List<ServiceUser> serviceUsers = getServiceUser(customerId,cateId);
|
|
//slaEntity.setServiceUsers(serviceUsers);
|
|
List<SLALevel> levels = getLevels(customerId,cateId);
|
//查询该加盟商的响应信息
|
slaEntity.setLevels(levels);
|
|
|
return slaEntity;
|
}
|
|
/**
|
* 查询级别信息
|
*/
|
private List<SLALevel> getLevels(String customerId,String cateId) {
|
SqlParameter sqlParameter = new SqlParameter("customerId",customerId).addValue("cateId", cateId);
|
//查询级别对应的协议设置
|
String configSql = "SELECT A.* FROM SC_SLA_CONFIG A,SC_SLA B WHERE A.LEVEL_ID = B.ID AND A.STATE = 1 AND A.CUSTOMER_ID = :customerId AND A.CATEGORY_ID = :cateId AND B.STATE = 1 ORDER BY B.SERIAL";
|
List<Map> configs = baseDao.queryForList(configSql,sqlParameter);
|
if(configs.size() ==0){
|
String tyconfigSql = "SELECT A.* FROM SC_SLA_CONFIG A,SC_SLA B WHERE A.LEVEL_ID = B.ID AND A.STATE = 1 AND A.CUSTOMER_ID IS NULL AND A.CATEGORY_ID = :cateId AND B.STATE = 1 ORDER BY B.SERIAL";
|
configs = baseDao.queryForList(tyconfigSql,sqlParameter);
|
}
|
if(configs.size() ==0){
|
String tyconfigSql = "SELECT A.* FROM SC_SLA_CONFIG A,SC_SLA B WHERE A.LEVEL_ID = B.ID AND A.STATE = 1 AND A.CUSTOMER_ID IS NULL AND A.CATEGORY_ID IS NULL AND B.STATE = 1 ORDER BY B.SERIAL";
|
configs = baseDao.queryForList(tyconfigSql,sqlParameter);
|
}
|
List<SLALevel> levels = new ArrayList<SLALevel>();
|
if(null!=configs && configs.size()>0) {
|
//查询级别下的协议人员配置
|
String selectSql = "SELECT A.*,B.CATEGORY_ID,B.LEVEL_ID,B.ID AS CONFIG_ID FROM SC_SLA_USER A,SC_SLA_CONFIG B WHERE A.LEVEL_ID = B.ID AND B.STATE = 1 AND B.CUSTOMER_ID = :customerId AND B.CATEGORY_ID = :cateId ORDER BY A.OVER_TIME ";
|
List<Map> users = baseDao.queryForList(selectSql,sqlParameter);
|
Map responseUser = new HashMap();
|
Map resolveUser = new HashMap();
|
if(null!=users && users.size()>0) {
|
for(Map user : users) {
|
String configId = ConvertUtil.obj2StrBlank(user.get("CONFIG_ID"));
|
NoticeUser noticeUser = new NoticeUser();
|
|
//超时时间
|
String overTime = ConvertUtil.obj2StrBlank(user.get("OVER_TIME"));
|
|
noticeUser.setOverTime(overTime);
|
String notice_type = ConvertUtil.obj2StrBlank(user.get("NOTICE_TYPE"));
|
noticeUser.setNoticeType(notice_type);
|
//通知人员类型 1:分组 2：指定人员
|
String dealerType = ConvertUtil.obj2StrBlank(user.get("DEALER_TYPE"));
|
noticeUser.setDealerType(dealerType);
|
|
if(dealerType.equals("2")) {
|
//通知人员编号
|
String userId = ConvertUtil.obj2StrBlank(user.get("USER_ID"));
|
//通知人员名称
|
String userName = ConvertUtil.obj2StrBlank(user.get("USER_NAME"));
|
|
noticeUser.setUserId(userId);
|
noticeUser.setUserName(userName);
|
}
|
//通知分组编号
|
String groupId = ConvertUtil.obj2StrBlank(user.get("GROUP_ID"));
|
//通知分组名称
|
String groupName = ConvertUtil.obj2StrBlank(user.get("GROUP_NAME"));
|
|
noticeUser.setGroupId(groupId);
|
noticeUser.setGroupName(groupName);
|
|
if(notice_type.equals("1")) {
|
if(responseUser.containsKey(configId)) {
|
List respUsers = (List)responseUser.get(configId);
|
respUsers.add(noticeUser);
|
} else {
|
List respUsers = new ArrayList();
|
respUsers.add(noticeUser);
|
responseUser.put(configId, respUsers);
|
}
|
} else {
|
if(resolveUser.containsKey(configId)) {
|
List resolveUsers = (List)resolveUser.get(configId);
|
resolveUsers.add(noticeUser);
|
} else {
|
List resolveUsers = new ArrayList();
|
resolveUsers.add(noticeUser);
|
resolveUser.put(configId, resolveUsers);
|
}
|
}
|
}
|
}
|
|
|
for(Map config : configs) {
|
SLALevel level = new SLALevel();
|
String configId = ConvertUtil.obj2StrBlank(config.get("ID"));
|
|
String levelId = ConvertUtil.obj2StrBlank(config.get("LEVEL_ID"));
|
level.setLevelId(levelId);
|
//服务级别名称
|
String levelName = ConvertUtil.obj2StrBlank(config.get("LEVEL_NAME"));
|
level.setLevelName(levelName);
|
//响应时间
|
String responseTime = ConvertUtil.obj2StrBlank(config.get("RESPONSE_TIME"));
|
level.setResponseTime(responseTime);
|
//解决时间
|
String resolveTime = ConvertUtil.obj2StrBlank(config.get("RESOLVE_TIME"));
|
level.setResolveTime(resolveTime);
|
//通知人员类型 1:分组 2：指定人员
|
String dealerType = ConvertUtil.obj2StrBlank(config.get("DEALER_TYPE"));
|
level.setDealerType(dealerType);
|
if(dealerType.equals("2")) {
|
//人员编号
|
String userId = ConvertUtil.obj2StrBlank(config.get("USER_ID"));
|
//人员名称
|
String userName = ConvertUtil.obj2StrBlank(config.get("USER_NAME"));
|
level.setUserId(userId);
|
level.setUserName(userName);
|
}
|
//分组编号
|
String groupId = ConvertUtil.obj2StrBlank(config.get("GROUP_ID"));
|
level.setGroupId(groupId);
|
//分组名称
|
String groupName = ConvertUtil.obj2StrBlank(config.get("GROUP_NAME"));
|
level.setGroupName(groupName);
|
|
|
if(responseUser.containsKey(configId)) {
|
List<NoticeUser> respUsers = (List<NoticeUser>)responseUser.get(configId);
|
level.setResponseNotices(respUsers);
|
} else {
|
level.setResponseNotices(null);
|
}
|
|
|
if(resolveUser.containsKey(configId)) {
|
List<NoticeUser> resolveUsers = (List<NoticeUser>)resolveUser.get(configId);
|
level.setResolveNotices(resolveUsers);
|
} else {
|
level.setResolveNotices(null);
|
}
|
levels.add(level);
|
}
|
}
|
return levels;
|
}
|
|
@Override
|
public Map getSla_level(Map param) {
|
String sql="select * from SC_SLA_CONFIG where LEVEL_ID=:levelId AND CATEGORY_ID=:cate_id AND CUSTOMER_ID=:customerId";
|
Map map=baseDao.queryForMap(sql, param);
|
return map;
|
}
|
|
@Override
|
public Map getGsSla(Map param) {
|
String sql="select * from SC_SLA_CONFIG where LEVEL_ID=:levelId AND CUSTOMER_ID IS NULL AND CATEGORY_ID IS NULL ";
|
Map map=baseDao.queryForMap(sql, param);
|
return map;
|
}
|
|
@Override
|
public Map getZsSla(Map param) {
|
String sql="select * from SC_SLA_CONFIG where LEVEL_ID=:levelId AND CUSTOMER_ID IS NULL AND CATEGORY_ID=:cate_id ";
|
Map map=baseDao.queryForMap(sql, param);
|
return map;
|
}
|
|
}
|
