|
@@ -41,11 +41,6 @@ class IncomeProductsView(View):
|
|
|
return response.json(444)
|
|
|
|
|
|
serial_number = serial_number[0:9]
|
|
|
- redis = RedisObject()
|
|
|
- lock = redis.get_data(f"income_device_scheme_{storage_code}_{serial_number}")
|
|
|
- if lock:
|
|
|
- return response.json(10, '重复扫码')
|
|
|
- redis.set_data(f"income_device_scheme_{storage_code}_{serial_number}", 1, 60)
|
|
|
|
|
|
try:
|
|
|
LOGGER.info(f"设备关联产品方案, storageCode: {storage_code}, serialNumber: {serial_number}")
|
|
@@ -53,7 +48,6 @@ class IncomeProductsView(View):
|
|
|
if device_scheme_qs.exists():
|
|
|
storage_code = device_scheme_qs.first().storage_code
|
|
|
LOGGER.info(f"设备关联产品方案, serialNumber已存在, storageCode: {storage_code}, serialNumber: {serial_number}")
|
|
|
- redis.del_data(f"income_device_scheme_{storage_code}_{serial_number}")
|
|
|
return response.json(173, f"数据已存在, storage_code为: {storage_code}")
|
|
|
|
|
|
now_time = int(time.time())
|
|
@@ -67,6 +61,5 @@ class IncomeProductsView(View):
|
|
|
return response.json(0)
|
|
|
|
|
|
except Exception as e:
|
|
|
- redis.del_data(f"income_device_scheme_{storage_code}_{serial_number}")
|
|
|
print(e)
|
|
|
return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|