文档库--推送

This commit is contained in:
zhn
2022-03-14 09:29:15 +08:00
parent 215cb5688c
commit cc7a8b6b29
2 changed files with 23 additions and 11 deletions
@@ -73,7 +73,7 @@ import java.util.stream.Collectors;
public class SysUserController { public class SysUserController {
@Autowired @Autowired
private ISysBaseAPI sysBaseAPI; private ISysBaseAPI sysBaseAPI;
@Autowired @Autowired
private ISysUserService sysUserService; private ISysUserService sysUserService;
@@ -833,7 +833,7 @@ public class SysUserController {
} }
return result; return result;
} }
/** /**
* 查询当前用户的所有部门/当前部门编码 * 查询当前用户的所有部门/当前部门编码
* @return * @return
@@ -857,12 +857,12 @@ public class SysUserController {
return result; return result;
} }
/** /**
* 用户注册接口 * 用户注册接口
* *
* @param jsonObject * @param jsonObject
* @param user * @param user
* @return * @return
@@ -973,7 +973,7 @@ public class SysUserController {
result.setMessage("验证失败"); result.setMessage("验证失败");
return result; return result;
} }
/** /**
* 用户手机号验证 * 用户手机号验证
*/ */
@@ -1001,7 +1001,7 @@ public class SysUserController {
result.setSuccess(true); result.setSuccess(true);
return result; return result;
} }
/** /**
* 用户更改密码 * 用户更改密码
*/ */
@@ -1045,11 +1045,11 @@ public class SysUserController {
return result; return result;
} }
} }
/** /**
* 根据TOKEN获取用户的部分信息(返回的数据是可供表单设计器使用的数据) * 根据TOKEN获取用户的部分信息(返回的数据是可供表单设计器使用的数据)
* *
* @return * @return
*/ */
@RequiresPermissions("sys:user:list") @RequiresPermissions("sys:user:list")
@@ -1061,7 +1061,7 @@ public class SysUserController {
if (oConvertUtils.isEmpty(token)) { if (oConvertUtils.isEmpty(token)) {
username = JwtUtil.getUserNameByToken(request); username = JwtUtil.getUserNameByToken(request);
} else { } else {
username = JwtUtil.getUsername(token); username = JwtUtil.getUsername(token);
} }
log.debug(" ------ 通过令牌获取部分用户信息,当前用户: " + username); log.debug(" ------ 通过令牌获取部分用户信息,当前用户: " + username);
@@ -1082,7 +1082,7 @@ public class SysUserController {
return Result.error(500, "查询失败:" + e.getMessage()); return Result.error(500, "查询失败:" + e.getMessage());
} }
} }
/** /**
* 【APP端接口】获取用户列表 根据用户名和真实名 模糊匹配 * 【APP端接口】获取用户列表 根据用户名和真实名 模糊匹配
* @param keyword * @param keyword
@@ -1120,7 +1120,7 @@ public class SysUserController {
log.error(e.getMessage(), e); log.error(e.getMessage(), e);
return Result.error(500, "查询失败:" + e.getMessage()); return Result.error(500, "查询失败:" + e.getMessage());
} }
} }
/** /**
@@ -1369,6 +1369,7 @@ public class SysUserController {
* *
* @return * @return
*/ */
@ApiOperation(value = "树形")
@RequestMapping(value = "/queryDepartUserTreeList", method = RequestMethod.GET) @RequestMapping(value = "/queryDepartUserTreeList", method = RequestMethod.GET)
public Result<List<SysDepartUserTreeModel>> queryDepartUserTreeList() { public Result<List<SysDepartUserTreeModel>> queryDepartUserTreeList() {
Result<List<SysDepartUserTreeModel>> result = new Result<>(); Result<List<SysDepartUserTreeModel>> result = new Result<>();
@@ -27,6 +27,7 @@ import com.jero.modules.document.enums.FieldTypeEnum;
import com.jero.modules.document.mapper.BussDocumentLibraryEOMapper; import com.jero.modules.document.mapper.BussDocumentLibraryEOMapper;
import com.jero.modules.document.service.IBussDocumentLibraryEOService; import com.jero.modules.document.service.IBussDocumentLibraryEOService;
import com.jero.modules.domain.service.DomainUserRelService; import com.jero.modules.domain.service.DomainUserRelService;
import com.jero.modules.feishu.service.IFeishuService;
import com.jero.modules.log.entity.BussLogEO; import com.jero.modules.log.entity.BussLogEO;
import com.jero.modules.log.service.IBussLogEOService; import com.jero.modules.log.service.IBussLogEOService;
import com.jero.modules.message.websocket.WebSocket; import com.jero.modules.message.websocket.WebSocket;
@@ -137,6 +138,8 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
private ISysUserService sysUserService; private ISysUserService sysUserService;
@Resource @Resource
private WebSocket webSocket; private WebSocket webSocket;
@Resource
private IFeishuService iFeishuService;
@Value(value = "${jero.path.upload}") @Value(value = "${jero.path.upload}")
private String uploadpath; private String uploadpath;
@@ -2472,11 +2475,19 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
//封装消息的实体类 //封装消息的实体类
SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdList, content, contentInfo); SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdList, content, contentInfo);
sysAnnouncementService.saveAnnouncement(sysAnnouncement); sysAnnouncementService.saveAnnouncement(sysAnnouncement);
//飞书
try {
iFeishuService.batchSendMessage(new String[userIdList.size()],content,null,null);
} catch (IOException e) {
log.error("飞书推送失败");
}
sendWebsocket(documentIds,content);
return "推送成功"; return "推送成功";
} }
/** /**
*
* 属性字典处理中文 * 属性字典处理中文
* *
* @param categoryList * @param categoryList