| | |
| | | String formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(information.getEstablishtime()); |
| | | //Integer id = information.getId(); |
| | | String s = "insert into sys_information(id,creditcode,enterprisename,representative,establishtime," + |
| | | "registeredcapital,organizationcode,registrationnumber,identificationnumber, enterprises, address," + |
| | | "registeredcapital,organizationcode,registrationnumber, enterprises, address," + |
| | | " business,region,registration,industry,departmentid,stats,jurisdiction,representativecell,contacts,contactscell) " + |
| | | "values(" + "'" + information.getId() + "'" + "," + "'" + information.getCreditcode() + "'" + "," + "'" + information.getEnterprisename() + "'" + "," + "'" + information.getRepresentative() + "'" + "," + |
| | | "'" + formatStr + "'" + "," + "'" + information.getRegisteredcapital() + "'" + "," + "'" + information.getOrganizationcode() + "'" + "," + "'" + information.getRegistrationnumber() + "'" + "," + |
| | | "'" + information.getIdentificationnumber() + "'" + "," + "'" + information.getEnterprises() + "'" + "," + "'" + |
| | | "'" + formatStr + "'" + "," + "'" + information.getRegisteredcapital() + "'" + "," + "'" + information.getOrganizationcode() + "'" + "," + "'" + information.getRegistrationnumber() + "'" + "," + "'" + information.getEnterprises() + "'" + "," + "'" + |
| | | information.getAddress() + "'" + "," + "'" + information.getBusiness() + "'" + "," + "'" + |
| | | information.getRegion() + "'" + "," + "'" + information.getRegistration() + "'" + "," + "'" + information.getIndustry() + "'" + "," + "'" + information.getDepartmentid() + "'" + "," + |
| | | "'" + information.getStats() + "'" + "," + "'" + information.getJurisdiction() + "'" + "," + "'" + information.getRepresentativecell() + "'" + "," + |
| | |
| | | |
| | | |
| | | /** |
| | | * |
| | | * app 文件上传 |
| | | * |
| | | * @param file 图片对象 |
| | | */ |
| | | @PostMapping("put-file-app") |
| | |
| | | |
| | | |
| | | /** |
| | | * |
| | | * 文件上传,自定义上传 |
| | | * |
| | | * @param file 图片对象 |
| | | */ |
| | | @PostMapping("put-files") |
| | |
| | | String urls = "http://223.82.109.183:2081/zhba/" + newName; |
| | | //数据封装 |
| | | Map<String, Object> map = new HashMap<>(2); |
| | | map.put("name",newName); |
| | | map.put("url",urls); |
| | | map.put("name", newName); |
| | | map.put("url", urls); |
| | | //返回 |
| | | return R.data(map); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * |
| | | * 文件上传,自定义上传 |
| | | * |
| | | * @param file 图片对象 |
| | | */ |
| | | @PostMapping("put-files-talk") |
| | |
| | | String urls = "http://223.82.109.183:2081/zhba/" + newName; |
| | | //数据封装 |
| | | Map<String, Object> map = new HashMap<>(2); |
| | | map.put("name",newName); |
| | | map.put("url",urls); |
| | | map.put("name", newName); |
| | | map.put("url", urls); |
| | | //返回 |
| | | return R.data(map); |
| | | } |
| | |
| | | */ |
| | | @SneakyThrows |
| | | @PostMapping("/put-file-attach") |
| | | public R<BladeFile> putFileAttach(@RequestParam MultipartFile file,String deptid,String type,Long noticeId,String cardid) { |
| | | public R<BladeFile> putFileAttach(@RequestParam MultipartFile file, String deptid, String type, Long noticeId, String cardid) { |
| | | String fileName = file.getOriginalFilename(); |
| | | BladeFile bladeFile = ossBuilder.template().putFile(fileName, file.getInputStream()); |
| | | Long attachId = buildAttach(fileName, file.getSize(), bladeFile,deptid,type,noticeId,cardid); |
| | | InputStream inputStream = file.getInputStream(); |
| | | Long attachId = buildAttach(fileName, file.getSize(), bladeFile, deptid, type, noticeId, cardid, inputStream); |
| | | bladeFile.setAttachId(attachId); |
| | | return R.data(bladeFile); |
| | | } |
| | |
| | | */ |
| | | @SneakyThrows |
| | | @PostMapping("/put-file-attach-by-name") |
| | | public R<BladeFile> putFileAttach(@RequestParam String fileName, @RequestParam MultipartFile file,String deptid,String type,Long noticeId,String cardid) { |
| | | public R<BladeFile> putFileAttach(@RequestParam String fileName, @RequestParam MultipartFile file, String deptid, String type, Long noticeId, String cardid) { |
| | | BladeFile bladeFile = ossBuilder.template().putFile(fileName, file.getInputStream()); |
| | | Long attachId = buildAttach(fileName, file.getSize(), bladeFile,deptid,type,noticeId,cardid); |
| | | Long attachId = buildAttach(fileName, file.getSize(), bladeFile, deptid, type, noticeId, cardid, file.getInputStream()); |
| | | bladeFile.setAttachId(attachId); |
| | | return R.data(bladeFile); |
| | | } |
| | |
| | | * @param bladeFile 对象存储文件 |
| | | * @return attachId |
| | | */ |
| | | private Long buildAttach(String fileName, Long fileSize, BladeFile bladeFile,String deptid,String type,Long noticeId,String cardid) throws Exception { |
| | | private Long buildAttach(String fileName, Long fileSize, BladeFile bladeFile, String deptid, String type, Long noticeId, String cardid, InputStream in) throws Exception { |
| | | //BladeUser user = AuthUtil.getUser(); |
| | | String fileExtension = FileUtil.getFileExtension(fileName); |
| | | Attach attach = new Attach(); |
| | |
| | | attach.setDeptid(deptid); |
| | | attach.setCardid(cardid); |
| | | attach.setType(type); |
| | | if (null!=noticeId){ |
| | | if (null != noticeId) { |
| | | attach.setNoticeId(noticeId); |
| | | } |
| | | attachService.save(attach); |
| | | String[] split = bladeFile.getName().split("/"); |
| | | String ip = "http://192.168.0.108/zhba/picture/"; |
| | | String imgurl = ip + split[2]; |
| | | FtpUtil.uploadFile(ftpHost_dev, ftpPort, ftpUserName, ftpPassword, ftpPath, "/", split[2], in); |
| | | //数据同步 |
| | | String s1 = |
| | | "insert into blade_attach(id,tenant_id,link,domain,name,original_name,extension,attach_size,create_user,create_dept," + |
| | | "create_time,update_user,update_time,status,is_deleted,deptid,type,notice_id,cardid) " + |
| | | "create_time,update_user,update_time,status,is_deleted,type,cardid"; |
| | | if (noticeId != null) { |
| | | s1 += ",notice_id"; |
| | | } else { |
| | | s1 += ") " + |
| | | "values(" + "'" + attach.getId() + "'" + "," + |
| | | "'" + attach.getTenantId() + "'" + "," + |
| | | "'" + attach.getLink() + "'" + "," + |
| | | "'" + attach.getDomain() + "'" + "," + |
| | | "'" + attach.getName() + "'" + "," + |
| | | "'" + imgurl + "'" + "," + |
| | | "'" + ip + "'" + "," + |
| | | "'" + split[2] + "'" + "," + |
| | | "'" + attach.getOriginalName() + "'" + "," + |
| | | "'" + attach.getExtension() + "'" + "," + |
| | | "'" + attach.getAttachSize() + "'" + "," + |
| | | "'" + attach.getCreateUser() + "'" + "," + |
| | | "'" + attach.getCreateDept() + "'" + "," + |
| | | "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "'" + "," + |
| | | "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "'" + "," + |
| | | "'" + attach.getUpdateUser() + "'" + "," + |
| | | "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "'" + "," + |
| | | "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "'" + "," + |
| | | "'" + attach.getStatus() + "'" + "," + |
| | | "'" + attach.getIsDeleted() + "'" + "," + |
| | | "'" + attach.getType() + "'" + "," + |
| | | "'" + attach.getNoticeId() + "'" + "," + |
| | | "'" +attach.getCardid() + "'" + ")"; |
| | | "'" + cardid + "'"; |
| | | } |
| | | if (noticeId != null) { |
| | | s1 += "'" + noticeId + "'" + ")"; |
| | | } |
| | | else { |
| | | s1+=")"; |
| | | } |
| | | FtpUtil.sqlFileUpload(s1); |
| | | return attach.getId(); |
| | | } |
| | |
| | | import springfox.documentation.annotations.ApiIgnore; |
| | | |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | |
| | | @ApiOperation(value = "新增", notes = "传入talk") |
| | | public R save(@Valid @RequestBody Talk talk) { |
| | | talkService.save(talk); |
| | | String ip = "http://192.168.0.108"; |
| | | String url = ""; |
| | | String[] split = talk.getImgurl().split(","); |
| | | for (int i=0;i<split.length;i++){ |
| | | String s = split[i].substring(0,split[i].indexOf("/")); |
| | | System.out.println(s); |
| | | for (int i = 0; i < split.length; i++) { |
| | | String s = split[i].substring(26, split[i].length()); |
| | | url += ip + s + ","; |
| | | } |
| | | // //数据同步 |
| | | // String s1 = |
| | | // "insert into sys_talk(id,title,real_name,talkcontent,talktime,conclusion,evaluate,deptid,imgurl) " + |
| | | // "values(" + "'" + talk.getId() + "'" + "," + |
| | | // "'" + talk.getTitle() + "'" + "," + |
| | | // "'" + talk.getRealName() + "'" + "," + |
| | | // "'" + talk.getTalkcontent() + "'" + "," + |
| | | // "'" + new SimpleDateFormat("yyyy-MM-dd").format(talk.getTalktime()) + "'" + "," + |
| | | // "'" + talk.getConclusion() + "'" + "," + |
| | | // "'" + talk.getEvaluate() + "'" + "," + |
| | | // "'" + talk.getDeptid() + "'" + "," + |
| | | // "'" + talk.getImgurl() + "'" + ")"; |
| | | // FtpUtil.sqlFileUpload(s1); |
| | | String substring = url.substring(0, url.length() - 1); |
| | | talk.setImgurl(substring); |
| | | //数据同步 |
| | | String s1 = |
| | | "insert into sys_talk(id,title,real_name,talkcontent,talktime,conclusion,evaluate,deptid,imgurl) " + |
| | | "values(" + "'" + talk.getId() + "'" + "," + |
| | | "'" + talk.getTitle() + "'" + "," + |
| | | "'" + talk.getRealName() + "'" + "," + |
| | | "'" + talk.getTalkcontent() + "'" + "," + |
| | | "'" + new SimpleDateFormat("yyyy-MM-dd").format(talk.getTalktime()) + "'" + "," + |
| | | "'" + talk.getConclusion() + "'" + "," + |
| | | "'" + talk.getEvaluate() + "'" + "," + |
| | | "'" + talk.getDeptid() + "'" + "," + |
| | | "'" + talk.getImgurl() + "'" + ")"; |
| | | FtpUtil.sqlFileUpload(s1); |
| | | return R.success("新增成功"); |
| | | } |
| | | |
| | |
| | | @ApiOperationSupport(order = 5) |
| | | @ApiOperation(value = "修改", notes = "传入talk") |
| | | public R update(@Valid @RequestBody Talk talk) { |
| | | return R.status(talkService.updateById(talk)); |
| | | talkService.updateById(talk); |
| | | String ip = "http://192.168.0.108"; |
| | | String url = ""; |
| | | String[] split = talk.getImgurl().split(","); |
| | | for (int i = 0; i < split.length; i++) { |
| | | String s = split[i].substring(26, split[i].length()); |
| | | url += ip + s + ","; |
| | | } |
| | | String substring = url.substring(0, url.length() - 1); |
| | | talk.setImgurl(substring); |
| | | String s1 = "update sys_talk set title = " + "'" + talk.getTitle() + "'" + |
| | | ",real_name = " + "'" + talk.getRealName() + "'" + |
| | | ",talkcontent = " + "'" + talk.getTalkcontent() + "'" + |
| | | ",talktime = " + "'" + new SimpleDateFormat("yyyy-MM-dd").format(talk.getTalktime()) + "'" + |
| | | ",conclusion = " + "'" + talk.getConclusion() + "'" + |
| | | ",evaluate = " + "'" + talk.getEvaluate() + "'" + |
| | | ",deptid = " + "'" + talk.getDeptid() + "'" + |
| | | ",imgurl = " + "'" + talk.getImgurl() + "'" + |
| | | " " + "where id = " + "'" + talk.getId() + "'"; |
| | | FtpUtil.sqlFileUpload(s1); |
| | | return R.success("修改成功"); |
| | | } |
| | | |
| | | /** |
| | |
| | | @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_talk where id = " + "'" + id + "'"; |
| | | FtpUtil.sqlFileUpload(s1); |
| | | }); |
| | | return R.status(talkService.removeByIds(Func.toLongList(ids))); |
| | | } |
| | | |