apksel-dev/apskel-pos-flutter
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: create product

Browse Source
This commit is contained in:
efrilm
2025-08-05 19:20:45 +07:00
parent 935b6b9a5b
commit bb9aef55cf
24 changed files with 2750 additions and 848 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/data/datasources/product_remote_datasource.dart
+53 -53
View File
@@ -6,7 +6,6 @@ import 'package:enaklo_pos/core/network/dio_client.dart';
import 'package:enaklo_pos/data/models/request/product_request_model.dart';
import 'package:enaklo_pos/data/models/response/add_product_response_model.dart';
import 'package:enaklo_pos/data/models/response/product_response_model.dart';
import 'package:http/http.dart' as http;
import '../../core/constants/variables.dart';
import 'auth_local_datasource.dart';
@@ -21,6 +20,10 @@ class ProductRemoteDatasource {
final response = await dio.get(
url,
queryParameters: {
'page': 1,
'limit': 30,
},
options: Options(
headers: {
'Authorization': 'Bearer ${authData.token}',
@@ -45,67 +48,64 @@ class ProductRemoteDatasource {
Future<Either<String, AddProductResponseModel>> addProduct(
ProductRequestModel productRequestModel) async {
final authData = await AuthLocalDataSource().getAuthData();
final Map<String, String> headers = {
'Authorization': 'Bearer ${authData.token}',
};
var request = http.MultipartRequest(
'POST', Uri.parse('${Variables.baseUrl}/api/products'));
request.fields.addAll(productRequestModel.toMap());
request.files.add(await http.MultipartFile.fromPath(
'image', productRequestModel.image!.path));
request.headers.addAll(headers);
try {
final authData = await AuthLocalDataSource().getAuthData();
final url = '${Variables.baseUrl}/api/v1/products';
http.StreamedResponse response = await request.send();
final response = await dio.post(
url,
data: productRequestModel.toMap(),
options: Options(
headers: {
'Authorization': 'Bearer ${authData.token}',
'Accept': 'application/json',
},
),
);
final String body = await response.stream.bytesToString();
log(response.stream.toString());
log(response.statusCode.toString());
if (response.statusCode == 201) {
return right(AddProductResponseModel.fromJson(body));
} else {
return left(body);
if (response.statusCode == 200) {
return Right(AddProductResponseModel.fromMap(response.data));
} else {
return const Left('Failed to create products');
}
} on DioException catch (e) {
log("Dio error: ${e.message}");
return Left(e.response?.data['message'] ?? 'Gagal menambah produk');
} catch (e) {
log("Unexpected error: $e");
return const Left('Unexpected error occurred');
}
}
Future<Either<String, AddProductResponseModel>> updateProduct(
ProductRequestModel productRequestModel) async {
final authData = await AuthLocalDataSource().getAuthData();
final Map<String, String> headers = {
'Authorization': 'Bearer ${authData.token}',
};
try {
final authData = await AuthLocalDataSource().getAuthData();
final url =
'${Variables.baseUrl}/api/v1/products/${productRequestModel.id}';
log("Update Product Request Data: ${productRequestModel.toMap()}");
log("Update Product ID: ${productRequestModel.id}");
log("Update Product Name: ${productRequestModel.name}");
log("Update Product Price: ${productRequestModel.price}");
log("Update Product Stock: ${productRequestModel.stock}");
log("Update Product Category ID: ${productRequestModel.categoryId}");
log("Update Product Is Best Seller: ${productRequestModel.isBestSeller}");
log("Update Product Printer Type: ${productRequestModel.printerType}");
log("Update Product Has Image: ${productRequestModel.image != null}");
final response = await dio.put(
url,
data: productRequestModel.toMap(),
options: Options(
headers: {
'Authorization': 'Bearer ${authData.token}',
'Accept': 'application/json',
},
),
);
var request = http.MultipartRequest(
'POST', Uri.parse('${Variables.baseUrl}/api/products/edit'));
request.fields.addAll(productRequestModel.toMap());
if (productRequestModel.image != null) {
request.files.add(await http.MultipartFile.fromPath(
'image', productRequestModel.image!.path));
}
request.headers.addAll(headers);
log("Update Product Request Fields: ${request.fields}");
log("Update Product Request Files: ${request.files.length}");
http.StreamedResponse response = await request.send();
final String body = await response.stream.bytesToString();
log("Update Product Status Code: ${response.statusCode}");
log("Update Product Body: $body");
if (response.statusCode == 200) {
return right(AddProductResponseModel.fromJson(body));
} else {
return left(body);
if (response.statusCode == 200) {
return Right(AddProductResponseModel.fromMap(response.data));
} else {
return const Left('Failed to update products');
}
} on DioException catch (e) {
log("Dio error: ${e.message}");
return Left(e.response?.data['message'] ?? 'Gagal update produk');
} catch (e) {
log("Unexpected error: $e");
return const Left('Unexpected error occurred');
}
}
}