package com.yami.trading.service.miner.service.impl;
|
|
import java.util.List;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.yami.trading.service.miner.service.AdminMinerOrderService;
|
import com.yami.trading.service.miner.service.MinerOrderService;
|
import com.yami.trading.service.miner.service.MinerService;
|
import com.yami.trading.bean.miner.Miner;
|
import com.yami.trading.bean.miner.MinerOrder;
|
import com.yami.trading.bean.model.User;
|
import com.yami.trading.common.constants.Constants;
|
import com.yami.trading.common.exception.BusinessException;
|
import com.yami.trading.common.util.DateUtil;
|
import com.yami.trading.common.util.RandomUtil;
|
import com.yami.trading.common.util.StringUtils;
|
import com.yami.trading.dao.miner.MinerOrderMapper;
|
import com.yami.trading.service.user.UserRecomService;
|
import com.yami.trading.service.user.UserService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
@Service
|
@Transactional
|
public class AdminMinerOrderServiceImpl extends ServiceImpl<MinerOrderMapper, MinerOrder> implements AdminMinerOrderService {
|
// protected PagedQueryDao pagedQueryDao;
|
@Autowired
|
protected UserRecomService userRecomService;
|
@Autowired
|
protected MinerOrderService minerOrderService;
|
@Autowired
|
protected MinerService minerService;
|
@Autowired
|
protected UserService partyService;
|
|
public Page pagedQuery(int pageNo, int pageSize, String name_para, String miner_para, String status_para,
|
List<String> children, String orderNo, String rolename_para) {
|
|
// Map<String, Object> parameters = new HashMap<>();
|
// StringBuffer queryString = new StringBuffer(
|
// " SELECT minerOrder.UUID id,minerOrder.ORDER_NO order_no ,minerOrder.MINER_ID minerId , ");
|
// queryString.append(" minerOrder.AMOUNT amount,minerOrder.CREATE_TIME create_time,minerOrder.BASE_COMPUTE_AMOUNT base_compute_amount, ");
|
// queryString.append(" minerOrder.EARN_TIME earn_time,minerOrder.STOP_TIME stop_time,minerOrder.PROFIT profit, ");
|
// queryString.append(" minerOrder.STATE state,minerOrder.CLOSE_TIME close_time,minerOrder.DEFAULT_MONEY default_money, ");
|
// queryString.append(" party.user_name username,party.user_code usercode,party.role_name rolename, ");
|
// queryString.append(" miner.NAME miner_name,miner.NAME_EN miner_name_en ");
|
// queryString.append(" FROM T_MINER_ORDER minerOrder ");
|
// queryString.append(" LEFT JOIN tz_user party ON minerOrder.party_id = party.user_id ");
|
// queryString.append(" LEFT JOIN T_MINER miner ON miner.UUID = minerOrder.MINER_ID ");
|
//
|
// queryString.append(" WHERE 1 = 1 ");
|
// if (!StringUtils.isNullOrEmpty(partyId)) {
|
// List children = this.userRecomService.findChildren(partyId);
|
// if (children.size() == 0) {
|
// return new Page();
|
// }
|
// queryString.append(" and minerOrder.PARTY_ID in (:children) ");
|
// parameters.put("children", children);
|
// }
|
|
|
// if (!StringUtils.isNullOrEmpty(miner_para)) {
|
// queryString.append(
|
// " and miner.UUID=:miner_para ");
|
// parameters.put("miner_para", miner_para);
|
// }
|
|
// if (!StringUtils.isNullOrEmpty(name_para)) {
|
// queryString.append("AND (party.user_name like:username OR party.user_code like:username ) ");
|
// parameters.put("username", "%" + name_para + "%");
|
// }
|
|
// if (!StringUtils.isNullOrEmpty(status_para)) {
|
// String status = status_para;
|
// if("0".equals(status)) {
|
// status ="'0','2'";
|
// }else {
|
// status ="'"+status+"'";
|
// }
|
// queryString.append(" and minerOrder.STATE in ("+status+") ");
|
// }
|
// if (!StringUtils.isNullOrEmpty(orderNo)) {
|
// queryString.append(" and minerOrder.ORDER_NO = :orderNo ");
|
// parameters.put("orderNo", orderNo);
|
//
|
// }
|
// if (!StringUtils.isNullOrEmpty(rolename_para)) {
|
// queryString.append(" and party.role_name =:rolename");
|
// parameters.put("rolename", rolename_para);
|
// }
|
// if("0".equals(status_para)) {
|
// queryString.append(" order by minerOrder.CLOSE_TIME desc ");
|
// }else {
|
// queryString.append(" order by minerOrder.CREATE_TIME desc ");
|
// }
|
System.out.println("****************************************");
|
|
String status = null;
|
if (!StringUtils.isNullOrEmpty(status_para)) {
|
// status = status_para;
|
if("0".equals(status_para)) {
|
status ="0";
|
}else if("1".equals(status_para)){
|
status ="1";
|
}else if("3".equals(status_para)){
|
status =null;
|
}
|
}
|
|
Page page = new Page(pageNo,pageSize);
|
this.baseMapper.pagedQueryAdmin(page,children,miner_para,status,orderNo,rolename_para,name_para);
|
|
|
// Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
|
// return page;
|
return page;
|
}
|
|
public void addOrder(String uid,double amount,String minerId,String operator_username) {
|
Miner miner = this.minerService.findById(minerId);
|
if(null == miner) {
|
throw new BusinessException("矿机不存在");
|
}
|
|
User party = partyService.findUserByUserCode(uid);
|
if(null==party) {
|
throw new BusinessException("购买用户不存在");
|
}else {
|
if(!(Constants.SECURITY_ROLE_MEMBER.equals(party.getRoleName())
|
||Constants.SECURITY_ROLE_GUEST.equals(party.getRoleName()))) {
|
throw new BusinessException("该用户并非正式用户或演示用户，无法购买");
|
}
|
}
|
|
MinerOrder order = new MinerOrder();
|
order.setPartyId(party.getUserId());
|
order.setMinerId(minerId);
|
order.setOrder_no(DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8));
|
order.setAmount(amount);
|
order.setState("1");
|
this.minerOrderService.saveCreateByManage(order, operator_username);
|
}
|
|
|
public void setUserRecomService(UserRecomService userRecomService) {
|
this.userRecomService = userRecomService;
|
}
|
|
public void setMinerOrderService(MinerOrderService minerOrderService) {
|
this.minerOrderService = minerOrderService;
|
}
|
|
public void setMinerService(MinerService minerService) {
|
this.minerService = minerService;
|
}
|
|
}
|
