package cn.ksource.web.facade.uc.ucsearch;
|
|
import java.util.HashMap;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import cn.ksource.beans.SC_WORKFLOW_INCIDENT;
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.page.PageInfo;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.StringUtil;
|
|
@Service("ucSearchFacade")
|
public class UcSearchFacadeImpl implements UcSearchFacade{
|
@Autowired
|
private BaseDao baseDao;
|
|
@Override
|
public int queryMainufacturerCount(Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT COUNT(DISTINCT C.ID) FROM CMDB_MAINUFACTURER C WHERE C.STATE=1 ");
|
queryMainufacturerIf(params,sql);
|
return baseDao.queryForInteger(sql.toString(), params);
|
}
|
|
@Override
|
public PageInfo queryMainufacturerData(PageInfo pageInfo,
|
Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT * FROM CMDB_MAINUFACTURER C WHERE C.STATE=1");
|
queryMainufacturerIf(params, sql);
|
sql.append(" ORDER BY C.STATE,C.CREATE_TIME DESC");
|
return baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
}
|
|
private void queryMainufacturerIf(Map<String, String> params,
|
StringBuilder sql) {
|
sql.append(" AND C.CUSTOMER_ID = :cusId");
|
if(StringUtil.notEmpty(params.get("mainufacturerName"))){
|
sql.append(" AND C.ZH_NAME LIKE :mainufacturerName");
|
String mainufacturerName = String.valueOf(params.get("mainufacturerName"));
|
params.put("mainufacturerName", "%"+mainufacturerName+"%");
|
}
|
if(StringUtil.notEmpty(params.get("type"))){
|
String[] types = params.get("type").split(",");
|
if(types.length==1){
|
params.put("type", types[0]);
|
sql.append(" AND C.TYPE =:type");
|
}else{
|
params.put("typeOne", types[0]);
|
params.put("typeTwo", types[1]);
|
sql.append(" AND (C.TYPE =:typeOne or C.TYPE=:typeTwo)");
|
}
|
}
|
}
|
|
@Override
|
public int queryContactPersonCount(Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT COUNT(DISTINCT p.ID) FROM CMDB_MAINUFACTURER_CONTACTS p,CMDB_MAINUFACTURER c WHERE p.MAINUFACTUREERID=c.ID AND p.DEL_FLAG=1 AND c.STATE=1 ");
|
queryContactPersonIf(params,sql);
|
return baseDao.queryForInteger(sql.toString(), params);
|
}
|
|
@Override
|
public PageInfo queryContactPersonData(PageInfo pageInfo,
|
Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT p.ID,p.CONTACTS,p.TELPHONE,p.MOBILE,p.COMPANYADDRESS,p.LEVEL,c.TYPE,c.ZH_NAME FROM CMDB_MAINUFACTURER_CONTACTS p,CMDB_MAINUFACTURER c WHERE p.MAINUFACTUREERID=c.ID AND p.DEL_FLAG=1 AND c.STATE=1 ");
|
queryContactPersonIf(params, sql);
|
sql.append(" ORDER BY p.LEVEL,p.CREATE_TIME DESC");
|
return baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
}
|
|
private void queryContactPersonIf(Map<String, String> params,
|
StringBuilder sql) {
|
sql.append(" AND C.CUSTOMER_ID = :cusId");
|
if(StringUtil.notEmpty(params.get("personName"))){
|
sql.append(" AND p.CONTACTS LIKE :personName");
|
}
|
if(StringUtil.notEmpty(params.get("type"))){
|
String[] types = params.get("type").split(",");
|
if(types.length==1){
|
params.put("type", types[0]);
|
sql.append(" AND C.TYPE =:type");
|
}else{
|
params.put("typeOne", types[0]);
|
params.put("typeTwo", types[1]);
|
sql.append(" AND (C.TYPE =:typeOne or C.TYPE=:typeTwo)");
|
}
|
}
|
if(StringUtil.notEmpty(params.get("phone"))){
|
sql.append(" AND p.MOBILE LIKE :phone");
|
}
|
if(StringUtil.notEmpty(params.get("contactsName"))){
|
sql.append(" AND c.ZH_NAME LIKE :contactsName");
|
}
|
}
|
|
@Override
|
public PageInfo queryContactsData(PageInfo pageInfo, Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT c.* FROM CUSTOMER_CONTACTS c WHERE c.STATE=1 ");
|
queryContactsIf(params, sql);
|
return baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
}
|
|
@Override
|
public int queryConttactsCount(Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT COUNT(DISTINCT c.ID) FROM CUSTOMER_CONTACTS c WHERE c.STATE=1 ");
|
queryContactsIf(params,sql);
|
return baseDao.queryForInteger(sql.toString(), params);
|
}
|
|
private void queryContactsIf(Map<String, String> params, StringBuilder sql) {
|
sql.append(" AND C.CUSTOMER_ID = :cusId");
|
if(StringUtil.notEmpty(params.get("contactName"))){
|
sql.append(" AND c.CONTACT_NAME LIKE :contactName");
|
}
|
if(StringUtil.notEmpty(params.get("mobile"))){
|
sql.append(" AND c.MOBILE LIKE :mobile");
|
}
|
if(StringUtil.notEmpty(params.get("levelId"))){
|
sql.append(" AND c.LEVEL_ID = :levelId");
|
}
|
if(StringUtil.notEmpty(params.get("allow_login"))){
|
sql.append(" AND c.ALLOW_LOGIN = :allow_login");
|
}
|
if(StringUtil.notEmpty(params.get("is_satis"))){
|
sql.append(" AND c.IS_SATIS = :is_satis");
|
}
|
}
|
|
@Override
|
public int getsearchKnowCount(Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT COUNT(DISTINCT K.ID) FROM KM_LIBRARY K WHERE K.STATE=1 AND ID IN (SELECT KNOWLEDGE_ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE CUSTOMER_ID = :userId) ");
|
querysearchKnowIf(params,sql);
|
return baseDao.queryForInteger(sql.toString(), params);
|
}
|
|
@Override
|
public PageInfo getsearchKnowData(PageInfo pageInfo,
|
Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT K.* FROM KM_LIBRARY K WHERE K.STATE=1 AND ID IN (SELECT KNOWLEDGE_ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE CUSTOMER_ID = :userId) ");
|
querysearchKnowIf(params, sql);
|
sql.append(" ORDER BY K.CREATE_TIME DESC");
|
return baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
}
|
|
private void querysearchKnowIf(Map<String, String> params, StringBuilder sql) {
|
String title = params.get("title");
|
String keyword = params.get("keyword");
|
String sl = params.get("sl");
|
if(StringUtil.notEmpty(sl)) {
|
String[] sls = sl.split(",");
|
if(sls.length==1) {
|
sql.append(" AND k.THIRD_CATEGORY_ID = :third_category_id");
|
params.put("third_category_id", sls[0]);
|
} else {
|
sql.append(" AND k.THIRD_CATEGORY_ID IN (");
|
for(int i=0; i<sls.length; i++) {
|
sql.append(" :third_category_id"+i);
|
sql.append(",");
|
params.put("third_category_id"+i, sls[i]);
|
}
|
sql.deleteCharAt(sql.lastIndexOf(","));
|
sql.append(")");
|
}
|
}
|
|
String know = params.get("know");
|
if(StringUtil.notEmpty(know)) {
|
String[] knows = know.split(",");
|
if(knows.length==1) {
|
sql.append(" AND k.CATEGORY_ID = :category_id");
|
params.put("category_id", knows[0]);
|
} else {
|
sql.append(" AND k.CATEGORY_ID IN (");
|
for(int i=0; i<knows.length; i++) {
|
sql.append(" :category_id"+i);
|
sql.append(",");
|
params.put("category_id"+i, knows[i]);
|
}
|
sql.deleteCharAt(sql.lastIndexOf(","));
|
sql.append(")");
|
}
|
}
|
|
String ci = params.get("ci");
|
if(StringUtil.notEmpty(ci)) {
|
String[] cis = ci.split(",");
|
if(cis.length==1) {
|
sql.append(" AND k.THIRDLEVEL_ID = :thirdlevel_id");
|
params.put("thirdlevel_id", cis[0]);
|
} else {
|
sql.append(" AND k.THIRDLEVEL_ID IN (");
|
for(int i=0; i<cis.length; i++) {
|
sql.append(" :thirdlevel_id"+i);
|
sql.append(",");
|
params.put("thirdlevel_id"+i, cis[i]);
|
}
|
sql.deleteCharAt(sql.lastIndexOf(","));
|
sql.append(")");
|
}
|
}
|
if (!StringUtil.isEmpty(title)) {
|
sql.append(" and k.TITLE like :title ");
|
params.put("title", "%" + title + "%");
|
}
|
|
if (!StringUtil.isEmpty(keyword)) {
|
sql.append(" and k.TAG like :keyword ");
|
params.put("keyword", "%" + keyword + "%");
|
}
|
}
|
|
@Override
|
public Map categoryListTree(HttpServletRequest request) {
|
String sql="SELECT * FROM KM_LIBRARY_CATEGORY WHERE STATE = 1 ";
|
sql +=" ORDER BY LEVEL ";
|
Map slMap = new HashMap();
|
String sl = request.getParameter("sl");
|
if(StringUtil.notEmpty(sl)) {
|
String[] sls = sl.split(",");
|
for(String s : sls) {
|
slMap.put(s, s);
|
}
|
}
|
Map param = new HashMap();
|
List<Map> categoryList = baseDao.queryForList(sql);
|
|
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("TAG").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("TAG")){
|
if(slMap.containsKey(map.get("ID"))) {
|
slMap.put(map.get("ID"), map.get("TITLE"));
|
map.put("check", 1);
|
} else {
|
map.put("check", 2);
|
}
|
|
Map ejgnMap = ejgnCache.get(map.get("TAG").toString());
|
List<Map> list = (List<Map>)ejgnMap.get("sjTree");
|
list.add(map);
|
}
|
}
|
}
|
Map resultMap = new HashMap();
|
resultMap.put("categoryList", resultList);
|
resultMap.put("slMap", slMap);
|
return resultMap;
|
}
|
|
@Override
|
public Map thirdlevelListTree(HttpServletRequest request) {
|
String sql="SELECT * FROM CMDB_CI_CATEGORY WHERE STATE = 1 and cate_type=1 ORDER BY LV,SERIAL ";
|
|
Map slMap = new HashMap();
|
String sl = request.getParameter("sl");
|
if(StringUtil.notEmpty(sl)) {
|
String[] sls = sl.split(",");
|
for(String s : sls) {
|
slMap.put(s, s);
|
}
|
}
|
|
List<Map> categoryList = baseDao.queryForList(sql);
|
|
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("LV").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("LV").toString().equalsIgnoreCase("2")) {
|
Map yjgnMap = yjgnCache.get(map.get("PID").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("LV").toString().equalsIgnoreCase("3")) {
|
if(null!=map.get("PID")){
|
if(slMap.containsKey(map.get("ID"))) {
|
slMap.put(map.get("ID"), map.get("NAME"));
|
map.put("check", 1);
|
} else {
|
map.put("check", 2);
|
}
|
|
Map ejgnMap = ejgnCache.get(map.get("PID").toString());
|
List<Map> list = (List<Map>)ejgnMap.get("sjTree");
|
list.add(map);
|
}
|
}
|
}
|
Map resultMap = new HashMap();
|
resultMap.put("categoryList", resultList);
|
resultMap.put("slMap", slMap);
|
return resultMap;
|
}
|
|
@Override
|
public Map repairDetail(String id) {
|
String sql = "SELECT A.*,B.YWKS,B.ZW,B.CONTACTS_TYPE,B.TELEPHONE,B.MOBILE,C.CUSTOMER_NAME FROM SC_PARTNER_CUSTOMER_INFO C,REPAIR_RECORD A left join CUSTOMER_CONTACTS B on B.ID = A.CREATE_ID WHERE A.CUS_ID = C.ID AND A.ID = :id ";
|
Map param = new HashMap();
|
param.put("id", id);
|
Map repair = baseDao.queryForMap(sql, param);
|
if(ConvertUtil.obj2Integer(repair.get("STATUS"))==3){
|
SC_WORKFLOW_INCIDENT incident = new SC_WORKFLOW_INCIDENT(ConvertUtil.obj2StrBlank(repair.get("INCIDENT_ID"))).getInstanceById();
|
repair.put("FLOWID", incident.getFlow_id());
|
repair.put("ORDER_CODE", incident.getOrder_code());
|
}
|
return repair;
|
}
|
|
@Override
|
public int repairListCount(Map<String, String> params) {
|
|
String userId = params.get("userId");
|
String state = params.get("state");
|
StringBuffer sql = new StringBuffer("SELECT COUNT(A.ID) FROM REPAIR_RECORD A,SC_PARTNER_CUSTOMER_INFO C WHERE A.CUS_ID = C.ID AND A.CREATE_ID = :user_id ");
|
Map param = new HashMap();
|
param.put("user_id", userId);
|
if(!StringUtil.isEmpty(state)){
|
sql.append(" AND A.STATUS = :state ");
|
param.put("state", state);
|
}
|
int count = baseDao.queryForInteger(sql.toString(), param);
|
return count;
|
}
|
|
@Override
|
public PageInfo repairListData(PageInfo pageInfo, Map<String, String> params) {
|
String userId = params.get("userId");
|
String state = params.get("state");
|
StringBuffer sql = new StringBuffer("SELECT A.*,C.CUSTOMER_NAME FROM REPAIR_RECORD A,SC_PARTNER_CUSTOMER_INFO C WHERE A.CUS_ID = C.ID AND A.CREATE_ID = :user_id ");
|
Map param = new HashMap();
|
param.put("user_id", userId);
|
if(!StringUtil.isEmpty(state)){
|
sql.append(" AND A.STATUS = :state ");
|
param.put("state", state);
|
}
|
sql.append(" ORDER BY A.CREATE_TIME DESC ");
|
PageInfo recordList = baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), param);
|
return recordList;
|
}
|
|
|
}
|
