94 lines
2.8 KiB
PHP
94 lines
2.8 KiB
PHP
<?php
|
|
/**
|
|
* @link http://www.yiiframework.com/
|
|
* @copyright Copyright (c) 2008 Yii Software LLC
|
|
* @license http://www.yiiframework.com/license/
|
|
*/
|
|
|
|
namespace app\commands;
|
|
|
|
use app\components\YopointApi;
|
|
use app\models\BallCart;
|
|
use app\models\BallMark;
|
|
use app\models\Order;
|
|
use app\models\YopointNotify;
|
|
use app\modules\api\components\Mqtt;
|
|
use yii\console\Controller;
|
|
use yii\console\ExitCode;
|
|
use \PhpMqtt\Client\MQTTClient;
|
|
use \PhpMqtt\Client\ConnectionSettings;
|
|
use app\models\Store;
|
|
|
|
/**
|
|
* This command echoes the first argument that you have entered.
|
|
*
|
|
* This command is provided as an example for you to learn how to create console commands.
|
|
*
|
|
* @author Qiang Xue <qiang.xue@gmail.com>
|
|
* @since 2.0
|
|
*/
|
|
class Script5minController extends Controller
|
|
{
|
|
/**
|
|
* This command echoes what you have entered as the message.
|
|
* @param string $message the message to be echoed.
|
|
* @return int Exit code
|
|
*/
|
|
public function actionIndex()
|
|
{
|
|
$redis_name = "cxaibc:console:script5min_lock";
|
|
try {
|
|
$get = \Yii::$app->redis->setnx($redis_name,1);
|
|
if(empty($get)){
|
|
$ttl = \Yii::$app->redis->ttl($redis_name);
|
|
if($ttl === -1){
|
|
\Yii::$app->redis->expire($redis_name,60);
|
|
}
|
|
var_dump("5分钟脚本正在执行中");
|
|
exit();
|
|
}
|
|
\Yii::$app->redis->expire($redis_name,60*10);
|
|
// 执行体
|
|
$this->syncDeviceList();
|
|
$this->YopointPayCall();
|
|
// 结束执行
|
|
\Yii::$app->redis->del($redis_name);
|
|
}catch (\Exception $e){
|
|
\Yii::$app->redis->del($redis_name);
|
|
var_dump($e->getMessage());
|
|
}
|
|
echo "5分钟脚本";
|
|
exit();
|
|
}
|
|
|
|
// 同步
|
|
public function syncDeviceList(){
|
|
$obj = new YopointApi();
|
|
$res = $obj->syncDeviceList();
|
|
var_dump($res);
|
|
$res = $obj->syncStockList();
|
|
var_dump($res);
|
|
}
|
|
|
|
// 友朋支付回调
|
|
public function YopointPayCall(){
|
|
var_dump("友朋支付回调");
|
|
$select = Order::find()->andWhere([
|
|
'is_pay' => 1,
|
|
'plugin_sign' => 'goods',
|
|
'yopoint_status' => 1,
|
|
])->asArray()->all();
|
|
$obj = new YopointApi();
|
|
foreach ($select as $key=>$val){
|
|
// 查找友朋回调接口
|
|
$find_yopoint = YopointNotify::findOne([
|
|
'id' => $val['yopoint_notify_id'],
|
|
]);
|
|
if(!empty($find_yopoint->return_data)){
|
|
$json_de = json_decode($find_yopoint->return_data,true);
|
|
$obj->openDevCall($json_de['data']['NotifyUrl'],$json_de['data']['ReceiptNo'],$val['order_no'],1);
|
|
}
|
|
}
|
|
}
|
|
}
|