Browse Source

后端整合模块

detached
huangqizhen 5 months ago
parent
commit
684814ebaf
  1. 4
      src/main/java/com/example/demo/controller/RateController.java
  2. 1
      src/main/java/com/example/demo/domain/entity/Rate.java
  3. 8
      src/main/java/com/example/demo/mapper/RateMapper.java
  4. 27
      src/main/java/com/example/demo/serviceImpl/RateServiceImpl.java
  5. 5
      src/main/java/com/example/demo/serviceImpl/StatisticsServiceImpl.java
  6. 2
      src/main/java/com/example/demo/sevice/RateService.java

4
src/main/java/com/example/demo/controller/RateController.java

@ -50,6 +50,10 @@ public class RateController {
}
}
@PostMapping("/status")
public Result status(@RequestBody Rate rate) throws Exception {
return Result.success(rateService.selectByStatus(rate));
}
@PostMapping("/searchById")
public Result searchById(@RequestParam Integer rateId) {

1
src/main/java/com/example/demo/domain/entity/Rate.java

@ -30,5 +30,6 @@ public class Rate {
private Integer flag;
private String token;
private Integer updateId;
private Integer status;
}

8
src/main/java/com/example/demo/mapper/RateMapper.java

@ -37,6 +37,7 @@ public interface RateMapper {
"<if test='exchangeRate!=null'>exchange_rate=#{exchangeRate},</if>",
"<if test='updateTime!=null'>update_time=#{updateTime},</if>",
"<if test='adminId!=null'>admin_id=#{adminId},</if>",
"<if test='status != null'>`status`=#{status},</if>",
"</set>",
"where rate_id = #{rateId}",
"</script>"
@ -63,9 +64,14 @@ public interface RateMapper {
"<if test='updateTime != null'>AND r.update_time LIKE CONCAT('%', #{updateTime}, '%')</if>",
"<if test='adminId != null'>AND r.admin_id = #{adminId}</if>",
"<if test='updateId != null'>AND r.update_id = #{updateId}</if>",
"ORDER BY r.create_time DESC",
"<if test='status != null'>`status`=#{status},</if>",
"ORDER BY r.status ASC,r.create_time DESC",
"</script>"
})
List<Rate> select(Rate rate);
@Select({
"select * from rate where status=1 and flag=1"
})
List<Rate> selectByStatus(Rate rate);
}

27
src/main/java/com/example/demo/serviceImpl/RateServiceImpl.java

@ -12,6 +12,7 @@ import org.springframework.cache.annotation.*;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.Date;
import java.util.List;
@Transactional
@Service
@ -52,6 +53,11 @@ public class RateServiceImpl implements RateService {
return rateMapper.insert(rate);
}
@Override
public List<Rate> selectByStatus(Rate rate) throws Exception {
return rateMapper.selectByStatus(rate);
}
//软删除
@CacheEvict(value = "rate",allEntries = true)
@Override
@ -77,8 +83,29 @@ public class RateServiceImpl implements RateService {
@Cacheable(key="#root.method.name + ':'+ #pageNum + '-' + #pageSize + '-' + #rate.hashCode() ")
@Override
public PageInfo<Rate> searchForPage(Integer pageNum, Integer pageSize, Rate rate) {
// PageHelper.startPage(pageNum, pageSize);
// List<Rate> list = rateMapper.select(rate);
// return new PageInfo<>(list);
PageHelper.startPage(pageNum, pageSize);
List<Rate> list = rateMapper.select(rate);
Date nowDate = new Date();
list.forEach(rate1 -> {
// 假设 getStartTime() getEndTime() 返回的是 java.util.Date 类型
Date startTime = rate1.getStartTime();
Date endTime = rate1.getEndTime();
// 使用 Date 类的 before after 方法进行比较
if (nowDate.before(startTime)) {
rate1.setStatus(0); // 设置状态为 0
} else if (nowDate.after(endTime)) {
rate1.setStatus(2); // 设置状态为 2
} else {
rate1.setStatus(1); // 设置状态为 1
}
// 保存修改后的对象
rateMapper.update(rate1);
});
return new PageInfo<>(list);
}
}

5
src/main/java/com/example/demo/serviceImpl/StatisticsServiceImpl.java

@ -120,6 +120,7 @@ public class StatisticsServiceImpl implements StatisticsService {
public List<SumCoin> getMediuConsumeCoin() {
return statisticsMapper.getMediuConsumeCoin();
}
@Cacheable(key="#root.method.name")
public SumCoin getMess(Integer jwcode){
return statisticsMapper.getMess(jwcode);
}
@ -135,7 +136,7 @@ public class StatisticsServiceImpl implements StatisticsService {
}
@Cacheable(key="#root.method.name + '-' + #meium.hashCode() ")
@Override
public List<Meium> getMee( Meium meium) {
@ -233,7 +234,7 @@ public class StatisticsServiceImpl implements StatisticsService {
// return null;
//
// }
@Cacheable(key="#root.method.name + '-' + #sumcoin.hashCode() ")
public List<SumCoin> getCoinTime(SumCoin sumcoin) {
System.out.println(sumcoin + "-------sumcoin----");

2
src/main/java/com/example/demo/sevice/RateService.java

@ -9,7 +9,7 @@ import java.util.List;
public interface RateService {
int add(Rate rate) throws Exception;
int edit(Rate rate) throws Exception;
List<Rate> selectByStatus(Rate rate) throws Exception;
void softDelete(Integer rateId) throws Exception;
Rate getById(Integer rateId);
List<Rate> search(Rate rate);

Loading…
Cancel
Save