init

web2erp_track.py

@@ -19,7 +19,7 @@ class web2erp_track(base):
     '''跟踪订单明细的采购轨迹'''
     def __init__(self, data=None):
         super().__init__(data)
-        self.needupdate_url = self.CommonConf.order_api_url + '/order/track/needupdate'
+        self.needupdate_url = self.CommonConf.order_api_url + '/ag/bdfdf/cdd'
         self.create_url = self.CommonConf.order_api_url + '/order/track/create'
         self.audit_url = self.CommonConf.order_api_url + '/order/getrecaudit'
         self.request = Request()
@@ -35,6 +35,7 @@ class web2erp_track(base):
                 try:
                     self.publish()
                 except EmptyException as e:
+                    self.needupdate_url = self.CommonConf.order_api_url + '/order/track/needupdate'
                     pass
                 except Exception as e:
                     self.elkReport('订单明细轨迹推送任务失败')
@@ -70,20 +71,7 @@ class web2erp_track(base):
             res = self.request.postUrl(self.audit_url, {'rec_id' : body_arr['rec_id']})
             if None == res:
                 raise Exception('rec_id %s，请求查询审核接口失败' % (body_arr['rec_id'], ))
-            audit_arr = json.loads(res)
-            if audit_arr['errcode'] != 0:
-                raise Exception(audit_arr['errmsg'])
-            #记录审核数据
-            post.append({
-                'rec_id' : body_arr['rec_id'],
-                'order_id' : body_arr['order_id'],
-                'order_goods_type' : body_arr['order_goods_type'],
-                'track_type' : 1,
-                'track_num' : audit_arr['data']['goods_number'],
-                'create_name' : audit_arr['data']['sale_name'],
-                'create_time' : audit_arr['data']['confirm_time'],
-                'relevance_sn' : audit_arr['data']['order_sn'],
-                })
+           
 
         #ERP查询轨迹
         data = {