EsignContractTaskMX.java 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487
  1. package restcontroller.webmanage.sale.contracttask;
  2. import beans.attachment.Attachment;
  3. import beans.datacontrllog.DataContrlLog;
  4. import com.alibaba.fastjson2.JSON;
  5. import com.alibaba.fastjson2.JSONArray;
  6. import com.alibaba.fastjson2.JSONObject;
  7. import com.tencentcloudapi.essbasic.v20210526.models.FlowApproverInfo;
  8. import com.tencentcloudapi.essbasic.v20210526.models.Recipient;
  9. import common.Controller;
  10. import common.YosException;
  11. import common.annotation.API;
  12. import common.data.*;
  13. import common.data.db.SQLList;
  14. import org.apache.commons.lang.ArrayUtils;
  15. import org.apache.commons.lang.StringUtils;
  16. import restcontroller.R;
  17. import java.io.InputStream;
  18. import java.math.BigDecimal;
  19. import java.util.ArrayList;
  20. import java.util.Arrays;
  21. import java.util.Map;
  22. /**
  23. * 电子签合同任务明细
  24. */
  25. public class EsignContractTaskMX extends Controller {
  26. public EsignContractTaskMX(JSONObject content) throws YosException {
  27. super(content);
  28. }
  29. @API(title = "电子签合同任务明细-添加经销商", apiversion = R.ID2026041315394702.v1.class)
  30. public String addAgents() throws YosException {
  31. Long sa_esign_contract_taskid = content.getLongValue("sa_esign_contract_taskid");
  32. JSONArray sa_agentsids = content.getJSONArray("sa_agentsids");
  33. SQLList sqlList = new SQLList();
  34. for (Object obj : sa_agentsids) {
  35. Long sa_agentsid = Long.parseLong(obj.toString());
  36. Rows mxRows = dbConnect.runSqlQuery("SELECT * FROM sa_esign_contract_taskmx WHERE sa_agentsid=" + sa_agentsid + " and sa_esign_contract_taskid=" + sa_esign_contract_taskid);
  37. if (mxRows.isNotEmpty()) {
  38. continue;
  39. }
  40. Rows agentRows = dbConnect.runSqlQuery("SELECT * FROM sa_agents WHERE sa_agentsid=" + sa_agentsid);
  41. if (agentRows.isEmpty()) {
  42. continue;
  43. }
  44. Row agentRow = agentRows.getRow(0);
  45. Long sys_enterpriseid = agentRow.getLong("sys_enterpriseid");
  46. Rows enterpriseRows = dbConnect.runSqlQuery("SELECT * FROM sys_enterprise WHERE sys_enterpriseid=" + sys_enterpriseid);
  47. if (enterpriseRows.isEmpty()) {
  48. continue;
  49. }
  50. Row enterpriseRow = enterpriseRows.getRow(0);
  51. String enterprisename = enterpriseRow.getString("enterprisename");
  52. InsertSQL insertSQL = SQLFactory.createInsertSQL(this, "sa_esign_contract_taskmx");
  53. insertSQL.setSiteid(siteid);
  54. insertSQL.setUniqueid(createTableID("sa_esign_contract_taskmx"));
  55. insertSQL.setValue("sa_agentsid", sa_agentsid);
  56. insertSQL.setValue("sys_enterpriseid", agentRow.getLong("sys_enterpriseid"));
  57. insertSQL.setValue("sa_esign_contract_taskid", sa_esign_contract_taskid);
  58. insertSQL.setValue("paymans", agentRow.getString("paymans"));
  59. insertSQL.setValue("aftersalesphonenumber", agentRow.getString("aftersalesphonenumber"));
  60. insertSQL.setValue("presalesphonenumber", agentRow.getString("presalesphonenumber"));
  61. insertSQL.setValue("taxno", enterpriseRow.getString("taxno"));
  62. insertSQL.setValue("phonenumber", enterpriseRow.getString("phonenumber"));
  63. insertSQL.setValue("license_name", enterpriseRow.getString("enterprisename"));
  64. insertSQL.setValue("license_address", enterpriseRow.getString("address"));
  65. insertSQL.setValue("legal_rep", enterpriseRow.getString("contact"));
  66. insertSQL.setValue("mobile", enterpriseRow.getString("telephone"));
  67. insertSQL.setValue("idcard", enterpriseRow.getString("idcard"));
  68. insertSQL.setValue("sa_esign_contract_taskid", sa_esign_contract_taskid);
  69. sqlList.add(insertSQL.getSQL());
  70. sqlList.add(DataContrlLog.createLog(this, "sa_esign_contract_task", sa_esign_contract_taskid, "添加", "添加经销商【" + enterprisename + "】成功").getSQL());
  71. }
  72. dbConnect.runSqlUpdate(sqlList);
  73. return getSucReturnObject().toString();
  74. }
  75. @API(title = "电子签合同任务明细-选择经销商列表", apiversion = R.ID2026041315545602.v1.class)
  76. public String chooseAgents() throws YosException {
  77. Long sa_esign_contract_taskid = content.getLongValue("sa_esign_contract_taskid");
  78. Rows templaterows = dbConnect.runSqlQuery("SELECT is_deposit_required from sa_esign_contract_template t1 " +
  79. "INNER JOIN sa_esign_contract_task t2 ON t2.sa_esign_contract_templateid=t1.sa_esign_contract_templateid " +
  80. "WHERE t2.sa_esign_contract_taskid=" + sa_esign_contract_taskid);
  81. //验证是否需要保证金
  82. boolean is_deposit_required = true;
  83. if (templaterows.isNotEmpty()) {
  84. is_deposit_required = templaterows.getRow(0).getBoolean("is_deposit_required");
  85. }
  86. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_agents", "*").setTableAlias("t1");
  87. querySQL.addJoinTable(JOINTYPE.inner, "sys_enterprise", "t2", "t1.sys_enterpriseid=t2.sys_enterpriseid"
  88. , "enterprisename", "abbreviation");
  89. if (is_deposit_required) {
  90. querySQL.addJoinTable(JOINTYPE.inner, "sa_accountbalance", "t3", "t1.sys_enterpriseid=t3.sys_enterpriseid");
  91. querySQL.addJoinTable(JOINTYPE.inner, "sa_accountclass", "t4", "t3.sa_accountclassid=t4.sa_accountclassid");
  92. querySQL.setWhere("t3.balance>0");
  93. querySQL.setWhere("t4.accountno='02'");
  94. }
  95. if (getDepartment(userid).getString("depname").equals("区域经理")) {
  96. querySQL.setWhere("t1.sys_enterpriseid in (SELECT sys_enterpriseid FROM sys_enterprise_tradefield WHERE hrid=" + hrid + ")");
  97. }
  98. querySQL.setWhere("NOT EXISTS (SELECT 1 from sa_esign_contract_taskmx WHERE sa_agentsid=t1.sa_agentsid and sa_esign_contract_taskid='" + sa_esign_contract_taskid + "' )");
  99. querySQL.setSiteid(siteid);
  100. querySQL.setOrderBy("t1.createdate desc");
  101. querySQL.setPage(pageSize, pageNumber);
  102. Rows rows = querySQL.query();
  103. return getSucReturnObject().setData(rows).toString();
  104. }
  105. @API(title = "电子签合同任务明细-删除明细", apiversion = R.ID2026041315414702.v1.class)
  106. public String delete() throws YosException {
  107. JSONArray sa_esign_contract_taskmxids = content.getJSONArray("sa_esign_contract_taskmxids");
  108. SQLList sqlList = new SQLList();
  109. DeleteSQL deleteSQL = SQLFactory.createDeleteSQL(this, "sa_esign_contract_taskmx");
  110. deleteSQL.setSiteid(siteid);
  111. deleteSQL.setWhere("sa_esign_contract_taskmxid", sa_esign_contract_taskmxids);
  112. sqlList.add(deleteSQL.getSQL());
  113. for (Object obj : sa_esign_contract_taskmxids) {
  114. Long sa_esign_contract_taskmxid = Long.parseLong(obj.toString());
  115. Rows rows = dbConnect.runSqlQuery("SELECT * FROM sa_esign_contract_taskmx WHERE sa_esign_contract_taskmxid=" + sa_esign_contract_taskmxid);
  116. if (rows.isNotEmpty()) {
  117. Long sa_agentsid = rows.get(0).getLong("sa_agentsid");
  118. Long sa_esign_contract_taskid = rows.get(0).getLong("sa_esign_contract_taskid");
  119. Rows agentRows = dbConnect.runSqlQuery("SELECT * FROM sv_agents WHERE sa_agentsid=" + sa_agentsid);
  120. String enterprisename = agentRows.get(0).getString("enterprisename");
  121. sqlList.add(DataContrlLog.createLog(this, "sa_esign_contract_task", sa_esign_contract_taskid, "删除", "删除经销商【" + enterprisename + "】成功").getSQL());
  122. }
  123. }
  124. dbConnect.runSqlUpdate(sqlList);
  125. return getSucReturnObject().toString();
  126. }
  127. @API(title = "电子签合同任务明细-修改期限", apiversion = R.ID2026041415245302.v1.class)
  128. public String updateDate() throws YosException {
  129. JSONArray items = content.getJSONArray("items");
  130. ArrayList<String> sqlList = new ArrayList<>();
  131. for (Object obj : items) {
  132. JSONObject jsonObject = (JSONObject) obj;
  133. Long sa_esign_contract_taskmxid = jsonObject.getLong("sa_esign_contract_taskmxid");
  134. String begindate = jsonObject.getStringValue("begindate");
  135. String enddate = jsonObject.getStringValue("enddate");
  136. UpdateSQL updateSQL = SQLFactory.createUpdateSQL(this, "sa_esign_contract_taskmx");
  137. updateSQL.setSiteid(siteid);
  138. updateSQL.setWhere("sa_esign_contract_taskmxid", sa_esign_contract_taskmxid);
  139. updateSQL.setValue("begindate", begindate);
  140. updateSQL.setValue("enddate", enddate);
  141. sqlList.add(updateSQL.getSQL());
  142. Rows rows = dbConnect.runSqlQuery("SELECT * FROM sa_esign_contract_taskmx WHERE sa_esign_contract_taskmxid=" + sa_esign_contract_taskmxid);
  143. if (rows.isNotEmpty()) {
  144. Long sa_agentsid = rows.get(0).getLong("sa_agentsid");
  145. Long sa_esign_contract_taskid = rows.get(0).getLong("sa_esign_contract_taskid");
  146. Rows agentRows = dbConnect.runSqlQuery("SELECT * FROM sv_agents WHERE sa_agentsid=" + sa_agentsid);
  147. String enterprisename = agentRows.get(0).getString("enterprisename");
  148. sqlList.add(DataContrlLog.createLog(this, "sa_esign_contract_task", sa_esign_contract_taskid, "修改期限", "修改经销商【" + enterprisename + "】期限为:" + begindate + "~" + enddate).getSQL());
  149. }
  150. }
  151. dbConnect.runSqlUpdate(sqlList);
  152. return getSucReturnObject().toString();
  153. }
  154. @API(title = "电子签合同任务明细-修改季度任务金额", apiversion = R.ID2026042113202402.v1.class)
  155. public String changeTaskMoney() throws YosException {
  156. JSONArray items = content.getJSONArray("items");
  157. ArrayList<String> sqlList = new ArrayList<>();
  158. for (Object obj : items) {
  159. JSONObject jsonObject = (JSONObject) obj;
  160. Long sa_esign_contract_taskmxid = jsonObject.getLong("sa_esign_contract_taskmxid");
  161. BigDecimal s1 = content.getBigDecimal("s1");
  162. BigDecimal s2 = content.getBigDecimal("s2");
  163. BigDecimal s3 = content.getBigDecimal("s3");
  164. BigDecimal s4 = content.getBigDecimal("s4");
  165. BigDecimal y1 = s1.add(s2).add(s3).add(s4);
  166. UpdateSQL updateSQL = SQLFactory.createUpdateSQL(this, "sa_esign_contract_taskmx");
  167. updateSQL.setSiteid(siteid);
  168. updateSQL.setWhere("sa_esign_contract_taskmxid", sa_esign_contract_taskmxid);
  169. updateSQL.setValue("s1", s1);
  170. updateSQL.setValue("s2", s2);
  171. updateSQL.setValue("s3", s3);
  172. updateSQL.setValue("s4", s4);
  173. updateSQL.setValue("y1", y1);
  174. sqlList.add(updateSQL.getSQL());
  175. Rows rows = dbConnect.runSqlQuery("SELECT * FROM sa_esign_contract_taskmx WHERE sa_esign_contract_taskmxid=" + sa_esign_contract_taskmxid);
  176. if (rows.isNotEmpty()) {
  177. Long sa_agentsid = rows.get(0).getLong("sa_agentsid");
  178. Long sa_esign_contract_taskid = rows.get(0).getLong("sa_esign_contract_taskid");
  179. Rows agentRows = dbConnect.runSqlQuery("SELECT * FROM sv_agents WHERE sa_agentsid=" + sa_agentsid);
  180. String enterprisename = agentRows.get(0).getString("enterprisename");
  181. sqlList.add(DataContrlLog.createLog(this, "sa_esign_contract_task", sa_esign_contract_taskid, "修改季度任务金额",
  182. "修改经销商【" + enterprisename + "】季度任务金为:第一季度(万元):" + s1 + ",第二季度(万元):" + s2 + ",第三季度(万元):" + s3 + ",第四季度(万元):" + s4).getSQL());
  183. }
  184. }
  185. dbConnect.runSqlUpdate(sqlList);
  186. return getSucReturnObject().toString();
  187. }
  188. @API(title = "电子签合同任务明细-明细列表", apiversion = R.ID2026041315403802.v1.class)
  189. public String list() throws YosException {
  190. Long sa_esign_contract_taskid = content.getLongValue("sa_esign_contract_taskid");
  191. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_esign_contract_taskmx",
  192. "sa_esign_contract_taskmxid", "status", "approvestatus", "license_address", "phonenumber", "legal_rep", "begindate", "enddate", "flowid",
  193. "s1", "s2", "s3", "s4", "y1").setTableAlias("t1");
  194. querySQL.addJoinTable(JOINTYPE.inner, "sa_agents", "t2", "t1.siteid = t2.siteid and t1.sa_agentsid=t2.sa_agentsid",
  195. "sys_enterpriseid", "agentnum");
  196. querySQL.addJoinTable(JOINTYPE.inner, "sys_enterprise", "t3", "t3.siteid = t2.siteid and t3.sys_enterpriseid = t2.sys_enterpriseid",
  197. "enterprisename", "abbreviation", "province", "city", "county");
  198. querySQL.addJoinTable(JOINTYPE.left, "sys_enterprise_tradefield", "t4", "t4.siteid = t2.siteid and t4.sys_enterpriseid = t2.sys_enterpriseid");
  199. querySQL.addJoinTable(JOINTYPE.left, "sa_salearea", "t5", "t5.sa_saleareaid = t4.sa_saleareaid and t5.siteid = t4 .siteid", "areaname");
  200. querySQL.setWhere("t1.sa_esign_contract_taskid=" + sa_esign_contract_taskid);
  201. querySQL.setPage(pageSize, pageNumber);
  202. Rows rows = querySQL.query();
  203. for (Row row : rows) {
  204. Long sa_esign_contract_taskmxid = row.getLong("sa_esign_contract_taskmxid");
  205. Rows attachments = Attachment.get(this, "sa_esign_contract_taskmx", sa_esign_contract_taskmxid);
  206. row.put("attinfos", attachments);
  207. String flowid = row.getString("flowid");
  208. if (!StringUtils.isBlank(flowid)) {
  209. row.put("downloadurl", WeChatContractUtil.describeFileUrls(flowid));
  210. }
  211. row.putIfAbsent("downloadurl", "");
  212. row.putIfAbsent("s1", 0);
  213. row.putIfAbsent("s2", 0);
  214. row.putIfAbsent("s3", 0);
  215. row.putIfAbsent("s4", 0);
  216. row.putIfAbsent("y1", 0);
  217. }
  218. return getSucReturnObject().setData(rows).toString();
  219. }
  220. @API(title = "电子签合同任务明细-明细详情", apiversion = R.ID2026041516335302.v1.class)
  221. public String detail() throws YosException {
  222. Long sa_esign_contract_taskmxid = content.getLongValue("sa_esign_contract_taskmxid");
  223. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_esign_contract_taskmx", "*").setTableAlias("t1");
  224. querySQL.addJoinTable(JOINTYPE.inner, "sa_esign_contract_task", "t2", "t2.sa_esign_contract_taskid=t1.sa_esign_contract_taskid",
  225. "taskname", "year", "senddate", "remarks");
  226. querySQL.addJoinTable(JOINTYPE.inner, "sa_esign_contract_template", "t3", "t3.sa_esign_contract_templateid=t2.sa_esign_contract_templateid",
  227. "name", "type");
  228. querySQL.addJoinTable(JOINTYPE.inner, "sa_agents", "t4", "t4.sa_agentsid=t1.sa_agentsid");
  229. querySQL.setSiteid(siteid);
  230. querySQL.setWhere("t1.sa_esign_contract_taskmxid", sa_esign_contract_taskmxid);
  231. Rows rows = querySQL.query();
  232. Row row = rows.isNotEmpty() ? rows.get(0) : new Row();
  233. String flowid = row.getString("flowid");
  234. if (!StringUtils.isBlank(flowid)) {
  235. row.put("downloadurl", WeChatContractUtil.describeFileUrls(flowid));
  236. }
  237. row.putIfAbsent("downloadurl", "");
  238. Rows attachments = Attachment.get(this, "sa_esign_contract_taskmx", sa_esign_contract_taskmxid);
  239. row.put("attinfos", attachments);
  240. return getSucReturnObject().setData(row).toString();
  241. }
  242. @API(title = "电子签合同任务明细-编辑任务明细", apiversion = R.ID2026041315410702.v1.class)
  243. public String edit() throws YosException {
  244. Long sa_esign_contract_taskmxid = content.getLongValue("sa_esign_contract_taskmxid");
  245. Rows taskmxrows = dbConnect.runSqlQuery("SELECT * FROM sa_esign_contract_taskmx WHERE sa_esign_contract_taskmxid=" + sa_esign_contract_taskmxid);
  246. if (taskmxrows.isEmpty()) {
  247. return getErrReturnObject().setErrMsg("合同不存在").toString();
  248. }
  249. Row taskmxrow = taskmxrows.get(0);
  250. Long sa_agentsid = taskmxrow.getLong("sa_agentsid");
  251. Long sys_enterpriseid = taskmxrow.getLong("sys_enterpriseid");
  252. String status = taskmxrow.getString("status");
  253. Long sa_esign_contract_taskid = taskmxrow.getLong("sa_esign_contract_taskid");
  254. String[] statuslist = new String[]{"合同创建", "合同签署中", "合同签署完成", "合同即将过期"};
  255. if (ArrayUtils.contains(statuslist, status)) {
  256. return getErrReturnObject().setErrMsg("当前状态不支持确认合同内容").toString();
  257. }
  258. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_esign_contract_template", "*").setTableAlias("t1");
  259. querySQL.addJoinTable(JOINTYPE.left, "sa_esign_contract_task", "t2", "t1.sa_esign_contract_templateid=t2.sa_esign_contract_templateid",
  260. "year");
  261. querySQL.setWhere("t2.sa_esign_contract_taskid", sa_esign_contract_taskid);
  262. Rows templaterows = querySQL.query();
  263. if (templaterows.isEmpty()) {
  264. return getErrReturnObject().setErrMsg("合同模板不存在").toString();
  265. }
  266. Long year = templaterows.get(0).getLong("year");
  267. Row agentRow = ContractTaskUtil.getAgentRow(this, sa_agentsid);
  268. Row enterpriseRow = ContractTaskUtil.getEnterpriseRow(this, sys_enterpriseid);
  269. //校验参数
  270. ContractTaskUtil.check(this, agentRow, enterpriseRow, taskmxrow);
  271. BigDecimal securitydeposit = ContractTaskUtil.getSecurityDeposit(this, sys_enterpriseid);
  272. String license_name = content.getStringValue("license_name");
  273. String legal_rep = content.getStringValue("legal_rep");
  274. String phonenumber = content.getStringValue("phonenumber");
  275. //构建需要上传的模板传递的数据
  276. CompanyInfo companyInfo = ContractTaskUtil.getCompanyInfo(this, enterpriseRow, agentRow, taskmxrow, year, securitydeposit);
  277. UpdateSQL updateSQL = SQLFactory.createUpdateSQL(this, "sa_esign_contract_taskmx");
  278. updateSQL.setSiteid(siteid);
  279. updateSQL.setUniqueid(sa_esign_contract_taskmxid);
  280. updateSQL.setValue("license_name", license_name);
  281. updateSQL.setValue("legal_rep", legal_rep);
  282. updateSQL.setValue("phonenumber", phonenumber);
  283. updateSQL.setValue("taxno", content.getStringValue("taxno"));
  284. updateSQL.setValue("license_address", content.getStringValue("license_address"));
  285. updateSQL.setValue("mobile", content.getStringValue("mobile"));
  286. updateSQL.setValue("presalesphonenumber", content.getStringValue("presalesphonenumber"));
  287. updateSQL.setValue("aftersalesphonenumber", content.getStringValue("aftersalesphonenumber"));
  288. updateSQL.setValue("paymans", content.getStringValue("paymans"));
  289. updateSQL.setValue("idcard", content.getStringValue("idcard"));
  290. updateSQL.setValue("companyinfo", JSON.toJSON(companyInfo));
  291. updateSQL.update();
  292. DataContrlLog.createLog(this, "sa_esign_contract_task", sa_esign_contract_taskid, "合同确认", "合同内容确认成功").insert();
  293. //创建签署流程
  294. WeChatContractUtil wccUtil = new WeChatContractUtil();
  295. String flowName = templaterows.get(0).getString("name");
  296. String templateId = templaterows.get(0).getString("templateid");
  297. // 获取模板里面的参与方RecipientId
  298. Recipient[] recipients = WeChatByTemplate.GetRecipients(templateId);
  299. if (recipients == null) {
  300. throw new NullPointerException("签署人不能为空");
  301. }
  302. //构造签署人信息
  303. FlowApproverInfo[] flowApproverInfos = WeChatByTemplate.BuildApprovers(Arrays.asList(recipients), license_name, legal_rep, phonenumber);
  304. // String organizationOpenId = DigestUtils.sha256Hex(license_name);
  305. ArrayList<String> fileBase64List = new ArrayList<>();
  306. Rows attachmentRows = Attachment.get(this, "sa_esign_contract_taskmx", sa_esign_contract_taskmxid);
  307. for (Row attachmentRow : attachmentRows) {
  308. Long attachmentid = attachmentRow.getLong("attachmentid");
  309. InputStream inputStream = getAttachmentFileInputStream(attachmentid);
  310. String fileBase64 = WeChatContractUtil.convertImageFileToBase64(inputStream);
  311. fileBase64List.add(fileBase64);
  312. }
  313. // 发起合同 样例为BtoC
  314. Map<String, String[]> resp = wccUtil.createFlowByTemplateDirectly(flowName
  315. , templateId, flowApproverInfos, WeChatConfig.SuperProxyOperatorOpenId, companyInfo, fileBase64List);
  316. int count = WeChatConfig.COUNT;
  317. for (int i = 0; i < count; i++) {
  318. // // 返回合同Id
  319. // System.out.println("您创建的合同id为:");
  320. // System.out.println(resp.get("FlowIds")[i]);
  321. // // 返回签署的链接
  322. // System.out.println("签署链接为:");
  323. // System.out.println(resp.get("Urls")[i]);
  324. // // Step 3 下载合同
  325. // // 返回合同下载链接
  326. // String url = WeChatContractUtil.describeFileUrls(resp.get("FlowIds")[i]);
  327. // System.out.println("请访问以下地址下载您的合同:");
  328. // System.out.println(url);
  329. updateSQL = SQLFactory.createUpdateSQL(this, "sa_esign_contract_taskmx");
  330. updateSQL.setSiteid(siteid);
  331. updateSQL.setUniqueid(sa_esign_contract_taskmxid);
  332. updateSQL.setValue("flowid", resp.get("FlowIds")[i]);
  333. updateSQL.setValue("signurl", resp.get("Urls")[i]);
  334. updateSQL.setValue("status", "合同创建");
  335. updateSQL.setValue("approvestatus", "待签署");
  336. updateSQL.update();
  337. }
  338. return detail();
  339. }
  340. @API(title = "经销商的合同列表", apiversion = R.ID2026041315425102.v1.class)
  341. public String agentsList() throws YosException {
  342. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_esign_contract_taskmx", "*").setTableAlias("t1");
  343. querySQL.addJoinTable(JOINTYPE.inner, "sa_esign_contract_task", "t2", "t2.sa_esign_contract_taskid=t1.sa_esign_contract_taskid",
  344. "taskname", "year", "senddate", "remarks");
  345. querySQL.addJoinTable(JOINTYPE.inner, "sa_esign_contract_template", "t3", "t3.sa_esign_contract_templateid=t2.sa_esign_contract_templateid",
  346. "name", "type");
  347. querySQL.addJoinTable(JOINTYPE.inner, "sa_agents", "t4", "t4.sa_agentsid=t1.sa_agentsid");
  348. querySQL.setSiteid(siteid);
  349. querySQL.setWhere("t4.sys_enterpriseid", sys_enterpriseid);
  350. querySQL.setPage(pageSize, pageNumber);
  351. Rows rows = querySQL.query();
  352. for (Row row : rows) {
  353. String flowid = row.getString("flowid");
  354. if (!StringUtils.isBlank(flowid)) {
  355. row.put("downloadurl", WeChatContractUtil.describeFileUrls(flowid));
  356. }
  357. row.putIfAbsent("downloadurl", "");
  358. }
  359. return getSucReturnObject().setData(rows).toString();
  360. }
  361. @API(title = "区域经理查询自己管辖的经销商合同", apiversion = R.ID2026041715520802.v1.class)
  362. public String agentsList2() throws YosException {
  363. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_esign_contract_taskmx", "*").setTableAlias("t1");
  364. querySQL.addJoinTable(JOINTYPE.inner, "sa_esign_contract_task", "t2", "t2.sa_esign_contract_taskid=t1.sa_esign_contract_taskid",
  365. "taskname", "year", "senddate", "remarks");
  366. querySQL.addJoinTable(JOINTYPE.inner, "sa_esign_contract_template", "t3", "t3.sa_esign_contract_templateid=t2.sa_esign_contract_templateid",
  367. "name", "type");
  368. querySQL.addJoinTable(JOINTYPE.inner, "sa_agents", "t4", "t4.sa_agentsid=t1.sa_agentsid",
  369. "agentnum");
  370. querySQL.addJoinTable(JOINTYPE.inner, "sys_enterprise", "t5", "t5.sys_enterpriseid=t4.sys_enterpriseid", "enterprisename", "abbreviation");
  371. if (getDepartment(userid).getString("depname").equals("区域经理")) {
  372. querySQL.setWhere(" exists(select 1 from sys_enterprise_tradefield where sa_agentsid=t1.sa_agentsid and hrid=" + hrid + " )");
  373. }
  374. querySQL.setSiteid(siteid);
  375. querySQL.setPage(pageSize, pageNumber);
  376. Rows rows = querySQL.query();
  377. RowsMap attachmentsMap = Attachment.get(this, "sa_esign_contract_taskmx", rows.toArrayList("sa_esign_contract_taskmxid", new ArrayList<>()));
  378. for (Row row : rows) {
  379. String flowid = row.getString("flowid");
  380. if (!StringUtils.isBlank(flowid)) {
  381. row.put("downloadurl", WeChatContractUtil.describeFileUrls(flowid));
  382. }
  383. row.putIfAbsent("downloadurl", "");
  384. Long sa_esign_contract_taskmxid = row.getLong("sa_esign_contract_taskmxid");
  385. row.put("attinfos", attachmentsMap.getOrDefault(sa_esign_contract_taskmxid, new Rows()));
  386. }
  387. return getSucReturnObject().setData(rows).toString();
  388. }
  389. @API(title = "经销商档案详情中的合同查询列表", apiversion = R.ID2026041810335702.v1.class)
  390. public String agentsList3() throws YosException {
  391. Long sa_agentsid = content.getLongValue("sa_agentsid");
  392. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_esign_contract_taskmx", "sa_esign_contract_taskmxid", "archiveddate").setTableAlias("t1");
  393. querySQL.addJoinTable(JOINTYPE.inner, "sa_esign_contract_task", "t2", "t2.sa_esign_contract_taskid=t1.sa_esign_contract_taskid",
  394. "taskname", "year", "senddate", "remarks");
  395. querySQL.addJoinTable(JOINTYPE.inner, "sa_esign_contract_template", "t3", "t3.sa_esign_contract_templateid=t2.sa_esign_contract_templateid",
  396. "name", "type");
  397. querySQL.setWhere("t1.sa_agentsid", sa_agentsid);
  398. querySQL.setSiteid(siteid);
  399. querySQL.setPage(pageSize, pageNumber);
  400. Rows rows = querySQL.query();
  401. RowsMap attachmentsMap = Attachment.get(this, "sa_esign_contract_taskmx", rows.toArrayList("sa_esign_contract_taskmxid", new ArrayList<>()));
  402. for (Row row : rows) {
  403. Long sa_esign_contract_taskmxid = row.getLong("sa_esign_contract_taskmxid");
  404. row.put("attinfos", attachmentsMap.getOrDefault(sa_esign_contract_taskmxid, new Rows()));
  405. row.putIfAbsent("archiveddate", "");
  406. }
  407. return getSucReturnObject().setData(rows).toString();
  408. }
  409. }