package cn.ksource.web.facade.uc.order;
|
|
import java.util.ArrayList;
|
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.beans.WORKFLOW_BASE;
|
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.DateUtil;
|
import cn.ksource.core.util.JsonUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.core.web.WebUtil;
|
import cn.ksource.web.Constants;
|
import cn.ksource.web.service.DataDictionaryService;
|
import cn.ksource.web.service.device.DeviceService;
|
import cn.ksource.web.service.file.FileService;
|
import cn.ksource.web.service.order.OrderService;
|
import cn.ksource.web.service.record.RecordService;
|
|
@Service("ucIncidentFacade")
|
public class UcIncidentFacadeImpl implements UcIncidentFacade {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
@Autowired
|
private DataDictionaryService dataDictionaryService;
|
|
@Autowired
|
private FileService fileService;
|
|
@Autowired
|
private RecordService recordService;
|
|
@Autowired
|
private OrderService orderService;
|
|
@Autowired
|
private DeviceService deviceService;
|
|
/**
|
* 查询服务目录三级树
|
*/
|
@Override
|
public Map serviceListTree(String cusId,String sl) {
|
String sql="SELECT A.* FROM SC_SERVCE_CATEGORY A,SC_SERVCE_CATEGORY_CUSTOMER B WHERE B.CATEGORY_ID = A.ID AND B.CUSTOMER_ID = :customer_id ORDER BY LEVEL,SERIAL ";
|
|
|
Map slMap = new HashMap();
|
if(StringUtil.notEmpty(sl)) {
|
String[] sls = sl.split(",");
|
for(String s : sls) {
|
slMap.put(s, s);
|
}
|
}
|
|
List<Map> categoryList = baseDao.queryForList(sql,new SqlParameter("customer_id",cusId));
|
|
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);
|
}
|
}
|
}
|
Map resultMap = new HashMap();
|
resultMap.put("categoryList", resultList);
|
resultMap.put("slMap", slMap);
|
return resultMap;
|
}
|
|
@Override
|
public Map queryIncidentCount(String cusId) {
|
//初始化变量
|
//未完成
|
int wyc = 0;
|
//SLA即将到期
|
int slaWillTimeOut = 0;
|
//SLA过期
|
int slaTimeOut = 0;
|
|
//服务台
|
int fwt = 0;
|
//服务台已登记
|
int fwtydj = 0;
|
//服务台处理中
|
int fwtclz = 0;
|
|
//一线
|
int yx = 0;
|
//一线待响应
|
int yxdxy = 0;
|
//一线处理中
|
int yxclz = 0;
|
|
|
//二线
|
int ex = 0;
|
|
//二线待响应
|
int exdxy = 0;
|
|
//二线处理中
|
int exclz = 0;
|
|
//三线
|
int sx = 0;
|
|
//三线待响应
|
int sxdxy = 0;
|
|
//三线处理中
|
int sxclz = 0;
|
|
//已完成
|
int ywc = 0;
|
//满意度待调查
|
int mydddc = 0;
|
//满意度已调查
|
int mydydc = 0;
|
|
|
String selectSql = new String();
|
String sql = new String();
|
|
Map paramMap = new HashMap();
|
selectSql = "SELECT COUNT(*) AS NUM,A.STATE FROM SC_WORKFLOW_INCIDENT A WHERE A.CUSTOMER_ID = :cusId GROUP BY A.STATE";
|
sql = "SELECT ANSWER_TIMEOUT,DEAL_TIMEOUT FROM SC_WORKFLOW_INCIDENT WHERE STATE != :yjj AND STATE!=:gb AND STATE != :ypj AND CUSTOMER_ID = :cusId";
|
|
paramMap.put("cusId", cusId);
|
|
List<Map> list = baseDao.queryForList(selectSql,paramMap);
|
if(null!=list && list.size()>0) {
|
for(Map map : list) {
|
String state = ConvertUtil.obj2StrBlank(map.get("STATE"));
|
int num = ConvertUtil.obj2Int(map.get("NUM"));
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDFWT)) {
|
fwtydj += num;
|
continue;
|
}
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FWTCLZ)) {
|
fwtclz += num;
|
continue;
|
}
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYCJSZC)) {
|
fwtydj += num;
|
continue;
|
}
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_YCJSZCCLZ)) {
|
fwtclz += num;
|
continue;
|
}
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYX)) {
|
yxdxy = num;
|
continue;
|
}
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_YXCLZ)) {
|
yxclz = num;
|
continue;
|
}
|
|
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDEX)) {
|
exdxy = num;
|
continue;
|
}
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_EXCLZ)) {
|
exclz = num;
|
continue;
|
}
|
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDSX)) {
|
sxdxy = num;
|
continue;
|
}
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_SXCLZ)) {
|
sxclz = num;
|
continue;
|
}
|
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_YJJ)) {
|
mydddc += num;
|
continue;
|
}
|
|
/*if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_GB)) {
|
mydddc += num;
|
continue;
|
}*/
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_YPJ)) {
|
mydydc = num;
|
}
|
|
}
|
}
|
|
fwt = fwtydj + fwtclz;
|
yx = yxdxy + yxclz;
|
ex = exdxy + exclz;
|
sx = sxdxy + sxclz;
|
//ywc = mydddc + mydydc;
|
ywc = mydddc;
|
|
Map map = new HashMap();
|
map.put("fwt", fwt);
|
map.put("fwtydj", fwtydj);
|
map.put("fwtclz", fwtclz);
|
|
map.put("yx", yx);
|
map.put("yxdxy", yxdxy);
|
map.put("yxclz", yxclz);
|
|
|
map.put("ex", ex);
|
map.put("exdxy", exdxy);
|
map.put("exclz", exclz);
|
|
|
map.put("sx", sx);
|
map.put("sxdxy", sxdxy);
|
map.put("sxclz", sxclz);
|
|
|
map.put("ywc", ywc);
|
map.put("mydddc", mydddc);
|
map.put("mydydc", mydydc);
|
|
|
//查询该加盟商未完成的事件
|
|
paramMap.put("yjj", Constants.SC_WORKFLOW_INCIDENT_STATE_YJJ);
|
paramMap.put("gb", Constants.SC_WORKFLOW_INCIDENT_STATE_GB);
|
paramMap.put("ypj", Constants.SC_WORKFLOW_INCIDENT_STATE_YPJ);
|
|
|
List<Map> wycList = baseDao.queryForList(sql,paramMap);
|
if(null!=wycList && wycList.size()>0) {
|
wyc = wycList.size();
|
for(Map m : wycList) {
|
String answer_timeout = ConvertUtil.obj2StrBlank(m.get("ANSWER_TIMEOUT"));
|
String deal_timeout = ConvertUtil.obj2StrBlank(m.get("DEAL_TIMEOUT"));
|
if(answer_timeout.equals("1") || deal_timeout.equals("1")) {
|
slaTimeOut += 1;
|
} else {
|
slaWillTimeOut += 1;
|
}
|
}
|
|
}
|
|
map.put("wwc", wyc);
|
map.put("slaWillTimeOut", slaWillTimeOut);
|
map.put("slaTimeOut", slaTimeOut);
|
|
return map;
|
|
}
|
|
@Override
|
public PageInfo queryIncidentOrderList(PageInfo pageInfo,Map<String,String> params) {
|
|
String cusId = params.get("cusId");
|
|
StringBuilder sql = new StringBuilder();
|
sql.append("SELECT WB.ID,WB.ORDER_CODE,WB.WFNAME,WB.BUSINESSTYPE,WB.CREATERNAME,WB.CREATETIME,WB.WFNOTE, ");
|
sql.append("WB.CURRENT_NODE_ID,WB.CURRENT_NODE_NAME,WB.CUSTOMER_NAME,WB.CURRENT_DEALER_NAME,WB.BUSINESS_ID,WB.WFSTATE,B.ANSWER_TIMEOUT,B.DEAL_TIMEOUT ");
|
sql.append("FROM WORKFLOW_BASE WB,SC_WORKFLOW_INCIDENT B WHERE WB.BUSINESS_ID = B.ID ");
|
sql.append("AND WB.BUSINESSTYPE = :businessType ");
|
|
sql.append(" AND B.CUSTOMER_ID = :cusId ");
|
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
params.put("cusId", cusId);
|
|
sql = getincidentSql(sql,params);
|
|
sql.append( " ORDER BY WB.CREATETIME DESC ");
|
return baseDao.queryforSplitPageInfo(pageInfo,sql.toString(),params);
|
}
|
|
@Override
|
public int queryIncidentOrderCount(Map<String,String> params) {
|
|
String cusId = params.get("cusId");
|
|
StringBuilder sql = new StringBuilder();
|
sql.append("SELECT COUNT(WB.ID) FROM WORKFLOW_BASE WB,SC_WORKFLOW_INCIDENT B WHERE WB.BUSINESS_ID = B.ID AND WB.BUSINESSTYPE = :businessType ");
|
|
|
sql.append(" AND B.CUSTOMER_ID = :cusId ");
|
|
params.put("cusId", cusId);
|
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
sql = getincidentSql(sql,params);
|
|
|
return baseDao.queryForInteger(sql.toString(),params);
|
}
|
|
public StringBuilder getincidentSql(StringBuilder sql,Map<String,String> params){
|
|
String orderName = params.get("orderName");
|
if(StringUtil.notEmpty(orderName)) {
|
sql.append(" AND B.NAME LIKE :orderName ");
|
params.put("orderName", "%"+orderName+"%");
|
}
|
|
String orderCode = params.get("orderCode");
|
if(StringUtil.notEmpty(orderCode)) {
|
sql.append(" AND B.ORDER_CODE LIKE :orderCode ");
|
params.put("orderCode", "%"+orderCode+"%");
|
}
|
|
|
String contract = params.get("contract");
|
if(StringUtil.notEmpty(contract)) {
|
sql.append(" AND B.CONTACT_NAME LIKE :contract ");
|
params.put("contract", "%"+contract+"%");
|
}
|
|
String state = params.get("state");
|
if(StringUtil.notEmpty(state)) {
|
sql.append(" AND WB.WFSTATE = :state ");
|
params.put("state", state);
|
}
|
|
String pri = params.get("pri");
|
if(StringUtil.notEmpty(pri)) {
|
String[] pris = pri.split(",");
|
if(pris.length==1) {
|
sql.append(" AND B.PRIORITY_ID = :priority_id");
|
params.put("priority_id", pris[0]);
|
} else {
|
sql.append(" AND B.PRIORITY_ID IN (");
|
for(int i=0; i<pris.length; i++) {
|
sql.append(" :pri"+i);
|
sql.append(",");
|
params.put("pri"+i, pris[i]);
|
}
|
sql.deleteCharAt(sql.lastIndexOf(","));
|
sql.append(")");
|
}
|
}
|
|
|
|
String dg = params.get("dg");
|
if(StringUtil.notEmpty(dg)) {
|
String[] dgs = dg.split(",");
|
if(dgs.length==1) {
|
sql.append(" AND B.INFLUENCE_ID = :influence_id");
|
params.put("influence_id", dgs[0]);
|
} else {
|
sql.append(" AND B.INFLUENCE_ID IN (");
|
for(int i=0; i<dgs.length; i++) {
|
sql.append(" :dg"+i);
|
sql.append(",");
|
params.put("dg"+i, dgs[i]);
|
}
|
sql.deleteCharAt(sql.lastIndexOf(","));
|
sql.append(")");
|
}
|
}
|
|
|
String type = params.get("type");
|
if(StringUtil.notEmpty(type)) {
|
String[] types = type.split(",");
|
if(types.length==1) {
|
sql.append(" AND B.TYPE_ID = :type_id");
|
params.put("type_id", types[0]);
|
} else {
|
sql.append(" AND B.TYPE_ID IN (");
|
for(int i=0; i<types.length; i++) {
|
sql.append(" :type"+i);
|
sql.append(",");
|
params.put("type"+i, types[i]);
|
}
|
sql.deleteCharAt(sql.lastIndexOf(","));
|
sql.append(")");
|
}
|
}
|
|
String sl = params.get("sl");
|
if(StringUtil.notEmpty(sl)) {
|
String[] sls = sl.split(",");
|
if(sls.length==1) {
|
sql.append(" AND B.THIRD_CATEGORY_ID = :third_category_id");
|
params.put("third_category_id", sls[0]);
|
} else {
|
sql.append(" AND B.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 status = params.get("status");
|
if(StringUtil.notEmpty(status)) {
|
if(status.equals("wwc")) {
|
sql.append(" AND B.STATE != :yjj AND B.STATE!=:gb AND B.STATE != :ypj ");
|
params.put("yjj", Constants.SC_WORKFLOW_INCIDENT_STATE_YJJ);
|
params.put("gb", Constants.SC_WORKFLOW_INCIDENT_STATE_GB);
|
params.put("ypj", Constants.SC_WORKFLOW_INCIDENT_STATE_YPJ);
|
} else if(status.equals("slaWillTimeout")) {
|
sql.append(" AND B.STATE != :yjj AND B.STATE!=:gb AND B.STATE != :ypj AND B.ANSWER_TIMEOUT = 2 AND B.DEAL_TIMEOUT = 2 ");
|
params.put("yjj", Constants.SC_WORKFLOW_INCIDENT_STATE_YJJ);
|
params.put("gb", Constants.SC_WORKFLOW_INCIDENT_STATE_GB);
|
params.put("ypj", Constants.SC_WORKFLOW_INCIDENT_STATE_YPJ);
|
} else if(status.equals("slaTimeout")) {
|
sql.append(" AND B.STATE != :yjj AND B.STATE!=:gb AND B.STATE != :ypj AND (B.ANSWER_TIMEOUT = 1 OR B.DEAL_TIMEOUT = 1) ");
|
params.put("yjj", Constants.SC_WORKFLOW_INCIDENT_STATE_YJJ);
|
params.put("gb", Constants.SC_WORKFLOW_INCIDENT_STATE_GB);
|
params.put("ypj", Constants.SC_WORKFLOW_INCIDENT_STATE_YPJ);
|
} else if(status.equals("fwt")) {
|
sql.append(" AND (B.STATE = :fpdfwt OR B.STATE=:fwtclz OR B.STATE = :fpdycjszc OR B.STATE = :ycjszcclz) ");
|
params.put("fpdfwt", Constants.SC_WORKFLOW_INCIDENT_STATE_FPDFWT);
|
params.put("fwtclz", Constants.SC_WORKFLOW_INCIDENT_STATE_FWTCLZ);
|
params.put("fpdycjszc", Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYCJSZC);
|
params.put("ycjszcclz", Constants.SC_WORKFLOW_INCIDENT_STATE_YCJSZCCLZ);
|
} else if(status.equals("fwtydj")) {
|
sql.append(" AND (B.STATE = :fpdfwt OR B.STATE = :fpdycjszc ) ");
|
params.put("fpdfwt", Constants.SC_WORKFLOW_INCIDENT_STATE_FPDFWT);
|
params.put("fpdycjszc", Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYCJSZC);
|
} else if(status.equals("fwtclz")) {
|
sql.append(" AND (B.STATE=:fwtclz OR B.STATE = :ycjszcclz) ");
|
params.put("fwtclz", Constants.SC_WORKFLOW_INCIDENT_STATE_FWTCLZ);
|
params.put("ycjszcclz", Constants.SC_WORKFLOW_INCIDENT_STATE_YCJSZCCLZ);
|
} else if(status.equals("yx")) {
|
sql.append(" AND (B.STATE=:fpdyx OR B.STATE = :yxclz) ");
|
params.put("fpdyx", Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYX);
|
params.put("yxclz", Constants.SC_WORKFLOW_INCIDENT_STATE_YXCLZ);
|
} else if(status.equals("yxdxy")) {
|
sql.append(" AND B.STATE=:fpdyx ");
|
params.put("fpdyx", Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYX);
|
} else if(status.equals("yxclz")) {
|
sql.append(" AND B.STATE = :yxclz ");
|
params.put("yxclz", Constants.SC_WORKFLOW_INCIDENT_STATE_YXCLZ);
|
} else if(status.equals("ex")) {
|
sql.append(" AND (B.STATE=:fpdex OR B.STATE = :exclz) ");
|
params.put("fpdex", Constants.SC_WORKFLOW_INCIDENT_STATE_FPDEX);
|
params.put("exclz", Constants.SC_WORKFLOW_INCIDENT_STATE_EXCLZ);
|
} else if(status.equals("exdxy")) {
|
sql.append(" AND B.STATE=:fpdex ");
|
params.put("fpdex", Constants.SC_WORKFLOW_INCIDENT_STATE_FPDEX);
|
} else if(status.equals("exclz")) {
|
sql.append(" AND B.STATE = :exclz ");
|
params.put("exclz", Constants.SC_WORKFLOW_INCIDENT_STATE_EXCLZ);
|
} else if(status.equals("sx")) {
|
sql.append(" AND (B.STATE=:fpdsx OR B.STATE = :sxclz) ");
|
params.put("fpdsx", Constants.SC_WORKFLOW_INCIDENT_STATE_FPDSX);
|
params.put("sxclz", Constants.SC_WORKFLOW_INCIDENT_STATE_SXCLZ);
|
} else if(status.equals("sxdxy")) {
|
sql.append(" AND B.STATE=:fpdsx ");
|
params.put("fpdsx", Constants.SC_WORKFLOW_INCIDENT_STATE_FPDSX);
|
} else if(status.equals("sxclz")) {
|
sql.append(" AND B.STATE = :sxclz ");
|
params.put("sxclz", Constants.SC_WORKFLOW_INCIDENT_STATE_SXCLZ);
|
} else if(status.equals("ywc")) {
|
sql.append(" AND (B.STATE = :yjj OR B.STATE = :ygb OR B.STATE = :ypj )");
|
params.put("yjj", Constants.SC_WORKFLOW_INCIDENT_STATE_YJJ);
|
params.put("ygb", Constants.SC_WORKFLOW_INCIDENT_STATE_GB);
|
params.put("ypj", Constants.SC_WORKFLOW_INCIDENT_STATE_YPJ);
|
} else if(status.equals("mydddc")) {
|
sql.append(" AND B.STATE = :yjj ");
|
params.put("yjj", Constants.SC_WORKFLOW_INCIDENT_STATE_YJJ);
|
} else if(status.equals("mydydc")) {
|
sql.append(" AND B.STATE = :ypj ");
|
params.put("ypj", Constants.SC_WORKFLOW_INCIDENT_STATE_YPJ);
|
}
|
|
}
|
return sql;
|
}
|
|
@Override
|
public Map queryIncidentBaseMsg(String orderId) {
|
String selectSql = "SELECT A.*,N.ANSWER_TIME AS XY_TIME,B.WFSTATE FROM SC_WORKFLOW_INCIDENT A LEFT JOIN WORKFLOW_BASE B ON A.ID = B.BUSINESS_ID LEFT JOIN WORKFLOW_NODE N ON B.CURRENT_NODE_ID = N.ID WHERE A.ID = :orderId ";
|
Map baseMap = baseDao.queryForMap(selectSql,new SqlParameter("orderId",orderId));
|
if(null!=baseMap && baseMap.size()>0) {
|
//查询附件
|
List<Map> files = fileService.getFileList(orderId);
|
baseMap.put("files", files);
|
}
|
return baseMap;
|
}
|
|
//查询事件流转记录
|
@Override
|
public List<Map> incidentLzRecord(String flowId) {
|
|
//查询该流程中，所有的流程节点模板对应的流程
|
String nodeSql = "SELECT N.* FROM WORKFLOW_NODE N,WORKFLOW_TEMPLATE_NODE B WHERE N.NODE_TEMPLATE_ID = B.ID AND N.FLOWID = :flowId ORDER BY N.CREATETIME DESC,N.IS_ADMIN DESC ";
|
/**
|
* 1.分配到分组
|
* 2.分配到单个人员
|
* 3.分配到多个人
|
*/
|
|
List<Map> records = baseDao.queryForList(nodeSql,new SqlParameter("flowId",flowId));
|
if(null!=records && records.size()>0) {
|
List<String> list = new ArrayList<String>();
|
|
Map<String,Object> cacheMap = new HashMap<String,Object>();
|
Map cacheName = new HashMap();
|
for(Map record : records) {
|
String node_template_id = ConvertUtil.obj2StrBlank(record.get("NODE_TEMPLATE_ID"));
|
String same_node_key = ConvertUtil.obj2StrBlank(record.get("SAME_NODE_KEY"));
|
String unitKey = node_template_id +"-"+ same_node_key;
|
String nodeName = ConvertUtil.obj2StrBlank(record.get("NODENAME"));
|
|
String dealType = ConvertUtil.obj2StrBlank(record.get("DEAL_TYPE"));
|
String current_deal_roleida = ConvertUtil.obj2StrBlank(record.get("CURRENT_DEAL_ROLEIDA"));
|
String current_dealer_id = ConvertUtil.obj2StrBlank(record.get("CURRENT_DEALER_ID"));
|
if(dealType.equals("1") && StringUtil.notEmpty(current_deal_roleida) && !StringUtil.notEmpty(current_dealer_id)) {
|
List<Map> users = queryUser(current_deal_roleida);
|
StringBuilder builder = new StringBuilder();
|
if(null!=users && users.size()>0) {
|
for(Map user : users) {
|
String userName = ConvertUtil.obj2StrBlank(user.get("USER_NAME"));
|
builder.append(userName).append(" ");
|
}
|
}
|
record.put("users", builder.toString());
|
}
|
|
|
cacheName.put(unitKey, nodeName);
|
if(cacheMap.containsKey(unitKey)) {
|
List rs = (List)cacheMap.get(unitKey);
|
rs.add(record);
|
} else {
|
List rs = new ArrayList();
|
rs.add(record);
|
cacheMap.put(unitKey, rs);
|
list.add(unitKey);
|
}
|
|
|
|
String answer_usertime = ConvertUtil.obj2StrBlank(record.get("ANSWER_USERTIME"));
|
if(StringUtil.notEmpty(answer_usertime) && !answer_usertime.equals("0")) {
|
String answerTime = DateUtil.getFormatSeconds(ConvertUtil.obj2Int(answer_usertime));
|
record.put("ANSWER_USERTIME", answerTime);
|
}
|
|
String deal_usetime = ConvertUtil.obj2StrBlank(record.get("DEAL_USETIME"));
|
if(StringUtil.notEmpty(deal_usetime) && !deal_usetime.equals("0")) {
|
String dealTime = DateUtil.getFormatSeconds(ConvertUtil.obj2Int(deal_usetime));
|
record.put("DEAL_USETIME", dealTime);
|
}
|
}
|
|
//查询工单类型
|
List<Map> result = new ArrayList<Map>();
|
for(String key : list) {
|
Map map = new HashMap();
|
map.put("node_template_id", key);
|
map.put("node_template_name", cacheName.get(key));
|
List<Map> rds = (List)cacheMap.get(key);
|
|
for(Map rd : rds) {
|
//判断主负责人的状态
|
String isAdmin = ConvertUtil.obj2StrBlank((rd.get("IS_ADMIN")));
|
if(isAdmin.equals("1")) {
|
map.put("flowstate", rd.get("FLOWSTATE"));
|
}
|
}
|
map.put("rds", rds);
|
result.add(map);
|
}
|
|
System.out.println(JsonUtil.list2Json(result));
|
return result;
|
|
}
|
return null;
|
}
|
|
private List<Map> queryUser(String current_deal_roleida) {
|
String selectSql = "SELECT B.ID AS USER_ID,B.ZSXM AS USER_NAME FROM AC_USER_REF_ROLE A,GG_USER B WHERE A.JSBH = :groupId AND A.YHBH = B.ID AND B.ZT = 1 ORDER BY B.ZSXM ";
|
List users = baseDao.queryForList(selectSql,new SqlParameter("groupId",current_deal_roleida));
|
return users;
|
}
|
|
@Override
|
public List queryDealRecord(String flowId) {
|
|
List<Map> list = recordService.queryRecord(flowId);
|
|
if(null!=list && list.size()>0) {
|
Map cacheFile = new HashMap();
|
//查询所有该事件工单下的文档
|
List<Map> files = fileService.getFileList(flowId,1);
|
if(null!=files && files.size()>0) {
|
for(Map file :files) {
|
String extend = ConvertUtil.obj2StrBlank(file.get("BUSINESS_ID"));
|
if(StringUtil.notEmpty(extend)) {
|
List cacheList = new ArrayList();
|
if(cacheFile.containsKey(extend)) {
|
cacheList = (List)cacheFile.get(extend);
|
}
|
cacheList.add(file);
|
cacheFile.put(extend, cacheList);
|
}
|
}
|
}
|
if(null!=cacheFile && cacheFile.size()>0) {
|
for(Map record : list) {
|
String recordId = ConvertUtil.obj2StrBlank(record.get("ID"));
|
if(cacheFile.containsKey(recordId)) {
|
record.put("files", cacheFile.get(recordId));
|
}
|
}
|
}
|
}
|
|
|
return list;
|
}
|
|
/**
|
* 查询该事件工单关联的设备
|
*/
|
@Override
|
public List queryDevices(String flowId) {
|
//查询流程所有的关联设备
|
List devices = deviceService.queryLinkDevices(flowId);
|
return devices;
|
}
|
|
/**
|
* 查询关联工单
|
*/
|
@Override
|
public List queryOrders(String flowId) {
|
List<Map> orders = orderService.queryLinkOrders(flowId);
|
return orders;
|
}
|
|
/**
|
* 查询所有的文档附件
|
*/
|
@Override
|
public List queryFiles(String flowId) {
|
List<Map> files = fileService.getFileList(flowId,1);
|
if(null!=files && files.size()>0) {
|
for(Map file : files) {
|
file.put("FILE_SIZE", StringUtil.getFileSize(ConvertUtil.obj2Double(file.get("FILE_SIZE"))));
|
}
|
}
|
return files;
|
}
|
|
@Override
|
public Map queryWcReport(String orderId) {
|
Map incident = new SC_WORKFLOW_INCIDENT(orderId).getBeanMapById();
|
String flowId = ConvertUtil.obj2StrBlank(incident.get("FLOW_ID"));
|
//查询关联工单
|
if(null!=incident && incident.size()>0) {
|
List<Map> orders = queryOrders(flowId);
|
List<Map> devices = queryDevices(flowId);
|
List<Map> files = queryFiles(flowId);
|
|
incident.put("orders", orders);
|
incident.put("devices", devices);
|
incident.put("files", files);
|
}
|
|
//判断当前事件工单是否已评价
|
|
WORKFLOW_BASE base = new WORKFLOW_BASE(flowId).getInstanceById();
|
int wfstate = base.getWfstate();
|
if(wfstate == Constants.WORKFLOW_BASE_WFSTATE_EVALUATE) {
|
//查询调查记录
|
Map statis = queryStatis(flowId);
|
incident.put("statis", statis);
|
}
|
|
|
return incident;
|
}
|
|
private Map queryStatis(String flowId) {
|
Map map = new HashMap();
|
String selectSql = " SELECT * FROM ORDER_SATIS_INFO WHERE BUSINESS_ID = :flowId ";
|
map = baseDao.queryForMap(selectSql,new SqlParameter("flowId",flowId));
|
return map;
|
}
|
|
@Override
|
public Map queryCloseReport(String orderId) {
|
Map incident = new SC_WORKFLOW_INCIDENT(orderId).getBeanMapById();
|
if(null!=incident && incident.size()>0) {
|
String merged_business_id = ConvertUtil.obj2StrBlank(incident.get("MERGED_BUSINESS_ID"));
|
if(StringUtil.notEmpty(merged_business_id)) {
|
Map linkIncident = new SC_WORKFLOW_INCIDENT(merged_business_id).getBeanMapById();
|
incident.put("linkIncident", linkIncident);
|
}
|
}
|
return incident;
|
}
|
|
/**
|
* 查询文档信息
|
*/
|
@Override
|
public Map queryFileMsg(String fileId) {
|
String selectSql = "SELECT * FROM GG_FILES WHERE ID = :id";
|
return baseDao.queryForMap(selectSql,new SqlParameter("id",fileId));
|
}
|
|
@Override
|
public Map getLastMonthIncidentEffect(HttpServletRequest request) {
|
Map chartMap = new HashMap();
|
String cusId = request.getParameter("cusId");
|
String userId = request.getParameter("userId");
|
Long endDay = DateUtil.getCurrentDate8();
|
Long startDay = DateUtil.getDateAdd(endDay,-30,8);
|
|
SqlParameter param = new SqlParameter();
|
param.addValue("startTime", startDay+"000000")
|
.addValue("endTime", endDay + "600000")
|
.addValue("userId", userId)
|
.addValue("cusId", cusId);
|
|
StringBuilder builder = new StringBuilder();
|
if(StringUtil.isBlank(userId)){
|
builder.append(" SELECT count(ID) NUM,INFLUENCE_ID FROM SC_WORKFLOW_INCIDENT WHERE ");
|
builder.append(" CUSTOMER_ID = :cusId AND CREATE_TIME >= :startTime AND CREATE_TIME <= :endTime ");
|
builder.append(" GROUP BY INFLUENCE_ID ");
|
}else{
|
builder.append(" SELECT count(q.ID) NUM,q.INFLUENCE_ID FROM SC_WORKFLOW_INCIDENT q,WORKFLOW_BASE b ");
|
builder.append(" where b.ID = q.FLOW_ID and EXISTS ( ");
|
builder.append(" select FLOWID from workflow_node n where b.ID = n.FLOWID and n.CURRENT_DEALER_ID = :userId ");
|
builder.append(" ) and q.CUSTOMER_ID = :cusId and q.CREATE_TIME>=:startTime and q.CREATE_TIME<=:endTime group by q.INFLUENCE_ID ");
|
}
|
|
List<Map> dataList = baseDao.queryForList(builder.toString(),param);
|
if(dataList!=null&&dataList.size()>0){
|
Map dataMap = new HashMap();
|
Map tempMap = new HashMap();
|
List serieslist = new ArrayList();
|
for(Map data : dataList){
|
dataMap.put(data.get("INFLUENCE_ID").toString(), data);
|
}
|
List<Map> catelist = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.EVENT_EFFECT_DG);
|
if(catelist!=null&&catelist.size()>0){
|
for(Map cate : catelist){
|
List tempList = new ArrayList();
|
tempList.add(cate.get("DATAVALUE").toString());
|
if(dataMap.get(cate.get("DATAKEY").toString())!=null){
|
tempList.add(((Map)dataMap.get(cate.get("DATAKEY").toString())).get("NUM"));
|
}else{
|
tempList.add(0);
|
}
|
serieslist.add(tempList);
|
}
|
}
|
chartMap.put("seriesData", serieslist);
|
}
|
return chartMap;
|
}
|
|
@Override
|
public Map getLastMonthIncidentServer(HttpServletRequest request) {
|
Map chartMap = new HashMap();
|
Long endDay = DateUtil.getCurrentDate8();
|
Long startDay = DateUtil.getDateAdd(endDay,-30,8);
|
|
String cusId = request.getParameter("cusId");
|
String userId = request.getParameter("userId");
|
StringBuilder builder = new StringBuilder();
|
SqlParameter param = new SqlParameter();
|
param.addValue("cusId", cusId)
|
.addValue("startTime", startDay+"000000")
|
.addValue("endTime", endDay + "600000")
|
.addValue("userId", userId);
|
if(StringUtil.isBlank(userId)){
|
builder.append(" select count(ID) NUM,THIRD_CATEGORY_ID SERVER_ID from SC_WORKFLOW_INCIDENT where CUSTOMER_ID = :cusId ");
|
builder.append(" and CREATE_TIME>=:startTime and CREATE_TIME<=:endTime group by SERVER_ID ");
|
}else{
|
builder.append(" select count(q.ID) NUM,q.THIRD_CATEGORY_ID SERVER_ID from SC_WORKFLOW_INCIDENT q,WORKFLOW_BASE b ");
|
builder.append(" where b.ID = q.FLOW_ID and EXISTS ( ");
|
builder.append(" select FLOWID from workflow_node n where b.ID = n.FLOWID and n.CURRENT_DEALER_ID = :userId ");
|
builder.append(" ) and q.CUSTOMER_ID = :cusId and q.CREATE_TIME>=:startTime and q.CREATE_TIME<=:endTime group by SERVER_ID ");
|
}
|
|
|
|
|
List<Map> dataList = baseDao.queryForList(builder.toString(),param);
|
if(dataList!=null&&dataList.size()>0){
|
builder.setLength(0);
|
builder.append(" SELECT C.ID SERVER_ID,C.CATEGORY_NAME SERVER_NAME FROM SC_SERVCE_CATEGORY C,SC_SERVCE_CATEGORY_CUSTOMER P ");
|
builder.append(" WHERE C.ID = P.CATEGORY_ID and C.LEVEL = 3 and C.STATE=1 ");
|
builder.append(" AND P.STATE = 1 AND P.CUSTOMER_ID = :cusId ORDER BY SERIAL ASC ");
|
List<Map> categoriesList = baseDao.queryForList(builder.toString(),param);
|
List<String> categories = new ArrayList<String>();
|
Map dataMap = new HashMap();
|
Map tempMap = new HashMap();
|
List<Map> series = new ArrayList<Map>();
|
tempMap.put("name", "数量");
|
List tempList = new ArrayList();
|
for(Map data:dataList){
|
dataMap.put(data.get("SERVER_ID").toString(), data);
|
}
|
for(Map cate:categoriesList){
|
categories.add(cate.get("SERVER_NAME").toString());
|
if(dataMap.get(cate.get("SERVER_ID").toString())!=null){
|
tempList.add(((Map)dataMap.get(cate.get("SERVER_ID").toString())).get("NUM"));
|
}else{
|
tempList.add(0);
|
}
|
}
|
tempMap.put("data", tempList);
|
series.add(tempMap);
|
chartMap.put("categories",categories);
|
chartMap.put("series",series);
|
}
|
return chartMap;
|
}
|
|
@Override
|
public Map getLastMonthIncidentLv(HttpServletRequest request) {
|
Map chartMap = new HashMap();
|
String cusId = request.getParameter("cusId");
|
String userId = request.getParameter("userId");
|
Long endDay = DateUtil.getCurrentDate8();
|
Long startDay = DateUtil.getDateAdd(endDay,-30,8);
|
|
SqlParameter param = new SqlParameter();
|
param.addValue("startTime", startDay+"000000")
|
.addValue("endTime", endDay + "600000")
|
.addValue("userId", userId)
|
.addValue("cusId", cusId);
|
|
StringBuilder builder = new StringBuilder();
|
if(StringUtil.isBlank(userId)){
|
builder.append(" SELECT count(ID) NUM,SLA_ID FROM SC_WORKFLOW_INCIDENT WHERE ");
|
builder.append(" CUSTOMER_ID = :cusId AND CREATE_TIME >= :startTime AND CREATE_TIME <= :endTime ");
|
builder.append(" GROUP BY SLA_ID ");
|
}else{
|
builder.append(" SELECT count(q.ID) NUM,q.SLA_ID FROM SC_WORKFLOW_INCIDENT q,WORKFLOW_BASE b ");
|
builder.append(" where b.ID = q.FLOW_ID and EXISTS ( ");
|
builder.append(" select FLOWID from workflow_node n where b.ID = n.FLOWID and n.CURRENT_DEALER_ID = :userId ");
|
builder.append(" ) and q.CUSTOMER_ID = :cusId and q.CREATE_TIME>=:startTime and q.CREATE_TIME<=:endTime group by q.SLA_ID ");
|
}
|
|
List<Map> dataList = baseDao.queryForList(builder.toString(),param);
|
if(dataList!=null&&dataList.size()>0){
|
Map dataMap = new HashMap();
|
Map tempMap = new HashMap();
|
List serieslist = new ArrayList();
|
|
for(Map data : dataList){
|
dataMap.put(data.get("SLA_ID").toString(), data);
|
}
|
|
builder.setLength(0);
|
builder.append(" select ID LEVEL_ID,LEVEL_NAME from SC_SLA order by SERIAL ");
|
List<Map> catelist = baseDao.queryForList(builder.toString());
|
for(Map cate : catelist){
|
List tempList = new ArrayList();
|
tempList.add(cate.get("LEVEL_NAME").toString());
|
if(dataMap.get(cate.get("LEVEL_ID").toString())!=null){
|
tempList.add(((Map)dataMap.get(cate.get("LEVEL_ID").toString())).get("NUM"));
|
}else{
|
tempList.add(0);
|
}
|
serieslist.add(tempList);
|
}
|
chartMap.put("seriesData", serieslist);
|
}
|
return chartMap;
|
}
|
|
@Override
|
public Map getLastMonthIncidentPri(HttpServletRequest request) {
|
Map chartMap = new HashMap();
|
String cusId = request.getParameter("cusId");
|
String userId = request.getParameter("userId");
|
Long endDay = DateUtil.getCurrentDate8();
|
Long startDay = DateUtil.getDateAdd(endDay,-30,8);
|
|
SqlParameter param = new SqlParameter();
|
param.addValue("startTime", startDay+"000000")
|
.addValue("endTime", endDay + "600000")
|
.addValue("userId", userId)
|
.addValue("cusId", cusId);
|
|
StringBuilder builder = new StringBuilder();
|
if(StringUtil.isBlank(userId)){
|
builder.append(" SELECT count(ID) NUM,PRIORITY_ID FROM SC_WORKFLOW_INCIDENT WHERE ");
|
builder.append(" CUSTOMER_ID = :cusId AND CREATE_TIME >= :startTime AND CREATE_TIME <= :endTime ");
|
builder.append(" GROUP BY PRIORITY_ID ");
|
}else{
|
builder.append(" SELECT count(q.ID) NUM,q.PRIORITY_ID FROM SC_WORKFLOW_INCIDENT q,WORKFLOW_BASE b ");
|
builder.append(" where b.ID = q.FLOW_ID and EXISTS ( ");
|
builder.append(" select FLOWID from workflow_node n where b.ID = n.FLOWID and n.CURRENT_DEALER_ID = :userId ");
|
builder.append(" ) and q.CUSTOMER_ID = :cusId and q.CREATE_TIME>=:startTime and q.CREATE_TIME<=:endTime group by q.PRIORITY_ID ");
|
}
|
|
List<Map> dataList = baseDao.queryForList(builder.toString(),param);
|
if(dataList!=null&&dataList.size()>0){
|
Map dataMap = new HashMap();
|
Map tempMap = new HashMap();
|
List serieslist = new ArrayList();
|
for(Map data : dataList){
|
dataMap.put(data.get("PRIORITY_ID").toString(), data);
|
}
|
List<Map> catelist = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.EVENT_PRI);
|
for(Map cate : catelist){
|
List tempList = new ArrayList();
|
tempList.add(cate.get("DATAVALUE").toString());
|
if(dataMap.get(cate.get("DATAKEY").toString())!=null){
|
tempList.add(((Map)dataMap.get(cate.get("DATAKEY").toString())).get("NUM"));
|
}else{
|
tempList.add(0);
|
}
|
serieslist.add(tempList);
|
}
|
chartMap.put("seriesData", serieslist);
|
}
|
return chartMap;
|
}
|
|
@Override
|
public Map getLastMonthIncidentCount(HttpServletRequest request) {
|
Map chartMap = new HashMap();
|
Long endDay = DateUtil.getCurrentDate8();
|
Long startDay = DateUtil.getDateAdd(endDay,-30,8);
|
|
String cusId = request.getParameter("cusId");
|
String userId = request.getParameter("userId");
|
StringBuilder builder = new StringBuilder();
|
SqlParameter param = new SqlParameter();
|
param.addValue("cusId", cusId)
|
.addValue("startTime", startDay+"000000")
|
.addValue("userId", userId)
|
.addValue("endTime", endDay + "600000");
|
if(StringUtil.isBlank(userId)){
|
builder.append(" select count(ID) NUM,DATE_FORMAT(CREATE_TIME,'%Y%m%d') CREATEDAY from SC_WORKFLOW_INCIDENT where CUSTOMER_ID = :cusId ");
|
builder.append(" and CREATE_TIME>=:startTime and CREATE_TIME<=:endTime group by CREATEDAY ");
|
}else{
|
builder.append(" select count(q.ID) NUM,DATE_FORMAT(q.CREATE_TIME,'%Y%m%d') CREATEDAY from workflow_base b ,SC_WORKFLOW_INCIDENT q ");
|
builder.append(" where b.ID = q.FLOW_ID and EXISTS ( ");
|
builder.append(" select FLOWID from workflow_node n where b.ID = n.FLOWID and n.CURRENT_DEALER_ID = :userId ");
|
builder.append(" ) and q.CUSTOMER_ID = :cusId and q.CREATE_TIME>=:startTime and q.CREATE_TIME<=:endTime group by CREATEDAY ");
|
}
|
|
List<Map> dataList = baseDao.queryForList(builder.toString(),param);
|
if(dataList!=null&&dataList.size()>0){
|
|
List<String> categories = DateUtil.getDates(startDay ,endDay);
|
categories.add(String.valueOf(DateUtil.getCurrentDate8()));
|
List<String> categories_format = new ArrayList<String>();
|
|
|
Map dataMap = new HashMap();
|
Map tempMap = new HashMap();
|
List<Map> series = new ArrayList<Map>();
|
tempMap.put("name", "事件数量");
|
List tempList = new ArrayList();
|
for(Map data:dataList){
|
dataMap.put(data.get("CREATEDAY").toString(), data);
|
}
|
for(String day:categories){
|
categories_format.add(DateUtil.format("yyyy-MM-dd",day));
|
if(dataMap.get(day)!=null){
|
tempList.add(((Map)dataMap.get(day)).get("NUM"));
|
}else{
|
tempList.add(0);
|
}
|
}
|
tempMap.put("data", tempList);
|
series.add(tempMap);
|
chartMap.put("categories",categories_format);
|
chartMap.put("step",Math.ceil(categories.size()/9));
|
chartMap.put("series",series);
|
}
|
return chartMap;
|
}
|
|
@Override
|
public int incidentpoolCount(Map<String,String> params) {
|
/**
|
* 查询我的工单池规则
|
* 如果是一二三线或者驻场工程师桌面,则直接查询工单表中 所属分组是当前工程师所在组的
|
* 如果是项目服务台，则直接查询工单表中所属分组是当前工程师所在组的 （同上）
|
* 如果是客户服务台，查询我的工单池 则查询工单表中分组是 （查询该客户下所有的项目的服务台分组）
|
* 如果是总服务台，则查询所有客户下（加盟商下所有项目的服务台分组）
|
*/
|
|
|
StringBuffer sql = new StringBuffer();
|
params.put("wfstate", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE));
|
|
sql.append("SELECT COUNT(D.ID) FROM SC_WORKFLOW_INCIDENT E,WORKFLOW_BASE D,(SELECT B.ID,B.ROLENAME FROM AC_ROLE B WHERE B.STATE = 1");
|
sql.append(") C WHERE E.ID = D.BUSINESS_ID AND D.CURRENT_DEAL_ROLEIDA = C.ID AND D.WFSTATE != :wfstate AND (D.CURRENT_DEALER_ID IS NULL OR D.CURRENT_DEALER_ID = '' )");
|
StringBuilder builder = new StringBuilder(sql);
|
String cusId = params.get("cusId");
|
if(StringUtil.notEmpty(cusId)) {
|
builder.append(" AND D.CUSTOMER_ID = :cusId ");
|
}
|
String status = params.get("status");
|
if(StringUtil.notEmpty(status)) {
|
builder.append(" AND E.STATE = :status ");
|
}
|
String subCustomerId = params.get("subCustomerId");
|
if(StringUtil.notEmpty(subCustomerId)) {
|
builder.append(" AND D.SUB_CUSTOMER_ID = :subCustomerId ");
|
}
|
String orderName = params.get("orderName");
|
if(StringUtil.notEmpty(orderName)) {
|
builder.append(" AND D.WFNAME LIKE :orderName ");
|
params.put("orderName", "%"+orderName+"%");
|
}
|
|
|
String orderCode = params.get("orderCode");
|
if(StringUtil.notEmpty(orderCode)) {
|
builder.append(" AND D.ORDER_CODE LIKE :orderCode");
|
params.put("orderCode", "%"+orderCode+"%");
|
}
|
|
String customerName = params.get("customerName");
|
if(StringUtil.notEmpty(customerName)) {
|
builder.append(" AND D.CUSTOMER_NAME LIKE :customerName ");
|
params.put("customerName", "%"+customerName+"%");
|
}
|
|
builder.append(" AND D.BUSINESSTYPE = :businessType");
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
|
int count = baseDao.queryForInteger(builder.toString(),params);
|
|
return count;
|
}
|
|
@Override
|
public PageInfo incidentpoolData(PageInfo pageInfo,Map<String,String> params) {
|
/**
|
* 查询我的工单池规则
|
* 如果是项目服务台，则直接查询工单表
|
* 如果是客户服务台，查询我的工单池 则查询工单表中分组是 （查询该客户下所有的项目的分组）
|
* 如果是总服务台，则查询所有客户下（加盟商下所有项目的分组）
|
*/
|
|
|
StringBuffer sql = new StringBuffer();
|
params.put("wfstate", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE));
|
//查询该人员所属的项目
|
sql.append("SELECT D.* FROM SC_WORKFLOW_INCIDENT E,WORKFLOW_BASE D,(SELECT B.ID,B.ROLENAME FROM AC_ROLE B WHERE B.STATE = 1 ");
|
|
sql.append(") C WHERE E.ID = D.BUSINESS_ID AND D.CURRENT_DEAL_ROLEIDA = C.ID AND D.WFSTATE != :wfstate AND (D.CURRENT_DEALER_ID IS NULL OR D.CURRENT_DEALER_ID = '' )");
|
StringBuilder builder = new StringBuilder(sql);
|
String status = params.get("status");
|
if(StringUtil.notEmpty(status)) {
|
builder.append(" AND E.STATE = :status ");
|
params.put("status", status);
|
}
|
String cusId = params.get("cusId");
|
if(StringUtil.notEmpty(cusId)) {
|
builder.append(" AND D.CUSTOMER_ID = :cusId ");
|
params.put("cusId", cusId);
|
}
|
String subCustomerId = params.get("subCustomerId");
|
if(StringUtil.notEmpty(subCustomerId)) {
|
builder.append(" AND D.SUB_CUSTOMER_ID = :subCustomerId ");
|
params.put("subCustomerId", subCustomerId);
|
}
|
|
String orderName = params.get("orderName");
|
if(StringUtil.notEmpty(orderName)) {
|
builder.append(" AND D.WFNAME LIKE :orderName ");
|
params.put("orderName", "%"+orderName+"%");
|
}
|
|
|
String orderCode = params.get("orderCode");
|
if(StringUtil.notEmpty(orderCode)) {
|
builder.append(" AND D.ORDER_CODE LIKE :orderCode");
|
params.put("orderCode", "%"+orderCode+"%");
|
}
|
|
String customerName = params.get("customerName");
|
if(StringUtil.notEmpty(customerName)) {
|
builder.append(" AND D.CUSTOMER_NAME LIKE :customerName ");
|
params.put("customerName", "%"+customerName+"%");
|
}
|
|
builder.append(" AND D.BUSINESSTYPE = :businessType");
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
|
PageInfo result = baseDao.queryforSplitPageInfo(pageInfo, builder.toString(), params);
|
|
return result;
|
}
|
|
@Override
|
public Map queryincidentpoolCount(String cusId) {
|
//初始化变量
|
int ywc = 0;
|
//服务台
|
int fwt = 0;
|
|
//一线工程师
|
int yxgcs = 0;
|
|
//二线工程师
|
int exgcs = 0;
|
|
//三线工程师
|
int sxgcs = 0;
|
StringBuffer sql = new StringBuffer();
|
StringBuffer sqlall = new StringBuffer();
|
Map paramMap = new HashMap();
|
paramMap.put("wfstate", Constants.WORKFLOW_BASE_WFSTATE_DELETE);
|
paramMap.put("cusId", cusId);
|
|
sql.append("SELECT COUNT(*) AS NUM,E.STATE FROM SC_WORKFLOW_INCIDENT E,WORKFLOW_BASE D,(SELECT B.ID,B.ROLENAME FROM AC_ROLE B WHERE B.STATE = 1 ");
|
sqlall.append("SELECT COUNT(F.ID) FROM (SELECT E.* FROM SC_WORKFLOW_INCIDENT E,WORKFLOW_BASE D,(SELECT B.ID,B.ROLENAME FROM AC_ROLE B WHERE B.STATE = 1 ");
|
|
sql.append(") C WHERE E.ID = D.BUSINESS_ID AND E.CUSTOMER_ID = :cusId AND D.CURRENT_DEAL_ROLEIDA = C.ID AND D.WFSTATE != :wfstate AND (D.CURRENT_DEALER_ID IS NULL OR D.CURRENT_DEALER_ID = '' )");
|
sql.append(" GROUP BY E.STATE ");
|
sqlall.append(") C WHERE E.ID = D.BUSINESS_ID AND E.CUSTOMER_ID = :cusId AND D.CURRENT_DEAL_ROLEIDA = C.ID AND D.WFSTATE != :wfstate AND (D.CURRENT_DEALER_ID IS NULL OR D.CURRENT_DEALER_ID = '' )");
|
sqlall.append(" GROUP BY E.ID) F ");
|
List<Map> list = baseDao.queryForList(sql.toString(),paramMap);
|
if(null!=list && list.size()>0) {
|
for(Map map : list) {
|
String state = ConvertUtil.obj2StrBlank(map.get("STATE"));
|
int num = ConvertUtil.obj2Int(map.get("NUM"));
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDFWT)) {
|
fwt += num;
|
continue;
|
}
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYX)) {
|
yxgcs += num;
|
continue;
|
}
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDEX)) {
|
exgcs += num;
|
continue;
|
}
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDSX)) {
|
sxgcs += num;
|
continue;
|
}
|
|
}
|
}
|
int all = baseDao.queryForInteger(sqlall.toString(), paramMap);
|
Map map = new HashMap();
|
map.put("fwt", fwt);
|
|
map.put("yxgcs", yxgcs);
|
|
map.put("exgcs", exgcs);
|
|
map.put("sxgcs", sxgcs);
|
|
|
map.put("all", all);
|
return map;
|
}
|
|
@Override
|
public Map queryincidentNodeCount(String cusId) {
|
//初始化变量
|
int ywc = 0;
|
//服务台
|
int fwt = 0;
|
|
//一线工程师
|
int yxgcs = 0;
|
|
//二线工程师
|
int exgcs = 0;
|
|
//三线工程师
|
int sxgcs = 0;
|
|
|
|
//只有服务台和管理人员才可以看到所有的工单，（所以查询当前的用户属于那种服务台）
|
StringBuffer selectSql = new StringBuffer();
|
StringBuffer sql = new StringBuffer();
|
|
Map paramMap = new HashMap();
|
paramMap.put("cusId", cusId);
|
selectSql.append( "SELECT COUNT(*) AS NUM,D.STATE FROM (SELECT A.* FROM SC_WORKFLOW_INCIDENT A,WORKFLOW_BASE B , WORKFLOW_NODE C WHERE B.ID = C.FLOWID AND C.FLOWSTATE = 1 AND C.CURRENT_DEALER_ID IS NOT NULL AND A.ID = B.BUSINESS_ID ");
|
sql.append( "SELECT COUNT(D.ID) FROM (SELECT A.* FROM SC_WORKFLOW_INCIDENT A,WORKFLOW_BASE B , WORKFLOW_NODE C WHERE B.ID = C.FLOWID AND C.FLOWSTATE = 1 AND C.CURRENT_DEALER_ID IS NOT NULL AND A.ID = B.BUSINESS_ID ");
|
|
selectSql.append(" AND A.CUSTOMER_ID = :cusId ");
|
sql.append(" AND A.CUSTOMER_ID =:cusId ");
|
|
selectSql.append(" GROUP BY A.ID) D GROUP BY D.STATE ");
|
sql.append(" GROUP BY A.ID) D ");
|
|
List<Map> list = baseDao.queryForList(selectSql.toString(),paramMap);
|
if(null!=list && list.size()>0) {
|
for(Map map : list) {
|
String state = ConvertUtil.obj2StrBlank(map.get("STATE"));
|
int num = ConvertUtil.obj2Int(map.get("NUM"));
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDFWT)) {
|
fwt += num;
|
continue;
|
}
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYX)) {
|
yxgcs += num;
|
continue;
|
}
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDEX)) {
|
exgcs += num;
|
continue;
|
}
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDSX)) {
|
sxgcs += num;
|
continue;
|
}
|
|
}
|
}
|
int all = baseDao.queryForInteger(sql.toString(), paramMap);
|
Map map = new HashMap();
|
map.put("fwt", fwt);
|
|
map.put("yxgcs", yxgcs);
|
|
map.put("exgcs", exgcs);
|
|
map.put("sxgcs", sxgcs);
|
|
|
map.put("all", all);
|
|
return map;
|
}
|
|
@Override
|
public int queryincidentOrderNodeCount(Map<String,String> params) {
|
StringBuilder sql = new StringBuilder();
|
StringBuilder sqlpart = new StringBuilder();
|
sql.append("SELECT COUNT(D.ID) FROM (SELECT B.* FROM SC_WORKFLOW_INCIDENT B,WORKFLOW_BASE WB , WORKFLOW_NODE C ");
|
sqlpart.append(" WHERE WB.BUSINESS_ID = B.ID AND C.FLOWID = WB.ID AND C.FLOWSTATE = 1 AND C.CURRENT_DEALER_ID IS NOT NULL AND WB.BUSINESSTYPE = :businessType ");
|
|
sqlpart = getIncidentNodeSql(sqlpart,params);
|
sql.append(sqlpart);
|
sql.append( " GROUP BY B.ID ) D");
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
return baseDao.queryForInteger(sql.toString(),params);
|
}
|
|
@Override
|
public PageInfo queryincidentOrderNodeList(PageInfo pageInfo,Map<String,String> params) {
|
StringBuilder sql = new StringBuilder();
|
StringBuilder sqlpart = new StringBuilder();
|
sql.append("SELECT WB.ID,WB.ORDER_CODE,WB.WFNAME,WB.BUSINESSTYPE,WB.CREATERNAME,WB.CREATETIME,WB.WFNOTE , ");
|
sql.append("WB.CURRENT_NODE_ID,WB.CURRENT_NODE_NAME,WB.CUSTOMER_NAME,WB.SUB_CUSTOMER_NAME,WB.PROJECT_NAME,WB.CURRENT_DEALER_NAME,WB.BUSINESS_ID,WB.WFSTATE,B.STATE ,B.NAME ");
|
sql.append("FROM SC_WORKFLOW_INCIDENT B,WORKFLOW_BASE WB , WORKFLOW_NODE C ");
|
sqlpart.append(" WHERE WB.BUSINESS_ID = B.ID AND C.FLOWID = WB.ID AND C.FLOWSTATE = 1 AND C.CURRENT_DEALER_ID IS NOT NULL AND WB.BUSINESSTYPE = :businessType ");
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
sqlpart = getIncidentNodeSql(sqlpart,params);
|
|
sql.append(sqlpart);
|
sql.append( " GROUP BY WB.ID ORDER BY WB.CREATETIME DESC ");
|
|
return baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
}
|
|
public StringBuilder getIncidentNodeSql(StringBuilder sqlpart,Map<String,String> params){
|
|
|
String cusId = params.get("cusId");
|
if(StringUtil.notEmpty(cusId)) {
|
sqlpart.append(" AND B.CUSTOMER_ID = :cusId ");
|
}
|
String subCustomerId = params.get("subCustomerId");
|
if(StringUtil.notEmpty(subCustomerId)) {
|
sqlpart.append(" AND B.SUB_CUSTOMER_ID = :subCustomerId ");
|
}
|
|
String orderName = params.get("orderName");
|
if(StringUtil.notEmpty(orderName)) {
|
sqlpart.append(" AND B.NAME LIKE :orderName ");
|
params.put("orderName", "%"+orderName+"%");
|
}
|
|
String orderCode = params.get("orderCode");
|
if(StringUtil.notEmpty(orderCode)) {
|
sqlpart.append(" AND B.ORDER_CODE LIKE :orderCode ");
|
params.put("orderCode", "%"+orderCode+"%");
|
}
|
|
|
String contract = params.get("contract");
|
if(StringUtil.notEmpty(contract)) {
|
sqlpart.append(" AND B.CONTACT_NAME LIKE :contract ");
|
params.put("contract", "%"+contract+"%");
|
}
|
|
|
String pri = params.get("pri");
|
if(StringUtil.notEmpty(pri)) {
|
String[] pris = pri.split(",");
|
if(pris.length==1) {
|
sqlpart.append(" AND B.PRIORITY_ID = :priority_id");
|
params.put("priority_id", pris[0]);
|
} else {
|
sqlpart.append(" AND B.PRIORITY_ID IN (");
|
for(int i=0; i<pris.length; i++) {
|
sqlpart.append(" :pri"+i);
|
sqlpart.append(",");
|
params.put("pri"+i, pris[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
|
|
String dg = params.get("dg");
|
if(StringUtil.notEmpty(dg)) {
|
String[] dgs = dg.split(",");
|
if(dgs.length==1) {
|
sqlpart.append(" AND B.INFLUENCE_ID = :influence_id");
|
params.put("influence_id", dgs[0]);
|
} else {
|
sqlpart.append(" AND B.INFLUENCE_ID IN (");
|
for(int i=0; i<dgs.length; i++) {
|
sqlpart.append(" :dg"+i);
|
sqlpart.append(",");
|
params.put("dg"+i, dgs[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
|
String type = params.get("source");
|
if(StringUtil.notEmpty(type)) {
|
String[] types = type.split(",");
|
if(types.length==1) {
|
sqlpart.append(" AND B.TYPE_ID = :type_id");
|
params.put("type_id", types[0]);
|
} else {
|
sqlpart.append(" AND B.TYPE_ID IN (");
|
for(int i=0; i<types.length; i++) {
|
sqlpart.append(" :type"+i);
|
sqlpart.append(",");
|
params.put("type"+i, types[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
String sl = params.get("sl");
|
if(StringUtil.notEmpty(sl)) {
|
String[] sls = sl.split(",");
|
if(sls.length==1) {
|
sqlpart.append(" AND B.THIRD_CATEGORY_ID = :third_category_id");
|
params.put("third_category_id", sls[0]);
|
} else {
|
sqlpart.append(" AND B.THIRD_CATEGORY_ID IN (");
|
for(int i=0; i<sls.length; i++) {
|
sqlpart.append(" :third_category_id"+i);
|
sqlpart.append(",");
|
params.put("third_category_id"+i, sls[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
String status = params.get("status");
|
if(StringUtil.notEmpty(status)) {
|
sqlpart.append( " AND B.STATE = :state ");
|
params.put("state", status);
|
|
}
|
return sqlpart;
|
}
|
|
@Override
|
public int queryincidentJxzCount(Map<String,String> params) {
|
StringBuilder sql = new StringBuilder();
|
StringBuilder sqlpart = new StringBuilder();
|
sql.append("SELECT COUNT(D.ID) FROM (SELECT B.* FROM SC_WORKFLOW_INCIDENT B,WORKFLOW_BASE WB ");
|
sqlpart.append(" WHERE WB.BUSINESS_ID = B.ID AND WB.BUSINESSTYPE = :businessType AND WB.WFSTATE = 1 ");
|
|
sqlpart = getIncidentJxzSql(sqlpart,params);
|
|
sql.append(sqlpart);
|
sql.append( " GROUP BY B.ID ) D");
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
return baseDao.queryForInteger(sql.toString(),params);
|
}
|
|
@Override
|
public PageInfo queryincidentJxzList(PageInfo pageInfo,Map<String,String> params) {
|
StringBuilder sql = new StringBuilder();
|
StringBuilder sqlpart = new StringBuilder();
|
sql.append("SELECT WB.ID,WB.ORDER_CODE,WB.WFNAME,WB.BUSINESSTYPE,WB.CREATERNAME,WB.CREATETIME,WB.WFNOTE , ");
|
sql.append("WB.CURRENT_NODE_ID,WB.CURRENT_NODE_NAME,WB.CUSTOMER_NAME,WB.SUB_CUSTOMER_NAME,WB.PROJECT_NAME,WB.CURRENT_DEALER_NAME,WB.BUSINESS_ID,WB.WFSTATE,B.STATE ,B.NAME ");
|
sql.append("FROM SC_WORKFLOW_INCIDENT B,WORKFLOW_BASE WB , WORKFLOW_NODE C ");
|
sqlpart.append(" WHERE WB.BUSINESS_ID = B.ID AND C.FLOWID = WB.ID AND WB.BUSINESSTYPE = :businessType AND WB.WFSTATE = 1 ");
|
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
sqlpart = getIncidentJxzSql(sqlpart,params);
|
|
sql.append(sqlpart);
|
sql.append( " GROUP BY WB.ID ORDER BY WB.CREATETIME DESC ");
|
|
return baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
}
|
|
public StringBuilder getIncidentJxzSql(StringBuilder sqlpart,Map<String,String> params){
|
|
String cusId = params.get("cusId");
|
if(StringUtil.notEmpty(cusId)) {
|
sqlpart.append(" AND B.CUSTOMER_ID = :cusId ");
|
}
|
String subCustomerId = params.get("subCustomerId");
|
if(StringUtil.notEmpty(subCustomerId)) {
|
sqlpart.append(" AND B.SUB_CUSTOMER_ID = :subCustomerId ");
|
}
|
|
String orderName = params.get("orderName");
|
if(StringUtil.notEmpty(orderName)) {
|
sqlpart.append(" AND B.NAME LIKE :orderName ");
|
params.put("orderName", "%"+orderName+"%");
|
}
|
|
String orderCode = params.get("orderCode");
|
if(StringUtil.notEmpty(orderCode)) {
|
sqlpart.append(" AND B.ORDER_CODE LIKE :orderCode ");
|
params.put("orderCode", "%"+orderCode+"%");
|
}
|
|
|
String contract = params.get("contract");
|
if(StringUtil.notEmpty(contract)) {
|
sqlpart.append(" AND B.CONTACT_NAME LIKE :contract ");
|
params.put("contract", "%"+contract+"%");
|
}
|
|
|
String pri = params.get("pri");
|
if(StringUtil.notEmpty(pri)) {
|
String[] pris = pri.split(",");
|
if(pris.length==1) {
|
sqlpart.append(" AND B.PRIORITY_ID = :priority_id");
|
params.put("priority_id", pris[0]);
|
} else {
|
sqlpart.append(" AND B.PRIORITY_ID IN (");
|
for(int i=0; i<pris.length; i++) {
|
sqlpart.append(" :pri"+i);
|
sqlpart.append(",");
|
params.put("pri"+i, pris[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
|
|
String dg = params.get("dg");
|
if(StringUtil.notEmpty(dg)) {
|
String[] dgs = dg.split(",");
|
if(dgs.length==1) {
|
sqlpart.append(" AND B.INFLUENCE_ID = :influence_id");
|
params.put("influence_id", dgs[0]);
|
} else {
|
sqlpart.append(" AND B.INFLUENCE_ID IN (");
|
for(int i=0; i<dgs.length; i++) {
|
sqlpart.append(" :dg"+i);
|
sqlpart.append(",");
|
params.put("dg"+i, dgs[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
|
String type = params.get("source");
|
if(StringUtil.notEmpty(type)) {
|
String[] types = type.split(",");
|
if(types.length==1) {
|
sqlpart.append(" AND B.TYPE_ID = :type_id");
|
params.put("type_id", types[0]);
|
} else {
|
sqlpart.append(" AND B.TYPE_ID IN (");
|
for(int i=0; i<types.length; i++) {
|
sqlpart.append(" :type"+i);
|
sqlpart.append(",");
|
params.put("type"+i, types[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
|
String sl = params.get("sl");
|
if(StringUtil.notEmpty(sl)) {
|
String[] sls = sl.split(",");
|
if(sls.length==1) {
|
sqlpart.append(" AND B.THIRD_CATEGORY_ID = :third_category_id");
|
params.put("third_category_id", sls[0]);
|
} else {
|
sqlpart.append(" AND B.THIRD_CATEGORY_ID IN (");
|
for(int i=0; i<sls.length; i++) {
|
sqlpart.append(" :third_category_id"+i);
|
sqlpart.append(",");
|
params.put("third_category_id"+i, sls[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
String status = params.get("status");
|
if(StringUtil.notEmpty(status)) {
|
sqlpart.append( " AND (B.STATE = :state OR B.STATE = :state1) ");
|
params.put("state", status);
|
params.put("state1", ConvertUtil.obj2StrBlank(ConvertUtil.obj2Integer(status)+1));
|
|
}
|
return sqlpart;
|
}
|
|
@Override
|
public Map queryincidentJxzNodeCount(String cusId) {
|
//初始化变量
|
int ywc = 0;
|
//服务台
|
int fwt = 0;
|
|
//一线工程师
|
int yxgcs = 0;
|
|
//二线工程师
|
int exgcs = 0;
|
|
//三线工程师
|
int sxgcs = 0;
|
|
|
//只有服务台和管理人员才可以看到所有的工单，（所以查询当前的用户属于那种服务台）
|
StringBuffer selectSql = new StringBuffer();
|
StringBuffer sql = new StringBuffer();
|
|
Map paramMap = new HashMap();
|
paramMap.put("cusId", cusId);
|
selectSql.append( "SELECT COUNT(*) AS NUM,A.STATE FROM SC_WORKFLOW_INCIDENT A,WORKFLOW_BASE B WHERE A.ID = B.BUSINESS_ID AND B.WFSTATE = 1 ");
|
sql.append( "SELECT COUNT(A.ID) FROM SC_WORKFLOW_INCIDENT A,WORKFLOW_BASE B WHERE A.ID = B.BUSINESS_ID AND B.WFSTATE = 1 ");
|
selectSql.append(" AND A.CUSTOMER_ID = :cusId ");
|
sql.append(" AND A.CUSTOMER_ID = :cusId ");
|
selectSql.append(" GROUP BY A.STATE ");
|
|
List<Map> list = baseDao.queryForList(selectSql.toString(),paramMap);
|
if(null!=list && list.size()>0) {
|
for(Map map : list) {
|
String state = ConvertUtil.obj2StrBlank(map.get("STATE"));
|
int num = ConvertUtil.obj2Int(map.get("NUM"));
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDFWT)||state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FWTCLZ)) {
|
fwt += num;
|
continue;
|
}
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYX)||state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_YXCLZ)) {
|
yxgcs += num;
|
continue;
|
}
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDEX)||state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_EXCLZ)) {
|
exgcs += num;
|
continue;
|
}
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDSX)||state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_SXCLZ)) {
|
sxgcs += num;
|
continue;
|
}
|
|
}
|
}
|
int all = baseDao.queryForInteger(sql.toString(), paramMap);
|
Map map = new HashMap();
|
map.put("fwt", fwt);
|
|
map.put("yxgcs", yxgcs);
|
|
map.put("exgcs", exgcs);
|
|
map.put("sxgcs", sxgcs);
|
|
map.put("all", all);
|
|
return map;
|
}
|
|
@Override
|
public int queryincidentEndCount(Map<String,String> params) {
|
StringBuilder sql = new StringBuilder();
|
StringBuilder sqlpart = new StringBuilder();
|
sql.append("SELECT COUNT(D.ID) FROM (SELECT B.* FROM SC_WORKFLOW_INCIDENT B,WORKFLOW_BASE WB ");
|
sqlpart.append(" WHERE WB.BUSINESS_ID = B.ID AND WB.BUSINESSTYPE = :businessType AND WB.WFSTATE = :type ");
|
sqlpart = getEndSql(sqlpart,params);
|
sql.append(sqlpart);
|
sql.append( " GROUP BY B.ID ) D");
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
return baseDao.queryForInteger(sql.toString(),params);
|
}
|
|
@Override
|
public PageInfo queryincidentEndList(PageInfo pageInfo,Map<String,String> params) {
|
StringBuilder sql = new StringBuilder();
|
StringBuilder sqlpart = new StringBuilder();
|
sql.append("SELECT B.RESOLVE_TYPE_NAME,B.CREATE_TIME,B.CREATE_USER_NAME,WB.ID,WB.ORDER_CODE,WB.WFNAME,WB.BUSINESSTYPE,WB.CREATERNAME,WB.CREATETIME,WB.WFNOTE ,WB.ENDTIME , ");
|
sql.append("WB.CURRENT_NODE_ID,WB.CURRENT_NODE_NAME,WB.CUSTOMER_NAME,WB.SUB_CUSTOMER_NAME,WB.PROJECT_NAME,WB.CURRENT_DEALER_NAME,WB.BUSINESS_ID,WB.WFSTATE,B.STATE ,B.NAME ,");
|
sql.append(" D.HANG_UP_USERNAME,D.HANG_UP_TIME,D.HANG_UP_REASON ,WB.SCORE ");
|
sql.append("FROM (SELECT F.*,E.SCORE FROM WORKFLOW_BASE F LEFT JOIN ORDER_SATIS_INFO E ON F.ID = E.BUSINESS_ID WHERE F.BUSINESSTYPE = :businessType ) WB, WORKFLOW_NODE C ,SC_WORKFLOW_INCIDENT B LEFT JOIN HANG_UP_INFO D ON B.ID = D.BUS_ID ");
|
sqlpart.append(" WHERE WB.BUSINESS_ID = B.ID AND C.FLOWID = WB.ID AND WB.WFSTATE = :type ");
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
sqlpart = getEndSql(sqlpart,params);
|
|
sql.append(sqlpart);
|
sql.append( " GROUP BY WB.ID ORDER BY WB.CREATETIME DESC ");
|
|
return baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
}
|
|
public StringBuilder getEndSql(StringBuilder sqlpart,Map<String,String> params){
|
|
String cusId = params.get("cusId");
|
if(StringUtil.notEmpty(cusId)) {
|
sqlpart.append(" AND B.CUSTOMER_ID = :cusId ");
|
}
|
String subCustomerId = params.get("subCustomerId");
|
if(StringUtil.notEmpty(subCustomerId)) {
|
sqlpart.append(" AND B.SUB_CUSTOMER_ID = :subCustomerId ");
|
}
|
|
String orderName = params.get("orderName");
|
if(StringUtil.notEmpty(orderName)) {
|
sqlpart.append(" AND B.NAME LIKE :orderName ");
|
params.put("orderName", "%"+orderName+"%");
|
}
|
|
String orderCode = params.get("orderCode");
|
if(StringUtil.notEmpty(orderCode)) {
|
sqlpart.append(" AND B.ORDER_CODE LIKE :orderCode ");
|
params.put("orderCode", "%"+orderCode+"%");
|
}
|
|
|
String contract = params.get("contract");
|
if(StringUtil.notEmpty(contract)) {
|
sqlpart.append(" AND B.CONTACT_NAME LIKE :contract ");
|
params.put("contract", "%"+contract+"%");
|
}
|
|
|
String pri = params.get("pri");
|
if(StringUtil.notEmpty(pri)) {
|
String[] pris = pri.split(",");
|
if(pris.length==1) {
|
sqlpart.append(" AND B.PRIORITY_ID = :priority_id");
|
params.put("priority_id", pris[0]);
|
} else {
|
sqlpart.append(" AND B.PRIORITY_ID IN (");
|
for(int i=0; i<pris.length; i++) {
|
sqlpart.append(" :pri"+i);
|
sqlpart.append(",");
|
params.put("pri"+i, pris[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
|
|
String dg = params.get("dg");
|
if(StringUtil.notEmpty(dg)) {
|
String[] dgs = dg.split(",");
|
if(dgs.length==1) {
|
sqlpart.append(" AND B.INFLUENCE_ID = :influence_id");
|
params.put("influence_id", dgs[0]);
|
} else {
|
sqlpart.append(" AND B.INFLUENCE_ID IN (");
|
for(int i=0; i<dgs.length; i++) {
|
sqlpart.append(" :dg"+i);
|
sqlpart.append(",");
|
params.put("dg"+i, dgs[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
|
String type = params.get("source");
|
if(StringUtil.notEmpty(type)) {
|
String[] types = type.split(",");
|
if(types.length==1) {
|
sqlpart.append(" AND B.TYPE_ID = :type_id");
|
params.put("type_id", types[0]);
|
} else {
|
sqlpart.append(" AND B.TYPE_ID IN (");
|
for(int i=0; i<types.length; i++) {
|
sqlpart.append(" :type"+i);
|
sqlpart.append(",");
|
params.put("type"+i, types[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
|
String sl = params.get("sl");
|
if(StringUtil.notEmpty(sl)) {
|
String[] sls = sl.split(",");
|
if(sls.length==1) {
|
sqlpart.append(" AND B.THIRD_CATEGORY_ID = :third_category_id");
|
params.put("third_category_id", sls[0]);
|
} else {
|
sqlpart.append(" AND B.THIRD_CATEGORY_ID IN (");
|
for(int i=0; i<sls.length; i++) {
|
sqlpart.append(" :third_category_id"+i);
|
sqlpart.append(",");
|
params.put("third_category_id"+i, sls[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
return sqlpart;
|
}
|
|
@Override
|
public Map queryincidentTimeoutCount(String cusId) {
|
//初始化变量
|
int ywc = 0;
|
//服务台
|
int fwt = 0;
|
|
//一线工程师
|
int yxgcs = 0;
|
|
//二线工程师
|
int exgcs = 0;
|
|
//三线工程师
|
int sxgcs = 0;
|
|
|
//只有服务台和管理人员才可以看到所有的工单，（所以查询当前的用户属于那种服务台）
|
StringBuffer selectSql = new StringBuffer();
|
StringBuffer sql = new StringBuffer();
|
|
Map paramMap = new HashMap();
|
paramMap.put("cusId", cusId);
|
selectSql.append( "SELECT COUNT(*) AS NUM,A.STATE FROM SC_WORKFLOW_INCIDENT A,WORKFLOW_BASE B WHERE A.ID = B.BUSINESS_ID AND B.WFSTATE = 1 AND (A.ANSWER_TIME = 1 OR A.DEAL_TIMEOUT = 1 ) ");
|
sql.append( "SELECT COUNT(A.ID) FROM SC_WORKFLOW_INCIDENT A,WORKFLOW_BASE B WHERE A.ID = B.BUSINESS_ID AND B.WFSTATE = 1 AND (A.ANSWER_TIME = 1 OR A.DEAL_TIMEOUT = 1 ) ");
|
selectSql.append(" AND A.CUSTOMER_ID = :cusId ");
|
sql.append(" AND A.CUSTOMER_ID = :cusId ");
|
|
selectSql.append(" GROUP BY A.STATE ");
|
|
List<Map> list = baseDao.queryForList(selectSql.toString(),paramMap);
|
if(null!=list && list.size()>0) {
|
for(Map map : list) {
|
String state = ConvertUtil.obj2StrBlank(map.get("STATE"));
|
int num = ConvertUtil.obj2Int(map.get("NUM"));
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDFWT)||state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FWTCLZ)) {
|
fwt += num;
|
continue;
|
}
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYX)||state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_YXCLZ)) {
|
yxgcs += num;
|
continue;
|
}
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDEX)||state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_EXCLZ)) {
|
exgcs += num;
|
continue;
|
}
|
|
if(state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_FPDSX)||state.equals(Constants.SC_WORKFLOW_INCIDENT_STATE_SXCLZ)) {
|
sxgcs += num;
|
continue;
|
}
|
|
}
|
}
|
int all = baseDao.queryForInteger(sql.toString(), paramMap);
|
Map map = new HashMap();
|
map.put("fwt", fwt);
|
|
map.put("yxgcs", yxgcs);
|
|
map.put("exgcs", exgcs);
|
|
map.put("sxgcs", sxgcs);
|
|
map.put("all", all);
|
|
return map;
|
}
|
|
@Override
|
public int queryincidentTimeoutCount(Map<String,String> params) {
|
StringBuilder sql = new StringBuilder();
|
StringBuilder sqlpart = new StringBuilder();
|
sql.append("SELECT COUNT(D.ID) FROM (SELECT B.* FROM SC_WORKFLOW_INCIDENT B,WORKFLOW_BASE WB ");
|
sqlpart.append(" WHERE WB.BUSINESS_ID = B.ID AND WB.BUSINESSTYPE = :businessType AND WB.WFSTATE = 1 AND (B.ANSWER_TIME = 1 OR B.DEAL_TIMEOUT = 1 ) ");
|
sqlpart = getIncidentTimeoutSql(sqlpart,params);
|
sql.append(sqlpart);
|
sql.append( " GROUP BY B.ID ) D");
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
return baseDao.queryForInteger(sql.toString(),params);
|
}
|
|
@Override
|
public PageInfo queryincidentTimeoutList(PageInfo pageInfo,Map<String,String> params) {
|
StringBuilder sql = new StringBuilder();
|
StringBuilder sqlpart = new StringBuilder();
|
sql.append("SELECT WB.ID,WB.ORDER_CODE,WB.WFNAME,WB.BUSINESSTYPE,WB.CREATERNAME,WB.CREATETIME,WB.WFNOTE , ");
|
sql.append("WB.CURRENT_NODE_ID,WB.CURRENT_NODE_NAME,WB.CUSTOMER_NAME,WB.SUB_CUSTOMER_NAME,WB.PROJECT_NAME,WB.CURRENT_DEALER_NAME,WB.BUSINESS_ID,WB.WFSTATE,B.STATE ,B.NAME ");
|
sql.append("FROM SC_WORKFLOW_INCIDENT B,WORKFLOW_BASE WB ");
|
sqlpart.append(" WHERE WB.BUSINESS_ID = B.ID AND WB.BUSINESSTYPE = :businessType AND WB.WFSTATE = 1 AND (B.ANSWER_TIME = 1 OR B.DEAL_TIMEOUT = 1 ) ");
|
params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT));
|
|
sqlpart = getIncidentTimeoutSql(sqlpart,params);
|
sql.append(sqlpart);
|
sql.append( " GROUP BY WB.ID ORDER BY WB.CREATETIME DESC ");
|
|
return baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
}
|
|
public StringBuilder getIncidentTimeoutSql(StringBuilder sqlpart,Map<String,String> params){
|
|
String cusId = params.get("cusId");
|
if(StringUtil.notEmpty(cusId)) {
|
sqlpart.append(" AND B.CUSTOMER_ID = :cusId ");
|
}
|
String subCustomerId = params.get("subCustomerId");
|
if(StringUtil.notEmpty(subCustomerId)) {
|
sqlpart.append(" AND B.SUB_CUSTOMER_ID = :subCustomerId ");
|
}
|
|
String orderName = params.get("orderName");
|
if(StringUtil.notEmpty(orderName)) {
|
sqlpart.append(" AND B.NAME LIKE :orderName ");
|
params.put("orderName", "%"+orderName+"%");
|
}
|
|
String orderCode = params.get("orderCode");
|
if(StringUtil.notEmpty(orderCode)) {
|
sqlpart.append(" AND B.ORDER_CODE LIKE :orderCode ");
|
params.put("orderCode", "%"+orderCode+"%");
|
}
|
|
|
String contract = params.get("contract");
|
if(StringUtil.notEmpty(contract)) {
|
sqlpart.append(" AND B.CONTACT_NAME LIKE :contract ");
|
params.put("contract", "%"+contract+"%");
|
}
|
|
|
String pri = params.get("pri");
|
if(StringUtil.notEmpty(pri)) {
|
String[] pris = pri.split(",");
|
if(pris.length==1) {
|
sqlpart.append(" AND B.PRIORITY_ID = :priority_id");
|
params.put("priority_id", pris[0]);
|
} else {
|
sqlpart.append(" AND B.PRIORITY_ID IN (");
|
for(int i=0; i<pris.length; i++) {
|
sqlpart.append(" :pri"+i);
|
sqlpart.append(",");
|
params.put("pri"+i, pris[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
|
|
String dg = params.get("dg");
|
if(StringUtil.notEmpty(dg)) {
|
String[] dgs = dg.split(",");
|
if(dgs.length==1) {
|
sqlpart.append(" AND B.INFLUENCE_ID = :influence_id");
|
params.put("influence_id", dgs[0]);
|
} else {
|
sqlpart.append(" AND B.INFLUENCE_ID IN (");
|
for(int i=0; i<dgs.length; i++) {
|
sqlpart.append(" :dg"+i);
|
sqlpart.append(",");
|
params.put("dg"+i, dgs[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
|
String type = params.get("source");
|
if(StringUtil.notEmpty(type)) {
|
String[] types = type.split(",");
|
if(types.length==1) {
|
sqlpart.append(" AND B.TYPE_ID = :type_id");
|
params.put("type_id", types[0]);
|
} else {
|
sqlpart.append(" AND B.TYPE_ID IN (");
|
for(int i=0; i<types.length; i++) {
|
sqlpart.append(" :type"+i);
|
sqlpart.append(",");
|
params.put("type"+i, types[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
|
|
String sl = params.get("sl");
|
if(StringUtil.notEmpty(sl)) {
|
String[] sls = sl.split(",");
|
if(sls.length==1) {
|
sqlpart.append(" AND B.THIRD_CATEGORY_ID = :third_category_id");
|
params.put("third_category_id", sls[0]);
|
} else {
|
sqlpart.append(" AND B.THIRD_CATEGORY_ID IN (");
|
for(int i=0; i<sls.length; i++) {
|
sqlpart.append(" :third_category_id"+i);
|
sqlpart.append(",");
|
params.put("third_category_id"+i, sls[i]);
|
}
|
sqlpart.deleteCharAt(sqlpart.lastIndexOf(","));
|
sqlpart.append(")");
|
}
|
}
|
String status = params.get("status");
|
if(StringUtil.notEmpty(status)) {
|
sqlpart.append( " AND (B.STATE = :state OR B.STATE = :state1) ");
|
params.put("state", status);
|
params.put("state1", ConvertUtil.obj2StrBlank(ConvertUtil.obj2Integer(status)+1));
|
|
}
|
return sqlpart;
|
}
|
|
@Override
|
public Map querySubCus(String customerId,String subCustomerId) {
|
Map resultMap = new HashMap();
|
Map paramMap = new HashMap();
|
paramMap.put("customerId", customerId);
|
String selectSubSql = "SELECT * FROM SC_PARTNER_CUSTOMER_SUB WHERE CUSTOMER_ID = :customerId AND DEL_FLAG = 1 ORDER BY MY_LEVEL ";
|
List<Map> subCus = baseDao.queryForList(selectSubSql,paramMap);
|
|
List subs = new ArrayList();
|
|
List checkSl = new ArrayList();
|
|
|
if(null!=subCus && subCus.size()>0){
|
Map cacheMap = new HashMap();
|
for(Map cus : subCus) {
|
String level = ConvertUtil.obj2StrBlank(cus.get("MY_LEVEL"));
|
String id = ConvertUtil.obj2Str(cus.get("ID"));
|
String name = ConvertUtil.obj2StrBlank(cus.get("CUSTOMER_NAME"));
|
|
if(subCustomerId.equals(id)) {
|
cus.put("checked", 1);
|
Map map = new HashMap();
|
map.put("checkId", id);
|
map.put("checkName", name);
|
checkSl.add(map);
|
} else {
|
cus.put("checked", 2);
|
}
|
|
|
if(level.equals("1")) {
|
List ejList = new ArrayList();
|
cacheMap.put(id, ejList);
|
cus.put("subs", ejList);
|
subs.add(cus);
|
continue;
|
}
|
|
if(level.equals("2")) {
|
String pid = ConvertUtil.obj2StrBlank(cus.get("P_ID"));
|
List ejList = (List)cacheMap.get(pid);
|
ejList.add(cus);
|
}
|
}
|
}
|
resultMap.put("subs", subs);
|
resultMap.put("checks", checkSl);
|
return resultMap;
|
}
|
|
|
}
|
