EsignContractTaskMX.java 27 KB

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