open compare

@@ -926,9 +926,9 @@ 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),
-                                        #                     queue='queue_compare')
+                                        # pass
+                                        compare.apply_async((doc.application_id, business_type, None, res_obj.id),
+                                                            queue='queue_compare')
                                     except Exception as e:
                                     except Exception as e:
                                         self.online_log.error(
                                         self.online_log.error(
                                             '{0} [process error (comparison info send)] [task={1}] [error={2}]'.format(
                                             '{0} [process error (comparison info send)] [task={1}] [error={2}]'.format(

@@ -346,7 +346,7 @@ class CompareView(GenericView):
             corporate_cus_info=corporate_cus_info,
             corporate_cus_info=corporate_cus_info,
         )
         )
         # 触发比对
         # 触发比对
-        # compare.apply_async((application_id, business_type, uniq_seq, None), queue='queue_compare')
+        compare.apply_async((application_id, business_type, uniq_seq, None), queue='queue_compare')
         return response.ok()
         return response.ok()
 
 
     post.openapi_doc = '''
     post.openapi_doc = '''