Skip to content
Toggle navigation
Toggle navigation
This project
Loading...
Sign in
Luciano Barletta
/
message-service
Go to a project
Toggle navigation
Toggle navigation pinning
Projects
Groups
Snippets
Help
Project
Activity
Repository
Pipelines
Graphs
Issues
0
Merge Requests
1
Wiki
Network
Create a new issue
Jobs
Commits
Issue Boards
Files
Commits
Network
Compare
Branches
Tags
Commit 391666ea
authored
2020-07-29 19:47:49 -0300
by
Tu Nombre
Browse Files
Options
Browse Files
Tag
Download
Email Patches
Plain Diff
se pone temporisador al server
1 parent
b8e02ebf
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
3 additions
and
4 deletions
process.py
process.py
View file @
391666e
from
datetime
import
datetime
from
services
import
serviceFactory
from
services
import
serviceFactory
from
database
import
DBconnection
from
database
import
DBconnection
from
enums
import
Services
,
States
,
Datatypes
,
Table
from
enums
import
Services
,
States
,
Datatypes
,
Table
,
datetime
import
ipdb
,
os
,
json
import
ipdb
,
os
,
json
class
Process
:
class
Process
:
...
@@ -65,7 +64,7 @@ class Process:
...
@@ -65,7 +64,7 @@ class Process:
self
.
stateMail
.
MailRompedor
=
[]
self
.
stateMail
.
MailRompedor
=
[]
def
_send
(
self
,
state
,
serv
):
def
_send
(
self
,
state
,
serv
):
fin
=
datetime
.
now
()
+
datetime
.
timedelta
(
seconds
=
15
)
fin
=
datetime
.
datetime
.
now
()
+
datetime
.
datetime
.
timedelta
(
seconds
=
15
)
rows
=
self
.
conn
.
query
(
"SELECT * FROM msg WHERE state = ? and serv = ? "
,(
state
,
serv
))
rows
=
self
.
conn
.
query
(
"SELECT * FROM msg WHERE state = ? and serv = ? "
,(
state
,
serv
))
if
not
len
(
rows
)
==
0
:
if
not
len
(
rows
)
==
0
:
print
(
"cantidad pendiente "
,
serv
,
len
(
rows
))
print
(
"cantidad pendiente "
,
serv
,
len
(
rows
))
...
@@ -99,7 +98,7 @@ class Process:
...
@@ -99,7 +98,7 @@ class Process:
# parcialmente enviado
# parcialmente enviado
elif
partial
:
elif
partial
:
self
.
conn
.
query
(
"UPDATE msg SET state = ?, type = ? WHERE id = ?"
,(
States
.
partial
,
json
.
dumps
(
d
),
query
[
Table
.
id
]))
self
.
conn
.
query
(
"UPDATE msg SET state = ?, type = ? WHERE id = ?"
,(
States
.
partial
,
json
.
dumps
(
d
),
query
[
Table
.
id
]))
if
datetime
.
now
()
>
fin
:
if
datetime
.
datetime
.
now
()
>
fin
:
print
(
"corto para q no se haga larga proces linea 100"
)
print
(
"corto para q no se haga larga proces linea 100"
)
return
()
return
()
# devuelve el estado de un mensaje, lo archiva si está enviado
# devuelve el estado de un mensaje, lo archiva si está enviado
...
...
Write
Preview
Styling with
Markdown
is supported
Attach a file
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to post a comment