package com.integrated.zyyt.enetity.business;
|
|
import cn.hutool.cache.CacheUtil;
|
import cn.hutool.cache.impl.TimedCache;
|
import cn.hutool.core.date.DateUnit;
|
import com.alibaba.fastjson.JSONObject;
|
import com.integrated.zyyt.enetity.TokenResult;
|
import com.integrated.zyyt.enetity.ZyytDataResult;
|
import com.integrated.zyyt.util.GetBeanUtil;
|
import com.integrated.zyyt.util.IdGenerator;
|
import com.integrated.zyyt.util.ZyytUtil;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
import java.lang.reflect.ParameterizedType;
|
import java.util.List;
|
import java.util.Map;
|
|
public class Zyyt<T> {
|
|
private JdbcTemplate jdbcTemplate = GetBeanUtil.getBean(JdbcTemplate.class);
|
// private RedisService redisService = GetBeanUtil.getBean(RedisService.class);
|
// private JdbcTemplate jdbcTemplate = null;
|
// 替代redis
|
private TimedCache<String, String> timedCache = CacheUtil.newTimedCache(DateUnit.MINUTE.getMillis() * 5);
|
|
|
// 用于认证
|
private String authonUrl;
|
private String dataUrl;
|
private boolean eciphrtext;
|
private String client;
|
private String secret;
|
|
// 获取到的权限
|
// private String bearToken;
|
|
// 用于获取数据
|
private String sourceSysKey;
|
// 请求参数
|
private JSONObject params;
|
// 返回对象
|
private List<T> queryData;
|
|
|
private String getToken() {
|
Class listType = this.getListType();
|
String typeName = listType.getName();
|
String businessName = typeName.substring(typeName.lastIndexOf(".") + 1);
|
String redisKey = "zyytBear_" + businessName + "_";
|
|
String bearStr = timedCache.get(redisKey);
|
if (bearStr == null) {
|
TokenResult tokenResult = ZyytUtil.getAuth(authonUrl, eciphrtext, client, secret,sourceSysKey);
|
if (tokenResult == null) {
|
return null;
|
}
|
bearStr = tokenResult.getToken();
|
timedCache.put(redisKey, bearStr, DateUnit.MINUTE.getMillis() * 5);
|
}
|
return bearStr;
|
}
|
|
/**
|
* 获取List内的泛型
|
* <p>
|
* // * @param listFiledName
|
*
|
* @return
|
*/
|
private Class getListType() {
|
ParameterizedType ptClass = (ParameterizedType) this.getClass().getGenericSuperclass();
|
Class clazz = (Class) ptClass.getActualTypeArguments()[0];
|
return clazz;
|
}
|
|
|
public ZyytDataResult<T> getData(int pageNum, int pageSize) {
|
String bearToken = this.getToken();
|
Class listType = getListType();
|
return ZyytUtil.getData(dataUrl, bearToken, sourceSysKey, params, pageNum, pageSize, listType);
|
|
}
|
|
/**
|
* 插入记录表 返回记录Id
|
*
|
* @param tableName
|
* @param batchNo
|
* @return
|
*/
|
public Long insertRecord(String tableName, String batchNo) {
|
Long id = IdGenerator.getId();
|
String insertSql = "INSERT INTO ZYYT_RECORD (id, BATCH_NO, COUNT_NUM, IS_FINISH, IS_ERROR, START_TIME, END_TIME, TABLE_NAME) " +
|
"VALUES (" + id + ", '" + batchNo + "', '0', '0', '0', SYSDATE, null, '" + tableName + "')";
|
jdbcTemplate.update(insertSql);
|
return id;
|
}
|
|
/**
|
* 更改记录表
|
*
|
* @param id
|
* @param isError
|
* @param countNum
|
* @return
|
*/
|
public int updateRecord(Long id, int isError, Long countNum, String errMsg) {
|
String updateSql = "update ZYYT_RECORD set IS_FINISH=1, IS_ERROR = " + isError + ",COUNT_NUM=" + countNum + ",END_TIME=SYSDATE,err_msg='" + errMsg + "' where id = " + id;
|
return jdbcTemplate.update(updateSql);
|
}
|
|
public Zyyt(String authonUrl,String dataUrl, boolean eciphrtext, String client, String secret, String sourceSysKey, JSONObject params) {
|
this.authonUrl = authonUrl;
|
this.dataUrl = dataUrl;
|
this.eciphrtext = eciphrtext;
|
this.client = client;
|
this.secret = secret;
|
this.sourceSysKey = sourceSysKey;
|
this.params = params;
|
}
|
|
public String getAuthonUrl() {
|
return authonUrl;
|
}
|
|
public void setAuthonUrl(String authonUrl) {
|
this.authonUrl = authonUrl;
|
}
|
|
public String getDataUrl() {
|
return dataUrl;
|
}
|
|
public void setDataUrl(String dataUrl) {
|
this.dataUrl = dataUrl;
|
}
|
|
public boolean isEciphrtext() {
|
return eciphrtext;
|
}
|
|
public void setEciphrtext(boolean eciphrtext) {
|
this.eciphrtext = eciphrtext;
|
}
|
|
public String getClient() {
|
return client;
|
}
|
|
public void setClient(String client) {
|
this.client = client;
|
}
|
|
public String getSecret() {
|
return secret;
|
}
|
|
public void setSecret(String secret) {
|
this.secret = secret;
|
}
|
|
public String getSourceSysKey() {
|
return sourceSysKey;
|
}
|
|
public void setSourceSysKey(String sourceSysKey) {
|
this.sourceSysKey = sourceSysKey;
|
}
|
|
public Map getParams() {
|
return params;
|
}
|
|
public void setParams(JSONObject params) {
|
this.params = params;
|
}
|
|
public List<T> getQueryData() {
|
return queryData;
|
}
|
|
public void setQueryData(List<T> queryData) {
|
this.queryData = queryData;
|
}
|
|
}
|
