policy pushs

center-order/app/base/service/impl/dbpolicy/policyneedSve.js

@@ -293,7 +293,8 @@ class PolicyneedService extends ServiceBase {
     });
     });
     for(var i=0;i<pns.length;i++){
     for(var i=0;i<pns.length;i++){
       var pn = pns[i];
       var pn = pns[i];
-      var needNo=await this.getBusUid("pn");
+      // var needNo=await this.getBusUid("pn");
+      var needNo = "PN"+pn.id+"_"+pn.mobile+pn.uapp_id;
       var pobj = {
       var pobj = {
         "idempotentId": needNo, 
         "idempotentId": needNo, 
         "idempotentSource": "policyMpm",
         "idempotentSource": "policyMpm",

center-order/app/base/service/impl/dbpolicy/policysubscribeSve.js

@@ -122,7 +122,7 @@ class PolicysubscribeService extends ServiceBase {
     var currentPage = obj.currentPage || 1;
     var currentPage = obj.currentPage || 1;
     var pageSize = obj.pageSize || 100 ;
     var pageSize = obj.pageSize || 100 ;
     var ps = await this.dao.model.findOne({
     var ps = await this.dao.model.findOne({
-      where:{id:obj.policySubscribeId,openid:obj.openid},
+      where:{id:obj.policySubscribeId},
       raw:true
       raw:true
     });
     });
     if(!ps || !ps.id){
     if(!ps || !ps.id){