編集履歴

質問編集履歴

ファイルの追加

2019/05/17 10:10

投稿

ariiiiiga

スコア66

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -10,17 +10,67 @@
 *現在user_insert.phpでinsertに成功した時webpushできています。
+*DB名
-### 該当のソースコード
+users:ユーザー情報
+shop:店舗情報
+reserve:予約情報
+subscription:shop.webpush.phpの'endpoint'、'p256dh'、'auth'
+よろしくお願いします。
-```ここに言語名を入力
+```ここに言語を入力
-<user_insert.php>
+<user_submit.php>
+// データの追加
+<?php
+require  'autoload.php';
+require_once 'shop_webpush.php';
+error_reporting(E_ALL);
+ini_set("display_errors",1);
+try {
+  require("db_user_connect.php");
+  require("db_usershop_connect.php");
+  // セッションの開始
+  $count = $_SESSION['count'];
+  $time = $_SESSION['time'];
+  $comment = $_SESSION['comment'];
+  // 接続設定
+  // データの追加
-$sql = "INSERT INTO mydb(id,comment) VALUES('".$id."','".$comment."')";
+  $sql = "INSERT INTO reserve(reserve_shop_id,count,time,reserve_comment,reserve_tel) VALUES('".$shop_id."','".$count."','".$time."','".$comment."','".$tel."')";
   $stmt = $pdo -> prepare($sql);
@@ -28,13 +78,559 @@
   if($stmt) {
-      sendWebPush(); //Webpush call when insert success.
+      sendWebPush(); //Webpush call when reserve success.
   }
+} catch (PDOException $e) {
+  var_dump($e);
+  die();
+}
 ```
+```ここに言語を入力
+<autoload.php>
+// autoload.php @generated by Composer
+require_once __DIR__ . '/autoload_real.php';
+return ComposerAutoloaderInit5211635af155434412c2432ac36ae6df::getLoader();
+```
+```ここに言語を入力
+<?php
+<autoload_real.php>
+// autoload_real.php @generated by Composer
+class ComposerAutoloaderInit5211635af155434412c2432ac36ae6df
+{
+    private static $loader;
+    public static function loadClassLoader($class)
+    {
+        if ('Composer\Autoload\ClassLoader' === $class) {
+            require __DIR__ . '/ClassLoader.php';
+        }
+    }
+    public static function getLoader()
+    {
+        if (null !== self::$loader) {
+            return self::$loader;
+        }
+        spl_autoload_register(array('ComposerAutoloaderInit5211635af155434412c2432ac36ae6df', 'loadClassLoader'), true, true);
+        self::$loader = $loader = new \Composer\Autoload\ClassLoader();
+        spl_autoload_unregister(array('ComposerAutoloaderInit5211635af155434412c2432ac36ae6df', 'loadClassLoader'));
+        $useStaticLoader = PHP_VERSION_ID >= 50600 && !defined('HHVM_VERSION');
+        if ($useStaticLoader) {
+            require_once __DIR__ . '/autoload_static.php';
+            call_user_func(\Composer\Autoload\ComposerStaticInit5211635af155434412c2432ac36ae6df::getInitializer($loader));
+        } else {
+            $map = require __DIR__ . '/autoload_namespaces.php';
+            foreach ($map as $namespace => $path) {
+                $loader->set($namespace, $path);
+            }
+            $map = require __DIR__ . '/autoload_psr4.php';
+            foreach ($map as $namespace => $path) {
+                $loader->setPsr4($namespace, $path);
+            }
+            $classMap = require __DIR__ . '/autoload_classmap.php';
+            if ($classMap) {
+                $loader->addClassMap($classMap);
+            }
+        }
+        $loader->register(true);
+        if ($useStaticLoader) {
+            $includeFiles = Composer\Autoload\ComposerStaticInit5211635af155434412c2432ac36ae6df::$files;
+        } else {
+            $includeFiles = require __DIR__ . '/autoload_files.php';
+        }
+        foreach ($includeFiles as $fileIdentifier => $file) {
+            composerRequire5211635af155434412c2432ac36ae6df($fileIdentifier, $file);
+        }
+        return $loader;
+    }
+}
+function composerRequire5211635af155434412c2432ac36ae6df($fileIdentifier, $file)
+{
+    if (empty($GLOBALS['__composer_autoload_files'][$fileIdentifier])) {
+        require $file;
+        $GLOBALS['__composer_autoload_files'][$fileIdentifier] = true;
+    }
+}
+```
+```ここに言語を入力
+<shop_webpush.php>
+<?php
+use Minishlink\WebPush\WebPush;
+use Minishlink\WebPush\Subscription;
+function sendWebPush() {
+	try {
+		$pdo = new PDO('mysql:host=localhost;dbname=reserve;charset=utf8','root','');
+		$pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES,false);
+		$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+		$query = "SELECT * FROM subscription";
+		$stmt = $pdo->prepare($query);
+		$stmt->execute();
+		if (!$stmt) {
+		  print('ユーザークエリーが失敗しました。' . $pdo->error);
+		  $pdo->close();
+		  exit();
+		}
+		$subscriptions = array();
+		while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
+		  $subscription = new stdClass;
+		  $subscription->endpoint = $row['endpoint'];
+		  $subscription->p256dh = $row['p256dh'];
+		  $subscription->auth = $row['auth'];
+		  array_push($subscriptions, $subscription);
+		}
+		$auth = array(
+		    'VAPID' => array(
+		        'subject' => 'localhost',
+		        'publicKey' => 'BMGh50KuOyQcXHWGQrzM_HjuCmC9Z03lqkBae9WFppVolNgUd16na_-2QjMXnCPfHx-j6cFRGXMAigIfzGeiy3U',
+		        'privateKey' => '1xnCy4tn7smJS8bvT9B9DOvNwD8yNT5E2_1DhoP5zVM',
+		    ),
+		);
+		$payload = [
+		    'title' => '通知があります。',
+		    'body' => 'HelloWorld',
+		    'link' => 'http://localhost/reserve/reserve_shop/shop_home.php'
+		];
+		$webPush = new WebPush($auth);
+		foreach ($subscriptions as $subscription) {
+			$subscriptionCreated = Subscription::create([
+				'endpoint' => $subscription->endpoint,
+		        'keys' => [
+		              'p256dh' => $subscription->p256dh,
+		              'auth' => $subscription->auth
+		    	],
+	    	]);
+		    $webPush->sendNotification(
+		        $subscriptionCreated,
+		        json_encode($payload)
+	    	);
+		}
+		// $webPush->flush();
+	    foreach ($webPush->flush() as $report) {
+	    	//flush
+			$endpoint = $report->getRequest()->getUri()->__toString();
+			}
+		} catch (Exception $e) {
+		   var_dump($e);
+		}
+}
+?>
+```
+```ここに言語を入力
+<db_user_connect.php>
+<?php
+  session_start();
+  $pdo = new PDO('mysql:host=localhost;dbname=reserve;charset=utf8','root','',);
+  $pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES,false);
+  $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+  if(!isset($_SESSION['user'])) {
+    header("Location: user_index.php");
+  }
+  // ①ユーザーIDからユーザー名を取り出す
+  $query = "SELECT * FROM users WHERE user_id=:user_id";
+  $result = $pdo->prepare($query);
+  $result->bindValue(':user_id', $_SESSION['user'], PDO::PARAM_INT);
+  $result->execute();
+  // ユーザー情報の取り出し
+  while ($row = $result->fetch(PDO::FETCH_ASSOC)) {
+    $user_name = $row['user_name'];
+    $user_id = $row['user_id'];
+    $tel = $row['tel'];
+  }
+```
+```ここに言語を入力
+<db_usershop_connect.php>
+<?php
+  // 渡されたidを受け取る
+  $shop_id = filter_input(INPUT_GET, 'shop_id', FILTER_SANITIZE_SPECIAL_CHARS);
+  // 受け取ったidからレコード取得sqlを生成
+  $sql = "SELECT * FROM shop WHERE shop_id = ".$shop_id;
+  //SQL文を実行する
+  $PostData = $pdo->query($sql);
+  //実行結果を配列で受け取る
+  $shop_result = $PostData->fetch( PDO::FETCH_ASSOC);
+  if (!$shop_result) {
+    print('shopクエリーが失敗しました。' . $pdo->error);
+    $pdo->close();
+    exit();
+  }
+  // ユーザー情報の取り出し
+  $shop_name = $shop_result['shop_name'];
+```
+```ここに言語を入力
+<save-subscription.php>
+<?php
+// データベースにSubscriptionを保存する。
+$data = json_decode(file_get_contents("php://input"));
+// make sure data is not empty
+if(
+    !empty($data->endpoint) &&
+    !empty($data->keys)
+){
+    // set product property values
+    $endpoint = $data->endpoint;
+    $auth = $data->keys->auth;
+    $p256dh = $data->keys->p256dh;
+    // 保存する
+    $query = "INSERT INTO
+                subscription
+            SET
+                endpoint=:endpoint, auth=:auth, p256dh=:p256dh";
+ 	//connect to DB
+ 	$pdo = new PDO('mysql:host=localhost;dbname=reserve;charset=utf8','root','');
+	$pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES,false);
+	$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+	// Save Subscription to DB to push
+	$subscription_stmt = $pdo->prepare($query);
+	$subscription_stmt->bindValue(':endpoint',$endpoint , PDO::PARAM_STR);
+	$subscription_stmt->bindValue(':auth', $auth, PDO::PARAM_STR);
+	$subscription_stmt->bindValue(':p256dh', $p256dh, PDO::PARAM_STR);
+	if($subscription_stmt->execute()) {
+		 // set response code - 201 created
+        http_response_code(201);
+        // tell the user
+        echo json_encode(array("message" => "Subscription was created."));
+	} else {
+		  // set response code - 503 service unavailable
+        http_response_code(503);
+        // tell the user
+        echo json_encode(array("message" => "Unable to create Subscription."));
+	}
+} else {
+    // set response code - 400 bad request
+    http_response_code(400);
+    // tell the user
+    echo json_encode(array("message" => "Unable to create Subscription. Data is incomplete."));
+}
+```
 ### 試したこと

実現したいことの変更

2019/05/17 10:10

投稿

ariiiiiga

スコア66

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -4,17 +4,11 @@
 店舗側が空き情報をサイト内で表示させ、ユーザーはログインした後にサイト内で予約が出来るという物です。
-ユーザー側のログイン後のページ（user_insert.php）で、予約に成功した場合webpush通知を店舗側のshop_home.phpで通知させたいのですがどのようにコードを作ればいいかわからなくなってしまいました。
+ユーザー側のログイン後のページ（user_insert.php）で、予約に成功した場合にshop_home.phpでsendWebPush();を実行する書き方を教えて頂きたいです。
 *現在user_insert.phpでinsertに成功した時webpushできています。
-わかる方よろしくお願いし致します。