Commit 3556b65e by 桂前礼

取消原有发邮件的流程

parent 9810b6e1
...@@ -163,18 +163,18 @@ public class PcloudRobotBizImpl implements PcloudRobotBiz { ...@@ -163,18 +163,18 @@ public class PcloudRobotBizImpl implements PcloudRobotBiz {
JedisClusterUtils.hset(BookBusinessConstants.ACTIVE_ROBOT_CACHE_KEY_PREFIX, wxId, String.valueOf(System.currentTimeMillis() + 7 * 1000)); JedisClusterUtils.hset(BookBusinessConstants.ACTIVE_ROBOT_CACHE_KEY_PREFIX, wxId, String.valueOf(System.currentTimeMillis() + 7 * 1000));
} }
//如果是手动上线,真实下线,发登录邮件 //如果是手动上线,真实下线,发登录邮件
if (0 == status && 1 == robot.getState()) { // if (0 == status && 1 == robot.getState()) {
String emailKey = BookBusinessConstants.EMAIL_SPAN_TIME + wxId; // String emailKey = BookBusinessConstants.EMAIL_SPAN_TIME + wxId;
String wxid = JedisClusterUtils.get(emailKey); // String wxid = JedisClusterUtils.get(emailKey);
if(wxid == null) { // if(wxid == null) {
ThreadPoolUtils.OTHER_THREAD_POOL.execute(() -> { // ThreadPoolUtils.OTHER_THREAD_POOL.execute(() -> {
LOGGER.info("发送登录二维码邮件===开始" + wxId); // LOGGER.info("发送登录二维码邮件===开始" + wxId);
wechatGroupConsr.sendQrcodeLoginEmail(wxId); // wechatGroupConsr.sendQrcodeLoginEmail(wxId);
LOGGER.info("发送登录二维码邮件===结束" + wxId); // LOGGER.info("发送登录二维码邮件===结束" + wxId);
}); // });
JedisClusterUtils.set(emailKey, wxId , 5 * 60); // JedisClusterUtils.set(emailKey, wxId , 5 * 60);
} // }
} // }
// 处理无响应的上线状态小号,更新为下线 // 处理无响应的上线状态小号,更新为下线
List<RobotClassifyDTO> allPcloudRobot = pcloudRobotDao.getAllPcloudRobot(); List<RobotClassifyDTO> allPcloudRobot = pcloudRobotDao.getAllPcloudRobot();
List<String> ids = allPcloudRobot.stream().filter(x -> 1 == x.getRealStatus()).map(RobotClassifyDTO::getWxId).collect(Collectors.toList()); List<String> ids = allPcloudRobot.stream().filter(x -> 1 == x.getRealStatus()).map(RobotClassifyDTO::getWxId).collect(Collectors.toList());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment