init

.gitignore

@@ -0,0 +1,4 @@
# Created by .ignore support plugin (hsz.mobi)
.idea
medical-share-console.iml
target

pom.xml

@@ -0,0 +1,84 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.ekexiu</groupId>
    <artifactId>medical-share-console</artifactId>
    <version>1.0-SNAPSHOT</version>
    <packaging>war</packaging>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.7</maven.compiler.source>
        <maven.compiler.target>1.7</maven.compiler.target>
        <maven.war.filteringDeploymentDescriptors>true</maven.war.filteringDeploymentDescriptors>
        <maven.tomcat.path>/</maven.tomcat.path>
    </properties>
    <dependencies>
    <dependency>
        <groupId>org.postgresql</groupId>
        <artifactId>postgresql</artifactId>
        <version>9.4.1207.jre7</version>
    </dependency>
    <dependency>
        <groupId>org.jfw</groupId>
        <artifactId>jfwApt</artifactId>
        <version>0.0.2-SNAPSHOT</version>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.jfw</groupId>
        <artifactId>jfwAptOrm</artifactId>
        <version>0.0.2-SNAPSHOT</version>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.jfw</groupId>
        <artifactId>jfwAptWeb</artifactId>
        <version>0.0.2-SNAPSHOT</version>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.jfw</groupId>
        <artifactId>jfwUtil</artifactId>
        <version>0.0.2-SNAPSHOT</version>
    </dependency>
    <dependency>
        <groupId>org.jfw</groupId>
        <artifactId>jfwWebUtil</artifactId>
        <version>0.0.2-SNAPSHOT</version>
    </dependency>
    <dependency>
        <groupId>javax.servlet</groupId>
        <artifactId>servlet-api</artifactId>
        <scope>provided</scope>
        <version>2.5</version>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid</artifactId>
        <version>1.0.20</version>
    </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.mortbay.jetty</groupId>
                <artifactId>jetty-maven-plugin</artifactId>
                <version>8.1.0.RC5</version>
                <configuration>
                    <stopPort>9966</stopPort>
                    <stopKey>foo</stopKey>
                    <webAppConfig>
                        <contextPath>/msconsole</contextPath>
                    </webAppConfig>
                </configuration>
            </plugin>
        </plugins>
        <finalName>msconsole</finalName>
    </build>
</project>

src/main/java/com/ekexiu/project/msconsole/base/po/BaseTable.java

@@ -0,0 +1,35 @@
package com.ekexiu.project.msconsole.base.po;
import org.jfw.apt.annotation.JfwAptConfig;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.VirtualTable;
import org.jfw.apt.orm.core.defaultImpl.FixLenStringHandler;
import org.jfw.apt.orm.core.enums.DE;
/**
 * Created by TT on 2019/5/30.
 */
@JfwAptConfig("DB:PostgreSQL")
@VirtualTable
public interface BaseTable {
    @Column(descp = "创建时间（YYYYMMDDHH24MISS）不可修改", handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", fixSqlValueWithInsert = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", insertable = true, nullable = false, queryable = true, renewable = false)
    String getCreateTime();
    void setCreateTime(String createTime);
    @Column(descp = "最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101", handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", fixSqlValueWithInsert = "'20000101010101'", fixSqlValueWithUpdate = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", insertable = true, nullable = false, queryable = true, renewable = true)
    String getModifyTime();
    void setModifyTime(String modifyTime);
    @Column(descp = "创建人ID", value = DE.id_32)
    String getCreator();
    void setCreator(String creator);
    @Column(descp = "最后修改人ID", value = DE.refid_32)
    String getModifier();
    void setModifier(String modifier);
}

src/main/java/com/ekexiu/project/msconsole/department/Department.java

@@ -0,0 +1,140 @@
package com.ekexiu.project.msconsole.department;
import com.ekexiu.project.msconsole.base.po.BaseTable;
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.core.enums.DE;
/**
 * Created by TT on 2019/5/30.
 */
@Table(descp = "科室",value = "DEPARTMENT")
@PrimaryKey("id")
public class Department implements BaseTable {
    private String id;
    private String hospital;
    private String name;
    private String type;
    private String phone;
    private String location;
    private String descp;
    private boolean active;
    private String createTime;
    private String modifyTime;
    private String creator;
    private String modifier;
    @Column(descp = "科室ID", value = DE.id_32)
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    @Column(descp = "所属医院ID", value = DE.id_32)
    public String getHospital() {
        return hospital;
    }
    public void setHospital(String hospital) {
        this.hospital = hospital;
    }
    @Column(descp = "科室名称", value = DE.text_de)
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    @Column(descp = "科室ID", value = DE.singleChar)
    public String getType() {
        return type;
    }
    public void setType(String type) {
        this.type = type;
    }
    @Column(descp = "科室电话", value = DE.Text_de)
    public String getPhone() {
        return phone;
    }
    public void setPhone(String phone) {
        this.phone = phone;
    }
    @Column(descp = "科室地址", value = DE.Text_de)
    public String getLocation() {
        return location;
    }
    public void setLocation(String location) {
        this.location = location;
    }
    @Column(descp = "科室简介", value = DE.Text_de)
    public String getDescp() {
        return descp;
    }
    public void setDescp(String descp) {
        this.descp = descp;
    }
    @Column(descp = "是否可用", value = DE.boolean_de)
    public boolean isActive() {
        return active;
    }
    public void setActive(boolean active) {
        this.active = active;
    }
    @Override
    public String getCreateTime() {
        return createTime;
    }
    @Override
    public void setCreateTime(String createTime) {
        this.createTime = createTime;
    }
    @Override
    public String getModifyTime() {
        return modifyTime;
    }
    @Override
    public void setModifyTime(String modifyTime) {
        this.modifyTime = modifyTime;
    }
    @Override
    public String getCreator() {
        return creator;
    }
    @Override
    public void setCreator(String creator) {
        this.creator = creator;
    }
    @Override
    public String getModifier() {
        return modifier;
    }
    @Override
    public void setModifier(String modifier) {
        this.modifier = modifier;
    }
}

src/main/java/com/ekexiu/project/msconsole/department/DepartmentDao.java

@@ -0,0 +1,52 @@
package com.ekexiu.project.msconsole.department;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.Exclude;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.PageSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.Update;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Like;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
/**
 * Created by TT on 2019/5/30.
 */
@DAO
public interface DepartmentDao {
    @Insert
    int insert(Connection con, Department department) throws SQLException;
    @Update
    @Exclude({"active"})
    int update(Connection con, Department department) throws SQLException;
    @UpdateWith
    @From(Department.class)
    @Where("ACTIVE ='1'")
    @SetSentence("ACTIVE ='0'")
    int ban(Connection con, String id, @Set String modifier) throws SQLException;
    @Nullable
    @SelectOne
    Department query(Connection con, String id) throws SQLException;
    @PageSelect
    @OrderBy("ORDER BY CREATE_TIME DESC")
    PageQueryResult<Department> pageQuery(Connection con,String hospital, @Nullable Boolean active, @Nullable @Like String name, int pageSize, int pageNo) throws SQLException;
    @Nullable
    @SelectOne
    Department queryByName(Connection con,String hospital, String name) throws SQLException;
}

src/main/java/com/ekexiu/project/msconsole/department/DepartmentService.java

@@ -0,0 +1,78 @@
package com.ekexiu.project.msconsole.department;
import com.ekexiu.project.msconsole.system.vo.SessionUser;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.LoginUser;
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.util.PageQueryResult;
import org.jfw.util.StringUtil;
import java.sql.Connection;
import java.sql.SQLException;
/**
 * Created by TT on 2019/5/30.
 */
@Path("/department")
public class DepartmentService {
    @Autowrie
    private DepartmentDao departmentDao;
    public DepartmentDao getDepartmentDao() {
        return departmentDao;
    }
    public void setDepartmentDao(DepartmentDao departmentDao) {
        this.departmentDao = departmentDao;
    }
    @Path
    @Post
    public String insert(@JdbcConn(true) Connection con, @LoginUser SessionUser sessionUser, Department department) throws SQLException {
        String id = StringUtil.buildUUID();
        department.setId(id);
        department.setActive(true);
        department.setHospital(sessionUser.getId());
        department.setCreator(sessionUser.getId());
        department.setModifier(sessionUser.getId());
        departmentDao.insert(con, department);
        return id;
    }
    @Path("/update")
    @Post
    public void update(@JdbcConn(true) Connection con, @LoginUser SessionUser sessionUser, Department department) throws SQLException {
        department.setModifier(sessionUser.getId());
        departmentDao.update(con, department);
    }
    @Path("/qo")
    @Get
    public Department query(@JdbcConn Connection con, String id) throws SQLException {
        return departmentDao.query(con, id);
    }
    @Path("/ban")
    @Get
    public void ban(@JdbcConn(true) Connection con, String id, @LoginUser SessionUser sessionUser) throws SQLException {
        departmentDao.ban(con, id, sessionUser.getId());
    }
    @Path("/pq")
    @Get
    public PageQueryResult<Department> pageQuery(@JdbcConn Connection con,@LoginUser SessionUser user, @Nullable Boolean active, @Nullable String name, int pageSize, int pageNo) throws SQLException {
        return departmentDao.pageQuery(con,user.getId(), active, name == null ? null : "%" + name + "%", pageSize, pageNo);
    }
    @Path("/checkName")
    @Get
    public Department queryByName(@JdbcConn Connection con,@LoginUser SessionUser user, String name)throws SQLException {
        return departmentDao.queryByName(con, user.getId(), name);
    }
}

src/main/java/com/ekexiu/project/msconsole/doctor/Doctor.java

@@ -0,0 +1,194 @@
package com.ekexiu.project.msconsole.doctor;
import com.ekexiu.project.msconsole.base.po.BaseTable;
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.StringHandler;
import org.jfw.apt.orm.core.enums.DE;
/**
 * Created by TT on 2019/5/30.
 */
@Table(descp = "医生", value = "DOCTOR")
@PrimaryKey("id")
@Uniques({@Unique(clolumns = "account", name = "UC_DOCTOR_ACCOUNT")})
public class Doctor implements BaseTable {
    private String id;
    private String hospital;
    private String department;
    private String account;
    private String name;
    private String clinicalTitle;
    private String teachTitle;
    private String position;
    private String direction;
    private String image;
    private String descp;
    private boolean active;
    private String passwd;
    private String createTime;
    private String modifyTime;
    private String creator;
    private String modifier;
    @Column(descp = "医生ID", value = DE.id_32)
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    @Column(descp = "医院ID", value = DE.id_32)
    public String getHospital() {
        return hospital;
    }
    public void setHospital(String hospital) {
        this.hospital = hospital;
    }
    @Column(descp = "医院ID", value = DE.REFID_32)
    public String getDepartment() {
        return department;
    }
    public void setDepartment(String department) {
        this.department = department;
    }
    @Column(descp = "帐号", value = DE.text_de)
    public String getAccount() {
        return account;
    }
    public void setAccount(String account) {
        this.account = account;
    }
    @Column(descp = "医生姓名", value = DE.text_de)
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    @Column(descp = "临床职称", value = DE.Text_de)
    public String getClinicalTitle() {
        return clinicalTitle;
    }
    public void setClinicalTitle(String clinicalTitle) {
        this.clinicalTitle = clinicalTitle;
    }
    @Column(descp = "教学职称", value = DE.Text_de)
    public String getTeachTitle() {
        return teachTitle;
    }
    public void setTeachTitle(String teachTitle) {
        this.teachTitle = teachTitle;
    }
    @Column(descp = "行政职务", value = DE.Text_de)
    public String getPosition() {
        return position;
    }
    public void setPosition(String position) {
        this.position = position;
    }
    @Column(descp = "擅长方向", value = DE.Text_de)
    public String getDirection() {
        return direction;
    }
    public void setDirection(String direction) {
        this.direction = direction;
    }
    @Column(descp = "图片", value = DE.String_de)
    public String getImage() {
        return image;
    }
    public void setImage(String image) {
        this.image = image;
    }
    @Column(descp = "个人简介", value = DE.Text_de)
    public String getDescp() {
        return descp;
    }
    public void setDescp(String descp) {
        this.descp = descp;
    }
    @Column(descp = "是否可用", value = DE.boolean_de)
    public boolean isActive() {
        return active;
    }
    public void setActive(boolean active) {
        this.active = active;
    }
    @Column(descp = "密码(MD5)", queryable = false, handlerClass = StringHandler.class, dbType = "TEXT")
    public String getPasswd() {
        return passwd;
    }
    public void setPasswd(String passwd) {
        this.passwd = passwd;
    }
    @Override
    public String getCreateTime() {
        return createTime;
    }
    @Override
    public void setCreateTime(String createTime) {
        this.createTime = createTime;
    }
    @Override
    public String getModifyTime() {
        return modifyTime;
    }
    @Override
    public void setModifyTime(String modifyTime) {
        this.modifyTime = modifyTime;
    }
    @Override
    public String getCreator() {
        return creator;
    }
    @Override
    public void setCreator(String creator) {
        this.creator = creator;
    }
    @Override
    public String getModifier() {
        return modifier;
    }
    @Override
    public void setModifier(String modifier) {
        this.modifier = modifier;
    }
}

src/main/java/com/ekexiu/project/msconsole/doctor/DoctorDao.java

@@ -0,0 +1,54 @@
package com.ekexiu.project.msconsole.doctor;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.Exclude;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.PageSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.Update;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Like;
import org.jfw.apt.orm.annotation.dao.param.Set;
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;
/**
 * Created by TT on 2019/5/30.
 */
@DAO
public interface DoctorDao {
    @Insert
    int insert(Connection con, Doctor doctor) throws SQLException;
    @Update
    @Exclude({"active", "passwd"})
    int update(Connection con, Doctor doctor) throws SQLException;
    @UpdateWith
    @From(Doctor.class)
    @Where("ACTIVE ='1'")
    @SetSentence("ACTIVE ='0'")
    int ban(Connection con, String id, @Set String modifier) throws SQLException;
    @SelectOne
    @Nullable
    Doctor query(Connection con, String id) throws SQLException;
    @PageSelect
    @OrderBy("ORDER BY CREATE_TIME DESC")
    PageQueryResult<Doctor> pageQuery(Connection con, String hospital, @Nullable boolean active, @Nullable @Like String name, @Nullable @SqlColumn(handlerClass = StringHandler.class, value = "ID IN (SELECT ID FROM DEPARTMENT WHERE NAME LIKE ?)") String department, int pageSize, int pageNo) throws SQLException;
    @Nullable
    @SelectOne
    Doctor queryByAccount(Connection con, String account) throws SQLException;
}

src/main/java/com/ekexiu/project/msconsole/doctor/DoctorService.java

@@ -0,0 +1,80 @@
package com.ekexiu.project.msconsole.doctor;
import com.ekexiu.project.msconsole.system.vo.SessionUser;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.LoginUser;
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.util.PageQueryResult;
import org.jfw.util.StringUtil;
import java.sql.Connection;
import java.sql.SQLException;
/**
 * Created by TT on 2019/5/30.
 */
@Path("/doctor")
public class DoctorService {
    @Autowrie
    private DoctorDao doctorDao;
    public DoctorDao getDoctorDao() {
        return doctorDao;
    }
    public void setDoctorDao(DoctorDao doctorDao) {
        this.doctorDao = doctorDao;
    }
    @Post
    @Path
    public String insert(@JdbcConn(true)Connection con, @LoginUser SessionUser user,Doctor doctor)throws SQLException {
        String id = StringUtil.buildUUID();
        doctor.setId(id);
        doctor.setActive(true);
        doctor.setCreator(user.getId());
        doctor.setModifier(user.getId());
        doctor.setHospital(user.getId());
        doctorDao.insert(con, doctor);
        return id;
    }
    @Post
    @Path("/update")
    public void update(@JdbcConn(true)Connection con,@LoginUser SessionUser user,Doctor doctor)throws SQLException {
        doctor.setModifier(user.getId());
        doctorDao.update(con, doctor);
    }
    @Get
    @Path("/qo")
    public Doctor query(@JdbcConn Connection con,String id)throws SQLException {
        return doctorDao.query(con, id);
    }
    @Get
    @Path("/pq")
    public PageQueryResult<Doctor> pageQuery(@JdbcConn Connection con, String hospital, @Nullable Boolean active,@Nullable String name,@Nullable String department,int pageSize,int pageNo)throws SQLException {
        return doctorDao.pageQuery(con, hospital, active, name == null ? null : "%" + name + "%", department == null ? null : "%" + department + "%", pageSize, pageNo);
    }
    @Get
    @Path("/ban")
    public void ban(@JdbcConn(true)Connection con,@LoginUser SessionUser user, String id)throws SQLException {
        doctorDao.ban(con, id, user.getId());
    }
    @Get
    @Path("/check")
    public Doctor queryByAccount(@JdbcConn Connection con,String account)throws SQLException {
        return doctorDao.queryByAccount(con, account);
    }
}

src/main/java/com/ekexiu/project/msconsole/instrument/Instrument.java

@@ -0,0 +1,160 @@
package com.ekexiu.project.msconsole.instrument;
import com.ekexiu.project.msconsole.base.po.BaseTable;
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.core.enums.DE;
/**
 * Created by TT on 2019/5/30.
 */
@Table(descp = "器械表", value = "INSTRUMENT")
@PrimaryKey("id")
public class Instrument implements BaseTable {
    private String id;
    private String name;
    private String status;
    private String department;
    private String hospital;
    private String spec;
    private String application;
    private String descp;
    private String image;
    private boolean active;
    private String createTime;
    private String modifyTime;
    private String creator;
    private String modifier;
    @Column(descp = "器械ID", value = DE.id_32)
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    @Column(descp = "器械名称", value = DE.text_de)
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    @Column(descp = "器械状态", value = DE.singleChar)
    public String getStatus() {
        return status;
    }
    public void setStatus(String status) {
        this.status = status;
    }
    @Column(descp = "所属科室", value = DE.REFID_32)
    public String getDepartment() {
        return department;
    }
    public void setDepartment(String department) {
        this.department = department;
    }
    @Column(descp = "所属医院", value = DE.id_32)
    public String getHospital() {
        return hospital;
    }
    public void setHospital(String hospital) {
        this.hospital = hospital;
    }
    @Column(descp = "厂商型号", value = DE.Text_de)
    public String getSpec() {
        return spec;
    }
    public void setSpec(String spec) {
        this.spec = spec;
    }
    @Column(descp = "功能用途", value = DE.Text_de)
    public String getApplication() {
        return application;
    }
    public void setApplication(String application) {
        this.application = application;
    }
    @Column(descp = "器械简介", value = DE.Text_de)
    public String getDescp() {
        return descp;
    }
    public void setDescp(String descp) {
        this.descp = descp;
    }
    @Column(descp = "器械图片", value = DE.Text_de)
    public String getImage() {
        return image;
    }
    public void setImage(String image) {
        this.image = image;
    }
    @Column(descp = "是否可用", value = DE.boolean_de)
    public boolean isActive() {
        return active;
    }
    public void setActive(boolean active) {
        this.active = active;
    }
    @Override
    public String getCreateTime() {
        return createTime;
    }
    @Override
    public void setCreateTime(String createTime) {
        this.createTime = createTime;
    }
    @Override
    public String getModifyTime() {
        return modifyTime;
    }
    @Override
    public void setModifyTime(String modifyTime) {
        this.modifyTime = modifyTime;
    }
    @Override
    public String getCreator() {
        return creator;
    }
    @Override
    public void setCreator(String creator) {
        this.creator = creator;
    }
    @Override
    public String getModifier() {
        return modifier;
    }
    @Override
    public void setModifier(String modifier) {
        this.modifier = modifier;
    }
}

src/main/java/com/ekexiu/project/msconsole/instrument/InstrumentDao.java

@@ -0,0 +1,48 @@
package com.ekexiu.project.msconsole.instrument;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.Exclude;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.PageSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.Update;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Like;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
/**
 * Created by TT on 2019/5/30.
 */
@DAO
public interface InstrumentDao {
    @Insert
    int insert(Connection con, Instrument instrument) throws SQLException;
    @Update
    @Exclude({"active"})
    int update(Connection con, Instrument instrument) throws SQLException;
    @UpdateWith
    @From(Instrument.class)
    @Where("ACTIVE ='1'")
    @SetSentence("ACTIVE ='0'")
    int ban(Connection con, String id, @Set String modifier) throws SQLException;
    @Nullable
    @SelectOne
    Instrument query(Connection con, String id) throws SQLException;
    @PageSelect
    @OrderBy("ORDER BY CREATE_TIME DESC")
    PageQueryResult<Instrument> pageQuery(Connection con, String hospital, @Nullable Boolean active, @Nullable @Like String name, @Nullable String status, int pageSize, int pageNo) throws SQLException;
}

src/main/java/com/ekexiu/project/msconsole/instrument/InstrumentService.java

@@ -0,0 +1,72 @@
package com.ekexiu.project.msconsole.instrument;
import com.ekexiu.project.msconsole.system.vo.SessionUser;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.LoginUser;
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.util.PageQueryResult;
import org.jfw.util.StringUtil;
import java.sql.Connection;
import java.sql.SQLException;
/**
 * Created by TT on 2019/5/30.
 */
@Path("/instrument")
public class InstrumentService {
    @Autowrie
    private InstrumentDao instrumentDao;
    public InstrumentDao getInstrumentDao() {
        return instrumentDao;
    }
    public void setInstrumentDao(InstrumentDao instrumentDao) {
        this.instrumentDao = instrumentDao;
    }
    @Path
    @Post
    public String insert(@JdbcConn(true) Connection con, @LoginUser SessionUser sessionUser, Instrument instrument) throws SQLException {
        String id = StringUtil.buildUUID();
        instrument.setId(id);
        instrument.setActive(true);
        instrument.setHospital(sessionUser.getId());
        instrument.setCreator(sessionUser.getId());
        instrument.setModifier(sessionUser.getId());
        instrumentDao.insert(con, instrument);
        return id;
    }
    @Path("/update")
    @Post
    public void update(@JdbcConn(true) Connection con, @LoginUser SessionUser sessionUser, Instrument instrument) throws SQLException {
        instrument.setModifier(sessionUser.getId());
        instrumentDao.update(con, instrument);
    }
    @Path("/qo")
    @Get
    public Instrument query(@JdbcConn Connection con, String id) throws SQLException {
        return instrumentDao.query(con, id);
    }
    @Path("/ban")
    @Get
    public void ban(@JdbcConn(true) Connection con, String id, @LoginUser SessionUser sessionUser) throws SQLException {
        instrumentDao.ban(con, id, sessionUser.getId());
    }
    @Path("/pq")
    @Get
    public PageQueryResult<Instrument> pageQuery(@JdbcConn Connection con, @LoginUser SessionUser user, @Nullable Boolean active, @Nullable String name, @Nullable String status, int pageSize, int pageNo) throws SQLException {
        return instrumentDao.pageQuery(con, user.getId(), active, name == null ? null : "%" + name + "%", status, pageSize, pageNo);
    }
}

src/main/java/com/ekexiu/project/msconsole/system/dao/DictDao.java

@@ -0,0 +1,45 @@
package com.ekexiu.project.msconsole.system.dao;
import com.ekexiu.project.msconsole.system.po.DictItem;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.IncludeFixSet;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Set;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
/**
 * Created by TT on 2019/5/30.
 */
@DAO
public interface DictDao {
    @SelectList
    List<DictItem> query(Connection con) throws SQLException;
    @Insert
    int insert(Connection con, DictItem dict) throws SQLException;
    @UpdateWith
    @From(DictItem.class)
    @Where("ACTIVE = '1' AND READONLY <> '1'")
    @SetSentence("ACTIVE='0'")
    @IncludeFixSet
    int disable(Connection con, String dictCode, String code) throws SQLException;
    @UpdateWith
    @From(DictItem.class)
    @Where("ACTIVE = '1' AND READONLY <> '1'")
    int update(Connection con, @Nullable @Set String bcode, @Set String caption, @Nullable @Set String fullCaption, @Set @Nullable String shortCut,
               @Nullable @Set String remark, String code, String dictCode) throws SQLException;
}

src/main/java/com/ekexiu/project/msconsole/system/dao/HospitalDao.java

@@ -0,0 +1,63 @@
package com.ekexiu.project.msconsole.system.dao;
import com.ekexiu.project.msconsole.system.po.Hospital;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.Exclude;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.PageSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.Update;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Like;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.apt.orm.annotation.dao.param.UnEquals;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
/**
 * Created by TT on 2019/5/30.
 */
@DAO
public interface HospitalDao {
    @Insert
    int insert(Connection con, Hospital hospital) throws SQLException;
    @Nullable
    @SelectOne
    Hospital query(Connection con, String id) throws SQLException;
    @Update
    @Exclude({"passwd", "active", "account"})
    int update(Connection con, Hospital hospital) throws SQLException;
    @Nullable
    @SelectOne
    Hospital login(Connection con, String account, String passwd) throws SQLException;
    @Nullable
    @SelectOne
    Hospital queryByAccount(Connection con, String account, @Nullable @UnEquals String id) throws SQLException;
    @UpdateWith
    @From(Hospital.class)
    @Where("ACTIVE ='1'")
    @SetSentence("ACTIVE ='0'")
    int ban(Connection con, String id, @Set String modifier) throws SQLException;
    @UpdateWith
    @From(Hospital.class)
    int changePw(Connection con, @Set String passwd, String id) throws SQLException;
    @PageSelect
    @OrderBy("ORDER BY CREATE_TIME DESC")
    PageQueryResult<Hospital> pageQuery(Connection con, @Nullable Boolean active, @Nullable String level, @Nullable String subLevel, @Nullable String type, @Nullable @Like String name, int pageSize,
                                        int pageNo) throws SQLException;
}

src/main/java/com/ekexiu/project/msconsole/system/po/DictItem.java

@@ -0,0 +1,106 @@
package com.ekexiu.project.msconsole.system.po;
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.core.enums.DE;
/**
 * Created by TT on 2019/5/30.
 */
@PrimaryKey({"dictCode", "code"})
@Table(descp = "数据字典表", value = "SYS_DICT")
public class DictItem {
    private String code;
    private String dictCode;
    private String bcode;
    private String caption;
    private String fullCaption;
    private String shortCut;
    private String remark;
    private boolean readonly;
    private boolean active;
    @Column(descp = "字典项编码", value = DE.rtext_de)
    public String getCode() {
        return code;
    }
    public void setCode(String code) {
        this.code = code;
    }
    @Column(descp = "字典项编码(业务编码)", value = DE.Text_de)
    public String getBcode() {
        return bcode;
    }
    public void setBcode(String bcode) {
        this.bcode = bcode;
    }
    @Column(descp = "字典编码", value = DE.rtext_de)
    public String getDictCode() {
        return dictCode;
    }
    public void setDictCode(String dictCode) {
        this.dictCode = dictCode;
    }
    @Column(descp = "字典项显示", value = DE.text_de)
    public String getCaption() {
        return caption;
    }
    public void setCaption(String caption) {
        this.caption = caption;
    }
    @Column(descp = "字典项显示(全)", value = DE.Text_de)
    public String getFullCaption() {
        return fullCaption;
    }
    public void setFullCaption(String fullCaption) {
        this.fullCaption = fullCaption;
    }
    @Column(descp = "助记码", value = DE.Text_de)
    public String getShortCut() {
        return shortCut;
    }
    public void setShortCut(String shortCut) {
        this.shortCut = shortCut;
    }
    @Column(descp = "备注", value = DE.Text_de)
    public String getRemark() {
        return remark;
    }
    public void setRemark(String remark) {
        this.remark = remark;
    }
    @Column(descp = "是否只读", value = DE.boolean_de)
    public boolean isReadonly() {
        return readonly;
    }
    public void setReadonly(boolean readonly) {
        this.readonly = readonly;
    }
    @Column(descp = "是否有效", value = DE.boolean_de)
    public boolean isActive() {
        return active;
    }
    public void setActive(boolean active) {
        this.active = active;
    }
}

src/main/java/com/ekexiu/project/msconsole/system/po/Hospital.java

@@ -0,0 +1,197 @@
package com.ekexiu.project.msconsole.system.po;
import com.ekexiu.project.msconsole.base.po.BaseTable;
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.StringHandler;
import org.jfw.apt.orm.core.enums.DE;
/**
 * Created by TT on 2019/5/30.
 */
@Table(descp = "医院登录表", value = "HOSPITAL")
@PrimaryKey("id")
@Uniques({@Unique(clolumns = "account", name = "UC_HOSPITAL_ACCOUNT")})
public class Hospital implements BaseTable {
    private String id;
    private String passwd;
    private String account;
    private String name;
    private String level;
    private String subLevel;
    private String type;
    private String phone;
    private String location;
    private String addr;
    private String descp;
    private String image;
    private boolean active;
    private String createTime;
    private String modifyTime;
    private String creator;
    private String modifier;
    @Column(descp = "医院ID", value = DE.id_32)
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    @Column(descp = "密码(MD5)", queryable = false, handlerClass = StringHandler.class, dbType = "TEXT")
    public String getPasswd() {
        return passwd;
    }
    public void setPasswd(String passwd) {
        this.passwd = passwd;
    }
    @Column(descp = "医院帐号", value = DE.text_de)
    public String getAccount() {
        return account;
    }
    public void setAccount(String account) {
        this.account = account;
    }
    @Column(descp = "医院名称", value = DE.text_de)
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    @Column(descp = "医院级别", value = DE.singleChar)
    public String getLevel() {
        return level;
    }
    public void setLevel(String level) {
        this.level = level;
    }
    @Column(descp = "医院子级别", value = DE.singleChar)
    public String getSubLevel() {
        return subLevel;
    }
    public void setSubLevel(String subLevel) {
        this.subLevel = subLevel;
    }
    @Column(descp = "医院类型", value = DE.singleChar)
    public String getType() {
        return type;
    }
    public void setType(String type) {
        this.type = type;
    }
    @Column(descp = "电话", value = DE.Text_de)
    public String getPhone() {
        return phone;
    }
    public void setPhone(String phone) {
        this.phone = phone;
    }
    @Column(descp = "医院详细地址", value = DE.Text_de)
    public String getLocation() {
        return location;
    }
    public void setLocation(String location) {
        this.location = location;
    }
    @Column(descp = "医院所在城市编码", value = DE.String_de)
    public String getAddr() {
        return addr;
    }
    public void setAddr(String addr) {
        this.addr = addr;
    }
    @Column(descp = "医院简介", value = DE.Text_de)
    public String getDescp() {
        return descp;
    }
    public void setDescp(String descp) {
        this.descp = descp;
    }
    @Column(descp = "医院图片", value = DE.Text_de)
    public String getImage() {
        return image;
    }
    public void setImage(String image) {
        this.image = image;
    }
    @Column(descp = "是否可用", value = DE.boolean_de)
    public boolean isActive() {
        return active;
    }
    public void setActive(boolean active) {
        this.active = active;
    }
    @Override
    public String getCreateTime() {
        return createTime;
    }
    @Override
    public void setCreateTime(String createTime) {
        this.createTime = createTime;
    }
    @Override
    public String getModifyTime() {
        return modifyTime;
    }
    @Override
    public void setModifyTime(String modifyTime) {
        this.modifyTime = modifyTime;
    }
    @Override
    public String getCreator() {
        return creator;
    }
    @Override
    public void setCreator(String creator) {
        this.creator = creator;
    }
    @Override
    public String getModifier() {
        return modifier;
    }
    @Override
    public void setModifier(String modifier) {
        this.modifier = modifier;
    }
}

src/main/java/com/ekexiu/project/msconsole/system/service/CommonUtilService.java

@@ -0,0 +1,277 @@
package com.ekexiu.project.msconsole.system.service;
import com.ekexiu.project.msconsole.system.vo.UploadFile;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.Upload;
import org.jfw.util.io.IoUtil;
import org.jfw.util.web.fileupload.Item;
import org.jfw.util.web.fileupload.UploadItemIterator;
import javax.imageio.ImageIO;
import java.awt.*;
import java.awt.image.BufferedImage;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.concurrent.atomic.AtomicInteger;
@Path
public class CommonUtilService {
    public String rootPath;
    public static final String JPG = "jpg";
    private static final AtomicInteger HOSPITAL_FN_IND = new AtomicInteger(1);
    private File hospitalPath;
    private static final AtomicInteger DOCTOR_FN_IDX = new AtomicInteger(1);
    private File doctorPath;
    private static final AtomicInteger INSTRUMENT_FN_IDX = new AtomicInteger(1);
    private File instrumentPath;
    private int headMaxHeight = Integer.MAX_VALUE;
    public String getRootPath() {
        return rootPath;
    }
    public void setRootPath(String rootPath) {
        this.rootPath = rootPath;
    }
    public File getDoctorPath() {
        return doctorPath;
    }
    public void setDoctorPath(File doctorPath) {
        this.doctorPath = doctorPath;
    }
    public File getHospitalPath() {
        return hospitalPath;
    }
    public void setHospitalPath(File hospitalPath) {
        this.hospitalPath = hospitalPath;
    }
    public File getInstrumentPath() {
        return instrumentPath;
    }
    public void setInstrumentPath(File instrumentPath) {
        this.instrumentPath = instrumentPath;
    }
    public int getHeadMaxHeight() {
        return headMaxHeight;
    }
    public void setHeadMaxHeight(int headMaxHeight) {
        this.headMaxHeight = headMaxHeight;
    }
    private String normalizeFileName(String fn) {
        int index = fn.indexOf('\\');
        if (index >= 0) {
            fn = fn.substring(fn.lastIndexOf('\\') + 1);
        }
        index = fn.indexOf('/');
        if (index >= 0) {
            fn = fn.substring(fn.lastIndexOf('/') + 1);
        }
        if (fn.length() == 0)
            throw new RuntimeException("invalid filename in Multipart/data request");
        return fn;
    }
    private UploadFile buildTargetFile(File parentPath, AtomicInteger FN_IDX, String ext) {
        StringBuilder sb = new StringBuilder();
        sb.append("/").append(System.currentTimeMillis() / (1000 * 60 * 60 * 24));
        File path = new File(parentPath, sb.toString());
        if (!path.exists()) {
            synchronized (this) {
                if (!path.mkdirs())
                    throw new RuntimeException("mkdir error[" + path + "]");
                FN_IDX.set(1);
            }
        }
        File file;
        do {
            String fn = FN_IDX.toString();
            if (ext.isEmpty()) {
                file = new File(path, fn);
            } else {
                file = new File(path, fn + "." + ext);
            }
            FN_IDX.incrementAndGet();
        } while (file.exists());
        sb.append("/").append(file.getName());
        UploadFile uf = new UploadFile();
        uf.setFn(file);
        uf.setUri(sb.toString());
        return uf;
    }
    private void saveHeadPhoto(InputStream in, UploadFile file) throws IOException {
        byte[] buf = new byte[8092];
        int w, h, sx1, sx2, sy1, sy2;
        int len;
        ByteArrayOutputStream of = new ByteArrayOutputStream();
        while ((len = in.read(buf)) >= 0) {
            if (len > 0) {
                of.write(buf, 0, len);
            }
        }
        BufferedImage im = ImageIO.read(in);
        if (im == null) {
            throw new IOException("unsupported image type");
        }
        sx1 = 0;
        sy1 = 0;
        sx2 = w = im.getWidth();
        sy2 = h = im.getHeight();
        if (w > h) {
            sx1 = (w - h) / 2;
            sx2 = sx1 + h;
            w = h;
        } else if (w < h) {
            sy1 = (h - w) / 2;
            sy2 = sy1 + w;
            h = w;
        }
        if (h > this.headMaxHeight) {
            w = h = this.headMaxHeight;
        }
        BufferedImage newBufferedImage = new BufferedImage(w, h, BufferedImage.TYPE_INT_RGB);
        newBufferedImage.createGraphics().drawImage(im, 0, 0, w, h, sx1, sy1, sx2, sy2, Color.WHITE, null);
        OutputStream fos = new FileOutputStream(file.getFn());
        try {
            ImageIO.write(newBufferedImage, JPG, fos);
            fos.flush();
            file.setSize(file.getFn().length());
        } finally {
            IoUtil.close(fos);
        }
    }
    @Post
    @Path("/hospitalPath/logo")
    public UploadFile logoUpload(@Upload UploadItemIterator it) throws IOException {
        UploadFile uf = null;
        try {
            while (it.hasNext()) {
                Item item = it.next();
                if (!item.isFormField()) {
                    String name = normalizeFileName(item.getName());
                    int index = name.lastIndexOf('.');
                    String ext = index >= 0 ? name.substring(index + 1) : "";
                    ext = ext.trim();
                    uf = buildTargetFile(this.hospitalPath,HOSPITAL_FN_IND , ext);
                    uf.setName(name);
                    InputStream in = item.getInputStream();
                    try {
                        OutputStream fos = new FileOutputStream(uf.getFn());
                        try {
                            IoUtil.copy(in, fos, false, false);
                            fos.flush();
                        } finally {
                            fos.close();
                        }
                        uf.setUri(rootPath + "/data/hospital/logo" + uf.getUri());
                        return uf;
                    } finally {
                        in.close();
                    }
                }
            }
        } finally {
            if (it != null)
                it.clean();
        }
        return uf;
    }
    @Post
    @Path("/doctor/image")
    public UploadFile articleImageUpload(@Upload UploadItemIterator it) throws IOException {
        UploadFile uf = null;
        try {
            while (it.hasNext()) {
                Item item = it.next();
                if (!item.isFormField()) {
                    String name = normalizeFileName(item.getName());
                    int index = name.lastIndexOf('.');
                    String ext = index >= 0 ? name.substring(index + 1) : "";
                    ext = ext.trim();
                    uf = buildTargetFile(this.doctorPath, DOCTOR_FN_IDX, ext);
                    uf.setName(name);
                    InputStream in = item.getInputStream();
                    try {
                        OutputStream fos = new FileOutputStream(uf.getFn());
                        try {
                            IoUtil.copy(in, fos, false, false);
                            fos.flush();
                        } finally {
                            fos.close();
                        }
                        uf.setUri(rootPath + "/data/doctor/logo" + uf.getUri());
                        return uf;
                    } finally {
                        in.close();
                    }
                }
            }
        } finally {
            if (it != null)
                it.clean();
        }
        return uf;
    }
    @Post
    @Path("/instrument/logo")
    public UploadFile productImageUpload(@Upload UploadItemIterator it) throws IOException {
        UploadFile uf = null;
        try {
            while (it.hasNext()) {
                Item item = it.next();
                if (!item.isFormField()) {
                    String name = normalizeFileName(item.getName());
                    int index = name.lastIndexOf('.');
                    String ext = index >= 0 ? name.substring(index + 1) : "";
                    ext = ext.trim();
                    uf = buildTargetFile(this.instrumentPath, INSTRUMENT_FN_IDX, ext);
                    uf.setName(name);
                    InputStream in = item.getInputStream();
                    try {
                        OutputStream fos = new FileOutputStream(uf.getFn());
                        try {
                            IoUtil.copy(in, fos, false, false);
                            fos.flush();
                        } finally {
                            fos.close();
                        }
                        uf.setUri(rootPath + "/data/instrument/logo" + uf.getUri());
                        return uf;
                    } finally {
                        in.close();
                    }
                }
            }
        } finally {
            if (it != null)
                it.clean();
        }
        return uf;
    }
}

src/main/java/com/ekexiu/project/msconsole/system/service/SysService.java

@@ -0,0 +1,161 @@
package com.ekexiu.project.msconsole.system.service;
import com.ekexiu.project.msconsole.system.dao.HospitalDao;
import com.ekexiu.project.msconsole.system.po.Hospital;
import com.ekexiu.project.msconsole.system.vo.SessionUser;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.LoginUser;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.method.InvalidSession;
import org.jfw.apt.web.annotation.method.SetSession;
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.util.PageQueryResult;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
/**
 * Created by TT on 2019/5/30.
 */
@Path("/sys")
public class SysService {
    public static final String DEFAULT_PW_STR = StringUtil.md5("123456");
    @Autowrie
    private HospitalDao hospitalDao;
    public HospitalDao getHospitalDao() {
        return hospitalDao;
    }
    public void setHospitalDao(HospitalDao hospitalDao) {
        this.hospitalDao = hospitalDao;
    }
    public static String getDefaultPwStr() {
        return DEFAULT_PW_STR;
    }
    @SetSession("/JFW_SESSION_LOGIN_USER=result")
    @Path("/login")
    @Post
    public SessionUser login(@JdbcConn Connection con, String account, String pw) throws SQLException, JfwBaseException {
        Hospital hospital = hospitalDao.login(con, account, pw);
        if (hospital != null) {
            if (!hospital.isActive()) {
                throw new JfwBaseException(-60005, "hospital is disabled");
            }
            return makeSessionUser(hospital);
        }
        return null;
    }
    @InvalidSession
    @Path("/logout")
    @Get
    public void logout() {
    }
    @Path("/user")
    @Get
    public SessionUser get(@LoginUser SessionUser user) {
        return user;
    }
    @Path("/insert")
    @Post
    public String insert(@JdbcConn(true) Connection con, @LoginUser SessionUser sessionUser, Hospital hospital) throws SQLException {
        String id = StringUtil.buildUUID();
        String account;
        for (; ; ) {
            double random = ((Math.random() * 9 + 1) * 100000);
            account = Double.toString(random);
            Hospital hospital1 = hospitalDao.queryByAccount(con, account, id);
            if (hospital1 == null) {
                break;
            }
        }
        hospital.setId(id);
        hospital.setAccount(account);
        hospital.setActive(true);
        hospital.setPasswd(DEFAULT_PW_STR);
        hospital.setCreator(sessionUser.getId());
        hospital.setModifier(sessionUser.getId());
        hospitalDao.insert(con, hospital);
        return id;
    }
    @Path("/qo")
    @Get
    public SessionUser query(@JdbcConn Connection con, String id) throws SQLException {
        return makeSessionUser(hospitalDao.query(con, id));
    }
    @Path("/update")
    @Post
    public void update(@JdbcConn(true) Connection con, @LoginUser SessionUser sessionUser, Hospital hospital) throws SQLException {
        hospital.setModifier(sessionUser.getId());
        hospitalDao.update(con, hospital);
    }
    @Path("/ban")
    @Get
    public void ban(@JdbcConn(true) Connection con, @LoginUser SessionUser sessionUser, String id) throws SQLException {
        hospitalDao.ban(con, id, sessionUser.getId());
    }
    @Post
    @Path("/resetPw")
    @LoginUser
    public void resetPw(@JdbcConn(true) Connection con,String id)throws SQLException {
        this.hospitalDao.changePw(con, DEFAULT_PW_STR, id);
    }
    @Path("/pq")
    @Get
    public PageQueryResult<SessionUser> pageQuery(@JdbcConn Connection con, @Nullable Boolean active,@Nullable String level,@Nullable String subLevel,@Nullable String type,@Nullable String name,int pageSize,int pageNo)throws SQLException {
        PageQueryResult<Hospital> pageQueryResult = hospitalDao.pageQuery(con, active, level, subLevel, type, name == null ? null : "%" + name + "%", pageSize, pageNo);
        List<Hospital> hospitals = pageQueryResult.getData();
        List<SessionUser> sessionUsers = new ArrayList<>();
        if (!hospitals.isEmpty()) {
            for (Hospital hospital : hospitals) {
                sessionUsers.add(makeSessionUser(hospital));
            }
            PageQueryResult<SessionUser> ret = new PageQueryResult<>();
            ret.setPageNo(pageQueryResult.getPageNo());
            ret.setPageSize(pageQueryResult.getPageSize());
            ret.setTotal(pageQueryResult.getTotal());
            ret.setData(sessionUsers);
            return ret;
        }
        return null;
    }
    private static SessionUser makeSessionUser(Hospital hospital) {
        SessionUser sessionUser = new SessionUser();
        sessionUser.setAccount(hospital.getAccount());
        sessionUser.setName(hospital.getName());
        sessionUser.setLevel(hospital.getLevel());
        sessionUser.setSubLevel(hospital.getSubLevel());
        sessionUser.setId(hospital.getId());
        sessionUser.setType(hospital.getType());
        sessionUser.setPhone(hospital.getPhone());
        sessionUser.setLocation(hospital.getLocation());
        sessionUser.setAddr(hospital.getAddr());
        sessionUser.setDesc(hospital.getDescp());
        sessionUser.setImage(hospital.getImage());
        sessionUser.setActive(hospital.isActive());
        return sessionUser;
    }
}

src/main/java/com/ekexiu/project/msconsole/system/vo/SessionUser.java

@@ -0,0 +1,123 @@
package com.ekexiu.project.msconsole.system.vo;
import org.jfw.util.auth.AuthUser;
/**
 * Created by TT on 2019/5/30.
 */
public class SessionUser implements AuthUser {
    private String id;
    private String account;
    private String name;
    private String level;
    private String subLevel;
    private String type;
    private String phone;
    private String location;
    private String addr;
    private String desc;
    private String image;
    private boolean active;
    @Override
    public boolean hasAuthority(int i) {
        return false;
    }
    @Override
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    public String getAccount() {
        return account;
    }
    public void setAccount(String account) {
        this.account = account;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getLevel() {
        return level;
    }
    public void setLevel(String level) {
        this.level = level;
    }
    public String getSubLevel() {
        return subLevel;
    }
    public void setSubLevel(String subLevel) {
        this.subLevel = subLevel;
    }
    public String getType() {
        return type;
    }
    public void setType(String type) {
        this.type = type;
    }
    public String getPhone() {
        return phone;
    }
    public void setPhone(String phone) {
        this.phone = phone;
    }
    public String getLocation() {
        return location;
    }
    public void setLocation(String location) {
        this.location = location;
    }
    public String getAddr() {
        return addr;
    }
    public void setAddr(String addr) {
        this.addr = addr;
    }
    public String getDesc() {
        return desc;
    }
    public void setDesc(String desc) {
        this.desc = desc;
    }
    public String getImage() {
        return image;
    }
    public void setImage(String image) {
        this.image = image;
    }
    public boolean isActive() {
        return active;
    }
    public void setActive(boolean active) {
        this.active = active;
    }
}

src/main/java/com/ekexiu/project/msconsole/system/vo/UploadFile.java

@@ -0,0 +1,42 @@
package com.ekexiu.project.msconsole.system.vo;
import java.io.File;
public class UploadFile {
	   private String name;
       private String uri;
       private long size;
       private transient File fn;
       public File getFn() {
           return fn;
       }
       public void setFn(File fn) {
           this.fn = fn;
       }
       public String getName() {
           return name;
       }
       public void setName(String name) {
           this.name = name;
       }
       public String getUri() {
           return uri;
       }
       public void setUri(String uri) {
           this.uri = uri;
       }
       public long getSize() {
           return size;
       }
       public void setSize(long size) {
           this.size = size;
       }
}

src/main/resources/database.sql

@@ -0,0 +1,155 @@
CREATE TABLE HOSPITAL (
  ID CHAR(32) NOT NULL,
  PASSWD TEXT NOT NULL,
  ACCOUNT TEXT NOT NULL,
  NAME TEXT NOT NULL,
  LEVEL CHAR(1) NOT NULL,
  SUB_LEVEL CHAR(1) NOT NULL,
  TYPE CHAR(1) NOT NULL,
  PHONE TEXT,
  LOCATION TEXT,
  ADDR VARCHAR(255),
  DESCP TEXT,
  IMAGE TEXT,
  ACTIVE CHAR(1) NOT NULL,
  CREATE_TIME CHAR(14) NOT NULL,
  MODIFY_TIME CHAR(14) NOT NULL,
  CREATOR CHAR(32) NOT NULL,
  MODIFIER CHAR(32) NOT NULL);
ALTER TABLE HOSPITAL ADD PRIMARY KEY (ID);
ALTER TABLE HOSPITAL ADD UNIQUE (ACCOUNT);
COMMENT ON TABLE HOSPITAL IS '医院登录表';
COMMENT ON COLUMN HOSPITAL.ID IS '医院ID';
COMMENT ON COLUMN HOSPITAL.PASSWD IS '密码(MD5)';
COMMENT ON COLUMN HOSPITAL.ACCOUNT IS '医院帐号';
COMMENT ON COLUMN HOSPITAL.NAME IS '医院名称';
COMMENT ON COLUMN HOSPITAL.LEVEL IS '医院级别';
COMMENT ON COLUMN HOSPITAL.SUB_LEVEL IS '医院子级别';
COMMENT ON COLUMN HOSPITAL.TYPE IS '医院类型';
COMMENT ON COLUMN HOSPITAL.PHONE IS '电话';
COMMENT ON COLUMN HOSPITAL.LOCATION IS '医院详细地址';
COMMENT ON COLUMN HOSPITAL.ADDR IS '医院所在城市编码';
COMMENT ON COLUMN HOSPITAL.DESCP IS '医院简介';
COMMENT ON COLUMN HOSPITAL.IMAGE IS '医院图片';
COMMENT ON COLUMN HOSPITAL.ACTIVE IS '是否可用';
COMMENT ON COLUMN HOSPITAL.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
COMMENT ON COLUMN HOSPITAL.MODIFY_TIME IS '最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101';
COMMENT ON COLUMN HOSPITAL.CREATOR IS '创建人ID';
COMMENT ON COLUMN HOSPITAL.MODIFIER IS '最后修改人ID';
CREATE TABLE SYS_DICT (
  CODE TEXT NOT NULL,
  BCODE TEXT,
  DICT_CODE TEXT NOT NULL,
  CAPTION TEXT NOT NULL,
  FULL_CAPTION TEXT,
  SHORT_CUT TEXT,
  REMARK TEXT,
  READONLY CHAR(1) NOT NULL,
  ACTIVE CHAR(1) NOT NULL);
ALTER TABLE SYS_DICT ADD PRIMARY KEY (DICT_CODE,CODE);
COMMENT ON TABLE SYS_DICT IS '数据字典表';
COMMENT ON COLUMN SYS_DICT.CODE IS '字典项编码';
COMMENT ON COLUMN SYS_DICT.BCODE IS '字典项编码(业务编码)';
COMMENT ON COLUMN SYS_DICT.DICT_CODE IS '字典编码';
COMMENT ON COLUMN SYS_DICT.CAPTION IS '字典项显示';
COMMENT ON COLUMN SYS_DICT.FULL_CAPTION IS '字典项显示(全)';
COMMENT ON COLUMN SYS_DICT.SHORT_CUT IS '助记码';
COMMENT ON COLUMN SYS_DICT.REMARK IS '备注';
COMMENT ON COLUMN SYS_DICT.READONLY IS '是否只读';
COMMENT ON COLUMN SYS_DICT.ACTIVE IS '是否有效';
CREATE TABLE INSTRUMENT (
  ID CHAR(32) NOT NULL,
  NAME TEXT NOT NULL,
  STATUS CHAR(1) NOT NULL,
  DEPARTMENT CHAR(32),
  HOSPITAL CHAR(32) NOT NULL,
  SPEC TEXT,
  APPLICATION TEXT,
  DESCP TEXT,
  IMAGE TEXT,
  ACTIVE CHAR(1) NOT NULL,
  CREATE_TIME CHAR(14) NOT NULL,
  MODIFY_TIME CHAR(14) NOT NULL,
  CREATOR CHAR(32) NOT NULL,
  MODIFIER CHAR(32) NOT NULL);
ALTER TABLE INSTRUMENT ADD PRIMARY KEY (ID);
COMMENT ON TABLE INSTRUMENT IS '器械表';
COMMENT ON COLUMN INSTRUMENT.ID IS '器械ID';
COMMENT ON COLUMN INSTRUMENT.NAME IS '器械名称';
COMMENT ON COLUMN INSTRUMENT.STATUS IS '器械状态';
COMMENT ON COLUMN INSTRUMENT.DEPARTMENT IS '所属科室';
COMMENT ON COLUMN INSTRUMENT.HOSPITAL IS '所属医院';
COMMENT ON COLUMN INSTRUMENT.SPEC IS '厂商型号';
COMMENT ON COLUMN INSTRUMENT.APPLICATION IS '功能用途';
COMMENT ON COLUMN INSTRUMENT.DESCP IS '器械简介';
COMMENT ON COLUMN INSTRUMENT.IMAGE IS '器械图片';
COMMENT ON COLUMN INSTRUMENT.ACTIVE IS '是否可用';
COMMENT ON COLUMN INSTRUMENT.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
COMMENT ON COLUMN INSTRUMENT.MODIFY_TIME IS '最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101';
COMMENT ON COLUMN INSTRUMENT.CREATOR IS '创建人ID';
COMMENT ON COLUMN INSTRUMENT.MODIFIER IS '最后修改人ID';
CREATE TABLE DOCTOR (
  ID CHAR(32) NOT NULL,
  HOSPITAL CHAR(32) NOT NULL,
  DEPARTMENT CHAR(32),
  ACCOUNT TEXT NOT NULL,
  NAME TEXT NOT NULL,
  CLINICAL_TITLE TEXT,
  TEACH_TITLE TEXT,
  POSITION TEXT,
  DIRECTION TEXT,
  IMAGE VARCHAR(255),
  DESCP TEXT,
  ACTIVE CHAR(1) NOT NULL,
  PASSWD TEXT NOT NULL,
  CREATE_TIME CHAR(14) NOT NULL,
  MODIFY_TIME CHAR(14) NOT NULL,
  CREATOR CHAR(32) NOT NULL,
  MODIFIER CHAR(32) NOT NULL);
ALTER TABLE DOCTOR ADD PRIMARY KEY (ID);
ALTER TABLE DOCTOR ADD UNIQUE (ACCOUNT);
COMMENT ON TABLE DOCTOR IS '医生';
COMMENT ON COLUMN DOCTOR.ID IS '医生ID';
COMMENT ON COLUMN DOCTOR.HOSPITAL IS '医院ID';
COMMENT ON COLUMN DOCTOR.DEPARTMENT IS '医院ID';
COMMENT ON COLUMN DOCTOR.ACCOUNT IS '帐号';
COMMENT ON COLUMN DOCTOR.NAME IS '医生姓名';
COMMENT ON COLUMN DOCTOR.CLINICAL_TITLE IS '临床职称';
COMMENT ON COLUMN DOCTOR.TEACH_TITLE IS '教学职称';
COMMENT ON COLUMN DOCTOR.POSITION IS '行政职务';
COMMENT ON COLUMN DOCTOR.DIRECTION IS '擅长方向';
COMMENT ON COLUMN DOCTOR.IMAGE IS '图片';
COMMENT ON COLUMN DOCTOR.DESCP IS '个人简介';
COMMENT ON COLUMN DOCTOR.ACTIVE IS '是否可用';
COMMENT ON COLUMN DOCTOR.PASSWD IS '密码(MD5)';
COMMENT ON COLUMN DOCTOR.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
COMMENT ON COLUMN DOCTOR.MODIFY_TIME IS '最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101';
COMMENT ON COLUMN DOCTOR.CREATOR IS '创建人ID';
COMMENT ON COLUMN DOCTOR.MODIFIER IS '最后修改人ID';
CREATE TABLE DEPARTMENT (
  ID CHAR(32) NOT NULL,
  HOSPITAL CHAR(32) NOT NULL,
  NAME TEXT NOT NULL,
  TYPE CHAR(1) NOT NULL,
  PHONE TEXT,
  LOCATION TEXT,
  DESCP TEXT,
  ACTIVE CHAR(1) NOT NULL,
  CREATE_TIME CHAR(14) NOT NULL,
  MODIFY_TIME CHAR(14) NOT NULL,
  CREATOR CHAR(32) NOT NULL,
  MODIFIER CHAR(32) NOT NULL);
ALTER TABLE DEPARTMENT ADD PRIMARY KEY (ID);
COMMENT ON TABLE DEPARTMENT IS '科室';
COMMENT ON COLUMN DEPARTMENT.ID IS '科室ID';
COMMENT ON COLUMN DEPARTMENT.HOSPITAL IS '所属医院ID';
COMMENT ON COLUMN DEPARTMENT.NAME IS '科室名称';
COMMENT ON COLUMN DEPARTMENT.TYPE IS '科室ID';
COMMENT ON COLUMN DEPARTMENT.PHONE IS '科室电话';
COMMENT ON COLUMN DEPARTMENT.LOCATION IS '科室地址';
COMMENT ON COLUMN DEPARTMENT.DESCP IS '科室简介';
COMMENT ON COLUMN DEPARTMENT.ACTIVE IS '是否可用';
COMMENT ON COLUMN DEPARTMENT.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
COMMENT ON COLUMN DEPARTMENT.MODIFY_TIME IS '最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101';
COMMENT ON COLUMN DEPARTMENT.CREATOR IS '创建人ID';
COMMENT ON COLUMN DEPARTMENT.MODIFIER IS '最后修改人ID';

src/main/resources/project.properties

@@ -0,0 +1,37 @@
dataSource=com.alibaba.druid.pool.DruidDataSource
#数据库连接地址、名称、密码
dataSource.url=jdbc:postgresql://192.168.3.233:5432/medical_share
dataSource.username=postgres
dataSource.password=postgres
#连接池启动时的初始值（初始化连接）
dataSource.initialSize::int=1
#最小空闲连接值
dataSource.minIdle::int=1 
#连接池的最大值（最大连接数量）
dataSource.maxActive::int=1
#超时等待时间（maxWait代表当Connection用尽了，多久之后进行回收丢失连接）
dataSource.maxWait::long=60000
#连接超时任务的时间间隔
dataSource.timeBetweenEvictionRunsMillis::long=60000
#连接的超时时间
dataSource.minEvictableIdleTimeMillis::long=300000  
#用来验证从连接池取出的连接
dataSource.validationQuery=SELECT 1  
#指明连接是否被空闲连接回收器(如果有)进行检验.如果检测失败则连接将被从池中去除
dataSource.testWhileIdle::boolean=true
#在从池中取出连接前进行检验,如果检验失败则从池中去除连接并尝试取出另一个
dataSource.testOnBorrow::boolean=true
#指明是否在归还到池中前进行检验
dataSource.testOnReturn::boolean=true   
#开启池的prepared statement 池功能
dataSource.poolPreparedStatements::boolean=true 
#statement池能够同时分配的打开的statements的最大数量
dataSource.maxPoolPreparedStatementPerConnectionSize::int=20
#默认的SQL语句自动提交状态(开启或关闭)设置由连接池本身设置(false由连接池定)
dataSource.defaultAutoCommit::boolean=false
com_ekexiu_project_msconsole_system_service_CommonUtilService.rootPath=http://192.168.3.233:84
com_ekexiu_project_msconsole_system_service_CommonUtilService.hospitalPath::java.io.File=/medical/data/hospitalPath/logo
com_ekexiu_project_msconsole_system_service_CommonUtilService.doctorPath::java.io.File=/medical/data/doctor/logo
com_ekexiu_project_msconsole_system_service_CommonUtilService.instrumentPath::java.io.File=/medical/data/instrument/logo

src/main/webapp/WEB-INF/web.xml

@@ -0,0 +1,29 @@
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
         version="4.0">
    <servlet>
        <servlet-name>ajax</servlet-name>
        <servlet-class>org.jfw.web.servlet.core.FilenameConfigServlet</servlet-class>
        <init-param>
            <param-name>prefixLen</param-name>
            <param-value>16</param-value>
        </init-param>
        <init-param>
            <param-name>viewType</param-name>
            <param-value>1</param-value>
        </init-param>
        <init-param>
            <param-name>configFileName</param-name>
            <param-value>beanConfig.properties,project.properties</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    <servlet-mapping>
        <servlet-name>ajax</servlet-name>
        <url-pattern>/ajax/*</url-pattern>
    </servlet-mapping>
</web-app>