UserController.php 53 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: leo
  5. * Date: 2018/2/24
  6. * Time: 下午12:48
  7. */
  8. namespace frontendApi\modules\v1\controllers;
  9. use common\helpers\bonus\CalcCache;
  10. use common\helpers\Cache;
  11. use common\helpers\Email;
  12. use common\helpers\Form;
  13. use common\helpers\LoggerTool;
  14. use common\helpers\Tool;
  15. use common\helpers\user\Info;
  16. use common\models\BaUser;
  17. use common\models\Config;
  18. use common\models\Countries;
  19. use common\models\Currency;
  20. use common\models\CurrencyConversions;
  21. use common\models\DeclarationLevel;
  22. use common\models\DeclarationPackage;
  23. use common\models\DecOrder;
  24. use common\models\forms\ApproachDeclarationLoopForm;
  25. use common\models\forms\BaApproachDeclarationLoopForm;
  26. use common\models\forms\ApproachDeclarationUpgradeForm;
  27. use common\models\forms\BaUserForm;
  28. use common\models\forms\DeclarationForm;
  29. use common\models\forms\BaDeclarationForm;
  30. use common\models\forms\DeclarationLoopForm;
  31. use common\models\forms\BaDeclarationLoopForm;
  32. use common\models\forms\UploadForm;
  33. use common\models\forms\UserBindForm;
  34. use common\models\forms\UserForm;
  35. use common\models\Instalment;
  36. use common\models\OpenBank;
  37. use common\models\Period;
  38. use common\models\ReceiveAddress;
  39. use common\models\Region;
  40. use common\models\ShopGoods;
  41. use common\models\ShopGoodsNature;
  42. use common\services\GuestDeclarationOrderService;
  43. use common\models\UpgradeType;
  44. use common\models\User;
  45. use common\models\UserBind;
  46. use common\models\UserBonus;
  47. use common\models\UserInfo;
  48. use common\models\BaUserInfo;
  49. use common\models\UserNetwork;
  50. use common\models\forms\DeclarationUpgradeForm;
  51. use common\models\UserPerformance;
  52. use common\models\UserWallet;
  53. use frontendApi\modules\v1\models\Relation;
  54. use Yii;
  55. use yii\db\Exception;
  56. use yii\web\UploadedFile;
  57. class UserController extends BaseController {
  58. public $modelClass = UserInfo::class;
  59. const LOOP_FINISH = 1;
  60. /**
  61. * 会员资料
  62. * @return mixed
  63. * @throws \yii\web\HttpException
  64. */
  65. public function actionIndex() {
  66. $allNation = \Yii::$app->params['nation'];
  67. $allOpenBank = OpenBank::findAllAsArray('STATUS=1');
  68. $data['allNation'] = $allNation;
  69. $data['allOpenBank'] = $allOpenBank;
  70. $data['userInfo'] = User::getEnCodeInfo(\Yii::$app->user->id);
  71. $data['userInfo']['NATION'] = $data['userInfo']['NATION_ID'];
  72. return static::notice($data);
  73. }
  74. /**
  75. * 编辑会员资料
  76. * @return mixed
  77. * @throws \yii\web\HttpException
  78. */
  79. public function actionEdit() {
  80. if(\Yii::$app->request->isPost){
  81. $form = new UserForm();
  82. $post = \Yii::$app->request->post();
  83. $form->scenario = 'modifyProfile';
  84. if($form->load($post, '') && $result = $form->modifyProfile()){
  85. return static::notice(Yii::t('app', 'personalDataModifiedSuccessfully'), 400);
  86. } else {
  87. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  88. }
  89. }
  90. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  91. }
  92. /**
  93. * 修改登录密码
  94. */
  95. public function actionPassword(){
  96. if(\Yii::$app->request->isPost){
  97. $form = new UserForm();
  98. $form->scenario = 'modifyPassword';
  99. $post = \Yii::$app->request->post();
  100. if($form->load($post, '') && $result = $form->modifyPassword()){
  101. return static::notice(Yii::t('app', 'passwordModifiedSuccessfully'), 400);
  102. } else {
  103. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  104. }
  105. }
  106. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  107. }
  108. /**
  109. * 修改支付密码
  110. */
  111. public function actionPayPassword(){
  112. if(\Yii::$app->request->isPost){
  113. $form = new UserForm();
  114. $form->scenario = 'modifyPasswordPay';
  115. $post = \Yii::$app->request->post();
  116. $form->userId = \Yii::$app->user->id;
  117. if($form->load($post, '') && $result = $form->modifyPasswordPay()){
  118. return static::notice(Yii::t('app', 'passwordModifiedSuccessfully'));
  119. } else {
  120. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  121. }
  122. }
  123. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  124. }
  125. /**
  126. * 直推会员列表
  127. * @return mixed
  128. * @throws \yii\web\HttpException
  129. */
  130. public function actionRecUser() {
  131. $allData = UserInfo::lists('AND REC_UID=:REC_UID', [':REC_UID' => \Yii::$app->user->id], ['useSlaves' => true, 'select'=>'USER_ID,CREATED_AT']);
  132. foreach ($allData['list'] as $key => $data) {
  133. $userBaseInfo = User::getEnCodeInfo($data['USER_ID']);
  134. $userBaseInfo['NATION'] = \Yii::$app->params['nation'][$userBaseInfo['NATION']]['name'] ?? '';
  135. $allData['list'][$key]['BASE_INFO'] = $userBaseInfo;
  136. }
  137. return static::notice($allData);
  138. }
  139. /**
  140. * 上传身份证
  141. * @return mixed
  142. * @throws \yii\base\Exception
  143. * @throws \yii\web\HttpException
  144. */
  145. public function actionIdCard() {
  146. if (\Yii::$app->request->isPost) {
  147. $formModel = new UploadForm();
  148. $formModel->scenario = 'idCardFront';
  149. $formModel->file = UploadedFile::getInstanceByName('file');
  150. //$formModel->token = \Yii::$app->request->post('uploadToken');
  151. $formModel->token = \Yii::$app->request->request('uploadToken');
  152. if ($formModel->file && $formModel->upload()) {
  153. return static::notice(Yii::t('app', 'successfully'));
  154. } else {
  155. return static::notice(Form::formatErrorsForApi($formModel->getErrors()), 400);
  156. }
  157. }
  158. // 查看该用户是否已经上传过身份证
  159. $oneData = User::find()->select('ID_IMAGE')->where('ID=:ID', [':ID' => \Yii::$app->user->id])->asArray()->one();
  160. if ($oneData['ID_IMAGE']) {
  161. return static::notice($oneData);
  162. } else {
  163. $token = Cache::setUploadToken();
  164. return static::notice($token);
  165. }
  166. }
  167. /**
  168. * 点位绑定
  169. * @return mixed
  170. * @throws \yii\base\Exception
  171. * @throws \yii\web\HttpException
  172. */
  173. public function actionBind() {
  174. $userBind = UserBind::findOneAsArray('USER_ID=:USER_ID AND IS_DEL=0', [':USER_ID' => \Yii::$app->user->id]);
  175. $allData['list']=UserBind::findAllAsArray('MAIN_UID=:MAIN_UID AND IS_DEL=0', [':MAIN_UID' => $userBind['MAIN_UID']], 'ID,USER_ID,MAIN_UID,CREATED_AT,UPDATED_AT');
  176. foreach ($allData['list'] as $key => $value) {
  177. $baseInfo = Info::baseInfoZh($value['USER_ID']);
  178. if ($baseInfo['STATUS'] != 1) {
  179. unset($allData['list'][$key]);
  180. continue;
  181. }
  182. $allData['list'][$key]['USER_NAME'] = $baseInfo['USER_NAME'];
  183. $allData['list'][$key]['REAL_NAME'] = $baseInfo['REAL_NAME'];
  184. $allData['list'][$key]['BANK_PROVINCE_NAME'] = $baseInfo['BANK_PROVINCE_NAME'];
  185. $allData['list'][$key]['BANK_CITY_NAME'] = $baseInfo['BANK_CITY_NAME'];
  186. $allData['list'][$key]['BANK_COUNTY_NAME'] = $baseInfo['BANK_COUNTY_NAME'];
  187. $allData['list'][$key]['OPEN_BANK_NAME'] = $baseInfo['OPEN_BANK_NAME'];
  188. $allData['list'][$key]['BANK_NO'] = $baseInfo['BANK_NO'];
  189. $allData['list'][$key]['MAIN_USER_NAME'] =Info::getUserNameByUserId($value['MAIN_UID']);
  190. }
  191. $allData['list'] = array_values($allData['list']);
  192. return static::notice($allData);
  193. }
  194. /**
  195. * 编辑点位绑定
  196. * @return mixed
  197. * @throws \yii\web\HttpException
  198. */
  199. public function actionBindEdit(){
  200. $id = \Yii::$app->request->get('id');
  201. if(\Yii::$app->request->isPost) {
  202. return parent::edit(UserBindForm::class, Yii::t('app', 'successfully'), 'frontEdit', ['frontEdit'], null, function($form, $result){
  203. //log
  204. });
  205. }
  206. // 获得当前会员的用户名等信息
  207. $userBind = UserBind::findOneAsArray('ID=:ID AND IS_DEL=0', [':ID' => $id]);
  208. $userBinds = UserBind::findAllAsArray('MAIN_UID=:MAIN_UID AND IS_DEL=0',[':MAIN_UID'=>$userBind['MAIN_UID']], 'ID,USER_ID,MAIN_UID,CREATED_AT,UPDATED_AT');
  209. foreach($userBinds as $key=>$value){
  210. $status = Info::getStatusByUserId($value['USER_ID']);
  211. if ($status != 1) {
  212. unset($userBinds[$key]);
  213. continue;
  214. }
  215. $userBinds[$key]['USER_NAME'] = Info::getUserNameByUserId($value['USER_ID']);
  216. }
  217. $userBinds = array_values($userBinds);
  218. return static::notice(['userBinds' => $userBinds,'mainUid'=>$userBind['MAIN_UID']]);
  219. }
  220. // 会员升级,通过会员的编号,获取会员信息
  221. public function actionUpgradeInfo() {
  222. $isSwitchUpgrade = Config::find()
  223. ->where("CONFIG_NAME='isOpenUpgrade'")
  224. ->asArray()
  225. ->one();
  226. $isOpen = !empty($isSwitchUpgrade) && isset($isSwitchUpgrade['VALUE']) ? $isSwitchUpgrade['VALUE'] : 0;
  227. if ($isOpen < 1) {
  228. return static::notice(Yii::t('app', 'theFunctionIsNotAvailable'), 400);
  229. }
  230. $userNumber = \Yii::$app->request->request('userName');
  231. $baseInfo = Info::baseInfoZhByUserName($userNumber);
  232. if ($baseInfo['STATUS'] != 1) {
  233. return static::notice(Yii::t('app', 'inactiveUser'), 400);
  234. }
  235. $loginUserInfo = User::getEnCodeInfo(\Yii::$app->user->id);
  236. if ($baseInfo['COUNTRY_ID'] !== $loginUserInfo['COUNTRY_ID']) {
  237. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  238. }
  239. // 1. 如果是最高级别,则只显示用户基本信息
  240. // 2. 如果不是最高级别,如果用户累计报单数据是0, 或者用户累计报单业绩不符合级别信息,则提示 请联系客服核对业绩
  241. $userId = $baseInfo['ID'];
  242. $userDecId = $baseInfo['DEC_LV'];// 用户当前的级别
  243. // 获取系统中的DEC 报单级别配置
  244. $decConfig = DeclarationLevel::getAllData();
  245. $userDecInfo = $decConfig[$userDecId]; // 会员的级别具体信息
  246. $maxPerfInfo = DeclarationLevel::getMaxDecPref();
  247. $maxDecId = $maxPerfInfo['ID']; // 级别配置中最高级别ID
  248. $observe = Config::getConfigByType('observe'); // 获取观察期配置信息
  249. $observeLimit = $observe['observePeriodLimit']['value']; // 月份限制
  250. $isObserve = User::checkIsObserve($baseInfo['CREATED_AT'], $observeLimit); // 判断用户是否再观察期中
  251. // 如果用户已经是最高级别,则只展示用户信息
  252. $isMax = false;
  253. if ($maxDecId == $userDecId) {
  254. $isMax = true;
  255. }
  256. // NA级别暂时不提供升级
  257. if ($userDecInfo['ID'] == '67ABC6AO8YTK2LN0E055736AECE8644D') {
  258. return static::notice(Yii::t('app', 'upgradeNotSupport'), 400);
  259. }
  260. // 分期的总期数
  261. $instalmentConfig = intval(Cache::getSystemConfig()['instalment']['VALUE'] ?? 3);
  262. // 查询是否有FX的分期订单
  263. $stageFX = Instalment::getOneStage($baseInfo['ID'], 'FX');
  264. if ($stageFX && $stageFX < $instalmentConfig) {
  265. $instalment = false;
  266. } else {
  267. // 是否有未完成的BD类型的分期订单
  268. $stage = Instalment::getOneStage($userId, 'BD');
  269. if ($stage && $stage < $instalmentConfig) {
  270. $instalment = true;
  271. } else if ($isMax && $stage == $instalmentConfig) {
  272. $instalment = false;
  273. } else {
  274. $instalment = false;
  275. }
  276. }
  277. // 如果用户已经是最高级别,则只展示用户信息
  278. $userInfo = [
  279. 'DEC_NAME' => $baseInfo['DEC_LV_NAME'], // 用户级别中文
  280. 'DEC_ID' => $userDecId, // 用户级别id
  281. 'REAL_NAME' => $baseInfo['REAL_NAME'], // 真实姓名
  282. 'ADD_AT' => date('Y-m-d', $baseInfo['CREATED_AT']), // 加入时间
  283. 'COUNTRY_NAME' => $baseInfo['COUNTRY_NAME'], // 国家
  284. 'IS_OBSERVE' => $isObserve, // 是否是观察期 true为是观察期
  285. 'IS_MAX' => $isMax, // 是否已是最大级别 最大级别不需要判断报单总PV是多少 只展示基本信息
  286. 'INSTALMENT' => $instalment,
  287. 'NOW_PERF' => User::sumDevPvByUserId($userId), // 用户所有报单PV总和
  288. ];
  289. // 如果是最高级别了,则无需升级
  290. if ($isMax) {
  291. return static::notice(['baseInfo' => $userInfo]);
  292. }
  293. $levelPerf = $userDecInfo['PERF'];// 用户当前级别对应的业绩值
  294. if (!$isMax) {
  295. $userDecPvSum = User::sumDevPvByUserId($userId); // 用户所有报单PV总和
  296. // // 如果总和小于级别业绩 去掉这校验直接补比如3000-980的差值
  297. // if ($userDecPvSum < $levelPerf) {
  298. // return static::notice('请联系客服人员核对业绩',400);
  299. // }
  300. // 下一级业绩
  301. $nextLevelPerf = DeclarationLevel::getNextDecPref($levelPerf)['PERF'];
  302. // 如果总和超过了下一级业绩
  303. if ($userDecPvSum >= $nextLevelPerf) {
  304. return static::notice(Yii::t('app', 'checkPerformance'), 400);
  305. }
  306. $type = $isObserve ? 1 : 2;
  307. $userInfo['UPGRADE_FUNC'] = $isObserve ? Yii::t('app', 'fillingUpOfADeficit') : Yii::t('app', 'fullPayment');
  308. $upgradeType = UpgradeType::getOneByType($type);
  309. // 如果用户不是最大级别,则需要获取是否观察期,算出PV是否有问题,应该补多少,
  310. $userInfo['UPGRADE_TYPE'] = $upgradeType;
  311. $userInfo['NOW_PERF'] = $userDecPvSum;
  312. $userInfo['NEXT_PERF'] = $nextLevelPerf;
  313. // 用户可选择的级别列表
  314. $userInfo['LEVEL_LIST'] = DeclarationLevel::getNextAll($levelPerf);// 用户可选择的级别列表
  315. // 如果用户正处于报单分期中,则可以升级到Elite
  316. $userInstalmentInfo = Instalment::getInfo($userId);
  317. if($userInstalmentInfo){
  318. if ($userInstalmentInfo['ORDER_TYPE']=='BD' && $userInstalmentInfo['STAGE'] < 3){
  319. $userInfo['LEVEL_LIST'] = DeclarationLevel::getNextAll(12);// 用户可选择的级别列表
  320. unset($userInfo['LEVEL_LIST'][$userDecId]);
  321. }
  322. }
  323. // 循环列表,补充升级所需要的补差
  324. foreach ($userInfo['LEVEL_LIST'] as &$v) {
  325. $v['REPAIR_PV'] = $isObserve ? $v['PERF'] - $userInfo['NOW_PERF'] : $v['PERF'];
  326. }
  327. }
  328. return static::notice(['baseInfo' => $userInfo]);
  329. }
  330. // 会员升级管理
  331. public function actionUpgrade() {
  332. $isMax = \Yii::$app->request->get('isMax');
  333. $userNumber = \Yii::$app->request->get('userName');
  334. $isSwitchUpgrade = Config::find()
  335. ->where("CONFIG_NAME='isOpenUpgrade'")
  336. ->asArray()
  337. ->one();
  338. $isOpen = !empty($isSwitchUpgrade) && isset($isSwitchUpgrade['VALUE']) ? $isSwitchUpgrade['VALUE'] : 0;
  339. if ($isOpen < 1) {
  340. return static::notice(Yii::t('app', 'theFunctionIsNotAvailable'), 400);
  341. }
  342. // 开始升级
  343. if (\Yii::$app->request->isPost) {
  344. $post = \Yii::$app->request->post();
  345. // 根据支付方式区分逻辑
  346. $payMethod = \Yii::$app->request->post('payType', '');
  347. if ($payMethod === 'pay_stack') {
  348. $formModel = new ApproachDeclarationUpgradeForm();
  349. } else {
  350. unset($post['payType']);
  351. $formModel = new DeclarationUpgradeForm();
  352. }
  353. $stockist = $post['decUserName'] ?? '';
  354. if (!$stockist) {
  355. return static::notice(Yii::t('app', 'stockistDoesNotExist'), 400);
  356. }
  357. $post['type'] = DeclarationForm::TYPE_ZC;
  358. if ($formModel->load($post, '') && $result = $formModel->add($post)) {
  359. return static::notice($result);// Upgrade declaration succeeded升级报单成功
  360. } else {
  361. return static::notice(Form::formatErrorsForApi($formModel->getErrors()),400);
  362. }
  363. }
  364. // 升级的会员
  365. $userName = \Yii::$app->request->get('userName');
  366. // 会员信息
  367. $user = User::findOneAsArray('USER_NAME=:USER_NAME', [':USER_NAME' => trim($userName)]);
  368. if (!$user) {
  369. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  370. }
  371. //所有报单套餐
  372. $allDecPackage = DeclarationPackage::getAllData();
  373. $decLevels = Cache::getDecLevelConfig();
  374. foreach ($allDecPackage as $k=>$v){
  375. $levelName = $decLevels[$v['LEVEL_ID']]['LEVEL_NAME'] ?? '';
  376. $allDecPackage[$k]['LEVEL_NAME'] = $levelName;
  377. }
  378. $baseInfo = Info::baseInfoZhByUserName($userNumber);
  379. // 分期的总期数
  380. $instalmentConfig = intval(Cache::getSystemConfig()['instalment']['VALUE'] ?? 3);
  381. // 查询是否有FX的分期订单
  382. $stageFX = Instalment::getOneStage($baseInfo['ID'], 'FX');
  383. if ($stageFX && $stageFX < $instalmentConfig) {
  384. if ($isMax === "true") {
  385. $condition = ") AND S.INSTALMENT = 1000";
  386. } else {
  387. $condition = ") AND (S.INSTALMENT = 0 OR S.INSTALMENT = 1000)";
  388. }
  389. } else {
  390. // 是否有未完成的BD类型的分期订单
  391. $stageBD = Instalment::getOneStage($baseInfo['ID'], 'BD');
  392. if ($isMax === "true") {
  393. if ($stageBD > 0 && $stageBD < $instalmentConfig) {
  394. $condition = ") AND (S.INSTALMENT = " . ($stageBD + 1) . ")";
  395. } else {
  396. $condition = ") AND S.INSTALMENT = 0";
  397. }
  398. } else {
  399. if ($stageBD > 0 && $stageBD < $instalmentConfig) {
  400. $condition = ") AND (S.INSTALMENT = 0 OR S.INSTALMENT = " . ($stageBD + 1) . ")";
  401. } else {
  402. $condition = ") AND (S.INSTALMENT = 0 OR S.INSTALMENT = 1)";
  403. }
  404. }
  405. }
  406. //所有自选商品
  407. $isDecReg = Cache::getSystemConfig()['isDecReg']['VALUE'];
  408. $isDec = User::getEnCodeInfo(\Yii::$app->user->id)['IS_DEC'];
  409. $isStudio = User::getEnCodeInfo(\Yii::$app->user->id)['IS_STUDIO'];
  410. $decUserName = User::getEnCodeInfo(\Yii::$app->user->id)['USER_NAME'];
  411. $query_condition= " AND (1<>1";
  412. if(!$isDecReg || ($isDecReg && $isDec==1)){
  413. $query_condition = " AND (FIND_IN_SET(1, S.GIFT_TYPE)>0";
  414. }
  415. if($isStudio==1){
  416. $query_condition .= " OR FIND_IN_SET(3, S.GIFT_TYPE)>0";
  417. }
  418. $query_condition .= $condition . ' AND N.COUNTRY_ID=:COUNTRY_ID ';
  419. $allGoods = ShopGoods::find()
  420. ->alias('S')
  421. ->select('S.*,N.MARKET_PRICE,N.SELL_PRICE,N.TAX_RATE,N.LOCAL_CURRENCY_ID,N.COUNTRY_ID,C.CODE')
  422. ->join('INNER JOIN', ShopGoodsNature::tableName() . ' AS N', 'N.GOODS_ID=S.ID')
  423. ->join('INNER JOIN', Currency::tableName() . ' AS C', 'C.ID=N.LOCAL_CURRENCY_ID')
  424. ->where("STATUS=1 AND CATEGORY_TYPE=1 " . $query_condition, [':COUNTRY_ID' => $user['COUNTRY_ID']])
  425. ->orderBy('SORT ASC')
  426. ->asArray()
  427. ->all();
  428. foreach ($allGoods as &$goods) {
  429. $goods['TAX'] = Tool::calculateTax($goods['SELL_PRICE'], $goods['TAX_RATE']);
  430. }
  431. // 报单中心汇率
  432. $decCountryId = User::getEnCodeInfo(\Yii::$app->user->id)['COUNTRY_ID'];
  433. $decCountry = Countries::getById($decCountryId);
  434. $decUserCurrencyRate = CurrencyConversions::getToUSDRate($decCountry['LOCAL_CURRENCY_ID']);
  435. // 升级会员汇率
  436. $country = Countries::getById($user['COUNTRY_ID']);
  437. $currencyRate = CurrencyConversions::getToUSDRate($country['LOCAL_CURRENCY_ID']);
  438. // 升级会员币种
  439. $currency = Currency::getById($country['LOCAL_CURRENCY_ID']);
  440. $userBalance = [
  441. 'cash' => 0,
  442. 'localCash' => 0,
  443. 'coin' => '',
  444. ];
  445. // 会员余额
  446. $userCash = UserWallet::findOneAsArray(['USER_ID' => \Yii::$app->user->id]);
  447. if ($userCash) {
  448. $userBalance['cash'] = $userCash['CASH'];
  449. $userBalance['coin'] = $currency['CODE'] ?? '';
  450. $userBalance['localCash'] = Tool::convertAmount($userCash['CASH'], $decUserCurrencyRate, $currencyRate);
  451. }
  452. // 会员绩效奖金
  453. $userPerformanceAmount = UserPerformance::getAmounts(\Yii::$app->user->id);
  454. $userBalance['prp'] = $userPerformanceAmount ?? 0;
  455. $userBalance['localPrp'] = Tool::convertAmount($userPerformanceAmount, $decUserCurrencyRate, $currencyRate);
  456. // 行政区划
  457. $region = Region::getByCountryId($user['COUNTRY_ID']);
  458. // 支付方式
  459. $payList = ShopGoods::payTypes();
  460. unset($payList['prp']);
  461. // 售卖方式
  462. $sellType = ShopGoods::getCategoryType();
  463. unset($sellType[0]['sell_type'][1]);
  464. return static::notice([
  465. 'allDecPackage' => $allDecPackage,
  466. 'allGoods' => $allGoods,
  467. 'decUserName'=>$decUserName,
  468. 'payList' => $payList,
  469. 'sellType' => $sellType,
  470. 'categoryType' => ShopGoods::getCategoryType()[0]['id'],
  471. 'userBalance' => $userBalance,
  472. 'decUserCurrencyRate' => $decUserCurrencyRate,
  473. 'userCurrencyRate' => $currencyRate,
  474. 'region' => $region,
  475. ]);
  476. }
  477. /**
  478. * 报单管理
  479. */
  480. public function actionGuestDec()
  481. {
  482. $service = new GuestDeclarationOrderService();
  483. try {
  484. if (Yii::$app->request->isPost) {
  485. $input = Yii::$app->request->post();
  486. $result = $service->submitDraft(
  487. (string) ($input['draftId'] ?? ''),
  488. (string) ($input['accessToken'] ?? ''),
  489. $input
  490. );
  491. return static::notice($result);
  492. }
  493. $countryId = (string) Yii::$app->request->get('countryId', '');
  494. if ($countryId === '') {
  495. return static::notice(Yii::t('app', 'countryDoesNotSelect'), 400);
  496. }
  497. $draft = $service->createDraft($countryId);
  498. $decLevels = Cache::getDecLevelConfig();
  499. $packages = DeclarationPackage::getAllData();
  500. foreach ($packages as $index => $package) {
  501. $packages[$index]['LEVEL_NAME'] = $decLevels[$package['LEVEL_ID']]['LEVEL_NAME'] ?? '';
  502. }
  503. $goods = ShopGoods::find()
  504. ->alias('S')
  505. ->select('S.*,N.MARKET_PRICE,N.SELL_PRICE,N.TAX_RATE,N.LOCAL_CURRENCY_ID,N.COUNTRY_ID,C.CODE')
  506. ->innerJoin(ShopGoodsNature::tableName() . ' N', 'N.GOODS_ID=S.ID')
  507. ->innerJoin(Currency::tableName() . ' C', 'C.ID=N.LOCAL_CURRENCY_ID')
  508. ->where('S.STATUS=1 AND S.CATEGORY_TYPE=1 AND FIND_IN_SET(1,S.GIFT_TYPE)>0 AND N.COUNTRY_ID=:COUNTRY_ID', [':COUNTRY_ID' => $countryId])
  509. ->orderBy('S.SORT ASC')
  510. ->asArray()->all();
  511. // 银行开户行
  512. $allOpenBank = OpenBank::find()
  513. ->where('STATUS=:STATUS AND COUNTRY_ID=:COUNTRY_ID', [':STATUS' => 1, ':COUNTRY_ID' => $countryId])
  514. ->orderBy('BANK_NAME ASC')
  515. ->asArray()
  516. ->all();
  517. // 售卖方式
  518. $sellType = ShopGoods::getCategoryType();
  519. unset($sellType[0]['sell_type'][1]);
  520. return static::notice([
  521. 'draft' => $draft,
  522. 'allDecPackage' => $packages,
  523. 'allGoods' => $goods,
  524. 'allOpenBank' => $allOpenBank,
  525. 'sellType' => $sellType,
  526. 'categoryType' => ShopGoods::getCategoryType()[0]['id'],
  527. 'region' => Region::getByCountryId($countryId),
  528. 'payList' => ['pay_stack' => ['name' => 'PayStack']],
  529. 'decLevel' => DeclarationLevel::getData(),
  530. ]);
  531. } catch (\Throwable $e) {
  532. LoggerTool::error('guestDec failed: ' . get_class($e));
  533. if ($e instanceof \yii\web\HttpException) {
  534. return static::notice($e->getMessage(), $e->statusCode);
  535. }
  536. return static::notice('Unable to process guest order.'.$e->getMessage(), 500);
  537. }
  538. }
  539. public function actionGuestDecStatus()
  540. {
  541. try {
  542. $result = (new GuestDeclarationOrderService())->getDraftStatus(
  543. (string) Yii::$app->request->get('draftId', ''),
  544. (string) Yii::$app->request->get('accessToken', '')
  545. );
  546. return static::notice($result);
  547. } catch (\Throwable $e) {
  548. return static::notice('Guest order draft was not found.', 404);
  549. }
  550. }
  551. public function actionDec() {
  552. $redis = \Yii::$app->redis;
  553. $post = \Yii::$app->request->post();
  554. if (\Yii::$app->request->isPost) {
  555. $email = $post['email'] ?? '';
  556. if ($email && !filter_var($email, FILTER_VALIDATE_EMAIL)) {
  557. return static::notice(Yii::t('app', 'invalidEmail'), 400);
  558. }
  559. $stockist = $post['decUserName'] ?? '';
  560. if (!$stockist) {
  561. return static::notice(Yii::t('app', 'stockistDoesNotExist'), 400);
  562. }
  563. $loginUserInfo = User::getEnCodeInfo(\Yii::$app->user->id);
  564. if($loginUserInfo['IS_DEC'] == 1 && !empty($post['decUserName']) && $post['decUserName'] != $loginUserInfo['USER_NAME']){
  565. return static::notice(Yii::t('app', 'decUserNameIsWrong'), 400);
  566. }
  567. if($loginUserInfo['IS_DEC'] == 0 && $post['decUserName']){
  568. //查询报单编号是否存在
  569. $userId = Info::getUserIdByUserName($post['decUserName']);
  570. if(!$userId){
  571. return static::notice(Yii::t('app', 'decUserNameIsWrong'), 400);
  572. }
  573. $isDec = User::getEnCodeInfo($userId)['IS_DEC'];
  574. if(!$isDec){
  575. return static::notice(Yii::t('app', 'decUserNameIsWrong'), 400);
  576. }
  577. }
  578. $conUserName = trim($post['conUserName']); // 实际推荐人
  579. $recUserName = trim($post['recUserName']);
  580. // 如果推荐人和实际推荐人是同一人,则跳过检查
  581. if ($recUserName != $conUserName) {
  582. // 实际推荐人必须是推荐人的推荐网上级
  583. $sqlUp = <<<SQL
  584. WITH recursive t_rec AS
  585. (
  586. SELECT
  587. m.USER_ID,
  588. U.USER_NAME,
  589. m.PARENT_UID,
  590. U2.USER_NAME AS PARENT_NAME,
  591. 1 AS node_level
  592. FROM
  593. AR_USER_RELATION_NEW m
  594. LEFT JOIN AR_USER U ON U.ID = m.USER_ID
  595. LEFT JOIN AR_USER U2 ON U2.ID = m.PARENT_UID
  596. WHERE
  597. U.USER_NAME = :USER_NAME
  598. UNION ALL
  599. SELECT
  600. t1.USER_ID,
  601. U.USER_NAME,
  602. t1.PARENT_UID,
  603. U2.USER_NAME AS PARENT_NAME,
  604. t2.node_level + 1 -- 结点层级
  605. FROM
  606. AR_USER_RELATION_NEW t1
  607. JOIN t_rec t2 ON t2.PARENT_UID = t1.USER_ID
  608. LEFT JOIN AR_USER U ON U.ID = t1.USER_ID
  609. LEFT JOIN AR_USER U2 ON U2.ID = t1.PARENT_UID
  610. )
  611. SELECT
  612. *
  613. FROM
  614. t_rec
  615. SQL;
  616. // 查询推荐人的所有上级
  617. $relationNodeUp = \Yii::$app->db->createCommand($sqlUp)
  618. ->bindValue(':USER_NAME', $post['recUserName'])
  619. ->queryAll();
  620. $relationNodeUp = array_column($relationNodeUp, 'USER_NAME');
  621. unset($relationNodeUp[$post['recUserName']]);
  622. if (!in_array($post['conUserName'], $relationNodeUp)) {
  623. return static::notice(Yii::t('app', 'fillSponsorUpline'), 400);
  624. }
  625. }
  626. // 根据支付方式区分逻辑
  627. $payMethod = \Yii::$app->request->post('payType', '');
  628. if ($payMethod === 'pay_stack') {
  629. $formModel = new ApproachDeclarationLoopForm();
  630. } else {
  631. unset($post['payType']);
  632. $formModel = new DeclarationLoopForm();
  633. }
  634. $formModel->scenario = 'userDec';
  635. $post['province'] = $post['province'] ? :1;
  636. $post['city'] = $post['city'] ? :1;
  637. $post['county'] = $post['county'] ? :1;
  638. $post['cityName'] = trim($post['cityName']);
  639. $post['lgaName'] = trim($post['lgaName']);
  640. // 针对那群沙雕移除安置网络的行为,强制增加自动安置左侧
  641. $recUserId = Info::getUserIdByUserName($conUserName);
  642. $bottomPlace = UserNetwork::getBottomPlace($recUserId,'', 'left');
  643. $bottomUser = UserNetwork::find()->select('USER_ID')->where('LOCATION_TAG=:LOCATION_TAG', ['LOCATION_TAG' => $bottomPlace])->asArray()->one();
  644. $bottomUser = User::findOneAsArray('ID=:ID', [':ID' => $bottomUser['USER_ID']], 'USER_NAME');
  645. $bottomUser = $bottomUser['USER_NAME']; // 推算出的安置人
  646. $post['conUserName'] = $bottomUser; // 安置人
  647. $post['recUserName'] = $conUserName; // 实际推荐人
  648. $post['bottomUserName'] = $recUserName; // 推荐人
  649. $post['location'] = 1;
  650. // 针对于会员编号的判断
  651. $insertUserName = strtoupper($post['insertUserName']);
  652. $getRedisUserName = $redis->get('key_' . $insertUserName);
  653. if (!$getRedisUserName){
  654. return static::notice(Yii::t('app', 'memberNumberExpired'), 400);
  655. }
  656. if ($insertUserName != $getRedisUserName){
  657. return static::notice(Yii::t('app', 'memberNumberDoesNotConformTo'), 400);
  658. }
  659. $post['insertUserName'] = $insertUserName;
  660. $post['type'] = DeclarationForm::TYPE_ZC;
  661. $allData['data'][] = $post;
  662. try {
  663. if ($formModel->load($allData, '') && $result = $formModel->add()) {
  664. //发送邮件
  665. // Email::sendRegistrationEmail($post['email'], $post['insertUserName'], $post['password']);
  666. return static::notice($result);//报单成功
  667. } else {
  668. return static::notice(Form::formatErrorsForApi($formModel->getErrors()),400);
  669. }
  670. } catch (\Exception $e) {
  671. LoggerTool::error($e->getMessage() . '; ' . $e->getLine() . '; ' . $e->getFile());
  672. return static::notice(Form::formatErrorsForApi($formModel->getErrors()),400);
  673. }
  674. }
  675. // 默认国家
  676. $countryId = \Yii::$app->request->get('countryId');
  677. if (!$countryId) {
  678. return static::notice(Yii::t('app', 'countryDoesNotSelect'), 400);
  679. }
  680. // 生成随机码 , 初始化redis
  681. $userName = Info::generateWebName($countryId);
  682. //所有报单套餐
  683. $allDecPackage = DeclarationPackage::getAllData();
  684. $decLevels = Cache::getDecLevelConfig();
  685. foreach ($allDecPackage as $k=>$v){
  686. $levelName = $decLevels[$v['LEVEL_ID']]['LEVEL_NAME'] ?? '';
  687. $allDecPackage[$k]['LEVEL_NAME'] = $levelName;
  688. }
  689. //所有自选商品
  690. $isDecReg = Cache::getSystemConfig()['isDecReg']['VALUE'];
  691. $isDec = User::getEnCodeInfo(\Yii::$app->user->id)['IS_DEC'];
  692. $isStudio = User::getEnCodeInfo(\Yii::$app->user->id)['IS_STUDIO'];
  693. $query_condition = " AND (1<>1";
  694. if(!$isDecReg || ($isDecReg && $isDec==1)){
  695. $query_condition = " AND (FIND_IN_SET(1, S.GIFT_TYPE)>0";
  696. }
  697. if($isStudio==1){
  698. $query_condition .= " OR FIND_IN_SET(3, S.GIFT_TYPE)>0";
  699. }
  700. $query_condition .= ") AND (S.INSTALMENT=0 OR S.INSTALMENT=1) AND N.COUNTRY_ID=:COUNTRY_ID";
  701. // 只查询普通商品
  702. $allGoods = ShopGoods::find()
  703. ->alias('S')
  704. ->select('S.*,N.MARKET_PRICE,N.SELL_PRICE,N.TAX_RATE,N.LOCAL_CURRENCY_ID,N.COUNTRY_ID,C.CODE')
  705. ->join('INNER JOIN', ShopGoodsNature::tableName() . ' AS N', 'N.GOODS_ID=S.ID')
  706. ->join('INNER JOIN', Currency::tableName() . ' AS C', 'C.ID=N.LOCAL_CURRENCY_ID')
  707. ->where("STATUS=1 AND CATEGORY_TYPE=1 " . $query_condition, [':COUNTRY_ID' => $countryId])
  708. ->orderBy('SORT ASC')
  709. ->asArray()
  710. ->all();
  711. // 银行开户行
  712. $allOpenBank = OpenBank::find()
  713. ->where('STATUS=:STATUS AND COUNTRY_ID=:COUNTRY_ID', [':STATUS' => 1, ':COUNTRY_ID' => $countryId])
  714. ->orderBy('BANK_NAME ASC')
  715. ->asArray()
  716. ->all();
  717. if (!$userName) {
  718. return static::notice(Yii::t('app', 'failedToGenerateMemberNumber'), 400);
  719. }
  720. //随机码保存在redis中方便进行比对
  721. $redis->setex('key_'.$userName , 3600 , $userName);
  722. // 报单中心会员的本地汇率
  723. $decCountryId = User::getEnCodeInfo(\Yii::$app->user->id)['COUNTRY_ID'];
  724. $decCountry = Countries::getById($decCountryId);
  725. $decUserCurrencyRate = CurrencyConversions::getToUSDRate($decCountry['LOCAL_CURRENCY_ID']);
  726. // 新会员的本地汇率
  727. $country = Countries::getById($countryId);
  728. $currencyRate = CurrencyConversions::getToUSDRate($country['LOCAL_CURRENCY_ID']);
  729. // 新会员币种
  730. $currency = Currency::getById($country['LOCAL_CURRENCY_ID']);
  731. // 会员账户
  732. $userBalance = [
  733. 'cash' => 0,
  734. 'localCash' => 0,
  735. 'coin' => '',
  736. ];
  737. $userCash = UserWallet::findOneAsArray(['USER_ID' => \Yii::$app->user->id]);
  738. if ($userCash) {
  739. $userBalance['cash'] = $userCash['CASH'];
  740. $userBalance['localCash'] = Tool::convertAmount($userCash['CASH'], $decUserCurrencyRate, $currencyRate);
  741. $userBalance['coin'] = $currency['CODE'] ?? '';
  742. }
  743. // 行政区划
  744. $region = Region::getByCountryId($countryId);
  745. // 支付方式
  746. $payList = ShopGoods::payTypes();
  747. unset($payList['prp']);
  748. // 售卖方式
  749. $sellType = ShopGoods::getCategoryType();
  750. unset($sellType[0]['sell_type'][1]);
  751. return static::notice([
  752. 'allDecPackage' => $allDecPackage,
  753. 'allGoods' => $allGoods,
  754. 'allOpenBank' => $allOpenBank,
  755. 'userName' => $userName,
  756. 'payList' => $payList,
  757. 'sellType' => $sellType,
  758. 'categoryType' => ShopGoods::getCategoryType()[0]['id'],
  759. 'userBalance' => $userBalance,
  760. 'isDec' => $isDec,
  761. 'decUserCurrencyRate' => $decUserCurrencyRate,
  762. 'userCurrencyRate' => $currencyRate,
  763. 'region' => $region,
  764. 'decLevel' => DeclarationLevel::getData(),
  765. ]);
  766. }
  767. /**
  768. * 报单级别套餐
  769. */
  770. public function actionDecPackage() {
  771. $decLv = \Yii::$app->request->get('id');
  772. //所有报单级别套餐
  773. $allDecPackage = DeclarationPackage::getPackageFromLevelId($decLv);
  774. return static::notice(['allDecPackage' => $allDecPackage]);
  775. }
  776. /*
  777. * 从会员名和左右,获取底部安置人
  778. *
  779. */
  780. public function actionGetAutoPlace() {
  781. $userName = \Yii::$app->request->get('userName');
  782. $side = \Yii::$app->request->get('side');
  783. $userId = Info::getUserIdByUserName($userName);
  784. $bottomPlace = UserNetwork::getBottomPlace($userId,'', $side);
  785. $bottomUser = UserNetwork::find()->select('USER_ID')->where('LOCATION_TAG=:LOCATION_TAG', ['LOCATION_TAG' => $bottomPlace])->asArray()->one();
  786. $bottomUser = User::findOneAsArray('ID=:ID', [':ID' => $bottomUser['USER_ID']], 'USER_NAME');
  787. return static::notice($bottomUser);
  788. }
  789. /**
  790. * 会员信息查询
  791. * @return mixed
  792. * @throws \yii\web\HttpException
  793. */
  794. public function actionFullInfo()
  795. {
  796. $userName = \Yii::$app->request->get('userName');
  797. $userId = Info::getUserIdByUserName($userName);
  798. $userInfo['REAL_NAME'] = '';
  799. $user = User::findOneAsArray('ID=:ID', [':ID' => $userId]);
  800. $loginUserInfo = User::getEnCodeInfo(\Yii::$app->user->id);
  801. if ($user['COUNTRY_ID'] !== $loginUserInfo['COUNTRY_ID']) {
  802. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  803. }
  804. if($user){
  805. $userInfo['REAL_NAME'] = $user['REAL_NAME'];
  806. $allChildUser = UserNetwork::getFirstFloorChildren($userId);
  807. $isLocation = [1 => 'Left-Null', 2 => 'Right-Null'];
  808. if($allChildUser) {
  809. foreach ($allChildUser as $child) {
  810. if ($child['RELATIVE_LOCATION']<'3'){
  811. // $isLocation[$child['RELATIVE_LOCATION']].= 'Full';
  812. $isLocation[$child['RELATIVE_LOCATION']] = str_replace('Null', 'Full', $isLocation[$child['RELATIVE_LOCATION']]);
  813. }
  814. }
  815. }
  816. $userInfo['countryId'] = $user['COUNTRY_ID'];
  817. $userInfo['userId'] = $userId;
  818. $userInfo['isLocation'] = '('.implode(',',$isLocation).')';
  819. return static::notice($userInfo);
  820. }else{
  821. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  822. }
  823. }
  824. /**
  825. * Public member information lookup for guest declaration flows.
  826. * @return mixed
  827. */
  828. public function actionGuestFullInfo()
  829. {
  830. $userName = trim((string) \Yii::$app->request->get('userName', ''));
  831. $userId = Info::getUserIdByUserName($userName);
  832. $user = $userId ? User::findOneAsArray('ID=:ID', [':ID' => $userId]) : null;
  833. if (!$user) {
  834. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  835. }
  836. $allChildUser = UserNetwork::getFirstFloorChildren($userId);
  837. $isLocation = [1 => 'Left-Null', 2 => 'Right-Null'];
  838. if ($allChildUser) {
  839. foreach ($allChildUser as $child) {
  840. if ($child['RELATIVE_LOCATION'] < '3' && isset($isLocation[$child['RELATIVE_LOCATION']])) {
  841. $isLocation[$child['RELATIVE_LOCATION']] = str_replace('Null', 'Full', $isLocation[$child['RELATIVE_LOCATION']]);
  842. }
  843. }
  844. }
  845. return static::notice([
  846. 'REAL_NAME' => $user['REAL_NAME'],
  847. 'countryId' => $user['COUNTRY_ID'],
  848. 'userId' => $userId,
  849. 'isLocation' => '(' . implode(',', $isLocation) . ')',
  850. ]);
  851. }
  852. public function actionInspectNetwork()
  853. {
  854. // 推荐人信息
  855. $recommenderName= \Yii::$app->request->get('recommenderName');
  856. $userId = Info::getUserIdByUserName($recommenderName);
  857. $recommender = User::findOneAsArray('ID=:ID', [':ID' => $userId]);
  858. if (!$recommender) {
  859. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  860. }
  861. // 实际推荐人信息
  862. $recommenderActualName= \Yii::$app->request->get('recommenderActualName');
  863. $actualId = Info::getUserIdByUserName($recommenderActualName);
  864. $recommenderActual = User::findOneAsArray('ID=:ID', [':ID' => $actualId]);
  865. if (!$recommenderActual) {
  866. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  867. }
  868. // 实际推荐人是否是推荐人本人
  869. if ($actualId == $userId) {
  870. return static::notice([
  871. 'REAL_NAME' => $recommenderActual['REAL_NAME'],
  872. 'userId' => $recommenderActual['ID'],
  873. ]);
  874. }
  875. // 实际推荐人必须是推荐人的推荐网上级
  876. $sqlUp =<<<SQL
  877. WITH recursive t_rec AS
  878. (
  879. SELECT
  880. m.USER_ID,
  881. U.USER_NAME,
  882. m.PARENT_UID,
  883. U2.USER_NAME AS PARENT_NAME,
  884. 1 AS node_level
  885. FROM
  886. AR_USER_RELATION_NEW m
  887. LEFT JOIN AR_USER U ON U.ID = m.USER_ID
  888. LEFT JOIN AR_USER U2 ON U2.ID = m.PARENT_UID
  889. WHERE
  890. U.USER_NAME = :USER_NAME
  891. UNION ALL
  892. SELECT
  893. t1.USER_ID,
  894. U.USER_NAME,
  895. t1.PARENT_UID,
  896. U2.USER_NAME AS PARENT_NAME,
  897. t2.node_level + 1 -- 结点层级
  898. FROM
  899. AR_USER_RELATION_NEW t1
  900. JOIN t_rec t2 ON t2.PARENT_UID = t1.USER_ID
  901. LEFT JOIN AR_USER U ON U.ID = t1.USER_ID
  902. LEFT JOIN AR_USER U2 ON U2.ID = t1.PARENT_UID
  903. )
  904. SELECT
  905. *
  906. FROM
  907. t_rec
  908. SQL;
  909. // 查询推荐人的所有上级
  910. $relationNodeUp = \Yii::$app->db->createCommand($sqlUp)
  911. ->bindValue(':USER_NAME' , $recommenderName)
  912. ->queryAll();
  913. $relationNodeUp = array_column($relationNodeUp, 'USER_NAME');
  914. unset($relationNodeUp[$recommenderName]);
  915. if (in_array($recommenderActualName, $relationNodeUp)) {
  916. return static::notice([
  917. 'REAL_NAME' => $recommenderActual['REAL_NAME'],
  918. 'userId' => $recommenderActual['ID'],
  919. ]);
  920. }
  921. return static::notice(Yii::t('ctx', 'fillSponsorUpline'), 400);
  922. }
  923. /**
  924. * Public sponsor relationship validation for guest declaration flows.
  925. * @return mixed
  926. */
  927. public function actionGuestInspectNetwork()
  928. {
  929. $recommenderName = trim((string) \Yii::$app->request->get('recommenderName', ''));
  930. $recommenderActualName = trim((string) \Yii::$app->request->get('recommenderActualName', ''));
  931. if ($recommenderName === '' || $recommenderActualName === '') {
  932. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  933. }
  934. $userId = Info::getUserIdByUserName($recommenderName);
  935. $recommender = $userId ? User::findOneAsArray('ID=:ID', [':ID' => $userId]) : null;
  936. if (!$recommender) {
  937. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  938. }
  939. $actualId = Info::getUserIdByUserName($recommenderActualName);
  940. $recommenderActual = $actualId ? User::findOneAsArray('ID=:ID', [':ID' => $actualId]) : null;
  941. if (!$recommenderActual) {
  942. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  943. }
  944. if ($actualId == $userId) {
  945. return static::notice([
  946. 'REAL_NAME' => $recommenderActual['REAL_NAME'],
  947. 'userId' => $recommenderActual['ID'],
  948. ]);
  949. }
  950. $sqlUp = <<<SQL
  951. WITH recursive t_rec AS
  952. (
  953. SELECT m.USER_ID, U.USER_NAME, m.PARENT_UID, U2.USER_NAME AS PARENT_NAME, 1 AS node_level
  954. FROM AR_USER_RELATION_NEW m
  955. LEFT JOIN AR_USER U ON U.ID = m.USER_ID
  956. LEFT JOIN AR_USER U2 ON U2.ID = m.PARENT_UID
  957. WHERE U.USER_NAME = :USER_NAME
  958. UNION ALL
  959. SELECT t1.USER_ID, U.USER_NAME, t1.PARENT_UID, U2.USER_NAME AS PARENT_NAME,
  960. t2.node_level + 1
  961. FROM AR_USER_RELATION_NEW t1
  962. JOIN t_rec t2 ON t2.PARENT_UID = t1.USER_ID
  963. LEFT JOIN AR_USER U ON U.ID = t1.USER_ID
  964. LEFT JOIN AR_USER U2 ON U2.ID = t1.PARENT_UID
  965. )
  966. SELECT * FROM t_rec
  967. SQL;
  968. $relationNodeUp = \Yii::$app->db->createCommand($sqlUp)
  969. ->bindValue(':USER_NAME', $recommenderName)
  970. ->queryAll();
  971. $relationNodeUp = array_column($relationNodeUp, 'USER_NAME');
  972. if (in_array($recommenderActualName, $relationNodeUp, true)) {
  973. return static::notice([
  974. 'REAL_NAME' => $recommenderActual['REAL_NAME'],
  975. 'userId' => $recommenderActual['ID'],
  976. ]);
  977. }
  978. return static::notice(Yii::t('ctx', 'fillSponsorUpline'), 400);
  979. }
  980. /**
  981. * 复消会员信息查询
  982. * @return mixed
  983. * @throws \yii\web\HttpException
  984. */
  985. public function actionUserBaseInfo()
  986. {
  987. $userName = \Yii::$app->request->get('userName');
  988. $userId = Info::getUserIdByUserName($userName);
  989. if($userId){
  990. $allAddress = ReceiveAddress::findAllAsArray('USER_ID=:USER_ID', [':USER_ID'=>$userId]);
  991. if($allAddress) {
  992. foreach ($allAddress as $key => $row) {
  993. $allAddress[$key]['PROVINCE_NAME'] = Region::getCnName($row['PROVINCE']);
  994. $allAddress[$key]['CITY_NAME'] = Region::getCnName($row['CITY']);
  995. $allAddress[$key]['COUNTY_NAME'] = Region::getCnName($row['COUNTY']);
  996. }
  997. }
  998. $userInfo = Info::baseInfoWithNet($userId);
  999. // $decLevelConfig = Cache::getDecLevelConfig();
  1000. // $empLevelConfig = Cache::getEmpLevelConfig();
  1001. $arr = [
  1002. 'REAL_NAME'=>$userInfo['REAL_NAME'],
  1003. // 'DEC_LEVEL_NAME' => $decLevelConfig[$userInfo['DEC_LV']]['LEVEL_NAME'],
  1004. // 'EMP_LEVEL_NAME'=>$empLevelConfig[$userInfo['EMP_LV']]['LEVEL_NAME'],
  1005. // 'REC_UID'=>$userInfo['REC_USER_NAME'].'('.$userInfo['REC_REAL_NAME'].')',
  1006. // 'CON_UID'=>$userInfo['CON_USER_NAME'].'('.$userInfo['CON_REAL_NAME'].')',
  1007. 'allAddress'=>$allAddress
  1008. ];
  1009. return static::notice($arr);
  1010. }else{
  1011. return static::notice(Yii::t('app', 'repeatSalesMemberNoDoesNotExist'), 400);
  1012. }
  1013. }
  1014. /**
  1015. * 会员资料
  1016. * @return mixed
  1017. * @throws \yii\web\HttpException
  1018. */
  1019. public function actionBaInfo()
  1020. {
  1021. $data['userInfo'] = BaUser::getEnCodeInfo(\Yii::$app->user->id);
  1022. $data['userInfo']['NATION'] = $data['userInfo']['NATION_ID'];
  1023. // 推荐人
  1024. $baUserInfo = BaUserInfo::findOneAsArray('USER_ID=:USER_ID', [':USER_ID' => \Yii::$app->user->id]);
  1025. $sponsor = User::findOneAsArray('ID=:USER_ID', [':USER_ID' => $baUserInfo['REC_UID']]);
  1026. $data['userInfo']['SponsorCode'] = $sponsor['USER_NAME'];
  1027. $data['userInfo']['SponsorName'] = $sponsor['REAL_NAME'];
  1028. return static::notice($data);
  1029. }
  1030. /**
  1031. * 编辑会员资料
  1032. * @return mixed
  1033. * @throws \yii\web\HttpException
  1034. */
  1035. public function actionBaEdit()
  1036. {
  1037. if(\Yii::$app->request->isPost)
  1038. {
  1039. $form = new BaUserForm();
  1040. $post = \Yii::$app->request->post();
  1041. $form->scenario = 'modifyProfile';
  1042. if ($form->load($post, '') && $result = $form->modifyProfile()){
  1043. return static::notice(Yii::t('app', 'personalDataModifiedSuccessfully'), 400);
  1044. } else {
  1045. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  1046. }
  1047. }
  1048. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  1049. }
  1050. /**
  1051. * 修改登录密码
  1052. */
  1053. public function actionBaPassword(){
  1054. if(\Yii::$app->request->isPost) {
  1055. $form = new BaUserForm();
  1056. $form->scenario = 'modifyPassword';
  1057. $post = \Yii::$app->request->post();
  1058. if($form->load($post, '') && $result = $form->modifyPassword()){
  1059. return static::notice(Yii::t('app', 'passwordModifiedSuccessfully'), 400);
  1060. } else {
  1061. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  1062. }
  1063. }
  1064. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  1065. }
  1066. /**
  1067. * 修改支付密码
  1068. */
  1069. public function actionBaPayPassword(){
  1070. if(\Yii::$app->request->isPost){
  1071. $form = new BaUserForm();
  1072. $form->scenario = 'modifyPasswordPay';
  1073. $post = \Yii::$app->request->post();
  1074. $form->userId = \Yii::$app->user->id;
  1075. if($form->load($post, '') && $result = $form->modifyPasswordPay()){
  1076. return static::notice(Yii::t('app', 'passwordModifiedSuccessfully'), 400);
  1077. } else {
  1078. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  1079. }
  1080. }
  1081. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  1082. }
  1083. /**
  1084. * BA报单管理
  1085. */
  1086. public function actionBaDec() {
  1087. // 生成随机码 , 初始化redis
  1088. $userName = Info::generateWebUserName('NG',9);
  1089. $redis = \Yii::$app->redis;
  1090. $post = \Yii::$app->request->post();
  1091. if (\Yii::$app->request->isPost) {
  1092. // 根据支付方式区分逻辑
  1093. $payMethod = \Yii::$app->request->post('payType', '');
  1094. if ($payMethod === 'pay_stack') {
  1095. $formModel = new BaApproachDeclarationLoopForm();
  1096. } else {
  1097. unset($post['payType']);
  1098. $formModel = new BaDeclarationLoopForm();
  1099. }
  1100. $formModel->scenario = 'userDec';
  1101. $post['province'] = $post['province'] ? :1;
  1102. $post['city'] = $post['city'] ? :1;
  1103. $post['county'] = $post['county'] ? :1;
  1104. // $post['conUserName'] = trim($post['conUserName']);
  1105. $post['recUserName'] = trim($post['recUserName']);
  1106. $post['cityName'] = trim($post['cityName']);
  1107. $post['lgaName'] = trim($post['lgaName']);
  1108. // 针对于会员编号的判断
  1109. $insertUserName = strtoupper($post['insertUserName']);
  1110. $getRedisUserName = $redis->get('key_' . $insertUserName);
  1111. if (!$getRedisUserName){
  1112. return static::notice(Yii::t('app', 'memberNumberExpired'), 400);
  1113. }
  1114. if ($insertUserName != $getRedisUserName){
  1115. return static::notice(Yii::t('app', 'memberNumberDoesNotConformTo'), 400);
  1116. }
  1117. $post['insertUserName'] = $insertUserName;
  1118. $post['type'] = BaDeclarationForm::TYPE_ZC;
  1119. $allData['data'][] = $post;
  1120. if ($formModel->load($allData, '') && $result = $formModel->add()) {
  1121. return static::notice($result); // 报单成功
  1122. } else {
  1123. return static::notice(Form::formatErrorsForApi($formModel->getErrors()),400);
  1124. }
  1125. }
  1126. // 只查询普通商品
  1127. $allGoods = ShopGoods::find()->where("ID='375895243322691584'")->orderBy('SORT ASC')->asArray()->all();
  1128. if (!$userName) {
  1129. return static::notice(Yii::t('app', 'failedToGenerateMemberNumber'), 400);
  1130. }
  1131. //随机码保存在redis中方便进行比对
  1132. $redis->setex('key_'.$userName , 3600 , $userName);
  1133. // 会员账户
  1134. $userBalance = [
  1135. 'cash' => 0,
  1136. // 'tourism_points' => 0,
  1137. // 'garage_points' => 0,
  1138. // 'villa_points' => 0,
  1139. ];
  1140. $userCash = UserWallet::findOneAsArray(['USER_ID' => \Yii::$app->user->id]);
  1141. if ($userCash) {
  1142. $userBalance['cash'] = $userCash['CASH'];
  1143. }
  1144. return static::notice([
  1145. 'allGoods' => $allGoods,
  1146. 'userName' => $userName,
  1147. 'payList' => ShopGoods::payTypes(),
  1148. 'sellType' => ShopGoods::getCategoryType(),
  1149. 'categoryType' => ShopGoods::getCategoryType()[0]['id'],
  1150. 'userBalance' => $userBalance,
  1151. ]);
  1152. }
  1153. /**
  1154. * BA会员信息
  1155. * @return mixed
  1156. * @throws \yii\web\HttpException
  1157. */
  1158. public function actionBaUserInfo()
  1159. {
  1160. $userName = \Yii::$app->request->get('userName');
  1161. $userId = Info::getBaUserIdByUserName($userName);
  1162. $userInfo['REAL_NAME'] = '';
  1163. $user = BaUser::findOneAsArray('ID=:ID', [':ID' => $userId], 'REAL_NAME');
  1164. $uInfo = BaUserInfo::findOneAsArray('USER_ID=:USER_ID', [':USER_ID' => $userId], 'REC_UID');
  1165. if($user){
  1166. $rec_user = UserInfo::findOneAsArray('USER_ID=:USER_ID',[':USER_ID' => $uInfo['REC_UID']], 'USER_ID, USER_NAME');
  1167. $userInfo['REAL_NAME'] = $user['REAL_NAME'];
  1168. $userInfo['REC_USER_ID'] = $rec_user['USER_ID'];
  1169. $userInfo['REC_USER_NAME'] = $rec_user['USER_NAME'];
  1170. return static::notice($userInfo);
  1171. }else{
  1172. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  1173. }
  1174. }
  1175. }