Commit 1c78c520 authored by jiaorz's avatar jiaorz

Merge remote-tracking branch 'origin/base-modify' into base-modify

parents 7df6b31d 91196d8b
...@@ -24,7 +24,7 @@ public class AppUserManageDTO { ...@@ -24,7 +24,7 @@ public class AppUserManageDTO {
/** /**
* 手机号 * 手机号
*/ */
private Integer mobile; private String mobile;
/** /**
* 注册终端 * 注册终端
...@@ -32,7 +32,7 @@ public class AppUserManageDTO { ...@@ -32,7 +32,7 @@ public class AppUserManageDTO {
private Integer channel; private Integer channel;
/** /**
* 会员等级 * 会员等级(-1为全不会员)
*/ */
private Integer memberLevel; private Integer memberLevel;
......
...@@ -12,6 +12,7 @@ import org.springframework.stereotype.Service; ...@@ -12,6 +12,7 @@ import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import tk.mybatis.mapper.entity.Example; import tk.mybatis.mapper.entity.Example;
import tk.mybatis.mapper.weekend.WeekendSqls;
import java.time.Instant; import java.time.Instant;
import java.util.HashMap; import java.util.HashMap;
...@@ -205,4 +206,13 @@ public class AppUserLoginBiz extends BaseBiz<AppUserLoginMapper, AppUserLogin> { ...@@ -205,4 +206,13 @@ public class AppUserLoginBiz extends BaseBiz<AppUserLoginMapper, AppUserLogin> {
criteria.andIn("username",phons); criteria.andIn("username",phons);
mapper.deleteByExample(example); mapper.deleteByExample(example);
} }
// @CacheClear(pre = "appUser{1}")
@Transactional(rollbackFor = Exception.class)
public void deleteAppUserById(Integer id) {
AppUserLogin appUserLogin = new AppUserLogin();
appUserLogin.setId(id);
appUserLogin.setIsdel(0);
mapper.updateByPrimaryKeySelective(appUserLogin);
}
} }
...@@ -80,6 +80,7 @@ public class AppUserManageBiz extends BaseBiz<AppUserDetailMapper, AppUserDetail ...@@ -80,6 +80,7 @@ public class AppUserManageBiz extends BaseBiz<AppUserDetailMapper, AppUserDetail
* 禁用账户 * 禁用账户
* @param id * @param id
*/ */
@Transactional(rollbackFor =Exception.class) @Transactional(rollbackFor =Exception.class)
public void deleteAppUser(Integer id,Integer isDel) { public void deleteAppUser(Integer id,Integer isDel) {
AppUserLogin appUserLogin = new AppUserLogin(); AppUserLogin appUserLogin = new AppUserLogin();
...@@ -111,7 +112,7 @@ public class AppUserManageBiz extends BaseBiz<AppUserDetailMapper, AppUserDetail ...@@ -111,7 +112,7 @@ public class AppUserManageBiz extends BaseBiz<AppUserDetailMapper, AppUserDetail
} }
/** /**
* *保存
* @param appUserVo * @param appUserVo
*/ */
@Transactional(rollbackFor =Exception.class) @Transactional(rollbackFor =Exception.class)
......
...@@ -34,16 +34,16 @@ public class AppUsersManageController extends BaseController<AppUserManageBiz,Ap ...@@ -34,16 +34,16 @@ public class AppUsersManageController extends BaseController<AppUserManageBiz,Ap
return ObjectRestResponse.succ(baseBiz.findAllByQuery(appUserManageDTO)); return ObjectRestResponse.succ(baseBiz.findAllByQuery(appUserManageDTO));
} }
/** // /**
* 禁用 // * 禁用
* @param id // * @param id
* @return // * @return
*/ // */
@DeleteMapping("/deleteById/{id}/{isDel}") // @DeleteMapping("/deleteById/{id}/{isDel}")
public ObjectRestResponse deleteById(@PathVariable Integer id,@PathVariable Integer isDel){ // public ObjectRestResponse deleteById(@PathVariable Integer id,@PathVariable Integer isDel){
baseBiz.deleteAppUser(id,isDel); // baseBiz.deleteAppUser(id,isDel);
return ObjectRestResponse.succ(); // return ObjectRestResponse.succ();
} // }
/** /**
* 查询一条 * 查询一条
...@@ -94,6 +94,17 @@ public class AppUsersManageController extends BaseController<AppUserManageBiz,Ap ...@@ -94,6 +94,17 @@ public class AppUsersManageController extends BaseController<AppUserManageBiz,Ap
return ObjectRestResponse.succ(); return ObjectRestResponse.succ();
} }
/**
* 删除用户
* @param id
* @return
*/
@DeleteMapping("/deleteById/{id}")
public ObjectRestResponse deleteById(@PathVariable Integer id){
appUserLoginBiz.deleteAppUserById(id);
return ObjectRestResponse.succ();
}
} }
...@@ -103,6 +103,11 @@ public class GroupController extends BaseController<GroupBiz, Group> { ...@@ -103,6 +103,11 @@ public class GroupController extends BaseController<GroupBiz, Group> {
return new ObjectRestResponse().data(baseBiz.getAuthorityElement(id)).rel(true); return new ObjectRestResponse().data(baseBiz.getAuthorityElement(id)).rel(true);
} }
@RequestMapping(value = "/getGroups",method = RequestMethod.GET)
@ResponseBody
public ObjectRestResponse<GroupUsers> getGroups(){
return new ObjectRestResponse<GroupUsers>().rel(true).data(baseBiz.selectListAll());
}
@RequestMapping(value = "/tree", method = RequestMethod.GET) @RequestMapping(value = "/tree", method = RequestMethod.GET)
@ResponseBody @ResponseBody
......
...@@ -95,23 +95,27 @@ ...@@ -95,23 +95,27 @@
) m ) m
on on
l.id = m.user_id l.id = m.user_id
where 1=1 where l.isdel = 0
<if test="mobile !=null"> <if test="mobile !=null and mobile !='' ">
and l.username like CONCAT('%',#{mobile},'%') and l.username like CONCAT('%',#{mobile},'%')
</if> </if>
<if test="channel !=null"> <if test="channel !=null ">
and d.channel=#{channel} and d.channel=#{channel}
</if> </if>
<if test="memberLevel !=null"> <if test="memberLevel !=null and memberLevel != -1">
and m.member_level = #{memberLevel} and m.member_level = #{memberLevel}
</if> </if>
<if test="registrationTimeBegin !=null"> <if test="memberLevel == -1">
and m.member_level in (select level from base_user_member_level)
</if>
<if test="registrationTimeBegin !=null ">
and l.createtime &gt;= #{registrationTimeBegin} and l.createtime &gt;= #{registrationTimeBegin}
</if> </if>
<if test="registrationTimeEnd !=null"> <if test="registrationTimeEnd !=null ">
and l.createtime &lt;= #{registrationTimeEnd} and l.createtime &lt;= #{registrationTimeEnd}
</if> </if>
<if test="source !=null"> <if test="source !=null ">
and d.source = #{source} and d.source = #{source}
</if> </if>
order by l.id ASC order by l.id ASC
......
...@@ -115,4 +115,7 @@ public class ActivityList implements Serializable { ...@@ -115,4 +115,7 @@ public class ActivityList implements Serializable {
@ApiModelProperty("活动时期类型:0-永久,1-有期限") @ApiModelProperty("活动时期类型:0-永久,1-有期限")
private Integer timeType; private Integer timeType;
} }
...@@ -57,10 +57,10 @@ public class ActivityManagement { ...@@ -57,10 +57,10 @@ public class ActivityManagement {
private Integer hasJoinNum; private Integer hasJoinNum;
/** /**
* 当前状态 1--显示在活动页 2--隐藏 * 当前状态 1--上架 2--下架
*/ */
@Column(name = "status") @Column(name = "status")
@ApiModelProperty(value = "当前状态 1--显示在活动页 2--隐藏") @ApiModelProperty(value = "当前状态 1--上架 2--下架")
private Integer status; private Integer status;
/** /**
...@@ -90,4 +90,12 @@ public class ActivityManagement { ...@@ -90,4 +90,12 @@ public class ActivityManagement {
@Column(name = "url") @Column(name = "url")
@ApiModelProperty(value = "活动页面链接") @ApiModelProperty(value = "活动页面链接")
private String url; private String url;
/**
* 活动时期类型:0-永久,1-有期限
*/
@Column(name = "time_type")
@ApiModelProperty(value = "活动页面链接")
private String timeType;
} }
...@@ -36,7 +36,6 @@ public class ActivityPopup { ...@@ -36,7 +36,6 @@ public class ActivityPopup {
private String background; private String background;
@Column(name = "start_time") @Column(name = "start_time")
private BigInteger startTime; private BigInteger startTime;
...@@ -56,6 +55,9 @@ public class ActivityPopup { ...@@ -56,6 +55,9 @@ public class ActivityPopup {
private BigInteger updTime; private BigInteger updTime;
@Column(name = "is_del")
private Integer isDel;
} }
package com.xxfc.platform.activity.entity;
import java.io.Serializable;
import java.util.Date;
import javax.persistence.*;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* 精彩活动
* @author Administrator
*/
@Data
@Table(name = "home_activities")
public class HomeActivities implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@Id
@GeneratedValue(generator = "JDBC")
@ApiModelProperty("主键")
private Integer id;
/**
* 创建时间
*/
@Column(name = "crt_time")
@ApiModelProperty(value = "创建时间", hidden = true )
private Long crtTime;
/**
* 更新时间
*/
@Column(name = "upd_time")
@ApiModelProperty(value = "更新时间", hidden = true )
private Long updTime;
/**
* 活动名称
*/
@Column(name = "name")
@ApiModelProperty(value = "精彩活动名称")
private String name;
/**
* 精彩活动开始时间
*/
@Column(name = "start_time")
@ApiModelProperty(value = "活动开始时间")
private Long startTime;
/**
* 精彩活动结束时间
*/
@Column(name = "end_time")
@ApiModelProperty(value = "活动结束时间")
private Long endTime;
/**
* 当前状态 1--显示在活动页 2--隐藏
*/
@Column(name = "status")
@ApiModelProperty(value = "当前状态 1--显示在活动页 2--隐藏")
private Integer status;
/**
* 排序
*/
@Column(name = "sort")
@ApiModelProperty(value = "排序")
private Integer sort;
/**
* 活动图片
*/
@Column(name = "picture")
@ApiModelProperty(value = "活动图片")
private String picture;
/**
* 活动页面链接
*/
@Column(name = "url")
@ApiModelProperty(value = "活动页面链接")
private String url;
/**
* 是否删除:0-否,1-是
*/
@Column(name = "is_del")
@ApiModelProperty(value = "是否删除")
private Integer isDel;
}
package com.xxfc.platform.activity.vo;
import lombok.Data;
/**
* @author Administrator
*/
@Data
public class ActivitiesQuery extends Query{
private String activitiesName;
}
package com.xxfc.platform.activity.vo;
import lombok.Data;
@Data
public class ActivityManagementQuery extends Query {
}
package com.xxfc.platform.activity.vo;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import net.bytebuddy.implementation.bytecode.assign.TypeCasting;
/**
* 弹窗搜索条件
* @author Administrator
*/
@Data
public class PopupQuery extends Query {
private String popupName;
}
package com.xxfc.platform.activity.vo;
import lombok.Data;
/**
* @author Administrator
*/
@Data
public class Query {
private Integer page;
private Integer limit;
}
...@@ -28,7 +28,6 @@ public class ActivityListBiz extends BaseBiz<ActivityListMapper,ActivityList> { ...@@ -28,7 +28,6 @@ public class ActivityListBiz extends BaseBiz<ActivityListMapper,ActivityList> {
.andEqualTo(ActivityList::getStatus,1) .andEqualTo(ActivityList::getStatus,1)
).orderByAsc("sort").build(); ).orderByAsc("sort").build();
List<ActivityList> activityLists = selectByExample(exa); List<ActivityList> activityLists = selectByExample(exa);
return activityLists; return activityLists;
} }
} }
\ No newline at end of file
package com.xxfc.platform.activity.biz; package com.xxfc.platform.activity.biz;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.github.wxiaoqi.security.common.biz.BaseBiz; import com.github.wxiaoqi.security.common.biz.BaseBiz;
import com.xxfc.platform.activity.entity.ActivityList; import com.xxfc.platform.activity.entity.ActivityList;
import com.xxfc.platform.activity.entity.ActivityManagement; import com.xxfc.platform.activity.entity.ActivityManagement;
import com.xxfc.platform.activity.mapper.ActivityManagementMapper; import com.xxfc.platform.activity.mapper.ActivityManagementMapper;
import com.xxfc.platform.activity.vo.ActivityManagementQuery;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.beanutils.BeanUtilsBean; import org.apache.commons.beanutils.BeanUtilsBean;
import org.apache.commons.jexl2.UnifiedJEXL;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import tk.mybatis.mapper.entity.Example;
import tk.mybatis.mapper.weekend.WeekendSqls;
import java.lang.reflect.InvocationTargetException; import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.List; import java.util.List;
/** /**
...@@ -32,10 +31,13 @@ public class ActivityManagementBiz extends BaseBiz<ActivityManagementMapper, Act ...@@ -32,10 +31,13 @@ public class ActivityManagementBiz extends BaseBiz<ActivityManagementMapper, Act
* @return * @return
* @throws InvocationTargetException * @throws InvocationTargetException
* @throws IllegalAccessException * @throws IllegalAccessException
* @param query
*/ */
public List<ActivityList> selectedActivityManagement() throws InvocationTargetException, IllegalAccessException { public PageInfo<ActivityList> selectedActivityManagement(ActivityManagementQuery query) throws InvocationTargetException, IllegalAccessException {
PageHelper.startPage(query.getPage(),query.getLimit());
List<ActivityList> activityLists = activityListBiz.selectListAll(); List<ActivityList> activityLists = activityListBiz.selectListAll();
return activityLists; return PageInfo.of(activityLists);
} }
......
...@@ -2,6 +2,7 @@ package com.xxfc.platform.activity.biz; ...@@ -2,6 +2,7 @@ package com.xxfc.platform.activity.biz;
import com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO; import com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO;
import com.github.wxiaoqi.security.common.biz.BaseBiz; import com.github.wxiaoqi.security.common.biz.BaseBiz;
import com.github.wxiaoqi.security.common.exception.BaseException;
import com.xxfc.platform.activity.entity.ActivityPopup; import com.xxfc.platform.activity.entity.ActivityPopup;
import com.xxfc.platform.activity.entity.ActivityPopupUser; import com.xxfc.platform.activity.entity.ActivityPopupUser;
import com.xxfc.platform.activity.mapper.ActivityPopupMapper; import com.xxfc.platform.activity.mapper.ActivityPopupMapper;
...@@ -49,14 +50,15 @@ public class ActivityPopupBiz extends BaseBiz<ActivityPopupMapper,ActivityPopup> ...@@ -49,14 +50,15 @@ public class ActivityPopupBiz extends BaseBiz<ActivityPopupMapper,ActivityPopup>
return activityPopups; return activityPopups;
} }
List<Integer> collect = activityPopups.parallelStream().map(ActivityPopup::getId).collect(Collectors.toList()); List<Integer> collect = activityPopups.parallelStream().map(ActivityPopup::getId).collect(Collectors.toList());
Example exaple= Example.builder(ActivityPopupUser.class).where( Example exaple= Example.builder(ActivityPopupUser.class)
WeekendSqls.<ActivityPopupUser>custom().andIn(ActivityPopupUser::getPopupId,collect) .where(WeekendSqls.<ActivityPopupUser>custom()
.andEqualTo(ActivityPopupUser::getUserId,userInfo.getUserid())
.andIn(ActivityPopupUser::getPopupId,collect)
).build(); ).build();
List<ActivityPopupUser> activityPopupUsers = activityPopupUserBiz.selectByExample(exaple); List<ActivityPopupUser> activityPopupUsers = activityPopupUserBiz.selectByExample(exaple);
if (activityPopupUsers==null||activityPopupUsers.size()==0) { if (activityPopupUsers==null||activityPopupUsers.size()==0) {
return activityPopups; return activityPopups;
} }
Set<Integer> popupIdSet = activityPopupUsers.parallelStream().map(ActivityPopupUser::getPopupId).collect(Collectors.toSet()); Set<Integer> popupIdSet = activityPopupUsers.parallelStream().map(ActivityPopupUser::getPopupId).collect(Collectors.toSet());
List<ActivityPopup> result= new ArrayList<>(); List<ActivityPopup> result= new ArrayList<>();
for (ActivityPopup activityPopup : activityPopups) { for (ActivityPopup activityPopup : activityPopups) {
...@@ -87,21 +89,27 @@ public class ActivityPopupBiz extends BaseBiz<ActivityPopupMapper,ActivityPopup> ...@@ -87,21 +89,27 @@ public class ActivityPopupBiz extends BaseBiz<ActivityPopupMapper,ActivityPopup>
.andLessThanOrEqualTo(ActivityPopup::getStartTime, BigInteger.valueOf(System.currentTimeMillis())) .andLessThanOrEqualTo(ActivityPopup::getStartTime, BigInteger.valueOf(System.currentTimeMillis()))
.andIn(ActivityPopup::getType, Arrays.asList(Types.split(","))) .andIn(ActivityPopup::getType, Arrays.asList(Types.split(",")))
.andEqualTo(ActivityPopup::getStatus, 1) .andEqualTo(ActivityPopup::getStatus, 1)
.andEqualTo(ActivityPopup::getIsDel,0)
).orderByAsc("sort").build(); ).orderByAsc("sort").build();
List<ActivityPopup> activityPopups = mapper.selectByExample(exa); List<ActivityPopup> activityPopups = mapper.selectByExample(exa);
long l = System.currentTimeMillis(); long l = System.currentTimeMillis();
return activityPopups ; return activityPopups ;
} }
/**
* 判断是否重复弹窗
* @param userInfo
* @param id
*/
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void setActivityPopup(AppUserDTO userInfo,Integer id){ public void setActivityPopup(AppUserDTO userInfo,Integer id){
if (userInfo!=null) { if (userInfo!=null) {
Example exa=Example.builder(ActivityPopupUser.class).where( Example exa=Example.builder(ActivityPopupUser.class).where(
WeekendSqls.<ActivityPopupUser>custom() WeekendSqls.<ActivityPopupUser>custom()
.andEqualTo(ActivityPopupUser::getPopupId,id) .andEqualTo(ActivityPopupUser::getPopupId,id)
.andEqualTo(ActivityPopupUser::getUserId,userInfo.getUserid())
).build(); ).build();
List<ActivityPopupUser> activityPopupUsers = activityPopupUserBiz.selectByExample(exa); List<ActivityPopupUser> activityPopupUsers = activityPopupUserBiz.selectByExample(exa);
if (activityPopupUsers==null||activityPopupUsers.size()==0) { if (activityPopupUsers==null||activityPopupUsers.size()==0) {
ActivityPopupUser activityPopupUser = new ActivityPopupUser(); ActivityPopupUser activityPopupUser = new ActivityPopupUser();
...@@ -114,4 +122,15 @@ public class ActivityPopupBiz extends BaseBiz<ActivityPopupMapper,ActivityPopup> ...@@ -114,4 +122,15 @@ public class ActivityPopupBiz extends BaseBiz<ActivityPopupMapper,ActivityPopup>
} }
} }
public void deleteOne(Integer id) {
ActivityPopup activityPopup = selectById(id);
if (activityPopup.getStatus()==1) {
throw new BaseException("Please take it off the shelves first");
}else{
activityPopup.setIsDel(1);
}
updateById(activityPopup);
}
} }
package com.xxfc.platform.activity.biz;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.github.wxiaoqi.security.common.biz.BaseBiz;
import com.github.wxiaoqi.security.common.exception.BaseException;
import com.xxfc.platform.activity.entity.ActivityList;
import com.xxfc.platform.activity.entity.HomeActivities;
import com.xxfc.platform.activity.mapper.HomeActivitiesMapper;
import com.xxfc.platform.activity.vo.ActivitiesQuery;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import tk.mybatis.mapper.entity.Example;
import tk.mybatis.mapper.weekend.WeekendSqls;
import java.util.List;
/**
* @author Administrator
*/
@Service
public class HomeActivitiesBiz extends BaseBiz<HomeActivitiesMapper, HomeActivities> {
public List<HomeActivities> activities () {
long currentTime = System.currentTimeMillis();
Example exa=Example.builder(HomeActivities.class).where(WeekendSqls.<HomeActivities>custom()
.andGreaterThanOrEqualTo(HomeActivities::getEndTime,currentTime)
.andLessThanOrEqualTo(HomeActivities::getStartTime,currentTime)
.andEqualTo(HomeActivities::getStatus,1)
.andEqualTo(HomeActivities::getIsDel,0)
).orderByAsc("sort").build();
List<HomeActivities> activityLists = selectByExample(exa);
return activityLists;
}
public PageInfo<HomeActivities> getPage (ActivitiesQuery query) {
Example exa =new Example(HomeActivities.class);
if (StringUtils.isNotBlank(query.getActivitiesName())){
exa.createCriteria().andLike("name","%"+query.getActivitiesName()+"%");
}
exa.createCriteria().andEqualTo("isDel",0);
exa.orderBy("sort").asc();
PageHelper.startPage(query.getPage(),query.getLimit());
List<HomeActivities> activityLists = selectByExample(exa);
return PageInfo.of(activityLists);
}
public void deleteOne(Integer id) {
HomeActivities homeActivities = selectById(id);
if (homeActivities.getStatus()==1) {
throw new BaseException("Please take it off the shelves first");
}else{
homeActivities.setIsDel(1);
}
updateById(homeActivities);
}
}
...@@ -269,10 +269,17 @@ public class UserCouponBiz extends BaseBiz<UserCouponMapper, UserCoupon> { ...@@ -269,10 +269,17 @@ public class UserCouponBiz extends BaseBiz<UserCouponMapper, UserCoupon> {
if (CollectionUtils.isEmpty(data)) { if (CollectionUtils.isEmpty(data)) {
return userCouponPag; return userCouponPag;
} }
Map<Integer, AppUserLogin> userIdAndAppuserLoginMap = null; Map<Integer, AppUserLogin> userIdAndAppuserLoginMap = new HashMap<>();
if (Objects.nonNull(userCouponFindDTO.getPhone())) {
List<Integer> userIds = data.stream().map(UserCouponDTO::getUserId).collect(Collectors.toList()); if (StringUtils.isEmpty(userCouponFindDTO.getPhone())) {
List<Integer> userIds = data.stream().map(UserCouponDTO::getUserId).distinct().collect(Collectors.toList());
if (log.isDebugEnabled()){
log.debug("查询的用户ids【{}】",userIds);
}
userIdAndAppuserLoginMap = userFeign.findAppUsersByUserIds(userIds); userIdAndAppuserLoginMap = userFeign.findAppUsersByUserIds(userIds);
if (log.isDebugEnabled()){
log.debug("查询的用户信息【{}】",userIdAndAppuserLoginMap);
}
} }
List<UserCouponPageVo> userCouponPageVos = new ArrayList<>(); List<UserCouponPageVo> userCouponPageVos = new ArrayList<>();
UserCouponPageVo userCouponPageVo; UserCouponPageVo userCouponPageVo;
...@@ -282,7 +289,7 @@ public class UserCouponBiz extends BaseBiz<UserCouponMapper, UserCoupon> { ...@@ -282,7 +289,7 @@ public class UserCouponBiz extends BaseBiz<UserCouponMapper, UserCoupon> {
if (Objects.nonNull(userCouponFindDTO.getPhone())) { if (Objects.nonNull(userCouponFindDTO.getPhone())) {
userCouponPageVo.setPhone(userCouponFindDTO.getPhone()); userCouponPageVo.setPhone(userCouponFindDTO.getPhone());
} else { } else {
userCouponPageVo.setPhone(userIdAndAppuserLoginMap == null ? "" : userIdAndAppuserLoginMap.get(userCouponDTO.getUserId()) == null ? "" : userIdAndAppuserLoginMap.get(userCouponDTO.getUserId()).getUsername()); userCouponPageVo.setPhone(userIdAndAppuserLoginMap.get(userCouponDTO.getUserId()) == null ? "" : userIdAndAppuserLoginMap.get(userCouponDTO.getUserId()).getUsername());
} }
userCouponPageVos.add(userCouponPageVo); userCouponPageVos.add(userCouponPageVo);
} }
...@@ -347,4 +354,11 @@ public class UserCouponBiz extends BaseBiz<UserCouponMapper, UserCoupon> { ...@@ -347,4 +354,11 @@ public class UserCouponBiz extends BaseBiz<UserCouponMapper, UserCoupon> {
userInfoDTO.setCouponNumber(couponNumber); userInfoDTO.setCouponNumber(couponNumber);
return userInfoDTO; return userInfoDTO;
} }
public void deleteByUserIds(List<Integer> userIds) {
Example example = new Example(UserCoupon.class);
Example.Criteria criteria = example.createCriteria();
criteria.andIn("userId",userIds);
mapper.deleteByExample(example);
}
} }
\ No newline at end of file
package com.xxfc.platform.activity.mapper;
import com.xxfc.platform.activity.entity.HomeActivities;
import tk.mybatis.mapper.common.Mapper;
/**
* @author Administrator
*/
public interface HomeActivitiesMapper extends Mapper<HomeActivities> {
}
...@@ -27,6 +27,4 @@ public class ActivityListController extends BaseController<ActivityListBiz,Activ ...@@ -27,6 +27,4 @@ public class ActivityListController extends BaseController<ActivityListBiz,Activ
List<ActivityList> list= baseBiz.activities(); List<ActivityList> list= baseBiz.activities();
return ObjectRestResponse.succ(list); return ObjectRestResponse.succ(list);
} }
} }
\ No newline at end of file
package com.xxfc.platform.activity.rest; package com.xxfc.platform.activity.rest;
import com.github.pagehelper.PageInfo;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse; import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.github.wxiaoqi.security.common.rest.BaseController; import com.github.wxiaoqi.security.common.rest.BaseController;
import com.xxfc.platform.activity.biz.ActivityManagementBiz; import com.xxfc.platform.activity.biz.ActivityManagementBiz;
import com.xxfc.platform.activity.entity.ActivityList; import com.xxfc.platform.activity.entity.ActivityList;
import com.xxfc.platform.activity.entity.ActivityManagement; import com.xxfc.platform.activity.entity.ActivityManagement;
import com.xxfc.platform.activity.vo.ActivityManagementQuery;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.lang.reflect.InvocationTargetException; import java.lang.reflect.InvocationTargetException;
...@@ -24,11 +26,10 @@ public class ActivityManagementController extends BaseController<ActivityManagem ...@@ -24,11 +26,10 @@ public class ActivityManagementController extends BaseController<ActivityManagem
* @throws InvocationTargetException * @throws InvocationTargetException
* @throws IllegalAccessException * @throws IllegalAccessException
*/ */
@RequestMapping("/activity/findAll") @PostMapping("/activity/findAll")
public ObjectRestResponse<List<ActivityManagement>> findAll() throws InvocationTargetException, IllegalAccessException { public ObjectRestResponse findAll(@RequestBody ActivityManagementQuery query) throws InvocationTargetException, IllegalAccessException {
PageInfo<ActivityList> pageInfo= baseBiz.selectedActivityManagement(query);
List<ActivityList> list= baseBiz.selectedActivityManagement(); return ObjectRestResponse.succ(pageInfo);
return ObjectRestResponse.succ(list);
} }
......
...@@ -38,4 +38,7 @@ public class ActivityPopupController extends ActivityBaseController<ActivityPopu ...@@ -38,4 +38,7 @@ public class ActivityPopupController extends ActivityBaseController<ActivityPopu
} }
} }
package com.xxfc.platform.activity.rest;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.github.wxiaoqi.security.common.rest.BaseController;
import com.xxfc.platform.activity.biz.ActivityPopupBiz;
import com.xxfc.platform.activity.entity.ActivityPopup;
import com.xxfc.platform.activity.vo.PopupQuery;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.*;
import tk.mybatis.mapper.entity.Example;
import java.util.List;
/**
* 弹窗后台
*
* @author Administrator
*/
@RestController
@RequestMapping("activityPopupManage")
@Slf4j
public class ActivityPopupManageController extends BaseController<ActivityPopupBiz, ActivityPopup> {
/**
* 后台列表
* @param query
* @return
*/
@PostMapping(value = "/manage/findAllByQuery")
public ObjectRestResponse findAllByQuery(@RequestBody PopupQuery query) {
Example example = new Example(ActivityPopup.class);
if (StringUtils.isNotBlank(query.getPopupName())) {
example.createCriteria().andLike("name", "%" + query.getPopupName() + "%");
}
PageHelper.startPage(query.getPage(), query.getLimit());
List<ActivityPopup> activityPopups = baseBiz.selectByExample(example);
return ObjectRestResponse.succ(PageInfo.of(activityPopups));
}
/**
* 查询一条
* @param id
* @return
*/
@PostMapping(value = "/manage/getOne/{id}")
public ObjectRestResponse<ActivityPopup> getOne(@PathVariable Integer id) {
Example exa=new Example(ActivityPopup.class);
exa.createCriteria().andEqualTo("isDel",0);
exa.createCriteria().andEqualTo("id",id);
List<ActivityPopup> activityPopups = baseBiz.selectByExample(exa);
if (activityPopups==null||activityPopups.size()==0) {
return ObjectRestResponse.succ(new ActivityPopup());
}
if (activityPopups.size()>1) {
return ObjectRestResponse.createDefaultFail();
}
return ObjectRestResponse.succ(activityPopups.get(0));
}
/**
* 删除
* @param id
* @return
*/
@DeleteMapping("manage/activity/deleteOne/{id}")
public ObjectRestResponse deleteOne(@PathVariable Integer id){
baseBiz.deleteOne(id);
return ObjectRestResponse.succ();
}
}
...@@ -2,6 +2,7 @@ package com.xxfc.platform.activity.rest; ...@@ -2,6 +2,7 @@ package com.xxfc.platform.activity.rest;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse; import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.xxfc.platform.activity.biz.ActivityPopularizeUserBiz; import com.xxfc.platform.activity.biz.ActivityPopularizeUserBiz;
import com.xxfc.platform.activity.biz.UserCouponBiz;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
...@@ -20,12 +21,16 @@ import java.util.List; ...@@ -20,12 +21,16 @@ import java.util.List;
@RequestMapping("/activity_data") @RequestMapping("/activity_data")
public class DateController { public class DateController {
@Autowired @Autowired
private ActivityPopularizeUserBiz activityPopularizeUserBiz; private ActivityPopularizeUserBiz activityPopularizeUserBiz;
private UserCouponBiz userCouponBiz;
@GetMapping("/clear") @GetMapping("/clear")
public ObjectRestResponse<Void> clearDate(@RequestParam(value = "userIds") List<Integer> userIds){ public ObjectRestResponse<Void> clearDate(@RequestParam(value = "userIds") List<Integer> userIds){
activityPopularizeUserBiz.deleteByUserIds(userIds); activityPopularizeUserBiz.deleteByUserIds(userIds);
userCouponBiz.deleteByUserIds(userIds);
return ObjectRestResponse.succ(); return ObjectRestResponse.succ();
} }
} }
package com.xxfc.platform.activity.rest;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.github.wxiaoqi.security.common.rest.BaseController;
import com.xxfc.platform.activity.biz.ActivityListBiz;
import com.xxfc.platform.activity.biz.HomeActivitiesBiz;
import com.xxfc.platform.activity.entity.ActivityList;
import com.xxfc.platform.activity.entity.HomeActivities;
import com.xxfc.platform.activity.vo.ActivitiesQuery;
import org.apache.ibatis.annotations.Delete;
import org.springframework.web.bind.annotation.*;
import tk.mybatis.mapper.entity.Example;
import java.lang.reflect.InvocationTargetException;
import java.util.List;
/**
* 精彩活动
* @author Administrator
*/
@RestController
@RequestMapping("homeActivities")
public class HomeActivitiesController extends BaseController<HomeActivitiesBiz, HomeActivities> {
/**
* app精彩活动列表
* @return
* @throws InvocationTargetException
* @throws IllegalAccessException
*/
@GetMapping("/app/unauth/activity/findAll")
public ObjectRestResponse<List<HomeActivities>> appFindAll() throws InvocationTargetException, IllegalAccessException {
List<HomeActivities> list= baseBiz.activities();
return ObjectRestResponse.succ(list);
}
/**
* 后台精彩活动列表
* @param query
* @return
*/
@PostMapping("manage/activity/findAll")
public ObjectRestResponse findAll(@RequestBody ActivitiesQuery query){
return ObjectRestResponse.succ(baseBiz.getPage(query));
}
/**
* 获取一条精彩活动
* @param id
* @return
*/
@PostMapping(value = "/manage/activity/getOne/{id}")
public ObjectRestResponse<HomeActivities> getOne(@PathVariable Integer id) {
Example exa=new Example(HomeActivities.class);
Example.Criteria criteria = exa.createCriteria();
criteria.andEqualTo("isDel",0);
criteria.andEqualTo("id",id);
List<HomeActivities> homeActivities = baseBiz.selectByExample(exa);
if (homeActivities==null||homeActivities.size()==0) {
return ObjectRestResponse.succ(new HomeActivities());
}
if (homeActivities.size()>1) {
return ObjectRestResponse.createDefaultFail();
}
return ObjectRestResponse.succ(homeActivities.get(0));
}
/**
* 删除
* @param id
* @return
*/
@DeleteMapping("manage/activity/deleteOne/{id}")
public ObjectRestResponse deleteOne(@PathVariable Integer id){
baseBiz.deleteOne(id);
return ObjectRestResponse.succ();
}
}
\ No newline at end of file
package com.xxfc.platform.order.entity;
import lombok.Data;
import javax.persistence.Column;
import java.util.Date;
@Data
public class DailyOrderStatistics {
@Column()
private Date oneDay;
}
...@@ -36,6 +36,7 @@ import lombok.extern.slf4j.Slf4j; ...@@ -36,6 +36,7 @@ import lombok.extern.slf4j.Slf4j;
import org.apache.commons.jexl2.MapContext; import org.apache.commons.jexl2.MapContext;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
...@@ -598,5 +599,10 @@ public class BaseOrderBiz extends BaseBiz<BaseOrderMapper,BaseOrder> { ...@@ -598,5 +599,10 @@ public class BaseOrderBiz extends BaseBiz<BaseOrderMapper,BaseOrder> {
log.error(e.getMessage(), e); log.error(e.getMessage(), e);
} }
} }
// @Scheduled(cron = "0 0 2 * * ? ")
// private void countDailyOrdersRegularly(){
// DailyOrderStatistics dailyOrderStatistics= mapper.getTotalOrder();
// }
//
} }
\ No newline at end of file
...@@ -26,4 +26,6 @@ public interface BaseOrderMapper extends Mapper<BaseOrder> { ...@@ -26,4 +26,6 @@ public interface BaseOrderMapper extends Mapper<BaseOrder> {
public List<OrderPageVO> getTourList(Map<String, Object> paramMap); public List<OrderPageVO> getTourList(Map<String, Object> paramMap);
public OrderPageVO getOrderDetail(String no); public OrderPageVO getOrderDetail(String no);
Integer getTotalOrder();
} }
...@@ -3,7 +3,7 @@ ...@@ -3,7 +3,7 @@
<mapper namespace="com.xxfc.platform.order.mapper.BaseOrderMapper"> <mapper namespace="com.xxfc.platform.order.mapper.BaseOrderMapper">
<!-- 可根据自己的需求,是否要使用 --> <!-- 可根据自己的需求,是否要使用 -->
<resultMap type="com.xxfc.platform.order.entity.BaseOrder" id="baseOrderMap"> <resultMap type="com.xxfc.platform.order.entity.BaseOrder" id="baseOrderMap">
<result property="id" column="id"/> <result property="id" column="id"/>
<result property="no" column="no"/> <result property="no" column="no"/>
...@@ -29,13 +29,19 @@ ...@@ -29,13 +29,19 @@
<result javaType="Integer" column="type" property="type"></result> <result javaType="Integer" column="type" property="type"></result>
<discriminator javaType="Integer" column="type"> <discriminator javaType="Integer" column="type">
<case value="1" resultType="com.xxfc.platform.order.pojo.order.OrderPageVO"> <case value="1" resultType="com.xxfc.platform.order.pojo.order.OrderPageVO">
<association column="{id=detail_id}" property="orderRentVehicleDetail" select="com.xxfc.platform.order.mapper.OrderRentVehicleDetailMapper.pageByParm" javaType="com.xxfc.platform.order.entity.OrderRentVehicleDetail"></association> <association column="{id=detail_id}" property="orderRentVehicleDetail"
select="com.xxfc.platform.order.mapper.OrderRentVehicleDetailMapper.pageByParm"
javaType="com.xxfc.platform.order.entity.OrderRentVehicleDetail"></association>
</case> </case>
<case value="2" resultType="com.xxfc.platform.order.pojo.order.OrderPageVO"> <case value="2" resultType="com.xxfc.platform.order.pojo.order.OrderPageVO">
<association column="detail_id" property="orderTourDetail" select="com.xxfc.platform.order.mapper.OrderTourDetailMapper.selectByPrimaryKey" javaType="com.xxfc.platform.order.entity.OrderTourDetail"></association> <association column="detail_id" property="orderTourDetail"
select="com.xxfc.platform.order.mapper.OrderTourDetailMapper.selectByPrimaryKey"
javaType="com.xxfc.platform.order.entity.OrderTourDetail"></association>
</case> </case>
<case value="3" resultType="com.xxfc.platform.order.pojo.order.OrderPageVO"> <case value="3" resultType="com.xxfc.platform.order.pojo.order.OrderPageVO">
<association column="detail_id" property="orderMemberDetail" select="com.xxfc.platform.order.mapper.OrderMemberDetailMapper.selectByPrimaryKey" javaType="com.xxfc.platform.order.entity.OrderMemberDetail"></association> <association column="detail_id" property="orderMemberDetail"
select="com.xxfc.platform.order.mapper.OrderMemberDetailMapper.selectByPrimaryKey"
javaType="com.xxfc.platform.order.entity.OrderMemberDetail"></association>
</case> </case>
</discriminator> </discriminator>
</resultMap> </resultMap>
...@@ -45,20 +51,26 @@ ...@@ -45,20 +51,26 @@
<result javaType="Integer" column="type" property="type"></result> <result javaType="Integer" column="type" property="type"></result>
<discriminator javaType="Integer" column="type"> <discriminator javaType="Integer" column="type">
<case value="1" resultType="com.xxfc.platform.order.pojo.order.OrderListVo"> <case value="1" resultType="com.xxfc.platform.order.pojo.order.OrderListVo">
<association column="{id=detail_id}" property="orderRentVehicleDetail" select="com.xxfc.platform.order.mapper.OrderRentVehicleDetailMapper.pageByParm" javaType="com.xxfc.platform.order.entity.OrderRentVehicleDetail"></association> <association column="{id=detail_id}" property="orderRentVehicleDetail"
select="com.xxfc.platform.order.mapper.OrderRentVehicleDetailMapper.pageByParm"
javaType="com.xxfc.platform.order.entity.OrderRentVehicleDetail"></association>
</case> </case>
<case value="2" resultType="com.xxfc.platform.order.pojo.order.OrderListVo"> <case value="2" resultType="com.xxfc.platform.order.pojo.order.OrderListVo">
<association column="detail_id" property="orderTourDetail" select="com.xxfc.platform.order.mapper.OrderTourDetailMapper.selectByPrimaryKey" javaType="com.xxfc.platform.order.entity.OrderTourDetail"></association> <association column="detail_id" property="orderTourDetail"
select="com.xxfc.platform.order.mapper.OrderTourDetailMapper.selectByPrimaryKey"
javaType="com.xxfc.platform.order.entity.OrderTourDetail"></association>
</case> </case>
<case value="3" resultType="com.xxfc.platform.order.pojo.order.OrderListVo"> <case value="3" resultType="com.xxfc.platform.order.pojo.order.OrderListVo">
<association column="detail_id" property="orderMemberDetail" select="com.xxfc.platform.order.mapper.OrderMemberDetailMapper.selectByPrimaryKey" javaType="com.xxfc.platform.order.entity.OrderMemberDetail"></association> <association column="detail_id" property="orderMemberDetail"
select="com.xxfc.platform.order.mapper.OrderMemberDetailMapper.selectByPrimaryKey"
javaType="com.xxfc.platform.order.entity.OrderMemberDetail"></association>
</case> </case>
</discriminator> </discriminator>
</resultMap> </resultMap>
<select id="pageByParm" parameterType="Map" resultMap="orderPageMap"> <select id="pageByParm" parameterType="Map" resultMap="orderPageMap">
select * select *
from base_order from base_order
<where> <where>
<if test="crtUser != null"> <if test="crtUser != null">
and crt_user = #{crtUser} and crt_user = #{crtUser}
...@@ -82,7 +94,7 @@ ...@@ -82,7 +94,7 @@
and and
( (
<foreach collection="multiStatus.split(',')" index="sIndex" item="statusEntity" separator=" or "> <foreach collection="multiStatus.split(',')" index="sIndex" item="statusEntity" separator=" or ">
status = #{statusEntity} status = #{statusEntity}
</foreach> </foreach>
) )
</if> </if>
...@@ -113,7 +125,7 @@ ...@@ -113,7 +125,7 @@
<if test="status != null"> <if test="status != null">
and b.status = #{status} and b.status = #{status}
</if> </if>
<if test="type != null"> <if test="type != null">
and b.type = #{type} and b.type = #{type}
</if> </if>
<if test="no != null"> <if test="no != null">
...@@ -123,8 +135,8 @@ ...@@ -123,8 +135,8 @@
and b.name like CONCAT ("%", #{name}, "%") and b.name like CONCAT ("%", #{name}, "%")
</if> </if>
<if test="startTime != null"> <if test="startTime != null">
and r.start_time between #{startTime} and #{endTime} and r.start_time between #{startTime} and #{endTime}
or t.start_time between #{startTime} and #{endTime} or t.start_time between #{startTime} and #{endTime}
</if> </if>
<if test="startCompanyId != null"> <if test="startCompanyId != null">
and r.start_company_id = #{startCompanyId} and r.start_company_id = #{startCompanyId}
...@@ -143,24 +155,24 @@ ...@@ -143,24 +155,24 @@
from base_order b from base_order b
LEFT JOIN order_rent_vehicle_detail r on r.order_id = b.id LEFT JOIN order_rent_vehicle_detail r on r.order_id = b.id
where b.type = 1 where b.type = 1
<if test="userId != null"> <if test="userId != null">
and b.user_id = #{userId} and b.user_id = #{userId}
</if> </if>
<if test="status != null"> <if test="status != null">
and b.status = #{status} and b.status = #{status}
</if> </if>
<if test="no != null"> <if test="no != null">
and no like CONCAT ("%", #{no}, "%") and no like CONCAT ("%", #{no}, "%")
</if> </if>
<if test="startTime != null and status == 4"> <if test="startTime != null and status == 4">
and r.start_time between #{startTime} and #{endTime} and r.start_time between #{startTime} and #{endTime}
</if> </if>
<if test="startTime != null and status == 5"> <if test="startTime != null and status == 5">
and r.start_time between #{startTime} and #{endTime} and r.start_time between #{startTime} and #{endTime}
</if> </if>
<if test="startCompanyId != null"> <if test="startCompanyId != null">
and r.start_company_id = #{startCompanyId} and r.start_company_id = #{startCompanyId}
</if> </if>
order by b.crt_time desc order by b.crt_time desc
</select> </select>
...@@ -169,21 +181,21 @@ ...@@ -169,21 +181,21 @@
from base_order b from base_order b
LEFT JOIN order_tour_detail r on r.order_id = b.id LEFT JOIN order_tour_detail r on r.order_id = b.id
where b.type = 2 where b.type = 2
<if test="userId != null"> <if test="userId != null">
and b.user_id = #{userId} and b.user_id = #{userId}
</if> </if>
<if test="status != null"> <if test="status != null">
and b.status = #{status} and b.status = #{status}
</if> </if>
<if test="no != null"> <if test="no != null">
and no like CONCAT ("%", #{no}, "%") and no like CONCAT ("%", #{no}, "%")
</if> </if>
<if test="startTime != null"> <if test="startTime != null">
and r.start_time between #{startTime} and #{endTime} and r.start_time between #{startTime} and #{endTime}
</if> </if>
<if test="startCompanyId != null"> <if test="startCompanyId != null">
and r.start_company_id = #{startCompanyId} and r.start_company_id = #{startCompanyId}
</if> </if>
order by b.crt_time desc order by b.crt_time desc
</select> </select>
...@@ -193,4 +205,16 @@ ...@@ -193,4 +205,16 @@
where no = #{no} where no = #{no}
</select> </select>
<select id="getTotalOrder" resultType="com.xxfc.platform.order.entity.DailyOrderStatistics">
select
date_format(crt_time,'%Y-%c-%d') as oneDay,
SUM(1)
from
base_order
where
date(crt_time)=date(now())-1
group by
date_format(crt_time,'%d')
</select>
</mapper> </mapper>
\ No newline at end of file
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