poyee-data-warehouse/dw_base/spark/udf/enterprise/ent_india_offline_udf.py

# 企业库印度唯一性调整，离线数据udf
from datetime import datetime


def clean_zau_date(zau_date):
    try:
        # 尝试解析日期字符串
        date_obj = datetime.strptime(zau_date, "%d %B %Y")
        # 格式化为新的日期字符串
        return date_obj.strftime("%Y-%m-%d")
    except (ValueError, TypeError):
        # 如果解析失败或类型错误，返回 None
        return None


def clean_his_gs_date(his_gs_date):
    try:
        # 解析输入的日期字符串
        date_obj = datetime.strptime(his_gs_date, "%d-%m-%Y")
        # 格式化为新的日期字符串
        return date_obj.strftime("%Y-%m-%d")
    except ValueError:
        # 如果解析失败，返回 None
        return None