Skip to content

Z
zhichan
Commit 83bda4e5 by 高宇强
Options

gyq

parent 0ec3cc10
Showing with 508 additions and 8 deletions
ic-deliver/app/base/controller/impl/bizchance/MaterialCtl.js 0 → 100644
var system = require("../../../system");
const http = require("http");
const querystring = require('querystring');
var settings = require("../../../../config/settings");
const CtlBase = require("../../ctl.base");
const moment = require('moment');
class MaterialCtl extends CtlBase {
constructor() {
super("bizchance", CtlBase.getServiceName(MaterialCtl));
}
/*根据交付单id获取材料信息*/
async findInfoByDeliverId(pobj,qobj,req){
if (pobj.deliverId && pobj.deliverId != 'undefined')
{
try{
var rs = await this.service.findInfoByDeliverId(pobj);
var rarr = {};
if (rs){
rarr.deliverId = rs.delivery_id;
rarr.deliverNumber = rs.delivery_code;
rarr.companyInfo = rs.company_info;
rarr.registeredInfo = rs.registered_info;
rarr.contributionInfo = rs.contribution_info;
rarr.positionInfo = rs.position_info;
rarr.regInfo = rs.file_info;
rarr.expressInfo = rs.express_info;
}
return system.getResult(rarr);
}
catch(error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误！");
}
}
/*根据交付单id更新交付单编号信息*/
async updateInfoByDeliverId(pobj,qobj,req){
if (pobj.deliverId && pobj.deliverId != 'undefined' && pobj.deliverNumber && pobj.deliverNumber != 'undefined'){
try{
var res = await this.service.updateInfoByDeliverId(pobj);
return system.getResult("更新成功！");
}
catch (error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误!");
}
}
/*插入缓存信息 */
async insertInfo(pobj,qobj,req){
if (pobj.deliverId && pobj.deliverId != 'undefined'){
try{
var res = await this.service.insertInfo(pobj);
return system.getResult("插入成功！");
}
catch (error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误!");
}
}
timeFormat(date) {
let localTime = moment.utc(date).toDate();
localTime = moment(localTime).format("YYYY-MM-DD");
return localTime;
}
}
module.exports = MaterialCtl;
// var task = new CacheInfoCtl();
// var obj={"demand_code":"30030302992","business_status":"isFinished"};
// task.updateStatusByDemandCode(obj,{},{}).then(d=>{
// console.log(d);
// //console.log(d[0].analyse);
// })
ic-deliver/app/base/controller/impl/bizchance/bizoptCtl.js
...@@ -9,6 +9,7 @@ class BizOptCtl extends CtlBase { ...@@ -9,6 +9,7 @@ class BizOptCtl extends CtlBase {
super("bizchance", CtlBase.getServiceName(BizOptCtl)); super("bizchance", CtlBase.getServiceName(BizOptCtl));
} }
/*根据用户id获取商机信息，分页获取*/
async findAndCountAll(pobj, qobj, req) { async findAndCountAll(pobj, qobj, req) {
try { try {
//TODO 根据业务员id获取该业务员所有列表 //TODO 根据业务员id获取该业务员所有列表
...@@ -19,14 +20,14 @@ class BizOptCtl extends CtlBase { ...@@ -19,14 +20,14 @@ class BizOptCtl extends CtlBase {
let results = rs.results.rows; let results = rs.results.rows;
results.forEach(element => { results.forEach(element => {
let robj = {}; let robj = {};
robj.demand_code = element.demand_code; robj.id = element.id;//数据的id
robj.source = element.source; robj.demand_code = element.demand_code;//商机编号
robj.business_type = element.business_type; robj.source = element.source_name;//商机来源
robj.business_info_person = element.business_info.person; robj.business_type = element.business_type;//商机类型
robj.business_info_phone = element.business_info.phone; robj.business_info_person = element.business_info.contacts_name;//联系人
robj.business_status = element.business_status; robj.business_info_phone = element.business_info.contacts_phone;//联系电话
robj.updated_at = this.timeFormat(element.updated_at); robj.business_status = element.business_status;//商机当前状态
robj.updated_at = this.timeFormat(element.updated_at);//商机当前状态日期
rarr.push(robj); rarr.push(robj);
}); });
rs.results.rows = rarr; rs.results.rows = rarr;
...@@ -36,6 +37,60 @@ class BizOptCtl extends CtlBase { ...@@ -36,6 +37,60 @@ class BizOptCtl extends CtlBase {
} }
} }
/*根据商机编号获取商机详情*/
async findInfoByDemandCode(pobj,qobj,req){
if (pobj.businessMode && pobj.businessMode != 'undefined')
{
try{
var rs = await this.service.findInfoByDemandCode(pobj);
var rarr = {}
if (rs){
rarr.id = rs.id;//数据的id
rarr.businessMode = rs.demand_code;//商机编号
rarr.channelSource = rs.source_name;//渠道来源
rarr.businessType = rs.business_type;//商机类型
rarr.currentStatus = rs.business_status;//商机状态
rarr.serviceArea = rs.service_address;//服务地区
rarr.statusReason = rs.close_reason;//商机关闭原因
rarr.clerkName = rs.salesman_name;//业务员名称
rarr.clerkPhone = rs.salesman_phone;//业务员联系方式
rarr.memoInfo = rs.business_info.memo_info;//备注信息
rarr.contactsName = rs.business_info.contacts_name;//联系人名称
rarr.contactsPhone = rs.business_info.contacts_phone;//联系人联系方式
rarr.createdTime = this.timeFormat(rs.created_at);//商机创建时间
rarr.statusTime = this.timeFormat(rs.updated_at);//当前状态时间
}
return system.getResult(rarr);
}
catch(error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误！");
}
}
/*根据商机编号更新商机状态*/
async updateStatusByDemandCode(pobj,qobj,req){
if (pobj.businessMode && pobj.businessMode != 'undefined' && pobj.currentStatus && pobj.currentStatus != 'undefined'){
try{
var res = await this.service.updateStatusByDemandCode(pobj);
//调商城接口，回传状态信息，后加
return system.getResult("更新成功！");
}
catch (error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误!");
}
}
timeFormat(date) { timeFormat(date) {
let localTime = moment.utc(date).toDate(); let localTime = moment.utc(date).toDate();
localTime = moment(localTime).format("YYYY-MM-DD"); localTime = moment(localTime).format("YYYY-MM-DD");
...@@ -43,3 +98,11 @@ class BizOptCtl extends CtlBase { ...@@ -43,3 +98,11 @@ class BizOptCtl extends CtlBase {
} }
} }
module.exports = BizOptCtl; module.exports = BizOptCtl;
var task = new BizOptCtl();
var obj={"demand_code":"30030302991","business_status":"isClosed","close_reason":"嗯哈哈"};
task.updateStatusByDemandCode(obj,{},{}).then(d=>{
console.log(d);
//console.log(d[0].analyse);
})
ic-deliver/app/base/controller/impl/bizchance/cacheinfoCtl.js 0 → 100644
var system = require("../../../system");
const http = require("http");
const querystring = require('querystring');
var settings = require("../../../../config/settings");
const CtlBase = require("../../ctl.base");
const moment = require('moment');
class CacheInfoCtl extends CtlBase {
constructor() {
super("bizchance", CtlBase.getServiceName(CacheInfoCtl));
}
/*根据交付单id获取缓存详情*/
async findInfoByDeliverId(pobj,qobj,req){
if (pobj.deliver_id && pobj.deliver_id != 'undefined')
{
try{
var rs = await this.service.findInfoByDeliverId(pobj);
var rarr = {};
if (rs){
rarr.deliverId = rs.deliver_id;
rarr.cacheInfo = rs.cache_info;
}
return system.getResult(rarr);
}
catch(error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误！");
}
}
/*根据交付单id更新缓存信息*/
async updateInfoByDeliverId(pobj,qobj,req){
if (pobj.deliver_id && pobj.deliver_id != 'undefined' && pobj.cache_info && pobj.cache_info != 'undefined'){
try{
var res = await this.service.updateInfoByDeliverId(pobj);
return system.getResult("更新成功！");
}
catch (error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误!");
}
}
/*插入缓存信息 */
async insertInfo(pobj,qobj,req){
if (pobj.deliver_id && pobj.deliver_id != 'undefined' && pobj.cache_info && pobj.cache_info != 'undefined'){
try{
var res = await this.service.insertInfo(pobj);
return system.getResult("插入成功！");
}
catch (error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误!");
}
}
timeFormat(date) {
let localTime = moment.utc(date).toDate();
localTime = moment(localTime).format("YYYY-MM-DD");
return localTime;
}
}
module.exports = CacheInfoCtl;
// var task = new CacheInfoCtl();
// var obj={"demand_code":"30030302992","business_status":"isFinished"};
// task.updateStatusByDemandCode(obj,{},{}).then(d=>{
// console.log(d);
// //console.log(d[0].analyse);
// })
ic-deliver/app/base/controller/impl/bizchance/deliverybillCtl.js 0 → 100644
var system = require("../../../system");
const http = require("http");
const querystring = require('querystring');
var settings = require("../../../../config/settings");
const CtlBase = require("../../ctl.base");
const moment = require('moment');
class DeliverybillCtl extends CtlBase {
constructor() {
super("bizchance", CtlBase.getServiceName(DeliverybillCtl));
}
/*根据用户id获取商机信息，分页获取*/
async findAndCountAll(pobj, qobj, req) {
try {
//TODO 根据业务员id获取该业务员所有列表
//设置查询条件
console.log("pobj--",pobj)
const rs = await this.service.findAndCountAll(pobj);
let rarr = [];
let results = rs.results.rows;
results.forEach(element => {
let robj = {};
robj.id = element.id;//数据的id
robj.deliverNumber = element.deliver_code;//交付单编号
robj.businessName = element.product_name;//产品名称
robj.businessType = element.product_code;//产品编码
robj.channelSource = element.source_name;//渠道名称
robj.channelNumber = element.source_number;//渠道编码
if (robj.businessName != '工商注册' && robj.businessName != '云上园区注册'){
robj.relatedProducts = '无';
}
// else{
// //获取材料信息中的
// }
robj.business_info_person = element.business_info.contacts_name;//联系人
robj.business_info_phone = element.business_info.contacts_phone;//联系电话
robj.business_status = element.business_status;//商机当前状态
robj.updated_at = this.timeFormat(element.updated_at);//商机当前状态日期
rarr.push(robj);
});
rs.results.rows = rarr;
return system.getResult(rs);
} catch (error) {
return system.getResultError(error);
}
}
/*根据交付单编号获取交付单详情*/
async findInfoByDeliverCode(pobj,qobj,req){
if (pobj.businessMode && pobj.businessMode != 'undefined')
{
try{
var rs = await this.service.findInfoByDeliverCode(pobj);
var rarr = {}
if (rs){
rarr.id = rs.id;//数据的id
rarr.businessMode = rs.demand_code;//商机编号
rarr.channelSource = rs.source_name;//渠道来源
rarr.businessType = rs.business_type;//商机类型
rarr.currentStatus = rs.business_status;//商机状态
rarr.serviceArea = rs.service_address;//服务地区
rarr.statusReason = rs.close_reason;//商机关闭原因
rarr.clerkName = rs.salesman_name;//业务员名称
rarr.clerkPhone = rs.salesman_phone;//业务员联系方式
rarr.memoInfo = rs.business_info.memo_info;//备注信息
rarr.contactsName = rs.business_info.contacts_name;//联系人名称
rarr.contactsPhone = rs.business_info.contacts_phone;//联系人联系方式
rarr.createdTime = this.timeFormat(rs.created_at);//商机创建时间
rarr.statusTime = this.timeFormat(rs.updated_at);//当前状态时间
}
return system.getResult(rarr);
}
catch(error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误！");
}
}
/*根据交付单编号更新交付单状态*/
async updateInfoByDeliverCode(pobj,qobj,req){
if (pobj.businessMode && pobj.businessMode != 'undefined' && pobj.currentStatus && pobj.currentStatus != 'undefined'){
try{
var res = await this.service.updateInfoByDeliverCode(pobj);
//调商城接口，回传状态信息，后加
return system.getResult("更新成功！");
}
catch (error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误!");
}
}
timeFormat(date) {
let localTime = moment.utc(date).toDate();
localTime = moment(localTime).format("YYYY-MM-DD");
return localTime;
}
}
module.exports = DeliverybillCtl;
var task = new DeliverybillCtl();
var obj={"demand_code":"30030302991","business_status":"isClosed","close_reason":"嗯哈哈"};
task.updateStatusByDemandCode(obj,{},{}).then(d=>{
console.log(d);
//console.log(d[0].analyse);
})
ic-deliver/app/base/controller/impl/bizchance/schemeCtl.js 0 → 100644
var system = require("../../../system");
const http = require("http");
const querystring = require('querystring');
var settings = require("../../../../config/settings");
const CtlBase = require("../../ctl.base");
const moment = require('moment');
class SchemeCtl extends CtlBase {
constructor() {
super("bizchance", CtlBase.getServiceName(SchemeCtl));
}
/*根据id获取方案信息详情*/
async findById(pobj, qobj, req) {
if (pobj.id && pobj.id != 'undefined'){
try{
var rs = await this.service.findById(pobj);
var rarr = {}
if (rs){
rarr.businessMode = rs.demand_code;//商机编号
rarr.schemeNumber = rs.scheme_number;//方案编号
rarr.planInfo = rs.scheme_info;//方案详情
rarr.memoInfo = rs.remark_info;//备注信息
rarr.currentStatus = rs.scheme_status;//当前状态
rarr.statusReason = rs.reject_reason;//状态原因
rarr.businessId = rs.bizopt_id;//商机id
rarr.servicerCode = rs.facilitator_id;//服务商id
rarr.servicerName = rs.facilitator_name;//服务商名称
rarr.clerkName = rs.salesman_name;//业务员名称
rarr.clerkPhone = rs.salesman_phone;//业务员联系方式
rarr.createdTime = this.timeFormat(rs.created_at);//创建方案的日期
rarr.statusTime = this.timeFormat(rs.updated_at);//当前状态的日期
}
return system.getResult(rarr);
}
catch(error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误！");
}
}
/*根据方案编号获取方案详情*/
async findInfoBySchemeNumber(pobj, qobj, req){
if (pobj.schemeNumber && pobj.schemeNumber != 'undefined'){
try{
var rs = await this.service.findInfoBySchemeNumber(pobj);
var rarr = {}
if (rs){
rarr.businessMode = rs.demand_code;//商机编号
rarr.schemeNumber = rs.scheme_number;//方案编号
rarr.planInfo = rs.scheme_info;//方案详情
rarr.memoInfo = rs.remark_info;//备注信息
rarr.currentStatus = rs.scheme_status;//当前状态
rarr.statusReason = rs.reject_reason;//状态原因
rarr.businessId = rs.bizopt_id;//商机id
rarr.servicerCode = rs.facilitator_id;//服务商id
rarr.servicerName = rs.facilitator_name;//服务商名称
rarr.clerkName = rs.salesman_name;//业务员名称
rarr.clerkPhone = rs.salesman_phone;//业务员联系方式
rarr.createdTime = this.timeFormat(rs.created_at);//创建方案的日期
rarr.statusTime = this.timeFormat(rs.updated_at);//当前状态的日期
}
return system.getResult(rarr);
}
catch(error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误！");
}
}
/* 根据方案编号更新方案状态及原因 */
async updateStatusBySchemeNumber(pobj, qobj, req){
if (pobj.schemeNumber && pobj.schemeNumber != 'undefined' && pobj.currentStatus && pobj.currentStatus != 'undefined'){
try{
await this.service.updateStatusBySchemeNumber(pobj);
//调商城接口
return system.getResult("更新成功！");
}
catch(error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误！");
}
}
/*根据方案编号更新方案详情*/
async updateInfoBySchemeNumber(pobj, qobj, req){
if (pobj.schemeNumber && pobj.schemeNumber != 'undefined' && pobj.planInfo != 'undefined'){
try{
await this.service.updateInfoBySchemeNumber(pobj);
return system.getResult("更新成功！");
}
catch(error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误！");
}
}
/*根据商机编号更新方案编号*/
async updateSchemeNumberByDemandCode(pobj, qobj, req){
if (pobj.schemeNumber && pobj.schemeNumber != 'undefined' && pobj.businessMode && pobj.businessMode != 'undefined'){
try{
await this.service.updateSchemeNumberByDemandCode(pobj);
return system.getResult("更新成功！");
}
catch(error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误！");
}
}
/*插入方案信息*/
async insertInfo(pobj, qobj, req){
if (pobj.businessMode && pobj.businessMode != 'undefined' && pobj.currentStatus && pobj.currentStatus != 'undefined' && pobj.planInfo!= 'undefined'){
try{
await this.service.insertInfo(pobj);
return system.getResult("插入成功！");
}
catch(error){
return system.getResultError(error);
}
}
else{
return system.getResultError("参数错误！");
}
}
timeFormat(date) {
let localTime = moment.utc(date).toDate();
localTime = moment(localTime).format("YYYY-MM-DD");
return localTime;
}
}
module.exports = SchemeCtl;
var task = new SchemeCtl();
var obj={"businessMode":"30030302991","currentStatus":"待提交","planInfo":{}};
task.insertInfo(obj,{},{}).then(d=>{
console.log(d);
//console.log(d[0].analyse);
})
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