Skip to content

C
Compass
Commit d3847920 by biao
Options

1

parent a1efc47f
Showing with 193 additions and 80 deletions
src/user/if/ajax_get_user_message.php 0 → 100644
<?php
// 获取用户消息列表
require_once ("../user_include.inc");
ErrorLogger::doOutput("Compass...ajax_get_user_message.php....Start.", 0);
//获取参数
$unionId = ParamUtil::getRequestString("unionId");
$readFlg = ParamUtil::getRequestNumber("readFlg", 0);
$page = ParamUtil::getRequestNumber("page", 0);
//参数检查
if(empty($unionId) || ($readFlg <> 0 && $readFlg <> 1 && $readFlg <> 2)) {
$result["message"] = "参数错误！";
responseNG($result);
}
$result = array();
//判断用户是否存在
$param = array();
$param['unionid'] = $unionId;
$param['delete_flg'] = false;
$userList = UserMst::getList($param,'id','desc', 0, 1);
if(empty($userList)) {
$result["message"] = "用户不存在！";
responseNG($result);
}
$userId = $userList[0]->id;
//获取用户消息列表
$rowCount = 10;
$offset = $page * $rowCount;
$param = array();
$param['user_id'] = $userId;
if($readFlg == 1) {
$param['is_read'] = false;
}
if($readFlg == 2) {
$param['is_read'] = true;
}
$param['delete_flg'] = false;
$userMessageList = UserMessageDat::getList($param,'id','desc', $offset, $rowCount);
$allCount = UserMessageDat::getListCount($param);
//接口返回数据
$result["allCount"] = $allCount;
$result["page"] = $page;
$result["rowCount"] = $rowCount;
$result["list"] = $userMessageList;
ErrorLogger::doOutput("Compass...ajax_get_user_message.php....End.", 0);
//返回结果
responseOK($result);
function responseNG($result) {
$result = array("status"=>"NG", "result"=>$result);
print json_encode($result);
exit;
}
function responseOK($result) {
$result = array("status"=>"OK", "result"=>$result);
print json_encode($result);
exit;
}
?>
\ No newline at end of file
src/user/if/ajax_get_user_message_count.php 0 → 100644
<?php
// 获取用户消息数量
require_once ("../user_include.inc");
ErrorLogger::doOutput("Compass...ajax_get_user_message_count.php....Start.", 0);
//获取参数
$unionId = ParamUtil::getRequestString("unionId");
$readFlg = ParamUtil::getRequestNumber("readFlg", 0);
//参数检查
if(empty($unionId) || ($readFlg <> 0 && $readFlg <> 1 && $readFlg <> 2)) {
$result["message"] = "参数错误！";
responseNG($result);
}
$result = array();
//判断用户是否存在
$param = array();
$param['unionid'] = $unionId;
$param['delete_flg'] = false;
$userList = UserMst::getList($param,'id','desc', 0, 1);
if(empty($userList)) {
$result["message"] = "用户不存在！";
responseNG($result);
}
$userId = $userList[0]->id;
//获取用户消息列表
$param = array();
$param['user_id'] = $userId;
if($readFlg == 1) {
$param['is_read'] = false;
}
if($readFlg == 2) {
$param['is_read'] = true;
}
$param['delete_flg'] = false;
$allCount = UserMessageDat::getListCount($param);
//接口返回数据
$result["allCount"] = $allCount;
ErrorLogger::doOutput("Compass...ajax_get_user_message_count.php....End.", 0);
//返回结果
responseOK($result);
function responseNG($result) {
$result = array("status"=>"NG", "result"=>$result);
print json_encode($result);
exit;
}
function responseOK($result) {
$result = array("status"=>"OK", "result"=>$result);
print json_encode($result);
exit;
}
?>
\ No newline at end of file
src/user/if/ajax_set_user_message_read.php 0 → 100644
<?php
// 修改用户的未读消息为已读状态
require_once ("../user_include.inc");
ErrorLogger::doOutput("Compass...ajax_set_user_message_read.php....Start.", 0);
//获取参数
$unionId = ParamUtil::getRequestString("unionId");
$messageId = ParamUtil::getRequestNumber("messageId");
//参数检查
if(empty($unionId) || empty($messageId)) {
$result["message"] = "参数错误！";
responseNG($result);
}
//检索用户是否存在
$param['unionid'] = $unionId;
$param['delete_flg'] = false;
$userList = UserMst::getList($param,'id','desc', 0, 1);
if(empty($userList)) {
$result["message"] = "用户不存在！";
responseNG($result);
}
$userId = $userList[0]->id;
//查询消息数据
$param = array();
$param['user_id'] = $userId;
$param['is_read'] = false;
$param['id'] = $messageId;
$param['delete_flg'] = false;
$userMessageList = UserMessageDat::getList($param,'id','desc', 0, 1);
//更新
if(!empty($userMessageList)) {
$userMessageList[0]->is_read = true;
$userMessageList[0]->save();
}
ErrorLogger::doOutput("Compass...ajax_set_user_message_read.php....End.", 0);
//返回结果
$result["message"] = "更新成功！";
responseOK($result);
function responseNG($result) {
$result = array("status"=>"NG", "result"=>$result);
print json_encode($result);
exit;
}
function responseOK($result) {
$result = array("status"=>"OK", "result"=>$result);
print json_encode($result);
exit;
}
?>
\ No newline at end of file
src/user/if/ajax_user_sign.php deleted 100644 → 0
<?php
// 提交用户签到结果
require_once ("../user_include.inc");
ErrorLogger::doOutput("Koala...ajax_user_sign.php....Start.", 0);
//文章ID
$article_id = ParamUtil::getRequestNumber("article_id", 0);
$ta = new TemplateAction();
if(!$ta->isLogin()) {
responseNG("请先登录！");
}
//判断当天是否已经签到
$param = array();
$param["object_date"] = date("Y-m-d");
$param["user_id"] = $ta->user->id;
$param["delete_flg"] = false;
$sign_count = UserSignDat::getListCount($param);
if($sign_count >= 1) {
responseNG("今天已经签到，请明天再来！");
}
//用户加点
$point_left = 0;
$add_point = rand(1, 10);
ErrorLogger::doOutput("Koala...ajax_user_sign.php....point_left=" . $point_left, 0);
ErrorLogger::doOutput("Koala...ajax_user_sign.php....add_point=" . $add_point, 0);
//签到操作
$user_sign_dat = new UserSignDat();
$user_sign_dat->object_date = date("Y-m-d");
$user_sign_dat->user_id = $ta->user->id;
$user_sign_dat->point = $add_point;
$user_sign_dat->article_id = $article_id;
$user_sign_dat->save();
//查找最后一条记录
$param = array();
$param["user_id"] = $ta->user->id;
$last_log_list = UserPointLog::getList($param, "id", "desc", 0, 1);
if(!empty($last_log_list)) {
$point_left = $last_log_list[0]->point_left;
}
//添加一条新的记录
$user_point_log = new UserPointLog();
$user_point_log->user_id = $ta->user->id;
$user_point_log->action_type = 2;//签到
$user_point_log->point = $add_point;
$user_point_log->point_left = $point_left + $add_point;
$user_point_log->status = "SUCCESS";
$user_point_log->save();
//更新用户表的point字段值
$ta->user->point = $user_point_log->point_left;
$ta->user->save();
ErrorLogger::doOutput("Koala...ajax_user_sign.php....End.", 0);
responseOK("签到成功！获得" . $add_point . "积分！");
function responseNG($message) {
$result = array("status"=>"NG", "message"=>$message);
header("Access-Control-Allow-Origin: *");
print json_encode($result);
exit;
}
function responseOK($message) {
$result = array("status"=>"OK", "message"=>$message);
header("Access-Control-Allow-Origin: *");
print json_encode($result);
exit;
}
?>
\ No newline at end of file
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