06-06-04 发送消息

class salary_entry_emp_warn(object):
    def execute(self,params):
        last_month = (datetime.datetime.now() + dateutil.relativedelta.relativedelta(months=-1)).strftime("%Y-%m")
        emp_list =self.get_entry_emp_list(month=last_month)
        if not emp_list:
            return
        role_list = self.get_salary_role_list()
        if not role_list:
            return
        emp_dict = {}
        for emp in emp_list:
            depart_id=emp.get("department").get("origin_id")
            if not depart_id:
                continue
            emp_dict[depart_id] = emp_dict.get(depart_id,"") + "{}({}) ".format(emp.get("name"),emp.get("number"))
        #组装消息
        msg_list = []
        for k, v in emp_dict.items():
            #接收人id
            receiver_id_list = [p.get("object_id") for p in role_list if p.get("role_range").get("depart_id") == k]
            #消息内容
            message = "{}-21号之后入职的员工有：{}".format(last_month,v)
            for receiver_id in receiver_id_list:
                msg_list.append({"sender": 0, "to": receiver_id, "content": message})
        if not msg_list:
            return
        #发送消息
        CustomerUtil.call_open_api(name="message.send.message", param={"msglist": msg_list})
       
    def get_entry_emp_list(self,month):
        """
        获取人员数据
        :param month: 
        :return: 
        """
        return  CustomerUtil.call_open_api(
            name="hcm.model.list",
            param={
                "model": "Employee",
                "page_index": 1,
                "page_size": 9999,
                "filter_dict": {
                    "entry_date": {"gte": "{}-21".format(month)}
                },
                "extra_property": {
                    "only_list": True,
                    "state": "search_zcl",
                    "sorts": [{"type": "asc", "key": "number"}],
                    "fields": [
                        {"field": ["name"], "key": "employee_name"},
                        {"field": ["number"], "key": "employee_number"},
                        {"field": ["department", "origin_id"], "key": "depart_id"}
                    ]
                }
            }
        )["list"]
    def get_salary_role_list(self):
        """
        获取薪酬专员角色信息
        :return: 
        """
        return CustomerUtil.call_open_api(
            name="hcm.model.list",
            param={
                "model": "SystemEmployeeRoles",
                "page_index": 1,
                "page_size": 9999,
                "filter_dict": {
                    "object_type": 1,
                    "role": "cm-salary"
                },
                "extra_property": {
                    "state": "search_zcl",
                    "only_list": True,
                    "fields": [
                        {"field": ["object_id"], "key": "object_id"},
                        {"field": ["object_type"], "key": "object_type"},
                        {"field": ["role"], "key": "role"},
                        {"field": ["role_range", "depart_id"], "key": "depart_id"}
                    ],
                    "relations": [
                        {
                            "filter": {
                                "role_range.object_type": 1,
                                "role_range.role": "cm-salary",
                                "object_id": ":role_range.object_id"
                            },
                            "type": "outer",
                            "model": "SystemRoleRange",
                            "key": "role_range"
                        }
                    ]
                }

            }
        )["list"]