| | |
|---|
| | | import com.github.yulichang.query.MPJQueryWrapper; |
|---|
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.commons.collections.CollectionUtils; |
|---|
| | | import org.apache.commons.lang3.StringUtils; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.transaction.annotation.Transactional; |
|---|
| | | |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.UUID; |
|---|
| | | import java.util.*; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 海康组织人员通过步Service实现 |
|---|
| | |
|---|
| | | public class HkSyncOrgUserServiceImpl extends HkSyncBaseServiceImpl { |
|---|
| | | @Autowired |
|---|
| | | private CompanyMapper companyMapper; |
|---|
| | | @Autowired |
|---|
| | | private DeviceRoleMapper deviceRoleMapper; |
|---|
| | | @Autowired |
|---|
| | | private MemberRoleMapper memberRoleMapper; |
|---|
| | | @Autowired |
|---|
| | |
|---|
| | | Constants.DEALING_HK_USER =false; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | private List<Integer> getRoleIdByParam( Member member) { |
|---|
| | | //查询数据库存在的权限 |
|---|
| | | List<DeviceRole> deviceRoleList= deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda() |
|---|
| | | .eq(DeviceRole::getType,Constants.TWO) |
|---|
| | | .exists("(select b.id from member_role b where b.ROLE_ID = device_role.ID and b.MEMBER_ID="+member.getRoleId()+")")); |
|---|
| | | if(CollectionUtils.isNotEmpty(deviceRoleList)){ |
|---|
| | | List<MemberRole> memberRoleList = new ArrayList<>(); |
|---|
| | | String ids = ""; |
|---|
| | | List<Integer> r = new ArrayList<>(); |
|---|
| | | for (int i = 0; i < deviceRoleList.size(); i++) { |
|---|
| | | DeviceRole deviceRole =deviceRoleList.get(i); |
|---|
| | | if(i>0){ |
|---|
| | | ids += ","; |
|---|
| | | } |
|---|
| | | String doorids =deviceRole.getDoorIds(); |
|---|
| | | if(StringUtils.isNotBlank(doorids)){ |
|---|
| | | String[] ss = doorids.split(","); |
|---|
| | | try { |
|---|
| | | for(String s :ss){ |
|---|
| | | r.add(Integer.parseInt(s)); |
|---|
| | | } |
|---|
| | | }catch (Exception e){ |
|---|
| | | //脏数据不处理 |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return r; |
|---|
| | | } |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | @Transactional |
|---|
| | | private boolean dealMemberInfoBiz(Member c, Date date, String path) { |
|---|
| | | if( c.getCompanyId() == null){ |
|---|
| | |
|---|
| | | } |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | |
|---|
| | | private void dealMemberRoleEmpower(Member member ) { |
|---|
| | | List<Integer> doorIds = getRoleIdByParam(member); |
|---|
| | | if(doorIds==null || doorIds.size() == 0){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | if(StringUtils.isBlank(member.getFaceImg())){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | if(Constants.equalsObject(member.getHkStatus(),Constants.ONE)){ |
|---|
| | | //如果用户是同步海康成功，添加带下发权限 |
|---|
| | | List<Empower> list = new ArrayList<>(); |
|---|
| | | List<Device> deviceList = deviceMapper.selectList(new QueryWrapper<Device>().lambda().in(Device::getId,doorIds)); |
|---|
| | | if(deviceList == null || deviceList.size() == 0){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | for (Device deviceRole:deviceList) { |
|---|
| | | Empower model = new Empower(); |
|---|
| | | model.setCreateDate(new Date()); |
|---|
| | | model.setMemberId(member.getId()); |
|---|
| | | model.setIsdeleted(Constants.ZERO); |
|---|
| | | model.setDeviceId(deviceRole.getId()); |
|---|
| | | model.setSendStatus(Constants.ZERO); |
|---|
| | | model.setStartTime(member.getStartTime()); |
|---|
| | | model.setEndTime(member.getEndTime()); |
|---|
| | | //默认给于虚拟卡 |
|---|
| | | model.setCardNos(Constants.VIRTUAL_CARD_INDEX+member.getId()); |
|---|
| | | model.setSendType(Constants.ZERO); |
|---|
| | | list.add(model); |
|---|
| | | } |
|---|
| | | //导入新增的授权信息 |
|---|
| | | empowerMapper.insertBatchSomeColumn(list); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | /** |
|---|
| | | * 如果之前已经和海康同步，则更新用户数据以及人脸数据（可能新增人脸 也可能更新人脸） |
|---|
| | | * @param c |
|---|
| | |
|---|
| | | c.setHkStatus(Constants.TWO); |
|---|
| | | c.setRemark("人员信息同步安防平台更新失败，请修正后重试！！"+(result!=null?result.getCode()+result.getMsg():"")); |
|---|
| | | } |
|---|
| | | |
|---|
| | | //重新下发权限数据 |
|---|
| | | dealMemberRoleEmpower(c); |
|---|
| | | } |
|---|
| | | c.setHkDate(date); |
|---|
| | | memberMapper.updateById(c); |
|---|
| | |
|---|
| | | c.setHkStatus(Constants.ONE); |
|---|
| | | c.setHkId(addHkModel.getPersonId()); |
|---|
| | | memberMapper.updateById(c); |
|---|
| | | dealMemberRoleEmpower(c); |
|---|
| | | return true; |
|---|
| | | }else{ |
|---|
| | | noticeErpFail(c,Constants.ZERO,"人员信息同步安防平台失败，请修正后重试！"+result.getCode()+result.getMsg()); |
|---|
