diff --git a/票据理赔自动化/database.db b/票据理赔自动化/database.db index 6332081..df642b9 100644 Binary files a/票据理赔自动化/database.db and b/票据理赔自动化/database.db differ diff --git a/票据理赔自动化/main.py b/票据理赔自动化/main.py index 7a36390..a4edb8e 100644 --- a/票据理赔自动化/main.py +++ b/票据理赔自动化/main.py @@ -73,33 +73,31 @@ if __name__ == "__main__": # 初始化在保被保险人表（TPA作业系统包括团单、个单和被保险人表，此处直接整合为宽表） self._execute( sql=""" - CREATE TABLE IF NOT EXISTS insured_person_policies + CREATE TABLE IF NOT EXISTS insured_persons ( - --被保险人 - insured_person TEXT NOT NULL, - --被保险人的证件类型 - identity_type TEXT NOT NULL, - --被保险人的证件号码 - identity_number TEXT NOT NULL, - --与主被保险人关系，包括本人和附属（配偶、父母和子女） - relationship TEXT NOT NULL, - --个单号 - person_policy TEXT NOT NULL, - --主被保险人 - master_insured_person TEXT NOT NULL, - --保险起期（取个单和团单起期最大值） - commencement_date REAL NOT NULL, - --保险止期（取个单和团单止期最小值） - termination_date REAL NOT NULL, --团单号 group_policy TEXT NOT NULL, - --投保公司 - insurance_company TEXT NOT NULL, + --个单号 + person_policy TEXT NOT NULL, --保险分公司 insurer_company TEXT NOT NULL, - --联合主键（投保公司+保险分公司+被保险人+被保险人的证件类型+被保险人的证件号码） - PRIMARY KEY (insurance_company, insurer_company, insured_person, identity_type, - identity_number) + --主被保险人 + master_insured_person TEXT NOT NULL, + --被保险人 + insured_person TEXT NOT NULL, + --证件类型 + identity_type TEXT NOT NULL, + --证件号码 + identity_number TEXT NOT NULL, + --与主被保险人关系，包括本人和附属（附属包括配偶、父母和子女等） + relationship TEXT NOT NULL, + --保险起期（取个单和团单起期最大值） + commencement_date TEXT NOT NULL, + --保险止期（取个单和团单止期最小值） + termination_date TEXT NOT NULL, + --联合主键（被保险人+证件类型+证件号码+保险分公司） + PRIMARY KEY (insured_person, identity_type, + identity_number, insurer_company) ) """ ) @@ -160,22 +158,20 @@ if __name__ == "__main__": raise RuntimeError("查询并获取单条购药及就医机构类型发生异常") # noinspection PyShadowingNames - def query_insured_person_records( + def query_insured_persons( self, - insurance_company: str, insurer_company: str, insured_person: str, identity_type: str, identity_number: str, ) -> Optional[List[Dict[str, Any]]]: """ - 查询并获取多条被保险人记录（例如，若夫妻同在投保公司则互为附加被保险人，一方被保险人记录包括本人和配偶两条） - :param insurance_company: 投保公司 + 根据保险分公司、被保险人、证件类型和证件号码查询被保险人（备注，若夫妻同在投保公司则互为附加被保险人，一方被保险人记录包括本人和配偶两条） :param insurer_company: 保险分公司 :param insured_person: 被保险人 - :param identity_type: 被保险人的证件类型 - :param identity_number: 被保险人的证件号码 - :return: 被保险人记录 + :param identity_type: 证件类型 + :param identity_number: 证件号码 + :return: 被保险人列表，包括被被保险人、个单号、主被保险人、与主被保险人关系、保险起期和保险止期 """ # noinspection PyBroadException try: @@ -183,21 +179,20 @@ if __name__ == "__main__": # noinspection SqlResolve result = self._query_all( sql=""" - SELECT insured_person AS "被保险人", - relationship AS "与主被保险人关系", + SELECT group_policy AS "团单号", person_policy AS "个单号", master_insured_person AS "主被保险人", + insured_person AS "被保险人", + relationship AS "与主被保险人关系", commencement_date AS "保险起期", termination_date AS "保险止期" - FROM insured_person_policies - WHERE insurance_company = ? - AND insurer_company = ? + FROM insured_persons + WHERE insurer_company = ? AND insured_person = ? AND identity_type = ? AND identity_number = ? """, parameters=( - insurance_company, insurer_company, insured_person, identity_type, @@ -208,7 +203,7 @@ if __name__ == "__main__": return [ { k: ( - datetime.fromtimestamp(v) + datetime.strptime(v, "%Y-%m-%d") # 保险 if k in ["保险起期", "保险止期"] else v ) @@ -217,9 +212,11 @@ if __name__ == "__main__": for e in result ] # 将保险起期和保险止期由时间戳转为datetime对象 raise - # TODO: 若查询并获取多条个单和被保险人记录发生异常则流转至主数据人工处理 + # TODO: 若根据保险分公司、被保险人、证件类型和证件号码查询被保险人发生异常则流转至主数据人工处理 except Exception: - raise RuntimeError("查询并获取多条个单和被保险人记录发生异常") + raise RuntimeError( + "根据保险分公司、被保险人、证件类型和证件号码查询被保险人发生异常" + ) # noinspection PyShadowingNames def query_medicine( @@ -462,24 +459,21 @@ if __name__ == "__main__": # noinspection PyShadowingNames def image_recognize( image, - insurance_company, insurer_company, ) -> None: """ 影像件识别并整合至赔案档案 :param image: 影像件 - :param insurance_company: 投保公司 :param insurer_company: 保险分公司 :return: 空 """ # TODO: 后续添加居民身份证(国徽面)和居民身份证(头像面)合并 # noinspection PyShadowingNames - def identity_card_recognize(image, insurance_company, insurer_company) -> None: + def identity_card_recognize(image, insurer_company) -> None: """ 居民身份证识别并整合至赔案档案 :param image: 影像件 - :param insurance_company: 投保公司 :param insurer_company: 保险分公司 :return: 空 """ @@ -574,8 +568,7 @@ if __name__ == "__main__": ) # 查询并获取多条被保险人记录 - dossier["被保险人层"] = master_data.query_insured_person_records( - insurance_company, + dossier["被保险人层"] = master_data.query_insured_persons( insurer_company, insured_person, # 出险人和被保险人为同一人，视角不同：出险人为理赔，被保险人为承保/保全 identity_type, @@ -1388,8 +1381,6 @@ if __name__ == "__main__": match (image["影像件类型"], receipt["购药及就医机构类型"]): # 就增值税发票且药店扣除不合理费用、增值税发票且私立医院解析个人自费、个人自付、医保支付、不合理金额和合理金额 case ("增值税发票", "药店"): - receipt["购药及就医类型"] = "药店购药" - items = ( pandas.DataFrame(receipt["明细项"]) .groupby("名称") # 就相同明细项名称合并数量和金额 @@ -1432,6 +1423,14 @@ if __name__ == "__main__": receipt.update( { + "起期": receipt["开票日期"], + "止期": receipt["开票日期"], + "姓名": ( + dossier["出险人层"]["姓名"] + if dossier["出险人层"]["姓名"] in receipt["姓名"] + else receipt["姓名"] + ), + "购药及就医类型": "药店购药", "个人自费": Decimal("0.00"), "个人自付": Decimal("0.00"), "医保支付": Decimal("0.00"), @@ -1448,6 +1447,7 @@ if __name__ == "__main__": "明细项": items.to_dict("records"), } ) + # TODO: 后续完善就购药及就医类型为门诊就诊（私立医院）处理 case ("增值税发票", "私立医院"): receipt["购药及就医类型"] = "门诊就医" @@ -1522,7 +1522,7 @@ if __name__ == "__main__": "居民身份证(国徽、头像面)" | "居民身份证(国徽面)" | "居民身份证(头像面)" ): # 居民身份证识别并整合至赔案档案 - identity_card_recognize(image, insurance_company, insurer_company) + identity_card_recognize(image, insurer_company) # TODO: 后续添加居民户口簿识别和整合方法 case "中国港澳台地区及境外护照": raise RuntimeError("暂不支持中国港澳台地区及境外护照") @@ -1618,7 +1618,6 @@ if __name__ == "__main__": # 影像件识别并整合至赔案档案 image_recognize( image, - insurance_company, insurer_company, )