ok

models/yzy_base.py

@@ -108,6 +108,7 @@ class YstYhpcsbEntity(Base):
     bzid = Column(String, default='')
     sfzh = Column(String, default='')
     xm = Column(String, default='')
+    qydm = Column(String, default='')
     qymc = Column(String, default='')
     qydz = Column(String, default='')
     qyjb = Column(String, default='')
@@ -143,6 +144,7 @@ class YstQyjcxxEntity(Base):
     bzid = Column(String, default='')
     sfzh = Column(String, default='')
     xm = Column(String, default='')
+    qydm = Column(String, default='')
     qymc = Column(String, default='')
     qydz = Column(String, default='')
     qyjb = Column(String, default='')
@@ -170,6 +172,7 @@ class YstQyyjyaEntity(Base):
     bzid = Column(String, default='')
     sfzh = Column(String, default='')
     xm = Column(String, default='')
+    qydm = Column(String, default='')
     qymc = Column(String, default='')
     qydz = Column(String, default='')
     qyjb = Column(String, default='')
@@ -202,6 +205,7 @@ class YstYjylzjEntity(Base):
     bzid = Column(String, default='')
     sfzh = Column(String, default='')
     xm = Column(String, default='')
+    qydm = Column(String, default='')
     qymc = Column(String, default='')
     qydz = Column(String, default='')
     qyjb = Column(String, default='')
@@ -228,6 +232,8 @@ class VwYstDaiban(Base):
     create_time = Column(DateTime)
     update_time = Column(DateTime)
     status = Column(Integer)
+    qymc = Column(String)
+    qydm = Column(String)
 
     class Config:
         orm_mode = True

routers/api/yst/daiban.py

@@ -151,6 +151,8 @@ def new_record(data: dict):
     updateTime = data['update_time']
     cid = data['sfzh']
     name = data['xm']
+    qymc = data['qymc']
+    qydm = data['qydm']
     
     H5_HOST = "https://yst.mmsyjj.cn:8086"
     if settings.IS_PROD == False:
@@ -232,15 +234,15 @@ def new_record(data: dict):
             # 申请人类型
             'applyerType': '1', # 自然人
             # 申请人名称
-            'applyerName': name,
+            'applyerName': qymc,
             # 申请人证件类型
             'applyerIdType': '10', # 身份证
             # 申请人证件号码
             'applyerIdNum': cid,
             # 申请人统一身份认证平台账号(可选)
-            'applyerUid': '',
+            'applyerUid': qydm,
             # 法定代表人(可选)
-            'legal': ''
+            'legal': name
         },
         # 联系人信息
         'contactInfo': {

routers/api/yst/qyjcxx.py

@@ -34,6 +34,7 @@ async def accept(
 
         sfzh = ext_info['cid']
         xm = ext_info['name']
+        qydm = ext_info['corp']['cid']
     
         redis_key = "mmyj_yhxx_" + uuid_str
         yhxx_info = redis_get_json(redis_key)
@@ -58,6 +59,7 @@ async def accept(
         db_entity.bzid = uuid_str
         db_entity.sfzh = sfzh
         db_entity.xm = xm
+        db_entity.qydm = qydm
         db_entity.qymc = qymc
         db_entity.qydz = qydz
         db_entity.qyjb = qyjb

routers/api/yst/qyyjya.py

@@ -26,7 +26,7 @@ async def accept(
 
         sfzh = ext_info['cid']
         xm = ext_info['name']
-        
+        qydm = ext_info['corp']['cid']
 
         redis_key = "mmyj_yhxx_" + bzid
         yhxx_info = redis_get_json(redis_key)
@@ -51,6 +51,7 @@ async def accept(
             bzid = bzid,
             sfzh = sfzh,
             xm = xm,
+            qydm = qydm,
             qymc = get_req_param(param, 'qymc'),
             qydz = get_req_param(param, 'qydz'),
             qyjb = get_req_param(param, 'qyjb'),

routers/api/yst/yhpcsb.py

@@ -25,6 +25,7 @@ async def accept(
 
         sfzh = ext_info['cid']
         xm = ext_info['name']
+        qydm = ext_info['corp']['cid']
 
         redis_key = "mmyj_yhxx_" + bzid
         yhxx_info = redis_get_json(redis_key)
@@ -49,6 +50,7 @@ async def accept(
             bzid = bzid,
             sfzh = sfzh,
             xm = xm,
+            qydm = qydm,
             qymc = get_req_param(param, 'qymc'),
             qydz = get_req_param(param, 'qydz'),
             qyjb = get_req_param(param, 'qyjb'),

routers/api/yst/yjylzj.py

@@ -26,6 +26,7 @@ async def accept(
 
         sfzh = ext_info['cid']
         xm = ext_info['name']
+        qydm = ext_info['corp']['cid']
 
         redis_key = "mmyj_yhxx_" + bzid
         yhxx_info = redis_get_json(redis_key)
@@ -50,6 +51,7 @@ async def accept(
             bzid = bzid,
             sfzh = sfzh,
             xm = xm,
+            qydm = qydm,
             qymc = get_req_param(param, 'qymc'),
             qydz = get_req_param(param, 'qydz'),
             qyjb = get_req_param(param, 'qyjb'),