package cn.ksource.web.facade.customerconfig;
|
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.dao.SqlParameter;
|
import cn.ksource.core.page.PageInfo;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.StringUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.*;
|
|
@Service("cusSubFacade")
|
@SuppressWarnings("unchecked")
|
public class CusSubFacadeImpl implements CusSubFacade {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
@Override
|
public Map querySubCustomer(String customerId) {
|
Map paramMap = new HashMap();
|
paramMap.put("customerId", customerId);
|
//查询当前客户的信息
|
String selectSql = "SELECT A.ID,A.CUSTOMER_NAME,wm_concat(B.USER_ID) AS USERID,wm_concat(B.USER_NAME) AS USERNAME FROM SC_PARTNER_CUSTOMER_INFO A LEFT JOIN SC_CUSTOMER_ZC_UESR B ON A.ID = B.CUSTOMER_ID WHERE A.ID = :customerId GROUP BY A.ID,A.CUSTOMER_NAME ";
|
Map customer = baseDao.queryForMap(selectSql,paramMap);
|
if(null!=customer && customer.size()>0) {
|
//查询下级客户
|
String selectSubSql = "SELECT A.id,A.CUSTOMER_NAME ,A.P_ID ,A.MY_LEVEL ,A.CUSTOMER_ID ,A.DEL_FLAG ,A.CONTACT ,A.PHONE,wm_concat(B.USER_ID) AS USERID,wm_concat(B.USER_NAME) AS USERNAME FROM SC_PARTNER_CUSTOMER_SUB A LEFT JOIN SC_CUSTOMER_ZC_UESR B ON A.ID = B.CUSTOMER_ID WHERE A.CUSTOMER_ID = :customerId AND A.DEL_FLAG = 1 GROUP BY A.ID,A.CUSTOMER_NAME ,A.P_ID ,A.MY_LEVEL ,A.CUSTOMER_ID ,A.DEL_FLAG ,A.CONTACT ,A.PHONE ORDER BY A.MY_LEVEL";
|
List<Map> subCus = baseDao.queryForList(selectSubSql,paramMap);
|
if(null!=subCus && subCus.size()>0){
|
List subs = new ArrayList();
|
Map<String, Map> yjgnCache = new HashMap<String, Map>();
|
Map<String, Map> ejgnCache = new HashMap<String, Map>();
|
for(Map cus : subCus) {
|
String level = ConvertUtil.obj2StrBlank(cus.get("MY_LEVEL"));
|
String id = ConvertUtil.obj2Str(cus.get("ID"));
|
//一级树
|
if (level.equalsIgnoreCase("1")) {
|
yjgnCache.put(id, cus);
|
List<Map> ejgnList = new LinkedList<Map>();
|
cus.put("ejTree", ejgnList);
|
subs.add(cus);
|
continue;
|
}
|
//二级树
|
if (level.equalsIgnoreCase("2")) {
|
String pId = cus.get("P_ID").toString();
|
if(yjgnCache.containsKey(pId)) {
|
Map yjgnMap = yjgnCache.get(pId);
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
list.add(cus);
|
|
ejgnCache.put(id, cus);
|
}
|
continue;
|
}
|
}
|
customer.put("subs", subs);
|
}
|
/*String selectSubSql = "SELECT * FROM SC_PARTNER_CUSTOMER_SUB WHERE CUSTOMER_ID = :customerId AND DEL_FLAG = 1 AND MY_LEVEL = 1 ";
|
List<Map> subCus = baseDao.queryForList(selectSubSql,paramMap);
|
customer.put("subs", subCus);*/
|
}
|
return customer;
|
}
|
|
|
@Override
|
public PageInfo querySubCusList(PageInfo pageInfo,Map<String,String> params) {
|
String pId = params.get("pId");
|
StringBuilder selectSql = new StringBuilder("SELECT * FROM SC_PARTNER_CUSTOMER_SUB WHERE CUSTOMER_ID = :customerId ");
|
if(StringUtil.isEmpty(pId)){
|
selectSql.append(" AND (P_ID IS NULL OR P_ID = '')");
|
}else{
|
selectSql.append(" AND P_ID = :pId ");
|
}
|
return baseDao.queryforSplitPageInfo(pageInfo, selectSql.toString(), params);
|
}
|
|
|
@Override
|
public int querySubCusCount(Map<String, String> params) {
|
String pId = params.get("pId");
|
StringBuilder selectSql = new StringBuilder("SELECT COUNT(ID) FROM SC_PARTNER_CUSTOMER_SUB WHERE CUSTOMER_ID = :customerId ");
|
if(StringUtil.isEmpty(pId)){
|
selectSql.append(" AND (P_ID IS NULL OR P_ID = '') ");
|
}else{
|
selectSql.append(" AND P_ID = :pId ");
|
}
|
return baseDao.queryForInteger(selectSql.toString(), params);
|
}
|
|
/**
|
* 保存下属单位
|
*/
|
@Override
|
public void saveSubCus(HttpServletRequest request) {
|
String customerId = request.getParameter("customerId");
|
String pId = request.getParameter("pId");
|
String customerName = request.getParameter("customer_name");
|
String level = request.getParameter("level");
|
String id = request.getParameter("id");
|
|
String contact = request.getParameter("contact");
|
String phone = request.getParameter("phone");
|
String note = request.getParameter("note");
|
|
Map paramMap = new HashMap();
|
String updateSql = new String();
|
if(StringUtil.notEmpty(id)) {
|
updateSql = "UPDATE SC_PARTNER_CUSTOMER_SUB SET CUSTOMER_NAME = :customerName,CONTACT = :contact,PHONE = :phone,NOTE = :note WHERE ID = :id";
|
paramMap.put("id", id);
|
Map param=new HashMap();
|
param.put("name", customerName);
|
param.put("id", id);
|
String sqla="update SC_WORKFLOW_INCIDENT_TEMPLATE set SUB_CUSTOMER_NAME=:name where SUB_CUSTOMER_ID=:id";
|
String sqlb="update SC_WORKFLOW_INCIDENT set SUB_CUSTOMER_NAME=:name where SUB_CUSTOMER_ID=:id";
|
String sqlc="update SC_WORKFLOW_QUESTION set SUB_CUSTOMER_NAME=:name where SUB_CUSTOMER_ID=:id";
|
baseDao.execute(sqla, param);
|
baseDao.execute(sqlb, param);
|
baseDao.execute(sqlc, param);
|
} else {
|
updateSql = "INSERT INTO SC_PARTNER_CUSTOMER_SUB (ID,CUSTOMER_NAME,P_ID,MY_LEVEL,CUSTOMER_ID,CONTACT,PHONE,NOTE,DEL_FLAG) VALUES (:id,:customerName,:pId,:level,:customerId,:contact,:phone,:note,1)";
|
paramMap.put("id", StringUtil.getUUID());
|
}
|
paramMap.put("customerName", customerName);
|
paramMap.put("pId", pId);
|
paramMap.put("level", level);
|
paramMap.put("customerId", customerId);
|
paramMap.put("contact", contact);
|
paramMap.put("phone", phone);
|
paramMap.put("note", note);
|
baseDao.execute(updateSql, paramMap);
|
}
|
|
@Override
|
public boolean updateState(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
String state = request.getParameter("state");
|
if(state.equals("2")) {
|
//查询该分类下是否有信息
|
String sql = "SELECT COUNT(ID) FROM SC_PARTNER_CUSTOMER_SUB WHERE P_ID = :id AND DEL_FLAG = 1";
|
int count = baseDao.queryForInteger(sql,new SqlParameter("id",id));
|
if(count>0) {
|
return false;
|
}
|
}
|
|
String updateSql = "UPDATE SC_PARTNER_CUSTOMER_SUB SET DEL_FLAG = :state WHERE ID = :id ";
|
baseDao.execute(updateSql, new SqlParameter("id",id).addValue("state", state));
|
return true;
|
}
|
|
|
@Override
|
public List<Map> queryCurrentZcUser(String customerId) {
|
String sql = "SELECT a.* FROM SC_CUSTOMER_ZC_UESR a,GG_USER b,AC_ROLE c,AC_USER_REF_ROLE d where a.USER_ID=b.ID and b.ID=D.YHBH and c.ID=D.JSBH and c.IDENTIFY='LOCATION' and b.ZT=1 ";
|
return baseDao.queryForList(sql);
|
}
|
|
|
@Override
|
public Map queryAllUser(String sl) {
|
//当前所有用户
|
StringBuffer userSql = new StringBuffer("select A.ID,A.ZSXM,A.SSBMBH,A.LOGINNAME from GG_USER A where A.ZT=1 ");
|
if(!StringUtil.isEmpty(sl)){
|
userSql.append("AND A.ID NOT IN ( ");
|
String[] sls = sl.split(",");
|
for(int i=0;i<sls.length;i++){
|
userSql.append("'"+sls[i]+"',");
|
}
|
userSql.deleteCharAt(userSql.lastIndexOf(","));
|
userSql.append(")");
|
}
|
userSql.append(" and A.ID IN (SELECT YHBH FROM ac_user_ref_role WHERE JSBH IN (SELECT ID FROM ac_role WHERE IDENTIFY = 'LOCATION'))");
|
userSql.append(" AND A.ID NOT IN (SELECT USER_ID FROM SC_CUSTOMER_ZC_UESR )");
|
List<Map> allUserList = baseDao.queryForList(userSql.toString());
|
Map resultMap = new HashMap();
|
resultMap.put("PARTNERLIST", allUserList);
|
//所有部门
|
String sql = "SELECT * FROM GG_ZZJG WHERE ZT=1 ORDER BY CENGJ ASC,SXH ASC";
|
List<Map> bmList = 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 : bmList) {
|
String level = map.get("CENGJ").toString();
|
String id = map.get("ID").toString();
|
|
//一级树
|
if (level.equalsIgnoreCase("1")) {
|
yjgnCache.put(id, map);
|
List<Map> ejgnList = new LinkedList<Map>();
|
map.put("ejTree", ejgnList);
|
resultList.add(map);
|
continue;
|
}
|
//二级树
|
if (level.equalsIgnoreCase("2")) {
|
String pId = map.get("SJBH").toString();
|
if(yjgnCache.containsKey(pId)) {
|
Map yjgnMap = yjgnCache.get(pId);
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
map.put("sjTree", new LinkedList<Map>());
|
list.add(map);
|
|
ejgnCache.put(id, map);
|
}
|
continue;
|
}
|
//三级树
|
if (level.equalsIgnoreCase("3")) {
|
if(null!=map.get("SJBH")){
|
String pId = map.get("SJBH").toString();
|
if(ejgnCache.containsKey(pId)) {
|
Map ejgnMap = ejgnCache.get(map.get("SJBH").toString());
|
List<Map> list = (List<Map>)ejgnMap.get("sjTree");
|
map.put("fjTree", new LinkedList<Map>());
|
list.add(map);
|
sjgnCache.put(id, map);
|
}
|
}
|
}
|
}
|
resultMap.put("resultList", resultList);
|
return resultMap;
|
}
|
|
|
@Override
|
public boolean saveZcCus(Map<String,String> params) {
|
|
String[] customers = params.get("customerId").split(",");
|
if(customers.length > 0){
|
List<SqlParameter> paramList = new ArrayList<SqlParameter>();
|
List<SqlParameter> delList = new ArrayList<SqlParameter>();
|
for(int i=0;i<customers.length;i++){
|
//将所有客户和子客户的id保存
|
SqlParameter delId = new SqlParameter("CUSTOMER_ID", customers[i]);
|
delList.add(delId);
|
|
if(!StringUtil.isEmpty(customers[i])){
|
String userId = params.get("user"+customers[i]);
|
String userName = params.get("userName"+customers[i]);
|
if(!StringUtil.isEmpty(userId)){
|
String[] userIds = userId.split(",");
|
String[] userNames = userName.split(",");
|
if(userIds.length > 0){
|
for(int j=0;j<userIds.length;j++){
|
SqlParameter param = new SqlParameter();
|
param.put("ID", StringUtil.getUUID());
|
param.put("CUSTOMER_ID", customers[i]);
|
param.put("USER_ID", userIds[j]);
|
param.put("USER_NAME", userNames[j]);
|
paramList.add(param);
|
}
|
|
}
|
}
|
}
|
}
|
|
String insertSql = "INSERT INTO SC_CUSTOMER_ZC_UESR(ID,CUSTOMER_ID,USER_ID,USER_NAME) VALUES (:ID,:CUSTOMER_ID,:USER_ID,:USER_NAME)";
|
|
//删除客户的驻场
|
String deleteSql = "DELETE FROM SC_CUSTOMER_ZC_UESR WHERE CUSTOMER_ID = :CUSTOMER_ID";
|
baseDao.executeBatch(deleteSql, delList);
|
|
//添加新的客户驻场
|
baseDao.executeBatch(insertSql,paramList);
|
return true;
|
}
|
|
|
return false;
|
}
|
|
}
|
