| 提交 | 用户 | age | ||
| 385e2d | 1 | package com.yc.crm.mail.service; |
| X | 2 | |
| 3 | import com.yc.action.grid.GridUtils; | |
| 4 | import com.yc.crm.mail.entity.T482106Entity; | |
| 5 | import com.yc.service.BaseService; | |
| 6 | import org.apache.commons.lang3.StringUtils; | |
| 7 | import org.springframework.jdbc.core.BeanPropertyRowMapper; | |
| 8 | import org.springframework.stereotype.Service; | |
| 9 | ||
| 10 | import java.util.List; | |
| 11 | ||
| 12 | /** | |
| 13 | * @BelongsProject: eCoWorksV3 | |
| 14 | * @BelongsPackage: com.yc.crm.mail.service | |
| 15 | * @author: xinyb | |
| 16 | * @CreateTime: 2024-08-19 15:37 | |
| 17 | * @Description:黑名单持久层 | |
| 18 | */ | |
| 19 | @Service | |
| 20 | public class MailBlackListImpl extends BaseService implements MailBlackListIfc { | |
| 21 | @Override | |
| 22 | public void saveBlackList(T482106Entity black) { | |
| 23 | String sql = "set nocount on\n"; | |
| 24 | try { | |
| f5cc47 | 25 | sql += "insert into t482106(companyId,companyName,black_content,userCode,userName,create_time,update_time,black_type) values " + |
| X | 26 | "(" + GridUtils.prossSqlParm(black.getCompanyId()) + "," + GridUtils.prossSqlParm(black.getCompanyName()) + "," + |
| 27 | GridUtils.prossSqlParm(black.getBlackContent())+","+GridUtils.prossSqlParm(black.getUserCode()) + "," + | |
| 28 | GridUtils.prossSqlParm(black.getUserName()) + ",getdate(),getdate(),'" + black.isBlackType() + "')"; | |
| 385e2d | 29 | jdbcTemplate.update(sql); |
| X | 30 | } catch (Exception e) { |
| 31 | throw e; | |
| 32 | } | |
| 33 | } | |
| 34 | ||
| 35 | @Override | |
| 36 | public Integer updateBlackList(T482106Entity black) { | |
| 37 | String sql = "set nocount on \n"; | |
| 38 | try { | |
| f5cc47 | 39 | sql += "update t482106 set black_content=" + GridUtils.prossSqlParm(black.getBlackContent()) + ",black_type='" + black.isBlackType() + "'," + |
| X | 40 | "update_time=getdate() where black_id=" + black.getBlackId() + " and userCode=" + GridUtils.prossSqlParm(black.getUserCode()) + "\n"; |
| 385e2d | 41 | sql += "select @@ROWCOUNT"; |
| f5cc47 | 42 | return jdbcTemplate.queryForObject(sql, Integer.class); |
| 385e2d | 43 | } catch (Exception e) { |
| X | 44 | throw e; |
| 45 | } | |
| 46 | } | |
| 47 | ||
| 48 | @Override | |
| f5cc47 | 49 | public Integer deleteBlackList(String userCode,Integer blackId) { |
| 385e2d | 50 | String sql = "set nocount on \n"; |
| X | 51 | try { |
| 428443 | 52 | sql += "delete t482106 where black_id=" + blackId + " and userCode='" + userCode + "'\n"; |
| 385e2d | 53 | sql += "select @@ROWCOUNT"; |
| f5cc47 | 54 | return jdbcTemplate.queryForObject(sql, Integer.class); |
| 385e2d | 55 | } catch (Exception e) { |
| X | 56 | throw e; |
| 57 | } | |
| 58 | } | |
| 59 | ||
| 60 | @Override | |
| f5cc47 | 61 | public List<T482106Entity> getBlackList(String userCode,String search) { |
| 385e2d | 62 | String sql = "set nocount on \n"; |
| X | 63 | try { |
| f5cc47 | 64 | sql += "select companyId,companyName,black_id,black_content,userCode,userName,create_time,update_time,black_type,DocVersion " + |
| X | 65 | "from t482106 where userCode="+GridUtils.prossSqlParm(userCode); |
| 66 | if (StringUtils.isNotBlank(search)) { | |
| 67 | sql += " and black_content like '%" + search+"%'"; | |
| 385e2d | 68 | } |
| f5cc47 | 69 | sql += "order by black_id \n"; |
| 385e2d | 70 | return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(T482106Entity.class)); |
| X | 71 | } catch (Exception e) { |
| 72 | throw e; | |
| 73 | } | |
| 74 | } | |
| 75 | } | |
