personnel.java 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684
  1. package restcontroller.webmanage.sale.salestarget;
  2. import beans.datacontrllog.DataContrlLog;
  3. import com.alibaba.fastjson.JSONArray;
  4. import com.alibaba.fastjson.JSONObject;
  5. import common.Controller;
  6. import common.YosException;
  7. import common.annotation.API;
  8. import common.annotation.CACHEING;
  9. import common.annotation.CACHEING_CLEAN;
  10. import common.annotation.cm;
  11. import common.data.*;
  12. import org.apache.commons.lang.StringUtils;
  13. import org.apache.poi.xssf.usermodel.*;
  14. import restcontroller.R;
  15. import restcontroller.webmanage.saletool.orderclue.ExportExcel;
  16. import java.util.ArrayList;
  17. import java.util.HashMap;
  18. @API(title = "管理端-销售目标-人员目标")
  19. public class personnel extends Controller {
  20. /**
  21. * 构造函数
  22. * @param content
  23. */
  24. public personnel(JSONObject content) throws YosException {
  25. super(content);
  26. }
  27. @API(title = "新建年度或添加人员", apiversion = R.ID20220831165302.v1.class)
  28. @CACHEING_CLEAN(cms = {@cm(clazz = personnel.class, method = {"queryList", "queryDetailList"}), @cm(clazz = personnelstatistics.class, method = {"queryList"})})
  29. public String insert() throws YosException {
  30. Long year = content.getLong("year");
  31. String assessmentindicators=content.getString("assessmentindicators");
  32. Long sa_salestargetbillid = content.getLong("sa_salestargetbillid");
  33. String statisticaldimension=content.getStringValue("statisticaldimension");
  34. String sa_accountclassids=content.getStringValue("sa_accountclassids");
  35. JSONArray salesArray = content.getJSONArray("sales");
  36. ArrayList<String> sqlList = new ArrayList<>();
  37. if (sa_salestargetbillid <= 0) {
  38. //查询创建年度是否存在
  39. if (dbConnect.runSqlQuery("SELECT 1 FROM sa_salestargetbill WHERE year = " + year + " AND targettype ='人员目标' AND siteid = '" + siteid + "'").isNotEmpty()) {
  40. return getErrReturnObject().setErrMsg(year + "年度目标已存在,无法创建").toString();
  41. }
  42. sa_salestargetbillid = createTableID("sa_salestargetbill");
  43. SQLFactory sqlFactory = new SQLFactory(this, "创建新年度");
  44. sqlFactory.addParameter("siteid", siteid);
  45. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  46. sqlFactory.addParameter("username", username);
  47. sqlFactory.addParameter("sys_enterpriseid", "null");
  48. sqlFactory.addParameter("userid", userid);
  49. sqlFactory.addParameter("year", year);
  50. sqlFactory.addParameter("assessmentindicators", assessmentindicators);
  51. sqlFactory.addParameter("statisticaldimension", statisticaldimension);
  52. sqlFactory.addParameter("sa_accountclassids", sa_accountclassids);
  53. sqlFactory.addParameter("targettype", "人员目标");
  54. sqlFactory.addParameter("tradefield", "");
  55. sqlList.add(sqlFactory.getSQL());
  56. sqlList.add(DataContrlLog.createLog(this, "sa_salestargetbill", sa_salestargetbillid, "人员目标新增", "人员目标新增"+year ).getSQL());
  57. //获取所有启用业务员
  58. SQLFactory saleareahrsqlFactory = new SQLFactory(this, "通用-人员范围查询");
  59. saleareahrsqlFactory.addParameter("siteid", siteid);
  60. saleareahrsqlFactory.addParameter_SQL("where", " 1=1 ");
  61. saleareahrsqlFactory.addParameter_SQL("isIn", " not in ");
  62. saleareahrsqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  63. String sql = saleareahrsqlFactory.getSQL();
  64. Rows saleareahrrows = dbConnect.runSqlQuery(sql);
  65. salesArray=saleareahrrows.toJsonArray();
  66. }else{
  67. SQLFactory sqlFactory = new SQLFactory(this, "更新新年度");
  68. sqlFactory.addParameter("siteid", siteid);
  69. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  70. sqlFactory.addParameter("username", username);
  71. sqlFactory.addParameter("userid", userid);
  72. sqlFactory.addParameter("assessmentindicators", assessmentindicators);
  73. sqlFactory.addParameter("statisticaldimension", statisticaldimension);
  74. sqlFactory.addParameter("sa_accountclassids", sa_accountclassids);
  75. sqlList.add(sqlFactory.getSQL());
  76. }
  77. String[] types = {"年", "季", "月"};
  78. long[] ids = createTableID("sa_salestarget", salesArray.size() * 17);
  79. int index = 1;
  80. for (Object obj : salesArray) {
  81. JSONObject saleObj = (JSONObject) obj;
  82. System.out.println(saleObj.toString());
  83. SQLFactory saleFactory = new SQLFactory(this, "人员范围新增");
  84. saleFactory.addParameter("siteid", siteid);
  85. saleFactory.addParameter("sa_salestargethrid", createTableID("sa_salestargethr"));
  86. saleFactory.addParameter("hrid", saleObj.getLongValue("hrid"));
  87. saleFactory.addParameter("position", saleObj.getStringValue("position"));
  88. saleFactory.addParameter("sa_saleareaid", saleObj.getStringValue("sa_saleareaid"));
  89. saleFactory.addParameter("areaname", saleObj.getStringValue("areaname"));
  90. saleFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  91. saleFactory.addParameter("depname", saleObj.getStringValue("depname"));
  92. saleFactory.addParameter("departmentid", saleObj.getLongValue("departmentid"));
  93. saleFactory.addParameter("name", saleObj.getStringValue("name"));
  94. sqlList.add(saleFactory.getSQL());
  95. for (String type : types) {
  96. int point;
  97. if (type.equals("年")) {
  98. point = 1;
  99. } else if (type.equals("季")) {
  100. point = 4;
  101. } else if (type.equals("月")) {
  102. point = 12;
  103. } else {
  104. point = 0;
  105. }
  106. for (int i = 0; i < point; i++) {
  107. SQLFactory targetFactory = new SQLFactory(this, "人员-目标明细新增");
  108. targetFactory.addParameter("siteid", siteid);
  109. targetFactory.addParameter("sa_salestargetid", ids[index - 1]);
  110. targetFactory.addParameter("type", type);
  111. targetFactory.addParameter("point", i + 1);
  112. targetFactory.addParameter("targettype", "人员目标");
  113. targetFactory.addParameter("sa_saleareaid", saleObj.getString("sa_saleareaid"));
  114. targetFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  115. targetFactory.addParameter("year", year);
  116. targetFactory.addParameter("sa_projectid", "null");
  117. targetFactory.addParameter("createby", username);
  118. targetFactory.addParameter("target_l", 0);
  119. targetFactory.addParameter("target_h", 0);
  120. sqlList.add(targetFactory.getSQL());
  121. index++;
  122. }
  123. }
  124. sqlList.add(DataContrlLog.createLog(this, "sa_salestargetbill", sa_salestargetbillid, "区域编辑", "添加区域" + saleObj.getStringValue("areaname")).getSQL());
  125. }
  126. dbConnect.runSqlUpdate(sqlList);
  127. return getSucReturnObject().toString();
  128. }
  129. @API(title = "删除人员", apiversion = R.ID20220901111202.v1.class)
  130. @CACHEING_CLEAN(cms = {@cm(clazz = personnel.class, method = {"queryList", "queryDetailList"}), @cm(clazz = personnelstatistics.class, method = {"queryList"})})
  131. public String deletePeople() throws YosException {
  132. Long sa_salestargetbillid = content.getLong("sa_salestargetbillid");
  133. JSONArray salesArray = content.getJSONArray("sa_saleareaid");
  134. if (salesArray.size() <= 0) {
  135. return getErrReturnObject().setErrMsg("请选择人员").toString();
  136. }
  137. String sql = "SELECT 1 FROM sa_salestarget WHERE sa_saleareaid in " + salesArray + " and sa_salestargetbillid = " + sa_salestargetbillid + " and targettype = '人员目标' and (target_l >0 or target_h >0)";
  138. sql = sql.replace("[", "(").replace("]", ")");
  139. if (dbConnect.runSqlQuery(sql).isNotEmpty()) {
  140. return getErrReturnObject().setErrMsg("存在已填写的数据,无法删除").toString();
  141. }
  142. ArrayList<String> sqlList = new ArrayList<>();
  143. //删除人员范围
  144. SQLFactory sqlFactory = new SQLFactory(this, "人员-删除人员范围");
  145. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  146. sqlFactory.addParameter("siteid", siteid);
  147. sqlFactory.addParameter_in("sa_saleareaid", salesArray.toArray());
  148. sqlList.add(sqlFactory.getSQL());
  149. //删除人员目标
  150. SQLFactory sqlFactory2 = new SQLFactory(this, "人员-删除目标明细");
  151. sqlFactory2.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  152. sqlFactory2.addParameter("siteid", siteid);
  153. sqlFactory2.addParameter_in("sa_saleareaid", salesArray.toArray());
  154. sqlList.add(sqlFactory2.getSQL());
  155. //操作记录
  156. for (Object obj : salesArray) {
  157. Long sa_saleareaid = Long.valueOf(obj.toString());
  158. String name = "";
  159. Rows rows = dbConnect.runSqlQuery("SELECT areaname from sa_salearea WHERE sa_saleareaid = " + sa_saleareaid);
  160. if (rows.isNotEmpty()) {
  161. name = rows.get(0).getString("areaname");
  162. }
  163. sqlList.add(DataContrlLog.createLog(this, "sa_salestargetbill", sa_salestargetbillid, "人员编辑", "移除人员" + name).getSQL());
  164. }
  165. dbConnect.runSqlUpdate(sqlList);
  166. return getSucReturnObject().toString();
  167. }
  168. @API(title = "年度目标列表", apiversion = R.ID20220901132502.v1.class)
  169. @CACHEING
  170. public String queryList() throws YosException {
  171. /*
  172. 过滤条件设置
  173. */
  174. String targettype =content.getString("targettype");
  175. StringBuffer where = new StringBuffer(" 1=1 ");
  176. if (content.containsKey("where")) {
  177. JSONObject whereObject = content.getJSONObject("where");
  178. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  179. where.append(" and(");
  180. where.append("t1.year like'%").append(whereObject.getString("condition")).append("%' ");
  181. where.append("or t1.createby like'%").append(whereObject.getString("condition")).append("%' ");
  182. where.append(")");
  183. }
  184. if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
  185. where.append(" and(");
  186. where.append("t1.status like'%").append(whereObject.getString("status")).append("%' ");
  187. where.append(")");
  188. }
  189. }
  190. SQLFactory sqlFactory = new SQLFactory(this, "年度目标列表", pageSize, pageNumber, pageSorting);
  191. sqlFactory.addParameter("siteid", siteid);
  192. sqlFactory.addParameter_SQL("where", where);
  193. sqlFactory.addParameter("targettype", targettype);
  194. Rows rows = dbConnect.runSqlQuery(sqlFactory);
  195. Rows accountclassrows = dbConnect.runSqlQuery("select sa_accountclassid,accountname from sa_accountclass where siteid='"+siteid+"'");
  196. RowsMap accountclassrowsMap = accountclassrows.toRowsMap("sa_accountclassid");
  197. for (Row row:rows) {
  198. JSONArray jsonArray= new JSONArray();
  199. if(isJSONArray(row.getString("statisticaldimension"))){
  200. row.put("statisticaldimension",JSONArray.parseArray(row.getString("statisticaldimension")));
  201. }
  202. if(isJSONObject(row.getString("statisticaldimension"))){
  203. row.put("statisticaldimension",JSONObject.parseObject(row.getString("statisticaldimension")));
  204. }
  205. if(isJSONArray(row.getString("sa_accountclassids"))){
  206. JSONArray sa_accountclassids =JSONArray.parseArray(row.getString("sa_accountclassids"));
  207. for (Object object:sa_accountclassids) {
  208. Long sa_accountclassid = Long.valueOf(object.toString());
  209. if(accountclassrowsMap.containsKey(String.valueOf(sa_accountclassid))){
  210. if(accountclassrowsMap.get(String.valueOf(sa_accountclassid)).isNotEmpty()){
  211. jsonArray.add(accountclassrowsMap.get(String.valueOf(sa_accountclassid)).get(0));
  212. }
  213. }
  214. }
  215. row.put("sa_accountclassids",jsonArray);
  216. }
  217. }
  218. return getSucReturnObject().setData(rows).toString();
  219. }
  220. @API(title = "目标详情", apiversion = R.ID20220901140402.v1.class)
  221. public String queryDetail() throws YosException {
  222. Long sa_salestargetbillid = content.getLong("sa_salestargetbillid");
  223. SQLFactory sqlFactory = new SQLFactory(this, "人员-目标详情");
  224. sqlFactory.addParameter("siteid", siteid);
  225. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  226. Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL());
  227. Rows accountclassrows = dbConnect.runSqlQuery("select sa_accountclassid,accountname from sa_accountclass where siteid='"+siteid+"'");
  228. RowsMap accountclassrowsMap = accountclassrows.toRowsMap("sa_accountclassid");
  229. for (Row row:rows) {
  230. JSONArray jsonArray= new JSONArray();
  231. if(isJSONArray(row.getString("statisticaldimension"))){
  232. row.put("statisticaldimension",JSONArray.parseArray(row.getString("statisticaldimension")));
  233. }
  234. if(isJSONObject(row.getString("statisticaldimension"))){
  235. row.put("statisticaldimension",JSONObject.parseObject(row.getString("statisticaldimension")));
  236. }
  237. if(isJSONArray(row.getString("sa_accountclassids"))){
  238. JSONArray sa_accountclassids =JSONArray.parseArray(row.getString("sa_accountclassids"));
  239. for (Object object:sa_accountclassids) {
  240. Long sa_accountclassid = Long.valueOf(object.toString());
  241. if(accountclassrowsMap.containsKey(String.valueOf(sa_accountclassid))){
  242. if(accountclassrowsMap.get(String.valueOf(sa_accountclassid)).isNotEmpty()){
  243. jsonArray.add(accountclassrowsMap.get(String.valueOf(sa_accountclassid)).get(0));
  244. }
  245. }
  246. }
  247. row.put("sa_accountclassids",jsonArray);
  248. }
  249. }
  250. return getSucReturnObject().setData(rows.isNotEmpty() ? rows.get(0) : new Rows()).toString();
  251. }
  252. @API(title = "目标编辑", apiversion = R.ID20220902162902.v1.class)
  253. @CACHEING_CLEAN(cms = {@cm(clazz = personnel.class, method = {"queryList", "queryDetailList"}), @cm(clazz = personnelstatistics.class, method = {"queryList"})})
  254. public String edit() throws YosException {
  255. Long sa_salestargetbillid = content.getLongValue("sa_salestargetbillid");
  256. Long sa_saleareaid = content.getLong("sa_saleareaid");
  257. if (sa_salestargetbillid == 0) {
  258. Long year = content.getLongValue("year");
  259. Rows rows = dbConnect.runSqlQuery("SELECT DISTINCT sa_salestargetbillid from sa_salestarget WHERE year = " + year + " and sa_saleareaid=" + sa_saleareaid + " and targettype ='人员目标' and siteid='" + siteid + "'");
  260. if (rows.isNotEmpty()) {
  261. sa_salestargetbillid = rows.get(0).getLong("sa_salestargetbillid");
  262. }
  263. }
  264. if (sa_salestargetbillid == 0) {
  265. return getErrReturnObject().setErrMsg("年度目标不存在或该人员不在年度目标中,请先创建年度目标或添加相关人员到年度目标中").toString();
  266. }
  267. ArrayList<String> sqlList = new ArrayList<>();
  268. String key_l = "y1l";
  269. String key_h = "y1h";
  270. if (content.containsKey(key_l) && content.containsKey(key_h)) {
  271. sqlList.add(getSql(content.getString(key_l), content.getString(key_h), sa_salestargetbillid, sa_saleareaid, "年", 1));
  272. }
  273. for (int i = 1; i < 5; i++) {
  274. key_l = "s" + i + "l";
  275. key_h = "s" + i + "h";
  276. if (content.containsKey(key_l) && content.containsKey(key_h)) {
  277. sqlList.add(getSql(content.getString(key_l), content.getString(key_h), sa_salestargetbillid, sa_saleareaid, "季", i));
  278. }
  279. }
  280. for (int i = 1; i < 13; i++) {
  281. key_l = "m" + i + "l";
  282. key_h = "m" + i + "h";
  283. if (content.containsKey(key_l) && content.containsKey(key_h)) {
  284. sqlList.add(getSql(content.getString(key_l), content.getString(key_h), sa_salestargetbillid, sa_saleareaid, "月", i));
  285. }
  286. }
  287. sqlList.add(DataContrlLog.createLog(this, "sa_salestargetbill", sa_salestargetbillid, "编辑人员目标", "编辑人员目标").getSQL());
  288. dbConnect.runSqlUpdate(sqlList);
  289. return getSucReturnObject().toString();
  290. }
  291. public String getSql(String target_l, String target_h, Long id, Long sa_saleareaid, String type, int point) {
  292. return " UPDATE sa_salestarget SET target_l=" + target_l + ",target_h = " + target_h + " WHERE sa_salestargetbillid =" + id + " and sa_saleareaid =" + sa_saleareaid + " and type ='" + type + "' AND point = " + point;
  293. }
  294. @API(title = "目标详情列表", apiversion = R.ID20220901141802.v1.class)
  295. @CACHEING
  296. public String queryDetailList() throws YosException {
  297. Long sa_salestargetbillid = content.getLong("sa_salestargetbillid");
  298. /*
  299. 过滤条件设置
  300. */
  301. StringBuffer where = new StringBuffer(" 1=1 ");
  302. if (content.containsKey("where")) {
  303. JSONObject whereObject = content.getJSONObject("where");
  304. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  305. where.append(" and(");
  306. where.append("t.name like'%").append(whereObject.getString("condition")).append("%' ");
  307. where.append("or t.depfullname like'%").append(whereObject.getString("condition")).append("%' ");
  308. where.append("or t.depname like'%").append(whereObject.getString("condition")).append("%' ");
  309. where.append("or t.position like'%").append(whereObject.getString("condition")).append("%' ");
  310. where.append(")");
  311. }
  312. }
  313. SQLFactory sqlFactory = new SQLFactory(this, "人员-目标详情列表");
  314. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  315. sqlFactory.addParameter_SQL("where", where);
  316. sqlFactory.addParameter("siteid", siteid);
  317. String sql = sqlFactory.getSQL();
  318. Rows rows = dbConnect.runSqlQuery(sql);
  319. Rows saleareas = dbConnect.runSqlQuery("select * from sa_salearea where parentid=0 and siteid='"+siteid+"'");
  320. Long sa_saleareaid=0l;
  321. if(!saleareas.isEmpty() && saleareas.size()==1){
  322. sa_saleareaid=saleareas.get(0).getLong("sa_saleareaid");
  323. for (Row row :rows) {
  324. if(row.getLong("parentid")==0 ){
  325. row.put("y1l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("y1l"));
  326. row.put("y1h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("y1h"));
  327. row.put("s1l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s1l"));
  328. row.put("s1h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s1h"));
  329. row.put("s2l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s2l"));
  330. row.put("s2h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s2h"));
  331. row.put("s3l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s3l"));
  332. row.put("s3h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s3h"));
  333. row.put("s4l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s4l"));
  334. row.put("s4h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s4h"));
  335. row.put("m1l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m1l"));
  336. row.put("m1h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m1h"));
  337. row.put("m2l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m2l"));
  338. row.put("m2h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m2h"));
  339. row.put("m3l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m3l"));
  340. row.put("m3h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m3h"));
  341. row.put("m4l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m4l"));
  342. row.put("m4h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m4h"));
  343. row.put("m5l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m5l"));
  344. row.put("m5h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m5h"));
  345. row.put("m6l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m6l"));
  346. row.put("m6h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m6h"));
  347. row.put("m7l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m7l"));
  348. row.put("m7h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m7h"));
  349. row.put("m8l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m8l"));
  350. row.put("m8h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m8h"));
  351. row.put("m9l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m9l"));
  352. row.put("m9h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m9h"));
  353. row.put("m10l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m10l"));
  354. row.put("m10h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m10h"));
  355. row.put("m11l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m11l"));
  356. row.put("m11h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m11h"));
  357. row.put("m12l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m12l"));
  358. row.put("m12h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m12h"));
  359. }
  360. }
  361. }
  362. return getSucReturnObject().setData(rows).toString();
  363. }
  364. @API(title = "人员目标导入模板", apiversion = R.ID20220913093102.v1.class)
  365. public String downloadExcel() throws YosException {
  366. ExcelFactory excelFactory = new ExcelFactory("人员目标导入模板");
  367. XSSFSheet sheet = excelFactory.getXssfWorkbook().createSheet("Sheet1");
  368. XSSFWorkbook xssfFWorkbook = excelFactory.getXssfWorkbook();
  369. personnelexcel.setBatchDetailSheetColumn1(sheet);// 设置工作薄列宽
  370. XSSFCellStyle titleCellStyle1 = ExportExcel.createTitleCellStyle1(xssfFWorkbook);
  371. XSSFCellStyle titleCellStyle2 = ExportExcel.createTitleCellStyle2(xssfFWorkbook);
  372. XSSFCellStyle titleCellStyle3 = ExportExcel.createBodyCellStyle(xssfFWorkbook);
  373. personnelexcel.batchDetail(sheet, titleCellStyle1, titleCellStyle2, titleCellStyle3, xssfFWorkbook);// 写入标题
  374. Rows aa = uploadExcelToObs(excelFactory);
  375. String url = "";
  376. if (!aa.isEmpty()) {
  377. url = aa.get(0).getString("url");
  378. }
  379. return getSucReturnObject().setData(url).toString();
  380. }
  381. @API(title = "人员目标导入", apiversion = R.ID20220913092702.v1.class)
  382. @CACHEING_CLEAN(apiversions = {R.ID20220901141802.class})
  383. public String personnelTargetImport() throws YosException {
  384. Long sa_salestargetbillid = content.getLong("sa_salestargetbillid");
  385. Long year = content.getLong("year");
  386. ExcelFactory e;
  387. try {
  388. if (content.getLong("attachmentid") > 0) {
  389. e = getPostExcelFactory(content.getLong("attachmentid"));
  390. // 本地
  391. //e = getPostExcelFactory();
  392. } else {
  393. e = getPostExcelFactory();
  394. // 本地
  395. //e = getPostExcelFactory();
  396. }
  397. ArrayList<String> keys = new ArrayList<>();
  398. ArrayList<String> sqllist = new ArrayList<>();
  399. keys.add("name");
  400. String keyl = "y1l";
  401. keys.add(keyl);
  402. for (int i = 1; i < 5; i++) {
  403. keyl = "s" + i + "l";
  404. keys.add(keyl);
  405. }
  406. for (int i = 1; i < 13; i++) {
  407. keyl = "m" + i + "l";
  408. keys.add(keyl);
  409. }
  410. Rows rows = e.getSheetRows(0, keys, 2);
  411. ArrayList<String> areanameList = new ArrayList<>();
  412. for (Row row : rows) {
  413. areanameList.add(row.getString("name"));
  414. }
  415. //查询可导入的用户信息
  416. SQLFactory sqlFactory = new SQLFactory(this, "人员-查询可导入区域信息");
  417. sqlFactory.addParameter("siteid", siteid);
  418. sqlFactory.addParameter_in("areaname", areanameList);
  419. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  420. String sql = sqlFactory.getSQL();
  421. RowsMap areaRowsMap = dbConnect.runSqlQuery(sql).toRowsMap("areaname");
  422. boolean iserr = false;
  423. Rows rowserr = new Rows();
  424. Rows rowssuc = new Rows();
  425. // 手机号码的格式:第一位只能为1,第二位可以是3,4,5,7,8,第三位到第十一位可以为0-9中任意一个数字
  426. String regex = "^((13[0-9])|(14[5,7,9])|(15[0-3,5-9])|(166)|(17[3,5,6,7,8])|(18[0-9])|(19[1,8,9]))\\d{8}$";
  427. for (Row row : rows) {
  428. if (StringUtils.isEmpty(row.getString("name"))) {
  429. iserr = true;
  430. row.put("msg", "错误信息:必填项不能为空");
  431. rowserr.add(row);
  432. } else {
  433. Rows userRows = areaRowsMap.get(row.getString("name"));
  434. if (userRows.isNotEmpty()) {
  435. row.putAll(userRows.get(0));
  436. rowssuc.add(row);
  437. } else {
  438. iserr = true;
  439. row.put("msg", "错误信息:数据已导入或区域不在数据库中");
  440. rowserr.add(row);
  441. }
  442. }
  443. }
  444. String[] types = {"年", "季", "月"};
  445. long[] ids = createTableID("sa_salestarget", rowssuc.size() * 17);
  446. int index = 1;
  447. if (!rowssuc.isEmpty()) {
  448. for (Row row : rowssuc) {
  449. SQLFactory saleFactory = new SQLFactory(this, "人员范围新增");
  450. saleFactory.addParameter("siteid", siteid);
  451. saleFactory.addParameter("sa_salestargethrid", createTableID("sa_salestargethr"));
  452. saleFactory.addParameter("hrid", 0);
  453. saleFactory.addParameter("position", "");
  454. saleFactory.addParameter("sa_saleareaid", row.getString("sa_saleareaid"));
  455. saleFactory.addParameter("areaname", row.getString("areaname"));
  456. saleFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  457. saleFactory.addParameter("depname", "");
  458. saleFactory.addParameter("departmentid",0);
  459. saleFactory.addParameter("name","");
  460. sqllist.add(saleFactory.getSQL());
  461. for (String type : types) {
  462. int point;
  463. if (type.equals("年")) {
  464. point = 1;
  465. } else if (type.equals("季")) {
  466. point = 4;
  467. } else if (type.equals("月")) {
  468. point = 12;
  469. } else {
  470. point = 0;
  471. }
  472. for (int i = 0; i < point; i++) {
  473. double target_l = 0L;
  474. double target_h = 0L;
  475. if (type.equals("年")) {
  476. target_l = row.getDouble("y1l");
  477. target_h = row.getDouble("y1h");
  478. }
  479. if (type.equals("季")) {
  480. target_l = row.getDouble("s" + (i + 1) + "l");
  481. target_h = row.getDouble("s" + (i + 1) + "h");
  482. }
  483. if (type.equals("月")) {
  484. target_l = row.getDouble("m" + (i + 1) + "l");
  485. target_h = row.getDouble("m" + (i + 1) + "h");
  486. }
  487. SQLFactory targetFactory = new SQLFactory(this, "人员-目标明细新增");
  488. targetFactory.addParameter("siteid", siteid);
  489. targetFactory.addParameter("sa_salestargetid", ids[index - 1]);
  490. targetFactory.addParameter("type", type);
  491. targetFactory.addParameter("point", i + 1);
  492. targetFactory.addParameter("targettype", "人员目标");
  493. targetFactory.addParameter("sa_saleareaid", row.getString("sa_saleareaid"));
  494. targetFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  495. targetFactory.addParameter("year", year);
  496. targetFactory.addParameter("sa_projectid", "null");
  497. targetFactory.addParameter("createby", username);
  498. targetFactory.addParameter("target_l", target_l);
  499. targetFactory.addParameter("target_h", target_h);
  500. sqllist.add(targetFactory.getSQL());
  501. index++;
  502. }
  503. }
  504. }
  505. }
  506. if (sqllist != null && !sqllist.isEmpty()) {
  507. dbConnect.runSqlUpdate("delete from sa_salestargethr where siteid='"+siteid+"' and sa_salestargetbillid="+sa_salestargetbillid);
  508. dbConnect.runSqlUpdate("delete from sa_salestarget where siteid='"+siteid+"' and sa_salestargetbillid="+sa_salestargetbillid);
  509. sqllist.add(DataContrlLog.createLog(this, "sa_salestargetbill", sa_salestargetbillid, "导入", "导入人员目标").getSQL());
  510. dbConnect.runSqlUpdate(sqllist);
  511. }
  512. if (iserr) {
  513. ExcelFactory excelFactory = new ExcelFactory("人员目标导入错误信息");
  514. ArrayList<String> colNameList = new ArrayList<String>();
  515. HashMap<String, Class> keytypemap = new HashMap<String, Class>();
  516. colNameList.add("name");
  517. String key_l = "y1l";
  518. colNameList.add(key_l);
  519. for (int a = 1; a < 5; a++) {
  520. key_l = "s" + a + "l";
  521. colNameList.add(key_l);
  522. }
  523. for (int a = 1; a < 13; a++) {
  524. key_l = "m" + a + "l";
  525. colNameList.add(key_l);
  526. }
  527. colNameList.add("msg");
  528. keytypemap.put("name", String.class);
  529. keytypemap.put("phonenumber", String.class);
  530. key_l = "y1l";
  531. keytypemap.put(key_l, String.class);
  532. for (int a = 1; a < 5; a++) {
  533. key_l = "s" + a + "l";
  534. keytypemap.put(key_l, String.class);
  535. }
  536. for (int a = 1; a < 13; a++) {
  537. key_l = "m" + a + "l";
  538. keytypemap.put(key_l, String.class);
  539. }
  540. keytypemap.put("msg", String.class);
  541. rowserr.setFieldList(colNameList);
  542. rowserr.setFieldTypeMap(keytypemap);
  543. addSheet(excelFactory, "Sheet1", rowserr);
  544. Rows aa = uploadExcelToObs(excelFactory);
  545. String url = "";
  546. if (!aa.isEmpty()) {
  547. url = aa.get(0).getString("url");
  548. }
  549. return getSucReturnObject().setData(url).toString();
  550. }
  551. } catch (Exception e1) {
  552. // TODO Auto-generated catch block
  553. e1.printStackTrace();
  554. return getErrReturnObject().setErrMsg(e1.getMessage()).toString();
  555. }
  556. return getSucReturnObject().toString();
  557. }
  558. public XSSFSheet addSheet(ExcelFactory excelFactory, String sheetname, Rows datarows) {
  559. ArrayList<String> keylist = datarows.getFieldList();
  560. XSSFSheet sheet = excelFactory.getXssfWorkbook().createSheet(sheetname);
  561. XSSFWorkbook xssfFWorkbook = excelFactory.getXssfWorkbook();
  562. XSSFCellStyle xssfCellStyle1 = xssfFWorkbook.createCellStyle();
  563. XSSFFont font = xssfFWorkbook.createFont();
  564. font.setColor((short) 0xa);
  565. font.setFontHeightInPoints((short) 12);
  566. font.setBold(true);
  567. xssfCellStyle1.setFont(font);
  568. personnelexcel.setBatchDetailSheetColumn2(sheet);// 设置工作薄列宽
  569. XSSFCellStyle titleCellStyle1 = ExportExcel.createTitleCellStyle1(xssfFWorkbook);
  570. XSSFCellStyle titleCellStyle2 = ExportExcel.createTitleCellStyle2(xssfFWorkbook);
  571. personnelexcel.batchDetailErr(sheet, titleCellStyle1, titleCellStyle2, xssfFWorkbook);// 写入标题
  572. for (int n = 0; n < datarows.size(); n++) {
  573. Row row = datarows.get(n);
  574. XSSFRow datarow = sheet.createRow(n + 2);
  575. for (int i1 = 0; i1 < keylist.size(); i1++) {
  576. Class fieldclazztype = datarows.getFieldMeta(keylist.get(i1)).getFieldtype();
  577. if (fieldclazztype == Integer.class) {
  578. datarow.createCell(i1).setCellValue(row.getInteger(keylist.get(i1)).intValue());
  579. } else if (fieldclazztype == Long.class) {
  580. datarow.createCell(i1).setCellValue(row.getLong(keylist.get(i1)));
  581. } else if (fieldclazztype == Float.class) {
  582. datarow.createCell(i1).setCellValue(row.getFloat(keylist.get(i1)));
  583. } else if (fieldclazztype == Double.class) {
  584. datarow.createCell(i1).setCellValue(row.getDouble(keylist.get(i1)));
  585. } else {
  586. datarow.createCell(i1).setCellValue(row.getString(keylist.get(i1)));
  587. }
  588. if (i1 == 18) {
  589. datarow.getCell(i1).setCellStyle(xssfCellStyle1);
  590. }
  591. }
  592. }
  593. return sheet;
  594. }
  595. }