添加积分成长

src/main/java/com/ekexiu/portal/dao/ProfessorDao.java

@@ -45,6 +45,26 @@ public abstract class ProfessorDao {
	@Update
	public abstract int update(Connection con, Professor professor) throws SQLException;
	
	public int updateScoreValue(Connection con,String id,Integer scoreValue)throws SQLException{
		String sql = "UPDATE PROFESSOR SET SCORE_VALUE = SCORE_VALUE + " + scoreValue + " WHERE ID = '" + id + "'";
		PreparedStatement ps = con.prepareStatement(sql);
		try{
			return ps.executeUpdate();
		}finally{
			try{ps.close();}catch(Exception e){}
		}
	}
	
	public int updateGrowthValue(Connection con,String id,Integer growthValue)throws SQLException{
		String sql = "UPDATE PROFESSOR SET GROWTH_VALUE = GROWTH_VALUE + " + growthValue + " WHERE ID = '" + id + "'";
		PreparedStatement ps = con.prepareStatement(sql);
		try{
			return ps.executeUpdate();
		}finally{
			try{ps.close();}catch(Exception e){}
		}
	}
	
	@UpdateWith
	@From(Professor.class)
	public abstract int updatePhone(Connection con, String id, @Set String phone) throws SQLException;

src/main/java/com/ekexiu/portal/po/Professor.java

@@ -51,6 +51,8 @@ public class Professor implements CreateTimeSupported, ModifyTimeSupported{
	private String phone;
	private String email;
	private Integer sortFirst;
	private Integer scoreValue;
	private Integer growthValue;
	
	private Organization organization;
	private List<Resource> resources;
@@ -294,7 +296,7 @@ public class Professor implements CreateTimeSupported, ModifyTimeSupported{
		this.email = email;
	}
	@Column(handlerClass=WIntHandler.class,dbType="INT",insertable=false,nullable=false,renewable=false,queryable=true)
	@Column(handlerClass=WIntHandler.class,dbType="INT",insertable=false,renewable=false)
	public Integer getSortFirst() {
		return sortFirst;
	}
@@ -303,4 +305,22 @@ public class Professor implements CreateTimeSupported, ModifyTimeSupported{
		this.sortFirst = sortFirst;
	}
	@Column(handlerClass=WIntHandler.class,dbType="INT",nullable=true,renewable=false)
	public Integer getScoreValue() {
		return scoreValue;
	}
	public void setScoreValue(Integer scoreValue) {
		this.scoreValue = scoreValue;
	}
	@Column(handlerClass=WIntHandler.class,dbType="INT",nullable=true,renewable=false)
	public Integer getGrowthValue() {
		return growthValue;
	}
	public void setGrowthValue(Integer growthValue) {
		this.growthValue = growthValue;
	}
}

src/main/java/com/ekexiu/portal/service/AuthApplyService.java

@@ -29,6 +29,8 @@ public class AuthApplyService {
	private ProfessorDao professorDao;
	@Autowrie
	private OrgDao orgDao;
	@Autowrie
	private GrowthLogService growthLogService;
	public AuthApplyDao getAuthApplyDao() {
		return authApplyDao;
@@ -62,6 +64,14 @@ public class AuthApplyService {
		this.orgDao = orgDao;
	}
	public GrowthLogService getGrowthLogService() {
		return growthLogService;
	}
	public void setGrowthLogService(GrowthLogService growthLogService) {
		this.growthLogService = growthLogService;
	}
	@Post
	@Path("/realName")
	public void realNameAuth(@JdbcConn(true) Connection con,AuthApply authApply,String[] fns) throws SQLException, IOException{
@@ -110,10 +120,16 @@ public class AuthApplyService {
		this.authApplyDao.updateSolveStatus(con,state,id);
		if(auth==1){
			this.professorDao.updateAuthStatus(con, professorId, state);
			//通过实名认证给用户增加积分
			if(state==3){
				this.growthLogService.authRealName(con, professorId);
			}
		}else if(auth==2){
			this.professorDao.updateAuthStatusExpert(con, professorId, state);
			if(state==3){
				this.professorDao.updateAuthType(con, professorId, 1);
				//通过专家认证给用户增加积分
				this.growthLogService.authExpert(con, professorId);
			}
		}else if(auth==3){
			this.orgDao.updateAuthStatus(con, professorId, state+"");

src/main/java/com/ekexiu/portal/service/ConsultService.java

@@ -38,6 +38,8 @@ public class ConsultService {
	private TidingsDao tidingsDao;
	@Autowrie
	private ConsultRejectDao consultRejectDao;
	@Autowrie
	private GrowthLogService growthLogService;
	
	public ConsultDao getConsultDao() {
		return consultDao;
@@ -69,6 +71,12 @@ public class ConsultService {
	public void setConsultRejectDao(ConsultRejectDao consultRejectDao) {
		this.consultRejectDao = consultRejectDao;
	}
	public GrowthLogService getGrowthLogService() {
		return growthLogService;
	}
	public void setGrowthLogService(GrowthLogService growthLogService) {
		this.growthLogService = growthLogService;
	}
	
	@Post
	@Path
@@ -92,6 +100,10 @@ public class ConsultService {
		tidings.setTidingsContant(consult.getConsultContant());
		tidings.setReadStatus(1);
		this.tidingsDao.insert(con, tidings);
		//需求确认给专家增加积分
		if(consult.getDemandId() != null){
			this.growthLogService.demandConfirm(con, consult.getProfessorId());
		}
		return consultId;
	}
	
@@ -104,8 +116,11 @@ public class ConsultService {
	@Post
	@Path("/agree")
	public void agreeConsult(@JdbcConn(true) Connection con,String consultId)throws SQLException{
		Consult consult = this.consultDao.query(con, consultId);
		//点击确认接受咨询，更新咨询状态为进行中
		this.consultDao.updateConsultStatus(con, consultId, 0);
		//接受咨询给专家增加积分
		this.growthLogService.consultReceive(con, consult.getProfessorId());
	}
	
	@Post
@@ -136,6 +151,8 @@ public class ConsultService {
			this.consultDao.updateFinishTime(con, consultId,consultStatus);
			int finishConsult = this.consultDao.queryReceiveConsult(con, consult.getProfessorId());
			this.professorDao.updateConsultCount(con, consult.getProfessorId(), finishConsult);
			//咨询完成给咨询者增加积分
			this.growthLogService.consultFinish(con, consult.getConsultantId());
			return true;
		}
		return false;
@@ -150,6 +167,12 @@ public class ConsultService {
			this.consultDao.updateAssess(con, consultId, assessStatus, assessStar, assessContant);
			BigDecimal avgStar = this.consultDao.queryStarLevel(con, consult.getProfessorId());
			this.professorDao.updateStarLevel(con, consult.getProfessorId(), avgStar);
			//评价一次咨询给咨询者增加积分
			this.growthLogService.consultAssess(con, consult.getConsultantId());
			//获得4星及以上评价给专家增加积分
			if(assessStar > 3){
				this.growthLogService.receiveFourStar(con, consult.getProfessorId());
			}
			return true;
		}
		return false;

src/main/java/com/ekexiu/portal/service/DemandService.java

@@ -38,6 +38,8 @@ public class DemandService {
	private ImageService imageService;
	@Autowrie
	private OrgService orgService;
	@Autowrie
	private GrowthLogService growthLogService;
	
	public DemandDao getDemandDao() {
		return demandDao;
@@ -69,6 +71,12 @@ public class DemandService {
	public void setOrgService(OrgService orgService) {
		this.orgService = orgService;
	}
	public GrowthLogService getGrowthLogService() {
		return growthLogService;
	}
	public void setGrowthLogService(GrowthLogService growthLogService) {
		this.growthLogService = growthLogService;
	}
	
	@Post
	@Path
@@ -88,6 +96,13 @@ public class DemandService {
				this.demandSubOrIndusDao.insert(con, subOrIndus);
			}
		}
		if("1".equals(demand.getDemandType())){
			//发布个人需求给发布者增加积分
			this.growthLogService.addProDemand(con, demand.getDemander());
		}else if("2".equals(demand.getDemandType())){
			//发布企业需求给发布者增加积分
			this.growthLogService.addOrgDemand(con, demand.getDemander());
		}
	}
	
	@Post

src/main/java/com/ekexiu/portal/service/InitUserService.java

@@ -27,6 +27,8 @@ public class InitUserService {
	private UserDao userDao;
	@Autowrie
	private ProfessorDao professorDao;
	@Autowrie
	private GrowthLogService growthLogService;
	
	
	public UserDao getUserDao() {
@@ -45,6 +47,14 @@ public class InitUserService {
		this.professorDao = professorDao;
	}
	public GrowthLogService getGrowthLogService() {
		return growthLogService;
	}
	public void setGrowthLogService(GrowthLogService growthLogService) {
		this.growthLogService = growthLogService;
	}
	@Get
	@Path("/user/{id}")
	public User getUser(@JdbcConn Connection con,@PathVar String id) throws SQLException{
@@ -72,6 +82,12 @@ public class InitUserService {
		user.setUserType("0");
		user.setInviteCode(inviteCode);
		this.userDao.insert(con, user);
		if(mobilePhone != null && mobilePhone.trim().length() == 11){
			this.growthLogService.bindMobile(con, id);
		}
		if(email != null && !"".equals(email)){
			this.growthLogService.bindEmail(con, id);
		}
		Professor professor = this.professorDao.queryOne(con, id);
		if(mobilePhone != null && (professor.getPhone() == null || professor.getPhone().isEmpty())){
			this.professorDao.updatePhone(con, id, mobilePhone);
@@ -85,6 +101,12 @@ public class InitUserService {
	public void modifyMobilePhone(@JdbcConn(true) Connection con ,@RequestBody User user)throws SQLException{
		this.userDao.updateMobilePhone(con, user.getMobilePhone(), user.getId());
		this.userDao.updateEmail(con, user.getEmail(), user.getId());
		if(user.getMobilePhone() != null && user.getMobilePhone().trim().length() == 11){
			this.growthLogService.bindMobile(con, user.getId());
		}
		if(user.getEmail() != null && !"".equals(user.getEmail())){
			this.growthLogService.bindEmail(con, user.getId());
		}
		Professor professor = this.professorDao.queryOne(con, user.getId());
		if(user.getMobilePhone() != null && (professor.getPhone() == null || professor.getPhone().isEmpty())){
			this.professorDao.updatePhone(con, user.getId(), user.getMobilePhone());

src/main/java/com/ekexiu/portal/service/ProfessorService.java

@@ -47,6 +47,10 @@ import com.ekexiu.portal.util.Calculate;
@Path("/professor")
public class ProfessorService {
	@Autowrie
	private GrowthLogService growthLogService;
	@Autowrie
	private GrowthRuleService rule;
	@Autowrie
	private ArticleDao articleDao;
	@Autowrie
@@ -84,7 +88,22 @@ public class ProfessorService {
	@Autowrie
	private ProjectDao projectDao;
	
	public GrowthLogService getGrowthLogService() {
		return growthLogService;
	}
	public void setGrowthLogService(GrowthLogService growthLogService) {
		this.growthLogService = growthLogService;
	}
	public GrowthRuleService getRule() {
		return rule;
	}
	public void setRule(GrowthRuleService rule) {
		this.rule = rule;
	}
	public ArticleDao getArticleDao() {
		return articleDao;
	}
@@ -249,8 +268,22 @@ public class ProfessorService {
		}
		User user = this.userDao.query(con, professor.getId());
		if(user != null){
			professor.setPhone(user.getMobilePhone());
			professor.setEmail(user.getEmail());
			int value = 0;
			if(user.getMobilePhone() != null && user.getMobilePhone().trim().length() == 11){
				professor.setPhone(user.getMobilePhone());
				value = value + this.rule.getBindMobile();
				this.growthLogService.firstBindMobile(con, professor.getId());
			}
			if(user.getEmail() != null && !"".equals(user.getEmail())){
				professor.setEmail(user.getEmail());
				value = value + this.rule.getBindEmail();
				this.growthLogService.firstBindEmail(con, professor.getId());
			}
			professor.setScoreValue(value);
			professor.setGrowthValue(value);
		}else{
			professor.setScoreValue(0);
			professor.setGrowthValue(0);
		}
		this.professorDao.insert(con, professor);
		return professor.getId();
@@ -437,6 +470,8 @@ public class ProfessorService {
	@Path("/passOrgAuth")
	public void passOrgAuth(@JdbcConn(true) Connection con,String id)throws SQLException{
		this.professorDao.updateOrgAuth(con, id, "1");
		//通过企业认证给用户增加积分
		this.growthLogService.authOrg(con, id);
	}
	
	@Post

src/main/java/com/ekexiu/portal/service/ResourceService.java

@@ -43,6 +43,8 @@ public class ResourceService {
	private ImageService imageService;
	@Autowrie
	private OperationDao operationDao;
	@Autowrie
	private GrowthLogService growthLogService;
	public ProfessorDao getProfessorDao() {
		return professorDao;
@@ -100,6 +102,14 @@ public class ResourceService {
		this.imagesService = imagesService;
	}
	public GrowthLogService getGrowthLogService() {
		return growthLogService;
	}
	public void setGrowthLogService(GrowthLogService growthLogService) {
		this.growthLogService = growthLogService;
	}
	@Post
	@Path
	public String insert(@JdbcConn(true) Connection con, Resource resource, @Nullable String fn) 
@@ -110,6 +120,7 @@ public class ResourceService {
		}
		resource.setResourceId(resourceId);
		this.resourceDao.insert(con, resource);
		this.growthLogService.addResource(con, resource.getProfessorId());
		return resourceId;
	}
	
@@ -123,6 +134,7 @@ public class ResourceService {
		}
		resource.setResourceId(resourceId);
		this.resourceDao.insert(con, resource);
		this.growthLogService.addResource(con, resource.getProfessorId());
		return resourceId;
	}
@@ -227,9 +239,11 @@ public class ResourceService {
	public boolean delete(@JdbcConn(true) Connection con, @PathVar String resourceId) throws SQLException {
		List<Operation> operations = this.operationDao.queryResourceId(con, resourceId);
		if(operations.isEmpty()){
			Resource resource = this.resourceDao.queryInfo(con, resourceId);
			this.imageDao.deleteRes(con, resourceId);
			this.resourceDao.delete(con, resourceId);
			this.watchDao.deleteWatch(con, resourceId);
			this.growthLogService.deleteResource(con, resource.getProfessorId());
			return true;
		}else{
			return false;

src/main/java/com/ekexiu/portal/service/SysService.java

@@ -59,6 +59,8 @@ public class SysService {
	private MailService mailservice;
	@Autowrie
	private MobilePhoneService mobilePhoneServcie;
	@Autowrie
	private GrowthLogService growthLogService;
	private String bindMailSubject;
@@ -179,6 +181,14 @@ public class SysService {
		this.mobilePhoneServcie = mobilePhoneServcie;
	}
	public GrowthLogService getGrowthLogService() {
		return growthLogService;
	}
	public void setGrowthLogService(GrowthLogService growthLogService) {
		this.growthLogService = growthLogService;
	}
	public String getPhoneRetrievePasswordReplaceKey() {
		return phoneRetrievePasswordReplaceKey;
	}
@@ -619,6 +629,9 @@ public class SysService {
	        user.setInviterId(inviterId);
	        user.setActiveTime(DATE.format(new Date()));
			this.userDao.insert(con, user);
			if(inviterId != null){
				this.growthLogService.invite(con, inviterId);
			}
			return user.getId();
		} finally {
			JfwAppContext.removeCachedObject(state);
@@ -655,6 +668,9 @@ public class SysService {
			user.setActiveTime(DATE.format(new Date()));
			this.userDao.insert(con, user);
			con.commit();
			if(sc.getValue() != null){
				this.growthLogService.invite(con, sc.getValue());
			}
		} catch (SQLException e) {
			try {
				con.rollback();
@@ -1083,7 +1099,9 @@ public class SysService {
			if (professor.getPhone() == null || professor.getPhone().isEmpty()) {
				this.professorDao.updateEmail(con, sc.getKey(), sc.getValue());
			}
			return this.userDao.updateEmail(con, sc.getValue(), sc.getKey()) > 0;
			this.userDao.updateEmail(con, sc.getValue(), sc.getKey());
			this.growthLogService.bindEmail(con, sc.getKey());
			return true;
		} finally {
			JfwAppContext.removeCachedObject(key);
		}
@@ -1241,7 +1259,9 @@ public class SysService {
			if (professor.getPhone() == null || professor.getPhone().isEmpty()) {
				this.professorDao.updatePhone(con, userid, mobilePhone);
			}
			return this.userDao.updateMobilePhone(con, mobilePhone, userid) > 0;
			this.userDao.updateMobilePhone(con, mobilePhone, userid);
			this.growthLogService.bindMobile(con, userid);
			return true;
		} finally {
			JfwAppContext.removeCachedObject(state);
		}