@@ 170-201 (lines=32) @@ | ||
167 | * @param int $priv |
|
168 | * @return array|bool |
|
169 | */ |
|
170 | public function Insert_Update($uid, $update, $priv) |
|
171 | { |
|
172 | global $xoopsUser, $xoopsDB; |
|
173 | $update = Smallworld_sanitize(htmlentities($update, ENT_QUOTES, 'UTF-8')); |
|
174 | $time = time(); |
|
175 | if (!isset($priv)) { |
|
176 | $priv = 0; |
|
177 | } |
|
178 | $query = 'SELECT msg_id,message FROM ' . $xoopsDB->prefix('smallworld_messages') . " WHERE uid_fk='" . $uid . "' ORDER BY msg_id DESC LIMIT 1"; |
|
179 | $result = $xoopsDB->queryF($query); |
|
180 | $row = $xoopsDB->fetchArray($result); |
|
181 | if ($update != $row['message']) { |
|
182 | $query = 'INSERT INTO ' . $xoopsDB->prefix('smallworld_messages') . " (message, uid_fk, priv, created) VALUES ('" . $update . "', '" . $uid . "', '" . $priv . "', '" . $time . "')"; |
|
183 | $result = $xoopsDB->queryF($query); |
|
184 | $newquery = 'SELECT M.msg_id, M.uid_fk, M.priv, M.message, M.created, U.username FROM ' . $xoopsDB->prefix('smallworld_messages') . ' M, ' . $xoopsDB->prefix('smallworld_user') . " U WHERE M.uid_fk=U.userid AND M.uid_fk='" . $uid . "' ORDER BY M.msg_id DESC LIMIT 1 "; |
|
185 | $result2 = $xoopsDB->queryF($newquery); |
|
186 | while ($row = $xoopsDB->fetchArray($result2)) { |
|
187 | $data[] = $row; |
|
188 | } |
|
189 | $count = $xoopsDB->getRowsNum($result2); |
|
190 | if ($count < 1) { |
|
191 | return false; |
|
192 | } else { |
|
193 | while ($row = $xoopsDB->fetchArray($result2)) { |
|
194 | $data[] = $row; |
|
195 | } |
|
196 | if (!empty($data)) { |
|
197 | return $data; |
|
198 | } |
|
199 | } |
|
200 | } |
|
201 | } |
|
202 | ||
203 | /** |
|
204 | * @Insert comment |
@@ 175-206 (lines=32) @@ | ||
172 | * @param int $priv |
|
173 | * @return array|bool |
|
174 | */ |
|
175 | public function Insert_Update($uid, $update, $priv) |
|
176 | { |
|
177 | global $xoopsUser, $xoopsDB; |
|
178 | $update = Smallworld_sanitize(htmlentities($update, ENT_QUOTES, 'UTF-8')); |
|
179 | $time = time(); |
|
180 | if (!isset($priv)) { |
|
181 | $priv = 0; |
|
182 | } |
|
183 | $query = 'SELECT msg_id,message FROM ' . $xoopsDB->prefix('smallworld_messages') . " WHERE uid_fk='" . $uid . "' ORDER BY msg_id DESC LIMIT 1"; |
|
184 | $result = $xoopsDB->queryF($query); |
|
185 | $row = $xoopsDB->fetchArray($result); |
|
186 | if ($update != $row['message']) { |
|
187 | $query = 'INSERT INTO ' . $xoopsDB->prefix('smallworld_messages') . " (message, uid_fk, priv, created) VALUES ('" . $update . "', '" . $uid . "', '" . $priv . "', '" . $time . "')"; |
|
188 | $result = $xoopsDB->queryF($query); |
|
189 | $newquery = 'SELECT M.msg_id, M.uid_fk, M.priv, M.message, M.created, U.username FROM ' . $xoopsDB->prefix('smallworld_messages') . ' M, ' . $xoopsDB->prefix('smallworld_user') . " U WHERE M.uid_fk=U.userid AND M.uid_fk='" . $uid . "' ORDER BY M.msg_id DESC LIMIT 1 "; |
|
190 | $result2 = $xoopsDB->queryF($newquery); |
|
191 | while ($row = $xoopsDB->fetchArray($result2)) { |
|
192 | $data[] = $row; |
|
193 | } |
|
194 | $count = $xoopsDB->getRowsNum($result2); |
|
195 | if ($count < 1) { |
|
196 | return false; |
|
197 | } else { |
|
198 | while ($row = $xoopsDB->fetchArray($result2)) { |
|
199 | $data[] = $row; |
|
200 | } |
|
201 | if (!empty($data)) { |
|
202 | return $data; |
|
203 | } |
|
204 | } |
|
205 | } |
|
206 | } |
|
207 | ||
208 | /** |
|
209 | * @Insert comment |