Merge branch 'master' of http://47.108.67.251:8099/coupon.xp.yn.cn/coupon_backend

@@ -210,7 +210,8 @@ class Client extends Api
         //插入订单表
         //插入订单表
         $res=Db::name('verification_order')->insertGetId($data);
         $res=Db::name('verification_order')->insertGetId($data);
         if($res){
         if($res){
-            $this->success('添加订单成功');
+            $res = (new \app\api\controller\v1\Wechat())->prepare_order($order_no);
+            $this->success('添加订单成功',$res);
         }else{
         }else{
             $this->error("添加订单失败!");
             $this->error("添加订单失败!");
         }
         }

@@ -9,7 +9,7 @@ use think\Config;
 use think\Db;
 use think\Db;
 use think\Response;
 use think\Response;
 use think\Validate;
 use think\Validate;
-
+use app\api\controller\Common;
 /**
 /**
  * 首页公共
  * 首页公共
  */
  */
@@ -287,16 +287,16 @@ class Wechat extends Api
 	*/
 	*/
 	public function prepare_order($order_no = ''){
 	public function prepare_order($order_no = ''){
 		$user_id = $this->auth->id;
 		$user_id = $this->auth->id;
-
+	
 		if(empty($user_id)){
 		if(empty($user_id)){
-			return $this->error('用户信息错误');
+			return $this->error('预下单的用户信息错误');
 		}
 		}
 		$userInfo = Db::name('user')->where(['id'=>$user_id])->find();
 		$userInfo = Db::name('user')->where(['id'=>$user_id])->find();
 
 
-		$out_trade_no = $order_no ='168532907259455';
+		$out_trade_no = $order_no;
 		$app = WehcatModule::getInstance()->initWechatPay();
 		$app = WehcatModule::getInstance()->initWechatPay();
 		$result = $app->order->unify([
 		$result = $app->order->unify([
-			'body' => '腾讯充值中心-QQ会员充值',
+			'body' => '优惠券购买',
 			'out_trade_no' => $out_trade_no,
 			'out_trade_no' => $out_trade_no,
 			'total_fee' => 1,
 			'total_fee' => 1,
 			'trade_type' => 'JSAPI', // 请对应换成你的支付方式对应的值类型
 			'trade_type' => 'JSAPI', // 请对应换成你的支付方式对应的值类型
@@ -306,10 +306,10 @@ class Wechat extends Api
 			$prepay_id = $result['prepay_id'];
 			$prepay_id = $result['prepay_id'];
 			$jssdk = $app->jssdk;
 			$jssdk = $app->jssdk;
 			$config = $jssdk->sdkConfig($prepay_id);
 			$config = $jssdk->sdkConfig($prepay_id);
-			return $this->success('下单成功',$config);
+			return $config;
 
 
 		}else{
 		}else{
-			return $this->error('下单失败',$result);
+			return $result;
 		}
 		}
 
 
 	}
 	}
@@ -322,15 +322,15 @@ class Wechat extends Api
 		$app = WehcatModule::getInstance()->initWechatPay();
 		$app = WehcatModule::getInstance()->initWechatPay();
 		$response = $app->handlePaidNotify(function($message, $fail){
 		$response = $app->handlePaidNotify(function($message, $fail){
 			// 使用通知里的 "微信支付订单号" 或者 "商户订单号" 去自己的数据库找到订单
 			// 使用通知里的 "微信支付订单号" 或者 "商户订单号" 去自己的数据库找到订单
-			file_put_contents("1_cc.log",json_encode($message),FILE_APPEND);
-			$order = $message['out_trade_no'];
+			Common::put_file_log('支付成功-微信支付回调信息',json_encode($message), 'pay_notify', __CLASS__ . __FUNCTION__ . __LINE__);
+			$out_trade_no = $message['out_trade_no'];
 			if ($message['return_code'] === 'SUCCESS' && $message['result_code'] === 'SUCCESS') {
 			if ($message['return_code'] === 'SUCCESS' && $message['result_code'] === 'SUCCESS') {
-
+				$o_w["order_no"] = $out_trade_no;
+				$order_info = Db::name('verification_order')->where($o_w)->find();
+				$this->sales_distribution($order_info);
 			} else {
 			} else {
-				return $fail('通信失败，请稍后再通知我');
+				Common::put_file_log('支付失败-微信支付回调信息',json_encode($message), 'pay_notify', __CLASS__ . __FUNCTION__ . __LINE__);
 			}
 			}
-
-
 			return true; // 返回处理完成
 			return true; // 返回处理完成
 		});
 		});
 		$response->send(); // return $response;
 		$response->send(); // return $response;
@@ -368,7 +368,7 @@ class Wechat extends Api
 		}
 		}
 	}
 	}
 
 
-	//查询上级
+	//支付后，根据用户角色 处理对应的事情
 	private function getParent($pid,$verification_store_id,$order_id){
 	private function getParent($pid,$verification_store_id,$order_id){
 		//上级身份
 		//上级身份
 		$time = time();
 		$time = time();
@@ -377,10 +377,16 @@ class Wechat extends Api
 		$role = Db::name('verification_staff')->where($w1)->find();
 		$role = Db::name('verification_staff')->where($w1)->find();
 		if(in_array($role['type'],['1','3'])){
 		if(in_array($role['type'],['1','3'])){
 			//属于代理 企业付款到佣金
 			//属于代理 企业付款到佣金
-			return '';
+			$this->grant_commission($pid,$order_id);
 		}else{
 		}else{
 			//属于普通用户 发送代金券
 			//属于普通用户 发送代金券
-			$w1['verification_store_id'] = $verification_store_id;
+			$this->send_voucher($pid,$verification_store_id,$order_id,$time);
+		}
+	}
+
+	//发放代金券
+	public function send_voucher($pid,$verification_store_id,$order_id,$time){
+		$w1['verification_store_id'] = $verification_store_id;
 			$w1['closetime'] = ['<',$time];
 			$w1['closetime'] = ['<',$time];
 			$coupon = Db::name('verification_coupon')->where($w1)->select();
 			$coupon = Db::name('verification_coupon')->where($w1)->select();
 			if(!empty($coupon)){
 			if(!empty($coupon)){
@@ -389,16 +395,41 @@ class Wechat extends Api
 					$save['verification_coupon_id'] = $v['id'];
 					$save['verification_coupon_id'] = $v['id'];
 					$save['verification_store_id'] = $v['verification_store_id'];
 					$save['verification_store_id'] = $v['verification_store_id'];
 					$save['user_id'] = $pid;
 					$save['user_id'] = $pid;
-					$save['type'] = 0;
-					$save['closetime'] = $v['closetime'];
-					$save['receive_no'] = $time.uniqid();
-					$res = (new \app\api\controller\v1\Index())->build($save['receive_no']);
-					$save['qr_code'] = $res;//二维码
-					$save['createtime'] = $time;
-					$save['verification_order_id'] = $order_id;
+					//用户是否已经领取该门店的券
+					$r = Db::name('verification_receive')->where($save)->find();
+					if(empty($r)){
+						$save['type'] = 0;
+						$save['closetime'] = $v['closetime'];
+						$save['receive_no'] = $time.uniqid();
+						$res = (new \app\api\controller\v1\Index())->build($save['receive_no']);
+						$save['qr_code'] = $res;//二维码
+						$save['createtime'] = $time;
+						$save['verification_order_id'] = $order_id;
+						Db::name('verification_receive')->insert($save);
+					}
 				}
 				}
 			}
 			}
+	}
+	// 发放佣金
+	public function grant_commission($pid=0,$order_id=0){
+		try{
+			$verification_order = Db::name('verification_order')->where(['id'=>$order_id])->find();
+			$app = WehcatModule::getInstance()->initWechatPay();
+			$result = $app->transfer->toBalance([
+				'partner_trade_no' => '168532907259455', // 商户订单号，需保持唯一性(只能是字母或者数字，不能包含有符号)
+				'openid' => 'o5OQw6PPEGaHqIjAir7gqeDV5MzQ',
+				'check_name' => 'NO_CHECK', // NO_CHECK：不校验真实姓名, FORCE_CHECK：强校验真实姓名
+				're_user_name' => '陈程', // 如果 check_name 设置为FORCE_CHECK，则必填用户真实姓名
+				'amount' => 1, // 企业付款金额，单位为分
+				'desc' => '理赔', // 企业付款操作说明信息。必填
+			]);
+			if($result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS'){
+				//记录佣金表
+			}else{
+				Common::put_file_log('失败-佣金发放',json_encode($result), 'grant_commission', __CLASS__ . __FUNCTION__ . __LINE__);
+			}
+		}catch(\Exception $e){
+			Common::put_file_log('异常-佣金发放',json_encode($result), 'grant_commission', __CLASS__ . __FUNCTION__ . __LINE__);
 		}
 		}
 	}
 	}
-
 }
 }