| | |
| | | import lombok.AllArgsConstructor; |
| | | import org.apache.commons.codec.Charsets; |
| | | import org.springblade.common.excel.RowWriteHandler; |
| | | import org.springblade.common.utils.DesensitizedUtil; |
| | | 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.DateUtil; |
| | | import org.springblade.core.tool.utils.Func; |
| | | import org.springblade.modules.social.entity.Social; |
| | |
| | | import org.springblade.modules.social.service.ISocialService; |
| | | import org.springblade.modules.social.vo.SocialVO; |
| | | import org.springblade.modules.system.excel.UserExcel; |
| | | 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 SocialController extends BladeController { |
| | | |
| | | private final ISocialService socialService; |
| | | |
| | | private final MyAsyncService myAsyncService; |
| | | |
| | | /** |
| | | * 详情 |
| | |
| | | @ApiOperationSupport(order = 4) |
| | | @ApiOperation(value = "新增", notes = "传入social") |
| | | public R save(@Valid @RequestBody Social social) { |
| | | socialService.upSoil(social.getCardid()); |
| | | return R.status(socialService.save(social)); |
| | | //修改为已参保 |
| | | socialService.upSoil(social.getNamb()); |
| | | 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 = socialService.save(social1); |
| | | if (save){ |
| | | //内网同步 |
| | | String s = "insert into sys_socil(" + |
| | | "id,namb,sex,nation,telephone,cardid,residence,address," + |
| | | "nature,amount,insuredtime,deptid) " + |
| | | "values(" + "'" + social1.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); |
| | | } |
| | | return R.status(save); |
| | | } |
| | | |
| | | /** |
| | |
| | | @ApiOperationSupport(order = 8) |
| | | @ApiOperation(value = "删除", notes = "传入ids") |
| | | public R remove(@ApiParam(value = "主键集合", required = true) @RequestParam String ids) { |
| | | //内网同步 |
| | | List<Long> list = Func.toLongList(ids); |
| | | list.forEach(id -> { |
| | | String s1 = "delete from sys_socil where id = " + "'" + id + "'"; |
| | | myAsyncService.FTP(s1); |
| | | }); |
| | | return R.status(socialService.removeByIds(Func.toLongList(ids))); |
| | | } |
| | | |