382 lines
13 KiB
PHP
382 lines
13 KiB
PHP
<?php
|
|
|
|
namespace App\Http\Controllers\Admin;
|
|
|
|
use App\Http\Controllers\Controller;
|
|
use App\Http\Controllers\SuperController;
|
|
use App\Models\Cnt;
|
|
use App\Models\Product;
|
|
use App\Models\Setting;
|
|
use App\DB\Te\TableEngine;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Http\Request;
|
|
use Symfony\Component\HttpKernel\Exception\UnprocessableEntityHttpException;
|
|
use Illuminate\Support\Facades\Http;
|
|
use \App\Http\Controllers\Customer\FundController;
|
|
use App\Http\Controllers\Site\ReportController;
|
|
use App\Services\ConfigService;
|
|
use App\Services\ProductPriceService;
|
|
use Illuminate\Support\Facades\Schema;
|
|
|
|
|
|
class ProductController extends SuperController
|
|
{
|
|
public function __construct()
|
|
{
|
|
$this->with = ['file'/*, 'price', 'default', 'sub'*/];
|
|
// $this->with = [];
|
|
parent::__construct(Product::class, $this->with, ['*'], null, null, ['title']);
|
|
}
|
|
public function tableProduct(Request $request)
|
|
{
|
|
$data = $request->all();
|
|
if (isset($data["select"]) && is_null($data["select"])){
|
|
$data["select"] = [];
|
|
}
|
|
if (is_null($this->query)){
|
|
$query_table = $this->model::with($this->with);
|
|
//*******کداضافه شده
|
|
// ->where('active', '<=', now()) // فیلتر محصولات فعال
|
|
// ->get();
|
|
//*********
|
|
}else{
|
|
$query_table = $this->query;
|
|
// $query_table = $query_table->where('active', '<=', now());
|
|
}
|
|
TableEngine::create($query_table, $data)
|
|
->initSearch($this->search)
|
|
->select($this->select)
|
|
->export($query_table);
|
|
|
|
if (Schema::hasColumn((new Product)->getTable(), 'auto_open_at')) {
|
|
$query_table['auto_open_at'] = Product::selectRaw(
|
|
'SEC_TO_TIME(AVG(TIME_TO_SEC(TIME(auto_open_at)))) as avg_time'
|
|
)->value('avg_time');
|
|
}
|
|
if (Schema::hasColumn((new Product)->getTable(), 'auto_close_at')) {
|
|
$query_table['auto_close_at'] = Product::selectRaw(
|
|
'SEC_TO_TIME(AVG(TIME_TO_SEC(TIME(auto_close_at)))) as avg_time'
|
|
)->value('avg_time');
|
|
}
|
|
|
|
// $query_table['11'] = $avgDuration;
|
|
// $query_table['11'] = Product::avg('auto_open_at');
|
|
// $query_table['112'] = Product::avg('auto_close_at');
|
|
return $query_table;
|
|
|
|
}
|
|
|
|
public function editProducts(Request $request)
|
|
{
|
|
if (isset($request->auto_open_at, $request->auto_close_at)) {
|
|
Product::query()->update([
|
|
'auto_open_at' => $request->auto_open_at,
|
|
'auto_close_at' => $request->auto_close_at,
|
|
]);
|
|
return response()->json(['message' => 'Products updated successfully.']);
|
|
}
|
|
|
|
return response()->json(['error' => 'auto_open_at and auto_close_at must be set'], 400);
|
|
}
|
|
|
|
public function store(Request $request)
|
|
{
|
|
$data = $this->filterProductData($request->all());
|
|
|
|
$product = Product::create($data);
|
|
return $this->resultCreate($product->id);
|
|
}
|
|
|
|
public function update(Request $request, $id)
|
|
{
|
|
// return 1;
|
|
|
|
$data = $this->filterProductData($request->all());
|
|
if (isset($data["price"])){
|
|
$data["reading_method"] = null;
|
|
if (Product::hasPriceOffsetColumn()) {
|
|
$data['price_offset_percent'] = 0;
|
|
}
|
|
}
|
|
if (isset($data["auto_close_at"]) and isset($data["auto_close_at"])){
|
|
if ($data["auto_close_at"] == $data["auto_open_at"]){
|
|
unset($data["auto_open_at"]);
|
|
unset($data["auto_close_at"]);
|
|
}
|
|
}
|
|
|
|
// return $data['price'];
|
|
|
|
|
|
// if(!isset($data['default'])){
|
|
// throw new UnprocessableEntityHttpException('مقادیر اعتبارات را وارد کنید');
|
|
// }
|
|
|
|
// $data['auto_open_at'] = Carbon::parse($data['auto_open_at'])->format('Y-m-d H:i:s');
|
|
// $data['auto_close_at'] = Carbon::parse($data['auto_close_at'])->format('Y-m-d H:i:s');
|
|
$product = Product::findOrFail($id);
|
|
$oldOffsetPercent = (float) ($product->price_offset_percent ?? 0);
|
|
|
|
if (
|
|
Product::hasPriceOffsetColumn()
|
|
&& $product->reading_method
|
|
&& array_key_exists('price_offset_percent', $data)
|
|
) {
|
|
ProductPriceService::reapplyOffsetPercent(
|
|
$product,
|
|
(float) $data['price_offset_percent'],
|
|
$oldOffsetPercent
|
|
);
|
|
unset($data['price'], $data['price_profit']);
|
|
}
|
|
|
|
$product->update($data);
|
|
|
|
return response()->json(true);
|
|
}
|
|
|
|
public function destroy($id)
|
|
{
|
|
Product::findOrFail($id)->delete();
|
|
return response()->json(true);
|
|
|
|
}
|
|
|
|
|
|
public function listProduct()
|
|
{
|
|
// $this->getPrice();
|
|
// $this->auto_close_open();
|
|
$products = Product::with(['file'])->where('active', 1)->get();
|
|
|
|
if (Product::hasPriceOffsetColumn() && str_contains(request()->path(), '/customer/')) {
|
|
$products->each->makeHidden(['price_offset_percent']);
|
|
}
|
|
|
|
return response()->json($products);
|
|
}
|
|
|
|
public function getPrice()
|
|
{
|
|
// $RPrices =Http::timeout(40)->get('http://212.23.201.173:8381/price_list', [])->json();
|
|
$RPrices = Http::timeout(40)->get('http://109.122.246.48:4949/api/free', [])->json();
|
|
|
|
// try{
|
|
// $cooper =Http::timeout(40)->get('https://www.livedata.ir/main/static/p.json', [])->json();
|
|
// if(isset($cooper['s_301006']) && isset($cooper['s_200103'])){
|
|
// $CP = (($cooper['s_301006']/1000000)*$cooper['s_200103'])*10;
|
|
//// Cnt::where('key', 'cu_price')
|
|
// }
|
|
// }catch (\Exception $e){}
|
|
|
|
$config = app(ConfigService::class);
|
|
$mainProductId = app(ConfigService::class)->mainProductId();
|
|
$hasExtremeKeys = Setting::whereIn('key', ['up_price', 'down_price'])->count() === 2;
|
|
$products = Product::with([])->whereNotNull('reading_method')->get();
|
|
foreach ($products as $product) {
|
|
$collection = collect($RPrices);
|
|
$RPrice = $collection->firstWhere('key', $product->reading_method);
|
|
if (!empty($RPrice)) {
|
|
// foreach ($RPrices as $RPrice) {
|
|
// if ($product->reading_method == $RPrice['name']) {
|
|
if ($RPrice['name'] == 'TGJU فلز مس') {
|
|
$copper = $RPrice['price'] + $RPrice['profit'];
|
|
}
|
|
if ($RPrice['name'] == 'TGJU دلار') {
|
|
$dollar = $RPrice['price'] + $RPrice['profit'];
|
|
}
|
|
if ($RPrice['name'] == 'گلد دات ای از آبشده - رسمی - نقد فردا') {
|
|
$RPrice['price'] = $RPrice['price'] / 4.3318;
|
|
}
|
|
ProductPriceService::syncFromReference(
|
|
$product,
|
|
(int) $RPrice['price'],
|
|
(int) ($RPrice['profit'] ?? 0)
|
|
);
|
|
$productPrice = (float) ProductPriceService::adjustedTotal(
|
|
(int) $RPrice['price'],
|
|
(int) ($RPrice['profit'] ?? 0),
|
|
ProductPriceService::offsetPercent($product)
|
|
);
|
|
if (
|
|
$hasExtremeKeys
|
|
&& $mainProductId
|
|
&& (int) $product->id === (int) $mainProductId
|
|
) {
|
|
$config->trackDailyPriceExtreme($productPrice);
|
|
}
|
|
|
|
if ($product->bubble == 1) {
|
|
$ReportController = new ReportController();
|
|
$liquidGold = $ReportController->lastPrice();
|
|
$p = Product::find($product->id);
|
|
$p->amount = $RPrice['price'] / $liquidGold['price'];
|
|
$p->save();
|
|
|
|
}
|
|
}
|
|
}
|
|
if (isset($copper) && isset($dollar)) {
|
|
$cp = (int) round(($copper / 1000000) * $dollar);
|
|
$copperProducts = Product::where('metal_id', 3)->get();
|
|
foreach ($copperProducts as $copperProduct) {
|
|
ProductPriceService::syncFromReference($copperProduct, $cp, 0);
|
|
}
|
|
Product::where('metal_id', 3)->update([
|
|
'updated_at' => \Carbon\Carbon::now()->format('Y-m-d H:i:s'),
|
|
]);
|
|
if (
|
|
$hasExtremeKeys
|
|
&& $mainProductId
|
|
&& Product::where('id', $mainProductId)->where('metal_id', 3)->exists()
|
|
) {
|
|
$mainCopper = Product::find($mainProductId);
|
|
$extremePrice = $mainCopper
|
|
? (float) ($mainCopper->price + ($mainCopper->price_profit ?? 0))
|
|
: (float) $cp;
|
|
$config->trackDailyPriceExtreme($extremePrice);
|
|
}
|
|
}
|
|
|
|
return response()->json(true);
|
|
}
|
|
|
|
public function auto_close_open()
|
|
{
|
|
$products = Product::with([])->get();
|
|
$current_time = now()->format('H:i:s');
|
|
foreach ($products as $product) {
|
|
$show = ($current_time >= $product->auto_open_at && $current_time <= $product->auto_close_at);
|
|
Product::where('id', $product->id)->update([
|
|
'show' => $show,
|
|
]);
|
|
}
|
|
return response()->json(true);
|
|
}
|
|
|
|
|
|
public function getProduct($id)
|
|
{
|
|
$product = Product::with($this->with)->where('id', $id)->first();
|
|
return response()->json($product);
|
|
}
|
|
|
|
/**
|
|
* فعال/غیرفعال محصول — show باید با active همگام باشد (اپ کاربر از show استفاده میکند).
|
|
*/
|
|
public function active($id)
|
|
{
|
|
$product = Product::findOrFail($id);
|
|
$active = !$product->active;
|
|
$product->update([
|
|
'active' => $active,
|
|
'show' => $active,
|
|
]);
|
|
|
|
return response()->json(true);
|
|
}
|
|
|
|
public function hide($id)
|
|
{
|
|
$query = Product::findOrFail($id);
|
|
$query->update([
|
|
'show' => !$query->show
|
|
]);
|
|
return response()->json(true);
|
|
}
|
|
|
|
public function openSell($id)
|
|
{
|
|
return $this->toggleBooleanStatus($id, 'open_sell');
|
|
}
|
|
|
|
public function openBuy($id)
|
|
{
|
|
return $this->toggleBooleanStatus($id, 'open_buy');
|
|
}
|
|
|
|
public function auto_buy($id)
|
|
{
|
|
return $this->toggleBooleanStatus($id, 'auto_buy');
|
|
}
|
|
|
|
public function auto_sell($id)
|
|
{
|
|
return $this->toggleBooleanStatus($id, 'auto_sell');
|
|
}
|
|
|
|
private function toggleBooleanStatus($id, $field)
|
|
{
|
|
$product = Product::findOrFail($id);
|
|
$product->$field = !$product->$field;
|
|
$product->save();
|
|
if (!$product->open_buy and !$product->open_sell) {
|
|
$product->show = false;
|
|
$product->active = false;
|
|
} else {
|
|
$product->show = true;
|
|
$product->active = true;
|
|
}
|
|
$product->save();
|
|
return response()->json($product->$field);
|
|
}
|
|
|
|
public function auto_group($action, $method)
|
|
{
|
|
// Define valid actions and methods
|
|
$validActions = ['sell' => 'auto_sell', 'buy' => 'auto_buy', 'all' => ['auto_buy', 'auto_sell']];
|
|
$validMethods = ['true' => 1, 'false' => 0];
|
|
// Validate action and method
|
|
if (!isset($validActions[$action]) || !array_key_exists($method, $validMethods)) {
|
|
return response()->json(['error' => 'Invalid action or method'], 400);
|
|
}
|
|
// Get fields to update and value to set
|
|
$fields = $validActions[$action];
|
|
$value = $validMethods[$method];
|
|
// Update products
|
|
Product::query()->update(array_fill_keys((array)$fields, $value));
|
|
return response()->json(true);
|
|
}
|
|
|
|
public function updatePrice(Request $request){
|
|
|
|
|
|
}
|
|
|
|
private function filterProductData(array $data): array
|
|
{
|
|
if (!Product::hasPriceOffsetColumn()) {
|
|
unset($data['price_offset_percent']);
|
|
}
|
|
|
|
if (!Product::hasOrderLimitColumns()) {
|
|
unset($data['order_limit_enabled'], $data['min_order_cash'], $data['max_order_cash']);
|
|
} elseif (empty($data['order_limit_enabled'])) {
|
|
$data['order_limit_enabled'] = false;
|
|
$data['min_order_cash'] = null;
|
|
$data['max_order_cash'] = null;
|
|
} else {
|
|
$min = $data['min_order_cash'] ?? null;
|
|
$max = $data['max_order_cash'] ?? null;
|
|
$hasMin = $min !== null && $min !== '';
|
|
$hasMax = $max !== null && $max !== '';
|
|
|
|
if (!$hasMin && !$hasMax) {
|
|
throw new UnprocessableEntityHttpException(
|
|
'با فعال بودن محدودیت مبلغ سفارش، حداقل یکی از حداقل یا حداکثر مبلغ باید وارد شود'
|
|
);
|
|
}
|
|
|
|
if ($hasMin && $hasMax && (float) $min > (float) $max) {
|
|
throw new UnprocessableEntityHttpException('حداقل مبلغ نمیتواند بیشتر از حداکثر باشد');
|
|
}
|
|
|
|
$data['order_limit_enabled'] = true;
|
|
$data['min_order_cash'] = $hasMin ? (int) $min : null;
|
|
$data['max_order_cash'] = $hasMax ? (int) $max : null;
|
|
}
|
|
|
|
return $data;
|
|
}
|
|
}
|