ImInterfaceController.java

package com.fh.controller.fhim;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;

import org.apache.shiro.session.Session;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.servlet.ModelAndView;

import com.fh.controller.base.BaseController;
import com.fh.util.AppUtil;
import com.fh.util.Const;
import com.fh.util.DateUtil;
import com.fh.util.FileUpload;
import com.fh.util.PageData;
import com.fh.util.Jurisdiction;
import com.fh.util.PathUtil;
import com.fh.util.Tools;
import com.fh.plugin.websocketInstantMsg.ChatServerPool;
import com.fh.service.fhim.fgroup.FgroupManager;
import com.fh.service.fhim.friends.FriendsManager;
import com.fh.service.fhim.hismsg.HismsgManager;
import com.fh.service.fhim.imstate.ImstateManager;
import com.fh.service.fhim.iqgroup.IQgroupManager;
import com.fh.service.fhim.qgroup.QgroupManager;
import com.fh.service.fhim.sysmsg.SysmsgManager;
import com.fh.service.system.user.UserManager;
import com.fh.service.system.userphoto.UserPhotoManager;

/** 
 * 说明：聊天即使通讯接口
 * 创建人：FH Q313596790
 * 修改时间：2018-08-2
 */
@Controller
@RequestMapping(value="/iminterface")
public class ImInterfaceController extends BaseController {
	
	@Resource(name="friendsService")
	private FriendsManager friendsService;
	@Resource(name="userService")
	private UserManager userService;
	@Resource(name="userphotoService")
	private UserPhotoManager userphotoService;
	@Resource(name="imstateService")
	private ImstateManager imstateService;
	@Resource(name="fgroupService")
	private FgroupManager fgroupService;
	@Resource(name="qgroupService")
	private QgroupManager qgroupService;
	@Resource(name="iqgroupService")
	private IQgroupManager iqgroupService;
	@Resource(name="sysmsgService")
	private SysmsgManager sysmsgService;
	@Resource(name="hismsgService")
	private HismsgManager hismsgService;
	
	 /**获取好友(群组)列表(聊天接口请求)
	 * @param
	 * @throws Exception
	 */
	@RequestMapping(value="/getList")
	@ResponseBody
	public Object getList() throws Exception{
		logBefore(logger, Jurisdiction.getUsername()+"获取好友列表(聊天接口请求)");
		PageData pd = new PageData();
		
		Map<String,Object> zmap = new LinkedHashMap<String,Object>();
		Map<String,Object> nmap = new LinkedHashMap<String,Object>();
		pd = this.getPageData();
		pd.put(Const.SESSION_USERNAME, Jurisdiction.getUsername());		//用户名
		
		Session session = Jurisdiction.getSession();
		PageData pds = new PageData();
		pds = (PageData)session.getAttribute(Const.SESSION_userpds);
		if(null == pds){
			pds = userService.findByUsername(pd);						//获取当前用户的基本信息
			session.setAttribute(Const.SESSION_userpds, pds);
		}
		PageData pdPhoto = userphotoService.findById(pds);
		PageData stapd = new PageData();
		stapd = imstateService.findByUsername(pd);
		
		Map<String,Object> nowmap = new LinkedHashMap<String,Object>();
		nowmap.put("username", pds.getString("NAME"));			//当前用户姓名
		nowmap.put("id", Jurisdiction.getUsername());			//当前用户名
		nowmap.put("status", null == stapd ?"online":stapd.getString("ONLINE"));		//在线状态
		nowmap.put("sign", null == stapd ?"个性签名":stapd.getString("AUTOGRAPH"));		//个性签名
		nowmap.put("avatar", null == pdPhoto?"static/ace/avatars/user.jpg":pdPhoto.getString("PHOTO2"));//当前用户头像
		
		nmap.put("mine", nowmap);
		
		List<PageData> fList = friendsService.listAll(pd);				//全部好友
		List<PageData> isGList = new ArrayList<PageData>();				//有分组的好友
		List<PageData> noGList = new ArrayList<PageData>();				//未分组的好友
		for(int i=0;i<fList.size();i++){
			if(null == fList.get(i).get("GNAME") || "".equals(fList.get(i).getString("GNAME").trim())){
				noGList.add(fList.get(i));
			}else{
				isGList.add(fList.get(i));
			}
		}
		List<PageData> groupList = fgroupService.listAll(pd);			//当然用户的全部好友分组
		List<Object> gmapList = new ArrayList<Object>();				//存放每个分组以及分组里面的好友
		for(int i=0;i<groupList.size();i++){
			Map<String,Object> gmap = new LinkedHashMap<String,Object>();
			gmap.put("groupname", groupList.get(i).getString("NAME"));
			gmap.put("id", groupList.get(i).getString("FGROUP_ID"));
			gmap.put("online", i+1);
			List<Object> gfList = new ArrayList<Object>();
			List<Object> gfListon = new ArrayList<Object>();			//存放在线的
			List<Object> gfListoff = new ArrayList<Object>();			//存放离线的
			for(int n=0;n<isGList.size();n++){
				if(groupList.get(i).getString("FGROUP_ID").equals(isGList.get(n).getString("FGROUP_ID"))){
					Map<String,Object> fpd = new LinkedHashMap<String,Object>();
					fpd.put("username", isGList.get(n).getString("NAME"));			//姓名
					fpd.put("id", isGList.get(n).getString("FUSERNAME"));			//用户名
					fpd.put("avatar", null==isGList.get(n).get("PHOTO2")?"static/ace/avatars/user.jpg":isGList.get(n).getString("PHOTO2"));			//头像
					fpd.put("sign", null==isGList.get(n).get("AUTOGRAPH")?"":isGList.get(n).getString("AUTOGRAPH"));								//个性签名
					if(null != isGList.get(n).get("ONLINE") && "hide".equals(isGList.get(n).getString("ONLINE"))){//好友在线状态设置为离线的(不管是否真实在线,都判定离线)
						fpd.put("status", "offline");								//离线状态
						gfListoff.add(fpd);
					}else{															//如果设置的状态为在线，再去判断真实是否在线
						Collection<String> user = ChatServerPool.getOnlineUser();	//所有在线用户
						if(!user.contains(isGList.get(n).getString("FUSERNAME"))){
							fpd.put("status", "offline");							//离线状态
							gfListoff.add(fpd);
						}else{														//其它情况都是在线状态，在线状态就不用加status了
							gfListon.add(fpd);
						}
					}
				}
			}
			gfList.addAll(gfListon);	//在线的放上面
			gfList.addAll(gfListoff);	//离线的放下面
			gmap.put("list", gfList);
			gmapList.add(gmap);
		}
		
		Map<String,Object> nogmap = new LinkedHashMap<String,Object>(); //存放无分组的好友(无分组就是默认分组)
		nogmap.put("groupname", "未分组");
		nogmap.put("id", "9999");
		nogmap.put("online", 999);
		List<Object> nogfList = new ArrayList<Object>();
		List<Object> nogfListon = new ArrayList<Object>();				//存放在线的
		List<Object> nogfListoff = new ArrayList<Object>();				//存放离线线的
		for(int n=0;n<noGList.size();n++){
			Map<String,Object> nfpd = new LinkedHashMap<String,Object>();
			nfpd.put("username", noGList.get(n).getString("NAME"));		//姓名
			nfpd.put("id", noGList.get(n).getString("FUSERNAME"));		//用户名
			nfpd.put("avatar", null==noGList.get(n).get("PHOTO2")?"static/ace/avatars/user.jpg":noGList.get(n).getString("PHOTO2"));		//头像
			nfpd.put("sign", null==noGList.get(n).get("AUTOGRAPH")?"":noGList.get(n).getString("AUTOGRAPH"));								//个性签名
			if(null != noGList.get(n).get("ONLINE") && "hide".equals(noGList.get(n).getString("ONLINE"))){//好友在线状态设置为离线的(不管是否真实在线,都判定离线)
				nfpd.put("status", "offline");								//离线状态
				nogfListoff.add(nfpd);
			}else{															//如果设置的状态为在线，再去判断真实是否在线
				Collection<String> user = ChatServerPool.getOnlineUser();	//所有在线用户
				if(!user.contains(noGList.get(n).getString("FUSERNAME"))){
					nfpd.put("status", "offline");							//离线状态
					nogfListoff.add(nfpd);
				}else{														//其它情况都是在线状态，在线状态就不用加status了
					nogfListon.add(nfpd);
				}
			}
		}
		nogfList.addAll(nogfListon);	//在线的放上面
		nogfList.addAll(nogfListoff);	//离线的放下面
		if(noGList.size() > 0){
			nogmap.put("list", nogfList);
			gmapList.add(nogmap);
		}
		
		nmap.put("friend", gmapList); //好友分组及好友数据
		
		List<Object> qfList = new ArrayList<Object>();
		List<PageData> myqList = getMyAllQgroup(pd);					//我在的全部群列表
		for(int i=0;i<myqList.size();i++){
			Map<String,Object> qmap = new LinkedHashMap<String,Object>();
			qmap.put("groupname", myqList.get(i).getString("NAME"));	//群名称
			qmap.put("id", myqList.get(i).getString("QGROUP_ID"));		//群ID
			qmap.put("avatar", myqList.get(i).getString("PHOTO"));		//群头像
			qfList.add(qmap);
		}
		nmap.put("group", qfList); //群组数据
		
		zmap.put("code", 0);
		zmap.put("msg", "");
		zmap.put("data", nmap);
		
		return AppUtil.returnObject(pd, zmap);
	}
	
	
	/**我在的全部群列表
	 * @param pd
	 * @return
	 * @throws Exception
	 */
	public List<PageData> getMyAllQgroup(PageData pd) throws Exception{
		pd.put("USERNAME", Jurisdiction.getUsername());		//当前用户
		PageData ipd = new PageData();
		ipd = iqgroupService.findById(pd);
		if(null == ipd){									//当我没有任何群时添加数据，否则修改
			pd.put("item", "('null')");
		}else{
			pd.put("item", ipd.getString("QGROUPS")+"'fh')");
		}
		return qgroupService.mylistAll(pd);					//列出Qgroup列表
		
	}
	
	/**获取群成员接口
	 * @return
	 */
	@RequestMapping(value="/getMembers")
	@ResponseBody
	public Object getMembers(){
		logBefore(logger, Jurisdiction.getUsername()+"获取群成员");
		Map<String,Object> map = new LinkedHashMap<String,Object>();
		Map<String,Object> dmap = new LinkedHashMap<String,Object>();
		PageData pd = new PageData();
		pd = this.getPageData();
		pd.put("QGROUP_ID", pd.getString("id"));						//群组的id
		try {
			List<Object> qlist = new ArrayList<Object>();				//存放群成员
			List<PageData> varList = iqgroupService.listAll(pd); 		//全部群成员
			int n = 0;
			for(int i=0;i<varList.size();i++){
				Map<String,Object> umap = new LinkedHashMap<String,Object>();
				umap.put("username", varList.get(i).getString("NAME"));	//姓名
				umap.put("id", varList.get(i).getString("USERNAME"));	//用户名即id
				umap.put("avatar", null == varList.get(i).get("PHOTO2")?"static/ace/avatars/user.jpg":varList.get(i).getString("PHOTO2"));	//头像 
				umap.put("sign", varList.get(i).getString("AUTOGRAPH"));//个性签名
				qlist.add(umap);
				n++;
			}
			dmap.put("members", n);
			dmap.put("list", qlist);
			map.put("code", 0);
			map.put("msg", "");
			map.put("data", dmap);
		} catch (Exception e) {
			e.printStackTrace();
		}	
		return AppUtil.returnObject(pd, map);
	}
	
	/**聊天上传图片接口
	 * @param file
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/updateImg")
	@ResponseBody
	public Object updateImg(@RequestParam(required=false) MultipartFile file) throws Exception{
		logBefore(logger, Jurisdiction.getUsername()+"聊天上传图片");
		Map<String,Object> zmap = new LinkedHashMap<String,Object>();
		Map<String,Object> nmap = new LinkedHashMap<String,Object>();
		String  ffile = DateUtil.getDays(), fileName = "";
		PageData pd = new PageData();
		if (null != file && !file.isEmpty()) {
			String filePath = PathUtil.getClasspath() + Const.FILEPATHIMG + ffile;		//文件上传路径
			fileName = FileUpload.fileUp(file, filePath, this.get32UUID());				//执行上传
			nmap.put("src", Const.FILEPATHIMG + ffile + "/" + fileName);
			zmap.put("code", 0); 			//0表示成功，其它表示失败
			zmap.put("msg", "");			//失败信息
			zmap.put("data", nmap);
		}else{
			nmap.put("src", "");
			zmap.put("code", 1); 			//0表示成功，其它表示失败
			zmap.put("msg", "上传失败");		//失败信息
			zmap.put("data", nmap);
		}
		return AppUtil.returnObject(pd, zmap);
	}
	
	/**聊天上传文件接口
	 * @param file
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/updateFile")
	@ResponseBody
	public Object updateFile(@RequestParam(required=false) MultipartFile file) throws Exception{
		logBefore(logger, Jurisdiction.getUsername()+"聊天上传文件");
		Map<String,Object> zmap = new LinkedHashMap<String,Object>();
		Map<String,Object> nmap = new LinkedHashMap<String,Object>();
		String  ffile = DateUtil.getDays(), fileName = "";
		PageData pd = new PageData();
		if (null != file && !file.isEmpty()) {
			String filePath = PathUtil.getClasspath() + Const.FILEPATHIMG + ffile;		//文件上传路径
			fileName = FileUpload.fileUp(file, filePath, this.get32UUID());				//执行上传
			nmap.put("src", Const.FILEPATHIMG + ffile + "/" + fileName);
			nmap.put("name", fileName);
			zmap.put("code", 0); 			//0表示成功，其它表示失败
			zmap.put("msg", "");			//失败信息
			zmap.put("data", nmap);
		}else{
			nmap.put("src", "");
			nmap.put("name", "");
			zmap.put("code", 1); 			//0表示成功，其它表示失败
			zmap.put("msg", "上传失败");		//失败信息
			zmap.put("data", nmap);
		}
		return AppUtil.returnObject(pd, zmap);
	}
	
	/**修改状态(在线隐身、个性签名、皮肤)接口
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/editState")
	@ResponseBody
	public Object editState() throws Exception{
		Map<String,Object> map = new LinkedHashMap<String,Object>();
		PageData pd = new PageData();
		pd = this.getPageData();
		pd.put(Const.SESSION_USERNAME, Jurisdiction.getUsername());		//当前用户名
		if(null != imstateService.findByUsername(pd)){					//判断数据库有没有此用的数据，有则修改，无则新增
			String TYPE = pd.getString("TYPE");
			if("online".equals(TYPE)){
				imstateService.editOnline(pd);	//修改在线状态
			}else if("auto".equals(TYPE)){
				imstateService.editAuto(pd);	//修改个性签名
			}else{
				imstateService.editSign(pd);	//修改皮肤
			}
		}else{
			pd.put("IMSTATE_ID", this.get32UUID());																	//主键
			pd.put("ONLINE", null!=pd.get("ONLINE")&&"hide".equals(pd.getString("ONLINE"))?"hide":"online");		//在线or隐身
			pd.put("AUTOGRAPH", null!=pd.get("AUTOGRAPH")?pd.getString("AUTOGRAPH"):"I LOVE FH Admin");				//个性签名
			pd.put("SIGN", null!=pd.get("SIGN")?pd.getString("SIGN"):"5.jpg");										//皮肤
			imstateService.save(pd);
		}
		return AppUtil.returnObject(pd, map);
	}
	
	/**获取皮肤接口
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/getImsign")
	@ResponseBody
	public Object getImsign() throws Exception{
		Map<String,Object> map = new LinkedHashMap<String,Object>();
		PageData pd = new PageData();
		pd.put(Const.SESSION_USERNAME, Jurisdiction.getUsername());		//当前用户名
		pd = imstateService.findByUsername(pd);
		if(null != pd){					
			map.put("imsign", pd.getString("SIGN"));
		}else{
			map.put("imsign", "5.jpg");
		}
		return AppUtil.returnObject(new PageData(), map);
	}
	
	/**添加好友接口
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/addFriends")
	@ResponseBody
	public Object addFriends() throws Exception{
		Map<String,Object> map = new LinkedHashMap<String,Object>();
		String result = "";
		PageData pd = new PageData();
		pd = this.getPageData();
		pd.put("USERNAME", Jurisdiction.getUsername());		//用户名
		if(null != friendsService.findMyFriend(pd)){		//判断是否已经是好友了
			result = "00";
		}else{
			pd.put("FRIENDS_ID", this.get32UUID());			//主键
			pd.put("CTIME", Tools.date2Str(new Date()));	//申请时间
			pd.put("ALLOW", "will");						//是否允许
			pd.put("FGROUP_ID", "9999".equals(pd.getString("FGROUP_ID"))?"":pd.getString("FGROUP_ID"));	//分组, 9999 代表无分组
			pd.put("DTIME", "");							//处理时间，刚添加等待对方处理，现在为空，处理的时候录入时间
			friendsService.save(pd);
			/*存入IM系统消息表中IM_SYSMSG*/
			pd.put("SYSMSG_ID", this.get32UUID());				//主键
			pd.put("USERNAME", pd.getString("FUSERNAME"));		//接收者用户名
			pd.put("FROMUSERNAME", Jurisdiction.getUsername());	//发送者用户名(即当前用户)
			pd.put("CTIME", Tools.date2Str(new Date()));		//操作时间
			pd.put("REMARK", pd.getString("BZ"));				//留言
			pd.put("TYPE", "friend");							//类型
			pd.put("CONTENT", "申请添加你为好友");				//事件内容
			pd.put("ISDONE", "no");								//是否完成
			pd.put("DTIME", "");								//完成时间
			pd.put("QGROUP_ID", "");							//申请加群是有值
			pd.put("DREAD", "0");								//阅读状态 0 未读
			sysmsgService.save(pd);
			result = "01";
		}
		map.put("result", result);
		return AppUtil.returnObject(new PageData(), map);
	}
	
	/**添加群接口
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/addQGroup")
	@ResponseBody
	public Object addQGroup() throws Exception{
		Map<String,Object> map = new LinkedHashMap<String,Object>();
		String result = "";
		PageData pd = new PageData();
		pd = this.getPageData();
		pd.put("USERNAME", Jurisdiction.getUsername());		//用户名
		if(null != iqgroupService.findByIdandQid(pd)){		//判断是否在此群了
			result = "00";
		}else{
			String FUSERNAME = qgroupService.findById(pd).getString("USERNAME");//通过群ID获取群主用户名
			String QNAME = qgroupService.findById(pd).getString("NAME");		//群名
			/*存入IM系统消息表中IM_SYSMSG*/
			pd.put("SYSMSG_ID", this.get32UUID());				//主键
			pd.put("USERNAME", FUSERNAME);						//接收者用户名
			pd.put("FROMUSERNAME", Jurisdiction.getUsername());	//发送者用户名(即当前用户)
			pd.put("CTIME", Tools.date2Str(new Date()));		//操作时间
			pd.put("REMARK", pd.getString("BZ"));				//留言
			pd.put("TYPE", "group");							//类型
			pd.put("CONTENT", "申请加入群:"+QNAME);				//事件内容
			pd.put("ISDONE", "no");								//是否完成
			pd.put("DTIME", "");								//完成时间
			pd.put("DREAD", "0");								//阅读状态 0 未读
			sysmsgService.save(pd);
			result = "01";
		}
		map.put("result", result);
		return AppUtil.returnObject(new PageData(), map);
	}
	
	 /**打开消息盒子页面(好友申请，群申请消息)
	 * @param
	 */
	@RequestMapping(value="/msgbox")
	public ModelAndView msgbox(){
		ModelAndView mv = this.getModelAndView();
		mv.setViewName("fhim/msgbox");
		return mv;
	}
	
	/**消息盒子数据接口
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/msgboxdata")
	@ResponseBody
	public Object msgboxdata() throws Exception{
		Map<String,Object> map = new LinkedHashMap<String,Object>();
		PageData pd = new PageData();
		List<Object> zmsglist = new ArrayList<Object>();			
		pd.put("USERNAME", Jurisdiction.getUsername());			//当前用户名
		List<PageData> msglist =  sysmsgService.listAll(pd);
		for(int i=0;i<msglist.size();i++){
			Map<String,Object> msgpd = new LinkedHashMap<String,Object>();
			msgpd.put("id", msglist.get(i).getString("SYSMSG_ID"));
			if("no".equals(msglist.get(i).getString("ISDONE"))){				//消息没办理(新消息)
				msgpd.put("content", msglist.get(i).getString("CONTENT"));		//消息内容
				msgpd.put("uid", msglist.get(i).getString("USERNAME"));			//接收者用户名
				msgpd.put("from", msglist.get(i).getString("FROMUSERNAME"));	//消息发送者
				msgpd.put("from_group", 0);
				msgpd.put("type", msglist.get(i).getString("TYPE"));
				msgpd.put("remark", msglist.get(i).getString("REMARK"));		//留言
				msgpd.put("href", null);
				msgpd.put("read", 1);
				msgpd.put("time", msglist.get(i).getString("CTIME"));			//申请时间
				msgpd.put("qgroupid", msglist.get(i).getString("QGROUP_ID"));	//申请添加群时有值
				Map<String,Object> statepd = new LinkedHashMap<String,Object>();
				statepd.put("id", msglist.get(i).getString("FROMUSERNAME"));	//用户名
				statepd.put("avatar", null == msglist.get(i).get("PHOTO2")?"static/ace/avatars/user.jpg":msglist.get(i).getString("PHOTO2"));	//头像
				statepd.put("username", msglist.get(i).getString("NAME"));		//姓名
				statepd.put("sign", msglist.get(i).getString("AUTOGRAPH"));		//签名
				msgpd.put("user", statepd);
			}else{
				msgpd.put("content", msglist.get(i).getString("CONTENT"));		//消息内容
				msgpd.put("uid", msglist.get(i).getString("USERNAME"));			//接收者用户名
				msgpd.put("from", null);	
				msgpd.put("from_group", null);
				msgpd.put("type", 1);
				msgpd.put("remark", null);		
				msgpd.put("href", null);
				msgpd.put("read", 1);
				msgpd.put("time", msglist.get(i).getString("DTIME"));			//处理时间
				Map<String,Object> statepd = new LinkedHashMap<String,Object>();
				statepd.put("id", null);
				msgpd.put("user", statepd);
			}
			zmsglist.add(msgpd);
		}
		map.put("code", 0);
		map.put("pages", 1);
		map.put("data", zmsglist);
		return AppUtil.returnObject(new PageData(), map);
	}
	
	/**消息盒子未读消息总数接口
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/getMsgCount")
	@ResponseBody
	public Object getMsgCount() throws Exception{
		Map<String,Object> map = new LinkedHashMap<String,Object>();
		String result = "";
		PageData pd = new PageData();
		pd.put("USERNAME", Jurisdiction.getUsername());				//用户名
		pd = sysmsgService.getMsgCount(pd);
		int count = Integer.parseInt(pd.get("msgCount").toString());
		if(count > 0){		//未读消息数大于0
			result = "01";
		}else{
			result = "00";
		}
		map.put("count", count);
		map.put("result", result);
		return AppUtil.returnObject(new PageData(), map);
	}
	
	
	/**同意申请(好友或者群)接口
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/agree")
	@ResponseBody
	public Object agree() throws Exception{
		PageData pd = new PageData();
		pd = this.getPageData();
		
		if("friend".equals(pd.getString("TYPE"))){			//同意好友申请
			pd.put("USERNAME", Jurisdiction.getUsername());	//当前用户名
			
			//修改消息状态
			pd.put("CONTENT", "您同意了"+pd.getString("FNAME")+"申请好友并加对方好友");
			pd.put("DTIME", Tools.date2Str(new Date()));	//完成时间
			pd.put("ISDONE", "yes");
			sysmsgService.edit(pd);
			
			pd.put("USERNAME", Jurisdiction.getUsername());	//用户名
			pd.put("ALLOW", "yes");							//是否允许
			pd.put("DTIME", Tools.date2Str(new Date()));	//处理时间，刚添加等待对方处理，现在为空，处理的时候录入时间
			
			if(null == friendsService.findMyFriend(pd)){
				//添加对方好友
				pd.put("FRIENDS_ID", this.get32UUID());			//主键
				pd.put("CTIME", Tools.date2Str(new Date()));	//申请时间
				pd.put("FGROUP_ID", "9999".equals(pd.getString("FGROUP_ID"))?"":pd.getString("FGROUP_ID"));	//分组, 9999 代表无分组
				pd.put("BZ", "同意对方申请好友并加对方好友");							
				friendsService.save(pd);
			}
			//修改对方好友(本人)的状态为同意yes
			friendsService.editAllow(pd);
			
			//添加系统消息
			pd.put("SYSMSG_ID", this.get32UUID());								//主键
			pd.put("USERNAME", pd.getString("FUSERNAME"));						//接收者用户名
			pd.put("FROMUSERNAME", Jurisdiction.getUsername());					//发送者用户名(即当前用户)
			pd.put("CTIME", Tools.date2Str(new Date()));						//操作时间
			pd.put("REMARK", "");												//留言
			pd.put("TYPE", "friend");											//类型
			pd.put("CONTENT", Jurisdiction.getU_name()+" 已经同意你的好友申请");	//事件内容
			pd.put("QGROUP_ID", "");											//申请加群是有值
			pd.put("DREAD", "0");												//阅读状态 0 未读
			sysmsgService.save(pd);
		}else{	//同意群申请
			
			PageData msgpd = new PageData();
			msgpd = sysmsgService.findById(pd);
			
			//修改消息状态
			pd.put("CONTENT", "您同意了"+pd.getString("FNAME")+msgpd.getString("CONTENT"));
			pd.put("DTIME", Tools.date2Str(new Date()));						//完成时间
			pd.put("ISDONE", "yes");
			sysmsgService.edit(pd);
			
			pd.put("USERNAME",  pd.getString("FUSERNAME"));	
			if(null == iqgroupService.findByIdandQid(pd)){		//判断是否在此群了
				
				//添加系统消息
				pd.put("SYSMSG_ID", this.get32UUID());								//主键
				pd.put("FROMUSERNAME", Jurisdiction.getUsername());					//发送者用户名(即当前用户)
				pd.put("CTIME", Tools.date2Str(new Date()));						//操作时间
				pd.put("REMARK", "");												//留言
				pd.put("TYPE", "group");											//类型
				pd.put("CONTENT", Jurisdiction.getU_name()+" 已经同意你"+msgpd.getString("CONTENT"));	//事件内容
				pd.put("DREAD", "0");												//阅读状态 0 未读
				sysmsgService.save(pd);
				
				//把此用户加入到群中
				PageData ipd = new PageData();
				ipd = iqgroupService.findById(pd);
				if(null == ipd){								//当我没有任何群时添加数据，否则修改
					pd.put("QGROUPS", "('"+pd.getString("QGROUP_ID")+"',");
					pd.put("IQGROUP_ID", this.get32UUID());		//主键
					iqgroupService.save(pd);
				}else{
					pd.put("QGROUPS", ipd.getString("QGROUPS").replaceAll("'"+pd.getString("QGROUP_ID")+"',", "")+"'"+pd.getString("QGROUP_ID")+"',");//防止同一群，重复的添加
					iqgroupService.edit(pd);
				}
			}
		}
		
		return AppUtil.returnObject(new PageData(), null);
	}
	
	/**拒绝申请(好友或者群)接口
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/refuse")
	@ResponseBody
	public Object refuse() throws Exception{
		Map<String,Object> map = new LinkedHashMap<String,Object>();
		String result = "";
		PageData pd = new PageData();
		pd = this.getPageData();
		
		if("friend".equals(pd.getString("TYPE"))){			//同意好友申请
			pd.put("USERNAME", Jurisdiction.getUsername());	//当前用户名
			
			//修改消息状态
			pd.put("CONTENT", "您拒绝了"+pd.getString("FNAME")+"申请好友");
			pd.put("DTIME", Tools.date2Str(new Date()));	//完成时间
			pd.put("ISDONE", "yes");
			sysmsgService.edit(pd);
			
			//从对方好友列表中删除本人
			friendsService.pullblack(pd);
			
			//添加系统消息
			pd.put("SYSMSG_ID", this.get32UUID());								//主键
			pd.put("USERNAME", pd.getString("FUSERNAME"));						//接收者用户名
			pd.put("FROMUSERNAME", Jurisdiction.getUsername());					//发送者用户名(即当前用户)
			pd.put("CTIME", Tools.date2Str(new Date()));						//操作时间
			pd.put("REMARK", "");												//留言
			pd.put("TYPE", "friend");											//类型
			pd.put("CONTENT", Jurisdiction.getU_name()+" 拒绝了你的好友申请");	//事件内容
			pd.put("QGROUP_ID", "");											//申请加群是有值
			pd.put("DREAD", "0");												//阅读状态 0 未读
			sysmsgService.save(pd);
		}else{	//拒绝群申请
			
			PageData msgpd = new PageData();
			msgpd = sysmsgService.findById(pd);
			
			pd.put("USERNAME",  pd.getString("FUSERNAME"));	
			if(null == iqgroupService.findByIdandQid(pd)){		//判断是否在此群了
				
				//添加系统消息
				pd.put("SYSMSG_ID", this.get32UUID());								//主键
				pd.put("FROMUSERNAME", Jurisdiction.getUsername());					//发送者用户名(即当前用户)
				pd.put("CTIME", Tools.date2Str(new Date()));						//操作时间
				pd.put("REMARK", "");												//留言
				pd.put("TYPE", "group");											//类型
				pd.put("CONTENT", Jurisdiction.getU_name()+" 已经拒绝你"+msgpd.getString("CONTENT"));	//事件内容
				pd.put("DREAD", "0");												//阅读状态 0 未读
				sysmsgService.save(pd);
				
			}else{//已经在此群了，就不能拒绝了，修改消息状态为同意
				
				//修改消息状态
				pd.put("CONTENT", "同意了"+pd.getString("FNAME")+msgpd.getString("CONTENT"));
				pd.put("DTIME", Tools.date2Str(new Date()));						//完成时间
				pd.put("ISDONE", "yes");
				sysmsgService.edit(pd);
				result = "01";
			}
		}
		map.put("result", result);
		return AppUtil.returnObject(new PageData(), map);
	}
	
	/**消息设置成已读
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/read")
	@ResponseBody
	public Object read() throws Exception{
		PageData pd = new PageData();
		pd.put("USERNAME", Jurisdiction.getUsername());		//用户名
		sysmsgService.read(pd);
		return AppUtil.returnObject(new PageData(), null);
	}
	
	/**获取未读消息(离线消息)接口
	 * @return
	 * @throws Exception
	 */
	@RequestMapping(value="/getNoreadMsg")
	@ResponseBody
	public Object getNoreadMsg() throws Exception{
		Map<String,Object> map = new LinkedHashMap<String,Object>();
		String result = "";
		PageData pd = new PageData();
		pd = this.getPageData();
		pd.put("USERNAME", Jurisdiction.getUsername());		//用户名
		List<PageData> varList = hismsgService.listAllnoread(pd);
		if(varList.size() > 0){
			result = "has";
			map.put("list", varList);
			hismsgService.edit(pd);							//设置成已读状态
		}else{
			result = "no";
		}
		map.put("result", result);
		return AppUtil.returnObject(new PageData(), map);
	}
	
	
}





/** 
 * 说明：聊天即使通讯接口
 * 创建人：F H ad min Q 3 135 96 790
 */