userdbadd.java

中国移动 provision MISC1.6 接口

package sms.sendmt;

import java.sql.PreparedStatement;

import cmd.db.*;

public class UserDBAdd {

	public boolean AddUserToDB(String sUSERMOBILE, String sORDERMOBIE,String sSPServiceID) {
		boolean bRetval = false;

		ConnDB connDB = new ConnDB();
		CodeChange codeChange = new CodeChange();
		connDB.setAutoCommit(connDB.AUTO_COMMIT);
		String sSQL = "INSERT INTO orderuser (USERMOBILE,ORDERMOBIE,SPSERVICEID) values (?,?,?)";
		System.out.println(sSQL);
		PreparedStatement pstmt = connDB.createPstmt(sSQL);
		if (pstmt != null) {
			try {

				pstmt.setString(1, sUSERMOBILE);
				pstmt.setString(2, sORDERMOBIE);
				pstmt.setString(3, sSPServiceID);

				if (connDB.executeUpdate() > 0) {
					bRetval = true;
				}

			} catch (Exception e) {
				System.out.println("ConnDB::InsertUse Error " + e.toString());
			} finally {
				connDB.closeStmt();
				connDB.close();
			}
		}

		return bRetval;

	}
	
	public boolean DelUserInDB(String sUSERMOBILE, String sORDERMOBIE) {
		boolean bRetval = false;

		ConnDB connDB = new ConnDB();
		CodeChange codeChange = new CodeChange();
		connDB.setAutoCommit(connDB.AUTO_COMMIT);
		String sSQL = "update orderuser set STATUS = '9' where USERMOBILE = ?";
		System.out.println(sSQL);
		PreparedStatement pstmt = connDB.createPstmt(sSQL);
		if (pstmt != null) {
			try {

				pstmt.setString(1, sUSERMOBILE);

				if (connDB.executeUpdate() > 0) {
					bRetval = true;
				}

			} catch (Exception e) {
				System.out.println("ConnDB::InsertUse Error " + e.toString());
			} finally {
				connDB.closeStmt();
				connDB.close();
			}
		}

		return bRetval;

	}
	
	public boolean insertSubmit(String msgid,
			                    String serviceId,
			                    String fee_userType,
			                    String Fee_terminal_Id,
			                    String TP_pId,
			                    String TP_udhi,
			                    String Msg_Fmt,
			                    String Msg_src,
			                    String FeeType,
			                    String FeeCode,
			                    String ValId_Time,
			                    String At_Time,
			                    String Src_Id,
			                    String Dest_terminal_Id,
			                    String Dest_terminal_type,
			                    String Msg_Content,
			                    String LinkID,
			                    String status) {
		boolean bRetval = false;

		ConnDB connDB = new ConnDB();
		CodeChange codeChange = new CodeChange();
		connDB.setAutoCommit(connDB.AUTO_COMMIT);
		String sSQL = "INSERT INTO submittask (msgid,serviceId,fee_userType,Fee_terminal_Id,"+
		"TP_pId,TP_udhi,Msg_Fmt,Msg_src,FeeType,FeeCode,ValId_Time,At_Time,Src_Id,Dest_terminal_Id,"+
		"Dest_terminal_type,Msg_Content,LinkID,status) values (?,?,?,?,?,?,?,?,?,?,now(),now(),?,?,?,?,?,?)";
		System.out.println(sSQL);
		PreparedStatement pstmt = connDB.createPstmt(sSQL);
		if (pstmt != null) {
			try {

				pstmt.setString(1, msgid);
				pstmt.setString(2, serviceId);
				pstmt.setString(3,fee_userType);
				pstmt.setString(4,Fee_terminal_Id);
				pstmt.setString(5,TP_pId);
				pstmt.setString(6,TP_udhi);
				pstmt.setString(7,Msg_Fmt);
				pstmt.setString(8,Msg_src);
				pstmt.setString(9,FeeType);
				pstmt.setString(10,FeeCode);
				//pstmt.setString(11,ValId_Time);
				//pstmt.setString(12,At_Time);
				pstmt.setString(11,Src_Id);
				pstmt.setString(12,Dest_terminal_Id);
				pstmt.setString(13,Dest_terminal_type);
				pstmt.setString(14,codeChange.toChinese(Msg_Content));
				pstmt.setString(15,LinkID);
				pstmt.setString(16,status);

				if (connDB.executeUpdate() > 0) {
					bRetval = true;
				}

			} catch (Exception e) {
				System.out.println("ConnDB::Insertsubmit Error " + e.toString());
			} finally {
				connDB.closeStmt();
				connDB.close();
			}
		}

		return bRetval;

	}	

}