<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    package="net.wellbeing.bioinfo">

    <uses-permission android:name="android.permission.WAKE_LOCK" />
    <uses-permission android:name="android.permission.INTERNET"/>
    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"/>

    <application
        android:allowBackup="true"
        android:icon="@mipmap/wblogo"
        android:label="@string/app_name"
        android:roundIcon="@mipmap/ic_launcher_round"
        android:supportsRtl="true"
        android:theme="@style/AppTheme">
        <activity android:name=".MainActivity">
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />

                <category android:name="android.intent.category.LAUNCHER" />
            </intent-filter>
        </activity>
    </application>

</manifest>

<?xml version="1.0" encoding="utf-8"?>
<androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:app="http://schemas.android.com/apk/res-auto"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    tools:context=".MainActivity">

    <LinearLayout android:layout_height="match_parent" android:layout_width="match_parent" android:orientation="vertical">

        <TextView android:layout_height="wrap_content" android:layout_width="match_parent" android:textSize="24sp" android:text="Time" android:id="@+id/timeTextView"/>

        <TextView android:layout_height="wrap_content" android:layout_width="wrap_content" android:textSize="24sp" android:text="TextView" android:id="@+id/xValue" android:background="@android:color/white" android:layout_alignParentLeft="true" android:layout_alignParentStart="true" android:layout_below="@+id/textView"/>

        <TextView android:layout_height="wrap_content" android:layout_width="wrap_content" android:textSize="24sp" android:text="TextView" android:id="@+id/yValue" android:background="@android:color/white" android:layout_alignParentLeft="true" android:layout_alignParentStart="true" android:layout_below="@+id/xValue"/>

        <TextView android:layout_height="wrap_content" android:layout_width="wrap_content" android:textSize="24sp" android:text="TextView" android:id="@+id/zValue" android:background="@android:color/white" android:layout_alignParentLeft="true" android:layout_alignParentStart="true" android:layout_below="@+id/yValue"/>

        <TextView android:layout_height="wrap_content" android:layout_width="wrap_content" android:textSize="24sp" android:text="hrValue" android:id="@+id/hrValue" android:background="@android:color/white" android:layout_alignParentLeft="true" android:layout_alignParentStart="true" android:layout_below="@+id/yValue"/>

        <TextView android:layout_height="wrap_content" android:layout_width="wrap_content" android:textSize="24sp" android:text="luxValue" android:id="@+id/luxValue" android:background="@android:color/white" android:layout_alignParentLeft="true" android:layout_alignParentStart="true" android:layout_below="@+id/yValue"/>

        <TextView android:layout_height="wrap_content" android:layout_width="wrap_content" android:textSize="24sp" android:text="scValue" android:id="@+id/scValue" android:background="@android:color/white" android:layout_alignParentLeft="true" android:layout_alignParentStart="true" android:layout_below="@+id/yValue"/>

        <TextView android:layout_height="wrap_content" android:layout_width="match_parent" android:text="tvProcess" android:id="@+id/tvProcess"/>

        <TextView android:layout_height="wrap_content" android:layout_width="match_parent" android:text="tvResult" android:id="@+id/tvResult"/>

    </LinearLayout>
</androidx.constraintlayout.widget.ConstraintLayout>

Wear側(送信側)のプログラム

   private class SensorWorker extends AsyncTask<JobParameters,Void,String> implements SensorEventListener {

        private final String TAG = MainActivity.class.getName();
        protected JobParameters mJobParam;

        private GoogleApiClient mGoogleApiClient;
        private String mNode;

        @Override
        protected String doInBackground(JobParameters... params) {
            mGoogleApiClient = new GoogleApiClient.Builder(getApplicationContext())
                    .addApi(Wearable.API)
                    .addConnectionCallbacks(new GoogleApiClient.ConnectionCallbacks() {
                        @Override
                        public void onConnected(Bundle bundle) {
                            Log.d(TAG, "onConnected");
                            Wearable.NodeApi.getConnectedNodes(mGoogleApiClient).setResultCallback(new ResultCallback<NodeApi.GetConnectedNodesResult>() {
                                @Override
                                public void onResult(NodeApi.GetConnectedNodesResult nodes) {
                                    if (nodes.getNodes().size() > 0) {
                                        mNode = nodes.getNodes().get(0).getId();

                                    }
                                }
                            });
                        }
                        @Override
                        public void onConnectionSuspended(int i) {
                            Log.d(TAG, "onConnectionSuspended");

                        }
                    })
                    .addOnConnectionFailedListener(new GoogleApiClient.OnConnectionFailedListener() {
                        @Override
                        public void onConnectionFailed(ConnectionResult connectionResult) {
                            Log.d(TAG, "onConnectionFailed : " + connectionResult.toString());
                        }
                    })
                    .build();

            mGoogleApiClient.connect();

            mJobParam = params[0];
            return String.valueOf(mJobParam.getJobId());
        }

        @Override
        protected void onPostExecute(String result) {

            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss z");
            String SEND_DATA = sdf.format(Calendar.getInstance().getTime()) + "," + x + "," + y + "," + z + "," + hr + "," + lux + "," + sc;
            if (mNode != null) {
                Wearable.MessageApi.sendMessage(mGoogleApiClient, mNode, SEND_DATA, null).setResultCallback(new ResultCallback<MessageApi.SendMessageResult>() {
                    @Override
                    public void onResult(MessageApi.SendMessageResult result) {
                        if (!result.getStatus().isSuccess()) {
                            Log.d(TAG, "ERROR : failed to send Message" + result.getStatus());
                        }
                    }
                });
            }

            jobFinished(mJobParam, false);
        }
    }

Mobile側(受信側)プログラム

public class MainActivity extends Activity implements GoogleApiClient.ConnectionCallbacks, MessageApi.MessageListener {
    private GoogleApiClient mGoogleApiClient;
  
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        mGoogleApiClient = new GoogleApiClient.Builder(this)
                .addConnectionCallbacks(this)
                .addOnConnectionFailedListener(new GoogleApiClient.OnConnectionFailedListener() {
                    @Override
                    public void onConnectionFailed(ConnectionResult connectionResult) {
                        Log.d(TAG, "onConnectionFailed:" + connectionResult.toString());
                    }
                })
                .addApi(Wearable.API)
                .build();
    }
 
    @Override
    protected void onStart() {
        super.onStart();
        mGoogleApiClient.connect();
    }
 
    @Override
    protected void onStop() {
        super.onStop();
    }
  
    @Override
    public void onConnected(Bundle bundle) {
        Wearable.MessageApi.addListener(mGoogleApiClient, this);
    }
 
    @Override
    public void onConnectionSuspended(int i) {
    }
 
    @Override
    public void onMessageReceived(MessageEvent messageEvent) {
        //xTextView.setText(messageEvent.getPath());
        String msg = messageEvent.getPath();
        String[] value = msg.split(",", 0);
    }
 }

Mobile側(送信)プログラム

public class MainActivity extends Activity implements GoogleApiClient.ConnectionCallbacks, MessageApi.MessageListener {

    @Override
    public void onMessageReceived(MessageEvent messageEvent) {

        PostAccess access = new PostAccess(tvProcess, tvResult);
        access.execute("http://www.cc.aoyama.ac.jp/~well-being//HR/wp-content/plugins/well-being/post.php", msg,"");
    }
 
 
    private class PostAccess extends AsyncTask<String, String, String> {
        private static final String DEBUG_TAG = "PostAccess";
        private boolean _success = false;
 
        public PostAccess(TextView tvProcess, TextView tvResult) {
        }
 
        @Override
        public String doInBackground(String... params) {
            String urlStr = params[0];
            String msg = params[1];
            String comment = params[2];
 
            String postData = "";
            String[] value = msg.split(",", 0);
            String timestamp = "";
            for( int i=0; i<7; i++) {
                if( i==0 ) {
                    timestamp = value[i];
                    continue;
                } else if( i==1 ) {
                    postData = "d0="+"0,0,"+timestamp+",acc x,"+value[i];
                } else if( i==2 ) {
                    postData = postData+"&amp;d1="+"0,0,"+timestamp+",acc y,"+value[i];
                } else if( i==3 ) {
                    postData = postData+"&amp;d2="+"0,0,"+timestamp+",acc z,"+value[i];
                } else if( i==4 ) {
                    postData = postData+"&amp;d3="+"0,0,"+timestamp+",hr,"+value[i];
                } else if( i==5 ) {
                    postData = postData+"&amp;d4="+"0,0,"+timestamp+",lux,"+value[i];
                } else if( i==6 ) {
                    postData = postData+"&amp;d5="+"0,0,"+timestamp+",sc,"+value[i];
                }
            }
 
            HttpURLConnection con = null;
            InputStream is = null;
            String result = "";
 
            try {
                URL url = new URL(urlStr);
                con = (HttpURLConnection) url.openConnection();
                con.setRequestMethod("POST");
                con.setConnectTimeout(5000);
                con.setReadTimeout(5000);
                con.setDoOutput(true);
                OutputStream os = con.getOutputStream();
                os.write(postData.getBytes());
                os.flush();
                os.close();
                int status = con.getResponseCode();
                if (status != 200) {
                    throw new IOException("ステータスコード: " + status);
                }
                is = con.getInputStream();
 
                result = is2String(is);
                _success = true;
            }
            catch(SocketTimeoutException ex) {
            }
            catch(MalformedURLException ex) {
            }
            catch(IOException ex) {
            }
            finally {
                if (con != null) {
                    con.disconnect();
                }
                try {
                    if (is != null) {
                        is.close();
                    }
                }
                catch (IOException ex) {
                }
            }
            return result;
        }
  
        @Override
        public void onPostExecute(String result) {
            if (_success) {
                String status = "";
                String message = "";
                try {
                    JSONObject rootJson = new JSONObject(result);
                    status = rootJson.getString("status");
                    message = rootJson.getString("message");
                }
                catch (JSONException ex) {
                }
 
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss z");
                message = "Sent "+sdf.format(Calendar.getInstance().getTime());
            }
        }
 
        private String is2String(InputStream is) throws IOException {
            BufferedReader reader = new BufferedReader(new InputStreamReader(is, "UTF-8"));
            StringBuffer sb = new StringBuffer();
            char[] b = new char[1024];
            int line;
            while(0 <= (line = reader.read(b))) {
                sb.append(b, 0, line);
            }
            return sb.toString();
        }
    }
}

Server側プログラム

<?php

require_once('bioinfo_classes.php');


if(
        ( isset($_SERVER["SHELL"]) || isset($_SERVER["HOMEPATH"]) )
                &amp;&amp; stristr($argv[0],'post.php') ){

                $_REQUEST["d0"]="0,0,".date("Y-m-d H:i:s").",0,0";
}

if( isset($_REQUEST["d0"]) ){
        $i = 0;
        $bioinfo_list = new BioInfo_List();
        while(true){
                $k = "d".$i;
                if( isset($_REQUEST[$k]) ){
                        $bioinfo_list->add_bioinfo_from_csv($_REQUEST[$k]);
                }else{
                        break;
                }
                $i++;
        }
        if( count($bioinfo_list->bioinfo_list) > 0 ){
                $bioinfo_list->insert_db();
        }
        //var_dump($bioinfo_list);
}

Class Bioinfo_List {

	public $bioinfo_list=array();

	public function add_bioinfo_from_csv($csv){
		$rec = new BioInfo();
		$rec->set_values_from_csv($csv);
		$this->bioinfo_list[] = $rec;
	}

	public function insert_db(){
		//echo "insert db<BR>\n";
		try {
			$pdo_opts = [
				PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
				PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
			];
			$pdo = new PDO ( 'mysql:host='.$GLOBALS["DB_HOST"].';dbname='.$GLOBALS["DB_NAME"].';charset=utf8', $GLOBALS["DB_USER"], $GLOBALS["DB_PW"], $pdo_opts );
			$stmt = $pdo->prepare( 'INSERT INTO `'."sensor_data".'`
				(`user_id`,`device_id`,`timestamp`,`sensor_id`,`value`)
				VALUES (:user_id,:device_id,:timestamp,:sensor_id,:value)
				ON DUPLICATE KEY UPDATE
				`value`=VALUES(`value`)
				;');

			foreach( $this->bioinfo_list as $i => $rec ){
				//var_dump($rec);
				$d = explode(' ', $rec->timestamp);
				if( count($d) == 3 ){
					array_pop($d);
					$rec->timestamp=join(' ',$d);
				}
				$stmt->bindValue(':user_id', $rec->user_id, PDO::PARAM_STR);
				$stmt->bindValue(':device_id', $rec->device_id, PDO::PARAM_STR);
				$stmt->bindValue(':timestamp', $rec->timestamp, PDO::PARAM_STR);
				$stmt->bindValue(':sensor_id', $rec->sensor_id, PDO::PARAM_STR);
				$stmt->bindValue(':value', $rec->value, PDO::PARAM_STR);
				$stmt->execute();
			}
		}catch(PDOException $PDO_ERROR){
			header('Content-Type: text/plain; charset=UTF-8', true, 500);
			exit('DataBase ERROR/'.$PDO_ERROR->getMessage()."\n");
		}
		return(count($this->bioinfo_list));
	}
}

Class BioInfo {
	public $user_id;
	public $device_id;
	public $timestamp;
	public $sensor_id;
	public $value;

	public function set_values_from_csv($csv){
		$d = explode(",",$csv);
		$this->user_id = $d[0];
		$this->device_id = $d[1];
		$this->timestamp = $d[2];
		$this->sensor_id = $d[3];
		$this->value = $d[4];
	}
	public function set_values_from_assoc($assoc){
		foreach ( $assoc as $k => $v ){
			$this->$k = $v;
		}
	}
}

?>