UserController.php 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842
  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. $decCountry = User::getEnCodeInfo(\Yii::$app->user->id)['COUNTRY_ID'];
  496. LoggerTool::error('$decCountry. ' . json_encode($decCountry));
  497. $decUserCurrencyRate = CurrencyConversions::getToUSDRate($decCountry['LOCAL_CURRENCY_ID']);
  498. // 新会员的本地汇率
  499. $country = Countries::getById($countryId);
  500. LoggerTool::error('$country. ' . json_encode($country));
  501. $currencyRate = CurrencyConversions::getToUSDRate($country['LOCAL_CURRENCY_ID']);
  502. // 会员账户
  503. $userBalance = [
  504. 'cash' => 0,
  505. 'localCash' => 0
  506. ];
  507. $userCash = UserWallet::findOneAsArray(['USER_ID' => \Yii::$app->user->id]);
  508. if ($userCash) {
  509. $userBalance['cash'] = $userCash['CASH'];
  510. $userBalance['localCash'] = Tool::convertAmount($userCash['CASH'], $decUserCurrencyRate, $currencyRate);
  511. }
  512. // 行政区划
  513. $region = Region::getByCountryId($countryId);
  514. return static::notice([
  515. 'allDecPackage' => $allDecPackage,
  516. 'allGoods' => $allGoods,
  517. 'allOpenBank' => $allOpenBank,
  518. 'userName' => $userName,
  519. 'payList' => ShopGoods::payTypes(),
  520. 'sellType' => ShopGoods::getCategoryType(),
  521. 'categoryType' => ShopGoods::getCategoryType()[0]['id'],
  522. 'userBalance' => $userBalance,
  523. 'isDec' => $isDec,
  524. 'decUserCurrencyRate' => $decUserCurrencyRate,
  525. 'userCurrencyRate' => $currencyRate,
  526. 'region' => $region,
  527. ]);
  528. }
  529. /**
  530. * 报单级别套餐
  531. */
  532. public function actionDecPackage() {
  533. $decLv = \Yii::$app->request->get('id');
  534. //所有报单级别套餐
  535. $allDecPackage = DeclarationPackage::getPackageFromLevelId($decLv);
  536. return static::notice(['allDecPackage' => $allDecPackage]);
  537. }
  538. /*
  539. * 从会员名和左右,获取底部安置人
  540. *
  541. */
  542. public function actionGetAutoPlace() {
  543. $userName = \Yii::$app->request->get('userName');
  544. $side = \Yii::$app->request->get('side');
  545. $userId = Info::getUserIdByUserName($userName);
  546. // print_r($userId);
  547. $bottomPlace = UserNetwork::getBottomPlace($userId,'', $side);
  548. $bottomUser = UserNetwork::find()->select('USER_ID')->where('LOCATION_TAG=:LOCATION_TAG', ['LOCATION_TAG' => $bottomPlace])->asArray()->one();
  549. $bottomUser = User::findOneAsArray('ID=:ID', [':ID' => $bottomUser['USER_ID']], 'USER_NAME');
  550. // print_r($bottomUser);
  551. return static::notice($bottomUser);
  552. }
  553. /**
  554. * 会员信息查询
  555. * @return mixed
  556. * @throws \yii\web\HttpException
  557. */
  558. public function actionFullInfo()
  559. {
  560. $userName = \Yii::$app->request->get('userName');
  561. $userId = Info::getUserIdByUserName($userName);
  562. $userInfo['REAL_NAME'] = '';
  563. $user = User::findOneAsArray('ID=:ID', [':ID' => $userId]);
  564. if($user){
  565. $userInfo['REAL_NAME'] = $user['REAL_NAME'];
  566. $allChildUser = UserNetwork::getFirstFloorChildren($userId);
  567. $isLocation = [1 => 'Left-Null', 2 => 'Right-Null'];
  568. if($allChildUser) {
  569. foreach ($allChildUser as $child) {
  570. if ($child['RELATIVE_LOCATION']<'3'){
  571. // $isLocation[$child['RELATIVE_LOCATION']].= 'Full';
  572. $isLocation[$child['RELATIVE_LOCATION']] = str_replace('Null', 'Full', $isLocation[$child['RELATIVE_LOCATION']]);
  573. }
  574. }
  575. }
  576. $userInfo['countryId'] = $user['COUNTRY_ID'];
  577. $userInfo['userId'] = $userId;
  578. $userInfo['isLocation'] = '('.implode(',',$isLocation).')';
  579. return static::notice($userInfo);
  580. }else{
  581. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  582. }
  583. }
  584. /**
  585. * 复消会员信息查询
  586. * @return mixed
  587. * @throws \yii\web\HttpException
  588. */
  589. public function actionUserBaseInfo()
  590. {
  591. $userName = \Yii::$app->request->get('userName');
  592. $userId = Info::getUserIdByUserName($userName);
  593. if($userId){
  594. $allAddress = ReceiveAddress::findAllAsArray('USER_ID=:USER_ID', [':USER_ID'=>$userId]);
  595. if($allAddress) {
  596. foreach ($allAddress as $key => $row) {
  597. $allAddress[$key]['PROVINCE_NAME'] = Region::getCnName($row['PROVINCE']);
  598. $allAddress[$key]['CITY_NAME'] = Region::getCnName($row['CITY']);
  599. $allAddress[$key]['COUNTY_NAME'] = Region::getCnName($row['COUNTY']);
  600. }
  601. }
  602. $userInfo = Info::baseInfoWithNet($userId);
  603. // $decLevelConfig = Cache::getDecLevelConfig();
  604. // $empLevelConfig = Cache::getEmpLevelConfig();
  605. $arr = [
  606. 'REAL_NAME'=>$userInfo['REAL_NAME'],
  607. // 'DEC_LEVEL_NAME' => $decLevelConfig[$userInfo['DEC_LV']]['LEVEL_NAME'],
  608. // 'EMP_LEVEL_NAME'=>$empLevelConfig[$userInfo['EMP_LV']]['LEVEL_NAME'],
  609. // 'REC_UID'=>$userInfo['REC_USER_NAME'].'('.$userInfo['REC_REAL_NAME'].')',
  610. // 'CON_UID'=>$userInfo['CON_USER_NAME'].'('.$userInfo['CON_REAL_NAME'].')',
  611. 'allAddress'=>$allAddress
  612. ];
  613. return static::notice($arr);
  614. }else{
  615. return static::notice(Yii::t('app', 'repeatSalesMemberNoDoesNotExist'), 400);
  616. }
  617. }
  618. /**
  619. * 会员资料
  620. * @return mixed
  621. * @throws \yii\web\HttpException
  622. */
  623. public function actionBaInfo()
  624. {
  625. $data['userInfo'] = BaUser::getEnCodeInfo(\Yii::$app->user->id);
  626. $data['userInfo']['NATION'] = $data['userInfo']['NATION_ID'];
  627. // 推荐人
  628. $baUserInfo = BaUserInfo::findOneAsArray('USER_ID=:USER_ID', [':USER_ID' => \Yii::$app->user->id]);
  629. $sponsor = User::findOneAsArray('ID=:USER_ID', [':USER_ID' => $baUserInfo['REC_UID']]);
  630. $data['userInfo']['SponsorCode'] = $sponsor['USER_NAME'];
  631. $data['userInfo']['SponsorName'] = $sponsor['REAL_NAME'];
  632. return static::notice($data);
  633. }
  634. /**
  635. * 编辑会员资料
  636. * @return mixed
  637. * @throws \yii\web\HttpException
  638. */
  639. public function actionBaEdit()
  640. {
  641. if(\Yii::$app->request->isPost)
  642. {
  643. $form = new BaUserForm();
  644. $post = \Yii::$app->request->post();
  645. $form->scenario = 'modifyProfile';
  646. if ($form->load($post, '') && $result = $form->modifyProfile()){
  647. return static::notice(Yii::t('app', 'personalDataModifiedSuccessfully'), 400);
  648. } else {
  649. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  650. }
  651. }
  652. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  653. }
  654. /**
  655. * 修改登录密码
  656. */
  657. public function actionBaPassword(){
  658. if(\Yii::$app->request->isPost) {
  659. $form = new BaUserForm();
  660. $form->scenario = 'modifyPassword';
  661. $post = \Yii::$app->request->post();
  662. if($form->load($post, '') && $result = $form->modifyPassword()){
  663. return static::notice(Yii::t('app', 'passwordModifiedSuccessfully'), 400);
  664. } else {
  665. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  666. }
  667. }
  668. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  669. }
  670. /**
  671. * 修改支付密码
  672. */
  673. public function actionBaPayPassword(){
  674. if(\Yii::$app->request->isPost){
  675. $form = new BaUserForm();
  676. $form->scenario = 'modifyPasswordPay';
  677. $post = \Yii::$app->request->post();
  678. $form->userId = \Yii::$app->user->id;
  679. if($form->load($post, '') && $result = $form->modifyPasswordPay()){
  680. return static::notice(Yii::t('app', 'passwordModifiedSuccessfully'), 400);
  681. } else {
  682. return static::notice(Form::formatErrorsForApi($form->getErrors()), 400);
  683. }
  684. }
  685. return static::notice(Yii::t('app', 'illegalRequest'), 400);
  686. }
  687. /**
  688. * BA报单管理
  689. */
  690. public function actionBaDec() {
  691. // 生成随机码 , 初始化redis
  692. $userName = Info::generateWebUserName('NG',9);
  693. $redis = \Yii::$app->redis;
  694. $post = \Yii::$app->request->post();
  695. if (\Yii::$app->request->isPost) {
  696. // 根据支付方式区分逻辑
  697. $payMethod = \Yii::$app->request->post('payType', '');
  698. if ($payMethod === 'pay_stack') {
  699. $formModel = new BaApproachDeclarationLoopForm();
  700. } else {
  701. unset($post['payType']);
  702. $formModel = new BaDeclarationLoopForm();
  703. }
  704. $formModel->scenario = 'userDec';
  705. $post['province'] = $post['province'] ? :1;
  706. $post['city'] = $post['city'] ? :1;
  707. $post['county'] = $post['county'] ? :1;
  708. // $post['conUserName'] = trim($post['conUserName']);
  709. $post['recUserName'] = trim($post['recUserName']);
  710. $post['cityName'] = trim($post['cityName']);
  711. $post['lgaName'] = trim($post['lgaName']);
  712. // 针对于会员编号的判断
  713. $insertUserName = strtoupper($post['insertUserName']);
  714. $getRedisUserName = $redis->get('key_' . $insertUserName);
  715. if (!$getRedisUserName){
  716. return static::notice(Yii::t('app', 'memberNumberExpired'), 400);
  717. }
  718. if ($insertUserName != $getRedisUserName){
  719. return static::notice(Yii::t('app', 'memberNumberDoesNotConformTo'), 400);
  720. }
  721. $post['insertUserName'] = $insertUserName;
  722. $post['type'] = BaDeclarationForm::TYPE_ZC;
  723. $allData['data'][] = $post;
  724. if ($formModel->load($allData, '') && $result = $formModel->add()) {
  725. return static::notice($result); // 报单成功
  726. } else {
  727. return static::notice(Form::formatErrorsForApi($formModel->getErrors()),400);
  728. }
  729. }
  730. // 只查询普通商品
  731. $allGoods = ShopGoods::find()->where("ID='375895243322691584'")->orderBy('SORT ASC')->asArray()->all();
  732. if (!$userName) {
  733. return static::notice(Yii::t('app', 'failedToGenerateMemberNumber'), 400);
  734. }
  735. //随机码保存在redis中方便进行比对
  736. $redis->setex('key_'.$userName , 3600 , $userName);
  737. // 会员账户
  738. $userBalance = [
  739. 'cash' => 0,
  740. // 'tourism_points' => 0,
  741. // 'garage_points' => 0,
  742. // 'villa_points' => 0,
  743. ];
  744. $userCash = UserWallet::findOneAsArray(['USER_ID' => \Yii::$app->user->id]);
  745. if ($userCash) {
  746. $userBalance['cash'] = $userCash['CASH'];
  747. }
  748. return static::notice([
  749. 'allGoods' => $allGoods,
  750. 'userName' => $userName,
  751. 'payList' => ShopGoods::payTypes(),
  752. 'sellType' => ShopGoods::getCategoryType(),
  753. 'categoryType' => ShopGoods::getCategoryType()[0]['id'],
  754. 'userBalance' => $userBalance,
  755. ]);
  756. }
  757. /**
  758. * BA会员信息
  759. * @return mixed
  760. * @throws \yii\web\HttpException
  761. */
  762. public function actionBaUserInfo()
  763. {
  764. $userName = \Yii::$app->request->get('userName');
  765. $userId = Info::getBaUserIdByUserName($userName);
  766. $userInfo['REAL_NAME'] = '';
  767. $user = BaUser::findOneAsArray('ID=:ID', [':ID' => $userId], 'REAL_NAME');
  768. $uInfo = BaUserInfo::findOneAsArray('USER_ID=:USER_ID', [':USER_ID' => $userId], 'REC_UID');
  769. if($user){
  770. $rec_user = UserInfo::findOneAsArray('USER_ID=:USER_ID',[':USER_ID' => $uInfo['REC_UID']], 'USER_ID, USER_NAME');
  771. $userInfo['REAL_NAME'] = $user['REAL_NAME'];
  772. $userInfo['REC_USER_ID'] = $rec_user['USER_ID'];
  773. $userInfo['REC_USER_NAME'] = $rec_user['USER_NAME'];
  774. return static::notice($userInfo);
  775. }else{
  776. return static::notice(Yii::t('app', 'memberNumberDoesNotExist'), 400);
  777. }
  778. }
  779. }