class DynamicCondition(DynamicConditionBase):
    """
    用于列表添加动态过滤条件
    使用示例:"conditions": {"job_info.employee_category_id": "dynamic#employee_category_dynamic_condition"}
    """
    def condition(self, query_, field_, condition_context):
        result = self.call_open_api("hcm.model.list", param={"model": "emp_role_detail", "filter_dict": {
            "employee_id": self.plugin_context.employee.id}})['list']

        job_step_value = [0]
        if len(result) > 0:
            if result[0]['emp_type'] == 1:  # 是什么类型人员
                job_step_value = [546, 547, 548]
            elif result[0]['emp_type'] == 2:
                job_step_value = [549, 550, 551]
            else:
                job_step_value = [0]
        query_ = query_.filter(field_.in_(job_step_value))
        return query_

class EndBeginTimeChecker(DynamicCheckBase):
    """
    云函数校验器示例，在对象新增，修改时会校验
    """
    def check(self, info):
        result = {}
        result['success'] = True
        return result

class ModelPlugInXXX(BaseModelPlugIn):
    """
    模型插件
    应用范围：create_data,edit_data,remove_data,remove_datas
    如果类型为pre，调用pre方法，类型为post，调用post方法
    """
    def pre(self, company_id, **kwargs):
        """
        Pre插件
        kwargs:经过转换的原函数调用参数，经过干预后，返回kwargs继续调用原函数
        """
        return kwargs
    
    def post(self, company_id, result,**kwargs):
        """
        Post插件
        result：原函数调用返回的结果，经过干预后，返回
        kwargs：原函数调用参数
        """
        return result

class ListPlugInXXX(BaseListPlugIn):
    """
    模型data list插件
    应用范围：对list接口返回的数据进行二次处理
    """
    def post(self, context, _list, _count, plugin_config, **kwargs):
        for _l in _list:
            _id = _l.get('id')
            _l['name']='aaaa'
            logging.info(_id)
        return _list, _count

class VirtualAction(DynamicActionBase):
    """
    动态Action方法，装成模型上的方法
    使用方法
    """

    def action(self, method_context, params):
        # raise NotImplementedError
        logging.info(method_context)
        logging.info("in method")
        logging.info(params)
        return params

class XXXXChecher(DynamicValidateCheckBase): 
    """
     数据检查，主要是检查数据逻辑关系是否有问题，返回值是 ['xxxxx1数据有问题','xxxx2数据有问题']     
""" 
    def check(self, **kwargs): 
        error_msg = [] 
        model = self.get_model('EmployeeEducation') 
        rows = self.db.query(model).filter(model.company_id == self.context.company.id).all() 
        emp_group = {} 
        for row in rows: 
            if len(emp_educations) == 0:     
            error_msg.append('人员:{}的最高学历为空'.format(emp)) 
            elif len(emp_educations) > 1:     
            error_msg.append('人员:{}的最高学历大于一个'.format(emp))  
        return error_msg

class DynamicFunctionReport(BaseFormulaObject):
    """
    报表云函数
    """

    def do(self,dept_id):
        # 引入日志
        company_id = self.context.get('COMPANY_ID')
        return {}

class BaseSalaryFormula(BaseSalaryFormulaObject):
    """
    薪酬公式云函数示例
    """
    def execute(self):
        _cache_key = 'my_cache_key'
        _cache = self.executor.context.get(_cache_key)
        if _cache is None:
            employee_ids = [_p.get('employee_id') for _p in self.context['profile_list']]
            #你的取数逻辑
            self.executor.context[_cache_key] = _cache
        _result = _cache.get(self.context['profile']['employee_id'], 0)
        return _result

class BaseSocialFormula(BaseSocialFormulaObject):
    """
    社保公式云函数示例
    """
    def execute(self):
        _cache_key = 'my_cache_key'
        _cache = self.executor.context.get(_cache_key)
        if _cache is None:
            employee_ids = [_p.get('employee_id') for _p in self.context['profile_list']]
            #你的取数逻辑
            self.executor.context[_cache_key] = _cache
        _result = _cache.get(self.context['profile']['employee_id'], 0)
        return _result

class WorkFlowDynamicScriptHandle(WorkFlowDynamicScriptBase):
    def execute(self, **kwargs):
        """
        方案很合理可能多项目使用,可以联系下流程平台作为经典解决方案案例
        :param kwargs:
        :return:
        """
        #  1. 原则上禁止重复接口多次调用,禁止使用 for 循环调用接口 . (不得不多次调用除外)
        #  2. 尽量不使用 try,如果是校验可以 raise
        #  3. 云函数标准耗时原则耗时不超 1秒
        #  4. log 测试完成后需要移除
        return

class CommonFormulaGETMESD(BaseCustomerFormulaObject):
    """
    公共个性化公式云函数示例
    """

    def execute(self, u_department_code, u_date, u_team_name, u_post_name, u_assess_desc, **kwargs):
        """
        取MES模型某车间，某天，某班组，某岗位的某指标的数值 模型: U_MES_XJ_FFJ_01
        C_GET_MES_D($('档案参数.车间（工段）编号'),$('档案参数.日期'),$('档案参数.班组'),$('档案参数.岗位'),'淀粉投入量')
        """
        param = {
            'model': 'U_MES_XJ_FFJ_01',
            'filter_dict': {'u_date': u_date,
                            'u_post_name': u_post_name,
                            'u_department_code': u_department_code,
                            'u_team_name': u_team_name,
                            'u_assess_desc': u_assess_desc},
            'extra_property': {
                'only_list': True,
                'fields': [
                    {'field': ['u_quanity_num']}
                ]
            }
        }
        _list = CustomerUtil.call_open_api("hcm.model.list", param)["list"]
        if _list:
            result = _list[0]["u_quanity_num"]
        else:
            result = None
        return result

class TestNumToId(BasePrivateApiService):
    """
    动态私有OpenAPI
    使用方法
    """
    def execute(self, **kwargs):
        """
        参数：number
        default 设置为None时，如果编码换取不到ID时，程序不会抛出异常
        """
        position_id = DataUtil.convert_num_to_id('OrgPosition', kwargs['number'], default=None) # 组织类，岗位ID
        employee_category_id = DataUtil.convert_num_to_id('EmployeeCategory', kwargs['number'], default=None) # 实体类，用工类型ID
        business_id = DataUtil.convert_num_to_id('Business', kwargs['number'], default=None) # 流程，流程ID
        item_id = DataUtil.convert_num_to_id('common_basic_item_data.性别', kwargs['number'], default=None) # 码表，代码项ID；如果是树形代码项，需要保证number唯一
		return