#基本信息接口 群聊数量，平均每天沟通次数调整从建模表取数

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<String> strlist = new ArrayList<>(100);
+        strlist.add(employeeId);
+        strlist.add(tenant_key);
+        String groupId = "weaver-ebuilder-form-service";
+        String sourceType = "LOGIC";
+        List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(strlist);
+        Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
+
+        List<Map<String,Object>> 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<String> strlist = new ArrayList<>(100);
+        strlist.add(employeeId);
+        strlist.add(tenant_key);
+        String groupId = "weaver-ebuilder-form-service";
+        String sourceType = "LOGIC";
+        List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(strlist);
+        Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
+
+        List<Map<String,Object>> 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 {