pp

tx-fi-tax/app/base/controller/impl/bizchance/bizoptCtl.js

@@ -121,34 +121,62 @@ class BizOptCtl extends CtlBase {
     async closeBizopt(mobj, qobj, req) {
     async closeBizopt(mobj, qobj, req) {
         let pobj = mobj.d;
         let pobj = mobj.d;
         pobj.business_status = "isClosed";
         pobj.business_status = "isClosed";
+        if (!qobj.demand_code || !qobj.close_reason) {
+            return system.getResultError("缺少必要参数.");
+        }
         //根据需求编号去更新该条需求的状态为已关闭
         //根据需求编号去更新该条需求的状态为已关闭
         try {
         try {
             let res = await this.service.updateStatusByDemandCode(pobj);
             let res = await this.service.updateStatusByDemandCode(pobj);
+            
             //添加到记录表
             //添加到记录表
             pobj.operator = {
             pobj.operator = {
                 id: mobj.userid ? mobj.userid : "",
                 id: mobj.userid ? mobj.userid : "",
                 name: mobj.username ? mobj.username : ""
                 name: mobj.username ? mobj.username : ""
             }
             }
+            pobj.operation_type = "close";
+            pobj.operation_details = {
+                close_reason: pobj.close_reason,
+                remarks: pobj.remarks
+            }
             let recordRes = await this.operationrecordSve.insertInfo(pobj);
             let recordRes = await this.operationrecordSve.insertInfo(pobj);
+
             //异步将该需求关闭信息同步到其他系统(走队列，融易算接口文档2.3)
             //异步将该需求关闭信息同步到其他系统(走队列，融易算接口文档2.3)
-            //构造参数
-            //TODO 构造参数，添加判断(有方案信息的才走队列同步到融易算，没有的直接关闭)
+            //构造参数，添加判断(有方案信息的才走队列同步到融易算，没有的直接关闭)
+            let schemeRes = await this.schemeSve.findInfo(pobj);
+            if (schemeRes && schemeRes.solution_bizid) {
+                let pushObj = this.buildObj(pobj, schemeRes);
+                system.queueOper(pushObj);
+            } else {
+                console.log(pobj.demand_code + "该需求没有方案信息，不需要同步");
+            }
+            return system.getResult("关闭需求成功!");
+        } catch (error) {
+            return system.getResultError("bizoptCtl/closeBizopt 关闭需求出错!");
+        }
+    }
+
+    buildObj(pobj, schemeRes) {
         let pushUrl = this.rysUrl + "leads/proposal/close";
         let pushUrl = this.rysUrl + "leads/proposal/close";
+        let solutionBizId;
+        if (schemeRes.solution_bizid) {
+            solutionBizId = schemeRes.solution_bizid;
+        }
         let pushObj = {
         let pushObj = {
             pushUrl: pushUrl,
             pushUrl: pushUrl,
             actionType: "close",
             actionType: "close",
-                messageBody: pobj,
+            messageBody: {
+                IntentionBizId: pobj.demand_code,
+                BizType: "bookkeeping",
+                Solution: {
+                    SolutionBizId: solutionBizId,//方案编号
+                    Note: pobj.close_reason //备注
+                }
+            },
             headData: {
             headData: {
-                    'Authorization': 'Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjE1OTg0MzQ2ODcsImlzcyI6InJFRVN6TU5ZUlM2RnBWNnZlY09vdExPNWdPcUNXSmFQIiwiaWF0IjoxNTk4NDMxMDg3fQ.isQ40HqHHfJ-rTsUQOhRIdu4XCitZU-AfzeqSH4kPbQ',
-                    'XAPPKEY': 'f6b59b74-f943-4735-bb86-e05d6b7fd78e',
                 'Source': 'GSB'
                 'Source': 'GSB'
             }
             }
         }
         }
-            system.queueOper(pushObj);
-            return system.getResult("关闭需求成功!");
-        } catch (error) {
-            return system.getResultError("bizoptCtl/closeBizopt 关闭需求出错!");
-        }
+        return pushObj;
     }
     }
 
 
     /**
     /**

tx-fi-tax/app/base/controller/impl/bizchance/fitaxschemeCtl.js

 var system = require("../../../system");
 var system = require("../../../system");
 var settings = require("../../../../config/settings");
 var settings = require("../../../../config/settings");
 const CtlBase = require("../../ctl.base");
 const CtlBase = require("../../ctl.base");
+const { json, JSON } = require("sequelize");
 const appconfig = system.getSysConfig();
 const appconfig = system.getSysConfig();
 class FitaxschemeCtl extends CtlBase {
 class FitaxschemeCtl extends CtlBase {
     constructor() {
     constructor() {
@@ -124,21 +125,3 @@ class FitaxschemeCtl extends CtlBase {
 }
 }
 module.exports = FitaxschemeCtl;
 module.exports = FitaxschemeCtl;
 
 
-// var task = new FitaxschemeCtl();
-// var obj = {
-//     d: {
-//         "demand_code": "20200728103902194844_book",
-//         "solution_bizid": "22222",
-//         "service_type": "代理记账",
-//         "service_name": "海南省三亚市",
-//         "company_type": "特殊行业",
-//         "buy_duration": 2,
-//         "remarks": "SaaS",
-//         "taxpayer_type": "小规模纳税人",
-//         "total_cost": "2222"
-//     }
-// }
-// task.insertInfo(obj, {}, {}).then(d => {
-//     console.log(JSON.stringify(d));
-// })
-

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

 const system = require("../../../system");
 const system = require("../../../system");
 const ServiceBase = require("../../sve.base");
 const ServiceBase = require("../../sve.base");
 const settings = require("../../../../config/settings");
 const settings = require("../../../../config/settings");
+const { json } = require("sequelize");
 const appconfig = system.getSysConfig();
 const appconfig = system.getSysConfig();
 class FitaxschemeService extends ServiceBase {
 class FitaxschemeService extends ServiceBase {
     constructor() {
     constructor() {
@@ -31,3 +32,15 @@ class FitaxschemeService extends ServiceBase {
     }
     }
 }
 }
 module.exports = FitaxschemeService;
 module.exports = FitaxschemeService;
+
+// var task = new FitaxschemeService();
+// test()
+// async function test() {
+//     var obj = {
+//         "demand_code": "20200728103902194844_book",
+//     }
+//     let res = await task.findInfo(obj);
+//     if (res) {
+//         console.log("返回结果：" + JSON.stringify(res));
+//     }
+// }
\ No newline at end of file