Compare commits

...
6 Commits
Author SHA1 Message Date
pvincent b14688417d tagged as 1.10.1 2021-08-28 16:41:12 +04:00
pvincent ea4da3c270 reply-to working 2021-08-28 16:40:37 +04:00
pvincent ef7b09454c cagettepéi 2021-08-28 11:05:37 +04:00
pvincent c23e3533d8 reply-to missing yet 2021-08-28 01:16:54 +04:00
pvincent 88b2549243 tagged as 1.10.0 2021-08-27 22:04:15 +04:00
pvincent a1ece5258a sendemail is working 2021-08-27 22:03:50 +04:00
18 changed files with 1005 additions and 978 deletions
+1 -1
View File
@@ -1 +1 @@
1.9.0 1.10.1
+2 -2
View File
@@ -41,7 +41,7 @@ install_dev:
#compile backend to Neko #compile backend to Neko
compile: compile:
@if [ $(PLUGINS) = 1 ]; then \ @if [ $(PLUGINS) = 1 ]; then \
echo "compile Cagette.net with plugins"; \ echo "compile CagettePéi plugins"; \
haxe cagetteAllPlugins.hxml; \ haxe cagetteAllPlugins.hxml; \
else \ else \
echo "compile CagettePéi core"; \ echo "compile CagettePéi core"; \
@@ -74,7 +74,7 @@ templates:
@make LANG=fr ctemplates @make LANG=fr ctemplates
msgfmt www/lang/texts_fr.po -o www/lang/texts_fr.mo msgfmt www/lang/texts_fr.po -o www/lang/texts_fr.mo
chown www-data:www-data -R www chown www-data:www-data -R www
chown www-data:www-data -R lang chown www-data:www-data -R lang/fr
ctemplates: ctemplates:
(cd lang/$(LANG)/tpl; temploc2 -macros macros.mtt -output ../tmp/ *.mtt */*.mtt */*/*.mtt) (cd lang/$(LANG)/tpl; temploc2 -macros macros.mtt -output ../tmp/ *.mtt */*.mtt */*/*.mtt)
+1
View File
@@ -21,6 +21,7 @@
-lib tink_streams:0.2.1 -lib tink_streams:0.2.1
-lib tink_syntaxhub:0.4.3 -lib tink_syntaxhub:0.4.3
-lib tink_typecrawler:0.7.0 -lib tink_typecrawler:0.7.0
-lib thx.text:0.2.1
## GIT ## GIT
# -lib sugoi:git:https://git.artcode.re/cagetters/sugoi.git # -lib sugoi:git:https://git.artcode.re/cagetters/sugoi.git
+34 -38
View File
@@ -1,4 +1,5 @@
package react.user; package react.user;
import react.ReactComponent; import react.ReactComponent;
import react.ReactMacro.jsx; import react.ReactMacro.jsx;
import Common; import Common;
@@ -19,23 +20,21 @@ typedef LoginBoxState = {
* Login Box * Login Box
* @author fbarbut * @author fbarbut
*/ */
class LoginBox extends react.ReactComponentOfPropsAndState<LoginBoxProps,LoginBoxState> class LoginBox extends react.ReactComponentOfPropsAndState<LoginBoxProps, LoginBoxState> {
{ public function new(props:LoginBoxProps) {
if (props.redirectUrl == null)
public function new(props:LoginBoxProps) props.redirectUrl = "/";
{ if (props.message == "")
if (props.redirectUrl == null) props.redirectUrl = "/"; props.message = null;
if (props.message == "") props.message = null;
super(props); super(props);
this.state = {email:"", password:"", error:null}; this.state = {email: "", password: "", error: null};
} }
function setError(err:String){ function setError(err:String) {
this.setState(cast {error:err}); this.setState(cast {error: err});
} }
override public function render(){ override public function render() {
return jsx('<div onKeyPress=$onKeyPress> return jsx('<div onKeyPress=$onKeyPress>
<$Error error="${state.error}" /> <$Error error="${state.error}" />
<$Message message="${props.message}" /> <$Message message="${props.message}" />
@@ -62,7 +61,7 @@ class LoginBox extends react.ReactComponentOfPropsAndState<LoginBoxProps,LoginBo
<!-- <!--
<hr/> <hr/>
<p className="text-center"> <p className="text-center">
<b>C\'est votre première visite sur Cagette.net ?</b>&nbsp;&nbsp; <b>C\'est votre première visite sur CagettePéi ?</b>&nbsp;&nbsp;
<a onClick={registerBox} className="btn btn-default"><span className="glyphicon glyphicon-chevron-right"></span> S\'inscrire</a> <a onClick={registerBox} className="btn btn-default"><span className="glyphicon glyphicon-chevron-right"></span> S\'inscrire</a>
</p> </p>
--> -->
@@ -72,11 +71,11 @@ class LoginBox extends react.ReactComponentOfPropsAndState<LoginBoxProps,LoginBo
/** /**
* @doc https://facebook.github.io/react/docs/forms.html * @doc https://facebook.github.io/react/docs/forms.html
*/ */
function onChange(e:js.html.Event){ function onChange(e:js.html.Event) {
e.preventDefault(); e.preventDefault();
var name :String = untyped e.target.name; var name:String = untyped e.target.name;
var value :String = untyped /*(e.target.value == "") ? null :*/ e.target.value; var value:String = untyped /*(e.target.value == "") ? null :*/ e.target.value;
Reflect.setField(state, name, value); Reflect.setField(state, name, value);
this.setState(this.state); this.setState(this.state);
} }
@@ -84,56 +83,53 @@ class LoginBox extends react.ReactComponentOfPropsAndState<LoginBoxProps,LoginBo
/** /**
* displays a registerBox * displays a registerBox
*/ */
public function registerBox(){ public function registerBox() {
var body = js.Browser.document.querySelector('#myModal .modal-body'); var body = js.Browser.document.querySelector('#myModal .modal-body');
ReactDOM.unmountComponentAtNode( body ); ReactDOM.unmountComponentAtNode(body);
js.Browser.document.querySelector("#myModal .modal-title").innerHTML = "Inscription"; js.Browser.document.querySelector("#myModal .modal-title").innerHTML = "Inscription";
ReactDOM.render(jsx('<$RegisterBox redirectUrl="${props.redirectUrl}" phoneRequired="${props.phoneRequired}"/>'), body ); ReactDOM.render(jsx('<$RegisterBox redirectUrl="${props.redirectUrl}" phoneRequired="${props.phoneRequired}"/>'), body);
} }
public function submit(?e:js.html.Event){ public function submit(?e:js.html.Event) {
if (state.email == "") {
if (state.email == ""){
setError("Veuillez saisir votre email"); setError("Veuillez saisir votre email");
return; return;
} }
if (state.password == ""){ if (state.password == "") {
setError("Veuillez saisir votre mot de passe"); setError("Veuillez saisir votre mot de passe");
return; return;
} }
//lock button // lock button
var el: js.html.Element = null; var el:js.html.Element = null;
if(e!=null){ if (e != null) {
el = cast e.target; el = cast e.target;
el.classList.add("disabled"); el.classList.add("disabled");
} }
var req = new haxe.Http("/api/user/login"); var req = new haxe.Http("/api/user/login");
req.addParameter("email", state.email); req.addParameter("email", state.email);
req.addParameter("password", state.password); req.addParameter("password", state.password);
req.addParameter("redirecturl", props.redirectUrl); req.addParameter("redirecturl", props.redirectUrl);
req.onData = req.onError = function(d){ req.onData = req.onError = function(d) {
var d = req.responseData; var d = req.responseData;
if(e!=null) el.classList.remove("disabled"); if (e != null)
el.classList.remove("disabled");
var d = haxe.Json.parse(d); var d = haxe.Json.parse(d);
if (Reflect.hasField(d, "error")) setError(d.error.message); if (Reflect.hasField(d, "error"))
if (Reflect.hasField(d, "success")) js.Browser.window.location.href = props.redirectUrl; setError(d.error.message);
if (Reflect.hasField(d, "success"))
js.Browser.window.location.href = props.redirectUrl;
} }
req.request(true); req.request(true);
} }
function onKeyPress(e:js.html.KeyboardEvent){ function onKeyPress(e:js.html.KeyboardEvent) {
if(e.key=="Enter") submit(); if (e.key == "Enter")
submit();
} }
} }
+1 -1
View File
@@ -11,7 +11,7 @@
::end:: ::end::
</title> </title>
<!-- Cagette CSS --> <!-- CagettePéi CSS -->
<link rel="stylesheet" type="text/css" href="/css/::getVariable('css')::/style.css"/> <link rel="stylesheet" type="text/css" href="/css/::getVariable('css')::/style.css"/>
<!-- <!--
<link rel="stylesheet" type="text/css" href="/css/::getVariable('css')::/shop.css"/> <link rel="stylesheet" type="text/css" href="/css/::getVariable('css')::/shop.css"/>
+2 -2
View File
@@ -14,7 +14,7 @@
<h1>::groupName::</h1> <h1>::groupName::</h1>
::else:: ::else::
<div style="margin-bottom:22px;" > <div style="margin-bottom:22px;" >
<a href="https://git.artcode.re/cagetters/cagette" target="_blank"> <a href="https://git.artcode.re/cagetters/cagettepei" target="_blank">
<img src="/img/logo3.png" alt="::NAME::" /> <img src="/img/logo3.png" alt="::NAME::" />
</a> </a>
</div> </div>
@@ -121,7 +121,7 @@
<!--<div class="row"> <!--<div class="row">
<div class="col-md-12 alert-danger text-center" style="border-radius: 8px;margin:8px 0;padding:8px 0;"> <div class="col-md-12 alert-danger text-center" style="border-radius: 8px;margin:8px 0;padding:8px 0;">
<span class="glyphicon glyphicon-cog"></span> <span class="glyphicon glyphicon-cog"></span>
Attention : Cagette.net sera indisponible le <b>mardi 7 août de 9:00 à 11:00</b>. Attention : CagettePéi sera indisponible le <b>mardi 7 août de 9:00 à 11:00</b>.
<br/> <br/>
Nous déménageons sur un nouveau serveur pour plus de rapidité et de fiabilité. Nous déménageons sur un nouveau serveur pour plus de rapidité et de fiabilité.
</div> </div>
+1 -1
View File
@@ -47,5 +47,5 @@
"bugs": { "bugs": {
"url": "https://github.com/bablukid/cagette/issues" "url": "https://github.com/bablukid/cagette/issues"
}, },
"version": "1.9.0" "version": "1.10.1"
} }
+34 -21
View File
@@ -77,10 +77,14 @@ class App extends sugoi.BaseApp {
} }
public static function log(t:Dynamic, ?infos:haxe.PosInfos) { public static function log(t:Dynamic, ?infos:haxe.PosInfos) {
// if (App.config.DEBUG) { var message:String = '[${infos.fileName}:${infos.lineNumber} ${infos.className}#${infos.methodName}] ';
// neko.Web.logMessage(Std.string(t)); // write in Apache error log message += Std.string(t);
// }
neko.Web.logMessage('[${infos.fileName}:${infos.lineNumber} ${infos.className}#${infos.methodName}] ' + Std.string(t)); // trace(message);
if (neko.Web.isModNeko)
neko.Web.logMessage(message);
else
Sys.println(message);
} }
public function event(e:Event) { public function event(e:Event) {
@@ -230,24 +234,34 @@ class App extends sugoi.BaseApp {
} }
public static function getMailer():sugoi.mail.IMailer { public static function getMailer():sugoi.mail.IMailer {
var mailer:sugoi.mail.IMailer = new sugoi.mail.BufferedMailer(); var typeOfMailer = sugoi.db.Variable.get("mailer");
App.log('type of mailer is <$typeOfMailer>');
if (typeOfMailer == null) {
var msg = sugoi.i18n.Locale.texts._("Please configure the email settings in a <href='/admin/emails'>this section</a>");
throw sugoi.ControllerAction.ErrorAction("/", msg);
}
if (App.config.DEBUG) { if (App.config.DEBUG) {
App.log("DEBUGEmailer enabled => emails are written to tmp folder"); App.log('mailer in DEBUG mode, no deferred mail from CRON');
mailer = new sugoi.mail.DebugMailer();
} else {
if (sugoi.db.Variable.get("mailer") == null) {
var msg = sugoi.i18n.Locale.texts._("Please configure the email settings in a <href='/admin/emails'>this section</a>");
throw sugoi.ControllerAction.ErrorAction("/", msg);
}
if (sugoi.db.Variable.get("mailer") == "mandrill") { var conf = {
// Buffered emails with Mandrill smtp_host: sugoi.db.Variable.get("smtp_host"),
untyped mailer.defineFinalMailer("mandrill"); smtp_port: sugoi.db.Variable.getInt("smtp_port"),
} else { smtp_user: sugoi.db.Variable.get("smtp_user"),
// Buffered emails with SMTP smtp_pass: sugoi.db.Variable.get("smtp_pass")
untyped mailer.defineFinalMailer("smtp"); };
}
return new sugoi.mail.SendEmailMailer().init(conf);
}
var mailer:sugoi.mail.IMailer = new sugoi.mail.BufferedMailer();
if (sugoi.db.Variable.get("mailer") == "mandrill") {
// Buffered emails with Mandrill
untyped mailer.defineFinalMailer("mandrill");
} else {
// Buffered emails with SMTP
untyped mailer.defineFinalMailer("smtp");
} }
return mailer; return mailer;
} }
@@ -265,7 +279,6 @@ class App extends sugoi.BaseApp {
App.log('about to send email with subject=<${m.getSubject()}> ...'); App.log('about to send email with subject=<${m.getSubject()}> ...');
getMailer().send(m, params, function(o) {}); getMailer().send(m, params, function(o) {});
App.log('email from=<${m.getSender().email}>, subject=<${m.getSubject()}> successfully sent');
} }
public static function quickMail(to:String, subject:String, html:String, ?group:db.Amap) { public static function quickMail(to:String, subject:String, html:String, ?group:db.Amap) {
@@ -274,7 +287,7 @@ class App extends sugoi.BaseApp {
var e = new sugoi.mail.Mail(); var e = new sugoi.mail.Mail();
e.setSubject(subject); e.setSubject(subject);
e.setRecipient(to); e.setRecipient(to);
e.setSender(App.config.get("default_email"), "Cagette.net"); e.setSender(App.config.get("default_email"), t._("Cagette.net"));
var html = App.current.processTemplate("mail/message.mtt", {text: html, group: group}); var html = App.current.processTemplate("mail/message.mtt", {text: html, group: group});
e.setHtmlBody(html); e.setHtmlBody(html);
App.sendMail(e); App.sendMail(e);
+3 -5
View File
@@ -77,7 +77,7 @@ class Cron extends Controller {
} }
var m = new Mail(); var m = new Mail();
m.setSender(App.config.get("default_email"), "Cagette.net"); m.setSender(App.config.get("default_email"), t._("Cagette.net"));
m.addRecipient(App.config.get("webmaster_email")); m.addRecipient(App.config.get("webmaster_email"));
m.setSubject(App.config.NAME + " Errors"); m.setSubject(App.config.NAME + " Errors");
m.setHtmlBody(app.processTemplate("mail/message.mtt", {text: report.toString()})); m.setHtmlBody(app.processTemplate("mail/message.mtt", {text: report.toString()}));
@@ -306,7 +306,7 @@ class Cron extends Controller {
try { try {
var m = new Mail(); var m = new Mail();
m.setSender(App.config.get("default_email"), "Cagette.net"); m.setSender(App.config.get("default_email"), t._("Cagette.net"));
if (group.contact != null) if (group.contact != null)
m.setReplyTo(group.contact.email, group.name); m.setReplyTo(group.contact.email, group.name);
m.addRecipient(u.user.email, u.user.getName()); m.addRecipient(u.user.email, u.user.getName());
@@ -444,7 +444,6 @@ class Cron extends Controller {
*/ */
function sendEmailsfromBuffer() { function sendEmailsfromBuffer() {
App.log("Send Emails from Buffer"); App.log("Send Emails from Buffer");
print("<h3>Send Emails from Buffer</h3>");
// send // send
for (e in sugoi.db.BufferedMail.manager.search($sdate == null, {limit: 50, orderBy: -cdate}, false)) { for (e in sugoi.db.BufferedMail.manager.search($sdate == null, {limit: 50, orderBy: -cdate}, false)) {
@@ -452,8 +451,7 @@ class Cron extends Controller {
if (e.isSent()) if (e.isSent())
continue; continue;
App.log('Send Email id=${e.id} - title=${e.title}'); App.log('Send Email id=#${e.id} - title=${e.title}');
print('#${e.id} - ${e.title}');
e.finallySend(); e.finallySend();
Sys.sleep(0.1); Sys.sleep(0.1);
} }
+285 -281
View File
@@ -1,4 +1,5 @@
package controller; package controller;
import Common; import Common;
import haxe.Utf8; import haxe.Utf8;
import sugoi.form.Form; import sugoi.form.Form;
@@ -6,111 +7,114 @@ import sugoi.form.elements.Selectbox;
import sugoi.form.validators.EmailValidator; import sugoi.form.validators.EmailValidator;
import sugoi.tools.Utils; import sugoi.tools.Utils;
class Member extends Controller {
class Member extends Controller public function new() {
{
public function new()
{
super(); super();
if (!app.user.canAccessMembership()) throw Redirect("/"); if (!app.user.canAccessMembership())
throw Redirect("/");
} }
@logged @logged
@tpl('member/default.mtt') @tpl('member/default.mtt')
function doDefault(?args: { ?search:String, ?select:String } ) { function doDefault(?args:{?search:String, ?select:String}) {
checkToken(); checkToken();
var browse:Int->Int->List<Dynamic>; var browse:Int->Int->List<Dynamic>;
var uids = db.UserAmap.manager.search($amap == app.user.getAmap(), false); var uids = db.UserAmap.manager.search($amap == app.user.getAmap(), false);
var uids = Lambda.map(uids, function(ua) return ua.user.id); var uids = Lambda.map(uids, function(ua) return ua.user.id);
if (args != null && args.search != null) { if (args != null && args.search != null) {
// SEARCH
//SEARCH
browse = function(index:Int, limit:Int) { browse = function(index:Int, limit:Int) {
var search = "%"+StringTools.trim(args.search)+"%"; var search = "%" + StringTools.trim(args.search) + "%";
return db.User.manager.search( return db.User.manager.search(($lastName.like(search) || $lastName2.like(search) || $address1.like(search) || $address2.like(search)
($lastName.like(search) || || $firstName.like(search) || $firstName2.like(search))
$lastName2.like(search) || && $id in uids,
$address1.like(search) || {
$address2.like(search) || orderBy: -id
$firstName.like(search) || }, false);
$firstName2.like(search)
) && $id in uids , { orderBy:-id }, false);
} }
view.search = args.search; view.search = args.search;
} else if (args != null && args.select != null) {
// SELECTION
}else if(args!=null && args.select!=null){ switch (args.select) {
//SELECTION
switch(args.select) {
case "nocontract": case "nocontract":
if (app.params.exists("csv")) { if (app.params.exists("csv")) {
sugoi.tools.Csv.printCsvDataFromObjects(Lambda.array(db.User.getUsers_NoContracts()), ["firstName", "lastName", "email"], t._("Without contracts")); sugoi.tools.Csv.printCsvDataFromObjects(Lambda.array(db.User.getUsers_NoContracts()), ["firstName", "lastName", "email"],
t._("Without contracts"));
return; return;
}else { } else {
browse = function(index:Int, limit:Int) { return db.User.getUsers_NoContracts(index, limit); } browse = function(index:Int, limit:Int) {
return db.User.getUsers_NoContracts(index, limit);
}
} }
case "contract": case "contract":
if (app.params.exists("csv")) { if (app.params.exists("csv")) {
sugoi.tools.Csv.printCsvDataFromObjects(Lambda.array(db.User.getUsers_Contracts()), ["firstName", "lastName", "email"], t._("With orders")); sugoi.tools.Csv.printCsvDataFromObjects(Lambda.array(db.User.getUsers_Contracts()), ["firstName", "lastName", "email"],
t._("With orders"));
return; return;
}else { } else {
browse = function(index:Int, limit:Int) { return db.User.getUsers_Contracts(index, limit); } browse = function(index:Int, limit:Int) {
return db.User.getUsers_Contracts(index, limit);
}
} }
case "nomembership" : case "nomembership":
if (app.params.exists("csv")) { if (app.params.exists("csv")) {
sugoi.tools.Csv.printCsvDataFromObjects(Lambda.array(db.User.getUsers_NoMembership()), ["firstName", "lastName", "email"], t._("Memberships to be renewed")); sugoi.tools.Csv.printCsvDataFromObjects(Lambda.array(db.User.getUsers_NoMembership()), ["firstName", "lastName", "email"],
t._("Memberships to be renewed"));
return; return;
}else { } else {
browse = function(index:Int, limit:Int) { return db.User.getUsers_NoMembership(index, limit); } browse = function(index:Int, limit:Int) {
return db.User.getUsers_NoMembership(index, limit);
}
} }
case "newusers" : case "newusers":
if (app.params.exists("csv")) { if (app.params.exists("csv")) {
sugoi.tools.Csv.printCsvDataFromObjects(Lambda.array(db.User.getUsers_NewUsers()), ["firstName", "lastName", "email"], t._("Never connected")); sugoi.tools.Csv.printCsvDataFromObjects(Lambda.array(db.User.getUsers_NewUsers()), ["firstName", "lastName", "email"],
t._("Never connected"));
return; return;
}else { } else {
browse = function(index:Int, limit:Int) { return db.User.getUsers_NewUsers(index, limit); } browse = function(index:Int, limit:Int) {
return db.User.getUsers_NewUsers(index, limit);
}
} }
default: default:
throw t._("Unknown selection"); throw t._("Unknown selection");
} }
view.select = args.select; view.select = args.select;
} else {
}else {
if (app.params.exists("csv")) { if (app.params.exists("csv")) {
var headers = ["firstName", "lastName", "email","phone", "firstName2", "lastName2","email2","phone2", "address1","address2","zipCode","city"]; var headers = [
sugoi.tools.Csv.printCsvDataFromObjects(Lambda.array(db.User.manager.search( $id in uids, {orderBy:lastName}, false)), headers, t._("Members")); "firstName", "lastName", "email", "phone", "firstName2", "lastName2", "email2", "phone2", "address1", "address2", "zipCode", "city"
];
sugoi.tools.Csv.printCsvDataFromObjects(Lambda.array(db.User.manager.search($id in uids, {orderBy: lastName}, false)), headers,
t._("Members"));
return; return;
}else { } else {
//default display // default display
browse = function(index:Int, limit:Int) { browse = function(index:Int, limit:Int) {
return db.User.manager.search( $id in uids, { limit:[index,limit], orderBy:lastName }, false); return db.User.manager.search($id in uids, {limit: [index, limit], orderBy: lastName}, false);
} }
} }
} }
var count = uids.length; var count = uids.length;
var rb = new sugoi.tools.ResultsBrowser(count, (args.select!=null||args.search!=null)?1000:10, browse); var rb = new sugoi.tools.ResultsBrowser(count, (args.select != null || args.search != null) ? 1000 : 10, browse);
view.members = rb; view.members = rb;
if (args.select == null || args.select != "newusers") { if (args.select == null || args.select != "newusers") {
//count new users // count new users
view.newUsers = db.User.getUsers_NewUsers().length; view.newUsers = db.User.getUsers_NewUsers().length;
} }
view.waitingList = db.WaitingList.manager.count($group == app.user.amap); view.waitingList = db.WaitingList.manager.count($group == app.user.amap);
} }
/** /**
* Move to waiting list * Move to waiting list
*/ */
function doMovetowl(u:db.User){ function doMovetowl(u:db.User) {
var ua = db.UserAmap.get(u, app.user.amap, true); var ua = db.UserAmap.get(u, app.user.amap, true);
ua.delete(); ua.delete();
@@ -119,93 +123,84 @@ class Member extends Controller
wl.group = app.user.amap; wl.group = app.user.amap;
wl.insert(); wl.insert();
throw Ok("/member", u.getName() +" "+ t._("is now on waiting list.") ); throw Ok("/member", u.getName() + " " + t._("is now on waiting list."));
} }
/** /**
* Display waiting list * Display waiting list
*/ */
@tpl('member/waiting.mtt') @tpl('member/waiting.mtt')
function doWaiting(?args:{?add:db.User,?remove:db.User}){ function doWaiting(?args:{?add:db.User, ?remove:db.User}) {
if (args != null) {
if (args != null){ if (args.add != null) {
if (args.add != null){ service.WaitingListService.approveRequest(args.add, app.user.amap);
throw Ok("/member/waiting", t._("Membership request accepted"));
service.WaitingListService.approveRequest(args.add,app.user.amap); } else if (args.remove != null) {
throw Ok("/member/waiting", t._("Membership request accepted") ); service.WaitingListService.cancelRequest(args.remove, app.user.amap);
throw Ok("/member/waiting", t._("Membership request refused"));
}else if (args.remove != null){
service.WaitingListService.cancelRequest(args.remove,app.user.amap);
throw Ok("/member/waiting", t._("Membership request refused") );
} }
} }
view.waitingList = db.WaitingList.manager.search($group == app.user.amap,{orderBy:-date}); view.waitingList = db.WaitingList.manager.search($group == app.user.amap, {orderBy: -date});
} }
/** /**
* Send an invitation to a new member * Send an invitation to a new member
*/ */
function doInviteMember(u:db.User){ function doInviteMember(u:db.User) {
if (checkToken()) {
if (checkToken() ) {
u.sendInvitation(app.user.amap); u.sendInvitation(app.user.amap);
throw Ok('/member/view/'+u.id, t._("Invitation sent.") ); throw Ok('/member/view/' + u.id, t._("Invitation sent."));
} }
} }
/** /**
* Invite 'never logged' users * Invite 'never logged' users
*/ */
function doInvite() { function doInvite() {
if (checkToken()) { if (checkToken()) {
var users = db.User.getUsers_NewUsers(); var users = db.User.getUsers_NewUsers();
try{ try {
for ( u in users) { for (u in users) {
u.sendInvitation(app.user.amap); u.sendInvitation(app.user.amap);
Sys.sleep(0.2); Sys.sleep(0.2);
} }
}catch (e:String){ } catch (e:String) {
if (e.indexOf("curl") >-1) { if (e.indexOf("curl") > -1) {
App.current.logError(e, haxe.CallStack.toString(haxe.CallStack.exceptionStack())); App.current.logError(e, haxe.CallStack.toString(haxe.CallStack.exceptionStack()));
throw Error("/member", t._("An error occurred while sending emails, please retry")); throw Error("/member", t._("An error occurred while sending emails, please retry"));
} }
} }
throw Ok('/member', t._("Congratulations, you just sent <b>::userLength::</b> invitations", {userLength:users.length})); throw Ok('/member', t._("Congratulations, you just sent <b>::userLength::</b> invitations", {userLength: users.length}));
} }
} }
@tpl("member/view.mtt") @tpl("member/view.mtt")
function doView(member:db.User) { function doView(member:db.User) {
view.member = member; view.member = member;
var userAmap = db.UserAmap.get(member, app.user.amap); var userAmap = db.UserAmap.get(member, app.user.amap);
if (userAmap == null) throw Error("/member", t._("This person does not belong to your group")); if (userAmap == null)
throw Error("/member", t._("This person does not belong to your group"));
view.userAmap = userAmap; view.userAmap = userAmap;
view.canLoginAs = (db.UserAmap.manager.count($userId == member.id) == 1 && app.user.isAmapManager()) || app.user.isAdmin(); view.canLoginAs = (db.UserAmap.manager.count($userId == member.id) == 1 && app.user.isAmapManager()) || app.user.isAdmin();
//orders // orders
var row = { constOrders:new Array<UserOrder>(), varOrders:new Map<String,Array<UserOrder>>() }; var row = {constOrders: new Array<UserOrder>(), varOrders: new Map<String, Array<UserOrder>>()};
//commandes fixes // commandes fixes
var contracts = db.Contract.manager.search($type == db.Contract.TYPE_CONSTORDERS && $amap == app.user.amap && $endDate > DateTools.delta(Date.now(),-1000.0*60*60*24*30), false); var contracts = db.Contract.manager.search($type == db.Contract.TYPE_CONSTORDERS
&& $amap == app.user.amap
&& $endDate > DateTools.delta(Date.now(), -1000.0 * 60 * 60 * 24 * 30), false);
var orders = member.getOrdersFromContracts(contracts); var orders = member.getOrdersFromContracts(contracts);
row.constOrders = service.OrderService.prepare(orders); row.constOrders = service.OrderService.prepare(orders);
//commandes variables groupées par date de distrib // commandes variables groupées par date de distrib
var contracts = db.Contract.manager.search($type == db.Contract.TYPE_VARORDER && $amap == app.user.amap && $endDate > DateTools.delta(Date.now(),-1000.0*60*60*24*30), false); var contracts = db.Contract.manager.search($type == db.Contract.TYPE_VARORDER
var distribs = new Map<String,List<db.UserContract>>(); && $amap == app.user.amap
&& $endDate > DateTools.delta(Date.now(), -1000.0 * 60 * 60 * 24 * 30), false);
var distribs = new Map<String, List<db.UserContract>>();
for (c in contracts) { for (c in contracts) {
var ds = c.getDistribs(); var ds = c.getDistribs();
for (d in ds) { for (d in ds) {
@@ -214,25 +209,23 @@ class Member extends Controller
if (orders.length > 0) { if (orders.length > 0) {
if (!distribs.exists(k)) { if (!distribs.exists(k)) {
distribs.set(k, orders); distribs.set(k, orders);
}else { } else {
var v = distribs.get(k); var v = distribs.get(k);
for ( o in orders ) v.add(o); for (o in orders)
v.add(o);
distribs.set(k, v); distribs.set(k, v);
} }
} }
} }
} }
for ( k in distribs.keys()){ for (k in distribs.keys()) {
var d = distribs.get(k); var d = distribs.get(k);
var d2 = service.OrderService.prepare(d); var d2 = service.OrderService.prepare(d);
row.varOrders.set(k,d2); row.varOrders.set(k, d2);
} }
view.userContracts = row; view.userContracts = row;
checkToken(); //to insert a token in tpl checkToken(); // to insert a token in tpl
} }
/** /**
@@ -241,35 +234,42 @@ class Member extends Controller
* @param amap * @param amap
*/ */
function doLoginas(member:db.User, amap:db.Amap) { function doLoginas(member:db.User, amap:db.Amap) {
if (!app.user.isAdmin()) {
if (!app.user.isAdmin()){ if (!app.user.isAmapManager())
if (!app.user.isAmapManager()) return; return;
if (member.isAdmin()) return; if (member.isAdmin())
if ( db.UserAmap.manager.count($userId == member.id) > 1 ) return; return;
if (db.UserAmap.manager.count($userId == member.id) > 1)
return;
} }
App.current.session.setUser(member); App.current.session.setUser(member);
App.current.session.data.amapId = amap.id; App.current.session.data.amapId = amap.id;
throw Redirect("/member/view/" + member.id ); throw Redirect("/member/view/" + member.id);
} }
@tpl('member/lastMessages.mtt') @tpl('member/lastMessages.mtt')
function doLastMessages(member:db.User){ function doLastMessages(member:db.User) {
var out = new Array<{
var out = new Array<{date:Date,subject:String,success:String,failure:String}>(); date:Date,
subject:String,
success:String,
failure:String
}>();
var threeMonth = DateTools.delta(Date.now(), -1000.0 * 60 * 60 * 24 * 30.5 * 3); var threeMonth = DateTools.delta(Date.now(), -1000.0 * 60 * 60 * 24 * 30.5 * 3);
for ( m in sugoi.db.BufferedMail.manager.search($remoteId == app.user.amap.id && $cdate > threeMonth, {limit:10, orderBy:-cdate})){ for (m in sugoi.db.BufferedMail.manager.search($remoteId == app.user.amap.id && $cdate > threeMonth, {limit: 10, orderBy: -cdate})) {
var status:sugoi.mail.IMailer.MailerResult = m.status;
var status : sugoi.mail.IMailer.MailerResult = m.status;
if ( status!=null && status.get(member.email)!=null ){
if (status != null && status.get(member.email) != null) {
var r = m.getMailerResultMessage(member.email); var r = m.getMailerResultMessage(member.email);
out.push( {date:m.cdate,subject:m.title,success:r.success,failure:r.failure} ); out.push({
date: m.cdate,
subject: m.title,
success: r.success,
failure: r.failure
});
} }
} }
view.emails = out; view.emails = out;
} }
@@ -279,127 +279,134 @@ class Member extends Controller
*/ */
@tpl('form.mtt') @tpl('form.mtt')
function doEdit(member:db.User) { function doEdit(member:db.User) {
if (member.isAdmin() && !app.user.isAdmin())
if (member.isAdmin() && !app.user.isAdmin()) throw Error("/", t._("You cannot modify the account of an administrator")); throw Error("/", t._("You cannot modify the account of an administrator"));
var form = sugoi.form.Form.fromSpod(member); var form = sugoi.form.Form.fromSpod(member);
//cleaning // cleaning
form.removeElement( form.getElement("rights") ); form.removeElement(form.getElement("rights"));
form.removeElement( form.getElement("lang") ); form.removeElement(form.getElement("lang"));
form.removeElement( form.getElement("ldate") ); form.removeElement(form.getElement("ldate"));
form.removeElement( form.getElement("apiKey") ); form.removeElement(form.getElement("apiKey"));
var isReg = member.isFullyRegistred(); var isReg = member.isFullyRegistred();
var groupNum = db.UserAmap.manager.count($userId == member.id); var groupNum = db.UserAmap.manager.count($userId == member.id);
//an administrator can modify a user's email only if he's not member elsewhere // an administrator can modify a user's email only if he's not member elsewhere
if (groupNum > 1){ if (groupNum > 1) {
form.removeElementByName("email"); form.removeElementByName("email");
form.removeElementByName("email2"); form.removeElementByName("email2");
app.session.addMessage(t._("For security reasons, you cannot modify the e-mail of this person because this person is a member of more than 1 group.")); app.session.addMessage(t._("For security reasons, you cannot modify the e-mail of this person because this person is a member of more than 1 group."));
} }
//an administrator can modify a user's pass only if he's a not registred user. // an administrator can modify a user's pass only if he's a not registred user.
if (!isReg){ if (!isReg) {
app.session.addMessage(t._("This person did not define yet a password. You are exceptionaly authorized to do it. Please don't forget to tell this person.")); app.session.addMessage(t._("This person did not define yet a password. You are exceptionaly authorized to do it. Please don't forget to tell this person."));
form.getElement("pass").required = false; form.getElement("pass").required = false;
}else{ } else {
form.removeElement( form.getElement("pass") ); form.removeElement(form.getElement("pass"));
} }
if (form.checkToken()) { if (form.checkToken()) {
if (app.user.amap.flags.has(db.Amap.AmapFlags.PhoneRequired) && form.getValueOf("phone") == null) {
if (app.user.amap.flags.has(db.Amap.AmapFlags.PhoneRequired) && form.getValueOf("phone") == null ){ throw Error("/member/edit/" + member.id, t._("Phone number is required in this group."));
throw Error("/member/edit/"+member.id, t._("Phone number is required in this group."));
} }
form.toSpod(member); form.toSpod(member);
//check that the given emails are not already used elsewhere // check that the given emails are not already used elsewhere
var sim = db.User.getSameEmail(member.email,member.email2); var sim = db.User.getSameEmail(member.email, member.email2);
for ( s in sim) { for (s in sim) {
if (s.id == member.id) sim.remove(s); if (s.id == member.id)
sim.remove(s);
} }
if (sim.length > 0) { if (sim.length > 0) {
// Let's merge the 2 users if it has no orders.
//Let's merge the 2 users if it has no orders.
var id = sim.first().id; var id = sim.first().id;
if (db.UserContract.manager.search( $userId == id || $userId2 == id , false).length == 0) { if (db.UserContract.manager.search($userId == id || $userId2 == id, false).length == 0) {
//merge // merge
member.merge( sim.first() ); member.merge(sim.first());
app.session.addMessage(t._("This e-mail was used by another user account. As this user account was not used, it has been merged into the current user account.")); app.session.addMessage(t._("This e-mail was used by another user account. As this user account was not used, it has been merged into the current user account."));
} else { } else {
var str = t._("Warning, this e-mail or this name already exists for another account : "); var str = t._("Warning, this e-mail or this name already exists for another account : ");
str += Lambda.map(sim, function(u) return "<a href='/member/view/" + u.id + "'>" + u.getCoupleName() + "</a>").join(","); str += Lambda.map(sim, function(u) return "<a href='/member/view/" + u.id + "'>" + u.getCoupleName() + "</a>").join(",");
str += " "+t._("These accounts can't be merged because the second account has orders"); str += " " + t._("These accounts can't be merged because the second account has orders");
throw Error("/member/edit/" + member.id, str); throw Error("/member/edit/" + member.id, str);
} }
} }
if (!isReg) member.setPass(form.getValueOf("pass")); if (!isReg)
member.setPass(form.getValueOf("pass"));
member.update(); member.update();
if (!App.config.DEBUG && groupNum == 1) { if (!App.config.DEBUG && groupNum == 1) {
// warn the user that his email has been updated
//warn the user that his email has been updated
if (form.getValueOf("email") != member.email) { if (form.getValueOf("email") != member.email) {
var m = new sugoi.mail.Mail(); var m = new sugoi.mail.Mail();
m.setSender(App.config.get("default_email"), t._("Cagette.net")); m.setSender(App.config.get("default_email"), t._("Cagette.net"));
m.addRecipient(member.email); m.addRecipient(member.email);
m.setSubject(t._("Change your e-mail in your account Cagette.net")); m.setSubject(t._("Change your e-mail in your account Cagette.net"));
m.setHtmlBody( app.processTemplate("mail/message.mtt", { text:app.user.getName() + t._(" just modified your e-mail in your account Cagette.net.<br/>Your e-mail is now:")+form.getValueOf("email") } ) ); m.setHtmlBody(app.processTemplate("mail/message.mtt",
{text: app.user.getName()
+ t._(" just modified your e-mail in your account Cagette.net.<br/>Your e-mail is now:")
+ form.getValueOf("email")}));
App.sendMail(m); App.sendMail(m);
} }
if (form.getValueOf("email2") != member.email2 && member.email2!=null) { if (form.getValueOf("email2") != member.email2 && member.email2 != null) {
var m = new sugoi.mail.Mail(); var m = new sugoi.mail.Mail();
m.setSender(App.config.get("default_email"),"Cagette.net"); m.setSender(App.config.get("default_email"), t._("Cagette.net"));
m.addRecipient(member.email2); m.addRecipient(member.email2);
m.setSubject(t._("Change the e-mail of your account Cagette.net")); m.setSubject(t._("Change the e-mail of your account Cagette.net"));
m.setHtmlBody( app.processTemplate("mail/message.mtt", { text:app.user.getName() +t._(" just modified your e-mail in your account Cagette.net.<br/>Your e-mail is now:")+form.getValueOf("email2") } ) ); m.setHtmlBody(app.processTemplate("mail/message.mtt",
{text: app.user.getName()
+ t._(" just modified your e-mail in your account Cagette.net.<br/>Your e-mail is now:")
+ form.getValueOf("email2")}));
App.sendMail(m); App.sendMail(m);
} }
} }
throw Ok('/member/view/'+member.id, t._("This member has beed updated")); throw Ok('/member/view/' + member.id, t._("This member has beed updated"));
} }
view.form = form; view.form = form;
} }
/** /**
* Remove a user from this group * Remove a user from this group
*/ */
function doDelete(user:db.User,?args:{confirm:Bool,token:String}) { function doDelete(user:db.User, ?args:{confirm:Bool, token:String}) {
if (checkToken()) { if (checkToken()) {
if (!app.user.canAccessMembership()) throw t._("You cannot do that."); if (!app.user.canAccessMembership())
if (user.id == app.user.id) throw Error("/member/view/" + user.id, t._("You cannot delete yourself.")); throw t._("You cannot do that.");
if ( Lambda.count(user.getOrders(app.user.amap),function(x) return x.quantity>0) > 0 && !args.confirm) { if (user.id == app.user.id)
throw Error("/member/view/"+user.id, t._("Warning, this account has orders. <a class='btn btn-default btn-xs' href='/member/delete/::userid::?token=::argstoken::&confirm=1'>Remove anyway</a>", {userid:user.id, argstoken:args.token})); throw Error("/member/view/" + user.id, t._("You cannot delete yourself."));
if (Lambda.count(user.getOrders(app.user.amap), function(x) return x.quantity > 0) > 0 && !args.confirm) {
throw Error("/member/view/" + user.id,
t._("Warning, this account has orders. <a class='btn btn-default btn-xs' href='/member/delete/::userid::?token=::argstoken::&confirm=1'>Remove anyway</a>",
{
userid: user.id,
argstoken: args.token
}));
} }
var ua = db.UserAmap.get(user, app.user.amap, true); var ua = db.UserAmap.get(user, app.user.amap, true);
if (ua != null) { if (ua != null) {
ua.delete(); ua.delete();
throw Ok("/member", t._("::user:: has been removed from your group",{user:user.getName()})); throw Ok("/member", t._("::user:: has been removed from your group", {user: user.getName()}));
}else { } else {
throw Error("/member", t._("This person does not belong to \"::amapname::\"", {amapname:app.user.amap.name})); throw Error("/member", t._("This person does not belong to \"::amapname::\"", {amapname: app.user.amap.name}));
} }
}else { } else {
throw Redirect("/member/view/"+user.id); throw Redirect("/member/view/" + user.id);
} }
} }
@tpl('form.mtt') @tpl('form.mtt')
function doMerge(user:db.User) { function doMerge(user:db.User) {
if (!app.user.canAccessMembership())
if (!app.user.canAccessMembership()) throw Error("/","Action interdite"); throw Error("/", "Action interdite");
view.title = t._("Merge an account with another one"); view.title = t._("Merge an account with another one");
view.text = t._("This action allows you to merge two accounts (when you have duplicates in the database for example).<br/>Contracts of account 2 will be moved to account 1, and account 2 will be deleted. Warning, it is not possible to cancel this action."); view.text = t._("This action allows you to merge two accounts (when you have duplicates in the database for example).<br/>Contracts of account 2 will be moved to account 1, and account 2 will be deleted. Warning, it is not possible to cancel this action.");
@@ -407,80 +414,77 @@ class Member extends Controller
var form = new Form("merge"); var form = new Form("merge");
var members = app.user.amap.getMembers(); var members = app.user.amap.getMembers();
var members = Lambda.array(Lambda.map(members, function(x) return { key:Std.string(x.id), value:x.getName() } )); var members = Lambda.array(Lambda.map(members, function(x) return {key: Std.string(x.id), value: x.getName()}));
var mlist = new Selectbox("member1", t._("Account 1"), members, Std.string(user.id)); var mlist = new Selectbox("member1", t._("Account 1"), members, Std.string(user.id));
form.addElement( mlist ); form.addElement(mlist);
var mlist = new Selectbox("member2", t._("Account 2"), members); var mlist = new Selectbox("member2", t._("Account 2"), members);
form.addElement( mlist ); form.addElement(mlist);
if (form.checkToken()) { if (form.checkToken()) {
var m1 = Std.parseInt(form.getElement("member1").value); var m1 = Std.parseInt(form.getElement("member1").value);
var m2 = Std.parseInt(form.getElement("member2").value); var m2 = Std.parseInt(form.getElement("member2").value);
var m1 = db.User.manager.get(m1,true); var m1 = db.User.manager.get(m1, true);
var m2 = db.User.manager.get(m2,true); var m2 = db.User.manager.get(m2, true);
//if (m1.amapId != m2.amapId) throw "ils ne sont pas de la même amap !"; // if (m1.amapId != m2.amapId) throw "ils ne sont pas de la même amap !";
//on prend tout à m2 pour donner à m1 // on prend tout à m2 pour donner à m1
//change usercontracts // change usercontracts
var contracts = db.UserContract.manager.search($user==m2 || $user2==m2,true); var contracts = db.UserContract.manager.search($user == m2 || $user2 == m2, true);
for (c in contracts) { for (c in contracts) {
if (c.user.id == m2.id) c.user = m1; if (c.user.id == m2.id)
if (c.user2!=null && c.user2.id == m2.id) c.user2 = m1; c.user = m1;
if (c.user2 != null && c.user2.id == m2.id)
c.user2 = m1;
c.update(); c.update();
} }
//group memberships // group memberships
var adh = db.UserAmap.manager.search($user == m2, true); var adh = db.UserAmap.manager.search($user == m2, true);
for ( a in adh) { for (a in adh) {
a.user = m1; a.user = m1;
a.update(); a.update();
} }
//change contacts // change contacts
var contacts = db.Contract.manager.search($contact==m2,true); var contacts = db.Contract.manager.search($contact == m2, true);
for (c in contacts) { for (c in contacts) {
c.contact = m1; c.contact = m1;
c.update(); c.update();
} }
//if (m2.amap.contact == m2) { // if (m2.amap.contact == m2) {
//m1.amap.lock(); // m1.amap.lock();
//m1.amap.contact = m1; // m1.amap.contact = m1;
//m1.amap.update(); // m1.amap.update();
//} // }
m2.delete(); m2.delete();
throw Ok("/member/view/" + m1.id, t._("Both accounts have been merged")); throw Ok("/member/view/" + m1.id, t._("Both accounts have been merged"));
} }
view.form = form; view.form = form;
} }
@tpl('member/import.mtt') @tpl('member/import.mtt')
function doImport(?args: { confirm:Bool } ) { function doImport(?args:{confirm:Bool}) {
var step = 1; var step = 1;
var request = Utils.getMultipart(1024 * 1024 * 4); //4mb var request = Utils.getMultipart(1024 * 1024 * 4); // 4mb
//on recupere le contenu de l'upload // on recupere le contenu de l'upload
var data = request.get("file"); var data = request.get("file");
if ( data != null) { if (data != null) {
var csv = new sugoi.tools.Csv(); var csv = new sugoi.tools.Csv();
csv.setHeaders([t._("Firstname"), t._("Lastname"), t._("E-mail"), t._("Mobile phone"), t._("Partner's firstname"), t._("Partner's lastname"), t._("Partner's e-mail"), t._("Partner's Mobile phone"), t._("Address 1"), t._("Address 2"), t._("Post code"), t._("City")]); csv.setHeaders([
t._("Firstname"), t._("Lastname"), t._("E-mail"), t._("Mobile phone"), t._("Partner's firstname"), t._("Partner's lastname"),
t._("Partner's e-mail"), t._("Partner's Mobile phone"), t._("Address 1"), t._("Address 2"), t._("Post code"), t._("City")]);
//utf8 encode if needed // utf8 encode if needed
try{ try {
if (!haxe.Utf8.validate(data)){ if (!haxe.Utf8.validate(data)) {
data = haxe.Utf8.encode(data); data = haxe.Utf8.encode(data);
} }
}catch (e:Dynamic){ } } catch (e:Dynamic) {}
var unregistred = csv.importDatas(data); var unregistred = csv.importDatas(data);
/*var checkEmail = function(email){ /*var checkEmail = function(email){
@@ -489,55 +493,57 @@ class Member extends Controller
} }
}*/ }*/
//cleaning // cleaning
for ( user in unregistred.copy() ) { for (user in unregistred.copy()) {
// check nom+prenom
//check nom+prenom
if (user[0] == null || user[1] == null) { if (user[0] == null || user[1] == null) {
throw Error("/member/import", t._("You must fill the name and the firstname of the person. This line is incomplete: ") + user); throw Error("/member/import", t._("You must fill the name and the firstname of the person. This line is incomplete: ") + user);
} }
if (user[2] == null) { if (user[2] == null) {
throw Error("/member/import", t._("Each person must have an e-mail to be able to log in. ::user0:: ::user1:: don't have one. ", {user0:user[0], user1:user[1]}) +user); throw Error("/member/import",
t._("Each person must have an e-mail to be able to log in. ::user0:: ::user1:: don't have one. ",
{user0: user[0], user1: user[1]}) + user);
} }
//uppercase du nom // uppercase du nom
if (user[1] != null) user[1] = user[1].toUpperCase(); if (user[1] != null)
if (user[5] != null) user[5] = user[5].toUpperCase(); user[1] = user[1].toUpperCase();
//lowercase email if (user[5] != null)
if (user[2] != null){ user[5] = user[5].toUpperCase();
// lowercase email
if (user[2] != null) {
user[2] = user[2].toLowerCase(); user[2] = user[2].toLowerCase();
//checkEmail(user[2]); // checkEmail(user[2]);
} }
if (user[6] != null){ if (user[6] != null) {
user[6] = user[6].toLowerCase(); user[6] = user[6].toLowerCase();
//checkEmail(user[6]); // checkEmail(user[6]);
} }
} }
//utf-8 check // utf-8 check
for ( row in unregistred.copy()) { for (row in unregistred.copy()) {
for (i in 0...row.length) {
for ( i in 0...row.length) {
var t = row[i]; var t = row[i];
if (t != "" && t != null) { if (t != "" && t != null) {
try{ try {
if (!Utf8.validate(t)) { if (!Utf8.validate(t)) {
t = Utf8.encode(t); t = Utf8.encode(t);
} }
}catch (e:Dynamic) {} } catch (e:Dynamic) {}
row[i] = t; row[i] = t;
} }
} }
} }
//put already registered people in another list // put already registered people in another list
var registred = []; var registred = [];
for (r in unregistred.copy()) { for (r in unregistred.copy()) {
//var firstName = r[0]; // var firstName = r[0];
//var lastName = r[1]; // var lastName = r[1];
var email = r[2]; var email = r[2];
//var firstName2 = r[4]; // var firstName2 = r[4];
//var lastName2 = r[5]; // var lastName2 = r[5];
var email2 = r[6]; var email2 = r[6];
var us = db.User.getSameEmail(email, email2); var us = db.User.getSameEmail(email, email2);
@@ -548,7 +554,6 @@ class Member extends Controller
} }
} }
app.session.data.csvUnregistered = unregistred; app.session.data.csvUnregistered = unregistred;
app.session.data.csvRegistered = registred; app.session.data.csvRegistered = registred;
@@ -557,20 +562,19 @@ class Member extends Controller
step = 2; step = 2;
} }
if (args != null && args.confirm) { if (args != null && args.confirm) {
// import unregistered members
//import unregistered members var i:Iterable<Dynamic> = cast app.session.data.csvUnregistered;
var i : Iterable<Dynamic> = cast app.session.data.csvUnregistered;
for (u in i) { for (u in i) {
if (u[0] == null || u[0] == "null" || u[0] == "") continue; if (u[0] == null || u[0] == "null" || u[0] == "")
continue;
var user = new db.User(); var user = new db.User();
user.firstName = u[0]; user.firstName = u[0];
user.lastName = u[1]; user.lastName = u[1];
user.email = u[2]; user.email = u[2];
if (user.email != null && user.email != "null" &&!EmailValidator.check(user.email)) { if (user.email != null && user.email != "null" && !EmailValidator.check(user.email)) {
throw t._("The E-mail ::useremail:: is invalid, please modify your file", {useremail:user.email}); throw t._("The E-mail ::useremail:: is invalid, please modify your file", {useremail: user.email});
} }
user.phone = u[3]; user.phone = u[3];
@@ -579,7 +583,8 @@ class Member extends Controller
user.email2 = u[6]; user.email2 = u[6];
if (user.email2 != null && user.email2 != "null" && !EmailValidator.check(user.email2)) { if (user.email2 != null && user.email2 != "null" && !EmailValidator.check(user.email2)) {
App.log(u); App.log(u);
throw t._("The E-mail of the partner of ::userFirstName:: ::userLastName:: '::userEmail::' is invalid, please check your file", {userFirstName:user.firstName, userLastName:user.lastName, userEmail:user.email2}); throw t._("The E-mail of the partner of ::userFirstName:: ::userLastName:: '::userEmail::' is invalid, please check your file",
{userFirstName: user.firstName, userLastName: user.lastName, userEmail: user.email2});
} }
user.phone2 = u[7]; user.phone2 = u[7];
user.address1 = u[8]; user.address1 = u[8];
@@ -594,16 +599,17 @@ class Member extends Controller
ua.insert(); ua.insert();
} }
//import registered members // import registered members
var i : Iterable<Array<String>> = cast app.session.data.csvRegistered; var i:Iterable<Array<String>> = cast app.session.data.csvRegistered;
for (u in i) { for (u in i) {
var email = u[2]; var email = u[2];
var email2 = u[6]; var email2 = u[6];
var us = db.User.getSameEmail(email, email2); var us = db.User.getSameEmail(email, email2);
var userAmaps = db.UserAmap.manager.search($amap == app.user.amap && $userId in Lambda.map(us, function(u) return u.id), false); var userAmaps = db.UserAmap.manager.search($amap == app.user.amap
&& $userId in Lambda.map(us, function(u) return u.id), false);
//member exists but is not member of this group. // member exists but is not member of this group.
if (userAmaps.length == 0) { if (userAmaps.length == 0) {
var ua = new db.UserAmap(); var ua = new db.UserAmap();
ua.user = us.first(); ua.user = us.first();
@@ -620,7 +626,7 @@ class Member extends Controller
} }
if (step == 1) { if (step == 1) {
//reset import when back to import page // reset import when back to import page
app.session.data.csvUnregistered = null; app.session.data.csvUnregistered = null;
app.session.data.csvRegistered = null; app.session.data.csvRegistered = null;
} }
@@ -630,60 +636,58 @@ class Member extends Controller
@tpl("user/insert.mtt") @tpl("user/insert.mtt")
public function doInsert() { public function doInsert() {
if (!app.user.canAccessMembership())
if (!app.user.canAccessMembership()) throw Error("/", t._("Forbidden action")); throw Error("/", t._("Forbidden action"));
var m = new db.User(); var m = new db.User();
var form = sugoi.form.Form.fromSpod(m); var form = sugoi.form.Form.fromSpod(m);
form.removeElement(form.getElement("lang")); form.removeElement(form.getElement("lang"));
form.removeElement(form.getElement("rights")); form.removeElement(form.getElement("rights"));
form.removeElement(form.getElement("pass")); form.removeElement(form.getElement("pass"));
form.removeElement(form.getElement("ldate") ); form.removeElement(form.getElement("ldate"));
form.removeElement( form.getElement("apiKey") ); form.removeElement(form.getElement("apiKey"));
form.addElement(new sugoi.form.elements.Checkbox("warnAmapManager", t._("Send an E-mail to the person in charge of the group"), true)); form.addElement(new sugoi.form.elements.Checkbox("warnAmapManager", t._("Send an E-mail to the person in charge of the group"), true));
form.getElement("email").addValidator(new EmailValidator()); form.getElement("email").addValidator(new EmailValidator());
form.getElement("email2").addValidator(new EmailValidator()); form.getElement("email2").addValidator(new EmailValidator());
if (form.isValid()) { if (form.isValid()) {
// check doublon de User et de UserAmap
//check doublon de User et de UserAmap var userSims = db.User.getSameEmail(form.getValueOf("email"), form.getValueOf("email2"));
var userSims = db.User.getSameEmail(form.getValueOf("email"),form.getValueOf("email2"));
view.userSims = userSims; view.userSims = userSims;
var userAmaps = db.UserAmap.manager.search($amap == app.user.amap && $userId in Lambda.map(userSims, function(u) return u.id), false); var userAmaps = db.UserAmap.manager.search($amap == app.user.amap
&& $userId in Lambda.map(userSims, function(u) return u.id), false);
view.userAmaps = userAmaps; view.userAmaps = userAmaps;
if (userAmaps.length > 0) { if (userAmaps.length > 0) {
//user deja enregistré dans cette amap // user deja enregistré dans cette amap
throw Error('/member/view/' + userAmaps.first().user.id, t._("This person is already member of this group")); throw Error('/member/view/' + userAmaps.first().user.id, t._("This person is already member of this group"));
} else if (userSims.length > 0) {
}else if (userSims.length > 0) { // des users existent avec ce nom ,
//des users existent avec ce nom , // if (userSims.length == 1) {
//if (userSims.length == 1) { // si yen a qu'un on l'inserte
// si yen a qu'un on l'inserte var ua = new db.UserAmap();
var ua = new db.UserAmap(); ua.user = userSims.first();
ua.user = userSims.first(); ua.amap = app.user.amap;
ua.amap = app.user.amap; ua.insert();
ua.insert(); throw Ok('/member/', t._("This person already had an account on Cagette.net, and is now member of your group."));
throw Ok('/member/', t._("This person already had an account on Cagette.net, and is now member of your group."));
/*}else { /*}else {
//demander validation avant d'inserer le userAmap //demander validation avant d'inserer le userAmap
//TODO //TODO
throw Error('/member', t._("Not possible to add this person because there are already some people in the database having the same firstname and name. Please contact the administrator.")+userSims); throw Error('/member', t._("Not possible to add this person because there are already some people in the database having the same firstname and name. Please contact the administrator.")+userSims);
}*/ }*/
return; return;
}else { } else {
if (app.user.amap.flags.has(db.Amap.AmapFlags.PhoneRequired) && form.getValueOf("phone") == null) {
if (app.user.amap.flags.has(db.Amap.AmapFlags.PhoneRequired) && form.getValueOf("phone") == null ){
throw Error("/member/insert", t._("Phone number is required in this group.")); throw Error("/member/insert", t._("Phone number is required in this group."));
} }
//insert user // insert user
var u = new db.User(); var u = new db.User();
form.toSpod(u); form.toSpod(u);
u.lang = app.user.lang; u.lang = app.user.lang;
u.insert(); u.insert();
//insert userAmap // insert userAmap
var ua = new db.UserAmap(); var ua = new db.UserAmap();
ua.user = u; ua.user = u;
ua.amap = app.user.getAmap(); ua.amap = app.user.getAmap();
@@ -691,38 +695,39 @@ class Member extends Controller
if (form.getValueOf("warnAmapManager") == "1") { if (form.getValueOf("warnAmapManager") == "1") {
var url = "http://" + App.config.HOST + "/member/view/" + u.id; var url = "http://" + App.config.HOST + "/member/view/" + u.id;
var text = t._("::admin:: just keyed-in contact details of a new member: <br/><strong>::newMember::</strong><br/> <a href='::url::'>See contact details</a>",{admin:app.user.getName(),newMember:u.getCoupleName(),url:url}); var text = t._("::admin:: just keyed-in contact details of a new member: <br/><strong>::newMember::</strong><br/> <a href='::url::'>See contact details</a>",
App.quickMail( {
app.user.getAmap().contact.email, admin: app.user.getName(),
app.user.amap.name +" - "+ t._("New member") + " : " + u.getCoupleName(), newMember: u.getCoupleName(),
app.processTemplate("mail/message.mtt", { text:text } ) url: url
); });
App.quickMail(app.user.getAmap().contact.email, app.user.amap.name + " - " + t._("New member") + " : " + u.getCoupleName(),
app.processTemplate("mail/message.mtt", {
text: text
}));
} }
throw Ok('/member/', t._("This person is now member of the group")); throw Ok('/member/', t._("This person is now member of the group"));
} }
} }
view.form = form; view.form = form;
} }
/** /**
* user payments history * user payments history
*/ */
@tpl('member/payments.mtt') @tpl('member/payments.mtt')
function doPayments(m:db.User){ function doPayments(m:db.User) {
service.PaymentService.updateUserBalance(m, app.user.amap); service.PaymentService.updateUserBalance(m, app.user.amap);
var browse:Int->Int->List<Dynamic>; var browse:Int->Int->List<Dynamic>;
//default display // default display
browse = function(index:Int, limit:Int) { browse = function(index:Int, limit:Int) {
return db.Operation.getOperationsWithIndex(m,app.user.amap,index,limit,true); return db.Operation.getOperationsWithIndex(m, app.user.amap, index, limit, true);
} }
var count = db.Operation.countOperations(m,app.user.amap); var count = db.Operation.countOperations(m, app.user.amap);
var rb = new sugoi.tools.ResultsBrowser(count, 10, browse); var rb = new sugoi.tools.ResultsBrowser(count, 10, browse);
view.rb = rb; view.rb = rb;
view.member = m; view.member = m;
@@ -732,10 +737,9 @@ class Member extends Controller
} }
@tpl('member/balance.mtt') @tpl('member/balance.mtt')
function doBalance(){ function doBalance() {
view.balanced = db.UserAmap.manager.search($amap == app.user.amap && $balance == 0.0, false); view.balanced = db.UserAmap.manager.search($amap == app.user.amap && $balance == 0.0, false);
view.credit = db.UserAmap.manager.search($amap == app.user.amap && $balance > 0, false); view.credit = db.UserAmap.manager.search($amap == app.user.amap && $balance > 0, false);
view.debt = db.UserAmap.manager.search($amap == app.user.amap && $balance < 0, false); view.debt = db.UserAmap.manager.search($amap == app.user.amap && $balance < 0, false);
} }
} }
+6 -29
View File
@@ -41,11 +41,6 @@ class Messages extends Controller {
var subject = form.getValueOf("subject"); var subject = form.getValueOf("subject");
App.log('about to send email <$subject> to listId=<$listId> to ${dest.length} recipient(s)'); App.log('about to send email <$subject> to listId=<$listId> to ${dest.length} recipient(s)');
// Sys.command("sh", [
// "-c",
// "sendemail -f no-reply@comptoirduvrac.re -s mail1.zourit.net:587 -t pvincent@comptoirduvrac.re -bcc 'pvincent974@gmail.com, pvincent974@laposte.net' -u TEST -m coucou -xu postmaster@comptoirduvrac.re -xp QqQeAPT6EpoK"
// ]);
var mails = []; var mails = [];
for (d in dest) { for (d in dest) {
if (d.email != null) if (d.email != null)
@@ -56,7 +51,7 @@ class Messages extends Controller {
// send mail confirmation link // send mail confirmation link
var e = new sugoi.mail.Mail(); var e = new sugoi.mail.Mail();
e.setSender(App.config.get("default_email")); e.setSender(App.config.get("default_email"), t._("Cagette.net"));
e.setSubject(subject); e.setSubject(subject);
var replyTo = form.getValueOf("senderMail"); var replyTo = form.getValueOf("senderMail");
@@ -64,34 +59,14 @@ class Messages extends Controller {
if (replyTo != null) if (replyTo != null)
e.setReplyTo(replyTo, replyToName); e.setReplyTo(replyTo, replyToName);
if (mails.length > 1) { for (x in mails)
var cc = mails.join(","); e.addRecipient(x);
App.log('add header Cc: $cc');
e.setHeader("CC:", cc);
// for (x in mails)
// e.addRecipient(x);
e.addRecipient(e.getSender().email);
} else {
App.log('no header');
e.addRecipient(mails[0]);
}
// sender : default email ( explicitly tells that the server send an email on behalf of the user )
// e.setHeader("Sender", App.config.get("default_email"));
var text:String = form.getValueOf("text"); var text:String = form.getValueOf("text");
var html = app.processTemplate("mail/message.mtt", {text: text, group: app.user.amap, list: getListName(listId)}); var html = app.processTemplate("mail/message.mtt", {text: text, group: app.user.amap, list: getListName(listId)});
e.setHtmlBody(html); e.setHtmlBody(html);
// FIXME: re-apply sendMail App.sendMail(e, app.user.getAmap(), listId, app.user);
// App.sendMail(e, app.user.getAmap(), listId, app.user);
// Sys.command("sendemail", [
// "-f", "no-reply@comptoirduvrac.re", "-s", "mail1.zourit.net:587", "-t", "pvincent@comptoirduvrac.re", "-bcc",
// "pvincent974@gmail.com,pvincent974@laposte.net", "-u", subject, "-m", "alors tout va bien", "-xu", "postmaster@comptoirduvrac.re", "-xp",
// "QqQeAPT6EpoK"
// ]);
sys.io.File.saveContent('/tmp/my_file.json', "CONTENT");
// store message // store message
var lm = new db.Message(); var lm = new db.Message();
@@ -107,6 +82,8 @@ class Messages extends Controller {
lm.insert(); lm.insert();
throw Ok("/messages", t._("The message has been sent")); throw Ok("/messages", t._("The message has been sent"));
} else {
App.log('Administrator #${app.user.id} <${senderName}> prepares sending an email from choices list');
} }
view.form = form; view.form = form;
+173 -173
View File
@@ -1,4 +1,5 @@
package service; package service;
import Common; import Common;
import tink.core.Error; import tink.core.Error;
@@ -6,10 +7,8 @@ import tink.core.Error;
* Order Service * Order Service
* @author web-wizard,fbarbut * @author web-wizard,fbarbut
*/ */
class OrderService class OrderService {
{ static function canHaveFloatQt(product:db.Product):Bool {
static function canHaveFloatQt(product:db.Product):Bool{
return product.hasFloatQt || product.wholesale || product.variablePrice; return product.hasFloatQt || product.wholesale || product.variablePrice;
} }
@@ -20,42 +19,45 @@ class OrderService
* @param productId * @param productId
*/ */
public static function make(user:db.User, quantity:Float, product:db.Product, ?distribId:Int, ?paid:Bool, ?user2:db.User, ?invert:Bool):db.UserContract { public static function make(user:db.User, quantity:Float, product:db.Product, ?distribId:Int, ?paid:Bool, ?user2:db.User, ?invert:Bool):db.UserContract {
var t = sugoi.i18n.Locale.texts; var t = sugoi.i18n.Locale.texts;
if(product.contract.type==db.Contract.TYPE_VARORDER && distribId==null) throw "You have to provide a distribId"; if (product.contract.type == db.Contract.TYPE_VARORDER && distribId == null)
if(quantity==null) throw "Quantity is null"; throw "You have to provide a distribId";
if (quantity == null)
throw "Quantity is null";
//quantity // quantity
if ( !canHaveFloatQt(product) ){ if (!canHaveFloatQt(product)) {
if( !tools.FloatTool.isInt(quantity) ) { if (!tools.FloatTool.isInt(quantity)) {
throw new tink.core.Error(t._("Error : product \"::product::\" quantity should be integer",{product:product.name})); throw new tink.core.Error(t._("Error : product \"::product::\" quantity should be integer", {product: product.name}));
} }
} }
//multiweight : make one row per product // multiweight : make one row per product
if (product.multiWeight && quantity > 1.0){ if (product.multiWeight && quantity > 1.0) {
if (product.multiWeight && quantity != Math.abs(quantity)) throw t._("multi-weighing products should be ordered only with integer quantities"); if (product.multiWeight && quantity != Math.abs(quantity))
throw t._("multi-weighing products should be ordered only with integer quantities");
var o = null; var o = null;
for ( i in 0...Math.round(quantity)){ for (i in 0...Math.round(quantity)) {
o = make(user, 1, product, distribId, paid, user2, invert); o = make(user, 1, product, distribId, paid, user2, invert);
} }
return o; return o;
} }
//checks // checks
if (quantity <= 0) return null; if (quantity <= 0)
return null;
//check for previous orders on the same distrib // check for previous orders on the same distrib
var prevOrders = new List<db.UserContract>(); var prevOrders = new List<db.UserContract>();
if (distribId == null) { if (distribId == null) {
prevOrders = db.UserContract.manager.search($product==product && $user==user, true); prevOrders = db.UserContract.manager.search($product == product && $user == user, true);
}else { } else {
prevOrders = db.UserContract.manager.search($product==product && $user==user && $distributionId==distribId, true); prevOrders = db.UserContract.manager.search($product == product && $user == user && $distributionId == distribId, true);
} }
//Create order object // Create order object
var o = new db.UserContract(); var o = new db.UserContract();
o.product = product; o.product = product;
o.quantity = quantity; o.quantity = quantity;
@@ -66,23 +68,26 @@ class OrderService
o.user = user; o.user = user;
if (user2 != null) { if (user2 != null) {
o.user2 = user2; o.user2 = user2;
if (invert != null) o.flags.set(InvertSharedOrder); if (invert != null)
o.flags.set(InvertSharedOrder);
} }
if (paid != null) o.paid = paid; if (paid != null)
if (distribId != null) o.distribution = db.Distribution.manager.get(distribId); o.paid = paid;
if (distribId != null)
o.distribution = db.Distribution.manager.get(distribId);
//cumulate quantities if there is a similar previous order // cumulate quantities if there is a similar previous order
if (prevOrders.length > 0 && !product.multiWeight) { if (prevOrders.length > 0 && !product.multiWeight) {
for (prevOrder in prevOrders) { for (prevOrder in prevOrders) {
//if (!prevOrder.paid) { // if (!prevOrder.paid) {
o.quantity += prevOrder.quantity; o.quantity += prevOrder.quantity;
prevOrder.delete(); prevOrder.delete();
//} // }
} }
} }
//create a basket object // create a basket object
if (distribId != null){ if (distribId != null) {
var dist = o.distribution; var dist = o.distribution;
var basket = db.Basket.getOrCreate(user, dist.place, dist.date); var basket = db.Basket.getOrCreate(user, dist.place, dist.date);
o.basket = basket; o.basket = basket;
@@ -90,129 +95,130 @@ class OrderService
o.insert(); o.insert();
//Stocks // Stocks
if (o.product.stock != null) { if (o.product.stock != null) {
var c = o.product.contract; var c = o.product.contract;
if (c.hasStockManagement()) { if (c.hasStockManagement()) {
//trace("stock for "+quantity+" x "+product.name); // trace("stock for "+quantity+" x "+product.name);
if (o.product.stock == 0) { if (o.product.stock == 0) {
if (App.current.session != null) { if (App.current.session != null) {
App.current.session.addMessage(t._("There is no more '::productName::' in stock, we removed it from your order", {productName:o.product.name}), true); App.current.session.addMessage(t._("There is no more '::productName::' in stock, we removed it from your order",
{productName: o.product.name}), true);
} }
o.quantity -= quantity; o.quantity -= quantity;
if ( o.quantity <= 0 ) { if (o.quantity <= 0) {
o.delete(); o.delete();
return null; return null;
} }
}else if (o.product.stock - quantity < 0) { } else if (o.product.stock - quantity < 0) {
var canceled = quantity - o.product.stock; var canceled = quantity - o.product.stock;
o.quantity -= canceled; o.quantity -= canceled;
o.update(); o.update();
if (App.current.session != null) { if (App.current.session != null) {
var msg = t._("We reduced your order of '::productName::' to quantity ::oQuantity:: because there is no available products anymore", {productName:o.product.name, oQuantity:o.quantity}); var msg = t._("We reduced your order of '::productName::' to quantity ::oQuantity:: because there is no available products anymore",
{productName: o.product.name, oQuantity: o.quantity});
App.current.session.addMessage(msg, true); App.current.session.addMessage(msg, true);
} }
o.product.lock(); o.product.lock();
o.product.stock = 0; o.product.stock = 0;
o.product.update(); o.product.update();
App.current.event(StockMove({product:o.product, move:0 - (quantity - canceled) })); App.current.event(StockMove({product: o.product, move: 0 - (quantity - canceled)}));
} else {
}else {
o.product.lock(); o.product.lock();
o.product.stock -= quantity; o.product.stock -= quantity;
o.product.update(); o.product.update();
App.current.event(StockMove({product:o.product, move:0 - quantity})); App.current.event(StockMove({product: o.product, move: 0 - quantity}));
} }
} }
} }
return o; return o;
} }
/** /**
* Edit an existing order (quantity) * Edit an existing order (quantity)
*/ */
public static function edit(order:db.UserContract, newquantity:Float, ?paid:Bool , ?user2:db.User,?invert:Bool) { public static function edit(order:db.UserContract, newquantity:Float, ?paid:Bool, ?user2:db.User, ?invert:Bool) {
var t = sugoi.i18n.Locale.texts; var t = sugoi.i18n.Locale.texts;
order.lock(); order.lock();
//quantity // quantity
if (newquantity == null) newquantity = 0; if (newquantity == null)
if ( !canHaveFloatQt(order.product) ){ newquantity = 0;
if( !tools.FloatTool.isInt(newquantity) ) { if (!canHaveFloatQt(order.product)) {
throw new tink.core.Error(t._("Error : product \"::product::\" quantity should be integer",{product:order.product.name})); if (!tools.FloatTool.isInt(newquantity)) {
throw new tink.core.Error(t._("Error : product \"::product::\" quantity should be integer", {product: order.product.name}));
} }
} }
//paid // paid
if (paid != null) { if (paid != null) {
order.paid = paid; order.paid = paid;
}else { } else {
if (order.quantity < newquantity) order.paid = false; if (order.quantity < newquantity)
order.paid = false;
} }
//shared order // shared order
if (user2 != null){ if (user2 != null) {
order.user2 = user2; order.user2 = user2;
if (invert == true) order.flags.set(InvertSharedOrder); if (invert == true)
if (invert == false) order.flags.unset(InvertSharedOrder); order.flags.set(InvertSharedOrder);
}else{ if (invert == false)
order.flags.unset(InvertSharedOrder);
} else {
order.user2 = null; order.user2 = null;
order.flags.unset(InvertSharedOrder); order.flags.unset(InvertSharedOrder);
} }
//stocks // stocks
var e : Event = null; var e:Event = null;
if (order.product.stock != null) { if (order.product.stock != null) {
var c = order.product.contract; var c = order.product.contract;
if (c.hasStockManagement()) { if (c.hasStockManagement()) {
if (newquantity < order.quantity) { if (newquantity < order.quantity) {
// on commande moins que prévu : incrément de stock
//on commande moins que prévu : incrément de stock
order.product.lock(); order.product.lock();
order.product.stock += (order.quantity-newquantity); order.product.stock += (order.quantity - newquantity);
e = StockMove({product:order.product, move:0 - (order.quantity-newquantity) }); e = StockMove({product: order.product, move: 0 - (order.quantity - newquantity)});
} else {
}else { // on commande plus que prévu : décrément de stock
//on commande plus que prévu : décrément de stock
var addedquantity = newquantity - order.quantity; var addedquantity = newquantity - order.quantity;
if (order.product.stock - addedquantity < 0) { if (order.product.stock - addedquantity < 0) {
// stock is not enough, reduce order
//stock is not enough, reduce order
newquantity = order.quantity + order.product.stock; newquantity = order.quantity + order.product.stock;
if( App.current.session!=null) App.current.session.addMessage(t._("We reduced your order of '::productName::' to quantity ::oQuantity:: because there is no available products anymore", {productName:order.product.name, oQuantity:newquantity}), true); if (App.current.session != null)
App.current.session.addMessage(t._("We reduced your order of '::productName::' to quantity ::oQuantity:: because there is no available products anymore",
{
productName: order.product.name,
oQuantity: newquantity
}), true);
e = StockMove({product:order.product, move: 0 - order.product.stock }); e = StockMove({product: order.product, move: 0 - order.product.stock});
order.product.lock(); order.product.lock();
order.product.stock = 0; order.product.stock = 0;
} else {
}else{ // stock is big enough
//stock is big enough
order.product.lock(); order.product.lock();
order.product.stock -= addedquantity; order.product.stock -= addedquantity;
e = StockMove({ product:order.product, move: 0 - addedquantity }); e = StockMove({product: order.product, move: 0 - addedquantity});
} }
} }
order.product.update(); order.product.update();
} }
} }
//update order // update order
if (newquantity == 0) { if (newquantity == 0) {
order.quantity = 0; order.quantity = 0;
order.paid = true; order.paid = true;
order.update(); order.update();
}else { } else {
order.quantity = newquantity; order.quantity = newquantity;
order.update(); order.update();
} }
@@ -222,58 +228,54 @@ class OrderService
return order; return order;
} }
/** /**
* Delete an order * Delete an order
*/ */
public static function delete(order:db.UserContract) { public static function delete(order:db.UserContract) {
var t = sugoi.i18n.Locale.texts; var t = sugoi.i18n.Locale.texts;
if(order==null) throw new Error(t._("This order has already been deleted.")); if (order == null)
throw new Error(t._("This order has already been deleted."));
order.lock(); order.lock();
if (order.quantity == 0) { if (order.quantity == 0) {
var contract = order.product.contract; var contract = order.product.contract;
var user = order.user; var user = order.user;
//Amap Contract // Amap Contract
if ( contract.type == db.Contract.TYPE_CONSTORDERS ) { if (contract.type == db.Contract.TYPE_CONSTORDERS) {
order.delete(); order.delete();
if( contract.amap.hasPayments() ){ if (contract.amap.hasPayments()) {
var orders = contract.getUserOrders(user); var orders = contract.getUserOrders(user);
if( orders.length == 0 ){ if (orders.length == 0) {
var operation = db.Operation.findCOrderTransactionFor(contract, user); var operation = db.Operation.findCOrderTransactionFor(contract, user);
if(operation!=null) operation.delete(); if (operation != null)
operation.delete();
} }
} }
} } else { // Variable orders contract
else { //Variable orders contract
//Get the basket for this user // Get the basket for this user
var place = order.distribution.place; var place = order.distribution.place;
var basket = db.Basket.get(user, place, order.distribution.date); var basket = db.Basket.get(user, place, order.distribution.date);
if( contract.amap.hasPayments() ){ if (contract.amap.hasPayments()) {
var orders = basket.getOrders(); var orders = basket.getOrders();
//Check if it is the last order, if yes then delete the related operation // Check if it is the last order, if yes then delete the related operation
if( orders.length == 1 && orders.first().id==order.id ){ if (orders.length == 1 && orders.first().id == order.id) {
var operation = db.Operation.findVOrderTransactionFor(order.distribution.getKey(), user, place.amap); var operation = db.Operation.findVOrderTransactionFor(order.distribution.getKey(), user, place.amap);
if(operation!=null) operation.delete(); if (operation != null)
operation.delete();
} }
} }
order.delete(); order.delete();
} }
} } else {
else {
throw new Error(t._("Deletion not possible: quantity is not zero.")); throw new Error(t._("Deletion not possible: quantity is not zero."));
} }
} }
/** /**
@@ -285,21 +287,20 @@ class OrderService
var view = App.current.view; var view = App.current.view;
var t = sugoi.i18n.Locale.texts; var t = sugoi.i18n.Locale.texts;
for (o in orders) { for (o in orders) {
var x:UserOrder = cast {};
var x : UserOrder = cast { };
x.id = o.id; x.id = o.id;
x.userId = o.user.id; x.userId = o.user.id;
x.userName = o.user.getCoupleName(); x.userName = o.user.getCoupleName();
x.userEmail = o.user.email; x.userEmail = o.user.email;
//shared order // shared order
if (o.user2 != null){ if (o.user2 != null) {
x.userId2 = o.user2.id; x.userId2 = o.user2.id;
x.userName2 = o.user2.getCoupleName(); x.userName2 = o.user2.getCoupleName();
x.userEmail2 = o.user2.email; x.userEmail2 = o.user2.email;
} }
//deprecated // deprecated
x.productId = o.product.id; x.productId = o.product.id;
x.productRef = o.product.ref; x.productRef = o.product.ref;
x.productQt = o.product.qt; x.productQt = o.product.qt;
@@ -308,45 +309,42 @@ class OrderService
x.productImage = o.product.getImage(); x.productImage = o.product.getImage();
x.productHasFloatQt = o.product.hasFloatQt; x.productHasFloatQt = o.product.hasFloatQt;
x.productHasVariablePrice = o.product.variablePrice; x.productHasVariablePrice = o.product.variablePrice;
//new way // new way
x.product = o.product.infos(); x.product = o.product.infos();
x.product.price = o.productPrice;//do not use current price, but price of the order x.product.price = o.productPrice; // do not use current price, but price of the order
x.quantity = o.quantity; x.quantity = o.quantity;
//smartQt // smartQt
if (x.quantity == 0.0){ if (x.quantity == 0.0) {
x.smartQt = t._("Canceled"); x.smartQt = t._("Canceled");
}else if(x.productHasFloatQt || x.productHasVariablePrice || o.product.wholesale){ } else if (x.productHasFloatQt || x.productHasVariablePrice || o.product.wholesale) {
x.smartQt = view.smartQt(x.quantity, x.productQt, x.productUnit); x.smartQt = view.smartQt(x.quantity, x.productQt, x.productUnit);
}else{ } else {
x.smartQt = Std.string(x.quantity); x.smartQt = Std.string(x.quantity);
} }
//product name. // product name.
if ( x.productHasVariablePrice || x.productQt==null || x.productUnit==null ){ if (x.productHasVariablePrice || x.productQt == null || x.productUnit == null) {
x.productName = o.product.name; x.productName = o.product.name;
}else{ } else {
x.productName = o.product.name + " " + view.formatNum(x.productQt) +" "+ view.unit(x.productUnit,x.productQt>1); x.productName = o.product.name + " " + view.formatNum(x.productQt) + " " + view.unit(x.productUnit, x.productQt > 1);
} }
x.subTotal = o.quantity * o.productPrice; x.subTotal = o.quantity * o.productPrice;
var c = o.product.contract; var c = o.product.contract;
if ( o.feesRate!=0 ) { if (o.feesRate != 0) {
x.fees = x.subTotal * (o.feesRate / 100);
x.fees = x.subTotal * (o.feesRate/100);
x.percentageName = c.percentageName; x.percentageName = c.percentageName;
x.percentageValue = o.feesRate; x.percentageValue = o.feesRate;
x.total = x.subTotal + x.fees; x.total = x.subTotal + x.fees;
} else {
}else {
x.total = x.subTotal; x.total = x.subTotal;
} }
//flags // flags
x.paid = o.paid; x.paid = o.paid;
x.invertSharedOrder = o.flags.has(InvertSharedOrder); x.invertSharedOrder = o.flags.has(InvertSharedOrder);
x.contractId = c.id; x.contractId = c.id;
@@ -363,12 +361,12 @@ class OrderService
* Confirms an order : create real orders from tmp orders in session * Confirms an order : create real orders from tmp orders in session
* @param order * @param order
*/ */
public static function confirmSessionOrder(tmpOrder:OrderInSession){ public static function confirmSessionOrder(tmpOrder:OrderInSession) {
var orders = []; var orders = [];
var user = db.User.manager.get(tmpOrder.userId); var user = db.User.manager.get(tmpOrder.userId);
for (o in tmpOrder.products){ for (o in tmpOrder.products) {
o.product = db.Product.manager.get(o.productId); o.product = db.Product.manager.get(o.productId);
orders.push( make(user, o.quantity, o.product, o.distributionId) ); orders.push(make(user, o.quantity, o.product, o.distributionId));
} }
App.current.event(MakeOrder(orders)); App.current.event(MakeOrder(orders));
@@ -377,82 +375,89 @@ class OrderService
return orders; return orders;
} }
/** /**
* Send an order-by-products report to the coordinator * Send an order-by-products report to the coordinator
*/ */
public static function sendOrdersByProductReport(d:db.Distribution){ public static function sendOrdersByProductReport(d:db.Distribution) {
var t = sugoi.i18n.Locale.texts;
var m = new sugoi.mail.Mail(); var m = new sugoi.mail.Mail();
m.addRecipient(d.contract.contact.email , d.contract.contact.getName()); m.addRecipient(d.contract.contact.email, d.contract.contact.getName());
m.setSender(App.config.get("default_email"),"Cagette.net"); m.setSender(App.config.get("default_email"), t._("Cagette.net"));
m.setSubject('[${d.contract.amap.name}] Distribution du ${App.current.view.dDate(d.date)} (${d.contract.name})'); m.setSubject('[${d.contract.amap.name}] Distribution du ${App.current.view.dDate(d.date)} (${d.contract.name})');
var orders = service.ReportService.getOrdersByProduct(d); var orders = service.ReportService.getOrdersByProduct(d);
var html = App.current.processTemplate("mail/ordersByProduct.mtt", { var html = App.current.processTemplate("mail/ordersByProduct.mtt", {
contract:d.contract, contract: d.contract,
distribution:d, distribution: d,
orders:orders, orders: orders,
formatNum:App.current.view.formatNum, formatNum: App.current.view.formatNum,
currency:App.current.view.currency, currency: App.current.view.currency,
dDate:App.current.view.dDate, dDate: App.current.view.dDate,
hHour:App.current.view.hHour, hHour: App.current.view.hHour,
group:d.contract.amap group: d.contract.amap
} ); });
m.setHtmlBody(html); m.setHtmlBody(html);
App.sendMail(m); App.sendMail(m);
} }
/** /**
* Order summary for a member * Order summary for a member
* WARNING : its for one distrib, not for a whole basket ! * WARNING : its for one distrib, not for a whole basket !
*/ */
public static function sendOrderSummaryToMembers(d:db.Distribution){ public static function sendOrderSummaryToMembers(d:db.Distribution) {
var t = sugoi.i18n.Locale.texts;
var title = '[${d.contract.amap.name}] Votre commande pour le ${App.current.view.dDate(d.date)} (${d.contract.name})'; var title = '[${d.contract.amap.name}] Votre commande pour le ${App.current.view.dDate(d.date)} (${d.contract.name})';
for( user in d.getUsers() ){ for (user in d.getUsers()) {
var m = new sugoi.mail.Mail(); var m = new sugoi.mail.Mail();
m.addRecipient(user.email , user.getName(),user.id); m.addRecipient(user.email, user.getName(), user.id);
if(user.email2!=null) m.addRecipient(user.email2 , user.getName(),user.id); if (user.email2 != null)
m.setSender(App.config.get("default_email"),"Cagette.net"); m.addRecipient(user.email2, user.getName(), user.id);
m.setSender(App.config.get("default_email"), t._("Cagette.net"));
m.setSubject(title); m.setSubject(title);
var orders = prepare(d.contract.getUserOrders(user,d)); var orders = prepare(d.contract.getUserOrders(user, d));
var html = App.current.processTemplate("mail/orderSummaryForMember.mtt", { var html = App.current.processTemplate("mail/orderSummaryForMember.mtt", {
contract:d.contract, contract: d.contract,
distribution:d, distribution: d,
orders:orders, orders: orders,
formatNum:App.current.view.formatNum, formatNum: App.current.view.formatNum,
currency:App.current.view.currency, currency: App.current.view.currency,
dDate:App.current.view.dDate, dDate: App.current.view.dDate,
hHour:App.current.view.hHour, hHour: App.current.view.hHour,
group:d.contract.amap group: d.contract.amap
} ); });
m.setHtmlBody(html); m.setHtmlBody(html);
App.sendMail(m); App.sendMail(m);
} }
} }
public static function sort(orders:Array<UserOrder>) {
// order by lastname (+lastname2 if exists), then contract
public static function sort(orders:Array<UserOrder>){
//order by lastname (+lastname2 if exists), then contract
orders.sort(function(a, b) { orders.sort(function(a, b) {
if (a.userName
if (a.userName + a.userId + a.userName2 + a.userId2 + a.contractId > b.userName + b.userId + b.userName2 + b.userId2 + b.contractId ) { + a.userId
+ a.userName2
+ a.userId2
+ a.contractId > b.userName
+ b.userId
+ b.userName2
+ b.userId2
+ b.contractId) {
return 1; return 1;
} }
if (a.userName + a.userId + a.userName2 + a.userId2 + a.contractId < b.userName + b.userId + b.userName2 + b.userId2 + b.contractId ) { if (a.userName
+ a.userId
+ a.userName2
+ a.userId2
+ a.contractId < b.userName
+ b.userId
+ b.userName2
+ b.userId2
+ b.contractId) {
return -1; return -1;
} }
return 0; return 0;
@@ -460,9 +465,4 @@ class OrderService
return orders; return orders;
} }
} }
+60 -70
View File
@@ -1,4 +1,5 @@
package sugoi.db; package sugoi.db;
import sys.db.Types; import sys.db.Types;
import sugoi.mail.IMail; import sugoi.mail.IMail;
import sugoi.mail.IMailer; import sugoi.mail.IMailer;
@@ -6,127 +7,116 @@ import sugoi.mail.IMailer;
/** /**
* DB Buffer for emails * DB Buffer for emails
*/ */
@:index(remoteId,sdate,cdate) @:index(remoteId, sdate, cdate)
class BufferedMail extends sys.db.Object class BufferedMail extends sys.db.Object {
{ public var id:SId;
public var id : SId;
//email content // email content
public var title : SString<256>; public var title:SString<256>;
public var htmlBody : SNull<SText>; public var htmlBody:SNull<SText>;
public var textBody : SNull<SText>; public var textBody:SNull<SText>;
public var headers : SData<Map<String,String>>; public var headers:SData<Map<String, String>>;
public var sender : SData<{name:String,email:String,?userId:Int}>; public var sender:SData<{name:String, email:String, ?userId:Int}>;
public var recipients : SData<Array<{name:String,email:String,?userId:Int}>>; public var recipients:SData<Array<{name:String, email:String, ?userId:Int}>>;
//utility fields // utility fields
public var mailerType : SString<32>; //mailer used when sending for real public var mailerType:SString<32>; // mailer used when sending for real
public var tries : SInt; //number of times we tried to send the mail public var tries:SInt; // number of times we tried to send the mail
public var cdate : SDateTime; //creation date public var cdate:SDateTime; // creation date
public var sdate : SNull<SDateTime>; //sent date public var sdate:SNull<SDateTime>; // sent date
public var rawStatus : SNull<SText>; //raw return from the smtp server or mandrill API public var rawStatus:SNull<SText>; // raw return from the smtp server or mandrill API
public var status : SNull<SData<MailerResult>>; //map of emails with api/smtp results public var status:SNull<SData<MailerResult>>; // map of emails with api/smtp results
//custom datas // custom datas
public var data : SNull<SData<Dynamic>>;//custom datas public var data:SNull<SData<Dynamic>>; // custom datas
public var remoteId : SNull<Int>; //custom remote Id (userId, groupId ...) public var remoteId:SNull<Int>; // custom remote Id (userId, groupId ...)
public function getMailerResultMessage(k:String):{failure:String, success:String} {
public function getMailerResultMessage(k:String):{failure:String, success:String}{
var t = sugoi.i18n.Locale.texts; var t = sugoi.i18n.Locale.texts;
var out = {failure:null, success:null}; var out = {failure: null, success: null};
switch(status.get(k)){ switch (status.get(k)) {
case tink.core.Outcome.Failure(f): case tink.core.Outcome.Failure(f):
out.failure = switch(f){ out.failure = switch (f) {
case GenericError(e): t._("Generic error: ") + e.toString(); case GenericError(e): t._("Generic error: ") + e.toString();
case HardBounce : t._("Mailbox does not exist"); case HardBounce: t._("Mailbox does not exist");
case SoftBounce : t._("Mailbox full or blocked"); case SoftBounce: t._("Mailbox full or blocked");
case Spam: t._("Message considered as spam"); case Spam: t._("Message considered as spam");
case Unsub: t._("This user unsubscribed"); case Unsub: t._("This user unsubscribed");
case Unsigned: t._("Sender incorrect (Unsigned)"); case Unsigned: t._("Sender incorrect (Unsigned)");
}; };
case tink.core.Outcome.Success(s): case tink.core.Outcome.Success(s):
out.success = switch(s){ out.success = switch (s) {
case Sent : t._("Sent"); case Sent: t._("Sent");
case Queued : t._("Queued"); case Queued: t._("Queued");
}; };
} }
return out; return out;
} }
public function new() {
public function new(){
super(); super();
cdate = Date.now(); cdate = Date.now();
tries = 0; tries = 0;
} }
public function isSent(){ public function isSent() {
return sdate!=null; return sdate != null;
} }
/** /**
* Finally really send the message * Finally really send the message
*/ */
public function finallySend():Void{ public function finallySend():Void {
if (isSent())
if(isSent()) throw "already sent"; throw "already sent";
var conf = { var conf = {
smtp_host:sugoi.db.Variable.get("smtp_host"), smtp_host: sugoi.db.Variable.get("smtp_host"),
smtp_port:sugoi.db.Variable.getInt("smtp_port"), smtp_port: sugoi.db.Variable.getInt("smtp_port"),
smtp_user:sugoi.db.Variable.get("smtp_user"), smtp_user: sugoi.db.Variable.get("smtp_user"),
smtp_pass:sugoi.db.Variable.get("smtp_pass") smtp_pass: sugoi.db.Variable.get("smtp_pass")
}; };
var mailer : sugoi.mail.IMailer = switch(this.mailerType){ App.log('choose mail from ${this.mailerType}');
var mailer:sugoi.mail.IMailer = switch (this.mailerType) {
case "mandrill": case "mandrill":
new sugoi.mail.MandrillMailer().init(conf); new sugoi.mail.MandrillMailer().init(conf);
case "smtp": case "smtp":
new sugoi.mail.SmtpMailer().init(conf); new sugoi.mail.SendEmailMailer().init(conf);
case "debug": default:
new sugoi.mail.DebugMailer(); throw "Unknown mailer type : " + this.mailerType;
default :
throw "Unknown mailer type : "+this.mailerType;
}; };
var m = new sugoi.mail.Mail(); var m = new sugoi.mail.Mail();
for( k in this.headers.keys() ) m.setHeader( k,headers[k] ); for (k in this.headers.keys())
m.setHeader(k, headers[k]);
m.setSubject(this.title); m.setSubject(this.title);
for( r in recipients) m.setRecipient(r.email,r.name,r.userId); for (r in recipients)
m.setSender(sender.email,sender.name,sender.userId); m.setRecipient(r.email, r.name, r.userId);
m.setSender(sender.email, sender.name, sender.userId);
m.setHtmlBody(this.htmlBody); m.setHtmlBody(this.htmlBody);
m.setTextBody(this.textBody); m.setTextBody(this.textBody);
this.lock(); this.lock();
this.tries++; this.tries++;
try{ try {
mailer.send(m,null,afterSendCb); mailer.send(m, null, afterSendCb);
this.sdate = Date.now(); this.sdate = Date.now();
this.rawStatus = null; this.rawStatus = null;
}catch(e:Dynamic){ } catch (e:Dynamic) {
this.sdate = null; this.sdate = null;
this.rawStatus = Std.string(e); this.rawStatus = Std.string(e);
// App.current.logError( Std.string(e) ); // App.current.logError( Std.string(e) );
} }
this.update(); this.update();
} }
function afterSendCb(status:MailerResult) {
function afterSendCb(status:MailerResult){ // App.current.logError(status);
//App.current.logError(status);
this.status = status; this.status = status;
this.update(); this.update();
} }
} }
+17 -22
View File
@@ -1,4 +1,5 @@
package sugoi.mail; package sugoi.mail;
import sugoi.mail.IMail; import sugoi.mail.IMail;
import sugoi.mail.IMailer; import sugoi.mail.IMailer;
@@ -6,23 +7,21 @@ import sugoi.mail.IMailer;
* Manage an email buffer in a table before sending them * Manage an email buffer in a table before sending them
* @author fbarbut * @author fbarbut
*/ */
class BufferedMailer implements IMailer class BufferedMailer implements IMailer {
{ var conf:Dynamic;
var conf : Dynamic; var type:String;
var type : String;
public function new() {} public function new() {}
public function init(?c:Dynamic):IMailer{ public function init(?c:Dynamic):IMailer {
return this; return this;
} }
public function defineFinalMailer(type:String){ public function defineFinalMailer(type:String) {
this.type = type; this.type = type;
} }
public function send(m:sugoi.mail.IMail,?params:Dynamic,?callback:MailerResult->Void):Void{ public function send(m:sugoi.mail.IMail, ?params:Dynamic, ?callback:MailerResult->Void):Void {
var bm = new sugoi.db.BufferedMail(); var bm = new sugoi.db.BufferedMail();
bm.headers = m.getHeaders(); bm.headers = m.getHeaders();
bm.title = m.getTitle(); bm.title = m.getTitle();
@@ -33,29 +32,25 @@ class BufferedMailer implements IMailer
bm.mailerType = this.type; bm.mailerType = this.type;
//custom params // custom params
if(params!=null){ if (params != null) {
bm.data = params; bm.data = params;
if(Reflect.hasField(params,"remoteId")){ if (Reflect.hasField(params, "remoteId")) {
bm.remoteId = Reflect.getProperty(params,"remoteId"); bm.remoteId = Reflect.getProperty(params, "remoteId");
} }
} }
//set sending status as "queued" // set sending status as "queued"
var map = new MailerResult(); var map = new MailerResult();
for( r in m.getRecipients() ){ for (r in m.getRecipients()) {
map.set( r.email , Success(Queued) ); map.set(r.email, Success(Queued));
} }
bm.status = map; bm.status = map;
bm.insert(); bm.insert();
if(callback!=null) callback(map); App.log('email from=<${m.getSender().email}>, subject=<${m.getSubject()}> buffered, waiting for cron to be further processed');
if (callback != null)
callback(map);
} }
} }
+46 -39
View File
@@ -1,38 +1,46 @@
package sugoi.mail; package sugoi.mail;
using Lambda; using Lambda;
class Mail implements IMail class Mail implements IMail {
{ public var title:String;
public var htmlBody:String;
public var title : String; public var textBody:String;
public var htmlBody : String;
public var textBody : String;
var headers : Map<String,String>;
var sender : {name:String,email:String,?userId:Int};
var recipients : Array<{name:String,email:String,?userId:Int}>;
var headers:Map<String, String>;
var sender:{name:String, email:String, ?userId:Int};
var recipients:Array<{name:String, email:String, ?userId:Int}>;
static public function fromString(name:String, email:String) {
if (name == null)
return email;
else {
var finalName = thx.text.Diactrics.clean(name);
return '${finalName} <${email}>';
}
}
public function new() { public function new() {
recipients = []; recipients = [];
headers = new Map(); headers = new Map();
} }
public function getRecipients(){ public function getRecipients() {
return recipients; return recipients;
} }
public function setSender(email, ?name,?userId) { public function setSender(email, ?name, ?userId) {
if(!isValid(email)) throw "invalid sender email : \""+email+"\""; if (!isValid(email))
throw "invalid sender email : \"" + email + "\"";
sender = {name:name,email:email,userId:userId}; sender = {name: name, email: email, userId: userId};
return this; return this;
} }
public function setReplyTo(email, ?name) { public function setReplyTo(email, ?name) {
if(!isValid(email)) throw "invalid reply-to email : \""+email+"\""; if (!isValid(email))
throw "invalid reply-to email : \"" + email + "\"";
setHeader("Reply-To","<"+email+">"+(name==null?"":name)); setHeader("Reply-To", fromString(name, email));
} }
public function setSubject(s:String) { public function setSubject(s:String) {
@@ -47,8 +55,9 @@ class Mail implements IMail
* @param ?userId * @param ?userId
*/ */
public function addRecipient(email:String, ?name:String, ?userId:Int) { public function addRecipient(email:String, ?name:String, ?userId:Int) {
if(!isValid(email)) throw "invalid recipient \""+email+"\""; if (!isValid(email))
recipients.push( {email:email, name:name, userId:userId } ); throw "invalid recipient \"" + email + "\"";
recipients.push({email: email, name: name, userId: userId});
return this; return this;
} }
@@ -63,7 +72,7 @@ class Mail implements IMail
return this; return this;
} }
public static function isValid( addr : String ){ public static function isValid(addr:String) {
var reg = ~/^[^()<>@,;:\\"\[\]\s[:cntrl:]]+@[A-Z0-9][A-Z0-9-]*(\.[A-Z0-9][A-Z0-9-]*)*\.(xn--[A-Z0-9]+|[A-Z]{2,8})$/i; var reg = ~/^[^()<>@,;:\\"\[\]\s[:cntrl:]]+@[A-Z0-9][A-Z0-9-]*(\.[A-Z0-9][A-Z0-9-]*)*\.(xn--[A-Z0-9]+|[A-Z]{2,8})$/i;
return addr != null && reg.match(addr); return addr != null && reg.match(addr);
} }
@@ -77,7 +86,7 @@ class Mail implements IMail
* generate a custom key for transactionnal emails, valid during the current day * generate a custom key for transactionnal emails, valid during the current day
*/ */
public function getKey() { public function getKey() {
return haxe.crypto.Md5.encode(App.config.get("key")+recipients[0].email+(Date.now().getDate())).substr(0,12); return haxe.crypto.Md5.encode(App.config.get("key") + recipients[0].email + (Date.now().getDate())).substr(0, 12);
} }
/** /**
@@ -88,7 +97,8 @@ class Mail implements IMail
public function setHtmlBodyWithTemplate(tpl, ctx:Dynamic) { public function setHtmlBodyWithTemplate(tpl, ctx:Dynamic) {
var app = App.current; var app = App.current;
var tpl = app.loadTemplate(tpl); var tpl = app.loadTemplate(tpl);
if( ctx == null ) ctx = { }; if (ctx == null)
ctx = {};
ctx.HOST = App.config.HOST; ctx.HOST = App.config.HOST;
ctx.key = getKey(); ctx.key = getKey();
ctx.senderName = sender.name; ctx.senderName = sender.name;
@@ -98,7 +108,6 @@ class Mail implements IMail
ctx.recipients = recipients; ctx.recipients = recipients;
CSSInlining(ctx); CSSInlining(ctx);
htmlBody = tpl.execute(ctx); htmlBody = tpl.execute(ctx);
} }
public function setHtmlBody(s) { public function setHtmlBody(s) {
@@ -109,17 +118,17 @@ class Mail implements IMail
public function setTextBodyWithTemplate(tpl, ctx:Dynamic) { public function setTextBodyWithTemplate(tpl, ctx:Dynamic) {
var app = App.current; var app = App.current;
var tpl = app.loadTemplate(tpl); var tpl = app.loadTemplate(tpl);
if( ctx == null ) ctx = { }; if (ctx == null)
ctx = {};
ctx.HOST = App.config.HOST; ctx.HOST = App.config.HOST;
ctx.key = getKey(); ctx.key = getKey();
textBody = tpl.execute(ctx); textBody = tpl.execute(ctx);
return this; return this;
} }
function CSSInlining(ctx) { function CSSInlining(ctx) {
// CSS inlining // CSS inlining
var css : Map<String,Array<String>> = new Map(); var css:Map<String, Array<String>> = new Map();
ctx.addStyle = function(sel:String, style:String) { ctx.addStyle = function(sel:String, style:String) {
sel = sel.toLowerCase(); sel = sel.toLowerCase();
if (css.exists(sel)) if (css.exists(sel))
@@ -130,11 +139,11 @@ class Mail implements IMail
} }
var applyStyleRec = null; var applyStyleRec = null;
applyStyleRec = function(x:Xml) { applyStyleRec = function(x:Xml) {
if (x.nodeType==Xml.Element) { if (x.nodeType == Xml.Element) {
var name = x.nodeName.toLowerCase(); var name = x.nodeName.toLowerCase();
if( css.exists(name) ) if (css.exists(name))
if (x.get("style")!=null) if (x.get("style") != null)
x.set("style", x.get("style")+";"+css.get(name).join(";")); x.set("style", x.get("style") + ";" + css.get(name).join(";"));
else else
x.set("style", css.get(name).join(";")); x.set("style", css.get(name).join(";"));
for (n in x) for (n in x)
@@ -143,40 +152,38 @@ class Mail implements IMail
} }
ctx.applyStyle = function(raw:String) { ctx.applyStyle = function(raw:String) {
var x = Xml.parse(raw); var x = Xml.parse(raw);
for(n in x) for (n in x)
applyStyleRec(n); applyStyleRec(n);
return x.toString(); return x.toString();
} }
} }
public function getSubject() {
public function getSubject(){
return title; return title;
} }
public function getTitle(){ public function getTitle() {
return getSubject(); return getSubject();
} }
public function getHtmlBody(){ public function getHtmlBody() {
return htmlBody; return htmlBody;
} }
public function getTextBody(){ public function getTextBody() {
return textBody; return textBody;
} }
public function setTextBody(t){ public function setTextBody(t) {
textBody = t; textBody = t;
return this; return this;
} }
public function getHeaders(){ public function getHeaders() {
return headers; return headers;
} }
public function getSender(){ public function getSender() {
return sender; return sender;
} }
} }
+114
View File
@@ -0,0 +1,114 @@
package sugoi.mail;
import tink.core.Future;
import tink.core.Noise;
import sugoi.mail.IMailer;
import smtpmailer.Address;
typedef SmtpInfo = {
host:String,
port:Int,
auth:{
username:String, password:String
}
}
/**
* Send emails thru OS command `sendemail`
* requires: `apt install sendemail libio-socket-ssl-perl libnet-ssleay-perl`
*/
class SendEmailMailer implements IMailer {
var m:SmtpInfo;
public function new() {}
public function init(?conf:{
smtp_host:String,
smtp_port:Int,
smtp_user:String,
smtp_pass:String
}):IMailer {
var mailer:SendEmailMailer = new SendEmailMailer();
mailer.m = {
host: conf.smtp_host,
port: conf.smtp_port,
auth: {
username: conf.smtp_user,
password: conf.smtp_pass
}
};
return mailer;
}
public function send(e:sugoi.mail.IMail, ?params:Dynamic, ?callback:MailerResult->Void) {
var to:String;
var bcc:String;
var recipientCounts = e.getRecipients().length;
if (recipientCounts > 1) {
to = sugoi.mail.Mail.fromString(e.getSender().name, e.getSender().email);
bcc = [for (i in e.getRecipients()) i.email].join(",");
App.log('recipients has been transformed to ${recipientCounts} bcc');
App.log(bcc);
} else {
to = e.getRecipients()[0].email;
bcc = "";
}
var args = [
// arguments
"-s",
'${this.m.host}:${this.m.port}',
"-xu",
${this.m.auth.username},
"-xp",
${this.m.auth.password},
"-o",
"message-charset=utf-8",
"-o",
"message-format=html",
"-o",
"message-header=X-Mailer: CagettePei",
"-f",
sugoi.mail.Mail.fromString(e.getSender().name, e.getSender().email),
"-t",
to,
"-bcc",
bcc,
"-u",
e.getSubject(),
];
// FIME: deal with replyTo
if (e.getHeaders().exists("Reply-To")) {
var replyTo = e.getHeaders()["Reply-To"];
App.log('replyTo "$replyTo" detected');
args.push("-o");
args.push('message-header=Reply-To: ${replyTo}');
}
args.push("-m");
args.push('<html>${e.getHtmlBody()}</html>');
// if (App.config.DEBUG)
// App.log('args=${args.join(" ")}');
var exitCode = Sys.command("sendemail", args);
// var exitCode = 0;
var summary = 'email from="${sugoi.mail.Mail.fromString(e.getSender().name, e.getSender().email)}" subject=<${e.getSubject()}>';
if (exitCode == 0)
App.log('$summary successfully sent');
else
App.log('ERROR: $summary cannot be sent, please review logs');
if (callback != null) {
var map = new MailerResult();
if (exitCode == 0)
map.set("*", Success(Sent));
else
map.set("*", Failure(HardBounce));
callback(map);
}
}
}
-68
View File
@@ -1,68 +0,0 @@
package sugoi.mail;
import tink.core.Future;
import tink.core.Noise;
import sugoi.mail.IMailer;
import smtpmailer.Address;
/**
* Send emails thru SMTP by using ben merckx's library
* @ref https://github.com/benmerckx/smtpmailer
*/
class SmtpMailer implements IMailer
{
var m : smtpmailer.SmtpMailer;
public function new(){}
public function init(?conf:{smtp_host:String,smtp_port:Int,smtp_user:String,smtp_pass:String}) :IMailer
{
m = new smtpmailer.SmtpMailer({
host: conf.smtp_host,
port: conf.smtp_port,
auth: {
username: conf.smtp_user,
password: conf.smtp_pass
}
});
return this;
}
public function send(e:sugoi.mail.IMail,?params:Dynamic,?callback:MailerResult->Void)
{
var surprise = m.send({
subject: e.getSubject(),
/*from: e.getSender().email,
to: Lambda.array(Lambda.map(e.getRecipients(), function(x) return smtpmailer.Address.ofString(x.email) )),
//headers : e.getHeaders(),*/
from: new Address({address:e.getSender().email}),
to: Lambda.array(Lambda.map(e.getRecipients(), function(x) return new Address({address:x.email}) )),
headers : e.getHeaders(),
content: {
text: e.getTextBody(),
html: e.getHtmlBody()
}/*,
attachments: []*/
});
if (callback != null){
surprise.handle(function(s){
var map = new MailerResult();
switch(s){
case Success(_):
map.set("*",Success(Sent));
case Failure(e):
map.set("*",Failure(GenericError(e)));
}
callback(map);
});
}
}
}