q792602257/qlg.tsgz.moe
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
qlg.tsgz.moe/hyhproject/admin/model/CronJobs.php
root f0ef89dfbb Init Repo
2019-09-06 23:53:10 +08:00

1369 lines
15 KiB
PHP
Executable File
Raw Permalink Blame History

<?php
namespace wstmart\admin\model;
use think\Db;
/**
* ============================================================================
* 定时业务处理
*/
class CronJobs extends Base{
/**
* 管理员登录触发动作
*/
public function autoByAdmin(){
$this->autoCancelNoPay();
$this->autoReceive();
$this->autoAppraise();
$this->autoSendMsg();
}
/**
* 取消未支付订单
*/
public function autoCancelNoPay(){
$autoCancelNoPayDays = (int)WSTConf('CONF.autoCancelNoPayDays');
$autoCancelNoPayDays = ($autoCancelNoPayDays>0)?$autoCancelNoPayDays:6;
$lastDay = date("Y-m-d H:i:s",strtotime("-".$autoCancelNoPayDays." hours"));
$orders = Db::name('orders')->alias('o')->join('__SHOPS__ s','o.shopId=s.shopId','left')->where("o.createTime<'".$lastDay."' and o.orderStatus=-2 and o.dataFlag=1 and o.payType=1 and o.isPay=0")->field("o.orderId,o.orderNo,o.userId,o.shopId,o.useScore,s.userId shopUserId,orderCode")->select();
if(!empty($orders)){
$prefix = config('database.prefix');
$orderIds = [];
foreach ($orders as $okey => $order){
$orderIds[] = $order['orderId'];
}
Db::startTrans();
try{
//提前锁定订单
Db::name('orders')->where(['orderId'=>['in',$orderIds]])->update(['orderStatus'=>-1]);
foreach ($orders as $okey => $order){
$shopId = $order['shopId'];
//未付款状态则直接退回积分
if($order['useScore']>0){
$score = [];
$score['userId'] = $order['userId'];
$score['score'] = $order['useScore'];
$score['dataSrc'] = 1;
$score['dataId'] = $order['orderId'];
$score['dataRemarks'] = "取消交易订单【".$order['orderNo']."】，退回积分".$order['useScore']."个";
$score['scoreType'] = 1;
model('common/UserScores')->add($score);
}
$goods = Db::name('order_goods')->alias('og')->join('__GOODS__ g','og.goodsId=g.goodsId','inner')
->where('orderId',$order['orderId'])->field('og.*,g.isSpec')->select();
foreach ($goods as $k => $v){
//处理虚拟产品
if($v['goodsType']==1){
$extraJson = json_decode($v['extraJson'],true);
foreach ($extraJson as $ecard) {
Db::name('goods_virtuals')->where('id',$ecard['cardId'])->update(['orderId'=>0,'orderNo'=>'','isUse'=>0]);
}
$counts = Db::name('goods_virtuals')->where(['dataFlag'=>1,'goodsId'=>$v['goodsId'],'isUse'=>0])->count();
Db::name('goods')->where('goodsId',$v['goodsId'])->update(['goodsStock'=>$counts]);
}else{
//只有正常下单的才会修改库存的，其他的任何插件都不会修改库存
if($order['orderCode'] == 'order'){
//修改库存
if($v['isSpec']>0){
Db::name('goods_specs')->where('id',$v['goodsSpecId'])->setInc('specStock',$v['goodsNum']);
}
Db::name('goods')->where('goodsId',$v['goodsId'])->setInc('goodsStock',$v['goodsNum']);
//Db::name('goods')->where('goodsId',$v['goodsId'])->setDec('saleNum',$v['goodsNum']);//减少销量 mark 20180412
}
}
}
//新增订单日志
$logOrder = [];
$logOrder['orderId'] = $order['orderId'];
$logOrder['orderStatus'] = -1;
$logOrder['logContent'] = "订单长时间未支付，系统自动取消订单";
$logOrder['logUserId'] = $order['userId'];
$logOrder['logType'] = 0;
$logOrder['logTime'] = date('Y-m-d H:i:s');
Db::name('log_orders')->insert($logOrder);
//发送消息
$tpl = WSTMsgTemplates('ORDER_USER_PAY_TIMEOUT');
if( $tpl['tplContent']!='' && $tpl['status']=='1'){
$find = ['${ORDER_NO}'];
$replace = [$order['orderNo']];
//发送一条用户信息
WSTSendMsg($order['userId'],str_replace($find,$replace,$tpl['tplContent']),['from'=>1,'dataId'=>$order['orderId']]);
}
$tpl = WSTMsgTemplates('ORDER_SHOP_PAY_TIMEOUT');
if( $tpl['tplContent']!='' && $tpl['status']=='1'){
$find = ['${ORDER_NO}'];
$replace = [$order['orderNo']];
//发送一条商家信息
$msg = array();
$msg["shopId"] = $shopId;
$msg["tplCode"] = $tpl["tplCode"];
$msg["msgType"] = 1;
$msg["content"] = str_replace($find,$replace,$tpl['tplContent']) ;
$msg["msgJson"] = ['from'=>1,'dataId'=>$order['orderId']];
model("common/MessageQueues")->add($msg);
}
//微信消息
if((int)WSTConf('CONF.wxenabled')==1){
$params = [];
$params['ORDER_NO'] = $order['orderNo'];
WSTWxMessage(['CODE'=>'WX_ORDER_USER_PAY_TIMEOUT','userId'=>$order['userId'],'URL'=>Url('wechat/orders/sellerorder','',true,true),'params'=>$params]);
$msg = array();
$tplCode = "WX_ORDER_SHOP_PAY_TIMEOUT";
$msg["shopId"] = $shopId;
$msg["tplCode"] = $tplCode;
$msg["msgType"] = 4;
$msg["paramJson"] = ['CODE'=>$tplCode,'URL'=>Url('wechat/orders/index',['type'=>'abnormal'],true,true),'params'=>$params] ;
$msg["msgJson"] = "";
model("common/MessageQueues")->add($msg);
}
}
Db::commit();
return WSTReturn('操作成功',1);
}catch (\Exception $e) {
Db::rollback();errLog($e);
return WSTReturn('操作失败',-1);
}
}
return WSTReturn('操作成功',1);
}
/**
* 自动好评
*/
public function autoAppraise(){
$autoAppraiseDays = (int)WSTConf('CONF.autoAppraiseDays');
$autoAppraiseDays = ($autoAppraiseDays>0)?$autoAppraiseDays:7;//避免有些客户没有设置值
$lastDay = date("Y-m-d 00:00:00",strtotime("-".$autoAppraiseDays." days"));
$rs = model('orders')->where("receiveTime<'".$lastDay."' and orderStatus=2 and dataFlag=1 and isAppraise=0")->field("orderId,userId,orderScore,shopId,orderNo")->select();
if(!empty($rs)){
$prefix = config('database.prefix');
$orderIds = [];
foreach ($rs as $okey => $order){
$orderIds[] = $order->orderId;
}
Db::startTrans();
try{
//提前锁定订单
Db::name('orders')->where(['orderId'=>['in',$orderIds]])->update(['isAppraise'=>1,'isClosed'=>1]);
foreach ($rs as $okey => $order){;
//获取订单相关的商品
$ordergoods = Db::name('order_goods')->where('orderId',$order->orderId)->field('goodsId,orderId,goodsSpecId')->select();
foreach($ordergoods as $goods){
//增加订单评价
$data = [];
$data['userId'] = $order->userId;
$data['goodsSpecId'] = (int)$goods['goodsSpecId'];
$data['goodsId'] = $goods['goodsId'];
$data['shopId'] = $order->shopId;
$data['orderId'] = $goods['orderId'];
$data['goodsScore'] = 5;
$data['serviceScore'] = 5;
$data['timeScore']= 5;
$data['content'] = '自动好评';
$data['createTime'] = date('Y-m-d H:i:s');
Db::name('goods_appraises')->insert($data);
}
//增加商品评分
$updateSql = "update ".$prefix."goods_scores set
totalScore=totalScore+15,
goodsScore=goodsScore+5,
serviceScore=serviceScore+5,
timeScore=timeScore+5,
totalUsers=totalUsers+1,goodsUsers=goodsUsers+1,serviceUsers=serviceUsers+1,timeUsers=timeUsers+1
where goodsId=".$goods['goodsId'];
Db::execute($updateSql);
//增加商品评价数
Db::name('goods')->where('goodsId',$goods['goodsId'])->setInc('appraiseNum');
//增加店铺评分
$updateSql = "update ".$prefix."shop_scores set
totalScore=totalScore+15,
goodsScore=goodsScore+5,
serviceScore=serviceScore+5,
timeScore=timeScore+5,
totalUsers=totalUsers+1,goodsUsers=goodsUsers+1,serviceUsers=serviceUsers+1,timeUsers=timeUsers+1
where shopId=".$order->shopId;
Db::execute($updateSql);
// 查询该订单是否已经完成评价,修改orders表中的isAppraise
$ogRs = Db::name('order_goods')->alias('og')
->join('__GOODS_APPRAISES__ ga','og.orderId=ga.orderId and og.goodsId=ga.goodsId and og.goodsSpecId=ga.goodsSpecId','left')
->where('og.orderId',$order->orderId)->field('og.id,ga.id gid')->select();
$isFinish = true;
foreach ($ogRs as $vkey => $v){
if($v['id']>0 && $v['gid']==''){
$isFinish = false;
break;
}
}
//订单商品全部评价完则修改订单状态
if($isFinish){
if(WSTConf("CONF.isAppraisesScore")==1){
$appraisesScore = (int)WSTConf('CONF.appraisesScore');
if($appraisesScore>0){
//给用户增加积分
$score = [];
$score['userId'] = $order->userId;
$score['score'] = $appraisesScore;
$score['dataSrc'] = 1;
$score['dataId'] = $order->orderId;
$score['dataRemarks'] = "评价订单【".$order->orderNo."】获得积分".$appraisesScore."个";
$score['scoreType'] = 1;
$score['createTime'] = date('Y-m-d H:i:s');
Db::name('user_scores')->insert($score);
// 增加用户积分
model('Users')->where("userId=".$order->userId)->update([
'userScore'=>['exp','userScore+'.$appraisesScore],
'userTotalScore'=>['exp','userTotalScore+'.$appraisesScore]
]);
}
}
}
}
Db::commit();
return WSTReturn('操作成功',1);
}catch (\Exception $e) {
Db::rollback();errLog($e);
return WSTReturn('操作失败',-1);
}
}
return WSTReturn('操作成功',1);
}
/**
* 自动确认收货
*/
public function autoReceive(){
$autoReceiveDays = (int)WSTConf('CONF.autoReceiveDays');
$autoReceiveDays = ($autoReceiveDays>0)?$autoReceiveDays:10;//避免有些客户没有设置值
$lastDay = date("Y-m-d 00:00:00",strtotime("-".$autoReceiveDays." days"));
$rs= model('orders')->where("deliveryTime<'".$lastDay."' and orderStatus=1 and dataFlag=1")->field("orderId,orderNo,shopId,userId,shopId,orderScore,commissionFee")->select();
//dump($rs);
//循环是否有延时收获的
$now_time = time();
foreach($rs as $key=>$v){
$delay_time = Db::name('order_delay')->where(['orderId'=>$v['orderId']])->value('delayTime');
if($now_time < $delay_time){
unset($rs[$key]);
}
}
if(!empty($rs)){
$prefix = config('database.prefix');
Db::startTrans();
try{
foreach ($rs as $key => $order){
//结束订单状态
$order->receiveTime = date('Y-m-d 00:00:00');
$order->orderStatus = 2;
$rsStatus = $order->save();
if(false !== $rsStatus){
hook('afterUserReceive',['orderId'=>$order->orderId]);
if(WSTConf('CONF.statementType')==1){
//修改商家未计算订单数
$upSql = 'update '.$prefix.'shops set noSettledOrderNum=noSettledOrderNum+1,noSettledOrderFee=noSettledOrderFee-'.$order->commissionFee.' where shopId='.$order->shopId;
Db::execute($upSql);
}else{
//即时结算
model('common/Settlements')->speedySettlement($order->orderId);
}
//新增订单日志
$logOrder = [];
$logOrder['orderId'] = $order->orderId;
$logOrder['orderStatus'] = 2;
$logOrder['logContent'] = "系统自动确认收货";
$logOrder['logUserId'] = $order->userId;
$logOrder['logType'] = 0;
$logOrder['logTime'] = date('Y-m-d H:i:s');
Db::name('log_orders')->insert($logOrder);
//发送一条商家信息
$tpl = WSTMsgTemplates('ORDER_ATUO_RECEIVE');
if( $tpl['tplContent']!='' && $tpl['status']=='1'){
$find = ['${ORDER_NO}'];
$replace = [$order['orderNo']];
$msg = array();
$msg["shopId"] = $order->shopId;
$msg["tplCode"] = $tpl["tplCode"];
$msg["msgType"] = 1;
$msg["content"] = str_replace($find,$replace,$tpl['tplContent']) ;
$msg["msgJson"] = ['from'=>1,'dataId'=>$order->orderId];
model("common/MessageQueues")->add($msg);
}
//给用户增加积分
if(WSTConf("CONF.isOrderScore")==1){
$score = [];
$score['userId'] = $order->userId;
$score['score'] = $order->orderScore;
$score['dataSrc'] = 1;
$score['dataId'] = $order->orderId;
$score['dataRemarks'] = "交易订单【".$order->orderNo."】获得积分".$order->orderScore."个";
$score['scoreType'] = 1;
$score['createTime'] = date('Y-m-d H:i:s');
model('UserScores')->save($score);
// 增加用户积分
model('Users')->where("userId=".$order->userId)->setInc('userScore',$order->orderScore);
// 用户总积分
model('Users')->where("userId=".$order->userId)->setInc('userTotalScore',$order->orderScore);
}
}
}
Db::commit();
return WSTReturn('操作成功',1);
}catch (\Exception $e) {
Db::rollback();errLog($e);
return WSTReturn('操作失败',-1);
}
}
//echo 1;
return WSTReturn('操作成功',1);
}
public function autoSendMsg(){
$now = date("Y-m-d H:i:s");
$list = Db::name("message_queues")->where(["sendStatus"=>0])->limit(500)->select();
foreach ($list as $key => $msg) {
Db::startTrans();
try{
$msgParams = json_decode($msg["paramJson"],true);
if($msg["msgType"]==2){//短信消息
//门店暂无
}else if($msg["msgType"]==3){//邮件消息
//门店暂无
}else if($msg["msgType"]==4){//微信消息
WSTWxMessage($msgParams);
}
Db::name("message_queues")->where(["id"=>$msg["id"]])->update(["sendStatus"=>1,"sendTime"=>$now]);
Db::commit();
}catch (\Exception $e) {
Db::rollback();errLog($e);
return WSTReturn('操作失败',-1);
}
}
return WSTReturn('操作成功',1);
}
}
Reference in New Issue View Git Blame Copy Permalink