need

gsb-marketplat-mag/app/base/service/impl/aggregation/needinfoSve.js

@@ -6,6 +6,7 @@ class NeedinfoService extends ServiceBase {
     constructor() {
         super("aggregation", ServiceBase.getDaoName(NeedinfoService));
         this.execClient = system.getObject("util.execClient");
+        this.fqUtilsSve = system.getObject("service.common.fqUtilsSve");
         // this.launchchannelDao = system.getObject("dao.configmag.launchchannelDao");
     }
     //推送聚合页需求至蜂擎
@@ -41,6 +42,8 @@ class NeedinfoService extends ServiceBase {
         console.log(pushRes,"pushRes############################3");
         if(pushRes && pushRes.data && pushRes.code && pushRes.code=="200" && pushRes.success ){//推送成功
             await this.dao.update({id:needinfo.id,push_status:1});
+        }else if( pushRes && pushRes.errorMsg){
+            await this.dao.update({id:needinfo.id,push_status:2,notes:pushRes.errorMsg});
         }else{
             await this.dao.update({id:needinfo.id,push_status:2});
         }
@@ -125,12 +128,8 @@ class NeedinfoService extends ServiceBase {
 module.exports = NeedinfoService;
 // var task = new NeedinfoService();
 // var obj={
-//     channel_code:"iqiyi",
-//     start_date:"2020-09-07 08:03:08",
-//     end_date:"2020-09-07 08:03:08",
-//     from:0,
-//     size:100
+//     id:1
 // };
-// task.getbrowsingrecordlist(obj).then(d=>{
-//     console.log(JSON.stringify(d),"!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+// task.pushAggregationNeedInfo2fq(obj).then(d=>{
+//     console.log(d,"!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
 // });
\ No newline at end of file