Commit c80c1a51 authored by 张俊's avatar 张俊

单位开户、单位变更、单位销户协议修改

parent f52f125f
...@@ -38,7 +38,7 @@ public class AlarmTask { ...@@ -38,7 +38,7 @@ public class AlarmTask {
*/ */
@Scheduled(initialDelay = 5 * 1000, fixedDelayString = "${dwkhPullTaskDelay}") @Scheduled(initialDelay = 5 * 1000, fixedDelayString = "${dwkhPullTaskDelay}")
public void dwkhPullTask() { public void dwkhPullTask() {
log.debug("第一个接口开始时间:{}", InternalUtils.getCurrentTime()); log.debug("dwkhPullTask 开始时间:{}", InternalUtils.getCurrentTime());
try { try {
openAccountService.syncDeptInfo(); openAccountService.syncDeptInfo();
} catch (Exception e) { } catch (Exception e) {
...@@ -53,8 +53,8 @@ public class AlarmTask { ...@@ -53,8 +53,8 @@ public class AlarmTask {
*/ */
@Scheduled(initialDelay = 20 * 1000, fixedDelayString = "${dwkhPushTaskDelay}") @Scheduled(initialDelay = 20 * 1000, fixedDelayString = "${dwkhPushTaskDelay}")
public void dwkhPushTask() { public void dwkhPushTask() {
log.debug("第二个接口开始时间:{}", InternalUtils.getCurrentTime()); log.debug("dwkhPushTask 开始时间:{}", InternalUtils.getCurrentTime());
openAccountService.dwkhPush(); openAccountService.openAccountPush();
} }
@Scheduled(initialDelay = 40 * 1000, fixedDelayString = "${dwxxbgPushTaskDelay}") @Scheduled(initialDelay = 40 * 1000, fixedDelayString = "${dwxxbgPushTaskDelay}")
...@@ -66,7 +66,7 @@ public class AlarmTask { ...@@ -66,7 +66,7 @@ public class AlarmTask {
@Scheduled(initialDelay = 80 * 1000, fixedDelayString = "${dwxhPushTaskDelay}") @Scheduled(initialDelay = 80 * 1000, fixedDelayString = "${dwxhPushTaskDelay}")
public void dwxhPushTask() { public void dwxhPushTask() {
log.debug("dwxhPushTask 开始时间:{}", InternalUtils.getCurrentTime()); log.debug("dwxhPushTask 开始时间:{}", InternalUtils.getCurrentTime());
deptLogoutService.dwxhPush(); deptLogoutService.deptLogoutPush();
} }
} }
......
...@@ -118,9 +118,9 @@ public class DeptLogoutService { ...@@ -118,9 +118,9 @@ public class DeptLogoutService {
* 住建部门返回公积金办理进度数据接口方法 * 住建部门返回公积金办理进度数据接口方法
* (第二个定时) * (第二个定时)
*/ */
public String dwxhPush() { public String deptLogoutPush() {
// 调oracle存储过程拿到进度推进的数据集合 // 调oracle存储过程拿到进度推进的数据集合
List<BusinessProcessing> collDwxhList = collDwxh(); List<BusinessProcessing> collDwxhList = collDeptLogout();
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
jsonObject.put("state", "1"); jsonObject.put("state", "1");
if (!CollectionUtils.isEmpty(collDwxhList)) { if (!CollectionUtils.isEmpty(collDwxhList)) {
...@@ -142,7 +142,7 @@ public class DeptLogoutService { ...@@ -142,7 +142,7 @@ public class DeptLogoutService {
String uscc = !CollectionUtils.isEmpty(collDwxhList) ? collDwxhList.get(0).getUscc() : ""; String uscc = !CollectionUtils.isEmpty(collDwxhList) ? collDwxhList.get(0).getUscc() : "";
log.info("入参 uscc:{} value:{}", uscc, value); log.info("入参 uscc:{} value:{}", uscc, value);
// 回写 // 回写
collDwxhHx(uscc, value); collDeptLogoutRewrite(uscc, value);
return forObject; return forObject;
} }
...@@ -150,7 +150,7 @@ public class DeptLogoutService { ...@@ -150,7 +150,7 @@ public class DeptLogoutService {
* 住建部门返回公积金办理进度数据接口方法 * 住建部门返回公积金办理进度数据接口方法
* 调用oracle存储过程拿到进度数据,然后请求前置机,让前置机请求市监接口,将办理的进度数据推送给市监 * 调用oracle存储过程拿到进度数据,然后请求前置机,让前置机请求市监接口,将办理的进度数据推送给市监
*/ */
public List<BusinessProcessing> collDwxh() { public List<BusinessProcessing> collDeptLogout() {
List<BusinessProcessing> list = new ArrayList<>(); List<BusinessProcessing> list = new ArrayList<>();
Connection connection = null; Connection connection = null;
CallableStatement dwxhCx = null; CallableStatement dwxhCx = null;
...@@ -221,7 +221,7 @@ public class DeptLogoutService { ...@@ -221,7 +221,7 @@ public class DeptLogoutService {
/** /**
* 回写 * 回写
*/ */
public void collDwxhHx(String uscc, Integer value) { public void collDeptLogoutRewrite(String uscc, Integer value) {
Connection connection = null; Connection connection = null;
CallableStatement pstm = null; CallableStatement pstm = null;
// 1.调用oracle存储过程,拿到业务办理进度数据 // 1.调用oracle存储过程,拿到业务办理进度数据
......
...@@ -265,7 +265,7 @@ public class OpenAccountService { ...@@ -265,7 +265,7 @@ public class OpenAccountService {
* 住建部门返回公积金办理进度数据接口方法 * 住建部门返回公积金办理进度数据接口方法
* (第二个定时) * (第二个定时)
*/ */
public String dwkhPush() { public String openAccountPush() {
logger.info("调第二个接口了"); logger.info("调第二个接口了");
// 调oracle存储过程拿到进度推进的数据集合 // 调oracle存储过程拿到进度推进的数据集合
List<BusinessProcessing> list = null; List<BusinessProcessing> list = null;
......
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