Commit d1a327fd authored by libin's avatar libin

Merge remote-tracking branch 'origin/master'

parents 54c89714 b4fdd45b
......@@ -110,6 +110,11 @@ public class Activity {
@ApiModelProperty("0-默认;1-报名中,2-进行中;3-已结束")
private Integer status;
@Column(name = "live_url")
@ApiModelProperty("直播地址")
private String liveUrl;
@Column(name = "content")
@ApiModelProperty("活动图文内容(峰会主题)")
private String content;
......
package com.xxfc.platform.summit.entity;
import io.swagger.annotations.ApiModel;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import tk.mybatis.mapper.annotation.KeySql;
import tk.mybatis.mapper.code.IdentityDialect;
import javax.persistence.Column;
import javax.persistence.Id;
import javax.persistence.Table;
import java.util.Date;
/**
* @author Administrator
*/
@Data
@Table(name = "fc_activity_temporary")
@AllArgsConstructor
@NoArgsConstructor
@ApiModel()
public class ActivityTemporary {
@Id
@KeySql(dialect = IdentityDialect.MYSQL)
private Integer id;
private String name;
private String phone;
private String inviter;
@Column(name = "crt_time")
private Date crtTime;
@Column(name = "upd_time")
private Date updTime;
}
......@@ -12,6 +12,7 @@ import com.github.wxiaoqi.security.common.util.process.ResultCode;
import com.google.common.collect.Lists;
import com.xxfc.platform.summit.entity.Activity;
import com.xxfc.platform.summit.entity.ActivityBm;
import com.xxfc.platform.summit.entity.ActivityTemporary;
import com.xxfc.platform.summit.entity.User;
import com.xxfc.platform.summit.mapper.ActivityBmMapper;;
import com.xxfc.platform.summit.pojo.ActivityBmExcel;
......@@ -48,6 +49,8 @@ public class ActivityBmBiz extends BaseBiz<ActivityBmMapper, ActivityBm> {
@Autowired
private MeepoUserQdBiz meepoUserQdBiz;
@Autowired
private ActivityTemporaryBiz activityTemporaryBiz;
......@@ -261,8 +264,8 @@ public class ActivityBmBiz extends BaseBiz<ActivityBmMapper, ActivityBm> {
return PageInfo.of(activityBms);
}
public ActivityBm userBm(ActivityBm activityBm, Integer id) {
return null;
public void userBm(ActivityTemporary activityTemporary) throws Exception {
activityTemporaryBiz.addModifyIfPresent(activityTemporary);
}
public List<ActivityBmExcel> excel(ActivityBmQuery query) throws Exception {
......
package com.xxfc.platform.summit.biz;
import com.github.wxiaoqi.security.common.biz.BaseBiz;
import com.xxfc.platform.summit.entity.ActivityTemporary;
import com.xxfc.platform.summit.mapper.ActivityTemporaryMapper;
import org.springframework.stereotype.Service;
import java.util.Date;
/**
* @author Administrator
*/
@Service
public class ActivityTemporaryBiz extends BaseBiz<ActivityTemporaryMapper, ActivityTemporary> {
public void addModifyIfPresent(ActivityTemporary activityTemporary)throws Exception {
activityTemporary.setCrtTime(new Date());
mapper.addModifyIfPresent(activityTemporary);
}
}
......@@ -81,6 +81,7 @@ public class UserBiz extends BaseBiz<UserMapper, User> {
userId=uses.get(0).getId();
user.setId(userId);
}else {
user.setId(null);
Long time=System.currentTimeMillis()/1000L;
user.setWeId(weId);
user.setRId(rId);
......@@ -97,8 +98,8 @@ public class UserBiz extends BaseBiz<UserMapper, User> {
log.info("----code为空---");
throw new BaseException(ResultCode.FAILED_CODE, Sets.newSet("code为空"));
}
String openid = "oXDd91MppH9i5F7xzPwigiMj--5w";
/*String access_token = null;
String openid= null ;
String access_token = null;
try {
JSONObject jsonData = weixinService.getAccessToken(code);
openid = jsonData.getString("openid");
......@@ -116,15 +117,15 @@ public class UserBiz extends BaseBiz<UserMapper, User> {
e.printStackTrace();
log.info("网络异常===" + e.getMessage());
throw new BaseException(ResultCode.FAILED_CODE, Sets.newSet("网络异常"));
}*/
}
try {
// 获取微信用户基本信息
/* JSONObject userinfo_json = weixinService.getUserInfo(access_token,openid);
JSONObject userinfo_json = weixinService.getUserInfo(access_token,openid);
if (userinfo_json == null || StringUtils.isNotBlank(userinfo_json.getString("errcode"))) {
log.info("调用微信用户基本信息接口失败");
throw new BaseException(ResultCode.FAILED_CODE, Sets.newSet("调用微信用户基本信息接口失败"));
}
log.info("微信用户基本信息---user===" +userinfo_json.toJSONString());*/
log.info("微信用户基本信息---user===" +userinfo_json.toJSONString());
if (activityId==null||activityId==0){
ActivityBm activityBm=activityBmBiz.userInfo(key);
if (activityBm==null){
......@@ -138,9 +139,9 @@ public class UserBiz extends BaseBiz<UserMapper, User> {
throw new BaseException(ResultCode.FAILED_CODE, Sets.newSet("redis的报名信息activityId---为空"));
}
User userInfo=new User();
String nickName = "苹果呀";//userinfo_json.getString("nickname");
String headimgurl = "http://thirdwx.qlogo.cn/mmopen/4eFHvhmOX6XuiaG6ib7wxkLa8AwMLFIbW9BSJ7EmwC3kRMUdgCrobdRUbhjMXbkY7aBc2CazjXFJiap5ianMH6yQnH2UQ4TfkXJw/132";//userinfo_json.getString("headimgurl");
String sex ="2"; //userinfo_json.getString("sex");
String nickName = userinfo_json.getString("nickname");
String headimgurl =userinfo_json.getString("headimgurl");
String sex =userinfo_json.getString("sex");
if (StringUtils.isBlank(sex)){
sex="0";
}
......
......@@ -39,7 +39,7 @@ public class SwaggerConfig {
return new Docket(DocumentationType.SWAGGER_2)
.select()
.apis(RequestHandlerSelectors.basePackage("com.xxfc.platform.tour"))
.apis(RequestHandlerSelectors.basePackage("com.xxfc.platform.summit"))
//.apis(RequestHandlerSelectors.any())
.build()
.globalOperationParameters(pars)
......
......@@ -9,6 +9,7 @@ import com.github.wxiaoqi.security.common.rest.BaseController;
import com.xxfc.platform.summit.biz.ActivityBmBiz;
import com.xxfc.platform.summit.biz.UserBiz;
import com.xxfc.platform.summit.entity.ActivityBm;
import com.xxfc.platform.summit.entity.ActivityTemporary;
import com.xxfc.platform.summit.entity.User;
import com.xxfc.platform.summit.pojo.ActivityBmExcel;
import com.xxfc.platform.summit.pojo.ActivityBmQuery;
......@@ -36,11 +37,11 @@ public class ActivityBmController extends BaseController<ActivityBmBiz, Activity
UserBiz userBiz;
@PostMapping("/add")
public ObjectRestResponse bm(@RequestBody ActivityBm activityBm, HttpServletRequest request) {
User user = userBiz.getSession(request);
@PostMapping("/app/unauth/add")
public ObjectRestResponse bm(@RequestBody ActivityTemporary activityTemporary) {
try {
return ObjectRestResponse.succ(baseBiz.userBm(activityBm, user.getId()));
baseBiz.userBm(activityTemporary);
return ObjectRestResponse.succ();
} catch (Exception e) {
e.printStackTrace();
return ObjectRestResponse.createDefaultFail();
......
package com.xxfc.platform.summit.mapper;
import com.xxfc.platform.summit.entity.ActivityTemporary;
import tk.mybatis.mapper.common.Mapper;
/**
* @author Administrator
*/
public interface ActivityTemporaryMapper extends Mapper<ActivityTemporary> {
void addModifyIfPresent(ActivityTemporary activityTemporary);
}
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.xxfc.platform.summit.mapper.ActivityTemporaryMapper">
<insert id="addModifyIfPresent" parameterType="com.xxfc.platform.summit.entity.ActivityTemporary"
useGeneratedKeys="true" keyProperty="id" keyColumn="id">
INSERT INTO fc_activity_temporary (name,phone,inviter,crt_time,upd_time)
VALUES (#{name},#{phone},#{inviter},#{crtTime},#{updTime}) ON DUPLICATE KEY UPDATE upd_time = VALUES(crt_time)
</insert>
</mapper>
\ No newline at end of file
......@@ -166,7 +166,7 @@ public class UploadService {
//文件存放路径
String filePath = videoUploadPath + realFileRelPath;
//将文件写入指定位置
// FileUtils.copyInputStreamToFile(file.getInputStream(), new File(filePath));
FileUtils.copyInputStreamToFile(file.getInputStream(), new File(filePath));
realFileRelPath=xx_url+SystemConfig.VIDEO_URL+realFileRelPath;
return realFileRelPath;
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment