SettleService.php 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
  4. // +----------------------------------------------------------------------
  5. // | 版权所有 2017~2021 LARAVEL研发中心
  6. // +----------------------------------------------------------------------
  7. // | 官方网站: http://www.laravel.cn
  8. // +----------------------------------------------------------------------
  9. // | Author: laravel开发员 <laravel.qq.com>
  10. // +----------------------------------------------------------------------
  11. namespace App\Services\Api;
  12. use App\Models\AccountLogModel;
  13. use App\Models\CouponModel;
  14. use App\Models\MemberCouponModel;
  15. use App\Models\MemberModel;
  16. use App\Models\OrderCommissionModel;
  17. use App\Models\OrderModel;
  18. use App\Models\PtAccountModel;
  19. use App\Models\StoreModel;
  20. use App\Services\BaseService;
  21. use App\Services\Common\MemberLevelService;
  22. use App\Services\ConfigService;
  23. use App\Services\RedisService;
  24. use Illuminate\Support\Facades\DB;
  25. /**
  26. * 结算管理-服务类
  27. * @author laravel开发员
  28. * @since 2020/11/11
  29. * @package App\Services\Api
  30. */
  31. class SettleService extends BaseService
  32. {
  33. /**
  34. * 构造函数
  35. * @author laravel开发员
  36. * @since 2020/11/11
  37. */
  38. public function __construct()
  39. {
  40. $this->model = new AccountLogModel();
  41. }
  42. /**
  43. * 静态入口
  44. * @return static|null
  45. */
  46. public static function make()
  47. {
  48. if (!self::$instance) {
  49. self::$instance = (new static());
  50. }
  51. return self::$instance;
  52. }
  53. /**
  54. * 商家收益结算
  55. * @param $storeId
  56. * @param $money 收益
  57. * @param $order 订单数据
  58. * @return array|false|int
  59. */
  60. public function storeBonus($storeId, $money, $order)
  61. {
  62. $orderNo = isset($order['order_no'])? $order['order_no'] : '';
  63. if($money<=0 && $storeId<=0){
  64. $this->error = '无企业佣金可结算';
  65. return false;
  66. }
  67. $storeInfo = StoreModel::where(['id'=> $storeId,'mark'=>1])->first();
  68. $balance = isset($storeInfo['bonus_total'])? $storeInfo['bonus_total'] : 0;
  69. $storeUserId = isset($storeInfo['user_id'])? $storeInfo['user_id'] : 0;
  70. if($storeUserId<=0){
  71. $this->error = '企业账号错误';
  72. return false;
  73. }
  74. if(!StoreModel::where(['id'=> $storeId])->update(['bonus_total'=>DB::raw("bonus_total + {$money}"),'update_time'=>time()])){
  75. $this->error = '收货错误,企业结算错误,请联系客服处理';
  76. return -1;
  77. }
  78. $log = [
  79. 'user_id'=> $storeUserId,
  80. 'store_id'=> $storeId,
  81. 'source_order_no'=> isset($order['order_no'])? $order['order_no'] : '',
  82. 'type'=> 7,
  83. 'money'=> $money,
  84. 'after_money'=> moneyFormat($balance+$money,2),
  85. 'date'=>date('Y-m-d'),
  86. 'create_time'=>time(),
  87. 'remark'=> '收益',
  88. 'status'=>1
  89. ];
  90. if(!$id = $this->model->insertGetId($log)){
  91. $this->error = '企业收益结算失败,请联系客服处理';
  92. return -1;
  93. }
  94. $result = ['id'=>$id,'store_id'=>$storeId,'bonus'=>$money];
  95. if(env('APP_DEBUG')){
  96. RedisService::set("caches:settle:{$orderNo}:store_{$storeId}", $result, 7200);
  97. }
  98. return $result;
  99. }
  100. /**
  101. * @param $order
  102. * @param int $orderType
  103. */
  104. public function commissionCount($order, $orderGoods, $userInfo, $orderType=1)
  105. {
  106. $userId = isset($order['user_id'])?$order['user_id']:0;
  107. $storeId = isset($order['store_id'])?$order['store_id']:0;
  108. $mealId = isset($order['meal_id'])?$order['meal_id']:0;
  109. $orderNo = isset($order['order_no'])?$order['order_no']:'';
  110. $orderTotal = isset($order['pay_total'])?$order['pay_total']:0;
  111. $profitTotal = isset($order['profit_total'])?$order['profit_total']:0;
  112. $data = [
  113. 'user_id'=> $userId,
  114. 'order_no'=> $orderNo,
  115. 'store_id'=> $storeId,
  116. 'total'=> $orderTotal,
  117. 'create_time'=>time(),
  118. 'status'=>2,
  119. 'mark'=>1,
  120. ];
  121. $errors = [];
  122. if($orderType==2){
  123. /* TODO 计算直推奖 */
  124. $pointId = isset($userInfo['point_id'])? $userInfo['point_id']:0;
  125. $directBonus = ConfigService::make()->getConfigByCode('business_direct_bonus', 0);
  126. $directBonus = $directBonus>0 && $directBonus<$orderTotal?$directBonus:0;
  127. $pointInfo = MemberModel::where(['id' => $pointId,'mark'=>1])
  128. ->select(['id','nickname','buy_type','bonus_status','status','mark'])
  129. ->first();
  130. $bonusStatus = isset($pointInfo['bonus_status'])?$pointInfo['bonus_status']:0;
  131. $data['direct_uid'] = $pointId;
  132. if($pointInfo && $bonusStatus==1){
  133. $data['direct_bonus'] = json_encode(['uid'=>$pointId,'bonus'=>$directBonus],256);
  134. }else{
  135. $data['direct_bonus']= json_encode(['uid'=>$pointId,'direct_bonus'=>$directBonus,'meal_id'=>$mealId,'error'=>'节点推荐人不存在或收益已领完','point'=>$pointInfo],256);
  136. }
  137. /* TODO 计算见单奖和分红奖励 */
  138. $points = isset($userInfo['points'])?$userInfo['points']:'';
  139. $points = $points? explode(',',$points) : [];
  140. $points = array_filter($points);
  141. $points = array_reverse($points); // 由下到上1-6层
  142. $rewardLayer = ConfigService::make()->getConfigByCode('business_reward_layer', 6);
  143. $points = array_splice($points,0, $rewardLayer);
  144. $jdBonus = ConfigService::make()->getConfigByCode("business_jd_bonus_{$mealId}", 0);
  145. $jdBonus = $jdBonus>0 && $jdBonus< $orderTotal? $jdBonus : 0;
  146. // 计算当前平台下各个等级的会员数量
  147. $levelCounts = MemberService::make()->getCountsByLevel();
  148. $levelList = MemberLevelService::make()->getListByLevel();
  149. if($points){
  150. $pointList = MemberModel::with(['levelData'])->whereIn('id', $points)
  151. ->select(['id','nickname','mobile','buy_type','member_level','bonus_status','status','mark'])
  152. ->orderBy(DB::raw("FIELD(id, ".implode(',',$points).")"))
  153. ->get();
  154. foreach ($pointList as $k => $point){
  155. // 默认只分6层
  156. $layer = $k+1;
  157. if($layer>$rewardLayer){
  158. continue;
  159. }
  160. // 处理见单奖
  161. $pid = isset($point['id'])?$point['id']:0;
  162. $pMark = isset($point['mark'])?$point['mark']:0;
  163. $buyType = isset($point['buy_type'])?$point['buy_type']:0;
  164. $bonusStatus = isset($point['bonus_status'])?$point['bonus_status']:0;
  165. $pLevel = isset($point['member_level'])?$point['member_level']:0;
  166. $levelWeightCountData = isset($levelCounts[$pLevel])? $levelCounts[$pLevel] : 0;
  167. $levelData = isset($levelList[$pLevel])? $levelList[$pLevel] : 0;
  168. $levelWeightCount = isset($levelWeightCountData['count'])? $levelWeightCountData['count']:0;
  169. $levelBonus = isset($levelData['bonus'])? $levelData['bonus']:0;
  170. $data["bonus_{$layer}_uid"] = $pid;
  171. $bonusData = [
  172. 'id'=> $pid,
  173. 'nickname'=> isset($point['nickname'])?$point['nickname']:'',
  174. 'mobile'=> isset($point['mobile'])?$point['mobile']:'',
  175. 'jd_bonus'=> 0,
  176. 'level'=> $pLevel,
  177. 'weight'=> $levelWeightCount,
  178. 'weight_bonus'=> $levelBonus,
  179. 'level_bonus'=> 0,
  180. ];
  181. if($pMark==1 && $bonusStatus==1){
  182. $bonusData['jd_bonus'] = $jdBonus;
  183. }else{
  184. $bonusData["error"]= "上{$layer}级节点推荐人不存在或收益已领完";
  185. }
  186. // 处理加权分红
  187. if($pLevel>0 && $levelWeightCount>0 && $levelBonus>0 && $bonusStatus==1){
  188. $bonusData['level_bonus'] = moneyFormat($levelBonus * 6/$levelWeightCount,2);
  189. }
  190. // 数据
  191. $data["bonus_{$layer}_data"] = json_encode($bonusData,256);
  192. }
  193. }
  194. }else{
  195. /* TODO 计算商家佣金 */
  196. $storeInfo = StoreModel::where(['id' => $storeId])->first();
  197. $bonusRate = isset($storeInfo['bonus_rate']) ? floatval($storeInfo['bonus_rate']) : 0;
  198. $storeBonusRate = ConfigService::make()->getConfigByCode('store_bonus_rate', 0);
  199. $storeBonusRate = $storeBonusRate > 0 && $storeBonusRate <= 100 ? $storeBonusRate : 0;
  200. $bonusRate = $bonusRate > 0 && $bonusRate <= 100 ? $bonusRate : $storeBonusRate;
  201. $bonus = moneyFormat($orderTotal * $bonusRate / 100, 2);
  202. $data['bonus'] = $bonus;
  203. $data['bonus_rate'] = $bonusRate;
  204. /* TODO 计算绿色积分奖励 */
  205. $lsScoreTotal = 0;
  206. $data['ls_score_rates'] = [];
  207. $ptLsScoreRate = ConfigService::make()->getConfigByCode('ls_score_rate',0);
  208. $ptLsScoreRate = $ptLsScoreRate>0&&$ptLsScoreRate<=50?$ptLsScoreRate:0;
  209. if($orderGoods){
  210. foreach ($orderGoods as $goods){
  211. $lsScoreRate = isset($goods['ls_score_rate'])?$goods['ls_score_rate']:0;
  212. $lsScoreRate = $lsScoreRate>0 && $lsScoreRate<=50?$lsScoreRate : $ptLsScoreRate;
  213. $profitTotal = isset($goods['profit_total'])?$goods['profit_total'] : 0;
  214. if($profitTotal>0 && $lsScoreRate>0){
  215. $lsScoreTotal += moneyFormat($profitTotal * $lsScoreRate/100,2);
  216. }
  217. $data['ls_score_rates'][$goods['goods_id']] = [
  218. 'goods_id'=> $goods['goods_id'],
  219. 'score'=>$lsScoreRate
  220. ];
  221. }
  222. }
  223. $data['ls_score'] = $lsScoreTotal;
  224. $data['ls_score_rates'] = json_encode($data['ls_score_rates'], 256);
  225. /* TODO 计算数字资产+底池金额 */
  226. $ptPoolRate = ConfigService::make()->getConfigByCode('pt_pool_rate', 0);
  227. $ptPoolRate = $ptPoolRate>0 && $ptPoolRate<50?$ptPoolRate:0;
  228. $rewardPropertyRate = ConfigService::make()->getConfigByCode('reward_property_rate', 0);
  229. $rewardPropertyRate = $rewardPropertyRate > 0 && $rewardPropertyRate <= 50 ? $rewardPropertyRate : 0;
  230. $propertyTotal = moneyFormat($rewardPropertyRate * $profitTotal/100,2);
  231. $poolTotal = moneyFormat($ptPoolRate * $profitTotal/100,2);
  232. $data['pt_pool_rate'] = $ptPoolRate;
  233. $data['pt_pool'] = $poolTotal;
  234. $data['property'] = $propertyTotal;
  235. $data['property_rate'] = $rewardPropertyRate;
  236. }
  237. // 佣金数据入库
  238. if(!$cid = OrderCommissionModel::where(['order_no'=>$orderNo])->value('id')){
  239. $cid = OrderCommissionModel::insertGetId($data);
  240. }else{
  241. OrderCommissionModel::where(['id'=>$cid])->update($data);
  242. }
  243. $this->error = '佣金计算成功';
  244. $data['id'] = $cid;
  245. return $data;
  246. }
  247. public function commissionSettle($orderId)
  248. {
  249. $info = OrderModel::with(['commission'])
  250. ->where(['id'=>$orderId,'mark'=>1])
  251. ->select(['id','order_no','type','user_id','total','pay_total','bd_score','pay_status','status','refund_status'])
  252. ->first();
  253. if(empty($info)){
  254. $this->error = '结算订单不存在';
  255. return false;
  256. }
  257. if($info['status']<=1 || $info['pay_status'] == 10){
  258. $this->error = '订单未支付';
  259. return false;
  260. }
  261. if(in_array($info['refund_status'],[1,2,3])){
  262. $this->error = '订单已退款';
  263. return false;
  264. }
  265. $orderType = isset($info['type'])?$info['type'] : 1;
  266. $orderNo = isset($info['order_no'])?$info['order_no'] : '';
  267. $orderUserId = isset($info['user_id'])?$info['user_id'] : 0;
  268. $commission = isset($info['commission'])?$info['commission'] : [];
  269. $commissionId = isset($commission['id'])?$commission['id'] : 0;
  270. if(empty($commission) || $commissionId<=0){
  271. $this->error = '结算订单收益参数错误';
  272. return false;
  273. }
  274. if($commission['status'] == 1){
  275. $this->error = '订单收益已结算';
  276. return false;
  277. }
  278. $cacheKey = "caches:ordersCommission:{$orderNo}_{$orderUserId}:";
  279. if(RedisService::get("{$cacheKey}lock")){
  280. $this->error = '订单结算中';
  281. return false;
  282. }
  283. // 创业订单
  284. $logs = [];
  285. RedisService::set("{$cacheKey}lock", $info, 300);
  286. DB::beginTransaction();
  287. if($orderType == 2){
  288. // TODO 结算直推奖
  289. $directData = isset($commission['direct_bonus'])? $commission['direct_bonus'] : [];
  290. $directUserId = isset($commission['direct_uid'])? $commission['direct_uid'] : 0;
  291. $directBonus = isset($directData['bonus'])? $directData['bonus'] : 0;
  292. if($directUserId>0 && $directBonus>0){
  293. $directUser = isset($commission['direct_user'])? $commission['direct_user'] : [];
  294. $directUserBalance = isset($directUser['balance'])?$directUser['balance'] : 0;
  295. if($directUser){
  296. $updateData = [
  297. 'balance'=>DB::raw("balance + {$directBonus}"),
  298. 'bonus_total'=>DB::raw("bonus_total + {$directBonus}"),
  299. 'update_time'=>time()
  300. ];
  301. if(!MemberModel::where(['id'=>$directUserId])->update($updateData)){
  302. DB::rollBack();
  303. $this->error = '直推奖励结算错误';
  304. return false;
  305. }
  306. $data = [
  307. 'user_id'=> $directUserId,
  308. 'source_order_no'=> $orderNo,
  309. 'user_type'=> 1,
  310. 'account_type'=> 1, // 余额
  311. 'type'=> 8,
  312. 'bonus_type'=> 1,
  313. 'money'=> $directBonus,
  314. 'after_money'=>moneyFormat($directUserBalance + $directBonus,2),
  315. 'date'=>date('Y-m-d'),
  316. 'create_time'=>time(),
  317. 'remark'=> '直推奖',
  318. 'remark1'=> "用户ID:{$orderUserId}购买礼包直推奖励",
  319. 'status'=>1,
  320. 'mark'=>1
  321. ];
  322. $logs[] = $data;
  323. }
  324. }
  325. // TODO 结算见单奖+分红
  326. $bonusUids = [];
  327. for($i=1; $i<=6; $i++){
  328. $uid = isset($commission["bonus_{$i}_uid"])? $commission["bonus_{$i}_uid"]:0;
  329. if($uid){
  330. $bonusUids[] = $uid;
  331. }
  332. }
  333. $bonusUsers = MemberModel::whereIn('id', $bonusUids)
  334. ->select(['id','openid','balance','mobile','nickname','property','ls_score','status'])
  335. ->get()
  336. ->keyBy('id');
  337. $bonusUsers = $bonusUsers? $bonusUsers->toArray() : [];
  338. for($i=1; $i<=6; $i++){
  339. $uid = isset($commission["bonus_{$i}_uid"])? $commission["bonus_{$i}_uid"]:0;
  340. $bonusData = isset($commission["bonus_{$i}_data"])? $commission["bonus_{$i}_data"]:0;
  341. $jdBonus = isset($bonusData['jd_bonus'])?$bonusData['jd_bonus']:0;
  342. $levelBonus = isset($bonusData['level_bonus'])?$bonusData['level_bonus']:0;
  343. $bonusUser = isset($bonusUsers[$uid])?$bonusUsers[$uid] : [];
  344. $bonusUserBalance = isset($bonusUser['balance'])?$bonusUser['balance'] : 0;
  345. $bonusTotal = moneyFormat($jdBonus + $levelBonus,2);
  346. if($uid && $bonusUser && $bonusTotal>0){
  347. $updateData = [
  348. 'balance'=>DB::raw("balance + {$bonusTotal}"),
  349. 'bonus_total'=>DB::raw("bonus_total + {$bonusTotal}"),
  350. 'update_time'=>time()
  351. ];
  352. if(!MemberModel::where(['id'=> $uid])->update($updateData)){
  353. DB::rollBack();
  354. $this->error = '见单和分红奖励结算错误';
  355. return false;
  356. }
  357. if($jdBonus>0){
  358. $bonusUserBalance = moneyFormat($bonusUserBalance + $jdBonus,2);
  359. $data = [
  360. 'user_id'=> $uid,
  361. 'source_order_no'=> $orderNo,
  362. 'user_type'=> 1,
  363. 'account_type'=> 1, // 余额
  364. 'type'=> 8,
  365. 'bonus_type'=> 2,
  366. 'money'=> $jdBonus,
  367. 'after_money'=> $bonusUserBalance,
  368. 'date'=>date('Y-m-d'),
  369. 'create_time'=>time()+$i,
  370. 'remark'=> '见单奖',
  371. 'remark1'=> "下{$i}级用户ID:{$orderUserId}购买礼包见单奖",
  372. 'status'=>1,
  373. 'mark'=>1
  374. ];
  375. $logs[] = $data;
  376. }
  377. if($levelBonus>0){
  378. $bonusUserBalance = moneyFormat($bonusUserBalance + $levelBonus,2);
  379. $data = [
  380. 'user_id'=> $uid,
  381. 'source_order_no'=> $orderNo,
  382. 'user_type'=> 1,
  383. 'account_type'=> 1, // 余额
  384. 'type'=> 8,
  385. 'bonus_type'=> 3,
  386. 'money'=> $levelBonus,
  387. 'after_money'=> $bonusUserBalance,
  388. 'date'=>date('Y-m-d'),
  389. 'create_time'=>time()+$i,
  390. 'remark'=> '分红收益',
  391. 'remark1'=> "下{$i}级用户ID:{$orderUserId}购买礼包分红收益",
  392. 'status'=>1,
  393. 'mark'=>1
  394. ];
  395. $logs[] = $data;
  396. }
  397. }
  398. }
  399. }
  400. // 商城订单
  401. else {
  402. // TODO 商家结算
  403. $storeInfo = isset($commission['store'])?$commission['store'] : [];
  404. $storeId = isset($commission['store_id'])?$commission['store_id'] : 0;
  405. $storeBonus = isset($commission['bonus'])?$commission['bonus'] : 0;
  406. $storeUserId = isset($storeInfo['user_id'])?$storeInfo['user_id'] : 0;
  407. $storeBalance = isset($storeInfo['balance'])?$storeInfo['balance'] : 0;
  408. if($storeId>0 && $storeInfo && $storeBonus>0){
  409. $updateData = [
  410. 'balance'=>DB::raw("balance + {$storeBonus}"),
  411. 'income'=>DB::raw("income + {$storeBonus}"),
  412. 'update_time'=>time()
  413. ];
  414. if(!StoreModel::where(['id'=> $storeId])->update($updateData)){
  415. DB::rollBack();
  416. $this->error = '商家提成结算失败';
  417. return false;
  418. }
  419. $storeBalance = moneyFormat($storeBalance + $storeBonus,2);
  420. $data = [
  421. 'user_id'=> $storeUserId,
  422. 'store_id'=> $storeId,
  423. 'source_order_no'=> $orderNo,
  424. 'user_type'=> 2,
  425. 'account_type'=> 1, // 余额
  426. 'type'=> 7,
  427. 'bonus_type'=> 0,
  428. 'money'=> $storeBonus,
  429. 'after_money'=> $storeBalance,
  430. 'date'=>date('Y-m-d'),
  431. 'create_time'=>time(),
  432. 'remark'=> '商家提成结算',
  433. 'remark1'=> "用户ID:{$orderUserId}购买商品提成结算",
  434. 'status'=>1,
  435. 'mark'=>1
  436. ];
  437. $logs[] = $data;
  438. }
  439. // TODO 绿色积分结算
  440. $userInfo = isset($commission['user'])?$commission['user']:[];
  441. $userId = isset($commission['user_id'])?$commission['user_id']:0;
  442. $userLsScore = isset($userInfo['ls_score'])?$userInfo['ls_score']:0;
  443. $lsScore = isset($commission['ls_score'])?$commission['ls_score']:0;
  444. if($userId>0 && $userInfo && $lsScore>0){
  445. $updateData = [
  446. 'ls_score'=>DB::raw("ls_score + {$lsScore}"),
  447. 'ls_score_total'=>DB::raw("ls_score_total + {$lsScore}"),
  448. 'update_time'=>time()
  449. ];
  450. if(!MemberModel::where(['id'=>$userId])->update($updateData)){
  451. DB::rollBack();
  452. $this->error = '绿色积分奖励结算错误';
  453. return false;
  454. }
  455. $data = [
  456. 'user_id'=> $userId,
  457. 'source_order_no'=> $orderNo,
  458. 'user_type'=> 1,
  459. 'account_type'=> 4, // 绿色积分
  460. 'type'=> 8,
  461. 'bonus_type'=> 4,
  462. 'money'=> $lsScore,
  463. 'after_money'=>moneyFormat($userLsScore + $lsScore,2),
  464. 'date'=>date('Y-m-d'),
  465. 'create_time'=>time(),
  466. 'remark'=> '绿色积分奖励',
  467. 'remark1'=> "用户ID:{$orderUserId}购买商品绿色积分奖励",
  468. 'status'=>1,
  469. 'mark'=>1
  470. ];
  471. $logs[] = $data;
  472. }
  473. // TODO 数字资产和底池
  474. $property = isset($commission['property'])?$commission['property']:0;
  475. $userProperty = isset($userInfo['property'])?$userInfo['property']:0;
  476. if($userId>0 && $userInfo && $property>0){
  477. $updateData = [
  478. 'property'=>DB::raw("property + {$property}"),
  479. 'property_total'=>DB::raw("property_total + {$property}"),
  480. 'update_time'=>time()
  481. ];
  482. if(!MemberModel::where(['id'=>$userId])->update($updateData)){
  483. DB::rollBack();
  484. $this->error = '数字资产奖励结算错误';
  485. return false;
  486. }
  487. $data = [
  488. 'user_id'=> $userId,
  489. 'source_order_no'=> $orderNo,
  490. 'user_type'=> 1,
  491. 'account_type'=> 2, // 数字资产
  492. 'type'=> 8,
  493. 'bonus_type'=> 5,
  494. 'money'=> $property,
  495. 'after_money'=>moneyFormat($userProperty + $property,2),
  496. 'date'=>date('Y-m-d'),
  497. 'create_time'=>time(),
  498. 'remark'=> '数字资产奖励',
  499. 'remark1'=> "用户ID:{$orderUserId}购买商品数字资产奖励",
  500. 'status'=>1,
  501. 'mark'=>1
  502. ];
  503. $logs[] = $data;
  504. }
  505. // 平台底池结算
  506. $ptAccount = PtAccountModel::where(['mark'=>1])->first();
  507. $accountId = isset($ptAccount['id'])?$ptAccount['id'] : 0;
  508. $poolTotal = isset($ptAccount['pool_total'])?$ptAccount['pool_total'] : 0;
  509. $ptPool = isset($commission['pt_pool'])?$commission['pt_pool'] : 0;
  510. if($ptAccount && ($ptPool>0 || $property>0)){
  511. $updateData = [
  512. 'pool_total'=>DB::raw("pool_total + {$ptPool}"),
  513. 'today_pool'=>DB::raw("today_pool + {$ptPool}"),
  514. 'today_property'=>DB::raw("today_property + {$property}"),
  515. 'update_time'=>time()
  516. ];
  517. if(!PtAccountModel::where(['id'=>$accountId])->update($updateData)){
  518. DB::rollBack();
  519. $this->error = '平台底池和资产结算错误';
  520. return false;
  521. }
  522. // 底池明细
  523. if($ptPool>0){
  524. $data = [
  525. 'user_id'=> 0,
  526. 'source_order_no'=> $orderNo,
  527. 'user_type'=> 0,
  528. 'account_type'=> 5, // 平台账户
  529. 'type'=> 10,
  530. 'bonus_type'=> 6,
  531. 'money'=> $ptPool,
  532. 'after_money'=>moneyFormat($poolTotal + $ptPool,2),
  533. 'date'=>date('Y-m-d'),
  534. 'create_time'=>time(),
  535. 'remark'=> '返回底池',
  536. 'remark1'=> "用户ID:{$orderUserId}购买商品返回底池",
  537. 'status'=>1,
  538. 'mark'=>1
  539. ];
  540. $logs[] = $data;
  541. }
  542. }
  543. }
  544. // TODO 明细入表
  545. RedisService::set("{$cacheKey}logs", $logs, 3600);
  546. if($logs && !AccountLogModel::insert($logs)){
  547. DB::rollBack();
  548. $this->error = '奖励明细结算处理错误';
  549. return false;
  550. }
  551. // 订单结算状态更新
  552. if(!OrderCommissionModel::where(['id'=>$commissionId])->update(['status'=>1,'arrival_at'=>date('Y-m-d H:i:s'),'update_time'=>time()])){
  553. DB::rollBack();
  554. $this->error = '订单结算状态更新失败';
  555. return false;
  556. }
  557. DB::commit();
  558. $this->error = '订单结算完成';
  559. RedisService::set("{$cacheKey}result", $info, 3600);
  560. return ['id'=>$orderId,'user_id'=>$orderUserId,'commission'=>$commission];
  561. }
  562. /**
  563. * 新人注册奖励
  564. * @param $userId
  565. * @return array|bool
  566. */
  567. public function registerReward($userId)
  568. {
  569. $rewardOpen = ConfigService::make()->getConfigByCode('register_award_coupon',0);
  570. $rewardCouponId = ConfigService::make()->getConfigByCode('register_reward_coupon_id',0);
  571. if($rewardCouponId<=0 || $rewardOpen!= 1){
  572. $this->error = '未开启或配置注册优惠券奖励';
  573. return true;
  574. }
  575. $couponInfo = CouponModel::where(['id'=>$rewardCouponId,'mark'=>1])
  576. ->first();
  577. $status = isset($couponInfo['status'])?$couponInfo['status']:0;
  578. if(empty($couponInfo) || $status != 1){
  579. $this->error = '配置的注册奖励优惠券不存在或无效';
  580. return true;
  581. }
  582. $data = [
  583. 'coupon_id'=> $rewardCouponId,
  584. 'user_id'=> $userId,
  585. 'store_id'=> isset($couponInfo['store_id'])?$couponInfo['store_id']:0,
  586. 'name'=> isset($couponInfo['name'])?$couponInfo['name']:'',
  587. 'coupon_type'=> isset($couponInfo['coupon_type'])?$couponInfo['coupon_type']: 20,
  588. 'reduce_price'=> isset($couponInfo['reduce_price'])?$couponInfo['reduce_price']:0,
  589. 'discount'=> isset($couponInfo['discount'])?$couponInfo['discount']:0,
  590. 'min_price'=> isset($couponInfo['min_price'])?$couponInfo['min_price']:0,
  591. 'expire_day'=> isset($couponInfo['expire_day'])?$couponInfo['expire_day']:0,
  592. 'start_time'=> isset($couponInfo['start_time'])?$couponInfo['start_time']:0,
  593. 'end_time'=> isset($couponInfo['end_time'])?$couponInfo['end_time']:0,
  594. 'goods_ids'=> isset($couponInfo['goods_ids'])&&$couponInfo['goods_ids']?$couponInfo['goods_ids']:'',
  595. 'create_time'=> time(),
  596. 'status'=> 1,
  597. ];
  598. if(!$id = MemberCouponModel::insertGetId($data)){
  599. $this->error = '奖励注册优惠券失败';
  600. return true;
  601. }
  602. $data['id'] = $id;
  603. $data['discount'] = floatval($data['discount']);
  604. $data['reduce_price'] = floatval($data['reduce_price']);
  605. unset($data['create_time']);
  606. unset($data['status']);
  607. unset($data['goods_ids']);
  608. $this->error = '奖励注册优惠券成功';
  609. return $data;
  610. }
  611. }