use reqwest::Method;
use serde::{Deserialize, Serialize};
use crate::{
core::{
api_req::ApiRequest,
api_resp::{ApiResponseTrait, BaseResponse, ResponseFormat},
config::Config,
constants::AccessTokenType,
endpoints::hire::*,
endpoints::EndpointBuilder,
http::Transport,
req_option::RequestOption,
SDKResult,
},
service::hire::models::{CommonResponse, I18nText, PageResponse},
};
pub struct WebsiteService {
pub config: Config,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct WebsiteJob {
pub id: String,
pub title: String,
pub description: Option<String>,
pub requirement: Option<String>,
pub location: Option<String>,
pub job_type: Option<String>,
pub salary_range: Option<String>,
pub publish_status: String,
pub publish_time: Option<String>,
pub deadline: Option<String>,
pub view_count: u32,
pub apply_count: u32,
pub tags: Vec<String>,
pub created_time: Option<String>,
pub updated_time: Option<String>,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct WebsiteApplication {
pub id: String,
pub job_id: String,
pub candidate_name: String,
pub candidate_email: String,
pub candidate_phone: Option<String>,
pub resume_url: Option<String>,
pub status: String,
pub apply_time: String,
pub candidate_remark: Option<String>,
pub source: Option<String>,
pub ip_address: Option<String>,
pub user_agent: Option<String>,
pub created_time: Option<String>,
pub updated_time: Option<String>,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct WebsiteConfiguration {
pub id: String,
pub site_name: I18nText,
pub site_description: Option<I18nText>,
pub logo_url: Option<String>,
pub contact_email: Option<String>,
pub contact_phone: Option<String>,
pub theme_config: Option<serde_json::Value>,
pub seo_config: Option<SeoConfig>,
pub enabled: bool,
pub created_time: Option<String>,
pub updated_time: Option<String>,
}
#[derive(Debug, Serialize, Deserialize, Default)]
pub struct SeoConfig {
}
#[derive(Debug, Serialize, Deserialize, Default)]
pub struct WebsiteJobPublishRequest {
pub job_id: String,
pub publish: bool,
pub publish_time: Option<String>,
pub deadline: Option<String>,
pub tags: Vec<String>,
}
#[derive(Debug, Serialize, Deserialize, Default)]
pub struct WebsiteApplicationListRequest {
pub page_size: Option<u32>,
pub page_token: Option<String>,
pub job_id: Option<String>,
pub status: Option<String>,
pub candidate_name: Option<String>,
pub candidate_email: Option<String>,
pub apply_start_time: Option<String>,
pub apply_end_time: Option<String>,
}
#[derive(Debug, Serialize, Deserialize, Default)]
pub struct WebsiteConfigurationUpdateRequest {
pub site_name: Option<I18nText>,
pub site_description: Option<I18nText>,
pub logo_url: Option<String>,
pub contact_email: Option<String>,
pub contact_phone: Option<String>,
pub theme_config: Option<serde_json::Value>,
pub seo_config: Option<SeoConfig>,
pub enabled: Option<bool>,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct WebsiteJobListResponse {
#[serde(flatten)]
pub jobs: PageResponse<WebsiteJob>,
}
impl ApiResponseTrait for WebsiteJobListResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct WebsiteApplicationListResponse {
#[serde(flatten)]
pub applications: PageResponse<WebsiteApplication>,
}
impl ApiResponseTrait for WebsiteApplicationListResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct WebsiteConfigurationResponse {
pub configuration: WebsiteConfiguration,
}
impl ApiResponseTrait for WebsiteConfigurationResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct WebsiteOperationResponse {
#[serde(flatten)]
pub result: CommonResponse,
pub id: Option<String>,
}
impl ApiResponseTrait for WebsiteOperationResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
impl WebsiteService {
pub fn new(config: Config) -> Self {
Self { config }
}
pub async fn list_website_jobs(
&self,
page_size: Option<u32>,
page_token: Option<String>,
publish_status: Option<String>,
job_type: Option<String>,
location: Option<String>,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<WebsiteJobListResponse>> {
let mut api_req = ApiRequest {
http_method: Method::GET,
api_path: HIRE_V1_WEBSITE_JOBS.to_string(),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: vec![],
..Default::default()
};
if let Some(page_size) = page_size {
api_req
.query_params
.insert("page_size", page_size.to_string());
}
if let Some(page_token) = page_token {
api_req.query_params.insert("page_token", page_token);
}
if let Some(publish_status) = publish_status {
api_req
.query_params
.insert("publish_status", publish_status);
}
if let Some(job_type) = job_type {
api_req.query_params.insert("job_type", job_type);
}
if let Some(location) = location {
api_req.query_params.insert("location", location);
}
Transport::request(api_req, &self.config, option).await
}
pub async fn publish_job_to_website(
&self,
request: WebsiteJobPublishRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<WebsiteOperationResponse>> {
let api_req = ApiRequest {
http_method: Method::POST,
api_path: HIRE_V1_WEBSITE_JOBS_PUBLISH.to_string(),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: serde_json::to_vec(&request).unwrap_or_default(),
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
pub async fn unpublish_job_from_website(
&self,
job_id: &str,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<WebsiteOperationResponse>> {
let api_req = ApiRequest {
http_method: Method::POST,
api_path: EndpointBuilder::replace_param(
HIRE_V1_WEBSITE_JOB_UNPUBLISH,
"job_id",
job_id,
),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: vec![],
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
pub async fn list_website_applications(
&self,
request: WebsiteApplicationListRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<WebsiteApplicationListResponse>> {
let mut api_req = ApiRequest {
http_method: Method::GET,
api_path: HIRE_V1_WEBSITE_APPLICATIONS.to_string(),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: vec![],
..Default::default()
};
if let Some(page_size) = request.page_size {
api_req
.query_params
.insert("page_size", page_size.to_string());
}
if let Some(page_token) = request.page_token {
api_req.query_params.insert("page_token", page_token);
}
if let Some(job_id) = request.job_id {
api_req.query_params.insert("job_id", job_id);
}
if let Some(status) = request.status {
api_req.query_params.insert("status", status);
}
if let Some(candidate_name) = request.candidate_name {
api_req
.query_params
.insert("candidate_name", candidate_name);
}
if let Some(candidate_email) = request.candidate_email {
api_req
.query_params
.insert("candidate_email", candidate_email);
}
if let Some(apply_start_time) = request.apply_start_time {
api_req
.query_params
.insert("apply_start_time", apply_start_time);
}
if let Some(apply_end_time) = request.apply_end_time {
api_req
.query_params
.insert("apply_end_time", apply_end_time);
}
Transport::request(api_req, &self.config, option).await
}
pub async fn get_website_configuration(
&self,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<WebsiteConfigurationResponse>> {
let api_req = ApiRequest {
http_method: Method::GET,
api_path: HIRE_V1_WEBSITE_CONFIGURATION.to_string(),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: vec![],
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
pub async fn update_website_configuration(
&self,
request: WebsiteConfigurationUpdateRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<WebsiteOperationResponse>> {
let api_req = ApiRequest {
http_method: Method::POST,
api_path: HIRE_V1_WEBSITE_CONFIGURATION.to_string(),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: serde_json::to_vec(&request).unwrap_or_default(),
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
pub async fn convert_website_application(
&self,
website_application_id: &str,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<WebsiteOperationResponse>> {
let api_req = ApiRequest {
http_method: Method::POST,
api_path: EndpointBuilder::replace_param(
HIRE_V1_WEBSITE_APPLICATION_CONVERT,
"website_application_id",
website_application_id,
),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: vec![],
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
pub async fn get_website_job_statistics(
&self,
job_id: Option<String>,
start_date: Option<String>,
end_date: Option<String>,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<serde_json::Value>> {
let mut api_req = ApiRequest {
http_method: Method::GET,
api_path: HIRE_V1_WEBSITE_STATISTICS.to_string(),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: vec![],
..Default::default()
};
if let Some(job_id) = job_id {
api_req.query_params.insert("job_id", job_id);
}
if let Some(start_date) = start_date {
api_req.query_params.insert("start_date", start_date);
}
if let Some(end_date) = end_date {
api_req.query_params.insert("end_date", end_date);
}
Transport::request(api_req, &self.config, option).await
}
}