| | |
| | | import com.nq.pojo.reponse.OrderEChoReponse; |
| | | import com.nq.service.IEchoServices; |
| | | import com.nq.service.IUserService; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | |
| | | @Slf4j |
| | | @Service |
| | | public class EchoServices implements IEchoServices { |
| | | |
| | |
| | | |
| | | @Override |
| | | public List<EChoBean> queryList() { |
| | | return eChoMapper.selectQueryAll(); |
| | | return eChoMapper.selectList(new LambdaQueryWrapper<EChoBean>()); |
| | | } |
| | | |
| | | @Override |
| | | public boolean buyECho(String eId, Integer money, HttpServletRequest request) { |
| | | public boolean buyECho(String eId, BigDecimal money, HttpServletRequest request) { |
| | | |
| | | User user = this.iUserService.getCurrentRefreshUser(request); |
| | | |
| | |
| | | .eq(UserAssets::getUserId, orderEchoBean.getUserId()) |
| | | .eq(UserAssets::getAccectType, "IN") |
| | | ); |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().subtract(new BigDecimal(money))); |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().subtract(money)); |
| | | userAssetsMapper.updateById(userAssets); |
| | | return orderEchoMapper.insert(orderEchoBean) >= 1; |
| | | } |
| | |
| | | queryWrapper.eq("state", 1); |
| | | queryWrapper.lt("end_time", System.currentTimeMillis()); |
| | | List<OrderEchoBean> list = orderEchoMapper.selectList(queryWrapper); |
| | | log.info("基金定时任务执行数量:{}",list.size()); |
| | | for (OrderEchoBean orderEchoBean : list) { |
| | | BigDecimal money = new BigDecimal(orderEchoBean.getMoney()); // 本金 |
| | | BigDecimal rate = new BigDecimal(orderEchoBean.getReturnOfRate()); // 收益率 |