/* * Copyright (c) 2018-2028, Chill Zhuang All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * Neither the name of the dreamlu.net developer nor the names of its * contributors may be used to endorse or promote products derived from * this software without specific prior written permission. * Author: Chill 庄骞 (smallchill@163.com) */ package org.springblade.modules.social.service.impl; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import lombok.AllArgsConstructor; import org.springblade.common.utils.DesensitizedUtil; import org.springblade.core.tool.utils.BeanUtil; import org.springblade.modules.social.entity.Social; import org.springblade.modules.social.excel.SocialExcel; import org.springblade.modules.social.mapper.SocialMapper; import org.springblade.modules.social.service.ISocialService; import org.springblade.modules.social.vo.SocialVO; import org.springblade.modules.system.service.MyAsyncService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import java.util.Objects; /** * 服务实现类 * * @author BladeX * @since 2021-07-16 */ @Service public class SocialServiceImpl extends ServiceImpl implements ISocialService { @Autowired private MyAsyncService myAsyncService; @Override public IPage selectSocialPage(IPage page, SocialVO social) { return page.setRecords(baseMapper.selectSocialPage(page, social)); } @Override public void importUser(List data, Boolean isCovered,String deptid) { data.forEach(SocialExcel -> { Social social = Objects.requireNonNull(BeanUtil.copy(SocialExcel, Social.class)); // if (null!=social.getSex() && !"".equals(social.getSex())) { // if (social.getSex().equals("男")){ // social.setSex("1"); // } // if (social.getSex().equals("女")){ // social.setSex("2"); // } // } if (null!=social.getBirthday()) { social.setBirthday(social.getBirthday()); } if (null!=social.getTelephone() && !"".equals(social.getTelephone())) { social.setTelephone(social.getTelephone()); } if (null!=social.getResidence() && !"".equals(social.getResidence())) { social.setResidence(social.getResidence()); } if (null!=social.getAddress() && !"".equals(social.getAddress())) { social.setAddress(social.getAddress()); } if (null!=social.getNature() && !"".equals(social.getNature())) { social.setNature(social.getNature()); } if (null!=social.getNation() && !"".equals(social.getNation())) { social.setNation(social.getNation()); } social.setDeptid(deptid); this.upSoil(social.getCardid()); Social social1 = Objects.requireNonNull(BeanUtil.copy(social, Social.class)); //脱敏处理 if (null!=social.getNation() && !social.getNation().equals("")){ social1.setNation("***"); } if (null!=social.getTelephone() && !social.getTelephone().equals("")){ social1.setTelephone(DesensitizedUtil.desensitizedPhoneNumber(social.getTelephone())); } if (null!=social.getCardid() && !social.getCardid().equals("")){ social1.setCardid(DesensitizedUtil.desensitizedIdNumberBy4(social.getCardid())); } if (null!=social.getResidence() && !social.getResidence().equals("")){ social1.setResidence(DesensitizedUtil.desensitizedAddress(social.getResidence())); } if (null!=social.getAddress() && !social.getAddress().equals("")){ social1.setAddress(DesensitizedUtil.desensitizedAddress(social.getAddress())); } if (null!=social.getNature() && !social.getNature().equals("")){ social1.setNature("***"); } if (null!=social.getAmount()){ social1.setAmount(null); } if (null!=social.getInsuredtime()){ social1.setInsuredtime(null); } boolean save = this.save(social); if (save) { //内网同步 String s = "insert into sys_socil(" + "id,namb,sex,nation,telephone,cardid,residence,address," + "nature,amount,insuredtime,deptid) " + "values(" + "'" + social.getId() + "'" + "," + "'" + social.getNamb() + "'" + "," + "'" + social.getSex() + "'" + "," + "'" + social.getNation() + "'" + "," + "'" + social.getTelephone() + "'" + "," + "'" + social.getCardid() + "'" + "," + "'" + social.getResidence() + "'" + "," + "'" + social.getAddress() + "'" + "," + "'" + social.getNature() + "'" + "," + "'" + social.getAmount() + "'" + "," + "," + "'" + new SimpleDateFormat("yyyy-MM-dd").format(social.getInsuredtime()) + "'" + "," + "'" + social.getDeptid() + "'" + ")"; myAsyncService.FTP(s); } }); } /** * 修改为已参保 * @param cardid */ @Override public void upSoil(String cardid) { baseMapper.upSoil(cardid); } }