request); $limitTimeList = [ 'yesterday' => implode(' - ', [date('Y/m/d', strtotime('-1 day')), date('Y/m/d')]), 'today' => implode(' - ', [date('Y/m/d'), date('Y/m/d', strtotime('+1 day'))]), 'week' => implode(' - ', [ date('Y/m/d', (time() - ((date('w') == 0 ? 7 : date('w')) - 1) * 24 * 3600)), date('Y-m-d', (time() + (7 - (date('w') == 0 ? 7 : date('w'))) * 24 * 3600)) ]), 'month' => implode(' - ', [date('Y/m') . '/01', date('Y/m') . '/' . date('t')]), 'quarter' => implode(' - ', [ date('Y') . '/' . (ceil((date('n')) / 3) * 3 - 3 + 1) . '/01', date('Y') . '/' . (ceil((date('n')) / 3) * 3) . '/' . date('t', mktime(0, 0, 0, (ceil((date('n')) / 3) * 3), 1, date('Y'))) ]), 'year' => implode(' - ', [ date('Y') . '/01/01', date('Y/m/d', strtotime(date('Y') . '/01/01 + 1year -1 day')) ]) ]; $this->assign(StoreOrderModel::systemPage($where, $this->adminId)); $this->assign('price', StoreOrderModel::getOrderPrice($where)); $this->assign(compact('where', 'limitTimeList')); return $this->fetch(); } public function orderchart() { $where = Util::getMore([ ['status', ''], ['real_name', ''], ['is_del', 0], ['data', ''], ['combination_id', ''], ['export', 0], ['order', 'id desc'] ], $this->request); $limitTimeList = [ 'today' => implode(' - ', [date('Y/m/d'), date('Y/m/d', strtotime('+1 day'))]), 'week' => implode(' - ', [ date('Y/m/d', (time() - ((date('w') == 0 ? 7 : date('w')) - 1) * 24 * 3600)), date('Y-m-d', (time() + (7 - (date('w') == 0 ? 7 : date('w'))) * 24 * 3600)) ]), 'month' => implode(' - ', [date('Y/m') . '/01', date('Y/m') . '/' . date('t')]), 'quarter' => implode(' - ', [ date('Y') . '/' . (ceil((date('n')) / 3) * 3 - 3 + 1) . '/01', date('Y') . '/' . (ceil((date('n')) / 3) * 3) . '/' . date('t', mktime(0, 0, 0, (ceil((date('n')) / 3) * 3), 1, date('Y'))) ]), 'year' => implode(' - ', [ date('Y') . '/01/01', date('Y/m/d', strtotime(date('Y') . '/01/01 + 1year -1 day')) ]) ]; if ($where['data'] == '') $where['data'] = $limitTimeList['today']; $orderCount = [ urlencode('未支付') => StoreOrderModel::getOrderWhere($where, StoreOrderModel::statusByWhere(0))->count(), urlencode('未发货') => StoreOrderModel::getOrderWhere($where, StoreOrderModel::statusByWhere(1))->count(), urlencode('待收货') => StoreOrderModel::getOrderWhere($where, StoreOrderModel::statusByWhere(2))->count(), urlencode('待评价') => StoreOrderModel::getOrderWhere($where, StoreOrderModel::statusByWhere(3))->count(), urlencode('交易完成') => StoreOrderModel::getOrderWhere($where, StoreOrderModel::statusByWhere(4))->count(), urlencode('退款中') => StoreOrderModel::getOrderWhere($where, StoreOrderModel::statusByWhere(-1))->count(), urlencode('已退款') => StoreOrderModel::getOrderWhere($where, StoreOrderModel::statusByWhere(-2))->count() ]; $model = StoreOrderModel::getOrderWhere($where, new StoreOrderModel())->field('sum(total_num) total_num,count(*) count,sum(total_price) total_price,sum(refund_price) refund_price,from_unixtime(add_time,\'%Y-%m-%d\') add_time') ->group('from_unixtime(add_time,\'%Y-%m-%d\')'); $orderPrice = $model->select()->toArray(); $orderDays = []; $orderCategory = [ ['name' => '商品数', 'type' => 'line', 'data' => []], ['name' => '订单数', 'type' => 'line', 'data' => []], ['name' => '订单金额', 'type' => 'line', 'data' => []], ['name' => '退款金额', 'type' => 'line', 'data' => []] ]; foreach ($orderPrice as $price) { $orderDays[] = $price['add_time']; $orderCategory[0]['data'][] = $price['total_num']; $orderCategory[1]['data'][] = $price['count']; $orderCategory[2]['data'][] = $price['total_price']; $orderCategory[3]['data'][] = $price['refund_price']; } $this->assign(StoreOrderModel::systemPage($where, $this->adminId)); $this->assign('price', StoreOrderModel::getOrderPrice($where)); $this->assign(compact('limitTimeList', 'where', 'orderCount', 'orderPrice', 'orderDays', 'orderCategory')); return $this->fetch(); } /** * 修改支付金额等 * @param $id * @return mixed|\think\response\Json|void */ public function edit($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); $this->assign([ 'title' => '修改订单', 'rules' => $this->read($id)->getContent(), 'action' => Url::buildUrl('update', array('id' => $id)) ]); return $this->fetch('public/common_form'); } public function read($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); Form::text('order_id', '订单编号', $product->getData('order_id'))->readonly(); Form::number('total_price', '商品总价', $product->getData('total_price'))->min(0); Form::number('total_postage', '原始邮费', $product->getData('total_postage'))->min(0); Form::number('pay_price', '实际支付金额', $product->getData('pay_price'))->min(0); Form::number('pay_postage', '实际支付邮费', $product->getData('pay_postage'))->min(0); Form::number('gain_integral', '赠送积分', $product->getData('gain_integral'))->min(0); return Form::builder(); } public function update($id) { $data = Util::postMore([ 'order_id', 'total_price', 'total_postage', 'pay_price', 'pay_postage', 'gain_integral', ]); if ($data['total_price'] <= 0) return Json::fail('请输入商品总价'); if ($data['pay_price'] <= 0) return Json::fail('请输入实际支付金额'); $data['order_id'] = StoreOrderModel::changeOrderId($data['order_id']); StoreOrderModel::edit($data, $id); event('StoreProductOrderEditAfter', [$data, $id]); StoreOrderStatus::setStatus($id, 'order_edit', '修改商品总价为:' . $data['total_price'] . ' 实际支付金额' . $data['pay_price']); return Json::successful('修改成功!'); } /** * 送货 * @param $id * send */ public function delivery($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); if ($product['paid'] == 1 && $product['status'] == 0) { $this->assign([ 'title' => '送货信息', 'rules' => $this->readDelivery($id)->getContent(), 'action' => Url::buildUrl('updateDelivery', array('id' => $id)) ]); return $this->fetch('public/common_form'); } else return Json::fail('数据不存在!'); } public function readDelivery($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); Form::text('delivery_name', '送货人姓名'); Form::text('delivery_id', '送货人电话')->number(); return Form::builder(); } public function updateDelivery($id) { $data = Util::postMore([ 'delivery_name', 'delivery_id', ]); $data['delivery_type'] = 'send'; if (!$data['delivery_name']) return Json::fail('请输入送货人姓名'); if (!(int)$data['delivery_id']) return Json::fail('请输入送货人电话号码'); else if (!preg_match("/^1[3456789]{1}\d{9}$/", $data['delivery_id'])) return Json::fail('请输入正确的送货人电话号码'); $data['status'] = 1; StoreOrderModel::edit($data, $id); event('storeProductOrderDeliveryAfter', [$data, $id]); StoreOrderStatus::setStatus($id, 'delivery', '已配送 发货人:' . $data['delivery_name'] . ' 发货人电话:' . $data['delivery_id']); return Json::successful('修改成功!'); } /** * 发货 * @param $id * express */ public function deliver_goods($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); if ($product['paid'] == 1 && $product['status'] == 0) { $this->assign([ 'title' => '发货信息', 'rules' => $this->readDeliveryGoods($id)->getContent(), 'action' => Url::buildUrl('updateDeliveryGoods', array('id' => $id)) ]); return $this->fetch('public/common_form'); } else return Json::fail('数据不存在!'); } public function readDeliveryGoods($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); Form::select('delivery_name', '快递公司', function () { $list = Express::where('is_show', 1)->order('sort DESC')->column('name', 'id'); $menus = []; foreach ($list as $k => $v) { $menus[] = ['value' => $v, 'label' => $v]; } return $menus; })->filterable(); Form::text('delivery_id', '快递单号'); return Form::builder(); } public function updateDeliveryGoods($id) { $data = Util::postMore([ 'delivery_name', 'delivery_id', ]); $data['delivery_type'] = 'express'; if (!$data['delivery_name']) return Json::fail('请选择快递公司'); if (!$data['delivery_id']) return Json::fail('请输入快递单号'); $data['status'] = 1; StoreOrderModel::edit($data, $id); event('StoreProductOrderDeliveryGoodsAfter', [$data, $id]); StoreOrderStatus::setStatus($id, 'delivery_goods', '已发货 快递公司:' . $data['delivery_name'] . ' 快递单号:' . $data['delivery_id']); return Json::successful('修改成功!'); } /** * 修改状态为已收货 * @param $id * @return \think\response\Json|void */ public function take_delivery($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); if ($product['status'] == 2) return Json::fail('不能重复收货!'); if ($product['paid'] == 1 && $product['status'] == 1) $data['status'] = 2; else if ($product['pay_type'] == 'offline') $data['status'] = 2; else return Json::fail('请先发货或者送货!'); if (!StoreOrderModel::edit($data, $id)) return Json::fail(StoreOrderModel::getErrorInfo('收货失败,请稍候再试!')); else { try { OrderRepository::storeProductOrderTakeDeliveryAdmin($data, $id); } catch (\Exception $e) { return Json::fail($e->getMessage()); } StoreOrderStatus::setStatus($id, 'take_delivery', '已收货'); return Json::successful('收货成功!'); } } /** * 修改退款状态 * @param $id * @return \think\response\Json|void */ public function refund_y($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); if ($product['paid'] == 1) { $this->assign([ 'title' => '退款', 'rules' => $this->readRefundY($id)->getContent(), 'action' => Url::buildUrl('updateRefundY', array('id' => $id)) ]); return $this->fetch('public/common_form'); } else return Json::fail('数据不存在!'); } public function readRefundY($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); Form::text('order_id', '退款单号', $product->getData('order_id'))->readonly(); Form::number('refund_price', '退款金额', $product->getData('pay_price'))->min(0); Form::radio('type', '状态', [['label' => '直接退款', 'value' => 1], ['label' => '退款后,返回原状态', 'value' => 2]], 1); return Form::builder(); } public function updateRefundY($id) { $data = Util::postMore([ 'refund_price', ['type', 1], ]); if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); if ($product['pay_price'] == $product['refund_price']) return Json::fail('已退完支付金额!不能再退款了'); if (!$data['refund_price']) return Json::fail('请输入退款金额'); $refund_price = $data['refund_price']; $data['refund_price'] = bcadd($data['refund_price'], $product['refund_price'], 2); $bj = bccomp((float)$product['pay_price'], (float)$data['refund_price'], 2); if ($bj < 0) return Json::fail('退款金额大于支付金额,请修改退款金额'); if ($data['type'] == 1) { $data['refund_status'] = 2; } else if ($data['type'] == 2) { $data['refund_status'] = 0; } $type = $data['type']; unset($data['type']); $refund_data['pay_price'] = $product['pay_price']; $refund_data['refund_price'] = $refund_price; if ($product['pay_type'] == 'weixin') { if ($product['is_channel'] == 1) {//TODO 小程序 try { MiniProgramService::payOrderRefund($product['order_id'], $refund_data);//2.5.36 } catch (\Exception $e) { return Json::fail($e->getMessage()); } } else { //TODO 公众号 try { WechatService::payOrderRefund($product['order_id'], $refund_data); } catch (\Exception $e) { return Json::fail($e->getMessage()); } } } else if ($product['pay_type'] == 'yue') { BaseModel::beginTrans(); $usermoney = User::where('uid', $product['uid'])->value('now_money'); $res1 = User::bcInc($product['uid'], 'now_money', $refund_price, 'uid'); $res2 = $res2 = UserBill::income('商品退款', $product['uid'], 'now_money', 'pay_product_refund', $refund_price, $product['id'], bcadd($usermoney, $refund_price, 2), '订单退款到余额' . floatval($refund_price) . '元'); try { OrderRepository::storeOrderYueRefund($product, $refund_data); } catch (\Exception $e) { BaseModel::rollbackTrans(); return Json::fail($e->getMessage()); } $res = $res1 && $res2; BaseModel::checkTrans($res); if (!$res) return Json::fail('余额退款失败!'); } $resEdit = StoreOrderModel::edit($data, $id); if ($resEdit) { $data['type'] = $type; if ($data['type'] == 1) StorePink::setRefundPink($id); try { OrderRepository::storeProductOrderRefundY($data, $id); } catch (\Exception $e) { return Json::fail($e->getMessage()); } StoreOrderStatus::setStatus($id, 'refund_price', '退款给用户' . $refund_price . '元'); return Json::successful('修改成功!'); } else { StoreOrderStatus::setStatus($id, 'refund_price', '退款给用户' . $refund_price . '元失败'); return Json::fail('修改失败!'); } } public function order_info($oid = '') { if (!$oid || !($orderInfo = StoreOrderModel::get($oid))) return $this->failed('订单不存在!'); $userInfo = User::getUserInfo($orderInfo['uid']); if ($userInfo['spread_uid']) { $spread = User::where('uid', $userInfo['spread_uid'])->value('nickname'); } else { $spread = ''; } $this->assign(compact('orderInfo', 'userInfo', 'spread')); return $this->fetch(); } public function express($oid = '') { if (!$oid || !($order = StoreOrderModel::get($oid))) return $this->failed('订单不存在!'); if ($order['delivery_type'] != 'express' || !$order['delivery_id']) return $this->failed('该订单不存在快递单号!'); $cacheName = $order['order_id'] . $order['delivery_id']; $result = CacheService::get($cacheName, null); if ($result === null) { $result = ExpressService::query($order['delivery_id']); if (is_array($result) && isset($result['result']) && isset($result['result']['deliverystatus']) && $result['result']['deliverystatus'] >= 3) $cacheTime = 0; else $cacheTime = 1800; CacheService::set($cacheName, $result, $cacheTime); } $this->assign([ 'order' => $order, 'express' => $result ]); return $this->fetch(); } /** * 修改配送信息 * @param $id * @return mixed|\think\response\Json|void */ public function distribution($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); $this->assign([ 'title' => '配送信息', 'rules' => $this->readDistribution($id)->getContent(), 'action' => Url::buildUrl('updateDistribution', array('id' => $id)) ]); return $this->fetch('public/common_form'); } public function readDistribution($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); if ($product['delivery_type'] == 'send') { Form::text('delivery_name', '送货人姓名', $product->getData('delivery_name')); Form::text('delivery_id', '送货人电话', $product->getData('delivery_id'))->number(); } else if ($product['delivery_type'] == 'express') { Form::select('delivery_name', '快递公司', function () { $list = Express::where('is_show', 1)->column('name', 'id'); $menus = []; foreach ($list as $k => $v) { $menus[] = ['value' => $v, 'label' => $v]; } return $menus; }, $product->getData('delivery_name'))->filterable(); Form::text('delivery_id', '快递单号', $product->getData('delivery_id')); } return Form::builder(); } public function updateDistribution($id) { $data = Util::postMore([ 'delivery_name', 'delivery_id', ]); if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); if ($product['delivery_type'] == 'send') { if (!$data['delivery_name']) return Json::fail('请输入送货人姓名'); if (!(int)$data['delivery_id']) return Json::fail('请输入送货人电话号码'); else if (!preg_match("/^1[3456789]{1}\d{9}$/", $data['delivery_id'])) return Json::fail('请输入正确的送货人电话号码'); } else if ($product['delivery_type'] == 'express') { if (!$data['delivery_name']) return Json::fail('请选择快递公司'); if (!$data['delivery_id']) return Json::fail('请输入快递单号'); } StoreOrderModel::edit($data, $id); event('StoreProductOrderDistributionAfter', [$data, $id]); StoreOrderStatus::setStatus($id, 'distribution', '修改发货信息为' . $data['delivery_name'] . '号' . $data['delivery_id']); return Json::successful('修改成功!'); } /** * 修改退款状态 * @param $id * @return mixed|\think\response\Json|void */ public function refund_n($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); $this->assign([ 'title' => '退款', 'rules' => $this->readRefundN($id)->getContent(), 'action' => Url::buildUrl('updateRefundN', array('id' => $id)) ]); return $this->fetch('public/common_form'); } public function readRefundN($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); Form::text('order_id', '退款单号', $product->getData('order_id'))->readonly(); Form::textarea('refund_reason', '退款原因'); return Form::builder(); } public function updateRefundN($id) { $data = Util::postMore([ 'refund_reason', ]); if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); if (!$data['refund_reason']) return Json::fail('请输入退款原因'); $data['refund_status'] = 0; StoreOrderModel::edit($data, $id); event('StoreProductOrderRefundNAfter', [$data['refund_reason'], $id]); StoreOrderStatus::setStatus($id, 'refund_n', '不退款原因:' . $data['refund_reason']); return Json::successful('修改成功!'); } /** * 立即支付 * @param $id */ public function offline($id) { $res = StoreOrderModel::updateOffline($id); if ($res) { event('StoreProductOrderOffline', [$id]); StoreOrderStatus::setStatus($id, 'offline', '线下付款'); return Json::successful('修改成功!'); } else { return Json::fail(StoreOrderModel::getErrorInfo('修改失败!')); } } /** * 修改积分和金额 * @param $id * @return mixed|\think\response\Json|void */ public function integral_back($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); if ($product['paid'] == 1) { $this->assign([ 'title' => '退积分', 'rules' => $this->readIntegralBack($id)->getContent(), 'action' => Url::buildUrl('updateIntegralBack', array('id' => $id)) ]); } else { return Json::fail('参数错误!'); } return $this->fetch('public/common_form'); } public function readIntegralBack($id) { if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); Form::text('order_id', '退积分单号', $product->getData('order_id'))->readonly(); Form::number('back_integral', '退积分')->min(0); return Form::builder(); } public function updateIntegralBack($id) { $data = Util::postMore([ 'back_integral', ]); if (!$id) return $this->failed('数据不存在'); $product = StoreOrderModel::get($id); if (!$product) return Json::fail('数据不存在!'); if ($data['back_integral'] <= 0) return Json::fail('请输入积分'); if ($product['use_integral'] == $product['back_integral']) return Json::fail('已退完积分!不能再积分了'); $back_integral = $data['back_integral']; $data['back_integral'] = bcadd($data['back_integral'], $product['back_integral'], 2); $bj = bccomp((float)$product['use_integral'], (float)$data['back_integral'], 2); if ($bj < 0) return Json::fail('退积分大于支付积分,请修改退积分'); BaseModel::beginTrans(); $integral = User::where('uid', product['uid'])->value('integral'); $res1 = User::bcInc($product['uid'], 'integral', $back_integral, 'uid'); $res2 = UserBill::income('商品退积分', $product['uid'], 'integral', 'pay_product_integral_back', $back_integral, $product['id'], bcadd($integral, $back_integral, 2), '订单退积分' . floatval($back_integral) . '积分到用户积分'); try { OrderRepository::storeOrderIntegralBack($product, $back_integral); } catch (\Exception $e) { BaseModel::rollbackTrans(); return Json::fail($e->getMessage()); } $res = $res1 && $res2; BaseModel::checkTrans($res); if (!$res) return Json::fail('退积分失败!'); StoreOrderModel::edit($data, $id); StoreOrderStatus::setStatus($id, 'integral_back', '商品退积分:' . $data['back_integral']); return Json::successful('退积分成功!'); } public function remark() { $data = Util::postMore(['id', 'remark']); if (!$data['id']) return Json::fail('参数错误!'); if ($data['remark'] == '') return Json::fail('请输入要备注的内容!'); $id = $data['id']; unset($data['id']); StoreOrderModel::edit($data, $id); return Json::successful('备注成功!'); } public function order_status($oid) { if (!$oid) return $this->failed('数据不存在'); $this->assign(StoreOrderStatus::systemPage($oid)); return $this->fetch(); } }