|
|
@@ -319,6 +319,10 @@ public class Controller extends BaseClass {
|
|
|
return dbConnect.runSqlQuery("select * from tenterprise_users where siteid='" + siteid + "' and tenterprise_userid in(" + where + ")").toRowsMap("tenterprise_userid");
|
|
|
}
|
|
|
|
|
|
+ public Row getMainUser(long tagentsid) {
|
|
|
+ return dbConnect.runSqlQuery("select * from tenterprise_users where siteid='" + siteid + "' and fisadministrator=1 and tagentsid=" + tagentsid).get(0);
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 获取用户账户余额
|
|
|
*
|
|
|
@@ -654,6 +658,18 @@ public class Controller extends BaseClass {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 发送系统消息
|
|
|
+ */
|
|
|
+ public void sendSystemWebSocketMessage(long userid, String message) {
|
|
|
+ JSONObject methodobject = new JSONObject();
|
|
|
+ methodobject.put("type", "remind");//提醒
|
|
|
+ methodobject.put("text", message);
|
|
|
+ for (WebClientSocket webClientSocket : parameter.websocketClients.get(userid).values()) {
|
|
|
+ webClientSocket.sendSystemMessage(methodobject);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
|
|
|
/**
|
|
|
* 生成系统消息
|
|
|
@@ -667,6 +683,7 @@ public class Controller extends BaseClass {
|
|
|
factory.addParameter("ftype", "系统");
|
|
|
factory.addParameter("fmessage", fmessage);
|
|
|
factory.addParameter("tenterprise_userid", userid);
|
|
|
+ sendSystemWebSocketMessage(userid, fmessage);
|
|
|
return dbConnect.runSqlUpdate(factory.getSQL());
|
|
|
}
|
|
|
|