Приложение для весов (android приложение + связь с сервером (php & MySQL) + связь с весами + общая синхронизация данных)

package com.example.database;
 
import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.net.ConnectivityManager;
import android.os.Bundle;
import android.view.View;
import android.widget.ListAdapter;
import android.widget.ListView;
import android.widget.ProgressBar;
import android.widget.Toast;
 
import androidx.appcompat.app.AppCompatActivity;
 
import com.android.volley.Request;
import com.android.volley.RequestQueue;
import com.android.volley.toolbox.StringRequest;
import com.android.volley.toolbox.Volley;
 
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
 
import java.util.ArrayList;
 
public class MainActivity extends AppCompatActivity {
 
    ListView listView;
 
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
 
        setContentView(R.layout.activity_main);
        listView = findViewById(R.id.listView);
        View InternetButton = findViewById(R.id.button1);
        InternetButton.setOnClickListener(v -> {
            //сделать ее не доступной
            if (!isOnline()) {
                Toast.makeText(getApplicationContext(),
                        "Нет соединениея с интернетом!", Toast.LENGTH_LONG).show();
 
            } else {
                Toast.makeText(getApplicationContext(),
                        "Соединение с интернетом установлено!", Toast.LENGTH_LONG).show();
                syncDb();
 
 
            }
 
        });
        View ScaleButton = findViewById(R.id.button2);
        ScaleButton.setOnClickListener(v -> {
            //сделать ее не доступной
            if (!isBluetooth()) {
                Toast.makeText(getApplicationContext(),
                        "Нет соединениея с блютуз!", Toast.LENGTH_LONG).show();
 
            } else {
                Toast.makeText(getApplicationContext(),
                        "Соединение с блютуз установлено!", Toast.LENGTH_LONG).show();
            }
 
        });
 
        loadJSONFromDB();
 
    }
 
    private void loadJSONFromDB() {
        SQLiteDatabase myDB =
                openOrCreateDatabase("my.db", MODE_PRIVATE, null);
        //ищем прогресс бар и делаем его видимым
        final ProgressBar progressBar = findViewById(R.id.progressBar);
        progressBar.setVisibility(ListView.VISIBLE);
        String select = Controller.all_scale(myDB);
 
        progressBar.setVisibility(View.INVISIBLE);
        try {
            JSONObject object = new JSONObject(select);
            JSONArray jsonArray = object.getJSONArray("data");
 
            ArrayList<JSONObject> listItems = getArrayListFromJSONArray(jsonArray);
            ListAdapter adapter = new ListViewAdapter(getApplicationContext(), R.layout.row, R.id.textViewResult, listItems);
            listView.setAdapter(adapter);
 
        } catch (JSONException e) {
            e.printStackTrace();
        }
 
        Toast.makeText(getApplicationContext(),
                "Данные из базы телефона загружены", Toast.LENGTH_LONG).show();
 
    }
 
 
    private ArrayList<JSONObject> getArrayListFromJSONArray(JSONArray jsonArray) {
        ArrayList<JSONObject> aList = new ArrayList<>();
        try {
            if (jsonArray != null) {
                for (int i = 0; i < jsonArray.length(); i++) {
                    aList.add(jsonArray.getJSONObject(i));
                }
            }
        } catch (JSONException js) {
            js.printStackTrace();
        }
        return aList;
    }
 
 
    private void syncDb() {
        SQLiteDatabase myDB =
                openOrCreateDatabase("my.db", MODE_PRIVATE, null);
        final ProgressBar progressBar = findViewById(R.id.progressBar);
        progressBar.setVisibility(ListView.VISIBLE);
        String select = Controller.syncDb(myDB);
 
        final String JSON_URL = "http://кислицин.рф/get_scale_sync";// UTF-8
 
        StringRequest stringRequest = new StringRequest(Request.Method.GET, JSON_URL + select,
                response -> {
                    progressBar.setVisibility(View.INVISIBLE);
                    try {
                        JSONObject object = new JSONObject(Controller.EncodingToUTF8(response));
 
                        if (object.has("data")) {
                            JSONArray jsonArray = object.getJSONArray("data");
                            ArrayList<JSONObject> listItems = getArrayListFromJSONArray(jsonArray);
 
                            int dateScaleSync = listItems.get(0).getInt("date");
                            int flowersScaleSync = listItems.get(0).getInt("flowers");
                            int placeScaleSync = listItems.get(0).getInt("place");
                            Context context = getApplicationContext();
                            if (object.has("sync")) {
                                //парсим данные с сервера и добавляем в базу приложения
                                JSONArray jsonArraySync = object.getJSONArray("sync");
                                ArrayList<JSONObject> listItemsSync = getArrayListFromJSONArray(jsonArraySync);
                                // String.valueOf(listItemsSync.get(0).getJSONObject("date"));
                                Controller.syncDbFromServer(myDB, context, dateScaleSync, flowersScaleSync, placeScaleSync, listItemsSync);
                            }
                            //берём данные из базы приложения и отправляем на сервер
                            if (dateScaleSync < 0 || flowersScaleSync < 0 || placeScaleSync < 0) {
                                syncDbToServer(Controller.syncDbToServer(myDB, context, dateScaleSync, flowersScaleSync, placeScaleSync));
                            }
                            Toast.makeText(getApplicationContext(),
                                    "Синхронизация завершена", Toast.LENGTH_LONG).show();
                            loadJSONFromDB();
                        } else {
                            Toast.makeText(getApplicationContext(),
                                    "Приложение синхронизировано", Toast.LENGTH_LONG).show();
                        }
 
 
                    } catch (JSONException e) {
                        e.printStackTrace();
                    }
                },
                error -> Toast.makeText(getApplicationContext(), error.getMessage(), Toast.LENGTH_SHORT).show());
        RequestQueue requestQueue = Volley.newRequestQueue(this);
        requestQueue.add(stringRequest);
 
 
    }
 
    private void syncDbToServer(String addData) {
        
 
        final String JSON_URL = "http://кислицин.рф/scale_sync_add_data?data=";// UTF-8
 
        StringRequest stringRequest = new StringRequest(Request.Method.GET, JSON_URL + addData,
                response -> {
                    try {
                        JSONObject object = new JSONObject(Controller.EncodingToUTF8(response));
 
                        if (object.has("update_ok")) {
                            Toast.makeText(getApplicationContext(),
                                    "Приложение синхронизировано", Toast.LENGTH_LONG).show();
                        } else {
                            Toast.makeText(getApplicationContext(),
                                    "Ошибка синхронизации", Toast.LENGTH_LONG).show();
                        }
 
 
                    } catch (JSONException e) {
                        e.printStackTrace();
                    }
                },
                error -> Toast.makeText(getApplicationContext(), error.getMessage(), Toast.LENGTH_SHORT).show());
        RequestQueue requestQueue = Volley.newRequestQueue(this);
        requestQueue.add(stringRequest);
 
    }
 
 
    protected boolean isOnline() {
        ConnectivityManager cm = (ConnectivityManager)
                getSystemService(Context.CONNECTIVITY_SERVICE);
        return cm.getActiveNetworkInfo() != null;
    }
 
    protected boolean isBluetooth() {
 
        return true;
 
    }
 
 
}

package com.example.database;
 
import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteException;
import android.renderscript.Sampler;
import android.widget.Toast;
 
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
 
import java.math.BigDecimal;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;
 
 
public class Controller {
 
    public static String getSyncData(SQLiteDatabase myDB, int dateScaleSync, String nameTable, String id) {
        Cursor myCursor = (Cursor) Model.getSyncData(myDB, dateScaleSync, nameTable, id);
        String result_text = dumpCursorToString(myCursor);
 
        return "\"" + nameTable + "\":[" + result_text + "]";
 
    }
 
    public static String all_scale(SQLiteDatabase myBd) {
 
        Cursor myCursor = (Cursor) Model.all_scale(myBd);
 
        StringBuilder result_text = new StringBuilder(new StringBuilder());
        int i = 0;
        if (myCursor.getCount() > 0) {
            myCursor.moveToFirst();
            float itog = 0;
            float itog_scale = 0;
            do {
                if (itog != 0) {
                    itog_scale = myCursor.getFloat(myCursor.getColumnIndex("result_scale")) - itog;
                }
                float floatNumber = BigDecimal.valueOf(itog_scale).setScale(2, BigDecimal.ROUND_HALF_DOWN).floatValue();
                String dateScales = myCursor.getString(myCursor.getColumnIndex("date"));
 
                result_text.insert(0, "{\"itog\":"
                        + floatNumber + ",\"result_scale\":"
                        + myCursor.getString(myCursor.getColumnIndex("result_scale"))
                        + ",\"date\":\"" + dateScales
                        + "\",\"name_flowers\":\""
                        + myCursor.getString(myCursor.getColumnIndex("name_flowers"))
                        + "\",\"place_name\":\""
                        + myCursor.getString(myCursor.getColumnIndex("place_name"))
                        + "\"},");
                itog = myCursor.getFloat(myCursor.getColumnIndex("result_scale"));
 
                i++;
            } while (myCursor.moveToNext());
            myCursor.close();
        }
        return "{\"data\":[" + result_text + "]}";
    }
 
    public static String syncDb(SQLiteDatabase myBd) {
        Cursor myCursor = (Cursor) Model.syncDb(myBd);
        if (myCursor.getCount() > 0) {
            myCursor.moveToFirst();
            String dateScale = myCursor.getString(myCursor.getColumnIndex("date"));
            String flowersScale = myCursor.getString(myCursor.getColumnIndex("flowers"));
            String placeScale = myCursor.getString(myCursor.getColumnIndex("place"));
 
            return "?date=" + dateScale + "&flowers=" + flowersScale + "&place=" + placeScale;
        } else {
            return "0";
        }
 
    }
 
    //сборщик недостающих данных для сервера
    static String syncDbToServer(SQLiteDatabase myDB, Context context, int dateScaleSync, int flowersScaleSync, int placeScaleSync) {
 
 
        //выбираем данные с базы приложения и отправляем на сервер
        StringBuilder ScalesSyncToServer = new StringBuilder();
 
        if (dateScaleSync < 0) {
            Toast.makeText(context, "Таблица взвешиваний на сервере меньше чем в приложении", Toast.LENGTH_LONG).show();
            ScalesSyncToServer.append(Controller.getSyncData(myDB, dateScaleSync, "weighing_scales", "id_weighing_scales"));
 
        }
        if (flowersScaleSync < 0) {
            Toast.makeText(context, "Таблица медоносов на сервере меньше чем в приложении", Toast.LENGTH_LONG).show();
 
 
            ScalesSyncToServer.append(Controller.comma(ScalesSyncToServer.length() > 0) +
                    Controller.getSyncData(myDB, flowersScaleSync, "flowers", "id_flowers"));
 
        }
        if (placeScaleSync < 0) {
            Toast.makeText(context, "Таблица локаций на сервере меньше чем в приложении", Toast.LENGTH_LONG).show();
            ScalesSyncToServer.append(Controller.comma(ScalesSyncToServer.length() > 0) +
                    Controller.getSyncData(myDB, placeScaleSync, "place", "id_place"));
        }
 
 
        return addTag(ScalesSyncToServer, "sync");
 
    }
 
    static void syncDbFromServer(SQLiteDatabase myDB, Context context, int dateScaleSync, int flowersScaleSync, int placeScaleSync, ArrayList<JSONObject> listItemsSync) throws JSONException {
 
        if (dateScaleSync > 0) {
            Toast.makeText(context, "Таблица взвешиваний на сервере больше чем в приложении", Toast.LENGTH_LONG).show();
            EncodingJSONToSqlInsert(myDB, listItemsSync, "weighing_scales");
        }
        if (flowersScaleSync > 0) {
            Toast.makeText(context, "Таблица медоносов на сервере больше чем в приложении", Toast.LENGTH_LONG).show();
            EncodingJSONToSqlInsert(myDB,  listItemsSync, "flowers");
        }
        if (placeScaleSync > 0) {
            Toast.makeText(context, "Таблица локаций на сервере больше чем в приложении", Toast.LENGTH_LONG).show();
            EncodingJSONToSqlInsert(myDB, listItemsSync,  "place");
        }
 
 
    }
 
    public static void EncodingJSONToSqlInsert(SQLiteDatabase myDB, ArrayList<JSONObject> listItemsSync, String tableName) throws JSONException {
        JSONArray weighing_scales = listItemsSync.get(0).getJSONArray(tableName);
        int count = weighing_scales.length();
        JSONArray keys = null;
 
        for (int i = 0; i < count; i++) {
            int m = 1;
            JSONObject valueString = (JSONObject) weighing_scales.get(i);
            int s = valueString.length();
            keys = valueString.names();
            ContentValues newValues = new ContentValues();
            for (int j = 0; j < s; j++) {
                assert keys != null;
                String key = keys.getString(j);
                newValues.put(key, valueString.getString(key));
            }
            Model.insertSyncData(myDB, tableName, newValues);
        }
    }
 
    public static String EncodingToUTF8(String response) {
        byte[] code = response.getBytes(StandardCharsets.ISO_8859_1);
        response = new String(code, StandardCharsets.UTF_8);
        return response;
    }
 
    public static void dumpCursor(Cursor cursor, StringBuilder sb) {
 
        if (cursor != null) {
            int startPos = cursor.getPosition();
 
            cursor.moveToPosition(-1);
            while (cursor.moveToNext()) {
                dumpCurrentRow(cursor, sb);
            }
            cursor.moveToPosition(startPos);
        }
 
    }
 
    public static String dumpCursorToString(Cursor cursor) {
        StringBuilder sb = new StringBuilder();
        dumpCursor(cursor, sb);
        return sb.toString();
    }
 
    public static void dumpCurrentRow(Cursor cursor, StringBuilder sb) {
        String[] cols = cursor.getColumnNames();
        sb.append("{");
        int length = cols.length;
        for (int i = 0; i < length; i++) {
            String z = comma(i != length - 1);
            String value;
            try {
                value = cursor.getString(i);
            } catch (SQLiteException e) {
                value = "";
            }
            sb.append('"').append(cols[i]).append("\":\"").append(value).append('"').append(z);
        }
        sb.append("}");
    }
 
    //запятая в строке
    public static String comma(boolean b) {
        String z = "";
        if (b) {
            z = ",";
        }
        return z;
    }
 
    //обёртка
    public static String addTag(StringBuilder text, String tag) {
        return "{\"" + tag + "\":{" + text + "}}";
    }
}

package com.example.database;
 
import android.content.ContentValues;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
 
import org.jetbrains.annotations.NotNull;
 
import java.util.ArrayList;
 
 
public class Model {
 
 
    public static Object all_scale(SQLiteDatabase myBd) {
        Cursor myCursor =
                myBd.rawQuery("SELECT weighing_scales.result_scale, strftime('%d.%m\n%Y',weighing_scales.date_scale) AS date, flowers.name_flowers, place.place_name\n" +
                        "FROM weighing_scales\n" +
                        "JOIN flowers ON flowers.id_flowers = weighing_scales.id_flowers\n" +
                        "JOIN place ON place.id_place = weighing_scales.id_place\n" +
                        //"WHERE weighing_scales.result_scale>=130 \n"+
                        "ORDER BY weighing_scales.date_scale", null);
 
        return myCursor;
    }
 
    public static Object syncDb(SQLiteDatabase myBd) {
        Cursor myCursor =
                myBd.rawQuery("select(SELECT MAX(weighing_scales.date_scale) FROM weighing_scales) AS date, (SELECT MAX(flowers.id_flowers) FROM flowers) AS flowers, (SELECT MAX(place.id_place) FROM place) AS place", null);
 
        return myCursor;
    }
 
    public static Object getSyncData(SQLiteDatabase myBd, int idScaleSync, String nameTable, String nameId) {
 
 
        String sql = "SELECT * FROM " + nameTable + " WHERE " + nameId + ">" + (idScaleSync * -1);
        Cursor myCursor = myBd.rawQuery(sql, null);
 
        return myCursor;
    }
    public static void  insertSyncData(SQLiteDatabase myBd,String tableName, ContentValues newValues) {
// Вставьте строку в вашу базу данных.
        myBd.insert(tableName, null, newValues);
 
    }
}

package com.example.database;
 
import android.content.Context;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.widget.ArrayAdapter;
import android.widget.TextView;
 
import org.json.JSONException;
import org.json.JSONObject;
 
import java.util.ArrayList;
 
public class ListViewAdapter  extends ArrayAdapter<JSONObject> {
    int listLayout;
    ArrayList<JSONObject> usersList;
    Context context;
 
    public ListViewAdapter(Context context, int listLayout , int field, ArrayList<JSONObject> usersList) {
        super(context, listLayout, field, usersList);
        this.context = context;
        this.listLayout=listLayout;
        this.usersList = usersList;
    }
 
    @Override
    public View getView(int position, View convertView, ViewGroup parent) {
        LayoutInflater inflater = (LayoutInflater) context.getSystemService(Context.LAYOUT_INFLATER_SERVICE);
        View listViewItem = inflater.inflate(listLayout, null, false);
        TextView date = listViewItem.findViewById(R.id.textViewDate);
        TextView result = listViewItem.findViewById(R.id.textViewResult);
        TextView flowers = listViewItem.findViewById(R.id.textViewFlowers);
        TextView itog = listViewItem.findViewById(R.id.textViewItog);
 
        try{
            date.setText(usersList.get(position).getString("date"));
            result.setText(usersList.get(position).getString("result_scale"));
            flowers.setText(usersList.get(position).getString("name_flowers"));
            itog.setText(usersList.get(position).getString("itog"));
        }catch (JSONException je){
            je.printStackTrace();
        }
        return listViewItem;
    }
 
 
}

List<Entry> entries = new ArrayList<Entry>();
            LineChart chart = (LineChart) findViewById(R.id.chart);
          
            int i = (jsonArray.length())-2;
            for (JSONObject data : listItems) {
                String[] d1 =listItems.get(i).getString("date").split("\\.");
                int d2 = Integer.parseInt(d1[0]);
                entries.add(new Entry(d2, Float.parseFloat(listItems.get(i).getString("itog"))));
                i--;
            }
            LineDataSet dataSet = new LineDataSet(entries, listItems.get(0).getString("name_flowers"));
            LineData lineData = new LineData(dataSet);
            chart.setData(lineData);
            chart.invalidate();