Skip to content

Z
zhichan
Commit e9407975 by 王昆
Options

gsb

parent d515db8a
Showing with 140 additions and 144 deletions
laowubao/app/base/service/impl/operator/recruitSve.js
const system = require("../../../system"); const system = require("../../../system");
const ServiceBase = require("../../sve.base"); const ServiceBase = require("../../sve.base");
const settings = require("../../../../config/settings"); const settings = require("../../../../config/settings");
/** /**
* 招聘信息 * 招聘信息
*/ */
...@@ -11,10 +12,10 @@ class RecruitService extends ServiceBase { ...@@ -11,10 +12,10 @@ class RecruitService extends ServiceBase {
//this.restClient = system.getObject("util.restClient"); //this.restClient = system.getObject("util.restClient");
} }
async SaveRecruitInfo(params){//添加或更新招聘信息 async SaveRecruitInfo(params) {//添加或更新招聘信息
var id = params.id; var id = params.id;
var recruit; var recruit;
if (id){ if (id) {
recruit = await this.dao.findById(id); recruit = await this.dao.findById(id);
recruit.recruit_name = params.recruit_name; recruit.recruit_name = params.recruit_name;
recruit.recruit_type = params.recruit_type; recruit.recruit_type = params.recruit_type;
...@@ -42,116 +43,115 @@ class RecruitService extends ServiceBase { ...@@ -42,116 +43,115 @@ class RecruitService extends ServiceBase {
recruit.cur_status = params.cur_status; recruit.cur_status = params.cur_status;
recruit = await recruit.save(); recruit = await recruit.save();
recruit = await this.dao.findById(id); recruit = await this.dao.findById(id);
} } else {
else{
recruit = await this.dao.create(params); recruit = await this.dao.create(params);
} }
return system.getResultSuccess(recruit); return system.getResultSuccess(recruit);
} }
async findAllList(obj){//获取全部招聘信息，返回符合条件的列表 async findAllList(obj) {//获取全部招聘信息，返回符合条件的列表
var pageSize=obj.page_size || 10; var pageSize = obj.page_size || 10;
var currentPage=obj.current_page || 1; var currentPage = obj.current_page || 1;
try { try {
var where = {}; var where = {};
if(obj.userId) { if (obj.userId) {
where.user_id = obj.userId; where.user_id = obj.userId;
} }
var sqlwhere = { var sqlwhere = {
order: [["publish_date", 'desc']], order: [["publish_date", 'desc']],
limit: pageSize, limit: pageSize,
offset: (currentPage - 1) * pageSize, offset: (currentPage - 1) * pageSize,
raw: true, raw: true,
where: where where: where
}; };
//var list = await this.dao.model.findAll(sqlwhere); //var list = await this.dao.model.findAll(sqlwhere);
var list = await this.dao.model.findAndCountAll(sqlwhere) || []; var list = await this.dao.model.findAndCountAll(sqlwhere) || [];
return system.getResult(list); return system.getResult(list);
}catch (e) { } catch (e) {
console.log(e); console.log(e);
return system.getResult(null,"操作失败"); return system.getResult(null, "操作失败");
} }
} }
async findListByUserid(obj){//获取userid招聘信息，返回符合条件的列表 async findListByUserid(obj) {//获取userid招聘信息，返回符合条件的列表
if (!obj.user_id){ if (!obj.user_id) {
return system.getResult(null,"参数错误!"); return system.getResult(null, "参数错误!");
} }
var user_id = obj.user_id; var user_id = obj.user_id;
// var curStatus = obj.curStatus;//当前的状态 // var curStatus = obj.curStatus;//当前的状态
var curType = obj.curType;//当前的状态 var curType = obj.curType;//当前的状态
let where={}; let where = {};
if(user_id){ if (user_id) {
where.user_id=user_id; where.user_id = user_id;
} }
if(curType){ if (curType) {
where.cur_type=curType; where.cur_type = curType;
} }
// if(curStatus){ // if(curStatus){
// where.cur_status=curStatus; // where.cur_status=curStatus;
// } // }
var pageSize=obj.page_size || 10; var pageSize = obj.page_size || 10;
var currentPage=obj.current_page || 1; var currentPage = obj.current_page || 1;
try { try {
var sqlwhere = { var sqlwhere = {
where:where, where: where,
order: [["publish_date", 'desc']], order: [["publish_date", 'desc']],
limit: pageSize, limit: pageSize,
offset: (currentPage - 1) * pageSize, offset: (currentPage - 1) * pageSize,
raw: true raw: true
}; };
var list = await this.dao.model.findAndCountAll(sqlwhere) || []; var list = await this.dao.model.findAndCountAll(sqlwhere) || [];
return system.getResult(list); return system.getResult(list);
}catch (e) { } catch (e) {
console.log(e); console.log(e);
return system.getResult(null,"操作失败"); return system.getResult(null, "操作失败");
} }
} }
/** /**
* 更新上架 或下架 * 更新上架 或下架
*/ */
async UpdateCurStatus(params){ async UpdateCurStatus(params) {
try { try {
let cur_type = params.curType; let cur_type = params.curType;
let id = Number(params.id); let id = Number(params.id);
let data = {}; let data = {};
//1:展示中、2:已下架、3:已过期、4:审核未通过 //1:展示中、2:已下架、3:已过期、4:审核未通过
if(cur_type){ if (cur_type) {
data.cur_type=cur_type; data.cur_type = cur_type;
if(cur_type==1){ if (cur_type == 1) {
data.cur_status='展示中'; data.cur_status = '展示中';
}else if(cur_type==2){ } else if (cur_type == 2) {
data.cur_status='已下架'; data.cur_status = '已下架';
}else if(cur_type==3){ } else if (cur_type == 3) {
data.cur_status='已过期、4'; data.cur_status = '已过期、4';
}else if(cur_type==4){ } else if (cur_type == 4) {
data.cur_status='审核未通过'; data.cur_status = '审核未通过';
}else{ } else {
return system.getResult("参数错误 状态码不存在"); return system.getResult("参数错误 状态码不存在");
} }
} }
let res = await this.dao.model.update(data,{where:{id:id}}); let res = await this.dao.model.update(data, {where: {id: id}});
return system.getResult(res); return system.getResult(res);
} catch (error) { } catch (error) {
return system.getResult(-1, `系统错误 错误信息 ${error}`); return system.getResult(-1, `系统错误 错误信息 ${error}`);
} }
} }
async findListByName(obj){//获取岗位名称招聘信息，返回符合条件的列表 async findListByName(obj) {//获取岗位名称招聘信息，返回符合条件的列表
//return await this.dao.findListByName(obj); //return await this.dao.findListByName(obj);
if (!obj.recruit_name){ if (!obj.recruit_name) {
return system.getResult(null,"参数错误!"); return system.getResult(null, "参数错误!");
} }
var recruit_name = obj.recruit_name; var recruit_name = obj.recruit_name;
var pageSize=obj.page_size || 10; var pageSize = obj.page_size || 10;
var currentPage=obj.current_page || 1; var currentPage = obj.current_page || 1;
try{ try {
var sqlwhere = { var sqlwhere = {
where:{recruit_name:{[this.db.Op.like]: "%" + recruit_name + "%"}}, where: {recruit_name: {[this.db.Op.like]: "%" + recruit_name + "%"}},
order: [["publish_date", 'desc']], order: [["publish_date", 'desc']],
limit: pageSize, limit: pageSize,
offset: (currentPage - 1) * pageSize, offset: (currentPage - 1) * pageSize,
...@@ -159,119 +159,114 @@ class RecruitService extends ServiceBase { ...@@ -159,119 +159,114 @@ class RecruitService extends ServiceBase {
}; };
var list = await this.dao.model.findAndCountAll(sqlwhere) || []; var list = await this.dao.model.findAndCountAll(sqlwhere) || [];
return system.getResult(list); return system.getResult(list);
} } catch (error) {
catch{ return system.getResult(null, "操作失败");
return system.getResult(null,"操作失败");
} }
} }
async findListByMark(obj){//获取标签招聘信息，返回符合条件的列表 async findListByMark(obj) {//获取标签招聘信息，返回符合条件的列表
if (!obj.counter_mark){ if (!obj.counter_mark) {
return system.getResult(null,"参数错误!"); return system.getResult(null, "参数错误!");
} }
var counter_mark = obj.counter_mark; var counter_mark = obj.counter_mark;
var pageSize=obj.page_size || 10; var pageSize = obj.page_size || 10;
var currentPage=obj.current_page || 1; var currentPage = obj.current_page || 1;
try { try {
var sqlwhere = { var sqlwhere = {
where:{counter_mark:{[this.db.Op.like]: "%" + counter_mark + "%"}}, where: {counter_mark: {[this.db.Op.like]: "%" + counter_mark + "%"}},
order: [["publish_date", 'desc']], order: [["publish_date", 'desc']],
limit: pageSize, limit: pageSize,
offset: (currentPage - 1) * pageSize, offset: (currentPage - 1) * pageSize,
raw: true raw: true
}; };
var list = await this.dao.model.findAndCountAll(sqlwhere) || []; var list = await this.dao.model.findAndCountAll(sqlwhere) || [];
return system.getResult(list); return system.getResult(list);
}catch (e) { } catch (e) {
return system.getResult(null,"操作失败"); return system.getResult(null, "操作失败");
} }
} }
async findListByAddress(obj){//获取工作地址招聘信息，返回符合条件的列表-用于同城好单 async findListByAddress(obj) {//获取工作地址招聘信息，返回符合条件的列表-用于同城好单
if (!obj.work_address){ if (!obj.work_address) {
return system.getResult(null,"参数错误!"); return system.getResult(null, "参数错误!");
} }
var work_address = obj.work_address; var work_address = obj.work_address;
var pageSize=obj.page_size || 10; var pageSize = obj.page_size || 10;
var currentPage=obj.current_page || 1; var currentPage = obj.current_page || 1;
try { try {
var sqlwhere = { var sqlwhere = {
where:{work_address:{[this.db.Op.like]: "%" + work_address + "%"}}, where: {work_address: {[this.db.Op.like]: "%" + work_address + "%"}},
order: [["publish_date", 'desc']], order: [["publish_date", 'desc']],
limit: pageSize, limit: pageSize,
offset: (currentPage - 1) * pageSize, offset: (currentPage - 1) * pageSize,
raw: true raw: true
}; };
var list = await this.dao.model.findAndCountAll(sqlwhere) || []; var list = await this.dao.model.findAndCountAll(sqlwhere) || [];
return system.getResult(list); return system.getResult(list);
}catch (e) { } catch (e) {
return system.getResult(null,"操作失败"); return system.getResult(null, "操作失败");
} }
} }
async findRecruitByWhere(obj){//根据条件获取招聘信息 async findRecruitByWhere(obj) {//根据条件获取招聘信息
var pageSize=obj.page_size || 10; var pageSize = obj.page_size || 10;
var currentPage=obj.current_page || 1; var currentPage = obj.current_page || 1;
var where = {}; var where = {};
if (obj.id){ if (obj.id) {
where.id = obj.id; where.id = obj.id;
} }
if (obj.recruit_name){ if (obj.recruit_name) {
where.recruit_name = obj.recruit_name; where.recruit_name = obj.recruit_name;
} }
if (obj.recruit_type && obj.recruit_type != "全部"){ if (obj.recruit_type && obj.recruit_type != "全部") {
where.recruit_type = obj.recruit_type; where.recruit_type = obj.recruit_type;
} }
if (obj.pay_name && obj.pay_name != "全部"){ if (obj.pay_name && obj.pay_name != "全部") {
where.pay_name = obj.pay_name; where.pay_name = obj.pay_name;
} }
if (obj.rfee_type && obj.rfee_type != "全部"){ if (obj.rfee_type && obj.rfee_type != "全部") {
if (obj.rfee_type == "面议"){ if (obj.rfee_type == "面议") {
where.rfee_type = 0; where.rfee_type = 0;
} } else if (obj.rfee_type == "时返") {
else if (obj.rfee_type == "时返"){
where.rfee_type = 3; where.rfee_type = 3;
} } else if (obj.rfee_type == "月返") {
else if (obj.rfee_type == "月返"){
where.rfee_type = 1; where.rfee_type = 1;
} } else if (obj.rfee_type == "日返") {
else if (obj.rfee_type == "日返"){
where.rfee_type = 2; where.rfee_type = 2;
} } else if (obj.rfee_type == "一次返") {
else if (obj.rfee_type == "一次返"){
where.rfee_type = 4; where.rfee_type = 4;
} }
} }
if (obj.work_address && obj.work_address != "全部"){ if (obj.work_address && obj.work_address != "全部") {
where.work_address = {[this.db.Op.like]: "%" + obj.work_address + "%"}; where.work_address = {[this.db.Op.like]: "%" + obj.work_address + "%"};
} }
if (obj.user_id){ if (obj.user_id) {
where.user_id = obj.user_id; where.user_id = obj.user_id;
} }
if (obj.phone_no){ if (obj.phone_no) {
where.phone_no = obj.phone_no; where.phone_no = obj.phone_no;
} }
if (obj.cur_status && obj.cur_status != "全部"){ if (obj.cur_status && obj.cur_status != "全部") {
where.cur_status = obj.cur_status; where.cur_status = obj.cur_status;
} }
try { try {
var sqlwhere = { var sqlwhere = {
where: where, where: where,
order: [["publish_date", 'desc']], order: [["publish_date", 'desc']],
limit: pageSize, limit: pageSize,
offset: (currentPage - 1) * pageSize, offset: (currentPage - 1) * pageSize,
raw: true raw: true
}; };
var list = await this.dao.model.findAndCountAll(sqlwhere) || []; var list = await this.dao.model.findAndCountAll(sqlwhere) || [];
if(list) { if (list) {
await this.setUserInfo(list.rows); await this.setUserInfo(list.rows);
} }
return system.getResult(list); return system.getResult(list);
}catch (e) { } catch (e) {
console.log(e); console.log(e);
return system.getResult(null,"操作失败"); return system.getResult(null, "操作失败");
} }
} }
...@@ -290,46 +285,43 @@ class RecruitService extends ServiceBase { ...@@ -290,46 +285,43 @@ class RecruitService extends ServiceBase {
} }
} }
async updatestatus(obj){//更新状态信息 async updatestatus(obj) {//更新状态信息
try{ try {
var whereobj = {where:{id: obj.id}}; var whereobj = {where: {id: obj.id}};
var setobj = {}; var setobj = {};
setobj.cur_status = obj.cur_status; setobj.cur_status = obj.cur_status;
if (obj.cur_status == "展示中"){ if (obj.cur_status == "展示中") {
setobj.cur_type = 1; setobj.cur_type = 1;
} } else if (obj.cur_status == "已下架") {
else if (obj.cur_status == "已下架"){
setobj.cur_type = 2; setobj.cur_type = 2;
} } else if (obj.cur_status == "已过期") {
else if (obj.cur_status == "已过期"){
setobj.cur_type = 3; setobj.cur_type = 3;
} } else if (obj.cur_status == "审核未通过") {
else if (obj.cur_status == "审核未通过"){
setobj.cur_type = 4; setobj.cur_type = 4;
} }
var self = this; var self = this;
var v = await this.db.transaction(async function (t) { var v = await this.db.transaction(async function (t) {
await self.dao.updateByWhere(setobj,whereobj,t); await self.dao.updateByWhere(setobj, whereobj, t);
}); });
return 1; return 1;
} } catch (e) {
catch (e){
console.log(e); console.log(e);
return 0; return 0;
} }
} }
/** /**
* 删除用户下制定 招聘或这是供招信息记录 * 删除用户下制定 招聘或这是供招信息记录
* @param {*} params * @param {*} params
*/ */
async RemRecOrLob(params){ async RemRecOrLob(params) {
try { try {
let res= await this.dao.model.destroy({ let res = await this.dao.model.destroy({
where:{ where: {
id:params.id, id: params.id,
user_id:params.userId user_id: params.userId
} }
}); });
return system.getResult(res); return system.getResult(res);
...@@ -337,19 +329,20 @@ class RecruitService extends ServiceBase { ...@@ -337,19 +329,20 @@ class RecruitService extends ServiceBase {
return system.getResult(-1, `系统错误 错误信息 ${error}`); return system.getResult(-1, `系统错误 错误信息 ${error}`);
} }
} }
/** /**
* 定时刷新招聘 * 定时刷新招聘
*/ */
async UpdateRecruitExpired(){ async UpdateRecruitExpired() {
try { try {
let nowTime=new Date(); let nowTime = new Date();
await this.dao.model.update({ await this.dao.model.update({
cur_type:3, cur_type: 3,
cur_status:"已过期" cur_status: "已过期"
},{ }, {
where:{ where: {
end_date:{ end_date: {
[this.db.Op.between]: ["1970-01-02",nowTime ], [this.db.Op.between]: ["1970-01-02", nowTime],
} }
} }
}); });
...@@ -362,17 +355,20 @@ class RecruitService extends ServiceBase { ...@@ -362,17 +355,20 @@ class RecruitService extends ServiceBase {
async ParamRecruitExcel(obj) {//批量上传 async ParamRecruitExcel(obj) {//批量上传
var resu = obj.dataList; var resu = obj.dataList;
try { try {
await this.dao.model.bulkCreate(resu, {fields: ["recruit_name", "recruit_type", "recruit_count", "pay_type", "pay_name", await this.dao.model.bulkCreate(resu, {
"pay_unit", "basic_salary", "compre_salary","work_duration","rfee_type","rfee_unit","rfee_duration","rfee_time","age_range", fields: ["recruit_name", "recruit_type", "recruit_count", "pay_type", "pay_name",
"work_address","publish_date","end_date","pic_path","recrui_require","phone_no","user_id","counter_mark","cur_type","cur_status"]}); "pay_unit", "basic_salary", "compre_salary", "work_duration", "rfee_type", "rfee_unit", "rfee_duration", "rfee_time", "age_range",
return 1; "work_address", "publish_date", "end_date", "pic_path", "recrui_require", "phone_no", "user_id", "counter_mark", "cur_type", "cur_status"]
});
return 1;
} catch (e) { } catch (e) {
console.log(e); console.log(e);
return 0; return 0;
} }
} }
} }
module.exports = RecruitService; module.exports = RecruitService;
// var tesk = new RecruitService(); // var tesk = new RecruitService();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment