initial

@@ -2037,6 +2037,7 @@ class Command(BaseCommand, LoggerMixin):
                                         result_class = AFCOCRResult if is_ca else AFCSEOCRResult
                                     res_obj = result_class.objects.select_for_update().filter(application_id=doc.application_id).first()
                                     with transaction.atomic():
+                                        self.online_log.info('{0} [sql lock application_id={1}]'.format(self.log_base, doc.application_id))
                                         if res_obj is None:
                                             res_obj = result_class()
                                             res_obj.application_id = doc.application_id
@@ -2061,6 +2062,7 @@ class Command(BaseCommand, LoggerMixin):
                                                 last_res_str = json.dumps(old_res_list)
                                             setattr(res_obj, field, last_res_str)
                                         res_obj.save()
+                                    self.online_log.info('{0} [sql lock release application_id={1}]'.format(self.log_base, doc.application_id))
                                 except Exception as e:
                                     self.online_log.error(
                                         '{0} [process error (ocr result save)] [task={1}] [error={2}]'.format(