| | |
| | | import io.swagger.annotations.ApiOperation; |
| | | import io.swagger.annotations.ApiParam; |
| | | import lombok.AllArgsConstructor; |
| | | import org.springblade.common.utils.DesensitizedUtil; |
| | | import org.springblade.common.utils.arg; |
| | | import org.springblade.core.boot.ctrl.BladeController; |
| | | import org.springblade.core.excel.util.ExcelUtil; |
| | | import org.springblade.core.mp.support.Condition; |
| | | import org.springblade.core.mp.support.Query; |
| | | import org.springblade.core.tool.api.R; |
| | | import org.springblade.core.tool.utils.BeanUtil; |
| | | import org.springblade.core.tool.utils.Func; |
| | | import org.springblade.modules.FTP.FtpUtil; |
| | | import org.springblade.modules.equipage.excel.EquipageExcel; |
| | |
| | | import org.springblade.modules.member.excel.memberImporter; |
| | | import org.springblade.modules.member.service.IMemberService; |
| | | import org.springblade.modules.member.vo.MemberVO; |
| | | import org.springblade.modules.shareholder.entity.Shareholder; |
| | | import org.springblade.modules.shareholder.excel.shareExcel; |
| | | import org.springblade.modules.shareholder.excel.shareImporter; |
| | | import org.springblade.modules.system.service.MyAsyncService; |
| | | import org.springframework.web.bind.annotation.*; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.Objects; |
| | | |
| | | /** |
| | | * 控制器 |
| | |
| | | public class MemberController extends BladeController { |
| | | |
| | | private final IMemberService memberService; |
| | | private final MyAsyncService myAsyncService; |
| | | |
| | | /** |
| | | * 详情 |
| | |
| | | @ApiOperationSupport(order = 4) |
| | | @ApiOperation(value = "新增", notes = "传入member") |
| | | public R save(@Valid @RequestBody Member member) throws Exception { |
| | | boolean save = memberService.save(member); |
| | | String s1 = |
| | | "insert into sys_member(id,name,post,cardid,cell,creditCode,dept_id) " + |
| | | "values(" + "'" + member.getId() + "'" + "," + |
| | | "'" + member.getName() + "'" + "," + |
| | | "'" + member.getPost() + "'" + "," + |
| | | "'" + member.getCardid() + "'" + "," + |
| | | "'" + member.getCell() + "'"+"," + |
| | | "'" + member.getCreditcode() + "'"+"," + |
| | | "'" + member.getDeptId() + "'"+")"; |
| | | FtpUtil.sqlFileUpload(s1); |
| | | Member member1 = Objects.requireNonNull(BeanUtil.copy(member, Member.class)); |
| | | if (null!=member1.getName() && !member1.getName().equals("")){ |
| | | member1.setName(DesensitizedUtil.desensitizedName(member1.getName())); |
| | | } |
| | | if (null!=member1.getPost() && !member1.getPost().equals("")){ |
| | | member1.setPost("***"); |
| | | } |
| | | if (null!=member1.getCardid() && !member1.getCardid().equals("")){ |
| | | member1.setCardid(DesensitizedUtil.desensitizedIdNumberBy4(member1.getCardid())); |
| | | } |
| | | if (null!=member1.getCell() && !member1.getCell().equals("")){ |
| | | member1.setCell(DesensitizedUtil.desensitizedPhoneNumber(member1.getCell())); |
| | | } |
| | | //脱敏处理 |
| | | boolean save = memberService.save(member1); |
| | | if (save) { |
| | | String s1 = |
| | | "insert into sys_member(id,name,post,cardid,cell,creditCode,dept_id) " + |
| | | "values(" + "'" + member1.getId() + "'" + "," + |
| | | "'" + member.getName() + "'" + "," + |
| | | "'" + member.getPost() + "'" + "," + |
| | | "'" + member.getCardid() + "'" + "," + |
| | | "'" + member.getCell() + "'" + "," + |
| | | "'" + member.getCreditcode() + "'" + "," + |
| | | "'" + member.getDeptId() + "'" + ")"; |
| | | //FtpUtil.sqlFileUpload(s1); |
| | | myAsyncService.FTP(s1); |
| | | } |
| | | return R.status(save); |
| | | } |
| | | |
| | |
| | | @ApiOperationSupport(order = 5) |
| | | @ApiOperation(value = "修改", notes = "传入member") |
| | | public R update(@Valid @RequestBody Member member) throws Exception { |
| | | boolean b = memberService.updateById(member); |
| | | String s1 = "update sys_member set name = " + "'" + member.getName() + "'" + |
| | | ",post = " + "'" + member.getPost() + "'" + |
| | | ",cardid = " + "'" + member.getCardid() + "'" + |
| | | ",cell = " + "'" + member.getCell() + "'" + |
| | | ",cardid = " + "'" + member.getCardid() + "'" + |
| | | ",creditCode = " + "'" + member.getCreditcode() + "'" + |
| | | ",dept_id = " + "'" + member.getDeptId() + "'" + |
| | | " " + "where id = " + "'" + member.getId() + "'"; |
| | | FtpUtil.sqlFileUpload(s1); |
| | | Member member1 = Objects.requireNonNull(BeanUtil.copy(member, Member.class)); |
| | | if (null!=member1.getName() && !member1.getName().equals("")){ |
| | | member1.setName(DesensitizedUtil.desensitizedName(member1.getName())); |
| | | } |
| | | if (null!=member1.getPost() && !member1.getPost().equals("")){ |
| | | member1.setPost("***"); |
| | | } |
| | | if (null!=member1.getCardid() && !member1.getCardid().equals("")){ |
| | | member1.setCardid(DesensitizedUtil.desensitizedIdNumberBy4(member1.getCardid())); |
| | | } |
| | | if (null!=member1.getCell() && !member1.getCell().equals("")){ |
| | | member1.setCell(DesensitizedUtil.desensitizedPhoneNumber(member1.getCell())); |
| | | } |
| | | boolean b = memberService.updateById(member1); |
| | | if (b) { |
| | | String s1 = "update sys_member set name = " + "'" + member.getName() + "'" + |
| | | ",post = " + "'" + member.getPost() + "'" + |
| | | ",cardid = " + "'" + member.getCardid() + "'" + |
| | | ",cell = " + "'" + member.getCell() + "'" + |
| | | ",cardid = " + "'" + member.getCardid() + "'" + |
| | | ",creditCode = " + "'" + member.getCreditcode() + "'" + |
| | | ",dept_id = " + "'" + member.getDeptId() + "'" + |
| | | " " + "where id = " + "'" + member.getId() + "'"; |
| | | //FtpUtil.sqlFileUpload(s1); |
| | | myAsyncService.FTP(s1); |
| | | } |
| | | return R.status(b); |
| | | } |
| | | |
| | |
| | | List<Long> list = Func.toLongList(ids); |
| | | list.forEach(id -> { |
| | | String s1 = "delete from sys_member where id = " + "'" + id + "'"; |
| | | FtpUtil.sqlFileUpload(s1); |
| | | myAsyncService.FTP(s1); |
| | | }); |
| | | return R.status(memberService.removeByIds(Func.toLongList(ids))); |
| | | } |