hy-farm/muchang/backend/controllers/MessageController.php

<?php
/**
 * Created by PhpStorm.
 * User: zn
 * Date: 2017/6/21
 * Time: 10:10
 */

namespace app\controllers;

use common\models\UserLog;
use common\modules\qixunpay\vo\Pay;
use common\modules\rebate\Rebate;
use common\modules\rebate\UserRebate;
use app\utils\InfoUtil;
use common\models\User;
use common\models\UserBroadcastMessage;
use common\services\BackMessageServices;
use common\services\ResultStatusServices;
use common\utils\CommUtil;
use common\utils\EnumUtil;
use common\utils\RedisKeyUtil;
use Symfony\Bridge\PsrHttpMessage\Tests\Fixtures\Message;
use Yii;
use yii\data\Pagination;
use yii\web\Controller;

/**
 * 小喇叭消息
 * Class MessageController
 * @package app\controllers
 */
class MessageController extends Controller
{
    public function actionMessageList()
    {
       $complete = Yii::$app->request->get('complete');
        $endTime = Yii::$app->request->get('end_time');
        $user_id = (int)Yii::$app->request->get('user_id');
        $type=27;
        $current_page = (int)Yii::$app->request->get('page');
        $sort = Yii::$app->request->get('sort');

        $find = UserLog::find();
      $find->andWhere(['=', 'type',27]);
        //if (!empty($user_id)) $find->andWhere(['=', 'user_id', $user_id]);
        //if (!empty($complete)) $find->andWhere(['=', 'complete', $complete]);
       // if (!empty($startTime)) $find->andWhere(['>=', 'created_at',  date_create($startTime)->getTimestamp()+3600*24]);
        //if (!empty($endTime)) $find->andWhere(['<=', 'created_at',  date_create($endTime)->getTimestamp()+3600*24]);


        $total = $find->count();

        $per_page = 12;
        $last_page = ceil($total / $per_page);

        $find->offset($per_page * ($current_page - 1))->limit($per_page);

      $find->addOrderBy(["id" => "desc"]);
        $dbList = $find->all();
        $list = [];
      
        foreach ($dbList as $item) {
            $itemData = $item->toArray();
            $itemData['created_time'] = CommUtil::formatDate($item->created_at);
          $user = User::findById($item->user_id);
          $itemData['num']= $item->num.'元'.'，实际提现'.($item->num*0.95).'元';
          if($item->status ==0){
            $itemData['pass']='等待审核';
          }elseif($item->status ==1){
            $itemData['pass']='审核通过';
          }else{
            $itemData['pass']='拒绝提现';
          }
          $itemData['zfb']= $user->zfb;
           $itemData['realname']= $user->realname;
            array_push($list, $itemData);
        }

        $returnData['data'] = $list;
        $returnData['total'] = $total;
        $returnData['per_page'] = $per_page;
        $returnData['current_page'] = $current_page;
        $returnData['last_page'] = $last_page;
      //var_dump($returnData);
        return BackMessageServices::sendMessage(ResultStatusServices::RS_OPERATION_SUCCESS, $returnData);
      exit;
        $user_id = (int)Yii::$app->request->get('user_id');
        $type=Yii::$app->request->get('type');
        $current_page = (int)Yii::$app->request->get('page');
        $sort = Yii::$app->request->get('sort');

        $find = UserBroadcastMessage::find();
        if (!empty($user_Id)) $find->andWhere(['=', $user_Id]);
        if (!empty($type)) $find->andWhere(['=',  $type]);

        $total = $find->count();

        $per_page = 12;
        $last_page = ceil($total / $per_page);

        $find->offset($per_page * ($current_page - 1))->limit($per_page);

        if (!empty($sort)) {
            list($field, $sortType) = explode("|", $sort);
            if (!empty($field) && !empty($sortType)) {
                $type = SORT_ASC;
                if ($sortType == 'desc') $type = SORT_DESC;
                $find->addOrderBy([$field => $type]);
            }
        }

        $dbList = $find->all();
        $list = [];
        foreach ($dbList as $item) {
            $itemData = $item->toArray();
            $itemData['update_time'] = CommUtil::formatDate($item->updated_at);
            $itemData['created_time'] = CommUtil::formatDate($item->created_at);
            array_push($list, $itemData);
        }

        $returnData['data'] = $list;
        $returnData['total'] = $total;
        $returnData['per_page'] = $per_page;
        $returnData['current_page'] = $current_page;
        $returnData['last_page'] = $last_page;
        return BackMessageServices::sendMessage(ResultStatusServices::RS_OPERATION_SUCCESS, $returnData);
    }

    /**
     * 审核消息
     */
    public function actionMessageEdit()
    {
        $id = Yii::$app->request->get('id');
        $type = Yii::$app->request->get('type');
        if (empty($id))return BackMessageServices::sendMessage(ResultStatusServices::RS_PARAM_ERROR);
        if (!in_array($type, EnumUtil::VERIFY_LIST) || $type == EnumUtil::VERIFY_WAIT) return BackMessageServices::sendMessage(ResultStatusServices::RS_PARAM_ERROR);

        $message = UserLog::findByID($id);
        if (empty($message))return BackMessageServices::sendMessage(ResultStatusServices::RS_PARAM_ERROR);
        if ($message->status != EnumUtil::VERIFY_WAIT)return BackMessageServices::sendMessage(ResultStatusServices::RS_PARAM_ERROR);
        $message->status = $type;
        $message->updated_at = time();
        if (!$message->save()) return BackMessageServices::sendMessage(ResultStatusServices::RS_PARAM_ERROR);
        if ($type == EnumUtil::VERIFY_PASS) {
            //添加到广播列表
//            MessageServices::addBroadcaseMessage(SocketEnum::COMMAND_ALL_SUONA_MESSAGE_R, $message->genClientData());
            Yii::$app->redis->setex(RedisKeyUtil::addBroadcaseMessageKey($message->id), 60 * 3, json_encode($message->toArray()));
        }
        return BackMessageServices::sendMessage(ResultStatusServices::RS_OPERATION_SUCCESS);
    }

    /**
     * 批量处理
     */
    public function actionDoList()
    {
        $idListStr = Yii::$app->request->get('id_list_str');
        $type = Yii::$app->request->get('type');

        if (!isset($idListStr)) return InfoUtil::Info($this, 'ID错误');

        if (!in_array($type, EnumUtil::VERIFY_LIST) || $type == EnumUtil::VERIFY_WAIT) return InfoUtil::Info($this, '操作类型错误');

        $list1 = explode(',', $idListStr);
        if (count($list1) == 0) return InfoUtil::Info($this, 'id错误');

        foreach ($list1 as $id) {
            $message = UserBroadcastMessage::findByID($id);
            if (empty($message) || $message->pass != EnumUtil::VERIFY_WAIT) continue;

            $message->pass = $type;

            if (!$message->save()) return InfoUtil::Info($this, '保存错误');

            if ($type == EnumUtil::VERIFY_PASS) {
                //添加到广播列表
//                MessageServices::addBroadcaseMessage(SocketEnum::COMMAND_ALL_SUONA_MESSAGE_R, $message->genClientData());
                Yii::$app->redis->setex(RedisKeyUtil::addBroadcaseMessageKey($message->id), 60 * 3, json_encode($message->toArray()));
            }
        }

        return InfoUtil::Info($this, '操作成功');
    }
}