package grand;

import java.io.File;
import java.sql.SQLException;
import java.util.Date;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import foundation.action.ActionProvider;
import foundation.capacity.ActorType;
import foundation.code.CodeEngine;
import foundation.dao.DataPackage;
import foundation.dao.DataSource;
import foundation.dao.Domain;
import foundation.dao.Filter;
import foundation.dao.PackageStringMap;
import foundation.data.entity.Entity;
import foundation.data.entity.EntitySet;
import foundation.data.object.DataObject;
import foundation.data.object.EntitySaver;
import foundation.io.FileCenter;
import foundation.io.FileField;
import foundation.io.FileInjector;
import foundation.io.FileMeta;
import foundation.io.FileMetaList;
import foundation.io.FileTypes;
import foundation.io.object.FileRecord;
import foundation.io.template.AuthorizeTemplate;
import foundation.org.PositionCategory;
import foundation.persist.NamedSQL;
import foundation.persist.SQLRunner;
import foundation.state.StateMachine;
import foundation.token.IOnlineUser;
import foundation.user.OnlineUser;
import foundation.util.DateTimeUtil;
import foundation.util.ID;
import foundation.util.Util;

public class OrgAccountHandler extends ActionProvider {

	private static Logger logger;
	private static String TermCode_Terminate = "terminate";
	private static String TABLE_ACCOUNT = "md_org_account";
	private static String TABLE_NCACCOUNT = "md_org_account_ncc";
	private static String TABLE_CLOSEACCOUNT = "md_org_account_close";
	
	static {
	    logger = LogManager.getLogger(OrgAccountHandler.class);
	}
	
	
	@Override
	protected void publishMethod() {
		//1. 获取初始授信金额
		addMethod("getAccountCreditInitialAmt");		
		
		//2. 生成协议附件
		addMethod("createAgreementFile");
		
		//3. 备案生效（协议来源）
		addMethod("activateAgreementRecord");
		
		//3. 备案失效（协议来源）
		addMethod("stopAgreementRecord");
		
		//4. 生成授权书
		addMethod("createAuthorization");
		
		//5. 终止授权书
		addMethod("terminateAuthorization");

		//6. 失效授权书
		addMethod("disableAuthorization");
		
		//7. 生成渠道关系
		addMethod("refreshChannelStructure");
		
		//8. 客商汇总
		addMethod("customerCount");

		//9. 新增岗位
		addMethod("addPosition");
		
		//10. 删除岗位
		addMethod("deletePosition");
		
		//11. 关闭账户
		addMethod("closeAccount");

	}
	
	public void createAgreementFile() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		
		if (dataPackage == null) {
			logger.error("create agreement file error: data not exists");
			return;
		}
		
		dataPackage.loadOneDataFromDB();
		
		//1. 获取模板列表
		Entity master = dataPackage.getMasterEntity();
		String templateId = master.getString("template_id");
		
		DataObject dataObject = DataObject.getInstance("agm_template_file");
		EntitySet templateSet = dataObject.getTableEntitySet(new Filter("sender_id", templateId));
		
		if (templateSet == null || templateSet.isEmpty()) {
			logger.error("create agreement file error: template not exists");
			dataWriter.reportOneError("createAgreementFile", "协议模板不存在，无法创建文件");
			return;
		}
		
		//2. 数据注入
		FileMetaList result = new FileMetaList();
		
		IOnlineUser user = IOnlineUser.getInstance();
		
		PackageStringMap dataMap = dataPackage.toStringMap();
		dataMap.setNullResult("***");
		
		for (Entity entity: templateSet) {
			File file = new File(entity.getString("file_path"));
			String targetName = entity.getString("file_name");
			
			if (!file.exists()) {
				logger.error("create agreement file error, template not exists: {}", file.toString());
				dataWriter.reportOneError("createAgreementFile", "协议模板不存在:" + targetName);
				continue;
			}
			
			File target = FileInjector.createOneFile(user, file, targetName, FileTypes.PDF, dataMap);
			targetName = target.getName();
			
			FileMeta fileMeta = new FileMeta(targetName, target);
			fileMeta.setSize(file.length());
			result.add(fileMeta);
		}
		
		//3. 回写到协议中
		FileField fileField = new FileField("contract_attachment_id", null);
		FileCenter.saveFileToRepository(user, result, dataPackage, fileField);

		//4. 删除临时文件
//		for (FileMeta fileMeta: result) {
//			File temp = fileMeta.getFile();
//			temp.delete();
//		}
		
		//5. 返回结果
		dataWriter.addValue("file", result);
	}
	
	public void activateAgreementRecord() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		
		if (dataPackage == null) {
			logger.error("activate agreement record error: data not exists");
			return;
		}
		
		Entity master = dataPackage.getMasterEntity();
		String agreementNo = master.getString("agreement_no");
		Date beginDate = master.getDate("date_from", null);
		Date endDate = master.getDate("date_to", null);
		
		NamedSQL namedSQL = NamedSQL.getInstance("activateAgreementRecord");
		namedSQL.setParam("agreement_id", master.getId());
		namedSQL.setParam("agreement_no", agreementNo);
		namedSQL.setParam("date_from", beginDate);
		namedSQL.setParam("date_to", endDate);
		namedSQL.setParam("state_code", StateMachine.State_Code_Open);
		namedSQL.setParam("state_name", StateMachine.State_Name_Open);
		
		//1. 生效备案（通用）
		namedSQL.setParam("tableName", "agm_record");
		namedSQL.execute();
		
		//2. 生效价格（产品）
		namedSQL.setParam("tableName", "agm_record_product");
		namedSQL.execute();
		
		//3. 生效价格（省份）
		namedSQL.setParam("tableName", "agm_record_province");
		namedSQL.execute();
		
		//4. 生效价格
		namedSQL.setParam("tableName", "md_prod_price_detail");
		namedSQL.execute();
	}
	
	public void stopAgreementRecord() throws Exception {
		Domain domain = dataReader.getDomain();
		
		NamedSQL namedSQL = NamedSQL.getInstance("stopAgreementRecord");
		namedSQL.setParam("agreement_id", domain.getId());
		namedSQL.setParam("state_code", StateMachine.State_Code_Close);
		namedSQL.setParam("state_name", StateMachine.State_Name_Close);
		
		//1. 中止备案（通用）
		namedSQL.setParam("tableName", "agm_record");
		namedSQL.execute();
		
		//2. 中止价格（产品）
		namedSQL.setParam("tableName", "agm_record_product");
		namedSQL.execute();
		
		//3. 中止价格（省份）
		namedSQL.setParam("tableName", "agm_record_provinces");
		namedSQL.execute();
		
		//4. 中止价格
		namedSQL.setParam("tableName", "md_prod_price_detail");
		namedSQL.execute();
	}
	
	
	public void createAuthorization() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		
		if (dataPackage == null) {
			logger.error("create authorization file error: data not exists");
			return;
		}
		
		dataPackage.loadOneDataFromDB();
		
		IOnlineUser user = IOnlineUser.getInstance();
		Entity masterEntity = dataPackage.getMasterEntity();
		String applyId = masterEntity.getId();
		
		//1. 获取模板列表, 创建授权书
		String companyId = masterEntity.getString("company_id");
		String buId = masterEntity.getString("bu_id");
		String orgId = masterEntity.getString("org_id");
		String categoryCode = masterEntity.getString("category_code");
		String termCode = masterEntity.getString("term_code");
		
		if (TermCode_Terminate.equalsIgnoreCase(termCode)) {
			logger.error("apply is terminate authorization, skip createAuthorization.");
			return;
		}
		
		//2. 获取开户客户
		DataObject dataObject = DataObject.getInstance(TABLE_ACCOUNT);
		Filter accountFilter = new Filter();
		accountFilter.add("bu_id", buId);
		accountFilter.add("company_id", companyId);
		accountFilter.add("org_id", orgId);
		String accountId = null;
		Entity accountEntity = dataObject.getTableEntity(accountFilter);
		if (accountEntity != null ) {
			accountId = accountEntity.getId();
		}
		
		AuthorizeTemplate template = AuthorizeTemplate.getInstance(companyId, buId, categoryCode, termCode);
		
		if (template == null) {
			logger.error("authorize template file not exists, skep");
			dataWriter.reportOneError("createAuthorization", "授权书模板不存在，过程终止");
			task.terminate();
			return;
		}
		
		//3. 获取授权申请下的所有授权书
		dataObject = DataObject.getInstance("md_org_account_hospital");
		Filter filter = new Filter("apply_id", applyId);
		EntitySet entitySet = dataObject.getTableEntitySet(filter);
		
		//4. 处理产品及生产产品描述
		NamedSQL namedSQL = NamedSQL.getInstance("createAuthorizeProduces");
		namedSQL.setParam("apply_id", applyId);
		
		String buName = masterEntity.getString("bu_name");
		DataObject productObject = DataObject.getInstance("md_org_account_hospital_apply_product");
		EntitySet productSet = productObject.getTableEntitySet(new Filter("parent_id", applyId));
		String productRemark = createProductRemark(buName, productSet);
		
		for (Entity entity :entitySet) {
			String id = entity.getId();
			
			//5.1 申请生效后，将产品拷贝到授权中
			namedSQL.setParam("new_id", ID.newValue()).setParam("authorize_id", id);
			namedSQL.execute();
			
			//5.2 申请生效后，明细授权生效
			EntitySaver saver = dataObject.createEntitySaver(entity);
			saver.set("state_code", "Open");
			saver.set("state_name", "已生效");
			saver.set("is_active", "T");
			saver.set("account_id", accountId);
			saver.set("org_id", masterEntity.getString("org_id"));
			saver.set("org_code", masterEntity.getString("org_code"));
			saver.set("org_name", masterEntity.getString("org_name"));
			saver.set("category_code", masterEntity.getString("category_code"));
			saver.set("category_name", masterEntity.getString("category_name"));
			saver.set("term_code", masterEntity.getString("term_code"));
			saver.set("term_name", masterEntity.getString("term_name"));
			saver.set("content", masterEntity.getString("content"));
			saver.set("company_id", masterEntity.getString("company_id"));
			saver.set("company_name", masterEntity.getString("company_name"));
			saver.set("bu_id", masterEntity.getString("bu_id"));
			saver.set("bu_name", masterEntity.getString("bu_name"));
			saver.set("account_id", masterEntity.getString("account_id"));
			saver.set("connected_org_id", masterEntity.getString("connected_org_id"));
			saver.set("connected_org_code", masterEntity.getString("connected_org_code"));
			saver.set("connected_org_name", masterEntity.getString("connected_org_name"));
			saver.set("date_from", masterEntity.getValue("date_from"));
			saver.set("date_to", masterEntity.getValue("date_to"));
			
			String dateTo = masterEntity.getString("date_to");
			if (!Util.isEmpty(dateTo)) {
				String implantDeatline = DateTimeUtil.addMonths(dateTo, 1);
				saver.set("implant_deadline", Util.StringToDate(implantDeatline));
			}
			
			saver.set("product_remark", productRemark);
			
			saver.update();

			//5.3 生成授权书
			DataPackage authorizePackage = DataPackage.getInstance("md_org_account_hospital");
			authorizePackage.setMasterId(entity.getId());
			authorizePackage.loadOneDataFromDB();
			
			PackageStringMap dataMap = authorizePackage.toStringMap();
			dataMap.addAlias("md_org_account_hospital", "authorize");
			dataMap.addAlias("md_org_account_hospital_product", "products");
			dataMap.setNullResult("***");
			
			File target = FileInjector.createOneFile(user, template.getPath(), FileTypes.PDF, dataMap);
			
			FileMeta fileMeta = new FileMeta(target.getName(), target);
			fileMeta.setSize(target.length());

			//5.4 回写到协议中
			FileField fileField = new FileField("file_authorization", "file_name_authorization");
			FileRecord fileRecord = FileCenter.saveFileToRepository(user, fileMeta, dataObject.getDataName(), id, fileField);
			
			saver = dataObject.createEntitySaver(id);
			saver.set("id", id);
			saver.set("file_authorization", fileRecord.getIndexId());
			saver.set("file_name_authorization", fileRecord.getFileName());
			saver.update();
		}

		//6. 返回结果
		int size = entitySet.size();
		dataWriter.reportOneMessage("createAuthorization", ("共生成" + size + "授权书"));
	}

	public void terminateAuthorization() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		if (dataPackage == null) {
			logger.error("terminate authorization error: data not exists");
			return;
		}
		
		OnlineUser user = OnlineUser.getInstance();
		Entity masterEntity = dataPackage.getMasterEntity();
		String applyId = dataPackage.getMasterId();	
		String companyId = masterEntity.getString("company_id");
		String buId = masterEntity.getString("bu_id");
		String categoryCode = masterEntity.getString("category_code");
		String termCode = masterEntity.getString("term_code");
		
		// 1. 判断是否为终止授权
		if (!TermCode_Terminate.equalsIgnoreCase(termCode)) {
			logger.error("apply is not terminate authorization, skip terminateAuthorization.");
			return;
		}
		
		// 2. 计算植入截止日期
		String suspendDate = masterEntity.getString("suspend_date");
		if (Util.isEmpty(suspendDate)) {
			logger.error("terminate authorization error: suspend_date is not fill");
			return;
		}
		String implantDeadline = DateTimeUtil.addMonths(suspendDate, 3);
		
		//3. 获取终止授权申请下的所有授权书
		AuthorizeTemplate template = AuthorizeTemplate.getInstance(companyId, buId, categoryCode, termCode);
		
		if (template == null) {
			logger.error("authorize template file not exists, skep");
			dataWriter.reportOneError("createAuthorization", "授权书模板不存在，过程终止");
			task.terminate();
			return;
		}
		
		DataObject dataObject = DataObject.getInstance("md_org_account_hospital");
		Filter filter = new Filter("apply_id", applyId);
		EntitySet entitySet = dataObject.getTableEntitySet(filter);
		EntitySaver saver = dataObject.createEntitySaver();
		
		for (Entity entity : entitySet){
			//4. 更新原授权
			String id = entity.getId();
			String oldAuthorizationId = entity.getString("old_id");
			saver = dataObject.createEntitySaver(oldAuthorizationId);
			
			saver.set("id", oldAuthorizationId);
			saver.set("state_code", "Closed");
			saver.set("state_name", "已终止");
			saver.set("suspend_date", suspendDate);
			saver.set("implant_deadline", implantDeadline);
			saver.update();
			
			//3. 生成终止授权书
			PackageStringMap dataMap = dataPackage.toStringMap();
			dataMap.addAlias("md_org_account_hospital", "authorize");
			dataMap.addAlias("md_org_account_hospital_product", "products");
			dataMap.addReplace("_", "-");
			dataMap.setNullResult("***");
			
			File target = FileInjector.createOneFile(user, template.getTemplateName(), FileTypes.PDF, dataMap);
			FileMeta fileMeta = new FileMeta(target.getName(), target);
			fileMeta.setSize(target.length());
			FileField fileField = new FileField("file_authorization", "file_name_authorization");
			FileRecord fileRecord = FileCenter.saveFileToRepository(user, fileMeta, dataObject.getDataName(), id, fileField);
			
			//4. 回写授权
			saver = dataObject.createEntitySaver(id);
			saver.set("id", id);
			saver.set("file_authorization", fileRecord.getIndexId());
			saver.set("file_name_authorization", fileRecord.getFileName());
			saver.set("suspend_date", suspendDate);
			saver.set("implant_deadline", implantDeadline);
			saver.update();
		}

		//5. 返回结果
		dataWriter.reportOneMessage("terminateAuthorization", "终止授权成功，植入上报截止时间为：" + implantDeadline);
	}
	
	private String createProductRemark(String buName, EntitySet productSet) {
		if (productSet.isEmpty()) {
			return buName;
		}
		
		Entity entity = productSet.getEntity(0);
		String result = entity.getString("product_name");
		
		int size = productSet.size();
		if (size > 1) {
			result = result + "(" + size + "个产品)";
		}
		
		return result;
	}

	public synchronized void refreshChannelStructure() throws Exception {
		NamedSQL namedSQL;
		
		//1. 获取上次更新时间
		namedSQL = NamedSQL.getInstance("getChannelStructureLastTime");
		Date date = SQLRunner.getDate(namedSQL);
		
		if (date == null) {
			date = new Date(0);
		}
		
		//2. 增加新的渠道关系
		int cnt_add = 0, cnt_delete = 0;
		
		namedSQL = NamedSQL.getInstance("createChannelStructure_dealerOnly");
		namedSQL.setParam("updateTime", date);
		cnt_add = cnt_add + namedSQL.execute();
		
		namedSQL = NamedSQL.getInstance("createChannelStructure_dealerDistributor");
		namedSQL.setParam("updateTime", date);
		cnt_add = cnt_add + namedSQL.execute();
		
		namedSQL = NamedSQL.getInstance("createChannelStructure_distributor");
		namedSQL.setParam("updateTime", date);
		cnt_add = cnt_add + namedSQL.execute();
		
		//3. 关闭取消的渠道关系
		namedSQL = NamedSQL.getInstance("closeChannelStructure");
		namedSQL.setParam("updateTime", date);
		cnt_delete = cnt_delete + namedSQL.execute();
		
		//4. 写入日志
		DataObject dataObject = DataObject.getInstance("md_channel_structure_log");
		EntitySaver saver = dataObject.createEntitySaver();
		saver.set("id", ID.newValue());
		saver.set("run_time", new Date());
		saver.set("cnt_add", cnt_add);
		saver.set("cnt_delete", cnt_delete);
		saver.insert();
	}
	
	public void customerCount() throws Exception {
		OnlineUser user = OnlineUser.getInstance();
		DataObject dataObject;
		Filter filter =  new Filter();
		int customerCount;
		
		//1. 直采客商
		dataObject = DataObject.getInstance(TABLE_ACCOUNT);
		filter = dataObject.loadUserLineFilter(user);
		filter.add("state_code", "open");
		filter.add("actor_code", "First");
		customerCount = dataObject.getCount(filter);
		dataWriter.addValue("first", customerCount);

		//2. 平台商
		filter.removeItemByName("actor_code");
		filter.add("actor_code", "Platform");
		customerCount = dataObject.getCount(filter);
		dataWriter.addValue("platform", customerCount);

		//3. 非直采
		filter.removeItemByName("actor_code");
		filter.add("actor_code", "Second");
		customerCount = dataObject.getCount(filter);
		dataWriter.addValue("second", customerCount);
		
		//4. 配送商
		dataObject = DataObject.getInstance("md_channel_structure");
		filter = dataObject.loadUserLineFilter(user);
		filter.add("category_code", "Distributor");
		
		NamedSQL namedSQL = NamedSQL.getInstance("getPositionDistributor");		
		namedSQL.setFilter(filter);
		Entity entity = namedSQL.getEntity(); 
		customerCount = entity.getInt("customerCount");
		dataWriter.addValue("distribute", customerCount);
		
		//5. 医院
		dataObject = DataObject.getInstance("md_position_hospital");
		filter = dataObject.loadUserLineFilter(user);
		customerCount = dataObject.getCount(filter);
		dataWriter.addValue("hospital", customerCount);
	
	}
	
	public void addPosition() throws Exception{
		String dataName = dataReader.getString("dataname");
		DataPackage dataPackage = dataReader.getDataPackage();
		dataPackage.loadDataFromRequest(dataName);
		Entity positionEntity = dataPackage.getMasterEntity(DataSource.Request);
		
		String buId = positionEntity.getString("bu_id");
		String companyId = positionEntity.getString("company_id");
		PositionCategory category = PositionCategory.parse(positionEntity.getString("category_code"));
		String dynamic = null;
		DataObject dataObject = DataObject.getInstance("md_bu_org");
		Filter filter = new Filter();
		
		if(PositionCategory.Sales == category) {
			String[] segment = buId.split("-");
			if(segment.length >= 1) {
				dynamic = segment[1];
			}
			filter.add("bu_id", buId);
			filter.add("company_id", companyId);
		}
		else {
			dynamic = "BS-O";
		}

		EntitySet buOrgRelation = dataObject.getTableEntitySet(filter);
		
		SQLRunner.beginTrans();
		try {
			 //1. 添加岗位
			dataObject = DataObject.getInstance(dataName);
			String positionId = positionEntity.getId(), actorTargetId = null;
			if (Util.isEmpty(positionEntity.getId())) {
				positionId = ID.newValue();
				actorTargetId = ID.newValue();
			}
			
			//2. 生成编码
			String code = CodeEngine.nextval("Code-Position", dynamic);
			positionEntity.setId(positionId);
			positionEntity.set("code", code);
			positionEntity.set("category_code", category);
			positionEntity.set("is_delete", "F");
			
			dataObject.saveEntity(positionEntity);

			//3. 获取公司BU关系，为岗位配置角色
			for (Entity entity: buOrgRelation) {
				String targetBuId = entity.getString("bu_id");
				String targetCompanyId = entity.getString("company_id");
				
				dataObject = DataObject.getInstance("sys_right_actor_target");
				Filter targetFilter = new Filter("target_id", positionId)
						.add("bu_id",targetBuId)
						.add("company_id", targetCompanyId);
				Entity actorTargetExistsEntity = dataObject.getTableEntity(targetFilter);
				
				
				if(actorTargetExistsEntity != null ) {
					actorTargetId = actorTargetExistsEntity.getId();
				}
				else {
					actorTargetId = ID.newValue();
				}
				
				Entity actorTargetEntity = dataPackage.getItemEntity("sys_right_actor_target",DataSource.Request);
				
				actorTargetEntity.set("id", actorTargetId);
				actorTargetEntity.set("bu_id", targetBuId);
				actorTargetEntity.set("type_code", ActorType.Position);
				actorTargetEntity.set("company_id", targetCompanyId);
				actorTargetEntity.set("target_id", positionId);
				actorTargetEntity.set("remark", positionEntity.getString("remark"));
				
				dataObject.saveEntity(actorTargetEntity);
			}
			
			SQLRunner.commit();
		} 
		catch(Exception e) {
			 e.printStackTrace();
			 try {
				 SQLRunner.rollback();
			} catch (SQLException e1) {
				 e1.printStackTrace();
			}
		}
	}
	
	public void deletePosition() throws Exception{
		String dataName = dataReader.getString("dataname");
		String id = dataReader.getString("id");
		SQLRunner.beginTrans();
		try {
			 //1. 删除岗位
			DataObject dataObject = DataObject.getInstance(dataName);
			EntitySaver saver = dataObject.createEntitySaver(id);
			saver.set("is_delete", "T");
			saver.update();
			
			//2. 删除岗位数据权限
			dataObject = DataObject.getInstance("sys_right_actor_target");
			dataObject.deleteEntity(new Filter("target_id", id));
			
			SQLRunner.commit();
		} 
		catch(Exception e) {
			 e.printStackTrace();
			 try {
				 SQLRunner.rollback();
			} catch (SQLException e1) {
				 e1.printStackTrace();
			}
		}
	}

	public void closeAccount() throws Exception{
		DataObject closeDataObject =  DataObject.getInstance(TABLE_CLOSEACCOUNT);
		DataObject accountDataObject =  DataObject.getInstance(TABLE_ACCOUNT);
		DataObject ncOrgDataObject =  DataObject.getInstance(TABLE_NCACCOUNT);
		DataObject actorTargetDataObject =  DataObject.getInstance("sys_right_actor_target");
		
		Filter  filter = new Filter();
		filter.add("state_code", "waitClose");
		
		if (dataReader != null) {
			String id = dataReader.getString("id");
			filter.add("id", id);
		}
		
		EntitySet entitySet = closeDataObject.getTableEntitySet(filter);
		
		for (Entity entity : entitySet) {
			Date terminationDate = entity.getDate("termination_date");
			String terminationDateStr = Util.DataTimeToString(terminationDate, Util.NORMALFORMAT);
			
			if (Util.newDateStr().compareToIgnoreCase(terminationDateStr) < 0) {
				continue;
			}
			
			//1. 更新关户申请状态
			entity.set("state_code", "Close");
			entity.set("state_name", "已关户");
			closeDataObject.updateEntity(entity);
			
			//2. 更新开户状态
			String accountId = entity.getString("host_id");
			Entity accountEntity = accountDataObject.getTableEntity(accountId);
			accountEntity.set("state_code", "Close");
			accountEntity.set("state_name", "已关户");
			accountDataObject.updateEntity(accountEntity);
			
			//3. 更新客商主数据状态
			String ncOrgId = accountEntity.getString("org_ncc_id");
			Entity ncAccountEntity = ncOrgDataObject.getTableEntity(ncOrgId);
			ncAccountEntity.set("state_code", "notExistsAccount");
			ncAccountEntity.set("state_name", "DMS未开户");
			ncOrgDataObject.updateEntity(ncAccountEntity);
			
			//4. 删除数据权限
			actorTargetDataObject.deleteEntity(new Filter("target_id", accountId));
		}
	}

}