UserController.php 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815
  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\Cache;
  10. use common\helpers\Form;
  11. use common\helpers\LoggerTool;
  12. use common\helpers\Tool;
  13. use common\helpers\user\Info;
  14. use common\models\BaUser;
  15. use common\models\Config;
  16. use common\models\DeclarationLevel;
  17. use common\models\DeclarationPackage;
  18. use common\models\DecOrder;
  19. use common\models\forms\ApproachDeclarationLoopForm;
  20. use common\models\forms\BaApproachDeclarationLoopForm;
  21. use common\models\forms\ApproachDeclarationUpgradeForm;
  22. use common\models\forms\BaUserForm;
  23. use common\models\forms\DeclarationForm;
  24. use common\models\forms\BaDeclarationForm;
  25. use common\models\forms\DeclarationLoopForm;
  26. use common\models\forms\BaDeclarationLoopForm;
  27. use common\models\forms\UploadForm;
  28. use common\models\forms\UserBindForm;
  29. use common\models\forms\UserForm;
  30. use common\models\Instalment;
  31. use common\models\OpenBank;
  32. use common\models\ReceiveAddress;
  33. use common\models\Region;
  34. use common\models\ShopGoods;
  35. use common\models\UpgradeType;
  36. use common\models\User;
  37. use common\models\UserBind;
  38. use common\models\UserBonus;
  39. use common\models\UserInfo;
  40. use common\models\BaUserInfo;
  41. use common\models\UserNetwork;
  42. use common\models\forms\DeclarationUpgradeForm;
  43. use common\models\UserWallet;
  44. use Yii;
  45. use yii\db\Exception;
  46. use yii\web\UploadedFile;
  47. class UserController extends BaseController {
  48. public $modelClass = UserInfo::class;
  49. /**
  50. * 会员资料
  51. * @return mixed
  52. * @throws \yii\web\HttpException
  53. */
  54. public function actionIndex() {
  55. $allNation = \Yii::$app->params['nation'];
  56. $allOpenBank = OpenBank::findAllAsArray('STATUS=1');
  57. $data['allNation'] = $allNation;
  58. $data['allOpenBank'] = $allOpenBank;
  59. $data['userInfo'] = User::getEnCodeInfo(\Yii::$app->user->id);
  60. $data['userInfo']['NATION'] = $data['userInfo']['NATION_ID'];
  61. return static::notice($data);
  62. }
  63. /**
  64. * 编辑会员资料
  65. * @return mixed
  66. * @throws \yii\web\HttpException
  67. */
  68. public function actionEdit() {
  69. if(\Yii::$app->request->isPost){
  70. $form = new UserForm();
  71. $post = \Yii::$app->request->post();
  72. $form->scenario = 'modifyProfile';
  73. if($form->load($post, '') && $result = $form->modifyProfile()){
  74. return static::notice(Yii::t('app', 'personalDataModifiedSuccessfully'), 400);
  75. } else {
  76. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  77. }
  78. }
  79. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  80. }
  81. /**
  82. * 修改登录密码
  83. */
  84. public function actionPassword(){
  85. if(\Yii::$app->request->isPost){
  86. $form = new UserForm();
  87. $form->scenario = 'modifyPassword';
  88. $post = \Yii::$app->request->post();
  89. if($form->load($post, '') && $result = $form->modifyPassword()){
  90. return static::notice(Yii::t('app', 'passwordModifiedSuccessfully'), 400);
  91. } else {
  92. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  93. }
  94. }
  95. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  96. }
  97. /**
  98. * 修改支付密码
  99. */
  100. public function actionPayPassword(){
  101. if(\Yii::$app->request->isPost){
  102. $form = new UserForm();
  103. $form->scenario = 'modifyPasswordPay';
  104. $post = \Yii::$app->request->post();
  105. $form->userId = \Yii::$app->user->id;
  106. if($form->load($post, '') && $result = $form->modifyPasswordPay()){
  107. return static::notice(Yii::t('app', 'passwordModifiedSuccessfully'));
  108. } else {
  109. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  110. }
  111. }
  112. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  113. }
  114. /**
  115. * 直推会员列表
  116. * @return mixed
  117. * @throws \yii\web\HttpException
  118. */
  119. public function actionRecUser() {
  120. $allData = UserInfo::lists('AND REC_UID=:REC_UID', [':REC_UID' => \Yii::$app->user->id], ['useSlaves' => true, 'select'=>'USER_ID,CREATED_AT']);
  121. foreach ($allData['list'] as $key => $data) {
  122. $userBaseInfo = User::getEnCodeInfo($data['USER_ID']);
  123. $userBaseInfo['NATION'] = \Yii::$app->params['nation'][$userBaseInfo['NATION']]['name'] ?? '';
  124. $allData['list'][$key]['BASE_INFO'] = $userBaseInfo;
  125. }
  126. return static::notice($allData);
  127. }
  128. /**
  129. * 上传身份证
  130. * @return mixed
  131. * @throws \yii\base\Exception
  132. * @throws \yii\web\HttpException
  133. */
  134. public function actionIdCard() {
  135. if (\Yii::$app->request->isPost) {
  136. $formModel = new UploadForm();
  137. $formModel->scenario = 'idCardFront';
  138. $formModel->file = UploadedFile::getInstanceByName('file');
  139. //$formModel->token = \Yii::$app->request->post('uploadToken');
  140. $formModel->token = \Yii::$app->request->request('uploadToken');
  141. if ($formModel->file && $formModel->upload()) {
  142. return static::notice(Yii::t('app', 'successfully'));
  143. } else {
  144. return static::notice(Form::formatErrorsForApi($formModel->getErrors()), 400);
  145. }
  146. }
  147. // 查看该用户是否已经上传过身份证
  148. $oneData = User::find()->select('ID_IMAGE')->where('ID=:ID', [':ID' => \Yii::$app->user->id])->asArray()->one();
  149. if ($oneData['ID_IMAGE']) {
  150. return static::notice($oneData);
  151. } else {
  152. $token = Cache::setUploadToken();
  153. return static::notice($token);
  154. }
  155. }
  156. /**
  157. * 点位绑定
  158. * @return mixed
  159. * @throws \yii\base\Exception
  160. * @throws \yii\web\HttpException
  161. */
  162. public function actionBind() {
  163. $userBind = UserBind::findOneAsArray('USER_ID=:USER_ID AND IS_DEL=0', [':USER_ID' => \Yii::$app->user->id]);
  164. $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');
  165. foreach ($allData['list'] as $key => $value) {
  166. $baseInfo = Info::baseInfoZh($value['USER_ID']);
  167. if ($baseInfo['STATUS'] != 1) {
  168. unset($allData['list'][$key]);
  169. continue;
  170. }
  171. $allData['list'][$key]['USER_NAME'] = $baseInfo['USER_NAME'];
  172. $allData['list'][$key]['REAL_NAME'] = $baseInfo['REAL_NAME'];
  173. $allData['list'][$key]['BANK_PROVINCE_NAME'] = $baseInfo['BANK_PROVINCE_NAME'];
  174. $allData['list'][$key]['BANK_CITY_NAME'] = $baseInfo['BANK_CITY_NAME'];
  175. $allData['list'][$key]['BANK_COUNTY_NAME'] = $baseInfo['BANK_COUNTY_NAME'];
  176. $allData['list'][$key]['OPEN_BANK_NAME'] = $baseInfo['OPEN_BANK_NAME'];
  177. $allData['list'][$key]['BANK_NO'] = $baseInfo['BANK_NO'];
  178. $allData['list'][$key]['MAIN_USER_NAME'] =Info::getUserNameByUserId($value['MAIN_UID']);
  179. }
  180. $allData['list'] = array_values($allData['list']);
  181. return static::notice($allData);
  182. }
  183. /**
  184. * 编辑点位绑定
  185. * @return mixed
  186. * @throws \yii\web\HttpException
  187. */
  188. public function actionBindEdit(){
  189. $id = \Yii::$app->request->get('id');
  190. if(\Yii::$app->request->isPost) {
  191. return parent::edit(UserBindForm::class, Yii::t('app', 'successfully'), 'frontEdit', ['frontEdit'], null, function($form, $result){
  192. //log
  193. });
  194. }
  195. // 获得当前会员的用户名等信息
  196. $userBind = UserBind::findOneAsArray('ID=:ID AND IS_DEL=0', [':ID' => $id]);
  197. $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');
  198. foreach($userBinds as $key=>$value){
  199. $status = Info::getStatusByUserId($value['USER_ID']);
  200. if ($status != 1) {
  201. unset($userBinds[$key]);
  202. continue;
  203. }
  204. $userBinds[$key]['USER_NAME'] = Info::getUserNameByUserId($value['USER_ID']);
  205. }
  206. $userBinds = array_values($userBinds);
  207. return static::notice(['userBinds' => $userBinds,'mainUid'=>$userBind['MAIN_UID']]);
  208. }
  209. // 会员升级,通过会员的编号,获取会员信息
  210. public function actionUpgradeInfo() {
  211. $isSwitchUpgrade = Config::find()
  212. ->where("CONFIG_NAME='isOpenUpgrade'")
  213. ->asArray()
  214. ->one();
  215. $isOpen = !empty($isSwitchUpgrade) && isset($isSwitchUpgrade['VALUE']) ? $isSwitchUpgrade['VALUE'] : 0;
  216. if ($isOpen < 1) {
  217. return static::notice(Yii::t('app', 'theFunctionIsNotAvailable'), 400);
  218. }
  219. $userNumber = \Yii::$app->request->request('userName');
  220. $baseInfo = Info::baseInfoZhByUserName($userNumber);
  221. if ($baseInfo['STATUS'] != 1) {
  222. return static::notice(Yii::t('app', 'inactiveUser'), 400);
  223. }
  224. // 1. 如果是最高级别,则只显示用户基本信息
  225. // 2. 如果不是最高级别,如果用户累计报单数据是0, 或者用户累计报单业绩不符合级别信息,则提示 请联系客服核对业绩
  226. $userId = $baseInfo['ID'];
  227. $userDecId = $baseInfo['DEC_LV'];// 用户当前的级别
  228. // 获取系统中的DEC 报单级别配置
  229. $decConfig = Cache::getDecLevelConfig();
  230. $userDecInfo = $decConfig[$userDecId]; // 会员的级别具体信息
  231. $maxPerfInfo = DeclarationLevel::getMaxDecPref();
  232. $maxDecId = $maxPerfInfo['ID']; // 级别配置中最高级别ID
  233. $observe = Config::getConfigByType('observe'); // 获取观察期配置信息
  234. $observeLimit = $observe['observePeriodLimit']['value']; // 月份限制
  235. $isObserve = User::checkIsObserve($baseInfo['CREATED_AT'], $observeLimit); // 判断用户是否再观察期中
  236. // 如果用户已经是最高级别,则只展示用户信息
  237. $isMax = false;
  238. if ($maxDecId == $userDecId) {
  239. $isMax = true;
  240. }
  241. // 分期的总期数
  242. $instalmentConfig = intval(Cache::getSystemConfig()['instalment']['VALUE'] ?? 3);
  243. // 查询是否有FX的分期订单
  244. $stageFX = Instalment::getOneStage($baseInfo['ID'], 'FX');
  245. if ($stageFX && $stageFX < $instalmentConfig) {
  246. $instalment = false;
  247. } else {
  248. // 是否有未完成的BD类型的分期订单
  249. $stage = Instalment::getOneStage($userId, 'BD');
  250. if ($stage && $stage < $instalmentConfig) {
  251. $instalment = true;
  252. } else {
  253. $instalment = false;
  254. }
  255. }
  256. // 如果用户已经是最高级别,则只展示用户信息
  257. $userInfo = [
  258. 'DEC_NAME' => $baseInfo['DEC_LV_NAME'], // 用户级别中文
  259. 'DEC_ID' => $userDecId, // 用户级别id
  260. 'REAL_NAME' => $baseInfo['REAL_NAME'], // 真实姓名
  261. 'ADD_AT' => date('Y-m-d', $baseInfo['CREATED_AT']), // 加入时间
  262. 'IS_OBSERVE' => $isObserve, // 是否是观察期 true为是观察期
  263. 'IS_MAX' => $isMax, // 是否已是最大级别 最大级别不需要判断报单总PV是多少 只展示基本信息
  264. 'INSTALMENT' => $instalment,
  265. ];
  266. // 如果是最高级别了,则无需升级
  267. if ($isMax) {
  268. return static::notice(['baseInfo' => $userInfo]);
  269. }
  270. $levelPerf = $userDecInfo['PERF'];// 用户当前级别对应的业绩值
  271. if (!$isMax) {
  272. $userDecPvSum = User::sumDevPvByUserId($userId); // 用户所有报单PV总和
  273. // // 如果总和小于级别业绩 去掉这校验直接补比如3000-980的差值
  274. // if ($userDecPvSum < $levelPerf) {
  275. // return static::notice('请联系客服人员核对业绩',400);
  276. // }
  277. // 下一级业绩
  278. $nextLevelPerf = DeclarationLevel::getNextDecPref($levelPerf)['PERF'];
  279. // 如果总和超过了下一级业绩
  280. if ($userDecPvSum >= $nextLevelPerf) {
  281. return static::notice(Yii::t('app', 'checkPerformance'), 400);
  282. }
  283. $type = $isObserve ? 1 : 2;
  284. $userInfo['UPGRADE_FUNC'] = $isObserve ? Yii::t('app', 'fillingUpOfADeficit') : Yii::t('app', 'fullPayment');
  285. $upgradeType = UpgradeType::getOneByType($type);
  286. // 如果用户不是最大级别,则需要获取是否观察期,算出PV是否有问题,应该补多少,
  287. $userInfo['UPGRADE_TYPE'] = $upgradeType;
  288. $userInfo['NOW_PERF'] = $userDecPvSum;
  289. $userInfo['NEXT_PERF'] = $nextLevelPerf;
  290. // 用户可选择的级别列表
  291. $userInfo['LEVEL_LIST'] = DeclarationLevel::getNextAll($levelPerf);// 用户可选择的级别列表
  292. // 如果用户正处于报单分期中,则可以升级到Elite
  293. $userInstalmentInfo = Instalment::getInfo($userId);
  294. if($userInstalmentInfo){
  295. if ($userInstalmentInfo['ORDER_TYPE']=='BD' && $userInstalmentInfo['STAGE'] < 3){
  296. $userInfo['LEVEL_LIST'] = DeclarationLevel::getNextAll(12);// 用户可选择的级别列表
  297. unset($userInfo['LEVEL_LIST'][$userDecId]);
  298. }
  299. }
  300. // 循环列表,补充升级所需要的补差
  301. foreach ($userInfo['LEVEL_LIST'] as &$v) {
  302. $v['REPAIR_PV'] = $isObserve ? $v['PERF'] - $userInfo['NOW_PERF'] : $v['PERF'];
  303. }
  304. }
  305. return static::notice(['baseInfo' => $userInfo]);
  306. }
  307. // 会员升级管理
  308. public function actionUpgrade() {
  309. $isMax = \Yii::$app->request->request('isMax');
  310. $userNumber = \Yii::$app->request->request('userName');
  311. $baseInfo = Info::baseInfoZhByUserName($userNumber);
  312. $isSwitchUpgrade = Config::find()
  313. ->where("CONFIG_NAME='isOpenUpgrade'")
  314. ->asArray()
  315. ->one();
  316. $isOpen = !empty($isSwitchUpgrade) && isset($isSwitchUpgrade['VALUE']) ? $isSwitchUpgrade['VALUE'] : 0;
  317. if ($isOpen < 1) {
  318. return static::notice(Yii::t('app', 'theFunctionIsNotAvailable'), 400);
  319. }
  320. // 开始升级
  321. if (\Yii::$app->request->isPost) {
  322. $post = \Yii::$app->request->post();
  323. // 根据支付方式区分逻辑
  324. $payMethod = \Yii::$app->request->post('payType', '');
  325. if ($payMethod === 'pay_stack') {
  326. $formModel = new ApproachDeclarationUpgradeForm();
  327. } else {
  328. unset($post['payType']);
  329. $formModel = new DeclarationUpgradeForm();
  330. }
  331. $post['type'] = DeclarationForm::TYPE_ZC;
  332. if ($formModel->load($post, '') && $result = $formModel->add($post)) {
  333. return static::notice($result);// Upgrade declaration succeeded升级报单成功
  334. } else {
  335. return static::notice(Form::formatErrorsForApi($formModel->getErrors()),400);
  336. }
  337. }
  338. //所有报单套餐
  339. $allDecPackage = DeclarationPackage::getAllData();
  340. $decLevels = Cache::getDecLevelConfig();
  341. foreach ($allDecPackage as $k=>$v){
  342. $levelName = $decLevels[$v['LEVEL_ID']]['LEVEL_NAME'] ?? '';
  343. $allDecPackage[$k]['LEVEL_NAME'] = $levelName;
  344. }
  345. // 分期的总期数
  346. $instalment = intval(Cache::getSystemConfig()['instalment']['VALUE'] ?? 3);
  347. // 是否有未完成的BD类型的分期订单
  348. $stage = Instalment::getOneStage($baseInfo['ID'], 'BD');
  349. // 如果分期未完成,切已经升级到顶级,则商品列表只返回分期商品
  350. if ($isMax === true) {
  351. $stage += (!$stage || ($stage >= $instalment)) ? 1000 : 1;
  352. } else {
  353. $stage += ($stage >= $instalment) ? 1000 : 1;
  354. }
  355. //所有自选商品
  356. $isDecReg = Cache::getSystemConfig()['isDecReg']['VALUE'];
  357. $isDec = User::getEnCodeInfo(\Yii::$app->user->id)['IS_DEC'];
  358. $isStudio = User::getEnCodeInfo(\Yii::$app->user->id)['IS_STUDIO'];
  359. $decUserName = User::getEnCodeInfo(\Yii::$app->user->id)['USER_NAME'];
  360. $query_condition= " AND (1<>1";
  361. if(!$isDecReg || ($isDecReg && $isDec==1)){
  362. $query_condition = " AND (FIND_IN_SET(1,GIFT_TYPE)>0";
  363. }
  364. if($isStudio==1){
  365. $query_condition.= " OR FIND_IN_SET(3,GIFT_TYPE)>0";
  366. }
  367. // 如果等级已经是顶级 && 没有分期订单,则不查询商品
  368. if ($stage == 100) {
  369. $query_condition.= ") AND ((INSTALMENT = 0) OR (INSTALMENT = :INSTALMENT))";
  370. } else if ($stage == 1000) {
  371. $query_condition.= ") AND (INSTALMENT = :INSTALMENT)";
  372. } else {
  373. $query_condition.= ") AND ((INSTALMENT = 0) OR (INSTALMENT = :INSTALMENT))";
  374. }
  375. $allGoods = ShopGoods::find()->where("STATUS=1 AND CATEGORY_TYPE=1 " . $query_condition, [':INSTALMENT' => $stage])->orderBy('SORT ASC')->asArray()->all();
  376. foreach ($allGoods as &$goods) {
  377. $goods['TAX'] = Tool::calculateTax($goods['SELL_PRICE'], $goods['TAX_RATE']);
  378. }
  379. // 会员账户
  380. $userBalance = ['cash' => 0];
  381. $userCash = UserWallet::findOneAsArray(['USER_ID' => \Yii::$app->user->id]);
  382. if ($userCash) {
  383. $userBalance['cash'] = $userCash['CASH'];
  384. }
  385. return static::notice([
  386. 'allDecPackage' => $allDecPackage,
  387. 'allGoods' => $allGoods,
  388. 'decUserName'=>$decUserName,
  389. 'payList' => ShopGoods::payTypes(),
  390. 'sellType' => ShopGoods::getCategoryType(),
  391. 'categoryType' => ShopGoods::getCategoryType()[0]['id'],
  392. 'userBalance' => $userBalance,
  393. ]);
  394. }
  395. /**
  396. * 报单管理
  397. */
  398. public function actionDec() {
  399. // 生成随机码 , 初始化redis
  400. $userName = Info::generateWebUserName('NG',9);
  401. $redis = \Yii::$app->redis;
  402. $post = \Yii::$app->request->post();
  403. if (\Yii::$app->request->isPost) {
  404. $userInfo = User::getEnCodeInfo(\Yii::$app->user->id);
  405. if($userInfo['IS_DEC'] == 1 && !empty($post['decUserName']) && $post['decUserName'] != $userInfo['USER_NAME']){
  406. return static::notice(Yii::t('app', 'decUserNameIsWrong'), 400);
  407. }
  408. if($userInfo['IS_DEC'] == 0 && $post['decUserName']){
  409. //查询报单编号是否存在
  410. $userId = Info::getUserIdByUserName($post['decUserName']);
  411. if(!$userId){
  412. return static::notice(Yii::t('app', 'decUserNameIsWrong'), 400);
  413. }
  414. $isDec = User::getEnCodeInfo($userId)['IS_DEC'];
  415. if(!$isDec){
  416. return static::notice(Yii::t('app', 'decUserNameIsWrong'), 400);
  417. }
  418. }
  419. // 根据支付方式区分逻辑
  420. $payMethod = \Yii::$app->request->post('payType', '');
  421. if ($payMethod === 'pay_stack') {
  422. $formModel = new ApproachDeclarationLoopForm();
  423. } else {
  424. unset($post['payType']);
  425. $formModel = new DeclarationLoopForm();
  426. }
  427. $formModel->scenario = 'userDec';
  428. $post['province'] = $post['province'] ? :1;
  429. $post['city'] = $post['city'] ? :1;
  430. $post['county'] = $post['county'] ? :1;
  431. $post['conUserName'] = trim($post['conUserName']);
  432. $post['recUserName'] = trim($post['recUserName']);
  433. $post['cityName'] = trim($post['cityName']);
  434. $post['lgaName'] = trim($post['lgaName']);
  435. // 针对于会员编号的判断
  436. if($post['decType']=='normal'){ // 普通报单,判断Redis中的用户名是否一致
  437. $insertUserName = strtoupper($post['insertUserName']);
  438. $getRedisUserName = $redis->get('key_' . $insertUserName);
  439. if (!$getRedisUserName){
  440. return static::notice(Yii::t('app', 'memberNumberExpired'), 400);
  441. }
  442. if ($insertUserName != $getRedisUserName){
  443. return static::notice(Yii::t('app', 'memberNumberDoesNotConformTo'), 400);
  444. }
  445. }else{ // BA升级,需要判断BA用户是否存在
  446. $insertUserName = $post['insertUserName'];
  447. }
  448. $post['insertUserName'] = $insertUserName;
  449. $post['type'] = DeclarationForm::TYPE_ZC;
  450. $allData['data'][] = $post;
  451. if ($formModel->load($allData, '') && $result = $formModel->add()) {
  452. return static::notice($result);//报单成功
  453. } else {
  454. return static::notice(Form::formatErrorsForApi($formModel->getErrors()),400);
  455. }
  456. }
  457. //所有报单套餐
  458. $allDecPackage = DeclarationPackage::getAllData();
  459. $decLevels = Cache::getDecLevelConfig();
  460. foreach ($allDecPackage as $k=>$v){
  461. $levelName = $decLevels[$v['LEVEL_ID']]['LEVEL_NAME'] ?? '';
  462. $allDecPackage[$k]['LEVEL_NAME'] = $levelName;
  463. }
  464. //所有自选商品
  465. $isDecReg = Cache::getSystemConfig()['isDecReg']['VALUE'];
  466. $isDec = User::getEnCodeInfo(\Yii::$app->user->id)['IS_DEC'];
  467. $isStudio = User::getEnCodeInfo(\Yii::$app->user->id)['IS_STUDIO'];
  468. $query_condition= " AND (1<>1";
  469. if(!$isDecReg || ($isDecReg && $isDec==1)){
  470. $query_condition = " AND (FIND_IN_SET(1,GIFT_TYPE)>0";
  471. }
  472. if($isStudio==1){
  473. $query_condition.= " OR FIND_IN_SET(3,GIFT_TYPE)>0";
  474. }
  475. $query_condition.= ")";
  476. // 只查询普通商品
  477. $allGoods = ShopGoods::find()->where("STATUS=1 AND CATEGORY_TYPE=1".$query_condition)->orderBy('SORT ASC')->asArray()->all();
  478. //$allGoods = ShopGoods::findAllAsArray('STATUS=1');
  479. // 所有开户行
  480. $allOpenBank = OpenBank::find()->where('STATUS=1')->orderBy('LIST_ORDER ASC')->asArray()->all();
  481. if (!$userName) {
  482. return static::notice(Yii::t('app', 'failedToGenerateMemberNumber'), 400);
  483. }
  484. //随机码保存在redis中方便进行比对
  485. $redis->setex('key_'.$userName , 3600 , $userName);
  486. // 会员账户
  487. $userBalance = ['cash' => 0];
  488. $userCash = UserWallet::findOneAsArray(['USER_ID' => \Yii::$app->user->id]);
  489. if ($userCash) {
  490. $userBalance['cash'] = $userCash['CASH'];
  491. }
  492. return static::notice([
  493. 'allDecPackage' => $allDecPackage,
  494. 'allGoods' => $allGoods,
  495. 'allOpenBank' => $allOpenBank,
  496. 'userName' => $userName,
  497. 'payList' => ShopGoods::payTypes(),
  498. 'sellType' => ShopGoods::getCategoryType(),
  499. 'categoryType' => ShopGoods::getCategoryType()[0]['id'],
  500. 'userBalance' => $userBalance,
  501. 'isDec' => $isDec,
  502. ]);
  503. }
  504. /**
  505. * 报单级别套餐
  506. */
  507. public function actionDecPackage() {
  508. $decLv = \Yii::$app->request->get('id');
  509. //所有报单级别套餐
  510. $allDecPackage = DeclarationPackage::getPackageFromLevelId($decLv);
  511. return static::notice(['allDecPackage' => $allDecPackage]);
  512. }
  513. /*
  514. * 从会员名和左右,获取底部安置人
  515. *
  516. */
  517. public function actionGetAutoPlace() {
  518. $userName = \Yii::$app->request->get('userName');
  519. $side = \Yii::$app->request->get('side');
  520. $userId = Info::getUserIdByUserName($userName);
  521. // print_r($userId);
  522. $bottomPlace = UserNetwork::getBottomPlace($userId,'', $side);
  523. $bottomUser = UserNetwork::find()->select('USER_ID')->where('LOCATION_TAG=:LOCATION_TAG', ['LOCATION_TAG' => $bottomPlace])->asArray()->one();
  524. $bottomUser = User::findOneAsArray('ID=:ID', [':ID' => $bottomUser['USER_ID']], 'USER_NAME');
  525. // print_r($bottomUser);
  526. return static::notice($bottomUser);
  527. }
  528. /**
  529. * 会员信息查询
  530. * @return mixed
  531. * @throws \yii\web\HttpException
  532. */
  533. public function actionFullInfo()
  534. {
  535. $userName = \Yii::$app->request->get('userName');
  536. $userId = Info::getUserIdByUserName($userName);
  537. $userInfo['REAL_NAME'] = '';
  538. $user = User::findOneAsArray('ID=:ID', [':ID' => $userId], 'REAL_NAME');
  539. if($user){
  540. $userInfo['REAL_NAME'] = $user['REAL_NAME'];
  541. $allChildUser = UserNetwork::getFirstFloorChildren($userId);
  542. $isLocation = [1 => 'Left-Null', 2 => 'Right-Null'];
  543. if($allChildUser) {
  544. foreach ($allChildUser as $child) {
  545. if ($child['RELATIVE_LOCATION']<'3'){
  546. // $isLocation[$child['RELATIVE_LOCATION']].= 'Full';
  547. $isLocation[$child['RELATIVE_LOCATION']] = str_replace('Null', 'Full', $isLocation[$child['RELATIVE_LOCATION']]);
  548. }
  549. }
  550. }
  551. $userInfo['isLocation'] = '('.implode(',',$isLocation).')';
  552. return static::notice($userInfo);
  553. }else{
  554. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  555. }
  556. }
  557. /**
  558. * 复消会员信息查询
  559. * @return mixed
  560. * @throws \yii\web\HttpException
  561. */
  562. public function actionUserBaseInfo()
  563. {
  564. $userName = \Yii::$app->request->get('userName');
  565. $userId = Info::getUserIdByUserName($userName);
  566. if($userId){
  567. $allAddress = ReceiveAddress::findAllAsArray('USER_ID=:USER_ID', [':USER_ID'=>$userId]);
  568. if($allAddress) {
  569. foreach ($allAddress as $key => $row) {
  570. $allAddress[$key]['PROVINCE_NAME'] = Region::getCnName($row['PROVINCE']);
  571. $allAddress[$key]['CITY_NAME'] = Region::getCnName($row['CITY']);
  572. $allAddress[$key]['COUNTY_NAME'] = Region::getCnName($row['COUNTY']);
  573. }
  574. }
  575. $userInfo = Info::baseInfoWithNet($userId);
  576. // $decLevelConfig = Cache::getDecLevelConfig();
  577. // $empLevelConfig = Cache::getEmpLevelConfig();
  578. $arr = [
  579. 'REAL_NAME'=>$userInfo['REAL_NAME'],
  580. // 'DEC_LEVEL_NAME' => $decLevelConfig[$userInfo['DEC_LV']]['LEVEL_NAME'],
  581. // 'EMP_LEVEL_NAME'=>$empLevelConfig[$userInfo['EMP_LV']]['LEVEL_NAME'],
  582. // 'REC_UID'=>$userInfo['REC_USER_NAME'].'('.$userInfo['REC_REAL_NAME'].')',
  583. // 'CON_UID'=>$userInfo['CON_USER_NAME'].'('.$userInfo['CON_REAL_NAME'].')',
  584. 'allAddress'=>$allAddress
  585. ];
  586. return static::notice($arr);
  587. }else{
  588. return static::notice(Yii::t('app', 'repeatSalesMemberNoDoesNotExist'), 400);
  589. }
  590. }
  591. /**
  592. * 会员资料
  593. * @return mixed
  594. * @throws \yii\web\HttpException
  595. */
  596. public function actionBaInfo()
  597. {
  598. $data['userInfo'] = BaUser::getEnCodeInfo(\Yii::$app->user->id);
  599. $data['userInfo']['NATION'] = $data['userInfo']['NATION_ID'];
  600. // 推荐人
  601. $baUserInfo = BaUserInfo::findOneAsArray('USER_ID=:USER_ID', [':USER_ID' => \Yii::$app->user->id]);
  602. $sponsor = User::findOneAsArray('ID=:USER_ID', [':USER_ID' => $baUserInfo['REC_UID']]);
  603. $data['userInfo']['SponsorCode'] = $sponsor['USER_NAME'];
  604. $data['userInfo']['SponsorName'] = $sponsor['REAL_NAME'];
  605. return static::notice($data);
  606. }
  607. /**
  608. * 编辑会员资料
  609. * @return mixed
  610. * @throws \yii\web\HttpException
  611. */
  612. public function actionBaEdit()
  613. {
  614. if(\Yii::$app->request->isPost)
  615. {
  616. $form = new BaUserForm();
  617. $post = \Yii::$app->request->post();
  618. $form->scenario = 'modifyProfile';
  619. if ($form->load($post, '') && $result = $form->modifyProfile()){
  620. return static::notice(Yii::t('app', 'personalDataModifiedSuccessfully'), 400);
  621. } else {
  622. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  623. }
  624. }
  625. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  626. }
  627. /**
  628. * 修改登录密码
  629. */
  630. public function actionBaPassword(){
  631. if(\Yii::$app->request->isPost) {
  632. $form = new BaUserForm();
  633. $form->scenario = 'modifyPassword';
  634. $post = \Yii::$app->request->post();
  635. if($form->load($post, '') && $result = $form->modifyPassword()){
  636. return static::notice(Yii::t('app', 'passwordModifiedSuccessfully'), 400);
  637. } else {
  638. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  639. }
  640. }
  641. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  642. }
  643. /**
  644. * 修改支付密码
  645. */
  646. public function actionBaPayPassword(){
  647. if(\Yii::$app->request->isPost){
  648. $form = new BaUserForm();
  649. $form->scenario = 'modifyPasswordPay';
  650. $post = \Yii::$app->request->post();
  651. $form->userId = \Yii::$app->user->id;
  652. if($form->load($post, '') && $result = $form->modifyPasswordPay()){
  653. return static::notice(Yii::t('app', 'passwordModifiedSuccessfully'), 400);
  654. } else {
  655. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  656. }
  657. }
  658. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  659. }
  660. /**
  661. * BA报单管理
  662. */
  663. public function actionBaDec() {
  664. // 生成随机码 , 初始化redis
  665. $userName = Info::generateWebUserName('NG',9);
  666. $redis = \Yii::$app->redis;
  667. $post = \Yii::$app->request->post();
  668. if (\Yii::$app->request->isPost) {
  669. // 根据支付方式区分逻辑
  670. $payMethod = \Yii::$app->request->post('payType', '');
  671. if ($payMethod === 'pay_stack') {
  672. $formModel = new BaApproachDeclarationLoopForm();
  673. } else {
  674. unset($post['payType']);
  675. $formModel = new BaDeclarationLoopForm();
  676. }
  677. $formModel->scenario = 'userDec';
  678. $post['province'] = $post['province'] ? :1;
  679. $post['city'] = $post['city'] ? :1;
  680. $post['county'] = $post['county'] ? :1;
  681. // $post['conUserName'] = trim($post['conUserName']);
  682. $post['recUserName'] = trim($post['recUserName']);
  683. $post['cityName'] = trim($post['cityName']);
  684. $post['lgaName'] = trim($post['lgaName']);
  685. // 针对于会员编号的判断
  686. $insertUserName = strtoupper($post['insertUserName']);
  687. $getRedisUserName = $redis->get('key_' . $insertUserName);
  688. if (!$getRedisUserName){
  689. return static::notice(Yii::t('app', 'memberNumberExpired'), 400);
  690. }
  691. if ($insertUserName != $getRedisUserName){
  692. return static::notice(Yii::t('app', 'memberNumberDoesNotConformTo'), 400);
  693. }
  694. $post['insertUserName'] = $insertUserName;
  695. $post['type'] = BaDeclarationForm::TYPE_ZC;
  696. $allData['data'][] = $post;
  697. if ($formModel->load($allData, '') && $result = $formModel->add()) {
  698. return static::notice($result); // 报单成功
  699. } else {
  700. return static::notice(Form::formatErrorsForApi($formModel->getErrors()),400);
  701. }
  702. }
  703. // 只查询普通商品
  704. $allGoods = ShopGoods::find()->where("ID='375895243322691584'")->orderBy('SORT ASC')->asArray()->all();
  705. if (!$userName) {
  706. return static::notice(Yii::t('app', 'failedToGenerateMemberNumber'), 400);
  707. }
  708. //随机码保存在redis中方便进行比对
  709. $redis->setex('key_'.$userName , 3600 , $userName);
  710. // 会员账户
  711. $userBalance = [
  712. 'cash' => 0,
  713. // 'tourism_points' => 0,
  714. // 'garage_points' => 0,
  715. // 'villa_points' => 0,
  716. ];
  717. $userCash = UserWallet::findOneAsArray(['USER_ID' => \Yii::$app->user->id]);
  718. if ($userCash) {
  719. $userBalance['cash'] = $userCash['CASH'];
  720. }
  721. return static::notice([
  722. 'allGoods' => $allGoods,
  723. 'userName' => $userName,
  724. 'payList' => ShopGoods::payTypes(),
  725. 'sellType' => ShopGoods::getCategoryType(),
  726. 'categoryType' => ShopGoods::getCategoryType()[0]['id'],
  727. 'userBalance' => $userBalance,
  728. ]);
  729. }
  730. /**
  731. * BA会员信息
  732. * @return mixed
  733. * @throws \yii\web\HttpException
  734. */
  735. public function actionBaUserInfo()
  736. {
  737. $userName = \Yii::$app->request->get('userName');
  738. $userId = Info::getBaUserIdByUserName($userName);
  739. $userInfo['REAL_NAME'] = '';
  740. $user = BaUser::findOneAsArray('ID=:ID', [':ID' => $userId], 'REAL_NAME');
  741. $uInfo = BaUserInfo::findOneAsArray('USER_ID=:USER_ID', [':USER_ID' => $userId], 'REC_UID');
  742. if($user){
  743. $rec_user = UserInfo::findOneAsArray('USER_ID=:USER_ID',[':USER_ID' => $uInfo['REC_UID']], 'USER_ID, USER_NAME');
  744. $userInfo['REAL_NAME'] = $user['REAL_NAME'];
  745. $userInfo['REC_USER_ID'] = $rec_user['USER_ID'];
  746. $userInfo['REC_USER_NAME'] = $rec_user['USER_NAME'];
  747. return static::notice($userInfo);
  748. }else{
  749. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  750. }
  751. }
  752. }