Commit 4b627354 authored by zuoadmin's avatar zuoadmin

Merge branch 'dev' into 'master'

Dev

See merge request !19
parents f8548932 80c048fe
...@@ -122,7 +122,7 @@ public class PushCallBackServiceImpl extends ServiceImpl<PushCallBackDao, PushCa ...@@ -122,7 +122,7 @@ public class PushCallBackServiceImpl extends ServiceImpl<PushCallBackDao, PushCa
List<PushCallBackEntity> list = new ArrayList<>(); List<PushCallBackEntity> list = new ArrayList<>();
while (matcher.find()) { while (matcher.find()) {
String group = matcher.group(1); String group = matcher.group(1);
log.error("回调信息:{}", group); log.info("回调信息:{}", group);
PushCallBackEntity callBackInfo = JSONObject.parseObject(group, PushCallBackEntity.class); PushCallBackEntity callBackInfo = JSONObject.parseObject(group, PushCallBackEntity.class);
String desc = JSONObject.parseObject(group).getString("desc"); String desc = JSONObject.parseObject(group).getString("desc");
callBackInfo.setDescStr(desc); callBackInfo.setDescStr(desc);
......
...@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; ...@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.weface.code.CommonResult; import com.weface.code.CommonResult;
import com.weface.common.utils.CommonUtil;
import com.weface.common.utils.SnowIdUtil; import com.weface.common.utils.SnowIdUtil;
import com.weface.dao.UserMenusDao; import com.weface.dao.UserMenusDao;
import com.weface.dto.UserMenuFrom; import com.weface.dto.UserMenuFrom;
...@@ -33,34 +34,30 @@ public class UserMenusServiceImpl extends ServiceImpl<UserMenusDao, UserMenusEnt ...@@ -33,34 +34,30 @@ public class UserMenusServiceImpl extends ServiceImpl<UserMenusDao, UserMenusEnt
*/ */
@Override @Override
public void batchInsert(List<UserMenusEntity> userMenusList) { public void batchInsert(List<UserMenusEntity> userMenusList) {
if (CollUtil.isNotEmpty(userMenusList)) { try {
List<String> deleteUid = getDeleteUid(userMenusList); if (CollUtil.isNotEmpty(userMenusList)) {
//批量插入前全删 List<String> deleteUid = getDeleteUid(userMenusList);
List<Long> ids = this.baseMapper.findIdByUserId(deleteUid); List<List<String>> lists = CommonUtil.fixedGrouping(deleteUid, 10000);
this.removeByIds(ids); for (List<String> list : lists) {
//获取集合长度 //批量插入前全删
int count = userMenusList.size(); List<Long> ids = this.baseMapper.findIdByUserId(list);
//每次批量插入个数 this.removeByIds(ids);
int limit = 10000; }
int sum = 0; int sum = 0;
//计算页数 List<List<UserMenusEntity>> tagLists = CommonUtil.fixedGrouping(userMenusList, 10000);
int totalPage = (count % limit == 0) ? (count / limit) : (count / limit + 1); for (List<UserMenusEntity> tagList : tagLists) {
for (int i = 0; i < totalPage; i++) { //批量插入每次一万条
List<UserMenusEntity> userMenusEntities = new ArrayList<>(10000); sum += this.baseMapper.batchInsert(tagList);
//如果是最后一页,则截取到最后 }
if (i == totalPage - 1) { if (sum > 0) {
userMenusEntities = userMenusList.subList(i * limit, count); log.warn("新增成功记录=={}==条", sum);
} else { } else {
userMenusEntities = userMenusList.subList(i * limit, (i + 1) * limit); log.error("新增失败");
} }
//批量插入每次一万条
sum += this.baseMapper.batchInsert(userMenusEntities);
}
if (sum > 0) {
log.warn("新增成功记录=={}==条", sum);
} else {
log.error("新增失败");
} }
} catch (Exception e) {
e.printStackTrace();
log.error("新增用户标签失败{}", e.getMessage());
} }
} }
......
...@@ -22,10 +22,17 @@ ...@@ -22,10 +22,17 @@
<!-- 根据uid查询标签id--> <!-- 根据uid查询标签id-->
<select id="findIdByUserId" resultType="long"> <select id="findIdByUserId" resultType="long">
SELECT id FROM tb_user_menus WHERE is_valid = 1 AND user_id IN SELECT
um.id
FROM
( SELECT id, tags_id FROM tb_user_menus WHERE is_valid = 1 AND user_id IN
<foreach collection="list" item="item" index="index" separator="," open="(" close=")"> <foreach collection="list" item="item" index="index" separator="," open="(" close=")">
#{item} #{item}
</foreach> </foreach>
) um
LEFT JOIN tb_menu_tags mt ON um.tags_id = mt.id
WHERE
mt.is_custom = 0
</select> </select>
</mapper> </mapper>
\ No newline at end of file
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