11111

src/main/java/com/ekexiu/project/editor/Controller.java

@@ -0,0 +1,281 @@
package com.ekexiu.project.editor;
import com.ekexiu.project.editor.define.BaseState;
import com.ekexiu.project.editor.define.State;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Bean;
import org.jfw.util.ConstData;
import org.jfw.util.json.JsonService;
import org.jfw.util.web.fileupload.Item;
import org.jfw.util.web.fileupload.UploadItemIterator;
import org.jfw.util.web.fileupload.impl.UploadItemIteratorImpl;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.Writer;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Bean
public class Controller {
    private String rootPath;
    @Autowrie
    private EditorConfig config;
    public String getRootPath() {
        return rootPath;
    }
    public void setRootPath(String rootPath) {
        this.rootPath = rootPath;
    }
    public EditorConfig getConfig() {
        return config;
    }
    public void setConfig(EditorConfig config) {
        this.config = config;
    }
    public void service(HttpServletRequest req, HttpServletResponse res, int _viewType) throws javax.servlet.ServletException, IOException {
        req.setCharacterEncoding("utf-8");
        res.setHeader("Content-Type", "text/html");
        String callbackName = req.getParameter("callback");
        String ret = null;
        if (callbackName != null) {
            if (!validCallbackName(callbackName)) {
                ret = new BaseState(false, 401).toJSONString();
            } else {
                ret = callbackName + "(" + invoke(req) + ");";
            }
        } else {
            ret = invoke(req);
        }
        Writer out = res.getWriter();
        try {
            out.write(ret);
        } finally {
            out.close();
        }
    }
    public String invoke(HttpServletRequest req) {
        String actionType = req.getParameter("action");
        if ((actionType == null) || (!mapping.containsKey(actionType))) {
            return new BaseState(false, 101).toJSONString();
        }
        State state = new BaseState(false, 101);
        int actionCode = getType(actionType);
        switch (actionCode) {
        case 0:
            return JsonService.toJson(this.config.getAllConfig());
        case 1:
        case 2:
        case 3:
        case 4:
            state = this.upload(req, actionCode);
            break;
        }
        return state.toJSONString();
    }
    public boolean validCallbackName(String name) {
        if (name.matches("^[a-zA-Z_]+[\\w0-9_]*$")) {
            return true;
        }
        return false;
    }
    private State upload(HttpServletRequest req, int actionCode) {
        if (2 == actionCode) {
            return this.uploadBase64(req);
        }
        boolean isAjaxUpload = req.getHeader("X_Requested_With") != null;
        if (!UploadItemIteratorImpl.isMultipartContent(req)) {
            return new BaseState(false, 5);
        }
        try {
            if (isAjaxUpload) {
                req.setCharacterEncoding("UTF-8");
            }
            String savePath = this.config.getImagePathFormat();
            long maxSize = this.config.getImageMaxSize();
            String afs = this.config.getImageAllowFiles();
            if (actionCode == 3) {
                savePath = this.config.getVideoPathFormat();
                maxSize = this.config.getVideoMaxSize();
                afs = this.config.getVideoAllowFiles();
            }
            if (actionCode == 4) {
                savePath = this.config.getFilePathFormat();
                maxSize = this.config.getFileMaxSize();
                afs = this.config.getFileAllowFiles();
            }
            List<String> afList = this.config.addDot(this.config.from(afs));
            UploadItemIterator it = UploadItemIteratorImpl.build(req);
            try {
                while (it.hasNext()) {
                    Item item = it.next();
                    if (!item.isFormField()) {
                        String filename = item.getName();
                        String suffix = filename.substring(filename.lastIndexOf(".")).toLowerCase();
                        if (!afList.contains(suffix)) {
                            return new BaseState(false, 8);
                        }
                        filename = filename.substring(0, filename.length() - suffix.length());
                        savePath = savePath + suffix;
                        savePath = PathFormat.parse(savePath, filename);
                        State storageState = this.saveFileByInputStream(item.getInputStream(), savePath, maxSize);
                        if (storageState.isSuccess()) {
                            storageState.putInfo("url", rootPath+PathFormat.format(savePath));
                            storageState.putInfo("type", suffix);
                            storageState.putInfo("original", filename + suffix);
                        }
                        return storageState;
                    }
                }
                return new BaseState(false, 7);
            } finally {
                it.clean();
            }
        } catch (IOException e) {
        }
        return new BaseState(false, 4);
    }
    private static boolean validSize(byte[] data, long length) {
        return data.length <= length;
    }
    private State uploadBase64(HttpServletRequest req) {
        String fn = this.config.getScrawlFieldName();
        String content = req.getParameter(fn);
        byte[] data = org.jfw.apt.util.Base64.decodeBase64(content.getBytes(ConstData.UTF8));
        long maxSize = this.config.getScrawlMaxSize();
        if (!validSize(data, maxSize)) {
            return new BaseState(false, 1);
        }
        String suffix = ".jpg";
        String savePath = PathFormat.parse(this.config.getScrawlPathFormat(), "scrawl");
        savePath = savePath + suffix;
        State storageState = saveBinaryFile(data, savePath);
        if (storageState.isSuccess()) {
            storageState.putInfo("url", PathFormat.format(savePath));
            storageState.putInfo("type", suffix);
            storageState.putInfo("original", "");
        }
        return storageState;
    }
    public static int getType(String key) {
        return ((Integer) mapping.get(key)).intValue();
    }
    public static final int BUFFER_SIZE = 8192;
    public State saveBinaryFile(byte[] data, String path) {
        File file = new File(this.config.getRootPath(), path);
        State state = valid(file);
        if (!state.isSuccess()) {
            return state;
        }
        try {
            BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(file));
            bos.write(data);
            bos.flush();
            bos.close();
        } catch (IOException ioe) {
            return new BaseState(false, 4);
        }
        state = new BaseState(true, file.getAbsolutePath());
        state.putInfo("size", data.length);
        state.putInfo("title", file.getName());
        return state;
    }
    public State saveFileByInputStream(InputStream is, String path, long maxSize) {
        State state = null;
        File file = new File(this.config.getRootPath(), path);
        if (file.exists()) {
            return new BaseState(false, 2);
        }
        File parent = file.getParentFile();
        if(!parent.exists()){
            if(!parent.mkdirs())return new BaseState(false, 3);
        }
        byte[] dataBuf = new byte[4096];
        BufferedInputStream bis = new BufferedInputStream(is, 8192);
        try {
            try {
                BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(file), 8192);
                int count = 0;
                while ((count = bis.read(dataBuf)) != -1) {
                    bos.write(dataBuf, 0, count);
                }
                bos.flush();
                bos.close();
                if (file.length() > maxSize) {
                    file.delete();
                    return new BaseState(false, 1);
                }
                state = new BaseState(true);
                state.putInfo("size", file.length());
                state.putInfo("title", file.getName());
                return state;
            } finally {
                is.close();
            }
        } catch (IOException localIOException) {
        }
        return new BaseState(false, 4);
    }
    private static State valid(File file) {
        File parentPath = file.getParentFile();
        if ((!parentPath.exists()) && (!parentPath.mkdirs())) {
            return new BaseState(false, 3);
        }
        if (!parentPath.canWrite()) {
            return new BaseState(false, 2);
        }
        return new BaseState(true);
    }
    public static final Map<String, Integer> mapping = new HashMap<String, Integer>();
    public static final int CONFIG = 0;
    public static final int UPLOAD_IMAGE = 1;
    public static final int UPLOAD_SCRAWL = 2;
    public static final int UPLOAD_VIDEO = 3;
    public static final int UPLOAD_FILE = 4;
    static {
        mapping.put("config", CONFIG);
        mapping.put("uploadimage", UPLOAD_IMAGE);
        mapping.put("uploadscrawl", UPLOAD_SCRAWL);
        mapping.put("uploadvideo", UPLOAD_VIDEO);
        mapping.put("uploadfile", UPLOAD_FILE);
    }
}

src/main/java/com/ekexiu/project/editor/EditorConfig.java

@@ -0,0 +1,657 @@
package com.ekexiu.project.editor;
import org.jfw.apt.annotation.Bean;
import org.jfw.util.ListUtil;
import java.io.File;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
@Bean
public class EditorConfig {
    private File rootPath;
    
    /* 执行上传图片的action名称 */
    private String imageActionName = "uploadimage";
    /* 提交的图片表单名称 */
    private String imageFieldName = "upfile";
    /* 上传大小限制，单位B */
    private long imageMaxSize = 2048000;
    /* 上传图片格式显示 */
    private String imageAllowFiles = "png,jpg,jpeg,gif,bmp";
    /* 是否压缩图片,默认是true */
    private boolean imageCompressEnable = true;
    /* 图片压缩最长边限制 */
    private long imageCompressBorder = 1600;
    /* 插入的图片浮动方式 */
    private String imageInsertAlign = "none";
    /* 图片访问路径前缀 */
    private String imageUrlPrefix = "";
    /* 上传保存路径,可以自定义保存路径和文件名格式 */
    /* {filename} 会替换成原文件名,配置这项需要注意中文乱码问题 */
    /* {rand:6} 会替换成随机数,后面的数字是随机数的位数 */
    /* {time} 会替换成时间戳 */
    /* {yyyy} 会替换成四位年份 */
    /* {yy} 会替换成两位年份 */
    /* {mm} 会替换成两位月份 */
    /* {dd} 会替换成两位日期 */
    /* {hh} 会替换成两位小时 */
    /* {ii} 会替换成两位分钟 */
    /* {ss} 会替换成两位秒 */
    /* 非法字符 \ : * ? " < > | */
    /* 具请体看线上文档: fexbaiducom/ueditor/#use-format_upload_filename */
    private String imagePathFormat = "/data/editor/image/{yyyy}{mm}{dd}/{time}{rand:6}";
    /* 涂鸦图片上传配置项 */
    /* 执行上传涂鸦的action名称 */
    private String scrawlActionName = "uploadscrawl";
    /* 提交的图片表单名称 */
    private String scrawlFieldName = "upfile";
    /* 上传保存路径,可以自定义保存路径和文件名格式 */
    private String scrawlPathFormat = "/data/editor/image/{yyyy}{mm}{dd}/{time}{rand:6}";
    /* 上传大小限制，单位B */
    private long scrawlMaxSize = 2048000;
    private String scrawlUrlPrefix = "";
    /* 图片访问路径前缀 */
    private String scrawlInsertAlign = "none";
    /* 截图工具上传 */
    /* 执行上传截图的action名称 */
    private String snapscreenActionName = "uploadimage";
    /* 上传保存路径,可以自定义保存路径和文件名格式 */
    private String snapscreenPathFormat = "/data/editor/image/{yyyy}{mm}{dd}/{time}{rand:6}";
    /* 图片访问路径前缀 */
    private String snapscreenUrlPrefix = "";
    /* 插入的图片浮动方式 */
    private String snapscreenInsertAlign = "none";
    /* 抓取远程图片配置 */
    private String catcherLocalDomain = "127001,localhost,imgbaiducom";
    /* 执行抓取远程图片的action名称 */
    private String catcherActionName = "catchimage";
    /* 提交的图片列表表单名称 */
    private String catcherFieldName = "source";
    /* 上传保存路径,可以自定义保存路径和文件名格式 */
    private String catcherPathFormat = "/data/editor/image/{yyyy}{mm}{dd}/{time}{rand:6}";
    /* 图片访问路径前缀 */
    private String catcherUrlPrefix = "";
    /* 上传大小限制，单位B */
    private long catcherMaxSize = 2048000;
    /* 抓取图片格式显示 */
    private String catcherAllowFiles = "png,jpg,jpeg,gif,bmp";
    /* 上传视频配置 */
    /* 执行上传视频的action名称 */
    private String videoActionName = "uploadvideo";
    /* 提交的视频表单名称 */
    private String videoFieldName = "upfile";
    /* 上传保存路径,可以自定义保存路径和文件名格式 */
    private String videoPathFormat = "/data/editor/video/{yyyy}{mm}{dd}/{time}{rand:6}";
    /* 视频访问路径前缀 */
    private String videoUrlPrefix = "";
    /* 上传大小限制，单位B，默认100MB */
    private long videoMaxSize = 102400000;
    /* 上传视频格式显示 */
    private String videoAllowFiles = "flv,swf,mkv,avi,rm,rmvb,mpeg,mpg,ogg,ogv,mov,wmv,mp4,webm,mp3,wav,mid";
    /* 上传文件配置 */
    /* controller里,执行上传视频的action名称 */
    private String fileActionName = "uploadfile";
    /* 提交的文件表单名称 */
    private String fileFieldName = "upfile";
    /* 上传保存路径,可以自定义保存路径和文件名格式 */
    private String filePathFormat = "/data/editor/file/{yyyy}{mm}{dd}/{time}{rand:6}";
    /* 文件访问路径前缀 */
    private String fileUrlPrefix = "";
    /* 上传大小限制，单位B，默认50MB */
    private long fileMaxSize = 51200000;
    /* 上传文件格式显示 */
    private String fileAllowFiles = "png,jpg,jpeg,gif,bmp,flv,swf,mkv,avi,rm,rmvb,mpeg,mpg,ogg,ogv,mov,wmv,mp4,webm,mp3,wav,mid,rar,zip,tar,gz,7z,bz2,cab,iso,doc,docx,xls,xlsx,ppt,pptx,pdf,txt,md,xml";
    /* 列出指定目录下的图片 */
    /* 执行图片管理的action名称 */
    private String imageManagerActionName = "listimage";
    /* 指定要列出图片的目录 */
    private String imageManagerListPath = "/data/editor/image/";
    /* 每次列出文件数量 */
    private long imageManagerListSize = 20;
    /* 图片访问路径前缀 */
    private String imageManagerUrlPrefix = "";
    /* 插入的图片浮动方式 */
    private String imageManagerInsertAlign = "none";
    /* 列出的文件类型 */
    private String imageManagerAllowFiles = "png,jpg,jpeg,gif,bmp";
    /* 列出指定目录下的文件 */
    /* 执行文件管理的action名称 */
    private String fileManagerActionName = "listfile";
    /* 指定要列出文件的目录 */
    private String fileManagerListPath = "/data/editor/upload/file/";
    /* 文件访问路径前缀 */
    private String fileManagerUrlPrefix = "";
    /* 每次列出文件数量 */
    private long fileManagerListSize = 20;
    /* 列出的文件类型 */
    private String fileManagerAllowFiles = "png,jpg,jpeg,gif,bmp,flv,swf,mkv,avi,rm,rmvb,mpeg,mpg,ogg,ogv,mov,wmv,mp4,webm,mp3,wav,mid,rar,zip,tar,gz,7z,bz2,cab,iso,doc,docx,xls,xlsx,ppt,pptx,pdf,txt,md,xml";
    public String getImageActionName() {
        return imageActionName;
    }
    public void setImageActionName(String imageActionName) {
        this.imageActionName = imageActionName;
    }
    public String getImageFieldName() {
        return imageFieldName;
    }
    public void setImageFieldName(String imageFieldName) {
        this.imageFieldName = imageFieldName;
    }
    public long getImageMaxSize() {
        return imageMaxSize;
    }
    public void setImageMaxSize(long imageMaxSize) {
        this.imageMaxSize = imageMaxSize;
    }
    public String getImageAllowFiles() {
        return imageAllowFiles;
    }
    public void setImageAllowFiles(String imageAllowFiles) {
        this.imageAllowFiles = imageAllowFiles;
    }
    public boolean isImageCompressEnable() {
        return imageCompressEnable;
    }
    public void setImageCompressEnable(boolean imageCompressEnable) {
        this.imageCompressEnable = imageCompressEnable;
    }
    public long getImageCompressBorder() {
        return imageCompressBorder;
    }
    public void setImageCompressBorder(long imageCompressBorder) {
        this.imageCompressBorder = imageCompressBorder;
    }
    public String getImageInsertAlign() {
        return imageInsertAlign;
    }
    public void setImageInsertAlign(String imageInsertAlign) {
        this.imageInsertAlign = imageInsertAlign;
    }
    public String getImageUrlPrefix() {
        return imageUrlPrefix;
    }
    public void setImageUrlPrefix(String imageUrlPrefix) {
        this.imageUrlPrefix = imageUrlPrefix;
    }
    public String getImagePathFormat() {
        return imagePathFormat;
    }
    public void setImagePathFormat(String imagePathFormat) {
        this.imagePathFormat = imagePathFormat;
    }
    public String getScrawlActionName() {
        return scrawlActionName;
    }
    public void setScrawlActionName(String scrawlActionName) {
        this.scrawlActionName = scrawlActionName;
    }
    public String getScrawlFieldName() {
        return scrawlFieldName;
    }
    public void setScrawlFieldName(String scrawlFieldName) {
        this.scrawlFieldName = scrawlFieldName;
    }
    public String getScrawlPathFormat() {
        return scrawlPathFormat;
    }
    public void setScrawlPathFormat(String scrawlPathFormat) {
        this.scrawlPathFormat = scrawlPathFormat;
    }
    public long getScrawlMaxSize() {
        return scrawlMaxSize;
    }
    public void setScrawlMaxSize(long scrawlMaxSize) {
        this.scrawlMaxSize = scrawlMaxSize;
    }
    public String getScrawlUrlPrefix() {
        return scrawlUrlPrefix;
    }
    public void setScrawlUrlPrefix(String scrawlUrlPrefix) {
        this.scrawlUrlPrefix = scrawlUrlPrefix;
    }
    public String getScrawlInsertAlign() {
        return scrawlInsertAlign;
    }
    public void setScrawlInsertAlign(String scrawlInsertAlign) {
        this.scrawlInsertAlign = scrawlInsertAlign;
    }
    public String getSnapscreenActionName() {
        return snapscreenActionName;
    }
    public void setSnapscreenActionName(String snapscreenActionName) {
        this.snapscreenActionName = snapscreenActionName;
    }
    public String getSnapscreenPathFormat() {
        return snapscreenPathFormat;
    }
    public void setSnapscreenPathFormat(String snapscreenPathFormat) {
        this.snapscreenPathFormat = snapscreenPathFormat;
    }
    public String getSnapscreenUrlPrefix() {
        return snapscreenUrlPrefix;
    }
    public void setSnapscreenUrlPrefix(String snapscreenUrlPrefix) {
        this.snapscreenUrlPrefix = snapscreenUrlPrefix;
    }
    public String getSnapscreenInsertAlign() {
        return snapscreenInsertAlign;
    }
    public void setSnapscreenInsertAlign(String snapscreenInsertAlign) {
        this.snapscreenInsertAlign = snapscreenInsertAlign;
    }
    public String getCatcherLocalDomain() {
        return catcherLocalDomain;
    }
    public void setCatcherLocalDomain(String catcherLocalDomain) {
        this.catcherLocalDomain = catcherLocalDomain;
    }
    public String getCatcherActionName() {
        return catcherActionName;
    }
    public void setCatcherActionName(String catcherActionName) {
        this.catcherActionName = catcherActionName;
    }
    public String getCatcherFieldName() {
        return catcherFieldName;
    }
    public void setCatcherFieldName(String catcherFieldName) {
        this.catcherFieldName = catcherFieldName;
    }
    public String getCatcherPathFormat() {
        return catcherPathFormat;
    }
    public void setCatcherPathFormat(String catcherPathFormat) {
        this.catcherPathFormat = catcherPathFormat;
    }
    public String getCatcherUrlPrefix() {
        return catcherUrlPrefix;
    }
    public void setCatcherUrlPrefix(String catcherUrlPrefix) {
        this.catcherUrlPrefix = catcherUrlPrefix;
    }
    public long getCatcherMaxSize() {
        return catcherMaxSize;
    }
    public void setCatcherMaxSize(long catcherMaxSize) {
        this.catcherMaxSize = catcherMaxSize;
    }
    public String getCatcherAllowFiles() {
        return catcherAllowFiles;
    }
    public void setCatcherAllowFiles(String catcherAllowFiles) {
        this.catcherAllowFiles = catcherAllowFiles;
    }
    public String getVideoActionName() {
        return videoActionName;
    }
    public void setVideoActionName(String videoActionName) {
        this.videoActionName = videoActionName;
    }
    public String getVideoFieldName() {
        return videoFieldName;
    }
    public void setVideoFieldName(String videoFieldName) {
        this.videoFieldName = videoFieldName;
    }
    public String getVideoPathFormat() {
        return videoPathFormat;
    }
    public void setVideoPathFormat(String videoPathFormat) {
        this.videoPathFormat = videoPathFormat;
    }
    public String getVideoUrlPrefix() {
        return videoUrlPrefix;
    }
    public void setVideoUrlPrefix(String videoUrlPrefix) {
        this.videoUrlPrefix = videoUrlPrefix;
    }
    public long getVideoMaxSize() {
        return videoMaxSize;
    }
    public void setVideoMaxSize(long videoMaxSize) {
        this.videoMaxSize = videoMaxSize;
    }
    public String getVideoAllowFiles() {
        return videoAllowFiles;
    }
    public void setVideoAllowFiles(String videoAllowFiles) {
        this.videoAllowFiles = videoAllowFiles;
    }
    public String getFileActionName() {
        return fileActionName;
    }
    public void setFileActionName(String fileActionName) {
        this.fileActionName = fileActionName;
    }
    public String getFileFieldName() {
        return fileFieldName;
    }
    public void setFileFieldName(String fileFieldName) {
        this.fileFieldName = fileFieldName;
    }
    public String getFilePathFormat() {
        return filePathFormat;
    }
    public void setFilePathFormat(String filePathFormat) {
        this.filePathFormat = filePathFormat;
    }
    public String getFileUrlPrefix() {
        return fileUrlPrefix;
    }
    public void setFileUrlPrefix(String fileUrlPrefix) {
        this.fileUrlPrefix = fileUrlPrefix;
    }
    public long getFileMaxSize() {
        return fileMaxSize;
    }
    public void setFileMaxSize(long fileMaxSize) {
        this.fileMaxSize = fileMaxSize;
    }
    public String getFileAllowFiles() {
        return fileAllowFiles;
    }
    public void setFileAllowFiles(String fileAllowFiles) {
        this.fileAllowFiles = fileAllowFiles;
    }
    public String getImageManagerActionName() {
        return imageManagerActionName;
    }
    public void setImageManagerActionName(String imageManagerActionName) {
        this.imageManagerActionName = imageManagerActionName;
    }
    public String getImageManagerListPath() {
        return imageManagerListPath;
    }
    public void setImageManagerListPath(String imageManagerListPath) {
        this.imageManagerListPath = imageManagerListPath;
    }
    public long getImageManagerListSize() {
        return imageManagerListSize;
    }
    public void setImageManagerListSize(long imageManagerListSize) {
        this.imageManagerListSize = imageManagerListSize;
    }
    public String getImageManagerUrlPrefix() {
        return imageManagerUrlPrefix;
    }
    public void setImageManagerUrlPrefix(String imageManagerUrlPrefix) {
        this.imageManagerUrlPrefix = imageManagerUrlPrefix;
    }
    public String getImageManagerInsertAlign() {
        return imageManagerInsertAlign;
    }
    public void setImageManagerInsertAlign(String imageManagerInsertAlign) {
        this.imageManagerInsertAlign = imageManagerInsertAlign;
    }
    public String getImageManagerAllowFiles() {
        return imageManagerAllowFiles;
    }
    public void setImageManagerAllowFiles(String imageManagerAllowFiles) {
        this.imageManagerAllowFiles = imageManagerAllowFiles;
    }
    public String getFileManagerActionName() {
        return fileManagerActionName;
    }
    public void setFileManagerActionName(String fileManagerActionName) {
        this.fileManagerActionName = fileManagerActionName;
    }
    public String getFileManagerListPath() {
        return fileManagerListPath;
    }
    public void setFileManagerListPath(String fileManagerListPath) {
        this.fileManagerListPath = fileManagerListPath;
    }
    public String getFileManagerUrlPrefix() {
        return fileManagerUrlPrefix;
    }
    public void setFileManagerUrlPrefix(String fileManagerUrlPrefix) {
        this.fileManagerUrlPrefix = fileManagerUrlPrefix;
    }
    public long getFileManagerListSize() {
        return fileManagerListSize;
    }
    public void setFileManagerListSize(long fileManagerListSize) {
        this.fileManagerListSize = fileManagerListSize;
    }
    public String getFileManagerAllowFiles() {
        return fileManagerAllowFiles;
    }
    public void setFileManagerAllowFiles(String fileManagerAllowFiles) {
        this.fileManagerAllowFiles = fileManagerAllowFiles;
    }
    public File getRootPath() {
        return rootPath;
    }
    public void setRootPath(File rootPath) {
        this.rootPath = rootPath;
    }
    public List<String> from(String src) {
        if (src == null)
            return null;
        return ListUtil.splitTrimExcludeEmpty(src, ',');
    }
    public List<String> addDot(List<String> list) {
        if (null == list)
            return null;
        List<String> ret = new LinkedList<String>();
        for (String s : list) {
            if (s.length() > 0)
                ret.add("." + s);
        }
        return ret;
    }
    public Map<String, Object> getAllConfig() {
        Map<String, Object> ret = new HashMap<String, Object>();
        ret.put("imageActionName", this.imageActionName);
        ret.put("imageFieldName", this.imageFieldName);
        ret.put("imageMaxSize", this.imageMaxSize);
        ret.put("imageAllowFiles", this.addDot(this.from(this.imageAllowFiles)));
        ret.put("imageCompressEnable", this.imageCompressEnable);
        ret.put("imageCompressBorder", this.imageCompressBorder);
        ;
        ret.put("imageInsertAlign", this.imageInsertAlign);
        ret.put("imageUrlPrefix", this.imageUrlPrefix);
        ret.put("imagePathFormat", this.imagePathFormat);
        ret.put("scrawlActionName", this.scrawlActionName);
        ret.put("scrawlFieldName", this.scrawlFieldName);
        ret.put("scrawlPathFormat", this.scrawlPathFormat);
        ret.put("scrawlMaxSize", this.scrawlMaxSize);
        ret.put("scrawlUrlPrefix", this.scrawlUrlPrefix);
        ret.put("scrawlInsertAlign", this.scrawlInsertAlign);
        ret.put("snapscreenActionName", this.snapscreenActionName);
        /* 上传保存路径,可以自定义保存路径和文件名格式 */
        ret.put("snapscreenPathFormat", this.snapscreenPathFormat);
        /* 图片访问路径前缀 */
        ret.put("snapscreenUrlPrefix", this.snapscreenUrlPrefix);
        /* 插入的图片浮动方式 */
        ret.put("snapscreenInsertAlign", this.snapscreenInsertAlign);
        /* 抓取远程图片配置 */
        ret.put("catcherLocalDomain", this.from(this.catcherLocalDomain));
        /* 执行抓取远程图片的action名称 */
        ret.put("catcherActionName", this.catcherActionName);
        /* 提交的图片列表表单名称 */
        ret.put("catcherFieldName", this.catcherFieldName);
        /* 上传保存路径,可以自定义保存路径和文件名格式 */
        ret.put("catcherPathFormat", this.catcherPathFormat);
        /* 图片访问路径前缀 */
        ret.put("catcherUrlPrefix", this.catcherUrlPrefix);
        /* 上传大小限制，单位B */
        ret.put("catcherMaxSize", this.catcherMaxSize);
        ret.put("catcherAllowFiles", this.addDot(this.from(this.catcherAllowFiles)));
        /* 上传视频配置 */
        /* 执行上传视频的action名称 */
        ret.put("videoActionName", this.videoActionName);
        /* 提交的视频表单名称 */
        ret.put("videoFieldName", this.videoFieldName);
        /* 上传保存路径,可以自定义保存路径和文件名格式 */
        ret.put("videoPathFormat", this.videoPathFormat);
        /* 视频访问路径前缀 */
        ret.put("videoUrlPrefix", this.videoUrlPrefix);
        ret.put("videoMaxSize", this.videoMaxSize);
        /* 上传视频格式显示 */
        ret.put("videoAllowFiles", this.addDot(this.from(this.videoAllowFiles)));
        /* 上传文件配置 */
        /* controller里,执行上传视频的action名称 */
        ret.put("fileActionName", this.fileActionName);
        /* 提交的文件表单名称 */
        ret.put("fileFieldName", this.fileFieldName);
        /* 上传保存路径,可以自定义保存路径和文件名格式 */
        ret.put("filePathFormat", this.filePathFormat);
        /* 文件访问路径前缀 */
        ret.put("fileUrlPrefix", this.fileUrlPrefix);
        /* 上传大小限制，单位B，默认50MB */
        ret.put("fileMaxSize", this.fileMaxSize);
        /* 上传文件格式显示 */
        ret.put("fileAllowFiles", this.addDot(this.from(this.fileAllowFiles)));
        /* 列出指定目录下的图片 */
        /* 执行图片管理的action名称 */
        ret.put("imageManagerActionName", this.imageManagerActionName);
        /* 指定要列出图片的目录 */
        ret.put("imageManagerListPath", this.imageManagerListPath);
        /* 每次列出文件数量 */
        ret.put("imageManagerListSize", this.imageManagerListSize);
        /* 图片访问路径前缀 */
        ret.put("imageManagerUrlPrefix", this.imageManagerUrlPrefix);
        /* 插入的图片浮动方式 */
        ret.put("imageManagerInsertAlign", this.imageManagerInsertAlign);
        /* 列出的文件类型 */
        ret.put("imageManagerAllowFiles", this.addDot(this.from(this.imageManagerAllowFiles)));
        /* 列出指定目录下的文件 */
        /* 执行文件管理的action名称 */
        ret.put("fileManagerActionName", this.fileManagerActionName);
        /* 指定要列出文件的目录 */
        ret.put("fileManagerListPath", this.fileManagerListPath);
        /* 文件访问路径前缀 */
        ret.put("fileManagerUrlPrefix", this.fileManagerUrlPrefix);
        /* 每次列出文件数量 */
        ret.put("fileManagerListSize", this.fileManagerListSize);
        /* 列出的文件类型 */
        ret.put("fileManagerAllowFiles", this.addDot(this.from(this.fileManagerAllowFiles)));
        return ret;
    }
}

src/main/java/com/ekexiu/project/editor/PathFormat.java

@@ -0,0 +1,128 @@
package com.ekexiu.project.editor;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
public class PathFormat {
    private static Date currentDate = null;
    public static String parse(String input) {
        Pattern pattern = Pattern.compile("\\{([^\\}]+)\\}", 2);
        Matcher matcher = pattern.matcher(input);
        currentDate = new Date();
        StringBuffer sb = new StringBuffer();
        while (matcher.find()) {
            matcher.appendReplacement(sb, getString(matcher.group(1)));
        }
        matcher.appendTail(sb);
        return sb.toString();
    }
    public static String format(String input) {
        return input.replace("\\", "/");
    }
    public static String parse(String input, String filename) {
        Pattern pattern = Pattern.compile("\\{([^\\}]+)\\}", 2);
        Matcher matcher = pattern.matcher(input);
        String matchStr = null;
        currentDate = new Date();
        StringBuffer sb = new StringBuffer();
        while (matcher.find()) {
            matchStr = matcher.group(1);
            if (matchStr.indexOf("filename") != -1) {
                filename = filename.replace("$", "\\$").replaceAll("[\\/:*?\"<>|]", "");
                matcher.appendReplacement(sb, filename);
            } else {
                matcher.appendReplacement(sb, getString(matchStr));
            }
        }
        matcher.appendTail(sb);
        return sb.toString();
    }
    private static String getString(String pattern) {
        pattern = pattern.toLowerCase();
        if (pattern.indexOf("time") != -1) {
            return "" + getTimestamp();
        }
        if (pattern.indexOf("yyyy") != -1) {
            return getFullYear();
        }
        if (pattern.indexOf("yy") != -1) {
            return getYear();
        }
        if (pattern.indexOf("mm") != -1) {
            return getMonth();
        }
        if (pattern.indexOf("dd") != -1) {
            return getDay();
        }
        if (pattern.indexOf("hh") != -1) {
            return getHour();
        }
        if (pattern.indexOf("ii") != -1) {
            return getMinute();
        }
        if (pattern.indexOf("ss") != -1) {
            return getSecond();
        }
        if (pattern.indexOf("rand") != -1) {
            return getRandom(pattern);
        }
        return pattern;
    }
    private static long getTimestamp() {
        return System.currentTimeMillis();
    }
    private static String getFullYear() {
        return new SimpleDateFormat("yyyy").format(currentDate);
    }
    private static String getYear() {
        return new SimpleDateFormat("yy").format(currentDate);
    }
    private static String getMonth() {
        return new SimpleDateFormat("MM").format(currentDate);
    }
    private static String getDay() {
        return new SimpleDateFormat("dd").format(currentDate);
    }
    private static String getHour() {
        return new SimpleDateFormat("HH").format(currentDate);
    }
    private static String getMinute() {
        return new SimpleDateFormat("mm").format(currentDate);
    }
    private static String getSecond() {
        return new SimpleDateFormat("ss").format(currentDate);
    }
    private static String getRandom(String pattern) {
        int length = 0;
        pattern = pattern.split(":")[1].trim();
        length = Integer.parseInt(pattern);
        return ("" + Math.random()).replace(".", "").substring(0, length);
    }
    public static void main(String[] args) {
    }
}

src/main/java/com/ekexiu/project/editor/define/AppInfo.java

@@ -0,0 +1,65 @@
package com.ekexiu.project.editor.define;
import java.util.HashMap;
import java.util.Map;
public class AppInfo {
    public static final int SUCCESS = 0;
    public static final int MAX_SIZE = 1;
    public static final int PERMISSION_DENIED = 2;
    public static final int FAILED_CREATE_FILE = 3;
    public static final int IO_ERROR = 4;
    public static final int NOT_MULTIPART_CONTENT = 5;
    public static final int PARSE_REQUEST_ERROR = 6;
    public static final int NOTFOUND_UPLOAD_DATA = 7;
    public static final int NOT_ALLOW_FILE_TYPE = 8;
    public static final int INVALID_ACTION = 101;
    public static final int CONFIG_ERROR = 102;
    public static final int PREVENT_HOST = 201;
    public static final int CONNECTION_ERROR = 202;
    public static final int REMOTE_FAIL = 203;
    public static final int NOT_DIRECTORY = 301;
    public static final int NOT_EXIST = 302;
    public static final int ILLEGAL = 401;
    public static Map<Integer, String> info = new HashMap<Integer, String>();
    public static String getStateInfo(int key) {
        return info.get(Integer.valueOf(key));
    }
    static {
        info.put(SUCCESS, "SUCCESS");
        info.put(INVALID_ACTION, "无效的Action");
        info.put(CONFIG_ERROR, "配置文件初始化失败");
        info.put(REMOTE_FAIL, "抓取远程图片失败");
        info.put(PREVENT_HOST, "被阻止的远程主机");
        info.put(CONNECTION_ERROR, "远程连接出错");
        info.put(MAX_SIZE, "文件大小超出限制");
        info.put(PERMISSION_DENIED, "权限不足");
        info.put(FAILED_CREATE_FILE, "创建文件失败");
        info.put(IO_ERROR, "IO错误");
        info.put(NOT_MULTIPART_CONTENT, "上传表单不是multipart/form-data类型");
        info.put(PARSE_REQUEST_ERROR, "解析上传表单错误");
        info.put(NOTFOUND_UPLOAD_DATA, "未找到上传数据");
        info.put(NOT_ALLOW_FILE_TYPE, "不允许的文件类型");
        info.put(NOT_DIRECTORY, "指定路径不是目录");
        info.put(NOT_EXIST, "指定路径并不存在");
        info.put(ILLEGAL, "Callback参数名不合法");
    }
}

src/main/java/com/ekexiu/project/editor/define/BaseState.java

@@ -0,0 +1,89 @@
package com.ekexiu.project.editor.define;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
public class BaseState implements State {
    private boolean state = false;
    private String info = null;
    private Map<String, String> infoMap = new HashMap<String, String>();
    public BaseState() {
        this.state = true;
    }
    public BaseState(boolean state) {
        setState(state);
    }
    public BaseState(boolean state, String info) {
        setState(state);
        this.info = info;
    }
    public BaseState(boolean state, int infoCode) {
        setState(state);
        this.info = AppInfo.getStateInfo(infoCode);
    }
    public boolean isSuccess() {
        return this.state;
    }
    public void setState(boolean state) {
        this.state = state;
    }
    public void setInfo(String info) {
        this.info = info;
    }
    public void setInfo(int infoCode) {
        this.info = AppInfo.getStateInfo(infoCode);
    }
    public String toJSONString() {
        return toString();
    }
    public String toString() {
        String key = null;
        String stateVal = isSuccess() ? AppInfo.getStateInfo(0) : this.info;
        StringBuilder builder = new StringBuilder();
        builder.append("{\"state\": \"" + stateVal + "\"");
        Iterator<String> iterator = this.infoMap.keySet().iterator();
        while (iterator.hasNext()) {
            key = (String) iterator.next();
            builder.append(",\"" + key + "\": \"" + (String) this.infoMap.get(key) + "\"");
        }
        builder.append("}");
        return toUnicode(builder.toString());
    }
    public void putInfo(String name, String val) {
        this.infoMap.put(name, val);
    }
    public void putInfo(String name, long val) {
        putInfo(name,""+val);
    }
    public static String toUnicode(String input) {
        StringBuilder builder = new StringBuilder();
        char[] chars = input.toCharArray();
        for (char ch : chars) {
            if (ch < '\u0100') {
                builder.append(ch);
            } else {
                builder.append("\\u" + Integer.toHexString(ch & 0xFFFF));
            }
        }
        return builder.toString();
    }
}

src/main/java/com/ekexiu/project/editor/define/State.java

@@ -0,0 +1,11 @@
package com.ekexiu.project.editor.define;
public interface State {
   boolean isSuccess();
   void putInfo(String name, String val);
   void putInfo(String name, long val);
    String toJSONString();
}

src/main/java/com/ekexiu/project/platform/article/Article.java

@@ -38,7 +38,7 @@ public class Article implements ManagedBaseTable {
        this.id = id;
    }
    @Column(descp = "内容分享ID", value = DE.long_de, insertable = false, renewable = false)
    @Column(descp = "内容分享ID", value = DE.bigSerial, insertable = false, renewable = false)
    public long getShareId() {
        return shareId;
    }

src/main/java/com/ekexiu/project/platform/base/po/ManagedBaseTable.java

@@ -1,8 +1,10 @@
package com.ekexiu.project.platform.base.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.VirtualTable;
import org.jfw.apt.orm.core.enums.DE;
@VirtualTable
public interface ManagedBaseTable extends BaseTable {
	@Column(descp="创建人ID",value= DE.id_32)
	String getCreator();

src/main/java/com/ekexiu/project/platform/company/CompInvite.java

@@ -0,0 +1,72 @@
package com.ekexiu.project.platform.company;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
/**
 * Created by TT on 2018/11/20.
 */
@Table(descp = "企业邀请表", value = "COMP_INVITE")
public class CompInvite {
    private String id;
    private String email;
    private String inviteCode;
    private String lastTime;
    private String lastInviter;
    private boolean active;
    @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 getEmail() {
        return email;
    }
    public void setEmail(String email) {
        this.email = email;
    }
    @Column(descp = "邀请码", value = DE.text_de)
    public String getInviteCode() {
        return inviteCode;
    }
    public void setInviteCode(String inviteCode) {
        this.inviteCode = inviteCode;
    }
    @Column(descp = "最后邀请时间", value = DE.dateTime_de)
    public String getLastTime() {
        return lastTime;
    }
    public void setLastTime(String lastTime) {
        this.lastTime = lastTime;
    }
    @Column(descp = "最后邀请人", value = DE.id_32)
    public String getLastInviter() {
        return lastInviter;
    }
    public void setLastInviter(String lastInviter) {
        this.lastInviter = lastInviter;
    }
    @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/platform/company/CompKeyWord.java

@@ -0,0 +1,52 @@
package com.ekexiu.project.platform.company;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
/**
 * Created by TT on 2018/11/26.
 */
@Table(descp = "企业关键词")
public class CompKeyWord {
    private String id;
    private int type;
    private String value;
    private int num;
    @Column(descp = "企业ID", value = DE.text_de)
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    @Column(descp = "关键词类型（所属行业：1，专注领域：2，企业资质：3，供应商领域：4，客户领域：5）", value = DE.int_de)
    public int getType() {
        return type;
    }
    public void setType(int type) {
        this.type = type;
    }
    @Column(descp = "关键词", value = DE.text_de)
    public String getValue() {
        return value;
    }
    public void setValue(String value) {
        this.value = value;
    }
    @Column(descp = "序号", value = DE.int_de)
    public int getNum() {
        return num;
    }
    public void setNum(int num) {
        this.num = num;
    }
}

src/main/java/com/ekexiu/project/platform/company/Company.java

@@ -0,0 +1,274 @@
package com.ekexiu.project.platform.company;
import com.ekexiu.project.platform.base.po.ManagedBaseTable;
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 2018/11/19.
 */
@PrimaryKey("id")
@Table(descp = "企业信息", value = "COMPANY")
public class Company implements ManagedBaseTable {
    private String id;
    private long shareId;
    private String name;
    private String logo;
    private String type;
    private String size;
    private String foundYear;
    private String descp;
    private String url;
    private String location;
    private String addr;
    private String zipCode;
    private String servicePhone;
    private String serviceEmail;
    private String operateTime;
    private String linkman;
    private String job;
    private String department;
    private String linkphone;
    private String linkemail;
    private boolean active;
    private String activeTime;
    private String creator;
    private String modifier;
    private String createTime;
    private String modifyTime;
    @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.bigSerial)
    public long getShareId() {
        return shareId;
    }
    public void setShareId(long shareId) {
        this.shareId = shareId;
    }
    @Column(descp = "企业名称", value = DE.text_de)
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    @Column(descp = "企业logo", value = DE.Text_de)
    public String getLogo() {
        return logo;
    }
    public void setLogo(String logo) {
        this.logo = logo;
    }
    @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 getSize() {
        return size;
    }
    public void setSize(String size) {
        this.size = size;
    }
    @Column(descp = "创立年份", value = DE.Text_de)
    public String getFoundYear() {
        return foundYear;
    }
    public void setFoundYear(String foundYear) {
        this.foundYear = foundYear;
    }
    @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 getUrl() {
        return url;
    }
    public void setUrl(String url) {
        this.url = url;
    }
    @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 getAddr() {
        return addr;
    }
    public void setAddr(String addr) {
        this.addr = addr;
    }
    @Column(descp = "企业邮编", value = DE.Text_de)
    public String getZipCode() {
        return zipCode;
    }
    public void setZipCode(String zipCode) {
        this.zipCode = zipCode;
    }
    @Column(descp = "客服电话", value = DE.Text_de)
    public String getServicePhone() {
        return servicePhone;
    }
    public void setServicePhone(String servicePhone) {
        this.servicePhone = servicePhone;
    }
    @Column(descp = "客服邮箱", value = DE.Text_de)
    public String getServiceEmail() {
        return serviceEmail;
    }
    public void setServiceEmail(String serviceEmail) {
        this.serviceEmail = serviceEmail;
    }
    @Column(descp = "工作时间", value = DE.Text_de)
    public String getOperateTime() {
        return operateTime;
    }
    public void setOperateTime(String operateTime) {
        this.operateTime = operateTime;
    }
    @Column(descp = "联系人", value = DE.Text_de)
    public String getLinkman() {
        return linkman;
    }
    public void setLinkman(String linkman) {
        this.linkman = linkman;
    }
    @Column(descp = "联系人职位", value = DE.Text_de)
    public String getJob() {
        return job;
    }
    public void setJob(String job) {
        this.job = job;
    }
    @Column(descp = "所在部门", value = DE.Text_de)
    public String getDepartment() {
        return department;
    }
    public void setDepartment(String department) {
        this.department = department;
    }
    @Column(descp = "联系人电话", value = DE.Text_de)
    public String getLinkphone() {
        return linkphone;
    }
    public void setLinkphone(String linkphone) {
        this.linkphone = linkphone;
    }
    @Column(descp = "联系人邮箱", value = DE.Text_de)
    public String getLinkemail() {
        return linkemail;
    }
    public void setLinkemail(String linkemail) {
        this.linkemail = linkemail;
    }
    @Column(descp = "激活状态", value = DE.boolean_de)
    public boolean isActive() {
        return active;
    }
    public void setActive(boolean active) {
        this.active = active;
    }
    @Column(descp = "激活时间", value = DE.DateTime_de)
    public String getActiveTime() {
        return activeTime;
    }
    public void setActiveTime(String activeTime) {
        this.activeTime = activeTime;
    }
    public String getCreator() {
        return creator;
    }
    public void setCreator(String creator) {
        this.creator = creator;
    }
    public String getModifier() {
        return modifier;
    }
    public void setModifier(String modifier) {
        this.modifier = modifier;
    }
    public String getCreateTime() {
        return createTime;
    }
    public void setCreateTime(String createTime) {
        this.createTime = createTime;
    }
    public String getModifyTime() {
        return modifyTime;
    }
    public void setModifyTime(String modifyTime) {
        this.modifyTime = modifyTime;
    }
}

src/main/java/com/ekexiu/project/platform/company/CompanyDao.java

@@ -0,0 +1,68 @@
package com.ekexiu.project.platform.company;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.Dynamic;
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.DeleteWith;
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.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
/**
 * Created by TT on 2018/11/26.
 */
@DAO
public interface CompanyDao {
    @Insert
    int insert(Connection con, Company company) throws SQLException;
    @Update
    @Dynamic
    int update(Connection con, Company company) throws SQLException;
    @UpdateWith
    @From(Company.class)
    @Where("ACTIVE = '1'")
    @SetSentence("ACTIVE = '0'")
    int delete(Connection con, String id) throws SQLException;
    @SelectOne
    @Nullable
    Company query(Connection con, String id) throws SQLException;
    @SelectOne
    @Nullable
    Company queryByShareId(Connection con, long shareId) throws SQLException;
    @PageSelect
    @OrderBy("ORDER BY CREATE_TIME DESC")
    PageQueryResult<Company> pageQuery(Connection con, @Nullable Boolean active, @Nullable String name, int pageSize, int pageNo) throws SQLException;
    @Insert
    int insert(Connection con, CompKeyWord compKeyWord) throws SQLException;
    @DeleteWith
    @From(CompKeyWord.class)
    int deleteKeyWord(Connection con, String id) throws SQLException;
    @Insert
    int insert(Connection con, CompInvite compInvite) throws SQLException;
    @UpdateWith
    @From(CompInvite.class)
    @Where("ACTIVE = '1'")
    @SetSentence("ACTIVE = '0'")
    int invited(Connection con, String id) throws SQLException;
}

src/main/java/com/ekexiu/project/platform/company/CompanyInfo.java

@@ -0,0 +1,55 @@
package com.ekexiu.project.platform.company;
import org.jfw.apt.orm.annotation.entry.ExtendTable;
/**
 * Created by TT on 2018/11/26.
 */
@ExtendTable
public class CompanyInfo extends Company {
    private String industry;
    private String subject;
    private String fieldOfSupplier;
    private String fieldOfCustomer;
    private String qualification;
    public String getIndustry() {
        return industry;
    }
    public void setIndustry(String industry) {
        this.industry = industry;
    }
    public String getSubject() {
        return subject;
    }
    public void setSubject(String subject) {
        this.subject = subject;
    }
    public String getFieldOfSupplier() {
        return fieldOfSupplier;
    }
    public void setFieldOfSupplier(String fieldOfSupplier) {
        this.fieldOfSupplier = fieldOfSupplier;
    }
    public String getFieldOfCustomer() {
        return fieldOfCustomer;
    }
    public void setFieldOfCustomer(String fieldOfCustomer) {
        this.fieldOfCustomer = fieldOfCustomer;
    }
    public String getQualification() {
        return qualification;
    }
    public void setQualification(String qualification) {
        this.qualification = qualification;
    }
}

src/main/java/com/ekexiu/project/platform/company/CompanyService.java

@@ -0,0 +1,10 @@
package com.ekexiu.project.platform.company;
import org.jfw.apt.web.annotation.Path;
/**
 * Created by TT on 2018/11/26.
 */
@Path("/company")
public class CompanyService {
}

src/main/java/com/ekexiu/project/platform/info/PlatformDao.java

@@ -1,7 +1,9 @@
package com.ekexiu.project.platform.info;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.Update;
import org.jfw.util.exception.JfwBaseException;
import java.sql.Connection;
import java.sql.SQLException;
@@ -14,4 +16,7 @@ public interface PlatformDao {
    @Update
    int update(Connection con, Platform platform) throws SQLException;
    @SelectOne
    Platform query(Connection con) throws SQLException, JfwBaseException;
}

src/main/java/com/ekexiu/project/platform/info/PlatformService.java

@@ -2,8 +2,10 @@ package com.ekexiu.project.platform.info;
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.Put;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.exception.JfwBaseException;
import java.sql.Connection;
import java.sql.SQLException;
@@ -30,4 +32,11 @@ public class PlatformService {
    public int update(@JdbcConn(true) Connection con, Platform platform) throws SQLException {
        return platformDao.update(con, platform);
    }
    @Path("/get")
    @Get
    public Platform query(@JdbcConn Connection con)throws SQLException, JfwBaseException {
        return platformDao.query(con);
    }
}

src/main/java/com/ekexiu/project/platform/organization/Organization.java

@@ -26,7 +26,7 @@ public class Organization {
        this.id = id;
    }
    @Column(descp = "合作机构共享ID", value = DE.long_de)
    @Column(descp = "合作机构共享ID", value = DE.bigSerial)
    public long getShareId() {
        return shareId;
    }

src/main/java/com/ekexiu/project/platform/product/Product.java

@@ -0,0 +1,176 @@
package com.ekexiu.project.platform.product;
import com.ekexiu.project.platform.base.po.ManagedBaseTable;
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 2018/11/20.
 */
@PrimaryKey("id")
@Table(descp = "产品表",value = "PRODUCT")
public class Product implements ManagedBaseTable {
    private String id;
    private long shareId;
    private String companyId;
    private String img;
    private String name;
    private String cnt;
    private String descp;
    private String spec;
    private String producingArea;
    private String price;
    private String parameter;
    private boolean active;
    private String creator;
    private String modifier;
    private String createTime;
    private String modifyTime;;
    @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.bigSerial)
    public long getShareId() {
        return shareId;
    }
    public void setShareId(long shareId) {
        this.shareId = shareId;
    }
    @Column(descp="所属企业ID",value = DE.id_32)
    public String getCompanyId() {
        return companyId;
    }
    public void setCompanyId(String companyId) {
        this.companyId = companyId;
    }
    @Column(descp="产品图片",value = DE.Text_de)
    public String getImg() {
        return img;
    }
    public void setImg(String img) {
        this.img = img;
    }
    @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 getCnt() {
        return cnt;
    }
    public void setCnt(String cnt) {
        this.cnt = cnt;
    }
    @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 getSpec() {
        return spec;
    }
    public void setSpec(String spec) {
        this.spec = spec;
    }
    @Column(descp="产地",value = DE.Text_de)
    public String getProducingArea() {
        return producingArea;
    }
    public void setProducingArea(String producingArea) {
        this.producingArea = producingArea;
    }
    @Column(descp="价格",value = DE.Text_de)
    public String getPrice() {
        return price;
    }
    public void setPrice(String price) {
        this.price = price;
    }
    @Column(descp="性能参数",value = DE.Text_de)
    public String getParameter() {
        return parameter;
    }
    public void setParameter(String parameter) {
        this.parameter = parameter;
    }
    @Column(descp="有效标识",value = DE.boolean_de)
    public boolean isActive() {
        return active;
    }
    public void setActive(boolean active) {
        this.active = active;
    }
    @Column(descp="创建人ID",value = DE.id_32)
    public String getCreator() {
        return creator;
    }
    public void setCreator(String creator) {
        this.creator = creator;
    }
    @Column(descp="最后修改人",value = DE.refid_32)
    public String getModifier() {
        return modifier;
    }
    public void setModifier(String modifier) {
        this.modifier = modifier;
    }
    public String getCreateTime() {
        return createTime;
    }
    public void setCreateTime(String createTime) {
        this.createTime = createTime;
    }
    public String getModifyTime() {
        return modifyTime;
    }
    public void setModifyTime(String modifyTime) {
        this.modifyTime = modifyTime;
    }
}

src/main/java/com/ekexiu/project/platform/product/ProductDao.java

@@ -0,0 +1,12 @@
package com.ekexiu.project.platform.product;
import org.jfw.apt.orm.annotation.dao.DAO;
/**
 * Created by TT on 2018/11/26.
 */
@DAO
public interface ProductDao {
}

src/main/java/com/ekexiu/project/platform/product/ProductKeyWord.java

@@ -0,0 +1,42 @@
package com.ekexiu.project.platform.product;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
/**
 * Created by TT on 2018/11/26.
 */
@Table(descp = "产品关键词")
public class ProductKeyWord {
    private String id;
    private String keyword;
    private int num;
    @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 getKeyword() {
        return keyword;
    }
    public void setKeyword(String keyword) {
        this.keyword = keyword;
    }
    @Column(descp = "序号", value = DE.int_de)
    public int getNum() {
        return num;
    }
    public void setNum(int num) {
        this.num = num;
    }
}

src/main/java/com/ekexiu/project/platform/product/ProductService.java

@@ -0,0 +1,10 @@
package com.ekexiu.project.platform.product;
import org.jfw.apt.web.annotation.Path;
/**
 * Created by TT on 2018/11/26.
 */
@Path("/product")
public class ProductService {
}

src/main/java/com/ekexiu/project/platform/professor/Professor.java

@@ -23,7 +23,7 @@ public class Professor {
        this.id = id;
    }
    @Column(descp = "特约专家共享ID", value = DE.long_de)
    @Column(descp = "特约专家共享ID", value = DE.bigSerial)
    public long getShareId() {
        return shareId;
    }

src/main/java/com/ekexiu/project/platform/system/dao/UserDao.java

@@ -5,6 +5,7 @@ import com.ekexiu.project.platform.system.po.Manager;
import com.ekexiu.project.platform.system.po.SysRight;
import com.ekexiu.project.platform.system.po.User;
import com.ekexiu.project.platform.system.po.UserLoginLog;
import com.ekexiu.project.platform.system.vo.ManagerInfo;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.Batch;
import org.jfw.apt.orm.annotation.dao.Column;
@@ -17,12 +18,15 @@ 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.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.PageQuery;
import org.jfw.apt.orm.annotation.dao.method.operator.PageSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.QueryOne;
import org.jfw.apt.orm.annotation.dao.method.operator.QueryValList;
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.Alias;
import org.jfw.apt.orm.annotation.dao.param.GroupSqlColumn;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.apt.orm.annotation.dao.param.UnEquals;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
@@ -63,8 +67,8 @@ public interface UserDao {
    int update(Connection con, User user) throws SQLException;
    @UpdateWith
    @From(User.class)
    int changePasswd(Connection con, String id, String passwd, @Set @Alias("passwd") String newPasswd) throws SQLException;
    @From(Manager.class)
    int changePasswd(Connection con, String id, @Set @Alias("passwd") String newPasswd) throws SQLException;
    @UpdateWith
    @From(User.class)
@@ -89,6 +93,19 @@ public interface UserDao {
    @From(InvalidUser.class)
    int validUser(Connection con, String id) throws SQLException;
    @PageSelect
    @Where("ACTIVE ='1'")
    @OrderBy("ORDER BY CREATE_TIME DESC")
    PageQueryResult<User> pageQuery(Connection con, @GroupSqlColumn(handlerClass = StringHandler.class, value = {"ACCOUNT LIKE ?", "LOGIN_PHONE LIKE ?"}, isAnd = false) @Nullable String key, int pageSize, int pageNo) throws SQLException;
    @PageSelect
    @OrderBy("ORDER BY INVALID_TIME DESC")
    PageQueryResult<InvalidUser> pageQueryInvalidUser(Connection con,@GroupSqlColumn(handlerClass = StringHandler.class, value = {"ACCOUNT LIKE ?", "LOGIN_PHONE LIKE ?"}, isAnd = false) @Nullable String key, int pageSize, int pageNo) throws SQLException;
    @Nullable
    @SelectOne
    InvalidUser queryInvalidUser(Connection con, String id) throws SQLException;
    /**
     * 后台用户
     */
@@ -123,8 +140,9 @@ public interface UserDao {
    int enable(Connection con, String id) throws SQLException;
    @Nullable
    @SelectOne
    Manager managerLogin(Connection con, String account, String passwd) throws SQLException;
    @QueryOne
    @From(Manager.class)
    ManagerInfo managerLogin(Connection con, String account, String passwd) throws SQLException;
    @Nullable
    @QueryValList
@@ -134,21 +152,23 @@ public interface UserDao {
    @Nullable
    @SelectOne
    Manager queryManagerByLoginPhone(Connection con, String account, Boolean actived) throws SQLException;
    Manager queryManagerByLoginPhone(Connection con, String account,@Nullable Boolean actived) throws SQLException;
    @UpdateWith
    @From(Manager.class)
    int changeManagerPasswd(Connection con, String id, String passwd, @Set @Alias("passwd") String newPasswd) throws SQLException;
    int changeManagerPasswd(Connection con, String id,@Set String passwd) throws SQLException;
    @UpdateWith
    @From(Manager.class)
    int managerResetPasswd(Connection con, String id, @Set String passwd) throws SQLException;
    @PageSelect
    @OrderBy("CREATE_TIME DESC")
    PageQueryResult<Manager> managerPageQuery(Connection con, boolean actived, int pageSize, int pageNo) throws SQLException;
    @PageQuery
    @From(Manager.class)
    @OrderBy("ORDER BY CREATE_TIME DESC")
    PageQueryResult<ManagerInfo> managerPageQuery(Connection con,@UnEquals String id, boolean actived, int pageSize, int pageNo) throws SQLException;
    @Nullable
    @SelectOne
    Manager managerQuery(Connection con, String id) throws SQLException;
    @QueryOne
    @From(Manager.class)
    ManagerInfo managerQuery(Connection con, String id) throws SQLException;
}

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

@@ -21,241 +21,305 @@ import java.util.concurrent.atomic.AtomicInteger;
@Path("")
public class CommonUtilService {
	public static final String JPG = "jpg";
	private static final AtomicInteger HEAD_FN_IDX = new AtomicInteger(1);
	private File headPath;
	
	private static final AtomicInteger LOGO_FN_IDX = new AtomicInteger(1);
	private File logoPath;
	
	
	private static final AtomicInteger ARTICLE_FN_IDX = new AtomicInteger(1);
	private File articlePath;
	
	private int headMaxHeight = Integer.MAX_VALUE;
	
	
	public File getHeadPath() {
		return headPath;
	}
	public void setHeadPath(File headPath) {
		this.headPath = headPath;
	}
	public File getArticlePath() {
		return articlePath;
	}
	public void setArticlePath(File articlePath) {
		this.articlePath = articlePath;
	}
	public File getLogoPath() {
		return logoPath;
	}
	public void setLogoPath(File logoPath) {
		this.logoPath = logoPath;
	}
	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("/manager/head")
	public UploadFile userHeadUpload(@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.headPath, HEAD_FN_IDX, ext);
					uf.setName(name);
					InputStream in = item.getInputStream();
					try {
						saveHeadPhoto(in, uf);
						return uf;
					} finally {
						in.close();
					}
				}
			}
		} finally {
			if (it != null)
				it.clean();
		}
		return uf;
	}
	@Post
	@Path("/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.logoPath, LOGO_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();
						}
						return uf;
					} finally {
						in.close();
					}
				}
			}
		} finally {
			if (it != null)
				it.clean();
		}
		return uf;
	}
	
	@Post
	@Path("/article/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.articlePath, ARTICLE_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();
						}
						return uf;
					} finally {
						in.close();
					}
				}
			}
		} finally {
			if (it != null)
				it.clean();
		}
		return uf;
	}
    public String rootPath;
    public static final String JPG = "jpg";
    private static final AtomicInteger LOGO_FN_IDX = new AtomicInteger(1);
    private File logoPath;
    private static final AtomicInteger ARTICLE_FN_IDX = new AtomicInteger(1);
    private File articlePath;
    private static final AtomicInteger COMPANY_FN_IDX = new AtomicInteger(1);
    private File companyPath;
    private static final AtomicInteger PRODUCT_FN_IDX = new AtomicInteger(1);
    private File productPath;
    private int headMaxHeight = Integer.MAX_VALUE;
    public String getRootPath() {
        return rootPath;
    }
    public void setRootPath(String rootPath) {
        this.rootPath = rootPath;
    }
    public File getArticlePath() {
        return articlePath;
    }
    public void setArticlePath(File articlePath) {
        this.articlePath = articlePath;
    }
    public File getLogoPath() {
        return logoPath;
    }
    public void setLogoPath(File logoPath) {
        this.logoPath = logoPath;
    }
    public File getCompanyPath() {
        return companyPath;
    }
    public void setCompanyPath(File companyPath) {
        this.companyPath = companyPath;
    }
    public File getProductPath() {
        return productPath;
    }
    public void setProductPath(File productPath) {
        this.productPath = productPath;
    }
    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("/platform/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.logoPath, LOGO_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/logo" + uf.getUri());
                        return uf;
                    } finally {
                        in.close();
                    }
                }
            }
        } finally {
            if (it != null)
                it.clean();
        }
        return uf;
    }
    @Post
    @Path("/article/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.articlePath, ARTICLE_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/article/logo" + uf.getUri());
                        return uf;
                    } finally {
                        in.close();
                    }
                }
            }
        } finally {
            if (it != null)
                it.clean();
        }
        return uf;
    }
    @Post
    @Path("/company/logo")
    public UploadFile companyImageUpload(@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.companyPath, COMPANY_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/company/logo" + uf.getUri());
                        return uf;
                    } finally {
                        in.close();
                    }
                }
            }
        } finally {
            if (it != null)
                it.clean();
        }
        return uf;
    }
    @Post
    @Path("/product/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.productPath, PRODUCT_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/product/logo" + uf.getUri());
                        return uf;
                    } finally {
                        in.close();
                    }
                }
            }
        } finally {
            if (it != null)
                it.clean();
        }
        return uf;
    }
}

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

@@ -7,6 +7,7 @@ import com.ekexiu.project.platform.system.po.SysRight;
import com.ekexiu.project.platform.system.po.User;
import com.ekexiu.project.platform.system.vo.ManagerInfo;
import com.ekexiu.project.platform.system.vo.SessionManager;
import com.ekexiu.project.platform.system.vo.SessionUser;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.LoginUser;
@@ -24,16 +25,20 @@ import org.jfw.util.PageQueryResult;
import org.jfw.util.StringUtil;
import org.jfw.util.auth.AuthUser;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.PreparedStatementConfig;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
@Path("/sys")
public class SysService {
    private String fixRightCode = "aaa";
    private String fixRightCode = "0";
    @Autowrie
    private UserDao userDao;
@@ -50,16 +55,15 @@ public class SysService {
    @Path("/login")
    @Post
    public SessionManager managerLogin(@JdbcConn Connection con, String account, String pw) throws SQLException, JfwBaseException {
        Manager user = userDao.managerLogin(con, account, StringUtil.md5(pw));
        ManagerInfo user = userDao.managerLogin(con, account, StringUtil.md5(pw));
        if (user != null) {
            if (!user.isActived()) {
                throw new JfwBaseException(-200001, "user is disabled");
            }
            ManagerInfo managerInfo = (ManagerInfo) user;
            List<String> rightList = userDao.right(con, user.getId());
            managerInfo.setRightCode(rightList.toArray(new String[0]));
            return makeSessionManager(managerInfo);
            user.setRightCode(rightList.toArray(new String[0]));
            return makeSessionManager(user);
        }
        return null;
    }
@@ -86,14 +90,14 @@ public class SysService {
    @Post
    @Path("/manager/changepasswd")
    public int changeManagerPasswd(@JdbcConn(true) Connection con, @LoginUser SessionManager loginUser, String opw, String npw) throws SQLException {
        return userDao.changePasswd(con, loginUser.getId(), StringUtil.md5(opw), StringUtil.md5(npw));
    public int changeManagerPasswd(@JdbcConn(true) Connection con, @LoginUser SessionManager loginUser, String npw) throws SQLException {
        return userDao.changeManagerPasswd(con, loginUser.getId(),StringUtil.md5(npw));
    }
    @Put
    @Path("/manager")
    public void modifyManager(@JdbcConn(true) Connection con, @LoginUser SessionManager loginUser,
                              @RequestParam(excludeFields = {"id", "createTime", "modifyTime", "account", "passwd", "active"}) Manager user) throws SQLException {
                              @RequestParam(excludeFields = {"id", "createTime", "modifyTime", "passwd", "active"}) Manager user) throws SQLException {
        user.setModifier(loginUser.getId());
        userDao.update(con, user);
    }
@@ -115,19 +119,18 @@ public class SysService {
    @Get
    @Path("/resetpw")
    public void managerResetPw(@JdbcConn(true) Connection con, String id) throws SQLException {
        userDao.resetPasswd(con, id, StringUtil.md5("123456"));
        userDao.managerResetPasswd(con, id, StringUtil.md5("123456"));
    }
    @LoginUser
    @Get
    @Path("/pq")
    public PageQueryResult<SessionManager> managerPageQuery(@JdbcConn Connection con, boolean active, int pageSize, int pageNo) throws SQLException {
        PageQueryResult<Manager> pageQueryResult = userDao.managerPageQuery(con, active, pageSize, pageNo);
        List<Manager> managers = pageQueryResult.getData();
    public PageQueryResult<SessionManager> managerPageQuery(@JdbcConn Connection con,@LoginUser SessionManager user, boolean active, int pageSize, int pageNo) throws SQLException {
        PageQueryResult<ManagerInfo> pageQueryResult = userDao.managerPageQuery(con,user.getId(), active, pageSize, pageNo);
        List<ManagerInfo> managers = pageQueryResult.getData();
        List<SessionManager> sessionManagers = new ArrayList<>();
        if (!managers.isEmpty()) {
            for (Manager manager : managers) {
                sessionManagers.add(makeSessionManager((ManagerInfo) manager));
            for (ManagerInfo manager : managers) {
                sessionManagers.add(makeSessionManager(manager));
            }
            PageQueryResult<SessionManager> ret = new PageQueryResult<>();
            ret.setPageNo(pageQueryResult.getPageNo());
@@ -143,19 +146,19 @@ public class SysService {
    @Get
    @Path("/qo")
    public SessionManager managerQueryOne(@JdbcConn Connection con, String id) throws SQLException {
        Manager manager = userDao.managerQuery(con, id);
        ManagerInfo managerInfo = (ManagerInfo) manager;
        List<String> rightList = userDao.right(con, manager.getId());
        ManagerInfo managerInfo = userDao.managerQuery(con, id);
        List<String> rightList = userDao.right(con, managerInfo.getId());
        managerInfo.setRightCode(rightList.toArray(new String[0]));
        return makeSessionManager(managerInfo);
    }
    @Path("/new")
    @Post
    public String addUser(@JdbcConn(true) Connection con, @LoginUser AuthUser au, @RequestParam(excludeFields = {"id", "acitve", "createor"}) Manager user, String[] rightCode) throws SQLException {
    public String addUser(@JdbcConn(true) Connection con, @LoginUser SessionManager au, @RequestParam(excludeFields = {"id", "acitve", "createor"}) Manager user, String[] rightCode) throws SQLException {
        String id = StringUtil.buildUUID();
        user.setActived(true);
        user.setCreator(au.getId());
        user.setModifier(au.getId());
        user.setId(id);
        user.setInvalidOperator(null);
        user.setInvalidTime(null);
@@ -175,7 +178,7 @@ public class SysService {
    @Path("/renew")
    @Put
    public void renewUser(@JdbcConn(true) Connection con, @LoginUser AuthUser au, @RequestBody ManagerInfo user) throws SQLException {
    public void renewUser(@JdbcConn(true) Connection con, @LoginUser SessionManager au, @RequestBody ManagerInfo user) throws SQLException {
        user.setModifier(au.getId());
        userDao.update(con, user);
        userDao.delete(con, user.getId(), this.fixRightCode);
@@ -238,9 +241,74 @@ public class SysService {
        userDao.validUser(con, id);
    }
    @LoginUser
    @Path("/user/pq")
    @Get
    public PageQueryResult<SessionUser> pageQuery(@JdbcConn Connection con, @Nullable String key, int pageSize, int pageNo) throws SQLException {
        PageQueryResult<User> pageQueryResult = userDao.pageQuery(con, key == null ? null : "%" + key + "%", pageSize, pageNo);
        List<User> users = pageQueryResult.getData();
        List<SessionUser> sessionUsers = new ArrayList<>();
        if (!users.isEmpty()) {
            for (User user : users) {
                sessionUsers.add(makeSessionUser(user));
            }
            PageQueryResult<SessionUser> ret = new PageQueryResult<>();
            ret.setPageNo(pageQueryResult.getPageNo());
            ret.setPageSize(pageQueryResult.getPageSize());
            ret.setTotal(pageQueryResult.getTotal());
            ret.setData(sessionUsers);
            return ret;
        }
        return null;
    }
    @LoginUser
    @Path("/user/invalid/pq")
    @Get
    public PageQueryResult<InvalidUser> pageQueryInvalidUser(@JdbcConn Connection con, @Nullable String key, int pageSize, int pageNo) throws SQLException {
        return userDao.pageQueryInvalidUser(con, key == null ? null : "%" + key + "%", pageSize, pageNo);
    }
    @LoginUser
    @Path("/user/qo")
    @Get
    public SessionUser query(@JdbcConn Connection con, String id) throws SQLException {
        User user = userDao.query(con, id);
        return makeSessionUser(user);
    }
    @LoginUser
    @Path("/user/invalid/qo")
    @Get
    public InvalidUser queryInvalidUser(@JdbcConn Connection con, String id) throws SQLException {
        return userDao.queryInvalidUser(con, id);
    }
    @LoginUser
    @Path("/user/lastTime")
    @Get
    public List<Map<String, Object>> queryLastTime(@JdbcConn Connection con, final String[] ids) throws SQLException {
        final StringBuilder stringBuilder = new StringBuilder();
        stringBuilder.append("SELECT ID,LAST_LOGIN_TIME WHERE ID IN(");
        for (String id : ids) {
            stringBuilder.append("?,");
        }
        stringBuilder.setCharAt(stringBuilder.length() - 1, ')');
        return JdbcUtil.queryMaps(con, stringBuilder.toString(), new PreparedStatementConfig() {
            @Override
            public void config(PreparedStatement preparedStatement) throws SQLException {
                int i = 1;
                for (String id : ids) {
                    preparedStatement.setString(i++, id);
                }
            }
        });
    }
    private static SessionManager makeSessionManager(ManagerInfo manager) {
        SessionManager sessionManager = new SessionManager();
        sessionManager.setId(manager.getId());
        sessionManager.setName(manager.getName());
        sessionManager.setAccount(manager.getAccount());
        sessionManager.setPhone(manager.getPhone());
        sessionManager.setEmail(manager.getEmail());
@@ -254,4 +322,24 @@ public class SysService {
        return sessionManager;
    }
    private static SessionUser makeSessionUser(User user) {
        SessionUser sessionUser = new SessionUser();
        sessionUser.setAccount(user.getAccount());
        sessionUser.setComp(user.getComp());
        sessionUser.setEmail(user.getEmail());
        sessionUser.setId(user.getId());
        sessionUser.setJob(user.getJob());
        sessionUser.setName(user.getName());
        sessionUser.setActive(user.isActive());
        sessionUser.setAddr(user.getAccount());
        sessionUser.setCreateTime(user.getCreateTime());
        sessionUser.setHead(user.getHead());
        sessionUser.setLinkPhone(user.getLinkPhone());
        sessionUser.setLoginPhone(user.getLoginPhone());
        sessionUser.setModifyTime(user.getModifyTime());
        sessionUser.setSex(user.getSex());
        return sessionUser;
    }
}

src/main/resources/.gitignore

@@ -1 +1 @@
/dev.properties
/dev1.properties

src/main/resources/database.sql

@@ -0,0 +1,353 @@
CREATE TABLE INVALID_USER (
        ID CHAR(32) NOT NULL,
        NAME TEXT,
        ACCOUNT TEXT NOT NULL,
        COMP TEXT,
        JOB TEXT,
        LINK_PHONE TEXT,
        EMAIL TEXT,
        SEX CHAR(1),
        LOGIN_PHONE TEXT NOT NULL,
        ADDR TEXT,
        HEAD TEXT,
        INVALID_TIME CHAR(14) NOT NULL,
        INVALID_OPERATOR TEXT NOT NULL,
        INVALID_REASON TEXT NOT NULL);
COMMENT ON TABLE INVALID_USER IS '拉黑用户表';
COMMENT ON COLUMN INVALID_USER.ID IS '用户ID';
COMMENT ON COLUMN INVALID_USER.NAME IS '真实姓名';
COMMENT ON COLUMN INVALID_USER.ACCOUNT IS '用户名';
COMMENT ON COLUMN INVALID_USER.COMP IS '用户所属单位';
COMMENT ON COLUMN INVALID_USER.JOB IS '用户职位';
COMMENT ON COLUMN INVALID_USER.LINK_PHONE IS '联系电话';
COMMENT ON COLUMN INVALID_USER.EMAIL IS '联系邮件';
COMMENT ON COLUMN INVALID_USER.SEX IS '性别';
COMMENT ON COLUMN INVALID_USER.LOGIN_PHONE IS '登录手机号';
COMMENT ON COLUMN INVALID_USER.ADDR IS '所在城市编码';
COMMENT ON COLUMN INVALID_USER.HEAD IS '头像';
COMMENT ON COLUMN INVALID_USER.INVALID_TIME IS '最后拉黑时间（YYYYMMDDHH24MISS）不可修改';
COMMENT ON COLUMN INVALID_USER.INVALID_OPERATOR IS '最后拉黑人';
COMMENT ON COLUMN INVALID_USER.INVALID_REASON IS '拉黑原因';
CREATE TABLE PRODUCT_KEY_WORD (
        ID CHAR(32) NOT NULL,
        KEYWORD TEXT,
        NUM INTEGER NOT NULL);
COMMENT ON TABLE PRODUCT_KEY_WORD IS '产品关键词';
COMMENT ON COLUMN PRODUCT_KEY_WORD.ID IS '产品ID';
COMMENT ON COLUMN PRODUCT_KEY_WORD.KEYWORD IS '关键词';
COMMENT ON COLUMN PRODUCT_KEY_WORD.NUM IS '序号';
create sequence product_share_id_seq increment by 1 minvalue 100000 no maxvalue start with 100000;
CREATE TABLE PRODUCT (
        ID CHAR(32) NOT NULL,
        SHARE_ID int8 DEFAULT nextval('product_share_id_seq'::regclass) NOT NULL,
        COMPANY_ID CHAR(32) NOT NULL,
        IMG TEXT,
        NAME TEXT,
        CNT TEXT,
        DESCP TEXT,
        SPEC TEXT,
        PRODUCING_AREA TEXT,
        PRICE TEXT,
        PARAMETER TEXT,
        ACTIVE CHAR(1) NOT NULL,
        CREATOR CHAR(32) NOT NULL,
        MODIFIER CHAR(32) NOT NULL,
        CREATE_TIME CHAR(14) NOT NULL,
        MODIFY_TIME CHAR(14) NOT NULL);
ALTER TABLE PRODUCT ADD PRIMARY KEY (ID);
COMMENT ON TABLE PRODUCT IS '产品表';
COMMENT ON COLUMN PRODUCT.ID IS '产品ID';
COMMENT ON COLUMN PRODUCT.SHARE_ID IS '分享ID';
COMMENT ON COLUMN PRODUCT.COMPANY_ID IS '所属企业ID';
COMMENT ON COLUMN PRODUCT.IMG IS '产品图片';
COMMENT ON COLUMN PRODUCT.NAME IS '产品名称';
COMMENT ON COLUMN PRODUCT.CNT IS '产品简介';
COMMENT ON COLUMN PRODUCT.DESCP IS '产品描述';
COMMENT ON COLUMN PRODUCT.SPEC IS '厂商型号';
COMMENT ON COLUMN PRODUCT.PRODUCING_AREA IS '产地';
COMMENT ON COLUMN PRODUCT.PRICE IS '价格';
COMMENT ON COLUMN PRODUCT.PARAMETER IS '性能参数';
COMMENT ON COLUMN PRODUCT.ACTIVE IS '有效标识';
COMMENT ON COLUMN PRODUCT.CREATOR IS '创建人ID';
COMMENT ON COLUMN PRODUCT.MODIFIER IS '最后修改人';
COMMENT ON COLUMN PRODUCT.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
COMMENT ON COLUMN PRODUCT.MODIFY_TIME IS '最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101';
create sequence organization_share_id_seq increment by 1 minvalue 100000 no maxvalue start with 100000;
CREATE TABLE ORGANIZATION (
        ID TEXT NOT NULL,
        SHARE_ID int8 DEFAULT nextval('organization_share_id_seq'::regclass) NOT NULL,
        LEVEL INTEGER,
        ASS_TIME TEXT NOT NULL);
ALTER TABLE ORGANIZATION ADD PRIMARY KEY (ID);
COMMENT ON TABLE ORGANIZATION IS '合作机构表';
COMMENT ON COLUMN ORGANIZATION.ID IS '合作机构ID';
COMMENT ON COLUMN ORGANIZATION.SHARE_ID IS '合作机构共享ID';
COMMENT ON COLUMN ORGANIZATION.LEVEL IS '排序字段';
COMMENT ON COLUMN ORGANIZATION.ASS_TIME IS '入驻时间';
CREATE TABLE USER_LOGIN_LOG (
        ID TEXT NOT NULL,
        LAST_LOGIN_TIME TEXT NOT NULL);
ALTER TABLE USER_LOGIN_LOG ADD PRIMARY KEY (ID);
COMMENT ON TABLE USER_LOGIN_LOG IS '登录日志表';
COMMENT ON COLUMN USER_LOGIN_LOG.ID IS '用户ID';
COMMENT ON COLUMN USER_LOGIN_LOG.LAST_LOGIN_TIME IS '最后登录时间';
CREATE TABLE MANAGER (
        ID CHAR(32) NOT NULL,
        ACCOUNT TEXT NOT NULL,
        PASSWD TEXT NOT NULL,
        NAME TEXT,
        PHONE TEXT,
        EMAIL TEXT,
        JOB TEXT,
        DEP TEXT,
        COMP TEXT,
        ACTIVED CHAR(1) NOT NULL,
        INVALID_TIME TEXT,
        INVALID_OPERATOR TEXT,
        CREATOR CHAR(32) NOT NULL,
        MODIFIER CHAR(32) NOT NULL,
        CREATE_TIME CHAR(14) NOT NULL,
        MODIFY_TIME CHAR(14) NOT NULL);
ALTER TABLE MANAGER ADD PRIMARY KEY (ID);
COMMENT ON TABLE MANAGER IS '后台管理用户表';
COMMENT ON COLUMN MANAGER.ID IS '后台用户ID';
COMMENT ON COLUMN MANAGER.ACCOUNT IS '后台用户帐号';
COMMENT ON COLUMN MANAGER.PASSWD IS '后台用户密码（md5）';
COMMENT ON COLUMN MANAGER.NAME IS '后台用户姓名';
COMMENT ON COLUMN MANAGER.PHONE IS '后台用户电话';
COMMENT ON COLUMN MANAGER.EMAIL IS '后台用户邮箱';
COMMENT ON COLUMN MANAGER.JOB IS '后台用户职位';
COMMENT ON COLUMN MANAGER.DEP IS '后台用户部门';
COMMENT ON COLUMN MANAGER.COMP IS '后台用户所在机构';
COMMENT ON COLUMN MANAGER.ACTIVED IS '后台用户帐号状态';
COMMENT ON COLUMN MANAGER.INVALID_TIME IS '后台用户最后停用时间';
COMMENT ON COLUMN MANAGER.INVALID_OPERATOR IS '后台用户最后停用人';
COMMENT ON COLUMN MANAGER.CREATOR IS '创建人ID';
COMMENT ON COLUMN MANAGER.MODIFIER IS '最后修改人ID';
COMMENT ON COLUMN MANAGER.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
COMMENT ON COLUMN MANAGER.MODIFY_TIME IS '最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101';
CREATE TABLE PLATFORM (
        ID CHAR(32) NOT NULL,
        NAME TEXT,
        LOGO TEXT,
        DESCP TEXT,
        URL TEXT,
        ADDR TEXT,
        LOCATION TEXT,
        ZIP_CODE TEXT,
        SERVICE_PHONE TEXT,
        SERVICE_EMAIL TEXT,
        OPERATE_TIME TEXT,
        MANAGE_ORG TEXT,
        LINKMAN TEXT,
        DEPARTMENT TEXT,
        JOB TEXT,
        COMP TEXT,
        LINKPHONE TEXT,
        LINKEMAIL TEXT,
        CREATOR CHAR(32) NOT NULL,
        MODIFIER CHAR(32) NOT NULL,
        CREATE_TIME CHAR(14) NOT NULL,
        MODIFY_TIME CHAR(14) NOT NULL);
ALTER TABLE PLATFORM ADD PRIMARY KEY (ID);
COMMENT ON TABLE PLATFORM IS '平台信息表';
COMMENT ON COLUMN PLATFORM.ID IS '平台ID';
COMMENT ON COLUMN PLATFORM.NAME IS '平台名称';
COMMENT ON COLUMN PLATFORM.LOGO IS '平台logo';
COMMENT ON COLUMN PLATFORM.DESCP IS '平台简介';
COMMENT ON COLUMN PLATFORM.URL IS '平台网址';
COMMENT ON COLUMN PLATFORM.ADDR IS '所在城市编码';
COMMENT ON COLUMN PLATFORM.LOCATION IS '平台地址';
COMMENT ON COLUMN PLATFORM.ZIP_CODE IS '平台邮编';
COMMENT ON COLUMN PLATFORM.SERVICE_PHONE IS '客服电话';
COMMENT ON COLUMN PLATFORM.SERVICE_EMAIL IS '客服邮箱';
COMMENT ON COLUMN PLATFORM.OPERATE_TIME IS '工作时间';
COMMENT ON COLUMN PLATFORM.MANAGE_ORG IS '管理机构';
COMMENT ON COLUMN PLATFORM.LINKMAN IS '联系人';
COMMENT ON COLUMN PLATFORM.DEPARTMENT IS '联系人所在部门';
COMMENT ON COLUMN PLATFORM.JOB IS '联系人职位';
COMMENT ON COLUMN PLATFORM.COMP IS '联系人所属单位';
COMMENT ON COLUMN PLATFORM.LINKPHONE IS '联系人电话';
COMMENT ON COLUMN PLATFORM.LINKEMAIL IS '联系人邮箱';
COMMENT ON COLUMN PLATFORM.CREATOR IS '创建人ID';
COMMENT ON COLUMN PLATFORM.MODIFIER IS '最后修改人ID';
COMMENT ON COLUMN PLATFORM.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
COMMENT ON COLUMN PLATFORM.MODIFY_TIME IS '最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101';
create sequence professor_share_id_seq increment by 1 minvalue 100000 no maxvalue start with 100000;
CREATE TABLE PROFESSOR (
        ID TEXT NOT NULL,
        SHARE_ID int8 DEFAULT nextval('professor_share_id_seq'::regclass) NOT NULL,
        LEVEL INTEGER,
        ASS_TIME TEXT NOT NULL);
ALTER TABLE PROFESSOR ADD PRIMARY KEY (ID);
COMMENT ON TABLE PROFESSOR IS '特约专家表';
COMMENT ON COLUMN PROFESSOR.ID IS '特约专家ID';
COMMENT ON COLUMN PROFESSOR.SHARE_ID IS '特约专家共享ID';
COMMENT ON COLUMN PROFESSOR.LEVEL IS '排序字段';
COMMENT ON COLUMN PROFESSOR.ASS_TIME IS '入驻时间';
CREATE TABLE SYS_RIGHT (
        UID CHAR(32) NOT NULL,
        RIGHT_CODE TEXT NOT NULL);
COMMENT ON TABLE SYS_RIGHT IS '用户权限表';
COMMENT ON COLUMN SYS_RIGHT.UID IS '后台用户ID';
COMMENT ON COLUMN SYS_RIGHT.RIGHT_CODE IS '权限码';
CREATE TABLE ARTICLE_PRO (
        ARTICLE_ID CHAR(32) NOT NULL,
        PROFESSOR_ID CHAR(32) NOT NULL,
        CREATE_TIME CHAR(14) NOT NULL);
COMMENT ON TABLE ARTICLE_PRO IS '内容关联专家';
COMMENT ON COLUMN ARTICLE_PRO.ARTICLE_ID IS '内容ID';
COMMENT ON COLUMN ARTICLE_PRO.PROFESSOR_ID IS '专家ID';
COMMENT ON COLUMN ARTICLE_PRO.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
create sequence article_share_id_seq increment by 1 minvalue 100000 no maxvalue start with 100000;
CREATE TABLE ARTICLE (
        ID CHAR(32) NOT NULL,
        SHARE_ID int8 DEFAULT nextval('article_share_id_seq'::regclass) NOT NULL,
        CATALOG TEXT,
        TITLE TEXT NOT NULL,
        SOURCE TEXT,
        IMG_URL TEXT,
        CNT TEXT,
        PUBLISHED CHAR(1) NOT NULL,
        ACTIVED CHAR(1) NOT NULL,
        PROFESSOR TEXT,
        ORG TEXT,
        COMP TEXT,
        CREATOR CHAR(32) NOT NULL,
        MODIFIER CHAR(32) NOT NULL,
        CREATE_TIME CHAR(14) NOT NULL,
        MODIFY_TIME CHAR(14) NOT NULL);
ALTER TABLE ARTICLE ADD PRIMARY KEY (ID);
COMMENT ON TABLE ARTICLE IS '内容表';
COMMENT ON COLUMN ARTICLE.ID IS '内容ID';
COMMENT ON COLUMN ARTICLE.SHARE_ID IS '内容分享ID';
COMMENT ON COLUMN ARTICLE.CATALOG IS '内容栏目';
COMMENT ON COLUMN ARTICLE.TITLE IS '内容标题';
COMMENT ON COLUMN ARTICLE.SOURCE IS '内容来源';
COMMENT ON COLUMN ARTICLE.IMG_URL IS '封面图片';
COMMENT ON COLUMN ARTICLE.CNT IS '内容';
COMMENT ON COLUMN ARTICLE.PUBLISHED IS '内容状态';
COMMENT ON COLUMN ARTICLE.ACTIVED IS '有效标志';
COMMENT ON COLUMN ARTICLE.PROFESSOR IS '关联专家';
COMMENT ON COLUMN ARTICLE.ORG IS '关联机构';
COMMENT ON COLUMN ARTICLE.COMP IS '关联企业';
COMMENT ON COLUMN ARTICLE.CREATOR IS '创建人ID';
COMMENT ON COLUMN ARTICLE.MODIFIER IS '最后修改人ID';
COMMENT ON COLUMN ARTICLE.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
COMMENT ON COLUMN ARTICLE.MODIFY_TIME IS '最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101';
CREATE TABLE COMP_KEY_WORD (
        ID TEXT NOT NULL,
        TYPE INTEGER NOT NULL,
        VALUE TEXT NOT NULL,
        NUM INTEGER NOT NULL);
COMMENT ON TABLE COMP_KEY_WORD IS '企业关键词';
COMMENT ON COLUMN COMP_KEY_WORD.ID IS '企业ID';
COMMENT ON COLUMN COMP_KEY_WORD.TYPE IS '关键词类型（所属行业：1，专注领域：2，企业资质：3，供应商领域：4，客户领域：5）';
COMMENT ON COLUMN COMP_KEY_WORD.VALUE IS '关键词';
COMMENT ON COLUMN COMP_KEY_WORD.NUM IS '序号';
CREATE TABLE COMP_INVITE (
        ID CHAR(32) NOT NULL,
        EMAIL TEXT NOT NULL,
        INVITE_CODE TEXT NOT NULL,
        LAST_TIME CHAR(14) NOT NULL,
        LAST_INVITER CHAR(32) NOT NULL,
        ACTIVE CHAR(1) NOT NULL);
COMMENT ON TABLE COMP_INVITE IS '企业邀请表';
COMMENT ON COLUMN COMP_INVITE.ID IS '企业ID';
COMMENT ON COLUMN COMP_INVITE.EMAIL IS '联系邮箱';
COMMENT ON COLUMN COMP_INVITE.INVITE_CODE IS '邀请码';
COMMENT ON COLUMN COMP_INVITE.LAST_TIME IS '最后邀请时间';
COMMENT ON COLUMN COMP_INVITE.LAST_INVITER IS '最后邀请人';
COMMENT ON COLUMN COMP_INVITE.ACTIVE IS '有效标识';
create sequence company_share_id_seq increment by 1 minvalue 100000 no maxvalue start with 100000;
CREATE TABLE COMPANY (
        ID CHAR(32) NOT NULL,
        SHARE_ID int8 DEFAULT nextval('company_share_id_seq'::regclass) NOT NULL,
        NAME TEXT NOT NULL,
        LOGO TEXT,
        TYPE CHAR(1),
        SIZE TEXT,
        FOUND_YEAR TEXT,
        DESCP TEXT,
        URL TEXT,
        LOCATION TEXT,
        ADDR TEXT,
        ZIP_CODE TEXT,
        SERVICE_PHONE TEXT,
        SERVICE_EMAIL TEXT,
        OPERATE_TIME TEXT,
        LINKMAN TEXT,
        JOB TEXT,
        DEPARTMENT TEXT,
        LINKPHONE TEXT,
        LINKEMAIL TEXT,
        ACTIVE CHAR(1) NOT NULL,
        ACTIVE_TIME CHAR(14),
        CREATOR CHAR(32) NOT NULL,
        MODIFIER CHAR(32) NOT NULL,
        CREATE_TIME CHAR(14) NOT NULL,
        MODIFY_TIME CHAR(14) NOT NULL);
ALTER TABLE COMPANY ADD PRIMARY KEY (ID);
COMMENT ON TABLE COMPANY IS '企业信息';
COMMENT ON COLUMN COMPANY.ID IS '企业ID';
COMMENT ON COLUMN COMPANY.SHARE_ID IS '共享ID';
COMMENT ON COLUMN COMPANY.NAME IS '企业名称';
COMMENT ON COLUMN COMPANY.LOGO IS '企业logo';
COMMENT ON COLUMN COMPANY.TYPE IS '企业类型';
COMMENT ON COLUMN COMPANY.SIZE IS '企业规模';
COMMENT ON COLUMN COMPANY.FOUND_YEAR IS '创立年份';
COMMENT ON COLUMN COMPANY.DESCP IS '企业简介';
COMMENT ON COLUMN COMPANY.URL IS '官方网址';
COMMENT ON COLUMN COMPANY.LOCATION IS '所在地';
COMMENT ON COLUMN COMPANY.ADDR IS '企业地址';
COMMENT ON COLUMN COMPANY.ZIP_CODE IS '企业邮编';
COMMENT ON COLUMN COMPANY.SERVICE_PHONE IS '客服电话';
COMMENT ON COLUMN COMPANY.SERVICE_EMAIL IS '客服邮箱';
COMMENT ON COLUMN COMPANY.OPERATE_TIME IS '工作时间';
COMMENT ON COLUMN COMPANY.LINKMAN IS '联系人';
COMMENT ON COLUMN COMPANY.JOB IS '联系人职位';
COMMENT ON COLUMN COMPANY.DEPARTMENT IS '所在部门';
COMMENT ON COLUMN COMPANY.LINKPHONE IS '联系人电话';
COMMENT ON COLUMN COMPANY.LINKEMAIL IS '联系人邮箱';
COMMENT ON COLUMN COMPANY.ACTIVE IS '激活状态';
COMMENT ON COLUMN COMPANY.ACTIVE_TIME IS '激活时间';
COMMENT ON COLUMN COMPANY.CREATOR IS '创建人ID';
COMMENT ON COLUMN COMPANY.MODIFIER IS '最后修改人ID';
COMMENT ON COLUMN COMPANY.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
COMMENT ON COLUMN COMPANY.MODIFY_TIME IS '最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101';
CREATE TABLE INVALID_ARTICLE (
        ID TEXT NOT NULL,
        TITLE TEXT NOT NULL,
        CATALOG TEXT,
        CREATOR TEXT NOT NULL,
        CREATE_TIME TEXT NOT NULL,
        INVALID_TIME TEXT NOT NULL,
        INVALID_OPERATOR TEXT NOT NULL);
ALTER TABLE INVALID_ARTICLE ADD PRIMARY KEY (ID);
COMMENT ON TABLE INVALID_ARTICLE IS '无效内容表';
COMMENT ON COLUMN INVALID_ARTICLE.ID IS '内容ID';
COMMENT ON COLUMN INVALID_ARTICLE.TITLE IS '内容标题';
COMMENT ON COLUMN INVALID_ARTICLE.CATALOG IS '内容栏目';
COMMENT ON COLUMN INVALID_ARTICLE.CREATOR IS '内容创建人';
COMMENT ON COLUMN INVALID_ARTICLE.CREATE_TIME IS '内容创建时间';
COMMENT ON COLUMN INVALID_ARTICLE.INVALID_TIME IS '最后删除时间';
COMMENT ON COLUMN INVALID_ARTICLE.INVALID_OPERATOR IS '最后删除人';
CREATE TABLE ARTICLE_COMP (
        ARTICLE_ID CHAR(32) NOT NULL,
        COMP_ID CHAR(32) NOT NULL,
        CREATE_TIME CHAR(14) NOT NULL);
COMMENT ON TABLE ARTICLE_COMP IS '内容关联企业';
COMMENT ON COLUMN ARTICLE_COMP.ARTICLE_ID IS '内容ID';
COMMENT ON COLUMN ARTICLE_COMP.COMP_ID IS '企业ID';
COMMENT ON COLUMN ARTICLE_COMP.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
CREATE TABLE ARTICLE_ORG (
        ARTICLE_ID CHAR(32) NOT NULL,
        ORG_ID CHAR(32) NOT NULL,
        CREATE_TIME CHAR(14) NOT NULL);
COMMENT ON TABLE ARTICLE_ORG IS '内容关联机构';
COMMENT ON COLUMN ARTICLE_ORG.ARTICLE_ID IS '内容ID';
COMMENT ON COLUMN ARTICLE_ORG.ORG_ID IS '机构ID';
COMMENT ON COLUMN ARTICLE_ORG.CREATE_TIME IS '创建时间（YYYYMMDDHH24MISS）不可修改';
INSERT INTO "public"."manager" ("id", "account", "passwd", "name", "phone", "email", "job", "dep", "comp", "actived", "invalid_time", "invalid_operator","create_time","creator","modify_time","modifier") VALUES ('4733F3525B4E40719242AB154932CAA5', '18888888888', 'E10ADC3949BA59ABBE56E057F20F883E', 'admin', '18888888888', 'admin@ekexiu.com', '11', '11', '11', '1','','', '20180718091626', '4733F3525B4E40719242AB154932CAA5','20180718091626', '4733F3525B4E40719242AB154932CAA5');