产品相关

src/main/java/com/ekexiu/console/system/dao/OrgLinkManDao.java

@@ -0,0 +1,43 @@
package com.ekexiu.console.system.dao;
import com.ekexiu.console.system.po.OrgLinkMan;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.Batch;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
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.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
@DAO
public interface OrgLinkManDao {
	@Insert
	@Batch
	int[] insert(Connection con, OrgLinkMan[] man)throws SQLException;
	@DeleteWith
	@From(OrgLinkMan.class)
	int deleteByOid(Connection con, String oid)throws SQLException;
	@DeleteWith
	@From(OrgLinkMan.class)
	int deleteByPid(Connection con, String pid)throws SQLException;
	@SelectOne
	@Nullable
	OrgLinkMan queryByPid(Connection con, String pid)throws SQLException;
	@SelectList
	@OrderBy("ORDER BY SEQ ASC")
	List<OrgLinkMan> queryByOid(Connection con, String oid)throws SQLException;
	
}

src/main/java/com/ekexiu/console/system/dao/ProductDao.java

@@ -0,0 +1,67 @@
package com.ekexiu.console.system.dao;
import com.ekexiu.console.system.po.Product;
import com.ekexiu.console.system.po.ProductPro;
import com.ekexiu.console.system.pojo.ProductInfo;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.Exclude;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.PageQuery;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
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.GtEq;
import org.jfw.apt.orm.annotation.dao.param.Like;
import org.jfw.apt.orm.annotation.dao.param.LtEq;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.apt.orm.annotation.dao.param.SqlColumn;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
/**
 * Created by TT on 2018/7/17.
 */
@DAO
public interface ProductDao {
    @SelectOne
    @Nullable
    Product queryById(Connection con, String id) throws SQLException;
    @PageQuery
    @OrderBy(" ORDER BY MODIFY_TIME DESC NULLS LAST")
    @Where("STATE = '1'")
    @Exclude("descp")
    PageQueryResult<ProductInfo> queryByTime(Connection con, @Nullable @Like String name, @SqlColumn(value = {"(p.name is null or p.name like ?)", "(o.name is null or o.name like ?)"}, handlerClass = StringHandler.class) String ownerName, @Nullable @GtEq @Alias("modifyTime") String bt, @Nullable @Alias("modifyTime") @LtEq String et, int pageSize, int pageNo) throws SQLException;
    @SelectList
    List<ProductPro> queryPro(Connection con, String id) throws SQLException;
    @UpdateWith
    @From(Product.class)
    @Where("STATE<>'0'")
    @SetSentence("STATE = '0'")
    int logicDelete(Connection con, String id) throws SQLException;
    @UpdateWith
    @From(Product.class)
    int updateKw(Connection con, String id, @Set String keywords) throws SQLException;
    @UpdateWith
    @From(Product.class)
    int updateSortFirst(Connection con, String id, @Set long sortFirst) throws SQLException;
    @DeleteWith
    @From(ProductPro.class)
    int deletePro(Connection con, String professor) throws SQLException;
}

src/main/java/com/ekexiu/console/system/dao/ProductKeyWordDao.java

@@ -0,0 +1,26 @@
package com.ekexiu.console.system.dao;
import com.ekexiu.console.system.po.ProductKeyWord;
import org.jfw.apt.orm.annotation.dao.Batch;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import java.sql.Connection;
import java.sql.SQLException;
/**
 * Created by TT on 2018/7/23.
 */
@DAO
public interface ProductKeyWordDao {
    @Insert
    @Batch
    int[] insert(Connection con, ProductKeyWord productKeyWord[]) throws SQLException;
    @DeleteWith
    @From(ProductKeyWord.class)
    int delete(Connection con, String id) throws SQLException;
}

src/main/java/com/ekexiu/console/system/dao/WareDao.java

@@ -87,4 +87,8 @@ public interface WareDao {
    @SelectList
    List<WarePro> queryPro(Connection con, String id) throws SQLException;
    @DeleteWith
    @From(WarePro.class)
    int deletePro(Connection con, String professor) throws SQLException;
}

src/main/java/com/ekexiu/console/system/po/Demand.java

@@ -27,7 +27,6 @@ public class Demand implements CreateTimeSupported, ModifyTimeSupported {
    private String state;
    private String orgName;
    private String modifier;
    private String creator;
    private String createTime;
    private String modifyTime;
@@ -178,19 +177,6 @@ public class Demand implements CreateTimeSupported, ModifyTimeSupported {
        this.source = source;
    }
    /**
     * 最后修改人
     * @return
     */
    @Column(handlerClass = FixLenStringHandler.class, dbType = "CHAR(32)", insertable = true, nullable = false, queryable = true, renewable = true)
    public String getModifier() {
        return modifier;
    }
    public void setModifier(String modifier) {
        this.modifier = modifier;
    }
    /**
     * 发布人ID
     * @return

src/main/java/com/ekexiu/console/system/po/OrgLinkMan.java

@@ -0,0 +1,37 @@
package com.ekexiu.console.system.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@PrimaryKey({"oid","pid"})
@Table
public class OrgLinkMan {
	private String oid;
	private String pid;
	private int seq;
	@Column(DE.text_de)
	public String getOid() {
		return oid;
	}
	public void setOid(String oid) {
		this.oid = oid;
	}
	@Column(DE.text_de)
	public String getPid() {
		return pid;
	}
	public void setPid(String pid) {
		this.pid = pid;
	}
	@Column(DE.int_de)
	public int getSeq() {
		return seq;
	}
	public void setSeq(int seq) {
		this.seq = seq;
	}
	
	
}

src/main/java/com/ekexiu/console/system/po/Product.java

@@ -0,0 +1,232 @@
package com.ekexiu.console.system.po;
import com.ekexiu.console.basepo.CreateTimeSupported;
import com.ekexiu.console.basepo.ModifyTimeSupported;
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.defaultImpl.LongHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.apt.orm.core.enums.DE;
/**
 * Created by TT on 2018/7/17.
 */
@PrimaryKey("id")
@Table
public class Product implements CreateTimeSupported, ModifyTimeSupported {
    private String id;
    private String name;
    /**
     * 关键字
     */
    private String keywords;
    /**
     *产品简介
     */
    private String cnt;
    /**
     *详细描述
     */
    private String descp;
    /**
     * 厂商型号
     */
    private String spec;
    /**
     * 产地
     */
    private String  producingArea;
    /**
     * 官方价格
     */
    private String price;
    /**
     *性能参数
     */
    private String parameter;
    /**
     *发布者
     */
    private String owner;
    /**
     *图片
     */
    private String images;
    /***
     *状态 0：删除，1:发布的 ，2：草稿
     */
    private String state;
    /**
     *创建时间
     */
    private String createTime;
    /**
     *最后修改时间
     */
    private String modifyTime;
    private long shareId;
    private long pageViews;
    private long sortFirst;
    @Column(DE.id_32)
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    @Column(DE.text_de)
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    @Column(DE.Text_de)
    public String getKeywords() {
        return keywords;
    }
    public void setKeywords(String keywords) {
        this.keywords = keywords;
    }
    @Column(DE.Text_de)
    public String getCnt() {
        return cnt;
    }
    public void setCnt(String cnt) {
        this.cnt = cnt;
    }
    @Column(DE.Text_de)
    public String getDescp() {
        return descp;
    }
    public void setDescp(String descp) {
        this.descp = descp;
    }
    @Column(DE.Text_de)
    public String getParameter() {
        return parameter;
    }
    public void setParameter(String parameter) {
        this.parameter = parameter;
    }
    @Column(DE.Text_de)
    public String getSpec() {
        return spec;
    }
    public void setSpec(String spec) {
        this.spec = spec;
    }
    @Column(DE.Text_de)
    public String getProducingArea() {
        return producingArea;
    }
    public void setProducingArea(String producingArea) {
        this.producingArea = producingArea;
    }
    @Column(DE.Text_de)
    public String getPrice() {
        return price;
    }
    public void setPrice(String price) {
        this.price = price;
    }
    @Column(handlerClass = StringHandler.class, dbType = "TEXT", insertable = true, nullable = false, queryable = true, renewable = false)
    public String getOwner() {
        return owner;
    }
    public void setOwner(String owner) {
        this.owner = owner;
    }
    @Column(DE.Text_de)
    public String getImages() {
        return images;
    }
    public void setImages(String images) {
        this.images = images;
    }
    @Column(DE.singleChar)
    public String getState() {
        return state;
    }
    public void setState(String state) {
        this.state = state;
    }
    @Column(DE.bigSerial)
    public long getShareId() {
        return shareId;
    }
    public void setShareId(long shareId) {
        this.shareId = shareId;
    }
    @Column(handlerClass = LongHandler.class, dbType = "INT8", nullable = true, renewable = false, fixSqlValueWithInsert = "0")
    public long getPageViews() {
        return pageViews;
    }
    public void setPageViews(long pageViews) {
        this.pageViews = pageViews;
    }
    @Column(handlerClass = LongHandler.class, dbType = "INT8", fixSqlValueWithInsert = "0", insertable = true, renewable = false, queryable = true, nullable = false)
    public long getSortFirst() {
        return sortFirst;
    }
    public void setSortFirst(long sortFirst) {
        this.sortFirst = sortFirst;
    }
    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/console/system/po/ProductKeyWord.java

@@ -0,0 +1,33 @@
package com.ekexiu.console.system.po;
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/7/23.
 */
@Table("product_key_word")
public class ProductKeyWord {
    private String id;
    private String kw;
    @Column(DE.id_32)
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    @Column(DE.text_de)
    public String getKw() {
        return kw;
    }
    public void setKw(String kw) {
        this.kw = kw;
    }
}

src/main/java/com/ekexiu/console/system/po/ProductPro.java

@@ -0,0 +1,32 @@
package com.ekexiu.console.system.po;
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/7/17.
 */
@Table
public class ProductPro {
    private String id;
    private String professor;
    @Column(DE.text_de)
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    @Column(DE.text_de)
    public String getProfessor() {
        return professor;
    }
    public void setProfessor(String professor) {
        this.professor = professor;
    }
}

src/main/java/com/ekexiu/console/system/pojo/ProductInfo.java

@@ -0,0 +1,33 @@
package com.ekexiu.console.system.pojo;
import com.ekexiu.console.system.po.Product;
import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendView;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
/**
 * Created by TT on 2018/7/17.
 */
@ExtendView(fromSentence = "product pd LEFT JOIN professor p on p.id = pd.owner LEFT JOIN organization o on o.id = pd.owner ",tableAlias = "pd")
public class ProductInfo extends Product {
    private String professorName;
    private String orgName;
    @CalcColumn(handlerClass = StringHandler.class, column = "p.name")
    public String getProfessorName() {
        return professorName;
    }
    public void setProfessorName(String professorName) {
        this.professorName = professorName;
    }
    @CalcColumn(handlerClass = StringHandler.class, column = "o.name")
    public String getOrgName() {
        return orgName;
    }
    public void setOrgName(String orgName) {
        this.orgName = orgName;
    }
}

src/main/java/com/ekexiu/console/system/service/KeyWordService.java

@@ -32,6 +32,8 @@ public class KeyWordService {
    private ResResultKeyWordDao resResultKeyWordDao;
    @Autowrie
    private WareKeyWordDao wareKeyWordDao;
    @Autowrie
    private ProductKeyWordDao productKeyWordDao;
    public ProKeyWordDao getProKeyWordDao() {
        return proKeyWordDao;
@@ -97,6 +99,14 @@ public class KeyWordService {
        this.wareKeyWordDao = wareKeyWordDao;
    }
    public ProductKeyWordDao getProductKeyWordDao() {
        return productKeyWordDao;
    }
    public void setProductKeyWordDao(ProductKeyWordDao productKeyWordDao) {
        this.productKeyWordDao = productKeyWordDao;
    }
    public void refreshProfessor(Connection con, String id, String kw) throws SQLException {
        String[] kws = splitKeyWord(kw);
        proKeyWordDao.delete(con, id);
@@ -220,6 +230,21 @@ public class KeyWordService {
        wareKeyWordDao.delete(con, id);
    }
    public void refreshProduct(Connection con,String id,String kw)throws SQLException {
        String[] kws = splitKeyWord(kw);
        productKeyWordDao.delete(con, id);
        if (kw != null && kws.length > 0) {
            ProductKeyWord[] productKeyWords = new ProductKeyWord[kws.length];
            for (int i = 0;i<kws.length;++i) {
                ProductKeyWord productKeyWord = new ProductKeyWord();
                productKeyWord.setId(id);
                productKeyWord.setKw(kws[i]);
                productKeyWords[i] = productKeyWord;
            }
            productKeyWordDao.insert(con, productKeyWords);
        }
    }
    public static String[] splitKeyWord(String kws) {
        if (kws == null || kws.trim().length() == 0) return null;
        kws = kws.trim();

src/main/java/com/ekexiu/console/system/service/ProductService.java

@@ -0,0 +1,84 @@
package com.ekexiu.console.system.service;
import com.ekexiu.console.system.dao.ProductDao;
import com.ekexiu.console.system.po.Product;
import com.ekexiu.console.system.po.ProductPro;
import com.ekexiu.console.system.pojo.ProductInfo;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.PathVar;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
/**
 * Created by TT on 2018/7/17.
 */
@Path("/product")
public class ProductService {
    @Autowrie
    private ProductDao productDao;
    @Autowrie
    private KeyWordService keyWordService;
    public ProductDao getProductDao() {
        return productDao;
    }
    public void setProductDao(ProductDao productDao) {
        this.productDao = productDao;
    }
    public KeyWordService getKeyWordService() {
        return keyWordService;
    }
    public void setKeyWordService(KeyWordService keyWordService) {
        this.keyWordService = keyWordService;
    }
    @Get
    @Path("/id/{id}")
    public Product query(@JdbcConn Connection con, @PathVar String id)throws SQLException {
        return this.productDao.queryById(con, id);
    }
    @Path("/pq")
    @Get
    public PageQueryResult<ProductInfo> pageQueryResult(@JdbcConn Connection con, @Nullable String name, @Nullable String ownerName, @Nullable String bt, @Nullable String et, @DefaultValue("1") int pageNo, @DefaultValue("10") int pageSize)throws SQLException {
            return this.productDao.queryByTime(con, name == null ? null : "%" + name + "%",  ownerName == null ? "%" : "%" + ownerName + "%", bt == null ? null : bt + "000000", et == null ? null : et + "235959", pageSize, pageNo);
    }
    @Path("/linkman")
    @Get
    public List<ProductPro> queryLinkman(@JdbcConn Connection con,String id)throws SQLException {
        return this.productDao.queryPro(con, id);
    }
    @Path("/delete")
    @Post
    public void delete(@JdbcConn(true) Connection con,String id) throws SQLException {
        this.productDao.logicDelete(con, id);
    }
    @Post
    @Path("/kw")
    public void updateKw(@JdbcConn(true)Connection con,String id,@Nullable String kw)throws SQLException {
        this.productDao.updateKw(con, id, kw);
        this.keyWordService.refreshProduct(con, id, kw);
    }
    @Post
    @Path("/sortFirst")
    public void updateSortFirst(@JdbcConn(true)Connection con,String id,long sortFirst)throws SQLException {
        this.productDao.updateSortFirst(con, id, sortFirst);
    }
}

src/main/java/com/ekexiu/console/system/service/ProfessorService.java

@@ -1,6 +1,16 @@
package com.ekexiu.console.system.service;
import com.ekexiu.console.system.dao.*;
import com.ekexiu.console.system.dao.DemandDao;
import com.ekexiu.console.system.dao.LuserDao;
import com.ekexiu.console.system.dao.OrgDao;
import com.ekexiu.console.system.dao.OrgLinkManDao;
import com.ekexiu.console.system.dao.OrgResStaffDao;
import com.ekexiu.console.system.dao.PaperAuthorDao;
import com.ekexiu.console.system.dao.PatentAuthorDao;
import com.ekexiu.console.system.dao.ProductDao;
import com.ekexiu.console.system.dao.ProfessorDao;
import com.ekexiu.console.system.dao.ResearchAreaDao;
import com.ekexiu.console.system.dao.WareDao;
import com.ekexiu.console.system.po.Luser;
import com.ekexiu.console.system.po.Professor;
import com.ekexiu.console.system.pojo.ProfessorInfo;
@@ -65,6 +75,12 @@ public class ProfessorService {
    private DemandDao demandDao;
    @Autowrie
    private OrgResStaffDao orgResStaffDao;
    @Autowrie
    private WareDao wareDao;
    @Autowrie
    private ProductDao productDao;
    @Autowrie
    private OrgLinkManDao orgLinkManDao;
    public OrgService getOrgService() {
        return orgService;
@@ -154,6 +170,30 @@ public class ProfessorService {
        this.orgResStaffDao = orgResStaffDao;
    }
    public WareDao getWareDao() {
        return wareDao;
    }
    public void setWareDao(WareDao wareDao) {
        this.wareDao = wareDao;
    }
    public ProductDao getProductDao() {
        return productDao;
    }
    public void setProductDao(ProductDao productDao) {
        this.productDao = productDao;
    }
    public OrgLinkManDao getOrgLinkManDao() {
        return orgLinkManDao;
    }
    public void setOrgLinkManDao(OrgLinkManDao orgLinkManDao) {
        this.orgLinkManDao = orgLinkManDao;
    }
    @Post
    @Path
    public String insert(@JdbcConn(true) Connection con, Professor professor, @Nullable String orgName)
@@ -407,6 +447,11 @@ public class ProfessorService {
            updateOrgName(con, id);
        }
        this.professorDao.updateOrgId(con, id, orgId);
        this.professorDao.updateOrgAuth(con, id, "0");
        this.orgResStaffDao.deletePro(con, id);
        this.orgLinkManDao.deleteByPid(con, id);
        this.wareDao.deletePro(con, id);
        this.productDao.deletePro(con, id);
    }
    @Get