gyq

ic-deliver/app/base/controller/impl/bizchance/cacheinfoCtl.js

@@ -11,13 +11,13 @@ class CacheInfoCtl extends CtlBase {
 
 
   /*根据交付单id获取缓存详情*/
   /*根据交付单id获取缓存详情*/
   async findInfoByDeliverId(pobj,qobj,req){
   async findInfoByDeliverId(pobj,qobj,req){
-    if (pobj.deliver_id && pobj.deliver_id != 'undefined')
+    if (pobj.deliverNumber && pobj.deliverNumber != 'undefined')
     {
     {
       try{
       try{
         var rs = await this.service.findInfoByDeliverId(pobj);
         var rs = await this.service.findInfoByDeliverId(pobj);
         var rarr = {};
         var rarr = {};
         if (rs){
         if (rs){
-          rarr.deliverId = rs.deliver_id;
+          rarr.deliverNumber = rs.deliver_id;
           rarr.cacheInfo = rs.cache_info;
           rarr.cacheInfo = rs.cache_info;
         }
         }
         return system.getResult(rarr);
         return system.getResult(rarr);
@@ -33,7 +33,7 @@ class CacheInfoCtl extends CtlBase {
 
 
   /*根据交付单id更新缓存信息*/
   /*根据交付单id更新缓存信息*/
   async updateInfoByDeliverId(pobj,qobj,req){
   async updateInfoByDeliverId(pobj,qobj,req){
-    if (pobj.deliver_id && pobj.deliver_id != 'undefined' && pobj.cache_info && pobj.cache_info != 'undefined'){
+    if (pobj.deliverNumber && pobj.deliverNumber != 'undefined' && pobj.cacheInfo && pobj.cacheInfo != 'undefined'){
       try{
       try{
         var res = await this.service.updateInfoByDeliverId(pobj);
         var res = await this.service.updateInfoByDeliverId(pobj);
         return system.getResult("更新成功！");
         return system.getResult("更新成功！");
@@ -47,12 +47,19 @@ class CacheInfoCtl extends CtlBase {
     }
     }
   }
   }
 
 
-  /*插入缓存信息 */
-  async insertInfo(pobj,qobj,req){
-    if (pobj.deliver_id && pobj.deliver_id != 'undefined' && pobj.cache_info && pobj.cache_info != 'undefined'){
+  /*插入或更新缓存信息 */
+  async createInfo(pobj,qobj,req){
+    if (pobj.deliverNumber && pobj.deliverNumber != 'undefined' && pobj.cacheInfo && pobj.cacheInfo != 'undefined'){
         try{
         try{
-          var res = await this.service.insertInfo(pobj);
-          return system.getResult("插入成功！");
+          var rs = await this.service.findInfoByDeliverId(pobj);
+          if (rs){
+            await this.service.updateInfoByDeliverId(pobj);
+          }
+          else{
+            await this.service.insertInfo(pobj);
+          }
+          
+          return system.getResult("操作成功！");
         }
         }
         catch (error){
         catch (error){
           return system.getResultError(error);
           return system.getResultError(error);

ic-deliver/app/base/db/impl/bizchance/cacheinfoDao.js

@@ -21,22 +21,22 @@ class CacheinfoDao extends Dao {
 
 
   /*根据订单id获取缓存信息详情*/
   /*根据订单id获取缓存信息详情*/
   async findInfoByDeliverId(qobj){
   async findInfoByDeliverId(qobj){
-    var qcwhere = {"deliver_id":qobj.deliver_id};
+    var qcwhere = {"deliver_id":qobj.deliverNumber};
     return await this.findOne(qcwhere);
     return await this.findOne(qcwhere);
   }  
   }  
 
 
   /*更加订单id更新缓存信息*/
   /*更加订单id更新缓存信息*/
   async updateInfoByDeliverId(qobj,t){
   async updateInfoByDeliverId(qobj,t){
-    var setobj = {"cache_info":qobj.cache_info};
-    var whereobj = {"deliver_id":qobj.deliver_id};
+    var setobj = {"cache_info":qobj.cacheInfo};
+    var whereobj = {"deliver_id":qobj.deliverNumber};
     return await this.updateByWhere(setobj,whereobj,t);
     return await this.updateByWhere(setobj,whereobj,t);
   }
   }
 
 
   /*插入缓存信息*/
   /*插入缓存信息*/
   async insertInfo(qobj,t){
   async insertInfo(qobj,t){
     var obj = {
     var obj = {
-        "deliver_id":qobj.deliver_id,
-        "cache_info":qobj.cache_info
+        "deliver_id":qobj.deliverNumber,
+        "cache_info":qobj.cacheInfo
     };
     };
     return await this.create(obj,t);
     return await this.create(obj,t);
   }
   }