package com.nq.service.impl; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.nq.common.ServerResponse; import com.nq.dao.*; import com.nq.pojo.*; import com.nq.service.IFundsApplyService; import com.nq.service.IFundsSettingService; import com.nq.service.IUserService; import com.nq.utils.DateTimeUtil; import com.nq.utils.KeyUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; /** * 配资申请 * @author lr * @date 2020/07/24 */ @Service("IFundsApplyService") public class FundsApplyServiceImpl implements IFundsApplyService { private static final Logger log = LoggerFactory.getLogger(FundsApplyServiceImpl.class); @Resource private FundsApplyMapper fundsApplyMapper; @Autowired UserMapper userMapper; @Autowired UserCashDetailMapper userCashDetailMapper; @Autowired FundsTradingAccountMapper fundsTradingAccountMapper; @Autowired IUserService iUserService; @Autowired IFundsSettingService iFundsSettingService; @Transactional public ServerResponse insert(FundsApply model, HttpServletRequest request) throws Exception { int ret = 0; if (model == null) { return ServerResponse.createBySuccessMsg("操作异常，请稍后重试！"); } User user = this.iUserService.getCurrentRefreshUser(request); if(user == null){ return ServerResponse.createBySuccessMsg("请登录后操作"); } BigDecimal user_enable_amt = user.getEnableAmt(); //支付金额=保证金+管理费 BigDecimal pay_amount = model.getMargin().add(model.getManageFee()); int compareUserAmtInt = user_enable_amt.compareTo(pay_amount); log.info("用户可用金额 = {} 实际购买金额 = {} 比较结果 = {} ", user_enable_amt, pay_amount, compareUserAmtInt); if (compareUserAmtInt == -1) { return ServerResponse.createByErrorMsg("申请失败，可用金额小于" + pay_amount + "元"); } //自动生成订单编号 model.setOrderNumber(KeyUtils.getUniqueKey()); model.setPayAmount(pay_amount); ret = fundsApplyMapper.insert(model); if(ret>0){ //修改用户可用余额= 当前余额-支付金额 BigDecimal reckon_enable = user_enable_amt.subtract(pay_amount); user.setEnableAmt(reckon_enable); int updateUserCount = this.userMapper.updateByPrimaryKeySelective(user); if (updateUserCount > 0) { log.info("【用户交易下单】修改用户金额成功"); UserCashDetail ucd = new UserCashDetail(); ucd.setPositionId(model.getId()); ucd.setAgentId(user.getAgentId()); ucd.setAgentName(user.getAgentName()); ucd.setUserId(user.getId()); ucd.setUserName(user.getRealName()); ucd.setDeType("配资冻结"); ucd.setDeAmt(model.getPayAmount().multiply(new BigDecimal("-1"))); ucd.setDeSummary("申请按天配资:" + model.getOrderNumber() + "，冻结金额：" + model.getPayAmount().multiply(new BigDecimal("-1")) ); ucd.setAddTime(new Date()); ucd.setIsRead(Integer.valueOf(0)); int insertSxfCount = this.userCashDetailMapper.insert(ucd); if (insertSxfCount > 0) { log.info("【按天配资】申请成功"); } } else { log.error("【按天配资】修改用户金额出错"); throw new Exception("【按天配资】修改用户金额出错"); } return ServerResponse.createBySuccessMsg("申请成功！"); } else { return ServerResponse.createBySuccessMsg("申请失败，请稍后重试！"); } } @Override public int update(FundsApply model) { int ret = fundsApplyMapper.update(model); return ret>0 ? ret: 0; } /** * 配资申请-保存 */ @Override public ServerResponse save(FundsApply model) { int ret = 0; if(model!=null && model.getId()>0){ ret = fundsApplyMapper.update(model); } else{ ret = fundsApplyMapper.insert(model); } if(ret>0){ return ServerResponse.createBySuccessMsg("操作成功"); } return ServerResponse.createByErrorMsg("操作失败"); } /** * 配资申请-审核 */ /* */ @Transactional /* */ public ServerResponse audit(FundsApply model, HttpServletRequest request) throws Exception { /* 135 */ FundsApply fundsApply = this.fundsApplyMapper.load(model.getId().intValue()); /* 136 */ int ret = 0; /* 137 */ if (model != null && model.getId().intValue() > 0) { /* 138 */ User user = this.userMapper.selectByPrimaryKey(fundsApply.getUserId()); /* */ /* 140 */ if (model.getStatus().intValue() == 1) { /* 141 */ SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); /* 142 */ String begtime = df.format(new Date()).split(" ")[0] + " 0:00:00"; /* 143 */ Date date = DateTimeUtil.strToDate(begtime); /* 144 */ Date begDate = DateTimeUtil.addDay(date, 1); /* 145 */ model.setBeginTime(begDate); /* 146 */ String endtime = df.format(new Date()).split(" ")[0] + " 23:59:59"; /* 147 */ Date endDate = DateTimeUtil.strToDate(endtime); /* 148 */ endDate = DateTimeUtil.addDay(endDate, model.getTradersCycle().intValue() + 1); /* 149 */ model.setEndTime(endDate); /* 150 */ model.setEnabledTradingAmount(fundsApply.getTotalTradingAmount()); /* 151 */ FundsSetting fundsSetting = this.iFundsSettingService.getFundsSetting(); /* */ /* 153 */ BigDecimal lineUnwind = fundsApply.getMargin().multiply(fundsSetting.getDaysUnwind()).add(fundsApply.getFundsAmount()).setScale(2, 4); /* 154 */ model.setLineUnwind(lineUnwind); /* */ /* 156 */ BigDecimal lineWarning = fundsApply.getMargin().multiply(fundsSetting.getDaysWarning()).add(fundsApply.getFundsAmount()).setScale(2, 4); /* 157 */ model.setLineWarning(lineWarning); /* */ } /* 159 */ model.setAuditTime(DateTimeUtil.getCurrentDate()); /* 160 */ ret = this.fundsApplyMapper.update(model); /* 161 */ if (ret > 0) { /* 162 */ BigDecimal user_enable_amt = user.getEnableAmt(); /* */ /* 164 */ if (model.getStatus().intValue() == 1) { /* 165 */ BigDecimal user_all_amt = user.getUserAmt(); /* */ /* 167 */ BigDecimal reckon_all = user_all_amt.subtract(fundsApply.getManageFee()); /* */ /* 169 */ BigDecimal tradingAmount = user.getTradingAmount().add(fundsApply.getTotalTradingAmount()); /* 170 */ log.info("【配资审核通过】用户平总资金 = {} , 可用资金 = {} , 总操盘资金 = {}", new Object[] { reckon_all, user_enable_amt, tradingAmount }); /* 171 */ user.setUserAmt(reckon_all); /* 172 */ user.setTradingAmount(tradingAmount); /* 173 */ int updateUserCount = this.userMapper.updateByPrimaryKeySelective(user); /* 174 */ if (updateUserCount > 0) { /* 175 */ log.info("【配资审核通过】修改用户金额成功"); /* */ /* 177 */ FundsTradingAccount fundsTradingAccount = this.fundsTradingAccountMapper.getAccountByNumber(model.getSubaccountNumber()); /* 178 */ if (fundsTradingAccount != null) { /* 179 */ fundsTradingAccount.setStatus(Integer.valueOf(1)); /* 180 */ this.fundsTradingAccountMapper.update(fundsTradingAccount); /* */ } /* */ /* 183 */ UserCashDetail ucd = new UserCashDetail(); /* 184 */ ucd.setPositionId(fundsApply.getId()); /* 185 */ ucd.setAgentId(user.getAgentId()); /* 186 */ ucd.setAgentName(user.getAgentName()); /* 187 */ ucd.setUserId(user.getId()); /* 188 */ ucd.setUserName(user.getRealName()); /* 189 */ ucd.setDeType("配资审核通过"); /* 190 */ ucd.setDeAmt(fundsApply.getPayAmount()); /* 191 */ ucd.setDeSummary("申请按天配资:" + fundsApply.getOrderNumber() + "，配资审核通过，解冻保证金到配资账户：" + fundsApply.getPayAmount()); /* 192 */ ucd.setAddTime(new Date()); /* 193 */ ucd.setIsRead(Integer.valueOf(0)); /* 194 */ int insertSxfCount = this.userCashDetailMapper.insert(ucd); /* 195 */ if (insertSxfCount > 0) { /* 196 */ log.info("【配资审核通过】申请成功"); /* */ } /* */ } else { /* 199 */ log.error("【配资审核通过】修改用户金额出错"); /* 200 */ throw new Exception("【配资审核通过】修改用户金额出错"); /* */ } /* */ /* */ } else { /* */ /* 205 */ BigDecimal reckon_enable = user_enable_amt.add(fundsApply.getPayAmount()); /* 206 */ user.setEnableAmt(reckon_enable); /* 207 */ int updateUserCount = this.userMapper.updateByPrimaryKeySelective(user); /* 208 */ if (updateUserCount > 0) { /* 209 */ log.info("【配资审核未通过】修改用户金额成功"); /* 210 */ UserCashDetail ucd = new UserCashDetail(); /* 211 */ ucd.setPositionId(fundsApply.getId()); /* 212 */ ucd.setAgentId(user.getAgentId()); /* 213 */ ucd.setAgentName(user.getAgentName()); /* 214 */ ucd.setUserId(user.getId()); /* 215 */ ucd.setUserName(user.getRealName()); /* 216 */ ucd.setDeType("配资审核未通过"); /* 217 */ ucd.setDeAmt(fundsApply.getPayAmount()); /* 218 */ ucd.setDeSummary("申请按天配资:" + fundsApply.getOrderNumber() + "，配资审核未通过，解冻保证金到余额：" + fundsApply.getPayAmount() + "，原因：" + model.getAuditOpinion()); /* 219 */ ucd.setAddTime(new Date()); /* 220 */ ucd.setIsRead(Integer.valueOf(0)); /* 221 */ int insertSxfCount = this.userCashDetailMapper.insert(ucd); /* 222 */ if (insertSxfCount > 0) { /* 223 */ log.info("【按天配资】申请成功"); /* */ } /* */ } else { /* 226 */ log.error("【按天配资】修改用户金额出错"); /* 227 */ throw new Exception("【按天配资】修改用户金额出错"); /* */ } /* */ } /* */ /* 231 */ log.info("配资申请-审核 = {} 实际购买金额 = {} 比较结果 = {} ", Integer.valueOf(0)); /* */ } /* */ } /* 234 */ if (ret > 0) { /* 235 */ return ServerResponse.createBySuccessMsg("操作成功"); /* */ } /* 237 */ return ServerResponse.createByErrorMsg("操作失败"); /* */ } /*配资申请-查询列表*/ @Override public ServerResponse getList(int pageNum, int pageSize, String keyword, Integer status, HttpServletRequest request){ PageHelper.startPage(pageNum, pageSize); List listData = this.fundsApplyMapper.pageList(pageNum, pageSize, keyword, status); PageInfo pageInfo = new PageInfo(listData); pageInfo.setList(listData); return ServerResponse.createBySuccess(pageInfo); } /*配资申请-查询详情*/ @Override public ServerResponse getDetail(int id) { return ServerResponse.createBySuccess(this.fundsApplyMapper.load(id)); } /** * 配资申请-用户配资列表 */ @Override public ServerResponse getUserApplyList(int pageNum, int pageSize, int userId, HttpServletRequest request){ User user = this.iUserService.getCurrentRefreshUser(request); if (user == null){ return ServerResponse.createBySuccessMsg("請先登錄"); } PageHelper.startPage(pageNum, pageSize); List listData = this.fundsApplyMapper.getUserApplyList(pageNum, pageSize, user.getId()); PageInfo pageInfo = new PageInfo(listData); pageInfo.setList(listData); return ServerResponse.createBySuccess(pageInfo); } /** * 配资申请-用户操盘中子账户 */ @Override public ServerResponse getUserEnabledSubaccount(HttpServletRequest request){ User user = this.iUserService.getCurrentRefreshUser(request); List listData = this.fundsApplyMapper.getUserEnabledSubaccount(user.getId()); PageInfo pageInfo = new PageInfo(); pageInfo.setList(listData); return ServerResponse.createBySuccess(pageInfo); } }