Procházet zdrojové kódy

话题关闭后,不允许更新话题分析数据及话题回复

沈静伟 před 3 roky
rodič
revize
08845844c5

+ 15 - 8
src/dsb/com/cnd3b/restcontroller/system/im/imdialog/imdialog.java

@@ -294,13 +294,15 @@ public class imdialog extends Controller {
                 row.put("attinfos", map.get(row.getString("timsubjectcontenid")));
             }
             imsubject.put("imsubjectcontent", imsubjectcontentrows);
+            if(!imsubject.getBoolean("fisclose")){
+                SQLFactory sqlFactory = new SQLFactory(this, "话题数据分析插入");
+                sqlFactory.addParameter("siteid", siteid);
+                sqlFactory.addParameter("timsubjectid", timsubjectid);
+                sqlFactory.addParameter("tenterprise_userid", userid);
+                sqlFactory.addParameter("tagentsid", tagentsid);
+                dbConnect.runSqlUpdate(sqlFactory.getSQL());
+            }
         }
-        SQLFactory sqlFactory = new SQLFactory(this, "话题数据分析插入");
-        sqlFactory.addParameter("siteid", siteid);
-        sqlFactory.addParameter("timsubjectid", timsubjectid);
-        sqlFactory.addParameter("tenterprise_userid", userid);
-        sqlFactory.addParameter("tagentsid", tagentsid);
-        dbConnect.runSqlUpdate(sqlFactory.getSQL());
         return getSucReturnObject().setData(imsubjectrows).toString();
     }
 
@@ -311,8 +313,13 @@ public class imdialog extends Controller {
      */
     public String subjectAnswer() {
         long timsubjectid = content.getLongValue("timsubjectid");
-        dbConnect.runSqlUpdate("update timsubjectanalysis set fisanswer=1,fanswertime=getDate() where siteid='" + siteid + "' and timsubjectid='" + timsubjectid + "' and tenterprise_userid='" + userid + "' and fisanswer=0");
-        return getSucReturnObject().toString();
+        Rows rows= dbConnect.runSqlQuery("select fisclose from timsubject where siteid='"+siteid+"' and timsubjectid="+timsubjectid);
+        if(!rows.isEmpty()&&!rows.get(0).getBoolean("fisclose")){
+            dbConnect.runSqlUpdate("update timsubjectanalysis set fisanswer=1,fanswertime=getDate() where siteid='" + siteid + "' and timsubjectid='" + timsubjectid + "' and tenterprise_userid='" + userid + "' and fisanswer=0");
+            return getSucReturnObject().toString();
+        }else{
+            return getErrReturnObject().setErrMsg("话题已关闭或不存在").toString();
+        }
     }
 
     /**