Browse Source

后端整合模块

detached
huangqizhen 5 months ago
parent
commit
dfe63f2f05
  1. 4
      src/main/java/com/example/demo/mapper/RateMapper.java
  2. 8
      src/main/java/com/example/demo/mapper/RechargeMapper.java
  3. 13
      src/main/java/com/example/demo/serviceImpl/RateServiceImpl.java
  4. 3
      src/main/java/com/example/demo/sevice/RateService.java

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

@ -74,4 +74,8 @@ public interface RateMapper {
"select * from rate where status=1 and flag=1"
})
List<Rate> selectByStatus(Rate rate);
@Select({
"select * from rate where currency=#{currency} and flag=1"
})
Integer selectByCurrency(String currency);
}

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

@ -33,10 +33,10 @@ public interface RechargeMapper {
@Select({
"<script>",
"SELECT DISTINCT user.`name` as user_name , recharge.*,activity.activity_name,audit.`status`,audit.audit_id,audit.reson, admin.name,admin.area,audit.detail_id FROM recharge",
"INNER JOIN audit ON recharge.recharge_id = audit.recharge_id",
"INNER JOIN `user` ON recharge.jwcode = `user`.jwcode",
"INNER JOIN activity on recharge.activity_id = activity.activity_id",
"INNER JOIN `admin` on recharge.admin_id = `admin`.admin_id",
"LEFT JOIN audit ON recharge.recharge_id = audit.recharge_id",
"LEFT JOIN `user` ON recharge.jwcode = `user`.jwcode",
"LEFT JOIN activity on recharge.activity_id = activity.activity_id",
"LEFT JOIN `admin` on recharge.admin_id = `admin`.admin_id",
"<where>",
"flag='1'",
"<if test='activityId!=null'>and recharge.activity_id=#{activityId}</if>",

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

@ -2,6 +2,7 @@ package com.example.demo.serviceImpl;
import com.example.demo.domain.entity.Rate;
import com.example.demo.domain.vo.Result;
import com.example.demo.mapper.RateMapper;
import com.example.demo.sevice.RateService;
import com.github.pagehelper.PageHelper;
@ -23,8 +24,16 @@ public class RateServiceImpl implements RateService {
@CacheEvict(value = "rate",allEntries = true)
@Override
public int add(Rate rate) {
return rateMapper.insert(rate);
public Result add(Rate rate) throws Exception {
// 检查名称是否存在
Integer count = rateMapper.selectByCurrency(rate.getCurrency());
if (count!=null && count > 0) {
// 如果存在抛出异常
throw new Exception( "该汇率已存在");
}
else
return Result.success(rateMapper.insert(rate));
}
//自动软删除数据加更新数据

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

@ -2,12 +2,13 @@ package com.example.demo.sevice;
import com.example.demo.domain.entity.Rate;
import com.example.demo.domain.vo.Result;
import com.github.pagehelper.PageInfo;
import java.util.List;
public interface RateService {
int add(Rate rate) throws Exception;
Result add(Rate rate) throws Exception;
int edit(Rate rate) throws Exception;
List<Rate> selectByStatus(Rate rate) throws Exception;
void softDelete(Integer rateId) throws Exception;

Loading…
Cancel
Save