Commit 452bf7c5 authored by wujiang's avatar wujiang

修改许可同步接口

parent 48a01860
package com.yeejoin.amos.api.openapi.face.service; package com.yeejoin.amos.api.openapi.face.service;
import java.text.SimpleDateFormat;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.typroject.tyboot.core.foundation.utils.ValidationUtil; import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
...@@ -14,6 +16,7 @@ import org.typroject.tyboot.core.restful.exception.instance.BadRequest; ...@@ -14,6 +16,7 @@ import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.csoft.sdk.client.CsoftDefaultSdkClient; import com.csoft.sdk.client.CsoftDefaultSdkClient;
import com.csoft.sdk.domain.App; import com.csoft.sdk.domain.App;
import com.csoft.sdk.domain.CsoftDataTzsbJbxxListParam; import com.csoft.sdk.domain.CsoftDataTzsbJbxxListParam;
...@@ -21,6 +24,7 @@ import com.csoft.sdk.domain.request.CsoftDataTzsbJbxxListRequest; ...@@ -21,6 +24,7 @@ import com.csoft.sdk.domain.request.CsoftDataTzsbJbxxListRequest;
import com.csoft.sdk.domain.response.CsoftDataTzsbJbxxListResponse; import com.csoft.sdk.domain.response.CsoftDataTzsbJbxxListResponse;
import com.yeejoin.amos.api.openapi.face.model.TaLicenseBaseInfoModel; import com.yeejoin.amos.api.openapi.face.model.TaLicenseBaseInfoModel;
import com.yeejoin.amos.api.openapi.face.orm.dao.TaLicenseBaseInfoMapper; import com.yeejoin.amos.api.openapi.face.orm.dao.TaLicenseBaseInfoMapper;
import com.yeejoin.amos.api.openapi.face.orm.entity.TaAccessConfig;
import com.yeejoin.amos.api.openapi.face.orm.entity.TaLicenseBaseInfo; import com.yeejoin.amos.api.openapi.face.orm.entity.TaLicenseBaseInfo;
/** /**
...@@ -32,6 +36,10 @@ import com.yeejoin.amos.api.openapi.face.orm.entity.TaLicenseBaseInfo; ...@@ -32,6 +36,10 @@ import com.yeejoin.amos.api.openapi.face.orm.entity.TaLicenseBaseInfo;
@Service @Service
public class TaLicenseBaseInfoServiceImpl public class TaLicenseBaseInfoServiceImpl
extends BaseService<TaLicenseBaseInfoModel, TaLicenseBaseInfo, TaLicenseBaseInfoMapper> { extends BaseService<TaLicenseBaseInfoModel, TaLicenseBaseInfo, TaLicenseBaseInfoMapper> {
@Autowired
TaAccessConfigServiceImpl taAccessConfigServiceImpl;
/** /**
* *
* 新增许可信息-许可基本信息表 * 新增许可信息-许可基本信息表
...@@ -61,18 +69,31 @@ public class TaLicenseBaseInfoServiceImpl ...@@ -61,18 +69,31 @@ public class TaLicenseBaseInfoServiceImpl
String appSecret = map.get("appSecret"); String appSecret = map.get("appSecret");
String server = map.get("server"); String server = map.get("server");
String startTime = map.get("startTime"); String startTime = map.get("startTime");
String endTime = map.get("endTime"); int isAll = Integer.valueOf(map.get("isAllBase"));
// String endTime = map.get("endTime");
App app = App.of(appId, appKey, appSecret, server); App app = App.of(appId, appKey, appSecret, server);
int current = 1; int current = 1;
int size = Integer.valueOf(map.get("pageSize")); int size = Integer.valueOf(map.get("pageSize"));
// 2.初始化请求客户端 // 2.初始化请求客户端
CsoftDefaultSdkClient client = CsoftDefaultSdkClient.of(app); CsoftDefaultSdkClient client = CsoftDefaultSdkClient.of(app);
// 3.设置参数,发送请求,并处理结果 // 3.设置参数,发送请求,并处理结果
CsoftDataTzsbJbxxListParam csoftDataTzsbJbxxListParam = new CsoftDataTzsbJbxxListParam(); CsoftDataTzsbJbxxListParam csoftDataTzsbJbxxListParam = new CsoftDataTzsbJbxxListParam();
csoftDataTzsbJbxxListParam.setStaTime(startTime); if (isAll == 0) {
// 开始日期 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
csoftDataTzsbJbxxListParam.setEndTime(endTime); // 开始日期
// 结束日期 csoftDataTzsbJbxxListParam.setStaTime(startTime);
// 结束日期
csoftDataTzsbJbxxListParam.setEndTime(sdf.format(new Date()));
} else {
SimpleDateFormat sdfsta = new SimpleDateFormat("yyyy-MM-dd 00:00:00");
SimpleDateFormat sdfend = new SimpleDateFormat("yyyy-MM-dd 23:59:59");
// 开始日期
csoftDataTzsbJbxxListParam.setStaTime(sdfsta.format(new Date()));
// 结束日期
csoftDataTzsbJbxxListParam.setEndTime(sdfend.format(new Date()));
}
csoftDataTzsbJbxxListParam.setPageSize(size); // 每 页记录数 csoftDataTzsbJbxxListParam.setPageSize(size); // 每 页记录数
csoftDataTzsbJbxxListParam.setCurrentPage(current); // 当前页码 csoftDataTzsbJbxxListParam.setCurrentPage(current); // 当前页码
CsoftDataTzsbJbxxListRequest request = new CsoftDataTzsbJbxxListRequest(csoftDataTzsbJbxxListParam); CsoftDataTzsbJbxxListRequest request = new CsoftDataTzsbJbxxListRequest(csoftDataTzsbJbxxListParam);
...@@ -103,6 +124,12 @@ public class TaLicenseBaseInfoServiceImpl ...@@ -103,6 +124,12 @@ public class TaLicenseBaseInfoServiceImpl
csoftDataTzsbJbxxListParam.setCurrentPage(++current); csoftDataTzsbJbxxListParam.setCurrentPage(++current);
saveData(client, csoftDataTzsbJbxxListParam); saveData(client, csoftDataTzsbJbxxListParam);
} }
if (isAll == 0) {
taAccessConfigServiceImpl
.update(new LambdaUpdateWrapper<TaAccessConfig>().eq(TaAccessConfig::getBizType, "license")
.eq(TaAccessConfig::getBizKey, "isAllBase").set(TaAccessConfig::getBizValue, 1));
}
} else { } else {
System.out.println("失败:" + response.getErrorMsg()); System.out.println("失败:" + response.getErrorMsg());
System.out.println("失败:" + response.getErrorCode()); System.out.println("失败:" + response.getErrorCode());
......
package com.yeejoin.amos.api.openapi.face.service; package com.yeejoin.amos.api.openapi.face.service;
import java.text.SimpleDateFormat;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled; import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
...@@ -15,6 +17,7 @@ import org.typroject.tyboot.core.restful.exception.instance.BadRequest; ...@@ -15,6 +17,7 @@ import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.csoft.sdk.client.CsoftDefaultSdkClient; import com.csoft.sdk.client.CsoftDefaultSdkClient;
import com.csoft.sdk.domain.App; import com.csoft.sdk.domain.App;
import com.csoft.sdk.domain.CsoftDataTzsbXkxxListParam; import com.csoft.sdk.domain.CsoftDataTzsbXkxxListParam;
...@@ -22,6 +25,7 @@ import com.csoft.sdk.domain.request.CsoftDataTzsbXkxxListRequest; ...@@ -22,6 +25,7 @@ import com.csoft.sdk.domain.request.CsoftDataTzsbXkxxListRequest;
import com.csoft.sdk.domain.response.CsoftDataTzsbXkxxListResponse; import com.csoft.sdk.domain.response.CsoftDataTzsbXkxxListResponse;
import com.yeejoin.amos.api.openapi.face.model.TaLicenseDetailInfoModel; import com.yeejoin.amos.api.openapi.face.model.TaLicenseDetailInfoModel;
import com.yeejoin.amos.api.openapi.face.orm.dao.TaLicenseDetailInfoMapper; import com.yeejoin.amos.api.openapi.face.orm.dao.TaLicenseDetailInfoMapper;
import com.yeejoin.amos.api.openapi.face.orm.entity.TaAccessConfig;
import com.yeejoin.amos.api.openapi.face.orm.entity.TaLicenseDetailInfo; import com.yeejoin.amos.api.openapi.face.orm.entity.TaLicenseDetailInfo;
/** /**
...@@ -32,7 +36,8 @@ import com.yeejoin.amos.api.openapi.face.orm.entity.TaLicenseDetailInfo; ...@@ -32,7 +36,8 @@ import com.yeejoin.amos.api.openapi.face.orm.entity.TaLicenseDetailInfo;
*/ */
@Service @Service
public class TaLicenseDetailInfoServiceImpl extends BaseService<TaLicenseDetailInfoModel, TaLicenseDetailInfo, TaLicenseDetailInfoMapper> { public class TaLicenseDetailInfoServiceImpl extends BaseService<TaLicenseDetailInfoModel, TaLicenseDetailInfo, TaLicenseDetailInfoMapper> {
@Autowired
TaAccessConfigServiceImpl taAccessConfigServiceImpl;
/** /**
* *
* 新增许可信息-许可详细信息表 * 新增许可信息-许可详细信息表
...@@ -62,7 +67,8 @@ public class TaLicenseDetailInfoServiceImpl extends BaseService<TaLicenseDetailI ...@@ -62,7 +67,8 @@ public class TaLicenseDetailInfoServiceImpl extends BaseService<TaLicenseDetailI
String appSecret = map.get("appSecret"); String appSecret = map.get("appSecret");
String server = map.get("server"); String server = map.get("server");
String startTime = map.get("startTime"); String startTime = map.get("startTime");
String endTime = map.get("endTime"); //String endTime = map.get("endTime");
int isAll = Integer.valueOf(map.get("isAllDetail"));
App app = App.of(appId, appKey, appSecret, server); App app = App.of(appId, appKey, appSecret, server);
int current = 1; int current = 1;
int size = Integer.valueOf(map.get("pageSize")); int size = Integer.valueOf(map.get("pageSize"));
...@@ -70,10 +76,20 @@ public class TaLicenseDetailInfoServiceImpl extends BaseService<TaLicenseDetailI ...@@ -70,10 +76,20 @@ public class TaLicenseDetailInfoServiceImpl extends BaseService<TaLicenseDetailI
CsoftDefaultSdkClient client = CsoftDefaultSdkClient.of(app); CsoftDefaultSdkClient client = CsoftDefaultSdkClient.of(app);
// 3.设置参数,发送请求,并处理结果 // 3.设置参数,发送请求,并处理结果
CsoftDataTzsbXkxxListParam csoftDataTzsbXKxxListParam = new CsoftDataTzsbXkxxListParam(); CsoftDataTzsbXkxxListParam csoftDataTzsbXKxxListParam = new CsoftDataTzsbXkxxListParam();
csoftDataTzsbXKxxListParam.setStaTime(startTime); if (isAll == 0) {
// 开始日期 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
csoftDataTzsbXKxxListParam.setEndTime(endTime); // 开始日期
// 结束日期 csoftDataTzsbXKxxListParam.setStaTime(startTime);
// 结束日期
csoftDataTzsbXKxxListParam.setEndTime(sdf.format(new Date()));
} else {
SimpleDateFormat sdfsta = new SimpleDateFormat("yyyy-MM-dd 00:00:00");
SimpleDateFormat sdfend = new SimpleDateFormat("yyyy-MM-dd 23:59:59");
// 开始日期
csoftDataTzsbXKxxListParam.setStaTime(sdfsta.format(new Date()));
// 结束日期
csoftDataTzsbXKxxListParam.setEndTime(sdfend.format(new Date()));
}
csoftDataTzsbXKxxListParam.setPageSize(size); // 每 页记录数 csoftDataTzsbXKxxListParam.setPageSize(size); // 每 页记录数
csoftDataTzsbXKxxListParam.setCurrentPage(current); // 当前页码 csoftDataTzsbXKxxListParam.setCurrentPage(current); // 当前页码
CsoftDataTzsbXkxxListRequest request = new CsoftDataTzsbXkxxListRequest(csoftDataTzsbXKxxListParam); CsoftDataTzsbXkxxListRequest request = new CsoftDataTzsbXkxxListRequest(csoftDataTzsbXKxxListParam);
...@@ -104,6 +120,12 @@ public class TaLicenseDetailInfoServiceImpl extends BaseService<TaLicenseDetailI ...@@ -104,6 +120,12 @@ public class TaLicenseDetailInfoServiceImpl extends BaseService<TaLicenseDetailI
csoftDataTzsbXKxxListParam.setCurrentPage(++current); csoftDataTzsbXKxxListParam.setCurrentPage(++current);
saveData(client, csoftDataTzsbXKxxListParam); saveData(client, csoftDataTzsbXKxxListParam);
} }
if (isAll == 0) {
taAccessConfigServiceImpl
.update(new LambdaUpdateWrapper<TaAccessConfig>().eq(TaAccessConfig::getBizType, "license")
.eq(TaAccessConfig::getBizKey, "isAllDetail").set(TaAccessConfig::getBizValue, 1));
}
} else { } else {
System.out.println("失败:" + response.getErrorMsg()); System.out.println("失败:" + response.getErrorMsg());
System.out.println("失败:" + response.getErrorCode()); System.out.println("失败:" + response.getErrorCode());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment