Merge branch 'feature/fsm-full' into 'feature/uat-tmp'

添加fsm 任务

See merge request !8

@@ -43,7 +43,7 @@ from apps.doc.models import (
     IDBCRecords,
     IDBCRecords,
     Configs,
     Configs,
 )
 )
-from celery_compare.tasks import compare
+from celery_compare.tasks import compare, fsm_compare
 
 
 
 
 class Command(BaseCommand, LoggerMixin):
 class Command(BaseCommand, LoggerMixin):
@@ -2056,8 +2056,13 @@ class Command(BaseCommand, LoggerMixin):
                                         self.log_base, task_str, res_obj.id))
                                         self.log_base, task_str, res_obj.id))
                                     # 触发比对
                                     # 触发比对
                                     try:
                                     try:
-                                        # pass
-                                        compare.apply_async((doc.application_id, business_type, None, res_obj.id,
+                                        fsm_activited = getattr(res_obj, 'fsm_activited')
+                                        if fsm_activited:
+                                            fsm_compare.apply_async((doc.application_id, business_type, None, res_obj.id, is_ca, True),
+                                                queue='queue_compare')
+                                        else:
+                                            # pass
+                                            compare.apply_async((doc.application_id, business_type, None, res_obj.id,
                                                              is_ca, True), queue='queue_compare')
                                                              is_ca, True), queue='queue_compare')
                                     except Exception as e:
                                     except Exception as e:
                                         self.online_log.error(
                                         self.online_log.error(