package com.qxueyou.scc.exercise.service.impl;


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.qxueyou.scc.base.dao.CommonDAO;
import com.qxueyou.scc.base.service.IONSExceptionLogService;

@Service("ExerciseSysMsgDealService")
public class ExerciseSysMsgDealService {

	@Autowired
	CommonDAO dao;
/*
	@Autowired
	IMsgVenderService  easemobService;*/
	
	@Autowired
	IONSExceptionLogService onsExceptionLogService;
	
	/*@Autowired
	protected IConfigService cfg;*/
	
	//private static Logger log = LogManager.getLogger("ONSExceptionLogService");
	
//	@PostConstruct
//	void init() {
//		CommonONSConsumer.registerHandler("SYS_EXER_SAVE", "ExerciseSysMsgDealService");
//	}
//
//	@Override
//	public void doHandle(Message msg, ConsumeContext context) {
		
		/*try {

//			String groupId = msg.getUserProperties("groupId");
//			String classId = msg.getUserProperties("classId");
//			String actionType = msg.getUserProperties("actionType");
			// 练习不再发系统通知 by cyq 20160823
			//sendSysNotice(groupId, classId, actionType);

		} catch (Exception e) {

			String businessId = cfg.getConfigByEnv("ons-common-topic") + "-" + UUIDUtils.generateUUID();
			String desp = "classId:" + msg.getUserProperties("classId") +
					";groupId:" + msg.getUserProperties("groupId") + 
					";actionType:" + msg.getUserProperties("actionType") ;

			log.error( businessId + " :更新练习系统消息发送失败:" + e , e);
			onsExceptionLogService.doSaveExceptionLog(cfg.getConfigByEnv("ons-common-topic"), "SYS_EXER_SAVE", businessId , desp );

		}*/
	}
	
	/**
	 * 发送消息
	 * @param groupId
	 * @param classId
	 * @param actionType
	 *//*
	private void sendSysNotice(String groupId, String classId, String actionType) {
		ExerciseGroup group = dao.read(ExerciseGroup.class, groupId);
		String hql = "from UserRegistration u where u.classId = ? and deleteFlag is false";
		
		List<UserRegistration> userList = dao.find(hql, CollectionUtils.newList(classId), UserRegistration.class);
		List<String> userIdList = new ArrayList<>();
		for (UserRegistration ur : userList) {
			userIdList.add(ur.getUserId());
		}
		OrgClass cls = dao.read(OrgClass.class, classId);
		String content = null;
			
		Map<String,String> extra = new HashMap<String,String>();
		extra.put("classId", classId);
		extra.put("className", cls.getName());
		if ("new".equalsIgnoreCase(actionType)) {
			extra.put("title", "有新的习题啦");
			content = cls.getName() + "班有新的习题哦，赶快去瞄瞄吧！";
		} else if ("update".equalsIgnoreCase(actionType)) {
			extra.put("title", "习题有更新啦");
			content = cls.getName() + "班习题有更新哦，赶快去瞄瞄吧！";
		}
		// add cyq 
		JSONObject androidParam = new JSONObject();
		JSONObject iOSParam = new JSONObject();
		if (group.getType() == ExerciseGroup.TYPE_HOMEWORK) {
			
			extra.put("type", SysNoticeConfigMetadata.TYPE_EXERCISE_HOMEWORK);
			androidParam.put("key_exercise_type_name", "家庭作业");
			androidParam.put("key_exercise_list_url", "http://www.qxueyou.com/qxueyou/exercise/Exercise/homeWorkListNew");
			androidParam.put("key_exercise_type", "1");
			iOSParam.put("Titlename", "家庭作业");
			
		} else if (group.getType() == ExerciseGroup.TYPE_MOCK_EXAM) {
			
			extra.put("type", SysNoticeConfigMetadata.TYPE_EXERCISE_ANALOGY);
			androidParam.put("key_exercise_type_name", "模拟考试");
			androidParam.put("key_exercise_list_url", "http://www.qxueyou.com/qxueyou/exercise/Exercise/examsListNew");
			androidParam.put("key_exercise_type", "4");
			iOSParam.put("Titlename", "模拟考试");
			
		} else if (group.getType() == ExerciseGroup.TYPE_CHAPTER_ITEM) {
			
			extra.put("type", SysNoticeConfigMetadata.TYPE_EXERCISE_CHAPTER);
			androidParam.put("key_exercise_type_name", "章节练习");
			androidParam.put("key_exercise_list_url", "http://www.qxueyou.com/qxueyou/exercise/Exercise/chapterListNew");
			androidParam.put("key_exercise_type", "6");
			iOSParam.put("Titlename", "章节练习");
			
		} else if (group.getType() == ExerciseGroup.TYPE_EXERCISE_TOPIC) {
			
			extra.put("type", SysNoticeConfigMetadata.TYPE_EXERCISE_CHAPTER);
			androidParam.put("key_exercise_type_name", "专项练习");
			androidParam.put("key_exercise_list_url", "http://www.qxueyou.com/qxueyou/exercise/Exercise/topicListNew");
			androidParam.put("key_exercise_type", "9");
			iOSParam.put("Titlename", "专项练习");
			
		} else if (group.getType() == ExerciseGroup.TYPE_EXERCISE_FREE) {
			
			extra.put("type", SysNoticeConfigMetadata.TYPE_EXERCISE_FREEDOM);
			androidParam.put("key_exercise_type_name", "自由练习");
			androidParam.put("key_exercise_list_url", "http://www.qxueyou.com/qxueyou/exercise/Exercise/freeListNew");
			androidParam.put("key_exercise_type", "10");
			iOSParam.put("Titlename", "自由练习");
			
		}
		
		extra.put("androidParams", androidParam.toString());
		extra.put("iosParams", iOSParam.toString());
		if (StringUtils.isNotEmpty(content)) {
			// 对消息接收人按每批最多20人分批发送
			String[] receivers;
			int loop = (userIdList.size() + 19) / 20;
			for (int i = 0; i < loop; i ++) {
				int len = (i == (loop - 1)) ? userIdList.size() - 20 * i : 20;
				receivers = new String[len];
				userIdList.subList(i * 20,  i * 20 + len).toArray(receivers);
				easemobService.doSendTextMsgToUsers("notice-sys", receivers, content, extra);
			}
		}
	}*/
//}