package project.blockchain.internal;
|
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.security.providers.encoding.PasswordEncoder;
|
|
import kernel.bo.RecordObjectMapper;
|
import kernel.exception.BusinessException;
|
import kernel.util.StringUtils;
|
import kernel.web.ApplicationUtil;
|
import kernel.web.Page;
|
import kernel.web.PagedQueryDao;
|
import project.Constants;
|
import project.blockchain.AdminRechargeBlockchainOrderService;
|
import project.blockchain.RechargeBlockchain;
|
import project.blockchain.RechargeBlockchainService;
|
import project.log.Log;
|
import project.log.LogService;
|
import project.party.recom.UserRecomService;
|
import project.tip.TipService;
|
import project.wallet.WalletLog;
|
import project.wallet.WalletLogService;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
public class AdminRechargeBlockchainOrderServiceImpl implements AdminRechargeBlockchainOrderService {
|
private JdbcTemplate jdbcTemplate;
|
private PagedQueryDao pagedQueryDao;
|
private UserRecomService userRecomService;
|
private PasswordEncoder passwordEncoder;
|
private RechargeBlockchainService rechargeBlockchainService;
|
|
private LogService logService;
|
private WalletLogService walletLogService;
|
private SecUserService secUserService;
|
private TipService tipService;
|
|
@Override
|
public Page pagedQuery(int pageNo, int pageSize, String name_para, Integer state_para, String loginPartyId,
|
String orderNo, String rolename_para, String startTime, String endTime) {
|
StringBuffer queryString = new StringBuffer();
|
queryString.append("SELECT");
|
queryString.append(" party.USERNAME username ,party.ROLENAME rolename,party.USERCODE usercode, party.REMARKS remarks,");
|
queryString.append(" recharge.UUID id,recharge.ORDER_NO order_no,recharge.BLOCKCHAIN_NAME blockchanin_name, "
|
+ "recharge.IMG img, recharge.TX hash, recharge.CREATED created, recharge.DESCRIPTION description, ");
|
|
queryString.append(" recharge.COIN coin,recharge.REVIEWTIME reviewTime, "
|
+ "recharge.SUCCEEDED succeeded,recharge.CHANNEL_AMOUNT channel_amount, "
|
+ "recharge.ADDRESS address,recharge.CHANNEL_ADDRESS channel_address, party_parent.USERNAME username_parent ");
|
queryString.append(" FROM ");
|
queryString.append(" T_RECHARGE_BLOCKCHAIN_ORDER recharge "
|
+ "LEFT JOIN PAT_PARTY party ON recharge.PARTY_ID = party.UUID "
|
+ " LEFT JOIN PAT_USER_RECOM user ON user.PARTY_ID = party.UUID "
|
+ " LEFT JOIN PAT_PARTY party_parent ON user.RECO_ID = party_parent.UUID " + " ");
|
queryString.append(" WHERE 1=1 ");
|
|
Map<String, Object> parameters = new HashMap<String, Object>();
|
|
if (!StringUtils.isNullOrEmpty(loginPartyId)) {
|
List children = this.userRecomService.findChildren(loginPartyId);
|
if (children.size() == 0) {
|
// return Page.EMPTY_PAGE;
|
return new Page();
|
}
|
queryString.append(" and recharge.PARTY_ID in (:children) ");
|
parameters.put("children", children);
|
}
|
|
// if (!StringUtils.isNullOrEmpty(name_para)) {
|
// queryString.append(" and (party.USERNAME like :name_para or party.USERCODE =:usercode) ");
|
// parameters.put("name_para", "%" + name_para + "%");
|
// parameters.put("usercode", name_para);
|
//
|
// }
|
if (!StringUtils.isNullOrEmpty(name_para)) {
|
queryString.append("AND (party.USERNAME like:username OR party.USERCODE like:username ) ");
|
parameters.put("username", "%" + name_para + "%");
|
}
|
if (!StringUtils.isNullOrEmpty(rolename_para)) {
|
queryString.append(" and party.ROLENAME =:rolename");
|
parameters.put("rolename", rolename_para);
|
}
|
if (!StringUtils.isNullOrEmpty(orderNo)) {
|
queryString.append(" and recharge.ORDER_NO = :orderNo ");
|
parameters.put("orderNo", orderNo);
|
|
}
|
if (state_para != null) {
|
queryString.append(" and recharge.SUCCEEDED = :succeeded ");
|
parameters.put("succeeded", state_para);
|
|
}
|
|
if (!StringUtils.isNullOrEmpty(startTime)) {
|
queryString.append(" AND DATE(recharge.CREATED) >= DATE('" + startTime + " 00:00:00') ");
|
// parameters.put("startTime",DateUtils.toDate(startTime));
|
}
|
if (!StringUtils.isNullOrEmpty(endTime)) {
|
queryString.append(" AND DATE(recharge.CREATED) <= DATE('" + endTime + " 23:59:59') ");
|
// parameters.put("endTime", DateUtils.toDate(endTime));
|
}
|
|
queryString.append(" order by recharge.CREATED desc ");
|
Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
|
|
return page;
|
}
|
|
@Override
|
public void saveSucceeded(String id, String safeword, String operator_username, double success_amount) {
|
SecUser sec = this.secUserService.findUserByLoginName(operator_username);
|
String sysSafeword = sec.getSafeword();
|
|
String safeword_md5 = passwordEncoder.encodePassword(safeword, operator_username);
|
if (!safeword_md5.equals(sysSafeword)) {
|
throw new BusinessException("资金密码错误");
|
}
|
|
rechargeBlockchainService.saveSucceeded(id, operator_username, success_amount);
|
}
|
|
public RechargeBlockchain get(String id) {
|
List<RechargeBlockchain> list = jdbcTemplate.query("SELECT * FROM T_RECHARGE_BLOCKCHAIN_ORDER WHERE UUID=?",
|
RecordObjectMapper.newInstance(RechargeBlockchain.class), id);
|
if (null != list && list.size() > 0) {
|
return list.get(0);
|
}
|
return null;
|
}
|
|
@Override
|
public void saveReject(String id, String failure_msg, String userName, String partyId) {
|
RechargeBlockchain recharge = this.get(id);
|
|
// 通过后不可驳回
|
if (recharge.getSucceeded() == 2 || recharge.getSucceeded() == 1) {
|
return;
|
}
|
Date date = new Date();
|
recharge.setReviewTime(date);
|
|
recharge.setSucceeded(2);
|
recharge.setDescription(failure_msg);
|
this.updateRechargeBlockchain(recharge);
|
|
WalletLog walletLog = walletLogService.find(Constants.MONEYLOG_CATEGORY_RECHARGE, recharge.getOrder_no());
|
walletLog.setStatus(recharge.getSucceeded());
|
walletLogService.update(walletLog);
|
|
SecUser sec = this.secUserService.findUserByPartyId(recharge.getPartyId());
|
|
Log log = new Log();
|
log.setCategory(Constants.LOG_CATEGORY_OPERATION);
|
log.setExtra(recharge.getOrder_no());
|
log.setUsername(sec.getUsername());
|
log.setOperator(userName);
|
log.setPartyId(partyId);
|
log.setLog("管理员驳回一笔充值订单。充值订单号[" + recharge.getOrder_no() + "]，驳回理由[" + recharge.getDescription() + "]。");
|
|
logService.saveSync(log);
|
tipService.deleteTip(id);
|
}
|
|
@Override
|
public void saveRejectRemark(String id, String failure_msg, String userName, String partyId) {
|
RechargeBlockchain recharge = this.get(id);
|
String before_failure_msg = recharge.getDescription();
|
|
recharge.setDescription(failure_msg);
|
this.updateRechargeBlockchain(recharge);
|
|
SecUser sec = this.secUserService.findUserByPartyId(recharge.getPartyId());
|
|
Log log = new Log();
|
log.setCategory(Constants.LOG_CATEGORY_OPERATION);
|
log.setExtra(recharge.getOrder_no());
|
log.setUsername(sec.getUsername());
|
log.setOperator(userName);
|
log.setPartyId(partyId);
|
log.setLog("管理员修改备注信息。充值订单号[" + recharge.getOrder_no() + "]，修改前备注信息[" + before_failure_msg + "]，修改后备注信息["
|
+ recharge.getDescription() + "]。");
|
|
logService.saveSync(log);
|
}
|
|
@Override
|
public void saveRechargeImg(String id, String img, String safeword, String userName, String partyId) {
|
SecUser sec = this.secUserService.findUserByLoginName(userName);
|
String sysSafeword = sec.getSafeword();
|
|
String safeword_md5 = passwordEncoder.encodePassword(safeword, userName);
|
if (!safeword_md5.equals(sysSafeword)) {
|
throw new BusinessException("资金密码错误");
|
}
|
|
RechargeBlockchain recharge = this.get(id);
|
String before_img = "为空";
|
if (!StringUtils.isEmptyString(recharge.getImg())) {
|
before_img = recharge.getImg();
|
}
|
|
recharge.setImg(img);
|
this.updateRechargeBlockchain(recharge);
|
|
SecUser secUser = secUserService.findUserByPartyId(recharge.getPartyId());
|
|
Log log = new Log();
|
log.setCategory(Constants.LOG_CATEGORY_OPERATION);
|
log.setExtra(recharge.getOrder_no());
|
log.setUsername(secUser.getUsername());
|
log.setOperator(userName);
|
log.setPartyId(secUser.getPartyId());
|
log.setLog("管理员修改用户充值订单上传截图信息。充值订单号[" + recharge.getOrder_no() + "]，修改前图片[" + before_img + "]，修改后图片["
|
+ recharge.getImg() + "]。");
|
|
logService.saveSync(log);
|
}
|
|
@Override
|
public void callback(String timestamp, String nonce, String sign, String body) {
|
rechargeBlockchainService.callback(timestamp, nonce, sign,body);
|
}
|
|
public void updateRechargeBlockchain(RechargeBlockchain recharge) {
|
Object[] jdbcParams = ApplicationUtil.getUpdateStatement(recharge, "WHERE UUID=?", new Object[] {recharge.getId()});
|
String updateUserSql = (String)jdbcParams[0];
|
Object[] sqlParameters = (Object[])jdbcParams[1];
|
jdbcTemplate.update(updateUserSql, sqlParameters);
|
}
|
|
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
|
this.jdbcTemplate = jdbcTemplate;
|
}
|
|
public void setPagedQueryDao(PagedQueryDao pagedQueryDao) {
|
this.pagedQueryDao = pagedQueryDao;
|
}
|
|
public void setUserRecomService(UserRecomService userRecomService) {
|
this.userRecomService = userRecomService;
|
}
|
|
public void setRechargeBlockchainService(RechargeBlockchainService rechargeBlockchainService) {
|
this.rechargeBlockchainService = rechargeBlockchainService;
|
}
|
|
public void setLogService(LogService logService) {
|
this.logService = logService;
|
}
|
|
public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
|
this.passwordEncoder = passwordEncoder;
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
|
public void setWalletLogService(WalletLogService walletLogService) {
|
this.walletLogService = walletLogService;
|
}
|
|
public void setTipService(TipService tipService) {
|
this.tipService = tipService;
|
}
|
|
}
|
