|
|
@@ -26,9 +26,10 @@ import com.muchinfo.mtp3pojos.vo.investor.DetailAfterResult;
|
|
|
import com.muchinfo.mtp3pojos.vo.investor.DetailBeforeResult;
|
|
|
import com.muchinfo.mtp3pojos.vo.investor.UserAccountDetailVo;
|
|
|
import com.muchinfo.mtp3pojos.vo.investor.UserinfoDetailVo;
|
|
|
+import com.muchinfo.mtp3pojos.vo.organ.UserAccountDetailResult;
|
|
|
import com.muchinfo.mtp3pojos.vo.organ.UserAccountReqParam;
|
|
|
-import com.muchinfo.mtp3pojos.vo.organ.UserAccountVo;
|
|
|
-import com.muchinfo.mtp3pojos.vo.organ.OrganParam;
|
|
|
+import com.muchinfo.mtp3pojos.vo.organ.UserAccountRspResult;
|
|
|
+import com.muchinfo.mtp3pojos.vo.organ.son.OrganAddSonOrganParam;
|
|
|
import com.muchinfo.mtp3pojos.vo.organ.son.OrganSonDetailResult;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
@@ -53,6 +54,8 @@ public class OrganServiceImpl implements IOrganService {
|
|
|
@Resource
|
|
|
private IUseraccountMapper iUseraccountMapper;
|
|
|
@Resource
|
|
|
+ private IBankBankinfoMapper iBankBankinfoMapper;
|
|
|
+ @Resource
|
|
|
private IUserinfoMapper iUserinfoMapper;
|
|
|
@Resource
|
|
|
private IUserauthinfoMapper iUserauthinfoMapper;
|
|
|
@@ -98,16 +101,16 @@ public class OrganServiceImpl implements IOrganService {
|
|
|
private IQuoterMapper iQuoterMapper;
|
|
|
|
|
|
@Override
|
|
|
- public PageResult<UserAccountVo> queryByPage(UserAccountReqParam userInfoReqParam, HttpServletRequest request) {
|
|
|
- IPage<UserAccountVo> userAccountVos;
|
|
|
- IPage<UserAccountVo> page = new Page<>(userInfoReqParam.getPageNum(), userInfoReqParam.getPageSize());
|
|
|
+ public PageResult<UserAccountRspResult> queryByPage(UserAccountReqParam userInfoReqParam, HttpServletRequest request) {
|
|
|
+ IPage<UserAccountRspResult> userAccountVos;
|
|
|
+ IPage<UserAccountRspResult> page = new Page<>(userInfoReqParam.getPageNum(), userInfoReqParam.getPageSize());
|
|
|
Systemmanager systemmanager = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>().eq("LOGINCODE", iCommonService.getUserLoginCode(request)));
|
|
|
if (systemmanager.getReletype() == 2) {
|
|
|
userAccountVos = iUseraccountMapper.querySonOrganPage(page, userInfoReqParam);
|
|
|
} else {
|
|
|
userAccountVos = iUseraccountMapper.queryOrganPage(page, userInfoReqParam);
|
|
|
}
|
|
|
- PageResult<UserAccountVo> pageResult = new PageResult<>();
|
|
|
+ PageResult<UserAccountRspResult> pageResult = new PageResult<>();
|
|
|
pageResult.setCode(Constants.Success_Code_Design);
|
|
|
pageResult.setMessage(AjaxResult.dealMsg(MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language")));
|
|
|
pageResult.setPages(userAccountVos.getPages());
|
|
|
@@ -119,855 +122,103 @@ public class OrganServiceImpl implements IOrganService {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public AjaxResult<UserAccountVo> queryDetail(Long areaId) {
|
|
|
- UserAccountVo userAccountVo = new UserAccountVo();
|
|
|
+ public AjaxResult<UserAccountRspResult> queryDetail(Long areaId,Integer role, HttpServletRequest request) {
|
|
|
+ UserAccountDetailResult result = new UserAccountDetailResult();
|
|
|
+ UserAccountRspResult userAccountVo = new UserAccountRspResult();
|
|
|
Useraccount useraccount = iUseraccountMapper.selectOne(new QueryWrapper<Useraccount>().eq("USERID", areaId));
|
|
|
BeanUtils.copyProperties(useraccount, userAccountVo);
|
|
|
+ result.setRspResult(userAccountVo);
|
|
|
|
|
|
+ result.setRefereeusername(iUseraccountMapper.selectOrganName(userAccountVo.getRefereeuserid()) != null ? iUseraccountMapper.selectOrganName(userAccountVo.getRefereeuserid()) : "");
|
|
|
+ result.setBorkername(iUseraccountMapper.selectOrganName(userAccountVo.getBroker()));
|
|
|
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public PageResult<UserAccountVo> querySon(UserAccountReqParam param, HttpServletRequest request) {
|
|
|
- Systemmanager systemmanager = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>().eq("LOGINCODE", iCommonService.getUserLoginCode(request)));
|
|
|
- if (systemmanager.getReletype() == 3) {
|
|
|
- if (param.getParentuserid() == null)
|
|
|
- param.setParentuserid(param.getMemberuserid());
|
|
|
- //父级和所属会员两个条件同时查,查不出来子机构,所以把所属会员条件去掉
|
|
|
- param.setMemberuserid(null);
|
|
|
+ Userinfo ui = iUserinfoMapper.selectOne(new QueryWrapper<Userinfo>().eq("userid", areaId));
|
|
|
+ if (StringUtils.isNotBlank(ui.getBankaccount())) {
|
|
|
+ ui.setBankaccount(EncryptionUtils.decryptForAES(ui.getBankaccount()));
|
|
|
}
|
|
|
- IPage<UserAccountVo> page = new Page<>(param.getPageNum(), param.getPageSize());
|
|
|
- IPage<UserAccountVo> userAccountVos = iUseraccountMapper.querySonOrganPage(page, param);
|
|
|
- PageResult<UserAccountVo> pageResult = new PageResult<>();
|
|
|
- pageResult.setCode(Constants.Success_Code_Design);
|
|
|
- pageResult.setMessage(AjaxResult.dealMsg(MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language")));
|
|
|
- pageResult.setPages(userAccountVos.getPages());
|
|
|
- pageResult.setCurrent(userAccountVos.getCurrent());
|
|
|
- pageResult.setTotal(userAccountVos.getTotal());
|
|
|
- pageResult.setPageSize(userAccountVos.getSize());
|
|
|
- pageResult.setData(userAccountVos.getRecords());
|
|
|
- return pageResult;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public AjaxResult<UserAccountVo> getAreaAndAllChilds(HttpServletRequest request) {
|
|
|
- Systemmanager systemmanager = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>().eq("LOGINCODE", iCommonService.getUserLoginCode(request)));
|
|
|
- List<UserAccountVo> result = iUseraccountMapper.getAreaAndAllChilds(systemmanager.getAreauserid());
|
|
|
- for (UserAccountVo userAccountVo : result) {
|
|
|
- //最大层级数
|
|
|
- Object maxLev = iCommonService.getSystemParam(Constants.REDIS_HEADER_SYSPARAM, "069");
|
|
|
- if (maxLev == null || StringUtils.isBlank(maxLev.toString())) {
|
|
|
- maxLev = 4;
|
|
|
- }
|
|
|
- userAccountVo.setMaxLevel(Math.min(7, Integer.parseInt(maxLev.toString())));
|
|
|
- userAccountVo.setParentid(systemmanager.getAreauserid());
|
|
|
-
|
|
|
- Useraccount ua = iUseraccountMapper.selectOne(new QueryWrapper<Useraccount>().eq("userid", systemmanager.getAreauserid()));
|
|
|
- Integer level = iUseraccountMapper.querySonOrganLevel(ua.getUserid(), ua.getMemberuserid());
|
|
|
- userAccountVo.setSubarealevel(level);
|
|
|
- userAccountVo.setCuruserid(ua.getUserid());
|
|
|
-
|
|
|
- // 是否可跨级添加子机构
|
|
|
- Object canCrossAdd = redisServiceUtil.getCacheMapValue(Constants.REDIS_HEADER_SYSPARAM, "1000");
|
|
|
- if (canCrossAdd == null || StringUtils.isBlank(canCrossAdd.toString())) {
|
|
|
- canCrossAdd = 1;
|
|
|
- }
|
|
|
- userAccountVo.setCancrossadd(Integer.valueOf(canCrossAdd.toString()));
|
|
|
-
|
|
|
- Userinfo userinfo = iUserinfoMapper.selectOne(new QueryWrapper<Userinfo>().eq("userid", userAccountVo.getUserid()));
|
|
|
- userAccountVo.setUserinfotype(userinfo.getUserinfotype());
|
|
|
- userAccountVo.setContactname(userinfo.getContactname());
|
|
|
- if (userinfo.getDistrictid() != null) {
|
|
|
- userAccountVo.setPathname(iDivisionMapper.selectAreaPathName(userinfo.getDistrictid()) + userinfo.getAddress());
|
|
|
+ if (ui.getBankid() != null) {
|
|
|
+ BankBankinfo bi = iBankBankinfoMapper.selectOne(new QueryWrapper<BankBankinfo>().eq("bankid", ui.getBankid()));
|
|
|
+ if (bi != null) {
|
|
|
+ ui.setBankname(bi.getBankname());
|
|
|
}
|
|
|
}
|
|
|
- return AjaxResult.success(Constants.Success_Code_Design, MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language"), result);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public AjaxResult<OrganSonDetailResult> viewson(Long areaid, Integer modifystatus, HttpServletRequest request) {
|
|
|
- Systemmanager systemmanager = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>().eq("LOGINCODE", iCommonService.getUserLoginCode(request)));
|
|
|
- new Thread(new Runnable() {
|
|
|
- @Override
|
|
|
- public void run() {
|
|
|
- systemmanagerService.saveMGLog(systemmanager, SysConstants.PART_CODE_ORGZ, areaid);
|
|
|
- }
|
|
|
- }).start();
|
|
|
-
|
|
|
- OrganSonDetailResult result = new OrganSonDetailResult();
|
|
|
- Useraccount useraccount = iUseraccountMapper.selectOne(new QueryWrapper<Useraccount>().eq("userid", areaid));
|
|
|
- String sp1 = iCommonService.getSysparmById(SysConstants.SYSPARAM_SETTING_SON_AUDIT);
|
|
|
|
|
|
- //管理员账户
|
|
|
- Systemmanager admin = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>()
|
|
|
- .eq("areauserid", areaid)
|
|
|
- .eq("isdefault", 1));
|
|
|
- result.setUserid(admin.getAutoid());
|
|
|
- result.setUsername(admin.getUsername());
|
|
|
- result.setUserstatus(admin.getManagerstatus());
|
|
|
- result.setLogincode(admin.getLogincode());
|
|
|
-
|
|
|
- //整理返回数据
|
|
|
- if (modifystatus != null && modifystatus >= 2 && useraccount.getAccountstatus() == 4
|
|
|
- && "1".equals(sp1)) {
|
|
|
- result.setOldResult(getUserAccountDetail(areaid, result));
|
|
|
- result.setNewResult(getModifyInvestorDetail(areaid));
|
|
|
- return AjaxResult.success(Constants.Success_Code_Design, MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language"), result);
|
|
|
- } else {
|
|
|
- result.setOldResult(getUserAccountDetail(areaid, result));
|
|
|
- return AjaxResult.success(Constants.Success_Code_Design, MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language"), result);
|
|
|
+ if (StringUtils.isNotBlank(ui.getCardnum())) {
|
|
|
+ ui.setCardnum(EncryptionUtils.decryptForAES(ui.getCardnum()));
|
|
|
}
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public AjaxResult rebackChange(Long areaid, HttpServletRequest request) {
|
|
|
- Systemmanager systemmanager = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>().eq("LOGINCODE", iCommonService.getUserLoginCode(request)));
|
|
|
- if (!iCommonService.checkUserAccountRole(systemmanager, areaid)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.MESSAGE_ERROR_CODE_SYSTEM003.getCode(), request.getHeader("Accept-Language"));
|
|
|
+ if (StringUtils.isNotBlank(ui.getMobile())) {
|
|
|
+ ui.setMobile(EncryptionUtils.decryptForAES(ui.getMobile()));
|
|
|
}
|
|
|
|
|
|
- iDraftUseraccountNewMapper.delete(new QueryWrapper<DraftUseraccountNew>().eq("userid", areaid));
|
|
|
- iDraftUserinfoMapper.delete(new QueryWrapper<DraftUserinfo>().eq("USERID", areaid));
|
|
|
-
|
|
|
- Useraccount organ = iUseraccountMapper.selectOne(new QueryWrapper<Useraccount>().eq("userid", areaid));
|
|
|
- //错误 #58783
|
|
|
- organ.setModifystatus(1);
|
|
|
- iUseraccountMapper.update(organ, new QueryWrapper<Useraccount>().eq("userid", organ.getUserid()));
|
|
|
-
|
|
|
- if (organ.getUsertype() == 3 || organ.getUsertype() == 4) {
|
|
|
- if (systemmanager.getReletype() == 1) {
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ, "撤回id=" + organ.getUserid(), systemmanager, null, null, null);
|
|
|
- } else {
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ_ZJG, "撤回id=" + organ.getUserid(), systemmanager, null, null, null);
|
|
|
- }
|
|
|
- } else if (organ.getUsertype() == 5) {
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_INVESTOR_MANAGE, "撤回id=" + organ.getUserid(), systemmanager, null, null, null);
|
|
|
+ if (StringUtils.isNotBlank(ui.getTelphone())) {
|
|
|
+ ui.setTelphone(EncryptionUtils.decryptForAES(ui.getTelphone()));
|
|
|
}
|
|
|
|
|
|
- return AjaxResult.success(Constants.Success_Code_Design, MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public AjaxResult delete(Long areaid, HttpServletRequest request) {
|
|
|
- Systemmanager systemmanager = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>().eq("LOGINCODE", iCommonService.getUserLoginCode(request)));
|
|
|
- Useraccount org = iUseraccountMapper.selectOne(new QueryWrapper<Useraccount>().eq("userid", areaid));
|
|
|
- //校验
|
|
|
- if (org.getUsertype() != 5) {
|
|
|
- List<Arearole> list2 = iArearoleMapper.selectList(new QueryWrapper<Arearole>().eq("userid", areaid));
|
|
|
- if (CollectionUtils.isNotEmpty(list2)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_001.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
-
|
|
|
- List<Useraccount> list = iUseraccountMapper.selectList(new QueryWrapper<Useraccount>()
|
|
|
- .eq("parentuserid", areaid)
|
|
|
- .eq("accountstatus", 4)
|
|
|
- .in("usertype", 3, 4)
|
|
|
- );
|
|
|
- if (CollectionUtils.isNotEmpty(list)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_002.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- if (org.getUsertype() == 4) {
|
|
|
- list = iUseraccountMapper.selectList(new QueryWrapper<Useraccount>()
|
|
|
- .eq("usertype", 5)
|
|
|
- .eq("broker", areaid)
|
|
|
- .eq("accountstatus", 4));
|
|
|
- if (CollectionUtils.isNotEmpty(list)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_003.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- } else {
|
|
|
- list = iUseraccountMapper.selectList(new QueryWrapper<Useraccount>()
|
|
|
- .eq("parentuserid", areaid)
|
|
|
- .eq("accountstatus", 4)
|
|
|
- .eq("usertype", 5));
|
|
|
- if (CollectionUtils.isNotEmpty(list)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_003.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- }
|
|
|
- } else {
|
|
|
- List<Taaccount> taList = iTaaccountMapper.selectList(new QueryWrapper<Taaccount>()
|
|
|
- .eq("userid", areaid)
|
|
|
- .gt("currentbalance", 0)
|
|
|
- );
|
|
|
- if (CollectionUtils.isNotEmpty(taList)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_004.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- List<Tradeposition> tpList = iTradepositionMapper.queryAmount(areaid);
|
|
|
- if (CollectionUtils.isNotEmpty(tpList)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_005.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
+ if (userAccountVo.getCreditquota() != null) {
|
|
|
+ ui.setCreditquota(userAccountVo.getCreditquota());
|
|
|
}
|
|
|
|
|
|
- log.info("收到用户注销请求:" + areaid.toString());
|
|
|
- org.setAccountstatus(6);
|
|
|
- org.setModifierid(systemmanager.getAutoid());
|
|
|
- org.setModifytime(new Date());
|
|
|
- org.setCanceltime(new Date());
|
|
|
- iUseraccountMapper.update(org, new QueryWrapper<Useraccount>().eq("userid", org.getUserid()));
|
|
|
-
|
|
|
- Userinfo ui = iUserinfoMapper.selectOne(new QueryWrapper<Userinfo>().eq("userid", areaid));
|
|
|
- ui.setUserstatus(2);
|
|
|
- iUserinfoMapper.update(ui, new QueryWrapper<Userinfo>().eq("userid", ui.getUserid()));
|
|
|
- //注销 所有账户
|
|
|
- List<Systemmanager> admin = iSystemmanagerMapper.selectList(new QueryWrapper<Systemmanager>().eq("areauserid", areaid));
|
|
|
- if (admin != null && !admin.isEmpty()) {
|
|
|
- admin.forEach(p -> {
|
|
|
- p.setManagerstatus(2);//停用
|
|
|
- iSystemmanagerMapper.updateById(p);
|
|
|
- });
|
|
|
+ if (StringUtils.isNotBlank(ui.getWechat())) {
|
|
|
+ ui.setWechat(EncryptionUtils.decryptForAES(ui.getWechat()));
|
|
|
}
|
|
|
- //删除登录关联关系
|
|
|
- iUserauthinfoMapper.delete(new QueryWrapper<Userauthinfo>().eq("userid", areaid));
|
|
|
- //写入日志
|
|
|
- if (org.getUsertype() == 2)
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ, "注销或删除机构id=" + org.getUserid(), systemmanager, null, null, null);
|
|
|
- else if (org.getUsertype() == 3 || org.getUsertype() == 4) {
|
|
|
- String name = "";
|
|
|
- if (org.getUsertype() == 3)
|
|
|
- name = "子机构";
|
|
|
- if (org.getUsertype() == 4)
|
|
|
- name = "经纪人";
|
|
|
- if (systemmanager.getReletype() == 1)
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ, "注销或删除" + name + "id=" + org.getUserid(), systemmanager, null, null, null);
|
|
|
- else
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ_ZJG, "注销或删除" + name + "id=" + org.getUserid(), systemmanager, null, null, null);
|
|
|
- } else if (org.getUsertype() == 5)
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_INVESTOR_MANAGE, "注销或删除投资者id=" + org.getUserid(), systemmanager, null, null, null);
|
|
|
-
|
|
|
- log.info("用户注销更新完成:" + areaid.toString());
|
|
|
- List<Loginaccount> las = iLoginaccountMapper.selectList(new QueryWrapper<Loginaccount>()
|
|
|
- .eq("userid", org.getUserid())
|
|
|
- .eq("loginstatus", 1));
|
|
|
-
|
|
|
- if (CollectionUtils.isNotEmpty(las)) {
|
|
|
- Loginaccount la = new Loginaccount();
|
|
|
- la.setUserid(org.getUserid());
|
|
|
- la.setLoginstatus(3);//无效
|
|
|
- iLoginaccountMapper.update(la, new QueryWrapper<Loginaccount>().eq("loginid", la.getLoginid()));
|
|
|
-
|
|
|
- NotifyMI1.LoginAccChangeNtf.Builder builder = NotifyMI1.LoginAccChangeNtf.newBuilder();
|
|
|
- Common.MessageHead.Builder hd = Common.MessageHead.newBuilder();
|
|
|
- PublicMI1.NotifyHead.Builder nhd = PublicMI1.NotifyHead.newBuilder();
|
|
|
- nhd.setNtfMode(0);
|
|
|
- hd.setFunCode(FunCodeConstants.FunCode_Trade_LoginAccChangeNtf);
|
|
|
- hd.setClientTime(System.currentTimeMillis());
|
|
|
- builder.setNtfHeader(nhd);
|
|
|
- builder.setHeader(hd);
|
|
|
- las.forEach(p -> {
|
|
|
- NotifyMI1.LoginAccChange.Builder lab = NotifyMI1.LoginAccChange.newBuilder();
|
|
|
- lab.setChangeType(SysEnums.AccountOperateTypeEnum.DEL.getType());
|
|
|
- lab.setLoginId(p.getLoginid());
|
|
|
- builder.addLoginAccChange(lab);
|
|
|
- });
|
|
|
- byte[] body = ProtoHelper.getNTAS(builder.build().toByteArray(),
|
|
|
- FunCodeConstants.FunCode_Trade_LoginAccChangeNtf);
|
|
|
- rabbitTemplate.send(SysConstants.RabbitNtfKey,
|
|
|
- new Message(body, new MessageProperties()));
|
|
|
-
|
|
|
- log.info("用户注销发送登录账户变更通知:" + areaid.toString());
|
|
|
+ if (StringUtils.isNotBlank(ui.getOtherurl())) {
|
|
|
+ result.setOtherurl(Arrays.asList(ui.getOtherurl().split(",")));
|
|
|
}
|
|
|
+ result.setUserinfo(ui);
|
|
|
|
|
|
- // 发送用户注销消息给中心\银行接口
|
|
|
- List<Taaccount> tas = iTaaccountMapper.selectList(new QueryWrapper<Taaccount>()
|
|
|
- .eq("userid", org.getUserid())
|
|
|
- .eq("ismain", 1));
|
|
|
- iSendMsgService.sendM2BUnregistCustomerInfo(tas);
|
|
|
-
|
|
|
- return AjaxResult.success(Constants.Success_Code_Design, MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public AjaxResult recover(Long areaid, HttpServletRequest request) {
|
|
|
- Systemmanager systemmanager = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>().eq("LOGINCODE", iCommonService.getUserLoginCode(request)));
|
|
|
- if (!iCommonService.checkUserAccountRole(systemmanager, areaid)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.MESSAGE_ERROR_CODE_SYSTEM003.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- Useraccount org = iUseraccountMapper.selectOne(new QueryWrapper<Useraccount>().eq("userid", areaid));
|
|
|
- Userinfo ui = iUserinfoMapper.selectOne(new QueryWrapper<Userinfo>().eq("userid", areaid));
|
|
|
- //校验
|
|
|
- List<Userinfo> uiList = iUserinfoMapper.selectList(new QueryWrapper<Userinfo>()
|
|
|
- .eq("userstatus", 1)
|
|
|
- .ne("userid", ui.getUserid())
|
|
|
- .and(a -> a.eq("cardnum", ui.getCardnum()).or().eq(StringUtils.isNotBlank(ui.getMobile()), "mobile", ui.getMobile()))
|
|
|
- );
|
|
|
- if (CollectionUtils.isNotEmpty(uiList)) {
|
|
|
- for (int i = 0; i < uiList.size(); i++) {
|
|
|
- if (uiList.get(i).getCardnum().equals(ui.getCardnum())) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_006.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- //5 投资者
|
|
|
- if (org.getUsertype() == 5 && uiList.get(i).getMobile().equals(ui.getMobile())) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_007.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
+ Long did = ui.getDistrictid() != null ? ui.getDistrictid() :
|
|
|
+ (ui.getCityid() != null ? ui.getCityid() : ui.getProvinceid());
|
|
|
+ if (did != null) {
|
|
|
+ Division division = iDivisionMapper.selectOne(new QueryWrapper<Division>().eq("autoid", did));
|
|
|
+ if (division != null) {
|
|
|
+ result.setDivision(division.getSeparablename().replaceAll(">", ""));
|
|
|
}
|
|
|
}
|
|
|
- if (org.getParentuserid() != 0) {
|
|
|
- Useraccount p = iUseraccountMapper.selectOne(new QueryWrapper<Useraccount>().eq("userid", org.getParentuserid()));
|
|
|
- if (p.getAccountstatus() != 4) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_008.getCode(), request.getHeader("Accept-Language"));
|
|
|
+ if (userAccountVo.getModifystatus() != null && userAccountVo.getModifystatus() == 2) {
|
|
|
+ DraftUseraccountNew uo = iDraftUseraccountNewMapper.selectOne(new QueryWrapper<DraftUseraccountNew>().eq("userid", areaId));
|
|
|
+ DraftUserinfo dui = iDraftUserinfoMapper.selectOne(new QueryWrapper<DraftUserinfo>().eq("userid", areaId));
|
|
|
+ if (uo.getRefereeuserid() != null) {
|
|
|
+ result.setAfterrefereeusername(iUseraccountMapper.selectOrganName(uo.getRefereeuserid()));
|
|
|
}
|
|
|
- }
|
|
|
- //所属会员是否有经纪角色
|
|
|
- if (org.getUsertype() == 5) {
|
|
|
- Arearole ar = iArearoleMapper.selectOne(new QueryWrapper<Arearole>()
|
|
|
- .eq("roletype", 7)
|
|
|
- .eq("userid", org.getMemberuserid()));
|
|
|
- if (ar == null) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_009.getCode(), request.getHeader("Accept-Language"));
|
|
|
+ if (uo.getBroker() != null) {
|
|
|
+ result.setAfterborkername(iUseraccountMapper.selectOrganName(uo.getBroker()));
|
|
|
}
|
|
|
- }
|
|
|
- // todo allocated != null && allocated == 1
|
|
|
- org.setAccountstatus(4);
|
|
|
- org.setModifierid(systemmanager.getAutoid());
|
|
|
- org.setModifytime(new Date());
|
|
|
- iUseraccountMapper.update(org, new QueryWrapper<Useraccount>().eq("userid", org.getUserid()));
|
|
|
|
|
|
- ui.setUserstatus(1);
|
|
|
- iUserinfoMapper.update(ui, new QueryWrapper<Userinfo>().eq("userid", ui.getUserid()));
|
|
|
-
|
|
|
- //管理员账户
|
|
|
- Systemmanager admin = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>()
|
|
|
- .eq("areauserid", areaid)
|
|
|
- .eq("isdefault", 1));
|
|
|
- if (admin != null) {
|
|
|
- admin.setManagerstatus(1);
|
|
|
- iSystemmanagerMapper.updateById(admin);
|
|
|
+ result.setDraftUseraccountNew(uo);
|
|
|
+ result.setDraftUserinfo(dui);
|
|
|
}
|
|
|
- //写入日志
|
|
|
- if (org.getUsertype() == 2)
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ, "恢复机构id=" + org.getUserid(), systemmanager, null, null, null);
|
|
|
- else if (org.getUsertype() == 3 || org.getUsertype() == 4) {
|
|
|
- String name = "";
|
|
|
- if (org.getUsertype() == 3)
|
|
|
- name = "子机构";
|
|
|
- if (org.getUsertype() == 4)
|
|
|
- name = "经纪人";
|
|
|
- if (systemmanager.getReletype() == 1)
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ, "恢复" + name + "id=" + org.getUserid(), systemmanager, null, null, null);
|
|
|
- else
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ_ZJG, "恢复" + name + "id=" + org.getUserid(), systemmanager, null, null, null);
|
|
|
- } else if (org.getUsertype() == 5)
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_INVESTOR_MANAGE, "恢复投资者id=" + org.getUserid(), systemmanager, null, null, null);
|
|
|
-
|
|
|
- return AjaxResult.success(Constants.Success_Code_Design, MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
|
|
|
- @Override
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
- public AjaxResult addsonorgan(OrganParam param, HttpServletRequest request) {
|
|
|
- //校验唯一性
|
|
|
- List<Useraccount> c2 = iUseraccountMapper.selectList(new QueryWrapper<Useraccount>().eq("userid", createUserid(param.getParentuserid(), param.getUserid(), 4)));
|
|
|
- if (CollectionUtils.isNotEmpty(c2)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_010.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- // 机构开户证件号码是否唯一
|
|
|
- String areacardflag = iCommonService.getSystemParam(Constants.REDIS_HEADER_SYSPARAM, Constants.SYSPARAM_CARD_NO);
|
|
|
- //验证证件号码是否存在
|
|
|
- Boolean checkFlag1 = iCommonService.checkOranCardNumOrMobile(1, EncryptionUtils.encryptByAES(param.getCardnum().trim()), null);
|
|
|
- if (areacardflag != null && areacardflag.equals("1") && checkFlag1) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_011.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- List<WskhBlacklist> wskhBlacklists = iWskhBlacklistMapper.selectList(new QueryWrapper<WskhBlacklist>()
|
|
|
- .eq("CARDTYPE", param.getCardtypeid())
|
|
|
- .eq("CARDNUM", EncryptionUtils.encryptByAES(param.getCardnum().trim())));
|
|
|
- if (!CollectionUtils.isEmpty(wskhBlacklists)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_012.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- if (param.getUserinfotype() == 2) {
|
|
|
- //机构类型为企业需 名称唯一
|
|
|
- List<Userinfo> c3 = iUserinfoMapper.selectList(new QueryWrapper<Userinfo>()
|
|
|
- .eq("customername", param.getCustomername().trim())
|
|
|
- .eq("userinfotype", 2));
|
|
|
- if (CollectionUtils.isNotEmpty(c3)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_013.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- }
|
|
|
- List<Systemmanager> list = iSystemmanagerMapper.selectList(new QueryWrapper<Systemmanager>().eq("logincode", param.getLogincode().trim()));
|
|
|
- if (CollectionUtils.isNotEmpty(list)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_014.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- try {
|
|
|
- Systemmanager systemmanager = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>().eq("LOGINCODE", iCommonService.getUserLoginCode(request)));
|
|
|
- if (param.getUsertype() == 3) {
|
|
|
- addSonOrgan(param, systemmanager);
|
|
|
- } else {
|
|
|
- // todo 新增经纪人
|
|
|
- // userAccountSercive.addBroker(param, rsp.getUser());
|
|
|
- }
|
|
|
- } catch (Exception e) {
|
|
|
- log.info("新增失败,失败原因:" + e);
|
|
|
- throw new GlobalException(Constants.Error_Code_Design,MessageType.ORGAN_ERROR_CODE_015.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- return AjaxResult.success(Constants.Success_Code_Design, MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
+ //管理员账户信息
|
|
|
+ Systemmanager user = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>().eq("areauserid", areaId).eq("isdefault", 1));
|
|
|
+ result.setUsers(user);
|
|
|
|
|
|
- @Override
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
- public AjaxResult editsonorgan(OrganParam param, HttpServletRequest request) {
|
|
|
- Systemmanager systemmanager = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>().eq("LOGINCODE", iCommonService.getUserLoginCode(request)));
|
|
|
- Useraccount organ = iUseraccountMapper.selectOne(new QueryWrapper<Useraccount>().eq("userid", param.getUserid()));
|
|
|
-
|
|
|
- DraftUseraccountNew dua = new DraftUseraccountNew();
|
|
|
- BeanUtils.copyProperties(organ, dua);
|
|
|
-
|
|
|
- //校验
|
|
|
- String card = param.getCardnum();
|
|
|
- if (StringUtils.isNotBlank(card)) {
|
|
|
- card = EncryptionUtils.encryptByAES(card);
|
|
|
- List<Userinfo> uiList = iUserinfoMapper.selectList(new QueryWrapper<Userinfo>()
|
|
|
- .eq("usertype", 5)
|
|
|
- .eq("cardnum", card)
|
|
|
- .eq("userid", param.getUserid()));
|
|
|
- if (CollectionUtils.isNotEmpty(uiList)) {
|
|
|
- String sysparm = iCommonService.getSysparmById(Constants.SYSPARAM_CARD_NOTWO);
|
|
|
- if (sysparm == null || "1".equals(sysparm)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_011.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- String mobile = param.getMobile();
|
|
|
- if (StringUtils.isNotBlank(mobile)) {
|
|
|
- mobile = EncryptionUtils.encryptByAES(param.getMobile());
|
|
|
- List<Userinfo> uiList = iUserinfoMapper.selectList(new QueryWrapper<Userinfo>()
|
|
|
- .eq("usertype", 5)
|
|
|
- .eq("mobile", mobile)
|
|
|
- .eq("userid", param.getUserid()));
|
|
|
- if (CollectionUtils.isNotEmpty(uiList)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_016.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- dua.setAccountname(param.getAccountname());
|
|
|
- dua.setModifierid(systemmanager.getAutoid());
|
|
|
- dua.setModifytime(new Date());
|
|
|
- dua.setModifystatus(param.getModifystatus());
|
|
|
- if (param.getParentuserid() != null) {
|
|
|
- dua.setParentuserid(param.getParentuserid());
|
|
|
- }
|
|
|
- //todo 子机构新增未引入 更新是否实名、newContent字段 -- dyp
|
|
|
- //dua.setHasauth(param.getHasauth());
|
|
|
- dua.setNewcontent(JsonUtils.object2Json(dua));
|
|
|
- dua.setOldcontent(JsonUtils.object2Json(organ));
|
|
|
- iDraftUseraccountNewMapper.insert(dua);
|
|
|
-
|
|
|
- organ.setModifystatus(param.getModifystatus());
|
|
|
- organ.setModifierid(systemmanager.getAutoid());
|
|
|
- organ.setModifytime(new Date());
|
|
|
- iUseraccountMapper.update(organ, new QueryWrapper<Useraccount>().eq("userid", organ.getUserid()));
|
|
|
-
|
|
|
-
|
|
|
- Userinfo ui = iUserinfoMapper.selectOne(new QueryWrapper<Userinfo>().eq("userid", param.getUserid()));
|
|
|
- DraftUserinfo dui = new DraftUserinfo();
|
|
|
- BeanUtils.copyProperties(ui, dui);
|
|
|
- dui.setAddress(param.getAddress());
|
|
|
- dui.setBiznature(param.getBiznature());
|
|
|
- dui.setCardbackphotourl(param.getCardbackphotourl());
|
|
|
- dui.setCardfrontphotourl(param.getCardfrontphotourl());
|
|
|
- dui.setCardnum(param.getCardnum());
|
|
|
- dui.setCardtypeid(param.getCardtypeid());
|
|
|
- dui.setCityid(param.getCityid());
|
|
|
- dui.setCompany(param.getCompany());
|
|
|
- if (StringUtils.isBlank(param.getCustomername())) {
|
|
|
- //取useraccount里的accountname
|
|
|
- dui.setCustomername(param.getAccountname());
|
|
|
- } else {
|
|
|
- dui.setCustomername(param.getCustomername());
|
|
|
- }
|
|
|
- dui.setDistrictid(param.getDistrictid());
|
|
|
- dui.setEmail(param.getEmail());
|
|
|
- dui.setMobile(param.getMobile());
|
|
|
- dui.setModifierid(systemmanager.getAutoid());
|
|
|
- dui.setModifiertime(new Date());
|
|
|
- dui.setContactname(param.getContactname());
|
|
|
- dui.setPostalcode(param.getPostalcode());
|
|
|
- dui.setProvinceid(param.getProvinceid());
|
|
|
- dui.setQq(param.getQq());
|
|
|
- dui.setRemark(param.getRemark());
|
|
|
- dui.setSex(param.getSex());
|
|
|
- dui.setTelphone(param.getTelphone());
|
|
|
- dui.setWechat(param.getWechat());
|
|
|
- dui.setLegalpersonname(param.getLegalpersonname());
|
|
|
- dui.setLegalcardbackphotourl(param.getLegalcardbackphotourl());
|
|
|
- dui.setLegalcardfrontphotourl(param.getLegalcardfrontphotourl());
|
|
|
- dui.setAttachment1(param.getAttachment1());
|
|
|
- dui.setAttachment2(param.getAttachment2());
|
|
|
- dui = (DraftUserinfo) SensitiveEncryptUtil.sensitiveEncrypt(dui, null);
|
|
|
- iDraftUserinfoMapper.insert(dui);
|
|
|
-
|
|
|
- //资金账户配置变更 配置业务
|
|
|
- /*if (param.getConfig() != null && param.getConfig().getAccountid() != null) {
|
|
|
- //子账户为 投资者机构所有 关联给投资者使用,,
|
|
|
- //此处变更时,记为投资者变更 ,变更表userid填入投资者的userid
|
|
|
- DraftTaAccountConfig config = new DraftTaAccountConfig();
|
|
|
- config.setAccountid(param.getConfig().getAccountid());
|
|
|
- config.setUserid(organ.getUserid());
|
|
|
- config.setNewcontent(JSonHelp.object2Json(param.getConfig()));
|
|
|
- commonDao.merge(config);
|
|
|
- }*/
|
|
|
- JSONObject jsonObj = JSONObject.parseObject(JSONObject.toJSONString(dua));
|
|
|
- JSONObject jsonObjUi = JSONObject.parseObject(JSONObject.toJSONString(dui));
|
|
|
- if (organ.getUsertype() == 3 || organ.getUsertype() == 4) {
|
|
|
- if (systemmanager.getReletype() == 1) {
|
|
|
- if (organ.getUsertype() == 3)
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ_ZJG, "修改子机构id=" + organ.getUserid() + "并提交审核", systemmanager, null, jsonObjUi.toString(), jsonObj.toString());
|
|
|
- else
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ, "修改经纪人id=" + organ.getUserid() + "并提交审核", systemmanager, null, jsonObjUi.toString(), jsonObj.toString());
|
|
|
- } else {
|
|
|
- if (organ.getUsertype() == 3)
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ_ZJG, "修改子机构id=" + organ.getUserid() + "并提交审核", systemmanager, null, jsonObjUi.toString(), jsonObj.toString());
|
|
|
- else
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ, "修改经纪人id=" + organ.getUserid() + "并提交审核", systemmanager, null, jsonObjUi.toString(), jsonObj.toString());
|
|
|
- }
|
|
|
- } else if (organ.getUsertype() == 5) {
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_INVESTOR_MANAGE, "修改交易商id=" + organ.getUserid() + "并提交审核", systemmanager, null, jsonObjUi.toString(), jsonObj.toString());
|
|
|
- }
|
|
|
- return AjaxResult.success(Constants.Success_Code_Design, MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
- public AjaxResult edit(OrganParam param, HttpServletRequest request) {
|
|
|
- Systemmanager systemmanager = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>().eq("LOGINCODE", iCommonService.getUserLoginCode(request)));
|
|
|
- Useraccount organ = iUseraccountMapper.selectOne(new QueryWrapper<Useraccount>().eq("userid", param.getUserid()));
|
|
|
-
|
|
|
- //当为特许经销商时,因为新增特许经销商的时候,默认加了一个名称一样的报价商,现在修改特许经销商名称时,报价商名称也一起修改
|
|
|
- if (organ.getUsertype() == 2) {
|
|
|
- List<Arearole> ar = iArearoleMapper.selectList(new QueryWrapper<Arearole>()
|
|
|
- .eq("roletype", 13)
|
|
|
- .eq("userid", organ.getUserid()));
|
|
|
- if (CollectionUtils.isNotEmpty(ar)) {
|
|
|
- Quoter qt = iQuoterMapper.selectOne(new QueryWrapper<Quoter>()
|
|
|
- .eq("areauserid", organ.getUserid())
|
|
|
- .eq("quotername", organ.getAccountname()));
|
|
|
- if (Objects.nonNull(qt)) {
|
|
|
- qt.setQuotername(param.getAccountname()); //修改为修改后的机构名称
|
|
|
- qt.setModifytime(new Date());
|
|
|
- qt.setModifierid(systemmanager.getAutoid());
|
|
|
- iQuoterMapper.updateById(qt);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- organ.setAccountname(param.getAccountname());
|
|
|
- organ.setModifierid(systemmanager.getAutoid());
|
|
|
- organ.setModifytime(new Date());
|
|
|
- if (param.getRefereeuserid() != null) {
|
|
|
- organ.setRefereeuserid(param.getRefereeuserid());
|
|
|
- }
|
|
|
- iUseraccountMapper.update(organ, new QueryWrapper<Useraccount>().eq("userid", organ.getUserid()));
|
|
|
-
|
|
|
- String sysparm = iCommonService.getSysparmById(Constants.SYSPARAM_CARD_NOTWO);
|
|
|
-
|
|
|
- Userinfo ui = iUserinfoMapper.selectOne(new QueryWrapper<Userinfo>().eq("userid", param.getUserid()));
|
|
|
- if (ui.getCardnum() != null && !ui.getCardnum().equals(EncryptionUtils.encryptByAES(param.getCardnum()))) {
|
|
|
- Map<String, Object> map = new HashMap<String, Object>();
|
|
|
- String card = param.getCardnum();
|
|
|
- if (StringUtils.isNotBlank(card)) {
|
|
|
- card = EncryptionUtils.encryptByAES(param.getCardnum());
|
|
|
- List<Userinfo> uiList = iUserinfoMapper.selectList(new QueryWrapper<Userinfo>()
|
|
|
- .eq("cardnum", card)
|
|
|
- .eq("userid", param.getUserid()));
|
|
|
- if (CollectionUtils.isNotEmpty(uiList)) {
|
|
|
- if ((sysparm == null) || ("1".equals(sysparm))) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_011.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- }
|
|
|
- }
|
|
|
- if (ui.getUserinfotype() == 2 && !ui.getCustomername().equals(param.getCustomername().trim())) {
|
|
|
- //机构类型为企业需 名称唯一
|
|
|
- List<Userinfo> uiList = iUserinfoMapper.selectList(new QueryWrapper<Userinfo>()
|
|
|
- .eq("customername", param.getCustomername().trim())
|
|
|
- .eq("userinfotype", 2));
|
|
|
- if (CollectionUtils.isNotEmpty(uiList)) {
|
|
|
- return AjaxResult.error(Constants.Error_Code_Design, MessageType.ORGAN_ERROR_CODE_017.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
- }
|
|
|
- ui.setAddress(param.getAddress());
|
|
|
- ui.setBiznature(param.getBiznature());
|
|
|
- ui.setCardbackphotourl(param.getCardbackphotourl());
|
|
|
- ui.setCardfrontphotourl(param.getCardfrontphotourl());
|
|
|
- ui.setCardnum(param.getCardnum());
|
|
|
- ui.setCardtypeid(param.getCardtypeid());
|
|
|
- ui.setCityid(param.getCityid());
|
|
|
- ui.setCompany(param.getCompany());
|
|
|
- ui.setCustomername(param.getCustomername());
|
|
|
- ui.setDistrictid(param.getDistrictid());
|
|
|
- ui.setEmail(param.getEmail());
|
|
|
- ui.setMobile(param.getMobile());
|
|
|
- ui.setModifierid(systemmanager.getAutoid());
|
|
|
- ui.setModifiertime(new Date());
|
|
|
- ui.setContactname(param.getContactname());
|
|
|
- ui.setPostalcode(param.getPostalcode());
|
|
|
- ui.setProvinceid(param.getProvinceid());
|
|
|
- ui.setQq(param.getQq());
|
|
|
- ui.setRemark(param.getRemark());
|
|
|
- ui.setSex(param.getSex());
|
|
|
- ui.setTelphone(param.getTelphone());
|
|
|
- ui.setLegalcardbackphotourl(param.getLegalcardbackphotourl());
|
|
|
- ui.setLegalpersonname(param.getLegalpersonname());
|
|
|
- ui.setLegalcardfrontphotourl(param.getLegalcardfrontphotourl());
|
|
|
- ui.setWechat(param.getWechat());
|
|
|
- ui.setAttachment1(param.getAttachment1());
|
|
|
- ui.setAttachment2(param.getAttachment2());
|
|
|
-
|
|
|
- ui = (Userinfo) SensitiveEncryptUtil.sensitiveEncrypt(ui, null);
|
|
|
- iUserinfoMapper.update(ui, new QueryWrapper<Userinfo>().eq("userid", ui.getUserid()));
|
|
|
-
|
|
|
- if (organ.getUsertype().intValue() != 4) {
|
|
|
- Systemmanager admin = iSystemmanagerMapper.selectOne(new QueryWrapper<Systemmanager>()
|
|
|
- .eq("logincode", param.getLogincode()));
|
|
|
- if (admin != null && !admin.getUsername().equals(param.getUsername())) {
|
|
|
- admin.setUsername(param.getUsername());
|
|
|
- iSystemmanagerMapper.updateById(admin);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if (param.getUsertype() == 2 || param.getUsertype() == 3) {
|
|
|
- try {
|
|
|
- Userinfo current = iUserinfoMapper.selectOne(new QueryWrapper<Userinfo>().eq("userid", param.getUserid()));
|
|
|
- List<Taaccount> list = iTaaccountMapper.selectList(new QueryWrapper<Taaccount>()
|
|
|
- .eq("userid", current.getUserid())
|
|
|
- .eq("ismain", 1));
|
|
|
- if (CollectionUtils.isNotEmpty(list)) {
|
|
|
- list.forEach(p -> {
|
|
|
- iSendMsgService.sendCustomerInfo(current, p.getAccountid(), "2", 3);
|
|
|
- });
|
|
|
- }
|
|
|
- } catch (Exception e) {
|
|
|
- log.error("保存子机构修改信息发送消息失败,失败原因:" + e);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return AjaxResult.success(Constants.Success_Code_Design, MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language"));
|
|
|
- }
|
|
|
-
|
|
|
- public void addSonOrgan(OrganParam param, Systemmanager systemmanager) {
|
|
|
- String lPwd = iCommonService.getSystemParam(Constants.REDIS_HEADER_SYSPARAM, SysConstants.SYSPARAM_CODE_DEFAULT_PWD);
|
|
|
- Useraccount organ = new Useraccount();
|
|
|
- String userid = createUserid(param.getParentuserid(), param.getUserid(), 4);
|
|
|
- organ.setUserid(Long.valueOf(userid));
|
|
|
- organ.setRefernum(generateReferNum());
|
|
|
- String sysparm = iCommonService.getSysparmById("063");
|
|
|
- Useraccount parent = iUseraccountMapper.selectOne(new QueryWrapper<Useraccount>().eq("userid", param.getParentuserid()));
|
|
|
- organ.setUsertype(3);
|
|
|
-
|
|
|
- if (sysparm == null) {
|
|
|
- organ.setAccountstatus(4);
|
|
|
- } else if (sysparm.equals("1")) {
|
|
|
- organ.setAccountstatus(2);
|
|
|
- } else {
|
|
|
- organ.setAccountstatus(4);
|
|
|
- }
|
|
|
- organ.setCreatetradedate(iMarketrunMapper.selectOne(new QueryWrapper<Marketrun>().eq("marketid", 0L)).getTradedate());
|
|
|
- organ.setParentuserid(param.getParentuserid());
|
|
|
- organ.setMemberuserid(parent.getMemberuserid());
|
|
|
- organ.setCreatorid(systemmanager.getAutoid());
|
|
|
- organ.setCreatetime(new Date());
|
|
|
- organ.setModifierid(systemmanager.getAutoid());
|
|
|
- organ.setModifytime(new Date());
|
|
|
- organ.setAccountname(param.getAccountname());
|
|
|
- organ.setSubarealevelpath(parent.getSubarealevelpath() + organ.getUserid() + ",");
|
|
|
- iUseraccountMapper.insert(organ);
|
|
|
-
|
|
|
- Userinfo ui = new Userinfo();
|
|
|
- ui.setCustomername(organ.getAccountname());
|
|
|
- ui.setUsertype(3);
|
|
|
- ui.setUserstatus(1);
|
|
|
- ui.setOpenmode(1);
|
|
|
- ui.setCreatetime(new Date());
|
|
|
- ui.setCreatorid(systemmanager.getAutoid());
|
|
|
- ui.setUserid(organ.getUserid());
|
|
|
- ui.setUserinfotype(param.getUserinfotype());
|
|
|
- ui.setCustomername(param.getCustomername());
|
|
|
- ui.setCompany(param.getCompany());
|
|
|
- ui.setBiznature(param.getBiznature());
|
|
|
- ui.setCardtypeid(param.getCardtypeid());
|
|
|
- ui.setCardnum(param.getCardnum());
|
|
|
- ui.setCardfrontphotourl(param.getCardfrontphotourl());
|
|
|
- ui.setCardbackphotourl(param.getCardbackphotourl());
|
|
|
- ui.setLegalpersonname(param.getLegalpersonname());
|
|
|
- ui.setLegalcardfrontphotourl(param.getLegalcardfrontphotourl());
|
|
|
- ui.setLegalcardbackphotourl(param.getLegalcardbackphotourl());
|
|
|
- ui.setContactname(param.getContactname());
|
|
|
- ui.setSex(param.getSex());
|
|
|
- ui.setMobile(param.getMobile());
|
|
|
- ui.setTelphone(param.getTelphone());
|
|
|
- ui.setProvinceid(param.getProvinceid());
|
|
|
- ui.setCityid(param.getCityid());
|
|
|
- ui.setDistrictid(param.getDistrictid());
|
|
|
- ui.setAddress(param.getAddress());
|
|
|
- ui.setPostalcode(param.getPostalcode());
|
|
|
- ui.setEmail(param.getEmail());
|
|
|
- ui.setQq(EncryptionUtils.encryptByAES(param.getQq()));
|
|
|
- ui.setWechat(param.getWechat());
|
|
|
- ui.setRemark(param.getRemark());
|
|
|
- ui.setAttachment1(param.getAttachment1());
|
|
|
- ui.setAttachment2(param.getAttachment2());
|
|
|
- ui = (Userinfo) SensitiveEncryptUtil.sensitiveEncrypt(ui, null);
|
|
|
- iUserinfoMapper.insert(ui);
|
|
|
-
|
|
|
- //管理员账户
|
|
|
- Systemmanager us = new Systemmanager();
|
|
|
- us.setLogincode(param.getLogincode());
|
|
|
- us.setAreauserid(organ.getUserid());
|
|
|
- us.setUsername(StringUtils.isNotBlank(param.getUsername()) ? param.getUsername() : organ.getAccountname());
|
|
|
- us.setReletype(3);
|
|
|
- us.setManagerstatus(1);
|
|
|
- us.setLoginfailnum(0);
|
|
|
- us.setLoginstatus(1);
|
|
|
- us.setIsdefault(1);
|
|
|
- us.setUploginid(systemmanager.getAutoid());
|
|
|
- us.setModifytime(new Date());
|
|
|
- us.setPassword(EncryptionUtils.encryptSHA(us.getLogincode() + lPwd));
|
|
|
- us.setPwdexpdate(new Date());
|
|
|
- us.setManagertype(1);
|
|
|
- iSystemmanagerMapper.insert(us);
|
|
|
-
|
|
|
- Object l = redisServiceUtil.getCacheMapValue(Constants.REDIS_HEADER_SYSPARAM, "002");
|
|
|
- if (l == null || !"2".equals(l.toString())) {
|
|
|
- Roleuser ur = new Roleuser();
|
|
|
- ur.setRoleid(1L);
|
|
|
- ur.setManagerid(us.getAutoid());
|
|
|
- ur.setRoletype(3);
|
|
|
- iRoleuserMapper.insert(ur);
|
|
|
- }
|
|
|
- //子机构
|
|
|
- if (organ.getUsertype() == 3) {
|
|
|
- Roleuser ur = new Roleuser();
|
|
|
- ur.setRoleid(12L);
|
|
|
- ur.setManagerid(us.getAutoid());
|
|
|
- ur.setRoletype(3);
|
|
|
- iRoleuserMapper.insert(ur);
|
|
|
- }
|
|
|
-
|
|
|
- //资金账户 多币种----
|
|
|
- List<Enumdicitem> li = iEnumdicitemMapper.selectList(new QueryWrapper<Enumdicitem>()
|
|
|
- .eq("enumdiccode", "currency")
|
|
|
- .eq("enumitemstatus", 1));
|
|
|
-
|
|
|
- BankSystemconfig config = iBankSystemconfigMapper.selectOne(new QueryWrapper<BankSystemconfig>().eq("CONFIGID", SysConstants.BANK_CONFIG_ACTIVATION));
|
|
|
- lPwd = EncryptionUtils.encryptSHA(lPwd);
|
|
|
- List<Taaccount> taaccounts = new ArrayList<>();
|
|
|
- for (int i = 0; i < li.size(); i++) {
|
|
|
- String manageid = redisServiceUtil.getCacheMapValue(Constants.REDIS_HEADER_SYSPARAM, "001");
|
|
|
- Long accountno = Long.valueOf(manageid + CommonUtil.addZero(String.valueOf(idGeneratorUtils.getGeneratorID(Taaccount.class)), 9));
|
|
|
- Taaccount ac = new Taaccount();
|
|
|
- ac.setAccountid(accountno);
|
|
|
- ac.setUserid(organ.getUserid());
|
|
|
- ac.setPassword(lPwd);
|
|
|
- ac.setCurrencyid(li.get(i).getEnumitemname());
|
|
|
- //资金账号是否需要激活
|
|
|
- if (config != null && config.getValidstatus() == 1 && config.getConfigvalue().equals("1") && ac.getIsmain() == 1) {
|
|
|
- ac.setTradestatus(SysEnums.TradeStatusEnum.TOBEACTIVATE.getType());
|
|
|
- } else {
|
|
|
- ac.setTradestatuschangetime(new Date()); //激活时间
|
|
|
- }
|
|
|
- if (1 == li.get(i).getEnumitemname()) {
|
|
|
- organ.setReckonaccountid(accountno);
|
|
|
+ //如果是经纪会员、会员子机构、经纪人,则查询网上开户地址
|
|
|
+ Map<String, Object> map = new HashMap<>();
|
|
|
+ if (null == role || role == SysEnums.OrganRole.broker.getCode().intValue()
|
|
|
+ || userAccountVo.getUsertype() == 3 || userAccountVo.getUsertype() == 4) {
|
|
|
+ WskhOpenaccountconfig config = iWskhOpenaccountconfigMapper.selectOne(new QueryWrapper<WskhOpenaccountconfig>().eq("configtype", 59));
|
|
|
+ if (null != config && null != config.getConfigvalue()) {
|
|
|
+ result.setOpenUrl(config.getConfigvalue());
|
|
|
}
|
|
|
- ac.setRelateduserid(organ.getUserid());
|
|
|
- ac.setRelatedaccountstatus(1);
|
|
|
- taaccounts.add(ac);
|
|
|
- iTaaccountMapper.insert(ac);
|
|
|
-
|
|
|
- Userreckonaccount ura = new Userreckonaccount();
|
|
|
- ura.setCurrencyid(ac.getCurrencyid());
|
|
|
- ura.setUserid(ac.getUserid());
|
|
|
- ura.setReckonaccountid(ac.getAccountid());
|
|
|
- ura.setUpdatetime(new Date());
|
|
|
- ura.setDefaultaccounttype(1);
|
|
|
- iUserreckonaccountMapper.insert(ura);
|
|
|
}
|
|
|
-
|
|
|
- Integer reletype = systemmanager.getReletype();
|
|
|
- String menucode = "";
|
|
|
- if (reletype.equals(1))
|
|
|
- menucode = "M00400220000";
|
|
|
- else
|
|
|
- menucode = SysConstants.PART_CODE_ORGZ_ZJG;
|
|
|
- JSONObject jsonObj = JSONObject.parseObject(JSONObject.toJSONString(param));
|
|
|
- if (organ.getUsertype() == 2) {
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_CODE_ORGZ, "新增机构id=" + organ.getUserid(), systemmanager, null, "{}", jsonObj.toString());
|
|
|
- } else if (organ.getUsertype() == 3) {
|
|
|
- systemmanagerService.writeOperateLog(menucode, "新增子机构id=" + organ.getUserid(), systemmanager, null, "{\"userid\":" + organ.getUserid() + "}", jsonObj.toString());
|
|
|
- } else if (organ.getUsertype() == 4) {
|
|
|
- systemmanagerService.writeOperateLog(menucode, "新增经纪人id=" + organ.getUserid(), systemmanager, null, "{\"userid\":" + organ.getUserid() + "}", jsonObj.toString());
|
|
|
- } else if (organ.getUsertype() == 5) {
|
|
|
- systemmanagerService.writeOperateLog(SysConstants.PART_INVESTOR_OPEN, "新增投资者id=" + organ.getUserid(), systemmanager, null, "{\"userid\":" + organ.getUserid() + "}", jsonObj.toString());
|
|
|
+ //移动端开户地址
|
|
|
+ WskhOpenaccountconfig config1 = iWskhOpenaccountconfigMapper.selectOne(new QueryWrapper<WskhOpenaccountconfig>().eq("configtype", 60));
|
|
|
+ if (null != config1 && null != config1.getConfigvalue()) {
|
|
|
+ result.setMobileUrl(config1.getConfigvalue());
|
|
|
}
|
|
|
|
|
|
- try {
|
|
|
- for (int i = 0; i < taaccounts.size(); i++) {
|
|
|
- iSendMsgService.sendCustomerInfo(ui, taaccounts.get(i).getAccountid(), "1", 3);
|
|
|
- iSendMsgService.sendUserChangeMsg(taaccounts.get(i).getAccountid(), taaccounts.get(i).getUserid(),
|
|
|
- SysEnums.UserOperateTypeEnum.ADD.getType(),
|
|
|
- SysEnums.AccountOperateTypeEnum.ADD.getType(),
|
|
|
- SysEnums.NotifyModeEnum.UNICAST.getType());
|
|
|
- }
|
|
|
- } catch (Exception e) {
|
|
|
- log.error("新增子机构发送消息失败;失败原因:" + e);
|
|
|
+ //微信开户地址
|
|
|
+ WskhOpenaccountconfig config2 = iWskhOpenaccountconfigMapper.selectOne(new QueryWrapper<WskhOpenaccountconfig>().eq("configtype", 65));
|
|
|
+ if (null != config2 && null != config2.getConfigvalue()) {
|
|
|
+ result.setWeixinUrl(config2.getConfigvalue());
|
|
|
}
|
|
|
- }
|
|
|
|
|
|
- private DetailAfterResult getModifyInvestorDetail(Long userid) {
|
|
|
- DetailAfterResult detailResult = new DetailAfterResult();
|
|
|
- UserAccountDetailVo userAccountDetailVo = iUseraccountMapper.selectNewDetail(userid);
|
|
|
- detailResult.setUserAccountDetailVo(userAccountDetailVo);
|
|
|
- UserinfoDetailVo userinfoDetailVo = iUserinfoMapper.getUserinfoNewDetail(userid);
|
|
|
- detailResult.setUserinfoDetailVo(userinfoDetailVo);
|
|
|
- return detailResult;
|
|
|
- }
|
|
|
-
|
|
|
- private DetailBeforeResult getUserAccountDetail(Long userid, OrganSonDetailResult result) {
|
|
|
- DetailBeforeResult detailResult = new DetailBeforeResult();
|
|
|
- UserAccountDetailVo userAccountDetailVo = iUseraccountMapper.selectDetail(userid);
|
|
|
- detailResult.setUserAccountDetailVo(userAccountDetailVo);
|
|
|
- UserinfoDetailVo userinfoDetailVo = iUserinfoMapper.getUserinfoDetail(userid);
|
|
|
- detailResult.setUserinfoDetailVo(userinfoDetailVo);
|
|
|
- //开户地址
|
|
|
- if (userAccountDetailVo.getUsertype() != 5) {
|
|
|
- //如果是经纪会员、会员子机构、经纪人,则查询网上开户地址
|
|
|
- WskhOpenaccountconfig config = iWskhOpenaccountconfigMapper.selectOne(new QueryWrapper<WskhOpenaccountconfig>()
|
|
|
- .eq("configtype", 59));
|
|
|
- if (null != config && null != config.getConfigvalue()) {
|
|
|
- result.setOpenUrl(config.getConfigvalue());
|
|
|
- }
|
|
|
- //移动端开户地址
|
|
|
- WskhOpenaccountconfig config1 = iWskhOpenaccountconfigMapper.selectOne(new QueryWrapper<WskhOpenaccountconfig>()
|
|
|
- .eq("configtype", 59));
|
|
|
- if (null != config1 && null != config1.getConfigvalue()) {
|
|
|
- result.setMobileUrl(config.getConfigvalue());
|
|
|
- }
|
|
|
- //微信开户地址
|
|
|
- WskhOpenaccountconfig config2 = iWskhOpenaccountconfigMapper.selectOne(new QueryWrapper<WskhOpenaccountconfig>()
|
|
|
- .eq("configtype", 59));
|
|
|
- if (null != config2 && null != config2.getConfigvalue()) {
|
|
|
- result.setWeixinUrl(config.getConfigvalue());
|
|
|
- }
|
|
|
- //三方开户地址
|
|
|
- WskhOpenaccountconfig config3 = iWskhOpenaccountconfigMapper.selectOne(new QueryWrapper<WskhOpenaccountconfig>()
|
|
|
- .eq("configtype", 59));
|
|
|
- if (null != config3 && null != config3.getConfigvalue()) {
|
|
|
- result.setSanfangUrl(config.getConfigvalue());
|
|
|
- }
|
|
|
+ //三方开户地址
|
|
|
+ WskhOpenaccountconfig config3 = iWskhOpenaccountconfigMapper.selectOne(new QueryWrapper<WskhOpenaccountconfig>().eq("configtype", 66));
|
|
|
+ if (null != config3 && null != config3.getConfigvalue()) {
|
|
|
+ result.setSanfangUrl(config3.getConfigvalue());
|
|
|
}
|
|
|
- return detailResult;
|
|
|
- }
|
|
|
|
|
|
- private String createUserid(Long pid, Long userid, Integer len) {
|
|
|
- String memid = pid.toString().substring(0, 4);
|
|
|
- return memid + CommonUtil.addZero(userid.toString(), len);
|
|
|
- }
|
|
|
-
|
|
|
- private String generateReferNum() {
|
|
|
- //系统参数996 为2时,推荐码只有数字;
|
|
|
- String sysparm = iCommonService.getSysparmById("996");
|
|
|
- if (sysparm != null && !sysparm.equals("2")) {
|
|
|
- return CommonUtil.getUuid2();
|
|
|
- }
|
|
|
- return CommonUtil.getUuid();
|
|
|
+ return AjaxResult.success(Constants.Success_Code_Design, MessageType.MESSAGE_CODE_SYSTEM001.getCode(), request.getHeader("Accept-Language"), result);
|
|
|
}
|
|
|
}
|