从高明获取,并补全websocket所需的代码

master
xm 4 years ago
parent c875dbe7f1
commit f0221eb716

@ -532,13 +532,13 @@ public class FontController {
return power_dept.getDeptCode();
}
/**
* deptcodeid
* deptcodeid
*/
@RequestMapping("/getUserInfoByDeptCodeForChief")
@ResponseBody
public String getUserInfoByDeptCodeForChief(String DeptCode) throws Exception{
List<Power_User> power_users = power_userMapper.selectAllForChief(DeptCode);
String result = null;
String result = "";
for (int i = 0; i < power_users.size(); i++) {
Power_User power_user = power_users.get(i);
result=power_user.getUserId()+","+power_user.getUserName()+","+power_user.getName()+";";
@ -552,7 +552,7 @@ public class FontController {
@ResponseBody
public String getUserInfoByDeptCodeForRecordRoom(String DeptCode) throws Exception{
List<Power_User> power_users = power_userMapper.selectAllForRecordRoom(DeptCode);
String result = null;
String result = "";
for (int i = 0; i < power_users.size(); i++) {
Power_User power_user = power_users.get(i);
result=power_user.getUserId()+","+power_user.getUserName()+","+power_user.getName()+";";
@ -593,4 +593,31 @@ public class FontController {
return result;
}
/**
* 2021/11/20
*
*
*
*
*/
@RequestMapping("sendMessage")
@ResponseBody
public Msg sendMessage(Message message) throws Exception{
if(null == message.getUserId()){
return Msg.fail("消息用户id不能为空");
}
if(StringUtils.isBlank(message.getSysFlag())){
return Msg.fail("消息系统标识不能为空");
}
if(StringUtils.isBlank(message.getTitle())){
return Msg.fail("消息标题不能为空");
}
if(StringUtils.isBlank(message.getContent())){
return Msg.fail("消息内容不能为空");
}
WsPool.sendMessageToAll(message.getSysFlag() + "_" + message.getUserId(), message.getTitle() + STR_SPLIT + message.getContent() + STR_SPLIT + message.getTypeFlag());
//修改为向特定用户发送信息
// WsPool.sendMessageToUser();
return Msg.success();
}
}

@ -80,4 +80,6 @@ public interface Power_UserMapper {
String selectForDeptId(Integer userId);
String selectForDeptCode(String deptId);
String selectForDeptIdForChief(Integer userId);
}

@ -0,0 +1,65 @@
package com.manage.vo;
/**
* @ProjectName:
* @Description:
* @Param
* @Return
* @Author:
* @CreateDate: 2020/11/9 15:18
* @UpdateUser:
* @UpdateDate: 2020/11/9 15:18
* @UpdateRemark:
* @Version: 1.0
*/
public class Message {
private Integer userId;
private String sysFlag;
private String title;
private String content;
private String typeFlag;
public Integer getUserId() {
return userId;
}
public void setUserId(Integer userId) {
this.userId = userId;
}
public String getSysFlag() {
return sysFlag;
}
public void setSysFlag(String sysFlag) {
this.sysFlag = sysFlag;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
public String getTypeFlag() {
return typeFlag;
}
public void setTypeFlag(String typeFlag) {
this.typeFlag = typeFlag;
}
}

@ -746,4 +746,13 @@
FROM `power_dept`
WHERE dept_id = #{deptId}
</select>
<select id="selectForDeptIdForChief" resultType="java.lang.String">
SELECT
power_user.dept_id
FROM
`power_user`
where
power_user.user_id = #{userId}
and role_id = 25
</select>
</mapper>
Loading…
Cancel
Save