111

src/main/java/com/ekexiu/portal/platform/Console.java

@@ -0,0 +1,104 @@
package com.ekexiu.portal.platform;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.PathVar;
import org.jfw.util.StringUtil;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
/**
 * Created by TT on 2018/5/21.
 */
@Path("/platformConsole")
public class Console {
    @Autowrie
    private PlatformDao platformDao;
    public PlatformDao getPlatformDao() {
        return platformDao;
    }
    public void setPlatformDao(PlatformDao platformDao) {
        this.platformDao = platformDao;
    }
    /*
	运营系统使用
	 */
    @Path("/createAccount")
    @Post
    public void createAccount(@JdbcConn(true) Connection con, String name, String email) throws SQLException {
        String id = StringUtil.buildUUID();
        PlatformUser platformUser = new PlatformUser();
        platformUser.setId(id);
        platformUser.setEmail(email);
        platformUser.setPasswd(StringUtil.md5("123456"));
        platformUser.setState("1");
        this.platformDao.insert(con, platformUser);
        PlatformInfo platformInfo = new PlatformInfo();
        platformInfo.setId(id);
        platformInfo.setName(name);
        this.platformDao.insert(con, platformInfo);
    }
    @Path("/updateAccount")
    @Post
    public void updateAccount(@JdbcConn(true) Connection con, String id, String name, String email) throws SQLException {
        this.platformDao.updateEmail(con, id, email);
        this.platformDao.updateName(con, id, name);
    }
    @Path("/createCheck")
    @Get
    public int createCheck(@JdbcConn Connection con, String name, String email) throws SQLException {
        PlatformUser platformUser = this.platformDao.queryUser(con, email);
        if (platformUser != null) {
            return 2;//该邮箱已被注册
        }
        PlatformInfo platformInfo = this.platformDao.queryInfoByName(con, name);
        if ((platformInfo != null) && (this.platformDao.queryUserById(con, platformInfo.getId()) != null)) {
            return 3;//该平台已注册帐号
        }
        return 1;//可以创建
    }
    @Path("/editCheck")
    @Get
    public int editCheck(@JdbcConn Connection con, String id, String name, String email) throws SQLException {
        PlatformUser platformUser = this.platformDao.queryUser(con, email);
        if ((platformUser != null)&&(!Objects.equals(platformUser.getId(), id))) {
            return 2;//该邮箱已被注册
        }
        PlatformInfo platformInfo = this.platformDao.queryInfoByName(con, name);
        if ((platformInfo != null) && (!Objects.equals(platformInfo.getId(), id))) {
            return 3;//该平台已注册帐号
        }
        return 1;
    }
    @Get
    @Path("/queryAccount/{id}")
    public Map<String, Object> queryAccount(@JdbcConn Connection con,@PathVar String id)throws SQLException {
        PlatformInfo platformInfo = this.platformDao.queryInfo(con, id);
        PlatformUser platformUser = this.platformDao.queryUserById(con, id);
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("id", id);
        map.put("email", platformUser.getEmail());
        map.put("name", platformInfo.getName());
        return map;
    }
}

src/main/java/com/ekexiu/portal/platform/PlatformDao.java

@@ -1,9 +1,5 @@
package com.ekexiu.portal.platform;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.Exclude;
@@ -28,6 +24,10 @@ import org.jfw.apt.orm.annotation.dao.param.SqlColumn;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
@DAO
public interface PlatformDao {
@@ -172,4 +172,24 @@ public interface PlatformDao {
	PageQueryResult<ButtedProfessorInfo> queryButtedProfessorInfo(Connection con,
			@SqlColumn(handlerClass = StringHandler.class, value = { "B.PID=?" }) String pid, int pageSize, int pageNo) throws SQLException;
	/*
	运营系统
	 */
	@Insert
	int insert(Connection con, PlatformInfo platformInfo) throws SQLException;
	@Insert
	int insert(Connection con, PlatformUser platformUser) throws SQLException;
	@UpdateWith
	@From(PlatformUser.class)
	int updateEmail(Connection con, String id, @Set String email) throws SQLException;
	@UpdateWith
	@From(PlatformInfo.class)
	int updateName(Connection con,String id,@Set String name)throws SQLException;
	@Nullable
	@SelectOne
	PlatformInfo queryInfoByName(Connection con, String name) throws SQLException;
}

src/main/java/com/ekexiu/portal/platform/PlatformInfo.java

@@ -3,6 +3,8 @@ package com.ekexiu.portal.platform;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.annotation.entry.Unique;
import org.jfw.apt.orm.annotation.entry.Uniques;
import org.jfw.apt.orm.core.defaultImpl.FixLenStringHandler;
import org.jfw.apt.orm.core.enums.DE;
@@ -11,6 +13,7 @@ import org.jfw.apt.orm.core.enums.DE;
 * @author Saga
 *
 */
@Uniques(@Unique(name="PLATFORMINFO_NAME_UN",clolumns="name"))
@PrimaryKey("id")
@Table
public class PlatformInfo {

src/main/resources/database.sql

@@ -2295,6 +2295,7 @@ CREATE TABLE PLATFORM_INFO (
	CREATE_TIME CHAR(14) NOT NULL,
	MODIFY_TIME CHAR(14) NOT NULL);
ALTER TABLE PLATFORM_INFO ADD PRIMARY KEY (ID);
ALTER TABLE PLATFORM_INFO ADD UNIQUE (name);
COMMENT ON TABLE PLATFORM_INFO is '平台信息表';
COMMENT ON COLUMN PLATFORM_INFO.NAME is '平台名称';