1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34 package fr.paris.lutece.plugins.announce.modules.workflow.business;
35
36 import fr.paris.lutece.plugins.announce.modules.workflow.service.AnnounceWorkflowPlugin;
37 import fr.paris.lutece.plugins.workflowcore.business.config.ITaskConfigDAO;
38 import fr.paris.lutece.util.sql.DAOUtil;
39
40
41
42
43
44
45 public class TaskNotifyAnnounceConfigDAO implements ITaskConfigDAO<TaskNotifyAnnounceConfig>
46 {
47 private static final String SQL_QUERY_FIND_BY_PRIMARY_KEY = "SELECT id_task,sender_name,sender_email,subject,message,recipients_cc,recipients_bcc "
48 + "FROM workflow_task_notify_announce_cf WHERE id_task=?";
49 private static final String SQL_QUERY_INSERT = "INSERT INTO workflow_task_notify_announce_cf( "
50 + "id_task,sender_name,sender_email,subject,message,recipients_cc,recipients_bcc)" + "VALUES (?,?,?,?,?,?,?)";
51 private static final String SQL_QUERY_UPDATE = "UPDATE workflow_task_notify_announce_cf "
52 + " SET sender_name = ?, sender_email = ?, subject = ?, message = ?, recipients_cc = ?, recipients_bcc = ?" + " WHERE id_task = ? ";
53 private static final String SQL_QUERY_DELETE = "DELETE FROM workflow_task_notify_announce_cf WHERE id_task = ? ";
54
55
56
57
58 @Override
59 public synchronized void insert( TaskNotifyAnnounceConfig config )
60 {
61 DAOUtil daoUtil = new DAOUtil( SQL_QUERY_INSERT, AnnounceWorkflowPlugin.getPlugin( ) );
62
63 int nIndex = 1;
64
65 daoUtil.setInt( nIndex++, config.getIdTask( ) );
66 daoUtil.setString( nIndex++, config.getSenderName( ) );
67 daoUtil.setString( nIndex++, config.getSenderEmail( ) );
68 daoUtil.setString( nIndex++, config.getSubject( ) );
69 daoUtil.setString( nIndex++, config.getMessage( ) );
70 daoUtil.setString( nIndex++, config.getRecipientsCc( ) );
71 daoUtil.setString( nIndex, config.getRecipientsBcc( ) );
72
73 daoUtil.executeUpdate( );
74 daoUtil.free( );
75 }
76
77
78
79
80 @Override
81 public void store( TaskNotifyAnnounceConfig config )
82 {
83 DAOUtil daoUtil = new DAOUtil( SQL_QUERY_UPDATE, AnnounceWorkflowPlugin.getPlugin( ) );
84
85 int nIndex = 1;
86
87 daoUtil.setString( nIndex++, config.getSenderName( ) );
88 daoUtil.setString( nIndex++, config.getSenderEmail( ) );
89 daoUtil.setString( nIndex++, config.getSubject( ) );
90 daoUtil.setString( nIndex++, config.getMessage( ) );
91 daoUtil.setString( nIndex++, config.getRecipientsCc( ) );
92 daoUtil.setString( nIndex++, config.getRecipientsBcc( ) );
93
94 daoUtil.setInt( nIndex, config.getIdTask( ) );
95 daoUtil.executeUpdate( );
96 daoUtil.free( );
97 }
98
99
100
101
102 @Override
103 public TaskNotifyAnnounceConfig load( int nIdTask )
104 {
105 TaskNotifyAnnounceConfig config = null;
106 DAOUtil daoUtil = new DAOUtil( SQL_QUERY_FIND_BY_PRIMARY_KEY, AnnounceWorkflowPlugin.getPlugin( ) );
107
108 daoUtil.setInt( 1, nIdTask );
109
110 daoUtil.executeQuery( );
111
112 int nIndex = 1;
113
114 if ( daoUtil.next( ) )
115 {
116 config = new TaskNotifyAnnounceConfig( );
117 config.setIdTask( daoUtil.getInt( nIndex++ ) );
118 config.setSenderName( daoUtil.getString( nIndex++ ) );
119 config.setSenderEmail( daoUtil.getString( nIndex++ ) );
120 config.setSubject( daoUtil.getString( nIndex++ ) );
121 config.setMessage( daoUtil.getString( nIndex++ ) );
122 config.setRecipientsCc( daoUtil.getString( nIndex++ ) );
123 config.setRecipientsBcc( daoUtil.getString( nIndex ) );
124 }
125
126 daoUtil.free( );
127
128 return config;
129 }
130
131
132
133
134 @Override
135 public void delete( int nIdTask )
136 {
137 DAOUtil daoUtil = new DAOUtil( SQL_QUERY_DELETE, AnnounceWorkflowPlugin.getPlugin( ) );
138
139 daoUtil.setInt( 1, nIdTask );
140 daoUtil.executeUpdate( );
141 daoUtil.free( );
142 }
143 }