-
Notifications
You must be signed in to change notification settings - Fork 0
/
function.php
215 lines (188 loc) · 10.7 KB
/
function.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
<?php
use \LINE\LINEBot\HTTPClient\CurlHTTPClient;
use \LINE\LINEBot;
use \LINE\LINEBot\MessageBuilder\TextMessageBuilder;
use LINE\LINEBot\MessageBuilder\MultiMessageBuilder;
use \LINE\LINEBot\Constant\HTTPHeader;
function take_env_var(){
$environment_json = file_get_contents("environment.json");
$environment = json_decode($environment_json);
return [$environment->channel_access_token,$environment->channel_secret];
}
function reply_for_Events($bot, $Events,$google_client){
$replytexts_json = file_get_contents("replytexts.json");
$replytexts = json_decode($replytexts_json);
foreach ($Events as $event) {
$type = $event->getType();
if ($type == 'message') {
if (preg_match('/[0-9]{6,6}/', $event->getText())) {
$user = ORM::for_table('user')->where("lineid",$event->getText())->find_one();
if ($user) {
$user->set('lineid', $event->getUserId());
$user->save();
$replyText_array = $replytexts->complete_register;
}
}else{
$user = ORM::for_table('user')->where("lineid",$event->getUserId())->find_one();
if ($user) {
$notice_time = ORM::for_table('notice_time')->where("user_id",$user->id)->where_null("time")->find_one();
$mecab = new MeCab_Tagger();
$words = $mecab->split($event->getText());
$today_flag = (in_array("予定", $words) && in_array("今日", $words)) || (in_array("予定", $words) && !in_array("明日", $words)) || in_array("今日", $words);
$tomorrow_flag = in_array("予定", $words) && in_array("明日", $words);
$today = new DateTime(date("Y/m/d 00:00:00"));
$start = new DateTime(date("Y/m/d 00:00:00"));
$end = new DateTime(date("Y/m/d 00:00:00"));
if ($today_flag) {
$end->modify('+1 day') ;
$replyText_array = [schedule($google_client,$start,$end)];
}elseif($tomorrow_flag){
$start->modify('+1 day') ;
$end->modify('+2 day') ;
$replyText_array = [schedule($google_client,$start,$end)];
}elseif(preg_match('/[0-9]{4,4}/', $event->getText())){
$format = "YmdHis";
$start = DateTime::createFromFormat($format, $today->format('Y').$event->getText()."000000");
if ($today > $start) $start->modify('+1 year');
$end = clone $start;
$end->modify('+1 day');
$replyText_array = [schedule($google_client,$start,$end)];
}elseif(in_array("設定", $words)){
if (!$notice_time) {
$notice_time = ORM::for_table('notice_time')->create();
$notice_time->set('user_id',$user->id);
$notice_time->save();
}
$notice_times = ORM::for_table('notice_time')->where("user_id",$user->id)->where_not_null("time")->find_many();
$replyText_array = [];
array_push($replyText_array,"予定通知時間を設定します。");
if ($notice_times) {
$replyText2 = "現在の設定は\n";
foreach ($notice_times as $time)$replyText2 .= ($time->today_or_tomorrow == 0 ? "当日":"翌日").$time->time."時\n";
$replyText2 .= "です。";
array_push($replyText_array, $replyText2);
}
$replyText3 ="当日or翌日のスケジュールを指定時間でお知らせします。当日、翌日に加えて0時から２３時までの時間を指定してください。";
$replyText4 = "例\n・当日の予定を朝８時に知りたいとき\n当日8\n・翌日の予定を夜９時に知りたいとき\n翌日21";
$replyText5 = "また、設定を消す場合は\n当日8削除\nなど、設定のあとに\"削除\"と入れてください。";
array_push($replyText_array, $replyText3,$replyText4,$replyText5);
}elseif((in_array("当日", $words)||in_array("翌日", $words)) && preg_match("/[0-9]{1,2}/", $event->getText(),$hour) && $notice_time && !in_array("削除", $words)){
$hour = $hour[0];
if (intval($hour)< 0 || intval($hour) >23) {
$replyText = "この時間は無効です。0から23の間で入力してください。";
}else{
$notice_time->set('time', $hour);
if (in_array("当日", $words)) $notice_time->set('today_or_tomorrow', 0);
elseif(in_array("翌日", $words)) $notice_time->set('today_or_tomorrow', 1);
$notice_time->save();
$replyText = "登録が完了しました。\n毎日".$notice_time->time."時に". ($notice_time->today_or_tomorrow == 0 ? "当日":"翌日")."の予定をお知らせします。";
}
$replyText_array = [$replyText];
}elseif((in_array("当日", $words)||in_array("翌日", $words)) && preg_match("/[0-9]{1,2}/", $event->getText(),$hour) && in_array("削除", $words)){
$notice_time_delete = ORM::for_table('notice_time')->where("user_id",$user->id)->where("time",$hour[0])->where("today_or_tomorrow",(in_array("当日", $words)? 0:1))->find_one();
if ($notice_time_delete->today_or_tomorrow == 0)$day_str = "当日";
else $day_str = "翌日";
$time = $notice_time_delete->time;
if ($notice_time_delete) {
$notice_time_delete->delete();
$replyText = "設定\"".$day_str.$time."時\"を削除しました。";
}else{
$replyText = "そのような設定はありません。";
}
$replyText_array = [$replyText];
}else {
$replyText_array = $replytexts->reply_else;
}
}else{
$replyText_array = ["まだ連携ができていません！\nこちらのurlをクリックしてgoogleアカウント認証をお願いします。\n"
.$google_client->createAuthUrl()];
}
}
if (isset($replyText_array)) reply_message($replyText_array, $bot,$event);
}elseif ($type == 'follow') {
$replyurl = "登録ありがとうございます！\nこちらのurlをクリックしてgoogleアカウント認証をお願いします。\n"
.$google_client->createAuthUrl();
$reply6num = "認証後に表示される６桁の番号をトーク画面に入力してください。";
$replyText_array = [$replyurl,$reply6num];
reply_message($replyText_array, $bot, $event);
}elseif ($type == 'unfollow'){
$user = ORM::for_table('user')->where("lineid",$event->getUserId())->find_one();
$user->delete();
}
}
}
function schedule($client,$start,$end){
$client->getAccessToken();
$calendar = new Google_Service_Calendar($client);
// 今日の0時0分のUNIX TIMESTAMP
$today = new DateTime( date("Y/m/d 00:00:00") ) ;
if ($start == $today) {
$date_str = "今日";
}elseif ($start == strtotime( "+1 day" , $today )) {
$date_str = "明日";
}else{
$date_str = $start->format("m月d日");
}
$calendarId = 'primary';
$optParams = array(
'orderBy' => 'startTime',
'singleEvents' => true,
'timeMin' => $start->format('c'),
'timeMax' => $end->format('c'),
);
$event_list = $calendar->events->listEvents($calendarId, $optParams);
$return = null;
if (empty($event_list->getItems())) {
return $date_str."の予定はありません。";
}else{
$return = $date_str."の予定をお伝えします。\n".$date_str."の予定は\n";
foreach ($event_list->getItems() as $event) {
$start = $event->start->dateTime;
if (empty($start))$start = $event->start->date;
$end = $event->end->dateTime;
if (empty($end))$end = $event->end->date;
$return .= date("H:i",strtotime($start))."-".date("H:i",strtotime($end))." ".$event->getSummary()."\n";
}
$return .= "です。頑張っていきましょう！";
return $return;
}
}
function reply_message($replyText_array,$bot,$event){
$sendMessage = new MultiMessageBuilder();
foreach ($replyText_array as $replyText) {
$TextMessageBuilder = new TextMessageBuilder($replyText);
$sendMessage->add($TextMessageBuilder);
}
$bot->replyMessage($event->getReplyToken(), $sendMessage);
}
function push_message($replyText_array,$bot,$user){
$sendMessage = new MultiMessageBuilder();
foreach ($replyText_array as $replyText) {
$TextMessageBuilder = new TextMessageBuilder($replyText);
$sendMessage->add($TextMessageBuilder);
}
$bot->pushMessage($user->lineid, $sendMessage);
}
function client_init(){
$client = new Google_Client();
$client->setAuthConfig('client_secret.json');
$scopes = array(Google_Service_Calendar::CALENDAR_READONLY, Google_Service_Oauth2::USERINFO_PROFILE);
$client->addScope($scopes);
$client->setApprovalPrompt('force');
$client->setAccessType('offline');
$redirect_uri = 'http://' . $_SERVER['HTTP_HOST'] . $_SERVER['PHP_SELF'];
$client->setRedirectUri($redirect_uri);
return $client;
}
function DB_init(){
$db_json = file_get_contents("db_env.json");
$db = json_decode($db_json);
ORM::configure('mysql:host=localhost;dbname=gbutler');
ORM::configure('username', $db->username);
ORM::configure('password', $db->password);
ORM::configure('driver_options', [
PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8',
PDO::ATTR_EMULATE_PREPARES => false,
PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => true,
]);
}