package cn.ksource.web.facade.customerconfig;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
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.CMDB_MAINUFACTURER;
|
import cn.ksource.beans.CMDB_MAINUFACTURER_CONTACTS;
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.dao.SqlParameter;
|
import cn.ksource.core.page.PageInfo;
|
import cn.ksource.core.util.AjaxUtil;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.DateUtil;
|
import cn.ksource.core.util.JsonUtil;
|
import cn.ksource.core.util.PinYinUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.core.web.WebUtil;
|
|
@Service("customerCsFacade")
|
@SuppressWarnings("unchecked")
|
public class CustomerCsFacadeImpl implements CustomerCsFacade {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
/**
|
* 查询厂商或者集成商数据
|
*/
|
@Override
|
public PageInfo queryCsJscList(PageInfo pageInfo,Map<String,String> params) {
|
String name = params.get("name");
|
String type = params.get("type");
|
String state = params.get("state");
|
StringBuilder selectSql = new StringBuilder("SELECT A.*,(SELECT COUNT(B.ID) FROM CMDB_MAINUFACTURER_CONTACTS B WHERE A.ID = B.MAINUFACTUREERID AND B.DEL_FLAG = 1) AS CONTACT_NUM FROM CMDB_MAINUFACTURER A WHERE A.CUSTOMER_ID = :customerId ");
|
if(StringUtil.notEmpty(name)) {
|
selectSql.append(" AND A.MANUFACTURERNAME LIKE :name");
|
params.put("name", "%"+name+"%");
|
}
|
if (StringUtil.isNotBlank(type)) {
|
selectSql.append(" AND A.TYPE = :type ");
|
}
|
if (StringUtil.isNotBlank(state)) {
|
selectSql.append(" AND A.STATE = :state ");
|
}
|
|
selectSql.append(" ORDER BY NAME_PINYIN ASC,CREATE_TIME DESC ");
|
PageInfo info = baseDao.queryforSplitPageInfo(pageInfo, selectSql.toString(), params);
|
return info;
|
}
|
|
@Override
|
public int queryCsJscCount(Map<String,String> params) {
|
String name = params.get("name");
|
String type = params.get("type");
|
String state = params.get("state");
|
StringBuilder selectSql = new StringBuilder("SELECT COUNT(ID) FROM CMDB_MAINUFACTURER WHERE TYPE = :type AND CUSTOMER_ID = :customerId ");
|
if(StringUtil.notEmpty(name)) {
|
selectSql.append(" AND MANUFACTURERNAME LIKE :name");
|
params.put("name", "%"+name+"%");
|
}
|
if (StringUtil.isNotBlank(type)) {
|
selectSql.append(" AND TYPE = :type ");
|
}
|
if (StringUtil.isNotBlank(state)) {
|
selectSql.append(" AND STATE = :state ");
|
}
|
int count = baseDao.queryForInteger(selectSql.toString(),params);
|
return count;
|
}
|
|
/**
|
* 查询联系人列表
|
*/
|
@Override
|
public List queryContacts(Map<String,String> params) {
|
String selectSql = "SELECT * FROM CMDB_MAINUFACTURER_CONTACTS WHERE DEL_FLAG = 1 AND MAINUFACTUREERID = :csId AND CUSTOMER_ID = :customerId ORDER BY NAME_PINYIN ASC,CREATE_TIME DESC ";
|
return baseDao.queryForList(selectSql,params);
|
}
|
|
/**
|
* 保存联系人
|
*/
|
@Override
|
public String saveContact(HttpServletRequest request,CMDB_MAINUFACTURER_CONTACTS contact) {
|
if(StringUtil.isEmpty(contact.getId())){
|
long createTime = DateUtil.getCurrentDate14();
|
Map user = WebUtil.getLoginUser(request).getLoginUser();
|
String userId = ConvertUtil.obj2StrBlank(user.get("ID"));
|
String userName = ConvertUtil.obj2StrBlank(user.get("ZSXM"));
|
contact.setCreate_time(createTime).setUser_id(userId).setUser_name(userName).setDel_flag(1);
|
}
|
contact.setName_pinyin(PinYinUtil.getStringPinYin(contact.getContacts(), false)).insertOrUpdate();
|
return "1";
|
}
|
|
/**
|
* 删除联系人
|
*/
|
@Override
|
public String deleteContact(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
String updateSql = "UPDATE CMDB_MAINUFACTURER_CONTACTS SET DEL_FLAG = 2 WHERE ID = :id";
|
baseDao.execute(updateSql, new SqlParameter("id",id));
|
return "1";
|
}
|
|
|
|
|
/**
|
* 保存厂商或者集成商
|
*/
|
@Override
|
public String saveCsJsc(HttpServletRequest request, CMDB_MAINUFACTURER csjcs) {
|
if(StringUtil.isEmpty(csjcs.getId())){
|
csjcs.setState(1).setCreate_time(DateUtil.getCurrentDate14());
|
}
|
csjcs.setName_pinyin(PinYinUtil.getStringPinYin(csjcs.getManufacturername(), false)).insertOrUpdate();
|
return "1";
|
}
|
|
/**
|
* 验证厂商或者集成商唯一性
|
*/
|
@Override
|
public String checkCsJsc(HttpServletRequest request) {
|
String manufacturername = AjaxUtil.decode(request.getParameter("manufacturername"));
|
String type = request.getParameter("type");
|
String id = request.getParameter("id");
|
String customerId=request.getParameter("customerId");
|
StringBuilder builder = new StringBuilder("SELECT COUNT(ID) FROM CMDB_MAINUFACTURER WHERE MANUFACTURERNAME = :manufacturername AND TYPE = :type AND CUSTOMER_ID=:customerId ");
|
Map paramMap = new HashMap();
|
paramMap.put("manufacturername", manufacturername);
|
paramMap.put("type", type);
|
paramMap.put("customerId", customerId);
|
if(StringUtil.notEmpty(id)) {
|
builder.append(" AND ID != :id");
|
paramMap.put("id", id);
|
}
|
int count = baseDao.queryForInteger(builder.toString(),paramMap);
|
if(count>0) {
|
return "1";
|
}
|
return "2";
|
}
|
|
/**
|
* 启用或者禁用厂商集成商信息
|
*/
|
@Override
|
public String updateCsState(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
String state = request.getParameter("state");
|
String updateSql = "UPDATE CMDB_MAINUFACTURER SET STATE = :state WHERE ID = :id ";
|
Map paramMap = new HashMap();
|
paramMap.put("id", id);
|
paramMap.put("state", state);
|
baseDao.execute(updateSql, paramMap);
|
return "1";
|
}
|
|
|
@Override
|
public List queryCsreport(String customerId) {
|
List<Map> result = new ArrayList<Map>();
|
Map paramMap = new HashMap();
|
paramMap.put("customerId", customerId);
|
//查询该项目下所有的厂商或者集成商
|
String selectCsSql = "SELECT * FROM CMDB_MAINUFACTURER WHERE STATE = 1 AND CUSTOMER_ID = :customerId ORDER BY TYPE ASC,CREATE_TIME DESC ";
|
result = baseDao.queryForList(selectCsSql,paramMap);
|
|
if(null!=result && result.size()>0) {
|
Map cacheMap = new HashMap();
|
for(Map cs : result) {
|
String csId = ConvertUtil.obj2StrBlank(cs.get("ID"));
|
List lxr = new ArrayList();
|
cacheMap.put(csId, lxr);
|
cs.put("lxrs", lxr);
|
}
|
|
//查询联系人信息
|
String selectLxrSql = "SELECT * FROM CMDB_MAINUFACTURER_CONTACTS WHERE DEL_FLAG = 1 AND CUSTOMER_ID = :customerId ";
|
List<Map> lxr = baseDao.queryForList(selectLxrSql,paramMap);
|
if(null!=lxr && lxr.size()>0) {
|
for(Map user : lxr) {
|
String csId = ConvertUtil.obj2StrBlank(user.get("MAINUFACTUREERID"));
|
if(cacheMap.containsKey(csId)) {
|
List lxrs = (List)cacheMap.get(csId);
|
lxrs.add(user);
|
}
|
}
|
}
|
|
}
|
System.out.println(JsonUtil.list2Json(result));
|
|
if(null!=result && result.size()>0) {
|
for(Map map : result) {
|
List lxrs = (List)map.get("lxrs");
|
int lxrSize = lxrs.size();
|
if(lxrSize>0) {
|
map.put("size", lxrSize);
|
} else {
|
map.put("size", 1);
|
}
|
}
|
}
|
|
return result;
|
}
|
|
}
|
