This commit is contained in:
777
2025-10-21 17:38:14 +08:00
parent 30f25788cc
commit 6087346eb6
10 changed files with 38 additions and 6 deletions

View File

@@ -1,6 +1,7 @@
package com.ruoyi.web.controller.cai.admin.init; package com.ruoyi.web.controller.cai.admin.init;
import cn.dev33.satoken.annotation.SaCheckRole;
import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.cai.pay.PayOrderInfoDTO; import com.ruoyi.cai.pay.PayOrderInfoDTO;
import com.ruoyi.cai.pay.PayReturnResp; import com.ruoyi.cai.pay.PayReturnResp;
@@ -24,12 +25,14 @@ public class CityController {
private PayTrdConfigService payTrdConfigService; private PayTrdConfigService payTrdConfigService;
@GetMapping("/resetRedis") @GetMapping("/resetRedis")
@SaCheckRole("admin")
public R<Void> resetRedis(){ public R<Void> resetRedis(){
citysService.resetRedis(); citysService.resetRedis();
return R.ok(); return R.ok();
} }
@GetMapping("/resetOrder") @GetMapping("/resetOrder")
@SaCheckRole("admin")
public R<JSONObject> resetOrder(String orderNo,String payType,boolean updateData){ public R<JSONObject> resetOrder(String orderNo,String payType,boolean updateData){
JSONObject jsonObject = payTrdConfigService.resetOrder(orderNo,payType,updateData); JSONObject jsonObject = payTrdConfigService.resetOrder(orderNo,payType,updateData);
return R.ok(jsonObject); return R.ok(jsonObject);
@@ -37,12 +40,14 @@ public class CityController {
@PostMapping("/createOrder") @PostMapping("/createOrder")
@SaCheckRole("admin")
public R<Object> createOrder(@RequestBody PayOrderInfoDTO dto){ public R<Object> createOrder(@RequestBody PayOrderInfoDTO dto){
PayReturnResp orderAli = payTrdConfigService.createOrderAli(dto,false); PayReturnResp orderAli = payTrdConfigService.createOrderAli(dto,false);
return R.ok(orderAli); return R.ok(orderAli);
} }
@GetMapping("/queryOrder") @GetMapping("/queryOrder")
@SaCheckRole("admin")
public R<JSONObject> queryOrder(String orderNo,String payType){ public R<JSONObject> queryOrder(String orderNo,String payType){
JSONObject jsonObject = payTrdConfigService.queryOrder(orderNo,payType); JSONObject jsonObject = payTrdConfigService.queryOrder(orderNo,payType);
return R.ok(jsonObject); return R.ok(jsonObject);

View File

@@ -1,5 +1,6 @@
package com.ruoyi.web.controller.cai.admin.init; package com.ruoyi.web.controller.cai.admin.init;
import cn.dev33.satoken.annotation.SaCheckRole;
import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.cai.domain.User; import com.ruoyi.cai.domain.User;
@@ -33,6 +34,7 @@ public class ImController {
private UserService userService; private UserService userService;
@GetMapping("/register") @GetMapping("/register")
@SaCheckRole("admin")
public R<Void> registerIm(Long userId){ public R<Void> registerIm(Long userId){
User user = userService.getById(userId); User user = userService.getById(userId);
if(user == null){ if(user == null){
@@ -66,6 +68,7 @@ public class ImController {
} }
@GetMapping("/registerAll") @GetMapping("/registerAll")
@SaCheckRole("admin")
public R<Void> registerAllIm(){ public R<Void> registerAllIm(){
int current = 0; int current = 0;
int success = 0; int success = 0;

View File

@@ -1,5 +1,6 @@
package com.ruoyi.web.controller.cai.admin.init; package com.ruoyi.web.controller.cai.admin.init;
import cn.dev33.satoken.annotation.SaCheckRole;
import com.ruoyi.cai.mq.AmqpHttpProducer; import com.ruoyi.cai.mq.AmqpHttpProducer;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@@ -18,6 +19,7 @@ public class MqControllerTest {
private AmqpHttpProducer amqpHttpProducer; private AmqpHttpProducer amqpHttpProducer;
@GetMapping("/send2") @GetMapping("/send2")
@SaCheckRole("admin")
public void send(String message){ public void send(String message){
amqpHttpProducer.sendCalculateSales(message); amqpHttpProducer.sendCalculateSales(message);
} }

View File

@@ -1,6 +1,7 @@
package com.ruoyi.web.controller.cai.admin.op; package com.ruoyi.web.controller.cai.admin.op;
import cn.dev33.satoken.annotation.SaCheckRole;
import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.utils.StringUtils; import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.job.op.BusOp; import com.ruoyi.job.op.BusOp;
@@ -26,6 +27,7 @@ public class BusOpController {
private BusOp busOp; private BusOp busOp;
@GetMapping("/copySysLog") @GetMapping("/copySysLog")
@SaCheckRole("admin")
public R<Void> copySysLog(int days){ public R<Void> copySysLog(int days){
log.info("备份操作日志-开始"); log.info("备份操作日志-开始");
busOp.copySysLog(days); busOp.copySysLog(days);
@@ -34,6 +36,7 @@ public class BusOpController {
} }
@GetMapping("/deleteUserCall") @GetMapping("/deleteUserCall")
@SaCheckRole("admin")
public R<Void> deleteUserCall(){ public R<Void> deleteUserCall(){
log.info("清洗垃圾通话记录-开始"); log.info("清洗垃圾通话记录-开始");
busOp.deleteUserCall(16); busOp.deleteUserCall(16);
@@ -43,12 +46,14 @@ public class BusOpController {
@GetMapping("/refreshUserVipStatus") @GetMapping("/refreshUserVipStatus")
@SaCheckRole("admin")
public R<Void> refreshUserVipStatus(){ public R<Void> refreshUserVipStatus(){
busOp.refreshUserVipStatus(); busOp.refreshUserVipStatus();
return R.ok(); return R.ok();
} }
@GetMapping("/checkVipOrder") @GetMapping("/checkVipOrder")
@SaCheckRole("admin")
public R<Void> checkVipOrder(String orderNo,String startTimeStr,String endTimeStr){ public R<Void> checkVipOrder(String orderNo,String startTimeStr,String endTimeStr){
LocalDateTime startTime = null; LocalDateTime startTime = null;
LocalDateTime endTime = null; LocalDateTime endTime = null;
@@ -63,6 +68,7 @@ public class BusOpController {
} }
@GetMapping("/checkRechargeOrder") @GetMapping("/checkRechargeOrder")
@SaCheckRole("admin")
public R<Void> checkRechargeOrder(String orderNo,String startTimeStr,String endTimeStr){ public R<Void> checkRechargeOrder(String orderNo,String startTimeStr,String endTimeStr){
LocalDateTime startTime = null; LocalDateTime startTime = null;
LocalDateTime endTime = null; LocalDateTime endTime = null;

View File

@@ -1,5 +1,6 @@
package com.ruoyi.web.controller.cai.admin.op; package com.ruoyi.web.controller.cai.admin.op;
import cn.dev33.satoken.annotation.SaCheckRole;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.domain.R;
import com.ruoyi.job.op.ImOp; import com.ruoyi.job.op.ImOp;
@@ -30,6 +31,7 @@ public class ImOpController {
private ImUserRefClient imUserRefClient; private ImUserRefClient imUserRefClient;
@GetMapping("/getImInfo") @GetMapping("/getImInfo")
@SaCheckRole("admin")
public R<YxUpdateUinfoR> getImInfo(String id) { public R<YxUpdateUinfoR> getImInfo(String id) {
GetUnifoReq getUnifoReq = new GetUnifoReq(); GetUnifoReq getUnifoReq = new GetUnifoReq();
String[] split = id.split(","); String[] split = id.split(",");
@@ -40,24 +42,28 @@ public class ImOpController {
@GetMapping("/refreshIm") @GetMapping("/refreshIm")
@SaCheckRole("admin")
public R<Void> list() { public R<Void> list() {
imOp.refreshIm(); imOp.refreshIm();
return R.ok(); return R.ok();
} }
@GetMapping("/refreshImUserInfo") @GetMapping("/refreshImUserInfo")
@SaCheckRole("admin")
public R<Void> refreshImUserInfo(){ public R<Void> refreshImUserInfo(){
imOp.refreshImUserInfo(); imOp.refreshImUserInfo();
return R.ok(); return R.ok();
} }
@GetMapping("/refreshImByUser") @GetMapping("/refreshImByUser")
@SaCheckRole("admin")
public R<Void> refreshImByUser(String usercode){ public R<Void> refreshImByUser(String usercode){
imOp.refreshImToken(usercode); imOp.refreshImToken(usercode);
return R.ok(); return R.ok();
} }
@GetMapping("/refreshImNoSaveToken") @GetMapping("/refreshImNoSaveToken")
@SaCheckRole("admin")
public R<Void> refreshImNoSaveToken(){ public R<Void> refreshImNoSaveToken(){
imOp.refreshImNoSaveToken(); imOp.refreshImNoSaveToken();
return R.ok(); return R.ok();

View File

@@ -1,6 +1,7 @@
package com.ruoyi.web.controller.cai.admin.op; package com.ruoyi.web.controller.cai.admin.op;
import cn.dev33.satoken.annotation.SaCheckRole;
import com.ruoyi.cai.kit.ShareUrlKit; import com.ruoyi.cai.kit.ShareUrlKit;
import com.ruoyi.cai.service.RankService; import com.ruoyi.cai.service.RankService;
import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.domain.R;
@@ -29,12 +30,14 @@ public class RefreshOpController {
private ShareUrlKit shareUrlKit; private ShareUrlKit shareUrlKit;
@GetMapping("/cleanShareUrlCacheByUsercode") @GetMapping("/cleanShareUrlCacheByUsercode")
@SaCheckRole("admin")
public R<Void> cleanShareUrlCacheByUsercode(String usercode){ public R<Void> cleanShareUrlCacheByUsercode(String usercode){
shareUrlKit.cleanShareUrlCacheByUsercode(usercode); shareUrlKit.cleanShareUrlCacheByUsercode(usercode);
return R.ok(); return R.ok();
} }
@GetMapping("/cleanShareUrlCache") @GetMapping("/cleanShareUrlCache")
@SaCheckRole("admin")
public R<Void> cleanShareUrlCache(){ public R<Void> cleanShareUrlCache(){
shareUrlKit.cleanShareUrlCache(); shareUrlKit.cleanShareUrlCache();
return R.ok(); return R.ok();
@@ -42,6 +45,7 @@ public class RefreshOpController {
@GetMapping("/day") @GetMapping("/day")
@SaCheckRole("admin")
public R<Void> day(String date,Integer type) { public R<Void> day(String date,Integer type) {
LocalDate localDate = LocalDate.parse(date, DateTimeFormatter.ofPattern("yyyy-MM-dd")); LocalDate localDate = LocalDate.parse(date, DateTimeFormatter.ofPattern("yyyy-MM-dd"));
rankService.saveDayRank(localDate, type); rankService.saveDayRank(localDate, type);
@@ -49,6 +53,7 @@ public class RefreshOpController {
} }
@GetMapping("/week") @GetMapping("/week")
@SaCheckRole("admin")
public R<Void> week(String date,Integer type){ public R<Void> week(String date,Integer type){
LocalDate localDate = LocalDate.parse(date, DateTimeFormatter.ofPattern("yyyy-MM-dd")); LocalDate localDate = LocalDate.parse(date, DateTimeFormatter.ofPattern("yyyy-MM-dd"));
rankService.saveWeekRank(localDate,type); rankService.saveWeekRank(localDate,type);
@@ -56,6 +61,7 @@ public class RefreshOpController {
} }
@GetMapping("/month") @GetMapping("/month")
@SaCheckRole("admin")
public R<Void> month(String date,Integer type){ public R<Void> month(String date,Integer type){
LocalDate localDate = LocalDate.parse(date, DateTimeFormatter.ofPattern("yyyy-MM-dd")); LocalDate localDate = LocalDate.parse(date, DateTimeFormatter.ofPattern("yyyy-MM-dd"));
rankService.saveMonthRank(localDate,type); rankService.saveMonthRank(localDate,type);

View File

@@ -1,6 +1,7 @@
package com.ruoyi.cai.controller; package com.ruoyi.cai.controller;
import cn.dev33.satoken.annotation.SaCheckPermission; import cn.dev33.satoken.annotation.SaCheckPermission;
import cn.dev33.satoken.annotation.SaCheckRole;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.cai.domain.Union; import com.ruoyi.cai.domain.Union;
@@ -57,6 +58,7 @@ public class UnionTotalController extends BaseController {
@Log(title = "刷新工会每日收益", businessType = BusinessType.DELETE) @Log(title = "刷新工会每日收益", businessType = BusinessType.DELETE)
@GetMapping("/refreshData") @GetMapping("/refreshData")
@SaCheckRole("admin")
public R<Void> refreshData(String date) { public R<Void> refreshData(String date) {
if(StringUtils.isBlank(date)){ if(StringUtils.isBlank(date)){
unionTotalService.refreshAll(); unionTotalService.refreshAll();
@@ -69,6 +71,7 @@ public class UnionTotalController extends BaseController {
@Log(title = "刷新所有工会总收益") @Log(title = "刷新所有工会总收益")
@GetMapping("/refreshAllUnion") @GetMapping("/refreshAllUnion")
@SaCheckRole("admin")
public R<Void> refreshAllUnion() { public R<Void> refreshAllUnion() {
unionTotalService.refreshUnionTotalAll(); unionTotalService.refreshUnionTotalAll();
return R.ok(); return R.ok();
@@ -76,6 +79,7 @@ public class UnionTotalController extends BaseController {
@Log(title = "刷新指定工会总收益") @Log(title = "刷新指定工会总收益")
@GetMapping("/refreshUnionTotal") @GetMapping("/refreshUnionTotal")
@SaCheckRole("admin")
public R<Void> refreshUnionTotal(Long unionId) { public R<Void> refreshUnionTotal(Long unionId) {
unionTotalService.refreshUnionTotal(unionId); unionTotalService.refreshUnionTotal(unionId);
return R.ok(); return R.ok();

View File

@@ -27,7 +27,7 @@ public class ProxyUserManager {
public IPage<OrderListDTO> orderLogList(String usercode,PageQuery pageQuery, OrderListDTO query){ public IPage<OrderListDTO> orderLogList(String usercode,PageQuery pageQuery, OrderListDTO query){
User user = getUser(usercode); User user = getUser(usercode);
return consumeLogMapper.selectProxyUserOrderPage(pageQuery.build(),user.getUsercode(), query); return consumeLogMapper.selectProxyUserOrderPage(pageQuery.build(),user.getId(), query);
} }
public IPage<BindUserListDTO> bindUserList(String userCode, PageQuery pageQuery, BindUserListDTO query) { public IPage<BindUserListDTO> bindUserList(String userCode, PageQuery pageQuery, BindUserListDTO query) {
@@ -37,7 +37,7 @@ public class ProxyUserManager {
public ProxyTotalDTO total(String userCode) { public ProxyTotalDTO total(String userCode) {
User user = getUser(userCode); User user = getUser(userCode);
BigDecimal priceSum = consumeLogMapper.sumProxyUserOrder(user.getUsercode()); BigDecimal priceSum = consumeLogMapper.sumProxyUserOrder(user.getId());
Long userCount = userInviteMapper.countProxyBindUser(user.getId()); Long userCount = userInviteMapper.countProxyBindUser(user.getId());
ProxyTotalDTO proxyTotalDTO = new ProxyTotalDTO(); ProxyTotalDTO proxyTotalDTO = new ProxyTotalDTO();
proxyTotalDTO.setBindUserCount(userCount == null ? 0 : userCount); proxyTotalDTO.setBindUserCount(userCount == null ? 0 : userCount);

View File

@@ -16,8 +16,8 @@ import java.math.BigDecimal;
*/ */
public interface ConsumeLogMapper extends BaseMapper<ConsumeLog> { public interface ConsumeLogMapper extends BaseMapper<ConsumeLog> {
IPage<OrderListDTO> selectProxyUserOrderPage(@Param("page") IPage<OrderListDTO> page, IPage<OrderListDTO> selectProxyUserOrderPage(@Param("page") IPage<OrderListDTO> page,
@Param("proxyUserCode") String proxyUserCode, @Param("proxyUserId") Long proxyUserId,
@Param("query") OrderListDTO query); @Param("query") OrderListDTO query);
BigDecimal sumProxyUserOrder(@Param("userCode") String userCode); BigDecimal sumProxyUserOrder(@Param("userId") Long userId);
} }

View File

@@ -11,7 +11,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
from cai_consume_log t1 from cai_consume_log t1
join cai_recharge_order t2 on t1.trace_id = t2.trace_id join cai_recharge_order t2 on t1.trace_id = t2.trace_id
left join cai_user t3 on t2.user_id = t3.id left join cai_user t3 on t2.user_id = t3.id
where t1.type = 1 and t1.one_user_id = #{proxyUserCode} and t1.`status` = 1 where t1.type = 1 and t1.one_user_id = #{proxyUserId} and t1.`status` = 1
<if test="query.usercode != null and query.usercode != ''"> <if test="query.usercode != null and query.usercode != ''">
and t3.usercode = #{query.usercode} and t3.usercode = #{query.usercode}
</if> </if>
@@ -31,6 +31,6 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
sum(t2.price) sum(t2.price)
from cai_consume_log t1 from cai_consume_log t1
join cai_recharge_order t2 on t1.trace_id = t2.trace_id join cai_recharge_order t2 on t1.trace_id = t2.trace_id
where t1.type = 1 and t1.one_user_id = #{userCode} and t1.`status` = 1 where t1.type = 1 and t1.one_user_id = #{userId} and t1.`status` = 1
</select> </select>
</mapper> </mapper>