#!/x/app/python3/bin/python3
# -*- coding: utf-8 -*-
import urllib.request
import urllib.parse
import urllib.error
import json


class TaskManage:
	
	def __init__(self):
		self.__header = {"Content-Type": "application/json-rpc"}


	#get请求
	def get_request(self,GetUrl,Param):
		request  = urllib.request.Request(GetUrl+Param)		
		result = urllib.request.urlopen(request).read().decode('utf-8')
		json=eval(result)
		return json

	#post请求
	def post_request(self,PostUrl,data):
		request = urllib.request.Request(PostUrl,json.dumps(data).encode('utf-8'),self.__header)
		result = urllib.request.urlopen(request).read().decode('utf-8')

	#改切片状态
	def change_slice_status(self,PostUrl,TaskId,Status,slice_server,slice_error_desc):
		data={"task_id" : TaskId, "status": Status, "slice_server": slice_server, "slice_error_desc": slice_error_desc}
		return self.post_request(PostUrl,data)

	#改发布状态
	def change_push_status(self,PostUrl,TaskId,Status,slice_server,source_cdn_error_desc):
		data={"task_id" : TaskId, "source_cdn_status": Status, "source_cdn_server": slice_server,"source_cdn_error_desc":source_cdn_error_desc}
		return self.post_request(PostUrl,data)