|
|
@@ -8,6 +8,7 @@ import com.kingdee.bos.BOSException;
|
|
|
import com.kingdee.bos.Context;
|
|
|
import com.kingdee.bos.bsf.service.app.IHRMsfService;
|
|
|
import com.kingdee.bos.dao.IObjectPK;
|
|
|
+import com.kingdee.bos.dao.ormapping.ObjectUuidPK;
|
|
|
import com.kingdee.bos.rabbitmq.guava.Lists;
|
|
|
import com.kingdee.bos.util.BOSUuid;
|
|
|
import com.kingdee.eas.basedata.person.PersonInfo;
|
|
|
@@ -32,9 +33,10 @@ import java.time.*;
|
|
|
import java.time.format.DateTimeFormatter;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
+import java.util.concurrent.ScheduledThreadPoolExecutor;
|
|
|
+import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
/**
|
|
|
- *
|
|
|
* description: EsignFlowListOSFService <br>
|
|
|
* date: 4/1/2026 下午 4:23 <br>
|
|
|
* author: lhbj <br>
|
|
|
@@ -61,7 +63,7 @@ public class EsignFlowListOSFService implements IHRMsfService {
|
|
|
LocalTime time1 = LocalTime.now();
|
|
|
LocalTime localT1 = LocalTime.of(time1.getHour(), 0, 0);
|
|
|
LocalDateTime dateTime = LocalDateTime.of(localD1, localT1);
|
|
|
- dateTime=dateTime.minusHours(1);
|
|
|
+ dateTime = dateTime.minusHours(1);
|
|
|
return dateTime;
|
|
|
}
|
|
|
|
|
|
@@ -102,148 +104,341 @@ public class EsignFlowListOSFService implements IHRMsfService {
|
|
|
startDateTime = startDateTimeNow();
|
|
|
endDateTime = endDateTimeNow();
|
|
|
}
|
|
|
- int pageNum=0;
|
|
|
- int pageSize=100;
|
|
|
- long totalNum=1;
|
|
|
+ int pageNum = 0;
|
|
|
+ int pageSize = 100;
|
|
|
+ long totalNum = 1;
|
|
|
+ IESignGlobalStatusOverview overview = ESignGlobalStatusOverviewFactory.getLocalInstance(context);
|
|
|
+ Map<String, Object> jsonMap = Maps.newHashMap();
|
|
|
+ long signFlowStartTimeFrom = startDateTime.atZone(ZoneId.systemDefault())
|
|
|
+ .toInstant()
|
|
|
+ .toEpochMilli();
|
|
|
+ long signFlowStartTimeTo = endDateTime.atZone(ZoneId.systemDefault())
|
|
|
+ .toInstant()
|
|
|
+ .toEpochMilli();
|
|
|
+ jsonMap.put("signFlowStartTimeFrom", signFlowStartTimeFrom);
|
|
|
+ jsonMap.put("signFlowStartTimeTo", signFlowStartTimeTo);
|
|
|
+// List<String> list = Lists.newArrayList();
|
|
|
+// list.add("2");
|
|
|
+// jsonMap.put("signFlowStatus", list);
|
|
|
do {
|
|
|
pageNum++;
|
|
|
- Map<String, Object> jsonMap = Maps.newHashMap();
|
|
|
- long signFlowStartTimeFrom = startDateTime.atZone(ZoneId.systemDefault())
|
|
|
- .toInstant()
|
|
|
- .toEpochMilli();
|
|
|
- long signFlowStartTimeTo = endDateTime.atZone(ZoneId.systemDefault())
|
|
|
- .toInstant()
|
|
|
- .toEpochMilli();
|
|
|
- jsonMap.put("signFlowStartTimeFrom", signFlowStartTimeFrom);
|
|
|
- jsonMap.put("signFlowStartTimeTo", signFlowStartTimeTo);
|
|
|
jsonMap.put("pageNum", pageNum);
|
|
|
jsonMap.put("pageSize", pageSize);
|
|
|
- List<String> list = Lists.newArrayList();
|
|
|
- list.add("2");
|
|
|
- jsonMap.put("signFlowStatus", list);
|
|
|
try {
|
|
|
- IESignGlobalStatusOverview overview = ESignGlobalStatusOverviewFactory.getLocalInstance(context);
|
|
|
EsignHttpResponse response = EsignHttpUtil.sign_flow_list(context, jsonMap, "查询签署流程列表");
|
|
|
- JSONObject jsonObject = JSON.parseObject(response.getBody());
|
|
|
- int code =jsonObject.getInteger("code");
|
|
|
- if (0==code){
|
|
|
+ if (response.getStatus() >= 200 && response.getStatus() < 300) {
|
|
|
+ if (StringUtils.isBlank(response.getBody())) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ //System.out.println(response.getBody());
|
|
|
+ JSONObject jsonObject = JSON.parseObject(response.getBody());
|
|
|
+ int code = jsonObject.getInteger("code");
|
|
|
+ if (0 != code) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
JSONObject data = jsonObject.getJSONObject("data");
|
|
|
- if (null!=data){
|
|
|
- long total = data.getLong("total");
|
|
|
- if(total%pageSize==0){
|
|
|
- totalNum=total/pageSize;
|
|
|
- }else {
|
|
|
- totalNum=total/pageSize+1;
|
|
|
- }
|
|
|
- JSONArray signFlowInfos = data.getJSONArray("signFlowInfos");
|
|
|
- for (int i=0;i<signFlowInfos.size();i++){
|
|
|
- JSONObject signFlowInfo = signFlowInfos.getJSONObject(i);
|
|
|
- String signFlowId = signFlowInfo.getString("signFlowId");
|
|
|
- String sel = "select fid from CT_ESI_ESGSO where CFSignFlowId ='"+signFlowId+"'";
|
|
|
- IRowSet rowSet = DbUtil.executeQuery(context,sel);
|
|
|
- if(rowSet.size()<=0){
|
|
|
- ESignGlobalStatusOverviewInfo nowInfo = new ESignGlobalStatusOverviewInfo();
|
|
|
- nowInfo.setSignFlowId(signFlowId);
|
|
|
- nowInfo.setEsignStatus(EsignStatusEnum.COMPLETED);
|
|
|
- nowInfo.setEsignName(EsignConfigEnum.sign_flow_list);
|
|
|
- nowInfo.setRequestParams(response.getBody());
|
|
|
- nowInfo.setFiesign(true);
|
|
|
- nowInfo.setSendStatus(SendStatusEnum.SUCCESS);
|
|
|
- JSONArray signers = signFlowInfo.getJSONArray("signers");
|
|
|
- for(int x=0;x<signers.size();x++) {
|
|
|
- JSONObject signer = signers.getJSONObject(x);
|
|
|
- JSONObject psnSigner=signer.getJSONObject("psnSigner");
|
|
|
- if (null==psnSigner){
|
|
|
- continue;
|
|
|
- }
|
|
|
- JSONObject psnAccount=psnSigner.getJSONObject("psnAccount");
|
|
|
- String accountMobile = psnAccount.getString("accountMobile");
|
|
|
- String accountEmail = psnAccount.getString("accountEmail");
|
|
|
- if(StringUtils.isNotBlank(accountMobile)){
|
|
|
- String selp = "select fid from t_bd_person where FNCELL='"+accountMobile+"'";
|
|
|
- IRowSet rs = DbUtil.executeQuery(context,selp);
|
|
|
- if (rs.next()){
|
|
|
- String fid = rs.getString("fid");
|
|
|
- PersonInfo personInfo = new PersonInfo();
|
|
|
- personInfo.setId(BOSUuid.read(fid));
|
|
|
- nowInfo.setPerson(personInfo);
|
|
|
- }
|
|
|
- }else {
|
|
|
- String selp = "select fid from t_bd_person where FEMail='"+accountEmail+"'";
|
|
|
- IRowSet rs = DbUtil.executeQuery(context,selp);
|
|
|
- if (rs.next()){
|
|
|
- String fid = rs.getString("fid");
|
|
|
- PersonInfo personInfo = new PersonInfo();
|
|
|
- personInfo.setId(BOSUuid.read(fid));
|
|
|
- nowInfo.setPerson(personInfo);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- if(null!=nowInfo.getPerson()) {
|
|
|
- IObjectPK pk = overview.addnew(nowInfo);
|
|
|
- SyncSignedFilesUtil.syncAttachmentsForEmpPage(context,pk.toString());
|
|
|
- }
|
|
|
+ if (null == data) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ long total = data.getLong("total");
|
|
|
+ if (total % pageSize == 0) {
|
|
|
+ totalNum = total / pageSize;
|
|
|
+ } else {
|
|
|
+ totalNum = total / pageSize + 1;
|
|
|
+ }
|
|
|
+ JSONArray signFlowInfos = data.getJSONArray("signFlowInfos");
|
|
|
+ for (int i = 0; i < signFlowInfos.size(); i++) {
|
|
|
+ JSONObject signFlowInfo = signFlowInfos.getJSONObject(i);
|
|
|
+ String signFlowId = signFlowInfo.getString("signFlowId");
|
|
|
+ String signFlowTitle = signFlowInfo.getString("signFlowTitle");
|
|
|
+
|
|
|
+ String sel = "select fid from CT_ESI_ESGSO where CFSignFlowId ='" + signFlowId + "'";
|
|
|
+ IRowSet rowSet = DbUtil.executeQuery(context, sel);
|
|
|
+ if (rowSet.next()) {
|
|
|
+ String id = rowSet.getString("fid");
|
|
|
+ updateSignFlow(context, overview, signFlowId, id);
|
|
|
+ } else {
|
|
|
+ if (signFlowTitle.indexOf("人资") < 0 && signFlowTitle.indexOf("人力资源") < 0) {
|
|
|
+ continue;
|
|
|
}
|
|
|
+ addNewSignFlow(context, overview, signFlowInfo, signFlowId, signFlowTitle);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
} catch (EsignException | SQLException e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
- } while (pageNum<totalNum);
|
|
|
+ } while (pageNum < totalNum);
|
|
|
+
|
|
|
return "ok";
|
|
|
}
|
|
|
|
|
|
- public static void main(String[] args) {
|
|
|
- System.setProperty("EAS_HOME","D:\\project\\kingdeeV90\\Project_hty\\tengda");
|
|
|
- LocalDateTime startDateTime = null;
|
|
|
- LocalDateTime endDateTime = null;
|
|
|
- if (null == startDateTime || null == endDateTime) {
|
|
|
- startDateTime = formatter("2025-02-01");;
|
|
|
- endDateTime = endDateTimeNow();
|
|
|
+ private boolean updateSignFlow(Context context, IESignGlobalStatusOverview overview, String signFlowId, String id) throws BOSException, EASBizException, EsignException, SQLException {
|
|
|
+ ESignGlobalStatusOverviewInfo oldInfo = overview.getESignGlobalStatusOverviewInfo(new ObjectUuidPK(id));
|
|
|
+ EsignHttpResponse respsf = EsignHttpUtil.getSign_fields(context, signFlowId, "查询签署流程详情");
|
|
|
+ if (respsf.getStatus() < 200 || respsf.getStatus() >= 300) {
|
|
|
+ return true;
|
|
|
}
|
|
|
- int pageNum=0;
|
|
|
- int pageSize=20;
|
|
|
- long totalNum=1;
|
|
|
- do {
|
|
|
- pageNum++;
|
|
|
- Map<String, Object> jsonMap = Maps.newHashMap();
|
|
|
- long signFlowStartTimeFrom = startDateTime.atZone(ZoneId.systemDefault())
|
|
|
- .toInstant()
|
|
|
- .toEpochMilli();
|
|
|
- long signFlowStartTimeTo = endDateTime.atZone(ZoneId.systemDefault())
|
|
|
- .toInstant()
|
|
|
- .toEpochMilli();
|
|
|
- jsonMap.put("signFlowStartTimeFrom", signFlowStartTimeFrom);
|
|
|
- jsonMap.put("signFlowStartTimeTo", signFlowStartTimeTo);
|
|
|
- jsonMap.put("pageNum", pageNum);
|
|
|
- jsonMap.put("pageSize", pageSize);
|
|
|
- List<String> list = Lists.newArrayList();
|
|
|
- //list.add("1");
|
|
|
- list.add("2");
|
|
|
- //list.add("3");
|
|
|
- jsonMap.put("signFlowStatus", list);
|
|
|
- try {
|
|
|
- EsignHttpResponse response = EsignHttpUtil.sign_flow_list(null, jsonMap, "查询签署流程列表");
|
|
|
- System.out.println(response.getBody());
|
|
|
- JSONObject jsonObject = JSON.parseObject(response.getBody());
|
|
|
- int code =jsonObject.getInteger("code");
|
|
|
- if (0==code){
|
|
|
- JSONObject data = jsonObject.getJSONObject("data");
|
|
|
- if (null!=data){
|
|
|
- JSONArray signFlowInfos = data.getJSONArray("signFlowInfos");
|
|
|
- System.out.println(signFlowInfos.size());
|
|
|
- long total = data.getLong("total");
|
|
|
- if(total%pageSize==0){
|
|
|
- totalNum=total/pageSize;
|
|
|
- }else {
|
|
|
- totalNum=total/pageSize+1;
|
|
|
- }
|
|
|
+ if (StringUtils.isBlank(respsf.getBody())) {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ JSONObject jsonObjsf = JSON.parseObject(respsf.getBody());
|
|
|
+ int codesf = jsonObjsf.getInteger("code");
|
|
|
+ if (0 != codesf) {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ JSONObject datasf = jsonObjsf.getJSONObject("data");
|
|
|
+ if (null == datasf) {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ Integer signFlowStatus = datasf.getInteger("signFlowStatus");
|
|
|
+ String statusDescription = datasf.getString("statusDescription");
|
|
|
+ //签署中
|
|
|
+ if (null != signFlowStatus && 1 == signFlowStatus) {
|
|
|
+ JSONArray signers = datasf.getJSONArray("signers");
|
|
|
+ StringBuilder signNames = new StringBuilder();
|
|
|
+ for (int j = 0; j < signers.size(); j++) {
|
|
|
+ JSONObject signer = signers.getJSONObject(j);
|
|
|
+ JSONObject psnSigner = signer.getJSONObject("psnSigner");
|
|
|
+ JSONObject orgSigner = signer.getJSONObject("orgSigner");
|
|
|
+ JSONArray signFields = signer.getJSONArray("signFields");
|
|
|
+ boolean signFieldBool=false;
|
|
|
+ for (int x = 0; x < signFields.size(); x++) {
|
|
|
+ JSONObject sign = signFields.getJSONObject(x);
|
|
|
+ Integer signFieldStatus = Integer.parseInt(sign.getString("signFieldStatus"));
|
|
|
+ //这三种情况的话说明是当前这个签署区所属的签署人在签署：1 - 执行中、2 - 执行失败、3 - 审批中
|
|
|
+ if (signFieldStatus > 0 && signFieldStatus < 4) {
|
|
|
+ signFieldBool=true;
|
|
|
}
|
|
|
}
|
|
|
- } catch (EsignException e) {
|
|
|
- e.printStackTrace();
|
|
|
+ oldInfo.setEsignStatus(EsignStatusEnum.getEnum(signFlowStatus));
|
|
|
+ oldInfo.setDescription(statusDescription);
|
|
|
+ oldInfo.setNowOperator("");
|
|
|
+ if (signFieldBool) {
|
|
|
+ signNames = getPsnName(context, signNames, psnSigner);
|
|
|
+ signNames = getOrgName(context, signNames, orgSigner);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(signNames.indexOf(",") == 0) {
|
|
|
+ signNames.delete(0,1);
|
|
|
+ }
|
|
|
+ if (signNames.length() > 500) {
|
|
|
+ oldInfo.setNowOperator(signNames.substring(0, 500));
|
|
|
+ } else {
|
|
|
+ oldInfo.setNowOperator(signNames.toString());
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ String signFlowDescription = datasf.getString("signFlowDescription");
|
|
|
+ String revokeReason = datasf.getString("revokeReason");
|
|
|
+ oldInfo.setNowOperator("");
|
|
|
+ oldInfo.setDescription(signFlowDescription);
|
|
|
+ oldInfo.setDescription(revokeReason);
|
|
|
+ }
|
|
|
+ overview.save(oldInfo);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ private StringBuilder getOrgName(Context context, StringBuilder signNames, JSONObject orgSigner) throws BOSException, SQLException {
|
|
|
+ if (null == orgSigner) {
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+ String orgName = orgSigner.getString("orgName");
|
|
|
+ JSONObject transactor = orgSigner.getJSONObject("transactor");
|
|
|
+ if (null == transactor) {
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+ String psnName = transactor.getString("psnName");
|
|
|
+ if (StringUtils.isNotBlank(psnName)) {
|
|
|
+ signNames.append("," + orgName + "(" + psnName + ")");
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+ JSONObject psnAccount = transactor.getJSONObject("psnAccount");
|
|
|
+ if (null == psnAccount) {
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+ String accountMobile = psnAccount.getString("accountMobile");
|
|
|
+ String accountEmail = psnAccount.getString("accountEmail");
|
|
|
+ if (StringUtils.isNotBlank(accountMobile)) {
|
|
|
+ String selp = "select fid,fname_l2,fnumber from t_bd_person where FNCELL='" + accountMobile + "'";
|
|
|
+ IRowSet rs = DbUtil.executeQuery(context, selp);
|
|
|
+ if (rs.next()) {
|
|
|
+ String fid = rs.getString("fid");
|
|
|
+ String fname_l2 = rs.getString("fname_l2");
|
|
|
+ String fnumber = rs.getString("fnumber");
|
|
|
+ signNames.append("," + orgName + "(" + fname_l2 + ")");
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotBlank(accountEmail)) {
|
|
|
+ String selp = "select fid,fname_l2,fnumber from t_bd_person where FEMail='" + accountEmail + "'";
|
|
|
+ IRowSet rs = DbUtil.executeQuery(context, selp);
|
|
|
+ if (rs.next()) {
|
|
|
+ String fid = rs.getString("fid");
|
|
|
+ String fname_l2 = rs.getString("fname_l2");
|
|
|
+ String fnumber = rs.getString("fnumber");
|
|
|
+ signNames.append("," + orgName + "(" + fname_l2 + ")");
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+
|
|
|
+ private StringBuilder getPsnName(Context context, StringBuilder signNames, JSONObject psnSigner) throws BOSException, SQLException {
|
|
|
+ if (null == psnSigner) {
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+ String psnName = psnSigner.getString("psnName");
|
|
|
+ if (StringUtils.isNotBlank(psnName)) {
|
|
|
+ signNames.append("," + psnName);
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+ JSONObject psnAccount = psnSigner.getJSONObject("psnAccount");
|
|
|
+ if (null == psnAccount) {
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+ String accountMobile = psnAccount.getString("accountMobile");
|
|
|
+ String accountEmail = psnAccount.getString("accountEmail");
|
|
|
+ if (StringUtils.isNotBlank(accountMobile)) {
|
|
|
+ String selp = "select fid,fname_l2,fnumber from t_bd_person where FNCELL='" + accountMobile + "'";
|
|
|
+ IRowSet rs = DbUtil.executeQuery(context, selp);
|
|
|
+ if (rs.next()) {
|
|
|
+ String fid = rs.getString("fid");
|
|
|
+ String fname_l2 = rs.getString("fname_l2");
|
|
|
+ String fnumber = rs.getString("fnumber");
|
|
|
+ signNames.append("," + fname_l2);
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotBlank(accountEmail)) {
|
|
|
+ String selp = "select fid,fname_l2,fnumber from t_bd_person where FEMail='" + accountEmail + "'";
|
|
|
+ IRowSet rs = DbUtil.executeQuery(context, selp);
|
|
|
+ if (rs.next()) {
|
|
|
+ String fid = rs.getString("fid");
|
|
|
+ String fname_l2 = rs.getString("fname_l2");
|
|
|
+ String fnumber = rs.getString("fnumber");
|
|
|
+ signNames.append("," + fname_l2);
|
|
|
+ return signNames;
|
|
|
}
|
|
|
- } while (pageNum<totalNum);
|
|
|
+ }
|
|
|
+
|
|
|
+ return signNames;
|
|
|
+ }
|
|
|
+
|
|
|
+ private void addNewSignFlow(Context context, IESignGlobalStatusOverview overview, JSONObject signFlowInfo, String signFlowId, String signFlowTitle) throws BOSException, SQLException, EASBizException {
|
|
|
+ ESignGlobalStatusOverviewInfo nowInfo = new ESignGlobalStatusOverviewInfo();
|
|
|
+ nowInfo.setSignFlowId(signFlowId);
|
|
|
+ nowInfo.setFileName(signFlowTitle);
|
|
|
+ nowInfo.setEsignStatus(EsignStatusEnum.COMPLETED);
|
|
|
+ nowInfo.setEsignName(EsignConfigEnum.sign_flow_list);
|
|
|
+ nowInfo.setRequestParams(signFlowInfo.toJSONString());
|
|
|
+ nowInfo.setFiesign(true);
|
|
|
+ nowInfo.setSendStatus(SendStatusEnum.SUCCESS);
|
|
|
+ JSONArray signers = signFlowInfo.getJSONArray("signers");
|
|
|
+ for (int x = 0; x < signers.size(); x++) {
|
|
|
+ JSONObject signer = signers.getJSONObject(x);
|
|
|
+ JSONObject psnSigner = signer.getJSONObject("psnSigner");
|
|
|
+ if (null == psnSigner) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ JSONObject psnAccount = psnSigner.getJSONObject("psnAccount");
|
|
|
+ String accountMobile = psnAccount.getString("accountMobile");
|
|
|
+ String accountEmail = psnAccount.getString("accountEmail");
|
|
|
+ if (StringUtils.isNotBlank(accountMobile)) {
|
|
|
+ String selp = "select fid from t_bd_person where FNCELL='" + accountMobile + "'";
|
|
|
+ IRowSet rs = DbUtil.executeQuery(context, selp);
|
|
|
+ if (rs.next()) {
|
|
|
+ String fid = rs.getString("fid");
|
|
|
+ PersonInfo personInfo = new PersonInfo();
|
|
|
+ personInfo.setId(BOSUuid.read(fid));
|
|
|
+ nowInfo.setPerson(personInfo);
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ String selp = "select fid from t_bd_person where FEMail='" + accountEmail + "'";
|
|
|
+ IRowSet rs = DbUtil.executeQuery(context, selp);
|
|
|
+ if (rs.next()) {
|
|
|
+ String fid = rs.getString("fid");
|
|
|
+ PersonInfo personInfo = new PersonInfo();
|
|
|
+ personInfo.setId(BOSUuid.read(fid));
|
|
|
+ nowInfo.setPerson(personInfo);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (null != nowInfo.getPerson()) {
|
|
|
+ IObjectPK pk = overview.addnew(nowInfo);
|
|
|
+ ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(1);
|
|
|
+ scheduledThreadPoolExecutor.schedule(() -> {
|
|
|
+ try {
|
|
|
+ this.updateSignFlow(context, overview, signFlowId, nowInfo.getId().toString());
|
|
|
+ SyncSignedFilesUtil.syncAttachmentsForEmpPage(context, nowInfo.getId().toString());
|
|
|
+ } catch (BOSException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } catch (EASBizException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } catch (EsignException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } catch (SQLException throwables) {
|
|
|
+ throwables.printStackTrace();
|
|
|
+ }
|
|
|
+ }, 1, TimeUnit.MINUTES);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ public static void main(String[] args) throws EsignException {
|
|
|
+ System.setProperty("EAS_HOME","D:\\project\\kingdeeV90\\Project_hty\\tengda");
|
|
|
+// LocalDateTime startDateTime = null;
|
|
|
+// LocalDateTime endDateTime = null;
|
|
|
+// if (null == startDateTime || null == endDateTime) {
|
|
|
+// startDateTime = formatter("2025-02-01");;
|
|
|
+// endDateTime = formatter("2026-02-01");;
|
|
|
+// }
|
|
|
+// int pageNum=0;
|
|
|
+// int pageSize=100;
|
|
|
+// long totalNum=1;
|
|
|
+// do {
|
|
|
+// pageNum++;
|
|
|
+// Map<String, Object> jsonMap = Maps.newHashMap();
|
|
|
+// long signFlowStartTimeFrom = startDateTime.atZone(ZoneId.systemDefault())
|
|
|
+// .toInstant()
|
|
|
+// .toEpochMilli();
|
|
|
+// long signFlowStartTimeTo = endDateTime.atZone(ZoneId.systemDefault())
|
|
|
+// .toInstant()
|
|
|
+// .toEpochMilli();
|
|
|
+// jsonMap.put("signFlowStartTimeFrom", signFlowStartTimeFrom);
|
|
|
+// jsonMap.put("signFlowStartTimeTo", signFlowStartTimeTo);
|
|
|
+// jsonMap.put("pageNum", pageNum);
|
|
|
+// jsonMap.put("pageSize", pageSize);
|
|
|
+// List<String> list = Lists.newArrayList();
|
|
|
+// list.add("1");
|
|
|
+// list.add("2");
|
|
|
+// list.add("3");
|
|
|
+// jsonMap.put("signFlowStatus", list);
|
|
|
+// try {
|
|
|
+// EsignHttpResponse response = EsignHttpUtil.sign_flow_list(null, jsonMap, "查询签署流程列表");
|
|
|
+// System.out.println(response.getBody());
|
|
|
+// JSONObject jsonObject = JSON.parseObject(response.getBody());
|
|
|
+// int code =jsonObject.getInteger("code");
|
|
|
+// if (0==code){
|
|
|
+// JSONObject data = jsonObject.getJSONObject("data");
|
|
|
+// if (null!=data){
|
|
|
+// JSONArray signFlowInfos = data.getJSONArray("signFlowInfos");
|
|
|
+// System.out.println(signFlowInfos.size());
|
|
|
+// long total = data.getLong("total");
|
|
|
+// if(total%pageSize==0){
|
|
|
+// totalNum=total/pageSize;
|
|
|
+// }else {
|
|
|
+// totalNum=total/pageSize+1;
|
|
|
+// }
|
|
|
+// }
|
|
|
+// }
|
|
|
+// } catch (EsignException e) {
|
|
|
+// e.printStackTrace();
|
|
|
+// }
|
|
|
+// } while (pageNum<totalNum);
|
|
|
+ System.out.println(12 + (3 - 1) / 2 * 1);
|
|
|
+ EsignHttpResponse r = EsignHttpUtil.getSign_fields(null,"d4d12e6ed7374775a9dcb4747e1e5e59");
|
|
|
+ System.out.println(r.getBody());
|
|
|
+
|
|
|
}
|
|
|
}
|
9060