|
@@ -10,10 +10,7 @@ import com.uas.platform.b2b.manage.support.CollectionUtil;
|
|
|
import com.uas.platform.b2b.manage.support.MyException;
|
|
import com.uas.platform.b2b.manage.support.MyException;
|
|
|
import com.uas.platform.b2b.manage.core.util.StringUtils;
|
|
import com.uas.platform.b2b.manage.core.util.StringUtils;
|
|
|
import com.uas.platform.b2b.manage.dao.EnterpriseBaseInfoDao;
|
|
import com.uas.platform.b2b.manage.dao.EnterpriseBaseInfoDao;
|
|
|
-import com.uas.platform.b2b.manage.support.MyThread;
|
|
|
|
|
import com.uas.platform.b2b.manage.support.MyThreadPoolExecutor;
|
|
import com.uas.platform.b2b.manage.support.MyThreadPoolExecutor;
|
|
|
-import com.uas.platform.b2b.manage.model.*;
|
|
|
|
|
-import com.uas.platform.b2b.manage.support.*;
|
|
|
|
|
import com.uas.platform.core.model.PageInfo;
|
|
import com.uas.platform.core.model.PageInfo;
|
|
|
import com.uas.platform.core.model.Status;
|
|
import com.uas.platform.core.model.Status;
|
|
|
import com.uas.platform.core.persistence.criteria.CriterionExpression;
|
|
import com.uas.platform.core.persistence.criteria.CriterionExpression;
|
|
@@ -22,21 +19,18 @@ import com.uas.platform.core.persistence.criteria.PredicateUtils;
|
|
|
import com.uas.platform.core.persistence.criteria.SimpleExpression;
|
|
import com.uas.platform.core.persistence.criteria.SimpleExpression;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.data.domain.Page;
|
|
import org.springframework.data.domain.Page;
|
|
|
-import org.springframework.data.jpa.domain.Specification;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.ui.ModelMap;
|
|
import org.springframework.ui.ModelMap;
|
|
|
import org.springframework.util.CollectionUtils;
|
|
import org.springframework.util.CollectionUtils;
|
|
|
|
|
|
|
|
import javax.persistence.criteria.CriteriaBuilder;
|
|
import javax.persistence.criteria.CriteriaBuilder;
|
|
|
import javax.persistence.criteria.CriteriaQuery;
|
|
import javax.persistence.criteria.CriteriaQuery;
|
|
|
-import javax.persistence.criteria.Predicate;
|
|
|
|
|
import javax.persistence.criteria.Root;
|
|
import javax.persistence.criteria.Root;
|
|
|
import java.text.ParseException;
|
|
import java.text.ParseException;
|
|
|
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 java.util.concurrent.*;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -77,13 +71,13 @@ public class InviteServiceImpl extends BaseService implements InviteService {
|
|
|
public Page<Invite> findInviteByPageInfo(final PageInfo info, String keyword, String fromDate, String endDate) throws ParseException {
|
|
public Page<Invite> findInviteByPageInfo(final PageInfo info, String keyword, String fromDate, String endDate) throws ParseException {
|
|
|
if (!StringUtils.isEmpty(keyword)) {
|
|
if (!StringUtils.isEmpty(keyword)) {
|
|
|
SimpleExpression name = new SimpleExpression("enName", keyword, CriterionExpression.Operator.LIKE, true);
|
|
SimpleExpression name = new SimpleExpression("enName", keyword, CriterionExpression.Operator.LIKE, true);
|
|
|
- SimpleExpression enBussinessCode = new SimpleExpression("enBussinessCode", keyword, CriterionExpression.Operator.LIKE, true);
|
|
|
|
|
|
|
+ SimpleExpression enBusinessCode = new SimpleExpression("enBussinessCode", keyword, CriterionExpression.Operator.LIKE, true);
|
|
|
SimpleExpression inviteEnName = new SimpleExpression("inviteEnName", keyword, CriterionExpression.Operator.LIKE, true);
|
|
SimpleExpression inviteEnName = new SimpleExpression("inviteEnName", keyword, CriterionExpression.Operator.LIKE, true);
|
|
|
SimpleExpression inviteUserName = new SimpleExpression("inviteUserName", keyword, CriterionExpression.Operator.LIKE, true);
|
|
SimpleExpression inviteUserName = new SimpleExpression("inviteUserName", keyword, CriterionExpression.Operator.LIKE, true);
|
|
|
SimpleExpression adminUserName = new SimpleExpression("adminName", keyword, CriterionExpression.Operator.LIKE, true);
|
|
SimpleExpression adminUserName = new SimpleExpression("adminName", keyword, CriterionExpression.Operator.LIKE, true);
|
|
|
List<SimpleExpression> expressionList = new ArrayList<>();
|
|
List<SimpleExpression> expressionList = new ArrayList<>();
|
|
|
expressionList.add(name);
|
|
expressionList.add(name);
|
|
|
- expressionList.add(enBussinessCode);
|
|
|
|
|
|
|
+ expressionList.add(enBusinessCode);
|
|
|
expressionList.add(inviteEnName);
|
|
expressionList.add(inviteEnName);
|
|
|
expressionList.add(inviteUserName);
|
|
expressionList.add(inviteUserName);
|
|
|
expressionList.add(adminUserName);
|
|
expressionList.add(adminUserName);
|
|
@@ -101,13 +95,8 @@ public class InviteServiceImpl extends BaseService implements InviteService {
|
|
|
if (!StringUtils.isEmpty(endDate)) {
|
|
if (!StringUtils.isEmpty(endDate)) {
|
|
|
info.expression(PredicateUtils.lte("enDate", SIMPLE_DATE_FORMAT.parse(endDate), false));
|
|
info.expression(PredicateUtils.lte("enDate", SIMPLE_DATE_FORMAT.parse(endDate), false));
|
|
|
}
|
|
}
|
|
|
- Page<Invite> invites = inviteDao.findAll(new Specification<Invite>() {
|
|
|
|
|
- @Override
|
|
|
|
|
- public Predicate toPredicate(Root<Invite> root, CriteriaQuery<?> query, CriteriaBuilder builder) {
|
|
|
|
|
- query.where(info.getPredicates(root, query, builder));
|
|
|
|
|
- return null;
|
|
|
|
|
- }
|
|
|
|
|
- }, info);
|
|
|
|
|
|
|
+ Page<Invite> invites = inviteDao.findAll((Root<Invite> root, CriteriaQuery<?> query, CriteriaBuilder builder)
|
|
|
|
|
+ -> query.where(info.getPredicates(root, query, builder)).getRestriction(), info);
|
|
|
Map<Long, InviteProdInfo> map = productService.findByEnUUList(CollectionUtil.getKeyCollection(invites.getContent()));
|
|
Map<Long, InviteProdInfo> map = productService.findByEnUUList(CollectionUtil.getKeyCollection(invites.getContent()));
|
|
|
for (Invite invite : invites) {
|
|
for (Invite invite : invites) {
|
|
|
if (null != invite.getUu()) {
|
|
if (null != invite.getUu()) {
|
|
@@ -152,13 +141,7 @@ public class InviteServiceImpl extends BaseService implements InviteService {
|
|
|
String sql = "update sec$enterprises set en_inviteuu = " + inviteUU +
|
|
String sql = "update sec$enterprises set en_inviteuu = " + inviteUU +
|
|
|
", en_inviteuseruu = " + inviteUserUU + " where en_uu = " + enUU;
|
|
", en_inviteuseruu = " + inviteUserUU + " where en_uu = " + enUU;
|
|
|
jdbcTemplate.execute(sql);
|
|
jdbcTemplate.execute(sql);
|
|
|
- MyThreadPoolExecutor.executor.execute(new Runnable() {
|
|
|
|
|
- @Override
|
|
|
|
|
- public void run() {
|
|
|
|
|
- // 更新邀请记录
|
|
|
|
|
- updateInvitation(inviteUserUU, enUU, inviteUU);
|
|
|
|
|
- }
|
|
|
|
|
- });
|
|
|
|
|
|
|
+ MyThreadPoolExecutor.executor.execute(() -> updateInvitation(inviteUserUU, enUU, inviteUU));
|
|
|
return new ModelMap("content", inviteDao.findOne(enUU));
|
|
return new ModelMap("content", inviteDao.findOne(enUU));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -296,21 +279,4 @@ public class InviteServiceImpl extends BaseService implements InviteService {
|
|
|
jdbcTemplate.execute(sql);
|
|
jdbcTemplate.execute(sql);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public static void main(String[] args) {
|
|
|
|
|
- ThreadPoolExecutor executor = new ThreadPoolExecutor(
|
|
|
|
|
- 5,
|
|
|
|
|
- 10,
|
|
|
|
|
- 60,
|
|
|
|
|
- TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),
|
|
|
|
|
- new MyThread(),
|
|
|
|
|
- new ThreadPoolExecutor.AbortPolicy());
|
|
|
|
|
- executor.execute(new Runnable() {
|
|
|
|
|
- @Override
|
|
|
|
|
- public void run() {
|
|
|
|
|
- System.out.println("Tread start");
|
|
|
|
|
- }
|
|
|
|
|
- });
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
}
|
|
}
|