feat: 服务处理反馈 队列

tx-fi-tax/app/base/service/impl/bizchance/deliverybillSve.js

@@ -40,6 +40,11 @@ class DeliverybillService extends ServiceBase {
                 close_reason: pobj.note
                 close_reason: pobj.note
             }
             }
         }
         }
+        // 通过消息队列 发送 融易算 
+        await toFtClient.feedbackToRys({
+            ...pobj,
+            bizId: deliverData.delivery_info.bizId
+        });
         await this.dao.updateByWhere(updateResult, {
         await this.dao.updateByWhere(updateResult, {
             id: pobj.deliverId
             id: pobj.deliverId
         });
         });

tx-fi-tax/app/base/utils/toFtClient.js

@@ -4,6 +4,8 @@ const system = require("../system");
 const moment = require('moment');
 const moment = require('moment');
 const ftConfig = settings.ftConfig();
 const ftConfig = settings.ftConfig();
 const _ = require("lodash")
 const _ = require("lodash")
+const uuidv4 = require('uuid/v4');
+
 
 
 /**
 /**
  * 发送 post 请求
  * 发送 post 请求
@@ -78,7 +80,7 @@ const getChannelCompany = async (id) => {
             return item.id === id
             return item.id === id
         })
         })
         if (!companyData) {
         if (!companyData) {
-            throw new Error(("查不到租户信息"));
+            throw new Error("查不到租户信息");
         }
         }
     }
     }
     return companyData;
     return companyData;
@@ -107,14 +109,51 @@ const addCusAccApplyInfo = async (deliverData, pobj) => {
         customerName: deliverData.delivery_info.companyName,
         customerName: deliverData.delivery_info.companyName,
         phoneNumber: deliverData.delivery_info.contactsPhone,
         phoneNumber: deliverData.delivery_info.contactsPhone,
         valueAddedTax: valueAddedTax[pobj.taxpayerType],
         valueAddedTax: valueAddedTax[pobj.taxpayerType],
-        serviceTime: Math.round(moment(deliverData.delivery_info.serviceEndTime).diff(moment(deliverData.delivery_info.serviceStartTime), 'months', true)).toString(),
+        serviceTime: Math.ceil(moment(deliverData.delivery_info.serviceEndTime).diff(moment(deliverData.delivery_info.serviceStartTime), 'months', true)).toString(),
         initPeriod: parseInt(moment(deliverData.delivery_info.serviceStartTime).format('YYYYMMDD')),
         initPeriod: parseInt(moment(deliverData.delivery_info.serviceStartTime).format('YYYYMMDD')),
         companyId: pobj.supplier
         companyId: pobj.supplier
     }
     }
     await postToFtBySign('/cusAccApplyInfo/addCusAccApplyInfo', reqData);
     await postToFtBySign('/cusAccApplyInfo/addCusAccApplyInfo', reqData);
 }
 }
+
+/**
+ * 向融易算 发消息
+ * @param {*} data 
+ */
+const feedbackToRys = async (data) => {
+    let reqData = {
+        BizId: data.bizId
+    };
+    if (data.orderStaus === true) {
+        reqData = {
+            ...reqData,
+            AuditResult: 1,
+            ServiceStartTime: moment(data.setupAt).format('YYYY-MM-DD')
+        }
+    }
+    if (data.orderStaus === false) {
+        reqData = {
+            ...reqData,
+            AuditResult: 2,
+            Note: data.note
+        }
+    }
+    let resData = await system.queueOper({
+        pushUrl: this.rysUrl + "service/feedback",
+        actionType: "feedback",
+        messageBody: reqData,
+        headData: {
+            'Source': 'GSB'
+        },
+        requestId: uuidv4()
+    });
+    if (resData !== 0) {
+        throw new Error(resData.msg)
+    }
+}
 module.exports = {
 module.exports = {
     postToFtBySign,
     postToFtBySign,
     addCusAccApplyInfo,
     addCusAccApplyInfo,
-    getChannelCompany
+    getChannelCompany,
+    feedbackToRys
 }
 }
\ No newline at end of file