gyq

center-manage/app/base/service/impl/common/channelhandlers/tx.js

+var system = require("../../../../system");
 class TxHandler {
   constructor() {
     this.icUrl = "http://ic.com:8000/web/bizchance";
@@ -10,22 +11,26 @@ class TxHandler {
    */
   //新商机处理
   async addChance(datajson){
-      //console.log("put in queue",datajson)
+      console.log("put in queue",datajson);
       try{
         //获取分配的业务员信息
-        var salesmanInfo = await this.userService.getBizUserForBizChance(datajson.actionBody.contactsMoblie, datajson.actionBody.servicerName, datajson.actionBody.consultTypeName);
+        var salesmanInfo = await this.userService.getBizUserForBizChance(datajson.actionBody.ContactsMoblie, datajson.actionBody.ServicerName, datajson.actionBody.ConsultTypeName);
+        console.log("salesman   " + salesmanInfo);
         var rc = system.getObject("util.execClient");
         var requrl = this.icUrl + "/bizoptCtl/insertInfo";
         var params =  {
           "businessMode": datajson.actionBody.needNum,
-          "servicerCode":datajson.actionBody.servicerCode,
-          "servicerName":datajson.actionBody.servicerName,
-          "serviceCode":datajson.actionBody.regionId,
-          "serviceName":datajson.actionBody.regionName,
-          "contactsName":datajson.actionBody.contactsName,
-          "contactsPhone":datajson.actionBody.contactsMoblie,
-          "businessType":datajson.actionBody.consultType,
-          "businessName":datajson.actionBody.consultTypeName
+          "servicerCode":datajson.actionBody.ServicerCode,
+          "servicerName":datajson.actionBody.ServicerName,
+          "serviceCode":datajson.actionBody.RegionId,
+          "serviceName":datajson.actionBody.RegionName,
+          "contactsName":datajson.actionBody.ContactsName,
+          "contactsPhone":datajson.actionBody.ContactsMoblie,
+          "businessType":datajson.actionBody.ConsultType,
+          "businessName":datajson.actionBody.ConsultTypeName
+        } 
+        if (datajson.actionBody.Notes && datajson.actionBody.Notes != 'undefined'){
+          params.memoInfo = datajson.actionBody.Notes;
         }
         if (salesmanInfo && salesmanInfo != 'undefined'){
           params.salesmanOpcode = salesmanInfo.opath;
@@ -38,6 +43,8 @@ class TxHandler {
         return j;
       }
       catch(error){
+        console.log("TTTTTTTTTTTTTT");
+        console.log(error);
         return  system.getResultError(error);
       }
       
@@ -45,6 +52,7 @@ class TxHandler {
 
   //退回商机处理
   async needClose(datajson){
+    console.log("put in queue",datajson);
     try{
       var rc = system.getObject("util.execClient");
       var requrl = this.icUrl + "/schemeCtl/updateStatusByDemandCode";
@@ -75,6 +83,7 @@ class TxHandler {
 
   //交付单处理
   async orderSubmit(datajson){
+    console.log("put in queue",datajson);
     try{
       //获取分配的业务员信息
       var salesmanInfo = await this.userService.getBizUserForDelivery(datajson.actionBody.contactsMoblie, datajson.actionBody.servicerName, datajson.actionBody.productTypeName, datajson.actionBody.skucode);
@@ -206,6 +215,7 @@ class TxHandler {
 
     //关闭交付单处理
   async needClose(datajson){
+    console.log("put in queue",datajson);
     try{
       var rc = system.getObject("util.execClient");
       var requrl = this.icUrl + "/deliverybillCtl/updateStatusByDeliverCode";