From bc56870059cca013649077af0e53891cba8dbfd1 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期日, 04 八月 2024 09:43:41 +0800
Subject: [PATCH] 代理新功能完善
---
src/main/java/com/taoke/autopay/service/impl/ClientInfoServiceImpl.java | 72 +++++++++++++++++++++++------------
1 files changed, 47 insertions(+), 25 deletions(-)
diff --git a/src/main/java/com/taoke/autopay/service/impl/ClientInfoServiceImpl.java b/src/main/java/com/taoke/autopay/service/impl/ClientInfoServiceImpl.java
index 6bda45d..37dbad7 100644
--- a/src/main/java/com/taoke/autopay/service/impl/ClientInfoServiceImpl.java
+++ b/src/main/java/com/taoke/autopay/service/impl/ClientInfoServiceImpl.java
@@ -2,12 +2,16 @@
import com.taoke.autopay.dao.ClientInfoMapper;
import com.taoke.autopay.entity.ClientInfo;
+import com.taoke.autopay.entity.SystemConfigKeyEnum;
import com.taoke.autopay.exception.LoginException;
import com.taoke.autopay.service.ClientInfoService;
+import com.taoke.autopay.service.SystemConfigService;
+import com.taoke.autopay.utils.StringUtil;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
+import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
@@ -22,6 +26,9 @@
public class ClientInfoServiceImpl implements ClientInfoService {
@Resource
private ClientInfoMapper clientInfoMapper;
+
+ @Resource
+ private SystemConfigService systemConfigService;
@Override
public ClientInfo login(String account, String pwd) throws LoginException {
@@ -70,47 +77,62 @@
@Override
public long count(ClientInfoMapper.DaoQuery query) {
- return clientInfoMapper.count(query);
+ return clientInfoMapper.count(query);
}
@Transactional(rollbackFor = Exception.class)
@Override
public void add(ClientInfo info) {
- if(info.getPwd()==null){
- info.setPwd("123456");
- }
- if(info.getRule()==null){
- info.setRule(ClientInfo.RULE_COMMON);
- }
- if(info.getCreateTime()==null){
- info.setCreateTime(new Date());
- }
+ if (info.getPwd() == null) {
+ info.setPwd("123456");
+ }
+ if (info.getRule() == null) {
+ info.setRule(ClientInfo.RULE_COMMON);
+ }
+ if (info.getCreateTime() == null) {
+ info.setCreateTime(new Date());
+ }
- if(info.getAccount()==null) {
- // 鏌ヨ鏈�澶х殑璐﹀彿
- ClientInfoMapper.DaoQuery query = new ClientInfoMapper.DaoQuery();
- query.sortList = Arrays.asList(new String[]{"id desc"});
- query.count = 1;
- List<ClientInfo> list = list(query);
- long maxId = 0;
- if (list.size() > 0) {
- maxId = list.get(0).getId();
- }
- info.setAccount("c" + maxId);
- }
+ if (info.getAccount() == null) {
+ // 鏌ヨ鏈�澶х殑璐﹀彿
+ ClientInfoMapper.DaoQuery query = new ClientInfoMapper.DaoQuery();
+ query.sortList = Arrays.asList(new String[]{"id desc"});
+ query.count = 1;
+ List<ClientInfo> list = list(query);
+ long maxId = 0;
+ if (list.size() > 0) {
+ maxId = list.get(0).getId();
+ }
+ info.setAccount("c" + maxId);
+ }
clientInfoMapper.insertSelective(info);
- ClientInfo update=new ClientInfo();
+ ClientInfo update = new ClientInfo();
update.setId(info.getId());
- update.setName("瀹㈡埛绔�"+(info.getId()-1));
+ update.setName("瀹㈡埛绔�" + (info.getId() - 1));
clientInfoMapper.updateByPrimaryKeySelective(update);
}
@Override
public void setPwd(Long id, String pwd) {
- ClientInfo update=new ClientInfo();
+ ClientInfo update = new ClientInfo();
update.setId(id);
update.setPwd(pwd);
clientInfoMapper.updateByPrimaryKeySelective(update);
}
+
+ @Override
+ public List<Long> getRePayClientIds() {
+ List<Long> idList = new ArrayList<>();
+
+ String clientIds = systemConfigService.getValueCache(SystemConfigKeyEnum.RE_EXCUTE_PAY_CLIENTS);
+ if (StringUtil.isNullOrEmpty(clientIds)) {
+ return idList;
+ }
+ String[] ids = clientIds.trim().split(",");
+ for (String id : ids) {
+ idList.add(Long.parseLong(id));
+ }
+ return idList;
+ }
}
--
Gitblit v1.8.0