You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
288 lines
11 KiB
Plaintext
288 lines
11 KiB
Plaintext
<%@ page import="weaver.general.*" %>
|
|
<%@page import="weaver.conn.RecordSet"%>
|
|
<%@ page import="weaver.hrm.User" %>
|
|
<%@ page import="weaver.hrm.HrmUserVarify" %>
|
|
<%@ page import="org.apache.commons.lang.StringUtils" %>
|
|
<%@ page import="com.alibaba.fastjson.JSONObject" %>
|
|
<%@ page import="weaver.mobile.webservices.workflow.WorkflowServiceImpl" %>
|
|
<%@ page import="java.util.Map" %>
|
|
<%@ page import="com.engine.common.util.ParamUtil" %>
|
|
<%@ page import="com.api.doc.center.service.DocCountService" %>
|
|
<%@ page import="com.engine.common.util.ServiceUtil" %>
|
|
<%@ page import="com.api.doc.center.service.impl.DocCountServiceImpl" %>
|
|
<%@ page import="com.api.doc.center.service.ReplyAndPraiseService" %>
|
|
<%@ page import="com.engine.workflow.util.CommonUtil" %>
|
|
<%@ page import="com.api.doc.center.service.impl.ReplyAndPraiseServiceImpl" %>
|
|
<%@ page import="com.engine.kq.service.KQReportService" %>
|
|
<%@ page import="com.engine.kq.service.impl.KQReportServiceImpl" %>
|
|
<%@ page import="com.alibaba.fastjson.JSONArray" %>
|
|
<%@ page import="java.util.HashMap" %>
|
|
<%@ page import="com.engine.portrait.util.PortraitUtil" %>
|
|
<jsp:useBean id="bb" class="weaver.general.BaseBean" scope="page" />
|
|
<%@ page language="java" contentType="text/html; charset=UTF-8" %>
|
|
|
|
<%
|
|
RecordSet rs = new RecordSet();
|
|
User user = HrmUserVarify.getUser(request , response) ;
|
|
int userid = user.getUID();
|
|
String lastname = user.getLastname();
|
|
|
|
|
|
|
|
int doc_create = 0;
|
|
//封装request传递参数到map
|
|
try{
|
|
Map<String, Object> map = ParamUtil.request2Map(request);
|
|
map.put("docCountType", "1");
|
|
Map<String,Object> apidatas = getCountService(request, response).getNumOfMy(map, user,request,response);
|
|
if(apidatas.containsKey("number")){
|
|
String number = Util.null2String(apidatas.get("number"));
|
|
if(StringUtils.isNotEmpty(number)){
|
|
doc_create = Util.getIntValue(number);
|
|
}
|
|
}
|
|
}catch (Exception e){
|
|
|
|
}
|
|
|
|
boolean isshowprocessed = true;
|
|
boolean belongtoshowFlag = true;
|
|
WorkflowServiceImpl ws = new WorkflowServiceImpl();
|
|
|
|
int wf_create = 0;
|
|
try{
|
|
wf_create = ws.getMyWorkflowRequestCount(user.getUID(), null,belongtoshowFlag);
|
|
}catch (Exception e){
|
|
|
|
}
|
|
|
|
int wf_deal = 0;
|
|
try{
|
|
wf_deal = ws.getHendledWorkflowRequestCount(user.getUID(), isshowprocessed, null,belongtoshowFlag);
|
|
}catch (Exception e){
|
|
}
|
|
|
|
|
|
int knowledge_interact = 0;
|
|
try{
|
|
Map<String, Object> map = ParamUtil.request2Map(request);
|
|
Map<String,Object> apidatas = getReplyAndPraiseService(request, response).getNumOfReplyAndPraise(map, user);
|
|
knowledge_interact = Util.getIntValue(Util.null2String(apidatas.get("number")));
|
|
}catch (Exception e){
|
|
|
|
}
|
|
|
|
String message_count = "0";
|
|
String dateType = "3";
|
|
try{
|
|
String sql = getQuerySql(userid+"","17");
|
|
if(StringUtils.isNotEmpty(sql))
|
|
{
|
|
rs.executeQuery(sql,userid,dateType);
|
|
if (rs.next())
|
|
{
|
|
String itemData = Util.null2String(rs.getString("itemData"));
|
|
String itemname = Util.null2String(rs.getString("itemname"));
|
|
String name = Util.null2String(rs.getString("name"));
|
|
bb.writeLog("itemname:"+itemname+" itemname:"+itemname+" name:"+name);
|
|
if(StringUtils.isNotEmpty(itemData) && itemData.contains("amount")){
|
|
message_count = itemData.substring(itemData.indexOf("=")+1);
|
|
}
|
|
}
|
|
}
|
|
}catch (Exception e){
|
|
|
|
}
|
|
|
|
String fromDate = "";
|
|
String sql = " select createdate from hrmresource where id= "+userid ;
|
|
rs.executeQuery(sql);
|
|
if(rs.next()){
|
|
fromDate = Util.null2String(rs.getString("createdate")) ;
|
|
}
|
|
String toDate = TimeUtil.getCurrentDateString();
|
|
double attendance_count = 0.00;
|
|
try{
|
|
JSONObject jsonObject = new JSONObject();
|
|
jsonObject.put("pageIndex","1");
|
|
jsonObject.put("typeselect","6");
|
|
jsonObject.put("viewScope","3");
|
|
jsonObject.put("fromDate",fromDate);
|
|
jsonObject.put("toDate",toDate);
|
|
jsonObject.put("resourceId",userid);
|
|
jsonObject.put("resourceIdValue",lastname);
|
|
|
|
JSONArray resourceArray = new JSONArray();
|
|
JSONObject resourceObject = new JSONObject();
|
|
resourceObject.put("name",lastname);
|
|
resourceObject.put("id",userid);
|
|
resourceObject.put("type","resource");
|
|
resourceObject.put("lastname",lastname);
|
|
resourceObject.put("nodeid","resource_"+userid+"x");
|
|
resourceArray.add(resourceObject);
|
|
jsonObject.put("resourceIdObject",resourceArray);
|
|
jsonObject.put("status","8");
|
|
jsonObject.put("isNoAccount","0");
|
|
jsonObject.put("attendanceSerial","");
|
|
|
|
Map<String, Object> map = new HashMap<String, Object>();
|
|
map.put("data",jsonObject.toJSONString());
|
|
Map<String,Object> apidatas = getService(user).getKQReport(map, user);
|
|
JSONObject apiJson = JSONObject.parseObject(JSONObject.toJSONString(apidatas));
|
|
if(apiJson !=null){
|
|
if(apiJson.containsKey("datas")){
|
|
JSONArray datasArray = apiJson.getJSONArray("datas");
|
|
if(datasArray.size()>0){
|
|
JSONObject dataJson = datasArray.getJSONObject(0);
|
|
String attendancedays = dataJson.getString("attendancedays");
|
|
if(StringUtils.isNotEmpty(attendancedays)){
|
|
attendance_count = Util.getDoubleValue(attendancedays);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}catch (Exception e){
|
|
}
|
|
|
|
JSONObject jsonObject = new JSONObject();
|
|
jsonObject.put("lastname",lastname);
|
|
jsonObject.put("doc_create",doc_create);
|
|
jsonObject.put("wf_create",wf_create);
|
|
jsonObject.put("wf_deal",wf_deal);
|
|
jsonObject.put("knowledge_interact",knowledge_interact);
|
|
jsonObject.put("message_count",message_count);
|
|
jsonObject.put("attendance_count",attendance_count);
|
|
|
|
%>
|
|
<%=jsonObject.toString() %>
|
|
|
|
|
|
<%!
|
|
|
|
private DocCountService getCountService(HttpServletRequest request, HttpServletResponse response) {
|
|
User user = com.engine.workflow.util.CommonUtil.getUserByRequest(request, response);//根据请求获取用户，包含主次账号信息
|
|
return ServiceUtil.getService(DocCountServiceImpl.class, user);
|
|
}
|
|
|
|
/***
|
|
* 微博填写数
|
|
* @param userid
|
|
* @return
|
|
*/
|
|
public int getBlogWriteCount(int userid){
|
|
int blog_write = 0;
|
|
RecordSet rs = new RecordSet();
|
|
BaseBean bb = new BaseBean();
|
|
bb.writeLog("getBlogWriteCount");
|
|
try{
|
|
String sql = " select isnull(count(1),0) as count from blog_discuss where userid=? ";
|
|
bb.writeLog("sql:"+sql);
|
|
rs.executeQuery(sql,new Object[]{userid});
|
|
if(rs.next()){
|
|
blog_write = rs.getInt(1);
|
|
}
|
|
bb.writeLog("blog_write:"+blog_write);
|
|
}catch (Exception e){
|
|
bb.writeLog("getBlogWriteCount-e:"+e);
|
|
}
|
|
return blog_write;
|
|
}
|
|
|
|
|
|
|
|
/***
|
|
* 沟通协作数
|
|
* @param userid
|
|
* @return
|
|
*/
|
|
public int getCoworkReplayCount(int userid){
|
|
int cwork_replay = 0;
|
|
RecordSet rs = new RecordSet();
|
|
BaseBean bb = new BaseBean();
|
|
bb.writeLog("getCoworkReplayCount");
|
|
try {
|
|
String sql = " select isnull(count(coworkid),0) as amount from cowork_discuss where discussant=? ";
|
|
bb.writeLog("sql:"+sql);
|
|
rs.executeQuery(sql,new Object[]{userid});
|
|
if(rs.next()){
|
|
cwork_replay = rs.getInt(1);
|
|
}
|
|
bb.writeLog("cwork_replay:"+cwork_replay);
|
|
}catch (Exception e){
|
|
bb.writeLog("getCoworkReplayCount-e:"+e);
|
|
}
|
|
|
|
return cwork_replay;
|
|
}
|
|
|
|
|
|
private ReplyAndPraiseService getReplyAndPraiseService(HttpServletRequest request, HttpServletResponse response) {
|
|
User user = CommonUtil.getUserByRequest(request, response);//根据请求获取用户，包含主次账号信息
|
|
return ServiceUtil.getService(ReplyAndPraiseServiceImpl.class, user);
|
|
}
|
|
|
|
|
|
private KQReportService getService(User user) {
|
|
return (KQReportService) ServiceUtil.getService(KQReportServiceImpl.class, user);
|
|
}
|
|
|
|
|
|
/***
|
|
*
|
|
* @param userid
|
|
* @param itemid
|
|
* @return
|
|
*/
|
|
private String getQuerySql(String userid,String itemid) {
|
|
|
|
BaseBean bb = new BaseBean();
|
|
StringBuilder sqlSB = new StringBuilder();
|
|
|
|
if(StringUtils.isNotEmpty(itemid))
|
|
{
|
|
sqlSB.append(" select e.id as itemdataid,e.userid,e.itemvalue,e.otherinfo as itemdata,d.* from (SELECT a.moduleid,a.name ,b.subname,b.subid ,b.iconname,b.iconcolor,b.iconbgcolor,c.id as itemid,c.iszeroshow,c.name as itemname,c.tipsinfo,c.isability,c.isnegative,c.overcolor,c.showorder")
|
|
.append(" FROM wr_individualitem_module a join wr_individualitem_submodule b on a.moduleid = b.moduleid ")
|
|
.append(" join wr_individualitem_info c on b.subid = c.subid ")
|
|
.append(" where a.status = 1 and b.status = 1 and c.status = 1 ");
|
|
if (!hasSubordinate(userid)) {
|
|
sqlSB.append(" and a.moduleid != 3 ");
|
|
}
|
|
String shareSql = "";
|
|
try {
|
|
shareSql = PortraitUtil.getShareBizidSql("10",userid);
|
|
} catch (Exception e) {
|
|
bb.writeLog("获取shareSql失败,userid="+userid+",type=10,"+e);
|
|
}
|
|
if (StringUtils.isNotEmpty(shareSql)) {
|
|
sqlSB.append(" and b.subid in (").append(shareSql).append(")");
|
|
}
|
|
sqlSB.append(" ) d join wr_individualitem_detail e on e.itemid = d.itemid ").append(" WHERE e.userid = ? and e.type = ? ");
|
|
sqlSB.append(" and d.itemid = "+itemid);
|
|
sqlSB.append(" order by d.moduleid asc,d.showorder asc");
|
|
}
|
|
return sqlSB.toString();
|
|
}
|
|
|
|
/***
|
|
*
|
|
* @param userId
|
|
* @return
|
|
*/
|
|
public static boolean hasSubordinate(String userId){
|
|
RecordSet rs = new RecordSet();
|
|
String baseSql = " SELECT COUNT(ID) as num from hrmresource where managerid = ? ";
|
|
String sqlWhere = " and status in (0,1,2,3) and loginid is not null ";
|
|
if(!"oracle".equals(rs.getDBType())){
|
|
sqlWhere +=" and loginid<>'' ";
|
|
}
|
|
rs.executeQuery(baseSql+sqlWhere,userId);
|
|
boolean hasSubordinate = false;
|
|
if (rs.next()) {
|
|
hasSubordinate = rs.getInt(1) > 0 ;
|
|
}
|
|
return hasSubordinate;
|
|
}
|
|
|
|
%>
|
|
|