package project.web.admin;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import kernel.web.ResultObject;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
import org.springframework.web.servlet.ModelAndView;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.StringUtils;
|
import kernel.web.Page;
|
import kernel.web.PageActionSupport;
|
import project.Constants;
|
import project.blockchain.AdminChannelBlockchainService;
|
import project.blockchain.ChannelBlockchain;
|
import project.blockchain.ChannelBlockchainService;
|
import project.blockchain.QRProducerService;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* 区块链充值地址维护
|
*/
|
@RestController
|
public class AdminChannelBlockchainController extends PageActionSupport {
|
|
@Autowired
|
private QRProducerService qRProducerService;
|
|
@Autowired
|
private ChannelBlockchainService channelBlockchainService;
|
|
@Autowired
|
private AdminChannelBlockchainService adminChannelBlockchainService;
|
|
private final String action = "normal/adminChannelBlockchainAction!";
|
|
private Logger logger = LoggerFactory.getLogger(AdminChannelBlockchainController.class);
|
|
/**
|
* 获取 区块链充值地址 列表
|
*
|
* name_para 链名称
|
* coin_para 币种名称
|
*/
|
@RequestMapping(action + "list.action")
|
public ModelAndView list(HttpServletRequest request) {
|
String pageNoStr = request.getParameter("pageNo");
|
String message = request.getParameter("message");
|
String error = request.getParameter("error");
|
String name_para = request.getParameter("name_para");
|
String coin_para = request.getParameter("coin_para");
|
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("channel_blockchain_list");
|
|
int pageNo=1;
|
Page page=null;
|
int pageSize=300;
|
try {
|
pageNo=checkAndSetPageNo(pageNoStr);
|
page = this.adminChannelBlockchainService.pagedQuery(pageNo, pageSize, name_para, coin_para);
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
modelAndView.addObject("error", "[ERROR] " + t.getMessage());
|
return modelAndView;
|
}
|
|
modelAndView.addObject("pageNo", pageNo);
|
modelAndView.addObject("pageSize", pageSize);
|
modelAndView.addObject("page", page);
|
modelAndView.addObject("message", message);
|
modelAndView.addObject("error", error);
|
modelAndView.addObject("name_para", name_para);
|
modelAndView.addObject("coin_para", coin_para);
|
return modelAndView;
|
}
|
|
@RequestMapping(action + "appList")
|
public Object apiList(HttpServletRequest request) {
|
String pageNoStr = request.getParameter("pageNo");
|
String message = request.getParameter("message");
|
String error = request.getParameter("error");
|
String name_para = request.getParameter("name_para");
|
String coin_para = request.getParameter("coin_para");
|
|
ResultObject resultObject = new ResultObject();
|
|
int pageNo=1;
|
Page page=null;
|
int pageSize=300;
|
try {
|
pageNo=checkAndSetPageNo(pageNoStr);
|
page = this.adminChannelBlockchainService.pagedQuery(pageNo, pageSize, name_para, coin_para);
|
} catch (BusinessException e) {
|
logger.error(" error ", e);
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
return resultObject;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
resultObject.setCode("1");
|
resultObject.setMsg( t.getMessage());
|
return resultObject;
|
}
|
Map<String,Object> map = new HashMap<>();
|
map.put("pageNo", pageNo);
|
map.put("pageSize", pageSize);
|
map.put("page", page);
|
map.put("message", message);
|
map.put("error", error);
|
map.put("name_para", name_para);
|
map.put("coin_para", coin_para);
|
resultObject.setData(map);
|
return resultObject;
|
}
|
|
/**
|
* 新增 区块链充值地址 页面
|
*/
|
@RequestMapping(action + "toAdd.action")
|
public ModelAndView toAdd(HttpServletRequest request) {
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.addObject("coins_map", Constants.BLOCKCHAIN_COINS);
|
modelAndView.addObject("blockchain_name_map", Constants.BLOCKCHAIN_COINS_NAME);
|
modelAndView.setViewName("channel_blockchain_add");
|
return modelAndView;
|
}
|
|
/**
|
* 新增 区块链充值地址
|
*
|
* blockchain_name 链名称
|
* coin 币种 BTC USDT ETH
|
* address 充值地址
|
* img 充值地址二维码
|
*/
|
//@RequestMapping(action + "add.action")
|
public ModelAndView add(HttpServletRequest request) {
|
String blockchain_name = request.getParameter("blockchain_name");
|
String coin = request.getParameter("coin");
|
String address = request.getParameter("address");
|
String img = request.getParameter("img");
|
String safeword = request.getParameter("safeword");
|
String email_code = request.getParameter("email_code");
|
String super_google_auth_code = request.getParameter("super_google_auth_code");
|
|
ModelAndView modelAndView = new ModelAndView();
|
|
try {
|
String error = this.verif(blockchain_name, coin, address, img);
|
if (!StringUtils.isNullOrEmpty(error)) {
|
throw new BusinessException(error);
|
}
|
|
ChannelBlockchain channelBlockchain = new ChannelBlockchain();
|
channelBlockchain.setBlockchain_name(blockchain_name);
|
channelBlockchain.setCoin(coin);
|
channelBlockchain.setAddress(address);
|
img = this.qRProducerService.generate(address);
|
channelBlockchain.setImg(img);
|
|
this.channelBlockchainService.save(channelBlockchain, this.getUsername_login(), safeword,
|
this.getIp(getRequest()), email_code, super_google_auth_code);
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
modelAndView.addObject("coins_map", Constants.BLOCKCHAIN_COINS);
|
modelAndView.addObject("blockchain_name_map", Constants.BLOCKCHAIN_COINS_NAME);
|
modelAndView.addObject("blockchain_name", blockchain_name);
|
modelAndView.addObject("coin", coin);
|
modelAndView.addObject("address", address);
|
modelAndView.addObject("img", img);
|
modelAndView.setViewName("channel_blockchain_add");
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
modelAndView.addObject("error", "[ERROR] " + t.getMessage());
|
modelAndView.addObject("coins_map", Constants.BLOCKCHAIN_COINS);
|
modelAndView.addObject("blockchain_name_map", Constants.BLOCKCHAIN_COINS_NAME);
|
modelAndView.addObject("blockchain_name", blockchain_name);
|
modelAndView.addObject("coin", coin);
|
modelAndView.addObject("address", address);
|
modelAndView.addObject("img", img);
|
modelAndView.setViewName("channel_blockchain_add");
|
return modelAndView;
|
}
|
|
modelAndView.addObject("message", "操作成功");
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
return modelAndView;
|
}
|
|
/**
|
* 修改 区块链充值地址 页面
|
*/
|
@RequestMapping(action + "toUpdate.action")
|
public ModelAndView toUpdate(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
ModelAndView modelAndView = new ModelAndView();
|
|
try {
|
ChannelBlockchain channelBlockchain = this.channelBlockchainService.findById(id);
|
modelAndView.addObject("id", id);
|
modelAndView.addObject("address", channelBlockchain.getAddress());
|
modelAndView.addObject("coin", channelBlockchain.getCoin());
|
modelAndView.addObject("blockchain_name", channelBlockchain.getBlockchain_name());
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
modelAndView.addObject("error", "[ERROR] " + t.getMessage());
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
return modelAndView;
|
}
|
|
modelAndView.setViewName("channel_blockchain_update");
|
return modelAndView;
|
}
|
|
/**
|
* 修改 区块链充值地址
|
*
|
* blockchain_name 链名称
|
* coin 币种 BTC USDT ETH
|
* address 充值地址
|
* img 充值地址二维码
|
*/
|
@RequestMapping(action + "update.action")
|
public ModelAndView update(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
String blockchain_name = request.getParameter("blockchain_name");
|
String coin = request.getParameter("coin");
|
String address = request.getParameter("address");
|
String img = request.getParameter("img");
|
String safeword = request.getParameter("safeword");
|
String email_code = request.getParameter("email_code");
|
String super_google_auth_code = request.getParameter("super_google_auth_code");
|
|
ModelAndView modelAndView = new ModelAndView();
|
|
try {
|
ChannelBlockchain channelBlockchain = this.channelBlockchainService.findById(id);
|
ChannelBlockchain old = new ChannelBlockchain();
|
BeanUtils.copyProperties(channelBlockchain, old);
|
|
String error = this.verif(blockchain_name, coin, address, img);
|
if (!StringUtils.isNullOrEmpty(error)) {
|
throw new BusinessException(error);
|
}
|
|
channelBlockchain.setBlockchain_name(blockchain_name);
|
channelBlockchain.setCoin(coin);
|
if (!address.equals(channelBlockchain.getAddress())) {
|
channelBlockchain.setAddress(address);
|
img = this.qRProducerService.generate(address);
|
channelBlockchain.setImg(img);
|
}
|
|
this.channelBlockchainService.update(old, channelBlockchain, this.getUsername_login(),
|
this.getLoginPartyId(), safeword, this.getIp(getRequest()), email_code, super_google_auth_code);
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
modelAndView.addObject("id", id);
|
modelAndView.addObject("blockchain_name", blockchain_name);
|
modelAndView.addObject("coin", coin);
|
modelAndView.addObject("address", address);
|
modelAndView.addObject("img", img);
|
modelAndView.setViewName("channel_blockchain_update");
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
modelAndView.addObject("error", "[ERROR] " + t.getMessage());
|
modelAndView.addObject("id", id);
|
modelAndView.addObject("blockchain_name", blockchain_name);
|
modelAndView.addObject("coin", coin);
|
modelAndView.addObject("address", address);
|
modelAndView.addObject("img", img);
|
modelAndView.setViewName("channel_blockchain_update");
|
return modelAndView;
|
}
|
|
modelAndView.addObject("message", "操作成功");
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
return modelAndView;
|
}
|
|
/**
|
* 删除 区块链充值地址
|
*/
|
//@RequestMapping(action + "toDelete.action")
|
public ModelAndView toDelete(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
String safeword = request.getParameter("safeword");
|
String email_code = request.getParameter("email_code");
|
String super_google_auth_code = request.getParameter("super_google_auth_code");
|
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
|
try {
|
|
this.channelBlockchainService.delete(id, safeword, this.getUsername_login(), this.getIp(), email_code, super_google_auth_code);
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error("update error ", t);
|
modelAndView.addObject("error", "程序错误");
|
return modelAndView;
|
}
|
|
modelAndView.addObject("message", "操作成功");
|
return modelAndView;
|
}
|
|
private String verif(String blockchain_name, String coin, String address, String img) {
|
if (StringUtils.isEmptyString(blockchain_name))
|
return "请输入链名称";
|
if (StringUtils.isEmptyString(coin))
|
return "请输入币种";
|
if (StringUtils.isEmptyString(address))
|
return "请输入地址";
|
return null;
|
}
|
|
}
|
