github/dootask
1
0
Fork 0
mirror of https://github.com/kuaifan/dootask.git synced 2026-01-12 17:08:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: 上班打开每日开心/下班打卡心灵鸡汤

Browse Source
This commit is contained in:
kuaifan 2023-02-01 12:13:25 +08:00
parent fff929d2b8
commit 7109eb0238
5 changed files with 90 additions and 65 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
.env.docker
View File

@ -53,6 +53,9 @@ PUSHER_APP_KEY=
PUSHER_APP_SECRET=
PUSHER_APP_CLUSTER=mt1
JUKE_KEY_JOKE=
JUKE_KEY_SOUP=
MIX_PUSHER_APP_KEY="${PUSHER_APP_KEY}"
MIX_PUSHER_APP_CLUSTER="${PUSHER_APP_CLUSTER}"

24
app/Http/Controllers/Api/PublicController.php
View File

@ -129,17 +129,19 @@ class PublicController extends AbstractController
}
//
if ($checkins && $botUser = User::botGetOrCreate('check-in')) {
$getJoke = function() {
$jokes = Base::json2array(Cache::get("JokeTask:rands"));
if ($jokes) {
$jokev = $jokes[array_rand($jokes)];
if ($jokev) {
return $jokev;
$getJokeSoup = function($type) {
$pre = $type == "up" ? "每日开心：" : "心灵鸡汤：";
$key = $type == "up" ? "JokeSoupTask:jokes" : "JokeSoupTask:soups";
$array = Base::json2array(Cache::get($key));
if ($array) {
$item = $array[array_rand($array)];
if ($item) {
return $pre . $item;
}
}
return null;
};
$sendMsg = function($type, UserCheckinMac $checkin) use ($getJoke, $botUser, $nowDate) {
$sendMsg = function($type, UserCheckinMac $checkin) use ($getJokeSoup, $botUser, $nowDate) {
$cacheKey = "Checkin::sendMsg-{$nowDate}-{$type}:" . $checkin->userid;
if (Cache::get($cacheKey) === "yes") {
return;
@ -151,10 +153,10 @@ class PublicController extends AbstractController
$hi = date("H:i");
$pre = $type == "up" ? "上班" : "下班";
$remark = $checkin->remark ? " ({$checkin->remark})": "";
$text = "<p>{$pre}打卡成功，打卡时间: {$hi} {$remark}</p>";
$joke = $getJoke();
if ($joke) {
$text = "<pre>{$text}<p>----------</p><p>每日开心：{$joke}。</p></pre>";
$text = "<p>{$pre}打卡成功，打卡时间: {$hi}{$remark}</p>";
$suff = $getJokeSoup($type);
if ($suff) {
$text = "{$text}<p>----------</p><p>{$suff}</p>";
}
WebSocketDialogMsg::sendMsg(null, $dialog->id, 'text', ['text' => $text], $botUser->userid);
}

6
app/Http/Controllers/IndexController.php
View File

@ -10,7 +10,7 @@ use App\Tasks\AppPushTask;
use App\Tasks\AutoArchivedTask;
use App\Tasks\DeleteTmpTask;
use App\Tasks\EmailNoticeTask;
use App\Tasks\JokeTask;
use App\Tasks\JokeSoupTask;
use App\Tasks\LoopTask;
use Arr;
use Cache;
@ -191,8 +191,8 @@ class IndexController extends InvokeController
Task::deliver(new DeleteTmpTask('tmp', 24));
// 周期任务
Task::deliver(new LoopTask());
// 获取笑话
Task::deliver(new JokeTask());
// 获取笑话/心灵鸡汤
Task::deliver(new JokeSoupTask());
return "success";
}

71
app/Tasks/JokeSoupTask.php Normal file
View File

@ -0,0 +1,71 @@
<?php
namespace App\Tasks;
use App\Module\Base;
use App\Module\Ihttp;
use Cache;
use Carbon\Carbon;
@error_reporting(E_ALL & ~E_NOTICE & ~E_WARNING);
/**
* 获取笑话、心灵鸡汤
*
* 在.env添加笑话 JUKE_KEY_JOKE
* 在.env添加鸡汤 JUKE_KEY_SOUP
*
* 每日小时采集1次
*/
class JokeSoupTask extends AbstractTask
{
public function __construct()
{
parent::__construct();
}
public function start()
{
// 判断每小时执行一次
if (Cache::get("JokeSoupTask:YmdH") == date("YmdH")) {
return;
}
Cache::put("JokeSoupTask:YmdH", date("YmdH"), Carbon::now()->addDay());
//
$jokeKey = env("JUKE_KEY_JOKE");
if ($jokeKey) {
$array = Base::json2array(Cache::get("JokeSoupTask:jokes"));
$res = Ihttp::ihttp_get("http://v.juhe.cn/joke/randJoke.php?key=" . $jokeKey);
if (Base::isSuccess($res)) {
$data = Base::json2array($res['data']);
if ($data['reason'] === 'success') {
foreach ($data['result'] as $item) {
if ($text = trim($item['content'])) {
$array[] = $text;
}
}
}
}
Cache::forever("JokeSoupTask:jokes", Base::array2json(array_slice($array, -100)));
}
//
$soupKey = env("JUKE_KEY_SOUP");
if ($soupKey) {
$array = Base::json2array(Cache::get("JokeSoupTask:soups"));
$res = Ihttp::ihttp_get("https://apis.juhe.cn/fapig/soup/query?key=" . $soupKey);
if (Base::isSuccess($res)) {
$data = Base::json2array($res['data']);
if ($data['reason'] === 'success' && $text = trim($data['result']['text'])) {
$array[] = $text;
}
}
Cache::forever("JokeSoupTask:soups", Base::array2json(array_slice($array, -100)));
}
}
public function end()
{
}
}

51
app/Tasks/JokeTask.php
View File

@ -1,51 +0,0 @@
<?php
namespace App\Tasks;
use App\Module\Base;
use App\Module\Ihttp;
use Cache;
use Carbon\Carbon;
@error_reporting(E_ALL & ~E_NOTICE & ~E_WARNING);
/**
* 获取笑话大全
*
* 每日小时采集1次
*/
class JokeTask extends AbstractTask
{
public function __construct()
{
parent::__construct();
}
public function start()
{
if (Cache::get("JokeTask:lastYmdH") == date("YmdH")) {
return;
}
Cache::put("JokeTask:lastYmdH", date("YmdH"), Carbon::now()->addDay());
//
$array = [];
for ($i = 0; $i < 10; $i++) {
$res = Ihttp::ihttp_get("https://api.vvhan.com/api/joke?type=json"); // 备用 https://api.ghser.com/xiaohua?type=json
if (Base::isError($res)) {
return;
}
$data = Base::json2array($res['data']);
if ($data['success'] !== true) {
return;
}
$array[] = $data['joke'];
}
Cache::forever("JokeTask:rands", Base::array2json($array));
}
public function end()
{
}
}