12 changed files with 566 additions and 17 deletions
@ -0,0 +1,134 @@ |
|||
package com.hxjt.dataupload.jobhandler.doubleprevent; |
|||
|
|||
import com.alibaba.fastjson.JSONObject; |
|||
import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdx; |
|||
import com.hxjt.dataupload.model.entity.doubleprevent.Fxgkcs; |
|||
import com.hxjt.dataupload.model.entity.doubleprevent.Yhpcjh; |
|||
import com.hxjt.dataupload.service.FxfxdxService; |
|||
import com.hxjt.dataupload.utils.HttpUtils; |
|||
import com.xxl.job.core.context.XxlJobHelper; |
|||
import com.xxl.job.core.handler.annotation.XxlJob; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import org.apache.http.protocol.HTTP; |
|||
import org.slf4j.Logger; |
|||
import org.slf4j.LoggerFactory; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import java.io.IOException; |
|||
import java.util.ArrayList; |
|||
|
|||
|
|||
@Component |
|||
public class YhpcjhJobHandler { |
|||
|
|||
private Logger log = LoggerFactory.getLogger(YhpcjhJobHandler.class); |
|||
|
|||
@Autowired |
|||
FxfxdxService fxfxdxService; |
|||
|
|||
@XxlJob(value = "YhpcjhJobHandler", init = "init", destroy = "destroy") |
|||
public void execute(String param) { |
|||
String jobParam = XxlJobHelper.getJobParam(); |
|||
ArrayList<Yhpcjh> fxgkcs = new ArrayList<>(); |
|||
if (jobParam.equals("全量")) { |
|||
fxgkcs = fxfxdxService.getYhpcjhs("N"); |
|||
}else if(jobParam.equals("每日")){ |
|||
fxgkcs = fxfxdxService.getYhpcjhs("Y"); |
|||
} |
|||
|
|||
ArrayList<Fxfxdx> zdwxys = fxfxdxService.getZdwxys(); |
|||
for (int i = 0; i < fxgkcs.size(); i++) { |
|||
String HAZARD_NAME = fxgkcs.get(i).getFengxianfenxiduixian(); |
|||
for (int j = 0; j < zdwxys.size(); j++) { |
|||
String DANGESOURCE_NAME = zdwxys.get(j).getZhongdaweixianyuanmi(); |
|||
switch (HAZARD_NAME) { |
|||
case "重大危险源甲醇中间储存": |
|||
if (DANGESOURCE_NAME.equals("甲醇中间储存单元")) { |
|||
fxgkcs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME); |
|||
fxgkcs.get(i).setZhongdaweixianyuande(zdwxys.get(j).getZhongdaweixianyuande()); |
|||
} |
|||
break; |
|||
case "重大危险源化产油库": |
|||
if (DANGESOURCE_NAME.equals("化产油库区")) { |
|||
fxgkcs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME); |
|||
fxgkcs.get(i).setZhongdaweixianyuande(zdwxys.get(j).getZhongdaweixianyuande()); |
|||
} |
|||
break; |
|||
case "重大危险源甲醇储罐": |
|||
if (DANGESOURCE_NAME.equals("甲醇储存单元")) { |
|||
fxgkcs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME); |
|||
fxgkcs.get(i).setZhongdaweixianyuande(zdwxys.get(j).getZhongdaweixianyuande()); |
|||
} |
|||
break; |
|||
case "重大危险源空分站": |
|||
if (DANGESOURCE_NAME.equals("空分站单元")) { |
|||
fxgkcs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME); |
|||
fxgkcs.get(i).setZhongdaweixianyuande(zdwxys.get(j).getZhongdaweixianyuande()); |
|||
} |
|||
break; |
|||
case "重大危险源气柜储存": |
|||
if (DANGESOURCE_NAME.equals("气柜")) { |
|||
fxgkcs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME); |
|||
fxgkcs.get(i).setZhongdaweixianyuande(zdwxys.get(j).getZhongdaweixianyuande()); |
|||
} |
|||
break; |
|||
case "重大危险源粗苯蒸馏": |
|||
if (DANGESOURCE_NAME.equals("粗苯蒸馏单元")) { |
|||
fxgkcs.get(i).setZhongdaweixianyuanmi(DANGESOURCE_NAME); |
|||
fxgkcs.get(i).setZhongdaweixianyuande(zdwxys.get(j).getZhongdaweixianyuande()); |
|||
} |
|||
break; |
|||
} |
|||
} |
|||
if((!StringUtils.isBlank(fxgkcs.get(i).getZhongdaweixianyuande()))&&fxgkcs.get(i).getZhongdaweixianyuande().length()>2){ |
|||
fxgkcs.get(i).setZhongdaweixianyuande(fxgkcs.get(i).getZhongdaweixianyuande().substring(0,2)); |
|||
} |
|||
|
|||
//System.out.println(fxfxdxs.get(i).toString());
|
|||
} |
|||
|
|||
|
|||
int success = 0; |
|||
int fail = 0; |
|||
for (int i = 0; i < fxgkcs.size(); i++) { |
|||
System.out.print(i + 1+","); |
|||
String company = fxgkcs.get(i).getQiyemingcheng(); |
|||
String url = "https://www.ny-fxfk.com/space-ningyanghuagongchany/sapi/qpaas/tiga/dys/keyAuthentication/yinhuanpaicharenwuqi/v1/yinhuanpaicharenwuqi"; |
|||
switch (company) { |
|||
case "山东恒信高科能源有限公司": |
|||
case "恒信中碳氢能源科技（山东）有限公司": |
|||
JSONObject jsonObject = (JSONObject) JSONObject.toJSON(fxgkcs.get(i)); |
|||
String post = null; |
|||
try { |
|||
post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "5JzJFKkwF5aHJ0GQUz3Y3D76035B58D84048"); |
|||
success++; |
|||
//System.out.println("post:"+post.toString());
|
|||
//XxlJobHelper.log("执行日志:" + company + post.toString());
|
|||
} catch (IOException e) { |
|||
fail++; |
|||
e.printStackTrace(); |
|||
XxlJobHelper.handleFail("任务执行失败" + e.getMessage()); |
|||
} |
|||
break; |
|||
} |
|||
} |
|||
if(fxgkcs.size()>0){ |
|||
XxlJobHelper.log("执行日志:本次有"+fxgkcs.size()+"条需要上传,成功上传"+success+"条,失败"+fail+"条"); |
|||
}else{ |
|||
XxlJobHelper.log("执行日志:本次无新数据需上传"); |
|||
} |
|||
|
|||
|
|||
} |
|||
|
|||
|
|||
private void init() { |
|||
log.info("init 方法调用成功"); |
|||
} |
|||
|
|||
private void destroy() { |
|||
log.info("destroy 方法调用成功"); |
|||
} |
|||
|
|||
} |
|||
@ -0,0 +1,277 @@ |
|||
package com.hxjt.dataupload.model.entity.doubleprevent; |
|||
|
|||
import org.springframework.stereotype.Repository; |
|||
|
|||
@Repository |
|||
public class Yhpcjh { |
|||
private String qiyemingcheng; |
|||
private String qiyebianma; |
|||
private String weixianhuaxuepindeng; |
|||
private String fengxianfenxiduixian; |
|||
private String anquanfengxianfenxid; |
|||
//--缺失字段 重大危险源名称
|
|||
private String zhongdaweixianyuanmi; |
|||
//--缺失字段 重大危险源等级
|
|||
private String zhongdaweixianyuande; |
|||
private String fengxianfenxidanyuan1; |
|||
private String fengxianfenxidanyuan; |
|||
private String fengxianshijianmingc; |
|||
private String fengxianshijianbianh; |
|||
private String duiyingguankongcuosh; |
|||
private String guankongcuoshiid; |
|||
private String yinhuanpaichaneirong; |
|||
private String yinhuanpaicharenwuid; |
|||
private String yinhuanpaichazhouqi; |
|||
private String danwei; |
|||
private String xunjianyouxiaokaishi; |
|||
private String xunjianyouxiaojieshu; |
|||
private String gongzuorileixing; |
|||
private String renwuleixing; |
|||
//--缺失字段 包保责任人对应 任务项
|
|||
private String baobaorenwuduiyingxi; |
|||
//--缺失字段 首次排查时间
|
|||
private String baobaozerenrenduiyin; |
|||
private String chushipaicharenwukai; |
|||
private String jiluren; |
|||
private String jilushijian; |
|||
|
|||
public String getQiyemingcheng() { |
|||
return qiyemingcheng; |
|||
} |
|||
|
|||
public void setQiyemingcheng(String qiyemingcheng) { |
|||
this.qiyemingcheng = qiyemingcheng; |
|||
} |
|||
|
|||
public String getQiyebianma() { |
|||
return qiyebianma; |
|||
} |
|||
|
|||
public void setQiyebianma(String qiyebianma) { |
|||
this.qiyebianma = qiyebianma; |
|||
} |
|||
|
|||
public String getWeixianhuaxuepindeng() { |
|||
return weixianhuaxuepindeng; |
|||
} |
|||
|
|||
public void setWeixianhuaxuepindeng(String weixianhuaxuepindeng) { |
|||
this.weixianhuaxuepindeng = weixianhuaxuepindeng; |
|||
} |
|||
|
|||
public String getFengxianfenxiduixian() { |
|||
return fengxianfenxiduixian; |
|||
} |
|||
|
|||
public void setFengxianfenxiduixian(String fengxianfenxiduixian) { |
|||
this.fengxianfenxiduixian = fengxianfenxiduixian; |
|||
} |
|||
|
|||
public String getAnquanfengxianfenxid() { |
|||
return anquanfengxianfenxid; |
|||
} |
|||
|
|||
public void setAnquanfengxianfenxid(String anquanfengxianfenxid) { |
|||
this.anquanfengxianfenxid = anquanfengxianfenxid; |
|||
} |
|||
|
|||
public String getZhongdaweixianyuanmi() { |
|||
return zhongdaweixianyuanmi; |
|||
} |
|||
|
|||
public void setZhongdaweixianyuanmi(String zhongdaweixianyuanmi) { |
|||
this.zhongdaweixianyuanmi = zhongdaweixianyuanmi; |
|||
} |
|||
|
|||
public String getZhongdaweixianyuande() { |
|||
return zhongdaweixianyuande; |
|||
} |
|||
|
|||
public void setZhongdaweixianyuande(String zhongdaweixianyuande) { |
|||
this.zhongdaweixianyuande = zhongdaweixianyuande; |
|||
} |
|||
|
|||
public String getFengxianfenxidanyuan1() { |
|||
return fengxianfenxidanyuan1; |
|||
} |
|||
|
|||
public void setFengxianfenxidanyuan1(String fengxianfenxidanyuan1) { |
|||
this.fengxianfenxidanyuan1 = fengxianfenxidanyuan1; |
|||
} |
|||
|
|||
public String getFengxianfenxidanyuan() { |
|||
return fengxianfenxidanyuan; |
|||
} |
|||
|
|||
public void setFengxianfenxidanyuan(String fengxianfenxidanyuan) { |
|||
this.fengxianfenxidanyuan = fengxianfenxidanyuan; |
|||
} |
|||
|
|||
public String getFengxianshijianmingc() { |
|||
return fengxianshijianmingc; |
|||
} |
|||
|
|||
public void setFengxianshijianmingc(String fengxianshijianmingc) { |
|||
this.fengxianshijianmingc = fengxianshijianmingc; |
|||
} |
|||
|
|||
public String getFengxianshijianbianh() { |
|||
return fengxianshijianbianh; |
|||
} |
|||
|
|||
public void setFengxianshijianbianh(String fengxianshijianbianh) { |
|||
this.fengxianshijianbianh = fengxianshijianbianh; |
|||
} |
|||
|
|||
public String getDuiyingguankongcuosh() { |
|||
return duiyingguankongcuosh; |
|||
} |
|||
|
|||
public void setDuiyingguankongcuosh(String duiyingguankongcuosh) { |
|||
this.duiyingguankongcuosh = duiyingguankongcuosh; |
|||
} |
|||
|
|||
public String getGuankongcuoshiid() { |
|||
return guankongcuoshiid; |
|||
} |
|||
|
|||
public void setGuankongcuoshiid(String guankongcuoshiid) { |
|||
this.guankongcuoshiid = guankongcuoshiid; |
|||
} |
|||
|
|||
public String getYinhuanpaichaneirong() { |
|||
return yinhuanpaichaneirong; |
|||
} |
|||
|
|||
public void setYinhuanpaichaneirong(String yinhuanpaichaneirong) { |
|||
this.yinhuanpaichaneirong = yinhuanpaichaneirong; |
|||
} |
|||
|
|||
public String getYinhuanpaicharenwuid() { |
|||
return yinhuanpaicharenwuid; |
|||
} |
|||
|
|||
public void setYinhuanpaicharenwuid(String yinhuanpaicharenwuid) { |
|||
this.yinhuanpaicharenwuid = yinhuanpaicharenwuid; |
|||
} |
|||
|
|||
public String getYinhuanpaichazhouqi() { |
|||
return yinhuanpaichazhouqi; |
|||
} |
|||
|
|||
public void setYinhuanpaichazhouqi(String yinhuanpaichazhouqi) { |
|||
this.yinhuanpaichazhouqi = yinhuanpaichazhouqi; |
|||
} |
|||
|
|||
public String getDanwei() { |
|||
return danwei; |
|||
} |
|||
|
|||
public void setDanwei(String danwei) { |
|||
this.danwei = danwei; |
|||
} |
|||
|
|||
public String getXunjianyouxiaokaishi() { |
|||
return xunjianyouxiaokaishi; |
|||
} |
|||
|
|||
public void setXunjianyouxiaokaishi(String xunjianyouxiaokaishi) { |
|||
this.xunjianyouxiaokaishi = xunjianyouxiaokaishi; |
|||
} |
|||
|
|||
public String getXunjianyouxiaojieshu() { |
|||
return xunjianyouxiaojieshu; |
|||
} |
|||
|
|||
public void setXunjianyouxiaojieshu(String xunjianyouxiaojieshu) { |
|||
this.xunjianyouxiaojieshu = xunjianyouxiaojieshu; |
|||
} |
|||
|
|||
public String getGongzuorileixing() { |
|||
return gongzuorileixing; |
|||
} |
|||
|
|||
public void setGongzuorileixing(String gongzuorileixing) { |
|||
this.gongzuorileixing = gongzuorileixing; |
|||
} |
|||
|
|||
public String getRenwuleixing() { |
|||
return renwuleixing; |
|||
} |
|||
|
|||
public void setRenwuleixing(String renwuleixing) { |
|||
this.renwuleixing = renwuleixing; |
|||
} |
|||
|
|||
public String getBaobaorenwuduiyingxi() { |
|||
return baobaorenwuduiyingxi; |
|||
} |
|||
|
|||
public void setBaobaorenwuduiyingxi(String baobaorenwuduiyingxi) { |
|||
this.baobaorenwuduiyingxi = baobaorenwuduiyingxi; |
|||
} |
|||
|
|||
public String getBaobaozerenrenduiyin() { |
|||
return baobaozerenrenduiyin; |
|||
} |
|||
|
|||
public void setBaobaozerenrenduiyin(String baobaozerenrenduiyin) { |
|||
this.baobaozerenrenduiyin = baobaozerenrenduiyin; |
|||
} |
|||
|
|||
public String getChushipaicharenwukai() { |
|||
return chushipaicharenwukai; |
|||
} |
|||
|
|||
public void setChushipaicharenwukai(String chushipaicharenwukai) { |
|||
this.chushipaicharenwukai = chushipaicharenwukai; |
|||
} |
|||
|
|||
public String getJiluren() { |
|||
return jiluren; |
|||
} |
|||
|
|||
public void setJiluren(String jiluren) { |
|||
this.jiluren = jiluren; |
|||
} |
|||
|
|||
public String getJilushijian() { |
|||
return jilushijian; |
|||
} |
|||
|
|||
public void setJilushijian(String jilushijian) { |
|||
this.jilushijian = jilushijian; |
|||
} |
|||
|
|||
@Override |
|||
public String toString() { |
|||
return "Yhpcjh{" + |
|||
"qiyemingcheng='" + qiyemingcheng + '\'' + |
|||
", qiyebianma='" + qiyebianma + '\'' + |
|||
", weixianhuaxuepindeng='" + weixianhuaxuepindeng + '\'' + |
|||
", fengxianfenxiduixian='" + fengxianfenxiduixian + '\'' + |
|||
", anquanfengxianfenxid='" + anquanfengxianfenxid + '\'' + |
|||
", zhongdaweixianyuanmi='" + zhongdaweixianyuanmi + '\'' + |
|||
", zhongdaweixianyuande='" + zhongdaweixianyuande + '\'' + |
|||
", fengxianfenxidanyuan1='" + fengxianfenxidanyuan1 + '\'' + |
|||
", fengxianfenxidanyuan='" + fengxianfenxidanyuan + '\'' + |
|||
", fengxianshijianmingc='" + fengxianshijianmingc + '\'' + |
|||
", fengxianshijianbianh='" + fengxianshijianbianh + '\'' + |
|||
", duiyingguankongcuosh='" + duiyingguankongcuosh + '\'' + |
|||
", guankongcuoshiid='" + guankongcuoshiid + '\'' + |
|||
", yinhuanpaichaneirong='" + yinhuanpaichaneirong + '\'' + |
|||
", yinhuanpaicharenwuid='" + yinhuanpaicharenwuid + '\'' + |
|||
", yinhuanpaichazhouqi='" + yinhuanpaichazhouqi + '\'' + |
|||
", danwei='" + danwei + '\'' + |
|||
", xunjianyouxiaokaishi='" + xunjianyouxiaokaishi + '\'' + |
|||
", xunjianyouxiaojieshu='" + xunjianyouxiaojieshu + '\'' + |
|||
", gongzuorileixing='" + gongzuorileixing + '\'' + |
|||
", renwuleixing='" + renwuleixing + '\'' + |
|||
", baobaorenwuduiyingxi='" + baobaorenwuduiyingxi + '\'' + |
|||
", baobaozerenrenduiyin='" + baobaozerenrenduiyin + '\'' + |
|||
", chushipaicharenwukai='" + chushipaicharenwukai + '\'' + |
|||
", jiluren='" + jiluren + '\'' + |
|||
", jilushijian='" + jilushijian + '\'' + |
|||
'}'; |
|||
} |
|||
} |
|||
Loading…
Reference in new issue