package com.eastnet.wechat.utils;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import com.mysql.jdbc.StringUtils;
public class OperatorUtil {
/**
* 获取账号绑定状态
* @param fromUserName
* @return
*/
public String getBindStatus(String fromUserName){
Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
conn=new DBCPConnection().getConnection();
String selectSql="select * from crm_stu_wechat where open_id='"+fromUserName+"'";
if(conn==null){
return "连接数据库失败";
}else{
try {
ps=conn.prepareStatement(selectSql);
rs=ps.executeQuery();
if(rs.next()){
return "用户名已绑定";
}else{
return "请输入\"用户名绑定\"+登录用户名 如:用户名绑定fangw";
}
} catch (SQLException e) {
return "查询数据库失败";
}finally{
closeConnection(conn,ps,rs);
}
}
}
public List<String> getAllUser(){
Connection conn=null;
List<String> list=new ArrayList<String>();
PreparedStatement ps=null;
ResultSet rs=null;
conn=new DBCPConnection().getConnection();
String selectSql="select * from qx_users ";
if(conn==null){
return null;
}else{
try {
ps=conn.prepareStatement(selectSql);
rs=ps.executeQuery();
while(rs.next()){
list.add(rs.getString("USERNAME"));
}
} catch (SQLException e) {
return null;
}finally{
closeConnection(conn,ps,rs);
}
}
return list;
}
/**
* 绑定账号
* @param fromUserName
* @param userName
* @return
*/
public String bindAccount(String fromUserName,String userName){
Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
String result=getBindStatus(fromUserName);
if("连接数据库失败".equals(result)||("查询数据库失败".equals(result))){
return "连接数据库失败";
}else if("用户名已绑定".equals(result)){
return "用户名已绑定,无需重复绑定";
}
conn = new DBCPConnection().getConnection();
List<String> list=getAllUser();
if(!list.contains(userName)){
return "用户名不存在,绑定失败";
}
int i = 0;
String sql = "insert into crm_stu_wechat (open_id,user_name) values(?,?)";
try {
ps = conn.prepareStatement(sql);
ps.setString(1, fromUserName);
ps.setString(2, userName);
i = ps.executeUpdate();
if(i>0){
return "用户名绑定成功";
}else{
return "用户名绑定失败";
}
} catch (SQLException e) {
return "用户名绑定失败,未知错误";
}finally{
closeConnection(conn,ps,rs);
}
}
/**
* 解除账号绑定
* @param fromUserName
* @param userName
* @return
*/
public String unBindAccount(String userName){
Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
conn = new DBCPConnection().getConnection();
int i = 0;
String sql=" delete from crm_stu_wechat where user_name= ?";
try {
ps = conn.prepareStatement(sql);
ps.setString(1, userName);
i = ps.executeUpdate();
if(i>0){
return "用户名解除绑定成功";
}else{
return "该用户名不存在";
}
} catch (SQLException e) {
return "用户名解除绑定失败,未知错误";
}finally{
closeConnection(conn,ps,rs);
}
}
/**
* 行程添加
* @param fromUserName
* @return
*/
public String addTravel(String fromUserName){
Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
String sbStr="";
conn = new DBCPConnection().getConnection();
String selectSql="select * from crm_stu_wechat where open_id='"+fromUserName+"'";
if(conn==null){
return "连接数据库失败";
}else{
try {
ps=conn.prepareStatement(selectSql);
rs=ps.executeQuery();
if(rs.next()){
String userName=rs.getString("user_name");
String selectTravelSql="select * from crm_student where user_id='"+userName+"'";
Connection connTravel= new DBCPConnection().getConnection();
PreparedStatement psTravel=connTravel.prepareStatement(selectTravelSql);
ResultSet rsTravel=psTravel.executeQuery();
if(rsTravel.next()){
String name=rsTravel.getString("id");
sbStr="点击添加行程";
return sbStr;
}else{
return "您未注册,请在电脑端完成注册";
}
}else{
return "用户名未绑定,请输入\"用户名绑定\"+登录用户名 如:用户名绑定fangw";
}
} catch (SQLException e) {
return "查询数据库失败";
}finally{
closeConnection(conn,ps,rs);
}
}
}
/**
* 行程查看
* @param fromUserName
* @return
*/
public String viewTravel(String fromUserName){
Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
StringBuffer sb=new StringBuffer();
conn = new DBCPConnection().getConnection();
String selectSql="select * from crm_stu_wechat where open_id='"+fromUserName+"'";
if(conn==null){
return "连接数据库失败";
}else{
try {
ps=conn.prepareStatement(selectSql);
rs=ps.executeQuery();
if(rs.next()){
String userName=rs.getString("user_name");
String selectTravelSql="select * from crm_student_info where user_id='"+userName+"'";
Connection connTravel= new DBCPConnection().getConnection();
PreparedStatement psTravel=connTravel.prepareStatement(selectTravelSql);
ResultSet rsTravel=psTravel.executeQuery();
while(rsTravel.next()){
sb.append("考试时间:").append(rsTravel.getString("exam_time")).append("\n");
sb.append("考试院校:").append(rsTravel.getString("exam_school")).append("\n");
sb.append("考试地点:").append(rsTravel.getString("exam_area")).append("\n");
sb.append("居住城市:").append(rsTravel.getString("live_city")).append("\n");
sb.append("\n");
sb.append("---------------------------------");
sb.append("\n");
}
if((sb.toString()==null||("".equals(sb.toString())))){
return "暂无您的行程";
}else{
return sb.toString();
}
}else{
return "用户名未绑定,请输入\"用户名绑定\"+登录用户名 如:用户名绑定fangw";
}
} catch (SQLException e) {
return "查询数据库失败";
}finally{
closeConnection(conn,ps,rs);
}
}
}
/**
* 查看个人信息
* @return
*/
public String viewStuInfo(String fromUserName){
Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
StringBuffer sb=new StringBuffer();
conn = new DBCPConnection().getConnection();
String selectSql="select * from crm_stu_wechat where open_id='"+fromUserName+"'";
if(conn==null){
return "连接数据库失败";
}else{
try {
ps=conn.prepareStatement(selectSql);
rs=ps.executeQuery();
if(rs.next()){
String userName=rs.getString("user_name");
String selectStuSql="select * from crm_student where user_id='"+userName+"'";
Connection connStu= new DBCPConnection().getConnection();
PreparedStatement psStu=connStu.prepareStatement(selectStuSql);
ResultSet rsStu=psStu.executeQuery();
if(rsStu.next()){
sb.append("用户名:").append(rsStu.getString("user_id")).append("\t").append("\n");
sb.append("姓名:").append(rsStu.getString("stu_name")).append("\t").append("\n");
if("0".equals(rsStu.getString("stu_sex"))){
sb.append("性别:").append("男").append("\t").append("\n");
}else{
sb.append("性别:").append("女").append("\t").append(
没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
收起资源包目录
eastnet_wechat.rar (93个子文件)
eastnet_wechat
.project 2KB
.mymetadata 311B
src
com
eastnet
wechat
service
EastnetService.java 9KB
pojo
Button.java 242B
ComplexButton.java 318B
Menu.java 260B
ViewButton.java 347B
AccessToken.java 534B
CommonButton.java 437B
utils
OpenDBConnection.java 2KB
MyX509TrustManager.java 688B
MessageUtil.java 5KB
OperatorUtil.java 13KB
SignUtil.java 3KB
WeixinUtil.java 6KB
DBCPConnection.java 1KB
message
resp
NewsMessage.java 650B
BaseMessage.java 1KB
Music.java 946B
MusicMessage.java 321B
Article.java 1KB
TextMessage.java 348B
req
LinkMessage.java 644B
BaseMessage.java 1KB
LocationMessage.java 869B
VoiceMessage.java 485B
TextMessage.java 338B
ImageMessage.java 311B
weChat 191B
test
Test.java 2KB
servlet
EastnetServlet.java 2KB
CreateMenuServlet.java 6KB
main
MenuManager.java 4KB
dbcp.properties 595B
WebRoot
WEB-INF
classes
com
eastnet
wechat
service
EastnetService.class 5KB
pojo
Menu.class 586B
AccessToken.class 773B
Button.class 541B
ViewButton.class 746B
CommonButton.class 752B
ComplexButton.class 639B
utils
SignUtil.class 3KB
MessageUtil$1$1.class 1KB
OpenDBConnection.class 2KB
OperatorUtil.class 9KB
DBCPConnection.class 1KB
MyX509TrustManager.class 903B
WeixinUtil.class 5KB
MessageUtil$1.class 759B
MessageUtil.class 4KB
message
resp
TextMessage.class 618B
MusicMessage.class 676B
Music.class 1KB
BaseMessage.class 1KB
NewsMessage.class 1KB
Article.class 1KB
req
ImageMessage.class 614B
VoiceMessage.class 815B
TextMessage.class 605B
BaseMessage.class 2KB
LocationMessage.class 1KB
LinkMessage.class 1009B
weChat 191B
test
Test.class 2KB
servlet
CreateMenuServlet.class 4KB
EastnetServlet.class 2KB
main
MenuManager.class 3KB
dbcp.properties 1KB
lib
slf4j-log4j12-1.7.7.jar 9KB
dom4j-1.6.1.jar 307KB
xstream-1.4.jar 481KB
com.springsource.org.apache.commons.pool-1.5.3.jar 95KB
commons-dbcp-1.4.jar 157KB
commons-beanutils-1.7.0.jar 184KB
xmlpull_1_0_5.jar 6KB
ezmorph-1.0.3.jar 76KB
commons-collections-3.1.jar 546KB
json-lib-2.4-jdk15.jar 155KB
com.springsource.org.apache.commons.logging-1.1.1.jar 60KB
mysql-connector-java-5.1.7-bin.jar 693KB
commons-lang-2.3.jar 240KB
web.xml 1KB
index.jsp 922B
success.jsp 840B
META-INF
MANIFEST.MF 36B
.myeclipse
.settings
org.eclipse.wst.jsdt.ui.superType.container 49B
org.eclipse.wst.common.project.facet.core.xml 252B
org.eclipse.jdt.core.prefs 364B
org.eclipse.wst.jsdt.ui.superType.name 6B
org.eclipse.core.resources.prefs 88B
org.eclipse.wst.common.component 476B
.jsdtscope 500B
.classpath 878B
共 93 条
- 1
资源评论
ding2wife
- 粉丝: 0
- 资源: 80
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功