| | |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import lombok.AllArgsConstructor; |
| | | import com.alibaba.fastjson.JSON; |
| | | import org.springblade.common.cache.DictCache; |
| | | import org.springblade.common.enums.DictEnum; |
| | | import org.springblade.common.utils.arg; |
| | | import org.springblade.core.boot.ctrl.BladeController; |
| | | import org.springblade.core.cache.utils.CacheUtil; |
| | | 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.support.Kv; |
| | | import org.springblade.modules.FTP.FtpUtil; |
| | | import org.springblade.modules.FTP.OutJson; |
| | | import org.springblade.modules.information.entity.Information; |
| | | import org.springblade.modules.information.excel.InforExcel; |
| | | import org.springblade.modules.information.excel.InforImporter; |
| | | import org.springblade.modules.information.service.IInformationService; |
| | | import org.springblade.modules.information.vo.InformationVO; |
| | | import org.springblade.modules.system.entity.Dept; |
| | | import org.springblade.modules.system.service.IDeptService; |
| | | import org.springframework.web.bind.annotation.*; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import javax.validation.Valid; |
| | | import java.lang.reflect.Field; |
| | | import java.util.ArrayList; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.io.*; |
| | | 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; |
| | |
| | | IPage<InformationVO> pages = informationService.selectInformationPage(Condition.getPage(query), information); |
| | | return R.data(pages); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 培训公司信息查询 |
| | | */ |
| | | @GetMapping("/security-page") |
| | | public R<IPage<InformationVO>> securityPage(InformationVO information, Query query) { |
| | | IPage<InformationVO> pages = informationService.securityPage(Condition.getPage(query), information); |
| | | return R.data(pages); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 新增 |
| | |
| | | dept.setAncestors("0,1420222961377357825"); |
| | | dept.setDeptCategory(1); |
| | | } |
| | | //跨区域保安公司 |
| | | if (information.getStats().equals("4")) { |
| | | Long i = 1425366663452196865L; |
| | | dept.setParentId(i); |
| | | dept.setTenantId("000000"); |
| | | dept.setDeptName(information.getEnterprisename()); |
| | | dept.setAncestors("0,1425366663452196865"); |
| | | dept.setDeptCategory(1); |
| | | } |
| | | if (iDeptService.submit(dept)) { |
| | | CacheUtil.clear(SYS_CACHE); |
| | | // 返回懒加载树更新节点所需字段 |
| | |
| | | String id = kv.get("id").toString(); |
| | | information.setDepartmentid(id); |
| | | } |
| | | //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("删除成功"); |
| | |
| | | return R.data(list); |
| | | } |
| | | |
| | | public static String getJSONStringFromJavaBean(Class<? extends Object> clazz) { |
| | | |
| | | Field[] fields = clazz.getDeclaredFields(); |
| | | |
| | | StringBuffer stb = new StringBuffer("{"); |
| | | |
| | | for (int i = 0; i < fields.length; i++) { |
| | | |
| | | try { |
| | | |
| | | Field field = fields[i]; |
| | | |
| | | field.setAccessible(true); |
| | | |
| | | String name = field.getName(); |
| | | |
| | | stb.append("\"").append(name).append("\"").append(":\"\"").append(","); |
| | | |
| | | } catch (Exception e) { |
| | | |
| | | e.printStackTrace(); |
| | | |
| | | } |
| | | |
| | | } |
| | | |
| | | int i = stb.lastIndexOf(","); |
| | | |
| | | return stb.substring(0, i) + "}"; |
| | | |
| | | /** |
| | | * 导入单位信息 |
| | | */ |
| | | @PostMapping("import-informaton") |
| | | @ApiOperationSupport(order = 12) |
| | | @ApiOperation(value = "导入单位", notes = "传入excel") |
| | | public R importUser(MultipartFile file, Integer isCovered) { |
| | | InforImporter inforImporter = new InforImporter(informationService, false); |
| | | ExcelUtil.save(file, inforImporter, InforExcel.class); |
| | | return R.success("操作成功"); |
| | | } |
| | | |
| | | |
| | | } |