|
|
@@ -0,0 +1,206 @@
|
|
|
+<?php
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | likeadmin快速开发前后端分离管理后台(PHP版)
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | 欢迎阅读学习系统程序代码,建议反馈是我们前进的动力
|
|
|
+// | 开源版本可自由商用,可去除界面版权logo
|
|
|
+// | gitee下载:https://gitee.com/likeshop_gitee/likeadmin
|
|
|
+// | github下载:https://github.com/likeshop-github/likeadmin
|
|
|
+// | 访问官网:https://www.likeadmin.cn
|
|
|
+// | likeadmin团队 版权所有 拥有最终解释权
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | author: likeadminTeam
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+
|
|
|
+namespace app\adminapi\logic\property;
|
|
|
+
|
|
|
+
|
|
|
+use app\adminapi\logic\user\UserLogic;
|
|
|
+use app\api\logic\ServiceOrderLogic;
|
|
|
+use app\common\logic\PaymentLogic;
|
|
|
+use app\common\model\property\PropertyOrder;
|
|
|
+use app\common\logic\BaseLogic;
|
|
|
+use think\Exception;
|
|
|
+use think\facade\Db;
|
|
|
+use think\facade\Log;
|
|
|
+
|
|
|
+
|
|
|
+/**
|
|
|
+ * PropertyOrder逻辑
|
|
|
+ * Class PropertyOrderLogic
|
|
|
+ * @package app\adminapi\logic
|
|
|
+ */
|
|
|
+class PropertyOrderLogic extends BaseLogic
|
|
|
+{
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 添加
|
|
|
+ * @param array $params
|
|
|
+ * @return bool
|
|
|
+ * @author likeadmin
|
|
|
+ * @date 2024/09/19 14:48
|
|
|
+ */
|
|
|
+ public static function add(array $params): bool
|
|
|
+ {
|
|
|
+ // 判断户主是否存在 返回户主id
|
|
|
+ $propertyUserId = PropertyUserLogic::getPropertyUserIdByMobile($params);
|
|
|
+ Db::startTrans();
|
|
|
+ try {
|
|
|
+ PropertyOrder::create([
|
|
|
+ 'property_head_id' => $params['property_head_id'],
|
|
|
+ 'property_user_id' => $propertyUserId,
|
|
|
+ 'remark' => $params['remark']
|
|
|
+ ]);
|
|
|
+ Db::commit();
|
|
|
+ return true;
|
|
|
+ } catch (\Exception $e) {
|
|
|
+ Db::rollback();
|
|
|
+ self::setError($e->getMessage());
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 编辑
|
|
|
+ * @param array $params
|
|
|
+ * @return bool
|
|
|
+ * @author likeadmin
|
|
|
+ * @date 2024/09/19 14:48
|
|
|
+ */
|
|
|
+ public static function edit(array $params): bool
|
|
|
+ {
|
|
|
+ Db::startTrans();
|
|
|
+ try {
|
|
|
+ $upData = ['remark' => $params['remark']];
|
|
|
+ if($params['order_status'] == 2){
|
|
|
+ $upData['order_status'] = $params['order_status'];
|
|
|
+ }
|
|
|
+ PropertyOrder::where('id', $params['id'])->update($upData);
|
|
|
+ Db::commit();
|
|
|
+ return true;
|
|
|
+ } catch (\Exception $e) {
|
|
|
+ Db::rollback();
|
|
|
+ self::setError($e->getMessage());
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 删除
|
|
|
+ * @param array $params
|
|
|
+ * @return bool
|
|
|
+ * @author likeadmin
|
|
|
+ * @date 2024/09/19 14:48
|
|
|
+ */
|
|
|
+ public static function delete(array $params): bool
|
|
|
+ {
|
|
|
+ return PropertyOrder::destroy($params['id']);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 获取详情
|
|
|
+ * @param $params
|
|
|
+ * @return array
|
|
|
+ * @author likeadmin
|
|
|
+ * @date 2024/09/19 14:48
|
|
|
+ */
|
|
|
+ public static function detail($params): array
|
|
|
+ {
|
|
|
+ return PropertyOrder::findOrEmpty($params['id'])->toArray();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 客服下单
|
|
|
+ * @param array $params
|
|
|
+ * @return bool
|
|
|
+ * @author likeadmin
|
|
|
+ * @date 2024/09/19 14:48
|
|
|
+ */
|
|
|
+ public static function placeOrder(array $params): bool
|
|
|
+ {
|
|
|
+ // 客服手动下单
|
|
|
+ /*
|
|
|
+ 1. 按照用户原预约下单参数创建 工单
|
|
|
+ 2. 由 工单id 状态-已接单 更新当前订单状态信息
|
|
|
+ // 订单状态:0=未接单,1=已接单,2=取消单,3=已完结
|
|
|
+ */
|
|
|
+
|
|
|
+ $orderInfo = PropertyOrder::where('id', $params['id'])->findOrEmpty()->toArray();
|
|
|
+ $propertyUserInfo = PropertyUserLogic::detail(['id'=>$orderInfo['property_user_id']]);
|
|
|
+ $userInfo = UserLogic::detail($propertyUserInfo['user_id']);
|
|
|
+ if($orderInfo['order_status'] != 0){
|
|
|
+ self::setError('当前订单状态不允许操作');
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ Db::startTrans();
|
|
|
+ try {
|
|
|
+
|
|
|
+ if($orderInfo['work_id'] == 0 && $orderInfo['order_status'] == 0){
|
|
|
+ /*// 'address','appointment_time','pay_way','goods_id','contact_number','contact_people'
|
|
|
+ 'sn.require' => '订单编号错误',
|
|
|
+ 'address.require' => '请填写地址',
|
|
|
+ 'appointment_time.require' => '请填写预约上门时间',
|
|
|
+ 'appointment_time.dateFormat' => '预约上门时间格式错误',
|
|
|
+ 'pay_way.require' => '请选择支付方式',
|
|
|
+ 'goods_id.require' => '订单商品不存在',
|
|
|
+ 'contact_number.require' => '联系电话不存在',
|
|
|
+ 'contact_people.require' => '联系人不存在',*/
|
|
|
+ $serviceOrderParams = array_merge($params,[
|
|
|
+ 'user_id' => $propertyUserInfo['user_id'],
|
|
|
+ 'terminal' => 4,
|
|
|
+ 'user_info' => ['mobile'=>$userInfo['mobile']]
|
|
|
+ ]);
|
|
|
+ Log::write(json_encode($serviceOrderParams,JSON_UNESCAPED_UNICODE));
|
|
|
+ $result = ServiceOrderLogic::submitOrder($serviceOrderParams);
|
|
|
+ if($result === false){
|
|
|
+ throw new Exception(PropertyOrderLogic::getError());
|
|
|
+ }
|
|
|
+ // $result['order_id'] $result['work_id']
|
|
|
+ $upData = [];
|
|
|
+ if(isset($result['work_id']) && !empty($result['work_id'])){
|
|
|
+ $upData['work_id'] = $result['work_id'];
|
|
|
+ $upData['order_status'] = 1;
|
|
|
+ }
|
|
|
+ if($upData){
|
|
|
+ $propertyOrder = PropertyOrder::where('id', $params['id'])->update($upData);
|
|
|
+ }
|
|
|
+ if($propertyOrder){
|
|
|
+ //订单信息 pay_way=2 goods order_id
|
|
|
+ $params['from'] = 'goods';
|
|
|
+ $order = PaymentLogic::getPayOrderInfo(['order_id'=>$result['order_id']]);
|
|
|
+ Log::info('ServiceOrder:',$result);
|
|
|
+ if (false === $order) {
|
|
|
+ Log::info(PaymentLogic::getError());
|
|
|
+ return false;
|
|
|
+ //throw new Exception(PaymentLogic::getError());
|
|
|
+ }
|
|
|
+ if ($order['order_amount'] == 0) {
|
|
|
+ //0元时自动支付
|
|
|
+ $redirectUrl = $params['redirect'] ?? '/pages/payment/payment';
|
|
|
+ PaymentLogic::pay($params['pay_way'], $params['from'], $order, 4, $redirectUrl);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ Db::commit();
|
|
|
+ return true;
|
|
|
+ } catch (\Exception $e) {
|
|
|
+ Db::rollback();
|
|
|
+ self::setError($e->getMessage());
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+}
|