zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: insert_mplogx_from_xscript 修改

This commit is contained in:
caoqianming 2024-08-27 18:42:18 +08:00
parent 417dae76fd
commit 4bfa8a5460
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/enm/tasks.py
View File

@ -40,15 +40,9 @@ def get_current_and_previous_time():
@shared_task(base=CustomTask) @shared_task(base=CustomTask)
def insert_mplogx_from_xscript(xscript_id): def insert_mplogx_from_xscript(xscript_id):
xscript = Xscript.objects.get(id=xscript_id) xscript = Xscript.objects.get(id=xscript_id)
eval_code = """ mcodes_list = Mpoint.objects.filter(enabled=True).values_list('code', flat=True)
from apps.utils.sql import DbConnection if mcodes_list:
from apps.enm.tasks import db_insert_mplogx_batch exec(xscript.code)
import datetime
from django.utils import timezone
{code}
""".format(code=xscript.code)
exec(eval_code)
def db_insert_mplogx_batch(rows): def db_insert_mplogx_batch(rows):