package project.web.admin.impl.user;
|
|
import java.io.Serializable;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.security.providers.encoding.PasswordEncoder;
|
|
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.party.PartyService;
|
import project.party.model.Party;
|
import project.party.model.UserRecom;
|
import project.party.recom.UserRecomService;
|
import project.syspara.Syspara;
|
import project.syspara.SysparaService;
|
import project.user.Agent;
|
import project.user.QRGenerateService;
|
import project.wallet.Wallet;
|
import project.wallet.WalletService;
|
import project.web.admin.service.user.AdminAgentService;
|
import project.web.admin.service.user.AgentNodes;
|
import security.Role;
|
import security.RoleService;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
public class AdminAgentServiceImpl implements AdminAgentService {
|
|
private RoleService roleService;
|
|
private PartyService partyService;
|
|
private PagedQueryDao pagedQueryDao;
|
|
private WalletService walletService;
|
|
private SecUserService secUserService;
|
|
private SysparaService sysparaService;
|
|
private PasswordEncoder passwordEncoder;
|
|
private UserRecomService userRecomService;
|
|
private QRGenerateService qRGenerateService;
|
|
private static final Logger logger=LoggerFactory.getLogger(AdminAgentServiceImpl.class);
|
|
@Override
|
public Page pagedQuery(int pageNo, int pageSize, String name_para, String checkedPartyId) {
|
|
StringBuffer queryString = new StringBuffer("SELECT agent.UUID id,party.NAME name,party.USERNAME username,party.USERCODE usercode,party.ROLENAME rolename,party.LOGINAUTHORITY login_authority,party.USERCODE usercode,party.REMARKS remarks,party_parent.NAME name_parent,party_parent.USERNAME username_parent ");
|
queryString.append(" FROM T_AGENT agent LEFT JOIN PAT_PARTY party ON agent.PARTY_ID = party.UUID LEFT JOIN PAT_PARTY party_parent ON agent.PARENT_PARTY_ID = party_parent.UUID WHERE 1 = 1 ");
|
|
Map<String, Object> parameters = new HashMap<String, Object>();
|
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(checkedPartyId)) {
|
|
List<String> checked_list = this.userRecomService.findChildren(checkedPartyId);
|
checked_list.add(checkedPartyId);
|
if (checked_list.size() == 0) {
|
return new Page();
|
}
|
queryString.append(" and party.UUID in(:checked_list)");
|
parameters.put("checked_list", checked_list);
|
}
|
|
queryString.append(" order by party.CREATE_TIME desc ");
|
Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
|
return page;
|
}
|
|
public Page pagedQueryNetwork(int pageNo, int pageSize, String loginPartyId,String roleName, String usernameOrUid, String targetPartyId) {
|
Page page = getPageList(pageNo, pageSize, loginPartyId, usernameOrUid, roleName,targetPartyId);// 获取当前页的用户相关
|
/**
|
* 页面查询第一层partyId级
|
*/
|
List<String> list_partyId = new ArrayList<String>();
|
|
for (int i = 0; i < page.getElements().size(); i++) {
|
Map<String, Object> map_party = (Map<String, Object>) page.getElements().get(i);
|
list_partyId.add(map_party.get("partyId").toString());
|
}
|
List<Map<String, Object>> result = new ArrayList<Map<String, Object>>();
|
|
for (int i = 0; i < list_partyId.size(); i++) {
|
int reco_agent = 0;
|
/**
|
* 所有子集
|
*/
|
List<String> children_all = this.userRecomService.findChildren(list_partyId.get(i));
|
/**
|
* 正式用户
|
*/
|
List<String> children_member = new ArrayList<>();
|
for (int j = 0; j < children_all.size(); j++) {
|
String partyId = children_all.get(j);
|
Party party = partyService.cachePartyBy(partyId,true);
|
if (Constants.SECURITY_ROLE_AGENT.equals(party.getRolename())||Constants.SECURITY_ROLE_AGENTLOW.equals(party.getRolename())) {
|
reco_agent++;
|
} else if (Constants.SECURITY_ROLE_MEMBER.equals(party.getRolename())) {
|
children_member.add(partyId);
|
}
|
}
|
|
Map<String, Object> item_result = new HashMap<String, Object>() ;
|
|
Party party = partyService.cachePartyBy(list_partyId.get(i),false);
|
|
UserRecom userRecom = this.userRecomService.findByPartyId(party.getId());
|
if(userRecom != null && !"".equals(userRecom.getReco_id()) ) {
|
Party party_parent = partyService.cachePartyBy(userRecom.getReco_id(),true);
|
item_result.put("username_parent", party_parent.getUsername());
|
}
|
Agent agent = this.findByPartyId(party.getId());
|
item_result.put("reco_agent", reco_agent);
|
item_result.put("reco_member", children_member.size());
|
item_result.put("partyId", list_partyId.get(i));
|
|
item_result.put("username", party.getUsername());
|
item_result.put("usercode", party.getUsercode());
|
item_result.put("remarks", party.getRemarks());
|
if(agent != null) {
|
item_result.put("id", agent.getId());
|
}
|
|
result.add(item_result);
|
}
|
|
Page page_result = Page.EMPTY_PAGE;
|
page_result.setElements(result);
|
return page_result;
|
}
|
|
private Page getPageList(int pageNo, int pageSize,String loginPartyId,String roleName, String usernameOrUid, String targetPartyId) {
|
Map<String, Object> parameters = new HashMap<String, Object>();
|
StringBuffer queryString = new StringBuffer();
|
queryString.append("SELECT party.ROLENAME AS rolename,party.USERNAME AS username,party.USERCODE AS UID,party.UUID AS partyId ");// 用户
|
queryString.append("FROM PAT_PARTY party ");
|
queryString.append("LEFT JOIN PAT_USER_RECOM ur ON party.UUID = ur.PARTY_ID ");// 推荐人 根目录判定
|
queryString.append("WHERE 1=1 ");
|
queryString.append("AND party.ROLENAME IN('" + Constants.SECURITY_ROLE_AGENT + "','"+Constants.SECURITY_ROLE_AGENTLOW+"') ");
|
if (!StringUtils.isNullOrEmpty(loginPartyId)) {
|
List children = this.userRecomService.findChildren(loginPartyId);
|
if (children.size() == 0) {
|
return new Page();
|
}
|
queryString.append(" and party.UUID in (:children) ");
|
parameters.put("children", children);
|
}
|
if (!StringUtils.isNullOrEmpty(targetPartyId)) {
|
List children = this.userRecomService.findRecomsToPartyId(targetPartyId);
|
if (children.size() == 0) {
|
return new Page();
|
}
|
queryString.append(" and party.UUID in (:children) ");
|
parameters.put("children", children);
|
}
|
if (StringUtils.isNullOrEmpty(targetPartyId) && StringUtils.isNullOrEmpty(usernameOrUid)) {// 目标partyId为空
|
// ，username参数为空，的情况下，如果是视图，显示根目录
|
queryString.append(" and ur.RECO_ID is NULL ");
|
}
|
if (!StringUtils.isNullOrEmpty(usernameOrUid)) {
|
queryString.append("AND (party.USERNAME like:username OR party.USERCODE like:username ) ");
|
parameters.put("username", "%" + usernameOrUid + "%");
|
}
|
queryString.append("ORDER BY party.USERCODE ASC ");
|
Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
|
return page;
|
}
|
|
|
public List<AgentNodes> findAgentNodes(String loginPartyId, String checkedPartyId, String url) {
|
Map<String, String> map_checked = new HashMap();
|
|
List<UserRecom> parents = userRecomService.getParents(checkedPartyId);
|
for (int i = 0; i < parents.size(); i++) {
|
UserRecom userRecom = parents.get(i);
|
map_checked.put(userRecom.getReco_id().toString(), userRecom.getReco_id().toString());
|
}
|
|
map_checked.put(checkedPartyId, checkedPartyId);
|
List result = new ArrayList();
|
List list = new ArrayList();
|
AgentNodes root = new AgentNodes();
|
root.setHref(url);
|
List<Agent> party_list;
|
if (StringUtils.isNullOrEmpty(loginPartyId)) {// " FROM Party WHERE reco_id IS NULL or reco_id = '' and
|
party_list = ApplicationUtil.executeSelect(Agent.class,"WHERE PARENT_PARTY_ID IS NULL OR PARENT_PARTY_ID=''",null);
|
root.setText("所有代理商");
|
} else {
|
List recom_list = userRecomService.findRecoms(loginPartyId);
|
/**
|
* 将自己放入列表中
|
*/
|
Party party = this.partyService.cachePartyBy(loginPartyId,true);
|
Agent agent=findByPartyId(party.getId());
|
party_list = new ArrayList();
|
party_list.add(agent);
|
/**
|
* 将子代理放入列表中
|
*/
|
for (int i = 0; i < recom_list.size(); i++) {
|
party = this.partyService.cachePartyBy(((UserRecom) recom_list.get(i)).getPartyId(),true);
|
agent=findByPartyId(party.getId());
|
if(agent != null)
|
party_list.add(agent);
|
}
|
root.setText("线下代理商");
|
}
|
|
for (int i = 0; i < party_list.size(); i++) {
|
Agent agent = (Agent) party_list.get(i);
|
AgentNodes nodes = new AgentNodes();
|
nodes.setTags(agent.getPartyId().toString());
|
nodes.setHref(url + "?partyId=" + agent.getPartyId().toString());
|
Party party = this.partyService.cachePartyBy(agent.getPartyId(),true);
|
String username = party.getUsername();
|
String name = party.getName();
|
if ((!StringUtils.isNullOrEmpty(loginPartyId)) && (!StringUtils.isNullOrEmpty(username))
|
&& (username.length() == 11)) {
|
username = username.substring(0, 3) + "****" + username.substring(7, 11);
|
}
|
|
Map state = new HashMap();
|
if (map_checked.get(agent.getId().toString()) != null) {
|
state.put("checked", Boolean.valueOf(true));
|
state.put("expanded", Boolean.valueOf(true));
|
root.setState(state);
|
}
|
|
nodes.setText(username);
|
findAgentNodesLoop(loginPartyId, nodes, map_checked, url);
|
list.add(nodes);
|
}
|
root.setNodes(list);
|
result.add(root);
|
return result;
|
}
|
|
public void findAgentNodesLoop(String loginPartyId, AgentNodes nodes, Map<String, String> map_checked, String url) {
|
List recom_list = userRecomService.findRecoms(nodes.getTags());
|
List list = new ArrayList();
|
for (int i = 0; i < recom_list.size(); i++) { // findPartyByCache
|
Party party = this.partyService.cachePartyBy(((UserRecom) recom_list.get(i)).getPartyId(),true);
|
/**
|
* 如果rolename不是代理商则不添加
|
*
|
*/
|
if(party == null) {
|
continue;
|
}
|
|
if(!Constants.SECURITY_ROLE_AGENT.equals(party.getRolename())||!Constants.SECURITY_ROLE_AGENTLOW.equals(party.getRolename())) {
|
continue;
|
}
|
AgentNodes children_nodes = new AgentNodes();
|
children_nodes.setTags(party.getId().toString());
|
children_nodes.setHref(url + "?partyId=" + party.getId().toString());
|
children_nodes.setText( party.getUsername() );
|
Map state = new HashMap();
|
if (map_checked.get(party.getId().toString()) != null) {
|
state.put("checked", Boolean.valueOf(true));
|
state.put("expanded", Boolean.valueOf(true));
|
children_nodes.setState(state);
|
}
|
list.add(children_nodes);
|
findAgentNodesLoop(loginPartyId, children_nodes, map_checked, url);
|
}
|
nodes.setNodes(list);
|
}
|
|
@Override
|
public void save(String name, String username, String password, boolean login_authority,String remarks, String parents_usercode,boolean opera_authority) {
|
username = username.trim();
|
password = password.trim();
|
|
if (secUserService.findUserByLoginName(username) != null) {
|
throw new BusinessException("用户名重复");
|
}
|
/**
|
* 用户code
|
*/
|
String usercode = getUsercode();
|
|
if (!StringUtils.isNullOrEmpty(parents_usercode)) {
|
Party party_parents=partyService.findPartyByUsercode(parents_usercode);
|
if (party_parents==null ) {
|
throw new BusinessException("推荐码不正确");
|
}
|
if (!Constants.SECURITY_ROLE_AGENT.equals(party_parents.getRolename()) && !Constants.SECURITY_ROLE_AGENTLOW.equals(party_parents.getRolename())) {
|
throw new BusinessException("推荐码不正确");
|
}
|
}
|
|
/**
|
* party
|
*/
|
Party party = new Party();
|
party.setUsername(username);
|
party.setUsercode(usercode);
|
party.setName(name);
|
party.setLogin_authority(login_authority);
|
party.setRemarks(remarks);
|
party.setSafeword(passwordEncoder.encodePassword("000000", party.getUsername()));
|
|
party.setRolename(opera_authority?Constants.SECURITY_ROLE_AGENT:Constants.SECURITY_ROLE_AGENTLOW);
|
|
party = partyService.save(party);
|
|
if (!StringUtils.isNullOrEmpty(parents_usercode)) {
|
Party party_parents=partyService.findPartyByUsercode(parents_usercode);
|
|
if (party_parents==null ) {
|
throw new BusinessException("推荐码不正确");
|
}
|
if (!Constants.SECURITY_ROLE_AGENT.equals(party_parents.getRolename()) && !Constants.SECURITY_ROLE_AGENTLOW.equals(party_parents.getRolename())) {
|
throw new BusinessException("推荐码不正确");
|
}
|
UserRecom userRecom = new UserRecom();
|
userRecom.setPartyId(party.getId());
|
userRecom.setReco_id(party_parents.getId().toString());// 父类partyId
|
this.userRecomService.save(userRecom);
|
}
|
/**
|
* SecUser
|
*/
|
Role role = this.roleService.findRoleByName(opera_authority?Constants.SECURITY_ROLE_AGENT:Constants.SECURITY_ROLE_AGENTLOW);
|
|
SecUser secUser = new SecUser();
|
secUser.setPartyId(String.valueOf(party.getId()));
|
secUser.getRoles().add(role);
|
|
secUser.setUsername(username);
|
secUser.setPassword(password);
|
secUser.setEnabled(login_authority);
|
secUser.setSafeword(passwordEncoder.encodePassword("000000", party.getUsername()));
|
|
this.secUserService.saveUser(secUser);
|
|
/**
|
* usdt账户
|
*/
|
Wallet wallet = new Wallet();
|
wallet.setPartyId(party.getId().toString());
|
this.walletService.save(wallet);
|
/**
|
* 5个币账户
|
*/
|
Agent agent=new Agent();
|
agent.setPartyId(party.getId());
|
if (!StringUtils.isNullOrEmpty(parents_usercode)) {
|
Party party_parents=partyService.findPartyByUsercode(parents_usercode);
|
agent.setParent_partyId(party_parents.getId().toString());
|
}
|
|
ApplicationUtil.executeInsert(agent);
|
}
|
|
private String getUsercode() {
|
Syspara syspara = sysparaService.find("agent_uid_sequence");
|
int random = (int) (Math.random() * 3 + 1);
|
int user_uid_sequence = syspara.getInteger() + random;
|
syspara.setValue(user_uid_sequence);
|
sysparaService.update(syspara);
|
|
String usercode = String.valueOf(user_uid_sequence);
|
return usercode;
|
}
|
|
public Agent findByPartyId(Serializable partyId) {
|
List<Agent> list = ApplicationUtil.executeSelect(Agent.class,"WHERE PARTY_ID=?",new Object[] {partyId});
|
return list.size()<=0?null:list.get(0);
|
}
|
|
@Override
|
public Agent get(String id) {
|
return ApplicationUtil.executeGet(id,Agent.class);
|
}
|
|
@Override
|
public void update(String id, String name, boolean login_authority, String remarks,boolean opera_authority) {
|
Agent agent= this.get(id);
|
Party party = this.partyService.cachePartyBy(agent.getPartyId(),false);
|
party.setRolename(opera_authority?Constants.SECURITY_ROLE_AGENT:Constants.SECURITY_ROLE_AGENTLOW);
|
party.setName(name);
|
party.setRemarks(remarks);
|
party.setLogin_authority(login_authority);
|
this.partyService.update(party);
|
|
SecUser secUser= secUserService.findUserByPartyId(agent.getPartyId());
|
Role role = this.roleService.findRoleByName(opera_authority?Constants.SECURITY_ROLE_AGENT:Constants.SECURITY_ROLE_AGENTLOW);
|
|
Set<Role> roles = secUser.getRoles();
|
roles.clear();
|
roles.add(role);
|
secUser.setRoles(roles);
|
secUser.setEnabled(login_authority);
|
|
this.secUserService.update(secUser);
|
|
}
|
@Override
|
public void update(Agent agent) {
|
ApplicationUtil.executeUpdate(agent);
|
}
|
|
public void setPagedQueryDao(PagedQueryDao pagedQueryDao) {
|
this.pagedQueryDao = pagedQueryDao;
|
}
|
|
public void setUserRecomService(UserRecomService userRecomService) {
|
this.userRecomService = userRecomService;
|
}
|
|
public void setWalletService(WalletService walletService) {
|
this.walletService = walletService;
|
}
|
|
public void setPartyService(PartyService partyService) {
|
this.partyService = partyService;
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
|
public void setRoleService(RoleService roleService) {
|
this.roleService = roleService;
|
}
|
|
public class PosterThread implements Runnable {
|
String image_name;
|
String usercode;
|
|
public void run() {
|
try {
|
qRGenerateService.generate_poster(image_name, usercode);
|
} catch (Exception e) {
|
logger.error("error:", e);
|
}
|
|
}
|
|
public PosterThread(String image_name, String usercode) {
|
this.image_name = image_name;
|
this.usercode = usercode;
|
}
|
|
}
|
|
public void setqRGenerateService(QRGenerateService qRGenerateService) {
|
this.qRGenerateService = qRGenerateService;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
|
|
public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
|
this.passwordEncoder = passwordEncoder;
|
}
|
|
|
|
|
|
}
|
