fix : MySQL=》DMSQL

cy

2022-06-27 161509b9f823511cf33041caaf25ce726999e39b

 src/cn/ksource/web/facade/desktop/DesktopFacadeImpl.java

@@ -1,33 +1,30 @@
package cn.ksource.web.facade.desktop;

import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.DateUtil;
import cn.ksource.core.util.NumberUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.web.Constants;
import cn.ksource.web.facade.customermanage.CustomerManageFacade;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import org.springframework.stereotype.Service;

import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.DateUtil;
import cn.ksource.core.util.JsonUtil;
import cn.ksource.core.util.NumberUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.web.Constants;
import cn.ksource.web.facade.customermanage.CustomerManageFacade;

@Service("desktopFacade")
public class DesktopFacadeImpl implements DesktopFacade {
	

   @Resource
   private BaseDao baseDao;
   @Resource
   private CustomerManageFacade customerFacade;
	

   @Override
   public Map getOperationDeskDetail(String cusId) {
      String incidentAddNum = getIncidentAddNum(cusId);
@@ -79,7 +76,7 @@
      info.put("fileDealNum", fileDealNum);
      return info;
   }
	

   /**
    * 事件新增数量
    * @param cusId
@@ -96,7 +93,7 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	

   /**
    * 事件处理数量
    * @param cusId
@@ -126,8 +123,8 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	
	


   /**
    * 问题新增数量
    * @param cusId
@@ -144,7 +141,7 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	

   /**
    * 问题处理数量
    * @param cusId
@@ -178,8 +175,8 @@
         .addValue("nodeTemplateId",Constants.WTHG);
      return baseDao.queryForString(builder.toString(),param);
   }
	
	


   /**
    * 驻场运维新增数量
    * @param cusId
@@ -196,8 +193,8 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	
	


   /**
    * 驻场运维新处理数量
    * @param cusId
@@ -227,8 +224,8 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	
	


   /**
    * 日常巡检新增数量
    * @param cusId
@@ -245,7 +242,7 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	

   /**
    * 日常巡检处理数量
    * @param cusId
@@ -265,8 +262,8 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	
	


   /**
    * 例行巡检新增数量
    * @param cusId
@@ -283,7 +280,7 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	

   /**
    * 例行巡检处理数量
    * @param cusId
@@ -314,7 +311,7 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	

   /**
    * 健康检查新增数量
    * @param cusId
@@ -329,10 +326,10 @@
      builder.append("    union all ");
      builder.append("    select count(id) num from SC_WORKFLOW_CI_HEALTH where DATE_FORMAT(CREATE_TIME,'%Y%m')= DATE_FORMAT(NOW(),'%Y%m') and CUSTOMER_ID=:cusId ");
      builder.append(" ) t ");
		

      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	

   /**
    * 健康检查处理数量
    * @param cusId
@@ -361,7 +358,7 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	

   /**
    * 知识库新增数量
    * @param cusId
@@ -378,7 +375,7 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	

   /**
    * 知识库处理数量
    * @param cusId
@@ -401,12 +398,12 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	
	
	
	
	
	






   /**
    * 配置库新增数量
    * @param cusId
@@ -423,7 +420,7 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	

   /**
    * 配置库处理数量
    * @param cusId
@@ -448,8 +445,8 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	
	


   /**
    * 满意度调查新增数量
    * @param cusId
@@ -466,7 +463,7 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("cusId",cusId));
   }
	

   /**
    * 满意度调查得分
    * @param cusId
@@ -486,8 +483,8 @@
      builder.append(" select i.customer_id id,i.all_score score  ");
      builder.append(" from totle_satis_info i ");
      builder.append(" where  i.month = date_format(now(),'%Y%m')  ");
      builder.append(" group by customer_id ");
		
      builder.append(" group by customer_id,i.all_score ");

      List<Map> dataList = baseDao.queryForList(builder.toString());
      Map dataListSet = new HashMap();
      if(dataList!=null&&dataList.size()>0){
@@ -495,13 +492,13 @@
            dataListSet.put(map.get("id").toString(), map.get("score"));
         }
      }
		

      List<String> categories = new ArrayList<String>();
      for(Map map:cusList){
         String cusName = ConvertUtil.obj2StrBlank(map.get("name"));
         categories.add(cusName);
      }
		

       List series = new ArrayList<Integer>();
      for(Map cus:cusList){
         String key =  ConvertUtil.obj2StrBlank(cus.get("id"));
@@ -522,14 +519,14 @@
      StringBuilder builder = new StringBuilder();
      customerFacade.getCusById(cusId);
      Map cusInfo = customerFacade.getCusById(cusId);
		

      builder.setLength(0);
      builder.append(" select CONCAT(d.SATIS_TYPE,'_',i.MONTH) ID,d.SATIS_SCORE SCORE   ");
      builder.append(" from TOTLE_SATIS_INFO i,TOTLE_SATIS_DETAIL d  ");
      builder.append(" where i.ID = d.BUS_ID  ");
      builder.append(" and left(i.MONTH,4) = DATE_FORMAT(now(),'%Y')  ");
      builder.append(" and i.CUSTOMER_ID = :cusId   ");
      builder.append(" group by i.MONTH,d.SATIS_TYPE  ");
      builder.append(" group by i.MONTH,d.SATIS_TYPE,d.SATIS_SCORE  ");
      List<Map> dataList = baseDao.queryForList(builder.toString(),new SqlParameter("cusId",cusId));
      Map dataListMap = new HashMap();
      if(dataList!=null&&dataList.size()>0){
@@ -555,7 +552,7 @@
      labelList.add("1");
      labelList.add("3");
      labelList.add("6");
		

      List<Map> series = new ArrayList<Map>();
      for(String label:labelList){
         Map tempMap = new HashMap();
@@ -584,7 +581,7 @@
      surveyMap.put("cusInfo",cusInfo);
      return surveyMap;
   }
	

   /**
    * 文档新增数量
    * @param cusId
@@ -601,7 +598,7 @@
      builder.append(" ) t ");
      return baseDao.queryForString(builder.toString(),new SqlParameter("shtg",Constants.FILE_STATE_SHTG));
   }
	

   /**
    * 文档处理数量
    * @param cusId
@@ -627,5 +624,5 @@
      param.put("shbtg", Constants.FILE_STATE_SHBTG);
      return baseDao.queryForString(builder.toString(),param);
   }
	

}