|
@@ -13,6 +13,7 @@ from Model.models import Device_User, Device_Info, iotdeviceInfoModel, UIDCompan
|
|
|
SerialNumberModel
|
|
|
from Object.IOTCore.IotObject import IOTClient
|
|
|
from Object.ResponseObject import ResponseObject
|
|
|
+from Object.TokenObject import TokenObject
|
|
|
from Service.CommonService import CommonService
|
|
|
|
|
|
|
|
@@ -31,7 +32,7 @@ class IotCoreView(View):
|
|
|
return self.validate(operation, request_dict, request)
|
|
|
|
|
|
def validate(self, operation, request_dict, request):
|
|
|
-
|
|
|
+ token = TokenObject(request_dict.get('token', None))
|
|
|
response = ResponseObject()
|
|
|
|
|
|
if operation == 'createKeysAndCertificate':
|
|
@@ -39,7 +40,12 @@ class IotCoreView(View):
|
|
|
elif operation == 'thingRegroup':
|
|
|
return self.thing_regroup(request_dict, response, request)
|
|
|
else:
|
|
|
- return response.json(404)
|
|
|
+ if token.code != 0:
|
|
|
+ return response.json(token.code)
|
|
|
+ if operation == 'clearIotCerm':
|
|
|
+ return self.clear_Iot_Cerm(request_dict, response)
|
|
|
+ else:
|
|
|
+ return response.json(404)
|
|
|
|
|
|
|
|
|
# CVM注册 :正使用
|
|
@@ -168,3 +174,16 @@ class IotCoreView(View):
|
|
|
except Exception as e:
|
|
|
print(e)
|
|
|
return response.json(500, repr(e))
|
|
|
+
|
|
|
+ def clear_Iot_Cerm(self, userID, request_dict, response):
|
|
|
+ serial_number = request_dict.get('serial_number', None)
|
|
|
+
|
|
|
+ if serial_number:
|
|
|
+
|
|
|
+ iot = iotdeviceInfoModel.objects.filter(thing_name="Ansjer_Device_" + serial_number)
|
|
|
+ if iot.exists():
|
|
|
+ iot.delete()
|
|
|
+ return response.json(0)
|
|
|
+
|
|
|
+ else:
|
|
|
+ return response.json(444)
|