shilei
/
E10-secondev-new
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

#E10-36# 优化员工信息及平均每天沟通数量的值

Browse Source
main
shilei 1 year ago
parent af03302445
commit 1cf1fa8b3e
3 changed files with 412 additions and 416 deletions
Show Stats Download Patch File Download Diff File

381
src/main/java/com/weaver/seconddev/jcldoor/cmd/UserInfoCmd.java
Unescape Escape View File

@ -67,9 +67,11 @@ public class UserInfoCmd {
*/ */
public Map<String, Object> getUserInfo(SimpleEmployee simpleEmployee) { public Map<String, Object> getUserInfo(SimpleEmployee simpleEmployee) {
Map<String, Object> map = new HashMap<>(100); Map<String, Object> map = new HashMap<>(100);
String userid = String.valueOf(simpleEmployee.getEmployeeId()); // String userid = String.valueOf(simpleEmployee.getEmployeeId());
Long employeeId = simpleEmployee.getEmployeeId();
String username = String.valueOf(simpleEmployee.getName()); String username = String.valueOf(simpleEmployee.getName());
String userimageurl = "/profile/" + userid + "/personal"; String userimageurl = "/profile/" + employeeId + "/personal";
String department = ""; String department = "";
String position = ""; String position = "";
String days = ""; String days = "";
@ -79,74 +81,82 @@ public class UserInfoCmd {
String cyqlsl = "0"; String cyqlsl = "0";
String mtgtrs = "0"; String mtgtrs = "0";
// String groupId = "weaver-ebuilder-form-service";
// String sourceType = "LOGIC";
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
try { try {
Map<String, Object> recordMap = new HashMap<String, Object>(); username = simpleEmployee.getName();
String groupId = "weaver-ebuilder-form-service"; department = simpleEmployee.getDepartment().getName();
String sourceType = "LOGIC"; position = simpleEmployee.getPosition().getName();
String tenant_key = "t7akvdnf84"; String hiredate = sdf.format(simpleEmployee.getHiredate());
// Map<String, Object> recordMap = new HashMap<String, Object>();
if (StringUtils.isNotBlank(userid)) { if (StringUtils.isNotBlank(employeeId+"")) {
String dataSql = "select " + // String dataSql = "select " +
" a.id, " + // " a.id, " +
" a.username, " + // " a.username, " +
" a.hiredate, " + // " a.hiredate, " +
" b.name as department, " + // " b.name as department, " +
" c.name as position " + // " c.name as position " +
"from " + // "from " +
" eteams.employee a " + // " eteams.employee a " +
" left join eteams.department b on a.department = b.id " + // " left join eteams.department b on a.department = b.id " +
" left join eteams.position c on c.id = a.position " + // " left join eteams.position c on c.id = a.position " +
"where " + // "where " +
" a.id = ? " + // " a.id = ? " +
" and a.tenant_key = ? " + // " and a.tenant_key = ? " +
" and a.status = 'normal' " + // " and a.status = 'normal' " +
" and a.type = 'inside'"; // " and a.type = 'inside'";
// log.error("getuserIfo--dataSql:" + dataSql);
log.error("getuserIfo--dataSql:" + dataSql); // List<String> strlist = new ArrayList<>(100);
// strlist.add(userid);
List<String> strlist = new ArrayList<>(100); // strlist.add(tenant_key);
strlist.add(userid); // List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(strlist);
strlist.add(tenant_key); // Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, dataSql, sqlparam);
// List<Map<String, Object>> recordList = databaseUtils.getDataSourceList(result);
// if (CollectionUtils.isNotEmpty(recordList)) {
List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(strlist); // recordMap = recordList.get(0);
Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, dataSql, sqlparam); // }
// username = CommonUtils.null2String(recordMap.get("username"));
List<Map<String, Object>> recordList = databaseUtils.getDataSourceList(result); // department = CommonUtils.null2String(recordMap.get("department"));
if (CollectionUtils.isNotEmpty(recordList)) { // position = CommonUtils.null2String(recordMap.get("position"));
recordMap = recordList.get(0);
} // String hiredate = CommonUtils.null2String(recordMap.get("hiredate"));
username = CommonUtils.null2String(recordMap.get("username"));
department = CommonUtils.null2String(recordMap.get("department")); log.error("hiredate:"+hiredate);
position = CommonUtils.null2String(recordMap.get("position"));
String hiredate = CommonUtils.null2String(recordMap.get("hiredate"));
if (StringUtils.isNotBlank(hiredate)) { if (StringUtils.isNotBlank(hiredate)) {
try { try {
days = calculateMinute2(hiredate); days = calculateMinute2(hiredate);
} catch (Exception e) { } catch (Exception e) {
log.error("calculateMinute2-e:" + e); log.error("calculateMinute2-e:" + e);
} }
if (StringUtils.isBlank(days)) { if (StringUtils.isBlank(days)) {
days = String.valueOf(calculateMinute(hiredate)); days = String.valueOf(calculateMinute(hiredate));
} }
} }
log.error("days:"+days);
//文档创建 //文档创建
doccreate = getDocCreateNum(userid); doccreate = getDocCreateNum(employeeId);
log.error("doccreate:"+doccreate);
//流程创建 //流程创建
wfcreate = getWfCreateNum(); wfcreate = getWfCreateNum(simpleEmployee);
log.error("wfcreate:"+wfcreate);
//流程处理 //流程处理
wfdeal = getWfDealNum(); wfdeal = getWfDealNum(simpleEmployee);
log.error("wfdeal:"+wfdeal);
//参与群聊数量 //参与群聊数量
cyqlsl = getCyqlNumNew(userid); cyqlsl = getCyqlNumNew(employeeId+"");
log.error("cyqlsl:"+cyqlsl);
mtgtrs = getPjMtgtcsNew(userid); mtgtrs = getPjMtgtcsNew(employeeId+"");
log.error("mtgtrs:"+mtgtrs);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("getUserInfo--Exception:" + e.getMessage()); log.error("getUserInfo--Exception:" + e.getMessage());
} }
map.put("userid", userid);
map.put("userid", employeeId+"");
map.put("userimageurl", userimageurl); map.put("userimageurl", userimageurl);
map.put("username", username); map.put("username", username);
map.put("department", department); map.put("department", department);
@ -157,20 +167,18 @@ public class UserInfoCmd {
map.put("wfdeal", wfdeal); map.put("wfdeal", wfdeal);
map.put("cyqlsl", cyqlsl); map.put("cyqlsl", cyqlsl);
map.put("mtgtrs", mtgtrs); map.put("mtgtrs", mtgtrs);
return map; return map;
} }
/** /**
* 获取文档创建数量 * 获取文档创建数量
* *
* @param userid * @param employeeId
* @return * @return
*/ */
public String getDocCreateNum(String userid) { public String getDocCreateNum(long employeeId) {
String num = "0"; String num = "0";
try { try {
long employeeId = Long.parseLong(userid);
int doccreatecount = docClientService.countByCreator(employeeId); int doccreatecount = docClientService.countByCreator(employeeId);
num = doccreatecount + ""; num = doccreatecount + "";
} catch (Exception e) { } catch (Exception e) {
@ -185,12 +193,10 @@ public class UserInfoCmd {
* *
* @return * @return
*/ */
public String getWfCreateNum() { public String getWfCreateNum(SimpleEmployee employee) {
String num = "0"; String num = "0";
try { try {
SimpleEmployee employee = UserContext.getCurrentUser();
RequestListConditionApiEntity conditionEntity = new RequestListConditionApiEntity(); RequestListConditionApiEntity conditionEntity = new RequestListConditionApiEntity();
WeaResult<RequestCountInfoPAEntity> RequestCountInfoPAEntity = wflRequestListRest.getRequestCountByTabId(employee, RequestListInitDimensionTabEnum.MINE_FLOWALL.getTabid(), conditionEntity); WeaResult<RequestCountInfoPAEntity> RequestCountInfoPAEntity = wflRequestListRest.getRequestCountByTabId(employee, RequestListInitDimensionTabEnum.MINE_FLOWALL.getTabid(), conditionEntity);
Long count = RequestCountInfoPAEntity.getData().getCount(); Long count = RequestCountInfoPAEntity.getData().getCount();
num = count + ""; num = count + "";
@ -206,18 +212,16 @@ public class UserInfoCmd {
* *
* @return * @return
*/ */
public String getWfDealNum() { public String getWfDealNum(SimpleEmployee employee) {
String num = "0"; String num = "0";
try { try {
Long count = 0L;
SimpleEmployee employee = UserContext.getCurrentUser();
RequestListConditionApiEntity conditionEntity = new RequestListConditionApiEntity(); RequestListConditionApiEntity conditionEntity = new RequestListConditionApiEntity();
WeaResult<RequestCountInfoPAEntity> RequestCountInfoPAEntity = wflRequestListRest.getRequestCountByTabId(employee, RequestListInitDimensionTabEnum.DONE_FLOWALL.getTabid(), conditionEntity); WeaResult<RequestCountInfoPAEntity> RequestCountInfoPAEntity = wflRequestListRest.getRequestCountByTabId(employee, RequestListInitDimensionTabEnum.DONE_FLOWALL.getTabid(), conditionEntity);
int code = RequestCountInfoPAEntity.getCode(); int code = RequestCountInfoPAEntity.getCode();
if (code == 200) { if (code == 200) {
count = RequestCountInfoPAEntity.getData().getCount(); Long count = RequestCountInfoPAEntity.getData().getCount();
num = count + "";
} }
num = count + "";
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
log.error("getWfDealNum:" + e); log.error("getWfDealNum:" + e);
@ -250,7 +254,7 @@ public class UserInfoCmd {
} }
public static String calculateMinute2(String sdate) throws ParseException { public static String calculateMinute2(String sdate) {
String rzsj = ""; String rzsj = "";
try { try {
if (sdate.length() >= 10) { if (sdate.length() >= 10) {
@ -357,88 +361,92 @@ public class UserInfoCmd {
*/ */
private String getCyqlNumNew(String employeeId) { private String getCyqlNumNew(String employeeId) {
String amount = "0"; String amount = "0";
String groupId = "weaver-ebuilder-form-service";
String sourceType = "LOGIC";
try{ try{
String sql = "select amount from uf_nj_cyqltjb where ry = ? and delete_type=0 and tenant_key = ?"; String sql = "select amount from uf_nj_cyqltjb where ry = ? and delete_type=0 and tenant_key = ?";
List<String> strlist = new ArrayList<>(100); List<String> strlist = new ArrayList<>(100);
strlist.add(employeeId); strlist.add(employeeId);
strlist.add(tenant_key); strlist.add(tenant_key);
String groupId = "weaver-ebuilder-form-service";
String sourceType = "LOGIC";
List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(strlist); List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(strlist);
Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result); List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
if(recordList.size()>0){ if(recordList.size()>0){
amount = String.valueOf(recordList.get(0).get("amount")); amount = String.valueOf(recordList.get(0).get("amount"));
} }
if(StringUtils.isBlank(amount)){
amount = "0";
}
}catch (Exception e){ }catch (Exception e){
e.printStackTrace(); e.printStackTrace();
log.error("getCyqlNumNew-e:" + e); log.error("getCyqlNumNew-e:" + e);
} }
return amount; return amount;
} }
private String getCyqlNum(String hiredate) { // private String getCyqlNum(String hiredate) {
int count = 0; // int count = 0;
try { // try {
//
boolean flag = isTimestampFormat(hiredate); // boolean flag = isTimestampFormat(hiredate);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); // 定义日期格式 // SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); // 定义日期格式
String sdate = ""; // String sdate = "";
//
Calendar calendar = Calendar.getInstance(); // Calendar calendar = Calendar.getInstance();
calendar.add(Calendar.DAY_OF_YEAR, -1); // calendar.add(Calendar.DAY_OF_YEAR, -1);
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); // SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
String edate = dateFormat.format(calendar.getTime()); // String edate = dateFormat.format(calendar.getTime());
//
if (flag) { // if (flag) {
sdate = hiredate.substring(0, 10); // sdate = hiredate.substring(0, 10);
} else { // } else {
long timestamp = new Long(hiredate); // 时间戳，单位是毫秒 // long timestamp = new Long(hiredate); // 时间戳，单位是毫秒
Date rzdate = new Date(timestamp); // 将时间戳转换为Date对象 // Date rzdate = new Date(timestamp); // 将时间戳转换为Date对象
sdate = sdf.format(rzdate); // sdate = sdf.format(rzdate);
} // }
SimpleEmployee employee = UserContext.getCurrentUser(); // SimpleEmployee employee = UserContext.getCurrentUser();
Long cid = employee.getCid(); // Long cid = employee.getCid();
//
log.error("cid:" + cid); // log.error("cid:" + cid);
//
String pageSize = "20"; // String pageSize = "20";
String pageNum = "1"; // String pageNum = "1";
//
Map<String, Object> json = new HashMap<String, Object>(); // Map<String, Object> json = new HashMap<String, Object>();
json.put("cid", cid); // json.put("cid", cid);
json.put("pageNum", pageNum); // json.put("pageNum", pageNum);
json.put("pageSize", pageSize); // json.put("pageSize", pageSize);
json.put("startDate", sdate); // json.put("startDate", sdate);
json.put("endDate", edate); // json.put("endDate", edate);
log.error("getCyqlNum json:" + JSON.toJSONString(json)); // log.error("getCyqlNum json:" + JSON.toJSONString(json));
//
com.weaver.em.msg.api.entity.Request emrequest = new com.weaver.em.msg.api.entity.Request(); // com.weaver.em.msg.api.entity.Request emrequest = new com.weaver.em.msg.api.entity.Request();
emrequest.setUrl("/user-profile/groupSession"); // emrequest.setUrl("/user-profile/groupSession");
emrequest.setParamsMap(json); // emrequest.setParamsMap(json);
emrequest.setAsync(false); // emrequest.setAsync(false);
log.error("getCyqlNum:" + emrequest.toString()); // log.error("getCyqlNum:" + emrequest.toString());
//
com.weaver.em.msg.api.entity.Response response2 = oaRest.executeIm(emrequest); // com.weaver.em.msg.api.entity.Response response2 = oaRest.executeIm(emrequest);
log.error("getCyqlNum:" + response2.toString()); // log.error("getCyqlNum:" + response2.toString());
//
String data = response2.getData(); // String data = response2.getData();
log.error("getCyqlNum data:" + data); // log.error("getCyqlNum data:" + data);
JSONObject resObj = JSONObject.parseObject(data); // JSONObject resObj = JSONObject.parseObject(data);
JSONObject actionMsg = (JSONObject) resObj.get("actionMsg"); // JSONObject actionMsg = (JSONObject) resObj.get("actionMsg");
int code = (int) actionMsg.get("code"); // int code = (int) actionMsg.get("code");
if(code == 0){ // if(code == 0){
JSONObject dataObj = (JSONObject) resObj.get("data"); // JSONObject dataObj = (JSONObject) resObj.get("data");
count = (int) dataObj.get("count"); // count = (int) dataObj.get("count");
} // }
} catch (Exception e) { // } catch (Exception e) {
log.error("getCyqlNum Exception:" + e.getMessage()); // log.error("getCyqlNum Exception:" + e.getMessage());
count = 0; // count = 0;
} // }
return count+""; // return count+"";
//
} // }
/** /**
* 平均每天沟通人数 * 平均每天沟通人数
@ -468,67 +476,68 @@ public class UserInfoCmd {
return amount; return amount;
} }
private String getPjMtgtcs(String hiredate){
int count = 0;
try {
boolean flag = isTimestampFormat(hiredate);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); // 定义日期格式
String sdate = "";
Calendar calendar = Calendar.getInstance();
calendar.add(Calendar.DAY_OF_YEAR, -1);
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
String edate = dateFormat.format(calendar.getTime());
if (flag) {
sdate = hiredate.substring(0, 10);
} else {
long timestamp = new Long(hiredate); // 时间戳，单位是毫秒
Date rzdate = new Date(timestamp); // 将时间戳转换为Date对象
sdate = sdf.format(rzdate);
}
SimpleEmployee employee = UserContext.getCurrentUser();
Long cid = employee.getCid();
String pageSize = "20";
String pageNum = "1";
Map<String, Object> json = new HashMap<String, Object>();
json.put("cid", cid);
json.put("pageNum", pageNum);
json.put("pageSize", pageSize);
json.put("startDate", sdate);
json.put("endDate", edate);
log.error("getPjMtgtcs json:" + JSON.toJSONString(json));
com.weaver.em.msg.api.entity.Request emrequest = new com.weaver.em.msg.api.entity.Request();
emrequest.setUrl("/user-profile/dailySingleSession");
emrequest.setParamsMap(json);
emrequest.setAsync(false);
log.error("getPjMtgtcs:" + emrequest.toString());
com.weaver.em.msg.api.entity.Response response2 = oaRest.executeIm(emrequest); // private String getPjMtgtcs(String hiredate){
log.error("getPjMtgtcs:" + response2.toString()); // int count = 0;
// try {
String data = response2.getData(); //
log.error("getPjMtgtcs data:" + data); // boolean flag = isTimestampFormat(hiredate);
JSONObject resObj = JSONObject.parseObject(data); // SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); // 定义日期格式
JSONObject actionMsg = (JSONObject) resObj.get("actionMsg"); // String sdate = "";
int code = (int) actionMsg.get("code"); //
if(code == 0){ // Calendar calendar = Calendar.getInstance();
JSONObject dataObj = (JSONObject) resObj.get("data"); // calendar.add(Calendar.DAY_OF_YEAR, -1);
count = (int) dataObj.get("count"); // SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
} // String edate = dateFormat.format(calendar.getTime());
} catch (Exception e) { //
log.error("getPjMtgtcs Exception:" + e.getMessage()); // if (flag) {
count = 0; // sdate = hiredate.substring(0, 10);
} // } else {
return count+""; // long timestamp = new Long(hiredate); // 时间戳，单位是毫秒
} // Date rzdate = new Date(timestamp); // 将时间戳转换为Date对象
// sdate = sdf.format(rzdate);
// }
// SimpleEmployee employee = UserContext.getCurrentUser();
// Long cid = employee.getCid();
//
//
//
// String pageSize = "20";
// String pageNum = "1";
//
// Map<String, Object> json = new HashMap<String, Object>();
// json.put("cid", cid);
// json.put("pageNum", pageNum);
// json.put("pageSize", pageSize);
// json.put("startDate", sdate);
// json.put("endDate", edate);
//
// log.error("getPjMtgtcs json:" + JSON.toJSONString(json));
//
// com.weaver.em.msg.api.entity.Request emrequest = new com.weaver.em.msg.api.entity.Request();
// emrequest.setUrl("/user-profile/dailySingleSession");
// emrequest.setParamsMap(json);
// emrequest.setAsync(false);
// log.error("getPjMtgtcs:" + emrequest.toString());
//
// com.weaver.em.msg.api.entity.Response response2 = oaRest.executeIm(emrequest);
// log.error("getPjMtgtcs:" + response2.toString());
//
// String data = response2.getData();
// log.error("getPjMtgtcs data:" + data);
// JSONObject resObj = JSONObject.parseObject(data);
// JSONObject actionMsg = (JSONObject) resObj.get("actionMsg");
// int code = (int) actionMsg.get("code");
// if(code == 0){
// JSONObject dataObj = (JSONObject) resObj.get("data");
// count = (int) dataObj.get("count");
// }
// } catch (Exception e) {
// log.error("getPjMtgtcs Exception:" + e.getMessage());
// count = 0;
// }
// return count+"";
// }
} }

445
src/main/java/com/weaver/seconddev/jcldoor/controller/HrmSelfHelpController.java
View File

File diff suppressed because one or more lines are too long

2
src/main/java/com/weaver/seconddev/jcldoor/util/JucailinPortalUtils.java
Unescape Escape View File

@ -6,8 +6,6 @@ import com.weaver.common.hrm.util.HrmCommonUtil;
import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity; import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity;
import com.weaver.ebuilder.datasource.api.enums.SqlParamType; import com.weaver.ebuilder.datasource.api.enums.SqlParamType;
import com.weaver.ebuilder.form.client.entity.data.*; import com.weaver.ebuilder.form.client.entity.data.*;
import com.weaver.ebuilder.form.client.entity.field.ModuleField;
import com.weaver.ebuilder.form.client.service.emobile.IEtFormDatasetService;
import com.weaver.framework.rpc.annotation.RpcReference; import com.weaver.framework.rpc.annotation.RpcReference;
import com.weaver.teams.domain.user.SimpleEmployee; import com.weaver.teams.domain.user.SimpleEmployee;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;

Write Preview
Loading…
Cancel
Save