|
|
@@ -6,24 +6,28 @@ import com.alibaba.fastjson.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.management.platform.constant.Constant;
|
|
|
import com.management.platform.entity.*;
|
|
|
+import com.management.platform.entity.vo.UserVO;
|
|
|
import com.management.platform.mapper.*;
|
|
|
import com.management.platform.service.FeishuInfoService;
|
|
|
import com.management.platform.service.SysRoleService;
|
|
|
import com.management.platform.service.UserService;
|
|
|
+import com.management.platform.service.impl.FeishuInfoServiceImpl;
|
|
|
import com.management.platform.util.*;
|
|
|
import com.taobao.api.ApiException;
|
|
|
+import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
-import org.springframework.http.HttpHeaders;
|
|
|
-import org.springframework.http.HttpStatus;
|
|
|
-import org.springframework.http.MediaType;
|
|
|
-import org.springframework.http.ResponseEntity;
|
|
|
+import org.springframework.http.*;
|
|
|
+import org.springframework.util.StringUtils;
|
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
|
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
|
+import org.springframework.web.client.RestTemplate;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
import java.time.LocalDateTime;
|
|
|
+import java.time.ZoneOffset;
|
|
|
import java.util.*;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
* <p>
|
|
|
@@ -59,6 +63,22 @@ public class FeishuInfoController {
|
|
|
private SysRoleMapper sysRoleMapper;
|
|
|
@Resource
|
|
|
private UserService userService;
|
|
|
+ @Resource
|
|
|
+ private UserMapper userMapper;
|
|
|
+ @Resource
|
|
|
+ private AuditWorkflowTimeSettingMapper auditWorkflowTimeSettingMapper;
|
|
|
+ @Resource
|
|
|
+ private SysFunctionMapper sysFunctionMapper;
|
|
|
+ @Resource
|
|
|
+ private SysRoleFunctionMapper sysRoleFunctionMapper;
|
|
|
+ @Resource
|
|
|
+ private SysRoleModuleMapper sysRoleModuleMapper;
|
|
|
+ @Resource
|
|
|
+ private SysModuleMapper sysModuleMapper;
|
|
|
+ @Resource
|
|
|
+ private TaskGroupMapper taskGroupMapper;
|
|
|
+ @Resource
|
|
|
+ private ProjectAuditorMapper projectAuditorMapper;
|
|
|
|
|
|
|
|
|
/**
|
|
|
@@ -189,8 +209,7 @@ public class FeishuInfoController {
|
|
|
.setRoleName(role.getRolename())
|
|
|
.setCompanyId(company.getId())
|
|
|
.setName(userJson.getString("name"))
|
|
|
- .setCorpwxUserid(openUserid)
|
|
|
- .setCorpwxRealUserid(curUserid)
|
|
|
+ .setFeishuUserid(openUserid)
|
|
|
.setColor(ColorUtil.randomColor())
|
|
|
.setJobNumber(curUserid)
|
|
|
.setPassword(MD5Util.getPassword("000000"))
|
|
|
@@ -235,5 +254,277 @@ public class FeishuInfoController {
|
|
|
return allList.stream().filter(all->all.getDepartmentId().intValue() == id).findFirst().get();
|
|
|
}
|
|
|
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ @RequestMapping("/loginByFeishu")
|
|
|
+ public HttpRespMsg loginByFeishu(String code,String appId){
|
|
|
+ HttpRespMsg httpRespMsg=new HttpRespMsg();
|
|
|
+ FeishuInfo feishuInfo = feishuInfoService.getOne(new QueryWrapper<FeishuInfo>().eq("app_id", appId));
|
|
|
+ String url = FeishuInfoServiceImpl.GET_USER_ACCESS_TOKEN;
|
|
|
+ HttpHeaders headers = new HttpHeaders();
|
|
|
+ RestTemplate restTemplate = new RestTemplate();
|
|
|
+ MediaType type = MediaType.parseMediaType("application/json; charset=UTF-8");
|
|
|
+ headers.setContentType(type);
|
|
|
+ headers.add("Authorization","Bearer "+feishuInfoService.getAppAccessToken(feishuInfo));
|
|
|
+ JSONObject ob = new JSONObject();
|
|
|
+ ob.put("grant_type", "authorization_code");
|
|
|
+ ob.put("code", code);
|
|
|
+ HttpEntity<JSONObject> Entity = new HttpEntity<>(ob, headers);
|
|
|
+ ResponseEntity<String> responseEntity = restTemplate.postForEntity(url, Entity, String.class);
|
|
|
+ String redirecUrl = null;
|
|
|
+ String openUserId=null;
|
|
|
+ String fsUserId=null;
|
|
|
+ String corpId=null;
|
|
|
+ if (responseEntity.getStatusCode() == HttpStatus.OK) {
|
|
|
+ String resp = responseEntity.getBody();
|
|
|
+ System.err.println(resp);
|
|
|
+ JSONObject obj = JSONObject.parseObject(resp);
|
|
|
+ if (obj.getIntValue("code") == 0) {
|
|
|
+ System.out.println(obj.toString());
|
|
|
+ JSONObject data = obj.getJSONObject("data");
|
|
|
+ fsUserId = data.getString("user_id");
|
|
|
+ openUserId = data.getString("open_id");
|
|
|
+ corpId = data.getString("tenant_key");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ List<User> userList = userMapper.selectList(new QueryWrapper<User>().eq("feishu_userid", openUserId));
|
|
|
+ Integer companyId = 0;
|
|
|
+ if (userList.size() > 0) {
|
|
|
+ //该用户已存在
|
|
|
+ User curUser = userList.get(0);
|
|
|
+ System.out.println("找到用户corpFeishuUserid=="+curUser.getFeishuUserid());
|
|
|
+ companyId = curUser.getCompanyId();
|
|
|
+ String userId = curUser.getId();
|
|
|
+ if (StringUtils.isEmpty(userId) || userId.length() > 50) {
|
|
|
+ //httpRespMsg.setError("账号不存在");
|
|
|
+ httpRespMsg.setError(MessageUtils.message("user.accountNoExist"));
|
|
|
+ return httpRespMsg;
|
|
|
+ }
|
|
|
+ User user = userMapper.selectById(userId);
|
|
|
+ if (user == null) {
|
|
|
+ //httpRespMsg.setError("账号不存在");
|
|
|
+ httpRespMsg.setError(MessageUtils.message("user.accountNoExist"));
|
|
|
+ return httpRespMsg;
|
|
|
+ }
|
|
|
+ if (user.getIsActive() == 0) {
|
|
|
+ //httpRespMsg.setError("该账号已停用");
|
|
|
+ httpRespMsg.setError(MessageUtils.message("user.accountDeactivation"));
|
|
|
+ return httpRespMsg;
|
|
|
+ }
|
|
|
+ //查看该公司非会员公司，只能允许试用三天，超时不可登录
|
|
|
+ Company company = companyMapper.selectOne(new QueryWrapper<Company>().eq("id", user.getCompanyId()));
|
|
|
+ //公司未办理会员
|
|
|
+ if (null != company.getExpirationDate()) {
|
|
|
+ if (0 == company.getSetMeal()) {
|
|
|
+ //未办理会员
|
|
|
+ if (company.getExpirationDate().isBefore(LocalDateTime.now())) {
|
|
|
+ //httpRespMsg.setError("账号试用已到期，请联系客服。");
|
|
|
+ httpRespMsg.setError(MessageUtils.message("user.accountExpired"));
|
|
|
+ return httpRespMsg;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ if (company.getExpirationDate().isBefore(LocalDateTime.now())) {
|
|
|
+ //httpRespMsg.setError("账号会员已到期，请联系客服。");
|
|
|
+ httpRespMsg.setError(MessageUtils.message("user.memberExpired"));
|
|
|
+ return httpRespMsg;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ UserVO userVO = new UserVO().setCompanyName(company.getCompanyName());
|
|
|
+ userVO.setCompany(company);
|
|
|
+ BeanUtils.copyProperties(user, userVO);
|
|
|
+ //还要多返回一个公司名字
|
|
|
+ userVO.setPassword("");
|
|
|
+ LocalDateTime remainingTime = company.getExpirationDate() == null ? LocalDateTime.now() : company.getExpirationDate();
|
|
|
+ userVO.setRemainingTime(remainingTime.toInstant(ZoneOffset.of("+8")).toEpochMilli() -
|
|
|
+ LocalDateTime.now().toInstant(ZoneOffset.of("+8")).toEpochMilli());
|
|
|
+ //检测是否是项目经理，项目经理有审核功能权限
|
|
|
+ userVO.setLeader(judgeIsLeader(userVO.getId()));
|
|
|
+ userVO.setTimeType(timeTypeMapper.selectById(company.getId()));
|
|
|
+ List<Department> manageDeptList = departmentMapper.selectList(new QueryWrapper<Department>().eq("manager_id", userVO.getId()));
|
|
|
+ List<Integer> deptIds = manageDeptList.stream().map(Department::getDepartmentId).collect(Collectors.toList());
|
|
|
+ int num = 0;
|
|
|
+ if (deptIds.size() > 0) {
|
|
|
+ num = auditWorkflowTimeSettingMapper.selectCount(new QueryWrapper<AuditWorkflowTimeSetting>().in("audit_dept_id", deptIds));
|
|
|
+ }
|
|
|
+ userVO.setHasAuditDept(num>0);
|
|
|
+ //获取当前角色的权限菜单
|
|
|
+ setUserRoleMenu(userVO);
|
|
|
+ httpRespMsg.data = userVO;
|
|
|
+ return httpRespMsg;
|
|
|
+ }else httpRespMsg.setError("飞书用户未开通");
|
|
|
+ return httpRespMsg;
|
|
|
+ }
|
|
|
+
|
|
|
+ private boolean judgeIsLeader(String userId) {
|
|
|
+ int cnt = projectAuditorMapper.selectCount(new QueryWrapper<ProjectAuditor>().eq("auditor_id", userId));
|
|
|
+ return cnt>0;
|
|
|
+ }
|
|
|
+
|
|
|
+ public void setUserRoleMenu(UserVO user) {
|
|
|
+ Integer roleId = user.getRoleId();
|
|
|
+ //获取公司的套餐
|
|
|
+ Company company = companyMapper.selectById(user.getCompanyId());
|
|
|
+ TimeType timeType = timeTypeMapper.selectById(company.getId());
|
|
|
+ //按照公司开通的模块进行匹配
|
|
|
+ QueryWrapper<SysModule> queryWrapper = new QueryWrapper<SysModule>().eq("package_time", 1);
|
|
|
+ if (company.getPackageProject() == 1) {
|
|
|
+ queryWrapper.or().eq("package_project", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageOa() == 1) {
|
|
|
+ queryWrapper.or().eq("package_oa", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageExpense() == 1) {
|
|
|
+ queryWrapper.or().eq("package_expense", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageCustomer() == 1) {
|
|
|
+ queryWrapper.or().eq("package_customer", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageEngineering() == 1) {
|
|
|
+ queryWrapper.or().eq("package_engineering", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageContract() == 1) {
|
|
|
+ queryWrapper.or().eq("package_contract", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageEtimecard()== 1) {
|
|
|
+ queryWrapper.or().eq("package_etimecard", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageFinance() == 1) {
|
|
|
+ queryWrapper.or().eq("package_finance", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageProvider() == 1) {
|
|
|
+ queryWrapper.or().eq("package_provider", 1);
|
|
|
+ }
|
|
|
+ if (timeType.getReportWorkflow() == 1) {
|
|
|
+ queryWrapper.or().eq("report_workflow", 1);
|
|
|
+ }
|
|
|
+ if (timeType.getNeedDeptAudit() == 1) {
|
|
|
+ queryWrapper.or().eq("need_dept_audit", 1);
|
|
|
+ }
|
|
|
+
|
|
|
+ queryWrapper.orderByAsc("orderitem");
|
|
|
+
|
|
|
+ //返回菜单
|
|
|
+ List<SysRoleModule> rModules = sysRoleModuleMapper.selectList(new QueryWrapper<SysRoleModule>().eq("role_id", roleId));
|
|
|
+ List<Integer> ids = rModules.stream().map(SysRoleModule::getModuleId).collect(Collectors.toList());
|
|
|
+ //项目报告审核模块,如果参与日报的审核，需要自动加上, 或者担任任务分组负责人
|
|
|
+ if (user.isLeader() || user.isHasAuditDept() || (company.getPackageProject() == 1 && taskGroupMapper.selectCount(new QueryWrapper<TaskGroup>().eq("incharger_id", user.getId())) > 0)) {
|
|
|
+ SysModule projectAuditModule = sysModuleMapper.selectOne(new QueryWrapper<SysModule>().eq("name", "项目报告审核"));
|
|
|
+ if (!ids.contains(projectAuditModule.getId())) {
|
|
|
+ ids.add(projectAuditModule.getId());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ List<SysModule> moduleList = sysModuleMapper.selectList(queryWrapper);
|
|
|
+
|
|
|
+ //过滤一下，这个角色选中的模块
|
|
|
+ moduleList = moduleList.stream().filter(m->ids.contains(m.getId())).collect(Collectors.toList());
|
|
|
+ if (company.getPackageEngineering() == 1) {
|
|
|
+ //生成虚拟的两个审核放进去
|
|
|
+ SysModule proModule = new SysModule();
|
|
|
+ proModule.setName("专业审核");
|
|
|
+ proModule.setPath("/reviewProfession");
|
|
|
+ proModule.setId(0);
|
|
|
+ moduleList.add(1,proModule);
|
|
|
+ SysModule deptModule = new SysModule();
|
|
|
+ deptModule.setName("部门审核");
|
|
|
+ deptModule.setPath("/reviewDepartment");
|
|
|
+ deptModule.setId(0);
|
|
|
+ moduleList.add(2,deptModule);
|
|
|
+ }
|
|
|
+ //开启了自定义日报列表的情况下，需要菜单上有
|
|
|
+ if (timeType.getCustomDegreeActive() == 1 && moduleList.stream().anyMatch(mod->mod.getName().equals("系统基础设置"))) {
|
|
|
+ SysModule centerManageModule = new SysModule();
|
|
|
+ //centerManageModule.setName(timeType.getCustomDegreeName()+"管理");
|
|
|
+ centerManageModule.setName(timeType.getCustomDegreeName()+MessageUtils.message("project.manage"));
|
|
|
+ centerManageModule.setPath("/centerManage");
|
|
|
+ centerManageModule.setId(0);
|
|
|
+ //加到组织架构前面
|
|
|
+ int findIndex = 0;
|
|
|
+ for (int i=0;i<moduleList.size(); i++) {
|
|
|
+ if (moduleList.get(i).getName().equals("组织架构") || moduleList.get(i).getName().equals("基础数据管理")) {
|
|
|
+ findIndex = i;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ moduleList.add(findIndex,centerManageModule);
|
|
|
+ }
|
|
|
+ //组装层级关系，默认只有两级
|
|
|
+ List<SysModule> menuList = new ArrayList<>();
|
|
|
+ for (SysModule module : moduleList) {
|
|
|
+ if (module.getParentId() == null) {
|
|
|
+ menuList.add(module);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ for (SysModule mainMenu : menuList) {
|
|
|
+ List<SysModule> list = moduleList.stream().filter(mod -> mainMenu.getId().equals(mod.getParentId())).collect(Collectors.toList());
|
|
|
+ mainMenu.setChildren(list);
|
|
|
+ }
|
|
|
+
|
|
|
+ user.setModuleList(menuList);
|
|
|
+ //此处返回权限集合
|
|
|
+ List<Integer> functionIdList = new ArrayList<>();
|
|
|
+ //获取角色所有的功能id
|
|
|
+ List<SysRoleFunction> funList = sysRoleFunctionMapper.selectList(new QueryWrapper<SysRoleFunction>()
|
|
|
+ .eq("role_id", roleId));
|
|
|
+ for (SysRoleFunction sysRoleFunction : funList) {
|
|
|
+ functionIdList.add(sysRoleFunction.getFunctionId());
|
|
|
+ }
|
|
|
+ //获取当前公司开启了得报表
|
|
|
+ List<CompanyReport> companyReportList = companyReportMapper.selectList(new QueryWrapper<CompanyReport>().eq("company_id", company.getId()));
|
|
|
+ List<Integer> formIds = companyReportList.stream().map(CompanyReport::getReportFormId).collect(Collectors.toList());
|
|
|
+ if (functionIdList.size() > 0) {
|
|
|
+ //根据功能id获取可用的操作代码
|
|
|
+ if (formIds.size() == 0) {
|
|
|
+ formIds.add(-1);
|
|
|
+ }
|
|
|
+ QueryWrapper<SysFunction> functionQueryWrapper = new QueryWrapper<SysFunction>().and(wrapper1->wrapper1.isNull("report_form_id").or().in("report_form_id",formIds)).and(wrapper->{
|
|
|
+ wrapper.eq("package_time", 1);
|
|
|
+ if (company.getPackageProject() == 1) {
|
|
|
+ wrapper.or().eq("package_project", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageOa() == 1) {
|
|
|
+ wrapper.or().eq("package_oa", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageExpense() == 1) {
|
|
|
+ wrapper.or().eq("package_expense", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageCustomer() == 1) {
|
|
|
+ wrapper.or().eq("package_customer", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageEngineering() == 1) {
|
|
|
+ wrapper.or().eq("package_engineering", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageContract() == 1) {
|
|
|
+ wrapper.or().eq("package_contract", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageEtimecard()== 1) {
|
|
|
+ wrapper.or().eq("package_etimecard", 1);
|
|
|
+ }
|
|
|
+ if (company.getPackageFinance() == 1) {
|
|
|
+ wrapper.or().eq("package_finance", 1);
|
|
|
+ }
|
|
|
+// if (company.getPackageProvider() == 1) {
|
|
|
+// wrapper.or().eq("package_provider", 1);
|
|
|
+// }
|
|
|
+ if (timeType.getSyncCorpwxTime() == 1) {
|
|
|
+ wrapper.or().eq("sync_corpwx_time", 1);
|
|
|
+ }
|
|
|
+ //开通财务审核功能的
|
|
|
+ if (timeType.getFinanceAudit() == 1) {
|
|
|
+ wrapper.or().eq("finance_audit", 1);
|
|
|
+ }
|
|
|
+ return wrapper;
|
|
|
+ });
|
|
|
+ functionQueryWrapper.orderByAsc("seq");
|
|
|
+ List<SysFunction> functionList = sysFunctionMapper.selectList(functionQueryWrapper);
|
|
|
+ functionList = functionList.stream().filter(f->functionIdList.contains(f.getId())).collect(Collectors.toList());
|
|
|
+ user.setFunctionList(functionList);
|
|
|
+ } else {
|
|
|
+ user.setFunctionList(new ArrayList<>());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
|
