Skip to content

Z
zhichan
Commit 511e38d3 by 庄冰
Options

policysubscribe

parent 7db505e5
Showing with 34 additions and 27 deletions
center-order/app/base/service/impl/dbpolicy/policysubscribeSve.js
......@@ -23,35 +23,42 @@ class PolicysubscribeService extends ServiceBase {
paramObj["policyProvince"] = obj.policyProvince;
paramObj["releaseDate"] = new Date();
// ,policyTypes:{ [this.db.Op.like]: "%" + obj.policyName + "%" }
var oldsubscribe = await this.dao.model.findOne({
where:{openid:obj.openid,policyProvince:obj.policyProvince},raw:true
});
// var oldsubscribe = await this.dao.model.findOne({
// where:{openid:obj.openid,policyProvince:obj.policyProvince},raw:true
// });
var policyTypes = "";
if(oldsubscribe && oldsubscribe.id){//存在某省份的订阅数据
policyTypes = oldsubscribe.policyTypes;
for(var i=0;i<obj.policyTypes.length;i++){
var pt = obj.policyTypes[i];
if(policyTypes.indexOf(pt)<0){
policyTypes = policyTypes+","+pt;
}
}
if(oldsubscribe.releaseDate){
paramObj["releaseDate"]=oldsubscribe.releaseDate;
}
paramObj["policyTypes"] = policyTypes;
paramObj["id"] = oldsubscribe.id;
await this.dao.update(paramObj);
}else{//新的订阅数据
policyTypes = obj.policyTypes[0];
for(var i=1;i<obj.policyTypes.length;i++){
var pt = obj.policyTypes[i];
if(policyTypes.indexOf(pt)<0){
policyTypes = policyTypes+","+pt;
}
}
paramObj["policyTypes"] = policyTypes;
var policysubscribe = await this.dao.create(paramObj);
policyTypes = obj.policyTypes[0];
for(var i=1;i<obj.policyTypes.length;i++){
var pt = obj.policyTypes[i];
policyTypes = policyTypes+","+pt;
}
paramObj["policyTypes"] = policyTypes;
var policysubscribe = await this.dao.create(paramObj);
// if(oldsubscribe && oldsubscribe.id){//存在某省份的订阅数据
// policyTypes = oldsubscribe.policyTypes;
// for(var i=0;i<obj.policyTypes.length;i++){
// var pt = obj.policyTypes[i];
// if(policyTypes.indexOf(pt)<0){
// policyTypes = policyTypes+","+pt;
// }
// }
// if(oldsubscribe.releaseDate){
// paramObj["releaseDate"]=oldsubscribe.releaseDate;
// }
// paramObj["policyTypes"] = policyTypes;
// paramObj["id"] = oldsubscribe.id;
// await this.dao.update(paramObj);
// }else{//新的订阅数据
// policyTypes = obj.policyTypes[0];
// for(var i=1;i<obj.policyTypes.length;i++){
// var pt = obj.policyTypes[i];
// if(policyTypes.indexOf(pt)<0){
// policyTypes = policyTypes+","+pt;
// }
// }
// paramObj["policyTypes"] = policyTypes;
// var policysubscribe = await this.dao.create(paramObj);
// }
return system.getResultSuccess();
}
//取消政策订阅
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment