UserController.php 34 KB

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