Skip to content

Z
zhichan
Commit 3c5c2c8b by 王勇飞
Options

pp

parent 34b3787d
Showing with 64 additions and 56 deletions
fqboss/app/base/api/impl/customerInfoPusherApi.js
......@@ -20,70 +20,73 @@ class CustomerInfoPusherApi {
async collectInfo() {
try {
//获取联系人信息(最少50条)
let resultTmCustomer = await this.trademarkS.queryTmCustomerInfo(orderNum);
oneItem.tmCustomer = resultTmCustomer[0];
//获取商标数据
let resultTm = await this.trademarkS.queryTmInfoForPush();
console.log('请求推送的数据成功：', resultTm.length);
let oneItem = {};
for (let i = 0; i < resultTm.length; i++) {
let d = resultTm[i];
let orderNum = d.orderNum;
let tmRegistNum = d.tmRegistNum;
let order_no = d.channelOrderListInfo;
oneItem.tm = d;
//商标状态
oneItem.tmStatusName = d.tmStatusName;
//获取商标申请人信息
let tmapplierSql = "SELECT * FROM `h_tmapplier_info` WHERE orderNum='" + orderNum + "';";
let resultApplier = await this.tmapplierinfoDao.customQuery(tmapplierSql);
oneItem.tmApplier = resultApplier[0];
//获取联系人信息
let resultTmCustomer = await this.trademarkS.queryTmCustomerInfoForPush(orderNum);
oneItem.tmCustomer = resultTmCustomer[0];
//获取官文信息, 一对多的关系，所以传入list
let resultTmFlow = await this.trademarkS.queryTmFlowInfoForPush(tmRegistNum);
oneItem.tmFlow = resultTmFlow;
console.log('收集商标信息完成--', i);
//调用推送接口推送oneItem
let url = fqReqUrl + '/cloudapi/iduty/igirl/pushFollowUp';
let body = {
'order_no': order_no,
'json': oneItem
};
let res = await this.aliyunClient.postig(url, body);
console.log('推送完成--' + i, res);
//将成功结果写入到日志
await this.oplogSve.create({
logLevel: "info",
optitle: "推送商标数据至蜂擎---",
op: "app/base/api/impl/tmInfoPusherApi.js/collectInfo",
content: "参数:" + JSON.stringify(body) + "返回结果:" + JSON.stringify(res),
clientIp: ""
});
//更新isPushed字段为1
await this.trademarkS.updateIsPushed(d.id);
console.log('更新isPushed字段完成--', i);
}
// for (let i = 0; i < resultTm.length; i++) {
// let d = resultTm[i];
// let orderNum = d.orderNum;
// let tmRegistNum = d.tmRegistNum;
// let order_no = d.channelOrderListInfo;
// oneItem.tm = d;
// //商标状态
// oneItem.tmStatusName = d.tmStatusName;
// //获取商标申请人信息
// let tmapplierSql = "SELECT * FROM `h_tmapplier_info` WHERE orderNum='" + orderNum + "';";
// let resultApplier = await this.tmapplierinfoDao.customQuery(tmapplierSql);
// oneItem.tmApplier = resultApplier[0];
// //获取联系人信息
// //获取官文信息, 一对多的关系，所以传入list
// let resultTmFlow = await this.trademarkS.queryTmFlowInfoForPush(tmRegistNum);
// oneItem.tmFlow = resultTmFlow;
// console.log('收集商标信息完成--', i);
// //调用推送接口推送oneItem
// let url = fqReqUrl + '/cloudapi/iduty/igirl/pushFollowUp';
// let body = {
// 'order_no': order_no,
// 'json': oneItem
// };
// let res = await this.aliyunClient.postig(url, body);
// console.log('推送完成--' + i, res);
// //将成功结果写入到日志
// // await this.oplogSve.create({
// // logLevel: "info",
// // optitle: "推送商标数据至蜂擎---",
// // op: "app/base/api/impl/tmInfoPusherApi.js/collectInfo",
// // content: "参数:" + JSON.stringify(body) + "返回结果:" + JSON.stringify(res),
// // clientIp: ""
// // });
// //更新isPushed字段为1
// await this.trademarkS.updateIsPushed(d.id);
// console.log('更新isPushed字段完成--', i);
// }
return { code: 200, message: "调用推送接口成功" };
} catch (e) {
console.log('collectInfo error: ', e);
//将错误写入到日志
await this.oplogSve.create({
logLevel: "error",
optitle: "推送商标数据至蜂擎---异常",
op: "app/base/api/impl/tmInfoPusherApi.js/collectInfo",
content: JSON.stringify(e.stack),
clientIp: ""
});
// await this.oplogSve.create({
// logLevel: "error",
// optitle: "推送商标数据至蜂擎---异常",
// op: "app/base/api/impl/tmInfoPusherApi.js/collectInfo",
// content: JSON.stringify(e.stack),
// clientIp: ""
// });
return e;
}
}
......
fqboss/app/base/db/dao.base.js
......@@ -54,7 +54,7 @@ class Dao {
}
orderBy() {
//return {"key":"include","value":{model:this.db.models.app}};
return [["lastUp", "DESC"]];
return [["created_at", "DESC"]];
}
buildQuery(qobj) {
var linkAttrs = [];
......
fqboss/app/base/db/impl/trademarkDao.js
......@@ -28,6 +28,10 @@ class TrademarkDao extends Dao {
return null;
}
}
orderBy() {
//return {"key":"include","value":{model:this.db.models.app}};
return [["lastUp", "DESC"]];
}
extraWhere(obj, w) {
if (obj.codepath && obj.codepath != "") {
if (obj.codepath.indexOf("alltrademark") < 0 && obj.codepath.indexOf("allfqtm") < 0) {
......
fqboss/app/base/service/impl/trademarkSve.js
......@@ -1615,7 +1615,7 @@ class TrademarkService extends ServiceBase {
//联系人信息查询-联系人地址信息推送接口
async queryTmCustomerInfo(orderNum) {
try {
let sql = "SELECT * FROM `h_tmcustomer_info` WHERE orderNum='" + orderNum + "';";
let sql = "SELECT orderNum,contactAddress,customerContact,mobile,email,zipCode FROM `h_tmcustomer_info` WHERE contactAddress != '' AND addressIsPushed = '0' LIMIT 50;";
let customerResult = await this.dao.customQuery(sql);
return customerResult;
} catch (e) {
......
fqboss/app/config/routes/web.js
......@@ -259,6 +259,7 @@ module.exports = function (app) {
req.url.indexOf("ncloneCtl/getNcl") > 0 ||
req.url.indexOf("orderCtl/getChannelOrderByOrderNum") > 0 ||
req.url.indexOf("tmInfoPusherCtl/pushInfo") > 0 ||
req.url.indexOf("customerInfoPusherCtl/pushInfo") > 0 ||
(
req.headers.access_source=="zqq1571212637509" &&
(
......
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