杜函宇 1 month ago
commit 621eaeee83

@ -53,7 +53,7 @@ public interface AssetAppCpMapper extends BaseMapper<AssetAppCpPo> {
* @param taskId id * @param taskId id
* @param btgyy * @param btgyy
*/ */
@Update("update asset_mini_programs_cp set btgyy=#{btgyy} where asset_id=#{assetId} and task_id =#{taskId} ") @Update("update asset_app_cp set btgyy=#{btgyy} where asset_id=#{assetId} and task_id =#{taskId} ")
void updateByAssetId(@Param("assetId") Integer assetId, @Param("taskId") Integer taskId, @Param("btgyy")String btgyy); void updateByAssetId(@Param("assetId") Integer assetId, @Param("taskId") Integer taskId, @Param("btgyy")String btgyy);

@ -45,7 +45,7 @@ public interface AssetEmailCpMapper extends BaseMapper<AssetEmailCpPo> {
* @param taskId id * @param taskId id
* @param btgyy * @param btgyy
*/ */
@Update("update asset_mini_programs_cp set btgyy=#{btgyy} where asset_id=#{assetId} and task_id =#{taskId} ") @Update("update asset_email_cp set btgyy=#{btgyy} where asset_id=#{assetId} and task_id =#{taskId} ")
void updateByAssetId(@Param("assetId") Integer assetId, @Param("taskId") Integer taskId, @Param("btgyy")String btgyy); void updateByAssetId(@Param("assetId") Integer assetId, @Param("taskId") Integer taskId, @Param("btgyy")String btgyy);
} }

@ -46,7 +46,7 @@ public interface AssetOfficialAccountCpMapper extends BaseMapper<AssetOfficialAc
* @param taskId id * @param taskId id
* @param btgyy * @param btgyy
*/ */
@Update("update asset_mini_programs_cp set btgyy=#{btgyy} where asset_id=#{assetId} and task_id =#{taskId} ") @Update("update asset_official_account_cp set btgyy=#{btgyy} where asset_id=#{assetId} and task_id =#{taskId} ")
void updateByAssetId(@Param("assetId") Integer assetId, @Param("taskId") Integer taskId, @Param("btgyy")String btgyy); void updateByAssetId(@Param("assetId") Integer assetId, @Param("taskId") Integer taskId, @Param("btgyy")String btgyy);
} }

@ -250,7 +250,8 @@ public class AssetTaskServiceImpl extends ServiceImpl<AssetTaskMapper, AssetTask
QueryWrapper<AssetMiniPrograms> queryWrapper = new QueryWrapper<>(); QueryWrapper<AssetMiniPrograms> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("ssdw", part); queryWrapper.eq("ssdw", part);
queryWrapper.eq("isbf", 0); queryWrapper.eq("isbf", 0);
List<AssetMiniPrograms> list = assetMiniProgramsService.list(queryWrapper); queryWrapper.eq("del_flag", 0);
List<AssetMiniPrograms> list = assetMiniProgramsService.lambdaQuery().eq(AssetMiniPrograms::getSsdw, part).eq(AssetMiniPrograms::getIsbf,0).eq(AssetMiniPrograms::getDelFlag,0).list();
List<AssetMiniProgramsCpPo> miniProgramsNewList = list.stream() List<AssetMiniProgramsCpPo> miniProgramsNewList = list.stream()
.map(cpPo -> { .map(cpPo -> {
AssetMiniProgramsCpPo assetMiniProgramsCpPo = new AssetMiniProgramsCpPo(); AssetMiniProgramsCpPo assetMiniProgramsCpPo = new AssetMiniProgramsCpPo();
@ -271,7 +272,8 @@ public class AssetTaskServiceImpl extends ServiceImpl<AssetTaskMapper, AssetTask
QueryWrapper<AssetOfficialAccount> queryWrapper = new QueryWrapper<>(); QueryWrapper<AssetOfficialAccount> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("ssdw", part); queryWrapper.eq("ssdw", part);
queryWrapper.eq("isbf", 0); queryWrapper.eq("isbf", 0);
List<AssetOfficialAccount> list = assetOfficialAccountService.list(queryWrapper); queryWrapper.eq("del_flag", 0);
List<AssetOfficialAccount> list = assetOfficialAccountService.lambdaQuery().eq(AssetOfficialAccount::getSsdw, part).eq(AssetOfficialAccount::getIsbf,0).eq(AssetOfficialAccount::getDelFlag,0).list();
List<AssetOfficialAccountCpPo> officialAccountProgramsNewList = list.stream() List<AssetOfficialAccountCpPo> officialAccountProgramsNewList = list.stream()
.map(cpPo -> { .map(cpPo -> {
AssetOfficialAccountCpPo assetOfficialAccountCpPo = new AssetOfficialAccountCpPo(); AssetOfficialAccountCpPo assetOfficialAccountCpPo = new AssetOfficialAccountCpPo();
@ -292,7 +294,8 @@ public class AssetTaskServiceImpl extends ServiceImpl<AssetTaskMapper, AssetTask
QueryWrapper<AssetEmail> queryWrapper = new QueryWrapper<>(); QueryWrapper<AssetEmail> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("ssdw", part); queryWrapper.eq("ssdw", part);
queryWrapper.eq("isbf", 0); queryWrapper.eq("isbf", 0);
List<AssetEmail> list = assetEmailService.list(queryWrapper); queryWrapper.eq("del_flag", 0);
List<AssetEmail> list = assetEmailService.lambdaQuery().eq(AssetEmail::getSsdw, part).eq(AssetEmail::getIsbf,0).eq(AssetEmail::getDelFlag,0).list();;
List<AssetEmailCpPo> emailCpNewList = list.stream() List<AssetEmailCpPo> emailCpNewList = list.stream()
.map(cpPo -> { .map(cpPo -> {
AssetEmailCpPo emailCpPo = new AssetEmailCpPo(); AssetEmailCpPo emailCpPo = new AssetEmailCpPo();
@ -313,7 +316,8 @@ public class AssetTaskServiceImpl extends ServiceImpl<AssetTaskMapper, AssetTask
QueryWrapper<AssetApp> queryWrapper = new QueryWrapper<>(); QueryWrapper<AssetApp> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("ssdw", part); queryWrapper.eq("ssdw", part);
queryWrapper.eq("isbf", 0); queryWrapper.eq("isbf", 0);
List<AssetApp> list = assetAppService.list(queryWrapper); queryWrapper.eq("del_flag", 0);
List<AssetApp> list = assetAppService.lambdaQuery().eq(AssetApp::getSsdw, part).eq(AssetApp::getIsbf,0).eq(AssetApp::getDelFlag,0).list();
List<AssetAppCpPo> appCpNewList = list.stream() List<AssetAppCpPo> appCpNewList = list.stream()
.map(cpPo -> { .map(cpPo -> {
AssetAppCpPo appCpPo = new AssetAppCpPo(); AssetAppCpPo appCpPo = new AssetAppCpPo();
@ -554,7 +558,7 @@ public class AssetTaskServiceImpl extends ServiceImpl<AssetTaskMapper, AssetTask
assetEmailService.deleteIdList(emailidList); assetEmailService.deleteIdList(emailidList);
} }
//将子表数据复制到主表中 //将子表数据复制到主表中
List<AssetEmail> emailNewList = appList.stream() List<AssetEmail> emailNewList = emailCpPoListList.stream()
.map(cpPo -> { .map(cpPo -> {
AssetEmail current = new AssetEmail(); AssetEmail current = new AssetEmail();
BeanUtils.copyProperties(cpPo, current); // 复制属性 BeanUtils.copyProperties(cpPo, current); // 复制属性
@ -572,7 +576,7 @@ public class AssetTaskServiceImpl extends ServiceImpl<AssetTaskMapper, AssetTask
assetMiniProgramsService.deleteIdList(miniidList); assetMiniProgramsService.deleteIdList(miniidList);
} }
//将子表数据复制到主表中 //将子表数据复制到主表中
List<AssetMiniPrograms> miniNewList = appList.stream() List<AssetMiniPrograms> miniNewList = miniProgramsCpPoListList.stream()
.map(cpPo -> { .map(cpPo -> {
AssetMiniPrograms current = new AssetMiniPrograms(); AssetMiniPrograms current = new AssetMiniPrograms();
BeanUtils.copyProperties(cpPo, current); // 复制属性 BeanUtils.copyProperties(cpPo, current); // 复制属性
@ -591,7 +595,7 @@ public class AssetTaskServiceImpl extends ServiceImpl<AssetTaskMapper, AssetTask
assetOfficialAccountService.deleteIdList(officialidList); assetOfficialAccountService.deleteIdList(officialidList);
} }
//将子表数据复制到主表中 //将子表数据复制到主表中
List<AssetOfficialAccount> officialNewList = appList.stream() List<AssetOfficialAccount> officialNewList = officialAccountCpPoListList.stream()
.map(cpPo -> { .map(cpPo -> {
AssetOfficialAccount current = new AssetOfficialAccount(); AssetOfficialAccount current = new AssetOfficialAccount();
BeanUtils.copyProperties(cpPo, current); // 复制属性 BeanUtils.copyProperties(cpPo, current); // 复制属性

@ -36,7 +36,7 @@
<select id="findBydwmc" resultType="java.lang.Integer" parameterType="java.lang.String"> <select id="findBydwmc" resultType="java.lang.Integer" parameterType="java.lang.String">
select count(*) select count(*)
from asset_app from asset_app
where ssdw = #{part} and isbf=0 where ssdw = #{part} and isbf=0 and del_flag=0
</select> </select>
</mapper> </mapper>

@ -462,6 +462,6 @@
select count(*) select count(*)
from asset_current from asset_current
where dwmc = #{part} and isbf=0 where dwmc = #{part} and isbf=0 and del_flag=0
</select> </select>
</mapper> </mapper>

@ -36,7 +36,7 @@
<select id="findBydwmc" resultType="java.lang.Integer" parameterType="java.lang.String"> <select id="findBydwmc" resultType="java.lang.Integer" parameterType="java.lang.String">
select count(*) select count(*)
from asset_email from asset_email
where ssdw = #{part} and isbf=0 where ssdw = #{part} and isbf=0 and del_flag=0
</select> </select>
</mapper> </mapper>

@ -37,7 +37,7 @@
<select id="findBydwmc" resultType="java.lang.Integer" parameterType="java.lang.String"> <select id="findBydwmc" resultType="java.lang.Integer" parameterType="java.lang.String">
select count(*) select count(*)
from asset_mini_programs from asset_mini_programs
where ssdw = #{part} and isbf=0 where ssdw = #{part} and isbf=0 and del_flag=0
</select> </select>
</mapper> </mapper>

@ -16,7 +16,7 @@
<select id="findBydwmc" resultType="java.lang.Integer" parameterType="java.lang.String"> <select id="findBydwmc" resultType="java.lang.Integer" parameterType="java.lang.String">
select count(*) select count(*)
from asset_official_account from asset_official_account
where ssdw = #{part} and isbf=0 where ssdw = #{part} and isbf=0 and del_flag=0
</select> </select>
<select id="page" resultType="com.ruoyi.tc.entity.AssetOfficialAccount"> <select id="page" resultType="com.ruoyi.tc.entity.AssetOfficialAccount">
select * from asset_official_account select * from asset_official_account

@ -148,8 +148,29 @@
FROM asset_task b FROM asset_task b
where where
b.task_status = 1 AND FIND_IN_SET(a.nick_name, b.dwmc) b.task_status = 1 AND FIND_IN_SET(a.nick_name, b.dwmc)
AND FIND_IN_SET(#{req.type}, b.type) <if test="req.type != null">
) AND a.del_flag = '0' AND (
<foreach item="type" collection="req.type.split(',')" separator=" OR ">
FIND_IN_SET(#{type}, b.type)
</foreach>
)
</if>
) AND a.del_flag = 0
<if test="req.type!= null and req.type.indexOf('0') != -1">
and cr.del_flag=0
</if>
<if test="req.type!= null and req.type.indexOf('1') != -1">
and pr.del_flag=0
</if>
<if test="req.type!= null and req.type.indexOf('2') != -1">
and ac.del_flag=0
</if>
<if test="req.type!= null and req.type.indexOf('3') != -1">
and em.del_flag=0
</if>
<if test="req.type!= null and req.type.indexOf('4') != -1">
and ap.del_flag=0
</if>
<if test="req.nickName != null and req.nickName != '' "> <if test="req.nickName != null and req.nickName != '' ">
and a.nick_name like concat('%',#{req.nickName},'%') and a.nick_name like concat('%',#{req.nickName},'%')

@ -115,7 +115,7 @@ public class SecurityConfig
// 静态资源,可匿名访问 // 静态资源,可匿名访问
.antMatchers(HttpMethod.GET, "/", "/*.html", "/**/*.html", "/**/*.css", "/**/*.js", "/profile/**").permitAll() .antMatchers(HttpMethod.GET, "/", "/*.html", "/**/*.html", "/**/*.css", "/**/*.js", "/profile/**").permitAll()
.antMatchers("/swagger-ui.html", "/swagger-resources/**", "/webjars/**", "/*/api-docs", "/druid/**").permitAll() .antMatchers("/swagger-ui.html", "/swagger-resources/**", "/webjars/**", "/*/api-docs", "/druid/**").permitAll()
// .antMatchers("/unit/assetTask/**","/tc/**","/unit/assetLc/**","/tc/unit/**").permitAll() .antMatchers("/unit/assetTask/**","/tc/**","/unit/assetLc/**","/tc/unit/**").permitAll()
// 除上面外的所有请求全部需要鉴权认证 // 除上面外的所有请求全部需要鉴权认证
.antMatchers("/tc/without/**").permitAll() .antMatchers("/tc/without/**").permitAll()
.anyRequest().authenticated(); .anyRequest().authenticated();

Loading…
Cancel
Save