HomePageMSDataController.java 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782
  1. package com.trs.ggzyexchange.datacentercontroller;
  2. import com.alibaba.fastjson.JSONObject;
  3. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  4. import com.baomidou.mybatisplus.core.metadata.IPage;
  5. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  6. import com.trs.ggzyexchange.api.vo.Result;
  7. import com.trs.ggzyexchange.entity.*;
  8. import com.trs.ggzyexchange.entity.pagedata.*;
  9. import com.trs.ggzyexchange.enums.CommonConstant;
  10. import com.trs.ggzyexchange.service.*;
  11. import com.trs.ggzyexchange.utils.DatesUtil;
  12. import com.trs.ggzyexchange.utils.RedisUtil;
  13. import lombok.extern.slf4j.Slf4j;
  14. import org.apache.commons.lang3.ObjectUtils;
  15. import org.apache.commons.lang3.time.DateFormatUtils;
  16. import org.springframework.beans.factory.annotation.Autowired;
  17. import org.springframework.web.bind.annotation.GetMapping;
  18. import org.springframework.web.bind.annotation.RequestMapping;
  19. import org.springframework.web.bind.annotation.RequestParam;
  20. import org.springframework.web.bind.annotation.RestController;
  21. import java.util.ArrayList;
  22. import java.util.Date;
  23. import java.util.List;
  24. @Slf4j
  25. @RestController
  26. @RequestMapping("/home-page-ms-data-controller")
  27. public class HomePageMSDataController {
  28. @Autowired
  29. private GcProjectService gcProjectService;
  30. @Autowired
  31. private QtjyNoticeService qtjyNoticeService;
  32. @Autowired
  33. private ZrzyTdCedeNoticeService zrzyTdCedeNoticeService;
  34. @Autowired
  35. private ZcProjectService zcProjectService;
  36. @Autowired
  37. private CqGqIssueBulletinService cqGqIssueBulletinService;
  38. @Autowired
  39. private CqSwIssueBulletinService cqSwIssueBulletinService;
  40. @Autowired
  41. private YcNoticeService ycNoticeService;
  42. @Autowired
  43. private BulletinService bulletinService;
  44. @Autowired
  45. private ZtLegalinfoService ztLegalinfoService;
  46. @Autowired
  47. private GcBidpublicityService gcBidpublicityService;
  48. @Autowired
  49. private ZrzyTdBidwinnoticeService zrzyTdBidwinnoticeService;
  50. @Autowired
  51. private CqSwBargainResultService cqSwBargainResultService;
  52. @Autowired
  53. private OtherTradePubInfoService otherTradePubInfoService;
  54. @Autowired
  55. private OtherTradeResultInfoService otherTradeResultInfoService;
  56. @Autowired
  57. private JgFieldApplyService jgFieldApplyService;
  58. @Autowired
  59. private RedisUtil redisUtil;
  60. @Autowired
  61. private ZcBidpublicityService zcBidpublicityService;
  62. @Autowired
  63. private ZrzyTdCedeResultService zrzyTdCedeResultService;
  64. @Autowired
  65. private GcPackageService gcPackageService;
  66. @Autowired
  67. private ZrzyTdCedeInfoService zrzyTdCedeInfoService;
  68. @Autowired
  69. private ZrzyTkqProjectInfoService zrzyTkqProjectInfoService;
  70. @Autowired
  71. private ZrzyCkqProjectInfoService zrzyCkqProjectInfoService;
  72. @Autowired
  73. private ZrzyDkProjectService zrzyDkProjectService;
  74. @Autowired
  75. private ZrzyBgStockIndexService zrzyBgStockIndexService;
  76. @Autowired
  77. private ZrzyJyzbStockIndexService zrzyJyzbStockIndexService;
  78. @Autowired
  79. private ZrzyTkqBidwinnoticeService zrzyTkqBidwinnoticeService;
  80. @Autowired
  81. private ZrzyCkqBidwinnoticeService zrzyCkqBidwinnoticeService;
  82. @Autowired
  83. private ZrzyDkBinwinNoticeService zrzyDkBinwinNoticeService;
  84. @Autowired
  85. private ZrzyBgBidwinNoticeService zrzyBgBidwinNoticeService;
  86. @Autowired
  87. private ZrzyJyzbBidwinNoticeService zrzyJyzbBidwinNoticeService;
  88. @Autowired
  89. private CqGqBargainResultService cqGqBargainResultService;
  90. @Autowired
  91. private CqGqProjectService cqGqProjectService;
  92. @Autowired
  93. private CqSwProjectService cqSwProjectService;
  94. @Autowired
  95. private AreaPlatformService areaPlatformService;
  96. @Autowired
  97. private SourceCodeNameService venueCodeNameService;
  98. /*
  99. * 内蒙古自治区首页数据中心
  100. * */
  101. @GetMapping(value = "/listTotal")
  102. public Result<HomePageDataCenter> queryPageListTotal(
  103. @RequestParam(name="platformCode", defaultValue="121500004600236091") String platformCode
  104. ) {
  105. HomePageDataCenter homePageDataCenter = new HomePageDataCenter();
  106. Object homePageDataCenterDataObj = redisUtil.get(platformCode+CommonConstant.MS_HOME_PAGE_DATA);
  107. if(!ObjectUtils.isEmpty(homePageDataCenterDataObj)){
  108. homePageDataCenter = JSONObject.parseObject(homePageDataCenterDataObj.toString(),HomePageDataCenter.class);
  109. return Result.OK(homePageDataCenter);
  110. }
  111. AreaPlatform areaPlatform = null;
  112. //获取区域编码对应的国标编码
  113. try {
  114. QueryWrapper<AreaPlatform> platformQueryWrapper = new QueryWrapper<AreaPlatform>();
  115. platformQueryWrapper.eq("PLATFORM_CODE",platformCode);
  116. areaPlatform = areaPlatformService.getOne(platformQueryWrapper);
  117. if(ObjectUtils.isEmpty(areaPlatform)){
  118. return Result.error("传入参数错误");
  119. }
  120. }catch (Exception e){
  121. e.printStackTrace();
  122. return Result.error("传入参数错误");
  123. }
  124. String sourceCode = null;
  125. String areaCode = areaPlatform.getAreaCode();
  126. try {
  127. QueryWrapper<SourceCodeName> sourceCodeNameQueryWrapper = new QueryWrapper<SourceCodeName>();
  128. sourceCodeNameQueryWrapper.eq("area_code",areaCode);
  129. Page<SourceCodeName> page = new Page<SourceCodeName>(1, 1);
  130. IPage<SourceCodeName> tenderDetailsVoIPage = venueCodeNameService.page(page,sourceCodeNameQueryWrapper);
  131. List<SourceCodeName> records = tenderDetailsVoIPage.getRecords();
  132. if(!ObjectUtils.isEmpty(records)){
  133. SourceCodeName sourceCodeName = records.get(0);
  134. sourceCode = sourceCodeName.getSourceCode();
  135. }
  136. }catch (Exception e){
  137. e.printStackTrace();
  138. }
  139. String regionCode = "";
  140. try {
  141. regionCode = areaCode.substring(0,4);
  142. }catch (Exception e){
  143. e.printStackTrace();
  144. }
  145. if(ObjectUtils.isEmpty(regionCode) || regionCode == ""){
  146. regionCode = "111111111111111111111";
  147. }
  148. /*入场数据总量*/
  149. /*入场数据总量*/
  150. /*入场数据总量*/
  151. /*入场数据总量*/
  152. TotalEntryData totalEntryData = new TotalEntryData();
  153. /*
  154. * 工程建设
  155. * */
  156. int totalzzq = 0;
  157. int total = 0;
  158. int totalGCJS = 0;
  159. int totalZFCG = 0;
  160. int totalZRZY = 0;
  161. int totalGYCQ = 0;
  162. int totalQTJY = 0;
  163. int totalYC = 0;
  164. try {
  165. QueryWrapper<GcPackage> gcProjectQueryWrapper = new QueryWrapper<GcPackage>();
  166. gcProjectQueryWrapper.eq("PLATFORM_CODE",platformCode);
  167. int countGcProject = gcPackageService.count(gcProjectQueryWrapper);
  168. totalGCJS = totalGCJS + countGcProject;
  169. total = total + countGcProject;
  170. }catch (Exception e){
  171. e.printStackTrace();
  172. }
  173. /*政府采购*/
  174. try {
  175. QueryWrapper<ZcProject> zcPurchaseBulletinQueryWrapper = new QueryWrapper<ZcProject>();
  176. zcPurchaseBulletinQueryWrapper.eq("PLATFORM_CODE",platformCode);
  177. int countZcPurchaseBulletin = zcProjectService.count(zcPurchaseBulletinQueryWrapper);
  178. totalZFCG = totalZFCG + countZcPurchaseBulletin;
  179. total = total + countZcPurchaseBulletin;
  180. }catch (Exception e){
  181. e.printStackTrace();
  182. }
  183. /*土地矿权*/
  184. /*ZRZY_TD_CEDE_INFO*/
  185. try {
  186. QueryWrapper<ZrzyTdCedeInfo> zrzyTdCedeInfoQueryWrapper = new QueryWrapper<ZrzyTdCedeInfo>();
  187. zrzyTdCedeInfoQueryWrapper.likeRight("region_code",regionCode);
  188. int countZrzyTdCedeNotice = zrzyTdCedeInfoService.count(zrzyTdCedeInfoQueryWrapper);
  189. totalZRZY = totalZRZY + countZrzyTdCedeNotice;
  190. total = total + countZrzyTdCedeNotice;
  191. }catch (Exception e){
  192. e.printStackTrace();
  193. }
  194. /*ZRZY_TKQ_PROJECT_INFO*/
  195. try {
  196. QueryWrapper<ZrzyTkqProjectInfo> zrzyTkqProjectInfoQueryWrapper = new QueryWrapper<ZrzyTkqProjectInfo>();
  197. zrzyTkqProjectInfoQueryWrapper.likeRight("region_code",regionCode);
  198. int countZrzyTdCedeNotice = zrzyTkqProjectInfoService.count(zrzyTkqProjectInfoQueryWrapper);
  199. totalZRZY = totalZRZY + countZrzyTdCedeNotice;
  200. total = total + countZrzyTdCedeNotice;
  201. }catch (Exception e){
  202. e.printStackTrace();
  203. }
  204. /*ZRZY_CKQ_PROJECT_INFO*/
  205. try {
  206. QueryWrapper<ZrzyCkqProjectInfo> zrzyTkqProjectInfoQueryWrapper = new QueryWrapper<ZrzyCkqProjectInfo>();
  207. zrzyTkqProjectInfoQueryWrapper.likeRight("region_code",regionCode);
  208. int countZrzyTdCedeNotice = zrzyCkqProjectInfoService.count(zrzyTkqProjectInfoQueryWrapper);
  209. totalZRZY = totalZRZY + countZrzyTdCedeNotice;
  210. total = total + countZrzyTdCedeNotice;
  211. }catch (Exception e){
  212. e.printStackTrace();
  213. }
  214. if(platformCode.equals("121500004600236091")){
  215. try {
  216. QueryWrapper<ZrzyDkProject> zrzyTkqProjectInfoQueryWrapper = new QueryWrapper<ZrzyDkProject>();
  217. int countZrzyTdCedeNotice = zrzyDkProjectService.count(zrzyTkqProjectInfoQueryWrapper);
  218. totalZRZY = totalZRZY + countZrzyTdCedeNotice;
  219. total = total + countZrzyTdCedeNotice;
  220. }catch (Exception e){
  221. e.printStackTrace();
  222. }
  223. }
  224. /*ZRZY_BG_STOCK_INDEX*/
  225. try {
  226. QueryWrapper<ZrzyBgStockIndex> zrzyTkqProjectInfoQueryWrapper = new QueryWrapper<ZrzyBgStockIndex>();
  227. zrzyTkqProjectInfoQueryWrapper.likeRight("zone",regionCode);
  228. int countZrzyTdCedeNotice = zrzyBgStockIndexService.count(zrzyTkqProjectInfoQueryWrapper);
  229. totalZRZY = totalZRZY + countZrzyTdCedeNotice;
  230. total = total + countZrzyTdCedeNotice;
  231. }catch (Exception e){
  232. e.printStackTrace();
  233. }
  234. /*ZRZY_JYZB_STOCK_INDEX*/
  235. try {
  236. QueryWrapper<ZrzyJyzbStockIndex> zrzyTkqProjectInfoQueryWrapper = new QueryWrapper<ZrzyJyzbStockIndex>();
  237. zrzyTkqProjectInfoQueryWrapper.likeRight("zone",regionCode);
  238. int countZrzyTdCedeNotice = zrzyJyzbStockIndexService.count(zrzyTkqProjectInfoQueryWrapper);
  239. totalZRZY = totalZRZY + countZrzyTdCedeNotice;
  240. total = total + countZrzyTdCedeNotice;
  241. }catch (Exception e){
  242. e.printStackTrace();
  243. }
  244. /*CQ_GQ_PROJECT*/
  245. try {
  246. QueryWrapper<CqGqProject> cqGqProjectQueryWrapper = new QueryWrapper<CqGqProject>();
  247. cqGqProjectQueryWrapper.likeRight("PROJECT_DISTRICT",regionCode);
  248. int countZrzyTdCedeNotice = cqGqProjectService.count(cqGqProjectQueryWrapper);
  249. totalGYCQ = totalGYCQ + countZrzyTdCedeNotice;
  250. total = total + countZrzyTdCedeNotice;
  251. }catch (Exception e){
  252. e.printStackTrace();
  253. }
  254. /*CQ_SW_PROJECT*/
  255. try {
  256. QueryWrapper<CqSwProject> cqGqProjectQueryWrapper = new QueryWrapper<CqSwProject>();
  257. cqGqProjectQueryWrapper.eq("zone",regionCode);
  258. int countZrzyTdCedeNotice = cqSwProjectService.count(cqGqProjectQueryWrapper);
  259. totalGYCQ = totalGYCQ + countZrzyTdCedeNotice;
  260. total = total + countZrzyTdCedeNotice;
  261. }catch (Exception e){
  262. e.printStackTrace();
  263. }
  264. totalEntryData.setTotal(total);
  265. totalEntryData.setTotalzzq(totalzzq);
  266. if(total > totalzzq){
  267. totalEntryData.setTotalms(total - totalzzq);
  268. }
  269. homePageDataCenter.setTotalEntryData(totalEntryData);
  270. /*成交数据总量*/
  271. /*成交数据总量*/
  272. /*成交数据总量*/
  273. /*成交数据总量*/
  274. TotalTransactionData totalTransactionData = new TotalTransactionData();
  275. int totalTransaction = 0;
  276. /*GC_BIDPUBLICITY*/
  277. try {
  278. QueryWrapper<GcBidpublicity> gcProjectQueryWrapper = new QueryWrapper<GcBidpublicity>();
  279. gcProjectQueryWrapper.eq("PLATFORM_CODE",platformCode);
  280. int countGcProject = gcBidpublicityService.count(gcProjectQueryWrapper);
  281. totalTransaction = totalTransaction + countGcProject;
  282. }catch (Exception e){
  283. e.printStackTrace();
  284. }
  285. try {
  286. QueryWrapper<ZcBidpublicity> zcBidpublicityQueryWrapper = new QueryWrapper<ZcBidpublicity>();
  287. zcBidpublicityQueryWrapper.eq("PLATFORM_CODE",platformCode);
  288. int countGcProject = zcBidpublicityService.count(zcBidpublicityQueryWrapper);
  289. totalTransaction = totalTransaction + countGcProject;
  290. }catch (Exception e){
  291. e.printStackTrace();
  292. }
  293. /*ZRZY_TD_BIDWINNOTICE*/
  294. try {
  295. QueryWrapper<ZrzyTdBidwinnotice> zcBidpublicityQueryWrapper = new QueryWrapper<ZrzyTdBidwinnotice>();
  296. zcBidpublicityQueryWrapper.likeRight("REGION_CODE",regionCode);
  297. int countGcProject = zrzyTdBidwinnoticeService.count(zcBidpublicityQueryWrapper);
  298. totalTransaction = totalTransaction + countGcProject;
  299. }catch (Exception e){
  300. e.printStackTrace();
  301. }
  302. /*ZRZY_TKQ_BIDWINNOTICE*/
  303. try {
  304. QueryWrapper<ZrzyTkqBidwinnotice> zcBidpublicityQueryWrapper = new QueryWrapper<ZrzyTkqBidwinnotice>();
  305. zcBidpublicityQueryWrapper.likeRight("REGION_CODE",regionCode);
  306. int countGcProject = zrzyTkqBidwinnoticeService.count(zcBidpublicityQueryWrapper);
  307. totalTransaction = totalTransaction + countGcProject;
  308. }catch (Exception e){
  309. e.printStackTrace();
  310. }
  311. /*ZRZY_CKQ_BIDWINNOTICE*/
  312. try {
  313. QueryWrapper<ZrzyCkqBidwinnotice> zcBidpublicityQueryWrapper = new QueryWrapper<ZrzyCkqBidwinnotice>();
  314. zcBidpublicityQueryWrapper.likeRight("REGION_CODE",regionCode);
  315. int countGcProject = zrzyCkqBidwinnoticeService.count(zcBidpublicityQueryWrapper);
  316. totalTransaction = totalTransaction + countGcProject;
  317. }catch (Exception e){
  318. e.printStackTrace();
  319. }
  320. /*Zrzy_Dk_Binwin_Notice*/
  321. try {
  322. QueryWrapper<ZrzyDkBinwinNotice> zcBidpublicityQueryWrapper = new QueryWrapper<ZrzyDkBinwinNotice>();
  323. zcBidpublicityQueryWrapper.likeRight("zone",regionCode);
  324. int countGcProject = zrzyDkBinwinNoticeService.count(zcBidpublicityQueryWrapper);
  325. totalTransaction = totalTransaction + countGcProject;
  326. }catch (Exception e){
  327. e.printStackTrace();
  328. }
  329. /*ZRZY_BG_BIDWIN_NOTICE*/
  330. try {
  331. int countGcProject = zrzyBgBidwinNoticeService.countNoticeByRegionCode(regionCode);
  332. totalTransaction = totalTransaction + countGcProject;
  333. }catch (Exception e){
  334. e.printStackTrace();
  335. }
  336. /*ZRZY_JYZB_BIDWIN_NOTICE*/
  337. try {
  338. int countGcProject = zrzyJyzbBidwinNoticeService.countNoticeByRegionCode(regionCode);
  339. totalTransaction = totalTransaction + countGcProject;
  340. }catch (Exception e){
  341. e.printStackTrace();
  342. }
  343. /*CQ_SW_BARGAIN_RESULT*/
  344. try {
  345. int countGcProject = cqSwBargainResultService.countByRegionCode(regionCode);
  346. totalTransaction = totalTransaction + countGcProject;
  347. }catch (Exception e){
  348. e.printStackTrace();
  349. }
  350. /*CQ_GQ_BARGAIN_RESULT*/
  351. try {
  352. QueryWrapper<CqGqBargainResult> gcProjectQueryWrapper = new QueryWrapper<CqGqBargainResult>();
  353. gcProjectQueryWrapper.likeRight("REGION_CODE",regionCode);
  354. int countGcProject = cqGqBargainResultService.count(gcProjectQueryWrapper);
  355. totalTransaction = totalTransaction + countGcProject;
  356. }catch (Exception e){
  357. e.printStackTrace();
  358. }
  359. totalTransactionData.setTotal(totalTransaction);
  360. homePageDataCenter.setTotalTransactionData(totalTransactionData);
  361. /*交易主体数据总量*/
  362. /*交易主体数据总量*/
  363. /*交易主体数据总量*/
  364. /*交易主体数据总量*/
  365. TotalAmountTransactionData totalAmountTransactionData = new TotalAmountTransactionData();
  366. try {
  367. /*
  368. *主体数量
  369. */
  370. if(platformCode.equals("121500004600236091")){
  371. QueryWrapper<ZtLegalinfo> ztLegalinfoQueryWrapper = new QueryWrapper<ZtLegalinfo>();
  372. ztLegalinfoQueryWrapper.likeRight("REGION_CODE","15");
  373. int countzzq = ztLegalinfoService.count(ztLegalinfoQueryWrapper);
  374. totalAmountTransactionData.setTotal(countzzq);
  375. }else{
  376. if(!ObjectUtils.isEmpty(areaCode) && areaCode != ""){
  377. QueryWrapper<ZtLegalinfo> ztLegalinfoQueryWrapper = new QueryWrapper<ZtLegalinfo>();
  378. ztLegalinfoQueryWrapper.likeRight("REGION_CODE",regionCode);
  379. int countzzq = ztLegalinfoService.count(ztLegalinfoQueryWrapper);
  380. totalAmountTransactionData.setTotal(countzzq);
  381. }
  382. }
  383. }catch (Exception e){
  384. e.printStackTrace();
  385. }
  386. homePageDataCenter.setTotalAmountTransactionData(totalAmountTransactionData);
  387. /*各交易类别 发布公告数量*/
  388. List<QuantityTransactionCategory> categoryList = new ArrayList<QuantityTransactionCategory>();
  389. try {
  390. QuantityTransactionCategory quantityTransactionCategory = new QuantityTransactionCategory();
  391. quantityTransactionCategory.setTotal(totalGCJS);
  392. quantityTransactionCategory.setName("工程建设");
  393. categoryList.add(quantityTransactionCategory);
  394. }catch (Exception e){
  395. e.printStackTrace();
  396. }
  397. try {
  398. QuantityTransactionCategory quantityTransactionCategory = new QuantityTransactionCategory();
  399. quantityTransactionCategory.setTotal(totalZFCG);
  400. quantityTransactionCategory.setName("政府采购");
  401. categoryList.add(quantityTransactionCategory);
  402. }catch (Exception e){
  403. e.printStackTrace();
  404. }
  405. try {
  406. QuantityTransactionCategory quantityTransactionCategory = new QuantityTransactionCategory();
  407. quantityTransactionCategory.setTotal(totalZRZY);
  408. quantityTransactionCategory.setName("自然资源");
  409. categoryList.add(quantityTransactionCategory);
  410. }catch (Exception e){
  411. e.printStackTrace();
  412. }
  413. try {
  414. QuantityTransactionCategory quantityTransactionCategory = new QuantityTransactionCategory();
  415. quantityTransactionCategory.setTotal(totalGYCQ);
  416. quantityTransactionCategory.setName("国有产权");
  417. categoryList.add(quantityTransactionCategory);
  418. }catch (Exception e){
  419. e.printStackTrace();
  420. }
  421. try {
  422. QuantityTransactionCategory quantityTransactionCategory = new QuantityTransactionCategory();
  423. quantityTransactionCategory.setTotal(0);
  424. quantityTransactionCategory.setName("疫苗交易");
  425. categoryList.add(quantityTransactionCategory);
  426. }catch (Exception e){
  427. e.printStackTrace();
  428. }
  429. try {
  430. if(platformCode.equals("121500004600236091")){
  431. try {
  432. totalYC = ycNoticeService.count();
  433. }catch (Exception e){
  434. e.printStackTrace();
  435. }
  436. }
  437. QuantityTransactionCategory quantityTransactionCategory = new QuantityTransactionCategory();
  438. quantityTransactionCategory.setTotal(totalYC);
  439. quantityTransactionCategory.setName("药采交易");
  440. categoryList.add(quantityTransactionCategory);
  441. }catch (Exception e){
  442. e.printStackTrace();
  443. }
  444. try {
  445. QuantityTransactionCategory quantityTransactionCategory = new QuantityTransactionCategory();
  446. quantityTransactionCategory.setTotal(totalQTJY);
  447. quantityTransactionCategory.setName("其他交易");
  448. categoryList.add(quantityTransactionCategory);
  449. }catch (Exception e){
  450. e.printStackTrace();
  451. }
  452. homePageDataCenter.setCategoryList(categoryList);
  453. TotalEntryDataRight totalEntryDataRight = new TotalEntryDataRight();
  454. try {
  455. Integer ProjectEntryDayTotal = getProjectTotalByTime(DatesUtil.getDayBegin(),DatesUtil.getDayEnd(),platformCode,regionCode);
  456. Integer ProjectEntryMoonTotal = getProjectTotalByTime(DatesUtil.getBeginDayOfMonth(),DatesUtil.getDayEnd(),platformCode,regionCode);
  457. Integer ProjectEntryYearTotal = getProjectTotalByTime(DatesUtil.getBeginDayOfYear(),DatesUtil.getDayEnd(),platformCode,regionCode);
  458. totalEntryDataRight.setProjectEntryDayTotal(ProjectEntryDayTotal);
  459. totalEntryDataRight.setProjectEntryMoonTotal(ProjectEntryMoonTotal);
  460. totalEntryDataRight.setProjectEntryYearTotal(ProjectEntryYearTotal);
  461. }catch (Exception e){
  462. e.printStackTrace();
  463. }
  464. try {
  465. Integer BidOpeningSessionsDayTotal = getFieldApplyByTime(DatesUtil.getDayBegin(),DatesUtil.getDayEnd(),sourceCode);
  466. Integer BidOpeningSessionsMoonTotal = getFieldApplyByTime(DatesUtil.getBeginDayOfMonth(),DatesUtil.getDayEnd(),sourceCode);
  467. Integer BidOpeningSessionsYearTotal = getFieldApplyByTime(DatesUtil.getBeginDayOfYear(),DatesUtil.getDayEnd(),sourceCode);
  468. totalEntryDataRight.setBidOpeningSessionsDayTotal(BidOpeningSessionsDayTotal);
  469. totalEntryDataRight.setBidOpeningSessionsMoonTotal(BidOpeningSessionsMoonTotal);
  470. totalEntryDataRight.setBidOpeningSessionsYearTotal(BidOpeningSessionsYearTotal);
  471. }catch (Exception e){
  472. e.printStackTrace();
  473. }
  474. try {
  475. Integer NumberTransactionsDayTotal = getEntryDataTotalByTime(DatesUtil.getDayBegin(),DatesUtil.getDayEnd(),platformCode,regionCode);
  476. Integer NumberTransactionsMoonTotal = getEntryDataTotalByTime(DatesUtil.getBeginDayOfMonth(),DatesUtil.getEndDayOfMonth(),platformCode,regionCode);
  477. Integer NumberTransactionsYearTotal = getEntryDataTotalByTime(DatesUtil.getBeginDayOfYear(),DatesUtil.getEndDayOfYear(),platformCode,regionCode);
  478. totalEntryDataRight.setNumberTransactionsDayTotal(NumberTransactionsDayTotal);
  479. totalEntryDataRight.setNumberTransactionsMoonTotal(NumberTransactionsMoonTotal);
  480. totalEntryDataRight.setNumberTransactionsYearTotal(NumberTransactionsYearTotal);
  481. }catch (Exception e){
  482. e.printStackTrace();
  483. }
  484. homePageDataCenter.setTotalEntryDataRight(totalEntryDataRight);
  485. redisUtil.set(platformCode+CommonConstant.MS_HOME_PAGE_DATA, JSONObject.toJSONString(homePageDataCenter),CommonConstant.REDIS_SAVE_TIME_TEN_MINUTES);
  486. return Result.OK(homePageDataCenter);
  487. }
  488. public Integer getFieldApplyByTime(Date startTime, Date endTime,String sourceCode){
  489. String strDateFormat = "yyyyMMddHHmmss";
  490. Long resultStartTime = Long.parseLong(DateFormatUtils.format(startTime,strDateFormat));
  491. Long resultEndTime = Long.parseLong(DateFormatUtils.format(endTime,strDateFormat));
  492. QueryWrapper<JgFieldApply> gcProjectQueryWrapper = new QueryWrapper<JgFieldApply>();
  493. gcProjectQueryWrapper.eq("source_data_code",sourceCode);
  494. gcProjectQueryWrapper.ge("BID_OPENING_TIME",resultStartTime);
  495. gcProjectQueryWrapper.le("BID_OPENING_TIME",resultEndTime);
  496. gcProjectQueryWrapper.eq("MEETING_TYPE","1");
  497. int count = jgFieldApplyService.count(gcProjectQueryWrapper);
  498. return count;
  499. }
  500. public Integer getProjectTotalByTime(Date startTime, Date endTime,String platformCode,String region_code){
  501. String strDateFormat = "yyyyMMddHHmmss";
  502. Long resultStartTime = Long.parseLong(DateFormatUtils.format(startTime,strDateFormat));
  503. Long resultEndTime = Long.parseLong(DateFormatUtils.format(endTime,strDateFormat));
  504. Integer total = 0;
  505. try {
  506. QueryWrapper<GcPackage> gcPackageQueryWrapper = new QueryWrapper<GcPackage>();
  507. gcPackageQueryWrapper.ge("CREATE_TIME",resultStartTime);
  508. gcPackageQueryWrapper.le("CREATE_TIME",resultEndTime);
  509. gcPackageQueryWrapper.eq("platform_code",platformCode);
  510. int countGcProject = gcPackageService.count(gcPackageQueryWrapper);
  511. total = total + countGcProject;
  512. }catch (Exception e){
  513. e.printStackTrace();
  514. }
  515. /*政府采购*/
  516. try {
  517. QueryWrapper<ZcProject> zcPurchaseBulletinQueryWrapper = new QueryWrapper<ZcProject>();
  518. zcPurchaseBulletinQueryWrapper.ge("CREATE_TIME",resultStartTime);
  519. zcPurchaseBulletinQueryWrapper.le("CREATE_TIME",resultEndTime);
  520. zcPurchaseBulletinQueryWrapper.eq("platform_code",platformCode);
  521. int countZcPurchaseBulletin = zcProjectService.count(zcPurchaseBulletinQueryWrapper);
  522. total = total + countZcPurchaseBulletin;
  523. }catch (Exception e){
  524. e.printStackTrace();
  525. }
  526. /*土地矿权*/
  527. /*ZRZY_TD_CEDE_INFO*/
  528. try {
  529. QueryWrapper<ZrzyTdCedeInfo> zrzyTdCedeInfoQueryWrapper = new QueryWrapper<ZrzyTdCedeInfo>();
  530. zrzyTdCedeInfoQueryWrapper.ge("SIGNUP_OPEN_TIME",resultStartTime);
  531. zrzyTdCedeInfoQueryWrapper.le("SIGNUP_OPEN_TIME",resultEndTime);
  532. zrzyTdCedeInfoQueryWrapper.likeRight("region_code",region_code);
  533. int countZrzyTdCedeNoticeSelf = zrzyTdCedeInfoService.count(zrzyTdCedeInfoQueryWrapper);
  534. total = total + countZrzyTdCedeNoticeSelf;
  535. }catch (Exception e){
  536. e.printStackTrace();
  537. }
  538. /*ZRZY_TKQ_PROJECT_INFO*/
  539. try {
  540. QueryWrapper<ZrzyTkqProjectInfo> zrzyTkqProjectInfoQueryWrapper = new QueryWrapper<ZrzyTkqProjectInfo>();
  541. zrzyTkqProjectInfoQueryWrapper.ge("SIGNUP_OPEN_TIME",resultStartTime);
  542. zrzyTkqProjectInfoQueryWrapper.le("SIGNUP_OPEN_TIME",resultEndTime);
  543. zrzyTkqProjectInfoQueryWrapper.likeRight("region_code",region_code);
  544. int countZrzyTdCedeNoticeSelf = zrzyTkqProjectInfoService.count(zrzyTkqProjectInfoQueryWrapper);
  545. total = total + countZrzyTdCedeNoticeSelf;
  546. }catch (Exception e){
  547. e.printStackTrace();
  548. }
  549. /*ZRZY_CKQ_PROJECT_INFO*/
  550. try {
  551. QueryWrapper<ZrzyCkqProjectInfo> zrzyTkqProjectInfoQueryWrapper = new QueryWrapper<ZrzyCkqProjectInfo>();
  552. zrzyTkqProjectInfoQueryWrapper.ge("SIGNUP_OPEN_TIME",resultStartTime);
  553. zrzyTkqProjectInfoQueryWrapper.le("SIGNUP_OPEN_TIME",resultEndTime);
  554. zrzyTkqProjectInfoQueryWrapper.likeRight("region_code",region_code);
  555. int countZrzyTdCedeNoticeSelf = zrzyCkqProjectInfoService.count(zrzyTkqProjectInfoQueryWrapper);
  556. total = total + countZrzyTdCedeNoticeSelf;
  557. }catch (Exception e){
  558. e.printStackTrace();
  559. }
  560. /*ZRZY_DK_PROJECT*/
  561. if(platformCode.equals("121500004600236091")){
  562. try {
  563. QueryWrapper<ZrzyDkProject> zrzyTkqProjectInfoQueryWrapper = new QueryWrapper<ZrzyDkProject>();
  564. zrzyTkqProjectInfoQueryWrapper.ge("NOTICE_SEND_TIME",resultStartTime);
  565. zrzyTkqProjectInfoQueryWrapper.le("NOTICE_SEND_TIME",resultEndTime);
  566. zrzyTkqProjectInfoQueryWrapper.eq("platform_code",platformCode);
  567. int countZrzyTdCedeNoticeSelf = zrzyDkProjectService.count(zrzyTkqProjectInfoQueryWrapper);
  568. total = total + countZrzyTdCedeNoticeSelf;
  569. }catch (Exception e){
  570. e.printStackTrace();
  571. }
  572. }
  573. /*ZRZY_BG_STOCK_INDEX*/
  574. try {
  575. QueryWrapper<ZrzyBgStockIndex> zrzyTkqProjectInfoQueryWrapper = new QueryWrapper<ZrzyBgStockIndex>();
  576. zrzyTkqProjectInfoQueryWrapper.ge("IN_TIME",resultStartTime);
  577. zrzyTkqProjectInfoQueryWrapper.le("IN_TIME",resultEndTime);
  578. zrzyTkqProjectInfoQueryWrapper.likeRight("zone",region_code);
  579. int countZrzyTdCedeNoticeSelf = zrzyBgStockIndexService.count(zrzyTkqProjectInfoQueryWrapper);
  580. total = total + countZrzyTdCedeNoticeSelf;
  581. }catch (Exception e){
  582. e.printStackTrace();
  583. }
  584. /*ZRZY_JYZB_STOCK_INDEX*/
  585. try {
  586. QueryWrapper<ZrzyJyzbStockIndex> zrzyTkqProjectInfoQueryWrapper = new QueryWrapper<ZrzyJyzbStockIndex>();
  587. zrzyTkqProjectInfoQueryWrapper.ge("DATA_TIMESTAMP",resultStartTime);
  588. zrzyTkqProjectInfoQueryWrapper.le("DATA_TIMESTAMP",resultEndTime);
  589. zrzyTkqProjectInfoQueryWrapper.likeRight("zone",region_code);
  590. int countZrzyTdCedeNoticeSelf = zrzyJyzbStockIndexService.count(zrzyTkqProjectInfoQueryWrapper);
  591. total = total + countZrzyTdCedeNoticeSelf;
  592. }catch (Exception e){
  593. e.printStackTrace();
  594. }
  595. try {
  596. QueryWrapper<CqGqProject> cqGqProjectQueryWrapper = new QueryWrapper<CqGqProject>();
  597. cqGqProjectQueryWrapper.ge("ENTRYREGISTDATE",resultStartTime);
  598. cqGqProjectQueryWrapper.le("ENTRYREGISTDATE",resultEndTime);
  599. cqGqProjectQueryWrapper.likeRight("PROJECT_DISTRICT",region_code);
  600. int countZrzyTdCedeNotice = cqGqProjectService.count(cqGqProjectQueryWrapper);
  601. total = total + countZrzyTdCedeNotice;
  602. }catch (Exception e){
  603. e.printStackTrace();
  604. }
  605. /*CQ_SW_PROJECT*/
  606. try {
  607. QueryWrapper<CqSwProject> cqGqProjectQueryWrapper = new QueryWrapper<CqSwProject>();
  608. cqGqProjectQueryWrapper.ge("ENTRYREGISTDATE",resultStartTime);
  609. cqGqProjectQueryWrapper.le("ENTRYREGISTDATE",resultEndTime);
  610. cqGqProjectQueryWrapper.eq("zone",platformCode);
  611. int countZrzyTdCedeNotice = cqSwProjectService.count(cqGqProjectQueryWrapper);
  612. total = total + countZrzyTdCedeNotice;
  613. }catch (Exception e){
  614. e.printStackTrace();
  615. }
  616. return total;
  617. }
  618. public Integer getEntryDataTotalByTime(Date startTime, Date endTime,String platformCode,String region_code){
  619. String strDateFormat = "yyyyMMddHHmmss";
  620. Long resultStartTime = Long.parseLong(DateFormatUtils.format(startTime,strDateFormat));
  621. Long resultEndTime = Long.parseLong(DateFormatUtils.format(endTime,strDateFormat));
  622. int totalTransaction = 0;
  623. /*GC_BIDPUBLICITY*/
  624. try {
  625. QueryWrapper<GcBidpublicity> gcProjectQueryWrapper = new QueryWrapper<GcBidpublicity>();
  626. gcProjectQueryWrapper.ge("NOTICE_SEND_TIME",resultStartTime);
  627. gcProjectQueryWrapper.le("NOTICE_SEND_TIME",resultEndTime);
  628. gcProjectQueryWrapper.eq("platform_code",platformCode);
  629. int countGcProject = gcBidpublicityService.count(gcProjectQueryWrapper);
  630. totalTransaction = totalTransaction + countGcProject;
  631. }catch (Exception e){
  632. e.printStackTrace();
  633. }
  634. try {
  635. QueryWrapper<ZcBidpublicity> zcBidpublicityQueryWrapper = new QueryWrapper<ZcBidpublicity>();
  636. zcBidpublicityQueryWrapper.ge("WIN_BID_BULLETIN_START_TIME",resultStartTime);
  637. zcBidpublicityQueryWrapper.le("WIN_BID_BULLETIN_START_TIME",resultEndTime);
  638. zcBidpublicityQueryWrapper.eq("platform_code",platformCode);
  639. int countGcProject = zcBidpublicityService.count(zcBidpublicityQueryWrapper);
  640. totalTransaction = totalTransaction + countGcProject;
  641. }catch (Exception e){
  642. e.printStackTrace();
  643. }
  644. /*ZRZY_TD_BIDWINNOTICE*/
  645. try {
  646. QueryWrapper<ZrzyTdBidwinnotice> zcBidpublicityQueryWrapper = new QueryWrapper<ZrzyTdBidwinnotice>();
  647. zcBidpublicityQueryWrapper.ge("PUBLISHING_TIME",resultStartTime);
  648. zcBidpublicityQueryWrapper.le("PUBLISHING_TIME",resultEndTime);
  649. zcBidpublicityQueryWrapper.likeRight("region_code",region_code);
  650. int countGcProject = zrzyTdBidwinnoticeService.count(zcBidpublicityQueryWrapper);
  651. totalTransaction = totalTransaction + countGcProject;
  652. }catch (Exception e){
  653. e.printStackTrace();
  654. }
  655. /*ZRZY_TKQ_BIDWINNOTICE*/
  656. try {
  657. QueryWrapper<ZrzyTkqBidwinnotice> zcBidpublicityQueryWrapper = new QueryWrapper<ZrzyTkqBidwinnotice>();
  658. zcBidpublicityQueryWrapper.ge("PUBLISHING_TIME",resultStartTime);
  659. zcBidpublicityQueryWrapper.le("PUBLISHING_TIME",resultEndTime);
  660. zcBidpublicityQueryWrapper.likeRight("region_code",region_code);
  661. int countGcProject = zrzyTkqBidwinnoticeService.count(zcBidpublicityQueryWrapper);
  662. totalTransaction = totalTransaction + countGcProject;
  663. }catch (Exception e){
  664. e.printStackTrace();
  665. }
  666. /*ZRZY_CKQ_BIDWINNOTICE*/
  667. try {
  668. QueryWrapper<ZrzyCkqBidwinnotice> zcBidpublicityQueryWrapper = new QueryWrapper<ZrzyCkqBidwinnotice>();
  669. zcBidpublicityQueryWrapper.ge("PUBLISHING_TIME",resultStartTime);
  670. zcBidpublicityQueryWrapper.le("PUBLISHING_TIME",resultEndTime);
  671. zcBidpublicityQueryWrapper.likeRight("region_code",region_code);
  672. int countGcProject = zrzyCkqBidwinnoticeService.count(zcBidpublicityQueryWrapper);
  673. totalTransaction = totalTransaction + countGcProject;
  674. }catch (Exception e){
  675. e.printStackTrace();
  676. }
  677. /*ZRZY_DK_BINWIN_NOTICE*/
  678. try {
  679. QueryWrapper<ZrzyDkBinwinNotice> zcBidpublicityQueryWrapper = new QueryWrapper<ZrzyDkBinwinNotice>();
  680. zcBidpublicityQueryWrapper.ge("SUBMITS_TIME",resultStartTime);
  681. zcBidpublicityQueryWrapper.le("SUBMITS_TIME",resultEndTime);
  682. zcBidpublicityQueryWrapper.likeRight("zone",region_code);
  683. int countGcProject = zrzyDkBinwinNoticeService.count(zcBidpublicityQueryWrapper);
  684. totalTransaction = totalTransaction + countGcProject;
  685. }catch (Exception e){
  686. e.printStackTrace();
  687. }
  688. /*ZRZY_BG_BIDWIN_NOTICE*/
  689. try {
  690. int countGcProject = zrzyBgBidwinNoticeService.countNoticeByRegionCodeAndTime(region_code,resultStartTime,resultEndTime);
  691. totalTransaction = totalTransaction + countGcProject;
  692. }catch (Exception e){
  693. e.printStackTrace();
  694. }
  695. /*ZRZY_JYZB_BIDWIN_NOTICE*/
  696. try {
  697. int countGcProject = zrzyJyzbBidwinNoticeService.countNoticeByRegionCodeAndTime(region_code,resultStartTime,resultEndTime);
  698. totalTransaction = totalTransaction + countGcProject;
  699. }catch (Exception e){
  700. e.printStackTrace();
  701. }
  702. /*CQ_SW_BARGAIN_RESULT*/
  703. try {
  704. String strDateFormatYyyyMMdd = "yyyyMMdd";
  705. Long resultStartTimeYyyyMMdd = Long.parseLong(DateFormatUtils.format(startTime,strDateFormatYyyyMMdd));
  706. Long resultEndTimeYyyyMMdd = Long.parseLong(DateFormatUtils.format(endTime,strDateFormatYyyyMMdd));
  707. int countGcProject = cqSwBargainResultService.countByRegionCodeAndTime(region_code,resultStartTimeYyyyMMdd,resultEndTimeYyyyMMdd);
  708. totalTransaction = totalTransaction + countGcProject;
  709. }catch (Exception e){
  710. e.printStackTrace();
  711. }
  712. /*CQ_GQ_BARGAIN_RESULT*/
  713. try {
  714. String strDateFormatYyyyMMdd = "yyyyMMdd";
  715. Long resultStartTimeYyyyMMdd = Long.parseLong(DateFormatUtils.format(startTime,strDateFormatYyyyMMdd));
  716. Long resultEndTimeYyyyMMdd = Long.parseLong(DateFormatUtils.format(endTime,strDateFormatYyyyMMdd));
  717. QueryWrapper<CqGqBargainResult> gcProjectQueryWrapper = new QueryWrapper<CqGqBargainResult>();
  718. gcProjectQueryWrapper.ge("TRADE_DATE",resultStartTimeYyyyMMdd);
  719. gcProjectQueryWrapper.le("TRADE_DATE",resultEndTimeYyyyMMdd);
  720. gcProjectQueryWrapper.likeRight("REGION_CODE",region_code);
  721. int countGcProject = cqGqBargainResultService.count(gcProjectQueryWrapper);
  722. totalTransaction = totalTransaction + countGcProject;
  723. }catch (Exception e){
  724. e.printStackTrace();
  725. }
  726. return totalTransaction;
  727. }
  728. }