diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/SettingConfigService.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/SettingConfigService.java index 79db995a..7318ebc1 100644 --- a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/SettingConfigService.java +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/api/SettingConfigService.java @@ -1,6 +1,5 @@ package com.xhpc.common.api; -import com.xhpc.common.api.factory.CardHistoryOrderFactory; import com.xhpc.common.api.factory.SettingConfigFactory; import com.xhpc.common.core.constant.ServiceNameConstants; import com.xhpc.common.core.domain.R; diff --git a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcAppUserController.java b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcAppUserController.java index 95852fd8..43fabe6f 100644 --- a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcAppUserController.java +++ b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcAppUserController.java @@ -166,7 +166,8 @@ public class XhpcAppUserController extends BaseController { R r = settingConfigService.settingConfig(1, tenantId); if(r !=null && r.getCode()==200){ XhpcSettingConfig xhpcSettingConfig = (XhpcSettingConfig)r.getData(); - String url = "https://api.weixin.qq.com/sns/jscode2session?appid="+xhpcSettingConfig.getWxAppId()+"&secret="+xhpcSettingConfig.getWxAppSecret()+"&js_code="+ jsCode + "&grant_type=authorization_code"; + Map mapConfig = (Map)r.getData(); + String url = "https://api.weixin.qq.com/sns/jscode2session?appid="+mapConfig.get("wxAppId").toString()+"&secret="+mapConfig.get("wxAppSecret").toString()+"&js_code="+ jsCode + "&grant_type=authorization_code"; String result = HttpUtils.get(url); JSONObject json = JSON.parseObject(result); if (null != json) { @@ -247,23 +248,23 @@ public class XhpcAppUserController extends BaseController { if("".equals(tenantId) || null==tenantId){ tenantId="000000"; } - R r = settingConfigService.settingConfig(1, tenantId); + R r = settingConfigService.settingConfig(2, tenantId); if(r !=null && r.getCode()==200){ - XhpcSettingConfig xhpcSettingConfig = (XhpcSettingConfig)r.getData(); + Map map = (Map)r.getData(); /** 初始化 **/ CertAlipayRequest certAlipayRequest = new CertAlipayRequest(); /** 支付宝网关 **/ certAlipayRequest.setServerUrl("https://openapi.alipay.com/gateway.do"); /** 应用id,如何获取请参考:https://opensupport.alipay.com/support/helpcenter/190/201602493024 **/ - certAlipayRequest.setAppId(xhpcSettingConfig.getZfbAppId()); + certAlipayRequest.setAppId(map.get("zfbAppId").toString()); /** 应用私钥, 如何获取请参考:https://opensupport.alipay.com/support/helpcenter/207/201602471154?ant_source=antsupport **/ - certAlipayRequest.setPrivateKey(xhpcSettingConfig.getZfbPrivateKey()); + certAlipayRequest.setPrivateKey(map.get("zfbPrivateKey").toString()); /** 应用公钥证书路径,下载后保存位置的绝对路径 **/ - certAlipayRequest.setCertPath(xhpcSettingConfig.getZfbAppCertPublicKey()); + certAlipayRequest.setCertPath(map.get("zfbAppCertPublicKey").toString()); /** 支付宝公钥证书路径,下载后保存位置的绝对路径 **/ - certAlipayRequest.setAlipayPublicCertPath(xhpcSettingConfig.getZfbAppCertPublicKey()); + certAlipayRequest.setAlipayPublicCertPath(map.get("zfbAlipayCertPublicKeyRsa").toString()); /** 支付宝根证书路径,下载后保存位置的绝对路径 **/ - certAlipayRequest.setRootCertPath(xhpcSettingConfig.getZfbAlipayRootCert()); + certAlipayRequest.setRootCertPath(map.get("zfbAlipayRootCert").toString()); /** 设置签名类型 **/ certAlipayRequest.setSignType("RSA2"); /** 设置请求格式,固定值json **/ diff --git a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcCommunityController.java b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcCommunityController.java index 2d569784..847bfc96 100644 --- a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcCommunityController.java +++ b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcCommunityController.java @@ -43,8 +43,8 @@ public class XhpcCommunityController extends BaseController { */ @Log(title = "社区", businessType = BusinessType.INSERT) @PostMapping(value = "/addCommunity") - public AjaxResult addCommunity(@RequestBody XhpcCommunity xhpcCommunity) { - return xhpcCommunityService.addCommunity(xhpcCommunity); + public AjaxResult addCommunity(HttpServletRequest request,@RequestBody XhpcCommunity xhpcCommunity) { + return xhpcCommunityService.addCommunity(request,xhpcCommunity); } /** @@ -94,8 +94,8 @@ public class XhpcCommunityController extends BaseController { */ @Log(title = "社区人员", businessType = BusinessType.INSERT) @PostMapping(value = "/addCommunityPersonnel") - public AjaxResult addCommunityPersonnel(@RequestBody XhpcCommunityPersonnel xhpcCommunityPersonnel) { - return xhpcCommunityService.addCommunityPersonnel(xhpcCommunityPersonnel); + public AjaxResult addCommunityPersonnel(HttpServletRequest request,@RequestBody XhpcCommunityPersonnel xhpcCommunityPersonnel) { + return xhpcCommunityService.addCommunityPersonnel(request,xhpcCommunityPersonnel); } /** diff --git a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcCustomersController.java b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcCustomersController.java index dbb3e958..3e38adba 100644 --- a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcCustomersController.java +++ b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/controller/XhpcCustomersController.java @@ -91,8 +91,8 @@ public class XhpcCustomersController extends BaseController { */ @Log(title = "大客户人员", businessType = BusinessType.INSERT) @PostMapping(value = "/addCustomersPersonnel") - public AjaxResult addCustomersPersonnel(@RequestBody XhpcCustomersPersonnel xhpcCustomersPersonnel) { - return xhpcCustomersService.addCustomersPersonnel(xhpcCustomersPersonnel); + public AjaxResult addCustomersPersonnel(HttpServletRequest request, @RequestBody XhpcCustomersPersonnel xhpcCustomersPersonnel) { + return xhpcCustomersService.addCustomersPersonnel(request,xhpcCustomersPersonnel); } /** diff --git a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCommunity.java b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCommunity.java index 465ec492..bb30c3b9 100644 --- a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCommunity.java +++ b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCommunity.java @@ -84,4 +84,10 @@ public class XhpcCommunity extends BaseEntity { * 电站id */ private String chargingStationIds; + + /** + * 运营商id + */ + private Long operatorId; + } diff --git a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCommunityPersonnel.java b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCommunityPersonnel.java index d4d62bf6..ee1b8f6b 100644 --- a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCommunityPersonnel.java +++ b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCommunityPersonnel.java @@ -79,4 +79,8 @@ public class XhpcCommunityPersonnel extends BaseEntity { * 充值订单id、退款订单id */ private Long moneyOrderId; + + private Long createId; + + private Integer createType; } diff --git a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCustomersPersonnel.java b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCustomersPersonnel.java index 8403471e..2d14f3e2 100644 --- a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCustomersPersonnel.java +++ b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/domain/XhpcCustomersPersonnel.java @@ -77,4 +77,8 @@ public class XhpcCustomersPersonnel extends BaseEntity { * 充值订单id、退款订单id */ private Long moneyOrderId; + + private Long createId; + + private Integer createType; } diff --git a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/IXhpcCommunityService.java b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/IXhpcCommunityService.java index 11a5ab2c..b7fc2e4b 100644 --- a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/IXhpcCommunityService.java +++ b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/IXhpcCommunityService.java @@ -30,7 +30,7 @@ public interface IXhpcCommunityService { * @param * @return */ - AjaxResult addCommunity(XhpcCommunity xhpcCommunity); + AjaxResult addCommunity(HttpServletRequest request,XhpcCommunity xhpcCommunity); /** * 删除社区组树 @@ -63,7 +63,7 @@ public interface IXhpcCommunityService { * @param * @return */ - AjaxResult addCommunityPersonnel(XhpcCommunityPersonnel xhpcCommunityPersonnel); + AjaxResult addCommunityPersonnel(HttpServletRequest request,XhpcCommunityPersonnel xhpcCommunityPersonnel); /** * 查询社区人员 diff --git a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/IXhpcCustomersService.java b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/IXhpcCustomersService.java index d30fdaea..1b805fb9 100644 --- a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/IXhpcCustomersService.java +++ b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/IXhpcCustomersService.java @@ -62,7 +62,7 @@ public interface IXhpcCustomersService { * @param * @return */ - AjaxResult addCustomersPersonnel(XhpcCustomersPersonnel xhpcCustomersPersonnel); + AjaxResult addCustomersPersonnel(HttpServletRequest request, XhpcCustomersPersonnel xhpcCustomersPersonnel); /** * 查询社区人员 diff --git a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/impl/XhpcCommunityServiceImpl.java b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/impl/XhpcCommunityServiceImpl.java index 7437a10a..c4d8def2 100644 --- a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/impl/XhpcCommunityServiceImpl.java +++ b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/impl/XhpcCommunityServiceImpl.java @@ -6,6 +6,7 @@ import com.xhpc.common.core.web.domain.AjaxResult; import com.xhpc.common.core.web.service.BaseService; import com.xhpc.common.security.service.TokenService; import com.xhpc.common.util.UserTypeUtil; +import com.xhpc.system.api.domain.SysUser; import com.xhpc.system.api.model.LoginUser; import com.xhpc.user.domain.XhpcCommunity; import com.xhpc.user.domain.XhpcCommunityPersonnel; @@ -57,7 +58,7 @@ public class XhpcCommunityServiceImpl extends BaseService implements IXhpcCommun } @Override - public AjaxResult addCommunity(XhpcCommunity xhpcCommunity) { + public AjaxResult addCommunity(HttpServletRequest request,XhpcCommunity xhpcCommunity) { R r= judgeXhpcCommunity(xhpcCommunity); if(r.getCode() !=200){ @@ -75,6 +76,19 @@ public class XhpcCommunityServiceImpl extends BaseService implements IXhpcCommun }else{ xhpcCommunity.setStatus(1); } + Long userId = SecurityUtils.getUserId(); + if(userId !=null){ + LoginUser loginUser = tokenService.getLoginUser(request); + SysUser sysUser = loginUser.getSysUser(); + if(UserTypeUtil.SYS_USER_TYPE_ZERO.equals(sysUser.getUserType())){ + xhpcCommunity.setType(2); + xhpcCommunity.setOperatorId(sysUser.getOperatorId()); + }else{ + xhpcCommunity.setType(1); + } + }else{ + return AjaxResult.error("请重新登录"); + } xhpcCommunityMapper.addCommunity(xhpcCommunity); if(!"".equals(chargingStationIds) && chargingStationIds !=null){ mechanismService.addMechanism(Arrays.asList(chargingStationIds.split(",")),xhpcCommunity.getCommunityId(),0); @@ -137,7 +151,7 @@ public class XhpcCommunityServiceImpl extends BaseService implements IXhpcCommun @Override @Transactional - public AjaxResult addCommunityPersonnel(XhpcCommunityPersonnel xhpcCommunityPersonnel) { + public AjaxResult addCommunityPersonnel(HttpServletRequest request,XhpcCommunityPersonnel xhpcCommunityPersonnel) { R r = judgeXhpcCommunityPersonnel(xhpcCommunityPersonnel); if(r.getCode()!=200){ return AjaxResult.error(r.getMsg()); @@ -158,6 +172,19 @@ public class XhpcCommunityServiceImpl extends BaseService implements IXhpcCommun //增加社区用户的剩余金额 xhpcCommunityPersonnel.setSurplusMoney(rechargeMoney); } + Long userId = SecurityUtils.getUserId(); + if(userId !=null){ + LoginUser loginUser = tokenService.getLoginUser(request); + SysUser sysUser = loginUser.getSysUser(); + if(UserTypeUtil.SYS_USER_TYPE_ZERO.equals(sysUser.getUserType())){ + xhpcCommunityPersonnel.setCreateType(2); + xhpcCommunityPersonnel.setCreateId(sysUser.getOperatorId()); + }else{ + xhpcCommunityPersonnel.setCreateType(1); + } + }else{ + return AjaxResult.error("请重新登录"); + } xhpcCommunityMapper.addCommunityPersonnel(xhpcCommunityPersonnel); //增加一条充值记录 if(new BigDecimal(0).compareTo(rechargeMoney)==-1){ diff --git a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/impl/XhpcCustomersServiceImpl.java b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/impl/XhpcCustomersServiceImpl.java index 1bf33324..bbf68b4b 100644 --- a/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/impl/XhpcCustomersServiceImpl.java +++ b/xhpc-modules/xhpc-user/src/main/java/com/xhpc/user/service/impl/XhpcCustomersServiceImpl.java @@ -6,6 +6,7 @@ import com.xhpc.common.core.web.domain.AjaxResult; import com.xhpc.common.core.web.service.BaseService; import com.xhpc.common.security.service.TokenService; import com.xhpc.common.util.UserTypeUtil; +import com.xhpc.system.api.domain.SysUser; import com.xhpc.system.api.model.LoginUser; import com.xhpc.user.domain.XhpcCommunity; import com.xhpc.user.domain.XhpcCustomers; @@ -65,14 +66,12 @@ public class XhpcCustomersServiceImpl extends BaseService implements IXhpcCustom Long userId = SecurityUtils.getUserId(); if(userId !=null){ LoginUser loginUser = tokenService.getLoginUser(request); - Map landUser = xhpcCustomersMapper.getLandUser(loginUser.getUserid()); - if(landUser !=null && landUser.get("userType") !=null){ - if("00".equals(landUser.get("userType").toString()) ){ - xhpcCustomers.setType(1); - }else{ - xhpcCustomers.setType(2); - xhpcCustomers.setOperatorId(Long.parseLong(landUser.get("operatorId").toString())); - } + SysUser sysUser = loginUser.getSysUser(); + if(UserTypeUtil.SYS_USER_TYPE_ZERO.equals(sysUser.getUserType())){ + xhpcCustomers.setType(2); + xhpcCustomers.setOperatorId(sysUser.getOperatorId()); + }else{ + xhpcCustomers.setType(1); } }else{ return AjaxResult.error("请重新登录"); @@ -141,7 +140,7 @@ public class XhpcCustomersServiceImpl extends BaseService implements IXhpcCustom } @Override - public AjaxResult addCustomersPersonnel(XhpcCustomersPersonnel xhpcCustomersPersonnel) { + public AjaxResult addCustomersPersonnel(HttpServletRequest request, XhpcCustomersPersonnel xhpcCustomersPersonnel) { R r = judgeXhpcCustomersPersonnel(xhpcCustomersPersonnel); if(r.getCode()!=200){ return AjaxResult.error(r.getMsg()); @@ -164,6 +163,19 @@ public class XhpcCustomersServiceImpl extends BaseService implements IXhpcCustom xhpcCustomersPersonnel.setSurplusMoney(rechargeMoney); } } + Long userId = SecurityUtils.getUserId(); + if(userId !=null){ + LoginUser loginUser = tokenService.getLoginUser(request); + SysUser sysUser = loginUser.getSysUser(); + if(UserTypeUtil.SYS_USER_TYPE_ZERO.equals(sysUser.getUserType())){ + xhpcCustomersPersonnel.setCreateType(2); + xhpcCustomersPersonnel.setCreateId(sysUser.getOperatorId()); + }else{ + xhpcCustomersPersonnel.setCreateType(1); + } + }else{ + return AjaxResult.error("请重新登录"); + } xhpcCustomersMapper.addCustomersPersonnel(xhpcCustomersPersonnel); if(rechargeMoney !=null){ //增加一条充值记录 diff --git a/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcCommunityMapper.xml b/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcCommunityMapper.xml index ef6c311f..f5fd9ad4 100644 --- a/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcCommunityMapper.xml +++ b/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcCommunityMapper.xml @@ -92,6 +92,12 @@ remark, + + type, + + + operatorId, + @@ -139,6 +145,12 @@ #{remark}, + + #{type}, + + + #{operatorId}, + @@ -280,6 +292,12 @@ remark, + + create_id, + + + create_type, + @@ -333,6 +351,12 @@ #{remark}, + + #{createId}, + + + #{createType}, + diff --git a/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcCustomersMapper.xml b/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcCustomersMapper.xml index 8cf5aef7..c6ed8ad4 100644 --- a/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcCustomersMapper.xml +++ b/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcCustomersMapper.xml @@ -90,6 +90,12 @@ remark, + + type, + + + operator_id, + @@ -134,6 +140,12 @@ #{remark}, + + #{type}, + + + #{operatorId}, + @@ -274,6 +286,12 @@ remark, + + create_id, + + + create_type, + @@ -327,6 +345,12 @@ #{remark}, + + #{createId}, + + + #{createType}, +