package com.his.service;
/*
* Copyright 2005 Joe Walker
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Set;
import org.directwebremoting.util.Logger;
import com.his.common.DBManage;
/**
* A container for a set of people
*
* @author Joe Walker [joe at getahead dot ltd dot uk]
*/
public class Messages {
Connection con = null;
/**
* Pre-populate with random people
*/
public Messages() {
con = DBManage.getConnection();
}
public Set getDepartsments() {
Set departments = new HashSet();
String sql = "select * from department";
try {
PreparedStatement pst = con.prepareStatement(sql);
ResultSet rs = pst.executeQuery();
while (rs.next()) {
Department department = new Department();
department.setDepartmentDescription(rs
.getString("department_description"));
department.setDepartmentName(rs.getString("department_name"));
department.setId(rs.getInt("Id"));
departments.add(department);
}
rs.close();
pst.close();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
return departments;
}
public Set getGroups() {
Set groups = new HashSet();
String sql = "select * from groups";
try {
PreparedStatement pst = con.prepareStatement(sql);
ResultSet rs = pst.executeQuery();
while (rs.next()) {
Group group = new Group();
group.setGroupDescription(rs.getString("group_description"));
group.setGroupName(rs.getString("group_name"));
group.setId(rs.getInt("Id"));
groups.add(group);
}
rs.close();
pst.close();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
return groups;
}
public Set getEmploys(int departmentID) {
Set persons = new HashSet();
String sql = "select * from employ where department_id=?";
try {
PreparedStatement pst = con.prepareStatement(sql);
pst.setInt(1, departmentID);
ResultSet rs = pst.executeQuery();
while (rs.next()) {
Employ person = new Employ();
person.setTelephone(rs.getString("emp_telephone"));
person.setId(rs.getInt("Id"));
person.setName(rs.getString("employ_name"));
persons.add(person);
}
rs.close();
pst.close();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
return persons;
}
public Set getPersons(int groupID) {
Set persons = new HashSet();
String sql = "select * from person where groupID=?";
try {
PreparedStatement pst = con.prepareStatement(sql);
pst.setInt(1, groupID);
ResultSet rs = pst.executeQuery();
while (rs.next()) {
Person person = new Person();
person.setTelephone(rs.getString("telephone"));
person.setId(rs.getInt("personID"));
person.setName(rs.getString("name"));
persons.add(person);
}
rs.close();
pst.close();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
return persons;
}
public int getReceiveMessagesCount(String beginDate, String endDate,
String telephone) {
int count = 0;
String sql = "select count(*) from receive_sms where receive_time> ? and receive_time < ?";
if (telephone != null && !telephone.trim().equalsIgnoreCase("")) {
sql = sql + " and send_telephone= ?";
}
if(beginDate.endsWith(""))beginDate="0";
if(endDate.endsWith(""))endDate="0";
try {
PreparedStatement pst = con.prepareStatement(sql);
pst.setDate(1, new java.sql.Date(Long.parseLong(beginDate)));
pst.setDate(2, new java.sql.Date(Long.parseLong(endDate)));
if (telephone != null && !telephone.trim().equalsIgnoreCase("")) {
pst.setString(3, telephone);
}
ResultSet rs = pst.executeQuery();
while (rs.next()) {
count = rs.getInt(1);
}
sql = "";
rs.close();
pst.close();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
return count;
}
public int getSendMessagesCount(String beginDate, String endDate,
String telephone) {
int count = 0;
String sql = "select count(*) from sended_sms where send_date > ? and send_date < ?";
if (telephone != null && !telephone.trim().equalsIgnoreCase("")) {
sql = sql + " and receive_telephone= ?";
}
if(beginDate.endsWith(""))beginDate="0";
if(endDate.endsWith(""))endDate="0";
try {
PreparedStatement pst = con.prepareStatement(sql);
pst.setDate(1, new java.sql.Date(Long.parseLong(beginDate)));
pst.setDate(2, new java.sql.Date(Long.parseLong(endDate)));
if (telephone != null && !telephone.trim().equalsIgnoreCase("")) {
pst.setString(3, telephone);
}
ResultSet rs = pst.executeQuery();
while (rs.next()) {
count = rs.getInt(1);
}
sql = "";
rs.close();
pst.close();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
return count;
}
/**
* Accessor for the current list of people
* 1:check2:pregnant3:health_care4:m5:sh6:ac7:bu
*
* @return the current list of people
*/
public Set getActivityMessages() {
messages.clear();
String sql = "select * from sended_sms where service_type=6";
try {
Statement st = con.createStatement();
ResultSet rs = st.executeQuery(sql);
while (rs.next()) {
Message message = new Message();
message.setContent(rs.getString("content"));
message.setId(rs.getInt("Id"));
message.setSendDate(rs.getDate("send_date").toLocaleString());
message.setSendedState(rs.getInt("sended_state"));
message.setTelephone(rs.getString("receive_telephone"));
message.setServiceType(rs.getInt("service_type"));
messages.add(message);
}
rs.close();
st.close();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
return messages;
}
public Set getBulletinMessages() {
messages.clear();
String sql = "select * from sended_sms where service_type=7";
try {
Statement st = con.createStatement();
ResultSet rs = st.executeQuery(sql);
while (rs.next()) {
Message message = new Message();
message.setContent(rs.getString("content"));
message.setId(rs.getInt("Id"));
message.setSendDate(rs.getDate("send_date").toLocaleString());
message.setSendedState(rs.getInt("sended_state"));
message.setTelephone(rs.getString("receive_telephone"));
message.setServiceType(rs.getInt("service_type"));
messages.add(message);
}
rs.close();
st.close();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
return messages;
}
public Set getSheduleMessages() {
messages.clear();
String sql = "select * from sended_sms where service_type=5";
try {
Statement st = con.createStatement();
ResultSet rs = st.executeQuery(sql);
while (rs.next()) {
Message message = new Message();
message.setContent(rs.getString("content"));
message.setId(rs.getInt("Id"));
message.setSendDate(rs.getDate("send_date").toLocaleString());
message.setSendedState(rs.getInt("sended_state"));
message.setTelephone(rs.getString("receive_telephone"));
message.setServiceType(rs.getInt("service_type"));
messages.add(message);
}
rs.close();
st.close();
} catch (SQLException e1) {
用dwr 写的一个医院程序 （332个子文件） 
Messages.class 11KB ApiTestDemo.class 9KB GroupManage.class 7KB Util.class 6KB SMApi.class 4KB SysInit.class 3KB SendService.class 3KB Const.class 3KB Person.class 3KB LogInValidate.class 2KB Employ.class 2KB DBManage.class 2KB ReceiveSMSTask.class 2KB ApiTestDemo$SendTask.class 2KB Message.class 2KB SendMessage.class 1KB MD5.class 1KB ReceiveRPT.class 1KB Receive.class 1KB Department.class 1KB Group.class 1KB UtilTimer.class 748B Test.class 433B .classpath 965B style.css 14KB hwhelp.css 9KB hwhelp_ns.css 5KB g_css1.css 3KB g_css1.css 3KB g_css.css 2KB g_css.css 2KB hw.css 2KB hw.css 2KB dtree.css 853B popMember.css 716B popMember.css 716B Thumbs.db 228KB
bannar_01.gif 12KB webbuild.gif 5KB bannar_09.gif 5KB bt_ok.gif 3KB bt_error.gif 3KB user_login.gif 1KB mmsPicBack.gif 1KB button_6size.gif 990B button_6size.gif 990B button_5size.gif 955B button_big.gif 950B button_small.gif 901B button_4size.gif 891B dygl.gif 301B button_1size.GIF 293B button.gif 231B cc.gif 202B scroll_down.gif 170B button_right.gif 153B scroll_left.gif 153B scroll_right.gif 151B aa.gif 150B button_left.gif 149B scroll_up.gif 144B b.gif 142B button_down.gif 139B bb.gif 138B button_up.gif 138B download.gif 120B linewhite.gif 95B add.gif 87B cancel.gif 76B pause.gif 73B send.gif 70B jiantou.gif 62B scroll_bg_bannar.gif 51B scroll_bg.gif 50B hint.htm 1KB ScollBar.htm 1007B Scoll.htm 998B hidden.htm 264B
test.html 5KB building.html 2KB error.html 2KB bottom.html 1KB pagelist.html 120B
mysql-connector-java-5.1.2-beta-bin.jar 622KB dwr.jar 478KB commons-jxpath-1.2.jar 278KB xmlParserAPIs.jar 127KB ImApi.jar 9KB Messages.java 14KB ApiTestDemo.java 10KB GroupManage.java 8KB Util.java 6KB SMApi.java 4KB SendService.java 3KB SysInit.java 3KB Const.java 3KB DBManage.java 2KB Person.java 2KB SendMessage.java 2KB LogInValidate.java 2KB共 332 条
- 1
- 2
- 3
- 4
评论0