forked from angelo/java-retail-app
Compare commits
No commits in common. "aa42aa02635e6c76e9cced7f80e4b34d1d8d4b02" and "b376571da25de842aa32fc044097c27ec947aecd" have entirely different histories.
aa42aa0263
...
b376571da2
|
|
@ -9,7 +9,6 @@ import com.hzs.common.domain.system.config.BdTradeWhiteConfig;
|
||||||
import com.hzs.member.base.dto.MemberCountDTO;
|
import com.hzs.member.base.dto.MemberCountDTO;
|
||||||
import com.hzs.member.base.param.*;
|
import com.hzs.member.base.param.*;
|
||||||
import com.hzs.member.base.vo.*;
|
import com.hzs.member.base.vo.*;
|
||||||
import com.hzs.member.census.param.CensusSummaryParam;
|
|
||||||
import com.hzs.member.handlebusiness.vo.BusinessMemberVO;
|
import com.hzs.member.handlebusiness.vo.BusinessMemberVO;
|
||||||
import com.hzs.member.handlebusiness.vo.HandleBusinessVO;
|
import com.hzs.member.handlebusiness.vo.HandleBusinessVO;
|
||||||
import com.hzs.member.marketnews.param.MarketNewsParam;
|
import com.hzs.member.marketnews.param.MarketNewsParam;
|
||||||
|
|
@ -629,13 +628,4 @@ public interface CuMemberMapper extends BaseMapper<CuMember> {
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
int getMemberCountWithGradeAndParent(@Param("parentId") Long parentId, @Param("gradeValue") Integer gradeValue);
|
int getMemberCountWithGradeAndParent(@Param("parentId") Long parentId, @Param("gradeValue") Integer gradeValue);
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询业绩汇总
|
|
||||||
*
|
|
||||||
* @param censusSummaryParam
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
List<MemberMeritsSummaryVo> queryDateBySummary(CensusSummaryParam censusSummaryParam);
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -13,8 +13,6 @@ import com.hzs.member.base.dto.ShowWaresDTO;
|
||||||
import com.hzs.member.base.dto.ZeroElementRevokeDTO;
|
import com.hzs.member.base.dto.ZeroElementRevokeDTO;
|
||||||
import com.hzs.member.base.param.*;
|
import com.hzs.member.base.param.*;
|
||||||
import com.hzs.member.base.vo.*;
|
import com.hzs.member.base.vo.*;
|
||||||
import com.hzs.member.census.param.CensusSummaryParam;
|
|
||||||
import com.hzs.member.census.vo.CensusSummaryVo;
|
|
||||||
import com.hzs.member.handlebusiness.dto.AnalysisBusinessAppealParam;
|
import com.hzs.member.handlebusiness.dto.AnalysisBusinessAppealParam;
|
||||||
import com.hzs.member.handlebusiness.vo.BusinessMemberVO;
|
import com.hzs.member.handlebusiness.vo.BusinessMemberVO;
|
||||||
import com.hzs.member.handlebusiness.vo.HandleBusinessVO;
|
import com.hzs.member.handlebusiness.vo.HandleBusinessVO;
|
||||||
|
|
@ -894,12 +892,4 @@ public interface ICuMemberService extends IService<CuMember> {
|
||||||
*/
|
*/
|
||||||
SaOrder listRecommendVipOrder(Long pkMember, String orderCode);
|
SaOrder listRecommendVipOrder(Long pkMember, String orderCode);
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询汇总
|
|
||||||
*
|
|
||||||
* @param censusSummaryParam 表格名称
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
List<CensusSummaryVo> selectCensusSummary(CensusSummaryParam censusSummaryParam, List<String> days);
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -46,8 +46,6 @@ import com.hzs.member.base.mapper.CuMemberMapper;
|
||||||
import com.hzs.member.base.param.*;
|
import com.hzs.member.base.param.*;
|
||||||
import com.hzs.member.base.service.*;
|
import com.hzs.member.base.service.*;
|
||||||
import com.hzs.member.base.vo.*;
|
import com.hzs.member.base.vo.*;
|
||||||
import com.hzs.member.census.param.CensusSummaryParam;
|
|
||||||
import com.hzs.member.census.vo.CensusSummaryVo;
|
|
||||||
import com.hzs.member.detail.service.ICuMemberServiceLogService;
|
import com.hzs.member.detail.service.ICuMemberServiceLogService;
|
||||||
import com.hzs.member.detail.service.impl.CuMemberLevelServiceImpl;
|
import com.hzs.member.detail.service.impl.CuMemberLevelServiceImpl;
|
||||||
import com.hzs.member.empty.service.ICuMemberEmptyCodeService;
|
import com.hzs.member.empty.service.ICuMemberEmptyCodeService;
|
||||||
|
|
@ -3259,66 +3257,4 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
|
||||||
return baseMapper.listRecommendVipOrder(pkMember, orderCode);
|
return baseMapper.listRecommendVipOrder(pkMember, orderCode);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public List<CensusSummaryVo> selectCensusSummary(CensusSummaryParam censusSummaryParam, List<String> days) {
|
|
||||||
// 根据类型查询所有人各类型的订单业绩汇总
|
|
||||||
List<CensusSummaryVo> censusSummaryList = new ArrayList<>();
|
|
||||||
for (String day : days) {
|
|
||||||
censusSummaryParam.setTime(day);
|
|
||||||
List<MemberMeritsSummaryVo> memberMeritsSummaryVoList = baseMapper.queryDateBySummary(censusSummaryParam);
|
|
||||||
Map<Integer, MemberMeritsSummaryVo> memberMeritsSummaryMap = memberMeritsSummaryVoList.stream().collect(Collectors.toMap(MemberMeritsSummaryVo::getOrderType, Function.identity()));
|
|
||||||
|
|
||||||
CensusSummaryVo censusSummaryVo = new CensusSummaryVo();
|
|
||||||
censusSummaryVo.setSettleDate(day);
|
|
||||||
|
|
||||||
// 注册
|
|
||||||
BigDecimal reAmount = BigDecimal.ZERO;
|
|
||||||
BigDecimal reAchieve = BigDecimal.ZERO;
|
|
||||||
if (memberMeritsSummaryMap.get(EOrderType.RETAIL_REGISTER.getValue()) != null) {
|
|
||||||
reAmount = memberMeritsSummaryMap.get(EOrderType.RETAIL_REGISTER.getValue()).getAmount();
|
|
||||||
reAchieve = memberMeritsSummaryMap.get(EOrderType.RETAIL_REGISTER.getValue()).getAchieve();
|
|
||||||
}
|
|
||||||
censusSummaryVo.setRegisterAmount(reAmount);
|
|
||||||
censusSummaryVo.setRegisterPv(reAchieve);
|
|
||||||
|
|
||||||
// 升级
|
|
||||||
BigDecimal upAmount = BigDecimal.ZERO;
|
|
||||||
BigDecimal upAchieve = BigDecimal.ZERO;
|
|
||||||
if (memberMeritsSummaryMap.get(EOrderType.RETAIL_UPGRADE.getValue()) != null) {
|
|
||||||
upAmount = memberMeritsSummaryMap.get(EOrderType.RETAIL_UPGRADE.getValue()).getAmount();
|
|
||||||
upAchieve = memberMeritsSummaryMap.get(EOrderType.RETAIL_UPGRADE.getValue()).getAchieve();
|
|
||||||
}
|
|
||||||
censusSummaryVo.setUpgradeAmount(upAmount);
|
|
||||||
censusSummaryVo.setUpgradePv(upAchieve);
|
|
||||||
|
|
||||||
// 首购
|
|
||||||
censusSummaryVo.setFirstPurchaseAmount(censusSummaryVo.getRegisterAmount().add(censusSummaryVo.getUpgradeAmount()));
|
|
||||||
censusSummaryVo.setFirstPurchasePv(censusSummaryVo.getRegisterPv().add(censusSummaryVo.getUpgradePv()));
|
|
||||||
|
|
||||||
// 复购订单
|
|
||||||
BigDecimal repurchaseAmount = BigDecimal.ZERO;
|
|
||||||
BigDecimal repurchaseAchieve = BigDecimal.ZERO;
|
|
||||||
if (memberMeritsSummaryMap.get(EOrderType.RETAIL_REPURCHASE.getValue()) != null) {
|
|
||||||
repurchaseAmount = memberMeritsSummaryMap.get(EOrderType.RETAIL_REPURCHASE.getValue()).getAmount();
|
|
||||||
repurchaseAchieve = memberMeritsSummaryMap.get(EOrderType.RETAIL_REPURCHASE.getValue()).getAchieve();
|
|
||||||
}
|
|
||||||
// 复消
|
|
||||||
if (memberMeritsSummaryMap.get(EOrderType.CONSUME_ORDER.getValue()) != null) {
|
|
||||||
repurchaseAmount = repurchaseAmount.add(memberMeritsSummaryMap.get(EOrderType.RETAIL_CONSUME.getValue()).getAmount());
|
|
||||||
}
|
|
||||||
|
|
||||||
// 复购
|
|
||||||
censusSummaryVo.setRepurchaseAmount(repurchaseAmount);
|
|
||||||
censusSummaryVo.setRepurchasePv(repurchaseAchieve);
|
|
||||||
|
|
||||||
// 金额总计
|
|
||||||
censusSummaryVo.setAmountTotal(censusSummaryVo.getFirstPurchaseAmount().add(censusSummaryVo.getRepurchaseAmount()));
|
|
||||||
// 业绩汇总
|
|
||||||
censusSummaryVo.setPvTotal(censusSummaryVo.getFirstPurchasePv().add(censusSummaryVo.getRepurchasePv()));
|
|
||||||
censusSummaryList.add(censusSummaryVo);
|
|
||||||
}
|
|
||||||
return censusSummaryList;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -1,119 +0,0 @@
|
||||||
package com.hzs.member.census.controller.manage;
|
|
||||||
|
|
||||||
import com.hzs.common.core.annotation.AccessPermissions;
|
|
||||||
import com.hzs.common.core.utils.DateUtils;
|
|
||||||
import com.hzs.common.core.utils.StringUtils;
|
|
||||||
import com.hzs.common.core.utils.poi.ExcelUtil;
|
|
||||||
import com.hzs.common.core.web.controller.BaseController;
|
|
||||||
import com.hzs.common.core.web.domain.AjaxResult;
|
|
||||||
import com.hzs.common.security.utils.SecurityUtils;
|
|
||||||
import com.hzs.member.achieve.service.ICuMemberSettlePeriodService;
|
|
||||||
import com.hzs.member.base.service.ICuMemberService;
|
|
||||||
import com.hzs.member.census.param.CensusSummaryParam;
|
|
||||||
import com.hzs.member.census.vo.CensusSummaryVo;
|
|
||||||
import com.hzs.system.sys.IMenuColumnServiceApi;
|
|
||||||
import org.apache.dubbo.config.annotation.DubboReference;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.web.bind.annotation.GetMapping;
|
|
||||||
import org.springframework.web.bind.annotation.PostMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RequestMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RestController;
|
|
||||||
|
|
||||||
import javax.servlet.http.HttpServletResponse;
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.Date;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.stream.Collectors;
|
|
||||||
|
|
||||||
@RestController
|
|
||||||
@RequestMapping("/manage/member-structure")
|
|
||||||
public class CensusSummaryController extends BaseController {
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private ICuMemberSettlePeriodService iCuMemberSettlePeriodService;
|
|
||||||
@Autowired
|
|
||||||
private ICuMemberService iCuMemberService;
|
|
||||||
|
|
||||||
@DubboReference
|
|
||||||
IMenuColumnServiceApi iMenuColumnServiceApi;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 业绩汇总
|
|
||||||
*
|
|
||||||
* @param censusSummaryParam
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
@AccessPermissions("performanceTotal")
|
|
||||||
@GetMapping("/list")
|
|
||||||
public AjaxResult list(CensusSummaryParam censusSummaryParam) {
|
|
||||||
if (null == censusSummaryParam.getStartDate()
|
|
||||||
|| null == censusSummaryParam.getEndDate()) {
|
|
||||||
return AjaxResult.success(new ArrayList<>());
|
|
||||||
}
|
|
||||||
|
|
||||||
List<Long> pkVertex = new ArrayList<>();
|
|
||||||
if (StringUtils.isNotEmpty(censusSummaryParam.getPkBdVertexStr())) {
|
|
||||||
pkVertex = Arrays.stream(censusSummaryParam.getPkBdVertexStr().split(","))
|
|
||||||
.map(Long::parseLong)
|
|
||||||
.collect(Collectors.toList());
|
|
||||||
}
|
|
||||||
censusSummaryParam.setPkVertex(pkVertex);
|
|
||||||
|
|
||||||
// 当天查询秒结
|
|
||||||
Date date = new Date();
|
|
||||||
// 查询当天
|
|
||||||
String thisTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, date);
|
|
||||||
// 查询当前时间范围
|
|
||||||
List<String> days = new ArrayList<>();
|
|
||||||
if (censusSummaryParam.getStartDate() != null && censusSummaryParam.getEndDate() != null) {
|
|
||||||
days = DateUtils.findDaysStr(DateUtils.parseDateTimeToStr(DateUtils.YYYY_MM_DD, censusSummaryParam.getStartDate()), DateUtils.parseDateTimeToStr(DateUtils.YYYY_MM_DD, censusSummaryParam.getEndDate()));
|
|
||||||
} else {
|
|
||||||
// 默认查询当天
|
|
||||||
days.add(thisTime);
|
|
||||||
}
|
|
||||||
|
|
||||||
censusSummaryParam.setPkCountry(SecurityUtils.getPkCountry());
|
|
||||||
List<CensusSummaryVo> resultList = iCuMemberService.selectCensusSummary(censusSummaryParam, days);
|
|
||||||
|
|
||||||
return AjaxResult.success(resultList);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 导出(导出)
|
|
||||||
*/
|
|
||||||
@PostMapping("/export")
|
|
||||||
public void export(CensusSummaryParam censusSummaryParam, HttpServletResponse response) {
|
|
||||||
if (null == censusSummaryParam.getStartDate()
|
|
||||||
|| null == censusSummaryParam.getEndDate()) {
|
|
||||||
ExcelUtil<CensusSummaryVo> util = new ExcelUtil<>(CensusSummaryVo.class);
|
|
||||||
util.exportExcel(response, new ArrayList<>(), "业绩汇总信息");
|
|
||||||
}
|
|
||||||
|
|
||||||
// 当天查询秒结
|
|
||||||
Date date = new Date();
|
|
||||||
// 查询当天
|
|
||||||
String thisTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, date);
|
|
||||||
if (censusSummaryParam.getMemberSettlePeriodId() != null) {
|
|
||||||
iCuMemberSettlePeriodService.getById(censusSummaryParam.getMemberSettlePeriodId());
|
|
||||||
} else {
|
|
||||||
iCuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(thisTime);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 查询当前时间范围
|
|
||||||
List<String> days = new ArrayList<>();
|
|
||||||
if (censusSummaryParam.getStartDate() != null && censusSummaryParam.getEndDate() != null) {
|
|
||||||
days = DateUtils.findDaysStr(DateUtils.parseDateTimeToStr(DateUtils.YYYY_MM_DD, censusSummaryParam.getStartDate()), DateUtils.parseDateTimeToStr(DateUtils.YYYY_MM_DD, censusSummaryParam.getEndDate()));
|
|
||||||
} else {
|
|
||||||
// 默认查询当天
|
|
||||||
days.add(thisTime);
|
|
||||||
}
|
|
||||||
|
|
||||||
censusSummaryParam.setPkCountry(SecurityUtils.getPkCountry());
|
|
||||||
List<CensusSummaryVo> resultList = iCuMemberService.selectCensusSummary(censusSummaryParam, days);
|
|
||||||
|
|
||||||
ExcelUtil<CensusSummaryVo> util = new ExcelUtil<>(CensusSummaryVo.class, iMenuColumnServiceApi.queryMenuColumn("performanceTotal", SecurityUtils.getUserId()).getData());
|
|
||||||
util.exportExcel(response, resultList, "业绩汇总信息");
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,55 +0,0 @@
|
||||||
package com.hzs.member.census.param;
|
|
||||||
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
import java.util.Date;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
@Data
|
|
||||||
public class CensusSummaryParam {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 结算期数
|
|
||||||
*/
|
|
||||||
private Long memberSettlePeriodId;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 币种展示
|
|
||||||
*/
|
|
||||||
private Long pkCurrency;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 所属国家
|
|
||||||
*/
|
|
||||||
private Integer pkCountry;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 开始时间
|
|
||||||
*/
|
|
||||||
private Date startDate;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 结束时间
|
|
||||||
*/
|
|
||||||
private Date endDate;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询时间
|
|
||||||
*/
|
|
||||||
private String time;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 体系
|
|
||||||
*/
|
|
||||||
private List<Long> pkVertex;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 团队
|
|
||||||
*/
|
|
||||||
private List<Long> pkMemberTeam;
|
|
||||||
/**
|
|
||||||
* 体系
|
|
||||||
*/
|
|
||||||
private String pkBdVertexStr;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,82 +0,0 @@
|
||||||
package com.hzs.member.census.vo;
|
|
||||||
|
|
||||||
import com.hzs.common.core.annotation.Excel;
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
import java.math.BigDecimal;
|
|
||||||
|
|
||||||
@Data
|
|
||||||
public class CensusSummaryVo {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 结算期数
|
|
||||||
*/
|
|
||||||
private Integer numberPeriods;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 结算时间
|
|
||||||
*/
|
|
||||||
@Excel(name = "结算时间")
|
|
||||||
private String settleDate;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 注册金额
|
|
||||||
*/
|
|
||||||
@Excel(name = "注册金额")
|
|
||||||
private BigDecimal registerAmount;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 注册业绩
|
|
||||||
*/
|
|
||||||
@Excel(name = "注册业绩")
|
|
||||||
private BigDecimal registerPv;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 升级金额
|
|
||||||
*/
|
|
||||||
@Excel(name = "升级金额")
|
|
||||||
private BigDecimal upgradeAmount;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 升级业绩
|
|
||||||
*/
|
|
||||||
@Excel(name = "升级业绩")
|
|
||||||
private BigDecimal upgradePv;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 首购金额
|
|
||||||
*/
|
|
||||||
@Excel(name = "首购金额")
|
|
||||||
private BigDecimal firstPurchaseAmount;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 首购业绩
|
|
||||||
*/
|
|
||||||
@Excel(name = "首购业绩")
|
|
||||||
private BigDecimal firstPurchasePv;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 复购金额
|
|
||||||
*/
|
|
||||||
@Excel(name = "复购金额")
|
|
||||||
private BigDecimal repurchaseAmount;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 复购pv
|
|
||||||
*/
|
|
||||||
@Excel(name = "复购业绩")
|
|
||||||
private BigDecimal repurchasePv;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 金额总计
|
|
||||||
*/
|
|
||||||
@Excel(name = "金额总计")
|
|
||||||
private BigDecimal amountTotal;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 业绩汇总
|
|
||||||
*/
|
|
||||||
@Excel(name = "业绩汇总")
|
|
||||||
private BigDecimal pvTotal;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -2429,27 +2429,4 @@
|
||||||
and bg.GRADE_VALUE = #{gradeValue}
|
and bg.GRADE_VALUE = #{gradeValue}
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
<select id="queryDateBySummary" resultType="com.hzs.member.base.vo.MemberMeritsSummaryVo">
|
|
||||||
select sa.order_type orderType,
|
|
||||||
sum(sa.order_amount - nvl(sa.consume_amount, 0)) amount,
|
|
||||||
sum(sa.order_achieve) achieve
|
|
||||||
from sa_order sa
|
|
||||||
inner join cu_member cm
|
|
||||||
on sa.pk_member = cm.pk_id
|
|
||||||
and cm.del_flag = 0
|
|
||||||
and cm.category = 0
|
|
||||||
where sa.order_status = 1
|
|
||||||
and sa.del_flag = 0
|
|
||||||
and to_char(sa.pay_time, 'yyyy-mm-dd') = #{time}
|
|
||||||
and sa.pk_country = #{pkCountry}
|
|
||||||
<if test="pkVertex != null and pkVertex.size > 0 ">
|
|
||||||
and cm.pk_vertex in
|
|
||||||
<foreach collection="pkVertex" item="item" open="(" close=")" separator=",">
|
|
||||||
#{item}
|
|
||||||
</foreach>
|
|
||||||
</if>
|
|
||||||
group by sa.order_type
|
|
||||||
</select>
|
|
||||||
|
|
||||||
|
|
||||||
</mapper>
|
</mapper>
|
||||||
|
|
|
||||||
|
|
@ -1,139 +0,0 @@
|
||||||
package com.hzs.system.board.controller;
|
|
||||||
|
|
||||||
import cn.hutool.core.collection.CollectionUtil;
|
|
||||||
import com.hzs.common.core.utils.BigDecimalUtil;
|
|
||||||
import com.hzs.common.core.web.controller.BaseController;
|
|
||||||
import com.hzs.common.core.web.domain.AjaxResult;
|
|
||||||
import com.hzs.system.board.service.IBoardService;
|
|
||||||
import com.hzs.system.board.vo.*;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.web.bind.annotation.GetMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RequestMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RestController;
|
|
||||||
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 首页看板 控制器
|
|
||||||
*/
|
|
||||||
@RestController
|
|
||||||
@RequestMapping("/manage/board")
|
|
||||||
public class BoardController extends BaseController {
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private IBoardService iBoardService;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 会员汇总数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
@GetMapping("/member-summary")
|
|
||||||
public AjaxResult memberSummary() {
|
|
||||||
// 会员汇总数据
|
|
||||||
BoardMemberVO boardMemberVO = iBoardService.getMemberBoard();
|
|
||||||
boardMemberVO.setMemberTodayLevelList(new ArrayList<>(6));
|
|
||||||
boardMemberVO.setMemberYesterdayLevelList(new ArrayList<>(6));
|
|
||||||
boardMemberVO.setMemberMonthLevelList(new ArrayList<>(6));
|
|
||||||
|
|
||||||
// 会员各等级数据
|
|
||||||
List<BoardMemberLevelVO> levelList = iBoardService.listMemberLevelBoard();
|
|
||||||
|
|
||||||
for (BoardMemberLevelVO boardMemberLevelVO : levelList) {
|
|
||||||
if (boardMemberLevelVO.getSort() == 0) {
|
|
||||||
// 今日
|
|
||||||
boardMemberVO.getMemberTodayLevelList().add(boardMemberLevelVO);
|
|
||||||
} else if (boardMemberLevelVO.getSort() == 1) {
|
|
||||||
// 昨日
|
|
||||||
boardMemberVO.getMemberYesterdayLevelList().add(boardMemberLevelVO);
|
|
||||||
} else {
|
|
||||||
// 本月
|
|
||||||
boardMemberVO.getMemberMonthLevelList().add(boardMemberLevelVO);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return AjaxResult.success(boardMemberVO);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 日业绩数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
@GetMapping("/day-achieve")
|
|
||||||
public AjaxResult dayAchieve() {
|
|
||||||
// 返回数据VO
|
|
||||||
BoardDayAchieveVO resultVO = new BoardDayAchieveVO();
|
|
||||||
|
|
||||||
List<BoardAchieveVO> dayAchieveList = iBoardService.getDayAchieve();
|
|
||||||
if (CollectionUtil.isNotEmpty(dayAchieveList)) {
|
|
||||||
for (BoardAchieveVO boardAchieveVO : dayAchieveList) {
|
|
||||||
if (boardAchieveVO.getSort() == 0) {
|
|
||||||
resultVO.setToday(BoardAchieveVO.builder()
|
|
||||||
.firstAchieve(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getFirstAchieve()))
|
|
||||||
.firstAmount(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getFirstAmount()))
|
|
||||||
.repAchieve(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getRepAchieve()))
|
|
||||||
.repAmount(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getRepAmount()))
|
|
||||||
.build());
|
|
||||||
} else {
|
|
||||||
resultVO.setYesterday(BoardAchieveVO.builder()
|
|
||||||
.firstAchieve(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getFirstAchieve()))
|
|
||||||
.firstAmount(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getFirstAmount()))
|
|
||||||
.repAchieve(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getRepAchieve()))
|
|
||||||
.repAmount(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getRepAmount()))
|
|
||||||
.build());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return AjaxResult.success(resultVO);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 月业绩数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
@GetMapping("/month-achieve")
|
|
||||||
public AjaxResult monthAchieve() {
|
|
||||||
BoardAchieveVO boardAchieveVO = iBoardService.getMonthAchieve();
|
|
||||||
boardAchieveVO.setFirstAchieve(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getFirstAchieve()));
|
|
||||||
boardAchieveVO.setFirstAmount(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getFirstAmount()));
|
|
||||||
boardAchieveVO.setRepAchieve(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getRepAchieve()));
|
|
||||||
boardAchieveVO.setRepAmount(BigDecimalUtil.handleBig10000Down(boardAchieveVO.getRepAmount()));
|
|
||||||
return AjaxResult.success(boardAchieveVO);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 充值汇总数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
@GetMapping("/recharge-summary")
|
|
||||||
public AjaxResult rechargeSummary() {
|
|
||||||
BoardRechargeVO boardRechargeVO = new BoardRechargeVO();
|
|
||||||
boardRechargeVO.setRechargeTodayList(new ArrayList<>(6));
|
|
||||||
boardRechargeVO.setRechargeYesterdayLevelList(new ArrayList<>(6));
|
|
||||||
boardRechargeVO.setRechargeMonthLevelList(new ArrayList<>(6));
|
|
||||||
|
|
||||||
// 会员汇总数据
|
|
||||||
List<BoardRechargeAccountVO> rechargeList = iBoardService.listAccountRechargeBoard();
|
|
||||||
|
|
||||||
for (BoardRechargeAccountVO boardMemberVO : rechargeList) {
|
|
||||||
// 充值金额按万处理
|
|
||||||
boardMemberVO.setRechargeAmount(BigDecimalUtil.handleBig10000Down(boardMemberVO.getRechargeAmount()));
|
|
||||||
if (boardMemberVO.getSort() == 0) {
|
|
||||||
// 今日
|
|
||||||
boardRechargeVO.getRechargeTodayList().add(boardMemberVO);
|
|
||||||
} else if (boardMemberVO.getSort() == 1) {
|
|
||||||
// 昨日
|
|
||||||
boardRechargeVO.getRechargeYesterdayLevelList().add(boardMemberVO);
|
|
||||||
} else {
|
|
||||||
// 本月
|
|
||||||
boardRechargeVO.getRechargeMonthLevelList().add(boardMemberVO);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return AjaxResult.success(boardRechargeVO);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,50 +0,0 @@
|
||||||
package com.hzs.system.board.mapper;
|
|
||||||
|
|
||||||
import com.hzs.system.board.vo.BoardAchieveVO;
|
|
||||||
import com.hzs.system.board.vo.BoardMemberLevelVO;
|
|
||||||
import com.hzs.system.board.vo.BoardMemberVO;
|
|
||||||
import com.hzs.system.board.vo.BoardRechargeAccountVO;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 首页看板 mapper
|
|
||||||
*/
|
|
||||||
public interface BoardMapper {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询会员汇总数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
BoardMemberVO getMemberBoard();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询会员等级数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
List<BoardMemberLevelVO> listMemberLevelBoard();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询日业绩汇总数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
List<BoardAchieveVO> getDayAchieve();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询月业绩汇总数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
BoardAchieveVO getMonthAchieve();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 各币种充值数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
List<BoardRechargeAccountVO> listAccountRechargeBoard();
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,50 +0,0 @@
|
||||||
package com.hzs.system.board.service;
|
|
||||||
|
|
||||||
import com.hzs.system.board.vo.BoardAchieveVO;
|
|
||||||
import com.hzs.system.board.vo.BoardMemberLevelVO;
|
|
||||||
import com.hzs.system.board.vo.BoardMemberVO;
|
|
||||||
import com.hzs.system.board.vo.BoardRechargeAccountVO;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 首页看板 service
|
|
||||||
*/
|
|
||||||
public interface IBoardService {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询会员汇总数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
BoardMemberVO getMemberBoard();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询会员等级数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
List<BoardMemberLevelVO> listMemberLevelBoard();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询日业绩汇总数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
List<BoardAchieveVO> getDayAchieve();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询月业绩汇总数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
BoardAchieveVO getMonthAchieve();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 各币种充值数据
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
List<BoardRechargeAccountVO> listAccountRechargeBoard();
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,48 +0,0 @@
|
||||||
package com.hzs.system.board.service.impl;
|
|
||||||
|
|
||||||
import com.hzs.system.board.mapper.BoardMapper;
|
|
||||||
import com.hzs.system.board.service.IBoardService;
|
|
||||||
import com.hzs.system.board.vo.BoardAchieveVO;
|
|
||||||
import com.hzs.system.board.vo.BoardMemberLevelVO;
|
|
||||||
import com.hzs.system.board.vo.BoardMemberVO;
|
|
||||||
import com.hzs.system.board.vo.BoardRechargeAccountVO;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
|
|
||||||
import javax.annotation.Resource;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 首页看板 service
|
|
||||||
*/
|
|
||||||
@Service
|
|
||||||
public class BoardServiceImpl implements IBoardService {
|
|
||||||
|
|
||||||
@Resource
|
|
||||||
private BoardMapper boardMapper;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public BoardMemberVO getMemberBoard() {
|
|
||||||
return boardMapper.getMemberBoard();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public List<BoardMemberLevelVO> listMemberLevelBoard() {
|
|
||||||
return boardMapper.listMemberLevelBoard();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public List<BoardAchieveVO> getDayAchieve() {
|
|
||||||
return boardMapper.getDayAchieve();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public BoardAchieveVO getMonthAchieve() {
|
|
||||||
return boardMapper.getMonthAchieve();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public List<BoardRechargeAccountVO> listAccountRechargeBoard() {
|
|
||||||
return boardMapper.listAccountRechargeBoard();
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,50 +0,0 @@
|
||||||
package com.hzs.system.board.vo;
|
|
||||||
|
|
||||||
import com.hzs.common.core.annotation.BigDecimalFormat;
|
|
||||||
import lombok.AllArgsConstructor;
|
|
||||||
import lombok.Builder;
|
|
||||||
import lombok.Data;
|
|
||||||
import lombok.NoArgsConstructor;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
import java.math.BigDecimal;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 看板业绩汇总数据
|
|
||||||
*/
|
|
||||||
@Builder
|
|
||||||
@AllArgsConstructor
|
|
||||||
@NoArgsConstructor
|
|
||||||
@Data
|
|
||||||
public class BoardAchieveVO implements Serializable {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 首购业绩
|
|
||||||
*/
|
|
||||||
@BigDecimalFormat
|
|
||||||
private BigDecimal firstAchieve;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 首购金额
|
|
||||||
*/
|
|
||||||
@BigDecimalFormat
|
|
||||||
private BigDecimal firstAmount;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 复购业绩
|
|
||||||
*/
|
|
||||||
@BigDecimalFormat
|
|
||||||
private BigDecimal repAchieve;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 复购金额
|
|
||||||
*/
|
|
||||||
@BigDecimalFormat
|
|
||||||
private BigDecimal repAmount;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 序号
|
|
||||||
*/
|
|
||||||
private Integer sort;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,23 +0,0 @@
|
||||||
package com.hzs.system.board.vo;
|
|
||||||
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 看板业绩汇总数据返回
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
public class BoardDayAchieveVO implements Serializable {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 今日
|
|
||||||
*/
|
|
||||||
private BoardAchieveVO today;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 昨日
|
|
||||||
*/
|
|
||||||
private BoardAchieveVO yesterday;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,28 +0,0 @@
|
||||||
package com.hzs.system.board.vo;
|
|
||||||
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 看板会员等级数据
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
public class BoardMemberLevelVO implements Serializable {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 等级名称
|
|
||||||
*/
|
|
||||||
private String gradeName;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 会员数量
|
|
||||||
*/
|
|
||||||
private Integer memberTotal;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 0=今日,1=昨日,2=当月
|
|
||||||
*/
|
|
||||||
private Integer sort;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,46 +0,0 @@
|
||||||
package com.hzs.system.board.vo;
|
|
||||||
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 看板会员汇总数据
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
public class BoardMemberVO implements Serializable {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 会员总数
|
|
||||||
*/
|
|
||||||
private Integer memberTotal;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 今日新増会员
|
|
||||||
*/
|
|
||||||
private Integer memberToday;
|
|
||||||
/**
|
|
||||||
* 今日会员等级
|
|
||||||
*/
|
|
||||||
private List<BoardMemberLevelVO> memberTodayLevelList;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 昨日新増会员
|
|
||||||
*/
|
|
||||||
private Integer memberYesterday;
|
|
||||||
/**
|
|
||||||
* 昨日会员等级
|
|
||||||
*/
|
|
||||||
private List<BoardMemberLevelVO> memberYesterdayLevelList;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 本月新増会员
|
|
||||||
*/
|
|
||||||
private Integer memberMonth;
|
|
||||||
/**
|
|
||||||
* 本月会员等级
|
|
||||||
*/
|
|
||||||
private List<BoardMemberLevelVO> memberMonthLevelList;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,31 +0,0 @@
|
||||||
package com.hzs.system.board.vo;
|
|
||||||
|
|
||||||
import com.hzs.common.core.annotation.BigDecimalFormat;
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
import java.math.BigDecimal;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 看板各币种充值数据
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
public class BoardRechargeAccountVO implements Serializable {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 账户名称
|
|
||||||
*/
|
|
||||||
private String accountName;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 充值金额
|
|
||||||
*/
|
|
||||||
@BigDecimalFormat
|
|
||||||
private BigDecimal rechargeAmount;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 0=今日,1=昨日,2=当月
|
|
||||||
*/
|
|
||||||
private Integer sort;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,30 +0,0 @@
|
||||||
package com.hzs.system.board.vo;
|
|
||||||
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 看板充值数据
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
public class BoardRechargeVO implements Serializable {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 今日充值
|
|
||||||
*/
|
|
||||||
private List<BoardRechargeAccountVO> rechargeTodayList;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 昨日充值
|
|
||||||
*/
|
|
||||||
private List<BoardRechargeAccountVO> rechargeYesterdayLevelList;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 本月充值
|
|
||||||
*/
|
|
||||||
private List<BoardRechargeAccountVO> rechargeMonthLevelList;
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,244 +0,0 @@
|
||||||
<?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.hzs.system.board.mapper.BoardMapper">
|
|
||||||
|
|
||||||
<!-- 查询会员汇总数据 -->
|
|
||||||
<select id="getMemberBoard" resultType="com.hzs.system.board.vo.BoardMemberVO">
|
|
||||||
select *
|
|
||||||
from (select count(1) member_total
|
|
||||||
from cu_member cm
|
|
||||||
where cm.del_flag = 0
|
|
||||||
and cm.pay_status = 1
|
|
||||||
and cm.category = 0
|
|
||||||
and cm.customer_type != 1) a
|
|
||||||
left join (
|
|
||||||
select count(1) member_today
|
|
||||||
from cu_member cm
|
|
||||||
where cm.del_flag = 0
|
|
||||||
and cm.pay_status = 1
|
|
||||||
and cm.category = 0
|
|
||||||
and to_char(cm.pay_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate, 'yyyy-mm-dd')
|
|
||||||
and cm.customer_type != 1
|
|
||||||
) b on 1 = 1
|
|
||||||
left join (select count(1) member_yesterday
|
|
||||||
from cu_member cm
|
|
||||||
where cm.del_flag = 0
|
|
||||||
and cm.pay_status = 1
|
|
||||||
and cm.category = 0
|
|
||||||
and to_char(cm.pay_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate - 1, 'yyyy-mm-dd')
|
|
||||||
and cm.customer_type != 1
|
|
||||||
) c
|
|
||||||
on 1 = 1
|
|
||||||
left join (select count(1) member_month
|
|
||||||
from cu_member cm
|
|
||||||
where cm.del_flag = 0
|
|
||||||
and cm.pay_status = 1
|
|
||||||
and cm.category = 0
|
|
||||||
and to_char(cm.pay_time, 'yyyy-mm') =
|
|
||||||
to_char(sysdate, 'yyyy-mm')
|
|
||||||
and cm.customer_type != 1
|
|
||||||
) d on 1 = 1
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<!-- 会员各等级数据 -->
|
|
||||||
<select id="listMemberLevelBoard" resultType="com.hzs.system.board.vo.BoardMemberLevelVO">
|
|
||||||
select bg.grade_name,
|
|
||||||
bg.grade_value,
|
|
||||||
nvl(a.member_total, 0) member_total,
|
|
||||||
0 sort
|
|
||||||
from (select cm.PK_REGISTER_GRADE, count(1) member_total
|
|
||||||
from cu_member cm
|
|
||||||
where cm.del_flag = 0
|
|
||||||
and cm.pay_status = 1
|
|
||||||
and cm.category = 0
|
|
||||||
and to_char(cm.pay_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate, 'yyyy-mm-dd')
|
|
||||||
and cm.customer_type != 1
|
|
||||||
group by cm.PK_REGISTER_GRADE
|
|
||||||
order by cm.PK_REGISTER_GRADE) a
|
|
||||||
right join bd_grade bg
|
|
||||||
on bg.pk_id = a.PK_REGISTER_GRADE
|
|
||||||
where bg.del_flag = 0
|
|
||||||
union all
|
|
||||||
select bg.grade_name,
|
|
||||||
bg.grade_value,
|
|
||||||
nvl(a.member_total, 0) member_total,
|
|
||||||
1 sort
|
|
||||||
from (select cm.PK_REGISTER_GRADE, count(1) member_total
|
|
||||||
from cu_member cm
|
|
||||||
where cm.del_flag = 0
|
|
||||||
and cm.pay_status = 1
|
|
||||||
and cm.category = 0
|
|
||||||
and to_char(cm.pay_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate - 1, 'yyyy-mm-dd')
|
|
||||||
and cm.customer_type != 1
|
|
||||||
group by cm.PK_REGISTER_GRADE
|
|
||||||
order by cm.PK_REGISTER_GRADE) a
|
|
||||||
right join bd_grade bg
|
|
||||||
on bg.pk_id = a.PK_REGISTER_GRADE
|
|
||||||
where bg.del_flag = 0
|
|
||||||
union all
|
|
||||||
select bg.grade_name,
|
|
||||||
bg.grade_value,
|
|
||||||
nvl(a.member_total, 0) member_total,
|
|
||||||
2 sort
|
|
||||||
from (select cm.PK_REGISTER_GRADE, count(1) member_total
|
|
||||||
from cu_member cm
|
|
||||||
where cm.del_flag = 0
|
|
||||||
and cm.pay_status = 1
|
|
||||||
and cm.category = 0
|
|
||||||
and to_char(cm.pay_time, 'yyyy-mm') = to_char(sysdate, 'yyyy-mm')
|
|
||||||
and cm.customer_type != 1
|
|
||||||
group by cm.PK_REGISTER_GRADE
|
|
||||||
order by cm.PK_REGISTER_GRADE) a
|
|
||||||
right join bd_grade bg
|
|
||||||
on bg.pk_id = a.PK_REGISTER_GRADE
|
|
||||||
where bg.del_flag = 0
|
|
||||||
order by sort, grade_value
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<!-- 查询日业绩汇总数据 -->
|
|
||||||
<select id="getDayAchieve" resultType="com.hzs.system.board.vo.BoardAchieveVO">
|
|
||||||
select a.*, b.*, 0 sort
|
|
||||||
from (
|
|
||||||
select nvl(sum(so.order_achieve), 0) first_achieve,
|
|
||||||
nvl(sum(so.order_amount), 0) first_amount
|
|
||||||
from sa_order so
|
|
||||||
where so.del_flag = 0
|
|
||||||
and so.order_status = 1
|
|
||||||
and so.order_type in (1, 2, 24, 25)
|
|
||||||
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate, 'yyyy-mm-dd')
|
|
||||||
) a
|
|
||||||
left join (
|
|
||||||
select nvl(sum(so.order_achieve), 0) rep_achieve,
|
|
||||||
nvl(sum(so.order_amount), 0) rep_amount
|
|
||||||
from sa_order so
|
|
||||||
where so.del_flag = 0
|
|
||||||
and so.order_status = 1
|
|
||||||
and so.order_type in (3, 26, 10)
|
|
||||||
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate, 'yyyy-mm-dd')
|
|
||||||
) b on 1 = 1
|
|
||||||
union all
|
|
||||||
select a.*, b.*, 1 sort
|
|
||||||
from (
|
|
||||||
select nvl(sum(so.order_achieve), 0) first_achieve,
|
|
||||||
nvl(sum(so.order_amount), 0) first_amount
|
|
||||||
from sa_order so
|
|
||||||
where so.del_flag = 0
|
|
||||||
and so.order_status = 1
|
|
||||||
and so.order_type in (1, 2, 24, 25)
|
|
||||||
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate - 1, 'yyyy-mm-dd')
|
|
||||||
) a
|
|
||||||
left join (
|
|
||||||
select nvl(sum(so.order_achieve), 0) rep_achieve,
|
|
||||||
nvl(sum(so.order_amount), 0) rep_amount
|
|
||||||
from sa_order so
|
|
||||||
where so.del_flag = 0
|
|
||||||
and so.order_status = 1
|
|
||||||
and so.order_type in (3, 26, 10)
|
|
||||||
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate - 1, 'yyyy-mm-dd')
|
|
||||||
) b on 1 = 1
|
|
||||||
order by sort
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<!-- 查询月业绩汇总数据 -->
|
|
||||||
<select id="getMonthAchieve" resultType="com.hzs.system.board.vo.BoardAchieveVO">
|
|
||||||
select a.*, b.*
|
|
||||||
from (select nvl(sum(so.order_achieve), 0) first_achieve,
|
|
||||||
nvl(sum(so.order_amount), 0) first_amount
|
|
||||||
from sa_order so
|
|
||||||
where so.del_flag = 0
|
|
||||||
and so.order_status = 1
|
|
||||||
and so.order_type in (1, 2, 24, 25)
|
|
||||||
and to_char(so.pay_time, 'yyyy-mm') = to_char(sysdate, 'yyyy-mm')
|
|
||||||
) a
|
|
||||||
left join (
|
|
||||||
select nvl(sum(so.order_achieve), 0) rep_achieve,
|
|
||||||
nvl(sum(so.order_amount - nvl(so.CONSUME_AMOUNT, 0)), 0) rep_amount
|
|
||||||
from sa_order so
|
|
||||||
where so.del_flag = 0
|
|
||||||
and so.order_status = 1
|
|
||||||
and so.order_type in (3, 26, 10)
|
|
||||||
and to_char(so.pay_time, 'yyyy-mm') =
|
|
||||||
to_char(sysdate, 'yyyy-mm')
|
|
||||||
) b on 1 = 1
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<!-- 各币种充值数据 -->
|
|
||||||
<select id="listAccountRechargeBoard" resultType="com.hzs.system.board.vo.BoardRechargeAccountVO">
|
|
||||||
select ba.account_name, nvl(a.recharge_amount, 0) recharge_amount, 0 sort, ba.field_value
|
|
||||||
from (select t.pk_account, sum(t.recharge_amount) recharge_amount
|
|
||||||
from CU_MEMBER_RECHARGE t
|
|
||||||
where t.del_flag = 0
|
|
||||||
and t.recharge_amount != 0
|
|
||||||
and t.pk_account in
|
|
||||||
(select t.pk_id
|
|
||||||
from bd_account t
|
|
||||||
where t.del_flag = 0
|
|
||||||
and t.enable_state = 0
|
|
||||||
and t.pk_country = 1
|
|
||||||
and t.field_value in (1, 2, 3, 4))
|
|
||||||
and ((t.recharge_source = 1 and t.approve_state = 2) or
|
|
||||||
(t.recharge_source = 0 and t.approve_state = 2))
|
|
||||||
and to_char(t.modified_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate, 'yyyy-mm-dd')
|
|
||||||
group by t.pk_account) a
|
|
||||||
right join bd_account ba
|
|
||||||
on ba.pk_id = a.pk_account
|
|
||||||
and ba.del_flag = 0
|
|
||||||
where ba.field_value in (1, 2, 3, 4)
|
|
||||||
union all
|
|
||||||
select ba.account_name, nvl(a.recharge_amount, 0) recharge_amount, 1 sort, ba.field_value
|
|
||||||
from (select t.pk_account, sum(t.recharge_amount) recharge_amount
|
|
||||||
from CU_MEMBER_RECHARGE t
|
|
||||||
where t.del_flag = 0
|
|
||||||
and t.recharge_amount != 0
|
|
||||||
and t.pk_account in
|
|
||||||
(select t.pk_id
|
|
||||||
from bd_account t
|
|
||||||
where t.del_flag = 0
|
|
||||||
and t.enable_state = 0
|
|
||||||
and t.pk_country = 1
|
|
||||||
and t.field_value in (1, 2, 3, 4))
|
|
||||||
and ((t.recharge_source = 1 and t.approve_state = 2) or
|
|
||||||
(t.recharge_source = 0 and t.approve_state = 2))
|
|
||||||
and to_char(t.modified_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate - 1, 'yyyy-mm-dd')
|
|
||||||
group by t.pk_account) a
|
|
||||||
right join bd_account ba
|
|
||||||
on ba.pk_id = a.pk_account
|
|
||||||
and ba.del_flag = 0
|
|
||||||
where ba.field_value in (1, 2, 3, 4)
|
|
||||||
union all
|
|
||||||
select ba.account_name, nvl(a.recharge_amount, 0) recharge_amount, 2 sort, ba.field_value
|
|
||||||
from (select t.pk_account, sum(t.recharge_amount) recharge_amount
|
|
||||||
from CU_MEMBER_RECHARGE t
|
|
||||||
where t.del_flag = 0
|
|
||||||
and t.recharge_amount != 0
|
|
||||||
and t.pk_account in
|
|
||||||
(select t.pk_id
|
|
||||||
from bd_account t
|
|
||||||
where t.del_flag = 0
|
|
||||||
and t.enable_state = 0
|
|
||||||
and t.pk_country = 1
|
|
||||||
and t.field_value in (1, 2, 3, 4))
|
|
||||||
and ((t.recharge_source = 1 and t.approve_state = 2) or
|
|
||||||
(t.recharge_source = 0 and t.approve_state = 2))
|
|
||||||
and to_char(t.modified_time, 'yyyy-mm') =
|
|
||||||
to_char(sysdate - 1, 'yyyy-mm')
|
|
||||||
group by t.pk_account) a
|
|
||||||
right join bd_account ba
|
|
||||||
on ba.pk_id = a.pk_account
|
|
||||||
and ba.del_flag = 0
|
|
||||||
where ba.field_value in (1, 2, 3, 4)
|
|
||||||
order by sort, field_value
|
|
||||||
</select>
|
|
||||||
|
|
||||||
</mapper>
|
|
||||||
|
|
@ -1,7 +1,5 @@
|
||||||
package com.hzs.common.core.constant;
|
package com.hzs.common.core.constant;
|
||||||
|
|
||||||
import java.math.BigDecimal;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 魔法数字常量类
|
* 魔法数字常量类
|
||||||
*/
|
*/
|
||||||
|
|
@ -85,9 +83,5 @@ public class MagicNumberConstants {
|
||||||
* 提现的倍数
|
* 提现的倍数
|
||||||
*/
|
*/
|
||||||
public static final Integer WITHDRAW_MULTIPLE = 100;
|
public static final Integer WITHDRAW_MULTIPLE = 100;
|
||||||
/**
|
|
||||||
* 转换万处理
|
|
||||||
*/
|
|
||||||
public static final BigDecimal big10000 = new BigDecimal("10000");
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -14,7 +14,11 @@ import java.util.HashMap;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* sui q
|
* @author: sui q
|
||||||
|
* @time: 2021/11/23 11:02
|
||||||
|
* @description: 条形码+文字 生成
|
||||||
|
* @classname: BarCodeUtils
|
||||||
|
* @package_name: com.hzs.web.util
|
||||||
*/
|
*/
|
||||||
@Slf4j
|
@Slf4j
|
||||||
public class BarCodeUtils {
|
public class BarCodeUtils {
|
||||||
|
|
|
||||||
|
|
@ -1,20 +0,0 @@
|
||||||
package com.hzs.common.core.utils;
|
|
||||||
|
|
||||||
import com.hzs.common.core.constant.MagicNumberConstants;
|
|
||||||
|
|
||||||
import java.math.BigDecimal;
|
|
||||||
import java.math.RoundingMode;
|
|
||||||
|
|
||||||
public class BigDecimalUtil {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 除万取2位小数并且去尾
|
|
||||||
*
|
|
||||||
* @param bigDecimal
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static BigDecimal handleBig10000Down(BigDecimal bigDecimal) {
|
|
||||||
return bigDecimal.divide(MagicNumberConstants.big10000, 2, RoundingMode.DOWN);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -0,0 +1,59 @@
|
||||||
|
package com.hzs.common.core.utils;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @Description: 自动生成密码 暂时先不使用
|
||||||
|
* @Author: sui q
|
||||||
|
* @Time: 2022/9/9 14:52
|
||||||
|
* @Classname: CreatePassword
|
||||||
|
* @PackageName: com.hzs.common.core.utils
|
||||||
|
*/
|
||||||
|
public class CreatePassword {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @Description: 生成密码
|
||||||
|
* @param len 密码长度
|
||||||
|
* @return: String
|
||||||
|
* @Author: sui q
|
||||||
|
* @Date: 2022/9/9 14:53
|
||||||
|
*/
|
||||||
|
public static String generatePassword(int len) {
|
||||||
|
// 1、定义基本字符串baseStr和出参password
|
||||||
|
StringBuilder password = null;
|
||||||
|
String baseStr = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ~!@#$%^&*()_+{}|<>?";
|
||||||
|
boolean flag = false;
|
||||||
|
// 2、使用循环来判断是否是正确的密码
|
||||||
|
while (!flag) {
|
||||||
|
// 密码重置
|
||||||
|
password = new StringBuilder();
|
||||||
|
// 个数计数
|
||||||
|
int a = 0, b = 0, c = 0, d = 0;
|
||||||
|
for (int i = 0; i < len; i++) {
|
||||||
|
int rand = (int) (Math.random() * baseStr.length());
|
||||||
|
password.append(baseStr.charAt(rand));
|
||||||
|
if (rand < 10) {
|
||||||
|
a++;
|
||||||
|
}
|
||||||
|
if (10 <= rand && rand < 36) {
|
||||||
|
b++;
|
||||||
|
}
|
||||||
|
if (36 <= rand && rand < 62) {
|
||||||
|
c++;
|
||||||
|
}
|
||||||
|
if (62 <= rand) {
|
||||||
|
d++;
|
||||||
|
}
|
||||||
|
if (a * b * c * d != 0) {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// 是否是正确的密码(4类中仅一类为0,其他不为0)
|
||||||
|
flag = (a * b * c != 0 && d == 0) || (a * b * d != 0 && c == 0) || (a * c * d != 0 && b == 0)
|
||||||
|
|| (b * c * d != 0 && a == 0);
|
||||||
|
}
|
||||||
|
return password.toString();
|
||||||
|
}
|
||||||
|
|
||||||
|
public static void main(String[] args) {
|
||||||
|
System.out.println(generatePassword(6));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -8,10 +8,8 @@ import java.time.*;
|
||||||
import java.time.format.DateTimeFormatter;
|
import java.time.format.DateTimeFormatter;
|
||||||
import java.time.temporal.ChronoUnit;
|
import java.time.temporal.ChronoUnit;
|
||||||
import java.time.temporal.TemporalAdjusters;
|
import java.time.temporal.TemporalAdjusters;
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Calendar;
|
import java.util.Calendar;
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 时间工具类
|
* 时间工具类
|
||||||
|
|
@ -885,37 +883,4 @@ public class DateUtils extends org.apache.commons.lang3.time.DateUtils {
|
||||||
return before7days.getTime() < addtime.getTime();
|
return before7days.getTime() < addtime.getTime();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取两个时间内的每一天
|
|
||||||
*
|
|
||||||
* @param startTime
|
|
||||||
* @param endTime
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public static List<String> findDaysStr(String startTime, String endTime) {
|
|
||||||
SimpleDateFormat sdf = new SimpleDateFormat(DateUtils.YYYY_MM_DD);
|
|
||||||
Date dBegin = null;
|
|
||||||
Date dEnd = null;
|
|
||||||
try {
|
|
||||||
dBegin = sdf.parse(startTime);
|
|
||||||
dEnd = sdf.parse(endTime);
|
|
||||||
} catch (ParseException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
List<String> daysStrList = new ArrayList<>();
|
|
||||||
daysStrList.add(sdf.format(dBegin));
|
|
||||||
Calendar calBegin = Calendar.getInstance();
|
|
||||||
calBegin.setTime(dBegin);
|
|
||||||
Calendar calEnd = Calendar.getInstance();
|
|
||||||
calEnd.setTime(dEnd);
|
|
||||||
|
|
||||||
while (dEnd.after(calBegin.getTime())) {
|
|
||||||
calBegin.add(Calendar.DAY_OF_MONTH, 1);
|
|
||||||
String dayStr = sdf.format(calBegin.getTime());
|
|
||||||
daysStrList.add(dayStr);
|
|
||||||
}
|
|
||||||
return daysStrList;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -1,12 +1,25 @@
|
||||||
package com.hzs.common.core.utils;
|
package com.hzs.common.core.utils;/**
|
||||||
|
* @Description:
|
||||||
|
* @Author: yuhui
|
||||||
|
* @Time: 2023/6/6 9:55
|
||||||
|
* @Classname: DeduplicationUtil
|
||||||
|
* @PackageName: com.hzs.common.core.utils
|
||||||
|
*/
|
||||||
|
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
import java.util.function.Function;
|
import java.util.function.Function;
|
||||||
import java.util.function.Predicate;
|
import java.util.function.Predicate;
|
||||||
|
|
||||||
|
/**
|
||||||
|
*@BelongsProject: hzs_cloud
|
||||||
|
*@BelongsPackage: com.hzs.common.core.utils
|
||||||
|
*@Author: yh
|
||||||
|
*@CreateTime: 2023-06-06 09:55
|
||||||
|
*@Description: TODO
|
||||||
|
*@Version: 1.0
|
||||||
|
*/
|
||||||
public class DeduplicationUtil {
|
public class DeduplicationUtil {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 自定义函数去重(采用 Predicate函数式判断,采用 Function获取比较key)
|
* 自定义函数去重(采用 Predicate函数式判断,采用 Function获取比较key)
|
||||||
* 内部维护一个 ConcurrentHashMap,并采用 putIfAbsent特性实现
|
* 内部维护一个 ConcurrentHashMap,并采用 putIfAbsent特性实现
|
||||||
|
|
@ -16,7 +29,7 @@ public class DeduplicationUtil {
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
public static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {
|
public static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {
|
||||||
Map<Object, Boolean> seen = new ConcurrentHashMap<>();
|
Map<Object,Boolean> seen = new ConcurrentHashMap<>();
|
||||||
return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;
|
return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -28,7 +41,7 @@ public class DeduplicationUtil {
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
public static <T> Predicate<T> distinctNotByKey(Function<? super T, ?> keyExtractor) {
|
public static <T> Predicate<T> distinctNotByKey(Function<? super T, ?> keyExtractor) {
|
||||||
Map<Object, Boolean> seen = new ConcurrentHashMap<>();
|
Map<Object,Boolean> seen = new ConcurrentHashMap<>();
|
||||||
return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) != null;
|
return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) != null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,14 +1,27 @@
|
||||||
package com.hzs.common.core.utils;
|
package com.hzs.common.core.utils;/**
|
||||||
|
* @Description:
|
||||||
|
* @Author: yuhui
|
||||||
|
* @Time: 2023/3/10 15:56
|
||||||
|
* @Classname: distinctByKeyUtil
|
||||||
|
* @PackageName: com.hzs.common.core.utils
|
||||||
|
*/
|
||||||
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
import java.util.function.Function;
|
import java.util.function.Function;
|
||||||
import java.util.function.Predicate;
|
import java.util.function.Predicate;
|
||||||
|
|
||||||
|
/**
|
||||||
|
*@BelongsProject: hzs_cloud
|
||||||
|
*@BelongsPackage: com.hzs.common.core.utils
|
||||||
|
*@Author: yh
|
||||||
|
*@CreateTime: 2023-03-10 15:56
|
||||||
|
*@Description: TODO
|
||||||
|
*@Version: 1.0
|
||||||
|
*/
|
||||||
public class DistinctByKeyUtil {
|
public class DistinctByKeyUtil {
|
||||||
/**
|
/**
|
||||||
* 对象根据某一值去重
|
* 对象根据某一值去重
|
||||||
*
|
|
||||||
* @param keyExtractor
|
* @param keyExtractor
|
||||||
* @param <T>
|
* @param <T>
|
||||||
* @return
|
* @return
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,29 @@
|
||||||
|
package com.hzs.common.core.utils;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
import com.hzs.common.core.utils.sign.Base64Util;
|
||||||
|
import org.springframework.util.Base64Utils;
|
||||||
|
|
||||||
|
import java.nio.charset.StandardCharsets;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @Description:
|
||||||
|
* @Author: ljc
|
||||||
|
* @Time: 2024/8/20 9:38
|
||||||
|
* @Classname: NacosSecretUtil
|
||||||
|
* @Package_name: com.hzs
|
||||||
|
*/
|
||||||
|
public class NacosSecretUtil {
|
||||||
|
|
||||||
|
public static void main(String[] args) {
|
||||||
|
// 自定义生成JWT令牌的密钥
|
||||||
|
String nacosSecret = "smYhZs_20240820_UNkSTzy_formY_toKen";
|
||||||
|
// 输出密钥长度,要求不得低于32字符,否则无法启动节点。
|
||||||
|
System.out.println("密钥长度》》》" + nacosSecret.length());
|
||||||
|
// 密钥进行Base64编码
|
||||||
|
byte[] data = nacosSecret.getBytes(StandardCharsets.UTF_8);
|
||||||
|
System.out.println("密钥Base64编码》》》" + Base64Utils.encodeToString(data));
|
||||||
|
System.out.println("密钥Base64编码》》》" + Base64Util.encode(data));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -2,11 +2,17 @@ package com.hzs.common.core.utils;
|
||||||
|
|
||||||
import java.text.DecimalFormat;
|
import java.text.DecimalFormat;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @Description:
|
||||||
|
* @Author: yuhui
|
||||||
|
* @Time: 2022/12/2 14:12
|
||||||
|
* @Classname: NumberUtil
|
||||||
|
* @PackageName: com.hzs.common.core.utils
|
||||||
|
*/
|
||||||
public class NumberUtil {
|
public class NumberUtil {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取百分比
|
* 获取百分比
|
||||||
*
|
|
||||||
* @param number1 /
|
* @param number1 /
|
||||||
* @param number2 总数/
|
* @param number2 总数/
|
||||||
* @return java.lang.String /
|
* @return java.lang.String /
|
||||||
|
|
|
||||||
|
|
@ -14,6 +14,8 @@ import java.io.InputStream;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* OSS 使用工具
|
* OSS 使用工具
|
||||||
|
*
|
||||||
|
* @author: jiiangchao
|
||||||
*/
|
*/
|
||||||
@Slf4j
|
@Slf4j
|
||||||
public class OssUtil {
|
public class OssUtil {
|
||||||
|
|
|
||||||
|
|
@ -7,6 +7,8 @@ import com.hzs.common.core.web.page.TableSupport;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 分页工具类
|
* 分页工具类
|
||||||
|
*
|
||||||
|
* @author hzs
|
||||||
*/
|
*/
|
||||||
public class PageUtils extends PageHelper {
|
public class PageUtils extends PageHelper {
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -27,6 +27,8 @@ import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 客户端工具类
|
* 客户端工具类
|
||||||
|
*
|
||||||
|
* @author hzs
|
||||||
*/
|
*/
|
||||||
public class ServletUtils {
|
public class ServletUtils {
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -9,6 +9,8 @@ import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* spring工具类 方便在非spring管理环境中获取bean
|
* spring工具类 方便在非spring管理环境中获取bean
|
||||||
|
*
|
||||||
|
* @author hzs
|
||||||
*/
|
*/
|
||||||
@Component
|
@Component
|
||||||
public final class SpringUtils implements BeanFactoryPostProcessor {
|
public final class SpringUtils implements BeanFactoryPostProcessor {
|
||||||
|
|
|
||||||
|
|
@ -7,7 +7,13 @@ import com.alibaba.fastjson2.JSONObject;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 将json串转化为map类型
|
* description: 将json串转化为map类型
|
||||||
|
*
|
||||||
|
* @author: sui q
|
||||||
|
* @time: 2023/4/3 14:17
|
||||||
|
* @classname: StringJsonUtils
|
||||||
|
* @package_name: com.hzs.common.core.utils
|
||||||
|
* version 1.0.0
|
||||||
*/
|
*/
|
||||||
public class StringJsonUtils {
|
public class StringJsonUtils {
|
||||||
|
|
||||||
|
|
@ -44,10 +50,10 @@ public class StringJsonUtils {
|
||||||
for (int j = 0; j < jsonArray.size(); j++) {
|
for (int j = 0; j < jsonArray.size(); j++) {
|
||||||
// JSONObject reagobj = JSONObject.parseObject(jsonStr);
|
// JSONObject reagobj = JSONObject.parseObject(jsonStr);
|
||||||
Object object = jsonArray.get(j);
|
Object object = jsonArray.get(j);
|
||||||
if (object instanceof String) {
|
if(object instanceof String){
|
||||||
jsonArray.set(j, jsonArray.get(j).toString().trim());
|
jsonArray.set(j, jsonArray.get(j).toString().trim());
|
||||||
} else {
|
}else{
|
||||||
if (jsonArray.get(j) instanceof JSONObject) {
|
if(jsonArray.get(j) instanceof JSONObject){
|
||||||
JSONObject reagobj = (JSONObject) jsonArray.get(j);
|
JSONObject reagobj = (JSONObject) jsonArray.get(j);
|
||||||
handleJsonObject(reagobj);
|
handleJsonObject(reagobj);
|
||||||
jsonArray.set(j, reagobj);
|
jsonArray.set(j, reagobj);
|
||||||
|
|
|
||||||
|
|
@ -6,7 +6,11 @@ import org.springframework.stereotype.Component;
|
||||||
import java.util.concurrent.*;
|
import java.util.concurrent.*;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 线程工具类
|
* Description: 线程工具类
|
||||||
|
* Author: jiang chao
|
||||||
|
* Time: 2022/8/30 10:10
|
||||||
|
* Classname: ThreadUtil
|
||||||
|
* PackageName: com.hzs.common.core.utils
|
||||||
*/
|
*/
|
||||||
@Slf4j
|
@Slf4j
|
||||||
@Component
|
@Component
|
||||||
|
|
|
||||||
|
|
@ -8,7 +8,11 @@ import org.springframework.web.multipart.MultipartFile;
|
||||||
import java.io.*;
|
import java.io.*;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 文件上传工具
|
* @Description: 文件上传工具
|
||||||
|
* @Author: jiang chao
|
||||||
|
* @Time: 2023/1/13 11:24
|
||||||
|
* @Classname: UploadUtil
|
||||||
|
* @PackageName: com.hzs.member.tool
|
||||||
*/
|
*/
|
||||||
@Slf4j
|
@Slf4j
|
||||||
public class UploadFileUtil {
|
public class UploadFileUtil {
|
||||||
|
|
|
||||||
|
|
@ -2,6 +2,8 @@ package com.hzs.common.core.utils.poi;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Excel数据格式处理适配器
|
* Excel数据格式处理适配器
|
||||||
|
*
|
||||||
|
* @author hzs
|
||||||
*/
|
*/
|
||||||
public interface ExcelHandlerAdapter {
|
public interface ExcelHandlerAdapter {
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -62,6 +62,8 @@ import com.hzs.common.core.utils.reflect.ReflectUtils;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Excel相关处理
|
* Excel相关处理
|
||||||
|
*
|
||||||
|
* @author hzs
|
||||||
*/
|
*/
|
||||||
@Slf4j
|
@Slf4j
|
||||||
public class ExcelUtil<T> {
|
public class ExcelUtil<T> {
|
||||||
|
|
|
||||||
|
|
@ -18,6 +18,8 @@ import com.hzs.common.core.utils.DateUtils;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 反射工具类. 提供调用getter/setter方法, 访问私有变量, 调用私有方法, 获取泛型类型Class, 被AOP过的真实类等工具函数.
|
* 反射工具类. 提供调用getter/setter方法, 访问私有变量, 调用私有方法, 获取泛型类型Class, 被AOP过的真实类等工具函数.
|
||||||
|
*
|
||||||
|
* @author hzs
|
||||||
*/
|
*/
|
||||||
@Slf4j
|
@Slf4j
|
||||||
@SuppressWarnings("rawtypes")
|
@SuppressWarnings("rawtypes")
|
||||||
|
|
|
||||||
|
|
@ -8,6 +8,8 @@ import java.net.URL;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Base64工具类
|
* Base64工具类
|
||||||
|
*
|
||||||
|
* @author hzs
|
||||||
*/
|
*/
|
||||||
public final class Base64Util {
|
public final class Base64Util {
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -5,6 +5,8 @@ import com.hzs.common.core.utils.StringUtils;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* sql操作工具类
|
* sql操作工具类
|
||||||
|
*
|
||||||
|
* @author hzs
|
||||||
*/
|
*/
|
||||||
public class SqlUtil {
|
public class SqlUtil {
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -2,6 +2,8 @@ package com.hzs.common.core.utils.uuid;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* ID生成器工具类
|
* ID生成器工具类
|
||||||
|
*
|
||||||
|
* @author hzs
|
||||||
*/
|
*/
|
||||||
public class IdUtils {
|
public class IdUtils {
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -6,7 +6,7 @@ import com.hzs.common.core.utils.DateUtils;
|
||||||
import com.hzs.common.core.utils.StringUtils;
|
import com.hzs.common.core.utils.StringUtils;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 序列生成类
|
* @author hzs 序列生成类
|
||||||
*/
|
*/
|
||||||
public class Seq {
|
public class Seq {
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -10,6 +10,8 @@ import com.hzs.common.core.exception.UtilException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 提供通用唯一识别码(universally unique identifier)(UUID)实现
|
* 提供通用唯一识别码(universally unique identifier)(UUID)实现
|
||||||
|
*
|
||||||
|
* @author hzs
|
||||||
*/
|
*/
|
||||||
public final class UUID implements java.io.Serializable, Comparable<UUID> {
|
public final class UUID implements java.io.Serializable, Comparable<UUID> {
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue