更新同步模块
This commit is contained in:
@@ -4,13 +4,18 @@ import math
|
||||
import requests
|
||||
from dateutil.relativedelta import relativedelta
|
||||
from datetime import timedelta, datetime
|
||||
|
||||
import requests
|
||||
import json
|
||||
import time
|
||||
import datetime
|
||||
from odoo import models, fields, api
|
||||
from odoo.exceptions import ValidationError
|
||||
import logging
|
||||
|
||||
_logger = logging.getLogger(__name__)
|
||||
|
||||
MRS = 'https://mrs.cs.jikimo.com'
|
||||
|
||||
|
||||
class MrsProductionMaterials(models.Model):
|
||||
_inherit = "mrs.production.materials"
|
||||
@@ -18,9 +23,24 @@ class MrsProductionMaterials(models.Model):
|
||||
url = '/api/production_materials/list'
|
||||
|
||||
def sync_production_materials(self):
|
||||
str = '定时同步材料资源库'
|
||||
timestamp_str = int(time.time())
|
||||
headers = {'TOKEN': '4130d97c-37be-11ed-84a7-f8b54df29535',
|
||||
'TIMESTAMP': '1663859413',
|
||||
'check_str': 'e840309b4ac386b5b9005dfb85ca9e9eee7149bd'}
|
||||
str = MRS + self.url
|
||||
print(str)
|
||||
return str
|
||||
r = requests.post(str, data=None, json={},headers=headers)
|
||||
r = r.json()
|
||||
data = json.loads(r['result'])
|
||||
if data['status'] == 1:
|
||||
production_materials_list = data['production_materials_list']
|
||||
if production_materials_list:
|
||||
for item in production_materials_list:
|
||||
port = self.env['mrs.production.materials'].search([('materials_no', '=', item.materials_no)])
|
||||
if not port:
|
||||
port = item
|
||||
else:
|
||||
return "访问失败"
|
||||
|
||||
|
||||
class MrsMaterialModel(models.Model):
|
||||
|
||||
Reference in New Issue
Block a user