all(); $arr = [ "appkey"=>env("MEITUAN_LIANMENG_KEY"), "type"=>$params["order_type"], "startTime"=>time()-$params["minute"]*60, "endTime"=>time(), // "startTime"=>strtotime("2021-09-22 11:25:00"), // "endTime"=>time(), "page"=>1, "limit"=>30, "queryTimeType"=>2, ]; $instance = new LoggerFactoryUtil(CronLogic::class); $instance->info("获取订单数据开始"); $bean = new OrderListParamBean($arr); $res = MeituanLianmengUtil::orderList($bean); // dd($res); $instance->info("美团返回数据:".json_encode($res)); $instance->info("订单数量:".$res["total"]); if($res){ //存在数据,写入订单数据表 if($res["total"]){ $instance->info("订单数据:".json_encode($res)); BaseUtil::sendBaoJing("","获取到订单数量:".$res["total"],"定时获取美团订单"); //处理订单 self::checkOrder($res["dataList"],$params["order_type"]); //判断订单数量是否大于分页 $pageNum = ceil($res["total"]/100)-1; if($pageNum){ for ($i=1;$i<=$pageNum;$i++){ $arr["page"]++; $bean = new OrderListParamBean($arr); $res = MeituanLianmengUtil::orderList($bean); if ($res) { //存在数据,写入订单数据表 if ($res["total"]) { self::checkOrder($res["dataList"],$params["order_type"]); } } } } } } } /** * 处理订单 */ protected static function checkOrder($orders,$orderType) { foreach ($orders as $data) { switch ($data["status"]) { case 1://已付款 $orderStatus = OrderStatusEnum::ALREADY_PAY; break; case 8://已收货 $orderStatus = OrderStatusEnum::ALREADY_RECEIVE; break; case 9://已退款或风控 $orderStatus = OrderStatusEnum::ALREADY_REFUND; break; } $params = [ "spreadSonType" => 0,//订单子类型 "orderNumber" => $data["orderid"],//订单编号 "payTime" => date("Y-m-d H:i:s", $data["paytime"]),//支付时间 "orderPrice" => $data["payprice"] * 100,//订单金额 "orderCommission" => $data["profit"] * 100,//订单佣金 "orderTitle" => $data["smstitle"],//订单标题 "orderRefundPrice" => isset($data["refundprice"]) ? $data["refundprice"] * 100 : 0,//退款金额 "orderRefundTime" => isset($data["refundtime"]) ? date("Y-m-d H:i:s", $data["refundtime"]) : null,//退款时间 "orderRefundCommission" => isset($data["refundprofit"]) ? $data["refundprofit"] : 0,//退款佣金 "orderStatus" => $orderStatus,//订单状态 "orderCouponPrice" => 0,//订单优惠 "productImgUrl" => "https://pic.rmb.bdstatic.com/bjh/f049242a789a22fb1a412bb6418c52e2.jpeg",//商品图片 "spreadType"=>PlatformTypeEnum::PLATFORM_MEITUAN,//订单类型 "userSpreadId"=>$data["sid"],//用户推广位 "platformSpreadId"=>$data["sid"],//平台推广位 "createdAt"=>date("Y-m-d H:i:s", $data["paytime"]) ]; $bean = new HandleOrderParamBean($params); OrderLogic::handleOrderLogic($bean); } } /** * 聚推客订单逻辑 */ public static function jutuikeOrdersLogic() { $params = request()->all(); $startTime = date("Y-m-d H:i:s",time()-600); $endTime = date("Y-m-d H:i:s"); if(isset($params["start_time"])){ $startTime = $params["start_time"]; } if (isset($params["end_time"])){ $endTime= $params["end_time"]; } $page = 1; $params = [ "start_time"=>$startTime, "end_time"=>$endTime, "query_type"=>2, "page"=>$page, "pageSize"=>100 ]; $bean = new GetOrderListParamBean($params); $data = JutuikeUtil::getOrderList($bean); $instance = new LoggerFactoryUtil(CronLogic::class); $instance->info("上游返回数据:".json_encode($data)); if($data["code"]!=1){ //上游错误 return; } //判断是否存在订单 $orderLists = $data["data"]["data"]; if(count($orderLists)){ BaseUtil::sendBaoJing("","获取到订单数量:".count($orderLists),"定时获取聚推客订单"); } foreach ($orderLists as $orderList){ self::handleOrderLogic($orderList); } } public static function handleOrderLogic($orderList) { //判断订单状态 switch ($orderList["status"]){ case 0://未付款 $orderStatus = OrderStatusEnum::PRE_PAY; break; case 1://已付款 $orderStatus = OrderStatusEnum::ALREADY_PAY; break; case 2://待结算 $orderStatus = OrderStatusEnum::ALREADY_RECEIVE; break; case 3://已结算 $orderStatus = OrderStatusEnum::ALREADY_FINISH; break; case 4://无效订单 $orderStatus = OrderStatusEnum::ALREADY_CANCEL; break; } //获取活动图片 $actImgUrl = CategoryModel::query() ->where("platform_type",PlatformTypeEnum::PLATFORM_JUTUIKE) ->where("activity_id",$orderList["act_id"]) ->value("category_img_url"); $params = [ "spreadSonType" => 0,//订单子类型 "orderNumber" => $orderList["order_sn"],//订单编号 "payTime" => $orderList["pay_time"],//支付时间 "orderPrice" => $orderList["order_price"] * 100,//订单金额 "orderCommission" => $orderList["jtk_share_fee"] * 100,//订单佣金 "orderTitle" => $orderList["order_title"],//订单标题 "orderRefundPrice" => 0,//退款金额 "orderRefundTime" => null,//退款时间 "orderRefundCommission" => 0,//退款佣金 "orderStatus" => $orderStatus,//订单状态 "orderCouponPrice" => 0,//订单优惠 "productImgUrl" => $actImgUrl,//商品图片 "spreadType"=>PlatformTypeEnum::PLATFORM_JUTUIKE,//订单类型 "userSpreadId"=>$orderList["sid"],//用户推广位 "platformSpreadId"=>$orderList["sid"],//平台推广位 "createdAt"=>$orderList["create_time"],//订单创建时间 ]; $bean = new HandleOrderParamBean($params); OrderLogic::handleOrderLogic($bean); } /** * 定时获取淘宝订单逻辑 */ public static function taobaoOrdersLogic() { //获取黑马授权账号 $heimaDatas = $data = TaobaoPidModel::query() ->select([DB::raw("any_value(heima_app_key) as heima_app_key"),DB::raw("any_value(heima_app_secret) as heima_app_secret"),"heima_sid"]) ->groupBy("heima_sid") ->get(); $instance = new LoggerFactoryUtil(CronLogic::class); foreach ($heimaDatas as $heimaData){ //查询黑马账号下的订单 $orders = HeiMaUtil::getOrderList($heimaData); if(!isset($orders["publisher_order_dto"])){ break; } $orders = $orders["publisher_order_dto"]; if($orders){ BaseUtil::sendBaoJing("","获取到淘宝订单:".count($orders),"定时获取黑马淘客订单"); } $instance->info("黑马淘客订单:".json_encode($orders)); try{ foreach ($orders as $orderList){ switch ($orderList["tk_status"]){ case 3: //订单结算 $orderStatus = OrderStatusEnum::ALREADY_RECEIVE; break; case 12: //订单付款 $orderStatus = OrderStatusEnum::ALREADY_PAY; break; case 13: //订单失效 $orderStatus = OrderStatusEnum::ALREADY_CANCEL; break; case 14: //订单成功 $orderStatus = OrderStatusEnum::ALREADY_PAY; break; } $params = [ "spreadSonType" => 0,//订单子类型 "orderNumber" => $orderList["trade_id"],//订单编号 "payTime" => $orderList["tb_paid_time"],//支付时间 "orderPrice" => $orderList["alipay_total_price"]*100,//订单金额 "orderCommission" => $orderList["pub_share_pre_fee"]*100,//订单佣金 "orderTitle" => $orderList["item_title"],//订单标题 "orderRefundPrice" => 0,//退款金额 "orderRefundTime" => null,//退款时间 "orderRefundCommission" => 0,//退款佣金 "orderStatus" => $orderStatus,//订单状态 "orderCouponPrice" => 0,//订单优惠 "productImgUrl" => $orderList["item_img"]??"",//商品图片 "spreadType"=>PlatformTypeEnum::PLATFORM_TAOBAO,//订单类型 "userSpreadId"=>$orderList["adzone_id"],//用户推广位 "platformSpreadId"=>$orderList["adzone_id"],//平台推广位 "createdAt"=>$orderList["tk_create_time"],//订单创建时间 ]; $bean = new HandleOrderParamBean($params); OrderLogic::handleOrderLogic($bean); } }catch (\Throwable $exception){ BaseUtil::sendBaoJing("","淘宝订单更新失败:".$exception->getMessage(),"定时获取黑马淘客订单"); } } } /** * 获取拼多多订单逻辑 */ public static function pddOrdersLogic() { $params = [ "startUpdateTime"=>time()-600, "endUpdateTime"=>time() ]; $bean = new OrderListIncrementGetParamBean($params); $res = DuoDuoKeUtil::orderListIncrementGet($bean); $instance = new LoggerFactoryUtil(CronLogic::class); $instance->info("上游返回信息:".json_encode($res)); if (isset($res["error_response"])){ return; } if($res["order_list_get_response"]["total_count"]){ BaseUtil::sendBaoJing("","获取到订单数量:".$res["order_list_get_response"]["total_count"],"定时获取拼多多订单"); } //获取数据 $datas = $res["order_list_get_response"]["order_list"]; foreach ($datas as $orderList){ switch ($orderList["order_status"]){ case 0: //已支付 $orderStatus = OrderStatusEnum::ALREADY_PAY; break; case 1: //已成团 $orderStatus = OrderStatusEnum::ALREADY_PAY; break; case 2: //确认收货 $orderStatus = OrderStatusEnum::ALREADY_RECEIVE; break; case 3: //审核成功 $orderStatus = OrderStatusEnum::ALREADY_RECEIVE; break; case 4: //审核失败(不可提现) $orderStatus = OrderStatusEnum::ALREADY_CANCEL; break; case 5: //已经结算 $orderStatus = OrderStatusEnum::ALREADY_RECEIVE; break; case 10: //已处罚 $orderStatus = OrderStatusEnum::ALREADY_CANCEL; break; } $params = [ "spreadSonType" => 0,//订单子类型 "orderNumber" => $orderList["order_sn"],//订单编号 "payTime" => date("Y-m-d H:i:s",$orderList["order_pay_time"]),//支付时间 "orderPrice" => $orderList["order_amount"],//订单金额 "orderCommission" => $orderList["promotion_amount"],//订单佣金 "orderTitle" => $orderList["goods_name"],//订单标题 "orderRefundPrice" => 0,//退款金额 "orderRefundTime" => null,//退款时间 "orderRefundCommission" => 0,//退款佣金 "orderStatus" => $orderStatus,//订单状态 "orderCouponPrice" => 0,//订单优惠 "productImgUrl" => "https://pic.rmb.bdstatic.com/bjh/6d9fb4a81eb5fc933da8949854c4fab2.jpeg",//商品图片 "spreadType"=>PlatformTypeEnum::PLATFORM_PINGDUODUO,//订单类型 "userSpreadId"=>$orderList["p_id"],//用户推广位 "platformSpreadId"=>$orderList["p_id"],//平台推广位 "createdAt"=>date("Y-m-d H:i:s",$orderList["order_create_time"]),//订单创建时间 ]; $bean = new HandleOrderParamBean($params); OrderLogic::handleOrderLogic($bean); } } /** * 发送用户下单模版 */ public static function sendOrderTemplateLogic() { $instance = new LoggerFactoryUtil(CronLogic::class); //1.新增粉丝通知 $userFans = UserModel::query() ->where("invite_user_id","<>",0) ->where("user_notify_status",0) ->get(); foreach ($userFans as $userFan){ //获取推荐人 $inviteUser = UserModel::findById($userFan->invite_user_id); if($inviteUser){ try{ //获取公众号实例 $app = WechatAccountUtil::getAppByID($userFan->wechat_account_id); $data = [ 'touser' => $inviteUser->user_open_id, 'template_id' => env("WECHAT_FANS_TEMPLATE_URL"), 'url' => env("WECHAT_FANS_URL"), 'data' => [ 'first' => "亲,您有新的粉丝", 'keyword1' => $userFan->user_nickname, 'keyword2' => $userFan->id+100000, "remark"=>"粉丝将提供分享佣金,粉丝越多比例越高哦,点击查看详情" ], ]; $res = $app->template_message->send($data); $instance->info("粉丝通知微信返回结果:".json_encode($res)); }catch (\Throwable $exception){ $instance->info("粉丝通知结果异常:".$exception->getMessage()); } UserModel::query()->where("id",$userFan->id)->update( [ "user_notify_status"=>1 ] ); } } //2.获取自购已支付且未通知进行模版推送 $orders = UserOrderCommissionModel::query() ->where("commission_status",0) ->where("order_commission",">",0) ->where("user_id","<>",0) ->where("order_notify_status",0) ->limit(10) ->get(); foreach ($orders as $order){ //判断是否自购订单 if($order->user_provider_id){ //反佣订单 $user = UserModel::findById($order->user_id); if($user){ try{ //获取公众号实例 $app = WechatAccountUtil::getAppByID($user->wechat_account_id); $tmpOrder = UserOrderModel::query()->where("order_number",$order->order_number)->first(); $privideUser = UserModel::findById($order->user_provider_id); $data = [ 'touser' => $user->user_open_id, 'template_id' => env("WECHAT_FANS_ORDER_TEMPLATE_URL"), 'url' => env("WECHAT_FANS_ORDER_URL"), 'data' => [ 'first' => "粉丝下单成功通知", 'keyword1' => $order->order_number, 'keyword2' => $tmpOrder->product_name, 'keyword3' => $order->created_at, 'keyword4' => round($tmpOrder->order_price/100,2)."元", 'keyword5' => $privideUser->user_nickname, "remark"=>"您的粉丝有新的订单,分享佣金已产生,3天后结算到您账户中,点击详情跳转粉丝订单" ], ]; $res = $app->template_message->send($data); $instance->info("粉丝下单微信返回结果:".json_encode($res)); }catch (\Throwable $exception){ $instance->info("粉丝下单通知结果异常:".$exception->getMessage()); } } }else{ $user = UserModel::findById($order->user_id); if($user){ try{ //获取公众号实例 $app = WechatAccountUtil::getAppByID($user->wechat_account_id); $tmpOrder = UserOrderModel::query()->where("order_number",$order->order_number)->first(); $data = [ 'touser' => $user->user_open_id, 'template_id' => env("WECHAT_ORDER_TEMPLATE_URL"), 'url' => env("WECHAT_ORDER_URL"), 'data' => [ 'first' => "下单成功通知", 'keyword1' => $order->created_at, 'keyword2' => $tmpOrder->product_name, 'keyword3' => $order->order_number, "remark"=>"感谢您的使用,每月20号结算上个月的佣金,将会结算到您的账户中点击详情跳转我的订单" ], ]; $res = $app->template_message->send($data); $instance->info("自购下单微信返回结果:".json_encode($res)); }catch (\Throwable $exception){ $instance->info("自购下单通知结果异常:".$exception->getMessage()); } } } UserOrderCommissionModel::query()->where("id",$order->id)->update( [ "order_notify_status"=>1 ] ); } //3.获取上月已结算订单,并通知 $completeOrders = UserOrderCommissionModel::query() ->where("commission_status",1) ->where("order_commission",">",0) ->where("user_id","<>",0) ->where("order_complete_notify_status",0) ->groupBy("user_id") ->select(["user_id",DB::Raw("sum(order_commission) as total_order_commission"),DB::Raw("GROUP_CONCAT(id) as ids")]) ->get(); foreach ($completeOrders as $order){ $user = UserModel::findById($order->user_id); if($user){ try{ //获取公众号实例 $app = WechatAccountUtil::getAppByID($user->wechat_account_id); $data = [ 'touser' => $user->user_open_id, 'template_id' => env("WECHAT_COMPLETE_ORDER_TEMPLATE_URL"), 'url' => env("WECHAT_BALANCE_URL"), 'data' => [ 'first' => "上月订单佣金已结算完成", 'keyword1' => round($order["total_order_commission"]/100,2)."元", 'keyword2' => round($order["total_order_commission"]/100,2)."元", 'keyword3' => date("Y-m-d H:i:s"), "remark"=>"订单佣金已结算完成,可以立即提现哦!零钱秒到账" ], ]; $res = $app->template_message->send($data); $instance->info("订单结算微信返回结果:".json_encode($res)); }catch (\Throwable $exception){ $instance->info("订单结算通知结果异常:".$exception->getMessage()); } } UserOrderCommissionModel::query()->whereIn("id",explode(",",$order["ids"]))->update( [ "order_complete_notify_status"=>1 ] ); } } /** * 结算佣金逻辑(每月的20号18点结算上个月的佣金) */ public static function settlementOrderCommissionLogic() { //获取上个月的开始结束时间 $startTime = date("Y-m-d",strtotime("-1 month"))." 00:00:00"; $endTime = date("Y-m-")."01 00:00:00"; //获取上个月未结算的订单且未退款 //这里有个bug,chunk里面自己改自己会导致有的数据娶不到 UserOrderCommissionModel::query() ->where("commission_status",0) ->where("order_commission",">",0) ->where("user_id","<>",0) ->where("order_complete_notify_status",0) ->where("created_at","<",$endTime) ->chunk(300,function ($orderCommissions){ foreach ($orderCommissions as $orderCommission){ try{ //开启事务 DB::beginTransaction(); //1.修改用户的余额 $user = UserModel::query()->lock(true)->find($orderCommission["user_id"]); if($user){ $userRes = UserModel::query() ->where("id",$orderCommission["user_id"]) ->increment("user_balance",$orderCommission["order_commission"]); if(!$userRes){ DB::rollBack(); throw new CommonException(ErrorEnum::ERROR_SYSTEM); } //2.添加用户流水记录 $logRes = UserFinanceModel::query() ->insert( [ "user_id"=>$orderCommission["id"], "order_number"=>$orderCommission["order_number"], "user_before_balance"=>$user["user_balance"], "user_after_balance"=>$orderCommission["order_commission"]+$user["user_balance"], "finance_balance"=>$orderCommission["order_commission"], "finance_remark"=>"订单佣金结算", "finance_type"=>1, "finance_number"=>uniqid("fbt-"), "created_at"=>date("Y-m-d H:i:s"), "updated_at"=>date("Y-m-d H:i:s"), "cash_status"=>1 ] ); if(!$logRes){ DB::rollBack(); throw new CommonException(ErrorEnum::ERROR_SYSTEM); } //3.修改佣金记录为已结算 $commissionRes = UserOrderCommissionModel::query() ->where("id",$orderCommission["id"]) ->update( [ "commission_status"=>1, "updated_at"=>date("Y-m-d H:i:s") ] ); if(!$commissionRes){ DB::rollBack(); throw new CommonException(ErrorEnum::ERROR_SYSTEM); } DB::commit(); } }catch (\Throwable $exception){} } }); } /** * 处理提现打款逻辑 */ public static function transferFinanceLogic() { $account = WechatAccountModel::query() ->where("wechat_app_code","fanbuting") ->first(); $config = [ "app_id"=>$account["wechat_app_id"], "mch_id"=>$account["account_mch_id"], "key"=>$account["account_key"], "cert_path"=>$account["account_cert_path"], "key_path"=>$account["account_key_path"] ]; $app = Factory::payment($config); //获取已审核且未打款的提现记录 $cashLogs = UserCashModel::query() ->where("check_status",2) ->where("cash_status",0) ->get(); if(!$cashLogs){ return ; } //将打款记录修改为执行中 $logIds = []; foreach ($cashLogs as $cashLog){ $logIds[] = $cashLog["id"]; } UserCashModel::query() ->whereIn("id",$logIds) ->update( [ "cash_status"=>1 ] ); foreach ($cashLogs as $cashLog){ //1.获取用户的openId $user = UserModel::query()->find($cashLog["user_id"]); if($user){ $res = $app->transfer->toBalance( [ "partner_trade_no"=>$cashLog["cash_order_number"], "openid"=>$user["user_open_id"], "check_name"=>"NO_CHECK",//不校验姓名 "re_user_name"=>"",//真实姓名 "amount"=>$cashLog["cash_money"], "desc"=>"用户提现" ] ); //判断是否支付成功 if($res["return_code"]=="SUCCESS" && $res["result_code"]=="SUCCESS"){ UserCashModel::query() ->where("id",$cashLog["id"]) ->update( [ "cash_status"=>2, "upstream_response"=>json_encode($res), "cash_receive_at"=>date("Y-m-d H:i:s") ] ); $cash_status = 1;//打款成功 }else{ //打款失败 UserCashModel::query() ->where("id",$cashLog["id"]) ->update( [ "cash_status"=>3, "upstream_response"=>json_encode($res) ] ); $cash_status = 2;//打款失败 } //修改提现流水的状态 UserFinanceModel::query()->where("id",$cashLog["user_finance_id"]) ->update( [ "cash_status"=>$cash_status, "updated_at"=>date("Y-m-d H:i:s") ] ); } } } /** * 打款失败退款逻辑 */ public static function callbackCashLogic() { //获取已审核且未打款的提现记录 $cashLogs = UserCashModel::query() ->where("callback_status",0) ->where(function ($query){ $query->where("check_status",3) ->orWhere("cash_status",3); }) ->get(); if(!$cashLogs){ return; } foreach ($cashLogs as $cashLog){ DB::beginTransaction(); //获取用户 $user = UserModel::query()->lock(true)->find($cashLog["user_id"]); //1.用户金额增加 $userRes = UserModel::query() ->where("id",$user["user_id"]) ->increment("user_balance",$cashLog["cash_money"]); if(!$userRes){ DB::rollBack(); break; } //2.添加流水记录 $financeRes = UserFinanceModel::query()->insert( [ "user_id"=>$cashLog["user_id"], "user_before_balance"=>$user["user_balance"], "user_after_balance"=>$user["user_balance"]+$cashLog["cash_money"], "finance_balance"=>$cashLog["cash_money"], "finance_remark"=>"提现失败退回,原提现记录ID为:".$cashLog["id"], "finance_type"=>1, "finance_number"=>BaseUtil::getOrderNumber(), "created_at"=>date("Y-m-d H:i:s"), "updated_at"=>date("Y-m-d H:i:s"), ] ); if(!$financeRes){ DB::rollBack(); break; } //3.修改提现记录为退款成功 $cashRes = UserCashModel::query() ->where("id",$cashLog["id"]) ->update([ "callback_status"=>1 ]); if(!$cashRes){ DB::rollBack(); break; } DB::commit(); } } }