EsignContractTaskMX.java 26 KB

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