19 Commits

Author SHA1 Message Date
06558d778d Merge pull request 'FIX: Skip handling import errors' (#49) from fix/add-venta into develop
Reviewed-on: #49
2025-10-06 12:08:39 -03:00
538833a5a4 FIX: Skip handling import errors 2025-10-06 12:08:08 -03:00
7bee4e3bb4 Merge pull request 'FIX: Cartolas not adding Movimientos or adding cargos and abonos' (#46) from fix/carga-cartolas into develop
Reviewed-on: #46
2025-10-04 14:16:29 -03:00
0c640d6cab FIX: Cartolas not adding Movimientos or adding cargos and abonos 2025-10-04 14:14:13 -03:00
6d871d77fe Merge branch 'master' into develop 2025-10-04 11:39:53 -03:00
b0267320a1 fix/add-venta (#44)
FIXES:
 - cast Comuna.id to int in Propietario
 - Inmobiliaria without tipoSociedad not loading descripcion

Log exception processor
Get Money values when stored as 0

Co-authored-by: Juan Pablo Vial <jpvialb@incoviba.cl>
Reviewed-on: #44
2025-10-03 12:13:02 -03:00
a668b6b7be Merge pull request 'FIX: cuando no existe departamento' (#43) from feature/resumen-escritura-sin-departamento into develop
Reviewed-on: #43
2025-09-23 15:45:33 -03:00
82ba2cfdff Merge pull request 'feature/cierres' (#42) from feature/cierres into develop
Reviewed-on: #42
2025-09-23 15:41:29 -03:00
496dca9133 Fetch reservation with unit 2025-09-23 15:37:45 -03:00
d171a61b8a Comment whe rejecting or canceling reservation 2025-09-22 15:28:54 -03:00
7b11fdc6ce Getter 2025-09-22 14:16:52 -03:00
31fc1269b4 Cleanup 2025-09-22 14:09:19 -03:00
46d810555c Rejected or canceled reservations, comments 2025-09-22 14:08:23 -03:00
3cf67a71b6 FIX: cuando no existe departamento 2025-09-22 12:19:29 -03:00
6ddc48ec60 Merge branch 'develop' 2024-03-13 16:31:34 -03:00
331ee1e584 Merge branch 'develop' 2023-06-22 23:18:13 -04:00
24c17debf3 Merge branch 'develop' 2023-02-15 18:30:09 -03:00
552fd0aa06 Merge branch 'develop' 2023-02-14 20:50:42 -03:00
60faf293d4 Merge branch 'develop' 2023-02-13 17:18:41 -03:00
28 changed files with 493 additions and 100 deletions

View File

@ -2,6 +2,7 @@
namespace Incoviba\Common\Define\Cartola;
use Psr\Http\Message\UploadedFileInterface;
use Incoviba\Exception\ServiceAction\Read;
interface Banco
{
@ -9,6 +10,7 @@ interface Banco
* Process bank movements for database inserts
* @param UploadedFileInterface $file
* @return array
* @throws Read
*/
public function process(UploadedFileInterface $file): array;

View File

@ -3,10 +3,16 @@ namespace Incoviba\Common\Ideal\Cartola;
use Incoviba\Common\Define;
use Incoviba\Common\Ideal\Service;
use Incoviba\Exception\ServiceAction\Read;
use Psr\Http\Message\UploadedFileInterface;
abstract class Banco extends Service implements Define\Cartola\Banco
{
/**
* @param UploadedFileInterface $file
* @return array
* @throws Read
*/
public function process(UploadedFileInterface $file): array
{
$filename = $this->processUploadedFile($file);
@ -40,6 +46,7 @@ abstract class Banco extends Service implements Define\Cartola\Banco
* Process the temp file from getFilename and remove it
* @param string $filename
* @return array
* @throws Read
*/
protected function processFile(string $filename): array
{
@ -88,6 +95,7 @@ abstract class Banco extends Service implements Define\Cartola\Banco
* Translate uploaded file data to database data
* @param string $filename
* @return array
* @throws Read
*/
abstract protected function parseFile(string $filename): array;
}

View File

@ -0,0 +1,68 @@
<?php
namespace Incoviba\Common\Implement\Log\Processor;
use Throwable;
use Monolog\LogRecord;
use Monolog\Processor\ProcessorInterface;
class Exception implements ProcessorInterface
{
public function __invoke(LogRecord $record): LogRecord
{
$context = $record->context;
$changed = false;
array_walk_recursive($context, function (&$item) use (&$changed) {
if (is_a($item, Throwable::class)) {
$item = $this->processException($item);
$changed = true;
}
});
if ($changed) {
$new_record = new LogRecord(
$record->datetime,
$record->channel,
$record->level,
$record->message,
$context,
$record->extra
);
$record = $new_record;
}
if (is_a($record->message, Throwable::class)) {
$exception = $record->message;
$output = $this->processException($exception);
$message = $output['message'];
if (array_key_exists('exception', $context)) {
$context['other_exception'] = $context['exception'];
}
$context['exception'] = $output;
$new_record = new LogRecord(
$record->datetime,
$record->channel,
$record->level,
$message,
$context,
$record->extra
);
$record = $new_record;
}
return $record;
}
protected function processException(Throwable $exception): array
{
$output = [
'class' => get_class($exception),
'code' => $exception->getCode(),
'message' => $exception->getMessage(),
'file' => $exception->getFile(),
'line' => $exception->getLine(),
'trace' => $exception->getTraceAsString(),
];
if ($exception->getPrevious() !== null) {
$output['previous'] = $this->processException($exception);
}
return $output;
}
}

View File

@ -0,0 +1,26 @@
<?php
declare(strict_types=1);
use Phinx\Migration\AbstractMigration;
final class AddCommentsToReservations extends AbstractMigration
{
/**
* Change Method.
*
* Write your reversible migrations using this method.
*
* More information on writing migrations is available here:
* https://book.cakephp.org/phinx/0/en/migrations.html#the-change-method
*
* Remember to call "create()" or "update()" and NOT "save()" when working
* with the Table class.
*/
public function change(): void
{
$this->table('reservations')
->addColumn('comments', 'text')
->update();
}
}

View File

@ -338,6 +338,7 @@
data.errors.forEach(errorData => {
console.error(errorData)
})
throw Error('Error al importar cartolas')
}
this.data.movimientos = data.movimientos.map(movimiento => new Movimiento(movimiento))
this.draw().movimientos()

View File

@ -19,7 +19,7 @@
<div class="header">
{{$inmobiliaria->abreviacion}}
</div>
<div class="description">{{$inmobiliaria->razon}} {{$inmobiliaria->tipoSociedad->descripcion}}</div>
<div class="description">{{$inmobiliaria->razon}} {{$inmobiliaria->tipoSociedad?->descripcion ?? ''}}</div>
<div class="meta">{{$inmobiliaria->rut()}}</div>
</div>
</div>

View File

@ -6,7 +6,12 @@
@section('venta_content')
<div class="ui segment">
El departamento {{$venta->propiedad()->departamentos()[0]->descripcion}}:<br />
@if (count($venta->propiedad()->departamentos()) > 0)
El departamento {{$venta->propiedad()->departamentos()[0]->descripcion}}:<br />
@else
La unidad {{ ucwords($venta->propiedad()->principal()?->proyectoTipoUnidad->tipoUnidad->descripcion) }}
{{ $venta->propiedad()->principal()?->descripcion }}:<br />
@endif
@php
$estacionamientos = $venta->propiedad()->estacionamientos();
@endphp

View File

@ -47,9 +47,9 @@
</div>
</div>
<div class="ui top attached tabular menu" id="tabs">
<div class="yellow active item" data-tab="pending">Pendientes</div>
<div class="green item" data-tab="active">Activas</div>
<div class="red item" data-tab="rejected">Rechazadas</div>
<div class="yellow active item link" data-tab="pending">Pendientes</div>
<div class="green item link" data-tab="active">Activas</div>
<div class="red item link" data-tab="rejected">Rechazadas</div>
</div>
<div class="ui bottom attached tab fitted segment active" data-tab="pending">
<table class="ui yellow striped table" id="pending_reservations">
@ -102,12 +102,13 @@
</div>
@include('ventas.reservations.modal.add')
@include('ventas.reservations.modal.comment')
@endsection
@push('page_styles')
<style>
.item.link {
cursor: pointer;
cursor: pointer !important;
text-decoration: underline;
}
</style>
@ -293,10 +294,10 @@
return this
}
}
columnsData() {
return this.reservations.map(reservation => {
get columnsData() {
return this.reservations.map(reservation => {
const date = new Date(Date.parse(reservation.date) + 24 * 60 * 60 * 1000)
return {
return {
id: reservation.id,
unidades: reservation.summary,
cliente: reservation.buyer.nombreCompleto,
@ -314,7 +315,7 @@
}
const tbody = this.component.querySelector('tbody')
tbody.innerHTML = ''
this.columnsData().forEach(column => {
this.columnsData.forEach(column => {
const tr = document.createElement('tr')
const contents = []
const id = column.id
@ -376,6 +377,9 @@
hide() {
this.component.style.display = 'none'
}
find(id) {
return this.reservations.find(reservation => reservation.id === parseInt(id))
}
send = {
get(url) {
return APIClient.fetch(url).then(response => response.json()).then(json => {
@ -392,14 +396,6 @@
}
})
},
delete(url) {
const method = 'delete'
return APIClient.fetch(url, {method}).then(response => response.json()).then(json => {
if (json.success) {
window.location.reload()
}
})
}
}
actions = {}
}
@ -409,10 +405,10 @@
super({component_id, formatters})
}
columnsData() {
const data = super.columnsData();
get columnsData() {
const data = super.columnsData;
return data.map(row => {
delete (row['valida'])
delete(row['valida'])
return row
})
}
@ -436,9 +432,12 @@
},
remove: event => {
event.preventDefault()
const id = event.currentTarget.dataset.id
const url = `{{ $urls->api }}/ventas/reservation/${id}/remove`
this.send.delete(url)
const reservation_id = event.currentTarget.dataset.id
const url = `{{ $urls->api }}/ventas/reservation/${reservation_id}/remove`
const method = 'delete'
const action = 'Cancelar'
const reservation_data = this.find(reservation_id)
reservations.components.modals.comment.show({reservation_id, action, url, method, reservation_data})
return false
}
}
@ -459,9 +458,12 @@
},
reject: event => {
event.preventDefault()
const id = event.currentTarget.dataset.id
const url = `{{ $urls->api }}/ventas/reservation/${id}/reject`
this.send.get(url)
const reservation_id = event.currentTarget.dataset.id
const url = `{{ $urls->api }}/ventas/reservation/${reservation_id}/reject`
const method = 'delete'
const action = 'Rechazar'
const reservation_data = this.find(reservation_id)
reservations.components.modals.comment.show({reservation_id, action, url, method, reservation_data})
return false
}
}
@ -472,11 +474,11 @@
super({component_id, formatters})
}
columnsData() {
const data = super.columnsData()
get columnsData() {
const data = super.columnsData
return this.reservations.map((reservation, idx) => {
data[idx]['estado'] = reservation.state.charAt(0).toUpperCase() + reservation.state.slice(1)
data[idx]['comentarios'] = reservation.comments?.join('<br />\n') ?? ''
data[idx]['estado'] = this.mapState(reservation.current_state)
data[idx]['comentarios'] = reservation.comments ?? ''
return data[idx]
})
}
@ -484,6 +486,13 @@
return ''
}
watch() {}
mapState(state) {
return {
'canceled': 'Cancelado',
'rejected': 'Rechazado'
}[state.toLowerCase()]
}
}
const reservations = {
@ -498,7 +507,8 @@
rejected: null
},
modals: {
add: null
add: null,
comment: null,
}
},
display: {
@ -638,6 +648,7 @@
this.show.projects()
this.components.modals.add = new AddReservationModal(configuration.ids.projects)
this.components.modals.comment = new CommentModal()
const project_id = {{ $project_id ?? 'null' }};
if (project_id !== null) {
@ -645,6 +656,7 @@
}
}
}
$(document).ready(() => {
reservations.setup({
ids: {

View File

@ -305,7 +305,6 @@
onChange: (value, text, $selectedItem) => {
const unitPromotions = this.promotions.filter(promotion => promotion.units.length > 0)
const promotions = unitPromotions.filter(promotion => promotion.units.filter(unit => unit.id === parseInt(value)).length > 0)
console.debug($selectedItem.parent().parent().parent().parent().find('.add_promotions_unit'))
$selectedItem.parent().parent().parent().parent().find('.add_promotions_unit')
.dropdown('change values', promotions.map(promotion => {
return {

View File

@ -0,0 +1,157 @@
<div class="ui modal" id="comment_modal">
<div class="header">
Comentar Cierre y <span id="comment_action"></span>
</div>
<div class="content">
<form class="ui form" id="comment_form">
<input type="hidden" name="reservation_id" id="comment_reservation_id" />
<input type="hidden" name="user_id" id="comment_user_id" />
<table class="ui collapsing table">
<tbody>
<tr>
<td>Unidades</td>
<td id="comment_units"></td>
</tr>
<tr>
<td>Cliente</td>
<td id="comment_client"></td>
</tr>
<tr>
<td>Fecha</td>
<td id="comment_date"></td>
</tr>
</tbody>
</table>
<div class="field">
<label>Comentario</label>
<textarea name="comment"></textarea>
</div>
</form>
</div>
<div class="actions">
<div class="ui cancel button">
Cancelar
</div>
<div class="ui green ok button">
Comentar y Guardar
</div>
</div>
</div>
@push('page_scripts')
<script>
class CommentModal {
ids = {
modal: 'comment_modal',
action: 'comment_action',
form: 'comment_form',
reservation_id: 'comment_reservation_id',
user_id: 'comment_user_id',
units: 'comment_units',
client: 'comment_client',
date: 'comment_date',
}
components = {
$modal: null,
action: null,
form: null,
reservation: null,
user: null,
units: null,
client: null,
date: null,
comment: null,
}
data = {
reservation_id: null,
url: '',
action: '',
method: 'delete',
reservation_data: {
units: '',
client: '',
date: '',
}
}
constructor() {
this.ids = {
modal: 'comment_modal',
action: 'comment_action',
form: 'comment_form',
reservation_id: 'comment_reservation_id',
user_id: 'comment_user_id',
units: 'comment_units',
client: 'comment_client',
date: 'comment_date',
}
this.setup()
}
show({reservation_id, reservation_data, url, action, method}) {
this.data.reservation_id = reservation_id
this.data.url = url
this.data.action = action
this.data.method = method
this.components.action.innerHTML = action
const date = new Date(Date.parse(reservation_data.date) + 24 * 60 * 60 * 1000)
const formatter = new Intl.DateTimeFormat('es-CL', {dateStyle: 'medium'})
this.data.reservation_data = {
units: reservation_data.summary,
client: reservation_data.buyer.nombreCompleto,
date: formatter.format(date),
}
this.components.reservation.value = this.data.reservation_id
this.components.units.innerHTML = this.data.reservation_data.units
this.components.client.innerHTML = this.data.reservation_data.client
this.components.date.innerHTML = this.data.reservation_data.date
this.components.$modal.modal('show')
}
hide() {
this.components.$modal.modal('hide')
}
submit() {
const url = this.data.url
const method = this.data.method
const body = new FormData(this.components.form)
return APIClient.fetch(url, {method, body}).then(response => response.json()).then(json => {
if (json.success) {
window.location.reload()
}
})
}
setup() {
this.components = {
$modal: $(`#${this.ids.modal}`),
action: document.getElementById(this.ids.action),
form: document.getElementById(this.ids.form),
reservation: document.getElementById(this.ids.reservation_id),
user: document.getElementById(this.ids.user_id),
units: document.getElementById(this.ids.units),
client: document.getElementById(this.ids.client),
date: document.getElementById(this.ids.date),
comment: null,
}
this.components.comment = this.components.form.querySelector('textarea[name="comment"]')
this.components.user.value = '{{ $user->id }}'
this.components.$modal.modal({
onApprove: $element => {
this.submit()
}
})
this.components.form.addEventListener('submit', event => {
event.preventDefault()
this.submit()
return false
})
}
}
</script>
@endpush

View File

@ -25,6 +25,7 @@ return [
$container->get(Monolog\Processor\MemoryPeakUsageProcessor::class),
$container->get(Monolog\Processor\PsrLogMessageProcessor::class),
$container->get(Monolog\Processor\UidProcessor::class),
$container->get(Incoviba\Common\Implement\Log\Processor\Exception::class),
];
},
'baseDefaultHandlers' => function(ContainerInterface $container) {

View File

@ -2,6 +2,7 @@
namespace Incoviba\Controller\API\Contabilidad;
use DateTimeImmutable;
use Incoviba\Exception\ServiceAction\Read;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Incoviba\Common\Ideal\Controller;
@ -117,24 +118,21 @@ class Cartolas extends Controller
UPLOAD_ERR_CANT_WRITE => 'No se pudo escribir el archivo',
UPLOAD_ERR_EXTENSION => 'Una extensión de PHP detuvo la subida del archivo'
];
if (is_array($files['file'])) {
foreach ($files['file'] as $i => $file) {
if ($file->getError() !== UPLOAD_ERR_OK) {
$output['errors'] []= ['filename' => $file->getClientFilename(), 'error' => $errors[$file->getError()]];
continue;
}
try {
$output['movimientos'] = array_merge($output['movimientos'], $cartolaService->import($body['cuenta_id'][$i], $file));
} catch (EmptyResult) {}
}
} else {
$file = $files['file'];
if (!is_array($files['file'])) {
$files['file'] = [$files['file']];
$body['cuenta_id'] = [$body['cuenta_id']];
}
foreach ($files['file'] as $i => $file) {
if ($file->getError() !== UPLOAD_ERR_OK) {
$output['errors'][] = ['filename' => $file->getClientFilename(), 'error' => $errors[$file->getError()]];
} else {
try {
$output['movimientos'] = $cartolaService->import($body['cuenta_id'], $file);
} catch (EmptyResult) {}
$output['errors'] []= ['filename' => $file->getClientFilename(), 'error' => $errors[$file->getError()]];
continue;
}
try {
$output['movimientos'] = array_merge($output['movimientos'], $cartolaService->import($body['cuenta_id'][$i], $file));
} catch (Read $exception) {
$output['errors'] []= ['filename' => $file->getClientFilename(),
'error' => ['message' => $exception->getMessage(), 'file' => $exception->getFile(),
'line' => $exception->getLine()]];
}
}
return $this->withJson($response, $output);

View File

@ -53,7 +53,7 @@ class Money
}
try {
$this->data[$provider] = (array) $this->fetchRedis($redisService, $redisKey);
if (!isset($this->data[$provider][$date->format('Y-m-d')])) {
if (!isset($this->data[$provider][$date->format('Y-m-d')]) or $this->data[$provider][$date->format('Y-m-d')] === 0) {
throw new EmptyRedis($redisKey);
}
} catch (EmptyRedis) {

View File

@ -71,9 +71,9 @@ class Reservations
$output['errors'] []= $this->parseError($exception);
}*/
if (count($input['reservations']) === count($output['reservations'])) {
/*if (count($input['reservations']) === count($output['reservations'])) {
$output['success'] = true;
}
}*/
return $this->withJson($response, $output);
}

View File

@ -117,6 +117,8 @@ class Reservation extends Common\Ideal\Model
return $base >= $price;
}
public string $comments;
protected function jsonComplement(): array
{
return [
@ -131,7 +133,10 @@ class Reservation extends Common\Ideal\Model
'base' => $this->base(),
'price' => $this->price(),
'valid' => $this->valid(),
'summary' => $this->summary()
'summary' => $this->summary(),
'states' => $this->states() ?? [],
'current_state' => $this->currentState()?->type?->name ?? null,
'comments' => $this->comments ?? '',
];
}
}

View File

@ -16,7 +16,10 @@ class State extends Common\Ideal\Model
return [
'reservation_id' => $this->reservation->id,
'date' => $this->date->format('Y-m-d'),
'type' => $this->type
'type' => [
'id' => $this->type->value,
'name' => $this->type->name,
]
];
}
}

View File

@ -18,6 +18,6 @@ enum Type: int
}
public static function getTypes(): array
{
return [self::ACTIVE->value, self::INACTIVE->value, self::REJECTED->value];
return [self::ACTIVE->value, self::INACTIVE->value, self::REJECTED->value, self::CANCELLED->value];
}
}

View File

@ -4,6 +4,7 @@ namespace Incoviba\Repository\Venta;
use DateTimeInterface;
use DateInterval;
use Incoviba\Common\Define;
use Incoviba\Common\Implement\Exception\EmptyResult;
use Incoviba\Exception\Model\InvalidState;
use PDO;
use Incoviba\Common;
@ -29,7 +30,7 @@ class Reservation extends Common\Ideal\Repository
public function create(?array $data = null): Model\Venta\Reservation
{
$map = (new Common\Implement\Repository\MapperParser())
$map = (new Common\Implement\Repository\MapperParser(['comments']))
->register('project_id', (new Common\Implement\Repository\Mapper())
->setProperty('project')
->setFunction(function($data) {
@ -91,18 +92,57 @@ class Reservation extends Common\Ideal\Repository
/**
* @param int $buyer_rut
* @param int $unit_id
* @param DateTimeInterface $date
* @return Model\Venta\Reservation
* @throws Common\Implement\Exception\EmptyResult
* @throws EmptyResult
*/
public function fetchByBuyerAndDate(int $buyer_rut, DateTimeInterface $date): Model\Venta\Reservation
public function fetchByBuyerAndUnitAndDate(int $buyer_rut, int $unit_id, DateTimeInterface $date): Model\Venta\Reservation
{
$query = $this->connection->getQueryBuilder()
->select('a.*')
->from('reservations a')
->joined('INNER JOIN reservation_details rd ON a.id = rd.reservation_id')
->where('a.buyer_rut = :buyer_rut AND rd.unit_id = :unit_id AND a.date >= :date');
return $this->fetchOne($query, ['buyer_rut' => $buyer_rut, 'unit_id' => $unit_id, 'date' => $date->sub(new DateInterval('P10D'))->format('Y-m-d')]);
}
/**
* @param int $buyer_rut
* @param int $project_id
* @param DateTimeInterface $date
* @return array
* @throws EmptyResult
*/
public function fetchByBuyerAndProjectAndDate(int $buyer_rut, int $project_id, DateTimeInterface $date): array
{
$query = $this->connection->getQueryBuilder()
->select()
->from('reservations')
->where('buyer_rut = :buyer_rut AND project_id = :project_id AND date >= :date');
return $this->fetchMany($query, ['buyer_rut' => $buyer_rut, 'project_id' => $project_id, 'date' => $date->sub(new DateInterval('P10D'))->format('Y-m-d')]);
}
/**
* @param int $buyer_rut
* @param DateTimeInterface $date
* @return array
* @throws EmptyResult
*/
public function fetchByBuyerAndDate(int $buyer_rut, DateTimeInterface $date): array
{
$query = $this->connection->getQueryBuilder()
->select()
->from('reservations')
->where('buyer_rut = :buyer_rut AND date >= :date');
return $this->fetchOne($query, ['buyer_rut' => $buyer_rut, 'date' => $date->sub(new DateInterval('P10D'))->format('Y-m-d')]);
return $this->fetchMany($query, ['buyer_rut' => $buyer_rut, 'date' => $date->sub(new DateInterval('P10D'))->format('Y-m-d')]);
}
/**
* @param int $project_id
* @return array
* @throws EmptyResult
*/
public function fetchByProject(int $project_id): array
{
$query = $this->connection->getQueryBuilder()
@ -114,13 +154,16 @@ class Reservation extends Common\Ideal\Repository
/**
* @param int $project_id
* @param int $state
* @param int|string $state
* @return array
* @throws Common\Implement\Exception\EmptyResult
* @throws EmptyResult
* @throws InvalidState
*/
public function fetchState(int $project_id, int $state): array
public function fetchState(int $project_id, int|string $state): array
{
if (is_string($state)) {
$state = Model\Venta\Reservation\State\Type::from($state)->value;
}
if (!in_array($state, Model\Venta\Reservation\State\Type::getTypes())) {
throw new InvalidState();
}
@ -141,6 +184,7 @@ class Reservation extends Common\Ideal\Repository
return $this->fetchMany($query, ['project_id' => $project_id,
'state' => $state]);
}
/**
* @param int $project_id
* @return array

View File

@ -1,18 +1,21 @@
<?php
namespace Incoviba\Service\Contabilidad;
use DateMalformedStringException;
use PDOException;
use DateTimeImmutable;
use DateTimeInterface;
use Psr\Http\Message\StreamFactoryInterface;
use Psr\Http\Message\UploadedFileInterface;
use Psr\Log\LoggerInterface;
use PhpOffice\PhpSpreadsheet;
use Incoviba\Common\Define\Cartola\Banco;
use Incoviba\Common\Define\Contabilidad\Exporter;
use Incoviba\Common\Ideal\Service;
use Incoviba\Common\Implement\Exception;
use Incoviba\Exception\ServiceAction\Read;
use Incoviba\Model;
use Incoviba\Repository;
use Psr\Http\Message\StreamFactoryInterface;
use Psr\Http\Message\UploadedFileInterface;
use Psr\Log\LoggerInterface;
class Cartola extends Service
{
@ -32,6 +35,13 @@ class Cartola extends Service
$this->bancos[$name] = $banco;
return $this;
}
/**
* @param Model\Contabilidad\Banco $banco
* @param UploadedFileInterface $file
* @return array
* @throws Read
*/
public function process(Model\Contabilidad\Banco $banco, UploadedFileInterface $file): array
{
return $this->bancos[strtolower($banco->nombre)]->process($file);
@ -93,9 +103,19 @@ class Cartola extends Service
return compact('cartola', 'movimientos');
}
/**
* @param int $cuenta_id
* @param UploadedFileInterface $file
* @return array
* @throws Read
*/
public function import(int $cuenta_id, UploadedFileInterface $file): array
{
$cuenta = $this->cuentaRepository->fetchById($cuenta_id);
try {
$cuenta = $this->cuentaRepository->fetchById($cuenta_id);
} catch (Exception\EmptyResult $exception) {
throw new Read(__CLASS__, $exception);
}
$movimientos = $this->process($cuenta->banco, $file);
$inmobiliaria = $cuenta->inmobiliaria;
@ -106,15 +126,23 @@ class Cartola extends Service
if (array_key_exists('centro_costo', $dataMovimiento) and $dataMovimiento['centro_costo'] !== 0) {
$dataMovimiento['centro_costo_id'] = $dataMovimiento['centro_costo'];
}
$dataMovimiento['fecha'] = new DateTimeImmutable($dataMovimiento['fecha']);
try {
$dataMovimiento['fecha'] = new DateTimeImmutable($dataMovimiento['fecha']);
} catch (DateMalformedStringException) {
continue;
}
if (array_key_exists('rut', $dataMovimiento)) {
$ruts = $this->parseRut($dataMovimiento['rut']);
if (key_exists('rut', $ruts)) {
$dataMovimiento['rut'] = $ruts['rut'];
$dataMovimiento['digito'] = $ruts['digito'];
if ($dataMovimiento['rut'] === '') {
unset($dataMovimiento['rut']);
} else {
$dataMovimiento['rut'] = $ruts[0]['rut'];
$dataMovimiento['digito'] = $ruts[0]['digito'];
$ruts = $this->parseRut($dataMovimiento['rut']);
if (key_exists('rut', $ruts)) {
$dataMovimiento['rut'] = $ruts['rut'];
$dataMovimiento['digito'] = $ruts['digito'];
} else {
$dataMovimiento['rut'] = $ruts[0]['rut'];
$dataMovimiento['digito'] = $ruts[0]['digito'];
}
}
}
try {
@ -133,14 +161,28 @@ class Cartola extends Service
$fechas = array_unique(array_map(function($movimiento) {
return $movimiento['fecha']->format('Y-m-d');
}, $movimientos));
if (count($fechas) === 0) {
throw new Read(__CLASS__);
}
foreach ($fechas as $dia) {
try {
$this->cartolaRepository->fetchByCuentaAndFecha($cuenta->id, new DateTimeImmutable($dia));
$dayDate = new DateTimeImmutable($dia);
} catch (DateMalformedStringException) {
continue;
}
try {
$this->cartolaRepository->fetchByCuentaAndFecha($cuenta->id, $dayDate);
continue;
} catch (Exception\EmptyResult) {}
$movs = array_filter($movimientos, function($movimiento) use ($dia) {
return $movimiento['fecha'] === $dia;
return $movimiento['fecha']->format('Y-m-d') === $dia;
});
if (count($movs) === 0) {
continue;
}
$cargos = array_sum(array_map(function($movimiento) {
return $movimiento['cargo'];
}, $movs));
@ -153,11 +195,19 @@ class Cartola extends Service
'abonos' => $abonos,
'saldo' => $saldo
];
$this->buildCartola($cuenta, new DateTimeImmutable($dia), $cartolaData);
$this->buildCartola($cuenta, $dayDate, $cartolaData);
}
$startDate = new DateTimeImmutable(min($fechas));
$endDate = new DateTimeImmutable(max($fechas));
try {
$startDate = new DateTimeImmutable(min($fechas));
} catch (DateMalformedStringException $exception) {
throw new Read(__CLASS__, $exception);
}
try {
$endDate = new DateTimeImmutable(max($fechas));
} catch (DateMalformedStringException $exception) {
throw new Read(__CLASS__, $exception);
}
$movimientosFaltantes = $this->movimientoService->findMissing($cuenta, $addedMovimientos, $startDate, $endDate);
$movimientosObsoletos = [];
if (count($movimientosFaltantes) > 0) {

View File

@ -3,6 +3,7 @@ namespace Incoviba\Service\Contabilidad\Cartola;
use DateTimeImmutable;
use Incoviba\Common\Ideal\Cartola\Banco;
use Incoviba\Exception\ServiceAction\Read;
use PhpOffice\PhpSpreadsheet;
use Psr\Http\Message\UploadedFileInterface;
@ -10,8 +11,8 @@ class Itau extends Banco
{
use isExcel;
const CUENTA_CORRIENTE = 0;
const ULTIMOS_MOVIMIENTOS = 1;
const int CUENTA_CORRIENTE = 0;
const int ULTIMOS_MOVIMIENTOS = 1;
public function processMovimientosDiarios(array $movimientos): array
{
@ -44,6 +45,12 @@ class Itau extends Banco
$ext = pathinfo($uploadedFile->getClientFilename(), PATHINFO_EXTENSION);
return "/tmp/cartola.{$ext}";
}
/**
* @param string $filename
* @return array
* @throws Read
*/
protected function parseFile(string $filename): array
{
$ext = pathinfo($filename, PATHINFO_EXTENSION);
@ -62,7 +69,7 @@ class Itau extends Banco
break;
}
} catch (PhpSpreadsheet\Exception $exception) {
$this->logger->critical($exception);
throw new Read(__CLASS__, $exception);
}
return $data;
}
@ -166,6 +173,11 @@ class Itau extends Banco
});
}
/**
* @param PhpSpreadsheet\Worksheet\Worksheet $sheet
* @return int
* @throws PhpSpreadsheet\Exception
*/
protected function identifySheet(PhpSpreadsheet\Worksheet\Worksheet $sheet): int
{
foreach ($sheet->getRowIterator(1, 10) as $row) {
@ -177,7 +189,7 @@ class Itau extends Banco
return self::ULTIMOS_MOVIMIENTOS;
}
}
throw new PhpSpreadsheet\Exception();
throw new PhpSpreadsheet\Exception('Incorrect type of Worksheet');
}
protected function getDateRange(PhpSpreadsheet\Worksheet\Row $row): array
{

View File

@ -21,7 +21,7 @@ class IPC
$ipcs = [];
try {
$ipcs = json_decode($this->redisService->get($this->redisKey), JSON_OBJECT_AS_ARRAY);
if (!isset($ipcs[$dateKey])) {
if (!isset($ipcs[$dateKey]) or $ipcs[$dateKey] === 0) {
throw new EmptyRedis($this->redisKey);
}
} catch (EmptyRedis) {

View File

@ -48,8 +48,8 @@ class Ine implements Provider
]);
try {
$response = $this->client->get($request_uri);
} catch (GuzzleException) {
throw new EmptyResponse($request_uri);
} catch (GuzzleException $exception) {
throw new EmptyResponse($request_uri, $exception);
}
$body = $response->getBody();
$json = json_decode($body->getContents());

View File

@ -12,6 +12,9 @@ class MiIndicador implements Provider
public function __construct(protected ClientInterface $client) {}
/**
* @param string $money_symbol
* @param DateTimeInterface|null $dateTime
* @return float
* @throws EmptyResponse
*/
public function get(string $money_symbol, ?DateTimeInterface $dateTime = null): float
@ -33,7 +36,7 @@ class MiIndicador implements Provider
$body = $response->getBody();
$json = json_decode($body->getContents());
if (empty($json) or $json->codigo !== $money_symbol or count($json->serie) === 0) {
if (empty($json) or !isset($json->codigo) or !isset($json->serie) or $json->codigo !== $money_symbol or count($json->serie) === 0) {
throw new EmptyResponse($request_uri);
}
return $json->serie[0]->valor;

View File

@ -79,13 +79,7 @@ class Queue extends Ideal\Service
try {
$this->jobService->update($job);
} catch (Update $exception) {
$this->logger->error($exception->getMessage(), ['job' => $job, 'exception' => [
'code' => $exception->getCode(),
'message' => $exception->getMessage(),
'file' => $exception->getFile(),
'line' => $exception->getLine(),
'trace' => $exception->getTraceAsString(),
]]);
$this->logger->error($exception->getMessage(), ['job' => $job, 'exception' => $exception]);
}
return false;
}

View File

@ -22,7 +22,7 @@ class UF
if ($date === null) {
$date = new DateTimeImmutable();
}
if ($date->diff($today)->days < 0) {
if ($date->diff($today)->invert === 1) {
return 0.0;
}
/**
@ -32,7 +32,7 @@ class UF
*/
try {
$ufs = $this->getRedisUFs();
if (!isset($ufs[$date->format('Y-m-d')])) {
if (!isset($ufs[$date->format('Y-m-d')]) or $ufs[$date->format('Y-m-d')] === 0) {
throw new EmptyRedis($this->redisKey);
}
return $ufs[$date->format('Y-m-d')];
@ -54,12 +54,16 @@ class UF
}
public function updateMany(array $dates): array
{
$today = new DateTimeImmutable();
$ufs = [];
try {
$ufs = json_decode($this->redisService->get($this->redisKey), JSON_OBJECT_AS_ARRAY);
} catch (EmptyRedis) {}
$updated = [];
foreach ($dates as $date) {
if ($date->diff($today)->invert === 1) {
continue;
}
if (!isset($ufs[$date->format('Y-m-d')]) or $ufs[$date->format('Y-m-d')] === 0) {
$uf = $this->moneyService->getUF($date);
if ($uf === 0.0) {

View File

@ -19,7 +19,7 @@ class USD
$usds = [];
try {
$usds = json_decode($this->redisService->get($this->redisKey), JSON_OBJECT_AS_ARRAY);
if (!isset($usds[$date->format('Y-m-d')])) {
if (!isset($usds[$date->format('Y-m-d')]) or $usds[$date->format('Y-m-d')] === 0) {
throw new EmptyRedis($this->redisKey);
}
$usd = $usds[$date->format('Y-m-d')];

View File

@ -181,7 +181,8 @@ class Propietario extends Service
]);
$filtered_data = array_intersect_key($data, $fields);
try {
$direccion = $this->direccionRepository->fetchByCalleAndNumeroAndExtraAndComuna($filtered_data['calle'], $filtered_data['numero'], $filtered_data['extra'], $filtered_data['comuna']);
$direccion = $this->direccionRepository->fetchByCalleAndNumeroAndExtraAndComuna($filtered_data['calle'],
$filtered_data['numero'], $filtered_data['extra'], (int) $filtered_data['comuna']);
} catch (EmptyResult) {
try {
$direccion = $this->direccionRepository->create($filtered_data);

View File

@ -123,7 +123,7 @@ class Reservation extends Ideal\Service\API
$date = new DateTimeImmutable($data['date']);
} catch (DateMalformedStringException) {}
try {
$reservation = $this->reservationRepository->fetchByBuyerAndDate($data['buyer_rut'], $date);
$reservation = $this->reservationRepository->fetchByBuyerAndUnitAndDate($data['buyer_rut'], (int) $data['units'][0], $date);
if (array_key_exists('broker_rut', $data) and $data['broker_rut'] !== '') {
try {
@ -174,7 +174,7 @@ class Reservation extends Ideal\Service\API
$this->reservationRepository->getConnection()->getPDO()->commit();
}
} catch (PDOException $exception) {
$this->logger->warning($exception->getMessage(), ['exception' => $exception->getTraceAsString()]);
$this->logger->warning($exception->getMessage(), ['exception' => $exception]);
if ($this->reservationRepository->getConnection()->getPDO()->inTransaction()) {
$this->reservationRepository->getConnection()->getPDO()->rollBack();
}