xiaoyong931011
2023-08-22 ef552b45c7affb3b91c39d2451a0233c1da67814
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
package cc.mrbird.febs.system.controller;
 
import cc.mrbird.febs.common.annotation.Limit;
import cc.mrbird.febs.common.controller.BaseController;
import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.exception.FebsException;
import cc.mrbird.febs.common.service.ValidateCodeService;
import cc.mrbird.febs.common.utils.Md5Util;
import cc.mrbird.febs.dapp.mapper.DappFundFlowDao;
import cc.mrbird.febs.dapp.mapper.DappMemberDao;
import cc.mrbird.febs.dapp.mapper.DappWalletCoinDao;
import cc.mrbird.febs.dapp.mapper.MallOrderInfoMapper;
import cc.mrbird.febs.monitor.entity.LoginLog;
import cc.mrbird.febs.monitor.service.ILoginLogService;
import cc.mrbird.febs.system.entity.User;
import cc.mrbird.febs.system.service.IUserService;
import cn.hutool.core.date.DateUtil;
import lombok.RequiredArgsConstructor;
import org.apache.shiro.authc.UsernamePasswordToken;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
 
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import javax.validation.constraints.NotBlank;
import java.io.IOException;
import java.math.BigDecimal;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
/**
 * @author MrBird
 */
@Validated
@RestController
@RequiredArgsConstructor
public class LoginController extends BaseController {
 
    private final IUserService userService;
    private final ValidateCodeService validateCodeService;
    private final ILoginLogService loginLogService;
    private final DappMemberDao dappMemberDao;
    private final DappWalletCoinDao dappWalletCoinDao;
    private final DappFundFlowDao dappFundFlowDao;
 
    @PostMapping("login")
    @Limit(key = "login", period = 60, count = 10, name = "登录接口", prefix = "limit")
    public FebsResponse login(
            @NotBlank(message = "{required}") String username,
            @NotBlank(message = "{required}") String password,
            @NotBlank(message = "{required}") String verifyCode,
            boolean rememberMe, HttpServletRequest request) throws FebsException {
        HttpSession session = request.getSession();
        validateCodeService.check(session.getId(), verifyCode);
        password = Md5Util.encrypt(username.toLowerCase(), password);
        UsernamePasswordToken token = new UsernamePasswordToken(username, password, rememberMe);
        super.login(token);
        // 保存登录日志
        LoginLog loginLog = new LoginLog();
        loginLog.setUsername(username);
        loginLog.setSystemBrowserInfo();
        this.loginLogService.saveLoginLog(loginLog);
 
        return new FebsResponse().success();
    }
 
    @PostMapping("regist")
    public FebsResponse regist(
            @NotBlank(message = "{required}") String username,
            @NotBlank(message = "{required}") String password) throws FebsException {
        User user = userService.findByName(username);
        if (user != null) {
            throw new FebsException("该用户名已存在");
        }
        this.userService.regist(username, password);
        return new FebsResponse().success();
    }
 
    @GetMapping("index/{username}")
    public FebsResponse index(@NotBlank(message = "{required}") @PathVariable String username) {
        // 更新登录时间
        this.userService.updateLoginTime(username);
        Map<String, Object> data = new HashMap<>(5);
        // 获取系统访问记录
        Long totalVisitCount = this.loginLogService.findTotalVisitCount();
        data.put("totalVisitCount", totalVisitCount);
        Long todayVisitCount = this.loginLogService.findTodayVisitCount();
        data.put("todayVisitCount", todayVisitCount);
        Long todayIp = this.loginLogService.findTodayIp();
        data.put("todayIp", todayIp);
        // 获取近期系统访问记录
        List<Map<String, Object>> lastSevenVisitCount = this.loginLogService.findLastSevenDaysVisitCount(null);
        data.put("lastSevenVisitCount", lastSevenVisitCount);
        User param = new User();
        param.setUsername(username);
        List<Map<String, Object>> lastSevenUserVisitCount = this.loginLogService.findLastSevenDaysVisitCount(param);
        data.put("lastSevenUserVisitCount", lastSevenUserVisitCount);
 
        data.put("orderAmountTotal", dappMemberDao.selectOrderAmountByTime(null, null));
        data.put("orderAmountMonth", dappMemberDao.selectOrderAmountByTime("M", new Date()));
        data.put("orderAmountToday", dappMemberDao.selectOrderAmountByTime("D", new Date()));
 
        data.put("orderTotalCnt", dappMemberDao.selectOrderCountByTime(null, null));
        data.put("orderMonthCnt", dappMemberDao.selectOrderCountByTime("M", new Date()));
        data.put("orderTodayCnt", dappMemberDao.selectOrderCountByTime("D", new Date()));
 
        BigDecimal releaseTotal = dappMemberDao.selectAccountChangeAfterAmountByTime(null, null);
        BigDecimal releaseTotalPre = dappMemberDao.selectAccountChangeAfterAmountByTime(null, null);
        BigDecimal releaseNot = releaseTotalPre.subtract(releaseTotal);
        data.put("releaseTotal", releaseTotal);
        data.put("releaseNot", releaseNot);
        data.put("releaseToday", dappMemberDao.selectAccountChangeAfterAmountByTime("D", new Date()));
 
        data.put("withdrawTotal",  dappWalletCoinDao.selectWithdrawAmountByType(null, null));
        data.put("withdrawToday", dappWalletCoinDao.selectWithdrawAmountByType("D", new Date()));
        data.put("withdrawNot", dappWalletCoinDao.selectTotal());
 
        data.put("releaseAmountTotal", dappFundFlowDao.selectSumAmountByType(27));
        data.put("releaseAmountToday", dappFundFlowDao.selectSumAmountByTypeAndDate(27, DateUtil.date()));
 
        data.put("releaseScoreTotal", dappFundFlowDao.selectSumAmountByType(28));
        data.put("releaseScoreToday", dappFundFlowDao.selectSumAmountByTypeAndDate(28, DateUtil.date()));
 
        data.put("releasePackageTotal", dappFundFlowDao.selectSumAmountByType(29));
        data.put("releasePackageToday", dappFundFlowDao.selectSumAmountByTypeAndDate(29, DateUtil.date()));
 
        data.put("releasePackageTotal", dappFundFlowDao.selectSumAmountByType(42));
        data.put("releasePackageToday", dappFundFlowDao.selectSumAmountByTypeAndDate(42, DateUtil.date()));
 
 
        return new FebsResponse().success().data(data);
    }
 
    @GetMapping("images/captcha")
    @Limit(key = "get_captcha", period = 60, count = 10, name = "获取验证码", prefix = "limit")
    public void captcha(HttpServletRequest request, HttpServletResponse response) throws IOException, FebsException {
        validateCodeService.create(request, response);
    }
}