| | |
| | | |
| | | import javax.validation.Valid; |
| | | import java.io.*; |
| | | import java.util.ArrayList; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.text.DateFormat; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.*; |
| | | |
| | | import static org.springblade.core.cache.constant.CacheConstant.SYS_CACHE; |
| | | |
| | |
| | | @RequestMapping("/information") |
| | | @Api(value = "", tags = "接口") |
| | | public class InformationController extends BladeController { |
| | | //ftp服务器IP地址 |
| | | private static String ftpHost = "192.168.0.105"; |
| | | //ftp服务器端口 |
| | | private static int ftpPort = 21; |
| | | //ftp服务器用户名 |
| | | private static String ftpUserName = "yly"; |
| | | //ftp服务器密码 |
| | | private static String ftpPassword = "Yly@123"; |
| | | //本地路径 |
| | | private static String localPath = "D:\\anbao"; |
| | | |
| | | private final IInformationService informationService; |
| | | private final IDeptService iDeptService; |
| | |
| | | @GetMapping("/page") |
| | | @ApiOperationSupport(order = 3) |
| | | @ApiOperation(value = "分页", notes = "传入information") |
| | | public R<IPage<Information>> page(Information information, Query query) { |
| | | IPage<Information> pages = informationService.selectInformationPage(Condition.getPage(query), information); |
| | | public R<IPage<InformationVO>> page(InformationVO information, Query query) { |
| | | IPage<InformationVO> pages = informationService.selectInformationPage(Condition.getPage(query), information); |
| | | return R.data(pages); |
| | | } |
| | | |
| | |
| | | String id = kv.get("id").toString(); |
| | | information.setDepartmentid(id); |
| | | } |
| | | //String json=JSON.toJSONString(information); |
| | | //com.util.OutJson.createJsonFile(json,"d:/anbao/information/","informationSave"); |
| | | //arg.test01(arg.url + "/information/save", information); |
| | | return R.status(informationService.save(information)); |
| | | informationService.save(information); |
| | | 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," + |
| | | " 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() + "'" + "," + "'" + |
| | | information.getAddress() + "'" + "," + "'" + information.getBusiness() + "'" + "," + "'" + |
| | | information.getRegion() + "'" + "," + "'" + information.getRegistration() + "'" + "," + "'" + information.getIndustry() + "'" + "," + "'" + information.getDepartmentid() + "'" + "," + |
| | | "'" + information.getStats() + "'" + "," + "'" + information.getJurisdiction() + "'" + "," + "'" + information.getRepresentativecell() + "'" + "," + |
| | | "'" + information.getContacts() + "'" + "," + "'" + information.getContactscell() + "'" + ");" + |
| | | "insert into blade_dept(id,parent_id,tenant_id,dept_name,ancestors,dept_category) values(" + "'" + information.getDepartmentid() + "'" + "," + "'" + dept.getParentId() + "'" + "," |
| | | + "'" + dept.getTenantId() + "'" + "," + "'" + information.getEnterprisename() + "'" + "," + "'" + dept.getAncestors() + "'" + "," + "'" + dept.getDeptCategory() + "'" + ")"; |
| | | FtpUtil.sqlFileUpload(s); |
| | | return R.success("成功"); |
| | | } |
| | | |
| | | /** |
| | |
| | | @ApiOperationSupport(order = 5) |
| | | @ApiOperation(value = "修改", notes = "传入information") |
| | | public R update(@Valid @RequestBody Information information) throws Exception { |
| | | //arg.test01(arg.url + "/information/update", information); |
| | | return R.status(informationService.updateById(information)); |
| | | } |
| | | |
| | |
| | | informationService.deleteIn(strArray[i]); |
| | | informationService.deleteSh(strArray[i]); |
| | | informationService.deleteMe(strArray[i]); |
| | | //arg.sendPostRemoveByIds(arg.url + "/information/remove", strArray[i]); |
| | | |
| | | } |
| | | for (int j = 0; j < strArrays.length; j++) { |
| | | //机构删除 |
| | | informationService.deleteDept(strArrays[j]); |
| | | //arg.sendPostRemoveByIds(arg.url + "/information/deleteDept", strArrays[j]); |
| | | } |
| | | |
| | | return R.success("删除成功"); |
| | |
| | | ExcelUtil.save(file, inforImporter, InforExcel.class); |
| | | return R.success("操作成功"); |
| | | } |
| | | |
| | | // public static void main(String[] args) { |
| | | // Information information = new Information(); |
| | | // information.setAddress("2"); |
| | | // information.setDepartmentid("123"); |
| | | // String json=JSON.toJSONString(information);//关键 |
| | | // com.util.OutJson.createJsonFile(json,"d:/anbao/information/","informationSave"); |
| | | // System.out.println("生成文件完成!"); |
| | | // } |
| | | |
| | | |
| | | @PostMapping("ss") |
| | | public void ss() throws FileNotFoundException { |
| | | //ftp服务器IP地址 |
| | | String ftpHost = "192.168.0.105"; |
| | | //ftp服务器端口 |
| | | int ftpPort = 21; |
| | | //ftp服务器用户名 |
| | | String ftpUserName = "yly"; |
| | | //ftp服务器密码 |
| | | String ftpPassword = "Yly@123"; |
| | | //ftp服务器路径 |
| | | String ftpPath = ""; |
| | | //本地路径 |
| | | String localPath = "D:\\anbao"; |
| | | //文件名 |
| | | String fileName = "sql.json"; |
| | | Information information = new Information(); |
| | | information.setCreditcode("1"); |
| | | informationService.insertIn(information); |
| | | Integer id = information.getId(); |
| | | String s = "insert into sys_information(id,creditcode) values(" + "'" + id + "'" + "," + "'" + 1 + "'" + ")"; |
| | | System.out.println(s); |
| | | Object o = s; |
| | | String json = JSON.toJSONString(o); |
| | | OutJson.createJsonFile(json, "d:/", "sql"); |
| | | FileInputStream in = new FileInputStream(new File("D:\\" + fileName)); |
| | | FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/", fileName, in); |
| | | } |
| | | |
| | | |
| | | public static void main(String[] args) throws Exception { |
| | | //ftp服务器IP地址 |
| | | String ftpHost = "192.168.0.105"; |
| | | //ftp服务器端口 |
| | | int ftpPort = 21; |
| | | //ftp服务器用户名 |
| | | String ftpUserName = "yly"; |
| | | //ftp服务器密码 |
| | | String ftpPassword = "Yly@123"; |
| | | //ftp服务器路径 |
| | | String ftpPath = "anbao/sql.json"; |
| | | //本地路径 |
| | | String localPath = "D:\\anbao"; |
| | | //文件名 |
| | | String fileName = "sql.json"; |
| | | // FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName); |
| | | String s = OutJson.TestJson(); |
| | | String sql = OutJson.stringReplace(s); |
| | | System.out.println(sql); |
| | | //boolean ftpFileExist = FtpUtil.isFTPFileExist(ftpPath, ftpUserName, ftpPassword, ftpHost, ftpPort); |
| | | //System.out.println(ftpFileExist); |
| | | } |
| | | |
| | | |
| | | |
| | | } |