<?php
/**
* Created by PhpStorm.
* User: lcz
* Date: 2018/4/17
* Time: 10:06
* 定时任务控制器
*/
namespace app\api\controller;
use app\common\controller\Weixin;
use app\common\model\Agent;
use app\common\model\CommissionRebate;
use app\common\model\CouponCollectRecord;
use app\common\model\OperatorSaleDetail;
use app\common\model\OrderGroup;
use app\common\model\Orderjd;
use app\common\model\OrderPdd;
use app\common\model\OrderTbk;
use app\common\model\SettingTime;
use think\Controller;
use think\Db;
use think\Request;
class Task extends Controller{
/**
* 检查超时付款订单
*/
public function checkTimeOutOrder(){
$settingModel = new SettingTime();
$setting = $settingModel
->where(['type' => $settingModel::PAY_ORDER_TIME])
->select();
$log = '============='.date('Y-m-d H:i:s').'=========='."\r\n";
if(!$setting){
$log .= '没有超时时间设置'."\r\n";
die($log);
}
foreach($setting as $v) {
//转换成秒
$time = $v['days']*24*3600+$v['hour']*3600+$v['minute']*60+$v['second'];
if($time <= 0){
$log .= '商家设置时间为0'."\r\n";
continue;
}
$orderModel = new \app\common\model\Order();
$map['create_time'] = ['lt', time()-$time];
$map['order_status'] = $orderModel::STATUS_WAIT_PAYMENT;
$res = $orderModel->save([
'order_status' => $orderModel::STATUS_CLOSE,
'close_type' => $orderModel::CLOSE_TYPE_TIMEOUT,
],$map);
if($res !== false) {
$log .= '商家处理成功，处理数量【'.$res.'】条'."\r\n";
} else {
$log .= "商家处理出错\r\n";
}
}
die($log);
}
/**
* 订单超时签收
*/
public function signOrder(){
$settingModel = new SettingTime();
$setting = $settingModel
->where(['type' => $settingModel::SIGN_ORDER_TIME])
->select();
$log = '============='.date('Y-m-d H:i:s').'=========='."\r\n";
if(!$setting){
$log .= '没有超时时间设置'."\r\n";
die($log);
}
foreach($setting as $v) {
//转换成秒
$time = $v['days']*24*3600+$v['hour']*3600+$v['minute']*60+$v['second'];
if($time <= 0){
$log .= '商家设置时间为0'."\r\n";
continue;
}
$orderModel = new \app\common\model\Order();
$map['shipping_time'] = ['lt', time()-$time];
$map['order_status'] = $orderModel::STATUS_WAIT_SIGN;
//更改订单状态及收货时间
$res = $orderModel->save([
'order_status' => $orderModel::STATUS_SIGN,
'confirm_time' => time(),
],$map);
//如果签收签单后有其它操作，记得开户事务
if($res !== false) {
$log .= '商家处理成功，处理数量【'.$res.'】条'."\r\n";
} else {
$log .= '商家'."处理出错\r\n";
}
}
die($log);
}
/**
* 统计用户，每天3点统计
*/
public function countUser(){
$model = new \app\common\model\User();
$endTime = strtotime(date('Y-m-d 00:00:00'));
$beginTime = strtotime('-1 days', $endTime);
$all = $model->where(['jointime' => ['lt', $endTime]])
->field('id, count(id) as all_number')
->select();
if($all) {
$where['jointime'] = [
['egt', $beginTime],
['lt', $endTime]
];
$new = $model->where($where)
->field('id, count(id) as new_number')
->select();
foreach($all as $v) {
$datas[] = [
'time' => $beginTime,
'all' => $v['all_number'],
'new' => isset($new[$v['merid']])?$new[$v['merid']]:0,
];
}
$res = Db::name('countUser')->insertAll($datas);
if($res) {
echo date('Y-m-d H:i:s', $beginTime).'统计用户完成'."\r\n";
} else {
echo date('Y-m-d H:i:s', $beginTime).'统计用户出错'."\r\n";
}
}
}
//统计订单，每天3点05分执行
public function countOrder(){
$model = new \app\common\model\Order();
$merids = $model->group('merid')->column('merid','id');
foreach($merids as $merid) {
$all = $model->where(['merid' => $merid])->count();
$endTime = strtotime(date('Y-m-d 00:00:00'));
$beginTime = strtotime('-1 days', $endTime);
$where['merid'] = $merid;
$where['jointime'] = [
['egt', $beginTime],
['lt', $endTime]
];
$where = [['egt', $beginTime], ['lt', $endTime]];
$new = $model
->where(['create_time' => $where, 'merid' => $merid])
->count();
$pay = $model
->where(['pay_time' =>$where, 'merid' => $merid])
->count();
$shipping = $model
->where(['shipping_time' => $where, 'merid' => $merid])
->count();
$cofirm = $model
->where(['confirm_time' => $where, 'merid' => $merid])
->count();
$res = Db::name('countOrder')->insert([
'time' => $beginTime,
'all' => $all,
'new' => $new,
'pay' => $pay,
'shipping' => $shipping,
'cofirm' => $cofirm,
'merid' => $merid
]);
if($res) {
echo date('Y-m-d H:i:s', $beginTime).'商户'.$merid.'统计订单完成'."\r\n";
} else {
echo date('Y-m-d H:i:s', $beginTime).'商户'.$merid.'统计订单出错'."\r\n";
}
}
}
/**
* 发送微信发货提醒，10分钟一次
*/
public function sendShipTemplate(){
$orderModel = new \app\common\model\Order();
$orders = Db::name('order')->alias('o')
->join('shipping s', 'o.shipping_id = s.id', 'left')
->join('orderAddress oa', 'oa.order_id = o.id', 'left')
->join('area pa', 'oa.province_id = pa.id', 'left')
->join('area ca', 'oa.city_id = ca.id', 'left')
->join('area aa', 'oa.area_id = aa.id', 'left')
->join('weixinInfo w', 'o.user_id = w.user_id', 'left')
->join('batchOrder bo', 'o.id = bo.order_ids', 'left')
->where([
'o.order_status' => $orderModel::STATUS_WAIT_SIGN,
'o.send_template_status' => 0,
'bo.prepay_id' => ['neq', ''],
'w.openid' => ['neq', '']
])
->field('o.id, o.order_no, o.shipping_code, s.name as shipping_name, pa.areaname as province_name, ca.areaname as city_name, aa.areaname as area_name, oa.address, oa.recipients, oa.mobile, w.openid, bo.prepay_id')
->select();
$ids = [];
if($orders) {
$obj = new Weixin();
foreach($orders as $order) {
$goods = Db::name('orderGoods')
->where(['order_id' => $order['id']])
->column('goods_name', 'id');
$goodsName = implode(',', $goods);
$address = $order['province_name'].$order['city_name'].$order['area_name'].$order['address'].' '.$order['recipients'].' '.$order['mobile'];
$data = [
'keyword1' => ['value' => $goodsName], //物品名称
'keyword2' => ['value' => $order['order_no']], //订单号
'keyword3' => ['value' => $address], //收货地址
'keyword4' => ['value' => $order['shipping_code']], //物流单号
'keyword5' => ['value' => $order['shipping_name']], //物流公司
];
$res = $obj->sendTemplate($order['openid'],'o2Yla366l71AoQK3KS3L7U5_Jw1yT_xpjj-ls1UEusI', $order['prepay_id'], $data, 'pages/order/detail/index?order_id='.$order['id']);
if($res) {
$ids[] = $order['id'];
}
}
}
if($ids) {
Db::name('order')->where(['id' => ['in', $ids]])->update(['send_template_status' => 1]);
}
}
/**
* 查询拼多多推广订单
* @throws \think\Exception
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\PDOException
*/
public function queryPddOrder(){
header('Content-type:text/html;charset=utf8');
$model = new \app\common\model\Pdd();
$startTime = strtotime(date('Y-m-d 00:00:00', strtotime('-1 days')));
$endTime = strtotime(date('Y-m-d 00:00:00'));
// $endTime = time();
// $startTime = strtotime('2019-01-21 00:00:00');
// $endTime = strtotime('2019-01-22 00:00:00');
$page = 1;
$pageNumber = 100;
$res = $model->orderListIncrementGet($startTime, $endTime, $page);
$str = '============'.date('Y-m-d H:i:s').'================'.PHP_EOL;
if(!isset($res['order_list_get_response'])){
die($str.'请求出错'.$res['error_response']['error_msg']);
}
if(isset($res['order_list_get_response']['order_list'])) {
//查询到的订单列表
$orders = $res['order_list_get_response']['order_list'];
if($orders){
$orderTable = Db::name('orderPdd');
$orderModel = new OrderPdd();
$config = Db::name('commissionRebate')
->where(['rebate_type' => CommissionRebate::REBATE_TYPE_PDD])
->group('merid')
->select();
$configs = [];
if($config) {
foreach($config as $v) {
$configs[$v['merid']] = $v;
}
unset($config);
}
foreach($orders as $order) {
$orderSn = $order['order_sn'];
$custom = $order['custom_parameters'];
//从自定义参数中切割出用户和商户
$arr = explode('_', $custom);
$order['user_id'] = $arr[0];
$order['merid'] = isset($arr[1]) ? $arr[1] : 888;
//查找是否已经添加了这个订单
$row = $orderTable
->where(['order_sn' => $orderSn])
->find();
if($row) {
//拼多多已返利，系统状态为待结算，更改为待返利
if($order['order_status'] == 5 && $row['status'] == OrderPdd::STATUS_N){
$order['status'] = OrderPdd::STATUS_W;
}
$res = $orderTable->where(['order_sn' => $orderSn])->update($order);
if($res !== false) {
$str .= $row['id'].'更新成功'.PHP_EOL;
} else {
$str .= $row['id'].'更新出错'.PHP_EOL;
}
} else {
//没有添加过订单
if($order['order_status'] == 5){
$order['status'] = OrderPdd::STATUS_W;
}
$rule = isset($configs[$order['merid']]) ? $configs[$order['merid']] : [];
$res = $orderModel->addRow($order, $rule);
if($res) {
$str .= $order['order_sn'].'添加成功'.PHP_EOL;
} else {
$str .= $order['order_sn'].'添加出错'.PHP_EOL;
}
}
}
}
}
echo $str;
}
/**
* 拼多多返利
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\PDOException
*/
public function pddRebate(){
header('Content-type:text/html; charset=utf8');
$model = new OrderPdd();
$orders = Db::name('orderPdd')
->where(['status' => $model::STATUS_W])
->select();
$str = '============'.date('Y-m-d H:i:s').'================'.PHP_EOL;
if(!$orders) {
die($str . '没有需要结算的订单'.PHP_EOL);
}
foreach($orders as $order) {
$res = $model->rebate($order);
if($res) {
$str .= $order['id'] . "返利成功\r\n";
} else {
$str .= $order['id'] . "返利出错【{$model->getError()}】\r\n";
}
}
echo $str;
}
/**
* 清除7天前的日志
*/
public function clearLog(){
$apiLogPath = RUNTIME_PATH.'apiLog';
$arr_file = array();
readDirFile($arr_file, $apiLogPath);
if($arr_file) {
$startTime = strtotime('-1 weeks');
foreach($arr_file as $file) {
if(filemtime($file) < $startTime) {
$res = unlink($file);
if($res) {
echo $file.'删除成功<br>';
} else {
echo $file.'删除出错<br>';
}
}
}
}
}
/**
* 运营商团队业绩统计，每月一号凌晨统计
*/
public function operatorSaleCount (){
//开始时间，上个月的1号0点
$begin_time = strtotime(date('Y-m-01 00:00:00', strtotime('-1 months')));
//结束时间，这个月的1号0点
$end_time = strtotime(date('Y-m-01 00:00:00'));
$detailModel = new OperatorSaleDetail();
$where['status'] = $detailModel::STATUS_W;
$where['create_time'] = [
['egt', $begin_time],
['lt', $end_time]
];
//计算自己的销量
$selfRows = Db::name('operatorSaleDetail')
->where(['type' => $detailModel::TYPE_SELF])
->group('user_id')
->column('sum(amount)', 'user_id');
//计算下级带来的销量
$sonRows = Db::name('operatorSaleDetail')
->where(['type' => $detailModel::TYPE_SON])
->group('user_id')
->column('sum(amount)', 'user_id');
$datas = [];
if($selfRows) {
foreach($selfRows as $k => $v) {
$datas[$k] = [
'self' => $v,
'son' => 0,
];
}
}
if($sonRows) {
foreach($sonRows as $sk => $sv) {
if(isset($datas[$sk])) {
$datas[$sk]['son'] = $sv;
} else {
$datas[$sk] = [
'self' => 0,
'son' => $sv
];
}
}
}
if($datas) {
$agents = [];
foreach ($datas as $key => $value) {
//总销量金额
$totalAmount = $value['self'] + $value['son'];
//计算自己领取比例
$proportion = $detailModel->getProportion($totalAmount);
//计算自己领取的部分
$selfAmount = $value['self']*$proportion;
$agents[$key] = [
'user_id' => $key,
'time' => $begin_time,
// 'amount' => $totalAmount,
'self_sale' => $value['self'],
'sons_sale' => $value['son'],
'self_profit' => $selfAmount,
'sons_profit' => 0,
'update_time' => time(),
'proportion' => $proportion
];
}
foreach($agents as $ak => $agent) {
if($agent['proportion'] < 0.15) {
//查找用户信息
$user = Db::name('user')->where(['id' => $agent['user_id']])->field('id,parent_path')->find();
if($user['parent_path']) {
$pids = explode(',', $user['parent_path']);
//查找上级推荐人中最靠近的运营商
$pAgent = Db::name('agent')->alias('a')
->join('user u', 'a.user_id = u.id', 'left')
->where(['u.id' => ['in',$pids], 'a.level' => Agent::LEVEL_3])
->order('u.id DESC')
->field('u.id')
->find();
if($pAgent) {
//下级的分红为上级的分红比例-下级的分红比例*下级的总销量
$sonAmount = ($agents[$pAgent['id']]['proportion']-$agent['proportion'])*($agent['self_sale'] + $agent['sons_sale']);
$agents[$pAgent['id']]['sons_profit'] += $sonAmount;
}
}
}
}
// dump($agents);
// die;
Db::startTrans();
try {
$datas = array_values($agents);
$res = Db::name('operatorSaleCount')->insertAll($datas);
if(!$res) {
throw new Exception('添加出错');
}
Db::commit();
echo 'OK';
} catch (Exception $e) {
Db::rollback();
echo $e->getMessage();
}
}
}
/**
* 检查拼团订单，10分钟一次
*/
public function checkGroupOrder() {
$model = new OrderGroup();
$res = $model->checkGroupOrder();
echo date('Y-m-d H:i:s')."\r\n".$model->getError()."\r\n";
}
/**
* 淘宝客返利, 更改淘宝订单状态，更改返利记录状态，加钱
*/
public function tbkRebate(){
header('Content-type:text/html; charset=utf8');
$model = new OrderTbk();
$orders = Db::name('orderTbk')
->where(['status' => $model::STATUS_S])
->field('id, user_id, merid, record_id, auctionId, createTime, feeString, taobaoTradeParentId')
->select();
$str = '============'.date('Y-m-d H:i:s').'================'.PHP_EOL;
if(!$orders) {
die($str . '没有需要结算的订单'.PHP_EOL);
}
$str = '';
foreach($orders as $order) {
$str .= $model->rebate($order).PHP_EOL;
}
echo $str;
}
/**
* 淘宝客订单匹配用户,更改领取记录状态，添加待返利记录
*/
public function tbkPregUser(){
header('Content-type:text/html; charset=utf8');
$model = new OrderTbk();
//查找待匹配用户的订单
$orders = Db::name('orderTbk')
->where(['status' => $model::STATUS_P])
->field('id, auctionId, createTime, feeString, taobaoTradeParentId')
->select();
$str = '============'.date('Y-m-d H:i:s').'================'.PHP_EOL;
if(!$orders) {
die($str . '没有需要匹配的订单'.PHP_EOL);
}
//查找返利配置
$config = Db::name('commissionRebate')
->where(['rebate_type' => CommissionRebate::REBATE_TYPE_TBK])
->group('merid')
->select();
if(!$config) {
die($str . '没有配置返利设置'.PHP_EOL);
}
//转成商户号为下标的数组
$configs = [];
foreach($config as $v) {
$configs[$v['merid']] = $v;
}
unset($config);
$str = '';
$recordModel = new CouponCollectRecord();
//需求返利的数据
$rebateOrder = [];
foreach($orders as $order) {
//查找领取类型为淘宝客，状态为待匹配的，商品ID和订单ID相同的记录
$records = Db::name('couponCollectRecord')
->where([
'type' => $recordModel::TYPE_TBK,
'status' => $recordModel::STATUS_N,
'goods_id' => $order['auctionId']])
->field('id as record_id, merid, user_id')
->select();
if(!$records || count($records) > 1) {
//没有记录或记录数量 大于1，更改状态为异常
$orderRes = Db::name('orderTbk')
->where(['id' => $order['id']])
->update([
'status' => $model::STATUS_N,
]);
if(!$orderRes) {
$str .= $order['id'].'更改状态为匹配失败出错'.PHP_EOL;
}
} else {
//商户号
$merid = $records[0]['merid'];
$data = array_merge($order, $records[0]);
$rule = isset($configs[$merid]) ? $configs[$merid] : [];
$data['rule'] = $rule;
$rebateOrder[] = array_merge($order, $data);
}
}
//有要返利的数据，去添加返利记录
if($rebateOrder) {
foreach ($rebateOrder as $order) {
$str .= $model->changeStauts($order).PHP_EOL;
}
}
echo $str;
}
/**
* 查询京东新订单，每分钟一次
* @param int $page
*/
public function queryJdNewOrder($page = 1){
header('Content-type:text/html;charset=utf8');
$obj = new \app\common\controller\Jd();
$time = date('YmdHi', time()-60);
$res = $obj->orderQuery(1, $time, $page);
if(!isset($res['jd_union_open_order_query_response']['result'])) {
die('查询京东新订单出错'.PHP_EOL);
}
$str = date('Y-m-d H:i:s').PHP_EOL;
$res = json_decode($res['jd_union_open_order_query_response']['result'], true);
$resData = isset($res['data'])?$res['data']:[];
if($resData) {
$str .= $obj->operateOrder($resData);
} else {
die($str.'没有新订单'.PHP_EOL);
}
if($res['hasMore']) {
$this->queryJdOrder($page++);
}
die($str);
}
/**查询京东结算订单，每分钟一次
* @param int $page
*/
public function queryJdOverOrder($page = 1){
header('Content-type:text/html;charset=utf8');
$obj = new \app\common\controller\Jd();
$time = date('YmdHi', time()-60);
// $time= '201812251531';
$res = $obj->orderQuery(2, $time, $page);
if(!isset($res['jd_union_open_order_query_response']['result'])) {
die('查询京东结算订单出错'.PHP_EOL);
}
$str = date('Y-m-d H:i:s').PHP_EOL;
$res = json_decode($res['jd_union_open_order_query_response']['result'], true);
$str .= var_export($res, true);
$resData = isset($res['data'])?$res['data']:[];
if($resData) {
$str .= $obj->operateOrder($resData);
} else {
die($str.'没有新结算订单'.PHP_EOL);
}
if($res['hasMore']) {
$this->queryJdOrder($page++);
}
die($str);
}
/**
* 京东返利
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\PDOException
*/
public function jdRebate(){
header('Content-type:text/html; charset=utf8');
$model = new Orderjd();
$orders = Db::name('orderJd')
->where(['status' => $model::STATUS_R])
->select();
$str = '============'.date('Y-m-d H:i:s').'================'.PHP_EOL;
if(!$orders) {
die($str . '没有需要结算的订单'.PHP_EOL);
}
foreach($orders as $order) {
$res = $model->rebate($order);
if($res) {
$str .= $order['id'] . "返利成功\r\n";
} else {
$str .= $order['id'] . "返利出错【{$model->getError()}】\r\n";
}
}
echo $str;
}
}
