This commit is contained in:
dute7liang
2024-01-04 00:07:34 +08:00
parent 4be439a6a1
commit 584f9dabe6
13 changed files with 54 additions and 20 deletions

View File

@@ -0,0 +1,27 @@
package com.ruoyi.cai.controller.admin;
import com.ruoyi.cai.service.CitysService;
import com.ruoyi.common.core.domain.R;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@Validated
@RequiredArgsConstructor
@RestController
@RequestMapping("/cai/city")
public class CityController {
@Autowired
private CitysService citysService;
@GetMapping("/resetRedis")
public R<Void> resetRedis(){
citysService.resetRedis();
return R.ok();
}
}

View File

@@ -3,7 +3,7 @@ package com.ruoyi.cai.controller.admin;
import cn.dev33.satoken.annotation.SaCheckPermission; import cn.dev33.satoken.annotation.SaCheckPermission;
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.CaiConsumeLog; import com.ruoyi.cai.domain.ConsumeLog;
import com.ruoyi.cai.service.ConsumeLogService; import com.ruoyi.cai.service.ConsumeLogService;
import com.ruoyi.common.annotation.Log; import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.annotation.RepeatSubmit; import com.ruoyi.common.annotation.RepeatSubmit;
@@ -41,8 +41,8 @@ public class ConsumeLogController extends BaseController {
*/ */
@SaCheckPermission("cai:consumeLog:list") @SaCheckPermission("cai:consumeLog:list")
@GetMapping("/list") @GetMapping("/list")
public TableDataInfo<CaiConsumeLog> list(CaiConsumeLog bo, PageQuery pageQuery) { public TableDataInfo<ConsumeLog> list(ConsumeLog bo, PageQuery pageQuery) {
Page<CaiConsumeLog> page = consumeLogService.page(pageQuery.build(), Wrappers.lambdaQuery(bo)); Page<ConsumeLog> page = consumeLogService.page(pageQuery.build(), Wrappers.lambdaQuery(bo));
return TableDataInfo.build(page); return TableDataInfo.build(page);
} }
@@ -53,7 +53,7 @@ public class ConsumeLogController extends BaseController {
*/ */
@SaCheckPermission("cai:consumeLog:query") @SaCheckPermission("cai:consumeLog:query")
@GetMapping("/{id}") @GetMapping("/{id}")
public R<CaiConsumeLog> getInfo(@NotNull(message = "主键不能为空") public R<ConsumeLog> getInfo(@NotNull(message = "主键不能为空")
@PathVariable Long id) { @PathVariable Long id) {
return R.ok(consumeLogService.getById(id)); return R.ok(consumeLogService.getById(id));
} }
@@ -65,7 +65,7 @@ public class ConsumeLogController extends BaseController {
@Log(title = "消费记录", businessType = BusinessType.INSERT) @Log(title = "消费记录", businessType = BusinessType.INSERT)
@RepeatSubmit() @RepeatSubmit()
@PostMapping() @PostMapping()
public R<Void> add(@Validated(AddGroup.class) @RequestBody CaiConsumeLog bo) { public R<Void> add(@Validated(AddGroup.class) @RequestBody ConsumeLog bo) {
return toAjax(consumeLogService.save(bo)); return toAjax(consumeLogService.save(bo));
} }
@@ -76,7 +76,7 @@ public class ConsumeLogController extends BaseController {
@Log(title = "消费记录", businessType = BusinessType.UPDATE) @Log(title = "消费记录", businessType = BusinessType.UPDATE)
@RepeatSubmit() @RepeatSubmit()
@PutMapping() @PutMapping()
public R<Void> edit(@Validated(EditGroup.class) @RequestBody CaiConsumeLog bo) { public R<Void> edit(@Validated(EditGroup.class) @RequestBody ConsumeLog bo) {
return toAjax(consumeLogService.updateById(bo)); return toAjax(consumeLogService.updateById(bo));
} }

View File

@@ -17,7 +17,7 @@ import java.time.LocalDateTime;
*/ */
@Data @Data
@TableName("cai_consume_log") @TableName("cai_consume_log")
public class CaiConsumeLog implements Serializable { public class ConsumeLog implements Serializable {
private static final long serialVersionUID=1L; private static final long serialVersionUID=1L;

View File

@@ -1,7 +1,7 @@
package com.ruoyi.cai.mapper; package com.ruoyi.cai.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ruoyi.cai.domain.CaiConsumeLog; import com.ruoyi.cai.domain.ConsumeLog;
/** /**
* 消费记录Mapper接口 * 消费记录Mapper接口
@@ -9,6 +9,6 @@ import com.ruoyi.cai.domain.CaiConsumeLog;
* @author 77 * @author 77
* @date 2023-12-24 * @date 2023-12-24
*/ */
public interface ConsumeLogMapper extends BaseMapper<CaiConsumeLog> { public interface ConsumeLogMapper extends BaseMapper<ConsumeLog> {
} }

View File

@@ -3,7 +3,7 @@ package com.ruoyi.cai.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.ruoyi.cai.domain.Account; import com.ruoyi.cai.domain.Account;
import com.ruoyi.cai.domain.CaiConsumeLog; import com.ruoyi.cai.domain.ConsumeLog;
import com.ruoyi.cai.dto.admin.vo.AccountAdminVo; import com.ruoyi.cai.dto.admin.vo.AccountAdminVo;
import com.ruoyi.common.core.domain.PageQuery; import com.ruoyi.common.core.domain.PageQuery;
@@ -17,7 +17,7 @@ public interface AccountService extends IService<Account> {
Account getByUserId(Long userId); Account getByUserId(Long userId);
CaiConsumeLog decr(CaiConsumeLog log); ConsumeLog decr(ConsumeLog log);
void withdraw(Long userId, Long incomeCoin); void withdraw(Long userId, Long incomeCoin);

View File

@@ -13,6 +13,8 @@ import java.util.Map;
*/ */
public interface CitysService extends IService<Citys> { public interface CitysService extends IService<Citys> {
void resetRedis();
Map<Long,String> all(); Map<Long,String> all();
String getByCityId(Integer cityId); String getByCityId(Integer cityId);

View File

@@ -1,7 +1,7 @@
package com.ruoyi.cai.service; package com.ruoyi.cai.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.ruoyi.cai.domain.CaiConsumeLog; import com.ruoyi.cai.domain.ConsumeLog;
/** /**
* 消费记录Service接口 * 消费记录Service接口
@@ -9,6 +9,6 @@ import com.ruoyi.cai.domain.CaiConsumeLog;
* @author 77 * @author 77
* @date 2023-12-24 * @date 2023-12-24
*/ */
public interface ConsumeLogService extends IService<CaiConsumeLog> { public interface ConsumeLogService extends IService<ConsumeLog> {
} }

View File

@@ -46,7 +46,7 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public CaiConsumeLog decr(CaiConsumeLog consumeLog) { public ConsumeLog decr(ConsumeLog consumeLog) {
log.info("开始扣费 consumeLog={}", JSON.toJSONString(consumeLog)); log.info("开始扣费 consumeLog={}", JSON.toJSONString(consumeLog));
Long userId = consumeLog.getSourceUserId(); Long userId = consumeLog.getSourceUserId();
Long amount = consumeLog.getAmount(); Long amount = consumeLog.getAmount();
@@ -108,7 +108,7 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
return baseMapper.pageAdmin(pageQuery.build(),bo); return baseMapper.pageAdmin(pageQuery.build(),bo);
} }
private void fenxiao(CaiConsumeLog consumeLog){ private void fenxiao(ConsumeLog consumeLog){
if(ConsumeLogType.PAY.getCode().equals(consumeLog.getType())){ if(ConsumeLogType.PAY.getCode().equals(consumeLog.getType())){
Long sourceUserId = consumeLog.getSourceUserId(); Long sourceUserId = consumeLog.getSourceUserId();
UserInvite userInvite = userInviteService.getByUserId(sourceUserId); UserInvite userInvite = userInviteService.getByUserId(sourceUserId);

View File

@@ -32,6 +32,11 @@ public class CitysServiceImpl extends ServiceImpl<CitysMapper, Citys> implements
@PostConstruct @PostConstruct
public void init() { public void init() {
this.resetRedis();
}
@Override
public void resetRedis(){
List<Citys> list = this.list(); List<Citys> list = this.list();
Map<String, String> map = list.stream().collect(Collectors.toMap(i -> String.valueOf(i.getId()), Citys::getName)); Map<String, String> map = list.stream().collect(Collectors.toMap(i -> String.valueOf(i.getId()), Citys::getName));
redisTemplate.opsForHash().putAll(RedisConstant.CITY_CACHE_REDIS, map); redisTemplate.opsForHash().putAll(RedisConstant.CITY_CACHE_REDIS, map);

View File

@@ -1,7 +1,7 @@
package com.ruoyi.cai.service.impl; package com.ruoyi.cai.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.cai.domain.CaiConsumeLog; import com.ruoyi.cai.domain.ConsumeLog;
import com.ruoyi.cai.mapper.ConsumeLogMapper; import com.ruoyi.cai.mapper.ConsumeLogMapper;
import com.ruoyi.cai.service.ConsumeLogService; import com.ruoyi.cai.service.ConsumeLogService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -13,6 +13,6 @@ import org.springframework.stereotype.Service;
* @date 2023-12-24 * @date 2023-12-24
*/ */
@Service @Service
public class ConsumeLogServiceImpl extends ServiceImpl<ConsumeLogMapper,CaiConsumeLog> implements ConsumeLogService { public class ConsumeLogServiceImpl extends ServiceImpl<ConsumeLogMapper, ConsumeLog> implements ConsumeLogService {
} }

View File

@@ -88,7 +88,7 @@ public class GuardTotalServiceImpl extends ServiceImpl<GuardTotalMapper, GuardTo
throw new ServiceException("守护价格发生变化"); throw new ServiceException("守护价格发生变化");
} }
Long guardValue = query.getGuardNum() * guardPrice; Long guardValue = query.getGuardNum() * guardPrice;
CaiConsumeLog consumeLog = new CaiConsumeLog(); ConsumeLog consumeLog = new ConsumeLog();
consumeLog.init(fromUser,toUser); consumeLog.init(fromUser,toUser);
consumeLog.setType(ConsumeLogType.GUARD.getCode()); consumeLog.setType(ConsumeLogType.GUARD.getCode());
consumeLog.setAmount(guardValue); consumeLog.setAmount(guardValue);

View File

@@ -52,7 +52,7 @@ public class UserGiftServiceImpl extends ServiceImpl<UserGiftMapper, UserGift> i
Anchor anchor = anchorService.getByUserId(query.getToUserId()); Anchor anchor = anchorService.getByUserId(query.getToUserId());
Long price = gift.getPrice(); Long price = gift.getPrice();
Long giftAmount = query.getGiftCount() * price; Long giftAmount = query.getGiftCount() * price;
CaiConsumeLog consumeLog = new CaiConsumeLog(); ConsumeLog consumeLog = new ConsumeLog();
consumeLog.init(fromUser,toUser); consumeLog.init(fromUser,toUser);
consumeLog.setType(ConsumeLogType.GIFT.getCode()); consumeLog.setType(ConsumeLogType.GIFT.getCode());
consumeLog.setAmount(giftAmount); consumeLog.setAmount(giftAmount);

View File

@@ -4,7 +4,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd"> "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ruoyi.cai.mapper.ConsumeLogMapper"> <mapper namespace="com.ruoyi.cai.mapper.ConsumeLogMapper">
<resultMap type="com.ruoyi.cai.domain.CaiConsumeLog" id="CaiConsumeLogResult"> <resultMap type="com.ruoyi.cai.domain.ConsumeLog" id="CaiConsumeLogResult">
<result property="id" column="id"/> <result property="id" column="id"/>
<result property="type" column="type"/> <result property="type" column="type"/>
<result property="sourceBusinessId" column="source_business_id"/> <result property="sourceBusinessId" column="source_business_id"/>