receiveAliTmOrder

center-order/app/base/service/impl/dbcorder/orderinfoSve.js

@@ -16,6 +16,7 @@ class OrderInfoService extends ServiceBase {
         this.orderReceiptVoucherDao = system.getObject("db.dbcpay.orderreceiptvoucherDao");
         this.orderReceiptVoucherDao = system.getObject("db.dbcpay.orderreceiptvoucherDao");
         this.moneyJourneyDao = system.getObject("db.dbcpay.moneyjourneyDao");
         this.moneyJourneyDao = system.getObject("db.dbcpay.moneyjourneyDao");
         this.needsolutionDao = system.getObject("db.dbneed.needsolutionDao");
         this.needsolutionDao = system.getObject("db.dbneed.needsolutionDao");
+        this.needinfoDao = system.getObject("db.dbneed.needinfoDao");
         this.orderRegionDao = system.getObject("db.dbcorder.orderregionDao");
         this.orderRegionDao = system.getObject("db.dbcorder.orderregionDao");
         this.push360Sve = system.getObject('service.common.push360Sve');
         this.push360Sve = system.getObject('service.common.push360Sve');
         this.orderinfoDao = system.getObject('db.dbcorder.orderinfoDao');
         this.orderinfoDao = system.getObject('db.dbcorder.orderinfoDao');
@@ -2554,10 +2555,14 @@ class OrderInfoService extends ServiceBase {
             serviceItemSnapshot: JSON.stringify(productInfo),      //产品快照
             serviceItemSnapshot: JSON.stringify(productInfo),      //产品快照
             orderSnapshot: JSON.stringify(ab)// 2020 1110 lin 新增 增加订单快照
             orderSnapshot: JSON.stringify(ab)// 2020 1110 lin 新增 增加订单快照
         };
         };
+        ab.pushStatus=3;
+        ab.isPushNum=1;
         var self = this;
         var self = this;
+
         return await self.db.transaction(async function (t) {
         return await self.db.transaction(async function (t) {
             var o = await self.dao.create(ab, t);
             var o = await self.dao.create(ab, t);
             var orderProduct = await self.orderproductDao.create(orderProductObj, t);//订单产品
             var orderProduct = await self.orderproductDao.create(orderProductObj, t);//订单产品
+            await self.needinfoDao.model.update({status:"ycd"},{ where: { channelNeedNo: ab.needNo }, transaction: t });
             return system.getResultSuccess(o);
             return system.getResultSuccess(o);
         })
         })