增加推送

eladmin-system/src/main/java/me/zhengjie/base/websocket/AppPcBindSocketIo.java

@@ -33,11 +33,12 @@ public class AppPcBindSocketIo {
 	public final static String PREFIX_BUSINESS_NO = "business-no-";
 	@Autowired
 	RedisUtils redisUtils;
+
 	/**
 	 * 
 	 * @param businessNo
-	 * @param json 
-	 * @param time 时间单位秒
+	 * @param json
+	 * @param time       时间单位秒
 	 */
 	public void setBusinessNo(String businessNo, String json, long time) {
 		redisUtils.set(PREFIX_BUSINESS_NO + businessNo, json, time);
@@ -110,13 +111,20 @@ public class AppPcBindSocketIo {
 		if (StringUtils.isBlank(businessNo)) {
 			return;
 		}
-		//这里判断得到三个人
+		// 这里判断得到三个人
 		Set<String> notarys = getBindNotary(businessNo);
 		if (CollectionUtils.isEmpty(notarys)) {
 			// 直接删除这条数据
 			delBusinessNo(businessNo);
 			// TDOO 发送给app。取消了视频通话
-			log.info("推送给app消息{}",businessNo);
+			log.info("推送给app消息{}", businessNo);
+			sendAppMsg(businessNo);
+		}
+		if (notarys.size() == 1 && notarys.contains(username)) {
+			// 直接删除这条数据
+			delBusinessNo(businessNo);
+			// TDOO 发送给app。取消了视频通话
+			log.info("推送给app消息 {} 当前公证员 {}", businessNo,username);
 			sendAppMsg(businessNo);
 		} else {
 			notarys.remove(username);
@@ -154,7 +162,7 @@ public class AppPcBindSocketIo {
 					businessNo = key;
 			}
 		}
-		log.info("app失去连接：{} ",businessNo);
+		log.info("app失去连接：{} ", businessNo);
 		removeNotary(getBindNo(businessNo), notary);
 //		String key = (String) redisUtils.get(PREFIX_BUSINESS_NO + businessNo);
 //		JSONArray json = JSON.parseArray((String) redisUtils.get(key));