diff --git a/src/main/java/com/weaver/seconddev/jcldoor/cmd/UserInfoCmd.java b/src/main/java/com/weaver/seconddev/jcldoor/cmd/UserInfoCmd.java index a8c01ed..b13f095 100644 --- a/src/main/java/com/weaver/seconddev/jcldoor/cmd/UserInfoCmd.java +++ b/src/main/java/com/weaver/seconddev/jcldoor/cmd/UserInfoCmd.java @@ -3,6 +3,7 @@ package com.weaver.seconddev.jcldoor.cmd; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.weaver.common.base.entity.result.WeaResult; +import com.weaver.common.hrm.util.Util; import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity; import com.weaver.framework.rpc.annotation.RpcReference; import com.weaver.seconddev.jcldoor.util.CommonUtils; @@ -138,9 +139,9 @@ public class UserInfoCmd { wfdeal = getWfDealNum(); //参与群聊数量 - cyqlsl = getCyqlNum(hiredate); + cyqlsl = getCyqlNumNew(userid); - mtgtrs = getPjMtgtcs(hiredate); + mtgtrs = getPjMtgtcsNew(userid); } } catch (Exception e) { log.error("getUserInfo--Exception:" + e.getMessage()); @@ -349,6 +350,34 @@ public class UserInfoCmd { return type; } + /** + * 参与群聊数 + * @param employeeId + * @return + */ + private String getCyqlNumNew(String employeeId) { + int count = 0; + + String sql = "select amount from uf_nj_cyqltjb where ry = ? and delete_type=0 and tenant_key = ?"; + + List strlist = new ArrayList<>(100); + strlist.add(employeeId); + strlist.add(tenant_key); + String groupId = "weaver-ebuilder-form-service"; + String sourceType = "LOGIC"; + List sqlparam = databaseUtils.getSqlParamEntity(strlist); + Map result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); + + List> recordList = databaseUtils.getDataSourceList(result); + if(recordList.size()>0){ + String amount = String.valueOf(recordList.get(0).get("amount")); + if(StringUtils.isNotBlank(amount)){ + count = Util.getIntValue(amount); + } + } + return count+""; + } + private String getCyqlNum(String hiredate) { int count = 0; try { @@ -411,6 +440,34 @@ public class UserInfoCmd { } + /** + * 平均每天沟通人数 + * @param employeeId + * @return + */ + private String getPjMtgtcsNew(String employeeId) { + int count = 0; + + String sql = "select amount from uf_nj_pjmrdlhhsl where ry = ? and delete_type=0 and tenant_key = ?"; + + List strlist = new ArrayList<>(100); + strlist.add(employeeId); + strlist.add(tenant_key); + String groupId = "weaver-ebuilder-form-service"; + String sourceType = "LOGIC"; + List sqlparam = databaseUtils.getSqlParamEntity(strlist); + Map result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); + + List> recordList = databaseUtils.getDataSourceList(result); + if(recordList.size()>0){ + String amount = String.valueOf(recordList.get(0).get("amount")); + if(StringUtils.isNotBlank(amount)){ + count = Util.getIntValue(amount); + } + } + return count+""; + } + private String getPjMtgtcs(String hiredate){ int count = 0; try {