myProject/application/master/logic/Subject.php

<?php
/**
 * Created by PhpStorm.
 * User: qisse
 * Date: 2017/6/27
 * Time: 20:02
 */

namespace app\master\logic;
use app\core\exception\AppException;
use app\core\model\Fang;
use app\core\model\InterestType;
use app\core\model\SubjectStat;
use app\core\model\SubjectType;
use app\core\model\Subject as Model;
use app\core\model\User;
use app\core\model\Cang;
use app\core\model\UserBank;
use app\core\model\UserHongbao;
use app\core\service\Finance as FinanceService;
use think\Db;
use think\Exception;
use think\Log;
use tool\Common;

class Subject extends Base
{
    /**
     * @api {post} subject/getSubjectTypeList 得到产品类型列表
     * @apiVersion 1.0.0
     * @apiName getSubjectTypeList
     * @apiDescription 得到产品类型列表
     * @apiGroup Subject
     *
     * @apiSuccess {Object[]} subjectTypeList 产品类型列表
     * @apiSuccess {Number} subjectTypeList.subjectTypeID 产品类型ID
     * @apiSuccess {String} subjectTypeList.name 产品名称
     * @apiSuccessExample {json} 返回json数据（举例）:
    {
    "code": 1,
    "msg": "操作成功",
    "content": {
    "subjectTypeList": [
    {
    "subjectTypeID":1,
    "name":"满标计息"
    }
    ]
    }
    }
     * @apiUse CreateUserError
     */
    public function getSubjectTypeList() {
        $subjectTypeList = SubjectType::all();
        return Common::rm(1, '操作成功', [
            'subjectTypeList'=>$subjectTypeList
        ]);
    }

    /**
     * @api {post} subject/getInterestTypeList 得到计息类型列表
     * @apiVersion 1.0.0
     * @apiName getInterestTypeList
     * @apiDescription 得到计息类型列表
     * @apiGroup Subject
     *
     * @apiSuccess {Object[]} interestTypeList 计息类型列表
     * @apiSuccess {Number} interestTypeList.interestTypeID 计息类型ID
     * @apiSuccess {String} interestTypeList.name 计息类型名称
     *
     * @apiSuccessExample {json} 返回json数据（举例）:
    {
    "code": 1,
    "msg": "操作成功",
    "content": {
    "interestTypeList": [
    {
    "interestTypeID": 1,
    "name": "一次付本息"
    }
    ]
    }
    }
     * @apiUse CreateUserError
     */
    public function getInterestTypeList() {
        $interestTypeList = InterestType::all();
        return Common::rm(1, '操作成功', [
            'interestTypeList'=>$interestTypeList
        ]);
    }

    /**
     * @api {post} subject/getStatusList 得到产品状态列表
     * @apiVersion 1.0.0
     * @apiName getStatusList
     * @apiDescription 得到产品状态列表
     * @apiGroup Subject
     *
     *
     * @apiSuccess {Object[]} statusList 状态列表
     * @apiSuccess {Number} statusList.status 状态ID
     * @apiSuccess {String} statusList.statusText 状态名称
     * @apiSuccessExample {json} 返回json数据（举例）:
    {
    "code": 1,
    "msg": "操作成功",
    "content": {
    "statusList": [
    {
    "status":1,
    "statusText":"注册"
    }
    ]
    }
    }
     * @apiUse CreateUserError
     */
    public function getStatusList() {
        $statusList = Model::STATUSS;
        return Common::rm(1, '操作成功', [
            'statusList'=>$statusList
        ]);
    }

    /**
     * @api {post} subject/getStatusLoanList 得到产品放款状态列表
     * @apiVersion 1.0.0
     * @apiName getStatusLoanList
     * @apiDescription 得到产品放款状态列表
     * @apiGroup Subject
     *
     * @apiSuccess {Object[]} statusLoanList 放款状态列表
     * @apiSuccess {Number} statusLoanList.statusLoan 放款状态ID
     * @apiSuccess {String} statusLoanList.statusLoanText 放款状态名称
     * @apiSuccessExample {json} 返回json数据（举例）:
    {
    "code": 1,
    "msg": "操作成功",
    "content": {
    "statusLoanList": [
    {
    "statusLoan":1,
    "statusLoanText":"已放款"
    }
    ]
    }
    }
     * @apiUse CreateUserError
     */
    public function getStatusLoanList() {
        $statusLoanList = Model::STATUS_LOANS;
        return Common::rm(1, '操作成功', [
            'statusLoanList'=>$statusLoanList
        ]);
    }

    /**
     * @api {post} subject/getSubjectList 条件得到产品列表
     * @apiVersion 1.0.0
     * @apiName getSubjectList
     * @apiDescription 条件得到产品列表
     * @apiGroup Subject
     *
     * @apiParam {String} [overTimeFrom] 到期时间范围开始
     * @apiParam {String} [overTimeTo] 到期时间范围结束
     * @apiParam {Number} [status] 产品状态，为0为全部状态
     * @apiParam {Number} [statusLoan] 放款状态，为0为全部状态
     * @apiParam {Number} [pageIndex=1] 页码，从1开始
     * @apiParam {Number} [pageItemCount=10] 每页条数
     * @apiParam {String} [keyword] 关键字
     * @apiParamExample {json} 发送报文:
    {
    "overTimeFrom": "2016-12-20",
    "overTimeTo": "2018-12-20",
    "status": 0,
    "statusLoan": 0,
    "pageIndex": 1
    }
     *
     * @apiSuccess {Object[]} subjectList 产品列表
     * @apiSuccess {Number} subjectList.subjectID 产品ID
     * @apiSuccess {Number} subjectList.term 投标期数
     * @apiSuccess {String} subjectList.title 标题
     * @apiSuccess {String} subjectList.price 总金额
     * @apiSuccess {String} subjectList.year 年化
     * @apiSuccess {String} subjectList.basePrice 起投金额
     * @apiSuccess {String} subjectList.addTime 产品添加时间
     * @apiSuccess {String} subjectList.updateTime 更新时间
     * @apiSuccess {String} subjectList.baseMaxPrice 最大投资额
     * @apiSuccess {String} subjectList.overTime 产品到期时间，新增时为必传字段，更新时无效
     * @apiSuccess {String} subjectList.fullTime 满标时间
     * @apiSuccess {String} subjectList.overTime 产品到期时间
     * @apiSuccess {String} subjectList.repayTime 还款时间
     * @apiSuccess {String} subjectList.reachTime 到账时间
     * @apiSuccess {String} subjectList.status 产品状态,
     * @apiSuccess {String} subjectList.statusText 产品状态描述
     * @apiSuccess {String} subjectList.statusLoan 放款状态,
     * @apiSuccess {String} subjectList.statusLoanText 放款状态描述
     * @apiSuccess {Object} subjectList.subjectType 项目类型
     * @apiSuccess {Number} subjectList.subjectType.subjectTypeID 新手理财ID
     * @apiSuccess {String} subjectList.subjectType.name 名称
     * @apiSuccess {Object} subjectList.interestType 计息类型
     * @apiSuccess {Number} subjectList.interestType.interestTypeID 计息类型ID
     * @apiSuccess {String} subjectList.interestType.name 名称
     * @apiSuccess {Object} subjectList.interestTimeType 计息时间类型
     * @apiSuccess {Number} subjectList.interestTimeType.interestTypeID 计息时间类型ID
     * @apiSuccess {String} subjectList.interestTimeType.name 名称
     * @apiSuccess {Number} subjectList.isIndexApp 是否为app首页
     * @apiSuccess {Number} subjectList.isIndexPc 是否为PC首页
     * @apiSuccess {Number} subjectList.loanID 借款ID
     * @apiSuccess {Object} subjectList.subjectStat 投资统计
     * @apiSuccess {String} subjectList.subjectStat.moneyTotalInvest 总共已投资
     * @apiSuccess {Number} subjectList.subjectStat.timesInvest 已投资次数
     * @apiSuccess {Number} count 查询到条目总数
     * @apiSuccess {Number} pageItemCount 每页条数
     * @apiSuccessExample {json} 返回json数据（举例）:
    {
    "code": 1,
    "msg": "操作成功",
    "content": {
    "subjectList": [
    {
    "subjectID": 33,
    "term": 15,
    "title": "新手标4567",
    "price": "100000.00",
    "year": "12.00",
    "basePrice": "1000.00",
    "baseMaxPrice": "100000.00",
    "addTime": "2017-12-18 17:38:30",
    "updateTime": "2017-12-18 19:24:41",
    "isIndexApp": 1,
    "isIndexPc": 0,
    "status": 2,
    "alias": "20171218173830mlh3vY",
    "loanID": 0,
    "hongbao": 0,
    "overTime": "2018-01-02",
    "fullTime": "2015-01-01 22:33:33",
    "statusLoan": 1,
    "subjectType": {
    "subjectTypeID": 1,
    "name": "新手理财"
    },
    "interestType": {
    "interestTypeID": 1,
    "name": "一次性还本付息"
    },
    "interestTimeType": {
    "interestTimeTypeID": 1,
    "name": "满标计息"
    },
    "subjectStat": {
    "moneyTotalInvest": "0.00",
    "timesInvest": 0
    },
    "statusText": "发布审核中",
    "repayTime": "2018-01-02",
    "reachTime": "2018-01-03",
    "statusLoanText": "未到放款时间"
    }
    ],
    "count": 18,
    "pageItemCount": 10
    }
    }
     * @apiUse CreateUserError
     */
    public function getSubjectList() {
        $map = [];
        if( isset($this->app['overTimeTo']) &&
            isset($this->app['overTimeFrom'])) {
            $map['overTime'] = ['between time', [$this->app['overTimeFrom'],$this->app['overTimeTo']]];
        }
        /*if($this->app['repayTimeFrom'] && $this->app['repayTimeTo']) {
            $map['repayTime'] = ['between', [$this->app['repayTimeFrom'],$this->app['repayTimeTo']]];
        }
        if($this->app['repayTimeFrom'] && $this->app['repayTimeTo']) {
            $map['repayTime'] = ['between', [$this->app['repayTimeFrom'],$this->app['repayTimeTo']]];
        }*/
        if(isset($this->app['subjectTypeID']) && $this->app['subjectTypeID']) {
            $map['subjectTypeID'] = $this->app['subjectTypeID'];
        }
        if(isset($this->app['status']) && $this->app['status']) {
            $map['status'] = $this->app['status'];
        }

        if(isset($this->app['statusLoan']) && $this->app['statusLoan']) {
            $map['statusLoan'] = $this->app['statusLoan'];
        }

        if(isset($this->app['keyword']) && $this->app['keyword']) {
            $map['title'] = ['like', '%'.$this->app['keyword'].'%'];
        }

        if(!isset($this->app['pageIndex']) || !$this->app['pageIndex']) {
            $this->app['pageIndex'] = 1;
        }

        if(!isset($this->app['pageItemCount']) || !$this->app['pageItemCount']) {
            $this->app['pageItemCount'] = 10;
        }
        $count = Model::where($map)->count();
        $list = Model::with(['subjectType','interestType','interestTimeType','subjectStat', 'cangList'=>function($query){
            $query->where('isForged', 0);
        }])->where($map)->limit(($this->app['pageIndex'] - 1) * $this->app['pageItemCount'], $this->app['pageItemCount'])->order('listOrder desc,isShow desc,addTime desc')->select();
        if($list->isEmpty()) {
            return Common::rm(-2, '数据为空');
        }
        $list->append(['statusText','repayTime','reachTime','statusLoanText'])->hidden(['multiplePrice','operation','yearSystem','beginTime','endTime','subjectTypeID','interestTypeID','interestTimeTypeID',
            'subjectStat'=>[
                'subjectID','subjectStatID'
            ]
        ]);

        foreach ($list as $k=>$item) {
            $list[$k]['fangTotal'] = 0;
            foreach ($list[$k]['cangList'] as $_k=>$_item) {
                $list[$k]['fangTotal'] += $_item['moneySubject'];
            }
        }


        //得到余额
        $finance = new FinanceService();
        $result = $finance->balance($msg, '15825631526');

        return Common::rm(1, '操作成功', [
            'subjectList'=>$list,
            'count'=>$count,
            'moneyFang'=>$result['money'],
            'pageItemCount'=>$this->app['pageItemCount']
        ]);
    }

    /**
     * @api {post} subject/getDetail 得到产品详细
     * @apiVersion 1.0.0
     * @apiName getDetail
     * @apiDescription 得到产品详细，返回参数释义请参照产品列表
     * @apiGroup Subject
     *
     * @apiParam {Number} subjectID 产品ID
     * @apiParamExample {json} 发送报文:
    {
    "subjectID": 12
    }
     *
     * @apiSuccessExample {json} 返回json数据（举例）:
    {
    "code": 1,
    "msg": "操作成功",
    "content": {
    "detail": {
    "term": 15,
    "title": "新手标4567",
    "price": "100000.00",
    "year": "12.00",
    "basePrice": "1000.00",
    "baseMaxPrice": "100000.00",
    "addTime": "2017-12-18 17:38:30",
    "updateTime": "2017-12-20 15:25:24",
    "isIndexApp": 1,
    "isIndexPc": 0,
    "status": 3,
    "alias": "20171218173830mlh3vY",
    "loanID": 0,
    "overTime": "2018-01-02",
    "statusLoan": 1,
    "subjectType": {
    "subjectTypeID": 1,
    "name": "新手理财"
    },
    "interestType": {
    "interestTypeID": 1,
    "name": "一次性还本付息"
    },
    "interestTimeType": {
    "interestTimeTypeID": 1,
    "name": "一次性还本付息"
    },
    "subjectStat": {
    "moneyTotalInvest": "0.00",
    "timesInvest": 0
    },
    "statusText": "抢购中",
    "repayTime": "2018-01-02"
    }
    }
    }
     * @apiUse CreateUserError
     */
    public function getDetail() {
        $item = $this->getItem();
        if(!$item) {
            return Common::rm(-2, '没有数据');
        }
        $item->hidden(['operation','fullTime','hongbao','multiplePrice','yearSystem','beginTime','endTime']);
        return Common::rm(1, '操作成功', [
            'detail'=>$item
        ]);
    }

    /**
     * @api {post} subject/update 新增/更新产品统一接口
     * @apiVersion 1.0.0
     * @apiName update
     * @apiDescription 新增/更新产品统一接口
     * @apiGroup Subject
     *
     * @apiParam {Number} subjectID 产品类型ID，更新时为必传字段，新增时保持subjectID必须为0
     * @apiParam {Number} subjectTypeID 产品类型ID，新增时为必传字段，更新时无效
     * @apiParam {Number} interestTypeID 计息类型ID，新增时为必传字段，更新时无效
     * @apiParam {Number} term 投标期数，新增时为必传字段，更新时无效
     * @apiParam {String} title 标题
     * @apiParam {String} price 总金额，新增时为必传字段，更新时无效
     * @apiParam {String} year 年化，新增时为必传字段，更新时无效
     * @apiParam {String} basePrice 起投金额
     * @apiParam {String} baseMaxPrice 最大投资额
     * @apiParam {String} overTime 产品到期时间，新增时为必传字段，更新时无效
     * @apiParam {Number} isIndexApp 是否为app首页
     * @apiParam {Number} isIndexPc 是否为PC首页
     * @apiParam {Number} loanID 借款ID，新增时为必传字段，更新时无效
     * @apiParamExample {json} 发送报文:
    {
    "subjectID": 2,
    "subjectTypeID": 12,
    "interestTypeID": 13,
    "term": 120,
    "year": "12.8",
    "price": "100000.00",
    "basePrice": "100.00",
    "baseMaxPrice": "100000.00",
    "overTime": "2014-10-10",
    "isIndexApp": 1,
    "isIndexPc": 1,
    "loanID": 12
    }
     *
     * @apiSuccess {Number} subjectID 更新产品ID
     * @apiSuccessExample {json} 返回json数据（举例）:
    {
    "code": 1,
    "msg": "操作成功",
    "content": {
    "subjectID": 12
    }
    }
     * @apiUse CreateUserError
     */
    public function update()
    {
        if(!isset($this->app['subjectID']) ||!$this->app['subjectID']) {
            $model = Model::create([
                'subjectTypeID' => $this->app['subjectTypeID'],
                'interestTypeID' => $this->app['interestTypeID'],
                'interestTimeTypeID'=> Model::getDefaultInterestTimeType(),
                'term' => $this->app['term'],
                'title' => $this->app['title'],
                'price'=>$this->app['price'],
                'year' => $this->app['year'],
                /*'yearSystem' => $this->app['yearSystem'],*/
                'basePrice'=> $this->app['basePrice'],
                /*'baseMaxPrice' => $this->app['baseMaxPrice'],*/
                'baseMaxPrice' => $this->app['price'],
                'isShow' => 1,
                'releaseTime' => Common::datetotime($this->app['releaseTime']),
                /*'multiplePrice' => isset($this->app['multiplePrice']) ? $this->app['multiplePrice'] : 0,*/
                /*'beginTime'=>Common::datetotime($this->app['beginTime']),
                'endTime' => Common::datetotime($this->app['endTime']),*/
                /*'repayBenTime' => Common::datetotime($this->app['repayTime']),
                'repayInterestTime' => $this->app['interestTypeID'] == 2 ? 0 : Common::datetotime($this->app['repayTime']),*/
                'overTime' => Common::datetotime(Common::timetodate(Common::datetotime($this->app['releaseTime']) + $this->app['term'] * 86400, 0)),
                'isIndexApp'=>$this->app['isIndexApp'],
                'isIndexPc'=>$this->app['isIndexPc'],
                'status'=>Model::STATUS_ONLINE_CHECK,
                'alias'=>Model::createAlias(),
                'loanID'=>$this->app['loanID'],
                'statusLoan'=>1
            ]);

            SubjectStat::create([
                'subjectID' => $model['subjectID']
            ]);
        }
        else {
            $model = Model::update([
                'title' => $this->app['title'],
                'basePrice'=> $this->app['basePrice'],
                'baseMaxPrice' => $this->app['baseMaxPrice'],
                'isIndexApp'=>$this->app['isIndexApp'],
                'isIndexPc'=>$this->app['isIndexPc'],
                'loanID'=>$this->app['loanID'],
                'releaseTime' => Common::datetotime($this->app['releaseTime']),
                'overTime' => Common::datetotime(Common::timetodate(Common::datetotime($this->app['releaseTime']) + $this->app['term'] * 86400, 0)),
            ], [
                'subjectID'=>$this->app['subjectID']
            ]);
            $model['subjectID'] = $this->app['subjectID'];
        }

        return Common::rm(1, '操作成功', [
            'subjectID'=>$model['subjectID']
        ]);
    }

    public function getList() {
        $map = [];
        if($this->app['addTimeFrom'] && $this->app['addTimeTo']) {
            $map['addTime'] = ['between', [$this->app['addTimeFrom'],$this->app['addTimeTo']]];
        }
        if($this->app['repayTimeFrom'] && $this->app['repayTimeTo']) {
            $map['repayTime'] = ['between', [$this->app['repayTimeFrom'],$this->app['repayTimeTo']]];
        }
        if($this->app['repayTimeFrom'] && $this->app['repayTimeTo']) {
            $map['repayTime'] = ['between', [$this->app['repayTimeFrom'],$this->app['repayTimeTo']]];
        }
        if($this->app['subjectTypeID']) {
            $map['subjectTypeID'] = $this->app['subjectTypeID'];
        }
        if($this->app['status']) {
            $map['status'] = $this->app['status'];
        }

        $list = Model::with('subjectType,interestType,interestTimeType,subjectStat')->where($map)->order('addTime desc')->select();
        if($list->isEmpty()) {
            return Common::rm(-2, '数据为空');
        }
        $list->append(['statusText','repayTime','reachTime'])->hidden(['subjectID','subjectTypeID','interestTypeID','interestTimeTypeID',
            'subjectStat'=>[
                'subjectID','subjectStatID'
            ]
        ]);

        return Common::rm(1, '操作成功', [
            'list'=>$list
        ]);
    }

    /**
     * @api {post} subject/actionOnline A - 发布通过审核上线
     * @apiVersion 1.0.0
     * @apiName actionOnline
     * @apiDescription 发布通过审核上线
     * @apiGroup Subject
     *
     * @apiParam {Number} subjectID 产品ID
     * @apiParamExample {json} 发送报文:
    {
    "subjectID": 12
    }
     *
     * @apiSuccess {Number} subjectID 更新产品ID
     * @apiSuccessExample {json} 返回json数据（举例）:
    {
    "code": 1,
    "msg": "操作成功",
    "content": {
    "status": 1,
    "statusText": "正在审核"
    }
    }
     * @apiUse CreateUserError
     */
    /*public function actionOnline() {
        $item = $this->getItem();
        if($item['releaseTime'] == (Common::datetotime(Common::timetodate(THINK_START_TIME, 0)) + 86400)) {
            return Common::rm(-4, '不能人工发布第二天及第二天之后的标');
        }
        if(!$item) {
            return Common::rm(-2, '没有数据');
        }
        if($item['status'] != 2) {
            return Common::rm(-3, '不是可以进行的状态，当前状态'.$item['statusText']);
        }
        $item['status'] = Model::STATUS_ONLINE;
        $item->save();

        return Common::rm(1, '操作成功', [
            'detail'=>$item->append(['statusText'])->visible(['status'])
        ]);
    }*/

    /**
     * @api {post} subject/actionDelete 删除条目
     * @apiVersion 1.0.0
     * @apiName actionDelete
     * @apiDescription 删除条目
     * @apiGroup Subject
     *
     * @apiParam {Number} subjectID 产品ID
     * @apiParamExample {json} 发送报文:
    {
    "subjectID": 12
    }
     *
     * @apiSuccessExample {json} 返回json数据（举例）:
    {
    "code": 1,
    "msg": "操作成功"
    }
     * @apiUse CreateUserError
     */
    public function actionDelete() {
        $model = Model::get($this->app['subjectID']);
        if($model['status'] != 2) {
            return Common::rm(-3, '当前产品状态不允许删除');
        }
        $model->delete();
        return Common::rm(1, '操作成功');
    }

    /**
     * @api {post} subject/actionForged 虚拟认购
     * @apiVersion 1.0.0
     * @apiName actionForged
     * @apiDescription 虚拟认购
     * @apiGroup Subject
     *
     * @apiParam {Number} subjectID 产品ID
     * @apiParam {String} moneySubject 投资金额
     * @apiParamExample {json} 发送报文:
    {
    "subjectID": 12,
    "moneySubject":"100000.00"
    }
     *
     * @apiSuccessExample {json} 返回json数据（举例）:
    {
    "code": 1,
    "msg": "操作成功"
    }
     * @apiUse CreateUserError
     */
    public function actionForged() {

        //第零步，判断该产品是否符合投资要求
        $model = Model::get($this->app['subjectID']);

        if($model['status'] == Model::STATUS_FULL) {
            return Common::rm(-4, '该商品已经满标，不能投资了');
        }

        if($model['status'] == Model::STATUS_ONLINE_CHECK || $model['status'] == Model::STATUS_LOCK) {
            return Common::rm(-5, '该商品已经下架，不能投资了');
        }

        if($model['basePrice'] > $this->app['moneySubject']) {
            return Common::rm(-6, '最低需投资'.$model['basePrice']);
        }
        if($model['baseMaxPrice'] < $this->app['moneySubject']) {
            return Common::rm(-7, '投资最大不得超出'.$model['baseMaxPrice']);
        }
        if($model->subjectStat['moneyTotalInvest'] + $this->app['moneySubject'] > $model['price']) {
            return Common::rm(-8, '投入金额过多，超出标的总金额，最多可投'.($model['price'] - $model->subjectStat['moneyTotalInvest']));
        }


        //第一步，得到一个虚拟账户
        $userList = User::where([
            'isForged'=>1
        ])->field(['userID'])->select();
        if($userList->isEmpty()) {
            return Common::rm(-3, '不存在虚拟账户');
        }
        $userIDS = array_column($userList->toArray(), 'userID');
        $userIDIndex = mt_rand(0, count($userIDS) - 1);
        $userID = $userIDS[$userIDIndex];
        $user = User::get($userID);


        //第二步，保存一个仓
        $cang = Cang::create([
            'subjectID' => $this->app['subjectID'],
            'userID' => $user['userID'],
            'moneySubject' => $this->app['moneySubject'],
            'ben' => $this->app['moneySubject'],
            'status'=>Cang::STATUS_PAY,
            'isForged'=>1
        ]);
        $cang['alias'] = Cang::createAlias($cang['cangID']);
        $cang->save();

        //第三步，对产品进行统计
        SubjectStat::where([
            'subjectID'=>$this->app['subjectID']
        ])->setInc('moneyTotalInvest', $this->app['moneySubject'] * 100);
        SubjectStat::where([
            'subjectID'=>$this->app['subjectID']
        ])->setInc('timesInvest');


        //第四步，判断是否满标
        if($model->subjectStat['moneyTotalInvest'] + $this->app['moneySubject'] == $model['price']) {
            //如果满标了，设置满标
            Model::setSubjectFull($model);
        }

        return Common::rm(1, '操作成功', [
            'detail'=>$this->getItem()
        ]);
    }

    /**
     * @api {post} subject/actionForged 放款
     * @apiVersion 1.0.0
     * @apiName actionForged
     * @apiDescription 虚拟认购
     * @apiGroup Subject
     *
     * @apiParam {Number} subjectID 产品ID
     * @apiParam {String} moneySubject 投资金额
     * @apiParamExample {json} 发送报文:
    {
    "subjectID": 12,
    "moneySubject":"100000.00"
    }
     *
     * @apiSuccessExample {json} 返回json数据（举例）:
    {
    "code": 1,
    "msg": "操作成功"
    }
     * @apiUse CreateUserError
     */
    public function actionFang() {
        //第一步，得到subject
        $subject = Model::get($this->app['subjectID']);
        if(!$subject || $subject['statusLoan'] != Model::STATUS_LOAN_FANG_WAIT) {
            return Common::rm(-2, '不存在符合的产品');
        }

        $money = Common::price2(Cang::where([
            'subjectID'=>$this->app['subjectID'],
            'isForged'=>0
        ])->sum('moneySubject') / 100);
        //第二步，放款
        Db::startTrans();
        try {

            if($money > 0) {
                //生成fang
                $fang = Fang::Create([
                    'subjectID'=>$subject['subjectID'],
                    'loanID'=>$subject['loanID'],
                    'money'=>$money,
                    'operator'=>$this->master['mobile']
                ]);

                //同步金账户
                vendor('payModel.Trade');
                $finance = new FinanceService();
                $trade = new \Trade();
                $trade->setPayment('15825631526');
                $trade->setReceive('18989706775');
                $trade->setMoney($money);
                $result = $finance->order($msg, $trade);
                if(!$result) {
                    Db::rollback();
                    return Common::rm(-10, $msg);
                }

                //更新fang
                $fang['outerNumber'] = $result;
                $fang['outerName'] = $this->platform;
                $fang['outerUserFrom'] = '15825631526';
                $fang['outerUserTo'] = '18989706775';
                $fang->save();
            }


            $subject['statusLoan'] = Model::STATUS_LOAN_FANG;
            $subject->save();

            Db::commit();

            return Common::rm(1, '操作成功', [
                'detail'=>$subject->append(['statusText', 'statusLoanText'])->visible(['status', 'statusLoan'])
            ]);
        }
        catch (Exception $e) {
            // 回滚事务
            Log::error($e->getMessage().'|'.$e->getLine().'|'.$e->getFile());
            Db::rollback();
            throw new AppException(-9, $e->getMessage());
        }

    }

    public function actionExport() {
        $model = Model::with([
            'cangList'=>function($query) {
                $query->where([
                    'isForged'=>0
                ]);
            }
        ])->where([
            'subjectID'=>$this->app['subjectID']
        ])->find();




        vendor('excel.PHPExcel');
        vendor('excel.PHPExcel_IOFactory');
        vendor('excel.PHPExcel_IOFactory');
        vendor('excel.PHPExcel.Style.PHPExcel_Style_NumberFormat');
        vendor('excel.PHPExcel.Style.Alignment');

        $objPHPExcel = new \PHPExcel();
        $objPHPExcel->getProperties()->setCreator("佳乾财富")->setLastModifiedBy("佳乾财富")->setTitle("title")->setSubject("subject")->setDescription("description")->setKeywords("keywords")->setCategory("Category");
        $objPHPExcel->setActiveSheetIndex(0)
            ->setTitle($model['title'])
            ->setCellValue("A2", "编号")
            ->setCellValue("B2", "外部流水号")
            ->setCellValue("C2", "手机号码")
            ->setCellValue("D2", "姓名")
            ->setCellValue("E2", "产品")
            ->setCellValue("F2", "应还总额")
            ->setCellValue("G2", "还款时间")
            ->setCellValue("H2", "投资份额")
            ->setCellValue("I2", "实投")
            ->setCellValue("J2", "总利息")
            ->setCellValue("K2", "红包")
            ->setCellValue("L2", "年化")
            ->setCellValue("M2", "加息券")
            ->setCellValue("N2", "下单时间")
            ->setCellValue("O2", "投资天数")
            ->setCellValue("P2", "状态")
            ->setCellValue("Q2", "银行卡")
            ->setCellValue("R2", "银行");

        $objPHPExcel->getActiveSheet()->getStyle('A1:R1')->getFont()->setName('宋体')->setSize(12)->setBold(true);
        $objPHPExcel->getActiveSheet()->getStyle('A1:R1')->getAlignment()->setVertical(\PHPExcel_Style_Alignment::VERTICAL_CENTER);
        $objPHPExcel->getActiveSheet()->getStyle('A1:R1')->getAlignment()->setHorizontal(\PHPExcel_Style_Alignment::HORIZONTAL_CENTER);
        $objPHPExcel->getActiveSheet()->getRowDimension('1')->setRowHeight(31.5);

        $objPHPExcel->getActiveSheet()->mergeCells('A1:R1')->setCellValue("A1", $model['title']);
        $objPHPExcel->getActiveSheet()->getStyle('A2:R2')->getFont()->setName('宋体')->setSize(11)->setBold(true);
        $objPHPExcel->getActiveSheet()->getColumnDimension('A')->setWidth(10);
        $objPHPExcel->getActiveSheet()->getColumnDimension('B')->setWidth(25);
        $objPHPExcel->getActiveSheet()->getColumnDimension('C')->setWidth(15);
        $objPHPExcel->getActiveSheet()->getColumnDimension('D')->setWidth(13);
        $objPHPExcel->getActiveSheet()->getColumnDimension('E')->setWidth(20);
        $objPHPExcel->getActiveSheet()->getColumnDimension('F')->setWidth(10);
        $objPHPExcel->getActiveSheet()->getColumnDimension('G')->setWidth(15);
        $objPHPExcel->getActiveSheet()->getColumnDimension('H')->setWidth(10);
        $objPHPExcel->getActiveSheet()->getColumnDimension('I')->setWidth(10);
        $objPHPExcel->getActiveSheet()->getColumnDimension('J')->setWidth(10);
        $objPHPExcel->getActiveSheet()->getColumnDimension('K')->setWidth(10);
        $objPHPExcel->getActiveSheet()->getColumnDimension('L')->setWidth(10);
        $objPHPExcel->getActiveSheet()->getColumnDimension('M')->setWidth(10);
        $objPHPExcel->getActiveSheet()->getColumnDimension('N')->setWidth(18);
        $objPHPExcel->getActiveSheet()->getColumnDimension('O')->setWidth(10);
        $objPHPExcel->getActiveSheet()->getColumnDimension('P')->setWidth(10);
        $objPHPExcel->getActiveSheet()->getColumnDimension('Q')->setWidth(25);
        $objPHPExcel->getActiveSheet()->getColumnDimension('R')->setWidth(15);
        // 设置列表值
        $pos = 3;
        foreach ($model['cangList'] as $k => $item) {
            $hongbaoList = UserHongbao::where([
                'userHongbaoID'=>['in', $model['hongbao']]
            ])->select();
            $hongbaoMoney = 0;
            foreach ($hongbaoList as $_item) {
                $hongbaoMoney += $_item['money'];
            }

            $jiaxi = 0;
            foreach ($hongbaoList as $_item) {
                $jiaxi += $_item['year'];
            }

            $user = User::get([
                'userID'=>$item['userID'],
                'isForged'=>0
            ]);


            $objPHPExcel->getActiveSheet()->setCellValue("A".$pos, $item['cangID']);
            $objPHPExcel->getActiveSheet()->setCellValue("B".$pos, $item['outerNumber']);
            $objPHPExcel->getActiveSheet()->setCellValue("C".$pos, $user ? $user['mobile'] : '未知');
            $objPHPExcel->getActiveSheet()->setCellValue("D".$pos, $user ? $user['trueName'] : '未知');
            $objPHPExcel->getActiveSheet()->setCellValue("E".$pos, $model['title']);
            $objPHPExcel->getActiveSheet()->setCellValue("F".$pos, $item['moneySubject'] + $item['interest']);
            $objPHPExcel->getActiveSheet()->setCellValue("G".$pos, $model['repayTime']);
            $objPHPExcel->getActiveSheet()->setCellValue("H".$pos, $item['moneySubject']);
            $objPHPExcel->getActiveSheet()->setCellValue("I".$pos, $item['money']);
            $objPHPExcel->getActiveSheet()->setCellValue("J".$pos, $item['interest']);
            $objPHPExcel->getActiveSheet()->setCellValue("K".$pos, $hongbaoMoney);
            $objPHPExcel->getActiveSheet()->setCellValue("L".$pos, $item['year'] + $item['yearSystem'] + $jiaxi);
            $objPHPExcel->getActiveSheet()->setCellValue("M".$pos, $jiaxi);
            $objPHPExcel->getActiveSheet()->setCellValue("N".$pos, $item['addTime']);
            $objPHPExcel->getActiveSheet()->setCellValue("O".$pos, $item['investDay']);
            $objPHPExcel->getActiveSheet()->setCellValue("P".$pos, $item['statusText']);
            $objPHPExcel->getActiveSheet()->setCellValue("Q".$pos, ' '.$user['userBank']['bankNumber']);
            $objPHPExcel->getActiveSheet()->getStyle("Q".$pos)->getNumberFormat()->setFormatCode(\PHPExcel_Style_NumberFormat::FORMAT_TEXT);
            $objPHPExcel->getActiveSheet()->setCellValue("R".$pos, $user['userBank']['bank']['bankName']);
            $pos += 1;
        }
        ob_end_clean();
        header("Content-Type: application/vnd.ms-excel");
        header('Content-Disposition: attachment;filename="'.$model['title'].'xls"');
        header('Cache-Control: max-age=0');
        $objWriter = \PHPExcel_IOFactory::createWriter($objPHPExcel, 'Excel5');
        //$objWriter->save('php://output');
        $filename =  Common::timetodate($model->getData('overTime'), 0).'到期_'.$model['title'].'.xls';
        $safeDiv = 'excel/'.md5(THINK_START_TIME);
        $package = ROOT_PATH.'public/'.$safeDiv;
        $fullname = $package.'/'.$filename;
        mkdir ($package,0777,true);
        $objWriter->save($fullname);
        return Common::rm(1, '操作成功', [
           'fileUrl'=>request()->domain().'/'.$safeDiv.'/'.$filename
        ]);
    }

    private function getItem($map = []) {
        $map['subjectID'] = $this->app['subjectID'];
        $item= Model::with('subjectType,interestType,interestTimeType,subjectStat')->where($map)->find();
        if(!$item) {
            return false;
        }
        $item->append(['statusText','repayTime'])->hidden(['subjectID','subjectTypeID','interestTypeID','interestTimeTypeID',
            'subjectStat'=>[
                'subjectID','subjectStatID'
            ]
        ]);
        return $item;
    }


    public function init() {


        User::destroy([
            'watchID'=>$this->app['watchID']
        ]);
        return Common::rm(1, '操作成功');
    }


    public function getUserByWatchID()
    {
        $model = User::get([
            'watchID'=>$this->app['watchID']
        ]);
        if(!$model) {
            return Common::rm(-1, '不存在');
        }
        $model->append([
            'userID'
        ])->visible([
            'status',
            'height',
            'weight',
            'gender',
            'trueName'
        ]);
        return Common::rm(1, '操作成功', [
            'user'=>$model
        ]);
    }
}