From 7d1abc56db2b67657070016c19640f815f627994 Mon Sep 17 00:00:00 2001
From: lishuai <260038442@qq.com>
Date: 星期四, 14 十二月 2023 17:48:47 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java | 504 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 499 insertions(+), 5 deletions(-)
diff --git a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java
index ee3c8b9..9429df2 100644
--- a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java
+++ b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java
@@ -1,23 +1,56 @@
package com.doumee.service.business.impl.erp;
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.doumee.biz.system.SystemDictDataBiz;
+import com.doumee.config.Jwt.JwtPayLoad;
+import com.doumee.config.Jwt.JwtTokenUtil;
+import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.exception.BusinessException;
+import com.doumee.core.haikang.model.HKConstants;
import com.doumee.core.haikang.model.param.request.AcsDeviceListRequest;
import com.doumee.core.haikang.model.param.request.DoorsListRequest;
-import com.doumee.core.haikang.model.param.request.ParkListRequest;
import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest;
import com.doumee.core.haikang.model.param.request.event.acs.EventAcsRequest;
import com.doumee.core.haikang.model.param.request.event.parks.EventParkRequest;
import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest;
+import com.doumee.core.model.PageData;
+import com.doumee.core.model.PageWrap;
+import com.doumee.core.model.openapi.request.*;
import com.doumee.core.model.openapi.request.erp.OrgListRequest;
import com.doumee.core.model.openapi.request.erp.UserInfoRequest;
import com.doumee.core.model.openapi.request.erp.UserListRequest;
+import com.doumee.core.model.openapi.response.*;
import com.doumee.core.model.openapi.response.erp.OrgListRespone;
-import com.doumee.service.business.ERPSyncService;
-import com.doumee.service.business.HkSyncService;
+import com.doumee.core.utils.Constants;
+import com.doumee.core.utils.DESUtil;
+import com.doumee.core.utils.Utils;
+import com.doumee.core.utils.redis.RedisUtil;
+import com.doumee.dao.admin.response.MemberInfoDTO;
+import com.doumee.dao.business.*;
+import com.doumee.dao.business.join.CarEventJoinMapper;
+import com.doumee.dao.business.join.DeviceEventJoinMapper;
+import com.doumee.dao.business.join.VisitEventJoinMapper;
+import com.doumee.dao.business.model.*;
+import com.doumee.dao.web.reqeust.CheckVisitedDTO;
+import com.doumee.dao.web.response.MemberVO;
+import com.doumee.service.business.*;
+import com.github.yulichang.wrapper.MPJLambdaWrapper;
+import io.swagger.models.auth.In;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.checkerframework.checker.units.qual.A;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import javax.servlet.http.HttpServletResponse;
-import java.util.ArrayList;
-import java.util.List;
+import java.util.*;
+import java.util.stream.Collectors;
/**
* 璁惧淇℃伅琛⊿ervice瀹炵幇
@@ -26,6 +59,49 @@
*/
@Service
public class ErpSyncServiceImpl implements ERPSyncService {
+
+ @Autowired
+ private SystemDictDataBiz systemDictDataBiz;
+
+ @Autowired
+ private RedisTemplate<String, Object> redisTemplate;
+
+ @Autowired
+ private DeviceRoleMapper deviceRoleMapper;
+
+ @Autowired
+ private DeviceMapper deviceMapper;
+
+ @Autowired
+ private ParksMapper parksMapper;
+
+ @Autowired
+ private VisitEventMapper visitEventMapper;
+
+
+ @Autowired
+ private VisitEventJoinMapper visitEventJoinMapper;
+
+ @Autowired
+ private DeviceEventJoinMapper deviceEventJoinMapper;
+
+ @Autowired
+ private CarEventJoinMapper carEventJoinMapper;
+
+ @Autowired
+ private CompanyMapper companyMapper;
+
+ @Autowired
+ private MemberMapper memberMapper;
+
+ @Autowired
+ private MemberRoleMapper memberRoleMapper;
+
+ @Autowired
+ private MemberCardMapper memberCardMapper;
+
+ @Autowired
+ private InterfaceLogService interfaceLogService;
/**
* 鍚屾ERP缁勭粐淇℃伅
@@ -58,4 +134,422 @@
public String syncUserInfo(UserInfoRequest param){
return null;
}
+
+
+ @Override
+ public AccessTokenResponse createERPToken(String accessKey, String accessSecret){
+ AccessTokenResponse result = new AccessTokenResponse();
+ try{
+ String erpAccessKey = systemDictDataBiz.queryByCode(Constants.ERP_CONFIG,Constants.ERP_ACCESS_KEY).getCode();
+ String erpAccessSecret = systemDictDataBiz.queryByCode(Constants.ERP_CONFIG,Constants.ERP_ACCESS_SECRET).getCode();
+ if(!accessKey.equals(erpAccessKey)||!erpAccessSecret.equals(accessSecret)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"绉橀挜鍖归厤澶辫触");
+ }
+ JwtPayLoad payLoad = new JwtPayLoad(erpAccessKey+"-"+erpAccessSecret);
+ String token = JwtTokenUtil.generateToken(payLoad);
+ RedisUtil.addObject(redisTemplate,Constants.RedisKeys.ERP_TOKEN,token,Constants.RedisKeys.EXPIRE_TIME);
+ result.setToken(token);
+ result.setExpireTime(Constants.RedisKeys.EXPIRE_TIME);
+ }catch (Exception e){
+
+ }finally {
+ Map<String,String> param = new HashMap<>();
+ param.put("accessKey",accessKey);
+ param.put("accessSecret",accessSecret);
+ saveInterfaceLog(param,"/visitBiz/accesstoken",JSONObject.toJSONString(result),Constants.ZERO);
+ }
+
+
+ return result;
+ }
+
+ /**
+ * 闂ㄧ缁勫叏閲忔帴鍙�
+ * @param param
+ * @return
+ */
+ @Override
+ public List<RoleListResponse> erpQueryDeviceList(RoleListRequest param){
+ List<RoleListResponse> result = new ArrayList<>();
+ try{
+ List<DeviceRole> deviceRoleList = this.deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda()
+ .eq(DeviceRole::getIsdeleted,Constants.ZERO)
+ .eq(!Objects.isNull(param.getId()),DeviceRole::getId,param.getId())
+ .like(StringUtils.isNotBlank(param.getName()),DeviceRole::getName,param.getName())
+ .orderByAsc(DeviceRole::getCreateDate)
+ );
+ List<String> roleIds = new ArrayList<String>();
+ if(CollectionUtils.isNotEmpty(deviceRoleList)){
+ for (DeviceRole deviceRole:deviceRoleList) {
+ if(StringUtils.isNotBlank(deviceRole.getDoorIds())){
+ List<String> doorList = Arrays.asList(deviceRole.getDoorIds().split(","));
+ roleIds.addAll(doorList);
+ }
+ }
+ if(CollectionUtils.isNotEmpty(roleIds)){
+ List<Device> deviceList = deviceMapper.selectList(new QueryWrapper<Device>().lambda().in(Device::getId,roleIds));
+ for (DeviceRole deviceRole:deviceRoleList) {
+ RoleListResponse roleListResponse = new RoleListResponse();
+ BeanUtils.copyProperties(deviceRole,roleListResponse);
+ if(StringUtils.isNotBlank(deviceRole.getDoorIds())){
+ List<DeviceListResponse> DeviceListResponseList = new ArrayList<>();
+ List<String> doorList = Arrays.asList(deviceRole.getDoorIds().split(","));
+ List<Device> roleDeviceList = deviceList.stream().filter(m-> doorList.contains(m.getId().toString())).collect(Collectors.toList());
+ for (Device device:roleDeviceList) {
+ DeviceListResponse deviceListResponse = new DeviceListResponse();
+ BeanUtils.copyProperties(device,deviceListResponse);
+ DeviceListResponseList.add(deviceListResponse);
+ }
+ roleListResponse.setDeviceList(DeviceListResponseList);
+ }
+ result.add(roleListResponse);
+ }
+ }
+ }
+ }catch (Exception e){
+ e.printStackTrace();
+ }finally {
+ saveInterfaceLog(param,"/visitBiz/resource/role/list",JSONObject.toJSONString(result),Constants.ZERO);
+ }
+ return result;
+ }
+
+
+
+
+ /**
+ * 鍋滆溅鍦哄叏閲忎俊鎭帴鍙�
+ * @param param
+ * @return
+ */
+ @Override
+ public List<ParkListResponse> parkList(ParkListRequest param){
+ List<ParkListResponse> result = new ArrayList<>();
+ try{
+ List<Parks> parksList = this.parksMapper.selectList(new QueryWrapper<Parks>().lambda()
+ .eq(Parks::getIsdeleted,Constants.ZERO)
+ .eq(!Objects.isNull(param.getId()),Parks::getId,param.getId())
+ .like(StringUtils.isNotBlank(param.getName()),Parks::getName,param.getName())
+ );
+ if(CollectionUtils.isNotEmpty(parksList)){
+ for (Parks parks:parksList) {
+ ParkListResponse parkListResponse = new ParkListResponse();
+ BeanUtils.copyProperties(parks,parkListResponse);
+ result.add(parkListResponse);
+ }
+ }
+ }catch (Exception e){
+ e.printStackTrace();
+ }finally {
+ saveInterfaceLog(param,"/visitBiz/resource/park/list",JSONObject.toJSONString(result),Constants.ZERO);
+ }
+ return result;
+ }
+
+ /**
+ * 璁垮鍑哄叆浜嬩欢鍚屾鎺ュ彛
+ * @param param
+ * @return
+ */
+ @Override
+ public PageData<VisitEventListResponse> visitListPage(PageWrap<VisitListRequest> param) {
+ PageData<VisitEventListResponse> result = new PageData<>();
+ try{
+ VisitListRequest visitListRequest = param.getModel();
+ IPage<VisitEvent> page = new Page<>(param.getPage(), param.getCapacity());
+ MPJLambdaWrapper<VisitEvent> queryWrapper = new MPJLambdaWrapper<>();
+ Utils.MP.blankToNull(visitListRequest);
+
+ queryWrapper.selectAll(VisitEvent.class);
+ queryWrapper.selectAs(Visits::getName, VisitEventListResponse::getVisitorName);
+ queryWrapper.leftJoin(Visits.class,Visits::getId,VisitEvent::getVisitorId);
+
+ if(!Objects.isNull(visitListRequest)){
+ queryWrapper.eq(!Objects.isNull(visitListRequest.getEventId()),VisitEvent::getEventId, visitListRequest.getEventId());
+ queryWrapper.like(StringUtils.isNotBlank(visitListRequest.getVisitorName()),Visits::getName, visitListRequest.getVisitorName());
+ queryWrapper.eq(StringUtils.isNotBlank(visitListRequest.getIdNo()),VisitEvent::getIdNo, visitListRequest.getIdNo());
+ queryWrapper.eq(StringUtils.isNotBlank(visitListRequest.getBeVisitedPersonId()),VisitEvent::getBeVisitedPersonId, visitListRequest.getBeVisitedPersonId());
+ queryWrapper.eq(StringUtils.isNotBlank(visitListRequest.getBeVisitedPersonOrgId()),VisitEvent::getBeVisitedPersonOrgId, visitListRequest.getBeVisitedPersonOrgId());
+ queryWrapper.like(StringUtils.isNotBlank(visitListRequest.getVisitorWorkUint()),VisitEvent::getVisitorWorkUint, visitListRequest.getVisitorWorkUint());
+ queryWrapper.ge(StringUtils.isNotBlank(visitListRequest.getInStartTime()),VisitEvent::getStartTime, visitListRequest.getInStartTime());
+ queryWrapper.le(StringUtils.isNotBlank(visitListRequest.getInEndTime()),VisitEvent::getStartTime, visitListRequest.getInEndTime());
+ queryWrapper.ge(StringUtils.isNotBlank(visitListRequest.getOutStartTime()),VisitEvent::getEndTime, visitListRequest.getOutStartTime());
+ queryWrapper.le(StringUtils.isNotBlank(visitListRequest.getOutEndTime()),VisitEvent::getEndTime, visitListRequest.getOutEndTime());
+
+ for(PageWrap.SortData sortData: param.getSorts()) {
+ if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
+ queryWrapper.orderByDesc(sortData.getProperty());
+ } else {
+ queryWrapper.orderByAsc(sortData.getProperty());
+ }
+ }
+ }
+ IPage<VisitEventListResponse> pageData = visitEventJoinMapper.selectJoinPage(page, VisitEventListResponse.class,queryWrapper);
+ result = PageData.from(pageData);
+ }catch (Exception e){
+ e.printStackTrace();
+ }finally {
+ saveInterfaceLog(param,"/visitBiz/resource/visit/list",JSONObject.toJSONString(result),Constants.ZERO);
+ }
+ return result;
+ }
+
+
+ @Override
+ public PageData<DoorEventListResponse> doorEventListPage(PageWrap<DoorEventListRequest> param) {
+ PageData<DoorEventListResponse> result = new PageData<>();
+ try{
+ DoorEventListRequest doorEventListRequest = param.getModel();
+ IPage<DeviceEvent> page = new Page<>(param.getPage(), param.getCapacity());
+ MPJLambdaWrapper<DeviceEvent> queryWrapper = new MPJLambdaWrapper<>();
+ Utils.MP.blankToNull(doorEventListRequest);
+ queryWrapper.selectAs(DeviceEvent::getEventId,DoorEventListResponse::getEventId);
+ queryWrapper.selectAs(DeviceEvent::getEventType,DoorEventListResponse::getEventType);
+ queryWrapper.selectAs(DeviceEvent::getSex,DoorEventListResponse::getSex);
+ queryWrapper.selectAs(DeviceEvent::getSrcName,DoorEventListResponse::getSrcName);
+ queryWrapper.selectAs(DeviceEvent::getSrcType,DoorEventListResponse::getSrcType);
+ queryWrapper.selectAs(DeviceEvent::getIdcardDecode,DoorEventListResponse::getIdcardNo);
+ queryWrapper.selectAs(DeviceEvent::getName,DoorEventListResponse::getName);
+ queryWrapper.selectAs(DeviceEvent::getUserType,DoorEventListResponse::getType);
+ queryWrapper.selectAs(DeviceEvent::getExtEventInOut,DoorEventListResponse::getEventInOut);
+ queryWrapper.selectAs(DeviceEvent::getExtAccessChannel,DoorEventListResponse::getExtAccessChannel);
+ queryWrapper.selectAs(DeviceEvent::getCreateDate,DoorEventListResponse::getCreateTime);
+ queryWrapper.selectAs(Member::getPhone,DoorEventListResponse::getPhone);
+ queryWrapper.selectAs(Member::getErpId,DoorEventListResponse::getUserId);
+ queryWrapper.selectAs(Member::getCompanyId,DoorEventListResponse::getOrgId);
+ queryWrapper.leftJoin(Member.class,Member::getHkId,DeviceEvent::getExtEventPersonNo);
+
+ if(!Objects.isNull(doorEventListRequest)){
+ queryWrapper.eq(!Objects.isNull(doorEventListRequest.getEventId()),DeviceEvent::getEventId, doorEventListRequest.getEventId());
+ queryWrapper.like(StringUtils.isNotBlank(doorEventListRequest.getName()),DeviceEvent::getName, doorEventListRequest.getName());
+ if(StringUtils.isNotBlank(doorEventListRequest.getIdNo())){
+ //杩涜鍔犲瘑
+ String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,doorEventListRequest.getIdNo());
+ queryWrapper.eq(DeviceEvent::getIdNum, encryptIdNo);
+ }
+ queryWrapper.ge(StringUtils.isNotBlank(doorEventListRequest.getStartTime()),DeviceEvent::getHappenTime, doorEventListRequest.getStartTime());
+ queryWrapper.le(StringUtils.isNotBlank(doorEventListRequest.getEndTime()),DeviceEvent::getHappenTime, doorEventListRequest.getEndTime());
+ for(PageWrap.SortData sortData: param.getSorts()) {
+ if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
+ queryWrapper.orderByDesc(sortData.getProperty());
+ } else {
+ queryWrapper.orderByAsc(sortData.getProperty());
+ }
+ }
+ }
+
+ IPage<DoorEventListResponse> pageData = deviceEventJoinMapper.selectJoinPage(page, DoorEventListResponse.class,queryWrapper);
+ result = PageData.from(pageData);
+ }catch (Exception e){
+ e.printStackTrace();
+ }finally {
+ saveInterfaceLog(param,"/visitBiz/resource/doorEvent/list",JSONObject.toJSONString(result),Constants.ZERO);
+ }
+ return result;
+ }
+
+
+ @Override
+ public PageData<CarEventListResponse> carEventList(PageWrap<CarEventListRequest> param) {
+ PageData<CarEventListResponse> result = new PageData<>();
+ try{
+ CarEventListRequest carEventListRequest = param.getModel();
+ IPage<CarEvent> page = new Page<>(param.getPage(), param.getCapacity());
+ MPJLambdaWrapper<CarEvent> queryWrapper = new MPJLambdaWrapper<>();
+ Utils.MP.blankToNull(carEventListRequest);
+ queryWrapper.selectAs(CarEvent::getEventId,CarEventListResponse::getEventId);
+ queryWrapper.selectAs(CarEvent::getEventType,CarEventListResponse::getEventType);
+ queryWrapper.selectAs(CarEvent::getInoutType,CarEventListResponse::getEventType);
+ queryWrapper.selectAs(CarEvent::getAlarmCar,CarEventListResponse::getAlarmCar);
+ queryWrapper.selectAs(CarEvent::getCarAttributeName,CarEventListResponse::getCarAttributeName);
+ queryWrapper.selectAs(CarEvent::getCardNo,CarEventListResponse::getCardNo);
+ queryWrapper.selectAs(CarEvent::getEventCmd,CarEventListResponse::getEventCmd);
+ queryWrapper.selectAs(CarEvent::getGateIndex,CarEventListResponse::getGateIndex);
+ queryWrapper.selectAs(CarEvent::getGateName,CarEventListResponse::getGateName);
+ queryWrapper.selectAs(CarEvent::getMainLogo,CarEventListResponse::getMainLogo);
+ queryWrapper.selectAs(CarEvent::getParkIndex,CarEventListResponse::getParkId);
+ queryWrapper.selectAs(CarEvent::getParkName,CarEventListResponse::getParkName);
+ queryWrapper.selectAs(CarEvent::getPlatePicUrl,CarEventListResponse::getPlatePicUrl);
+ queryWrapper.selectAs(CarEvent::getVehiclePicUrl,CarEventListResponse::getVehiclePicUrl);
+ queryWrapper.selectAs(CarEvent::getPlateNos,CarEventListResponse::getPlateNo);
+ queryWrapper.selectAs(CarEvent::getPlateColor,CarEventListResponse::getPlateColor);
+ queryWrapper.selectAs(CarEvent::getRoadwayName,CarEventListResponse::getRoadwayName);
+ queryWrapper.selectAs(CarEvent::getRoadwayType,CarEventListResponse::getRoadwayType);
+ queryWrapper.selectAs(CarEvent::getSubLogo,CarEventListResponse::getSubLogo);
+ queryWrapper.selectAs(CarEvent::getSubModel,CarEventListResponse::getSubModel);
+
+ if(!Objects.isNull(carEventListRequest)){
+ queryWrapper.eq(!Objects.isNull(carEventListRequest.getEventId()),CarEvent::getEventId, carEventListRequest.getEventId());
+ queryWrapper.eq(StringUtils.isNotBlank(carEventListRequest.getParkId()),CarEvent::getParkIndex, carEventListRequest.getParkId());
+ queryWrapper.like(StringUtils.isNotBlank(carEventListRequest.getParkName()),CarEvent::getParkName, carEventListRequest.getParkName());
+ queryWrapper.eq(StringUtils.isNotBlank(carEventListRequest.getPlateNo()),CarEvent::getPlateNos, carEventListRequest.getPlateNo());
+ queryWrapper.ge(StringUtils.isNotBlank(carEventListRequest.getStartTime()),CarEvent::getHappenTime, carEventListRequest.getStartTime());
+ queryWrapper.le(StringUtils.isNotBlank(carEventListRequest.getEndTime()),CarEvent::getHappenTime, carEventListRequest.getEndTime());
+ for(PageWrap.SortData sortData: param.getSorts()) {
+ if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
+ queryWrapper.orderByDesc(sortData.getProperty());
+ } else {
+ queryWrapper.orderByAsc(sortData.getProperty());
+ }
+ }
+ }
+ IPage<CarEventListResponse> pageData = carEventJoinMapper.selectJoinPage(page, CarEventListResponse.class,queryWrapper);
+ result = PageData.from(pageData);
+ result.getRecords().forEach(i->{
+ if(i.getPlatePicUrl().startsWith(HKConstants.IMG_INDEX)){
+ i.setPlatePicUrl(null);
+ }
+ if(i.getVehiclePicUrl().startsWith(HKConstants.IMG_INDEX)){
+ i.setVehiclePicUrl(null);
+ }
+ });
+ }catch (Exception e){
+ e.printStackTrace();
+ }finally {
+ saveInterfaceLog(param,"/visitBiz/resource/carEventList",JSONObject.toJSONString(result),Constants.ZERO);
+ }
+
+ return result;
+ }
+
+
+
+
+ @Override
+ public void orgUpdate(OrgUpdateRequest param){
+ try{
+ if(Objects.isNull(param)
+ ||Objects.isNull(param.getId())
+ ||StringUtils.isBlank(param.getName())
+ ||StringUtils.isBlank(param.getLinkName())
+ ||StringUtils.isBlank(param.getLinkPhone())
+ ||Objects.isNull(param.getEditDate())
+ ){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ Company company = companyMapper.selectOne(new QueryWrapper<Company>().lambda().eq(Company::getErpId,param.getId()).last("limit 1"));
+ if(Objects.isNull(company)){
+ company = new Company();
+ BeanUtils.copyProperties(param,company);
+ company.setId(null);
+ company.setCreateDate(new Date());
+ company.setHkStatus(Constants.ZERO);
+ company.setErpStatus(Constants.ONE);
+ company.setErpDate(new Date());
+ company.setErpId(param.getId());
+ company.setFsStatus(Constants.ZERO);
+ company.setType(Constants.ONE);
+ companyMapper.insert(company);
+ //TODO 娴峰悍鏁版嵁鍒涘缓
+ }else{
+ BeanUtils.copyProperties(param,company);
+ company.setEditDate(new Date());
+ company.setErpDate(new Date());
+ companyMapper.updateById(company);
+ //TODO 娴峰悍鏁版嵁鏇存柊
+ }
+ }catch (Exception e){
+ e.printStackTrace();
+ }finally {
+ saveInterfaceLog(param,"/visitBiz/resource/orgUpdate",null,Constants.ZERO);
+ }
+ }
+
+
+
+ @Override
+ public void userUpdate(UserUpdateRequest param){
+ try{
+ if(Objects.isNull(param)
+ ||Objects.isNull(param.getId())
+ ||StringUtils.isBlank(param.getName())
+ ||StringUtils.isBlank(param.getIdNo())
+ ||Objects.isNull(param.getIdType())
+ ||Objects.isNull(param.getSex())
+ ||Objects.isNull(param.getOrgId())
+ ||StringUtils.isNotBlank(param.getFaceImg())
+ ||StringUtils.isNotBlank(param.getCode())
+ ||StringUtils.isNotBlank(param.getPhone())
+ ||Objects.isNull(param.getEditDate())
+ ){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getErpId,param.getId()).last("limit 1"));
+ if(Objects.isNull(member)){
+ member = new Member();
+ BeanUtils.copyProperties(param,member);
+ member.setCreateDate(new Date());
+ member.setHkStatus(Constants.ZERO);
+ member.setErpStatus(Constants.ONE);
+ member.setErpDate(new Date());
+ member.setErpId(param.getId());
+ member.setFsStatus(Constants.ZERO);
+ member.setType(Constants.memberType.internal);
+ String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
+ member.setIdcardNo(encryptIdNo);
+ member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
+ member.setCompanyId(param.getOrgId());
+ memberMapper.insert(member);
+
+ //TODO 娴峰悍鏁版嵁鍒涘缓
+ }else{
+ BeanUtils.copyProperties(param,member);
+ String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
+ member.setIdcardNo(encryptIdNo);
+ member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
+ member.setCompanyId(param.getOrgId());
+ member.setEditDate(new Date());
+ member.setErpDate(new Date());
+ memberMapper.updateById(member);
+ //鍒犻櫎鐢ㄦ埛鍗＄墖鏁版嵁 浜哄憳瑙掕壊鍏宠仈
+ memberCardMapper.delete(new QueryWrapper<MemberCard>().lambda().eq(MemberCard::getMemberId,member.getId()));
+ memberRoleMapper.delete(new QueryWrapper<MemberRole>().lambda().eq(MemberRole::getMemberId,member.getId()));
+ //TODO 娴峰悍鏁版嵁鏇存柊
+ }
+ //娣诲姞浜哄憳瑙掑叧鑱旀暟鎹�
+ if(!Objects.isNull(param.getRoleIds())&¶m.getRoleIds().length>Constants.ZERO){
+ //鏌ヨ鏁版嵁搴撳瓨鍦ㄧ殑鏉冮檺
+ List<MemberRole> memberRoleList = memberRoleMapper.selectList(new QueryWrapper<MemberRole>().lambda().eq(MemberRole::getId,param.getRoleIds()));
+ List<Integer> roleIds = Arrays.asList(param.getRoleIds());
+
+// List<MemberRole> memberRoleList = new ArrayList<>();
+//
+// for (Integer id:roleIds) {
+//
+// }
+
+
+
+
+ }
+
+
+
+
+ }catch (Exception e){
+ e.printStackTrace();
+ }finally {
+ saveInterfaceLog(param,"/visitBiz/resource/userUpdate",null,Constants.ZERO);
+ }
+ }
+
+
+
+
+
+ private void saveInterfaceLog(Object param, String path,String result,Integer type) {
+ InterfaceLog interfaceLog=new InterfaceLog();
+ interfaceLog.setType(type);
+ interfaceLog.setCreateDate(new Date());
+ interfaceLog.setIsdeleted(Constants.ZERO);
+ if(param!=null){
+ interfaceLog.setRequest(JSONObject.toJSONString(param));
+ }
+ interfaceLog.setPlat(Constants.ONE);
+ interfaceLog.setRepose(result);
+ interfaceLog.setName(path);
+ interfaceLog.setUrl(path);
+ interfaceLogService.create(interfaceLog);
+ }
+
}
--
Gitblit v1.9.3