Skip to content

Z
zhichan
Commit 77cc6158 by 任晓松
Options

商标驳回复审

parent 20508a9c
Showing with 518 additions and 0 deletions
center-order/app/base/api/impl/action/tmreview.js 0 → 100644
var APIBase = require("../../api.base");
var system = require("../../../system");
var settings = require("../../../../config/settings");
class tmreview extends APIBase{
constructor() {
super();
this.orderDeliverSve = system.getObject("service.dbcorder.orderDeliverSve");
}
async springBoard(pobj, qobj, req) {
if (!pobj.actionType) {
return system.getResult(null, "actionType参数不能为空");
}
var result = await this.opActionProcess(pobj, pobj.actionType, req);
return result;
}
async opActionProcess(pobj, action_type, req) {
var opResult = null;
switch (action_type) {
case "addReviewList":
opResult = await this.orderDeliverSve.submitReview(pobj,pobj.actionBody);
break;
case "getReOrderList"://获取订单列表信息
opResult = await this.orderDeliverSve.getReOrderList(pobj, pobj.actionBody);
break;
case "addOfficial"://接收官文信息
opResult = await this.orderDeliverSve.addOfficial(pobj,pobj.actionBody);
break;
case "getOfficalList":
opResult = await this.orderDeliverSve.getOfficialList(pobj,pobj.actionBody)
break;
default:
opResult = system.getResult(null, "action_type参数错误");
break;
}
return opResult;
}
}
module.exports = tmreview;
\ No newline at end of file
center-order/app/base/db/impl/dbcorder/orderdeliveryofficialDao.js 0 → 100644
const system = require("../../../system");
const Dao = require("../../dao.base");
class OrderdeliveryofficialDao extends Dao {
constructor() {
super(Dao.getModelName(OrderdeliveryofficialDao));
}
}
module.exports = OrderdeliveryofficialDao;
center-order/app/base/db/models/dbcorder/orderOfficial.js 0 → 100644
const system = require("../../../system");
const settings = require("../../../../config/settings");
const uiconfig = system.getUiConfig2(settings.appKey);
module.exports = (db, DataTypes) => {
return db.define("orderOfficial", {
sourceNo: DataTypes.STRING(128), // 订单号
channelUserId: DataTypes.STRING(128), // 用户id
officialInfo: DataTypes.JSON // 官文信息
}, {
paranoid: true,//假的删除
underscored: true,
version: true,
freezeTableName: true,
timestamps: true,
updatedAt: true,
tableName: 'c_delivery_official',
validate: {
},
indexes: [
]
});
}
center-order/app/base/service/impl/dbcorder/orderdeliverSve.js 0 → 100644
const system = require("../../../system");
const settings = require("../../../../config/settings");
const uiconfig = system.getUiConfig2(settings.appKey);
const ServiceBase = require("../../sve.base");
const uuidv4 = require('uuid/v4');
class OrderInfoService extends ServiceBase {
constructor() {
super("dbcorder", ServiceBase.getDaoName(OrderInfoService));
this.flowlogDao = system.getObject("db.dbcorder.flowlogDao");
this.orderproductDao = system.getObject("db.dbcorder.orderproductDao");
this.ordercontactsDao = system.getObject("db.dbcorder.ordercontactsDao");
this.orderReceiptVoucherDao = system.getObject("db.dbcpay.orderreceiptvoucherDao");
this.officialDao = system.getObject("db.dbcorder.orderdeliveryofficialDao");
this.centerChannelUrl = settings.centerChannelUrl();
}
//----------------------订单创建-----------start----------------
async createOrder(pobj, orderNo, t) {
var actionBody = pobj.actionBody;
var channelOrder = actionBody.channelOrder;
var orderContact = actionBody.orderContact;
var price_item = actionBody.product_info.price_item;
var totalServiceCharge = Number(price_item.service_charge || 0) * Number(actionBody.quantity || 0);
var totalPublicExpense = Number(price_item.public_expense || 0) * Number(actionBody.quantity || 0);
var totalSupplyPrice = Number(price_item.supply_price || 0) * Number(actionBody.quantity || 0);//统计供货价格
var totalProfitSum = Number(actionBody.totalSum) - Number(totalSupplyPrice || 0);//利润
var pfProfitSum = (100 - Number(price_item.channel_profit_rate || 0)) / 100 * totalProfitSum;
if (pfProfitSum < 0) {
pfProfitSum = 0;
}
var channelProfitSum = Number(totalProfitSum) - Number(pfProfitSum);
var payTime = channelOrder.payTime || new Date();
var params = {
uapp_id: pobj.appInfo.uapp_id,//int(11) //
orderNo: orderNo,//varchar(64) //订单号
channelServiceNo: channelOrder.channelServiceNo || orderNo,//varchar(64) //渠道服务单号
channelOrderNo: channelOrder.channelOrderNo || orderNo,//varchar(1024) //渠道订单号列表，多个以,隔开
needNo: channelOrder.needNo || "",//需求号--用于服务商或需求表中创建订单
channelUserId: pobj.userInfo.channel_userid,//varchar(64) //
ownerUserId: pobj.userInfo.channel_userid,//varchar(20) //
payTime: channelOrder.orderStatus && channelOrder.orderStatus == 2 ? payTime : null,//datetime //
quantity: actionBody.quantity,//int(11) //项目订单数量（即服务项目的倍数，默认值为1）
serviceQuantity: 0,//int(11) //项目订单交付数量（即与项目订单数量相对应）
orderStatus: channelOrder.orderStatus || 1,//int //订单状态: 1: 待付款, 2: 已付款, 4: 待服务, 8: 已完成
totalSum: actionBody.totalSum,//decimal(12,2) //订单总额(产品价格×优惠费率×订单件数)
payTotalSum: actionBody.payTotalSum || actionBody.totalSum,//decimal(12,2) //
refundSum: 0,//decimal(12,2) //退款总额
totalServiceCharge: totalServiceCharge,//decimal(12,2) //服务费总额（产品配置的服务费*订单件数）
totalPublicExpense: totalPublicExpense,//decimal(12,2) //官费总额（产品配置的官费*订单件数）
totalProfitSum: totalProfitSum,//decimal(12,2) //订单毛利润总额（产品价格-供货价格））
pfProfitSum: pfProfitSum,//decimal(12,2) //订单平台毛利润总额（(100-渠道利润分成比例)/100 * 订单毛利润总额）
channelProfitSum: channelProfitSum,//decimal(12,2) //订单渠道分成毛利润总额(订单毛利润总额-平台毛利润总额)
totalDiscounts: 0,//decimal(12,2) //优惠总额（（服务费总额+官费总额）-订单总额(产品价格×优惠费率×订单件数)>0则有优惠额度）暂时没有用到
pfSettleProfit: 0,//int(11) //平台结算渠道利润,0否，1是
invoiceApplyStatus: "00",//varchar(10) //发票状态:00: 未申请, 10: 已申请,20:已开票
notes: actionBody.notes || "",//varchar(255) //
opNotes: "",//varchar(255) //操作备注
};
var order = await this.dao.create(params, t);//创建订单
var orderLog = {
uapp_id: pobj.appInfo.uapp_id,
sourceOrderNo: orderNo,
opContent: "您提交了订单，请及时支付",
isShow: 1
};
await this.flowlogDao.create(orderLog, t);
var orderProductObj = {
uapp_id: pobj.appInfo.uapp_id,
sourceOrderNo: orderNo, // 来源单号
productType_id: actionBody.product_info.productType_id,//产品类型Id
pathCode: actionBody.product_info.path_code,//产品路径
itemCode: actionBody.product_info.item_code,//产品编码
itemName: actionBody.product_info.item_name,//产品名称
channelItemCode: actionBody.product_info.channel_item_code,// 渠道产品编码
channelItemName: actionBody.product_info.channel_item_name,// 渠道产品名称
channelItemAppendName: actionBody.channelItemAppendName || "",//服务商产品附加名称
serviceItemCode: actionBody.product_info.service_item_code,// 服务商产品编码
payAfterJumpH5Url: actionBody.product_info.pay_after_jump_h5url || "",
payAfterJumpPcUrl: actionBody.product_info.pay_after_jump_pcurl || "",
picUrl: actionBody.product_info.pic_url,// 产品图片地址
price: actionBody.product_info.price_item.price,//定价
priceDesc: actionBody.product_info.price_item.price_desc,//定价描述
priceTypeName: actionBody.product_info.price_item.price_type_name,//定价类型名称
quantity: actionBody.quantity,// 订单数量（即产品的倍数，默认值为1）
opPayType: "00",// 操作付款类型:00: 创建订单, 10: 补单
serviceItemSnapshot: JSON.stringify(actionBody.product_info), //产品快照
orderSnapshot:JSON.stringify(actionBody.deliveryData.apply)
};
var orderProduct = await this.orderproductDao.create(orderProductObj, t);//订单产品
var orderReceiptVoucherObj = {
uapp_id: pobj.appInfo.uapp_id,
sourceOrderNo: orderNo, // 来源单号
accountType: "other",
payDate: payTime,//支付时间
totalSum: actionBody.payTotalSum || actionBody.totalSum,//订单总额
auditStatus: "dsh",
wxPayOrderCode: orderNo,//业务微信支付订单号
aliPayOrderCode: orderNo,//业务支付宝支付订单号
busPayOrderCode: orderNo//业务支付订单号
};
if (orderContact && orderContact.mobile) {
var customerContactObj = {
uapp_id: pobj.appInfo.uapp_id,//int(11) //
sourceOrderNo: orderNo,//交付订单号
contactName: orderContact.contacts || "",//手机号
mobile: orderContact.mobile,//手机号
email: orderContact.email || ""
};
await this.ordercontactsDao.create(customerContactObj, t);
}
var orderReceiptVoucher = await this.orderReceiptVoucherDao.create(orderReceiptVoucherObj, t);
}
/**
* 创建其他订单
* @param {*} pobj
*/
async createOtherOrder(pobj) {
var self = this;
return await self.db.transaction(async function (t) {
var orderNo = await self.getBusUid("ot" + pobj.appInfo.uapp_id);
if (pobj.actionBody.channelOrder && pobj.actionBody.channelOrder.channelOrderNo) {
var count = await self.dao.findCount({where: {channelOrderNo: pobj.actionBody.channelOrder.channelOrderNo}});
if (count > 0) {
return system.getResultFail(-1, "订单不能重复创建s");
}
}
var item = await self.createOrder(pobj, orderNo, t);
return system.getResultSuccess({
orderNo: orderNo,
channelServiceNo: pobj.actionBody.channelOrder.channelServiceNo || orderNo,
channelOrderNo: pobj.actionBody.channelOrder.channelOrderNo || orderNo,
channelParams: pobj.actionBody.channelOrder.channelParams || ""
});
});
}
/**
* 创建商标驳回复审订单
* @param pobj
* @returns {Promise<*>}
*/
async createTmReOrder(pobj) {
var packagingTmResult = await this.packagingTmReDeliveryData(pobj, pobj.actionBody);
if (packagingTmResult.status != 0) {
return packagingTmResult;
}
var self = this;
return await self.db.transaction(async function (t) {
var orderNo = await self.getBusUid("tm" + pobj.appInfo.uapp_id);
var item = await self.createOrder(pobj, orderNo, t);
self.addOrderDelivery(pobj.actionBody.deliveryData, orderNo);
return system.getResultSuccess({
orderNo: orderNo,
channelServiceNo: pobj.actionBody.channelOrder.channelServiceNo || orderNo,
channelOrderNo: pobj.actionBody.channelOrder.channelOrderNo || orderNo,
channelParams: pobj.actionBody.channelOrder.channelParams || ""
});
});
}
/**
* 重新组装交付信息
* @param pobj
* @param actionBody
* @returns {Promise<{msg: string, data: (*|null), bizmsg: *, status: number}|{msg: *, data: (*|null), status: number}>}
*/
async packagingTmReDeliveryData(pobj, actionBody) {
if (!actionBody.deliveryData || Object.keys(actionBody.deliveryData).length == 0) {
return system.getResult(null, "交付数据不能为空，20135");
}
var deliveryData = actionBody.deliveryData;
//商标申请信息
const apply = deliveryData.apply;
//商标申请人信息
const applyUser = actionBody.deliveryData.applyUser;
//复审证据材料
const askForData = actionBody.deliveryData.askForData;
//商标驳回信息
const trademarkRejInfo = actionBody.deliveryData.trademarkRejInfo;
//补充材料
const supData = actionBody.deliveryData.supData;
//申请信息校验
let re1 = await this.checkApply(apply);
if (re1.status != 0) {
return re1;
}
//商标驳回信息校验
let re2= await this.checkRejInfo(trademarkRejInfo);
if (re2.status != 0) {
return re2;
}
if (Object.keys(applyUser).length === 0 || Object.keys(askForData).length === 0) {
var deliveryStatusName = "待完善材料";
var recDate = "";
var askforDate = "";
} else {
var deliveryStatusName = deliveryData.deliveryStatusName || "待审核";
var recDate = deliveryData.reDate || "";
var askforDate = deliveryData.askforDate || "";
}
pobj.actionBody.deliveryData.deliveryStatusName = deliveryStatusName;
pobj.actionBody.deliveryData.reDate = recDate;
pobj.actionBody.deliveryData.askforDate = askforDate;
pobj.actionBody.deliveryData.notes = actionBody.notes || ""; // 订单备注
pobj.actionBody.deliveryData.opNotes = ""; //操作备注
return system.getResultSuccess();
}
/**
* 新增交付信息
* @param data
* @param orderNo
*/
addOrderDelivery(data, orderNo) {
var sql = "INSERT INTO `c_order_delivery` (`sourceOrderNo`,`deliveryContent`) VALUE('" +
orderNo + "','" + JSON.stringify(data) + "')";
this.customQuery(sql);
}
/**
* 修改交付信息并推送到交付中心
* @param pobj
* @param actionBody
* @returns {Promise<{msg: *, data: (*|null), status: number}>}
*/
async submitReview(pobj, actionBody) {
var packagingTmResult = await this.packagingTmReDeliveryData(pobj, pobj.actionBody);
if (packagingTmResult.status != 0) {
return packagingTmResult;
}
const orderNo = actionBody.orderNo;
const deliveryData = JSON.stringify(pobj.actionBody.deliveryData);
let sql = `UPDATE c_order_delivery SET deliveryContent ='${deliveryData}' where sourceOrderNo='${orderNo}'`;
sql = sql.replace('\n', '');
const result = await this.customUpdate(sql);
return system.getResultSuccess();
}
//申请信息校验
async checkApply(apply) {
if (!apply) {
return system.getResult(null, "申请信息不能为空，20230");
}
if (!apply.askforId) {
return system.getResult(null, "申请号为空");
}
if (!apply.applicantName) {
return system.getResult(null, "申请人为空");
}
if (!apply.agentName) {
return system.getResult(null, "代理机构为空");
}
if (!apply.tradeImg) {
return system.getResult(null, "商标图样不能为空");
}
if (!apply.tradeType) {
return system.getResult(null, '商标类别为空');
}
if (!apply.usccode) {
return system.getResult(null, "申请统一社会信用代码不能为空");
}
return system.getResultSuccess();
}
//复审证据材料校验
async checkRejInfo(trademarkRejInfo) {
if(!trademarkRejInfo.noticeDate){
return system.getResult(null,'收到通知书日期不能为空');
}
if(!trademarkRejInfo.noticeMode){
return system.getResult(null,'通知的方式不能为空');
}
if(!["电子版","纸质版"].includes(trademarkRejInfo.noticeMode)){
return system.getResult(null,'通知书的类型错误')
}
if(!trademarkRejInfo.zhichanNumber){
return system.getResult(null,'知识产权局发文号不能为空');
}
if(!trademarkRejInfo.rejNotice){
return system.getResult(null,'商标驳回通知书不能为空');
}
if(!trademarkRejInfo.quotedTrademark){
return system.getResult(null,'引证商标不能为空');
}
return system.getResultSuccess()
}
/**
* 商标驳回复审列表 + 模糊查询
* @param pobj
* @param actionBody
* @returns {Promise<void>}
*/
async getReOrderList(pobj, actionBody) {
let pageSize = Number(actionBody.pageSize || 20);
if (pageSize > 50) {
pageSize = 50;
}
let pageIndex = Number(actionBody.pageIndex || 1);
let from = pageIndex == 1 ? 0 : Number((pageIndex - 1) * pageSize);
let sql = `SELECT orderNo,json_extract(d.deliveryContent,'$.apply.askforId') askforId,json_extract(d.deliveryContent,'$.apply.tradeType') tradeType,json_extract(d.deliveryContent,'$.apply.tradeImg') tradeImg,json_extract(d.deliveryContent,'$.applyUser.applicantName') applicantName,json_extract(d.deliveryContent,'$.deliveryStatusName') deliveryStatusName,json_extract(d.deliveryContent,'$.deliveryUpdated') deliveryUpdated from c_order_info i left join c_order_delivery d on i.orderNo = d.sourceOrderNo where i.uapp_id = ${pobj.appInfo.uapp_id}`;
let sqlCount = `SELECT count(1) as dataCount from c_order_info i left join c_order_delivery d on i.orderNo = d.sourceOrderNo where i.uapp_id = ${pobj.appInfo.uapp_id}`;
if (pobj.userInfo.channel_userid) {
sql += ` and i.channelUserId='${pobj.userInfo.channel_userid}'`;
sqlCount += ` and i.channelUserId='${pobj.userInfo.channel_userid}'`;
}
if (actionBody.orderNo) {
sql += ` and orderNo='${actionBody.orderNo}'`;
sqlCount += ` and orderNo='${actionBody.orderNo}'`;
}
if (actionBody.askforId) {
sql += ` and json_extract(deliveryContent,'$.apply.askforId')='${actionBody.askforId}'`;
sqlCount += ` and json_extract(deliveryContent,'$.apply.askforId')='${actionBody.askforId}'`;
}
if(actionBody.applicantName){
sql += ` and json_extract(deliveryContent,'$.applyUser.applicantName') like '%${actionBody.applicantName}%'`;
sqlCount += ` and json_extract(deliveryContent,'$.applyUser.applicantName') like '%${actionBody.applicantName}'%`;
}
if(actionBody.status){
sql += ` and json_extract(deliveryContent,'$.deliveryStatusName')='${actionBody.status}'`;
sqlCount += ` and json_extract(deliveryContent,'$.deliveryStatusName')='${actionBody.status}'`;
}
if (actionBody.startTime && actionBody.entTime) {
var startTime = actionBody.startTime.trim() + " 00:00:00";
var endTime = actionBody.entTime + " 23:59:59";
sql += ` and json_extract(deliveryContent,'$.deliveryUpdated') between '${startTime}' and '${endTime}'`;
sqlCount += ` and json_extract(deliveryContent,'$.deliveryUpdated') between '${startTime}' and '${endTime}'`;
}
sql += ` order by i.id desc LIMIT ${pageSize} OFFSET ${from}`;
let list = await this.customQuery(sql);
let result = system.getResultSuccess(list);
let tmpResultCount = await this.customQuery(sqlCount);
result.dataCount = tmpResultCount && tmpResultCount.length > 0 ? tmpResultCount[0].dataCount : 0;
return result;
}
/**
* 官文列表
* @param pobj
* @param actionBody
* @returns {Promise<void>}
*/
async getOfficialList(pobj,actionBody){
let pageSize = Number(actionBody.pageSize || 20);
if (pageSize > 50) {
pageSize = 50;
}
let pageIndex = Number(actionBody.pageIndex || 1);
let from = pageIndex == 1 ? 0 : Number((pageIndex - 1) * pageSize);
let sql = `select o.serviceNo,json_extract(officialInfo,'$.applyUser') applyUser,json_extract(officialInfo,'$.askforId') askforId,json_extract(officialInfo,'$.tmType') tmType,json_extract(officialInfo,'$.tmPicUrl') tmPicUrl,json_extract(officialInfo,'$.applicantName') applicantName,json_extract(officialInfo,'$.fileType') fileType from c_order_info i left join c_delivery_official o on i.orderNo = o.serviceNo where i.uapp_id = ${pobj.appInfo.uapp_id}`;
let sqlCount = `select count(1) as dataCount from c_order_info i left join c_delivery_official o on i.orderNo = o.serviceNo where i.uapp_id = ${pobj.appInfo.uapp_id}`
if (pobj.userInfo.channel_userid) {
sql += ` and o.channelUserId='${pobj.userInfo.channel_userid}'`;
sqlCount += ` and o.channelUserId='${pobj.userInfo.channel_userid}'`;
}
if (actionBody.orderNo) {
sql += ` and serviceNo='${actionBody.orderNo}'`;
sqlCount += ` and serviceNo='${actionBody.orderNo}'`;
}
if (actionBody.askforId) {
sql += ` and json_extract(officialInfo,'$.askforId')='${actionBody.askforId}'`;
sqlCount += ` and json_extract(officialInfo,'$.askforId')='${actionBody.askforId}'`;
}
if (actionBody.applicantName){
sql += ` and json_extract(officialInfo,'$.applicantName') like '%${actionBody.applicantName}%'`;
sqlCount += ` and json_extract(officialInfo,'$.applicantName') like'%${actionBody.applicantName}%'`;
}
if(actionBody.fileType){
sql += ` and json_extract(officialInfo,'$.fileType')='${actionBody.fileType}'`;
sqlCount += ` and json_extract(officialInfo,'$.fileType')='${actionBody.fileType}'`;
}
if (actionBody.startTime && actionBody.entTime) {
var startTime = actionBody.startTime.trim() + " 00:00:00";
var endTime = actionBody.entTime + " 23:59:59";
sql += ` and json_extract(officialInfo,'$.received_at') >='${startTime}' and json_extract(officialInfo,'$.received_at')<='${endTime}'`;
sqlCount += ` and json_extract(officialInfo,'$.received_at') >='${startTime}' and json_extract(officialInfo,'$.received_at')<='${endTime}'`;
}
sql += ` order by o.id desc LIMIT ${pageSize} OFFSET ${from}`;
let list = await this.customQuery(sql);
let result = system.getResultSuccess(list);
let tmpResultCount = await this.customQuery(sqlCount);
result.dataCount = tmpResultCount && tmpResultCount.length > 0 ? tmpResultCount[0].dataCount : 0;
return result;
}
/**
* 接收交付中心推送的官文
* @param pobj
* @param actionBody
* @returns {Promise<void>}
*/
async addOfficial(pobj,actionBody){
if(!actionBody.orderNo){
return system.getResult(null,'orderNo can not be empty');
}
let orderSql = `select channelUserId from c_order_info where orderNo = '${actionBody.orderNo}'`;
let list = await this.customQuery(orderSql);
if (!list || list.length == 0) {
return system.getResult(null, "订单数据为空，30200");
}
let orderItem = list[0];
let officialData = {
serviceNo: actionBody.orderNo,
channelUserId:orderItem.channelUserId,
officialInfo: JSON.parse(actionBody.officialData),
created_at: new Date(),
updated_at: new Date()
}
await this.officialDao.create(officialData,"");
}
}
module.exports = OrderInfoService;
\ No newline at end of file
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