|
@@ -1,18 +1,19 @@
|
|
|
import uuid, json
|
|
import uuid, json
|
|
|
-from service.video.Video3DAnalyzer import Video3DAnalyzer
|
|
|
|
|
|
|
+# from service.video.Video3DAnalyzer import Video3DAnalyzer
|
|
|
from db import db
|
|
from db import db
|
|
|
from flask import request
|
|
from flask import request
|
|
|
from db.task import Task
|
|
from db.task import Task
|
|
|
from worker.thread_pool import pool
|
|
from worker.thread_pool import pool
|
|
|
from route.util import make_response
|
|
from route.util import make_response
|
|
|
from flask import Blueprint
|
|
from flask import Blueprint
|
|
|
-from service.photo import StandingPhotoAnalyzer
|
|
|
|
|
|
|
+from service.photo.StandingPhotoAnalyzer import StandingPhotoAnalyzer
|
|
|
|
|
|
|
|
|
|
|
|
|
bp = Blueprint("analyze", __name__, url_prefix='/')
|
|
bp = Blueprint("analyze", __name__, url_prefix='/')
|
|
|
|
|
|
|
|
def callback_generator(task_uuid):
|
|
def callback_generator(task_uuid):
|
|
|
def callback(status, **args):
|
|
def callback(status, **args):
|
|
|
|
|
+ print("caling back")
|
|
|
task = Task.query.get(task_uuid)
|
|
task = Task.query.get(task_uuid)
|
|
|
task.status = status
|
|
task.status = status
|
|
|
if status == 'FINISHED':
|
|
if status == 'FINISHED':
|
|
@@ -31,12 +32,14 @@ def photo_analysis():
|
|
|
|
|
|
|
|
ana = StandingPhotoAnalyzer(req['front'], req['right'])
|
|
ana = StandingPhotoAnalyzer(req['front'], req['right'])
|
|
|
|
|
|
|
|
- task_uuid = str(uuid.uuid4)
|
|
|
|
|
|
|
+ task_uuid = str(uuid.uuid4())
|
|
|
new_task = Task(task_uuid, 'PHOTO_STANDINGPOSE')
|
|
new_task = Task(task_uuid, 'PHOTO_STANDINGPOSE')
|
|
|
db.session.add(new_task)
|
|
db.session.add(new_task)
|
|
|
db.session.commit()
|
|
db.session.commit()
|
|
|
|
|
|
|
|
- pool.submit(ana.analyze, (callback_generator(task_uuid), ))
|
|
|
|
|
|
|
+ ana.analyze(callback_generator(task_uuid))
|
|
|
|
|
+
|
|
|
|
|
+ # pool.submit(ana.analyze, (callback_generator(task_uuid), ))
|
|
|
|
|
|
|
|
return make_response(201, "success", {'task_uuid' : task_uuid})
|
|
return make_response(201, "success", {'task_uuid' : task_uuid})
|
|
|
|
|
|
|
@@ -44,9 +47,9 @@ def photo_analysis():
|
|
|
def video_analysis():
|
|
def video_analysis():
|
|
|
req = request.get_json()
|
|
req = request.get_json()
|
|
|
|
|
|
|
|
- ana_3d = Video3DAnalyzer()
|
|
|
|
|
|
|
+ # ana_3d = Video3DAnalyzer()
|
|
|
|
|
|
|
|
- task_uuid = str(uuid.uuid4)
|
|
|
|
|
|
|
+ task_uuid = str(uuid.uuid4())
|
|
|
new_task = Task(task_uuid, req['type'])
|
|
new_task = Task(task_uuid, req['type'])
|
|
|
db.session.add(new_task)
|
|
db.session.add(new_task)
|
|
|
db.session.commit()
|
|
db.session.commit()
|