spacesaction.java

论坛软件系统亦称电子公告板(BBS)系统

			cale.setTimeInMillis(Long.valueOf(begin + "000"));
			int days = calcCalenday(cale);
			int ddd = cale.get(Calendar.DAY_OF_WEEK);
			request.setAttribute("week", ddd - 1);
			int month = cale.get(Calendar.MONTH);
			int year = cale.get(Calendar.YEAR);
			if (cale.compareTo(nowcale) == -1&& (cale.get(Calendar.MONTH) != nowcale.get(Calendar.MONTH) || cale.get(Calendar.YEAR) != nowcale.get(Calendar.YEAR))) {
				cale.set(Calendar.MONTH, month + 1);
				int afterdays = calcCalenday(cale);
				cale.set(Calendar.DATE, 1);
				String afterbegintime = cale.getTimeInMillis() + "";
				afterbegintime = afterbegintime.substring(0, 10);
				cale.set(Calendar.DATE, afterdays);
				String afterendtime = cale.getTimeInMillis() + "";
				afterendtime = afterendtime.substring(0, 10);
				request.setAttribute("afterbegintime", afterbegintime);
				request.setAttribute("afterendtime", afterendtime);
			}
			Calendar calp = Common.getGMTCalendar();
			calp.setTimeInMillis(calp.getTimeInMillis()+timeoffset*1000);
			calp.setTimeInMillis(Long.valueOf(begin + "000"));
			calp.set(Calendar.MONTH, month - 1);
			int befordays = calcCalenday(calp);
			calp.set(Calendar.DATE, 1);
			String beforbegintime = calp.getTimeInMillis() + "";
			beforbegintime = beforbegintime.substring(0, 10);
			calp.set(Calendar.DATE, befordays);
			String beforendtime = calp.getTimeInMillis() + "";
			beforendtime = beforendtime.substring(0, 10);
			request.setAttribute("beforendtime", beforendtime);
			request.setAttribute("beforbegintime", beforbegintime);
			request.setAttribute("days", days);
			request.setAttribute("month", month + 1);
			request.setAttribute("year", year);
		}
		request.setAttribute("begintime", begin);
		request.setAttribute("endtime", end);
		String blogcount = "select count(*) from Threads as t where  t.displayorder>=0 and t.authorid = "
				+ uid + " and t.blog = 1 and t.dateline >= " + begin + " and t.dateline <= " + end;
		String bloghql = "select t.*,f.name,p.message,p.pid from jrun_threads as t left join jrun_forums as f on t.fid=f.fid left join jrun_posts as p on t.tid=p.tid where t.authorid = " + uid + " and t.blog = 1 and t.dateline >= " + begin
				+ " and t.dateline<=" + end + " and t.displayorder>=0 and p.first=1 order by t.lastpost desc";
		Map<String,String> settings=(Map<String,String>)request.getAttribute("settings");
		Map spacemap = ((DataParse) BeanFactory.getBean("dataParse")).characterParse(settings.get("spacedata"),false);
		int messagelength = convertInt(spacemap.get("textlength").toString());
		int size = threadService.findThreadCountByHql(blogcount);
		String currpage = request.getParameter("page");
		int pages = 1;
		if (currpage != null) {
			pages = Integer.valueOf(currpage);
		}
		int pagesize = 10;
		LogPage logpage = new LogPage(size, pagesize, pages);
		int beginsize = (pages - 1) * pagesize;
		if (beginsize > size) {
			beginsize = size;
		}
		request.setAttribute("logpage", logpage);
		String dateformat = (String)session.getAttribute("dateformat");
		List list = new ArrayList();
		List<Map<String,String>> blogthread = dataBaseService.executeQuery(bloghql+" limit "+beginsize+","+pagesize);
		if (blogthread != null && blogthread.size()>0) {
			for (Map<String,String> thread : blogthread) {
				SpaceVO spacevo = new SpaceVO();
				spacevo.setSpecial(thread.get("special"));
				spacevo.setPrice(thread.get("price"));
				spacevo.setFid(Common.toDigit(thread.get("fid")));
				spacevo.setForums(thread.get("name"));
				String message = thread.get("message");
				spacevo.setPid(Common.toDigit(thread.get("pid")));
				if (message.length() > messagelength) {
					message = message.substring(0, messagelength) + "...";
				}
				spacevo.setMessage(message);
				spacevo.setSubject(thread.get("subject"));
				spacevo.setTid(Common.toDigit(thread.get("tid")));
				String datetime = Common.gmdate(dateformat, (int)(Common.toDigit(thread.get("dateline"))+timeoffset));
				spacevo.setOperdate(datetime);
				spacevo.setViewnum(Common.toDigit(thread.get("views")));
				spacevo.setReplicenum(Common.toDigit(thread.get("replies")));
				if (thread.get("attachment").equals("1")) {
					spacevo.setIsattc(true);
				} else {
					spacevo.setIsattc(false);
				}
				if (Common.toDigit(thread.get("lastpost"))> member.getLastvisit()) {
					spacevo.setIsnew(true);
				} else {
					spacevo.setIsnew(false);
				}
				list.add(spacevo);
			}
		}
		String bloghqlto5 = "from Threads as t where t.authorid = " + uid
				+ " and t.blog = 1 and t.displayorder>=0 order by t.views desc";
		List<Threads> blogthreads = threadService.findThreadsByHql(bloghqlto5,
				0, 5);
		String blogrepto5 = "from Threads as t where t.authorid = " + uid
				+ " and t.blog = 1 and t.displayorder>=0 order by t.lastpost desc";
		List<Threads> blogthreadr = threadService.findThreadsByHql(blogrepto5,
				0, 5);
		request.setAttribute("myblogs", list);
		request.setAttribute("repblog", blogthreadr);
		request.setAttribute("blogthread", blogthreads);
		short groupid = (Short)session.getAttribute("jsprun_groupid");
		request.setAttribute("forumselect", Common.forumselect(false, false,groupid,member!=null?member.getExtgroupids():"",null,false));
		Memberspaces memberspace = spaceServer.findMemberspace(uid);
		if(memberspace==null){
			request.setAttribute("errorInfo", "该用户空间没有开启,请到个人空间首页开启。");
			return mapping.findForward("showMessage");
		}
		String layout = memberspace.getLayout();
		Map menuMap = new HashMap();
		if (layout.indexOf("[myblogs]") != -1) {
			menuMap.put("myblogs", "ok");
		}
		if (layout.indexOf("[mythreads]") != -1) {
			menuMap.put("mythreads", "ok");
		}
		if (layout.indexOf("[myreplies]") != -1) {
			menuMap.put("myreplies", "ok");
		}
		if (layout.indexOf("[myrewards]") != -1) {
			menuMap.put("myrewards", "ok");
		}
		if (layout.indexOf("[mytrades]") != -1) {
			menuMap.put("mytrades", "ok");
		}
		if (layout.indexOf("[myfavforums]") != -1) {
			menuMap.put("myfavforums", "ok");
		}
		if (layout.indexOf("[myfavthreads]") != -1) {
			menuMap.put("myfavthreads", "ok");
		}
		request.setAttribute("menuMap", menuMap);
		UserInfoVO userinfo = new UserInfoVO();
		userinfo.setUsername(member.getUsername());
		userinfo.setAvoras(memberfild.getAvatar());
		String bio = memberfild.getBio();
		String[] bios = bio.split("\t");
		if(bios!=null && bios.length>0){
			userinfo.setBios(bios[0]);
		}else{
			userinfo.setBios("");
		}
		userinfo.setWidth(memberfild.getAvatarwidth());
		userinfo.setHeight(memberfild.getAvatarheight());
		userinfo.setIsonline(spaceServer.findSessionByUid(uid));
		request.setAttribute("userinfo", userinfo);
		request.setAttribute("member", member);
		request.setAttribute("memberspace", memberspace);
		return mapping.findForward("tomyblogs");
	}
	@SuppressWarnings("unchecked")
	public ActionForward toMythreads(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		String suid = request.getParameter("uid");  
		int uid = convertInt(suid);
		Members member = memberServer.findMemberById(uid);
		if(member==null){
			request.setAttribute("errorInfo", "该用户不存在或已被删除，请返回上一页");
			return mapping.findForward("showMessage");
		}
		Memberfields memberfild = memberServer.findMemberfieldsById(uid);
		request.setAttribute("bember", member);
		request.setAttribute("memberfild", memberfild);
		String blogcount = "SELECT COUNT(*)  FROM Mythreads m, Threads t WHERE m.id.uid=" + uid +  " AND m.id.tid=t.tid";
		int size = threadService.findThreadCountByHql(blogcount);
		String currpage = request.getParameter("page");
		int pages = 1;
		if (currpage != null) {
			pages = Integer.valueOf(currpage);
		}
		int pagesize = 10;
		LogPage logpage = new LogPage(size, pagesize, pages);
		int beginsize = (pages - 1) * pagesize;
		if (beginsize > size) {
			beginsize = size;
		}
		request.setAttribute("logpage", logpage);
		String bloghql = "select t.*,f.name from jrun_mythreads as m left join jrun_threads as t on m.tid=t.tid left join jrun_forums as f on t.fid=f.fid  where m.uid = " + uid
		+ " and t.special<>3 and t.displayorder>=0  order by t.lastpost desc limit "+beginsize+","+pagesize;
		List<Map<String,String>> threadlist = dataBaseService.executeQuery(bloghql);
		List list = new ArrayList();
		if (threadlist != null && threadlist.size()>0) {
			for (Map<String,String>threads  : threadlist) {
				MythreadsVO mythread = new MythreadsVO();
				mythread.setFid(threads.get("fid"));
				mythread.setForums(threads.get("name"));
				mythread.setSpecial(threads.get("special"));
				mythread.setPrice(threads.get("price"));
				mythread.setLastpost(Common.toDigit(threads.get("lastpost")));
				mythread.setLastposter(threads.get("lastposter"));
				mythread.setTid(threads.get("tid"));
				mythread.setSubjcet(threads.get("subject"));
				mythread.setViewnum(Common.toDigit(threads.get("views")));
				mythread.setReplaynum(Common.toDigit(threads.get("replies")));
				if (threads.get("attachment").equals("1")) {
					mythread.setIsattc(true);
				} else {
					mythread.setIsattc(false);
				}
				if (Common.toDigit(threads.get("lastpost")) > member.getLastvisit()) {
					mythread.setIsnew(true);
				} else {
					mythread.setIsnew(false);
				}
				list.add(mythread);
			}
		}
		request.setAttribute("mythread", list);
		Memberspaces memberspace = spaceServer.findMemberspace(uid);
		if(memberspace==null){
			request.setAttribute("errorInfo", "该用户空间没有开启,请到个人空间首页开启。");
			return mapping.findForward("showMessage");
		}
		String layout = memberspace.getLayout();
		Map menuMap = new HashMap();
		if (layout.indexOf("[myblogs]") != -1) {
			menuMap.put("myblogs", "ok");
		}
		if (layout.indexOf("[mythreads]") != -1) {
			menuMap.put("mythreads", "ok");
		}
		if (layout.indexOf("[myreplies]") != -1) {
			menuMap.put("myreplies", "ok");
		}
		if (layout.indexOf("[myrewards]") != -1) {
			menuMap.put("myrewards", "ok");
		}
		if (layout.indexOf("[mytrades]") != -1) {
			menuMap.put("mytrades", "ok");
		}
		if (layout.indexOf("[myfavforums]") != -1) {
			menuMap.put("myfavforums", "ok");
		}
		if (layout.indexOf("[myfavthreads]") != -1) {
			menuMap.put("myfavthreads", "ok");
		}
		request.setAttribute("menuMap", menuMap);
		UserInfoVO userinfo = new UserInfoVO();
		userinfo.setUsername(member.getUsername());
		userinfo.setAvoras(memberfild.getAvatar());
		String bio = memberfild.getBio();
		String bios[] = bio.split("\t");
		if(bios!=null && bios.length>0){
		userinfo.setBios(bios[0]);
		}else{
			userinfo.setBios("");
		}
		userinfo.setWidth(memberfild.getAvatarwidth());
		userinfo.setHeight(memberfild.getAvatarheight());
		userinfo.setIsonline(spaceServer.findSessionByUid(uid));
		request.setAttribute("userinfo", userinfo);
		request.setAttribute("member", member);
		request.setAttribute("memberspace", memberspace);
		return mapping.findForward("tomythreads");
	}
	@SuppressWarnings("unchecked")
	public ActionForward toMyreplay(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		String suid = request.getParameter("uid"); 
		int uid = convertInt(suid);
		Members member = memberServer.findMemberById(uid);
		if(member==null){
			request.setAttribute("errorInfo", "该用户不存在或已被删除，请返回上一页");
			return mapping.findForward("showMessage");
		}
		String blogcount = "select count(*) from Threads as t,Myposts as m,Posts as p where p.pid=m.pid and m.id.tid=t.tid and m.id.uid="+ uid + " and t.replies > 0 and t.displayorder>=0";
		int size = threadService.findThreadCountByHql(blogcount);
		String currpage = request.getParameter("page");
		int pages = 1;
		if (currpage != null) {
			pages = Integer.valueOf(currpage);
		}
		int pagesize = 10;
		LogPage logpage = new LogPage(size, pagesize, pages);
		int beginsize = (pages - 1) * pagesize;
		if (beginsize > size) {
			beginsize = size;
		}
		request.setAttribute("logpage", logpage);
		Memberfields memberfild = memberServer.findMemberfieldsById(uid);
		request.setAttribute("bember", member);
		request.setAttribute("memberfild", memberfild);
		List list = new ArrayList();
		String rephql = "select t.*,f.name from jrun_myposts as m left join jrun_threads as t on m.tid=t.tid left join jrun_forums as f on t.fid=f.fid where m.uid="+uid+" and  t.displayorder>=0 order by t.lastpost desc limit "+beginsize+","+pagesize;
		List<Map<String,String>> replythread = dataBaseService.executeQuery(rephql);
		if (replythread != null && replythread.size()>0) {
			for (Map<String,String> thread : replythread) {
				MythreadsVO mythread = new MythreadsVO();
				mythread.setFid(thread.get("fid"));
				mythread.setForums(thread.get("name"));
				mythread.setLastpost(Common.toDigit(thread.get("lastpost")));
				mythread.setLastposter(thread.get("lastposter"));
				mythread.setTid(thread.get("tid"));
				mythread.setSubjcet(thread.get("subject"));
				mythread.setSpecial(thread.get("special"));
				mythread.setPrice(thread.get("price"));
				mythread.setViewnum(Common.toDigit(thread.get("views")));
				mythread.setReplaynum(Common.toDigit(thread.get("replies")));
				if (thread.get("attachment").equals("1")) {
					mythread.setIsattc(true);
				} else {
					mythread.setIsattc(false);
				}
				if (Common.toDigit(thread.get("lastpost")) > member.getLastvisit()) {
					mythread.setIsnew(true);
				} else {
					mythread.setIsnew(false);
				}