Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
278f69e7d9 | ||
|
|
8699728593 | ||
|
|
b14688417d | ||
|
|
ea4da3c270 | ||
|
|
ef7b09454c | ||
|
|
c23e3533d8 | ||
|
|
88b2549243 | ||
|
|
a1ece5258a |
+1
-1
@@ -1 +1 @@
|
|||||||
1.9.0
|
1.10.2
|
||||||
|
|||||||
@@ -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)
|
||||||
|
|||||||
@@ -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
|
||||||
|
|||||||
+16
-20
@@ -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,13 +20,12 @@ 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};
|
||||||
}
|
}
|
||||||
@@ -35,7 +35,6 @@ class LoginBox extends react.ReactComponentOfPropsAndState<LoginBoxProps,LoginBo
|
|||||||
}
|
}
|
||||||
|
|
||||||
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>
|
<b>C\'est votre première visite sur CagettePéi ?</b>
|
||||||
<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>
|
||||||
-->
|
-->
|
||||||
@@ -85,7 +84,6 @@ 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);
|
||||||
|
|
||||||
@@ -94,7 +92,6 @@ class LoginBox extends react.ReactComponentOfPropsAndState<LoginBoxProps,LoginBo
|
|||||||
}
|
}
|
||||||
|
|
||||||
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;
|
||||||
@@ -111,29 +108,28 @@ class LoginBox extends react.ReactComponentOfPropsAndState<LoginBoxProps,LoginBo
|
|||||||
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();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -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"/>
|
||||||
|
|||||||
@@ -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>
|
||||||
@@ -199,7 +199,7 @@
|
|||||||
<!--
|
<!--
|
||||||
::raw _("Cagette.net is made by <a href='https://www.alilo.fr' target='_blank'><img src='/img/alilo-trans-black.png' /></a>")::<br/>
|
::raw _("Cagette.net is made by <a href='https://www.alilo.fr' target='_blank'><img src='/img/alilo-trans-black.png' /></a>")::<br/>
|
||||||
-->
|
-->
|
||||||
<span>version ::VERSION::</span>
|
<span>version cagettepei-<a href="https://git.artcode.re/cagetters/cagettepei/src/tag/::VERSION::">::VERSION::</a></span>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div class="row">
|
<div class="row">
|
||||||
|
|||||||
+2
-2
@@ -1,5 +1,5 @@
|
|||||||
{
|
{
|
||||||
"name": "CagettePei",
|
"name": "cagette-pei",
|
||||||
"description": "le logiciel libre du circuit court",
|
"description": "le logiciel libre du circuit court",
|
||||||
"license": "AGPL-3.0",
|
"license": "AGPL-3.0",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
@@ -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.2"
|
||||||
}
|
}
|
||||||
|
|||||||
+28
-14
@@ -16,7 +16,8 @@ class App extends sugoi.BaseApp {
|
|||||||
*/
|
*/
|
||||||
// public static var VERSION = ([0,9,2] : Version).withPre("july");
|
// public static var VERSION = ([0,9,2] : Version).withPre("july");
|
||||||
// public static var VERSION = ([0,9,2] : Version).withPre(MyMacros.getGitShortSHA(), MyMacros.getGitCommitDate());
|
// public static var VERSION = ([0,9,2] : Version).withPre(MyMacros.getGitShortSHA(), MyMacros.getGitCommitDate());
|
||||||
public static var VERSION = "cagette-péi " + MyMacros.getGitCommitDate();
|
// public static var VERSION = "cagette-péi " + MyMacros.getGitCommitDate();
|
||||||
|
public static var VERSION = "cagette-pei"; // empty yet, cf.BaseApp.loadConfig
|
||||||
|
|
||||||
public function new() {
|
public function new() {
|
||||||
super();
|
super();
|
||||||
@@ -77,10 +78,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,17 +235,28 @@ 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 (App.config.DEBUG) {
|
if (typeOfMailer == null) {
|
||||||
App.log("DEBUGEmailer enabled => emails are written to tmp folder");
|
|
||||||
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>");
|
var msg = sugoi.i18n.Locale.texts._("Please configure the email settings in a <href='/admin/emails'>this section</a>");
|
||||||
throw sugoi.ControllerAction.ErrorAction("/", msg);
|
throw sugoi.ControllerAction.ErrorAction("/", msg);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (App.config.DEBUG) {
|
||||||
|
App.log('mailer in DEBUG mode, no deferred mail from CRON');
|
||||||
|
|
||||||
|
var conf = {
|
||||||
|
smtp_host: sugoi.db.Variable.get("smtp_host"),
|
||||||
|
smtp_port: sugoi.db.Variable.getInt("smtp_port"),
|
||||||
|
smtp_user: sugoi.db.Variable.get("smtp_user"),
|
||||||
|
smtp_pass: sugoi.db.Variable.get("smtp_pass")
|
||||||
|
};
|
||||||
|
|
||||||
|
return new sugoi.mail.SendEmailMailer().init(conf);
|
||||||
|
}
|
||||||
|
|
||||||
|
var mailer:sugoi.mail.IMailer = new sugoi.mail.BufferedMailer();
|
||||||
if (sugoi.db.Variable.get("mailer") == "mandrill") {
|
if (sugoi.db.Variable.get("mailer") == "mandrill") {
|
||||||
// Buffered emails with Mandrill
|
// Buffered emails with Mandrill
|
||||||
untyped mailer.defineFinalMailer("mandrill");
|
untyped mailer.defineFinalMailer("mandrill");
|
||||||
@@ -248,7 +264,6 @@ class App extends sugoi.BaseApp {
|
|||||||
// Buffered emails with SMTP
|
// Buffered emails with SMTP
|
||||||
untyped mailer.defineFinalMailer("smtp");
|
untyped mailer.defineFinalMailer("smtp");
|
||||||
}
|
}
|
||||||
}
|
|
||||||
return mailer;
|
return mailer;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -265,7 +280,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 +288,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);
|
||||||
|
|||||||
@@ -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);
|
||||||
}
|
}
|
||||||
|
|||||||
+125
-121
@@ -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,14 +7,11 @@ 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
|
||||||
@@ -25,65 +23,73 @@ class Member extends Controller
|
|||||||
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) {
|
} else if (args != null && args.select != null) {
|
||||||
|
|
||||||
// SELECTION
|
// SELECTION
|
||||||
|
|
||||||
switch (args.select) {
|
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
|
||||||
@@ -103,14 +109,12 @@ class Member extends Controller
|
|||||||
}
|
}
|
||||||
|
|
||||||
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();
|
||||||
|
|
||||||
@@ -120,8 +124,6 @@ class Member extends Controller
|
|||||||
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."));
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -129,18 +131,13 @@ class Member extends Controller
|
|||||||
*/
|
*/
|
||||||
@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);
|
service.WaitingListService.approveRequest(args.add, app.user.amap);
|
||||||
throw Ok("/member/waiting", t._("Membership request accepted"));
|
throw Ok("/member/waiting", t._("Membership request accepted"));
|
||||||
|
|
||||||
} else if (args.remove != null) {
|
} else if (args.remove != null) {
|
||||||
|
|
||||||
service.WaitingListService.cancelRequest(args.remove, app.user.amap);
|
service.WaitingListService.cancelRequest(args.remove, app.user.amap);
|
||||||
throw Ok("/member/waiting", t._("Membership request refused"));
|
throw Ok("/member/waiting", t._("Membership request refused"));
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -151,21 +148,17 @@ class Member extends Controller
|
|||||||
* 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) {
|
||||||
@@ -181,16 +174,14 @@ class Member extends Controller
|
|||||||
|
|
||||||
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();
|
||||||
@@ -199,12 +190,16 @@ class Member extends Controller
|
|||||||
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
|
||||||
|
&& $amap == app.user.amap
|
||||||
|
&& $endDate > DateTools.delta(Date.now(), -1000.0 * 60 * 60 * 24 * 30), false);
|
||||||
var distribs = new Map<String, List<db.UserContract>>();
|
var distribs = new Map<String, List<db.UserContract>>();
|
||||||
for (c in contracts) {
|
for (c in contracts) {
|
||||||
var ds = c.getDistribs();
|
var ds = c.getDistribs();
|
||||||
@@ -215,9 +210,9 @@ class Member extends Controller
|
|||||||
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);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -229,10 +224,8 @@ class Member extends Controller
|
|||||||
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,12 +234,13 @@ 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()) return;
|
if (!app.user.isAmapManager())
|
||||||
if (member.isAdmin()) return;
|
return;
|
||||||
if ( db.UserAmap.manager.count($userId == member.id) > 1 ) return;
|
if (member.isAdmin())
|
||||||
|
return;
|
||||||
|
if (db.UserAmap.manager.count($userId == member.id) > 1)
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
App.current.session.setUser(member);
|
App.current.session.setUser(member);
|
||||||
@@ -256,20 +250,26 @@ class Member extends Controller
|
|||||||
|
|
||||||
@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,8 +279,8 @@ 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);
|
||||||
|
|
||||||
@@ -290,7 +290,6 @@ class Member extends Controller
|
|||||||
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);
|
||||||
|
|
||||||
@@ -310,7 +309,6 @@ class Member extends Controller
|
|||||||
}
|
}
|
||||||
|
|
||||||
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."));
|
||||||
}
|
}
|
||||||
@@ -320,17 +318,16 @@ class Member extends Controller
|
|||||||
// 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(",");
|
||||||
@@ -339,28 +336,33 @@ class Member extends Controller
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
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);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -369,19 +371,24 @@ class Member extends Controller
|
|||||||
}
|
}
|
||||||
|
|
||||||
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 (user.id == app.user.id)
|
||||||
|
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) {
|
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}));
|
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);
|
||||||
@@ -398,8 +405,8 @@ class Member extends Controller
|
|||||||
|
|
||||||
@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.");
|
||||||
@@ -414,7 +421,6 @@ class Member extends Controller
|
|||||||
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);
|
||||||
@@ -426,8 +432,10 @@ class Member extends Controller
|
|||||||
// 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();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -453,27 +461,23 @@ class Member extends Controller
|
|||||||
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 {
|
||||||
@@ -491,17 +495,20 @@ 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();
|
||||||
|
if (user[5] != null)
|
||||||
|
user[5] = user[5].toUpperCase();
|
||||||
// lowercase email
|
// lowercase email
|
||||||
if (user[2] != null) {
|
if (user[2] != null) {
|
||||||
user[2] = user[2].toLowerCase();
|
user[2] = user[2].toLowerCase();
|
||||||
@@ -515,7 +522,6 @@ class Member extends Controller
|
|||||||
|
|
||||||
// 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) {
|
||||||
@@ -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,13 +562,12 @@ 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];
|
||||||
@@ -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];
|
||||||
@@ -601,7 +606,8 @@ class Member extends Controller
|
|||||||
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) {
|
||||||
@@ -630,8 +636,8 @@ 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);
|
||||||
@@ -645,17 +651,16 @@ class Member extends Controller
|
|||||||
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) {
|
||||||
@@ -672,7 +677,6 @@ class Member extends Controller
|
|||||||
}*/
|
}*/
|
||||||
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."));
|
||||||
}
|
}
|
||||||
@@ -691,29 +695,30 @@ 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>;
|
||||||
|
|
||||||
@@ -737,5 +742,4 @@ class Member extends Controller
|
|||||||
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);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -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;
|
||||||
|
|||||||
+66
-66
@@ -1,4 +1,5 @@
|
|||||||
package service;
|
package service;
|
||||||
|
|
||||||
import Common;
|
import Common;
|
||||||
import tink.core.Error;
|
import tink.core.Error;
|
||||||
|
|
||||||
@@ -6,9 +7,7 @@ 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,11 +19,12 @@ 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)) {
|
||||||
@@ -35,7 +35,8 @@ class OrderService
|
|||||||
|
|
||||||
// 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)) {
|
||||||
@@ -45,7 +46,8 @@ class OrderService
|
|||||||
}
|
}
|
||||||
|
|
||||||
// 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>();
|
||||||
@@ -66,10 +68,13 @@ 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) {
|
||||||
@@ -97,7 +102,8 @@ class OrderService
|
|||||||
// 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) {
|
||||||
@@ -110,14 +116,14 @@ class OrderService
|
|||||||
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;
|
||||||
@@ -129,18 +135,17 @@ class OrderService
|
|||||||
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)
|
||||||
|
newquantity = 0;
|
||||||
if (!canHaveFloatQt(order.product)) {
|
if (!canHaveFloatQt(order.product)) {
|
||||||
if (!tools.FloatTool.isInt(newquantity)) {
|
if (!tools.FloatTool.isInt(newquantity)) {
|
||||||
throw new tink.core.Error(t._("Error : product \"::product::\" quantity should be integer", {product: order.product.name}));
|
throw new tink.core.Error(t._("Error : product \"::product::\" quantity should be integer", {product: order.product.name}));
|
||||||
@@ -151,14 +156,17 @@ class OrderService
|
|||||||
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);
|
||||||
|
if (invert == false)
|
||||||
|
order.flags.unset(InvertSharedOrder);
|
||||||
} else {
|
} else {
|
||||||
order.user2 = null;
|
order.user2 = null;
|
||||||
order.flags.unset(InvertSharedOrder);
|
order.flags.unset(InvertSharedOrder);
|
||||||
@@ -170,32 +178,30 @@ class OrderService
|
|||||||
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;
|
||||||
@@ -222,36 +228,34 @@ 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;
|
||||||
@@ -262,18 +266,16 @@ class OrderService
|
|||||||
// 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,7 +287,6 @@ 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;
|
||||||
@@ -312,7 +313,6 @@ class OrderService
|
|||||||
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
|
||||||
@@ -336,12 +336,10 @@ class OrderService
|
|||||||
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;
|
||||||
}
|
}
|
||||||
@@ -377,15 +375,15 @@ 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);
|
||||||
|
|
||||||
@@ -402,24 +400,22 @@ class OrderService
|
|||||||
|
|
||||||
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));
|
||||||
|
|
||||||
@@ -437,22 +433,31 @@ class OrderService
|
|||||||
m.setHtmlBody(html);
|
m.setHtmlBody(html);
|
||||||
App.sendMail(m);
|
App.sendMail(m);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
public static function sort(orders:Array<UserOrder>) {
|
public static function sort(orders:Array<UserOrder>) {
|
||||||
|
|
||||||
// order by lastname (+lastname2 if exists), then contract
|
// 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;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
+45
-35
@@ -1,9 +1,9 @@
|
|||||||
package sugoi;
|
package sugoi;
|
||||||
|
|
||||||
import sugoi.i18n.TemplateTranslator;
|
import sugoi.i18n.TemplateTranslator;
|
||||||
import sugoi.Web;
|
import sugoi.Web;
|
||||||
|
|
||||||
class BaseApp {
|
class BaseApp {
|
||||||
|
|
||||||
public var cnx:sys.db.Connection;
|
public var cnx:sys.db.Connection;
|
||||||
public var template:templo.Loader;
|
public var template:templo.Loader;
|
||||||
public var maintain:Bool;
|
public var maintain:Bool;
|
||||||
@@ -16,10 +16,10 @@ class BaseApp {
|
|||||||
public var uri:String;
|
public var uri:String;
|
||||||
|
|
||||||
public static var config:Config;
|
public static var config:Config;
|
||||||
|
|
||||||
// public static var classPathes = sugoi.tools.Macros.getClassPathes();
|
// public static var classPathes = sugoi.tools.Macros.getClassPathes();
|
||||||
|
|
||||||
public function new() {
|
public function new() {
|
||||||
|
|
||||||
if (config == null) {
|
if (config == null) {
|
||||||
loadConfig();
|
loadConfig();
|
||||||
}
|
}
|
||||||
@@ -28,24 +28,33 @@ class BaseApp {
|
|||||||
cookieDomain = "." + App.config.HOST;
|
cookieDomain = "." + App.config.HOST;
|
||||||
|
|
||||||
#if plugins
|
#if plugins
|
||||||
if( false ) sugoi.plugin.PlugIn.copyTpl();
|
if (false)
|
||||||
|
sugoi.plugin.PlugIn.copyTpl();
|
||||||
#end
|
#end
|
||||||
|
|
||||||
// This macro generates translated templates for each langage
|
// This macro generates translated templates for each langage
|
||||||
#if i18n_generation
|
#if i18n_generation
|
||||||
if( false ) TemplateTranslator.parse("lang/master");
|
if (false)
|
||||||
|
TemplateTranslator.parse("lang/master");
|
||||||
#end
|
#end
|
||||||
}
|
}
|
||||||
|
|
||||||
public function loadConfig() {
|
public function loadConfig() {
|
||||||
App.config = BaseApp.config = new sugoi.Config();
|
App.config = BaseApp.config = new sugoi.Config();
|
||||||
|
|
||||||
|
var PATH = Web.getCwd() + "../";
|
||||||
|
var json = haxe.Json.parse(sys.io.File.getContent(PATH + "package.json"));
|
||||||
|
App.VERSION = json.version;
|
||||||
|
|
||||||
|
App.log('configuration has been reloaded, VERSION=${App.VERSION}');
|
||||||
}
|
}
|
||||||
|
|
||||||
public function loadTemplate(t:String) {
|
public function loadTemplate(t:String) {
|
||||||
templo.Loader.OPTIMIZED = App.config.DEBUG == false;
|
templo.Loader.OPTIMIZED = App.config.DEBUG == false;
|
||||||
templo.Loader.BASE_DIR = App.config.TPL;
|
templo.Loader.BASE_DIR = App.config.TPL;
|
||||||
templo.Loader.TMP_DIR = App.config.TPL_TMP;
|
templo.Loader.TMP_DIR = App.config.TPL_TMP;
|
||||||
if ( t == null ) return null;
|
if (t == null)
|
||||||
|
return null;
|
||||||
#if neko
|
#if neko
|
||||||
return new templo.Loader(t, App.config.getBool("cachetpl"));
|
return new templo.Loader(t, App.config.getBool("cachetpl"));
|
||||||
#else
|
#else
|
||||||
@@ -58,8 +67,8 @@ class BaseApp {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public function initLang(lang:String) {
|
public function initLang(lang:String) {
|
||||||
|
if (lang == null || lang == "")
|
||||||
if (lang == null || lang == "") lang = config.LANG;
|
lang = config.LANG;
|
||||||
|
|
||||||
// Define template path
|
// Define template path
|
||||||
var path;
|
var path;
|
||||||
@@ -83,8 +92,8 @@ class BaseApp {
|
|||||||
}
|
}
|
||||||
|
|
||||||
function saveAndClose() {
|
function saveAndClose() {
|
||||||
|
if (cnx == null)
|
||||||
if( cnx == null ) return;
|
return;
|
||||||
if (session.sid != null)
|
if (session.sid != null)
|
||||||
session.update();
|
session.update();
|
||||||
|
|
||||||
@@ -97,10 +106,12 @@ class BaseApp {
|
|||||||
function executeTemplate(?save) {
|
function executeTemplate(?save) {
|
||||||
view.init();
|
view.init();
|
||||||
var result = template.execute(view);
|
var result = template.execute(view);
|
||||||
if ( save ) saveAndClose();
|
if (save)
|
||||||
|
saveAndClose();
|
||||||
#if php
|
#if php
|
||||||
// strange bug with templo in PHP
|
// strange bug with templo in PHP
|
||||||
if (result.substr(0, 4) == "null") result = result.substr(4);
|
if (result.substr(0, 4) == "null")
|
||||||
|
result = result.substr(4);
|
||||||
#end
|
#end
|
||||||
Sys.print(result);
|
Sys.print(result);
|
||||||
}
|
}
|
||||||
@@ -137,14 +148,13 @@ class BaseApp {
|
|||||||
return App.config.LANG;
|
return App.config.LANG;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Setup current app language
|
* Setup current app language
|
||||||
*/
|
*/
|
||||||
function setupLang() {
|
function setupLang() {
|
||||||
|
|
||||||
// this app is monolingual and doesn't manage i18n
|
// this app is monolingual and doesn't manage i18n
|
||||||
if (App.config.LANG == "master") return;
|
if (App.config.LANG == "master")
|
||||||
|
return;
|
||||||
|
|
||||||
// lang is taken from user object or from HTTP headers
|
// lang is taken from user object or from HTTP headers
|
||||||
if (session.lang == null || !Lambda.has(App.config.LANGS, session.lang)) {
|
if (session.lang == null || !Lambda.has(App.config.LANGS, session.lang)) {
|
||||||
@@ -155,7 +165,6 @@ class BaseApp {
|
|||||||
var lang = params.get("lang");
|
var lang = params.get("lang");
|
||||||
if (lang != null && Lambda.has(App.config.LANGS, lang)) {
|
if (lang != null && Lambda.has(App.config.LANGS, lang)) {
|
||||||
session.lang = lang;
|
session.lang = lang;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// init lang
|
// init lang
|
||||||
@@ -170,7 +179,8 @@ class BaseApp {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public function rollback() {
|
public function rollback() {
|
||||||
if( cnx != null ) cnx.rollback();
|
if (cnx != null)
|
||||||
|
cnx.rollback();
|
||||||
sys.db.Manager.cleanup();
|
sys.db.Manager.cleanup();
|
||||||
if (user != null && session != null)
|
if (user != null && session != null)
|
||||||
user = session.user;
|
user = session.user;
|
||||||
@@ -189,8 +199,10 @@ class BaseApp {
|
|||||||
// Get session
|
// Get session
|
||||||
var sids = [];
|
var sids = [];
|
||||||
var cookieSid = Web.getCookies().get(cookieName);
|
var cookieSid = Web.getCookies().get(cookieName);
|
||||||
if( params.exists("sid") ) sids.push(params.get("sid"));
|
if (params.exists("sid"))
|
||||||
if( cookieSid != null ) sids.push(cookieSid);
|
sids.push(params.get("sid"));
|
||||||
|
if (cookieSid != null)
|
||||||
|
sids.push(cookieSid);
|
||||||
session = sugoi.db.Session.init(sids);
|
session = sugoi.db.Session.init(sids);
|
||||||
|
|
||||||
// Check for maintenance
|
// Check for maintenance
|
||||||
@@ -200,7 +212,6 @@ class BaseApp {
|
|||||||
// setup langage
|
// setup langage
|
||||||
setupLang();
|
setupLang();
|
||||||
|
|
||||||
|
|
||||||
if (maintain && ((user != null && user.isAdmin())))
|
if (maintain && ((user != null && user.isAdmin())))
|
||||||
maintain = false;
|
maintain = false;
|
||||||
|
|
||||||
@@ -214,9 +225,9 @@ class BaseApp {
|
|||||||
|
|
||||||
// dispatching
|
// dispatching
|
||||||
try {
|
try {
|
||||||
|
|
||||||
uri = Web.getURI();
|
uri = Web.getURI();
|
||||||
if ( StringTools.endsWith(uri, "/index.n") ) uri = uri.substr(0, -8);
|
if (StringTools.endsWith(uri, "/index.n"))
|
||||||
|
uri = uri.substr(0, -8);
|
||||||
|
|
||||||
// "before dispatch" callback
|
// "before dispatch" callback
|
||||||
beforeDispatch();
|
beforeDispatch();
|
||||||
@@ -224,9 +235,7 @@ class BaseApp {
|
|||||||
var d = new haxe.web.Dispatch(uri, params);
|
var d = new haxe.web.Dispatch(uri, params);
|
||||||
d.onMeta = onMeta;
|
d.onMeta = onMeta;
|
||||||
d.dispatch(new controller.Main());
|
d.dispatch(new controller.Main());
|
||||||
|
|
||||||
} catch (e:haxe.web.Dispatch.DispatchError) {
|
} catch (e:haxe.web.Dispatch.DispatchError) {
|
||||||
|
|
||||||
// dispatch / routing error
|
// dispatch / routing error
|
||||||
if (App.config.DEBUG) {
|
if (App.config.DEBUG) {
|
||||||
#if neko
|
#if neko
|
||||||
@@ -238,9 +247,7 @@ class BaseApp {
|
|||||||
cnx.rollback();
|
cnx.rollback();
|
||||||
Web.redirect("/");
|
Web.redirect("/");
|
||||||
return;
|
return;
|
||||||
|
|
||||||
} catch (e:sugoi.ControllerAction) {
|
} catch (e:sugoi.ControllerAction) {
|
||||||
|
|
||||||
switch (e) {
|
switch (e) {
|
||||||
case RedirectAction(url):
|
case RedirectAction(url):
|
||||||
Web.redirect(url);
|
Web.redirect(url);
|
||||||
@@ -251,8 +258,12 @@ class BaseApp {
|
|||||||
url = Web.getURI();
|
url = Web.getURI();
|
||||||
}
|
}
|
||||||
Web.redirect(url);
|
Web.redirect(url);
|
||||||
var error = switch(e) { case ErrorAction(_): true; default: false; };
|
var error = switch (e) {
|
||||||
if( error ) rollback();
|
case ErrorAction(_): true;
|
||||||
|
default: false;
|
||||||
|
};
|
||||||
|
if (error)
|
||||||
|
rollback();
|
||||||
if (error) {
|
if (error) {
|
||||||
session.addMessage(text, true);
|
session.addMessage(text, true);
|
||||||
} else {
|
} else {
|
||||||
@@ -274,9 +285,7 @@ class BaseApp {
|
|||||||
* Override this function if you want
|
* Override this function if you want
|
||||||
* to insert some actions
|
* to insert some actions
|
||||||
*/
|
*/
|
||||||
public function beforeDispatch() {
|
public function beforeDispatch() {}
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public function logError(e:Dynamic, ?stack:String) {
|
public function logError(e:Dynamic, ?stack:String) {
|
||||||
var stack = if (stack != null) stack else haxe.CallStack.toString(haxe.CallStack.exceptionStack());
|
var stack = if (stack != null) stack else haxe.CallStack.toString(haxe.CallStack.exceptionStack());
|
||||||
@@ -316,7 +325,6 @@ class BaseApp {
|
|||||||
|
|
||||||
setTemplate("error.mtt");
|
setTemplate("error.mtt");
|
||||||
executeTemplate(false);
|
executeTemplate(false);
|
||||||
|
|
||||||
} catch (e:Dynamic) {
|
} catch (e:Dynamic) {
|
||||||
Sys.print("<pre>");
|
Sys.print("<pre>");
|
||||||
Sys.println("Error : " + try Std.string(e) catch (e:Dynamic) "???");
|
Sys.println("Error : " + try Std.string(e) catch (e:Dynamic) "???");
|
||||||
@@ -380,9 +388,11 @@ class BaseApp {
|
|||||||
}
|
}
|
||||||
|
|
||||||
function run() {
|
function run() {
|
||||||
|
|
||||||
// Will close the connection
|
// Will close the connection
|
||||||
sys.db.Transaction.main(cnx, cloneApp, function(e) { var b : BaseApp = App.current; b.errorHandler(e); });
|
sys.db.Transaction.main(cnx, cloneApp, function(e) {
|
||||||
|
var b:BaseApp = App.current;
|
||||||
|
b.errorHandler(e);
|
||||||
|
});
|
||||||
App.current = null;
|
App.current = null;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -396,13 +406,13 @@ class BaseApp {
|
|||||||
}
|
}
|
||||||
|
|
||||||
static function main() {
|
static function main() {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* this macro will parse the code and generate the allTexts.pot file
|
* this macro will parse the code and generate the allTexts.pot file
|
||||||
* which will be used as a template for translation files (*.po and *.mo)
|
* which will be used as a template for translation files (*.po and *.mo)
|
||||||
*/
|
*/
|
||||||
#if i18n_parsing
|
#if i18n_parsing
|
||||||
if( false ) sugoi.i18n.GetText.parse(["src", "lang/master","js","common"], "www/lang/allTexts.pot");
|
if (false)
|
||||||
|
sugoi.i18n.GetText.parse(["src", "lang/master", "js", "common"], "www/lang/allTexts.pot");
|
||||||
#end
|
#end
|
||||||
|
|
||||||
App.current = new App();
|
App.current = new App();
|
||||||
|
|||||||
@@ -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;
|
||||||
@@ -7,8 +8,7 @@ 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
|
||||||
@@ -31,7 +31,6 @@ class BufferedMail extends sys.db.Object
|
|||||||
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};
|
||||||
@@ -44,7 +43,6 @@ class BufferedMail extends sys.db.Object
|
|||||||
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) {
|
||||||
@@ -53,10 +51,8 @@ class BufferedMail extends sys.db.Object
|
|||||||
};
|
};
|
||||||
}
|
}
|
||||||
return out;
|
return out;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public function new() {
|
public function new() {
|
||||||
super();
|
super();
|
||||||
cdate = Date.now();
|
cdate = Date.now();
|
||||||
@@ -71,8 +67,8 @@ class BufferedMail extends sys.db.Object
|
|||||||
* 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"),
|
||||||
@@ -81,27 +77,27 @@ class BufferedMail extends sys.db.Object
|
|||||||
smtp_pass: sugoi.db.Variable.get("smtp_pass")
|
smtp_pass: sugoi.db.Variable.get("smtp_pass")
|
||||||
};
|
};
|
||||||
|
|
||||||
|
App.log('choose mail from ${this.mailerType}');
|
||||||
|
|
||||||
var mailer:sugoi.mail.IMailer = switch (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":
|
|
||||||
new sugoi.mail.DebugMailer();
|
|
||||||
default:
|
default:
|
||||||
throw "Unknown mailer type : " + this.mailerType;
|
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.setRecipient(r.email, r.name, r.userId);
|
||||||
m.setSender(sender.email, sender.name, sender.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++;
|
||||||
|
|
||||||
@@ -116,17 +112,11 @@ class BufferedMail extends sys.db.Object
|
|||||||
}
|
}
|
||||||
|
|
||||||
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();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -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,8 +7,7 @@ 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;
|
||||||
|
|
||||||
@@ -22,7 +22,6 @@ class BufferedMailer implements IMailer
|
|||||||
}
|
}
|
||||||
|
|
||||||
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();
|
||||||
@@ -50,12 +49,8 @@ class BufferedMailer implements IMailer
|
|||||||
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);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
+24
-17
@@ -1,17 +1,24 @@
|
|||||||
package sugoi.mail;
|
package sugoi.mail;
|
||||||
|
|
||||||
using Lambda;
|
using Lambda;
|
||||||
|
|
||||||
class Mail implements IMail
|
class Mail implements IMail {
|
||||||
{
|
|
||||||
|
|
||||||
public var title:String;
|
public var title:String;
|
||||||
public var htmlBody:String;
|
public var htmlBody:String;
|
||||||
public var textBody:String;
|
public var textBody:String;
|
||||||
|
|
||||||
var headers:Map<String, String>;
|
var headers:Map<String, String>;
|
||||||
var sender:{name:String, email:String, ?userId:Int};
|
var sender:{name:String, email:String, ?userId:Int};
|
||||||
var recipients:Array<{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 = [];
|
||||||
@@ -23,16 +30,17 @@ class Mail implements IMail
|
|||||||
}
|
}
|
||||||
|
|
||||||
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};
|
var finalName = (name != null) ? thx.text.Diactrics.clean(name) : null;
|
||||||
|
sender = {name: finalName, 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,7 +55,8 @@ 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))
|
||||||
|
throw "invalid recipient \"" + email + "\"";
|
||||||
recipients.push({email: email, name: name, userId: userId});
|
recipients.push({email: email, name: name, userId: userId});
|
||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
@@ -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,14 +118,14 @@ 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();
|
||||||
@@ -149,7 +158,6 @@ class Mail implements IMail
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public function getSubject() {
|
public function getSubject() {
|
||||||
return title;
|
return title;
|
||||||
}
|
}
|
||||||
@@ -178,5 +186,4 @@ class Mail implements IMail
|
|||||||
public function getSender() {
|
public function getSender() {
|
||||||
return sender;
|
return sender;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -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);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -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);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@@ -1538,7 +1538,7 @@ msgid ""
|
|||||||
"Group and user 'admin' created. Your email is 'admin@cagette.net' and your "
|
"Group and user 'admin' created. Your email is 'admin@cagette.net' and your "
|
||||||
"password is 'admin'"
|
"password is 'admin'"
|
||||||
msgstr ""
|
msgstr ""
|
||||||
"Groupe et utilisateur 'admin' créé. Votre email est 'admin@cagette.net' et "
|
"Groupe et utilisateur 'admin' créé. Votre email est 'admin@cagettepei.re' et "
|
||||||
"votre mot de passe est 'admin'"
|
"votre mot de passe est 'admin'"
|
||||||
|
|
||||||
#: src/controller/Install.hx:4677
|
#: src/controller/Install.hx:4677
|
||||||
@@ -4551,7 +4551,7 @@ msgstr "Extrait non exhaustif des produits proposés :"
|
|||||||
|
|
||||||
#: lang/master/tpl/group/view.mtt:5027
|
#: lang/master/tpl/group/view.mtt:5027
|
||||||
msgid "http://www.cagette.net"
|
msgid "http://www.cagette.net"
|
||||||
msgstr "http://www.cagette.net"
|
msgstr "https://git.artcode.re/cagetters/cagettepei"
|
||||||
|
|
||||||
#: lang/master/tpl/group/view.mtt:5060
|
#: lang/master/tpl/group/view.mtt:5060
|
||||||
msgid "Cagette.net, the free software of food direct-selling"
|
msgid "Cagette.net, the free software of food direct-selling"
|
||||||
@@ -4618,7 +4618,7 @@ msgid ""
|
|||||||
"Cagette.net is made by <a href='https://www.alilo.fr' target='_blank'><img "
|
"Cagette.net is made by <a href='https://www.alilo.fr' target='_blank'><img "
|
||||||
"src='/img/alilo-trans-black.png' /></a>"
|
"src='/img/alilo-trans-black.png' /></a>"
|
||||||
msgstr ""
|
msgstr ""
|
||||||
"CagettePéi est une fourche du logiciel Cagette.net réalisé par <a href='https://www.alilo.fr' "
|
"CagettePéi est un logiciel libre, fourche du logiciel Cagette "
|
||||||
"target='_blank'><img src='/img/alilo-trans-black.png' /></a>"
|
"target='_blank'><img src='/img/alilo-trans-black.png' /></a>"
|
||||||
|
|
||||||
#: lang/master/tpl/validate/user.mtt:2124
|
#: lang/master/tpl/validate/user.mtt:2124
|
||||||
|
|||||||
Reference in New Issue
Block a user