| | |
| | | import cn.hutool.core.lang.PatternPool; |
| | | import cn.hutool.core.lang.Validator; |
| | | import cn.hutool.core.util.ReUtil; |
| | | import com.doumee.core.exception.BusinessException; |
| | | import com.doumee.core.haikang.model.HKConstants; |
| | | import com.doumee.core.haikang.model.param.BaseResponse; |
| | | import com.doumee.core.haikang.model.param.request.CardDeletionRequest; |
| | | import com.doumee.core.haikang.service.HKService; |
| | | import com.doumee.core.model.PageData; |
| | | import com.doumee.core.model.PageWrap; |
| | | import com.doumee.core.utils.Constants; |
| | | import com.doumee.core.utils.Utils; |
| | | import com.doumee.dao.admin.response.CarEventDTO; |
| | | import com.doumee.dao.business.MemberCardMapper; |
| | | import com.doumee.dao.business.*; |
| | | import com.doumee.dao.business.join.MemberCardJoinMapper; |
| | | import com.doumee.dao.business.model.Company; |
| | | import com.doumee.dao.business.model.Member; |
| | |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.doumee.service.business.impl.hksync.HkSyncOrgUserServiceImpl; |
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.util.CollectionUtils; |
| | | |
| | | import java.util.*; |
| | |
| | | */ |
| | | @Service |
| | | public class MemberCardServiceImpl implements MemberCardService { |
| | | |
| | | @Autowired |
| | | private MemberRoleMapper memberRoleMapper; |
| | | @Autowired |
| | | private DeviceRoleMapper deviceRoleMapper; |
| | | @Autowired |
| | | private DeviceMapper deviceMapper; |
| | | @Autowired |
| | | private EmpowerMapper empowerMapper; |
| | | @Autowired |
| | | private MemberCardMapper memberCardMapper; |
| | | @Autowired |
| | | private MemberMapper memberMapper; |
| | | |
| | | @Autowired |
| | | private MemberCardJoinMapper memberCardJoinMapper; |
| | | |
| | | @Override |
| | | public Integer create(MemberCard memberCard) { |
| | | memberCard.setStatus(Constants.ONE); |
| | | memberCardMapper.insert(memberCard); |
| | | return memberCard.getId(); |
| | | } |
| | |
| | | this.updateById(memberCard); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = {Exception.class, BusinessException.class}) |
| | | public void updateRefundCard(MemberCard memberCard) { |
| | | int i = memberCardMapper.updateById(memberCard); |
| | | // 调用service 同步更新海康那边的对应卡状态,也改为退卡 |
| | | if(i > 0){ |
| | | MemberCard model = memberCardMapper.selectById(memberCard.getId()); |
| | | memberCardMapper.updateById(memberCard); |
| | | dealMemberRoleEmpower(memberMapper.selectById(memberCard.getMemberId())); |
| | | |
| | | BaseResponse response = HKService.cardDeletion(new CardDeletionRequest()); |
| | | if(){ |
| | | |
| | | } |
| | | } |
| | |
| | | wrapper.lambda().and(param -> param.eq(MemberCard::getStatus,Constants.ZERO). |
| | | or().eq(MemberCard::getStatus,Constants.TWO)); |
| | | return memberCardMapper.selectList(wrapper); |
| | | } |
| | | |
| | | /** |
| | | * 更细人员全部门禁权限 |
| | | * @param member |
| | | */ |
| | | private void dealMemberRoleEmpower(Member member ) { |
| | | //处理新增的人员卡片数据(与海康同步) |
| | | List<MemberCard> cards = HkSyncOrgUserServiceImpl.getNormalCardList(member,memberCardMapper); |
| | | HkSyncOrgUserServiceImpl.dealMemberRoleEmpowerDo(cards,member,deviceRoleMapper,empowerMapper,deviceMapper); |
| | | } |
| | | |
| | | @Override |
| | |
| | | queryWrapper.selectAll(MemberCard.class) |
| | | .selectAs(Member::getName,MemberCard::getMemberName) |
| | | .selectAs(Member::getPhone,MemberCard::getMemberPhone) |
| | | .selectAs(Member::getType,MemberCard::getMemberType) |
| | | .selectAs(Company::getName,MemberCard::getCompanyName); |
| | | queryWrapper.like(Objects.nonNull(pageWrap.getModel().getCode()),MemberCard::getCode,pageWrap.getModel().getCode()) |
| | | .eq(Objects.nonNull(pageWrap.getModel().getStatus()),MemberCard::getStatus,pageWrap.getModel().getStatus()) |
| | |
| | | private List<MemberCard> getDataPackage(IPage<MemberCard> memberCardIPage) { |
| | | List<MemberCard> newDataList = new ArrayList<>(); |
| | | memberCardIPage.getRecords().stream().forEach(obj->{ |
| | | if(null != obj.getType()) { |
| | | if(Constants.equalsInteger(obj.getCardType(),Constants.ZERO)) { |
| | | obj.setTypeName(Constants.Status.LW_FK.getDes()); |
| | | }else if(Constants.equalsInteger(obj.getCardType(),Constants.ONE)){ |
| | | obj.setTypeName(Constants.Status.PT_FK.getDes()); |
| | | }else if(Constants.equalsInteger(obj.getCardType(),Constants.TWO)){ |
| | | obj.setTypeName(Constants.Status.NB_FK.getDes()); |
| | | } |
| | | } |
| | | if(null != obj.getCardType()) { |
| | | if(Constants.equalsInteger(obj.getCardType(),Constants.ZERO)) { |
| | | obj.setCardTypeName(HKConstants.CardStatus.DISABLE.getName()); |
| | | }else if(Constants.equalsInteger(obj.getCardType(),Constants.ONE)) { |
| | | obj.setCardTypeName(HKConstants.CardStatus.ENABLE.getName()); |
| | | }else if(Constants.equalsInteger(obj.getCardType(),Constants.TWO)) { |
| | | obj.setCardTypeName(HKConstants.CardStatus.REFUNDCARD.getName()); |
| | | }else if(Constants.equalsInteger(obj.getCardType(),Constants.THREE)) { |
| | | obj.setCardTypeName(HKConstants.CardStatus.LOSS.getName()); |
| | | if(null != obj.getMemberType()) { |
| | | if(Constants.equalsInteger(obj.getMemberType(),Constants.ZERO)) { |
| | | obj.setMemberTypeName(Constants.Status.LW_FK.getDes()); |
| | | }else if(Constants.equalsInteger(obj.getMemberType(),Constants.ONE)){ |
| | | obj.setMemberTypeName(Constants.Status.PT_FK.getDes()); |
| | | }else if(Constants.equalsInteger(obj.getMemberType(),Constants.TWO)){ |
| | | obj.setMemberTypeName(Constants.Status.NB_FK.getDes()); |
| | | } |
| | | } |
| | | if(null != obj.getStatus()) { |
| | | if(Constants.equalsInteger(obj.getCardType(),Constants.ONE)) { |
| | | if(Constants.equalsInteger(obj.getStatus(),Constants.ZERO)) { |
| | | obj.setStatusName(HKConstants.CardStatus.DISABLE.getName()); |
| | | }else if(Constants.equalsInteger(obj.getStatus(),Constants.ONE)) { |
| | | obj.setStatusName(HKConstants.CardStatus.ENABLE.getName()); |
| | | }else if(Constants.equalsInteger(obj.getStatus(),Constants.TWO)) { |
| | | obj.setStatusName(HKConstants.CardStatus.REFUNDCARD.getName()); |
| | | }else if(Constants.equalsInteger(obj.getStatus(),Constants.THREE)) { |
| | | obj.setStatusName(HKConstants.CardStatus.LOSS.getName()); |
| | | } |
| | | } |
| | | if(null != obj.getMemberType()) { |
| | | if(Constants.equalsInteger(obj.getMemberType(),Constants.ONE)) { |
| | | obj.setCardTypeName(HKConstants.CardStatus.IC.getName()); |
| | | }else if(Constants.equalsInteger(obj.getCardType(),Constants.TWO)) { |
| | | }else if(Constants.equalsInteger(obj.getMemberType(),Constants.TWO)) { |
| | | obj.setCardTypeName(HKConstants.CardStatus.CPU.getName()); |
| | | }else if(Constants.equalsInteger(obj.getCardType(),Constants.THREE)) { |
| | | }else if(Constants.equalsInteger(obj.getMemberType(),Constants.THREE)) { |
| | | obj.setCardTypeName(HKConstants.CardStatus.YJLCARD.getName()); |
| | | }else if(Constants.equalsInteger(obj.getCardType(),Constants.FOUR)) { |
| | | }else if(Constants.equalsInteger(obj.getMemberType(),Constants.FOUR)) { |
| | | obj.setCardTypeName(HKConstants.CardStatus.MCARD.getName()); |
| | | } |
| | | } |