'中午'], true)); } /** * 测试异步任务 * ./yii test/async-task calcBonus * @param null $routeAndParamsMethod 想要测试的方法名 * @throws \yii\base\Exception * @throws \yii\base\InvalidConfigException */ public function actionAsyncTask($routeAndParamsMethod = null){ if($routeAndParamsMethod !== null){ $routeAndParams = call_user_func(self::class.'::_'.$routeAndParamsMethod); $route = $routeAndParams['route']; $params = $routeAndParams['params']; } else { $moveInfo = UserMove::find()->select('UM.ID,UM.LOCATION,UM.TYPE,MU.USER_NAME AS moveUserName,TU.USER_NAME AS toConUserName,TU.REAL_NAME AS toConRealName') ->from(UserMove::tableName().' AS UM') ->leftJoin(User::tableName().' AS MU', 'UM.USER_ID=MU.ID') ->leftJoin(User::tableName() . ' AS TU', 'UM.TO_UID=TU.ID') ->where('AUDIT_STATUS=0')->asArray()->all(); foreach($moveInfo as $k=>$moves){ // route换成要测试的路由路径 if($moves['TYPE']=='relation'){ $route = 'user/move-relation'; }else{ $route = 'user/move-network'; } // params的数组内容替换为要传的值 $params = [ 'moveId' => $moves['ID'], 'moveUserName' => $moves['moveUserName'], 'toConUserName' => $moves['toConUserName'], 'toConRealName' => $moves['toConRealName'], 'location' => $moves['LOCATION'], 'type' => $moves['TYPE'], ]; echo sprintf("任务【%s】开始执行".PHP_EOL, $k); $params['handleUserId'] = null; $taskKey = Cache::setAsyncParams($params); $parts = \Yii::$app->createController($route); if(is_array($parts)){ $res = \Yii::$app->runAction($route,[$taskKey]); var_dump($res); unset($res); } else { echo('失败'.PHP_EOL); } unset($k,$moves,$route,$params,$taskKey,$parts); } } // $params['handleUserId'] = null; // $taskKey = Cache::setAsyncParams($params); // $parts = \Yii::$app->createController($route); // if(is_array($parts)){ // $res = \Yii::$app->runAction($route,[$taskKey]); // var_dump($res); // } else { // echo('失败'.PHP_EOL); // } } /** * 异步发奖 * @param string $router * @param int $periodNum * @return void */ public function actionBonusAsyncTask($router='bonus/perf', $periodNum=105) { // 异步处理添加任务 $taskKey = Cache::setAsyncParams([ 'handleUserId' => null, 'handleUserName' => null, 'periodNum' => $periodNum, ]); $data = [ 'data' => [ [ 'a' => $router, 'p' => [$taskKey], ] ], ]; if(\Yii::$app->swooleAsyncTimer->async(Json::encode($data))){ echo 'ok' . PHP_EOL; } else { echo 'fail' . PHP_EOL; } } private static function _calcPerf(){ return [ 'route' => 'bonus/perf', 'params' => [ 'periodNum' => 105, ], ]; } /** * 测试结算 * @return array */ private static function _calcBonus(){ return [ 'route' => 'bonus/calc', 'params' => [ 'periodNum' => 105, ], ]; } /** * 测试结算 * @return array */ private static function _sendBonus(){ return [ 'route' => 'bonus/send', 'params' => [ 'periodNum' => 118, ], ]; } /** * 测试移网 * @return array */ private static function _moveRouteAndParams(){ return [ 'route' => 'user/move-network', 'params' => [ 'moveId' => 'A090B24973524443BE8BA95A40EE2148', 'moveUserName' => 'b30746926', 'toConUserName' => 'tester004', 'toConRealName' => 'hhhjhjj', 'location' => 1, 'type' => 'network', ], ]; } /** * 添加体系 * @return array */ private static function _addSystem(){ return [ 'route' => 'user/system-add', 'params' => [ 'systemName' => '测试', 'leaderUserName' => 'tester001', 'remark' => '测试', ], ]; } private $_addUserNum = 1; private $_md5UserId = 2; private $_userNameNum = 2; public function actionAddUserTable(){ $notDelUserId = "'670B84FD7C216D4EE055736AECE8644D','B322C18F7E274A9D9FC5DADC3B385E8B','638A5A3B617F46C999C5E4D072EED369','3C313C66D1724D658BF10B08194022BB'"; User::deleteAll("ID NOT IN (".$notDelUserId.")"); DecOrder::deleteAll("TO_USER_ID NOT IN (".$notDelUserId.")"); $offset = 100; $allCount = UserInfo::find()->where("USER_ID NOT IN (".$notDelUserId.")")->orderBy('NETWORK_DEEP ASC')->asArray()->count("USER_ID"); $pageCount = ceil($allCount/$offset); for($page=1;$page<=$pageCount;$page++) { $allUser = UserInfo::find()->where("USER_ID NOT IN (".$notDelUserId.")")->offset(($page-1)*$offset)->limit($offset)->orderBy('NETWORK_DEEP ASC')->asArray()->all(); $insertData = []; $userInsertData=[]; $decSn = 190310000000; foreach($allUser as $key=>$user){ $decSn += 1; $decPv = rand(1, 100) * 1000; $insertData[] = [ 'DEC_SN' => 'D'.$decSn.'0000', 'ORDER_SN' => $decSn, 'USER_ID' => $user['USER_ID'], 'TYPE' => 'ZC', 'TO_USER_ID' => $user['USER_ID'], 'DEC_AMOUNT' => $decPv, 'DEC_PV' => $decPv, 'PAID_WALLET' => 'bill', 'PERIOD_NUM' => 102, 'IS_DEL' => 0, 'P_CALC_MONTH' => Date::ociToDate(202001, Date::OCI_TIME_FORMAT_SHORT_MONTH), 'CREATED_AT' => strtotime('2020-01-20'), 'DEC_ID' => $user['REC_UID'], ]; $userInsertData[] = [ 'ID' => $user['USER_ID'], 'USER_NAME' => $user['USER_NAME'], 'AVATAR' => 'http://abc.anran.ming/cdn/avatar/1.png', 'PASSWORD_HASH' => password_hash('111111', PASSWORD_DEFAULT), 'PAY_PASSWORD' => password_hash('111111', PASSWORD_DEFAULT), 'NATION' => 1, 'REAL_NAME' => $user['USER_NAME'], 'ID_CARD' => '130322111111111113', 'ID_TYPE' => 0, 'MOBILE' => '13333333339', 'ADDRESS' => '广东省 / 广州市荔湾区三号五弄', 'IS_DEC' => 1, 'DEC_ID' => '670B84FD7C216D4EE055736AECE8644D', 'PERIOD_AT' => 102, 'CREATED_AT' => strtotime('2020-02-12'), 'LAST_DEC_LV' => '67ABCE0ECE705575E055736AECE8644D', 'DEC_LV' => '67ABCB8C1F7D5519E055736AECE8644D', 'EMP_LV' => '67BE1C6C21F81B32E055736AECE8644D' ]; } User::batchInsert($userInsertData); DecOrder::batchInsert($insertData); echo('第'.$page.'页数据'.PHP_EOL); } echo('全部完成'.PHP_EOL); } /** * 模拟添加会员 * @param $num * @param string $conUid * @param string $recUid * @param int $location * @return bool * @throws Exception * @throws \yii\db\Exception */ public function actionAddUser($num, $conUid = 'B322C18F7E274A9D9FC5DADC3B385E8B', $recUid = 'B322C18F7E274A9D9FC5DADC3B385E8B', $location = 1){ if($num <= $this->_addUserNum) { echo('模拟加入完成'.PHP_EOL); return true; } $this->_md5UserId += 1; $this->_userNameNum += 1; $form = new UserForm(); $form->scenario = 'addWithUid'; $form->userId = md5($this->_md5UserId); $form->userName = 'simulate'.($this->_userNameNum); $form->zcPv = 1000; $form->zcAmount = 1000; $form->conUid = $conUid; $form->recUid = $recUid; $form->location = $location; if($form->add()){ echo('添加了'.$this->_addUserNum.'名会员'.PHP_EOL); $this->_addUserNum += 1; // 获取全网深度最浅还没满的会员ID 作为节点人ID $conUser = UserInfo::find()->select('USER_ID, CON_NUM')->where('CON_NUM < 3')->orderBy('NETWORK_DEEP ASC')->asArray()->one(); if($conUser['CON_NUM'] == 0){ $newLocation = 1; } elseif($conUser['CON_NUM'] == 1){ $newLocation = 2; } elseif($conUser['CON_NUM'] == 2) { $newLocation = 3; } else { throw new Exception('添加失败,原因：加入会员的点位区位错误'); } return $this->actionAddUser($num, $conUser['USER_ID'], $conUser['USER_ID'], $newLocation); } else { throw new Exception('添加失败,原因：'.Form::formatErrorsForApi($form->getErrors())); } return true; } /** * 清空已增加的会员 */ public function actionClearAddUser(){ $notDelUserId = "'670B84FD7C216D4EE055736AECE8644D','B322C18F7E274A9D9FC5DADC3B385E8B','638A5A3B617F46C999C5E4D072EED369','3C313C66D1724D658BF10B08194022BB'"; $netChangeUserId = "'B322C18F7E274A9D9FC5DADC3B385E8B','638A5A3B617F46C999C5E4D072EED369','3C313C66D1724D658BF10B08194022BB'"; UserInfo::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); UserNetwork::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); UserRelation::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); UserInfo::updateAll(['CON_NUM' => 0, 'REC_NUM' => 0], "USER_ID IN (".$netChangeUserId.")"); User::deleteAll("ID NOT IN (".$notDelUserId.")"); CalcBonus::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); CalcBonusBD::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); CalcBonusTG::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); CalcBonusYJ::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); CalcBonusGX::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); CalcBonusGL::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); CalcBonusQY::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); CalcBonusYC::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); FlowBonus::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); FlowReconsumePoints::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); PerfPeriod::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); PerfMonth::deleteAll("USER_ID NOT IN (".$notDelUserId.")"); DecOrder::deleteAll("TO_USER_ID NOT IN (".$notDelUserId.")"); UserBonus::deleteAll(); echo '删除完成'.PHP_EOL; } /** * 清空所有会员 */ public function actionClearAllUser(){ UserInfo::deleteAll(); UserNetwork::deleteAll(); UserRelation::deleteAll(); User::deleteAll(); CalcBonus::deleteAll(); CalcBonusBD::deleteAll(); CalcBonusTG::deleteAll(); CalcBonusYJ::deleteAll(); CalcBonusGX::deleteAll(); CalcBonusGL::deleteAll(); CalcBonusQY::deleteAll(); CalcBonusYC::deleteAll(); FlowBonus::deleteAll(); FlowReconsumePoints::deleteAll(); PerfPeriod::deleteAll(); PerfMonth::deleteAll(); DecOrder::deleteAll(); UserBonus::deleteAll(); echo '删除完成'.PHP_EOL; } /** * 清空结算的奖金 */ public function actionClearBonus(){ CalcBonus::deleteAll(); CalcBonusBD::deleteAll(); CalcBonusTG::deleteAll(); CalcBonusYJ::deleteAll(); CalcBonusGX::deleteAll(); CalcBonusGL::deleteAll(); CalcBonusQY::deleteAll(); CalcBonusYC::deleteAll(); FlowBonus::deleteAll(); FlowReconsumePoints::deleteAll(); PerfPeriod::deleteAll(); PerfMonth::deleteAll(); echo '删除完成'.PHP_EOL; } /** * 清空会员的网络 */ public function actionClearNetRedis(){ \Yii::$app->redis->del(Cache::USER_NETWORK_PARENTS); \Yii::$app->redis->del(Cache::USER_RELATION_PARENTS); echo '全部完成'.PHP_EOL; } public function actionLoopUser($offset = 0){ $query = UserInfo::findUseDbCalc()->select('USER_ID,USER_NAME,ZC_PV,CON_UID,REC_UID,CON_NUM,REC_NUM,NETWORK_DEEP,RELATION_DEEP,STORE_TYPE,PERIOD_NUM,CREATED_AT,UPDATED_AT')->where('1=1')->orderBy('NETWORK_DEEP DESC')->offset($offset)->limit(100)->asArray()->all(); if($query){ foreach($query as $data){ echo($data['USER_NAME'].PHP_EOL); } $this->actionLoopUser($offset + 100); } exit(); } public function actionLoopUserTwo(){ // $query = UserInfo::findUseDbCalc()->select('USER_ID,USER_NAME,ZC_PV,CON_UID,REC_UID,CON_NUM,REC_NUM,NETWORK_DEEP,RELATION_DEEP,STORE_TYPE,PERIOD_NUM,CREATED_AT,UPDATED_AT')->where('1=1')->orderBy('NETWORK_DEEP DESC')->asArray(); // // foreach($query->batch() as $allData){ // foreach($allData as $data){ // echo($data['USER_NAME'].PHP_EOL); // } // } // // exit(); // $test=(new \yii\db\Query()); // $test->from('AR_USER_INFO'); // $reader=$test->prepare(\Yii::$app->db->queryBuilder)->createCommand()->query(); // while ($row = $reader->read()) { // print_r($row); // } $query = (new Query())->from('{{%USER_INFO}}')->prepare(\Yii::$app->db->queryBuilder)->where('1=1'); // while ($row = $query->read()) { // print_r($row['USER_NAME'].PHP_EOL); // } try { foreach($query->batch() as $allData){ foreach($allData as $data){ echo($data['USER_NAME'].PHP_EOL); } } } catch (\PDOException $e){ print_r($e->getMessage()); } } /** * 循环加入报单 * @throws \yii\db\Exception */ public function actionLoopAddDec(){ // 获取最底层的100名会员 $allUser = UserInfo::find()->where('1=1')->limit(100)->orderBy('NETWORK_DEEP DESC')->asArray()->all(); $insertData = []; $decSn = 190310000000; foreach($allUser as $key=>$user){ $decSn += 1; $decPv = rand(1, 100) * 1000; $insertData[] = [ 'DEC_SN' => 'D'.$decSn.'0000', 'ORDER_SN' => $decSn, 'USER_ID' => $user['USER_ID'], 'TYPE' => 'ZC', 'TO_USER_ID' => $user['USER_ID'], 'DEC_AMOUNT' => $decPv, 'DEC_PV' => $decPv, 'PAID_WALLET' => 'bill', 'PERIOD_NUM' => 121, 'IS_DEL' => 0, 'P_CALC_MONTH' => Date::ociToDate(202001, Date::OCI_TIME_FORMAT_SHORT_MONTH), 'CREATED_AT' => strtotime('2020-01-20'), 'DEC_ID' => $user['REC_UID'], ]; } DecOrder::batchInsert($insertData); echo('全部完成'.PHP_EOL); } /** * 清空报单 */ public function actionClearDec(){ DecOrder::deleteAll('PERIOD_NUM = 100'); echo('删除完成'.PHP_EOL); } /** * 测试rpc接口 * @throws Exception */ public function actionRpcCli(){ // $data = [ // ['type' => 'ZC', 'userId' => '670B84FD7C216D4EE055736AECE8644D', 'toUserId'=>'dec001', 'decPv' => '5000', 'insertUserName' => 'dec001', 'conUserName' => 'tester005', 'recUserName' => 'tester003', 'location' => 1], // ['type' => 'ZC', 'userId' => '670B84FD7C216D4EE055736AECE8644D', 'toUserId'=>'dec002', 'decPv' => '5000', 'insertUserName' => 'dec002', 'conUserName' => 'tester003', 'recUserName' => 'tester003', 'location' => 2], // ['type' => 'ZC', 'userId' => '670B84FD7C216D4EE055736AECE8644D', 'toUserId'=>'dec003', 'decPv' => '5000', 'insertUserName' => 'dec003', 'conUserName' => 'tester003', 'recUserName' => 'tester003', 'location' => 3], // ['type' => 'ZC', 'userId' => '670B84FD7C216D4EE055736AECE8644D', 'toUserId'=>'dec004', 'decPv' => '5000', 'insertUserName' => 'dec004', 'conUserName' => 'dec001', 'recUserName' => 'tester003', 'location' => 1], // ['type' => 'ZC', 'userId' => '670B84FD7C216D4EE055736AECE8644D', 'toUserId'=>'dec005', 'decPv' => '5000', 'insertUserName' => 'dec005', 'conUserName' => 'dec001', 'recUserName' => 'tester003', 'location' => 2], // ['type' => 'ZC', 'userId' => '670B84FD7C216D4EE055736AECE8644D', 'toUserId'=>'dec006', 'decPv' => '5000', 'insertUserName' => 'dec006', 'conUserName' => 'dec001', 'recUserName' => 'tester003', 'location' => 3], // ]; // $data = array ( // 0 => // array ( // 'type' => 'ZC', // 'userId' => 'B322C18F7E274A9D9FC5DADC3B385E8B', // 'toUserId' => '6B2869C5958446CAB479CF1A5D9E3763', // 'decPv' => '705', // 'insertUserName' => 'b80346267', // 'insertUserIdCard' => '130302199905051113', // 'conUserName' => 'b90556236', // 'recUserName' => 'tester002', // 'location' => '1', // ), // 1 => // array ( // 'type' => 'ZC', // 'userId' => 'B322C18F7E274A9D9FC5DADC3B385E8B', // 'toUserId' => '940644BC1C2D41F392EA0EDCB4354F55', // 'decPv' => '875', // 'insertUserName' => 'b27486502', // 'insertUserIdCard' => '130302199905051113', // 'conUserName' => 'b80346267', // 'recUserName' => 'tester002', // 'location' => '1', // ), // 2 => // array ( // 'type' => 'ZC', // 'userId' => 'B322C18F7E274A9D9FC5DADC3B385E8B', // 'toUserId' => '854E59FE17494633A853872C878B93D7', // 'decPv' => '1405', // 'insertUserName' => 'b76328656', // 'insertUserIdCard' => '130302199905051113', // 'conUserName' => 'b80346267', // 'recUserName' => 'b27486502', // 'location' => '2', // ), // ); $data = [ [ 'type' => 'ZC', 'userId' => '3C313C66D1724D658BF10B08194022BB', 'toUserId' => '', 'decPv' => '3000', 'insertUserName' => 'b27251926', 'conUserName' => 'b83825142', 'recUserName' => 'b92223569', 'location' => '1', 'insertUserIdCard' => '110227196504215915', ], [ 'type' => 'ZC', 'userId' => '3C313C66D1724D658BF10B08194022BB', 'toUserId' => '', 'decPv' => 12000.0, 'insertUserName' => 'b86268542', 'conUserName' => 'b92223569', 'recUserName' => 'b27251926', 'location' => '2', 'insertUserIdCard' => '110227196504215915', ], ]; $condition = [ 'namespace' => '\\'.RPCApi::class.'::api', 'param' => [ 'class'=> '\\'.DeclarationLoopForm::class, 'fields'=>[ 'scenario' => 'canDec', 'data' => $data, ], 'action'=>'validate', 'param'=>[], ], ]; $rpcApi = new RPCApi(); if($result = $rpcApi->request($condition)){ var_dump($result); } else { var_dump($rpcApi->getError()); } } /** * 发票识别 */ public function actionOcr(){ $result = OcrApi::instance()->vatInvoice('/Volumes/HDD/Downloads/vatInvoice.jpg'); print_r($result); } /** * 备份数据库测试 * @throws \yii\db\Exception */ public function actionBakData(){ DataBak::backup(142); } /** * 测试短信发送（可协程发送） */ public function actionSendSms(){ $params = [ 'mobiles' => '19933643193', 'content' => '测试短息，您好', ]; SmsApi::instance()->clearError(); for($i=0;$i<10;$i++){ SmsApi::instance()->goSend($params); } print_r(SmsApi::instance()->getError()); } /** * 测试绑定 * @throws \yii\db\Exception */ public function actionBind(){ UserBind::autoBind('9AC80FF809B04EED96321D34CBA0EAA9','32132419900307929X'); } /** * 测试任务队列 */ public function actionTaskQueue(){ if(Queue::instance()->addTask(Queue::TYPE_FUNC, TaskFunc::class.'::testTaskQueue', [], Queue::LOOP_TYPE_DAY, '16:39:00', 2)){ echo('任务添加成功'.PHP_EOL); } else { echo('任务添加失败'.PHP_EOL); } } public function actionMsg(){ $r=Reconsume::getUserReconsumePool("8C5E7DEB93767021E053693418ACB2B6"); } public function actionGenerateId() { for($i=1;$i<=10;$i++) { echo SnowFake::instance()->generateId() . PHP_EOL; } } public function actionShow() { $a4Uid = '76202856516030464'; $data = CalcCache::bonus($a4Uid, 104); print_r($data);die; } public function actionLoopAllUsers($findUid='76193630875947008', $periodNum=105, $offset = 0) { // 从缓存列表里面从底层往上倒序获取会员 $allData = CalcCache::getUsers($periodNum, $offset, 100); if($allData) { foreach($allData as $userId){ // echo sprintf("userId:%s", $userId) . PHP_EOL; if( $userId === $findUid ) { echo "find user" . $findUid . PHP_EOL; // $data = CalcCache::bonus($findUid, 104); // var_dump($data);die; } unset($userId); } unset($allData); return $this->actionLoopAllUsers($findUid, $periodNum, $offset + 100); } return true; } public function actionLoopAllPerfUser($offset=0, $periodNum=103, $limit=1000) { $allData = CalcCache::getHasPerfUsers($periodNum, $offset, $limit); if ($allData) { foreach ($allData as $userId) { $user = User::find()->select(["USER_NAME"])->where('ID=:ID', ['ID'=>$userId])->asArray()->all(); if( !$user ) { echo $userId . PHP_EOL; } } $this->actionLoopAllPerfUser($offset+$limit, $periodNum, $limit); } } public function actionLoopAllGxUser($offset=0, $periodNum=105, $limit=1000) { return false; $allData = CalcBonus::find()->select(["ID", "USER_ID", "ORI_BONUS_GX"])->where("PERIOD_NUM=:PERIOD_NUM", ["PERIOD_NUM"=>$periodNum])->offset($offset)->limit($limit)->asArray()->all(); if ($allData) { foreach ($allData as $everyData) { if( $everyData['ORI_BONUS_GX'] <= 0 ) continue; $list = CalcBonusGX::find()->select(['ID', 'USER_ID', 'ORI_BONUS'])->where('USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', [ 'USER_ID' => $everyData['USER_ID'], 'PERIOD_NUM' => $periodNum, ])->asArray()->all(); if( count($list) <= 1) { unset($list); continue; } //删除一条 $firstData = array_shift($list); if( $firstData['ORI_BONUS'] != $everyData['ORI_BONUS_GX'] ) { //修改奖金 echo 'ID:' . $everyData['ID'] . '奖金:' . $everyData['ORI_BONUS_GX'] . '修改为:' . $firstData['ORI_BONUS'] . PHP_EOL; CalcBonus::updateAll(['ORI_BONUS_GX'=>$firstData['ORI_BONUS']], 'ID=:ID', [ 'ID' => $everyData['ID'], ]); } //删除其它记录 foreach ($list as $deleteData) { echo '删除记录为:' . $deleteData['ID'] . PHP_EOL; CalcBonusGX::deleteAll('ID=:ID', ['ID'=>$deleteData['ID']]); unset($deleteData); } unset($everyData, $list, $firstData); } unset($allData); $this->actionLoopAllGxUser($offset+$limit, $periodNum, $limit); } } public function actionLoopAllGxUserTwo($offset=0, $periodNum=105, $limit=1000) { return false; $allData = CalcBonusGX::find()->select(['ID', 'USER_ID', 'ORI_BONUS', 'AMOUNT', 'RECONSUME_POINTS', 'MANAGE_TAX'])->where('PERIOD_NUM=:PERIOD_NUM', [ 'PERIOD_NUM' => $periodNum, ])->offset($offset)->limit($limit)->asArray()->all(); if ($allData) { foreach ($allData as $everyData) { $oneData = CalcBonus::find()->select(["ID", "USER_ID", "BONUS_GX", "RECONSUME_POINTS", "MANAGE_TAX", "BONUS_TOTAL"])->where('USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', [ 'USER_ID' => $everyData['USER_ID'], 'PERIOD_NUM' => $periodNum, ])->asArray()->one(); if( $oneData['BONUS_GX'] != $everyData['AMOUNT'] ) { //修改奖金 echo 'ID:' . $oneData['ID'] . '奖金:' . $oneData['BONUS_GX'] . '修改为:' . $everyData['AMOUNT'] . PHP_EOL; // echo 'RECONSUME_POINTS:' . ($oneData['RECONSUME_POINTS']-$everyData['RECONSUME_POINTS']) . 'MANAGE_TAX:' . ($oneData['MANAGE_TAX']-$everyData['MANAGE_TAX']) . PHP_EOL; CalcBonus::updateAll([ 'BONUS_GX'=>$everyData['AMOUNT'], 'RECONSUME_POINTS'=>$oneData['RECONSUME_POINTS']-$everyData['RECONSUME_POINTS'], 'MANAGE_TAX'=>$oneData['MANAGE_TAX']-$everyData['MANAGE_TAX'], 'BONUS_TOTAL'=>$oneData['BONUS_TOTAL']-$everyData['ORI_BONUS'], ], 'ID=:ID', [ 'ID' => $oneData['ID'], ]); } unset($everyData, $oneData); } unset($allData); $this->actionLoopAllGxUserTwo($offset+$limit, $periodNum, $limit); } } /** * 导入结余业绩 * @param int $periodNum */ public function actionAddSurplusData($periodNum=107) { $allCount = PerfPeriod::find()->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$periodNum])->count('ID'); $pageSize = 1000; $pageCount = ceil($allCount/$pageSize); unset($allCount); for($page=1;$page<=$pageCount;$page++){ echo sprintf('导入【%d】期结余业绩，总页数为【%d】，当前页数为【%d】' . PHP_EOL, $periodNum, $pageCount, $page); $perfPeriodData = PerfPeriod::find()->select(['USER_ID', 'SURPLUS_1L', 'SURPLUS_2L', 'SURPLUS_3L', 'SURPLUS_4L', 'SURPLUS_5L'])->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$periodNum])->orderBy('ID ASC')->offset(($page-1)*$pageSize)->limit($pageSize)->asArray()->all(); foreach ($perfPeriodData as $data) { UserPerf::updateAll([ 'SURPLUS_1L' => $data['SURPLUS_1L'], 'SURPLUS_2L' => $data['SURPLUS_2L'], 'SURPLUS_3L' => $data['SURPLUS_3L'], 'SURPLUS_4L' => $data['SURPLUS_4L'], 'SURPLUS_5L' => $data['SURPLUS_5L'], ], 'USER_ID=:USER_ID', [':USER_ID' => $data['USER_ID']]); unset($data); } unset($perfPeriodData); } } public function actionAddLastSurplus() { $data = [ 'A10505648'=>360, 'D86714213'=>120, 'F10401034'=>120, 'A16768918'=>360, 'H72700605'=>720, 'H19166726'=>550, 'H38585848'=>360, 'A18950413'=>1560, 'H87620691'=>120, 'E10242995'=>426, 'Eh78786514'=>124, 'E14356640'=>120, 'E12757473'=>360, 'A19273920'=>240, 'H10164357'=>120, ]; foreach ($data as $username=>$perf) { $user = User::find()->select(['ID'])->where('USER_NAME=:USER_NAME', [ 'USER_NAME' => $username ])->asArray()->one(); UserPerf::updateAll([ 'SURPLUS_2L' => $perf, ], 'USER_ID=:USER_ID', [':USER_ID' => $user['ID']]); unset($username, $perf); } echo 'OK' . PHP_EOL; } public function actionBackup() { DataBak::backup(105); } /** * 结算最后一步写数据 * @param int $periodNum * @throws \yii\db\Exception */ public function actionCalcWriteDb($periodNum=108) { // 周业绩 // PerfPeriod::pageDeleteAll('PERIOD_NUM='.$periodNum); // // 奖金表 // CalcBonus::pageDeleteAll('PERIOD_NUM='.$periodNum); // // $calcWrite = new CalcWrite(); // $calcWrite->start($periodNum); Period::updateAll(['IS_CALCING' => 0, 'IS_CALCULATED' => Period::CALCULATE_FINISH, 'CALCULATED_AT' => Date::nowTime(), 'CALC_PERCENT' => 100], 'PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $periodNum]); } /** * 计算某一期的聘级 * @param $periodNum * @return string * @throws Exception * @throws \yii\db\Exception */ public function actionCalcEmpLevel($periodNum) { $bonusCalc = PerfCalc::instance(); $bonusCalc->setPeriodNum($periodNum); $bonusCalc->initCalcTask(); $bonusCalc->loopCalcEmpLevel(); return 'ok' . PHP_EOL; } /** * 计算某一期的聘级 * @param $periodNum * @return string * @throws Exception * @throws \yii\db\Exception */ public function actionCheckVipBonus($periodNum) { $bonusCalc = BonusCalc::instance(); $bonusCalc->setPeriodNum($periodNum); $bonusCalc->initCalcTask(); $bonusCalc->calcBonusVIP(); return 'ok' . PHP_EOL; } /** * 检测共享奖 * @param $periodNum * @return string * @throws \yii\db\Exception */ public function actionCheckShareBonus($periodNum) { $bonusCalc = BonusCalc::instance(); $bonusCalc->setPeriodNum($periodNum); $bonusCalc->initCalcTask(); $bonusCalc->calcBonusGXBefore(); return 'ok' . PHP_EOL; } /** * 修正导入数据的报单中心ID * @param int $startPage * @param int $limit * @return bool */ public function actionFixImportDecId($startPage=1, $limit = 1000) { $numCount = TmpOldNetwork::find()->where("1=1")->orderBy("ID ASC")->count("ID"); $pageCount = ceil($numCount/$limit); for ($page=$startPage;$page<=$pageCount;$page++) { $pageList = TmpOldNetwork::find()->where("1=1")->orderBy("ID ASC")->limit($limit)->offset(($page - 1) * $limit)->asArray()->all(); foreach ($pageList as $pageData) { User::updateAll(['DEC_ID'=>'670B84FD7C216D4EE055736AECE8644D'], 'USER_NAME=:USER_NAME', ['USER_NAME'=>$pageData['USER_NAME']]); unset($pageData); } unset($pageList); echo sprintf("修改所属报单中心，总页数【%s】，当前页数：【%s】写入成功".PHP_EOL, $pageCount, $page); } unset($numCount, $pageCount, $page, $startPage, $limit); return true; } /** * * 环循所有会员找到错误的数据 * @param int $periodNum * @param int $offset * @return bool */ public function actionLoopAllUsersForError($periodNum=115, $offset = 0) { echo '当前offset:' . $offset . PHP_EOL; // 从缓存列表里面从底层往上倒序获取会员 $allData = CalcCache::getUsers($periodNum, $offset, 1000); if($allData) { foreach($allData as $userId){ // 获取到级别以后，给上级的相应人数中追加数量 $parentRecUserId = $userId; $this->loopRelationParentDo($userId, function ($parent) use ($periodNum, &$parentRecUserId) { //判断$parentRecUserId是否为$parent['PARENT_UID']的直推 $parentUid = $parent['PARENT_UID']; $toInfo = CalcCache::getUserInfo($parentRecUserId, $periodNum); if( !isset($toInfo['REC_UID']) ) { echo '错误数据:' . $parentRecUserId . PHP_EOL; } if( isset($toInfo['REC_UID']) && $parentUid !== $toInfo['REC_UID'] ) { $parentUid = $toInfo['REC_UID']; } unset($toInfo); if( !$parentUid ) return 1; //每次记录上次的USER_ID $parentRecUserId = $parentUid; }); unset($userId); } unset($allData); return $this->actionLoopAllUsersForError($periodNum, $offset + 1000); } return true; } /** * 循环推荐网络的父级 * @param $userId * @param callable $callbackFunc * @param int $offset * @return bool */ public function loopRelationParentDo($userId, callable $callbackFunc, int $offset = 0) { $allParents = Cache::getAllRelationParents($userId); $allData = array_slice($allParents, $offset, 1000); unset($allParents); if ($allData) { foreach ($allData as $data) { $funcResult = $callbackFunc($data); if ($funcResult === 1) { return true; } elseif ($funcResult === 2) { continue; } unset($data, $funcResult); } unset($allData); return $this->loopRelationParentDo($userId, $callbackFunc, $offset + 1000); } return true; } /** * 循环父级并执行回调函数 * @param $userId * @param callable $callbackFunc * @param int $offset * @return bool */ public function loopNetworkParentDo($userId, callable $callbackFunc, int $offset = 0) { $allParents = Cache::getAllNetworkParents($userId); $allData = array_slice($allParents, $offset, 1000); unset($allParents); if ($allData) { foreach ($allData as $data) { $funcResult = $callbackFunc($data); if ($funcResult === 1) { return true; } elseif ($funcResult === 2) { continue; } unset($data, $funcResult); } unset($allData); return $this->loopNetworkParentDo($userId, $callbackFunc, $offset + 1000); } return true; } /** * 计算某人某一期的聘级 * @param $userId * @param $periodNum * @return string * @throws Exception * @throws \yii\db\Exception */ public function actionCheckUserEmpLevel($userId, $periodNum) { $bonusCalc = PerfCalc::instance(); $bonusCalc->setPeriodNum($periodNum); $bonusCalc->initCalcTask(); $nowMonthPerf = CalcCache::nowMonthPerf($userId, $periodNum); var_dump($nowMonthPerf); $empLevelData = $bonusCalc->isEmpLevel1($userId, $nowMonthPerf); var_dump($empLevelData); return 'ok' . PHP_EOL; } public function actionCheckYcBonus($userId, $periodNum) { $empLevelConfig = Cache::getEmpLevelConfig(); $nowMonthPerf = CalcCache::nowMonthPerf($userId, $periodNum); // $monthPvPss = $nowMonthPerf['PV_PCS'] + $nowMonthPerf['PV_PSS']; $empLevelId = $nowMonthPerf['EMP_LEVEL']; $empLevel = $empLevelConfig[$empLevelId]; $rxPercent = $empLevel['RX_PERCENT'] ?? 0; if( $rxPercent <= 0 ) { echo 'rxPercent error' . PHP_EOL; return false; } //个人业绩的奖金 $empBonus = $nowMonthPerf['PV_PCS'] * $rxPercent / 100; //2020-06-05修改荣衔奖的计算方式、不由自己的业绩决定、由直推会员的业绩决定 $childList = CalcCache::getChildrenOneDeepFromRedis($userId, $periodNum); foreach ($childList as $child) { $childMaxPercent = CalcCache::ycMaxBonusPercent($child['USER_ID'], $periodNum); $percentDiff = $rxPercent - $childMaxPercent; if( $percentDiff <= 0 ) continue; $childNowMonthPerf = CalcCache::nowMonthPerf($child['USER_ID'], $periodNum); $childBonus = $childNowMonthPerf['PV_PSS_TOTAL'] * $percentDiff / 100; $empBonus += $childBonus; echo sprintf('childUserId:%s,childMaxPercent:%s,childBonus:%s' . PHP_EOL, $child['USER_ID'], $childMaxPercent, $childBonus); unset($child, $childMaxPercent, $percentDiff, $childNowMonthPerf, $childBonus); } unset($childList); echo sprintf('userId:%s,rxPercent:%s,empBonus:%s' . PHP_EOL, $userId, $rxPercent, $empBonus); } /** * 修正移网业绩错误的问题 * @return bool */ public function actionFixMoveNetPerf() { //获取未结算的月份 $noSentPeriod = Period::find()->where('IS_SENT=0')->orderBy('PERIOD_NUM ASC')->asArray()->one(); if( !$noSentPeriod ) return false; $thisYearMonth = $noSentPeriod['CALC_YEAR'].Tool::numFix($noSentPeriod['CALC_MONTH'], 2); $lastYearMonth = Date::lastMonth($noSentPeriod['CALC_YEAR'].'-'.$noSentPeriod['CALC_MONTH'], 'Ym'); // $lastYearMonth = '202003'; echo sprintf("当前期数为:%s,当前结算年月为:%s,上一个结算年月为:%s" . PHP_EOL, $noSentPeriod['PERIOD_NUM'], $thisYearMonth, $lastYearMonth); unset($noSentPeriod); //找到所有的relation的移网 $allRelationList = UserMove::find()->where('TYPE=:TYPE', ['TYPE'=>'relation'])->asArray()->all(); //根据原来的父级、找到所有的原父级 $lastYearMonthPerf = [ '86821386802302976'=>960.000, '76193537884033024'=>1053.000, '76200969452523520'=>1098.000, '76193583539032064'=>360.000, '76220073806794752'=>4678.400, '76218844456292352'=>17825.000, '76219777546326016'=>12316.000, '76220534563672064'=>6844.000, '76220988731297792'=>2680.000, '86805887292936192'=>508.000, '86803242738126848'=>6688.200, '76193502618324992'=>28590.000, '86804998209540096'=>0.000, '86802876130791424'=>8938.000, '76196752000159744'=>436.000, '76189559771238400'=>90423.400, ]; foreach ($allRelationList as $moveData) { echo sprintf("当前用户ID:%s,原看接点人ID:%s,新接点人ID:%s" . PHP_EOL, $moveData['USER_ID'], $moveData['FROM_UID'], $moveData['TO_UID']); if( !isset($lastYearMonthPerf[$moveData['USER_ID']]) || $lastYearMonthPerf[$moveData['USER_ID']] == 0 ) continue; //查找移动点位这个人的上个月的累计业绩 // $lastYearMonthPerf = PerfMonth::find()->where('USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH', ['USER_ID'=>$moveData['USER_ID'], 'CALC_MONTH'=>$lastYearMonth])->asArray()->one(); // echo sprintf("'%s'=>%s," . PHP_EOL, $moveData['USER_ID'], $lastYearMonthPerf['PV_PSS_TOTAL']); //本月的已结算业绩 // $thisPerfPeriodList = PerfPeriod::find()->select(['PV_PCS', 'PERIOD_NUM'])->where('USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH', ['USER_ID'=>$moveData['USER_ID'], 'CALC_MONTH'=>$thisYearMonth])->asArray()->all(); $oldParentList = UserRelation::find()->where('USER_ID=:USER_ID', ['USER_ID'=>$moveData['FROM_UID']])->asArray()->all(); $oldParentUids = [$moveData['FROM_UID']]; foreach ($oldParentList as $oldData) { $oldParentUids[] = $oldData['PARENT_UID']; unset($oldData); } unset($oldParentList); $newParentList = UserRelation::find()->where('USER_ID=:USER_ID', ['USER_ID'=>$moveData['TO_UID']])->asArray()->all(); $newParentUids = [$moveData['TO_UID']]; foreach ($newParentList as $newData) { $newParentUids[] = $newData['PARENT_UID']; unset($newData); } unset($newParentList); //修改上个月的累计业绩 foreach ($oldParentUids as $oldParentUid) {//减 PerfMonth::updateAllCounters(['PV_PSS_TOTAL'=>(-1)*$lastYearMonthPerf[$moveData['USER_ID']]], 'USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH', ['USER_ID'=>$oldParentUid, 'CALC_MONTH'=>$lastYearMonth]); unset($oldParentUid); } foreach ($newParentUids as $newParentUid) {//加 PerfMonth::updateAllCounters(['PV_PSS_TOTAL'=>$lastYearMonthPerf[$moveData['USER_ID']]], 'USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH', ['USER_ID'=>$newParentUid, 'CALC_MONTH'=>$lastYearMonth]); unset($newParentUid); } //修改本月的已结算业绩 // foreach ($thisPerfPeriodList as $periodPerf) { // if( $periodPerf['PV_PCS'] <= 0 ) continue; // // foreach ($oldParentUids as $oldParentUid) {//减 // PerfPeriod::updateAllCounters(['PV_PSS'=>(-1)*$periodPerf['PV_PCS']], 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', ['USER_ID'=>$oldParentUid, 'PERIOD_NUM'=>$periodPerf['PERIOD_NUM']]); // unset($oldParentUid); // } // foreach ($newParentUids as $newParentUid) {//加 // PerfPeriod::updateAllCounters(['PV_PSS'=>$periodPerf['PV_PCS']], 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', ['USER_ID'=>$newParentUid, 'PERIOD_NUM'=>$periodPerf['PERIOD_NUM']]); // unset($newParentUid); // } // // unset($periodPerf); // } unset($moveData); } unset($allRelationList, $thisYearMonth, $lastYearMonth, $lastYearMonthPerf); } /** * 检测聘级 * @param $userId * @param int $periodNum * @throws \yii\db\Exception */ public function actionCheckEmpLevel($userId, $periodNum=115) { $bonusCalc = PerfCalc::instance(); $bonusCalc->setPeriodNum($periodNum); $bonusCalc->initCalcTask(); $userInfo = CalcCache::getUserInfo($userId, $periodNum); $nowMonthPerf = CalcCache::nowMonthPerf($userId, $periodNum); $empLevel = $bonusCalc->checkEmpLevel($userId, $nowMonthPerf, $userInfo['EMP_LV']); var_dump($empLevel); die; } /* * 清空所有会员的剩余业绩 */ public function actionClearSurplusPerf() { $allCount = UserPerf::find()->where('1=1')->orderBy('ID ASC')->count('ID'); $pageSize = 1000; $pageCount = ceil($allCount/$pageSize); for( $page=1;$page<=$pageCount;$page++ ) { echo sprintf('清空所有会员的剩余业绩，总页数为【%d】，当前页数为【%d】' . PHP_EOL, $pageCount, $page); $list = UserPerf::find()->where('1=1')->orderBy('ID ASC')->offset(($page-1)*$pageSize)->limit($pageSize)->asArray()->all(); foreach ($list as $every) { UserPerf::updateAll([ 'SURPLUS_1L' => 0, 'SURPLUS_2L' => 0, 'SURPLUS_3L' => 0, 'SURPLUS_4L' => 0, 'SURPLUS_5L' => 0], 'ID=:ID', ['ID'=>$every['ID']]); unset($every); } unset($list); } } /** * 手动清空RepairCache */ public function actionClearRepairCache() { CalcCache::clearRepairAllCache(); } /** * 修正剩余业绩没有记录的错误 */ public function actionFixSurplusPerf() { $bigPercentPeriod = 116; $pageSize = 1000; for ($periodNum=111;$periodNum<=118;$periodNum++) { $allCount = PerfPeriod::find()->from(PerfPeriod::tableName() . 'AS PP')->select('PP.ID,PP.USER_ID, PP.PV_1L,PP.PV_2L,PP.PV_3L,CBQ.LOGS')->leftJoin(CalcBonusQY::tableName() . ' AS CBQ', 'CBQ.USER_ID=PP.USER_ID AND CBQ.PERIOD_NUM=PP.PERIOD_NUM')->where('PP.PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $periodNum])->orderBy('PP.ID ASC')->count(); $pageCount = ceil($allCount/$pageSize); for ($page=1;$page<=$pageCount;$page++) { $allData = PerfPeriod::find()->from(PerfPeriod::tableName() . 'AS PP')->select('PP.ID,PP.USER_ID, PP.PV_1L,PP.PV_2L,PP.PV_3L,CBQ.LOGS')->leftJoin(CalcBonusQY::tableName() . ' AS CBQ', 'CBQ.USER_ID=PP.USER_ID AND CBQ.PERIOD_NUM=PP.PERIOD_NUM')->where('PP.PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $periodNum])->orderBy('PP.ID ASC')->offset(($page-1)*$pageSize)->limit($pageSize)->asArray()->all(); if( !$allData ) continue; foreach ($allData as $everyData) { if( $everyData['LOGS'] ) { $logData = json_decode($everyData['LOGS'], true); $surplusData = $logData['touchPerfArr']; unset($logData); }else { $surplusData = [ 'SURPLUS_1L' => $everyData['PV_1L'], 'SURPLUS_2L' => $everyData['PV_2L'], 'SURPLUS_3L' => $everyData['PV_3L'], 'SURPLUS_4L' => 0, 'SURPLUS_5L' => 0, ]; } //更新当前记录 PerfPeriod::updateAll($surplusData, 'ID=:ID', ['ID'=>$everyData['ID']]); //更新userPerf if( $periodNum >= $bigPercentPeriod ) { UserPerf::updateAllCounters($surplusData, 'USER_ID=:USER_ID', ['USER_ID'=>$everyData['USER_ID']]); }else { //@todo 存储到缓存中或新字段里 CalcCache::setRepairSurplusPerf($everyData['USER_ID'], $surplusData); } $baseUser = Info::getBaseUserById($everyData['USER_ID']); echo sprintf('当前期数:%s,当前用户ID为:%s,用户名为:%s,更新的数为,一区剩余:%s,二区剩余:%s,三区剩余:%s' . PHP_EOL, $periodNum, $everyData['USER_ID'], $baseUser['USER_NAME'], $surplusData['SURPLUS_1L'], $surplusData['SURPLUS_2L'], $surplusData['SURPLUS_3L']); unset($everyData, $surplusData, $baseUser); } unset($allData); } } } public function actionTestUpdateEmpLevel() { $allCount = PerfMonth::find()->where('CALC_MONTH=:CALC_MONTH', ['CALC_MONTH' => '202005'])->count('ID'); $periodNum = 115; $pageSize = 1000; $pageCount = ceil($allCount / $pageSize); for ($page = 1; $page <= $pageCount; $page++) { $list = PerfMonth::find()->where('CALC_MONTH=:CALC_MONTH', ['CALC_MONTH' => '202005'])->offset(($page - 1) * $pageSize)->limit($pageSize)->asArray()->all(); foreach ($list as $every) { $userInfo = CalcCache::getUserInfo($every['USER_ID'], $periodNum); //更新月业绩的聘级和用户信息中的聘级 CalcCache::nowMonthPerf($every['USER_ID'], $periodNum, [ 'EMP_LEVEL' => $every['LAST_EMP_LV'] ]); if ($userInfo['EMP_LV'] != $every['LAST_EMP_LV']) { $userInfo['EMP_LV'] = $every['LAST_EMP_LV']; CalcCache::setUserInfo($every['USER_ID'], $periodNum, $userInfo); } CalcBonus::updateAll(['LAST_EMP_LV' => $every['LAST_EMP_LV']], 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', ['USER_ID' => $every['USER_ID'], 'PERIOD_NUM' => $periodNum]); unset($every, $userInfo); } unset($list); echo sprintf("更新【聘级】数据，总页数【%s】，当前页数：【%s】导入成功" . PHP_EOL, $pageCount, $page); } } /** * 修正PSS_TOTAL */ public function actionFixPssTotal() { $db = \Yii::$app->db; $sql = "SELECT COUNT(ID) as allCount FROM AR_USER_PERF_NEW WHERE 1=1 ORDER BY ID ASC"; $allCountOne = $db->createCommand($sql)->queryOne(); $pageSize = 1000; $pageCount = ceil($allCountOne['allCount']/$pageSize); for($page=1;$page<=$pageCount;$page++) { echo sprintf('修正PSS_TOTAL，总页数为【%d】，当前页数为【%d】' . PHP_EOL, $pageCount, $page); $offset = ($page-1)*$pageSize; $listSql = "SELECT * FROM AR_USER_PERF_NEW WHERE 1=1 ORDER BY ID ASC LIMIT {$pageSize} OFFSET {$offset}"; $list = $db->createCommand($listSql)->queryAll(); foreach ($list as $every) { //更新pss_total UserPerf::updateAll(['PV_PSS'=>$every['PV_PSS_TOTAL'], 'PV_PSS_TOTAL'=>$every['PV_PSS_TOTAL']], 'USER_ID=:USER_ID', ['USER_ID'=>$every['USER_ID']]); //更新perf_month PerfMonth::updateAll(['PV_PSS_TOTAL'=>$every['PV_PSS_TOTAL']], 'USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH', ['USER_ID'=>$every['USER_ID'], 'CALC_MONTH'=>'202006']); unset($every); } } } public function actionCheckRepairUser($offset, $limit=1000) { $allData = CalcCache::getHasRepairPerfUsers($offset, $limit); if ($allData) { foreach ($allData as $userId) { if( $userId === '102239880700104704' ) { echo 'OK' . PHP_EOL; } } $this->actionCheckRepairUser($offset+$limit); } echo 'END' . PHP_EOL; } /** * 在数据库查询注册的前7人 * @param int $limit */ public function actionCheckGxCreateAt($limit=7) { $userId = '110188471594913792'; $list = UserInfo::findUseDbCalc()->select('USER_ID')->where('USER_ID>:USER_ID', [ 'USER_ID' => $userId, ])->orderBy('USER_ID ASC')->limit($limit)->asArray()->all(); foreach ($list as $every) { echo $every['USER_ID'] . PHP_EOL; } } public function actionRelationList($userId) { $this->loopRelationParentDo($userId, function ($parent) { $parentUid = $parent['PARENT_UID']; echo $parentUid . PHP_EOL; }); } /** * 检测用户服务奖金 * @param string $userId * @param int $periodNum * @throws \yii\db\Exception */ public function actionCheckUserBdQyBonus($userId='', $periodNum=125) { // 从缓存中获取会员的业绩信息 $perfData = CalcCache::nowPeriodPerf($userId, $periodNum); // 从缓存中获取会员的上期结余业绩信息 $pervSurplusPerf = CalcCache::surplusPerf($userId, $periodNum); // 本期 + 上期结余 $perfArr = [ 'SURPLUS_1L_ZC' => $perfData['PV_1L_ZC'] + $pervSurplusPerf['SURPLUS_1L_ZC'], 'SURPLUS_2L_ZC' => $perfData['PV_2L_ZC'] + $pervSurplusPerf['SURPLUS_2L_ZC'], 'SURPLUS_3L_ZC' => $perfData['PV_3L_ZC'] + $pervSurplusPerf['SURPLUS_3L_ZC'], 'SURPLUS_4L_ZC' => $perfData['PV_4L_ZC'] + $pervSurplusPerf['SURPLUS_4L_ZC'], 'SURPLUS_5L_ZC' => $perfData['PV_5L_ZC'] + $pervSurplusPerf['SURPLUS_5L_ZC'], ]; $oriPerfArr = [ 'perfArr' => $perfArr, 'touchBonus' => 0, ]; // 获取会员的报单级别 $userBaseInfo = CalcCache::getUserInfo($userId, $periodNum); $decLevelConfig = Cache::getDecLevelConfig(); // 对碰 $touchBonusArr = $this->touchPerf($oriPerfArr, $perfArr, $userBaseInfo['DEC_LV'], $decLevelConfig); // $nowDecLevelConfig = $decLevelConfig[$userBaseInfo['DEC_LV']]; $touchPerfArr = []; foreach ($touchBonusArr['perfArr'] as $keyR => $perfR) { $touchPerfArr[$keyR] = $perfR; } var_dump($touchBonusArr);die; // 对碰完成后把结余的业绩存入本期业绩缓存中 if ($touchBonusArr['touchBonus'] <= 0) return; $teamBonus = $touchBonusArr['touchBonus']; // 把对碰后的奖金存入缓存中 // CalcCache::bonus($userId, $periodNum, 'BONUS_QY_BD', $teamBonus, [ // 'reConsumePoints' => 0, // 'manageTax' => 0, // 'surplus' => $teamBonus, // ]); unset($perfData, $pervSurplusPerf, $perfArr, $oriPerfArr, $touchPerfArr, $userBaseInfo, $decLevelConfig, $touchBonusArr, $userId, $nowDecLevelConfig, $teamBonus, $deductData); } /** * 对碰 * @param array $oriPerfArr * @param array $perfArr * @param $decLevel * @param $decLevelConfig * @param $loopTimes * @return array */ public function touchPerf(array $oriPerfArr, array $perfArr, $decLevel, $decLevelConfig, $loopTimes=1) { $resultArr = $oriPerfArr; foreach ($perfArr as $keyT => $perfT) { if ($perfT <= 0) { unset($perfArr[$keyT]); } } if (count($perfArr) >= 2 && $loopTimes < 6) { $nowDecLevelConfig = $decLevelConfig[$decLevel]; arsort($perfArr, SORT_NUMERIC); $onePerf = null; $oneKey = null; // $touchSurplusAmount = 0; $touchAmount = 0; // 前两个进行对碰 foreach ($perfArr as $key => $perf) { if ($onePerf === null) { $oneKey = $key; $onePerf = $perf; } else { $touchSurplusAmount = $perf - $onePerf; if ($touchSurplusAmount > 0) { unset($perfArr[$oneKey]); $resultArr['perfArr'][$oneKey] = 0; $perfArr[$key] = $touchSurplusAmount; $touchAmount = $onePerf; } elseif ($touchSurplusAmount < 0) { unset($perfArr[$key]); $resultArr['perfArr'][$key] = 0; $perfArr[$oneKey] = abs($touchSurplusAmount); $touchAmount = $perf; } else { unset($perfArr[$oneKey], $perfArr[$key]); $resultArr['perfArr'][$oneKey] = 0; $resultArr['perfArr'][$key] = 0; $touchAmount = $perf; } break; } } /*if ($touchAmount > $nowDecLevelConfig['QY_TOUCH_CAP']) { $touchAmount = $nowDecLevelConfig['QY_TOUCH_CAP']; }*/ $touchBonus = Tool::formatPrice($touchAmount * $nowDecLevelConfig['QY_PERCENT'] / 100); // if ($touchBonus > $nowDecLevelConfig['QY_TOUCH_CAP']) { // $resultArr['touchBonus'] += $nowDecLevelConfig['QY_TOUCH_CAP']; // } else { // $resultArr['touchBonus'] += $touchBonus; // } $resultArr['touchBonus'] += $touchBonus; foreach ($perfArr as $keyR => $perfR) { $resultArr['perfArr'][$keyR] = $perfR; } return $this->touchPerf($resultArr, $perfArr, $decLevel, $decLevelConfig, $loopTimes+1); } return $resultArr; } /** * 检测用户报单管理奖奖金 * @param string $userId * @param string $parentUid * @param int $periodNum * @throws \yii\db\Exception */ public function actionCheckUserBdGlBonus($userId='', $parentUid='', $periodNum=125) { //会员信息 $decLevelConfig = Cache::getDecLevelConfig(); $netWorkParents = Cache::getAllRelationParents($userId); $userBaseInfo = CalcCache::getUserInfo($userId, $periodNum); $userEmpLevel = $userBaseInfo['EMP_LV']; foreach ($netWorkParents as $netWorkParent) { echo '父级ID：' . $netWorkParent['PARENT_UID'] . PHP_EOL; //自已距顶端的深度减去父级距顶端的深度 $diffLayer = $netWorkParent['TOP_DEEP'] - $netWorkParent['PARENT_DEEP']; if( $diffLayer <= 0) continue; //@todo 超过最大代数就跳出本次循环 //偶数代跳过 if( $diffLayer % 2 == 0 ) continue; // 获取会员的报单级别 $bonusUserId = $netWorkParent['PARENT_UID']; if( !$bonusUserId ) continue; if( $bonusUserId != $parentUid ) continue; $bonusUserBaseInfo = CalcCache::getUserInfo($bonusUserId, $periodNum); $nowDecLevelConfig = $decLevelConfig[$bonusUserBaseInfo['DEC_LV']]; if( !$nowDecLevelConfig ) continue; //推荐人数 $recNum = $bonusUserBaseInfo['REC_NUM']; if( $recNum <= 0 ) continue; if( $recNum == 1 ) { $maxOddLayer = $nowDecLevelConfig['GL_ODD_DEEP_ONE']; }else if( $recNum == 2 ) { $maxOddLayer = $nowDecLevelConfig['GL_ODD_DEEP_TWO']; }else { $maxOddLayer = $nowDecLevelConfig['GL_ODD_DEEP_THREE']; } //超过代数上限也跳过 if( $diffLayer >= 2 * $maxOddLayer ) continue; $everyLayer = floor(2 * $nowDecLevelConfig['GL_ODD_DEEP_THREE'] / $nowDecLevelConfig['SORT']); //多少代 // $theLayer = $diffLayer % $everyLayer; $theLayerLevel = floor($diffLayer/$everyLayer); $parentOddPercentName = sprintf('parentOddPercent_%s', $theLayerLevel); if( !isset($this->_sysConfig[$parentOddPercentName]) ) continue; $bonusPercent = $this->_sysConfig[$parentOddPercentName]['VALUE']; // 从缓存中获取会员的收入信息 $incomeBonus = CalcCache::bonus($userId, $periodNum); $parentOddIncomeFromName = sprintf('parentOddIncomeFrom_%s', $theLayerLevel); $parentOddIncomeFrom = explode(',', $this->_sysConfig[$parentOddIncomeFromName]['VALUE']); $parentOddIncome = 0; foreach ($parentOddIncomeFrom as $incomeType) { if( $incomeType === 'TG' ) { $incomeTypeName = sprintf('ORI_BONUS_%s', $incomeType); }else { $incomeTypeName = sprintf('ORI_BONUS_%s_BD', $incomeType); } $incomeTypeValue = $incomeBonus[$incomeTypeName] ?? 0; $parentOddIncome += $incomeTypeValue; unset($incomeType, $incomeTypeName, $incomeTypeValue); } unset($parentOddIncomeFrom); $manageBonus = Tool::formatPrice($parentOddIncome * $bonusPercent / 100); var_dump($manageBonus);die; if ($manageBonus <= 0) continue; //总金额限制 // $manageBonus = $this->bonusTotalLimit($manageBonus, $bonusUserId, $recNum, $bonusUserBaseInfo['ZC_AMOUNT']); // if( $manageBonus <= 0 ) continue; //扣除相应的复消积分和管理费 // $deductData = $this->deduct($bonusUserId, $manageBonus); // CalcCache::bonus($bonusUserId, $periodNum, 'BONUS_GL', $manageBonus, $deductData, CalcCache::FROM_MEANS_BD); //管理奖流水 unset($netWorkParent, $diffLayer, $bonusUserId, $bonusUserBaseInfo, $bonusPercent, $nowDecLevelConfig, $manageBonus, $incomeBonus, $maxOddLayer, $theLayerLevel, $recNum, $parentOddPercentName, $parentOddIncomeFromName, $deductData); } unset($userId, $userBaseInfo, $userEmpLevel, $netWorkParents, $decLevelConfig); } /** * 修改总业绩 */ public function actionModifyPssTotal() { $modifyData = [ 'Q08186744' => 600.01, 'Q62088906' => 150, 'Q08480433' => 150, 'Q43506253' => 48.75, 'Q12863038' => 600.01, 'Q78680727' => 41.25, 'Q94839185' => 308265.61, 'A14938155' => 11206.89, 'H779051HD' => 162.5, 'D75201679' => 150, 'H49297159' => 481.25, 'H17118288' => 481.25, 'A12336641' => -160, 'D18233466' => 157.5, 'H19657853' => -1320, 'H17219628' => -120, 'H10821466' => -1320, 'H11050788' => -4920, 'H15532405' => -1320, 'H65057238' => -360, 'H49978401' => -720, 'H17767474' => -1260, 'F17628577' => -4008, 'F17072646' => -359.99, 'F59854958' => -240, 'F10634375' => -1440, 'F17425461' => -120, 'F18852157' => -593, 'F68846358' => -2301.99, 'Q14703000' => -120, 'D17865446' => -112, 'D16104173' => -119.99, 'D19426525' => -360, 'D13146869' => -420, 'D13336250' => -845, 'Q16475055' => -120, 'E19911439' => -159, 'E17429791' => -166, 'E14226349' => -240, 'E16315856' => -480, 'E18363352' => -240, 'E18322188' => -120, 'A19477210' => -120, 'A13628496791' => -240, 'A14488417' => -120, 'A15836950' => -120, 'E69809425' => -480, 'D14193606' => -360, 'D13663861' => -120, 'D10776466' => -240, 'D11736447' => -120, 'D13128139' => -725, 'D15308257' => -360, 'D19443335' => -855, 'H16408887' => -960, 'H15328699' => -120, 'H18951571' => -480, 'H15167279' => -480, 'H15382316' => -360, 'H12129027' => -240, 'H15359261' => -840, 'H16004849' => -120, 'H14711148' => -120, 'H14276238' => -240, 'H69162532' => -240, 'H93297042' => -4680, 'H88875817' => -120, 'H11847679' => -120, 'F90795660' => -3768, 'F17797628' => -840, 'F17546019' => -473, 'F15803008' => -2062, 'H10394296' => -960, 'E17839915' => -166, 'E13466446' => -240, 'A16594718' => -240, 'A19671826' => -120, 'A15198548' => -120, 'A51726927' => -2635.98, 'H11036379' => -240, 'H12907432' => -817.99, 'H17973140' => -960, 'H12666892' => -600, 'H11866173' => -2460, 'E10658077' => -120, 'E17573755' => -480, 'E45944014' => -1184, 'E15960537' => -240, 'E12683263' => -592, 'E11002878' => -360, 'E10602731' => -120, 'A17081891' => -120, 'A18717229' => -835.98, 'H11097065' => -1200, 'H19578891' => -1080, 'H12505489' => -120, 'H10746043' => -960, 'E12569967' => -120, 'H11295941' => -1666, 'H59287202' => -120, 'H18132610' => -120, 'H18113300' => -240, 'H19096880' => -120, 'H12050104' => -480, 'H10655472' => -3000, 'H12439274' => -720, 'F31467862' => -3528, 'F29042730' => -360, 'F10062708' => -982, 'F60226072' => -120, 'E13291482' => -120, 'D13390146' => -360, 'D15369301' => -376, 'D10058595' => -240, 'H17368844' => -120, 'H17673492' => -360, 'H40420622' => -120, 'H37612456' => -240, 'H16239634' => -720, 'H19200443' => -2760, 'F10693156' => -3407.99, 'F15664716' => -360, 'F14542850' => -120, 'F15821274' => -600, 'A14314525' => -120, 'A16968827' => -480, 'D19551159' => -240, 'D17359769' => -120, 'D17464140' => -240, 'D12103432' => -128, 'H11158785' => -578, 'H11304078' => -120, 'H38384841' => -120, 'H15263058' => -120, 'H44636655' => -240, 'H13540567' => -720, 'H11372262' => -2160, 'H95402009' => -1260, 'H59876727' => -960, 'F16723562' => -819.99, 'F14010022' => -2468, 'F16485738' => -360, 'F17398416' => -360, 'F11668609' => -120, 'E14666737' => -120, 'E18812880' => -213, 'D13299101' => -240, 'D18768019' => -120, 'D18898064' => -128, 'D16748142' => -240, 'H19464479' => -1080, 'H11879978' => -240, 'H18864434' => -840, 'H15868186' => -120, 'H68332692' => -720, 'H50691564' => -2160, 'F17368654' => -2348, 'F17121859' => -699.99, 'H93093611' => -600, 'A17962339' => -120, 'A18358406' => -480, 'D15539120' => -240, 'D19181661' => -240, 'H17928312' => -960, 'H14358188' => -840, 'H10699566' => -1666, 'H15912596' => -240, 'H31173575' => -480, 'H19433676' => -240, 'H17288092' => -360, 'A17816239' => -120, 'A10678307' => -360, 'H23275366' => -720, 'H12591081' => -240, 'H16504568' => -840, 'H16531555' => -480, 'H38486089' => -600, 'H83574838' => -1320, 'H18357186' => -120, 'H16049391' => -120, 'H16379925' => -240, 'F13307818' => -120, 'F11580708' => -1868, 'F11108484' => -120, 'H13915722' => -360, 'D15805087' => -120, 'D15467159' => -240, 'H10366600' => -720, 'H63372506' => -120, 'H14710441' => -840, 'H10090408' => -1666, 'H33154162' => -360, 'H15358396' => -480, 'H72700605' => -840, 'H12827073' => -480, 'F15846968' => -1748, 'H16660022' => -360, 'D11624328' => -240, 'H11552847' => -1666, 'H19166726' => -240, 'H14364498' => -480, 'H17797668' => -600, 'H12452235' => -480, 'H18592203' => -120, 'F14890926' => -1628, 'D13778545' => -240, 'H11066019' => -600, 'H11306623' => -120, 'H16157527' => -840, 'H13701187' => -240, 'H18248205' => -600, 'H17907648' => -840, 'H13779328' => -1666, 'H19450811' => -240, 'H17008421' => -480, 'H16387500' => -840, 'H91950177' => -1666, 'H18592565' => -240, 'H77879934' => -1666, 'H13711477' => -120, 'H13833502' => -240, 'H12286615' => -240, 'F17783334' => -1148, 'D11204865' => -240, 'H17393209' => -480, 'H17832251' => -840, 'H10164361' => -240, 'H19291917' => -120, 'H16253624' => -720, 'H15216330' => -120, 'F12562440' => -680, 'D15177935' => -240, 'H17439829' => -840, 'H19424150' => -480, 'H13125893' => -840, 'H24399895' => -840, 'H10159130' => -840, 'H11682345' => -840, 'H17826076' => -840, 'H10656939' => -840, 'H17396420' => -840, 'H10514419' => -840, 'H16934767' => -840, 'H14181865' => -840, 'H16130940' => -840, 'H17608191' => -840, 'H11569007' => -840, 'H14576782' => -840, 'H15577686' => -840, 'H11753266' => -840, 'H12284905' => -720, 'H15872474' => -720, 'H13200796' => -600, 'H15478592' => -480, 'H19659132' => -480, 'D12199046' => 503.75, 'D19795156' => 155, 'D15436866' => 155, 'H49758932' => -360, 'H16852727' => -360, 'H15064959' => -360, 'H15043547' => -360, 'H14896153' => -360, 'H12062745' => -360, 'H11705904' => -360, 'H44310375' => -360, 'H17570490' => -360, 'H15866731' => -360, 'H10082397' => -360, 'H17197020' => -360, 'H96244925' => -360, 'H18278522' => -360, 'H16921167' => -360, 'H11746826' => -360, 'H14231961' => -360, 'H17528587' => -360, 'H19118260' => -360, 'H12448611' => -360, 'H16502115' => -360, 'H66096080' => -360, 'H13333591' => -360, 'H12704168' => -360, 'H10822555' => -360, 'H27825190' => -360, 'H62054512' => -360, 'H18450323' => -360, 'H16863190' => -360, 'H11241039' => -360, 'H15641979' => -360, 'H15453609' => -360, 'H88069590' => -360, 'H17085313' => -360, 'H13018948' => -360, 'H12503677' => -360, 'H46274824' => -360, 'H50970678' => -360, 'H15757860' => -360, 'H65559852' => -360, 'H15888980' => -360, 'H18669651' => -240, 'H12966470' => -240, 'H15605405' => -240, 'H13302229' => -240, 'H19988098' => -240, 'H19139717' => -240, 'H17419145' => -240, 'H15179291' => -240, 'H15024184' => -240, 'H13577736' => -240, 'D13347854' => 200, 'H16105967' => -240, 'H10292657' => -240, 'H14109018' => -240, 'H15892232' => -240, 'H10659498' => -240, 'H18383896' => -240, 'H14304440' => -240, 'H97331452' => -240, 'H12055085' => -240, 'H87950486' => -240, 'H13902912' => -240, 'H14311006' => -240, 'H89043517' => -240, 'H20947501' => -240, 'H10466894' => -240, 'H19591200' => -240, 'H19920650' => -240, 'H10809534' => -240, 'H13081445' => -240, 'H19304638' => -240, 'H17167739' => -240, 'H13575379' => -240, 'H19106582' => -240, 'H17782450' => -240, 'H11446432' => -240, 'H15058672' => -240, 'H10535417' => -240, 'H92052401' => -240, 'H11517133' => -240, 'H80093994' => -240, 'H11956092' => -240, 'H17165790' => -240, 'H11424567' => -240, 'H19560581' => -240, 'H19423232' => -240, 'H16184781' => -240, 'H10780996' => -240, 'H12168567' => -240, 'H69093228' => -240, 'H10849787' => -240, 'D18829108' => 200, 'D18507164' => 347.5, 'Q73338908' => 150, 'Q69472907' => 150 ]; foreach ($modifyData as $username => $modifyValue) { $oneUser = User::find()->select(['ID', 'USER_NAME'])->where('USER_NAME=:USER_NAME', ['USER_NAME'=>$username])->asArray()->one(); if( !$oneUser ) { echo sprintf('用户%s不存在' . PHP_EOL, $username); continue; } $realModifyValue = (-1) * $modifyValue; UserPerf::updateAllCounters(['PV_PSS_TOTAL'=>$realModifyValue], 'USER_ID=:USER_ID', ['USER_ID'=>$oneUser['ID']]); echo sprintf('用户%s变化业绩为：%s' . PHP_EOL, $username, $realModifyValue); unset($username, $modifyValue, $oneUser, $realModifyValue); } } public function actionGetYcData($userId, $periodNum=132) { $ycBonusData = CalcCache::getYCBonusList($userId, $periodNum); if( $ycBonusData ) { if( $ycBonusData['fromData'] ) { foreach ($ycBonusData['fromData'] as $every) { //fromPvPcs fromUid $fromBaseInfo = CalcCache::getUserInfo($every['fromUid'], $periodNum); echo sprintf("来源用户名：%s,来源用户pv：%s" . PHP_EOL, $fromBaseInfo['USER_NAME'], $every['fromPvPcs']); } } } } /** * 计算某期复消现金金额 */ public function actionCalcPeriodFxCash() { $periodNumList = [146]; foreach ($periodNumList as $periodNum) { $this->_calcPeriodFxCash($periodNum); } } private function _calcPeriodFxCash($periodNum) { //复消订单 $pageSize = 1000; $allCount = Order::findUseDbCalc()->where("PERIOD_NUM=:PERIOD_NUM AND IS_DELETE=0 AND ORDER_TYPE=:ORDER_TYPE", [':PERIOD_NUM' => $periodNum, ':ORDER_TYPE'=>DeclarationForm::TYPE_FX])->count('ID'); $pageCount = ceil($allCount/$pageSize); for ($page=1;$page<=$pageCount;$page++) { echo sprintf('期数：%s，复消订单：当前页数%s，总页数：%s' . PHP_EOL, $periodNum, $page, $pageCount); $allData = Order::findUseDbCalc()->select('ID,SN,DEC_SN,USER_ID,ORDER_TYPE,ORDER_AMOUNT,PAY_AMOUNT,PAY_PV,PAY_TYPE,PERIOD_NUM,STATUS,IS_DELETE,P_CALC_MONTH,CREATED_AT')->where("PERIOD_NUM=:PERIOD_NUM AND IS_DELETE=0 AND ORDER_TYPE=:ORDER_TYPE", [':PERIOD_NUM' => $periodNum, ':ORDER_TYPE'=>DeclarationForm::TYPE_FX])->orderBy('CREATED_AT DESC,ID DESC')->offset(($page-1)*$pageSize)->limit($pageSize)->asArray()->all(); if( $allData ) { foreach ($allData as $data) { //如果支付方式是现金，那么实际业绩是支付PV的50% if ($data['PAY_TYPE'] === 'cash') { PerfPeriod::updateAll([ 'FX_AMOUNT_CASH'=>new Expression('FX_AMOUNT_CASH+' . $data['ORDER_AMOUNT']) ], 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', ['USER_ID'=>$data['USER_ID'], 'PERIOD_NUM'=>$periodNum]); } unset($data); } } unset($allData); } unset($allCount, $pageCount, $page); //导入的复消订单 $allCount = OrderShop::findUseDbCalc()->where("PERIOD_NUM=:PERIOD_NUM AND IS_DELETE=0 AND ORDER_TYPE=:ORDER_TYPE", [':PERIOD_NUM' => $periodNum, ':ORDER_TYPE'=>DeclarationForm::TYPE_FX])->count('ID'); $pageCount = ceil($allCount/$pageSize); for ($page=1;$page<=$pageCount;$page++) { echo sprintf('期数：%s，导入订单：当前页数%s，总页数：%s' . PHP_EOL, $periodNum, $page, $pageCount); $allData = OrderShop::findUseDbCalc()->select('ID,SN,DEC_SN,USER_ID,ORDER_TYPE,ORDER_AMOUNT,PAY_AMOUNT,PAY_PV,PAY_TYPE,PERIOD_NUM,STATUS,IS_DELETE,P_CALC_MONTH,CREATED_AT')->where("PERIOD_NUM=:PERIOD_NUM AND IS_DELETE=0 AND ORDER_TYPE=:ORDER_TYPE", [':PERIOD_NUM' => $periodNum, ':ORDER_TYPE'=>DeclarationForm::TYPE_FX])->orderBy('CREATED_AT DESC,ID DESC')->offset(($page-1)*$pageSize)->limit($pageSize)->asArray()->all(); if( $allData ) { foreach ($allData as $data) { //如果支付方式是现金，那么实际业绩是支付PV的50% if ($data['PAY_TYPE'] === 'cash') { PerfPeriod::updateAll([ 'FX_AMOUNT_CASH'=>new Expression('FX_AMOUNT_CASH+' . $data['ORDER_AMOUNT']) ], 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', ['USER_ID'=>$data['USER_ID'], 'PERIOD_NUM'=>$periodNum]); } unset($data); } } unset($allData); } unset($allCount, $pageCount, $page); } public function actionCheckGxNextFive() { $userId = '76190398896279552'; $periodNum = 160; $bonusUserData = []; $sysConfig = Cache::getSystemConfig(); $bonusPercentTwo = $sysConfig['sharePercent']['VALUE'] / 100; // 从缓存中获取会员的收入信息 $incomeBonus = CalcCache::bonus($userId, $periodNum); $lastTwoIncome = $incomeBonus['ORI_BONUS_QY_BD'] ?? 0; unset($lastTwoIncome); $nextFiveIncome = $incomeBonus['ORI_BONUS_QY_BD'] ?? 0; $shareBonusTwo = $nextFiveIncome * $bonusPercentTwo; unset($nextFiveIncome); //找到下5代(安置网) 紧缩 相对偶数层2、4、6、8、10层 if( $shareBonusTwo > 0 ) { $validDeep = 1; $this->loopNetworkParentDo($userId, function ($parent) use ($userId, $shareBonusTwo,$periodNum, &$validDeep, &$bonusUserData) { if ( $validDeep % 2 === 0 ) { $bonusUserData[] = [ 'bonusUid' => $parent['PARENT_UID'], 'bonus' => $shareBonusTwo ]; } //判断$parent是否有首单团队奖 $parentBonus = CalcCache::bonus($parent['PARENT_UID'], $periodNum); if( $parentBonus['ORI_BONUS_QY_BD'] > 0 ) {//有效层 $validDeep += 1; } unset($parent, $parentBonus); if ( $validDeep >= 11 ) { return 1; } }); unset($validDeep); } // if ( !$bonusUserData ) return; var_dump($bonusUserData);die; } public function actionCheckGxLastTwo() { $userId = '76189391281852416'; $periodNum = 160; $bonusUserData = []; $bonusPercentOne = 5 / 100; // 从缓存中获取会员的收入信息 $incomeBonus = CalcCache::bonus($userId, $periodNum); $lastTwoIncome = $incomeBonus['ORI_BONUS_QY_BD'] ?? 0; $shareBonusOne = $lastTwoIncome * $bonusPercentOne; unset($lastTwoIncome); //找到上2代 新增个人+推荐团队业绩 加权平均分配 这个奖 if( $shareBonusOne > 0) { $bonusUserList = CalcCache::getShareBonusOneRelation($userId, $periodNum); if( $bonusUserList ) { $bonusUserTotalPerf = 0; $bonusUserRealList = []; foreach ($bonusUserList as $bonusUserId) { //查看该用户的个人业绩和团队新增业绩总和 $nowPeriodData = CalcCache::nowPeriodPerf($bonusUserId, $periodNum); //本期新增业绩 $bonusUserPerf = $nowPeriodData['PV_PCS'] + $nowPeriodData['PV_PSS']; if ($bonusUserPerf <= 0) { unset($bonusUserId, $nowPeriodData, $bonusUserPerf); continue; } $bonusUserTotalPerf += $bonusUserPerf; $bonusUserRealList[] = [ 'bonusUserId' => $bonusUserId, 'bonusUserPerf' => $bonusUserPerf ]; unset($bonusUserId, $nowPeriodData, $bonusUserPerf); } unset($bonusUserList); foreach ($bonusUserRealList as $everyData) { $bonusUserData[] = [ 'bonusUid' => $everyData['bonusUserId'], 'bonus' => $shareBonusOne * $everyData['bonusUserPerf'] / $bonusUserTotalPerf ]; unset($everyData); } unset($bonusUserRealList); } } var_dump($bonusUserData);die; } public function actionCheckGxMonthData() { //查看是否复消300 $userId = '76189026280935424'; $periodNum = 162; $sysConfig = Cache::getSystemConfig(); $monthPerfData = CalcCache::nowMonthPerf($userId, $periodNum); $fxPvStatus = $monthPerfData['PV_PCS_FX'] >= $sysConfig['monthPcsPvFxCondition']['VALUE']; if ( $fxPvStatus ) {//加上本期和往期的共享和管理奖 $monthSumData = CalcBonus::findUseSlaves()->select('SUM(BONUS_GX) AS BONUS_GX_SUM, SUM(BONUS_GL) AS BONUS_GL_SUM')->where('USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH', ['USER_ID'=>$userId, 'CALC_MONTH'=>'202104'])->asArray()->one(); $bonus = CalcCache::bonus($userId, $periodNum); $bonusGxSum = $monthSumData['BONUS_GX_SUM'] ?? 0; $bonusGlSum = $monthSumData['BONUS_GL_SUM'] ?? 0; $realBonusGx = $bonusGxSum + $bonus['BONUS_GX']; $realBonusGl = $bonusGlSum + $bonus['BONUS_GL']; var_dump($realBonusGx, $realBonusGl);die; } echo "..OK" . PHP_EOL; } /** * 根据奖金表中的记录 */ public function actionAddMonthBonusUser($calcMonth) { // $calcMonth = '202104'; $pageSize = 1000; $allCount = CalcBonus::find()->where('CALC_MONTH=:CALC_MONTH', [ 'CALC_MONTH' => $calcMonth ])->asArray()->count(); $pageCount = ceil($allCount/$pageSize); for($page=1;$page<=$pageCount;$page++) { echo sprintf('【%d】月奖金用户，总页数为【%d】，当前页数为【%d】' . PHP_EOL, $calcMonth, $pageCount, $page); $insertDataBonusUser = []; $offset = ($page-1)*$pageSize; $listData = CalcBonus::find()->select('USER_ID,CALC_MONTH,PERIOD_NUM,ORI_BONUS_GX,ORI_BONUS_GL')->where('CALC_MONTH=:CALC_MONTH', [ 'CALC_MONTH' => $calcMonth ])->offset($offset)->limit($pageSize)->asArray()->all(); foreach ($listData as $everyData) { if( $everyData['ORI_BONUS_GX'] == 0 && $everyData['ORI_BONUS_GL'] == 0 ) continue; $insertDataBonusUser[] = [ 'ID' => SnowFake::instance()->generateId(), 'USER_ID' => $everyData['USER_ID'], 'CALC_MONTH' => $everyData['CALC_MONTH'], 'PERIOD_NUM' => $everyData['PERIOD_NUM'], 'CREATED_AT' => Date::nowTime() ]; } if( $insertDataBonusUser ) CalcMonthBonusUser::batchInsert($insertDataBonusUser); unset($listData, $insertDataBonusUser); } } /** * 后续计算共享和管理奖 * @param $tableName * @param $toPeriod * @throws \yii\db\Exception */ public function actionAfterCalcBonusGxAndGl($tableName, $toPeriod) { $db = \Yii::$app->db; $fromTableName = sprintf("AR_CALC_BONUS_%s", $tableName); $sql = "SELECT COUNT(ID) as allCount FROM {$fromTableName} WHERE PERIOD_NUM={$toPeriod} ORDER BY ID ASC"; $allCountOne = $db->createCommand($sql)->queryOne(); $pageSize = 1000; $pageCount = ceil($allCountOne['allCount']/$pageSize); for($page=1;$page<=$pageCount;$page++) { echo sprintf('同步【%d】期的数据，总页数为【%d】，当前页数为【%d】' . PHP_EOL, $toPeriod, $pageCount, $page); $offset = ($page-1)*$pageSize; $listSql = "SELECT * FROM {$fromTableName} WHERE PERIOD_NUM={$toPeriod} ORDER BY ID ASC LIMIT {$pageSize} OFFSET {$offset}"; $list = $db->createCommand($listSql)->queryAll(); foreach ($list as $every) { //判断该会员在AR_CALC_BONUS 表中 对应期数是否有相应的数据，有就更新，没有就插入。 $one = CalcBonus::find()->where('USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', ['USER_ID'=>$every['USER_ID'], 'PERIOD_NUM'=>$toPeriod])->asArray()->one(); if( $one ) { CalcBonus::updateAll([ 'BONUS_GX' => $every['BONUS_GX'], 'ORI_BONUS_GX' => $every['ORI_BONUS_GX'], 'REAL_BONUS_GX' => $every['REAL_BONUS_GX'], 'BONUS_GL' => $every['BONUS_GL'], 'ORI_BONUS_GL' => $every['ORI_BONUS_GL'], 'REAL_BONUS_GL' => $every['REAL_BONUS_GL'], ], 'ID=:ID', ['ID'=>$one['ID']]); }else { $insertData = $every; $insertData['ID'] = SnowFake::instance()->generateId(); $insertData['IS_SENT'] = 1; $insertData['SENT_AT'] = Date::nowTime(); CalcBonus::insertOne($insertData); unset($insertData); } unset($every, $one); } } } /** * 补发$fromPeriod 共享和管理实发奖金 * @param $fromPeriod * @throws Exception * @throws \yii\db\Exception */ public function actionSendBonusGxAndGl($fromPeriod) { $allCount = CalcBonus::find()->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$fromPeriod])->asArray()->count(1); $pageSize = 1000; $pageCount = ceil($allCount/$pageSize); for($page=1;$page<=$pageCount;$page++) { echo sprintf('补发【%d】期共享奖金和管理奖金，总页数为【%d】，当前页数为【%d】' . PHP_EOL, $fromPeriod, $pageCount, $page); $offset = ($page-1)*$pageSize; $pageList = CalcBonus::find()->select(['USER_ID', 'REAL_BONUS_GX', 'REAL_BONUS_GL'])->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$fromPeriod])->offset($offset)->limit($pageSize)->asArray()->all(); foreach ($pageList as $everyData) { $sendBonus = $everyData['REAL_BONUS_GX'] + $everyData['REAL_BONUS_GL']; if( $sendBonus <= 0 ) { unset($everyData, $sendBonus); continue; } Balance::changeUserBonus($everyData['USER_ID'], 'bonus', $sendBonus, [ 'REMARK' => 'From ' . $fromPeriod . '期补发共享和管理奖', 'PERIOD_NUM' => $fromPeriod, 'DEAL_TYPE_ID' => DealType::BONUS_SEND, ]); unset($everyData, $sendBonus); } } } public function actionCheckGxMinPv() { $userId = '76190155484041216'; $periodNum = 160; $bonusCalc = BonusCalc::instance(); $bonusCalc->setPeriodNum($periodNum); $rt = $bonusCalc->checkSmallMarketPerf($userId); var_dump($rt); return 'ok' . PHP_EOL; } /** * 同步VIP奖 * @param $tableName * @param $toPeriod * @throws \yii\db\Exception */ public function actionAfterCalcBonusVip($tableName, $toPeriod) { $db = \Yii::$app->db; $fromTableName = sprintf("AR_CALC_BONUS_%s", $tableName); $sql = "SELECT COUNT(ID) as allCount FROM {$fromTableName} WHERE PERIOD_NUM={$toPeriod} ORDER BY ID ASC"; $allCountOne = $db->createCommand($sql)->queryOne(); $pageSize = 1000; $pageCount = ceil($allCountOne['allCount']/$pageSize); for($page=1;$page<=$pageCount;$page++) { echo sprintf('同步【%d】期的VIP数据，总页数为【%d】，当前页数为【%d】' . PHP_EOL, $toPeriod, $pageCount, $page); $offset = ($page-1)*$pageSize; $listSql = "SELECT * FROM {$fromTableName} WHERE PERIOD_NUM={$toPeriod} ORDER BY ID ASC LIMIT {$pageSize} OFFSET {$offset}"; $list = $db->createCommand($listSql)->queryAll(); foreach ($list as $every) { //判断该会员在AR_CALC_BONUS 表中 对应期数是否有相应的数据，有就更新，没有就插入。 $one = CalcBonus::find()->where('USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', ['USER_ID'=>$every['USER_ID'], 'PERIOD_NUM'=>$toPeriod])->asArray()->one(); if( $one ) { CalcBonus::updateAll([ 'BONUS_VIP' => $every['BONUS_VIP'], 'ORI_BONUS_VIP' => $every['ORI_BONUS_VIP'], ], 'ID=:ID', ['ID'=>$one['ID']]); }else { $insertData = $every; $insertData['ID'] = SnowFake::instance()->generateId(); $insertData['IS_SENT'] = 1; $insertData['SENT_AT'] = Date::nowTime(); CalcBonus::insertOne($insertData); unset($insertData); } unset($every, $one); } } } /** * 补发VIP奖 * @param $fromPeriod * @throws Exception * @throws \yii\db\Exception */ public function actionSendBonusVip($fromPeriod) { $allCount = CalcBonus::find()->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$fromPeriod])->asArray()->count(1); $pageSize = 1000; $pageCount = ceil($allCount/$pageSize); for($page=1;$page<=$pageCount;$page++) { echo sprintf('补发【%d】期VIP奖金，总页数为【%d】，当前页数为【%d】' . PHP_EOL, $fromPeriod, $pageCount, $page); $offset = ($page-1)*$pageSize; $pageList = CalcBonus::find()->select(['USER_ID', 'BONUS_VIP', 'ORI_BONUS_VIP'])->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$fromPeriod])->offset($offset)->limit($pageSize)->asArray()->all(); foreach ($pageList as $everyData) { $sendBonus = $everyData['BONUS_VIP']; if( $sendBonus <= 0 ) { unset($everyData, $sendBonus); continue; } Balance::changeUserBonus($everyData['USER_ID'], 'bonus', $sendBonus, [ 'REMARK' => 'From ' . $fromPeriod . '期补发VIP奖', 'PERIOD_NUM' => $fromPeriod, 'DEAL_TYPE_ID' => DealType::BONUS_SEND, ]); unset($everyData, $sendBonus); } } } /** * 补发复消积分对应的奖金 * @param $calcMonth * @throws Exception * @throws \yii\db\Exception */ public function actionSendReConsumePoints($calcMonth) { $pageSize = 1000; $allCount = CalcBonus::find()->where('CALC_MONTH=:CALC_MONTH', [ 'CALC_MONTH' => $calcMonth ])->groupBy('USER_ID')->orderBy('USER_ID DESC')->count(); $pageCount = ceil($allCount/$pageSize); for($page=1;$page<=$pageCount;$page++) { echo sprintf('【%d】补发复消积分，总页数为【%d】，当前页数为【%d】' . PHP_EOL, $calcMonth, $pageCount, $page); $offset = ($page-1)*$pageSize; $list = CalcBonus::find()->select('USER_ID,SUM(ORI_BONUS_GX) AS ORI_BONUS_GX_SUM,SUM(ORI_BONUS_GL) AS ORI_BONUS_GL_SUM,SUM(REAL_BONUS_GX) AS REAL_BONUS_GX_SUM,SUM(REAL_BONUS_GL) AS REAL_BONUS_GL_SUM')->where('CALC_MONTH=:CALC_MONTH', [ 'CALC_MONTH' => $calcMonth ])->groupBy('USER_ID')->orderBy('USER_ID DESC')->offset($offset)->limit($pageSize)->asArray()->all(); foreach ($list as $everyData) { //计算出实发共享奖扣除的积分和管理奖扣除的积分 $userReconsumePoints = 0; if( $everyData['ORI_BONUS_GX_SUM'] > 0 ) { $manageGx = $everyData['ORI_BONUS_GX_SUM'] * 5 / 100; $gxReconsumePoints = $everyData['ORI_BONUS_GX_SUM'] - $manageGx - $everyData['REAL_BONUS_GX_SUM']; if( $gxReconsumePoints > 0 ) $userReconsumePoints += $gxReconsumePoints; unset($manageGx, $gxReconsumePoints); } if( $everyData['ORI_BONUS_GL_SUM'] > 0 ) { $manageGL = $everyData['ORI_BONUS_GL_SUM'] * 5 / 100; $glReconsumePoints = $everyData['ORI_BONUS_GL_SUM'] - $manageGL - $everyData['REAL_BONUS_GL_SUM']; if( $glReconsumePoints > 0 ) $userReconsumePoints += $glReconsumePoints; unset($manageGL, $glReconsumePoints); } if( $userReconsumePoints <= 0 ) continue; $all = FlowBonus::find()->where('USER_ID=:USER_ID AND REMARK=:REMARK', ['USER_ID'=>$everyData['USER_ID'], 'REMARK' => 'From162期补发复消积分对应的奖金'])->asArray()->all(); if( $all ) { $countAll = count($all); if( $countAll > 1 ) { array_pop($all); foreach ($all as $one) { $oneBonus = (-1) * Tool::formatPrice($one['AMOUNT']); Balance::changeUserBonus($one['USER_ID'], 'bonus', $oneBonus, [ 'REMARK' => 'From162期撤消重复补发复消积分对应的奖金', 'PERIOD_NUM' => 162, 'DEAL_TYPE_ID' => DealType::BONUS_SEND, ]); unset($one, $oneBonus); } } }else { //发放复消积分金额的奖金 Balance::changeUserBonus($everyData['USER_ID'], 'bonus', $userReconsumePoints, [ 'REMARK' => 'From162期补发复消积分对应的奖金', 'PERIOD_NUM' => 162, 'DEAL_TYPE_ID' => DealType::BONUS_SEND, ]); } unset($everyData, $userReconsumePoints, $all); } } } /** * 清除某一期结算缓存 * @param $periodNum */ public function actionClearPeriodCalcCache($periodNum) { CalcCache::clearAll($periodNum); } public function actionDeleteSendPoints() { $pageSize = 1000; $allCount = FlowBonus::find()->where('PERIOD_NUM=162 AND REMARK=:REMARK', ['REMARK' => 'From162期补发复消积分对应的奖金'])->count(1); $pageCount = ceil($allCount/$pageSize); for($page=1;$page<=$pageCount;$page++) { echo sprintf('【%d】撤消补发复消积分，总页数为【%d】，当前页数为【%d】' . PHP_EOL, 162, $pageCount, $page); $offset = ($page-1)*$pageSize; $list = FlowBonus::find()->where('PERIOD_NUM=162 AND REMARK=:REMARK', ['REMARK' => 'From162期补发复消积分对应的奖金'])->offset($offset)->limit($pageSize)->asArray()->all(); foreach ($list as $everyData) { //查询金额是否足够 $bonus = Tool::formatPrice($everyData['AMOUNT']); $useBonus = UserBonus::find()->where('USER_ID=:USER_ID', ['USER_ID'=>$everyData['USER_ID']])->asArray()->one(); if( $useBonus['BONUS'] < $bonus ) { echo $everyData['USER_ID'] . PHP_EOL; } // $bonus = (-1) * $everyData['AMOUNT']; // Balance::changeUserBonus($everyData['USER_ID'], 'bonus', $bonus, [ // 'REMARK' => 'From162期撤消重复补发复消积分对应的奖金', // 'PERIOD_NUM' => 162, // 'DEAL_TYPE_ID' => DealType::BONUS_SEND, // ]); unset($bonus); } } } /** * 补发其它期奖金不正确的脚本 * @param $tableName * @param $toPeriod * @throws Exception * @throws \yii\db\Exception */ public function actionAddOtherPeriodGXAndGl($tableName, $toPeriod) { $db = \Yii::$app->db; $fromTableName = sprintf("AR_CALC_BONUS_%s", $tableName); $sql = "SELECT COUNT(ID) as allCount FROM {$fromTableName} WHERE PERIOD_NUM={$toPeriod} ORDER BY ID ASC"; $allCountOne = $db->createCommand($sql)->queryOne(); $pageSize = 1000; $pageCount = ceil($allCountOne['allCount']/$pageSize); for($page=1;$page<=$pageCount;$page++) { echo sprintf('同步【%d】期的数据，总页数为【%d】，当前页数为【%d】' . PHP_EOL, $toPeriod, $pageCount, $page); $offset = ($page-1)*$pageSize; $listSql = "SELECT * FROM {$fromTableName} WHERE PERIOD_NUM={$toPeriod} ORDER BY ID ASC LIMIT {$pageSize} OFFSET {$offset}"; $list = $db->createCommand($listSql)->queryAll(); foreach ($list as $every) { //判断该会员在AR_CALC_BONUS 表中 对应期数是否有相应的数据，有就更新，没有就插入。 $one = CalcBonus::find()->where('USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', ['USER_ID'=>$every['USER_ID'], 'PERIOD_NUM'=>$toPeriod])->asArray()->one(); if( !$one ) { $insertData = $every; $insertData['ID'] = SnowFake::instance()->generateId(); $insertData['IS_SENT'] = 1; $insertData['SENT_AT'] = Date::nowTime(); CalcBonus::insertOne($insertData); unset($insertData); //发对应的奖金 $sendBonus = $every['REAL_BONUS_GX'] + $every['REAL_BONUS_GL']; if( $sendBonus <= 0 ) { unset($sendBonus); continue; } //计算复消积分 $oldOne = CalcBonus::find()->select('USER_ID,SUM(ORI_BONUS_GX) AS ORI_BONUS_GX_SUM,SUM(ORI_BONUS_GL) AS ORI_BONUS_GL_SUM,SUM(REAL_BONUS_GX) AS REAL_BONUS_GX_SUM,SUM(REAL_BONUS_GL) AS REAL_BONUS_GL_SUM')->where('USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH', ['USER_ID'=>$every['USER_ID'], 'CALC_MONTH'=>202104])->asArray()->one(); //计算出实发共享奖扣除的积分和管理奖扣除的积分 $userReconsumePoints = 0; if( $oldOne['ORI_BONUS_GX_SUM'] > 0 ) { $manageGx = $oldOne['ORI_BONUS_GX_SUM'] * 5 / 100; $gxReconsumePoints = $oldOne['ORI_BONUS_GX_SUM'] - $manageGx - $oldOne['REAL_BONUS_GX_SUM']; if( $gxReconsumePoints > 0 ) $userReconsumePoints += $gxReconsumePoints; unset($manageGx, $gxReconsumePoints); } if( $oldOne['ORI_BONUS_GL_SUM'] > 0 ) { $manageGL = $oldOne['ORI_BONUS_GL_SUM'] * 5 / 100; $glReconsumePoints = $oldOne['ORI_BONUS_GL_SUM'] - $manageGL - $oldOne['REAL_BONUS_GL_SUM']; if( $glReconsumePoints > 0 ) $userReconsumePoints += $glReconsumePoints; unset($manageGL, $glReconsumePoints); } $sendBonus += $userReconsumePoints; Balance::changeUserBonus($every['USER_ID'], 'bonus', $sendBonus, [ 'REMARK' => 'From ' . $toPeriod . '期补发共享和管理奖', 'PERIOD_NUM' => $toPeriod, 'DEAL_TYPE_ID' => DealType::RESEND, ]); unset($sendBonus, $oldOne, $userReconsumePoints); } unset($every, $one); } } } /** * 修正某一期bonusTotal * @param $periodNum */ public function actionFixBonusTotal($periodNum) { $allCount = CalcBonus::find()->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$periodNum])->count('ID'); $pageSize = 1000; $pageCount = ceil($allCount/$pageSize); for($page=1;$page<=$pageCount;$page++) { echo sprintf('修正【%d】期的数据，总页数为【%d】，当前页数为【%d】' . PHP_EOL, $periodNum, $pageCount, $page); $offset = ($page-1)*$pageSize; $list = CalcBonus::find()->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$periodNum])->offset($offset)->limit($pageSize)->asArray()->all(); foreach ($list as $everyData) { $bonusTotal = $everyData['ORI_BONUS_BD'] + $everyData['ORI_BONUS_TG'] + $everyData['ORI_BONUS_XF'] + $everyData['ORI_BONUS_YJ'] + $everyData['ORI_BONUS_QY'] + $everyData['ORI_BONUS_YC'] + $everyData['ORI_BONUS_VIP'] + $everyData['ORI_BONUS_GX'] + $everyData['ORI_BONUS_GL'] + $everyData['ORI_BONUS_STANDARD']; $bonusTotalStr = strval($bonusTotal); if( $bonusTotalStr != $everyData['BONUS_TOTAL'] ) { echo sprintf('当前期数【%d】BONUS_TOTAL：%s, 计算结果：%s' . PHP_EOL, $periodNum, $everyData['BONUS_TOTAL'], $bonusTotalStr); CalcBonus::updateAll([ 'BONUS_TOTAL' => $bonusTotalStr ], 'ID=:ID', ['ID'=>$everyData['ID']]); } } } } function actionCalcPoints($offset = 0) { echo sprintf("时间:[%s]基础积分，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset); //查询本月的，每人的累计总收入 $limit = 1000; $empLevelConfig = Cache::getEmpLevelConfig(); $allData = CalcBonus::findUseDbCalc()->select('USER_ID, SUM(BONUS_TOTAL) AS TOTAL_SUM, SUM(ORI_BONUS_BD) AS BD_TOTAL_SUM')->where('CALC_MONTH=:CALC_MONTH', [':CALC_MONTH' => '202104'])->groupBy('USER_ID')->orderBy('USER_ID DESC')->offset($offset)->limit($limit)->asArray()->all(); if ($allData) { $insertData = []; foreach ($allData as $everyData) { $validTotalSum = $everyData['TOTAL_SUM'] - $everyData['BD_TOTAL_SUM']; if( $validTotalSum <=0 ) continue; //达不到 见习主任级别，不产生基础积分 $userBaseInfo = User::findOneAsArray('ID=:ID', [':ID' => $everyData['USER_ID']]); $userEmpLevel = $empLevelConfig[$userBaseInfo['EMP_LV']]; $userEmpLevelSort = $userEmpLevel['SORT'] ?? EmployLevel::EMP_LEVEL_SORT['NO_LEVEL']; unset($userBaseInfo, $userEmpLevel); if( $userEmpLevelSort < EmployLevel::EMP_LEVEL_SORT['JX_ZR_LEVEL'] ) { unset($userEmpLevelSort); continue; } unset($userEmpLevelSort); //根据总收入获取积分 $baseScore = $this->_getBaseScoreByTotalBonus($validTotalSum); //根据用户的级别判断 能否得到级别积分 if( $baseScore > 0 ) { //有记录就更新，没有记录就插入 $one = ScoreMonth::find()->where("USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH", [ "USER_ID" => $everyData['USER_ID'], "CALC_MONTH" => 202104 ])->asArray()->one(); if ( $one ) { $totalScore = $baseScore + $one["LEVEL_SCORE"] + $one["UPGRADE_SCORE"]; ScoreMonth::updateAll(["BASE_SCORE"=>$baseScore, "TOTAL_SCORE"=>$totalScore], "ID=:ID", ["ID"=>$one["ID"]]); }else { $insertData[] = [ 'ID' => SnowFake::instance()->generateId(), 'USER_ID' => $everyData['USER_ID'], 'BASE_SCORE' => $baseScore, 'TOTAL_SCORE' => $baseScore, 'PERIOD_NUM' => 162, 'CALC_MONTH' => 202104, 'CREATED_AT' => time(), ]; } } unset($everyData, $validTotalSum, $baseScore); } if($insertData) ScoreMonth::batchInsert($insertData); unset($insertData, $allData); return $this->actionCalcPoints($offset + $limit); } unset($allData); return true; } /** * 根据总收入获取相应的基础积分 * @param $totalBonus * @return int|mixed */ private function _getBaseScoreByTotalBonus($totalBonus) { $sysConfig = cache::getSystemConfig(); $baseScoreConfig = Json::decode($sysConfig['baseScore']['VALUE']); $baseScore = 0; foreach ($baseScoreConfig as $everyScoreData) { if( $totalBonus < $everyScoreData['monthTotalPvMin'] ) continue; if( $everyScoreData['monthTotalPvMax'] != 0 && $totalBonus >= $everyScoreData['monthTotalPvMax'] ) continue; $baseScore = $everyScoreData['score']; unset($everyScoreData); break; } unset($baseScoreConfig, $totalBonus); return $baseScore; } }