From c75d665f5c8cb15d23ed613d0a8d74bb15e94291 Mon Sep 17 00:00:00 2001 From: haozq <1611483981@qq.com> Date: Wed, 5 Nov 2025 17:04:11 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=AE=89=E5=85=A8=E5=8D=95?= =?UTF-8?q?=E4=BD=8D=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../job/executor/inter/config/GenEntity.java | 6 +-- .../executor/inter/config/GlobalConfig.java | 8 +++ .../job/executor/inter/entity/JjAqUnit.java | 50 +++++++++++++++++++ .../executor/inter/mapper/InterMapper.java | 32 +++++++----- .../inter/service/DataCenterService.java | 8 +++ .../executor/inter/service/InterService.java | 33 ++++++++++++ .../inter/service/InterTwoService.java | 28 +++++++++++ .../service/jobhandler/DataCenterXxlJob.java | 10 ++++ .../src/main/resources/mapper/InterMapper.xml | 22 ++++++++ 9 files changed, 182 insertions(+), 15 deletions(-) create mode 100644 xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjAqUnit.java diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GenEntity.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GenEntity.java index eac8a01..95b52ce 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GenEntity.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GenEntity.java @@ -27,7 +27,7 @@ public class GenEntity { private static boolean f_sql = false; // 是否需要导入包java.sql.* /*** 数据库连接常量,需优化.每次运行main方法创建连接CPU损耗率高; **/ - private static final String URL = "jdbc:mysql://127.0.0.1:3306/exportdata?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true"; + private static final String URL = "jdbc:mysql://127.0.0.1:3306/add_all?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true"; private static final String NAME = "mroot"; private static final String PASS = "bonus@admin123"; private static final String DRIVER = "com.mysql.cj.jdbc.Driver"; @@ -41,7 +41,7 @@ public class GenEntity { try { Class.forName(DRIVER); conn = DriverManager.getConnection(URL, NAME, PASS); - conn.setCatalog("exportdata"); + conn.setCatalog("add_all"); } catch (Exception e1) { e1.printStackTrace(); } @@ -65,7 +65,7 @@ public class GenEntity { //获取数据库的元数据 DatabaseMetaData db = getConnection().getMetaData(); //从元数据中获取到所有的表名 - rs = db.getTables("exportdata","exportdata", null, new String[] { "TABLE" }); + rs = db.getTables("add_all","add_all", null, new String[] { "TABLE" }); while(rs.next()) { tableNames.add(rs.getString(3)); } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GlobalConfig.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GlobalConfig.java index 1cf8ef3..e0fa7a9 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GlobalConfig.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GlobalConfig.java @@ -97,6 +97,14 @@ public class GlobalConfig { * 安全人员信息 */ public final static String AQ_ZR_USER_URL=IP_URL+"/biz-api/ifsct/up/sel/smSafetyPersonnel"; + + /** + * 安全单位 + */ + public final static String AQ_UNIT=IP_URL+"/biz-api/ifsct/up/sel/smSafetySgcUnit"; + + + /** * 基建布控球 */ diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjAqUnit.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjAqUnit.java new file mode 100644 index 0000000..9fce59c --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjAqUnit.java @@ -0,0 +1,50 @@ +package com.xxl.job.executor.inter.entity; + +import lombok.Data; + +/** + * jjAqUnit 实体类 + * 2025-11-05 16:35:21 zijixiangba + */ + +@Data +public class JjAqUnit{ + + private String id; //主键 + private String iscUnitId; //基建id + private String safetySgcUnitId; //安监id + private String unitName; //单位全称 + private String unitAbbrName; //单位简称 + private String unitCode; //单位编码 + private String mainCode; //主数据单位编码 + private String unifiedSocialCreditId; //统一社会信用代码 + private String legalRepr; // 法定代表人 + private String legalReprMobile; //法定代表人手机号 + private String contactPhone; //联系方式 + private String unitType; //单位类型 1：建设管理单位、2：勘察单位、3：设计单位、4：评审单位、5：监理单位、6：施工单位、7：分包单位、8：环保单位、99：其他 + private String unitNature; //单位性质 + private String sysType; //系统类型 + private String sysCateg; //系统分类 + private String unitSign; //单位标识 + private String establishmentDate; //成立日期 + private String registerCapital; //注册资本 + private String website; //企业网站 + private String province; //所在省 + private String city; //所在市 + private String county; //所在县 + private String address; //单位地址 + private String mainBusiness; //经营范围 + private String dataSource; //数据来源 + private String huvFlag; //是否特高压0：常规工程、1：特高压 + private String provinceCode; //省公司编码 + private String buildUnitCode; //建设管理单位编码 + private String createrId; //创建人 + private String createTime; //创建时间 + private String updaterId; //更新人 + private String updateTime; //更新时间 + private String deleteFlag; //删除状态 + private String legalIdCard; //法人身份证号 + private String businessFileId; //营业执照照片id + +} + diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java index 7c11e08..77633d8 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java @@ -23,65 +23,71 @@ public interface InterMapper { * 处理标段工程 * @param list */ - void insertBidPro(List list); + void insertBidPro(@Param("list")List list); /** * 处理标段工程 * @param list */ - void insertBidProNew(List list); + void insertBidProNew(@Param("list")List list); /** * 插入 班组team * @param list */ - void insertTeam(List list); + void insertTeam(@Param("list")List list); - void insertTeamPeople(List list); + void insertTeamPeople(@Param("list")List list); /** * 作业票信息 * @param list */ - void insertTicket(List list); + void insertTicket(@Param("list")List list); /** * 新增作业票信息 * @param list */ - void insertTicketPeople(List list); + void insertTicketPeople(@Param("list")List list); /** * 新增周计划 */ - void insertWeeksPlanData(List list); + void insertWeeksPlanData(@Param("list")List list); /** * 新增日计划 * @param list */ - void insertDayPlanData(List list); + void insertDayPlanData(@Param("list")List list); /** * 基建人员信息 * @param list */ - void insertJJUser(List list); + void insertJJUser(@Param("list")List list); + + /** + * 基建单位 + * @param list + */ + void insertJJAQunit(@Param("list")List list); /** * 新增布控球 * @param list */ - void insertJjBall(List list); + void insertJjBall(@Param("list")List list); /** * 基建标段信息 * @param list */ - void insertJjBidInfo(List list); + void insertJjBidInfo(@Param("list")List list); /** *工程 履历 * @param list */ - void insertGcLlData(List list); + void insertGcLlData(@Param("list")List list); /* * 插入站班会数据 @@ -316,4 +322,6 @@ public interface InterMapper { * @param vo */ void insertTicketInfo(TicketInfo vo); + + ; } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java index 0cf6420..bad5f32 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java @@ -582,4 +582,12 @@ public class DataCenterService { } } + + public void insertJJAQunit(List list) { + try{ + mapper.insertJJAQunit(list); + }catch (Exception e){ + log.error(e.toString(),e); + } + } } diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java index 39594e6..65e836a 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java @@ -322,6 +322,39 @@ public class InterService { } } + /** + * 安全单位 + * @param pageNum + */ + public void getJJAQUnit(int pageNum) { + try { + JSONObject obj= DataUtils.getJsonObject(pageNum); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.AQ_UNIT); + Map map = DataUtils.getArray(httpResponse); + Object objata=map.get("array"); + if (objata != null) { + JSONArray array = (JSONArray) map.get("array"); + List list = JSONArray.parseArray(array.toJSONString(), JjAqUnit.class); + if(list==null || list.isEmpty()){ + XxlJobHelper.log("无数据-->"); + return; + } + list.forEach(vo->{ + vo.setLegalReprMobile(Sm4Utils.decode(vo.getLegalReprMobile())); + }); + service.insertJJAQunit(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + if (FY_BOOLEAN){ + getJJAQUnit(pageNum); + } + } + } + } catch (Exception e) { + XxlJobHelper.log("数据处理异常内容--->{}",e.toString()); + } + } + /** * 布控球 */ diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterTwoService.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterTwoService.java index 458eaa7..74449f7 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterTwoService.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterTwoService.java @@ -324,6 +324,34 @@ public class InterTwoService { XxlJobHelper.handleFail(e.toString()); } } + @Async + public void getJJAQUnit(int pageNum) { + try { + JSONObject obj= DataUtils.getJsonObject2(pageNum); + HttpResponse httpResponse = PostUtils.sendData(obj.toString(), GlobalConfig.AQ_UNIT); + Map map = DataUtils.getArray(httpResponse); + JSONArray array = (JSONArray) map.get("array"); + if (array != null) { + List list = JSONArray.parseArray(array.toJSONString(), JjAqUnit.class); + if(list==null || list.isEmpty()){ + XxlJobHelper.log("无数据-->"); + return; + } + list.forEach(vo->{ + vo.setLegalReprMobile(Sm4Utils.decode(vo.getLegalReprMobile())); + }); + service.insertJJAQunit(list); + pageNum++; + if (pageNum <= (Integer) map.get("TOTAL_PAGE")) { + if (FY_BOOLEAN){ + getJJAQUnit(pageNum); + } + } + } + } catch (Exception e) { + XxlJobHelper.handleFail(e.toString()); + } + } /** * 布控球 diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java index 79eda87..ed7d2d5 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java @@ -117,6 +117,16 @@ public class DataCenterXxlJob { interService.getJJUser(1); twtoService.getJJUser(1); } + + /** + * 安全单位 + */ + @XxlJob("getJJAQUnit") + @PostConstruct + public void getJJAQUnit(){ + interService.getJJAQUnit(1); + twtoService.getJJAQUnit(1); + } /** * 布控球 */ diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml index 88313ba..855ef90 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml @@ -232,6 +232,28 @@ #{item.plannedStartDate},#{item.deleteFlag} ) + + + replace into jj_aq_unit( + id,isc_unit_id,safety_sgc_unit_id,unit_name, + unit_abbr_name,unit_code,main_code,unified_social_credit_id,legal_repr, + legal_repr_mobile,contact_phone,unit_type,unit_nature, + sys_type,sys_categ,unit_sign,establishment_date, + register_capital,website,province, city,county,address,main_business, + data_source, huv_flag,province_code, build_unit_code, creater_id, create_time, + updater_id, update_time, delete_flag, legal_id_card,business_file_id + ) values + ( + #{item.id},#{item.iscUnitId},#{item.safetySgcUnitId},#{item.unitName}, + #{item.unitAbbrName},#{item.unitCode},#{item.mainCode},#{item.unifiedSocialCreditId},#{item.legalRepr}, + #{item.legalReprMobile},#{item.contactPhone},#{item.unitType},#{item.unitNature}, + #{item.sysType},#{item.sysCateg},#{item.unitSign},#{item.establishmentDate}, + #{item.registerCapital},#{item.website},#{item.province},#{item.city},#{item.county},#{item.address},#{item.mainBusiness}, + #{item.dataSource},#{item.huvFlag},#{item.provinceCode},#{item.buildUnitCode},#{item.createrId},#{item.createTime}, + #{item.updaterId},#{item.updateTime},#{item.deleteFlag},#{item.legalIdCard},#{item.businessFileId} + ) + + replace into jj_user( id,nation,birth_place,unit_id,