zhenghuang
/
bsdgy-server
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

大屏接口

Browse Source
dev_0531
yechenhao 6 years ago
parent fb0570eeb5
commit 5cba1b3e7b
2 changed files with 52 additions and 80 deletions
Show Stats Download Patch File Download Diff File

130
src/main/java/com/kiisoo/ic/customer/service/CustomerViewService.java
Unescape Escape View File

@ -717,89 +717,61 @@ public class CustomerViewService {
* @return
*/
public void syncVip() throws InterruptedException {
//初始化线程
ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(8);
//查询现有企业微信账号
List<OpCustomer> customers = opCustomerDOMapper.selectList(null);
if (CollectionUtils.isNotEmpty(customers)){
//分组
final List<List<OpCustomer>> afterPageList = com.kiisoo.ic.utils.CollectionUtils.portListByQuantity(customers, 100);
//定义线程池长度
int threadPoolSize = afterPageList.size();
//定义countDownLatch
final CountDownLatch countDownLatch = new CountDownLatch(threadPoolSize);
for (int i = 0; i < afterPageList.size(); i++) {
List<OpCustomer> opCustomers = afterPageList.get(i);
newFixedThreadPool.execute(new Runnable() {
@Override
public void run() {
try {
//查询企业微信已配置联系我的用户
for (OpCustomer customer : opCustomers) {
String wechatUniId = customer.getWechatUniId();
if (StringUtils.isBlank(wechatUniId)){
continue;
}
String url = "";
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
Map<String, Object> params = new HashMap<>();
params.put("unionId", wechatUniId);
String message = HttpClientUtil.httpPost(vipBsdUrl + MD5FileUtil.getMD5String("BOSIDENG" + sdf.format(new Date())), JSONObject.toJSONString(params)).getMessage();
if (StringUtils.isBlank(message)){
continue;
}
JSONObject vipJson = JSONObject.parseObject(message);
BsdVipResponse bsdResponse = vipJson.toJavaObject(BsdVipResponse.class);
if (bsdResponse.getSuccess() && bsdResponse.getData() != null){
MemberDtlDTO data = bsdResponse.getData();
OpCustomer opCustomer = new OpCustomer(data.getMemberName(), data.getMobileNo());
opCustomer.setUpdateBy(Constants.SYS_OPERATION);
// 根据手机号码去重
QueryWrapper<OpVip> wrapper = new QueryWrapper<>();
wrapper.eq("phone", data.getMobileNo());
OpVip opVip = opVipDOMapper.selectOne(wrapper);
OpVip opVip1 = new OpVip();
opVip1.setStatus(1L);
opVip1.setLevel(data.getMemberLevel().toString());
opVip1.setPhone(data.getMobileNo());
opVip1.setName(data.getMemberName());
opVip1.setBirthday(data.getBirthday());
opVip1.setRegisterTime(data.getCreateDate());
if (opVip == null) {
//数据库没有这个数据--新建数据
opVip1.setCreateBy(Constants.SYS_OPERATION);
opVip1.setCreateTime(new Date());
opVipDOMapper.insert(opVip1);
//有vip信息就绑定信息
opCustomer.setMemberId(opVip1.getId());
} else {
opVip1.setId(opVip.getId());
opVip1.setUpdateTime(new Date());
opVip1.setUpdateBy(Constants.SYS_OPERATION);
opVipDOMapper.updateById(opVip1);
//有vip信息就绑定信息
opCustomer.setMemberId(opVip.getId());
}
QueryWrapper<OpCustomer> wrapper1 = new QueryWrapper<>();
wrapper1.eq("wechat_uni_id", wechatUniId);
opCustomerDOMapper.update(opCustomer, wrapper1);
}
}
} catch (Exception e) {
log.error("同步会员数据", e);
} finally {
//每次减去一，避免死锁
countDownLatch.countDown();
}
}
});
//查询企业微信已配置联系我的用户
for (OpCustomer customer : customers) {
String wechatUniId = customer.getWechatUniId();
if (StringUtils.isBlank(wechatUniId)){
continue;
}
String url = "";
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
Map<String, Object> params = new HashMap<>();
params.put("unionId", wechatUniId);
String message = HttpClientUtil.httpPost(vipBsdUrl + MD5FileUtil.getMD5String("BOSIDENG" + sdf.format(new Date())), JSONObject.toJSONString(params)).getMessage();
if (StringUtils.isBlank(message)){
continue;
}
JSONObject vipJson = JSONObject.parseObject(message);
BsdVipResponse bsdResponse = vipJson.toJavaObject(BsdVipResponse.class);
if (bsdResponse.getSuccess() && bsdResponse.getData() != null){
MemberDtlDTO data = bsdResponse.getData();
OpCustomer opCustomer = new OpCustomer(data.getMemberName(), data.getMobileNo());
opCustomer.setUpdateBy(Constants.SYS_OPERATION);
// 根据手机号码去重
QueryWrapper<OpVip> wrapper = new QueryWrapper<>();
wrapper.eq("phone", data.getMobileNo());
OpVip opVip = opVipDOMapper.selectOne(wrapper);
OpVip opVip1 = new OpVip();
opVip1.setStatus(1L);
opVip1.setLevel(data.getMemberLevel().toString());
opVip1.setPhone(data.getMobileNo());
opVip1.setName(data.getMemberName());
opVip1.setBirthday(data.getBirthday());
opVip1.setRegisterTime(data.getCreateDate());
if (opVip == null) {
//数据库没有这个数据--新建数据
opVip1.setCreateBy(Constants.SYS_OPERATION);
opVip1.setCreateTime(new Date());
opVipDOMapper.insert(opVip1);
//有vip信息就绑定信息
opCustomer.setMemberId(opVip1.getId());
} else {
opVip1.setId(opVip.getId());
opVip1.setUpdateTime(new Date());
opVip1.setUpdateBy(Constants.SYS_OPERATION);
opVipDOMapper.updateById(opVip1);
//有vip信息就绑定信息
opCustomer.setMemberId(opVip.getId());
}
QueryWrapper<OpCustomer> wrapper1 = new QueryWrapper<>();
wrapper1.eq("wechat_uni_id", wechatUniId);
opCustomerDOMapper.update(opCustomer, wrapper1);
}
countDownLatch.await();
}
}
}

2
src/main/java/com/kiisoo/ic/job/CustomerDataJob.java
Unescape Escape View File

@ -28,7 +28,7 @@ public class CustomerDataJob {
// 指定 ring buffer字节大小，必需为2的N次方(能将求模运算转为位运算提高效率 )，否则影响性能
private static final int BUFFER_SIZE = 1024 * 1024;
//固定线程数
private static final int THREAD_NUMBERS = 50;
private static final int THREAD_NUMBERS = 30;
@Autowired

Write Preview
Loading…
Cancel
Save