package project.web.admin;
|
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
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.futures.AdminProfitAndLossConfigService;
|
import project.futures.ProfitAndLossConfig;
|
import project.futures.ProfitAndLossConfigService;
|
import project.item.ItemService;
|
import project.log.LogService;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.party.recom.UserRecomService;
|
import project.syspara.SysparaService;
|
|
/**
|
* 交割场控设置
|
*/
|
@RestController
|
public class AdminProfitAndLossConfigController extends PageActionSupport {
|
|
@Autowired
|
private LogService logService;
|
|
@Autowired
|
private ItemService itemService;
|
|
@Autowired
|
private PartyService partyService;
|
|
@Autowired
|
private SysparaService sysparaService;
|
|
@Autowired
|
private UserRecomService userRecomService;
|
|
@Autowired
|
private ProfitAndLossConfigService profitAndLossConfigService;
|
|
private final String action = "normal/adminProfitAndLossConfigAction!";
|
|
@Autowired
|
private AdminProfitAndLossConfigService adminProfitAndLossConfigService;
|
|
private Logger logger = LoggerFactory.getLogger(AdminProfitAndLossConfigController.class);
|
|
/**
|
* 获取 交割场控设置 列表
|
*/
|
@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");
|
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("profit_loss_config_list");
|
|
Map<String, String> type_map = Constants.PROFIT_LOSS_TYPE;
|
|
int pageNo=1;
|
Page page=null;
|
int pageSize=30;
|
try {
|
pageNo=checkAndSetPageNo(pageNoStr);
|
page = this.adminProfitAndLossConfigService.pagedQuery(pageNo, pageSize, name_para, this.getLoginPartyId());
|
|
List<Map> list = page.getElements();
|
for (int i = 0; i < list.size(); i++) {
|
Map map = list.get(i);
|
|
map.put("type", type_map.get(map.get("type")));
|
|
if (null == map.get("rolename")) {
|
map.put("roleNameDesc", "");
|
} else {
|
String roleName = map.get("rolename").toString();
|
map.put("roleNameDesc", Constants.ROLE_MAP.containsKey(roleName) ? Constants.ROLE_MAP.get(roleName) : roleName);
|
}
|
}
|
|
} 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);
|
return modelAndView;
|
}
|
|
/**
|
* 新增 交割场控设置 页面
|
*/
|
@RequestMapping(action + "toAdd.action")
|
public ModelAndView toAdd(HttpServletRequest request) {
|
ModelAndView modelAndView = new ModelAndView();
|
Map<String, String> type_map = Constants.PROFIT_LOSS_TYPE;
|
modelAndView.addObject("type_map", type_map);
|
modelAndView.setViewName("profit_loss_config_add");
|
return modelAndView;
|
}
|
|
/**
|
* 新增 交割场控设置
|
*/
|
@RequestMapping(action + "add.action")
|
public ModelAndView add(HttpServletRequest request) {
|
String usercode = request.getParameter("usercode");
|
String type = request.getParameter("type");
|
String remark = request.getParameter("remark");
|
|
ModelAndView modelAndView = new ModelAndView();
|
|
Map<String, String> type_map = Constants.PROFIT_LOSS_TYPE;
|
|
try {
|
|
if (StringUtils.isEmptyString(usercode)) {
|
throw new BusinessException("请输入用户UID");
|
}
|
|
Party party = this.partyService.findPartyByUsercode(usercode);
|
if (null == party) {
|
throw new BusinessException("用户不存在");
|
}
|
|
Party party_login = this.partyService.findPartyByUsername(this.getUsername_login());
|
if (party_login != null) {
|
|
List<String> childrens = this.userRecomService.findChildren(party_login.getId());
|
double isChildren = 0;
|
if (childrens != null) {
|
for (String children : childrens) {
|
if (party.getId().equals(children)) {
|
isChildren = 1;
|
}
|
}
|
}
|
|
if (isChildren == 0) {
|
throw new BusinessException("用户不存在或者不属于登录用户名下");
|
}
|
}
|
|
ProfitAndLossConfig profitAndLossConfig = new ProfitAndLossConfig();
|
profitAndLossConfig.setType(type);
|
profitAndLossConfig.setRemark(remark);
|
profitAndLossConfig.setPartyId(party.getId());
|
|
this.profitAndLossConfigService.save(profitAndLossConfig, this.getUsername_login());
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
modelAndView.addObject("usercode", usercode);
|
modelAndView.addObject("type", type);
|
modelAndView.addObject("remark", remark);
|
modelAndView.addObject("type_map", type_map);
|
modelAndView.setViewName("profit_loss_config_add");
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
modelAndView.addObject("error", "[ERROR] " + t.getMessage());
|
modelAndView.addObject("usercode", usercode);
|
modelAndView.addObject("type", type);
|
modelAndView.addObject("remark", remark);
|
modelAndView.addObject("type_map", type_map);
|
modelAndView.setViewName("profit_loss_config_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();
|
|
Map<String, String> type_map = Constants.PROFIT_LOSS_TYPE;
|
|
try {
|
|
ProfitAndLossConfig profitAndLossConfig = this.profitAndLossConfigService.findById(id);
|
|
Party party = this.partyService.cachePartyBy(profitAndLossConfig.getPartyId(), true);
|
|
modelAndView.addObject("id", id);
|
modelAndView.addObject("type", profitAndLossConfig.getType());
|
modelAndView.addObject("remark", profitAndLossConfig.getRemark());
|
modelAndView.addObject("username", party.getUsername());
|
modelAndView.addObject("usercode", party.getUsercode());
|
modelAndView.addObject("type_map", type_map);
|
|
} 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("profit_loss_config_update");
|
return modelAndView;
|
}
|
|
/**
|
* 修改 交割场控设置
|
*/
|
@RequestMapping(action + "update.action")
|
public ModelAndView update(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
String type = request.getParameter("type");
|
String remark = request.getParameter("remark");
|
String username = request.getParameter("username");
|
String usercode = request.getParameter("usercode");
|
|
ModelAndView modelAndView = new ModelAndView();
|
|
Map<String, String> type_map = Constants.PROFIT_LOSS_TYPE;
|
|
try {
|
|
ProfitAndLossConfig profitAndLossConfig = this.profitAndLossConfigService.findById(id);
|
|
Party party = this.partyService.cachePartyBy(profitAndLossConfig.getPartyId(), true);
|
if (null == party) {
|
throw new BusinessException("用户不存在");
|
}
|
|
Party party_login = this.partyService.findPartyByUsername(this.getUsername_login());
|
if (party_login != null) {
|
|
List<String> childrens = this.userRecomService.findChildren(party_login.getId());
|
|
double isChildren = 0;
|
if (childrens != null) {
|
for (String children : childrens) {
|
if (party.getId().equals(children)) {
|
isChildren = 1;
|
}
|
}
|
}
|
|
if (0 == isChildren) {
|
throw new BusinessException("用户不存在或者不属于登录用户名下");
|
}
|
}
|
|
profitAndLossConfig.setRemark(remark);
|
profitAndLossConfig.setType(type);
|
|
this.profitAndLossConfigService.update(profitAndLossConfig, this.getUsername_login());
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
modelAndView.addObject("id", id);
|
modelAndView.addObject("type", type);
|
modelAndView.addObject("remark", remark);
|
modelAndView.addObject("username", username);
|
modelAndView.addObject("usercode", usercode);
|
modelAndView.addObject("type_map", type_map);
|
modelAndView.setViewName("profit_loss_config_update");
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
modelAndView.addObject("error", "[ERROR] " + t.getMessage());
|
modelAndView.addObject("id", id);
|
modelAndView.addObject("type", type);
|
modelAndView.addObject("remark", remark);
|
modelAndView.addObject("username", username);
|
modelAndView.addObject("usercode", usercode);
|
modelAndView.addObject("type_map", type_map);
|
modelAndView.setViewName("profit_loss_config_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");
|
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
|
try {
|
|
ProfitAndLossConfig profitAndLossConfig = this.profitAndLossConfigService.findById(id);
|
|
Party party = this.partyService.cachePartyBy(profitAndLossConfig.getPartyId(), true);
|
if (null == party) {
|
throw new BusinessException("用户不存在");
|
}
|
|
Party party_login = this.partyService.findPartyByUsername(this.getUsername_login());
|
if (party_login != null) {
|
|
List<String> childrens = this.userRecomService.findChildren(party_login.getId());
|
|
double isChildren = 0;
|
if (childrens != null) {
|
for (String children : childrens) {
|
if (party.getId().equals(children)) {
|
isChildren = 1;
|
}
|
}
|
}
|
|
if (0 == isChildren) {
|
throw new BusinessException("用户不存在或者不属于登录用户名下");
|
}
|
}
|
|
this.profitAndLossConfigService.delete(id, this.getUsername_login());
|
|
} 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;
|
}
|
|
// public String toProductProfitLoss() {
|
// profit_loss_symbol = sysparaService.find("profit_loss_symbol").getValue();
|
// profit_loss_type = sysparaService.find("profit_loss_type").getValue();
|
// for (Item item : itemService.cacheGetAll()) {
|
// symbol_map.put(item.getSymbol(), item.getSymbol());
|
// }
|
// return "profitLossProduct";
|
// }
|
|
// public String updateProductProfitLoss() {
|
// try {
|
// Syspara profit_loss_symbol_sys = sysparaService.find("profit_loss_symbol");
|
// String old_profit_loss_symbol = profit_loss_symbol_sys.getValue();
|
// profit_loss_symbol_sys.setValue(profit_loss_symbol);
|
// sysparaService.update(profit_loss_symbol_sys);
|
//
|
// Syspara profit_loss_type_sys = sysparaService.find("profit_loss_type");
|
// String old_profit_loss_type = profit_loss_type_sys.getValue();
|
// profit_loss_type_sys.setValue(profit_loss_type);
|
// sysparaService.update(profit_loss_type_sys);
|
// project.log.Log log = new project.log.Log();
|
// log.setCategory(Constants.LOG_CATEGORY_OPERATION);
|
// log.setOperator(this.getUsername_login());
|
//// log.setUsername(party.getUsername());
|
//// log.setPartyId(entity.getPartyId());
|
// log.setCreateTime(new Date());
|
// log.setLog("管理员手动修改产品交割场控。原场控币种[" + old_profit_loss_symbol + "],修改后场控币种为[" + profit_loss_symbol + "]."
|
// + "原币种交割场控类型[" + Constants.PROFIT_LOSS_TYPE.get(old_profit_loss_type) + "],修改后币种交割场控类型["
|
// + Constants.PROFIT_LOSS_TYPE.get(profit_loss_type) + "]");
|
// this.logService.saveSync(log);
|
//
|
// this.message = "操作成功";
|
// } catch (BusinessException e) {
|
// this.error = e.getMessage();
|
// } catch (Throwable t) {
|
// logger.error("update error ", t);
|
// this.error = "程序错误";
|
// }
|
// return toProductProfitLoss();
|
// }
|
|
}
|
