personnelstatistics.java 49 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940
  1. package restcontroller.webmanage.sale.salestarget;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.alibaba.fastjson.JSONObject;
  4. import common.Controller;
  5. import common.YosException;
  6. import common.annotation.API;
  7. import common.annotation.CACHEING;
  8. import common.data.*;
  9. import org.apache.commons.lang.StringUtils;
  10. import org.apache.poi.xssf.usermodel.*;
  11. import restcontroller.R;
  12. import restcontroller.webmanage.saletool.orderclue.ExportExcel;
  13. import java.math.BigDecimal;
  14. import java.util.ArrayList;
  15. import java.util.Calendar;
  16. @API(title = "管理端-销售目标-人员目标统计")
  17. public class personnelstatistics extends Controller {
  18. /**
  19. * 构造函数
  20. *
  21. * @param content
  22. */
  23. public personnelstatistics(JSONObject content) throws YosException {
  24. super(content);
  25. }
  26. @API(title = "人员目标导出", apiversion = R.ID20220916095402.v1.class)
  27. public String export() throws YosException {
  28. JSONArray array = content.getJSONArray("row");
  29. ExcelFactory excelFactory = new ExcelFactory("人员目标导出模板");
  30. XSSFSheet sheet = excelFactory.getXssfWorkbook().createSheet("Sheet1");
  31. XSSFWorkbook xssfFWorkbook = excelFactory.getXssfWorkbook();
  32. personnelexcel.setBatchDetailSheetColumn3(sheet);// 设置工作薄列宽
  33. XSSFCellStyle titleCellStyle1 = ExportExcel.createTitleCellStyle1(xssfFWorkbook);
  34. XSSFCellStyle titleCellStyle2 = ExportExcel.createTitleCellStyle2(xssfFWorkbook);
  35. XSSFCellStyle titleCellStyle3 = ExportExcel.createBodyCellStyle(xssfFWorkbook);
  36. personnelexcel.batchDetailExport(sheet, titleCellStyle1, titleCellStyle2, titleCellStyle3, xssfFWorkbook, array);// 写入标题
  37. Rows aa = uploadExcelToObs(excelFactory);
  38. String url = "";
  39. if (!aa.isEmpty()) {
  40. url = aa.get(0).getString("url");
  41. }
  42. return getSucReturnObject().setData(url).toString();
  43. }
  44. public XSSFSheet addSheet(ExcelFactory excelFactory, String sheetname, Rows datarows) {
  45. ArrayList<String> keylist = datarows.getFieldList();
  46. XSSFSheet sheet = excelFactory.getXssfWorkbook().createSheet(sheetname);
  47. XSSFWorkbook xssfFWorkbook = excelFactory.getXssfWorkbook();
  48. XSSFCellStyle xssfCellStyle1 = xssfFWorkbook.createCellStyle();
  49. XSSFFont font = xssfFWorkbook.createFont();
  50. font.setColor((short) 0xa);
  51. font.setFontHeightInPoints((short) 12);
  52. font.setBold(true);
  53. xssfCellStyle1.setFont(font);
  54. personnelexcel.setBatchDetailSheetColumn2(sheet);// 设置工作薄列宽
  55. XSSFCellStyle titleCellStyle1 = ExportExcel.createTitleCellStyle1(xssfFWorkbook);
  56. XSSFCellStyle titleCellStyle2 = ExportExcel.createTitleCellStyle2(xssfFWorkbook);
  57. personnelexcel.batchDetailErr(sheet, titleCellStyle1, titleCellStyle2, xssfFWorkbook);// 写入标题
  58. for (int n = 0; n < datarows.size(); n++) {
  59. Row row = datarows.get(n);
  60. XSSFRow datarow = sheet.createRow(n + 2);
  61. for (int i1 = 0; i1 < keylist.size(); i1++) {
  62. Class fieldclazztype = datarows.getFieldMeta( keylist.get(i1)).getFieldtype();
  63. if (fieldclazztype == Integer.class) {
  64. datarow.createCell(i1).setCellValue(row.getInteger(keylist.get(i1)).intValue());
  65. } else if (fieldclazztype == Long.class) {
  66. datarow.createCell(i1).setCellValue(row.getLong(keylist.get(i1)));
  67. } else if (fieldclazztype == Float.class) {
  68. datarow.createCell(i1).setCellValue(row.getFloat(keylist.get(i1)));
  69. } else if (fieldclazztype == Double.class) {
  70. datarow.createCell(i1).setCellValue(row.getDouble(keylist.get(i1)));
  71. } else {
  72. datarow.createCell(i1).setCellValue(row.getString(keylist.get(i1)));
  73. }
  74. if (i1 == 36) {
  75. datarow.getCell(i1).setCellStyle(xssfCellStyle1);
  76. }
  77. }
  78. }
  79. return sheet;
  80. }
  81. // @API(title = "获取区域经理的营销区域", apiversion = R.ID20231018093803.v1.class)
  82. // public String getcurrentusersalearea() throws YosException {
  83. //
  84. // SQLFactory sqlFactory = new SQLFactory(this, "业务员列表查询");
  85. // sqlFactory.addParameter("siteid", siteid);
  86. // sqlFactory.addParameter("hrid", hrid);
  87. // Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL());
  88. //
  89. // SQLFactory areasqlFactory = new SQLFactory(this, "下级区域获取");
  90. // areasqlFactory.addParameter("siteid", siteid);
  91. // areasqlFactory.addParameter_in("sa_saleareaid", rows.toArrayList("sa_saleareaid",new ArrayList<>()));
  92. // Rows arearows = dbConnect.runSqlQuery(areasqlFactory.getSQL());
  93. // return getSucReturnObject().setData(arearows).toString();
  94. // }
  95. @API(title = "查询当前账户负责的区域", apiversion = R.ID20231108160203.v1.class)
  96. @CACHEING
  97. public String queryList_currentArea() throws YosException {
  98. SQLFactory hrsqlFactory = new SQLFactory(this, "业务员列表查询");
  99. hrsqlFactory.addParameter("siteid", siteid);
  100. hrsqlFactory.addParameter("hrid", hrid);
  101. Rows hrrows = dbConnect.runSqlQuery(hrsqlFactory.getSQL());
  102. return getSucReturnObject().setData(hrrows).toString();
  103. }
  104. @API(title = "人员目标统计(区域经理)", apiversion = R.ID20231018103203.v1.class)
  105. @CACHEING
  106. public String queryList_areamanager() throws YosException {
  107. //年份
  108. Calendar cal = Calendar.getInstance();
  109. int year = cal.get(Calendar.YEAR);
  110. long sa_saleareaid=content.getLongValue("sa_saleareaid");
  111. Rows billRows = dbConnect.runSqlQuery("SELECT sa_salestargetbillid,assessmentindicators,statisticaldimension,sa_accountclassids FROM sa_salestargetbill WHERE year="+year+" AND siteid ='" + siteid + "' and targettype = '人员目标'");
  112. SQLFactory hrsqlFactory = new SQLFactory(this, "业务员列表查询");
  113. hrsqlFactory.addParameter("siteid", siteid);
  114. hrsqlFactory.addParameter("hrid", hrid);
  115. Rows hrrows = dbConnect.runSqlQuery(hrsqlFactory.getSQL());
  116. if(sa_saleareaid==0){
  117. if(hrrows.isNotEmpty()){
  118. sa_saleareaid=hrrows.get(0).getLong("sa_saleareaid");
  119. }
  120. }
  121. //考核指标类型
  122. long sa_salestargetbillid = 0;
  123. String assessmentindicators="";
  124. //统计维度
  125. String statisticaldimension="";
  126. //账户
  127. String sa_accountclassids="";
  128. if (billRows.isNotEmpty()) {
  129. sa_salestargetbillid=billRows.get(0).getLong("sa_salestargetbillid");
  130. assessmentindicators=billRows.get(0).getString("assessmentindicators");
  131. statisticaldimension=billRows.get(0).getString("statisticaldimension");
  132. sa_accountclassids=billRows.get(0).getString("sa_accountclassids");
  133. }
  134. /*
  135. 过滤条件设置
  136. */
  137. StringBuffer where = new StringBuffer(" 1=1 ");
  138. SQLFactory sqlFactory = new SQLFactory(this, "人员-目标详情列表");
  139. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  140. sqlFactory.addParameter_SQL("where", where);
  141. sqlFactory.addParameter("siteid", siteid);
  142. String sql = sqlFactory.getSQL();
  143. Rows rows = dbConnect.runSqlQuery(sql);
  144. Rows saleareas = dbConnect.runSqlQuery("select * from sa_salearea where parentid=0");
  145. Long sa_saleareaidtop=0l;
  146. if(!saleareas.isEmpty() && saleareas.size()==1){
  147. sa_saleareaidtop=saleareas.get(0).getLong("sa_saleareaid");
  148. for (Row row :rows) {
  149. if(row.getLong("parentid")==0){
  150. row.put("y1l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("y1l"));
  151. row.put("y1h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("y1h"));
  152. row.put("s1l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s1l"));
  153. row.put("s1h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s1h"));
  154. row.put("s2l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s2l"));
  155. row.put("s2h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s2h"));
  156. row.put("s3l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s3l"));
  157. row.put("s3h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s3h"));
  158. row.put("s4l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s4l"));
  159. row.put("s4h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s4h"));
  160. row.put("m1l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m1l"));
  161. row.put("m1h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m1h"));
  162. row.put("m2l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m2l"));
  163. row.put("m2h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m2h"));
  164. row.put("m3l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m3l"));
  165. row.put("m3h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m3h"));
  166. row.put("m4l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m4l"));
  167. row.put("m4h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m4h"));
  168. row.put("m5l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m5l"));
  169. row.put("m5h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m5h"));
  170. row.put("m6l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m6l"));
  171. row.put("m6h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m6h"));
  172. row.put("m7l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m7l"));
  173. row.put("m7h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m7h"));
  174. row.put("m8l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m8l"));
  175. row.put("m8h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m8h"));
  176. row.put("m9l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m9l"));
  177. row.put("m9h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m9h"));
  178. row.put("m10l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m10l"));
  179. row.put("m10h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m10h"));
  180. row.put("m11l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m11l"));
  181. row.put("m11h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m11h"));
  182. row.put("m12l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m12l"));
  183. row.put("m12h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m12h"));
  184. }
  185. }
  186. }
  187. Rows actualRows = new Rows();
  188. //开票
  189. if (assessmentindicators .equals("开票")) {
  190. String where1 =" 1=1 ";
  191. sqlFactory = new SQLFactory(this, "人员目标统计-开票");
  192. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  193. sqlFactory.addParameter_SQL("where", where);
  194. if(statisticaldimension.equals("订单审核")){
  195. where1=where1+" and t2.status='审核'";
  196. }else{
  197. where1=where1+" and t2.status='提交'";
  198. }
  199. if(StringUtils.isNotBlank(sa_accountclassids)){
  200. if(isJSONArray(sa_accountclassids)){
  201. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  202. if(!jsonArrayResult.isEmpty()){
  203. where1=where1+ " and t2.sa_accountclassid in"+jsonArrayResult;
  204. where1 = where1.replace("[", "(").replace("]", ")");
  205. }
  206. }
  207. }
  208. sqlFactory.addParameter_SQL("where1",where1);
  209. sqlFactory.addParameter("siteid", siteid);
  210. sqlFactory.addParameter("year", year);
  211. actualRows = dbConnect.runSqlQuery(sqlFactory);
  212. }
  213. //订单
  214. if (assessmentindicators .equals("订单")) {
  215. String where1 =" 1=1 ";
  216. sqlFactory = new SQLFactory(this, "人员目标统计-订单");
  217. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  218. sqlFactory.addParameter_SQL("where", where);
  219. if(statisticaldimension.equals("订单审核")){
  220. where1=where1+" and t2.status='审核'";
  221. }else{
  222. where1=where1+" and t2.status='提交'";
  223. }
  224. if(StringUtils.isNotBlank(sa_accountclassids)){
  225. if(isJSONArray(sa_accountclassids)){
  226. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  227. if(!jsonArrayResult.isEmpty()){
  228. where1=where1+ " and t2.sa_accountclassid in"+jsonArrayResult;
  229. where1 = where1.replace("[", "(").replace("]", ")");
  230. }
  231. }
  232. }
  233. sqlFactory.addParameter_SQL("where1",where1);
  234. sqlFactory.addParameter("siteid", siteid);
  235. sqlFactory.addParameter("year", year);
  236. actualRows = dbConnect.runSqlQuery(sqlFactory);
  237. }
  238. //出货
  239. if (assessmentindicators .equals("出货")) {
  240. String where1 =" 1=1 ";
  241. sqlFactory = new SQLFactory(this, "人员目标统计-出货");
  242. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  243. sqlFactory.addParameter_SQL("where", where);
  244. if(StringUtils.isNotBlank(sa_accountclassids)){
  245. if(isJSONArray(sa_accountclassids)){
  246. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  247. if(!jsonArrayResult.isEmpty()){
  248. where1=where1+ " and t2.sa_accountclassid in"+jsonArrayResult;
  249. where1 = where1.replace("[", "(").replace("]", ")");
  250. }
  251. }
  252. }
  253. sqlFactory.addParameter_SQL("where1",where1);
  254. sqlFactory.addParameter("siteid", siteid);
  255. sqlFactory.addParameter("year", year);
  256. actualRows = dbConnect.runSqlQuery(sqlFactory);
  257. }
  258. //收款
  259. if (assessmentindicators .equals("收款")) {
  260. String where1 =" 1=1 ";
  261. sqlFactory = new SQLFactory(this, "人员目标统计-收款");
  262. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  263. sqlFactory.addParameter_SQL("where", where);
  264. if(StringUtils.isNotBlank(statisticaldimension)){
  265. if(isJSONObject(statisticaldimension)){
  266. JSONObject jsonObjectResult = JSONObject.parseObject(statisticaldimension);
  267. if(!jsonObjectResult.isEmpty()){
  268. where1= where1+ " and (t1.class in"+ jsonObjectResult.get("type")+" or t1.subclass in"+ jsonObjectResult.get("mx")+")";
  269. where1 = where1.replace("[", "(").replace("]", ")");
  270. }
  271. }
  272. }
  273. if(StringUtils.isNotBlank(sa_accountclassids)){
  274. if(isJSONArray(sa_accountclassids)){
  275. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  276. if(!jsonArrayResult.isEmpty()){
  277. where1=where1+ " and t1.sa_accountclassid in"+jsonArrayResult;
  278. where1 = where1.replace("[", "(").replace("]", ")");
  279. }
  280. }
  281. }
  282. sqlFactory.addParameter_SQL("where1",where1);
  283. sqlFactory.addParameter("siteid", siteid);
  284. sqlFactory.addParameter("year", year);
  285. actualRows = dbConnect.runSqlQuery(sqlFactory);
  286. }
  287. if(!saleareas.isEmpty() && saleareas.size()==1){
  288. for (Row row :actualRows) {
  289. if(row.getLong("parentid")==0){
  290. row.put("y1a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("y1a"));
  291. row.put("s1a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s1a"));
  292. row.put("s2a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s2a"));
  293. row.put("s3a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s3a"));
  294. row.put("s4a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s4a"));
  295. row.put("m1a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m1a"));
  296. row.put("m2a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m2a"));
  297. row.put("m3a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m3a"));
  298. row.put("m4a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m4a"));
  299. row.put("m5a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m5a"));
  300. row.put("m6a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m6a"));
  301. row.put("m7a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m7a"));
  302. row.put("m8a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m8a"));
  303. row.put("m9a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m9a"));
  304. row.put("m10a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m10a"));
  305. row.put("m11a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m11a"));
  306. row.put("m12a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m12a"));
  307. }
  308. }
  309. }
  310. Rows rowsResult =new Rows();
  311. for (Row row : rows) {
  312. if(row.getLong("sa_saleareaid")==sa_saleareaid){
  313. rowsResult.add(row);
  314. }
  315. }
  316. for (Row row : rowsResult) {
  317. //初始化
  318. row = addActualRow(row);
  319. Long sa_saleareaid1 = row.getLong("sa_saleareaid");
  320. Row actualRow = new Row();
  321. for (Row tempActualRow : actualRows) {
  322. if (tempActualRow.getLong("sa_saleareaid") == sa_saleareaid1) {
  323. actualRow.putAll(tempActualRow);
  324. }
  325. }
  326. row.putAll(actualRow);
  327. row.putAll(calculate(row, actualRow));
  328. }
  329. return getSucReturnObject().setData(rowsResult).toString();
  330. }
  331. @API(title = "人员目标统计列表(区域经理)", apiversion = R.ID20231018103303.v1.class)
  332. @CACHEING
  333. public String queryList_areamanagerList() throws YosException {
  334. //年份
  335. Calendar cal = Calendar.getInstance();
  336. int year = cal.get(Calendar.YEAR);
  337. Rows billRows = dbConnect.runSqlQuery("SELECT sa_salestargetbillid,assessmentindicators,statisticaldimension,sa_accountclassids FROM sa_salestargetbill WHERE year="+year+" AND siteid ='" + siteid + "' and targettype = '人员目标'");
  338. SQLFactory hrsqlFactory = new SQLFactory(this, "业务员列表查询");
  339. hrsqlFactory.addParameter("siteid", siteid);
  340. hrsqlFactory.addParameter("hrid", hrid);
  341. Rows hrrows = dbConnect.runSqlQuery(hrsqlFactory.getSQL());
  342. SQLFactory areasqlFactory = new SQLFactory(this, "下级区域获取");
  343. areasqlFactory.addParameter("siteid", siteid);
  344. areasqlFactory.addParameter_in("sa_saleareaid", hrrows.toArrayList("sa_saleareaid",new ArrayList<>()));
  345. Rows arearows = dbConnect.runSqlQuery(areasqlFactory.getSQL());
  346. ArrayList<Long> areaList = arearows.toArrayList("sa_saleareaid",new ArrayList<Long>());
  347. areaList.add(0l);
  348. //考核指标类型
  349. long sa_salestargetbillid = 0;
  350. String assessmentindicators="";
  351. //统计维度
  352. String statisticaldimension="";
  353. //账户
  354. String sa_accountclassids="";
  355. if (billRows.isNotEmpty()) {
  356. sa_salestargetbillid=billRows.get(0).getLong("sa_salestargetbillid");
  357. assessmentindicators=billRows.get(0).getString("assessmentindicators");
  358. statisticaldimension=billRows.get(0).getString("statisticaldimension");
  359. sa_accountclassids=billRows.get(0).getString("sa_accountclassids");
  360. }
  361. /*
  362. 过滤条件设置
  363. */
  364. StringBuffer where = new StringBuffer(" 1=1 and t.sa_saleareaid in "+areaList.toString().replace("[", "(").replace("]", ")"));
  365. SQLFactory sqlFactory = new SQLFactory(this, "人员-目标详情列表");
  366. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  367. sqlFactory.addParameter_SQL("where", where);
  368. sqlFactory.addParameter("siteid", siteid);
  369. String sql = sqlFactory.getSQL();
  370. Rows rows = dbConnect.runSqlQuery(sql);
  371. Rows saleareas = dbConnect.runSqlQuery("select * from sa_salearea where parentid=0");
  372. Long sa_saleareaidtop=0l;
  373. if(!saleareas.isEmpty() && saleareas.size()==1){
  374. sa_saleareaidtop=saleareas.get(0).getLong("sa_saleareaid");
  375. for (Row row :rows) {
  376. if(row.getLong("parentid")==0){
  377. row.put("y1l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("y1l"));
  378. row.put("y1h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("y1h"));
  379. row.put("s1l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s1l"));
  380. row.put("s1h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s1h"));
  381. row.put("s2l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s2l"));
  382. row.put("s2h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s2h"));
  383. row.put("s3l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s3l"));
  384. row.put("s3h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s3h"));
  385. row.put("s4l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s4l"));
  386. row.put("s4h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s4h"));
  387. row.put("m1l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m1l"));
  388. row.put("m1h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m1h"));
  389. row.put("m2l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m2l"));
  390. row.put("m2h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m2h"));
  391. row.put("m3l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m3l"));
  392. row.put("m3h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m3h"));
  393. row.put("m4l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m4l"));
  394. row.put("m4h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m4h"));
  395. row.put("m5l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m5l"));
  396. row.put("m5h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m5h"));
  397. row.put("m6l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m6l"));
  398. row.put("m6h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m6h"));
  399. row.put("m7l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m7l"));
  400. row.put("m7h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m7h"));
  401. row.put("m8l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m8l"));
  402. row.put("m8h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m8h"));
  403. row.put("m9l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m9l"));
  404. row.put("m9h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m9h"));
  405. row.put("m10l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m10l"));
  406. row.put("m10h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m10h"));
  407. row.put("m11l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m11l"));
  408. row.put("m11h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m11h"));
  409. row.put("m12l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m12l"));
  410. row.put("m12h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m12h"));
  411. }
  412. }
  413. }
  414. Rows actualRows = new Rows();
  415. //开票
  416. if (assessmentindicators .equals("开票")) {
  417. String where1 =" 1=1 ";
  418. sqlFactory = new SQLFactory(this, "人员目标统计-开票");
  419. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  420. sqlFactory.addParameter_SQL("where", where);
  421. if(statisticaldimension.equals("订单审核")){
  422. where1=where1+" and t2.status='审核'";
  423. }else{
  424. where1=where1+" and t2.status='提交'";
  425. }
  426. if(StringUtils.isNotBlank(sa_accountclassids)){
  427. if(isJSONArray(sa_accountclassids)){
  428. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  429. if(!jsonArrayResult.isEmpty()){
  430. where1=where1+ " and t2.sa_accountclassid in"+jsonArrayResult;
  431. where1 = where1.replace("[", "(").replace("]", ")");
  432. }
  433. }
  434. }
  435. sqlFactory.addParameter_SQL("where1",where1);
  436. sqlFactory.addParameter("siteid", siteid);
  437. sqlFactory.addParameter("year", year);
  438. actualRows = dbConnect.runSqlQuery(sqlFactory);
  439. }
  440. //订单
  441. if (assessmentindicators .equals("订单")) {
  442. String where1 =" 1=1 ";
  443. sqlFactory = new SQLFactory(this, "人员目标统计-订单");
  444. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  445. sqlFactory.addParameter_SQL("where", where);
  446. if(statisticaldimension.equals("订单审核")){
  447. where1=where1+" and t2.status='审核'";
  448. }else{
  449. where1=where1+" and t2.status='提交'";
  450. }
  451. if(StringUtils.isNotBlank(sa_accountclassids)){
  452. if(isJSONArray(sa_accountclassids)){
  453. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  454. if(!jsonArrayResult.isEmpty()){
  455. where1=where1+ " and t2.sa_accountclassid in"+jsonArrayResult;
  456. where1 = where1.replace("[", "(").replace("]", ")");
  457. }
  458. }
  459. }
  460. sqlFactory.addParameter_SQL("where1",where1);
  461. sqlFactory.addParameter("siteid", siteid);
  462. sqlFactory.addParameter("year", year);
  463. actualRows = dbConnect.runSqlQuery(sqlFactory);
  464. }
  465. //出货
  466. if (assessmentindicators .equals("出货")) {
  467. String where1 =" 1=1 ";
  468. sqlFactory = new SQLFactory(this, "人员目标统计-出货");
  469. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  470. sqlFactory.addParameter_SQL("where", where);
  471. if(StringUtils.isNotBlank(sa_accountclassids)){
  472. if(isJSONArray(sa_accountclassids)){
  473. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  474. if(!jsonArrayResult.isEmpty()){
  475. where1=where1+ " and t2.sa_accountclassid in"+jsonArrayResult;
  476. where1 = where1.replace("[", "(").replace("]", ")");
  477. }
  478. }
  479. }
  480. sqlFactory.addParameter_SQL("where1",where1);
  481. sqlFactory.addParameter("siteid", siteid);
  482. sqlFactory.addParameter("year", year);
  483. actualRows = dbConnect.runSqlQuery(sqlFactory);
  484. }
  485. //收款
  486. if (assessmentindicators .equals("收款")) {
  487. String where1 =" 1=1 ";
  488. sqlFactory = new SQLFactory(this, "人员目标统计-收款");
  489. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  490. sqlFactory.addParameter_SQL("where", where);
  491. if(StringUtils.isNotBlank(statisticaldimension)){
  492. if(isJSONObject(statisticaldimension)){
  493. JSONObject jsonObjectResult = JSONObject.parseObject(statisticaldimension);
  494. if(!jsonObjectResult.isEmpty()){
  495. where1= where1+ " and (t1.class in"+ jsonObjectResult.get("type")+" or t1.subclass in"+ jsonObjectResult.get("mx")+")";
  496. where1 = where1.replace("[", "(").replace("]", ")");
  497. }
  498. }
  499. }
  500. if(StringUtils.isNotBlank(sa_accountclassids)){
  501. if(isJSONArray(sa_accountclassids)){
  502. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  503. if(!jsonArrayResult.isEmpty()){
  504. where1=where1+ " and t1.sa_accountclassid in"+jsonArrayResult;
  505. where1 = where1.replace("[", "(").replace("]", ")");
  506. }
  507. }
  508. }
  509. sqlFactory.addParameter_SQL("where1",where1);
  510. sqlFactory.addParameter("siteid", siteid);
  511. sqlFactory.addParameter("year", year);
  512. actualRows = dbConnect.runSqlQuery(sqlFactory);
  513. }
  514. if(!saleareas.isEmpty() && saleareas.size()==1){
  515. for (Row row :actualRows) {
  516. if(row.getLong("parentid")==0){
  517. row.put("y1a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("y1a"));
  518. row.put("s1a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s1a"));
  519. row.put("s2a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s2a"));
  520. row.put("s3a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s3a"));
  521. row.put("s4a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s4a"));
  522. row.put("m1a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m1a"));
  523. row.put("m2a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m2a"));
  524. row.put("m3a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m3a"));
  525. row.put("m4a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m4a"));
  526. row.put("m5a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m5a"));
  527. row.put("m6a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m6a"));
  528. row.put("m7a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m7a"));
  529. row.put("m8a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m8a"));
  530. row.put("m9a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m9a"));
  531. row.put("m10a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m10a"));
  532. row.put("m11a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m11a"));
  533. row.put("m12a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m12a"));
  534. }
  535. }
  536. }
  537. for (Row row : rows) {
  538. //初始化
  539. row = addActualRow(row);
  540. Long sa_saleareaid1 = row.getLong("sa_saleareaid");
  541. Row actualRow = new Row();
  542. for (Row tempActualRow : actualRows) {
  543. if (tempActualRow.getLong("sa_saleareaid") == sa_saleareaid1) {
  544. actualRow.putAll(tempActualRow);
  545. }
  546. }
  547. row.putAll(actualRow);
  548. row.putAll(calculate(row, actualRow));
  549. }
  550. return getSucReturnObject().setData(rows).toString();
  551. }
  552. @API(title = "人员目标统计", apiversion = R.ID20220904134102.v1.class)
  553. @CACHEING
  554. public String queryList() throws YosException {
  555. //年份
  556. Long sa_salestargetbillid = content.getLong("sa_salestargetbillid");
  557. Rows billRows = dbConnect.runSqlQuery("SELECT assessmentindicators,year,statisticaldimension,sa_accountclassids FROM sa_salestargetbill WHERE sa_salestargetbillid=" + sa_salestargetbillid + " AND siteid ='" + siteid + "'");
  558. //考核指标类型
  559. String assessmentindicators = "";
  560. //统计维度
  561. String statisticaldimension="";
  562. //账户
  563. String sa_accountclassids="";
  564. long year = 2023;
  565. if (billRows.isNotEmpty()) {
  566. assessmentindicators=billRows.get(0).getString("assessmentindicators");
  567. statisticaldimension=billRows.get(0).getString("statisticaldimension");
  568. sa_accountclassids=billRows.get(0).getString("sa_accountclassids");
  569. year=billRows.get(0).getLong("year");
  570. }
  571. /*
  572. 过滤条件设置
  573. */
  574. StringBuffer where = new StringBuffer(" 1=1 ");
  575. if (content.containsKey("where")) {
  576. JSONObject whereObject = content.getJSONObject("where");
  577. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  578. where.append(" and(");
  579. where.append("t.name like'%").append(whereObject.getString("condition")).append("%' ");
  580. where.append("or t.depfullname like'%").append(whereObject.getString("condition")).append("%' ");
  581. where.append("or t.depname like'%").append(whereObject.getString("condition")).append("%' ");
  582. where.append("or t.position like'%").append(whereObject.getString("condition")).append("%' ");
  583. where.append(")");
  584. }
  585. }
  586. SQLFactory sqlFactory = new SQLFactory(this, "人员-目标详情列表");
  587. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  588. sqlFactory.addParameter_SQL("where", where);
  589. sqlFactory.addParameter("siteid", siteid);
  590. String sql = sqlFactory.getSQL();
  591. Rows rows = dbConnect.runSqlQuery(sql);
  592. Rows saleareas = dbConnect.runSqlQuery("select * from sa_salearea where parentid=0");
  593. Long sa_saleareaidtop=0l;
  594. if(!saleareas.isEmpty() && saleareas.size()==1){
  595. sa_saleareaidtop=saleareas.get(0).getLong("sa_saleareaid");
  596. for (Row row :rows) {
  597. if(row.getLong("parentid")==0){
  598. row.put("y1l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("y1l"));
  599. row.put("y1h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("y1h"));
  600. row.put("s1l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s1l"));
  601. row.put("s1h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s1h"));
  602. row.put("s2l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s2l"));
  603. row.put("s2h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s2h"));
  604. row.put("s3l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s3l"));
  605. row.put("s3h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s3h"));
  606. row.put("s4l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s4l"));
  607. row.put("s4h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s4h"));
  608. row.put("m1l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m1l"));
  609. row.put("m1h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m1h"));
  610. row.put("m2l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m2l"));
  611. row.put("m2h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m2h"));
  612. row.put("m3l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m3l"));
  613. row.put("m3h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m3h"));
  614. row.put("m4l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m4l"));
  615. row.put("m4h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m4h"));
  616. row.put("m5l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m5l"));
  617. row.put("m5h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m5h"));
  618. row.put("m6l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m6l"));
  619. row.put("m6h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m6h"));
  620. row.put("m7l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m7l"));
  621. row.put("m7h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m7h"));
  622. row.put("m8l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m8l"));
  623. row.put("m8h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m8h"));
  624. row.put("m9l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m9l"));
  625. row.put("m9h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m9h"));
  626. row.put("m10l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m10l"));
  627. row.put("m10h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m10h"));
  628. row.put("m11l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m11l"));
  629. row.put("m11h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m11h"));
  630. row.put("m12l",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m12l"));
  631. row.put("m12h",rows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m12h"));
  632. }
  633. }
  634. }
  635. Rows actualRows = new Rows();
  636. //开票
  637. if (assessmentindicators .equals("开票")) {
  638. String where1 =" 1=1 ";
  639. sqlFactory = new SQLFactory(this, "人员目标统计-开票");
  640. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  641. sqlFactory.addParameter_SQL("where", where);
  642. if(statisticaldimension.equals("订单审核")){
  643. where1=where1+" and t2.status='审核'";
  644. }else{
  645. where1=where1+" and t2.status='提交'";
  646. }
  647. if(StringUtils.isNotBlank(sa_accountclassids)){
  648. if(isJSONArray(sa_accountclassids)){
  649. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  650. if(!jsonArrayResult.isEmpty()){
  651. where1=where1+ " and t2.sa_accountclassid in"+jsonArrayResult;
  652. where1 = where1.replace("[", "(").replace("]", ")");
  653. }
  654. }
  655. }
  656. sqlFactory.addParameter_SQL("where1",where1);
  657. sqlFactory.addParameter("siteid", siteid);
  658. sqlFactory.addParameter("year", year);
  659. actualRows = dbConnect.runSqlQuery(sqlFactory);
  660. }
  661. //订单
  662. if (assessmentindicators .equals("订单")) {
  663. String where1 =" 1=1 ";
  664. sqlFactory = new SQLFactory(this, "人员目标统计-订单");
  665. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  666. sqlFactory.addParameter_SQL("where", where);
  667. if(statisticaldimension.equals("订单审核")){
  668. where1=where1+" and t2.status='审核'";
  669. }else{
  670. where1=where1+" and t2.status='提交'";
  671. }
  672. if(StringUtils.isNotBlank(sa_accountclassids)){
  673. if(isJSONArray(sa_accountclassids)){
  674. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  675. if(!jsonArrayResult.isEmpty()){
  676. where1=where1+ " and t2.sa_accountclassid in"+jsonArrayResult;
  677. where1 = where1.replace("[", "(").replace("]", ")");
  678. }
  679. }
  680. }
  681. sqlFactory.addParameter_SQL("where1",where1);
  682. sqlFactory.addParameter("siteid", siteid);
  683. sqlFactory.addParameter("year", year);
  684. actualRows = dbConnect.runSqlQuery(sqlFactory);
  685. }
  686. //出货
  687. if (assessmentindicators .equals("出货")) {
  688. String where1 =" 1=1 ";
  689. sqlFactory = new SQLFactory(this, "人员目标统计-出货");
  690. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  691. sqlFactory.addParameter_SQL("where", where);
  692. if(StringUtils.isNotBlank(sa_accountclassids)){
  693. if(isJSONArray(sa_accountclassids)){
  694. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  695. if(!jsonArrayResult.isEmpty()){
  696. where1=where1+ " and t2.sa_accountclassid in"+jsonArrayResult;
  697. where1 = where1.replace("[", "(").replace("]", ")");
  698. }
  699. }
  700. }
  701. sqlFactory.addParameter_SQL("where1",where1);
  702. sqlFactory.addParameter("siteid", siteid);
  703. sqlFactory.addParameter("year", year);
  704. actualRows = dbConnect.runSqlQuery(sqlFactory);
  705. }
  706. //收款
  707. if (assessmentindicators .equals("收款")) {
  708. String where1 =" 1=1 ";
  709. sqlFactory = new SQLFactory(this, "人员目标统计-收款");
  710. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  711. sqlFactory.addParameter_SQL("where", where);
  712. if(StringUtils.isNotBlank(statisticaldimension)){
  713. if(isJSONObject(statisticaldimension)){
  714. JSONObject jsonObjectResult = JSONObject.parseObject(statisticaldimension);
  715. if(!jsonObjectResult.isEmpty()){
  716. where1= where1+ " and (t1.class in"+ jsonObjectResult.get("type")+" or t1.subclass in"+ jsonObjectResult.get("mx")+")";
  717. where1 = where1.replace("[", "(").replace("]", ")");
  718. }
  719. }
  720. }
  721. if(StringUtils.isNotBlank(sa_accountclassids)){
  722. if(isJSONArray(sa_accountclassids)){
  723. JSONArray jsonArrayResult = JSONArray.parseArray(sa_accountclassids);
  724. if(!jsonArrayResult.isEmpty()){
  725. where1=where1+ " and t1.sa_accountclassid in"+jsonArrayResult;
  726. where1 = where1.replace("[", "(").replace("]", ")");
  727. }
  728. }
  729. }
  730. sqlFactory.addParameter_SQL("where1",where1);
  731. sqlFactory.addParameter("siteid", siteid);
  732. sqlFactory.addParameter("year", year);
  733. actualRows = dbConnect.runSqlQuery(sqlFactory);
  734. }
  735. if(!saleareas.isEmpty() && saleareas.size()==1){
  736. for (Row row :actualRows) {
  737. if(row.getLong("parentid")==0){
  738. row.put("y1a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("y1a"));
  739. row.put("s1a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s1a"));
  740. row.put("s2a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s2a"));
  741. row.put("s3a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s3a"));
  742. row.put("s4a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("s4a"));
  743. row.put("m1a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m1a"));
  744. row.put("m2a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m2a"));
  745. row.put("m3a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m3a"));
  746. row.put("m4a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m4a"));
  747. row.put("m5a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m5a"));
  748. row.put("m6a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m6a"));
  749. row.put("m7a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m7a"));
  750. row.put("m8a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m8a"));
  751. row.put("m9a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m9a"));
  752. row.put("m10a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m10a"));
  753. row.put("m11a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m11a"));
  754. row.put("m12a",actualRows.toRowsMap("parentid").get(sa_saleareaidtop.toString()).sum("m12a"));
  755. }
  756. }
  757. }
  758. for (Row row : rows) {
  759. //初始化
  760. row = addActualRow(row);
  761. Long sa_saleareaid = row.getLong("sa_saleareaid");
  762. Row actualRow = new Row();
  763. for (Row tempActualRow : actualRows) {
  764. if (tempActualRow.getLong("sa_saleareaid") == sa_saleareaid) {
  765. actualRow.putAll(tempActualRow);
  766. }
  767. }
  768. row.putAll(actualRow);
  769. row.putAll(calculate(row, actualRow));
  770. }
  771. return getSucReturnObject().setData(rows).toString();
  772. }
  773. //添加实际数据
  774. public Row addActualRow(Row targetRow) {
  775. String key = "y1a";
  776. targetRow.put(key, 0);
  777. for (int i = 1; i < 5; i++) {
  778. key = "s" + i + "a";
  779. targetRow.put(key, 0);
  780. }
  781. for (int i = 1; i < 13; i++) {
  782. key = "m" + i + "a";
  783. targetRow.put(key, 0);
  784. }
  785. return targetRow;
  786. }
  787. public Row calculate(Row targetRow, Row actualRow) {
  788. Row row = new Row();
  789. String key_l = "y1l";
  790. String key_h = "y1h";
  791. String key_a = "y1a";
  792. String key_p_l = "y1pl";
  793. String key_p_h = "y1ph";
  794. if (targetRow.getDouble(key_l) == 0) {
  795. row.put(key_p_l, 0);
  796. } else {
  797. row.put(key_p_l, getPercent(actualRow.getDouble(key_a), targetRow.getDouble(key_l)));
  798. }
  799. if (targetRow.getDouble(key_h) == 0) {
  800. row.put(key_p_h, 0);
  801. } else {
  802. row.put(key_p_h, getPercent(actualRow.getDouble(key_a), targetRow.getDouble(key_h)));
  803. }
  804. for (int i = 1; i < 5; i++) {
  805. key_l = "s" + i + "l";
  806. key_h = "s" + i + "h";
  807. key_a = "s" + i + "a";
  808. key_p_l = "s" + i + "pl";
  809. key_p_h = "s" + i + "ph";
  810. if (targetRow.getDouble(key_l) == 0) {
  811. row.put(key_p_l, 0);
  812. } else {
  813. row.put(key_p_l, getPercent(actualRow.getDouble(key_a), targetRow.getDouble(key_l)));
  814. }
  815. if (targetRow.getDouble(key_h) == 0) {
  816. row.put(key_p_h, 0);
  817. } else {
  818. row.put(key_p_h, getPercent(actualRow.getDouble(key_a), targetRow.getDouble(key_h)));
  819. }
  820. }
  821. for (int i = 1; i < 13; i++) {
  822. key_l = "m" + i + "l";
  823. key_h = "m" + i + "h";
  824. key_a = "m" + i + "a";
  825. key_p_l = "m" + i + "pl";
  826. key_p_h = "m" + i + "ph";
  827. if (targetRow.getDouble(key_l) == 0) {
  828. row.put(key_p_l, 0);
  829. } else {
  830. row.put(key_p_l, getPercent(actualRow.getDouble(key_a), targetRow.getDouble(key_l)));
  831. }
  832. if (targetRow.getDouble(key_h) == 0) {
  833. row.put(key_p_h, 0);
  834. } else {
  835. row.put(key_p_h, getPercent(actualRow.getDouble(key_a), targetRow.getDouble(key_h)));
  836. }
  837. }
  838. return row;
  839. }
  840. public double getPercent(Double a, Double b) {
  841. double c = a * 100 / b;
  842. BigDecimal bigDecimal = new BigDecimal(c);
  843. return bigDecimal.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  844. }
  845. }