NewMerchantForm.php 48 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119
  1. <?php
  2. /**
  3. * 重庆赤晓店信息科技有限公司
  4. * https://www.chixiaodian.com
  5. * Copyright (c) 2023 赤店商城 All rights reserved.
  6. */
  7. namespace app\modules\client\models\v1;
  8. use app\constants\OptionSetting;
  9. use app\jobs\order\NoAfterSalesOrderJob;
  10. use app\models\AccountLog;
  11. use app\models\Coupon;
  12. use app\models\CouponAutoSend;
  13. use app\models\GiveIntegralRules;
  14. use app\models\OrderDetail;
  15. use app\models\Recharge;
  16. use app\models\ReOrder;
  17. use app\models\RulesFaceStore;
  18. use app\models\SaaSLeaguePriceLog;
  19. use app\models\SaasUser;
  20. use app\models\User;
  21. use app\models\UserCoupon;
  22. use app\models\UserShareMoney;
  23. use app\plugins\scanCodePay\models\ScanCodePaySetting;
  24. use app\utils\Alipay\alipaySdk\aop\request\AlipaySystemOauthTokenRequest;
  25. use app\models\Goods;
  26. use app\models\MerchantInfo;
  27. use app\models\Option;
  28. use app\models\SaasCategory;
  29. use app\models\Salesman;
  30. use app\models\Store;
  31. use app\models\StoreAliMini;
  32. use app\models\StoreAudit;
  33. use app\models\StoreMini;
  34. use app\models\WechatConfig;
  35. use app\modules\admin\models\AlipayThirdForm;
  36. use app\modules\admin\models\WechatThirdForm;
  37. use app\modules\client\models\v1\DiyForm;
  38. use app\utils\OrderNo;
  39. use app\utils\Wechat\WechatNewPay;
  40. use app\utils\yunst\src\OrderYunst;
  41. use yii\base\Model;
  42. use EasyWeChat\Factory;
  43. use yii\data\Pagination;
  44. use app\plugins\scanCodePay\models\Order;
  45. use app\utils\Alipay\Alipay;
  46. use app\utils\Alipay\AlipayProfit;
  47. use app\utils\Wechat\Wechat;
  48. use app\utils\Wechat\WechatPay;
  49. use Overtrue\Socialite\SocialiteManager;
  50. use yii\helpers\ArrayHelper;
  51. use yii\helpers\Json;
  52. use app\utils\Adapay\Adapay;
  53. use app\models\Order as COrder;
  54. class NewMerchantForm extends Model
  55. {
  56. public $pay_type = 1;
  57. public $contact_info;
  58. public $subject_info;
  59. public $business_info;
  60. public $bank_account_info;
  61. public $apply_id;
  62. public $mini_apply_info;
  63. public $type; //'weixin'
  64. public $code;
  65. public $pay_fee;
  66. public $id;
  67. public $send_price;
  68. public $take_price;
  69. public $config;
  70. public $openPlatform;
  71. public $order_no;
  72. public $user_id;
  73. public $coupon_id;
  74. public $recharge_id;
  75. public $is_balance;
  76. public $order;
  77. public $reOrder;
  78. public $is_use_coupon;
  79. public $md_id;
  80. public $mch_id;
  81. public static $notify_url = 'wechat/notify';
  82. public function rules()
  83. {
  84. return [
  85. [['order_no',"license_pic", "license_no", "license_name", "legal_personal_name", "contact_info", "subject_info", "business_info", "bank_account_info", "type","code","pay_fee"], 'string'],
  86. [["apply_id","id",'qrcode_id', 'recharge_id', 'is_balance', 'is_use_coupon', 'md_id', 'mch_id'], "integer"],
  87. [["mini_apply_info"], "array"],
  88. [['pay_type'], 'safe']//, 'range' => [1, 2, 3, 4, COrder::PAY_TYPE_ADAPAY_WX]], // 'WECHAT_PAY', 'HUODAO_PAY', 'BALANCE_PAY' 'ALIPAY',
  89. ];
  90. }
  91. public function __construct($config = [])
  92. {
  93. parent::__construct($config);
  94. $this->config = [
  95. 'app_id' => Option::get("platform_third_appid",0,'saas')['value'],
  96. 'secret' => Option::get("platform_third_secret",0,'saas')['value'],
  97. 'token' =>Option::get("platform_token",0,'saas')['value'],
  98. 'aes_key' => Option::get("platform_encodingAesKey",0,'saas')['value']
  99. ];
  100. $this->openPlatform = Factory::openPlatform($this->config);
  101. }
  102. /**
  103. * mini业务
  104. */
  105. public function miniProgram($appid = ""){
  106. $store = StoreMini::find()->where(['or',['id' => $this->id],['appid'=>$appid,'store_id'=>get_store_id()]])->one();
  107. return $this->openPlatform->miniProgram($store->appid,$store->authorizer_refresh_token);
  108. }
  109. //商户逻辑 end
  110. //TODO 当面付逻辑 start
  111. public function facePayConfig($total_price = 0){
  112. try {
  113. // HKG 新增判断商城打烊状态 开始
  114. if(Option::get(OptionSetting::MALL_STATUS,get_store_id(),'store',0)['value'] == 1)
  115. return [
  116. 'code' => 1,
  117. 'msg' => '商城已打烊~'
  118. ];
  119. // HKG 新增判断商城打烊状态 结束
  120. $info = Store::find()->where(['id' => get_store_id()])->select("id,name,logo")->asArray()->one();
  121. $rule_ids = GiveIntegralRules::find()->where(['and', ['<', 'start_date', time()], ['>', 'end_date', time()], ['status' => 1, 'is_delete' => 0]])->select('id')->column();
  122. $rule_ids = RulesFaceStore::find()->where(['rule_id' => $rule_ids, 'store_id' => get_store_id()])->select('rule_id')->column();
  123. $mini_info = StoreAliMini::find()->where(['store_id' => get_store_id()])->andWhere(['is not', 'license_pic', null])
  124. ->select('license_no, license_pic, app_name, app_slogan, app_desc, service_phone, contact_name, category_name')->asArray()->one();
  125. if (empty($mini_info)) {
  126. $mini_info = [
  127. 'license_no' => md5(123),
  128. 'app_name' => Option::get('sp_name', '0', 'saas')['value'],
  129. 'app_slogan' => "小程序新版本更新",
  130. 'app_desc' => "小程序新版本更新,优化用户操作体验",
  131. 'service_phone' => "暂无",
  132. 'contact_name' => "暂无",
  133. 'category_name' => "购物_零售电商_综合零售商品;"
  134. ];
  135. }
  136. $combine_pay = Option::get(OptionSetting::STORE_COMBINE_PAY, get_store_id(), 'recharge', 0)['value'];
  137. if ($rule_ids || $combine_pay) {
  138. if ((int)get_user_id() === 0) {
  139. return [
  140. 'code' => 0,
  141. 'msg' => "请重新登陆",
  142. 'data' => [
  143. 'reLogin' => 1,
  144. 'store_info' => $info,
  145. 'mini_info' => $mini_info
  146. ]
  147. ];
  148. }
  149. }
  150. $user = null;
  151. if (get_user()) {
  152. $user = [];
  153. $user['id'] = get_user()->id;
  154. $user['money'] = get_user()->money;
  155. }
  156. $query = Recharge::find();
  157. $recharge = $query->where(['is_delete' => Recharge::IS_DELETE_NO, 'store_id' => get_store_id()])
  158. ->orderBy("sort desc,id desc")->asArray()->all();
  159. $store = Store::findOne($info['id']);
  160. // $send_profit_model = Option::findOne(['name' => 'store_send_profit']);//平台让利比例
  161. $send_model= Option::findOne(['name' => 'goods_send_profit','store_id' => get_store_id()]);
  162. $take_model= Option::findOne(['name' => 'goods_take_price','store_id' => get_store_id()]);
  163. // $this_store_send_profit_model= Option::findOne(['name' => 'store_this_profit','store_id' => get_store_id()]);
  164. // if($this_store_send_profit_model->value > 0){
  165. // $basic_send_profit = $this_store_send_profit_model->value;
  166. // }else{
  167. // $basic_send_profit = $send_profit_model->value;
  168. // }
  169. $new_send_profit = floatval($send_model->value * 0.01);
  170. $new_take_profit = floatval($take_model->value * 0.01);
  171. $user = User::findOne($user['id']);
  172. $saas_user = SaasUser::findOne(['mobile' => $user->binding]);
  173. // $store_league_model = Store::findOne(get_store_id());
  174. $show_saas_alliance_coupon = true;
  175. if (\Yii::$app->prod_is_dandianpu()) {
  176. $show_saas_alliance_coupon = false;
  177. }
  178. $coupon_list = $this->getCouponList($total_price);
  179. $use_balance = (int)Option::get('recharge_wallet_status', get_store_id(), 'recharge', 0)['value'];
  180. return [
  181. 'code'=>0,
  182. 'msg'=>"商户信息获取成功",
  183. 'data'=>[
  184. 'send_profit_model' => 100,
  185. 'send_model' =>$send_model->value,
  186. 'take_model' =>$take_model->value,
  187. 'user_price' => $saas_user->league_price,
  188. 'store_price' => $store->league_price,
  189. 'new_send_profit' => $new_send_profit,
  190. 'new_take_profit' => $new_take_profit,
  191. 'take_price' => $take_model->value,
  192. 'send_profit' => $send_model->value,
  193. 'store_info'=>$info,
  194. 'mini_info' => $mini_info,
  195. 'user' => $user,
  196. 'recharge' => $recharge,
  197. 'coupon_list' => $coupon_list,
  198. 'show_saas_alliance_coupon' => $show_saas_alliance_coupon,
  199. 'reLogin' => (int)((int)get_user_id() === 0),
  200. 'use_balance' => $use_balance,
  201. ]
  202. ];
  203. }catch (\Exception $e){
  204. return [
  205. 'code'=>1,
  206. 'msg'=>$e->getMessage()
  207. ];
  208. }
  209. }
  210. protected function getCouponList($total_price = 1100001)
  211. {
  212. // $total_price = 1100001 ;//$mch['total_price'];
  213. $list = UserCoupon::find()->alias('uc')
  214. ->leftJoin(['c' => Coupon::tableName()], 'uc.coupon_id=c.id')
  215. ->where([
  216. 'AND',
  217. ['uc.is_delete' => 0],
  218. ['uc.is_use' => 0],
  219. ['c.mch_id' => 0],
  220. ['uc.is_expire' => 0],
  221. ['uc.user_id' => get_user_id()],
  222. // ['<=', 'c.min_price', $total_price],
  223. ])
  224. ->select('c.name, c.expire_day, c.id coupon_id, c.expire_type, c.discount_type, c.discount, c.discount_max_price, uc.id user_coupon_id,c.mch_id,c.rule,c.sub_price,c.min_price,uc.begin_time,uc.end_time,uc.type,c.appoint_type,c.cat_id_list,c.goods_id_list')
  225. ->asArray()->all();
  226. $new_list = [];
  227. foreach ($list as $i => $item) {
  228. if ($item['expire_type'] == 1) {
  229. if ($item['end_time'] > 0) {
  230. if (time() > $item['end_time']) {
  231. continue;
  232. }
  233. }
  234. }
  235. if ($item['expire_type'] == 2) {
  236. if (time() > $item['end_time'] || time() < $item['begin_time']) {
  237. continue;
  238. }
  239. }
  240. if (isset($item['is_use']) && $item['is_use']) {
  241. continue;
  242. }
  243. if (isset($item['is_expire']) && $item['is_expire']) {
  244. continue;
  245. }
  246. if ($total_price < $item['min_price']) {
  247. continue;
  248. }
  249. $list[$i]['min_price_desc'] = $item['min_price'] == 0 ? '无门槛' : '满' . $item['min_price'] . '元可用';
  250. $list[$i]['begin_time'] = date('Y.m.d H:i', (int)$item['begin_time']);
  251. $list[$i]['end_time'] = date('Y.m.d H:i', (int)$item['end_time']);
  252. $list[$i]['discount_type'] = $item['discount_type'];
  253. $list[$i]['discount'] = $item['discount'];
  254. $list[$i]['min_price'] = doubleval($item['min_price']);
  255. if ($list[$i]['discount_type'] == 1) {
  256. $list[$i]['sub_price'] = round($total_price - doubleval($total_price * $list[$i]['discount'] / 10), 2);
  257. if($item['discount_max_price'] > 0 && $list[$i]['sub_price'] > $item['discount_max_price']){
  258. $list[$i]['sub_price'] = $item['discount_max_price'];
  259. }
  260. } else {
  261. $list[$i]['sub_price'] = doubleval($item['sub_price']);
  262. }
  263. $new_list[] = $list[$i];
  264. }
  265. return $new_list;
  266. }
  267. public function submitOrder($pay_type = 1){
  268. $t = \Yii::$app->db->beginTransaction();
  269. try {
  270. $pay_fee = $this->pay_fee;
  271. $combine_pay = Option::get(OptionSetting::STORE_COMBINE_PAY, get_store_id(), 'recharge', 0)['value'];
  272. $is_combine_pay = 0;
  273. $combine_money = 0;
  274. $user = User::findOne(get_user_id());
  275. $recharge_id = $this->recharge_id;
  276. $is_balance = $this->is_balance;
  277. //使用余额抵扣
  278. $is_finish = 0;
  279. $user_coupon_id = 0;
  280. $sub_price = 0;
  281. if ($this->coupon_id) {
  282. // $order->user_coupon_id = $this->coupon_id;
  283. $userCoupon = UserCoupon::findOne($this->coupon_id);
  284. $coupon = Coupon::findOne($userCoupon->coupon_id);
  285. if ($coupon) {
  286. if ($pay_fee > $coupon->min_price) {
  287. if ($coupon->discount_type == 1) {
  288. $sub_price = round($pay_fee - doubleval($pay_fee * $coupon->discount / 10), 2);
  289. if($coupon['discount_max_price'] > 0 && $sub_price > $coupon['discount_max_price']){
  290. $sub_price = $coupon['discount_max_price'];
  291. }
  292. } else {
  293. $sub_price = doubleval($coupon->sub_price);
  294. }
  295. $user_coupon_id = $this->coupon_id;
  296. $pay_fee -= $sub_price;
  297. $this->is_use_coupon = 1;
  298. }
  299. }
  300. // $order->coupon_sub_price = $sub_price;
  301. // $order->pay_price -= $sub_price;
  302. // UserCoupon::updateAll(['is_use' => 1], ['id' => $this->coupon_id]);
  303. }
  304. //计算联盟券抵扣的钱 和赠送的联盟券
  305. $send_model = Option::findOne(['name' => 'goods_send_profit', 'store_id' => get_store_id()]);
  306. $take_model = Option::findOne(['name' => 'goods_take_price', 'store_id' => get_store_id()]);
  307. $new_send_profit = bcmul($send_model->value, 0.01, 2);
  308. $new_take_profit = bcmul($take_model->value, 0.01, 2);
  309. $take_price = 0;
  310. $send_price = 0;
  311. //计算联盟券赠送的金额
  312. $store = Store::findOne(get_store_id());
  313. if ($store && $store->league_price) {
  314. // $pay_fee = bcmul($pay_fee, $new_send_profit, 2);
  315. $send_price = bcmul($pay_fee, $new_send_profit, 2);
  316. if ($send_price > $store->league_price) {
  317. $send_price = 0;
  318. }
  319. }
  320. //计算联盟券抵扣的金额
  321. $saas_user = SaasUser::findOne(['mobile' => $user->binding, 'is_delete' => 0]);
  322. if ($saas_user) {
  323. $take_price = bcmul($pay_fee, $new_take_profit, 2);
  324. if ($take_price > $saas_user->league_price) {
  325. $take_price = 0;
  326. if ($saas_user->league_price > 0) {
  327. $take_price = $saas_user->league_price;
  328. }
  329. }
  330. $pay_fee = bcsub($pay_fee, $take_price, 2);
  331. }
  332. if ($combine_pay && $is_balance) {
  333. $is_combine_pay = 1;
  334. $money = $user->money;
  335. if (($money - $pay_fee) >= 0) {
  336. $combine_money = $pay_fee;
  337. $pay_fee = 0;
  338. } else {
  339. $pay_fee = number_format(($pay_fee - $money), 2, '.', '');
  340. $combine_money = $money;
  341. $is_finish = 1;
  342. }
  343. }
  344. $md_id = $this->md_id;
  345. if ($md_id <= 0) {
  346. $md_id = 0;
  347. }
  348. $user_id = $this->user_id;
  349. $mch_id = $this->mch_id ?: 0;
  350. $order = new Order();
  351. $order->store_id = get_store_id();
  352. $order->md_id = $md_id;
  353. $order->saas_id = get_saas_user_id();
  354. $order->user_id = ($user_id ?: get_user_id());
  355. $order->order_no = OrderNo::getOrderNo(OrderNo::ORDER_SCAN_CODE_PAY);
  356. $order->pay_price = $pay_fee ?: 0;
  357. $order->send_price = $send_price;
  358. $order->take_price = $take_price;
  359. $order->created_at = time();
  360. $order->first_price = 0;
  361. $order->second_price = 0;
  362. $order->third_price = 0;
  363. $order->content = "";
  364. $order->is_platform = 0;
  365. $order->is_offline = 1;
  366. $order->version = cyy_version();
  367. $order->mch_id = $mch_id;
  368. $order->discount = 10; // 当面付订单不享受会员折扣
  369. $order->remark = '' ;
  370. $order->pay_type = $pay_type;
  371. $order->is_pay = ($pay_fee == 0 ? 1 : 0);
  372. $order->total_price = $this->pay_fee ?: 0;
  373. $order->express_price = 0;
  374. $order->is_combine_pay = $is_combine_pay;
  375. $order->combine_money = $combine_money;
  376. if ($is_balance && $pay_fee == 0) {
  377. $order->trade_status = Order::ORDER_FLOW_CONFIRM;
  378. }
  379. if (\Yii::$app->prod_is_dandianpu() && !Store::hasIncoming($order->store_id)) {
  380. $order->is_use_platform_mch = 1;
  381. }
  382. if ($user_coupon_id > 0) {
  383. $order->user_coupon_id = $user_coupon_id;
  384. $order->coupon_sub_price = $sub_price;
  385. }
  386. $res = $order->save();
  387. $this->order = $order;
  388. if($res){
  389. //使用充值方案
  390. if ($recharge_id) {
  391. $recharge = Recharge::findOne(['id' => $recharge_id, 'is_delete' => 0, 'store_id' => get_store_id()]);
  392. $pay_price = $recharge->pay_price;
  393. $all_price = $recharge->pay_price + $recharge->send_price;
  394. /**
  395. * 如果为余额支付
  396. * 判断充值金额、赠送金额和用户余额是否大于支付金额
  397. * 如果不为余额支付
  398. * 判断充值金额、赠送金额是否大于支付金额
  399. * 如果选择的充值金额依旧小于应支付的金额,则这时应该使用应支付的金额进行微信支付
  400. * 充值后将选择的充值条件增加记录并增加支付记录
  401. */
  402. if ($is_balance) {
  403. $all_price += doubleval(sprintf('%.2f', $user->money));
  404. }
  405. if ($all_price < $this->pay_fee) {
  406. return [
  407. 'code' => 1,
  408. 'msg' => '当前所选充值方案不能满足支付需求'
  409. ];
  410. $pay_price = $this->pay_fee;
  411. }
  412. if ($recharge) {
  413. $ReOrder = new ReOrder();
  414. $ReOrder->store_id = get_store_id();
  415. $ReOrder->user_id = ($user_id ?: get_user_id());
  416. $ReOrder->pay_price = $recharge->pay_price;
  417. $ReOrder->send_price = $recharge->send_price;
  418. $ReOrder->send_integral = $recharge->send_integral;
  419. $ReOrder->order_no = OrderNo::getOrderNo(OrderNo::ORDER_RECHARGE);
  420. $ReOrder->is_pay = 0;
  421. $ReOrder->pay_type = $pay_type;
  422. $ReOrder->is_delete = 0;
  423. $ReOrder->created_at = time();
  424. $ReOrder->type = 0;
  425. $ReOrder->order_id = $order->id;
  426. if (\Yii::$app->prod_is_dandianpu() && !Store::hasIncoming($ReOrder->store_id)) {
  427. $ReOrder->is_use_platform_mch = 1;
  428. }
  429. if ($ReOrder->save()) {
  430. $this->order = $ReOrder;
  431. $t->commit();
  432. return [
  433. 'code'=>0,
  434. 'data'=>[
  435. 'order_id'=>$ReOrder->id,
  436. 'add_time'=>time(),
  437. 'order_no'=>$ReOrder->order_no,
  438. 'pay_fee' => $pay_price,
  439. 'is_recharge' => 1,
  440. 'is_finish' => $is_finish
  441. ]
  442. ];
  443. } else {
  444. throw new \Exception("创建订单失败" . json_encode($ReOrder->errors));
  445. }
  446. } else {
  447. throw new \Exception("充值方案查找失败");
  448. }
  449. } else {
  450. if ($pay_fee == 0) {
  451. $before = $user->money;
  452. $user->money -= $combine_money;
  453. if ($user->save()) {
  454. $log = new AccountLog();
  455. $log->store_id = $order->store_id;
  456. $log->user_id = $user->id;
  457. $log->type = AccountLog::TYPE_BALANCE;
  458. $log->log_type = AccountLog::LOG_TYPE_EXPEND;
  459. $log->amount = floatval($combine_money);
  460. $log->desc = "当面付在线支付,订单编号为" . $order->order_no;
  461. $log->before = $before;
  462. $log->after = $user->money;
  463. $log->operator = '';
  464. $log->operator_id = 0;
  465. $log->operator_type = AccountLog::TYPE_OPERATOR_NORMAL;
  466. $log->created_at = time();
  467. $log->order_id = $order->id;
  468. $log->order_type = AccountLog::TYPE_SCAN_CODE_PAY;
  469. if (!$log->save()) {
  470. throw new \Exception("创建余额记录失败" . json_encode($log->errors));
  471. };
  472. }
  473. }
  474. $t->commit();
  475. return [
  476. 'code'=>0,
  477. 'data'=>[
  478. 'order_id'=>$order->id,
  479. 'add_time'=>time(),
  480. 'order_no'=>$order->order_no,
  481. 'pay_fee' => $pay_fee,
  482. 'is_recharge' => 0,
  483. 'is_finish' => $is_finish
  484. ]
  485. ];
  486. }
  487. }else{
  488. throw new \Exception("创建订单失败" . json_encode($order->errors));
  489. }
  490. } catch (\Exception $e) {
  491. $t->rollBack();
  492. return [
  493. 'code' => 1,
  494. 'msg' => $e->getMessage()
  495. ];
  496. }
  497. }
  498. public function wx_b2b_pay($session_key, $pay_type, $config){
  499. $result = \app\modules\admin\models\UserAuditForm::pay($session_key, $this->order, OrderNo::ORDER_SCAN_CODE_PAY, $config['body']);
  500. return $result;
  501. }
  502. public function adapay($pay_type, $config){
  503. $result = Adapay::create($pay_type, $this->order, OrderNo::ORDER_SCAN_CODE_PAY, $config['body']);
  504. return $result;
  505. }
  506. public function facePay(){
  507. if($this->type == "weixin"){
  508. //获取商户配置信息
  509. $wechat_config = WechatConfig::find()->where(['store_id' => get_store_id(), 'type' => 1])->select(['mch_id','app_id'])->asArray()->one();
  510. $audit_status = Option::get('one_store_is_shenhe', 0, 'saas', 0)['value'];
  511. // if (\Yii::$app->prod_is_dandianpu() && $audit_status) {
  512. // $wechat_config = WechatConfig::find()->where(['type' => 1])
  513. // ->andWhere(['AND', ['<>', 'mch_id', ''], ['<>', 'mch_id', 0], ['is not', 'mch_id', null]])
  514. // ->select(['mch_id','app_id'])->asArray()->one();
  515. // }
  516. $open_id = '';
  517. $user = get_user();
  518. if (!$user) {
  519. if (is_isv()) {
  520. //小程序登陆获取openid
  521. $miniProgram = $this->miniProgram($wechat_config['app_id']);
  522. $res = $miniProgram->auth->session($this->code);
  523. } else {
  524. $wechat = isset(\Yii::$app->controller->wechat) ? \Yii::$app->controller->wechat : null;
  525. if (!$wechat) {
  526. return [
  527. 'code' => 1,
  528. 'msg' => '登录异常'
  529. ];
  530. }
  531. $res = $wechat->auth->session($this->code);
  532. //小程序登陆获取openid
  533. // $res = \Yii::$app->controller->wechatMini->auth->session($this->code);
  534. }
  535. $open_id = $res['openid'];
  536. if (!isset($open_id)) {
  537. return [
  538. 'code' => 1,
  539. 'msg' => 'openId错误'
  540. ];
  541. }
  542. $user = User::find()->where(['wechat_open_id' => $open_id, 'store_id' => get_store_id()])->select('id')->one();
  543. }
  544. if ($user) {
  545. $this->user_id = $user->id;
  546. $open_id = $user->wechat_open_id;
  547. if (is_h5()) {
  548. $open_id = $user->wechat_platform_open_id;
  549. }
  550. }
  551. $res = $this->submitOrder($this->pay_type);
  552. if($res['code'] === 0){
  553. $data = $res['data'];
  554. $data['pay_fee'] = round($data['pay_fee'],2);
  555. if ($data['pay_fee'] == 0) {
  556. if (get_user_id() > 0) {
  557. $form = new \app\modules\alliance\models\NewMerchantForm();
  558. $form->store_id = get_store_id();
  559. $form->saasGiveIntegral($this->pay_fee, get_user_id(), $data['order_no']);
  560. if ($this->is_use_coupon) {
  561. UserCoupon::updateAll(['is_use' => 1], ['id' => $this->coupon_id]);
  562. }
  563. }
  564. $this->order_no = $data['order_no'];
  565. $this->payResult();
  566. return [
  567. 'code' => 0,
  568. 'data' => [
  569. 'is_pay' => 1,
  570. 'order_no'=>$data['order_no'],
  571. ]
  572. ];
  573. }
  574. }else{
  575. return $res;
  576. }
  577. $config = [
  578. 'body' => '当面付',
  579. 'out_trade_no' => $data['order_no'],
  580. 'total_fee' => $data['pay_fee'] * 100,
  581. 'notify_url' => pay_notify_url(self::$notify_url),
  582. 'trade_type' => 'JSAPI',
  583. ];
  584. if (in_array($this->pay_type, [COrder::PAY_TYPE_WX_B2B])) {
  585. $res = $this->wx_b2b_pay($session_key, $this->pay_type, $config);
  586. debug_log('支付数据' . json_encode($res));
  587. return $res;
  588. }
  589. if (in_array($this->pay_type, [COrder::PAY_TYPE_ADAPAY_WX, COrder::PAY_TYPE_ADAPAY_ALIPAY])) {
  590. $res = $this->adapay($this->pay_type, $config);
  591. if ($res['code'] != 0) {
  592. debug_log('支付数据' . json_encode($res));
  593. return $res;
  594. }
  595. $res['data'] = array_merge($res['data'], [
  596. 'order_no'=>$data['order_no'],
  597. 'is_pay' => 0,
  598. 'is_finish' => 1
  599. ]);
  600. debug_log('支付数据' . json_encode($res));
  601. return $res;
  602. }
  603. $is_h5 = false;
  604. if (is_h5()) {
  605. $is_h5 = true;
  606. }
  607. if (\Yii::$app->prod_is_dandianpu() && !Store::hasIncoming(get_store_id()) && self_mini() === false) {
  608. $res = WechatPay::orderUnify($this->order,OrderNo::ORDER_SCAN_CODE_PAY, $config['body'], '0', false, '0', false, $is_h5, $openid ?? '');
  609. if ($res['res']['return_code'] === 'SUCCESS' && $res['res']['result_code'] === 'SUCCESS' && isset($res['data'])) {
  610. $res['data'] = array_merge($res['data'], [
  611. 'order_no'=>$data['order_no'],
  612. 'is_pay' => 0,
  613. 'is_finish' => 1
  614. ]);
  615. }
  616. debug_log('支付数据' . json_encode($res));
  617. return $res;
  618. } else {
  619. // 判断是否走服务商支付
  620. if (is_profit_pay()) {
  621. $result = WechatNewPay::orderUnify($this->order,OrderNo::ORDER_SCAN_CODE_PAY, $config['body'], 0, false, 0, false, $is_h5, $open_id);
  622. } else {
  623. $result = WechatPay::orderUnify($this->order,OrderNo::ORDER_SCAN_CODE_PAY, $config['body'], 0, false, 0, false, false, $open_id);
  624. }
  625. if ($result['code']) {
  626. return $result;
  627. }
  628. $data = [
  629. 'order_no'=>$data['order_no'],
  630. 'is_pay' => 0,
  631. 'is_finish' => 1
  632. ];
  633. $result['data'] = array_merge($result['data'], $data);
  634. return $result;
  635. }
  636. } elseif ($this->type == "yunst") {
  637. $res = $this->submitOrder(\app\models\Order::PAY_TYPE_YUNST_WECHAT_PAY);
  638. if($res['code'] === 0){
  639. $data = $res['data'];
  640. $data['pay_fee'] = round($data['pay_fee'],2);
  641. if ($data['pay_fee'] == 0) {
  642. if (get_user_id() > 0) {
  643. $form = new \app\modules\alliance\models\NewMerchantForm();
  644. $form->store_id = get_store_id();
  645. $form->saasGiveIntegral($this->pay_fee, get_user_id(), $data['order_no']);
  646. if ($this->is_use_coupon) {
  647. UserCoupon::updateAll(['is_use' => 1], ['id' => $this->coupon_id]);
  648. }
  649. }
  650. $this->order_no = $data['order_no'];
  651. $this->payResult();
  652. return [
  653. 'code' => 0,
  654. 'data' => [
  655. 'is_pay' => 1,
  656. 'order_no'=>$data['order_no'],
  657. ]
  658. ];
  659. }
  660. }else{
  661. return $res;
  662. }
  663. $order_no = $data['order_no'];
  664. $store = Store::findOne(['id' => get_store_id()]);
  665. // print_r($store);die;
  666. if ($store->cusid) {
  667. // print_r($store->cusid);die;
  668. $OrderYunst = new OrderYunst();
  669. $result2 = $OrderYunst->payYunst(get_store_id(), $order_no, $store->cusid, $data['pay_fee'] * 100);
  670. if ($result2['subCode']== 'SUCCESS'){
  671. if ($result2['data']['trxstatus'] == 3045){
  672. return [
  673. 'code' => 1,
  674. 'msg' => $result2['data']['errmsg']
  675. ];
  676. }
  677. $result2 = json_decode($result2['data']['payinfo'],true);
  678. $result2['order_no'] = $order_no;
  679. $result2['is_pay'] = 0;
  680. $result2['is_finish'] = 1;
  681. $res_data = [
  682. 'code'=>0,
  683. 'data'=>$result2,
  684. 'msg'=>'success',
  685. 'res'=>$result2
  686. ];
  687. return $res_data;
  688. }else{
  689. return [
  690. 'code' => 1,
  691. 'msg' => '支付异常'
  692. ];
  693. }
  694. }
  695. } elseif ($this->type == "alipay") {
  696. $id = $this->id ?: 0;
  697. if($id != 0 && is_isv()){
  698. $query = StoreAliMini::find()->where(['id' => $this->id])->orderBy("id desc");
  699. $mini_info = $query->select("app_name,app_logo,id")->asArray()->one();
  700. if(empty($mini_info['id'])){
  701. return [
  702. 'code'=>1,
  703. 'msg'=>"获取数据失败",
  704. ];
  705. }
  706. $id = $mini_info['id'];
  707. }
  708. $form = new AlipayThirdForm();
  709. $form->method = "alipay.open.auth.token.app";
  710. $form->bind_store_id = get_store_id();
  711. if (is_isv()) {
  712. $request = new AlipaySystemOauthTokenRequest();
  713. $request->setGrantType("authorization_code");
  714. $request->setCode($this->code);
  715. $result = $form->miniCommon($request, 1, $id, 0, 1);
  716. $open_user_id = $result->user_id;
  717. } else {
  718. if (\Yii::$app->prod_is_dandianpu() && self_mini() === false) {
  719. $alipay_config = Json::decode(Option::get('one_store_alipay_config', 0, 'saas', '')['value']);
  720. } else {
  721. $config_cache = \Yii::$app->cache->get('alipay_config_cache_' . get_store_id());
  722. if ($config_cache) {
  723. $alipay_config = Json::decode($config_cache);
  724. } else {
  725. $alipay_config = Json::decode(Option::get(Option::OPTOPN_KEY, get_store_id(), 'alipay')['value']);
  726. }
  727. }
  728. $config = [
  729. 'alipay' => [
  730. 'client_id' => $alipay_config['app_id'],
  731. 'rsa_private_key' => $alipay_config['app_private_key'],
  732. ]
  733. ];
  734. $socialite = new SocialiteManager($config);
  735. $res_code = $socialite->create('alipay')->tokenFromCode($this->code);
  736. $open_user_id = $res_code['user_id'];
  737. }
  738. if (!$open_user_id) {
  739. return [
  740. 'code' => 0,
  741. 'msg' => '参数获取错误'
  742. ];
  743. }
  744. $user = User::findOne(['alipay_open_id' => $open_user_id, 'store_id' => get_store_id()]);
  745. if ($user) {
  746. $this->user_id = $user->id;
  747. }
  748. $OrderRes = $this->submitOrder(4);
  749. if($OrderRes['code'] == 1){
  750. return $OrderRes;
  751. }
  752. if ($OrderRes['data']['pay_fee'] == 0) {
  753. if (get_user_id() > 0) {
  754. $form = new \app\modules\alliance\models\NewMerchantForm();
  755. $form->store_id = get_store_id();
  756. $form->saasGiveIntegral($this->pay_fee, get_user_id(), $OrderRes['data']['order_no']);
  757. if ($this->is_use_coupon) {
  758. UserCoupon::updateAll(['is_use' => 1], ['id' => $this->coupon_id]);
  759. }
  760. }
  761. $this->order_no = $OrderRes['data']['order_no'];
  762. debug_log($this->payResult(), 'scanCodePay.log');
  763. return [
  764. 'code' => 0,
  765. 'data' => [
  766. 'is_pay' => 1,
  767. 'order_no'=>$OrderRes['data']['order_no'],
  768. ]
  769. ];
  770. }
  771. if (is_profit_pay('ali')) {
  772. if(!empty($user)){
  773. if (\Yii::$app->prod_is_dandianpu() && !Store::hasIncoming(get_store_id()) && self_mini() === false) {
  774. $res = Alipay::mini($this->order, '当面付', $user, '', '', 0, 0);
  775. } else {
  776. if (is_profit_pay('ali')) {
  777. $res = AlipayProfit::mini($this->order, '当面付', $user, '', '', false, 0, 0);
  778. } else {
  779. $res = Alipay::mini($this->order, '当面付', $user, '', '', 0, 0);
  780. }
  781. }
  782. if (isset($res['code']) && $res['code'] == 1) {
  783. return $res;
  784. }
  785. if (isset($res['data'])) {
  786. $res['data'] = array_merge($res['data'], [
  787. 'is_finish' => 1,
  788. 'order_no' => $res['data']['out_trade_no']
  789. ]);
  790. }
  791. return $res;
  792. }
  793. return $result;
  794. } else {
  795. if ($OrderRes['data']['is_recharge'] === 1) {
  796. $order = ReOrder::findOne($OrderRes['data']['order_id']);
  797. $subject = '充值';
  798. } else {
  799. $order = Order::findOne($OrderRes['data']['order_id']);
  800. $order->pay_price = $OrderRes['data']['pay_fee'];
  801. $subject = '当面付';
  802. }
  803. $result = Alipay::scan($order, $subject, '', $open_user_id);
  804. $data = [
  805. 'trade_no' => $result['data']['trade_no'],
  806. 'order_no' => $order->order_no,
  807. 'is_pay' => 0,
  808. 'is_finish' => 1
  809. ];
  810. return [
  811. 'code' => 0,
  812. 'msg' => "成功",
  813. 'data' => $data
  814. ];
  815. }
  816. // if (is_profit_pay('ali')) {
  817. // if(!empty($result->user_id)){
  818. // $user_id = $result->user_id;
  819. // $res = $form->payconfig($id,$OrderRes['data']['order_no'],$user_id,$this->pay_fee);
  820. // \Yii::error($res);
  821. // return $res;
  822. // }
  823. // return $result;
  824. // } else {
  825. // $order = Order::findOne($res['data']['order_id']);
  826. // $result = Alipay::scan($order, '当面付');
  827. // $data = [
  828. // 'trade_no' => $result['data']['out_trade_no'],
  829. // 'order_no' => $order->order_no
  830. // ];
  831. // return [
  832. // 'code' => 0,
  833. // 'msg' => "成功",
  834. // 'data' => $data
  835. // ];
  836. // // return $result;
  837. // }
  838. }
  839. }
  840. //返回前端展示支付结果
  841. public function payResult(){
  842. try {
  843. $reorder = ReOrder::findOne(['order_no' => $this->order_no]);
  844. if ($reorder) {
  845. $order_no = Order::findOne($reorder->order_id)->order_no;
  846. } else {
  847. $order_no = $this->order_no;
  848. }
  849. $order = Order::find()->alias('o')->where(['o.order_no'=>$order_no])
  850. ->leftJoin(['s'=>Store::tableName()],'o.store_id = s.id')
  851. ->select("o.id,o.is_pay,o.pay_type,o.pay_time,o.order_no,o.store_id,s.name,s.logo,o.pay_price,
  852. o.is_combine_pay, o.combine_money, o.send_price, o.take_price")->asArray()->one();
  853. if(empty($order)){
  854. throw new \Exception("未查找到数据");
  855. }
  856. $goods_list = Goods::find()->where(['store_id' => $order['store_id'], 'status' => Goods::STATUS_NORMAL, 'is_delete' => 0, 'md_food_id' => 0, 'is_recommend' => 1])
  857. ->andWhere(['!=', 'product_type',Goods::GOODS_TYPE_INTEGRAL])
  858. ->orderBy('sort desc')->asArray()->all();
  859. foreach ($goods_list as &$item) {
  860. $item['virtual_sales'] += OrderDetail::find()->where(['goods_id' => $item['id']])->select('id')->count() ?? 0;
  861. }
  862. $data['list'] = $goods_list;
  863. $data = array_merge($order,$data);
  864. if(!empty($order['is_pay']) && $order['is_pay'] == 1){
  865. $this->order_event();
  866. $id = \queue_push(new NoAfterSalesOrderJob(['order_id' => $order['id'], 'store_id' => $order['store_id'], 'is_scan' => 1]), 30);
  867. debug_log($id, '20250519.log');
  868. return [
  869. 'code'=>0,
  870. 'msg'=>"支付成功",
  871. 'data'=>$data
  872. ];
  873. }else{
  874. return [
  875. 'code'=>0,
  876. 'msg'=>"订单尚未支付",
  877. 'data'=>$data
  878. ];
  879. }
  880. }catch (\Exception $e){
  881. return [
  882. 'code'=>1,
  883. 'msg'=>$e->getMessage()
  884. ];
  885. }
  886. }
  887. //TODO id 790
  888. public function order_event()
  889. {
  890. $order = Order::findOne(['order_no' => $this->order_no]);
  891. $face_first_profit = Option::findOne(['name' => 'face_first_profit','store_id' => $order['store_id']]);
  892. $face_second_profit = Option::findOne(['name' => 'face_second_profit','store_id' =>$order['store_id']]);
  893. $face_third_profit = Option::findOne(['name' => 'face_third_profit','store_id' => $order['store_id']]);
  894. $order_all_price = $order->total_price + $order->take_price;
  895. $order_first_price = $face_first_profit->value * $order_all_price / 100;
  896. $order_second_price = $face_second_profit->value * $order_all_price / 100;
  897. $order_third_price = $face_third_profit->value * $order_all_price ;
  898. //奖金池补充奖金
  899. \app\utils\Share\BonusPool::poolPush($order, 6);
  900. //处理联盟券
  901. $order = Order::findOne($order->id);
  902. $store = Store::findOne($order->store_id);
  903. $user = User::findOne($order->user_id);
  904. //处理佣金
  905. $user = User::findOne($order->user_id);
  906. $first_user = User::findOne($user->old_parent_id);
  907. //判断已经处理过就不再处理佣金
  908. if ($order->is_share) {
  909. return;
  910. }
  911. if ($first_user && $order_first_price > 0) {
  912. if($order_first_price > 0){
  913. $order->share_user_first_id = $first_user->id;
  914. $order->is_share = 1;
  915. $order->first_price = $order_first_price;
  916. $order->save();
  917. $first_user->total_price += $order->first_price;
  918. $first_user->price += $order->first_price;
  919. $first_user->save();
  920. UserShareMoney::set($order->first_price, $first_user->id, $order->id, 0, 3, $order->store_id, 0);
  921. }
  922. $second_user = User::findOne($first_user->old_parent_id);
  923. if ($second_user && $order_second_price > 0) {
  924. if($order_second_price > 0){
  925. $order->share_user_second_id = $second_user->id;
  926. $order->is_share = 1;
  927. $order->second_price = $order_second_price;
  928. $order->save();
  929. $second_user->total_price += $order->second_price;
  930. $second_user->price += $order->second_price;
  931. $second_user->save();
  932. UserShareMoney::set($order->second_price, $second_user->id, $order->id, 0, 3, $order->store_id, 0);
  933. }
  934. $third_user = User::findOne($second_user->old_parent_id);
  935. if ($third_user && $order_third_price > 0) {
  936. if($order_third_price > 0){
  937. $order->share_user_third_id = $third_user->id;
  938. $order->is_share = 1;
  939. $order->third_price = $order_third_price;
  940. $order->save();
  941. $third_user->total_price += $order->third_price;
  942. $third_user->price += $order->third_price;
  943. $third_user->save();
  944. UserShareMoney::set($order->third_price, $third_user->id, $order->id, 0, 3, $order->store_id, 0);
  945. }
  946. }
  947. }
  948. }
  949. // if ($order->send_price > 0 && $store->league_price > 0) {
  950. //给用户发放联盟券
  951. if ($user->binding) {
  952. $saas_user = SaasUser::findOne(['mobile' => $user->binding]);
  953. } elseif ($user->alipay_open_id) {
  954. $saas_user = SaasUser::findOne(['ali_user_id' => $user->alipay_open_id]);
  955. } else {
  956. $saas_user = SaasUser::findOne(get_saas_user_id());
  957. }
  958. if ($order->send_price > $store->league_price) {
  959. $send_price = 0;
  960. } else {
  961. $send_price = $order->send_price;
  962. }
  963. $saaSLeaguePriceLog = SaaSLeaguePriceLog::findOne(['order_id' => $order->id]);
  964. if ($saaSLeaguePriceLog) {
  965. return;
  966. }
  967. //赠送的联盟券
  968. if ($send_price) {
  969. if ($saas_user) {
  970. $before = $saas_user->league_price;
  971. $saas_user->updateCounters(['league_price' => floatval($send_price)]);
  972. \app\models\SaaSLeaguePriceLog::setLeaguePriceLog(
  973. $order->store_id,
  974. $saas_user->id,
  975. $send_price,
  976. $before,
  977. \app\models\SaaSLeaguePriceLog::TYPE_FACE_PAY_ORDER,
  978. \app\models\SaaSLeaguePriceLog::SEND_TYPE,
  979. \app\models\SaaSLeaguePriceLog::ROLE_USER,
  980. $order->id
  981. );
  982. }
  983. //给商家扣减 (用户赠送的联盟券钱从商家从扣减)
  984. $before = $store->league_price;
  985. $store->updateCounters(['league_price' => -floatval($send_price)]);
  986. \app\models\SaaSLeaguePriceLog::setLeaguePriceLog(
  987. $order->store_id,
  988. $saas_user->id,
  989. $send_price,
  990. $before,
  991. \app\models\SaaSLeaguePriceLog::TYPE_FACE_PAY_ORDER,
  992. \app\models\SaaSLeaguePriceLog::TAKE_TYPE,
  993. \app\models\SaaSLeaguePriceLog::ROLE_STORE,
  994. $order->id
  995. );
  996. }
  997. // }
  998. //计算抵扣的联盟券
  999. if ($order->take_price > 0){
  1000. if ($saas_user) {
  1001. $before = $saas_user->league_price;
  1002. $saas_user->updateCounters(['league_price' => -floatval($order->take_price)]);
  1003. \app\models\SaaSLeaguePriceLog::setLeaguePriceLog(
  1004. $order->store_id,
  1005. $saas_user->id,
  1006. $order->take_price,
  1007. $before,
  1008. \app\models\SaaSLeaguePriceLog::TYPE_FACE_PAY_ORDER,
  1009. \app\models\SaaSLeaguePriceLog::TAKE_TYPE,
  1010. \app\models\SaaSLeaguePriceLog::ROLE_USER,
  1011. $order->id
  1012. );
  1013. }
  1014. //给商家增加 (用户抵扣钱从赠送给商家)
  1015. $before = $store->league_price;
  1016. $store->updateCounters(['league_price' => floatval($order->take_price)]);
  1017. \app\models\SaaSLeaguePriceLog::setLeaguePriceLog(
  1018. $order->store_id,
  1019. $saas_user->id,
  1020. $send_price,
  1021. $order->take_price,
  1022. \app\models\SaaSLeaguePriceLog::TYPE_FACE_PAY_ORDER,
  1023. \app\models\SaaSLeaguePriceLog::SEND_TYPE,
  1024. \app\models\SaaSLeaguePriceLog::ROLE_STORE,
  1025. $order->id
  1026. );
  1027. }
  1028. }
  1029. //
  1030. // }
  1031. }