<?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);



	}



}