bonus
/
jjsp-xxl-job
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增安全单位接口

This commit is contained in:
haozq 2025-11-05 17:04:11 +08:00
parent 036139fc29
commit c75d665f5c
9 changed files with 182 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GenEntity.java
View File

@ -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));
}

8
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/config/GlobalConfig.java
View File

@ -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";
/**
* 基建布控球
*/

50
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjAqUnit.java Normal file
View File

@ -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
}

32
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java
View File

@ -23,65 +23,71 @@ public interface InterMapper {
* 处理标段工程
* @param list
*/
void insertBidPro(List<BidProject> list);
void insertBidPro(@Param("list")List<BidProject> list);
/**
* 处理标段工程
* @param list
*/
void insertBidProNew(List<JjBiddingProject> list);
void insertBidProNew(@Param("list")List<JjBiddingProject> list);
/**
* 插入 班组team
* @param list
*/
void insertTeam(List<JjTeam> list);
void insertTeam(@Param("list")List<JjTeam> list);
void insertTeamPeople(List<JjTeamPeople> list);
void insertTeamPeople(@Param("list")List<JjTeamPeople> list);
/**
* 作业票信息
* @param list
*/
void insertTicket(List<JjTicket> list);
void insertTicket(@Param("list")List<JjTicket> list);
/**
* 新增作业票信息
* @param list
*/
void insertTicketPeople(List<JjTicketPeople> list);
void insertTicketPeople(@Param("list")List<JjTicketPeople> list);
/**
* 新增周计划
*/
void insertWeeksPlanData(List<JjWeeksPlan> list);
void insertWeeksPlanData(@Param("list")List<JjWeeksPlan> list);
/**
* 新增日计划
* @param list
*/
void insertDayPlanData(List<JjDayPlan> list);
void insertDayPlanData(@Param("list")List<JjDayPlan> list);
/**
* 基建人员信息
* @param list
*/
void insertJJUser(List<JjUser> list);
void insertJJUser(@Param("list")List<JjUser> list);
/**
* 基建单位
* @param list
*/
void insertJJAQunit(@Param("list")List<JjAqUnit> list);
/**
* 新增布控球
* @param list
*/
void insertJjBall(List<JjBall> list);
void insertJjBall(@Param("list")List<JjBall> list);
/**
* 基建标段信息
* @param list
*/
void insertJjBidInfo(List<JjBidInfo> list);
void insertJjBidInfo(@Param("list")List<JjBidInfo> list);
/**
*工程 履历
* @param list
*/
void insertGcLlData(List<JjPrjEnginneringExperience> list);
void insertGcLlData(@Param("list")List<JjPrjEnginneringExperience> list);
/*
* 插入站班会数据
@ -316,4 +322,6 @@ public interface InterMapper {
* @param vo
*/
void insertTicketInfo(TicketInfo vo);
;
}

8
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DataCenterService.java
View File

@ -582,4 +582,12 @@ public class DataCenterService {
}
}
public void insertJJAQunit(List<JjAqUnit> list) {
try{
mapper.insertJJAQunit(list);
}catch (Exception e){
log.error(e.toString(),e);
}
}
}

33
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java
View File

@ -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<String, Object> map = DataUtils.getArray(httpResponse);
Object objata=map.get("array");
if (objata != null) {
JSONArray array = (JSONArray) map.get("array");
List<JjAqUnit> 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());
}
}
/**
* 布控球
*/

28
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterTwoService.java
View File

@ -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<String, Object> map = DataUtils.getArray(httpResponse);
JSONArray array = (JSONArray) map.get("array");
if (array != null) {
List<JjAqUnit> 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());
}
}
/**
* 布控球

10
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java
View File

@ -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);
}
/**
* 布控球
*/

22
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/InterMapper.xml
View File

@ -232,6 +232,28 @@
#{item.plannedStartDate},#{item.deleteFlag}
)</foreach>
</insert>
<insert id="insertJJAQunit">
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
<foreach collection="list" item="item" separator=",">(
#{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}
)</foreach>
</insert>
<insert id="insertJJUser">
replace into jj_user(
id,nation,birth_place,unit_id,