sql+=" and channelItemName like :channelItemName";
sql+=" and channelItemName like :channelItemName";
sqlCount+=" and channelItemName like :channelItemName";
sqlCount+=" and channelItemName like :channelItemName";
...
@@ -1226,25 +1287,25 @@ class OrderInfoService extends ServiceBase {
...
@@ -1226,25 +1287,25 @@ class OrderInfoService extends ServiceBase {
* @param pobj
* @param pobj
* @returns {Promise<void>}
* @returns {Promise<void>}
*/
*/
asyncgetOrdersStatisticsByUappId(pobj){
asyncgetOrdersStatisticsByUappId(pobj){
letac=pobj.actionBody;
letac=pobj.actionBody;
letsql=`SELECT uapp_id,count(*) count,DATE_FORMAT(created_at,'%Y-%m-%d') time FROM c_order_info WHERE deleted_at is null `;
letsql=`SELECT uapp_id,count(*) count,DATE_FORMAT(created_at,'%Y-%m-%d') time FROM c_order_info WHERE deleted_at is null `;
letwhereParam={};
letwhereParam={};
if(ac.start&&ac.end){
if(ac.start&&ac.end){
sql+=` AND created_at >= :start AND created_at <= :end`;
sql+=` AND created_at >= :start AND created_at <= :end`;
whereParam.start=ac.start;
whereParam.start=ac.start;
whereParam.end=ac.end;
whereParam.end=ac.end;
}
}
if(ac.type_code){
if(ac.type_code){
sql+=` AND typeCode = :type_code`;
sql+=` AND typeCode = :type_code`;
whereParam.type_code=ac.type_code;
whereParam.type_code=ac.type_code;
}
}
if(ac.status){
if(ac.status){
sql+=` AND orderStatus = :status`;
sql+=` AND orderStatus = :status`;
whereParam.status=ac.status;
whereParam.status=ac.status;
}
}
sql+=` GROUP BY uapp_id,DATE_FORMAT(created_at,'%Y-%m-%d') ORDER BY created_at ASC`
sql+=` GROUP BY uapp_id,DATE_FORMAT(created_at,'%Y-%m-%d') ORDER BY created_at ASC`
letresult=awaitthis.customQuery(sql,whereParam);
letresult=awaitthis.customQuery(sql,whereParam);
returnsystem.getResultSuccess(result);
returnsystem.getResultSuccess(result);
}
}
...
@@ -1253,53 +1314,54 @@ class OrderInfoService extends ServiceBase {
...
@@ -1253,53 +1314,54 @@ class OrderInfoService extends ServiceBase {
* @param pobj
* @param pobj
* @returns {Promise<void>}
* @returns {Promise<void>}
*/
*/
asyncgetOrdersStatisticsByProduct(pobj){
asyncgetOrdersStatisticsByProduct(pobj){
letac=pobj.actionBody;
letac=pobj.actionBody;
letsql=`SELECT b.channelItemName typeCode,a.uapp_id,count( * ) count FROM c_order_info a left join c_order_product b on a.orderNo = b.sourceOrderNo WHERE b.itemCode is not null `;
letsql=`SELECT b.channelItemName typeCode,a.uapp_id,count( * ) count FROM c_order_info a left join c_order_product b on a.orderNo = b.sourceOrderNo WHERE b.itemCode is not null `;
letwhereParams={};
letwhereParams={};
if(ac.start&&ac.end){
if(ac.start&&ac.end){
sql+=` and a.created_at >= :start and a.created_at <= :end `;
sql+=` and a.created_at >= :start and a.created_at <= :end `;
whereParams.start=ac.start;
whereParams.start=ac.start;
whereParams.end=ac.end;
whereParams.end=ac.end;
}
}
sql+=` GROUP BY b.channelItemName,a.uapp_id`;
sql+=` GROUP BY b.channelItemName,a.uapp_id`;
letresult=awaitthis.customQuery(sql,whereParams);
letresult=awaitthis.customQuery(sql,whereParams);
returnsystem.getResultSuccess(result);
returnsystem.getResultSuccess(result);
}
}
/**
/**
* 订单对比
* 订单对比
* @param pobj
* @param pobj
* @returns {Promise<void>}
* @returns {Promise<void>}
*/
*/
asyncgetOrdersComparison(pobj){
asyncgetOrdersComparison(pobj){
letab=pobj.actionBody;
letab=pobj.actionBody;
letsql1=`select count(*) count from c_order_info a left join c_order_product b on a.orderNo = b.sourceOrderNo where a.deleted_at is null `;
letsql1=`select count(*) count from c_order_info a left join c_order_product b on a.orderNo = b.sourceOrderNo where a.deleted_at is null `;
letwhereParams={};
letwhereParams={};
if(ab.startNow&&ab.endNow){
if(ab.startNow&&ab.endNow){
sql1+=` and a.created_at >= :start and a.created_at <= :end`;
sql1+=` and a.created_at >= :start and a.created_at <= :end`;
@@ -1310,7 +1372,7 @@ class OrderInfoService extends ServiceBase {
...
@@ -1310,7 +1372,7 @@ class OrderInfoService extends ServiceBase {
* @param pobj
* @param pobj
* @returns {Promise<void>}
* @returns {Promise<void>}
*/
*/
asyncgetOrdersComparisonList(pobj){
asyncgetOrdersComparisonList(pobj){
letab=pobj.actionBody;
letab=pobj.actionBody;
letpageSize=Number(ab.pageSize||20);
letpageSize=Number(ab.pageSize||20);
letpageIndex=Number(ab.pageIndex||1);
letpageIndex=Number(ab.pageIndex||1);
...
@@ -1339,51 +1401,51 @@ class OrderInfoService extends ServiceBase {
...
@@ -1339,51 +1401,51 @@ class OrderInfoService extends ServiceBase {
WHERE
WHERE
a.deleted_at IS NULL`;
a.deleted_at IS NULL`;
lettotalSql=`select count(DISTINCT(a.orderNo)) count from c_order_info a left join c_order_product b on a.orderNo = b.sourceOrderNo LEFT JOIN center_order.c_order_contacts c on a.orderNo = c.sourceOrderNo where a.deleted_at is null `
lettotalSql=`select count(DISTINCT(a.orderNo)) count from c_order_info a left join c_order_product b on a.orderNo = b.sourceOrderNo LEFT JOIN center_order.c_order_contacts c on a.orderNo = c.sourceOrderNo where a.deleted_at is null `
letwhereParams={};
letwhereParams={};
if(ab.start&&ab.end){
if(ab.start&&ab.end){
listSql+=` and a.created_at >= :start and a.created_at <= :end`;
listSql+=` and a.created_at >= :start and a.created_at <= :end`;
totalSql+=` and a.created_at >= :start and a.created_at <= :end`;
totalSql+=` and a.created_at >= :start and a.created_at <= :end`;
whereParams.start=ab.start;
whereParams.start=ab.start;
whereParams.end=ab.end;
whereParams.end=ab.end;
}
}
if(ab.uapp_id){
if(ab.uapp_id){
listSql+=` and a.uapp_id = :uapp_id`;
listSql+=` and a.uapp_id = :uapp_id`;
totalSql+=` and a.uapp_id = :uapp_id`;
totalSql+=` and a.uapp_id = :uapp_id`;
whereParams.uapp_id=ab.uapp_id;
whereParams.uapp_id=ab.uapp_id;
}
}
if(ab.status){
if(ab.status){
listSql+=` and a.orderStatus = :status`;
listSql+=` and a.orderStatus = :status`;
totalSql+=` and a.orderStatus = :status`;
totalSql+=` and a.orderStatus = :status`;
whereParams.status=ab.status;
whereParams.status=ab.status;
}
}
if(ab.type_code){
if(ab.type_code){
listSql+=` and b.itemCode = :type_code`;
listSql+=` and b.itemCode = :type_code`;
totalSql+=` and b.itemCode = :type_code`;
totalSql+=` and b.itemCode = :type_code`;
whereParams.type_code=ab.type_code;
whereParams.type_code=ab.type_code;
}
}
if(ab.fuzzy_code){
if(ab.fuzzy_code){
listSql+=` and ( a.orderNo like :fuzzy_code or a.channelOrderNo like :fuzzy_code or c.mobile like :fuzzy_code)`;
listSql+=` and ( a.orderNo like :fuzzy_code or a.channelOrderNo like :fuzzy_code or c.mobile like :fuzzy_code)`;
totalSql+=` and ( a.orderNo like :fuzzy_code or a.channelOrderNo like :fuzzy_code or c.mobile like :fuzzy_code)`;
totalSql+=` and ( a.orderNo like :fuzzy_code or a.channelOrderNo like :fuzzy_code or c.mobile like :fuzzy_code)`;
" `invoiceApplyStatus`,`opNotes`,`notes`,`channelItemCode`,`channelItemName`,`price`,priceDesc,priceTypeName,channelItemAppendName,`serviceItemCode`,`picUrl`,`serviceItemSnapshot`,`orderSnapshot`,created_at from "+
" `invoiceApplyStatus`,`opNotes`,`notes`,`channelItemCode`,`channelItemName`,`price`,priceDesc,priceTypeName,channelItemAppendName,`serviceItemCode`,`picUrl`,`serviceItemSnapshot`,`orderSnapshot`,created_at from "+
" v_order where uapp_id=:uapp_id and orderNo=:orderNo LIMIT 1";
" v_order where uapp_id=:uapp_id and orderNo=:orderNo LIMIT 1";
sql="UPDATE `c_delivery_official_flow` SET officialFlow ='"+JSON.stringify(flowList)+"' where sourceOrderNo='"+actionBody.officialInfo.tmRegistNum+"'";
sql="UPDATE `c_delivery_official_flow` SET officialFlow ='"+JSON.stringify(flowList)+"' where sourceOrderNo='"+actionBody.officialInfo.tmRegistNum+"'";
sql=sql.replace('\n','');
sql=sql.replace('\n','');
}
}
...
@@ -1749,7 +1811,7 @@ class OrderInfoService extends ServiceBase {
...
@@ -1749,7 +1811,7 @@ class OrderInfoService extends ServiceBase {
