package com.fzzy.appwx.manager;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.fzzy.appwx.param.WeChatBaseParam;
|
import com.fzzy.appwx.util.WeChatUtil;
|
import com.fzzy.igds.constant.Constant;
|
import com.fzzy.igds.constant.RespCodeEnum;
|
import com.fzzy.igds.data.IgdsBaseParam;
|
import com.fzzy.igds.data.PageResponse;
|
import com.fzzy.igds.domain.SnapReply;
|
import com.fzzy.igds.service.SnapReplyService;
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
import com.ruoyi.system.service.ISysUserService;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
|
@Component
|
public class WeChatManager {
|
|
@Autowired
|
private WeChatUtil weChatUtil;
|
@Autowired
|
private ISysUserService sysUserService;
|
@Resource
|
private SnapReplyService snapReplyService;
|
|
|
public String getOpenid(String code) {
|
//根据code获取用户openid
|
return weChatUtil.getOpenid(code);
|
}
|
|
|
public SysUser getUser(String openid) {
|
//根据openid获取用户信息
|
return sysUserService.selectUserByOpenId(openid);
|
}
|
|
//获取用户绑定信息
|
public PageResponse<SysUser> getUserBindInfo(WeChatBaseParam param) {
|
//判断参数
|
if (null == param) {
|
return new PageResponse<SysUser>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
}
|
|
SysUser user = null;
|
|
//微信公众号
|
if (StringUtils.isEmpty(param.getOpenid())) {
|
return new PageResponse<SysUser>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
|
}
|
//根据openid查询用户是否已经绑定
|
user = sysUserService.selectUserByOpenId(param.getOpenid());
|
if (user == null) {
|
return new PageResponse<SysUser>(RespCodeEnum.CODE_1008.getCode(), "业务数据返回为空");
|
|
}
|
|
Long deptId = user.getDeptId();
|
if (deptId == null) {
|
deptId = Long.valueOf(user.getCompanyId());
|
user.setDeptId(deptId);
|
}
|
return new PageResponse(RespCodeEnum.CODE_0000.getCode(), "查询成功", user);
|
}
|
|
//绑定openId
|
public PageResponse<String> bandOpenId(WeChatBaseParam param) {
|
|
//判断参数
|
if (null == param || StringUtils.isEmpty(param.getOpenid())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
|
}
|
if (StringUtils.isEmpty(param.getMobile())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "手机号为空，请填写");
|
|
}
|
// if (StringUtils.isEmpty(param.getMsgCode())) {
|
// return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "验证码不能为空");
|
//
|
// }
|
//
|
// String code = (String) redisService.getCacheObject(WeChatConst.WX_MOBILE_CODE + param.getMobile());
|
// if(StringUtils.isEmpty(code)){
|
// res.put("code","1007");
|
// res.put("msg","验证码已失效，请重新获取");
|
// return res;
|
// }
|
// if(! code.equals(param.getMsgCode())){
|
// res.put("code","1007");
|
// res.put("msg","验证码错误");
|
// return res;
|
// }
|
|
//根据手机号查看用户是否是系统用户
|
SysUser user = sysUserService.selectUserByPhoneNumber(param.getMobile());
|
if (user == null || StringUtils.isEmpty(user.getPhonenumber())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1006.getCode(), "手机号不在系统内，请联系管理员！");
|
}
|
|
//更新数据库，用户信息加入微信认证ID
|
user.setOpenId(param.getOpenid());
|
sysUserService.updateUserInfo(user);
|
|
// redisService.deleteObject(WeChatConst.WX_MOBILE_CODE + param.getMobile());
|
|
return new PageResponse<String>(RespCodeEnum.CODE_0000.getCode(), "请求成功");
|
|
}
|
|
|
//解绑openId
|
public PageResponse<String> unBandOpenId(WeChatBaseParam param) {
|
|
//判断参数
|
if (null == param || StringUtils.isEmpty(param.getOpenid())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
|
}
|
if (StringUtils.isEmpty(param.getMobile())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "手机号为空，请填写");
|
}
|
if (StringUtils.isEmpty(param.getMsgCode())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "验证码不能为空");
|
|
}
|
|
// String code = (String) redisService.getCacheObject(WeChatConst.WX_MOBILE_CODE + param.getMobile());
|
// if(StringUtils.isEmpty(code)){
|
// res.put("code","1007");
|
// res.put("msg","验证码已失效，请重新获取");
|
// return res;
|
//
|
// }
|
// if(! code.equals(param.getMsgCode())){
|
// res.put("code","1007");
|
// res.put("msg","验证码错误");
|
// return res;
|
// }
|
|
//根据手机号查询用户是否已经绑定
|
SysUser user = sysUserService.selectUserByPhoneNumber(param.getMobile());
|
if (user == null || StringUtils.isEmpty(user.getPhonenumber())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1006.getCode(), "手机号不在系统内，请联系管理员！");
|
|
}
|
|
user.setOpenId("");
|
sysUserService.updateUserInfo(user);
|
|
// redisService.deleteObject(WeChatConst.WX_MOBILE_CODE + param.getMobile());
|
|
return new PageResponse<String>(RespCodeEnum.CODE_0000.getCode(), "请求成功");
|
|
}
|
|
public PageResponse<Page<SnapReply>> getSnapReplyPage(WeChatBaseParam param) {
|
|
if (null == param) {
|
return new PageResponse<Page<SnapReply>>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
}
|
|
SysUser user;
|
|
//微信公众号
|
if (StringUtils.isEmpty(param.getOpenid())) {
|
return new PageResponse<Page<SnapReply>>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
|
}
|
//根据openid查询用户是否已经绑定
|
user = sysUserService.selectUserByOpenId(param.getOpenid());
|
if (user == null) {
|
return new PageResponse<Page<SnapReply>>(RespCodeEnum.CODE_1006.getCode(), "尚未绑定服务，请先绑定！");
|
|
}
|
//分页拼接
|
Page<SnapReply> page = new Page<>(param.getPageNo(), param.getPageSize());
|
//查询参数组装
|
IgdsBaseParam queryParam = new IgdsBaseParam();
|
queryParam.setDeptId(String.valueOf(user.getDeptId()));
|
queryParam.setCompanyId(user.getCompanyId());
|
queryParam.setKey(Constant.YN_N);
|
snapReplyService.listPage(page, queryParam);
|
return new PageResponse<Page<SnapReply>>(RespCodeEnum.CODE_0000.getCode(), "请求成功", page);
|
}
|
|
public PageResponse<SnapReply> getSnapReplyInfoById(WeChatBaseParam param) {
|
|
//判断参数
|
if (null == param || StringUtils.isEmpty(param.getId())) {
|
return new PageResponse<SnapReply>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
|
}
|
|
SnapReply warn = snapReplyService.getById(param.getId());
|
if (warn == null) {
|
return new PageResponse<SnapReply>(RespCodeEnum.CODE_1007.getCode(), "未获取到该警告信息！");
|
|
}
|
|
return new PageResponse<SnapReply>(RespCodeEnum.CODE_0000.getCode(), "请求成功", warn);
|
|
}
|
|
public PageResponse<String> handleSnapReply(WeChatBaseParam param) {
|
|
//判断参数
|
if (null == param || StringUtils.isEmpty(param.getId())) {
|
return new PageResponse<String>(RespCodeEnum.CODE_1007.getCode(), "参数不完整，请核查");
|
|
}
|
|
//处理时间
|
Date date = new Date();
|
|
// if(StringUtils.isEmpty(companyId)){
|
// companyId = ShiroUtils.getLoginUserCompanyId();
|
// }
|
String info = (String) param.getRemark();
|
String id = param.getId();
|
String userName = param.getUserName();
|
|
//告警处理
|
SnapReply warn = snapReplyService.getById(id);
|
if(Constant.YN_N.equals(warn.getIsHandle())){
|
return new PageResponse<String>(RespCodeEnum.CODE_1008.getCode(), "改告警已处理，无需重复批复！");
|
}
|
warn.setId(id);
|
warn.setUpdateBy(userName);
|
warn.setUpdateTime(date);
|
warn.setIsHandle(Constant.YN_Y);
|
warn.setReplyText(info);
|
warn.setDays(param.getDays());
|
snapReplyService.updateData(warn);
|
|
return new PageResponse<String>(RespCodeEnum.CODE_0000.getCode(), "请求成功");
|
|
}
|
|
}
|
