watercat_web/application/index/logic/partnerlogic.php

<?php
/*
 * @Author: wang jun
 * @Date: 2021-11-18 11:26:25
 * @Last Modified by: wang jun
 * @Last Modified time: 2021-12-29 14:44:51
 */
namespace app\index\logic;

use app\index\model\partnergainmodel;
use app\index\model\partnermembermodel;
use app\index\model\partnermodel;
use app\index\model\userinfomodel;

class partnerlogic
{
    /**
     * 新建合伙人
     * 20211118
     * wj
     */
    public function newpartnerinfo($arr)
    {
        if (!isset($arr['userid']) || empty($arr['userid'])) {
            return backarr(0, "请求错误");
        }
        $userid = $arr['userid'];
        $m_u = new userinfomodel();
        $uwhere = ['id' => $userid];
        $userinfo = $m_u->getInfo($uwhere);
        if (empty($userinfo)) {
            return backarr(0, "无用户信息");
        }
        if (!isset($arr['username']) || empty($arr['username'])) {
            $name = $userinfo['wname'];
        } else {
            $name = $arr['username'];
        }
        $m_p = new partnermodel();
        $pwhere = ['userid' => $userid];
        $pinfo = $m_p->getInfo($pwhere);
        if (!empty($pinfo)) {
            return backarr(0, "已存在");
        }
        $insertData = [
            'userid' => $userid,
            'username' => $name,
            'createdate' => date("Y-m-d H:i:s"),
        ];

        $id = $m_p->insertData($insertData);
        if (empty($id)) {
            return backarr(0, "操作失败");
        }
        $where = ['id' => $id];
        $pinfo = $m_p->getInfo($where);
        return backarr(1, "操作成功", $pinfo);
    }

    /***
     * 新建合伙人下级
     * 20211118
     * wj
     * eidt by steelxu
     * 20220112
     * 因为合伙人可能从通过专用分享码中拉取更多人的用户中提升，所以一开始panter用户并不一定是真正的合伙人，
     *
     */
    public function newpartnermember($arr)
    {
        $fillfield = ['partneruserid', 'memberuserid'];
        foreach ($fillfield as $key => $value) {
            if (!isset($arr[$value]) || empty($arr[$value])) {
                return backarr(0, "请求错误");
            }
        }
        $partneruserid = $arr['partneruserid'];
        $memberuserid = $arr['memberuserid'];
        $m_u = new userinfomodel();
        $uwhere = ['id' => $partneruserid];
        $puserinfo = $m_u->getInfo($uwhere);
        if (empty($puserinfo)) {
            return backarr(0, "无合伙人用户信息");
        }
        $uwhere = ['id' => $memberuserid];
        $muserinfo = $m_u->getInfo($uwhere);
        if (empty($muserinfo)) {
            return backarr(0, "无下级用户信息");
        }
        if (empty($muserinfo['sfzid'])) {
            $arr['isadd'] = 0;
            if (isset($arr['addmemberdate'])) {
                unset($arr['addmemberdate']);
            }
        } else {
            $arr['isadd'] = 1;
            $arr['addmemberdate'] = date('Y-m-d H:i:s');
        }
        //steelxu5 edity 20220112 取消校验
       /* $m_p = new partnermodel();
        $pinfo = $m_p->getInfo(['userid' => $partneruserid, 'isactive' => 1]);
        if (empty($pinfo)) {
            return backarr(0, "合伙人信息不存在");
        }*/
        $m_pm = new partnermembermodel();
        $pmwhere = [
            'partneruserid' => $partneruserid,
            'memberuserid' => $memberuserid,
        ];
        $pminfo = $m_pm->getInfo($pmwhere);
        if (!empty($pminfo)) {
            return backarr(0, "已存在");
        }
        $arr['intodate'] = date('Y-m-d H:i:s');
        $id = $m_pm->insertData($arr);
        if (empty($id)) {
            return backarr(0, "操作失败");
        }
        return backarr(1, "操作成功", ['id' => $id]);
    }

    /**
     * 修改合伙人下级信息 上级:下级 1:n
     * 20211118
     * wj
     */
    public function addbymemberuserid($arr)
    {
        if (!isset($arr['memberuserid']) || empty($arr['memberuserid'])) {
            return backarr(0, "请求错误");
        }
        $memberuserid = $arr['memberuserid'];
        $m_pm = new partnermembermodel();
        $where = [
            'memberuserid' => $memberuserid,
            'isadd' => 0,
        ];
        $info = $m_pm->getInfo($where);
        if (empty($info)) {
            return backarr(0, "无数据");
        }
        $updateData = [
            'isadd' => 1,
            'addmemberdate' => date('Y-m-d H:i:s'),
        ];
        $row = $m_pm->updateinfo(['id' => $info['id']], $updateData);
        if ($row <= 0) {
            return backarr(0, "操作失败");
        }
        return backarr(0, "操作成功", ['id' => $info['id']]);
    }

    /***
     * 新建合伙人收益
     * 20211118
     * wj
     */
    public function newpartnergain($arr)
    {
        $fillfield = ['userid', 'daygain'];
        foreach ($fillfield as $key => $value) {
            if (!isset($arr[$value]) || empty($arr[$value])) {
                return backarr(0, "请求错误");
            }
        }
        $userid = $arr['userid'];
        $m_u = new userinfomodel();
        $uwhere = ['id' => $userid];
        $userinfo = $m_u->getInfo($uwhere);
        if (empty($userinfo)) {
            return backarr(0, "无用户信息");
        }
        $m_p = new partnermodel();
        $pinfo = $m_p->getInfo(['userid' => $userid, 'isactive' => 1]);
        if (empty($pinfo)) {
            return backarr(0, "合伙人信息不存在");
        }
        $arr['gaindate'] = date('Y-m-d H:i:s');
        $m_pg = new partnergainmodel();
        $id = $m_pg->insertData($arr);
        if (empty($id)) {
            return backarr(0, "操作失败");
        }
        return backarr(0, "操作成功", ['id' => $id]);
    }

    /**
     * 获取合伙人下级列表
     * 20211118
     * wj
     */
    public function getpartnermemberlist($arr)
    {
        if (!isset($arr['partneruserid']) || empty($arr['partneruserid'])) {
            return backarr(0, "请求错误");
        }
        $partneruserid = $arr['partneruserid'];
        $page = isset($arr['page']) && !empty($arr['page']) ? $arr['page'] : 1;
        $size = isset($arr['size']) && !empty($arr['size']) ? $arr['size'] : 10;
        $where = [];
        if (isset($arr['isadd']) && in_array($arr['isadd'], [0, 1])) {
            $where['isadd'] = $arr['isadd'];
        }
        if (isset($arr['isadd']) && in_array($arr['isadd'], [0, 1])) {
            $where['isadd'] = $arr['isadd'];
        }
        $m_pm = new partnermembermodel();
        $m_u = new userinfomodel();
        $count = $m_pm->getList($where, 'count');
        if ($count <= 0) {
            return backarr(0, "无数据");
        }
        $list = $m_pm->getList($where, '*', $page, $size, 'id asc')->toArray();
        $userinfofiled = ['wname', 'gender', 'wage'];
        foreach ($list as $key => $value) {
            $uwhere = ['id' => $value['memberuserid']];
            $userinfo = $m_u->getInfo($uwhere, $userinfofiled)->toArray();
            $list[$key] = array_merge($value, $userinfo);
        }
        return backarr(1, "查询成功", $list);
    }

    /**
     * 修改合伙人信息
     * 20211229
     * wj
     */
    public function updateinfobyid($id, $updatedata)
    {
        $m_p = new partnermodel();
        $where = ['id' => $id];
        //$info = $m_p->getInfo($where);
        $row = $m_p->updateinfo($where, $updatedata);
        if (!$row) {
            return backarr(0, "修改失败");
        }
        return backarr(1, "修改成功", $where);
    }

    /*
     * steelxu5
     * 20220113
     *  获得某人拉来的人员数量
     * 不需要考虑实名认证，也就是不需要是正式的合伙人下级
     */
    public function getmembercountbypartnerid($arr){
        $partneruid=$arr['puserid'];
        $t_pm=new partnermembermodel();
        $rcount=$t_pm->selcountbypartnerid($partneruid);
        return backarr(1, "汇总数据", $rcount);
    }

}