xialei 1 год назад
Родитель
Сommit
7a62f7d29d

+ 2 - 0
app/common/repositories/user/UserThirdRepository.php

@@ -709,6 +709,8 @@ class UserThirdRepository extends BaseRepository
709
                 $make="苏宁";
709
                 $make="苏宁";
710
             }else if($type_shop==2){
710
             }else if($type_shop==2){
711
                 $make="唯品会";
711
                 $make="唯品会";
712
+            }else if($type_shop==9){
713
+                $make="话费";
712
             }
714
             }
713
 
715
 
714
             $user_score = $user['score'];
716
             $user_score = $user['score'];

+ 28 - 1
app/controller/api/store/service/Huafei.php

@@ -5,6 +5,7 @@ namespace app\controller\api\store\service;
5
 use think\App;
5
 use think\App;
6
 use think\facade\Db;
6
 use think\facade\Db;
7
 use crmeb\basic\BaseController;
7
 use crmeb\basic\BaseController;
8
+use app\common\repositories\user\UserThirdRepository;
8
 
9
 
9
 class Huafei extends BaseController
10
 class Huafei extends BaseController
10
 {
11
 {
@@ -27,6 +28,10 @@ class Huafei extends BaseController
27
 
28
 
28
 		$order_no = $param['order_no'];
29
 		$order_no = $param['order_no'];
29
 		$order_number = $param['order_number'];
30
 		$order_number = $param['order_number'];
31
+
32
+		$huafeiInfo = Db::name('order_huafei')->where("order_number", $order_number)->where("order_sn", $order_no)->find();
33
+		if(!$huafeiInfo) echo 'error';exit;
34
+
30
 		$updateData = [
35
 		$updateData = [
31
 			'amount_price' => $param['amount'],
36
 			'amount_price' => $param['amount'],
32
 			'fanli_price' => $param['fanli'],
37
 			'fanli_price' => $param['fanli'],
@@ -37,6 +42,25 @@ class Huafei extends BaseController
37
 		];
42
 		];
38
 		$ret = Db::name("order_huafei")->where("order_number", $order_number)->where("order_sn", $order_no)->update($updateData);
43
 		$ret = Db::name("order_huafei")->where("order_number", $order_number)->where("order_sn", $order_no)->update($updateData);
39
 		if($ret){
44
 		if($ret){
45
+			//判断数据库有无此订单
46
+			$type_shop = 9;
47
+			$orderThird = app()->make(UserThirdRepository::class);
48
+			//预估养老金
49
+			$orderThird->yuguOrder(
50
+				$huafeiInfo['order_pdd_id'],
51
+				$huafeiInfo['commission'],
52
+				$huafeiInfo['uid'],
53
+				$huafeiInfo['order_sn'],
54
+				$type_shop,
55
+				'order_huafei');
56
+			//预估积分
57
+			$orderThird->yuguJifen(
58
+				$huafeiInfo['commission'] ,
59
+				$huafeiInfo['uid'],
60
+				$huafeiInfo['order_sn'],
61
+				$type_shop
62
+			);
63
+
40
 			echo 'success';exit;
64
 			echo 'success';exit;
41
 		}else{
65
 		}else{
42
 			Db::name('log')->insert(['data'=>'话费充值回调数据处理失败']);
66
 			Db::name('log')->insert(['data'=>'话费充值回调数据处理失败']);
@@ -111,11 +135,14 @@ class Huafei extends BaseController
111
 		//推送订单
135
 		//推送订单
112
 		$push = $this->pushOrder($order_sn, $phone, $money);
136
 		$push = $this->pushOrder($order_sn, $phone, $money);
113
 		if($push['code'] == '0000'){
137
 		if($push['code'] == '0000'){
138
+
139
+			$commissionMoney = $money*0.04;
140
+
114
 			//入库记录
141
 			//入库记录
115
 			$insertdata = [
142
 			$insertdata = [
116
 				'uid'=> $uid,
143
 				'uid'=> $uid,
117
 				'mobile' => $phone,
144
 				'mobile' => $phone,
118
-				'commission'=> 0,
145
+				'commission'=> $commissionMoney,
119
 				'commission_share'=> 0.04,
146
 				'commission_share'=> 0.04,
120
 				'order_number' => $push['data']['order_number'],
147
 				'order_number' => $push['data']['order_number'],
121
 				'order_sn' => $order_sn,
148
 				'order_sn' => $order_sn,