package weaver;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.alibaba.fastjson.JSONObject;
import com.google.gson.Gson;
import foundation.action.ActionProvider;
import foundation.capacity.ActorTarget;
import foundation.dao.preload.Bucket;
import foundation.data.entity.Entity;
import foundation.data.object.DataObject;
import foundation.data.object.EntitySaver;
import foundation.handler.envelop.ILetterWriter;
import foundation.icall.callout.HttpServerMeta;
import foundation.icall.callout.RemoteSourceBucket;
import foundation.io.FileCenter;
import foundation.io.object.FileRecord;
import foundation.user.OnlineUser;
import foundation.util.MD5Utils;
import foundation.util.Util;
import foundation.variant.expression.VariantExpression;
import net.qiyuesuo.v3sdk.SdkClient;
import net.qiyuesuo.v3sdk.http.StreamFile;
import net.qiyuesuo.v3sdk.model.common.Action;
import net.qiyuesuo.v3sdk.model.common.DocumentFormDto;
import net.qiyuesuo.v3sdk.model.common.SignAuthConfigBean;
import net.qiyuesuo.v3sdk.model.common.Signatory;
import net.qiyuesuo.v3sdk.model.common.SignatoryRect;
import net.qiyuesuo.v3sdk.model.common.SignurlActions;
import net.qiyuesuo.v3sdk.model.contract.request.ContractCreatebycategoryRequest;
import net.qiyuesuo.v3sdk.model.contract.request.ContractDownloadRequest;
import net.qiyuesuo.v3sdk.model.contract.request.ContractInitiateCancelRequest;
import net.qiyuesuo.v3sdk.model.contract.request.ContractRecallRequest;
import net.qiyuesuo.v3sdk.model.contract.request.ContractSignurlV3Request;
import net.qiyuesuo.v3sdk.model.contract.request.ContractViewurlRequest;
import net.qiyuesuo.v3sdk.model.contract.response.ContractSignurlV3Response;
import net.qiyuesuo.v3sdk.model.contract.response.ContractViewurlResponse;
import net.qiyuesuo.v3sdk.model.v2document.request.V2DocumentCreatebyfileRequest;
import net.qiyuesuo.v3sdk.model.v2document.response.V2DocumentCreatebyfileResponse;
import net.qiyuesuo.v3sdk.utils.SdkResponse;
import weaver.dao.BusinessData;
import weaver.dao.CallbackType;
import weaver.dao.ISignLetter;
import weaver.dao.SignState;
import weaver.dao.Signer;
import weaver.util.QiyuesuoCallbackUtils;

public class WeaverHandler extends ActionProvider{
	
	//泛微
	private static SdkClient sdkClient = null;	
	private static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd_HH_mm_ss");
	private static HttpServerMeta callBackSourceMeta;
	
	@Override
	protected void publishMethod() {
		//13. 泛微上传本地文件创建签署文档
		addMethod("weaverCreatebyFile");
		
		//14. 泛微创建或发起电子签约
		addMethod("weaverCreatebyCategory");
		
		//15.文件签署页面v3
		addMethod("weaverSignUrl");
		
		//16.文件浏览页面
		addMethod("weaverViewUrl");
		
		//17.文件download
		addMethod("weaverDownLoad");
		
		//18.撤回文件
		addMethod("weaverRecall");
		
		//19.发起作废
		addMethod("weaverCancel");

		//20.签章状态同步
		addMethod("signStateSync");
	}
	
	//发起作废
	public void weaverCancel() throws Exception {
		HttpServerMeta eSignSourceMeta = (HttpServerMeta) RemoteSourceBucket.getInstance().get(ISignLetter.WAEVER_SIGN);
		String accessKey = eSignSourceMeta.getString(ISignLetter.AppToken);
		String accessSecret = eSignSourceMeta.getString(ISignLetter.AppSecret);
		
		DataObject dataNameObject = null;
		Entity dataNameEntity = null;
		String contractId = "", result = "";
		
		String id = dataReader.getString("id");
		String reason = dataReader.getString(ISignLetter.Reason);
		String dataName = dataReader.getString("dataName");
		String signer = dataReader.getString(ISignLetter.Signer);
		
		//1.记录文档信息
		dataNameObject = DataObject.getInstance(dataName);
		dataNameEntity = dataNameObject.getTableEntity(id);
		EntitySaver saver = dataNameObject.createEntitySaver(id);
		
		if (dataNameEntity == null || dataNameEntity.isEmpty()) {
			dataWriter.setSuccess(false);
			dataWriter.addValue("weaver", "获取不到文档信息");
			return;
		}
		
		//电子签约文件ID
		contractId = dataNameEntity.getString(ISignLetter.ContractId, "");
		
		String serverUrl = "https://partneropen.qiyuesuo.cn/contract/initiate/cancel?_="+ System.currentTimeMillis();
		sdkClient = new SdkClient(serverUrl, accessKey, accessSecret);
		
		ContractInitiateCancelRequest request = new ContractInitiateCancelRequest();
		
		request.setContractId(Long.parseLong(contractId));
        request.setReason(reason);
        try {
        	 SdkResponse<?> response = sdkClient.service(request);
        	 if (response.getCode() == 0) {
        		 dataWriter.setSuccess(true);
        		 
        		 if (!Util.isEmpty(signer)) {
        			 saver.set(signer, "F");
        		 }
        		 else {
        			 saver.set(ISignLetter.IsSignature, "F");
        		 }

        		 if("F".equalsIgnoreCase(dataNameEntity.getString(ISignLetter.PartyB, "F")) 
        				 || "F".equalsIgnoreCase(dataNameEntity.getString(ISignLetter.IsSignature, "F"))) {
        			 saver.set(ISignLetter.SignStateCode, SignState.DRAFT);
        			 saver.set(ISignLetter.SignStateName, SignState.DRAFT.getName());
        		 }
        		 saver.update();
        	 }
        	 else {
        		 dataWriter.setSuccess(false);
        		 result = response.getMessage();
        	 }
        	 
        	 if (Util.isEmpty(result)) {
        		 dataWriter.addValue("weaver", response.getResult());
        	 }
        	 else {
        		 dataWriter.addValue("weaver", result);
        	 }
        } catch(Exception e) {
        	 e.printStackTrace();
        }		
	}
	
	//撤回文件
	public void weaverRecall() throws Exception {
		DataObject dataNameObject = null;
		Entity dataNameEntity = null;
		String contractId = "", result = "";
		
		String id = dataReader.getString("id");
		String dataName = dataReader.getString("dataName");
		String reason = dataReader.getString(ISignLetter.Reason);
		String signer = dataReader.getString(ISignLetter.Signer);
		
		HttpServerMeta eSignSourceMeta = (HttpServerMeta) RemoteSourceBucket.getInstance().get(ISignLetter.WAEVER_SIGN);
		String accessKey = eSignSourceMeta.getString(ISignLetter.AppToken);
		String accessSecret = eSignSourceMeta.getString(ISignLetter.AppSecret);
		//1.记录文档信息
		dataNameObject = DataObject.getInstance(dataName);
		dataNameEntity = dataNameObject.getTableEntity(id);
		EntitySaver saver = dataNameObject.createEntitySaver(id);
		
		if (dataNameEntity == null || dataNameEntity.isEmpty()) {
			dataWriter.setSuccess(false);
			dataWriter.addValue("weaver", "获取不到文档信息");
			return;
		}
		
		//电子签约文件ID
		contractId = dataNameEntity.getString(ISignLetter.ContractId);
		
		String serverUrl = "https://partneropen.qiyuesuo.cn/contract/recall?_="+ System.currentTimeMillis();
		sdkClient = new SdkClient(serverUrl, accessKey, accessSecret);
		
		ContractRecallRequest request = new ContractRecallRequest();
		
		request.setContractId(Long.parseLong(contractId));
        request.setReason(reason);
        try {
        	 SdkResponse<?> response = sdkClient.service(request);
        	 if (response.getCode() == 0) {
        		 dataWriter.setSuccess(true);
        		 
        		 if (!Util.isEmpty(signer)) {
        			 saver.set(signer, "F");
        		 }
        		 else {
        			 saver.set(ISignLetter.IsSignature, "F");
        		 }
        		 
        		 if("F".equalsIgnoreCase(dataNameEntity.getString(ISignLetter.PartyB, "F")) 
        				 || "F".equalsIgnoreCase(dataNameEntity.getString(ISignLetter.IsSignature, "F"))) {
        			 saver.set(ISignLetter.SignStateCode, SignState.TERMINATED);
        			 saver.set(ISignLetter.SignStateName, SignState.TERMINATED.getName());
        		 }
        		 
        		 saver.update();
        	 }
        	 else {
        		 dataWriter.setSuccess(false);
        		 result = response.getMessage();
        	 }
        	 
        	 if (Util.isEmpty(result)) {
        		 dataWriter.addValue("weaver", response.getResult());
        	 }
        	 else {
        		 dataWriter.addValue("weaver", result);
        	 }
        	 
        } catch(Exception e) {
        	 e.printStackTrace();
        }		
	}
	
	//文件下载
	public void weaverDownLoad() throws Exception {
		HttpServerMeta eSignSourceMeta = (HttpServerMeta) RemoteSourceBucket.getInstance().get(ISignLetter.WAEVER_SIGN);
		String accessKey = eSignSourceMeta.getString(ISignLetter.AppToken);
		String accessSecret = eSignSourceMeta.getString(ISignLetter.AppSecret);
		
		//电子签约文件ID
		String contractId = dataReader.getString("contractId");
		String needCompressForOneFile = dataReader.getString("needCompressForOneFile");
		String fileName = contractId + "_" + sdf.format(new Date()) + ".zip";
		
		String serverUrl = "https://partneropen.qiyuesuo.cn/contract/download?_="+ System.currentTimeMillis();
		sdkClient = new SdkClient(serverUrl, accessKey, accessSecret);
		
		ContractDownloadRequest request = new ContractDownloadRequest();
		
		request.setContractId(Long.parseLong(contractId));
		request.setNeedCompressForOneFile(needCompressForOneFile);
        try {
        	 File file = new File("D:\\repository\\weaver\\" + fileName);
        	 if (!file.exists()) {
        		 file.createNewFile();
        	 }
        	 OutputStream outputStream = new FileOutputStream(file);
        	 sdkClient.download(request, outputStream);
        	 outputStream.close();
        } catch(Exception e) {
        	 e.printStackTrace();
        }		
	}
	
	//文件浏览页面
	public void weaverViewUrl() throws Exception {
		DataObject dataNameObject = null;
		Entity dataNameEntity = null;
		String contractId = "", documentId = "";
		
		String id = dataReader.getString("id");
		String dataName = dataReader.getString("dataName");
		
		//1.记录文档信息
		dataNameObject = DataObject.getInstance(dataName);
		dataNameEntity = dataNameObject.getTableEntity(id);
		
		if (dataNameEntity == null || dataNameEntity.isEmpty()) {
			dataWriter.setSuccess(false);
			dataWriter.addValue("weaver", "获取不到文档信息");
			return;
		}
		
		HttpServerMeta eSignSourceMeta = (HttpServerMeta) RemoteSourceBucket.getInstance().get(ISignLetter.WAEVER_SIGN);
		String accessKey = eSignSourceMeta.getString(ISignLetter.AppToken);
		String accessSecret = eSignSourceMeta.getString(ISignLetter.AppSecret);
		
		//电子签约文件ID
		contractId = dataNameEntity.getString(ISignLetter.ContractId, "");
		documentId = dataNameEntity.getString(ISignLetter.DocumentId, "");
		
		String serverUrl = "https://partneropen.qiyuesuo.cn/contract/viewurl?_="+ System.currentTimeMillis();
		sdkClient = new SdkClient(serverUrl, accessKey, accessSecret);
		
		ContractViewurlRequest request = new ContractViewurlRequest();
		
		request.setContractId(Long.parseLong(contractId));
		request.setAllowDownload("true");
		
        try {
        	SdkResponse<ContractViewurlResponse> response = sdkClient.service(request, ContractViewurlResponse.class);
        	 if (response.getCode() == 0) {
        		 dataWriter.setSuccess(true);
        	 }
        	 else {
        		 dataWriter.setSuccess(false);
        	 }
        	 Gson gson = new Gson();
        	 String resultStr = gson.toJson(response.getResult());
        	 resultStr = resultStr.replace("\\u003d", "=");
        	 resultStr = resultStr.replace("\\u0026", "&");
        	 
        	 dataWriter.addValue("weaver", resultStr);
        } catch(Exception e) {
        	 e.printStackTrace();
        }		
	}
	
	//文件签署页面v3
	public void weaverSignUrl() throws Exception {
		DataObject dataNameObject = null;
		Entity dataNameEntity = null;
		String documentId = "", contractId = "";
		String result = "";
		
		String id = dataReader.getString("id");
		if (Util.isEmpty(id)) {
			id = dataReader.getString("id");
		}

		String dataName = dataReader.getString("dataName");
		if (Util.isEmpty(dataName)) {
			dataName = dataReader.getString("dataName");
		}
		
		HttpServerMeta eSignSourceMeta = (HttpServerMeta) RemoteSourceBucket.getInstance().get(ISignLetter.WAEVER_SIGN);
		String accessKey = eSignSourceMeta.getString(ISignLetter.AppToken);
		String accessSecret = eSignSourceMeta.getString(ISignLetter.AppSecret);
		
		String signerCode = dataReader.getString(ISignLetter.Signer);
		SignBucket signBucket = SignBucket.getInstance();
		SignConfig signConfig = signBucket.get(dataName);

		//1.记录文档信息
		dataNameObject = DataObject.getInstance(dataName);
		dataNameEntity = dataNameObject.getTableEntity(id);
		if (dataNameEntity == null || dataNameEntity.isEmpty()) {
			dataWriter.setSuccess(false);
			dataWriter.addValue("weaver", "获取不到文档信息");
			return;
		}
		
		documentId = dataNameEntity.getString(ISignLetter.DocumentId, "");
		contractId = dataNameEntity.getString(ISignLetter.ContractId, "");
		String companyId = dataNameEntity.getString("company_id");
		Signer signer = getSigner(companyId);
		
		String serverUrl = "https://partneropen.qiyuesuo.cn/contract/signurl/v3?_"+ System.currentTimeMillis();
		sdkClient = new SdkClient(serverUrl, accessKey, accessSecret);
		ContractSignurlV3Request request = new ContractSignurlV3Request();
		
		//电子签约文件ID
		request.setContractId(Long.parseLong(contractId));
		//签署方名称
		request.setTenantName(signer.getTenantName());
		request.setSignatoryNo(signer.getSignatoryNo());
		//签署方类型
		request.setTenantType("COMPANY");
		//接收人名称
		request.setReceiverName(signer.getReceiverName());
		//签署方的联系方式
		request.setContact(signer.getContactPhone());
		
        try {
        	 SdkResponse<ContractSignurlV3Response> response = sdkClient.service(request, ContractSignurlV3Response.class);
        	 if (response.getCode() == 0) {
        		 dataWriter.setSuccess(true);
        	 }
        	 else {
        		 dataWriter.setSuccess(false);
        		 result = response.getMessage();
        	 }
        	 Gson gson = new Gson();
        	 String resultStr = gson.toJson(response.getResult());
        	 resultStr = resultStr.replace("\\u003d", "=");
        	 resultStr = resultStr.replace("\\u0026", "&");
        	 
        	 if (Util.isEmpty(result)) {
        		 dataWriter.addValue("weaver", resultStr);
        	 }
        	 else {
        		 dataWriter.addValue("weaver", result);
        	 }
        	 
        } catch(Exception e) {
        	 e.printStackTrace();
        }		
	}

	//泛微创建或发起电子签约
	public void weaverCreatebyCategory() throws Exception {
		HttpServerMeta eSignSourceMeta = (HttpServerMeta) RemoteSourceBucket.getInstance().get(ISignLetter.WAEVER_SIGN);
		String accessKey = eSignSourceMeta.getString(ISignLetter.AppToken);
		String accessSecret = eSignSourceMeta.getString(ISignLetter.AppSecret);
		
		DataObject dataNameObject = null;
		Entity dataNameEntity = null;
		String subject = "", description = "", tenantName = "", documentId = "";
		String customerCode = "", customerName = "", companyId = "";
		ISignService signService = null;
		ContractCreatebycategoryRequest request = new ContractCreatebycategoryRequest();
		SignBucket signBucket = SignBucket.getInstance();
		
		String id = dataReader.getString("id");
		String dataName = dataReader.getString("dataName");
		SignConfig signConfig = signBucket.get(dataName);
		
		List<Action> actions = new ArrayList<Action>();
		Action action = new Action();
		action.setType("CORPORATE");
		action.setName(signConfig.getName());
		action.setSerialNo(1L);
		actions.add(action);
		
		SignAuthConfigBean signAuthConfig = new SignAuthConfigBean();
		signAuthConfig.setSignAuth("DEFAULT");
		signAuthConfig.setQuestion("您好，为确保您本人操作");
		signAuthConfig.setAnswer("我确认");
		
		List<Signatory> signatories = new ArrayList<Signatory>();
		Signatory signatory = new Signatory();
		//1.记录文档信息
		dataNameObject = DataObject.getInstance(dataName);
		dataNameEntity = dataNameObject.getTableEntity(id);
		EntitySaver saver = dataNameObject.createEntitySaver(id);
		
		if (dataNameEntity == null || dataNameEntity.isEmpty()) {
			dataWriter.setSuccess(false);
			dataWriter.addValue("weaver", "获取不到文档信息");
			return;
		}

		
		if (SignType.Both == signConfig.getSignType()) {
			signService = new BothSignService();
		}
		else if (SignType.PartyB == signConfig.getSignType()) {
			signService = new PartyBSignService();
		}
		else if (SignType.PartyA == signConfig.getSignType()) {
			signService = new PartyASignService();
		}
		List<Signer> signers = signService.getSigners(dataNameEntity);
		
		for (int serialNo = 1; serialNo <= signers.size(); serialNo++) {
			Signer signer = signers.get(serialNo - 1);
			signatory = new Signatory();
			signatory.setTenantType("COMPANY");
			signatory.setTenantName(signer.getTenantName());
			signatory.setSerialNo(String.valueOf(serialNo));
			signatory.setActions(actions);
			signatory.setSignAuthConfig(signAuthConfig);
			signatory.setSignatoryNo(signer.getSignatoryNo());
			signatories.add(signatory);
		}
		
		documentId = dataNameEntity.getString(ISignLetter.DocumentId, ""); 
		description = dataNameEntity.getString(ISignLetter.CategoryName, ""); 
		subject = signConfig.getSubjectContent(dataNameEntity);
		companyId = dataNameEntity.getString("company_id");
		Signer initiator = getSigner(companyId);
		tenantName = initiator.getTenantName();
		
		String serverUrl = "https://partneropen.qiyuesuo.cn/contract/createbycategory?_"+ System.currentTimeMillis();
		sdkClient = new SdkClient(serverUrl, accessKey, accessSecret);
		
		BusinessData businessData = new BusinessData(dataName, dataNameEntity);
		
		request.setSubject(subject);
		request.setDescription(description);
		request.setTenantName(tenantName);
		List<Long> documents = new ArrayList<Long>();
		documents.add(Long.parseLong(documentId));
		request.setDocuments(documents);
		request.setSignatories(signatories);
		request.setBusinessData(businessData.toString());
		request.setCategoryId(signConfig.getFlowId());
		
        try {
        	 SdkResponse<String> response = sdkClient.service(request, String.class);
        	 Map<String, String> msgMap = new HashMap<String, String>();
        	 if (response.getCode() == 0) {
        		 dataWriter.setSuccess(true);
        		 
        		 saver.set(ISignLetter.ContractId, response.getResult());
        		 saver.set(ISignLetter.SignStateCode, SignState.SIGNING);
        		 saver.set(ISignLetter.SignStateName, SignState.SIGNING.getName());
        		
        		 saver.update();        		 
        	 }
        	 else {
        		 dataWriter.setSuccess(false);
        	 }
    		 msgMap.put("code", String.valueOf(response.getCode()));
    		 msgMap.put("message", response.getMessage());
    		 msgMap.put("result", response.getResult());
    		 dataWriter.addValue("weaver", msgMap);
        } catch(Exception e) {
        	 e.printStackTrace();
        }			
	}
	
	//泛微上传本地文件创建签署文档
	public void weaverCreatebyFile() throws Exception {
		HttpServerMeta eSignSourceMeta = (HttpServerMeta) RemoteSourceBucket.getInstance().get(ISignLetter.WAEVER_SIGN);
		String accessKey = eSignSourceMeta.getString(ISignLetter.AppToken);
		String accessSecret = eSignSourceMeta.getString(ISignLetter.AppSecret);
		//1.解析上传文件
		DataObject dataNameObject = null, dataObject = null;
		Entity dataNameEntity = null, entity = null;
		String fileId = "";
		
		String id = dataReader.getString("id");
		if (Util.isEmpty(id)) {
			id = dataReader.getString("id");
		}
		String dataName = dataReader.getString("dataName");
		if (Util.isEmpty(dataName)) {
			dataName = dataReader.getString("dataName");
		}		
		
		SignBucket signBucket = SignBucket.getInstance();
		SignConfig signConfig = signBucket.get(dataName);
		
		//1.记录文档信息
		dataNameObject = DataObject.getInstance(dataName);
		dataNameEntity = dataNameObject.getTableEntity(id);
		
		if (dataNameEntity == null || dataNameEntity.isEmpty()) {
			dataWriter.setSuccess(false);
			dataWriter.addValue("weaver", "获取不到文档信息");
			return;
		}
		
		fileId = dataNameEntity.getString(signConfig.getFileField(), "");
		
		if (Util.isEmpty(fileId)) {
			dataWriter.setSuccess(false);
			dataWriter.addValue("weaver", "获取不到文档");
			return;			
		}
		
		//2. 获取文档文件
		dataObject = DataObject.getInstance(dataName);
		entity = dataObject.getBrowseEntity(fileId);
		
		FileRecord fileRecord = FileCenter.getFile(dataName, fileId);
		File file = fileRecord.getFile();
		
		String serverUrl = "https://partneropen.qiyuesuo.cn/v2/document/createbyfile?_="+ System.currentTimeMillis();
		sdkClient = new SdkClient(serverUrl, accessKey, accessSecret);
		
		DocumentFormDto form = new DocumentFormDto();
		V2DocumentCreatebyfileRequest request = new V2DocumentCreatebyfileRequest();
		
		InputStream inputStream = new FileInputStream(file);
		StreamFile streamFile = new StreamFile(file.getName(), inputStream);
		request.setFile(streamFile);
		request.setTitle(file.getName());
        request.setFileType(file.getName().substring(file.getName().lastIndexOf(".") + 1, file.getName().length()).trim());
        request.setFormObject(form);
        
        try {
        	 SdkResponse<V2DocumentCreatebyfileResponse> response = sdkClient.service(request, V2DocumentCreatebyfileResponse.class);
        	 if (response.getCode() == 0) {
        		 dataWriter.setSuccess(true);
        		 //保存documentId
        		 EntitySaver saver = dataObject.createEntitySaver(id);
        		 
        		 saver.set(ISignLetter.DocumentId, response.getResult().getDocumentId());
        		 saver.set(ISignLetter.SignStateCode, SignState.DRAFT);
        		 saver.set(ISignLetter.SignStateName, SignState.DRAFT.getName());
        		 saver.update();
        	 }
        	 else {
        		 dataWriter.setSuccess(false);
        	 }
        	 Gson gson = new Gson();
        	 String resultStr = gson.toJson(response.getResult());
        	 dataWriter.addValue("weaver", resultStr);
        } catch(Exception e) {
        	 e.printStackTrace();
        }		
	}
	
	//签章状态同步
	public void signStateSync() throws Exception{
		String encryptedResult = dataReader.getRawString("encrypted");

		// token check
		RemoteSourceBucket remoteSourceBucket = RemoteSourceBucket.getInstance();
		callBackSourceMeta = (HttpServerMeta) remoteSourceBucket.get(ISignLetter.WAEVER_SIGN_CALL);
		String aesKey = callBackSourceMeta.getString(ISignLetter.AesKey);
		
		String token = dataReader.getString("token");
		if (!tokenValid(token)) {
			dataWriter.setSuccess(false);
			dataWriter.addValue("用户身份认证失败");
			return ;
		}
		
		QiyuesuoCallbackUtils callUtils = new QiyuesuoCallbackUtils(aesKey, token);
		String decryptedResult = callUtils.decrypt(encryptedResult);
		
		String nonce = dataReader.getString("nonce");
		String signature = dataReader.getString("signature");
		Long timestamp = Long.valueOf(dataReader.getString("timestamp")); 
		String compSignature = MD5Utils.MD5Encode(decryptedResult + timestamp + nonce + token, "UTF-8");
		
		if (!compSignature.equals(signature)) {
			dataWriter.setSuccess(false);
			dataWriter.addValue("signStateSync", "签名校验失败");
			return ;
		}
		
		JSONObject resultJson = JSONObject.parseObject(decryptedResult);
		CallbackType callBackType = CallbackType.parse(resultJson.getString("callbackType"));
		BusinessData businessData = new BusinessData(resultJson.getJSONObject("businessData"));
		
		
		if(Util.isEmpty(businessData.getDataname()) ) {
			dataWriter.setSuccess(false);
			dataWriter.addValue("业务数据缺失");
			return ;
		}
		
		DataObject dataObject =  DataObject.getInstance(businessData.getDataname());
		EntitySaver saver = dataObject.createEntitySaver(businessData.getId());

		SignState signState = callBackType.getSignState();
		saver.set(ISignLetter.SignStateCode, signState);
		saver.set(ISignLetter.SignStateName, signState.getName());
		
		saver.update();
		
		dataWriter.setSuccess(true);
		dataWriter.addValue("合同已"+ signState.getName());
	}
	
	private Signer getSigner(String companyId) throws Exception {
		Signer signer = new Signer();
		OnlineUser user = OnlineUser.getInstance();
		ActorTarget actor = user.getCurrentActor();
		String actorId = user.getActorId();
		String accountId = actor.getTargetId();
		
		if(!Util.isEmpty(user.getCompanyId())) {
			companyId = user.getCompanyId();
		}
		
		if (actorId.contains("Customer")) {
			DataObject dataObject = DataObject.getInstance("md_org_account");
			Entity account = dataObject.getBrowseEntity(accountId);
			
			signer.setSignatoryNo(account.getString("code")); 
			signer.setTenantName(account.getString("account_name"));
			signer.setReceiverName(account.getString("business_person")); 
			signer.setContactPhone(account.getString("business_phone"));
		}
		else {
			DataObject dataObject = DataObject.getInstance("md_org");
			Entity org = dataObject.getBrowseEntity(companyId);
			
			signer.setSignatoryNo(org.getString("id")); 
			signer.setTenantName(ISignLetter.DefaultInitiator);
			signer.setReceiverName(org.getString("business_person")); 
			signer.setContactPhone(org.getString("business_phone"));
		}
		
		return signer;
	}

	private boolean tokenValid(String token) {
		String weaverToken = callBackSourceMeta.getString(ISignLetter.AccessToken);
		
		if(!weaverToken.equals(token)) {
			return false;
		}
		
		return true;
	}
	
}