开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > WEB源码(ASP,PHP,...) > 查看源码
ianService.java~1~
资源名称：shihua.rar　[点击查看]
上传用户：zghglow
上传日期：2022-08-09
资源大小：27227k
文件大小：11k
源码类别：

WEB源码(ASP,PHP,...)

开发平台：

JavaScript

ianService.java~1~：源码内容
  1. package cn.com.ivisions.xfb.service;
  3. import java.util.ArrayList;
  4. import java.util.Collection;
  5. import java.util.HashMap;
  6. import java.util.Iterator;
  8. import javax.servlet.http.HttpServletRequest;
  10. import cn.com.ivisions.dipper.Result;
  11. import cn.com.ivisions.dipper.data.Context;
  12. import cn.com.ivisions.dipper.data.ContextObject;
  13. import cn.com.ivisions.dipper.model.Model;
  14. import cn.com.ivisions.dipper.operation.OperationRunner;
  15. import cn.com.ivisions.xfb.RequestData;
  17. public class DianService {
  19. // 对应tbxTransactEntity表中的dianOnline字段，0表示此办理单位对来电流程是不联网状态.1表示是联网状态.
  20. private final static String onLineFlag = "1";
  22. // 对应tbxTransactEntity表中的transactEntityGrade字段,1表示此办理单位级别为区县级,2表示市委办局级.3或空表示为一般的办理单位.
  23. private final static String weiBanJuFlag = "2";
  25. private static final Integer SOURCEENTITYID = new Integer(9);
  27. private static final String SOURCEENTITYCODE = "SXFB-ENT9";
  29. private static final Integer TRANSFERENTITYID = new Integer(53);
  31. /**
  32.  * 
  33.  * 检查信访件主送单位是否全部联网(只针对来电这种信访形式)
  34.  * 
  35.  * 
  36.  * @param Integer
  37.  *            appealId
  38.  * @return boolean
  39.  */
  40. public static boolean checkAllOnLineForDian(Integer appealId) {
  41. return checkAllOnLineForDian(AppealService
  42. .listAppeal_TransactEntitys(appealId));
  43. }
  45. /**
  46.  * 
  47.  * 检查指定单位是否全部联网(只针对来电这种信访形式)�
  48.  * 
  49.  * @param Collection
  50.  *            coll
  51.  * @return boolean
  52.  */
  53. public static boolean checkAllOnLineForDian(Collection collection) {
  54. boolean allOnLine = true;
  55. if (collection == null) {
  56. allOnLine = false;
  57. } else if (collection.isEmpty()) {
  58. allOnLine = false;
  59. } else {
  60. for (Iterator iter = collection.iterator(); iter.hasNext();) {
  61. Model model = (Model) iter.next();
  62. if (model.getStringValue("dianOnline") == null) {
  63. allOnLine = false;
  64. break;
  65. } else if (model.getStringValue("dianOnline").equals("")) {
  66. allOnLine = false;
  67. break;
  68. } else if (!model.getStringValue("dianOnline").equals(
  69. onLineFlag)) {
  70. allOnLine = false;
  71. break;
  72. }
  73. }
  74. }
  75. return allOnLine;
  76. }
  78. /**
  79.  * 
  80.  * 检查信访件主送单位是否全都不联网(只针对来电这种信访形式)
  81.  * 
  82.  * 
  83.  * @param Integer
  84.  *            appealId
  85.  * @return boolean
  86.  */
  87. public static boolean checkAllOffLineForDian(Integer appealId) {
  88. return checkAllOffLineForDian(AppealService
  89. .listAppeal_TransactEntitys(appealId));
  90. }
  92. /**
  93.  * 
  94.  * 检查指定单位是否全都不联网(只针对来电这种信访形式)�
  95.  * 
  96.  * @param Collection
  97.  *            coll
  98.  * @return boolean
  99.  */
  100. public static boolean checkAllOffLineForDian(Collection collection) {
  101. boolean allOnLine = true;
  102. if (collection == null) {
  103. allOnLine = false;
  104. } else if (collection.isEmpty()) {
  105. allOnLine = false;
  106. } else {
  107. for (Iterator iter = collection.iterator(); iter.hasNext();) {
  108. Model model = (Model) iter.next();
  109. if (model.getStringValue("dianOnline") != null
  110. && model.getStringValue("dianOnline")
  111. .equals(onLineFlag)) {
  112. allOnLine = false;
  113. break;
  114. }
  115. }
  116. }
  117. return allOnLine;
  118. }
  120. /**
  121.  * 根据tbxEntity表中的entityId去查出对应tbxTransactEntity的记录
  122.  * 
  123.  * @param int
  124.  *            entityId
  125.  * 
  126.  * @return Model
  127.  */
  128. public static Model getTransactEntityByEntityId(int entityId) {
  129. Model model = null;
  130. Context ctx = new ContextObject();
  131. ctx.setAttribute("entityId", new Integer(entityId));
  132. OperationRunner runner = new OperationRunner(ctx);
  133. try {
  134. model = runner.extractModel("getTransactEntityByEntityId");
  135. } catch (Exception ex) {
  136. ex.printStackTrace();
  137. }
  138. return model;
  139. }
  141. /**
  142.  * 验证此办理单位是否为市委办局级别.
  143.  * 
  144.  * @param transactEntity
  145.  * @return
  146.  */
  147. public static boolean checkShiWeiBanJu(Model transactEntity) {
  148. boolean result = true;
  149. if (transactEntity == null) {
  150. result = false;
  151. } else if (transactEntity.getStringValue("transactEntityGrade") == null) {
  152. result = false;
  153. } else if (!transactEntity.getStringValue("transactEntityGrade")
  154. .equals(weiBanJuFlag)) {
  155. result = false;
  156. }
  157. return result;
  158. }
  160. /**
  161.  * 验证此办理单位是否为市委办局级别.
  162.  * 
  163.  * @param entityId
  164.  * @return
  165.  */
  166. public static boolean checkShiWeiBanJu(int entityId) {
  167. return checkShiWeiBanJu(getTransactEntityByEntityId(entityId));
  168. }
  170. /**
  171.  * 根据办理单位的等级来列出办理单位对应的TBENTITY表的信息
  172.  * 
  173.  * @param transactEntityGrade
  174.  * @return
  175.  */
  176. public static Collection listTransactEntityByGrade(
  177. String transactEntityGrade) {
  178. Collection coll = new ArrayList();
  179. Context ctx = new ContextObject();
  180. ctx.setAttribute("transactEntityGrade", transactEntityGrade);
  181. OperationRunner runner = new OperationRunner(ctx);
  182. try {
  183. coll = runner.search("listTransactEntityByGrade").getResult();
  184. } catch (Exception ex) {
  185. ex.printStackTrace();
  186. }
  187. return coll;
  188. }
  190. /**
  191.  * <p>
  192.  * 下转信访件
  193.  * 
  194.  * 
  195.  * @param HttpServletRequest
  196.  *            request
  197.  */
  198. public static void batchTransferAppeal(HttpServletRequest request) {
  199. Integer appealId = RequestData.requestInteger("appealId", request);
  200. String appealCode = RequestData.requestString("appealCode", request);
  201. Integer appealFormId = RequestData.requestInteger("appealFormId",
  202. request);
  203. String transferFlowNode = RequestData.requestString("transferFlowNode",
  204. request);
  205. Integer transferFlowRole = RequestData.requestInteger(
  206. "transferFlowRole", request);
  207. String sendToUnits = RequestData.requestString("sendToUnits", request);
  208. Collection coll = listTransactEntityByIds(sendToUnits);
  209. for (Iterator iter = coll.iterator(); iter.hasNext();) {
  210. Model model = (Model) iter.next();
  211. HashMap hmp = new HashMap();
  212. hmp.put("sourceAppealId", appealId);
  213. hmp.put("sourceAppealCode", appealCode);
  214. hmp.put("sourceEntityId", SOURCEENTITYID);
  215. hmp.put("sourceEntityCode", SOURCEENTITYCODE);
  216. hmp.put("transferEntityId", TRANSFERENTITYID);
  217. hmp.put("appealFormId", appealFormId);
  218. hmp.put("targetEntityId",
  219. new Integer(model.getIntValue("entityId")));
  220. hmp.put("targetEntityCode", model
  221. .getStringValue("transactEntityCode"));
  222. if (model.getStringValue("dianOnline").equals("1")) {
  223.                              if (model.getIntValue("absoluteSystem") == 1) {
  224. hmp.put("inSide", new Integer(1));
  226. Model appealModel = transferAppeal(hmp);
  228. String userIds = UserService.listEntityUserIds(new Integer(
  229. model.getIntValue("entityId")), new Integer(0),
  230. transferFlowRole);
  232. FlowService.startFlow(new Integer(appealModel
  233. .getIntValue("appealFormId")), transferFlowNode,
  234. userIds, FlowService.FLOWSTATUSON, null, userIds, null,
  235. new Integer(appealModel.getIntValue("appealId")));
  236. }else if (model.getIntValue("absoluteSystem") == 2) {
  237.                 hmp.put("inSide", new Integer(0));
  238.                 Model appealModel = transferAppeal(hmp);
  239.                 DipperService.execute("updateDataCommuteStatus",request);
  240.             }
  241. }
  242. }
  244. /**
  245.  * <p>
  246.  * 根据单位ids取得信息
  247.  * 
  248.  * @param String
  249.  *            endityIds
  250.  * @return Collection
  251.  */
  252. public static Collection listTransactEntityByIds(String entityIds) {
  253. Collection list = new ArrayList();
  254. Context ctx = new ContextObject();
  255. ctx.setAttribute("transactEntityIds", entityIds);
  256. OperationRunner runner = new OperationRunner(ctx);
  257. try {
  258. list = runner.search("listTransactEntityByIds").getResult();
  259. } catch (Exception ex) {
  260. ex.printStackTrace();
  261. }
  262. return list;
  263. }
  265. /**
  266.  * <p>
  267.  * 添加区县信访件并记录下转信息
  268.  * 
  269.  * @param HashMap
  270.  *            <p>
  271.  *            HashMap包含的信息
  272.  * 
  273.  * @param sourceAppealId
  274.  *            源信访件id
  275.  * @param sourceAppealCode
  276.  *            源信访件编号
  277.  * @param sourceEntityId
  278.  *            源单位Id
  279.  * @param appealFormId
  280.  *            信访形式
  281.  * @param targetEntityId
  282.  *            目标单位Id
  283.  * @param inSide
  284.  *            是否系统内单位
  285.  * 
  286.  */
  287. public static Model transferAppeal(HashMap hmp) {
  288. Model model = null;
  289. Context ctx = new ContextObject();
  290. ctx.addHashMap(hmp);
  291. OperationRunner runner = new OperationRunner(ctx);
  292. try {
  293. Result rs = runner.operate("transferAppeal");
  294. model = (Model) rs.getResultValue();
  295. } catch (Exception ex) {
  296. ex.printStackTrace();
  297. }
  298. return model;
  299. }
  301. /**
  302.  * <p>
  303.  * 检测用户是否具有某个角色
  304.  * 
  305.  * 
  306.  * @param int
  307.  *            userId
  308.  * @param int
  309.  *            roleId
  310.  * @param Collection
  311.  *            coll
  312.  * @return boolean
  313.  */
  314. public static boolean checkUserHaveRole(int userId, String roleName,
  315. Collection coll) {
  316. boolean haveRole = false;
  317. Iterator ite = coll.iterator();
  318. while (ite.hasNext()) {
  319. Model roleModel = (Model) ite.next();
  320. if (userId != roleModel.getIntValue("userId"))
  321. continue;
  322. if (roleModel.getStringValue("roleName").equals(roleName)) {
  323. haveRole = true;
  324. break;
  325. }
  326. }
  327. return haveRole;
  328. }
  330. /**
  331.  * 根据appealId和adviceTitle两个字段来取tbxAppeal_advice表中的记录
  332.  * 
  333.  * @param int
  334.  *            appealId
  335.  * @param String
  336.  *            adviceTitle
  337.  * @return Model
  338.  */
  339. public static Model getAppealAdviceByAppealIdAndTitle(int appealId,
  340. String adviceTitle) {
  341. Model model = null;
  342. Context ctx = new ContextObject();
  343. ctx.setAttribute("appealId", new Integer(appealId));
  344. ctx.setAttribute("adviceTitle", adviceTitle);
  345. OperationRunner runner = new OperationRunner(ctx);
  346. try {
  347. model = runner.extractModel("getAdviceByAppealIdTitle");
  348. } catch (Exception ex) {
  349. ex.printStackTrace();
  350. }
  351. return model;
  352. }
  354. /**
  355.  * 根据appealId和adviceTitle两个字段来更新tbxAppeal_advice表中的adviceContent字段
  356.  * 
  357.  * @param int
  358.  *            appealId
  359.  * @param String
  360.  *            adviceTitle
  361.  * @return Model
  362.  */
  363. public static void updateAppealAdvice(int appealId, String adviceTitle, String adviceContent) {
  364. Context ctx = new ContextObject();
  365. ctx.setAttribute("appealId", new Integer(appealId));
  366. ctx.setAttribute("adviceTitle", adviceTitle);
  367. ctx.setAttribute("adviceContent", adviceContent);
  368. OperationRunner runner = new OperationRunner(ctx);
  369. try {
  370. runner.extractModel("updateAppealAdvice");
  371. } catch (Exception ex) {
  372. ex.printStackTrace();
  373. }
  374. }
  375. }