TEquipmentController.java 89 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882
  1. package com.szwl.controller;
  2. import cn.com.crbank.ommo.bean.ResultMessage;
  3. import cn.com.crbank.ommo.esUtil.BeanUtils;
  4. //import org.apache.commons.beanutils.BeanUtils;
  5. import com.alibaba.fastjson.JSONObject;
  6. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  7. import com.baomidou.mybatisplus.core.metadata.IPage;
  8. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  9. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  10. import com.gexin.fastjson.JSON;
  11. import com.qiniu.common.QiniuException;
  12. import com.qiniu.storage.BucketManager;
  13. import com.qiniu.storage.Configuration;
  14. import com.qiniu.storage.Region;
  15. import com.qiniu.storage.model.FileInfo;
  16. import com.qiniu.util.Auth;
  17. import com.szwl.annotation.Audit;
  18. import com.szwl.constant.AuditEnum;
  19. import com.szwl.constant.ConfigConsts;
  20. import com.szwl.constant.ResponseCodesEnum;
  21. import com.szwl.manager.TokenManager;
  22. import com.szwl.model.bean.*;
  23. import com.szwl.model.bo.R;
  24. import com.szwl.model.bo.ResponseModel;
  25. import com.szwl.model.bo.UserDetailBO;
  26. import com.szwl.model.entity.*;
  27. import com.szwl.model.param.PasswordParam;
  28. import com.szwl.model.query.StatisticsParam;
  29. import com.szwl.model.utils.DateUtils;
  30. import com.szwl.model.utils.MailUtil;
  31. import com.szwl.model.utils.PushUtils;
  32. import com.szwl.model.vo.EquipmentVO;
  33. import com.szwl.service.*;
  34. import com.szwl.util.DownloadUtils;
  35. import com.szwl.util.WechatSendUtil;
  36. import io.swagger.annotations.Api;
  37. import io.swagger.annotations.ApiOperation;
  38. import org.apache.commons.lang.StringUtils;
  39. import org.springframework.amqp.core.MessageProperties;
  40. import org.springframework.beans.factory.annotation.Autowired;
  41. import org.springframework.http.HttpStatus;
  42. import org.springframework.http.ResponseEntity;
  43. import org.springframework.web.bind.annotation.*;
  44. import org.springframework.web.servlet.mvc.support.RedirectAttributes;
  45. import javax.annotation.Resource;
  46. import javax.servlet.http.HttpServletResponse;
  47. import java.io.*;
  48. import java.net.URL;
  49. import java.net.URLConnection;
  50. import java.net.URLEncoder;
  51. import java.nio.file.Files;
  52. import java.nio.file.Paths;
  53. import java.text.ParseException;
  54. import java.text.SimpleDateFormat;
  55. import java.util.*;
  56. import java.util.concurrent.Executors;
  57. import java.util.concurrent.ScheduledExecutorService;
  58. import java.util.concurrent.ScheduledFuture;
  59. import java.util.concurrent.TimeUnit;
  60. import java.util.stream.Collectors;
  61. import static com.szwl.constant.ResponseCodesEnum.*;
  62. /**
  63. * <p>
  64. * 前端控制器
  65. * </p>
  66. *
  67. * @author wuhs
  68. * @since 2023-10-25
  69. */
  70. @Api(value = "/tEquipment", tags = {"设备控制器"})
  71. @RestController
  72. @RequestMapping("/tEquipment")
  73. public class TEquipmentController {
  74. @Autowired
  75. TEquipmentService tEquipmentService;
  76. @Autowired
  77. TEquipmentDescService equipmentDescService;
  78. @Autowired
  79. TAdminService tAdminService;
  80. @Autowired
  81. TParametersService parametersService;
  82. @Autowired
  83. TAlarmRecordService tAlarmRecordService;
  84. @Autowired
  85. TAreaService tAreaService;
  86. @Autowired
  87. TOrderService tOrderService;
  88. @Autowired
  89. TAdminEquipmentService tAdminEquipmentService;
  90. @Autowired
  91. TDiyFlowerService tDiyFlowerService;
  92. @Autowired
  93. TLabelService labelService;
  94. TokenManager tokenManager;
  95. private int j;
  96. // 超时时间为30秒
  97. private static final int TIMEOUT = 30000;
  98. @ApiOperation(value = "根据经纬度获取区域内设备信息")
  99. @GetMapping("/getEquipmentByLatLon")
  100. public ResponseModel<List<TEquipment>> getEquipmentByLatLon(String lat1, String lat2, String lon1, String lon2) {
  101. LambdaQueryWrapper<TEquipment> lqw = Wrappers.lambdaQuery();
  102. lqw.between(TEquipment::getLatitude, lat1, lat2)
  103. .between(TEquipment::getLongitude, lon1, lon2)
  104. .notLike(TEquipment::getClientId, "%xxx");
  105. List<TEquipment> equipmentList = tEquipmentService.list(lqw);
  106. return R.ok(equipmentList);
  107. }
  108. @ApiOperation(value = "设备是否存在")
  109. @GetMapping("/getEquipmentBool")
  110. public ResponseModel<Boolean> getEquipmentBool(String clientId) {
  111. if (StringUtils.isEmpty(clientId)) {
  112. return R.fail("clientId参数不能为空");
  113. }
  114. LambdaQueryWrapper<TEquipment> lqw = Wrappers.lambdaQuery();
  115. lqw.eq(TEquipment::getClientId, clientId);
  116. List<TEquipment> equipmentList = tEquipmentService.list(lqw);
  117. if (equipmentList.isEmpty()) {
  118. return R.fail("设备clientId不存在");
  119. } else if (equipmentList.size() > 1) {
  120. return R.fail("设备clientId不唯一");
  121. } else {
  122. return R.ok(true);
  123. }
  124. }
  125. /**
  126. * @param adminName 商户的登录名
  127. * @param equipmentName 机器名称
  128. * @param areaName 地址名-fullName
  129. * @return
  130. */
  131. @ApiOperation(value = "查找机器列表")
  132. @PostMapping("/findList")
  133. public ResponseModel<IPage<?>> findList(Long id, String clientId, String adminName, String equipmentName,
  134. String areaName, String eqeStatus, String machineType, String equimentType,
  135. String channel, String companyType, String labelId, String todayDate, long current, long size) {
  136. LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
  137. TAdmin admin = tAdminService.getById(id);
  138. // 申泽管理员
  139. if (id == 2738) {
  140. companyType = "0";
  141. }
  142. // 七云管理员
  143. if (id == 2739) {
  144. companyType = "1";
  145. }
  146. Integer type = admin.getType();
  147. if (type > 1) {
  148. if (type == 2) {
  149. query.eq(TEquipment::getAdminId, id);
  150. }
  151. if (type == 3) {
  152. //查找属于这个商家子账户的设备 todo
  153. TAdminEquipment adminEquipment = tAdminEquipmentService.getById(admin.getId());
  154. if (adminEquipment.getType().equals("0")) {
  155. //全部机器
  156. query.eq(TEquipment::getAdminId, admin.getParentId());
  157. } else {
  158. String equipmentIds = adminEquipment.getEquipmentIds();
  159. String[] strings = equipmentIds.split(",");
  160. // List<String> equipmentIdList = JSON.parseArray(equipmentIds, String.class);
  161. query.in(TEquipment::getId, strings);
  162. }
  163. }
  164. }
  165. if (StringUtils.isNotEmpty(clientId)) {
  166. query.like(TEquipment::getClientId, clientId);
  167. }
  168. if (StringUtils.isNotEmpty(adminName) && !adminName.equals("admin")) {
  169. LambdaQueryWrapper<TAdmin> adminQuery = Wrappers.lambdaQuery();
  170. adminQuery.eq(TAdmin::getUsername, adminName);
  171. List<TAdmin> list = tAdminService.list(adminQuery);
  172. if (list.size() > 0) {
  173. query.eq(TEquipment::getAdminId, list.get(0).getId());
  174. }
  175. }
  176. if (StringUtils.isNotEmpty(equipmentName)) {
  177. query.like(TEquipment::getName, equipmentName);
  178. }
  179. if (StringUtils.isNotEmpty(areaName)) {
  180. query.like(TEquipment::getFullName, areaName);
  181. }
  182. if (StringUtils.isNotEmpty(eqeStatus)) {
  183. query.eq(TEquipment::getEqeStatus, eqeStatus);
  184. }
  185. if (StringUtils.isNotEmpty(machineType)) {
  186. query.eq(TEquipment::getMachineType, machineType);
  187. }
  188. if (StringUtils.isNotEmpty(equimentType)) {
  189. query.eq(TEquipment::getEquimentType, equimentType);
  190. }
  191. if (StringUtils.isNotEmpty(channel)) {
  192. query.eq(TEquipment::getChannel, channel);
  193. }
  194. // 公司平台
  195. if (StringUtils.isNotEmpty(companyType)) {
  196. if (companyType.equals("0")) {
  197. query.isNull(TEquipment::getCompanyType)
  198. .or().eq(TEquipment::getCompanyType, companyType);
  199. } else {
  200. query.eq(TEquipment::getCompanyType, companyType);
  201. }
  202. }
  203. // 分组ID
  204. if (StringUtils.isNotEmpty(labelId)) {
  205. TLabel label = labelService.getById(labelId);
  206. String equipmentIds = label.getEquipmentIds();
  207. equipmentIds = equipmentIds.replace("\"", "").replace("[","").replace("]","");
  208. String[] split = equipmentIds.split(",");
  209. query.in(TEquipment::getId, split);
  210. }
  211. query.orderByDesc(TEquipment::getCreateDate);
  212. Page<TEquipment> page = new Page<>(current, size, true);
  213. IPage<TEquipment> iPage = tEquipmentService.page(page, query);
  214. Page<TEquipmentDTO> pageDTO = new Page<>(current, size, true);
  215. IPage<TEquipmentDTO> iPageDTO = pageDTO;
  216. iPageDTO.setCurrent(iPage.getCurrent());
  217. iPageDTO.setPages(iPage.getPages());
  218. iPageDTO.setSize(iPage.getSize());
  219. iPageDTO.setTotal(iPage.getTotal());
  220. List<TEquipment> list = iPage.getRecords();
  221. List<TEquipmentDTO> equipmentDTOList = list.stream().map(equipment -> {
  222. TEquipmentDTO equipmentDTO = new TEquipmentDTO();
  223. BeanUtils.copyPropertiesIgnoreNull(equipment, equipmentDTO, true);
  224. return equipmentDTO;
  225. }).collect(Collectors.toList());
  226. for (TEquipmentDTO equipmentDTO : equipmentDTOList) {
  227. // Date date = new Date();
  228. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
  229. Date date = null;
  230. try {
  231. date = sdf.parse(todayDate);
  232. } catch (ParseException e) {
  233. e.printStackTrace();
  234. }
  235. Calendar calendar = new GregorianCalendar();
  236. Calendar calendar_end = new GregorianCalendar();
  237. calendar.setTime(date);
  238. calendar_end.setTime(date);
  239. calendar.set(Calendar.HOUR_OF_DAY, 0);
  240. calendar.set(Calendar.MINUTE, 0);
  241. calendar.set(Calendar.SECOND, 0);
  242. calendar.set(Calendar.MILLISECOND, 0);
  243. calendar_end.set(Calendar.HOUR_OF_DAY, 23);
  244. calendar_end.set(Calendar.MINUTE, 59);
  245. calendar_end.set(Calendar.SECOND, 59);
  246. calendar_end.set(Calendar.MILLISECOND, 999);
  247. Date date_start = calendar.getTime();
  248. Date date_end = calendar_end.getTime();
  249. LambdaQueryWrapper<TAlarmRecord> query1 = Wrappers.lambdaQuery();
  250. query1.eq(TAlarmRecord::getEquipmentId, equipmentDTO.getId());
  251. query1.eq(TAlarmRecord::getIsEliminate, 0);
  252. query1.gt(TAlarmRecord::getOccurrenceTime, date_start);
  253. query1.le(TAlarmRecord::getOccurrenceTime, date_end);
  254. List<TAlarmRecord> alarmRecordList = tAlarmRecordService.list(query1);
  255. if (alarmRecordList.size() > 0) {
  256. equipmentDTO.setHasTodayAlarm(true);
  257. equipmentDTO.setAlarmList(alarmRecordList);
  258. } else {
  259. equipmentDTO.setHasTodayAlarm(false);
  260. }
  261. TEquipmentDesc equipmentDesc = equipmentDescService.getById(equipmentDTO.getId());
  262. if (equipmentDesc != null) {
  263. equipmentDTO.setRedSugar(equipmentDesc.getRedSugar());
  264. equipmentDTO.setWasteWater(equipmentDesc.getWasteWater());
  265. equipmentDTO.setWater(equipmentDesc.getWater());
  266. equipmentDTO.setYellowSugar(equipmentDesc.getYellowSugar());
  267. equipmentDTO.setBlueSugar(equipmentDesc.getBlueSugar());
  268. equipmentDTO.setIsMaterialUse(equipmentDesc.getIsMaterialUse());
  269. equipmentDTO.setStick(equipmentDesc.getStick());
  270. equipmentDTO.setWhiteSugar(equipmentDesc.getWhiteSugar());
  271. equipmentDTO.setSleepDesc(equipmentDesc.getSleepDesc());
  272. equipmentDTO.setOutDoor(equipmentDesc.getOutDoor());
  273. equipmentDTO.setInDoor(equipmentDesc.getInDoor());
  274. equipmentDTO.setCupQuantity(equipmentDesc.getCupQuantity());
  275. equipmentDTO.setStirTm(equipmentDesc.getStirTm());
  276. equipmentDTO.setCornGeneratorTm(equipmentDesc.getCornGeneratorTm());
  277. equipmentDTO.setNumberOne(equipmentDesc.getNumberOne());
  278. equipmentDTO.setCandyGeneratorTm(equipmentDesc.getCandyGeneratorTm());
  279. equipmentDTO.setOutsideHd(equipmentDesc.getOutsideHd());
  280. equipmentDTO.setOutsideTm(equipmentDesc.getOutsideTm());
  281. equipmentDTO.setDiyFlowerStatus(equipmentDesc.getDiyFlowerStatus());
  282. }
  283. }
  284. iPageDTO.setRecords(equipmentDTOList);
  285. return R.ok(iPageDTO);
  286. }
  287. @ApiOperation(value = "id查找机器详情")
  288. @PostMapping("/findById")
  289. public ResponseModel<?> findById(@RequestParam Long id) {
  290. TEquipment equipment = tEquipmentService.getById(id);
  291. TEquipmentDTO equipmentDTO = new TEquipmentDTO();
  292. // BeanUtils.copyProperties(equipment, equipmentDTO);
  293. BeanUtils.copyPropertiesIgnoreNull(equipment, equipmentDTO, true);
  294. TEquipmentDesc equipmentDesc = equipmentDescService.getById(id);
  295. if (equipmentDesc != null) {
  296. equipmentDTO.setCouponStatus(equipmentDesc.getCouponStatus());
  297. equipmentDTO.setInDoor(equipmentDesc.getInDoor());
  298. equipmentDTO.setOutDoor(equipmentDesc.getOutDoor());
  299. if (equipmentDesc.getFlowers() != null) {
  300. equipmentDTO.setFlowers(equipmentDesc.getFlowers());
  301. }
  302. equipmentDTO.setNumberOne(equipmentDesc.getNumberOne());
  303. equipmentDTO.setCandyGeneratorTm(equipmentDesc.getCandyGeneratorTm());
  304. equipmentDTO.setOutsideHd(equipmentDesc.getOutsideHd());
  305. equipmentDTO.setOutsideTm(equipmentDesc.getOutsideTm());
  306. equipmentDTO.setDiyFlowerStatus(equipmentDesc.getDiyFlowerStatus());
  307. }
  308. String messageReceiver = equipment.getMessageReceiver();
  309. if (StringUtils.isNotEmpty(messageReceiver)) {
  310. String[] message = messageReceiver.split(",");
  311. int i = message.length;
  312. if (i > 0) {
  313. equipmentDTO.setMessageReceiver1(message[0]);
  314. }
  315. if (i > 1) {
  316. equipmentDTO.setMessageReceiver2(message[1]);
  317. }
  318. if (i > 2) {
  319. equipmentDTO.setMessageReceiver3(message[2]);
  320. }
  321. // equipmentDTO.setMessageReceiver1(message[0]);
  322. // equipmentDTO.setMessageReceiver2(message[1]);
  323. // equipmentDTO.setMessageReceiver3(message[2]);
  324. }
  325. return R.ok(equipmentDTO);
  326. }
  327. @ApiOperation(value = "id查找机器详情")
  328. @PostMapping("/findById2")
  329. public ResponseModel<TEquipment> findById2(@RequestParam Long id) {
  330. TEquipment equipment = tEquipmentService.getById(id);
  331. return R.ok(equipment);
  332. }
  333. @ApiOperation(value = "id查找机器详情")
  334. @GetMapping("/findEquipmentById")
  335. public ResponseModel<TEquipment> findEquipmentById(@RequestParam String id) {
  336. TEquipment equipment = tEquipmentService.getById(id);
  337. return R.ok(equipment);
  338. }
  339. @ApiOperation(value = "ClientId查找设备")
  340. @GetMapping("/findEquipmentByClientId")
  341. public ResponseModel<TEquipment> findEquipmentByClientId(@RequestParam String clientId) {
  342. LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
  343. query.eq(TEquipment::getClientId, clientId);
  344. TEquipment equipment = tEquipmentService.getOnly(query);
  345. return R.ok(equipment);
  346. }
  347. @ApiOperation(value = "获取对应的机器id")
  348. @GetMapping("/getClientIdList")
  349. public ResponseModel<TAdminEquipment> getClientIdList(@RequestParam String adminId) {
  350. //查找属于这个商家子账户的设备
  351. TAdminEquipment adminEquipment = tAdminEquipmentService.getById(adminId);
  352. return R.ok(adminEquipment);
  353. }
  354. @ApiOperation(value = "获取对应的机器编号")
  355. @GetMapping("/getClientIds")
  356. public ResponseModel<List<String>> getClientIds(@RequestParam String adminId) {
  357. //查找属于这个商家子账户的设备
  358. TAdminEquipment adminEquipment = tAdminEquipmentService.getById(adminId);
  359. String equipmentIds = adminEquipment.getEquipmentIds();
  360. // 分割保存在设备ID保存在list
  361. String[] tEquipmentIds = equipmentIds.split(",");
  362. List<String> list = Arrays.asList(tEquipmentIds);
  363. List<String> returnList = new ArrayList<>();
  364. if (list.size() > 0) {
  365. for (String id : list) {
  366. TEquipment equipment = tEquipmentService.getById(id);
  367. returnList.add(equipment.getClientId());
  368. }
  369. }
  370. return R.ok(returnList);
  371. }
  372. @ApiOperation(value = "获取机器列表 分页")
  373. @GetMapping("/pageEquipment2")
  374. public ResponseModel<IPage<TEquipment>> pageEquipment2(@RequestParam(value = "current") long current, @RequestParam(value = "size") long size) {
  375. LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
  376. Page<TEquipment> page = new Page<>(current, size, true);
  377. IPage<TEquipment> iPage = tEquipmentService.page(page, query);
  378. return R.ok(iPage);
  379. }
  380. @ApiOperation(value = "adminId查找设备")
  381. @GetMapping("/listEquipment")
  382. public ResponseModel<?> listEquipment(String adminId) {
  383. LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
  384. TAdmin admin = tAdminService.getById(adminId);
  385. Integer type = admin.getType();
  386. if (type < 2) {
  387. query.eq(TEquipment::getAdminId, 238);
  388. }
  389. if (type == 2) {
  390. query.eq(TEquipment::getAdminId, adminId);
  391. }
  392. if (type == 3) {
  393. //查找属于这个商家子账户的设备
  394. TAdminEquipment adminEquipment = tAdminEquipmentService.getById(admin.getId());
  395. if (adminEquipment.getType().equals("0")) {
  396. //全部机器
  397. query.eq(TEquipment::getAdminId, admin.getParentId());
  398. } else {
  399. String equipmentIds = adminEquipment.getEquipmentIds();
  400. String[] strings = equipmentIds.split(",");
  401. // List<String> equipmentIdList = JSON.parseArray(equipmentIds, String.class);
  402. query.in(TEquipment::getId, strings);
  403. }
  404. }
  405. // query.eq(TEquipment::getAdminId,adminId);
  406. List<TEquipment> list = tEquipmentService.list(query);
  407. List<EquipmentVO> equipmentVOs = new ArrayList<>();
  408. // for (TEquipment equipment : list) {
  409. // EquipmentVO equipmentVO = new EquipmentVO();
  410. // equipmentVO.setId(equipment.getId());
  411. // String name = StringUtils.isEmpty(equipment.getName()) ? equipment.getClientId() : equipment.getName();
  412. // equipmentVO.setName(name);
  413. // equipmentVO.setClientId(equipment.getClientId());
  414. // equipmentVOS.add(equipmentVO);
  415. // }
  416. Map<String, String> duplicateNames = new HashMap<>();
  417. for (TEquipment equipment : list) {
  418. String name = StringUtils.isEmpty(equipment.getName()) ? equipment.getClientId() : equipment.getName();
  419. String clientId = equipment.getClientId();
  420. if (duplicateNames.containsValue(name)) {
  421. name = clientId;
  422. }
  423. duplicateNames.put(String.valueOf(equipment.getId()), name);
  424. EquipmentVO equipmentVO = new EquipmentVO();
  425. equipmentVO.setId(equipment.getId());
  426. equipmentVO.setName(name);
  427. equipmentVO.setClientId(clientId);
  428. equipmentVOs.add(equipmentVO);
  429. }
  430. return R.ok(equipmentVOs);
  431. }
  432. @ApiOperation(value = "查找设备")
  433. @PostMapping("/getEquipmentByNameAndId")
  434. public ResponseModel<TEquipment> getEquipmentByNameAndId(@RequestBody TEquipment equipment) {
  435. LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
  436. TAdmin admin = tAdminService.getById(equipment.getId());
  437. if (admin.getType() == 3) {
  438. //子账户
  439. TAdmin parentAdmin = tAdminService.getById(admin.getParentId());
  440. LambdaQueryWrapper<TEquipment> query1 = Wrappers.lambdaQuery();
  441. query1.eq(TEquipment::getAdminId, parentAdmin.getId());
  442. List<TEquipment> list1 = tEquipmentService.list(query1);
  443. if (list1.size() > 0) {
  444. for (TEquipment tEquipment : list1) {
  445. if (equipment.getName().equals(tEquipment.getName())) {
  446. return R.ok(tEquipment);
  447. }
  448. }
  449. }
  450. }
  451. if (admin.getType() < 2) {
  452. query.eq(TEquipment::getName, equipment.getName());
  453. }
  454. if (admin.getType() == 2) {
  455. query.eq(TEquipment::getAdminId, equipment.getAdminId());
  456. query.eq(TEquipment::getName, equipment.getName());
  457. }
  458. List<TEquipment> list = tEquipmentService.list(query);
  459. TEquipment tEquipment = list.get(0);
  460. return R.ok(tEquipment);
  461. }
  462. /**
  463. * 更新
  464. */
  465. @ApiOperation(value = "更新机器")
  466. @RequestMapping(value = "/update", method = RequestMethod.POST)
  467. public ResponseModel<?> update(@RequestBody TEquipmentDTO equipment) {
  468. //获取修改前的设备
  469. TEquipment oldEquipment = tEquipmentService.getById(equipment.getId());
  470. if (StringUtils.isNotEmpty(equipment.getSn())) {
  471. oldEquipment.setSn(equipment.getSn());
  472. }
  473. String name = equipment.getName();
  474. if (StringUtils.isNotEmpty(name) && !name.equals(oldEquipment.getName())) {
  475. LambdaQueryWrapper<TEquipment> queryWrapper = new LambdaQueryWrapper<>();
  476. queryWrapper.eq(TEquipment::getAdminId, oldEquipment.getAdminId());
  477. queryWrapper.eq(TEquipment::getName, name);
  478. TEquipment tEquipment = tEquipmentService.getOne(queryWrapper);
  479. if (tEquipment != null) {
  480. return R.fail(A0001);
  481. }
  482. oldEquipment.setName(equipment.getName());
  483. }
  484. if (StringUtils.isNotEmpty(equipment.getSelfName())) {
  485. oldEquipment.setSelfName(equipment.getSelfName());
  486. }
  487. if (equipment.getAreaId() != null) {
  488. oldEquipment.setAreaId(equipment.getAreaId());
  489. }
  490. if (StringUtils.isNotEmpty(equipment.getContactName())) {
  491. oldEquipment.setContactName(equipment.getContactName());
  492. }
  493. if (StringUtils.isNotEmpty(equipment.getContactPhone())) {
  494. oldEquipment.setContactPhone(equipment.getContactPhone());
  495. }
  496. if (StringUtils.isNotEmpty(equipment.getOperationalName())) {
  497. oldEquipment.setOperationalName(equipment.getOperationalName());
  498. }
  499. if (StringUtils.isNotEmpty(equipment.getOperationalPhone())) {
  500. oldEquipment.setOperationalPhone(equipment.getOperationalPhone());
  501. }
  502. if (StringUtils.isNotEmpty(equipment.getOperator())) {
  503. oldEquipment.setOperator(equipment.getOperator());
  504. }
  505. if (StringUtils.isNotEmpty(equipment.getSimNo())) {
  506. oldEquipment.setSimNo(equipment.getSimNo());
  507. }
  508. if (equipment.getTimeRuleId() != null) {
  509. oldEquipment.setTimeRuleId(equipment.getTimeRuleId());
  510. }
  511. if (StringUtils.isNotEmpty(equipment.getPlcVersion())) {
  512. oldEquipment.setPlcVersion(equipment.getPlcVersion());
  513. }
  514. if (StringUtils.isNotEmpty(equipment.getChannel())) {
  515. oldEquipment.setChannel(equipment.getChannel());
  516. }
  517. if (equipment.getPayType() != null) {
  518. oldEquipment.setPayType(equipment.getPayType());
  519. }
  520. if (equipment.getEndDate() != null) {
  521. oldEquipment.setEndDate(equipment.getEndDate());
  522. }
  523. if (equipment.getAreaId() != null) {
  524. oldEquipment.setFullName(tAreaService.getById(equipment.getAreaId()).getFullName());
  525. }
  526. if (StringUtils.isNotEmpty(equipment.getFlowers())) {
  527. if (StringUtils.isEmpty(oldEquipment.getFlowers())) {
  528. //发信息
  529. tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("flowers", equipment.getFlowers()).toString());
  530. }
  531. if (StringUtils.isNotEmpty(oldEquipment.getFlowers()) && !oldEquipment.getFlowers().equals(equipment.getFlowers())) {
  532. //发信息
  533. tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("flowers", equipment.getFlowers()).toString());
  534. }
  535. oldEquipment.setFlowers(equipment.getFlowers());
  536. }
  537. String[] message = new String[3];
  538. ;
  539. message[0] = equipment.getMessageReceiver1();
  540. message[1] = equipment.getMessageReceiver2();
  541. message[2] = equipment.getMessageReceiver3();
  542. if (message.length > 0) {
  543. oldEquipment.setMessageReceiver(message[0] + "," + message[1] + "," + message[2]);
  544. }
  545. tEquipmentService.updateById(oldEquipment);
  546. String channel = oldEquipment.getChannel();
  547. String equimentType = oldEquipment.getEquimentType();
  548. String clientId = oldEquipment.getClientId();
  549. if (equipment.getPayType() != null) {
  550. tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("payType", oldEquipment.getPayType().toString() + ":" + oldEquipment.getTimeRuleId()).toString());
  551. }
  552. if (StringUtils.isNotEmpty(oldEquipment.getContactName()) && StringUtils.isNotEmpty(oldEquipment.getContactPhone())) {
  553. tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("phone", oldEquipment.getContactName() + ":" + oldEquipment.getContactPhone().toString()).toString());
  554. }
  555. if (StringUtils.isNotEmpty(oldEquipment.getCompanyPhone())) {
  556. tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("companyPhone", oldEquipment.getCompanyPhone()).toString());
  557. }
  558. if (StringUtils.isNotEmpty(oldEquipment.getPlcVersion())) {
  559. tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("plcVersion", oldEquipment.getPlcVersion()).toString());
  560. }
  561. if (StringUtils.isNotEmpty(oldEquipment.getSelfName())) {
  562. tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("selfName", oldEquipment.getSelfName()).toString());
  563. }
  564. if (oldEquipment.getTimeRuleId() != null) {
  565. tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("pushTimeRule", oldEquipment.getTimeRuleId() + "").toString());
  566. }
  567. if (StringUtils.isNotEmpty(oldEquipment.getOperationalName())) {
  568. tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("operational", oldEquipment.getOperationalName() + ":" + oldEquipment.getOperationalPhone()).toString());
  569. }
  570. return R.ok("null", "更新成功!");
  571. }
  572. @ApiOperation(value = "更新机器 整体")
  573. @PostMapping("/updateByEquipment")
  574. public ResponseModel<?> updateByEquipment(@RequestBody TEquipment equipment) {
  575. if (equipment != null && equipment.getId() != null) {
  576. equipment.setModifyDate(new Date());
  577. tEquipmentService.updateById(equipment);
  578. }
  579. return R.ok();
  580. }
  581. @ApiOperation(value = "查找机器")
  582. @PostMapping("/getEquipmentListByUser")
  583. public ResponseEntity<?> getEquipmentListByUser(@RequestBody TAdmin param) {
  584. List<TAdminDTO> resultList = new ArrayList<>();
  585. if ("admin".equals(param.getUsername())) { // 管理员查所有商家
  586. List<TAdmin> adminList = tAdminService.list();
  587. List<TEquipment> equipmentList = tEquipmentService.list();
  588. List<TAlarmRecord> alarmRecordList = tAlarmRecordService.list();
  589. //获取当前用户今天所有机器的所以警报信息
  590. List<TAlarmRecord> alarmList = tAlarmRecordService.getAlarmList(null);
  591. resultList = adminList.stream().map(e -> {
  592. TAdminDTO dto = new TAdminDTO();
  593. BeanUtils.copyPropertiesIgnoreNull(e, dto, true);
  594. List<TEquipmentDTO> selList = equipmentList.stream()
  595. .filter(equipment -> e.getId().equals(equipment.getAdminId())) // 查对应的设备
  596. .map(equipment -> {
  597. TEquipmentDTO equipmentDTO = new TEquipmentDTO();
  598. BeanUtils.copyPropertiesIgnoreNull(equipment, equipmentDTO, true);
  599. Optional<TAlarmRecord> op = alarmRecordList.stream().filter(alarm -> equipment.getClientId().equals(alarm.getClientId())).findFirst();
  600. if (op.isPresent()) {
  601. equipmentDTO.setAlarmContent(op.get().getAlarmContent());
  602. equipmentDTO.setOccurrenceTime(op.get().getOccurrenceTime());
  603. }
  604. //获取该机器的所有警报信息
  605. List<TAlarmRecord> eqAlarmList = alarmList.stream().filter(alarm -> equipment.getClientId().equals(alarm.getClientId())).collect(Collectors.toList());
  606. equipmentDTO.setAlarmList(eqAlarmList);
  607. if (eqAlarmList.size() > 0) {
  608. int i = 0;
  609. for (TAlarmRecord alarmRecord : eqAlarmList) {
  610. if (DateUtils.isSameDay(new Date(), alarmRecord.getOccurrenceTime())) {
  611. if (alarmRecord.getIsEliminate() == null || alarmRecord.getIsEliminate() == 0) {
  612. i++;
  613. }
  614. }
  615. }
  616. if (i > 0) {
  617. equipmentDTO.setHasTodayAlarm(true);
  618. } else {
  619. equipmentDTO.setHasTodayAlarm(false);
  620. }
  621. }
  622. return equipmentDTO;
  623. }).collect(Collectors.toList());
  624. dto.setEquipmentList(selList);
  625. return dto;
  626. }).collect(Collectors.toList());
  627. } else { // 只查当前商家的设备列表
  628. TAdminDTO dto = new TAdminDTO();
  629. BeanUtils.copyPropertiesIgnoreNull(param, dto, true);
  630. // 需要区分是否商家子账户
  631. LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
  632. query.eq(TEquipment::getAdminId, param.getId());
  633. List<TEquipment> equipmentList = tEquipmentService.list(query);
  634. List<TAlarmRecord> alarmRecordList = tAlarmRecordService.getLastAlarmRecord(param.getId());
  635. //获取当前用户今天所有机器的所以警报信息
  636. List<TAlarmRecord> alarmList = tAlarmRecordService.getAlarmList(param.getId());
  637. List<TEquipmentDTO> equipmentDTOList = equipmentList.stream().map(equipment -> {
  638. TEquipmentDTO equipmentDTO = new TEquipmentDTO();
  639. BeanUtils.copyPropertiesIgnoreNull(equipment, equipmentDTO, true);
  640. Optional<TAlarmRecord> op = alarmRecordList.stream().filter(alarm -> equipment.getClientId().equals(alarm.getClientId())).findFirst();
  641. if (op.isPresent()) {
  642. equipmentDTO.setAlarmContent(op.get().getAlarmContent());
  643. equipmentDTO.setOccurrenceTime(op.get().getOccurrenceTime());
  644. }
  645. //获取该机器的所有警报信息
  646. List<TAlarmRecord> eqAlarmList = alarmList.stream().filter(alarm -> equipment.getClientId().equals(alarm.getClientId())).collect(Collectors.toList());
  647. equipmentDTO.setAlarmList(eqAlarmList);
  648. if (eqAlarmList.size() > 0) {
  649. int i = 0;
  650. for (TAlarmRecord alarmRecord : eqAlarmList) {
  651. if (DateUtils.isSameDay(new Date(), alarmRecord.getOccurrenceTime())) {
  652. if (alarmRecord.getIsEliminate() == null || alarmRecord.getIsEliminate() == 0) {
  653. i++;
  654. }
  655. }
  656. }
  657. if (i > 0) {
  658. equipmentDTO.setHasTodayAlarm(true);
  659. } else {
  660. equipmentDTO.setHasTodayAlarm(false);
  661. }
  662. }
  663. return equipmentDTO;
  664. }).collect(Collectors.toList());
  665. dto.setEquipmentList(equipmentDTOList);
  666. resultList.add(dto);
  667. }
  668. return ResponseEntity.status(HttpStatus.OK)
  669. .body(new ResultMessage().setCode(true).setData(resultList).setMessage("SUCCESS"));
  670. }
  671. @ApiOperation(value = "消除报警")
  672. @PostMapping("/eliminate")
  673. public ResponseEntity<?> eliminate(@RequestBody TAlarmRecord param) {
  674. TAlarmRecord tAlarmRecord = tAlarmRecordService.getById(param.getId());
  675. TEquipment equipment = tEquipmentService.getById(tAlarmRecord.getEquipmentId());
  676. JSONObject kindData = new JSONObject();
  677. kindData.put("id", param.getId());
  678. kindData.put("content", tAlarmRecord.getAlarmContent());
  679. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("eliminate", kindData.toString()).toString());
  680. // PushUtils.push(equipment.getGtClientId(), "", "", PushUtils.buildJson("eliminate", kindData.toString()).toString());
  681. return ResponseEntity.status(HttpStatus.OK)
  682. .body(new ResultMessage().setCode(true).setData("0").setMessage("已发送"));
  683. }
  684. @ApiOperation(value = "修改机器音量")
  685. @PostMapping("/updateVolume")
  686. public ResponseEntity<?> updateVolume(@RequestBody TEquipment equipment) {
  687. if (!StringUtils.isEmpty(equipment.getVolume())) {
  688. TEquipment tEquipment = tEquipmentService.getById(equipment.getId());
  689. tEquipmentService.sentMessage(tEquipment.getClientId(), PushUtils.buildJson("volume", equipment.getVolume()).toString());
  690. // PushUtils.push(tEquipment.getGtClientId(), "", "", PushUtils.buildJson("volume", equipment.getVolume()).toString());
  691. }
  692. return ResponseEntity.status(HttpStatus.OK)
  693. .body(new ResultMessage().setCode(true).setData(true).setMessage("修改成功"));
  694. }
  695. @ApiOperation(value = "修改机器信息")
  696. @PostMapping("/updateEquipment")
  697. public ResponseEntity<?> updateEquipment(@RequestBody TEquipment equipment) {
  698. TEquipment equipment1 = tEquipmentService.getById(equipment.getId());
  699. Integer type = equipment.getType();
  700. //修改基本信息
  701. if (type == 0) {
  702. equipment1.setName(equipment.getName());
  703. equipment1.setSimNo(equipment.getSimNo());
  704. equipment1.setOperator(equipment.getOperator());
  705. }
  706. //修改后台密码
  707. if (type == 1) {
  708. equipment1.setAdminPwd(equipment.getAdminPwd());
  709. equipment1.setGuestPwd(equipment.getGuestPwd());
  710. tEquipmentService.sentMessage(equipment1.getClientId(), PushUtils.buildJson("guestPwd", equipment1.getGuestPwd()).toString());
  711. tEquipmentService.sentMessage(equipment1.getClientId(), PushUtils.buildJson("adminPwd", equipment1.getAdminPwd()).toString());
  712. // PushUtils.push(equipment1.getGtClientId(), "【棉花糖】设备管理-更改密码", "修改guest密码", PushUtils.buildJson("guestPwd", equipment1.getGuestPwd()).toString());
  713. // PushUtils.push(equipment1.getGtClientId(), "【棉花糖】设备管理-更改密码", "修改admin密码", PushUtils.buildJson("adminPwd", equipment1.getAdminPwd()).toString());
  714. }
  715. //定时开机
  716. if (type == 3) {
  717. // equipment1.setBootTime(equipment.getBootTime());
  718. // tEquipmentService.sentMessage(equipment1.getClientId(),PushUtils.buildJson("updateBootTime", equipment.getBootTime()).toString());
  719. // PushUtils.push(equipment.getGtClientId(), "", "", PushUtils.buildJson("updateBootTime", equipment.getBootTime()).toString());
  720. }
  721. //定时关机
  722. if (type == 4) {
  723. // equipment1.setOffTime(equipment.getOffTime());
  724. // tEquipmentService.sentMessage(equipment1.getClientId(), PushUtils.buildJson("updateOffTime", equipment.getBootTime()).toString());
  725. // PushUtils.push(equipment.getGtClientId(), "", "", PushUtils.buildJson("updateOffTime", equipment.getBootTime()).toString());
  726. }
  727. if (type == 5) {
  728. equipment1.setMessageReceiver(equipment.getMessageReceiver());
  729. }
  730. Boolean t = tEquipmentService.updateById(equipment1);
  731. if (t == true) {
  732. return ResponseEntity.status(HttpStatus.OK)
  733. .body(new ResultMessage().setCode(true).setData(equipment1).setMessage("修改成功"));
  734. } else {
  735. return ResponseEntity.status(HttpStatus.OK)
  736. .body(new ResultMessage().setCode(false).setData(t).setMessage("修改失败"));
  737. }
  738. }
  739. @ApiOperation(value = "根据机器id获取用户信息")
  740. @PostMapping("/findByEquipment")
  741. public ResponseEntity<?> findByEquipment(@RequestBody TEquipment equipment) {
  742. TEquipment tEquipment = tEquipmentService.getById(equipment.getId());
  743. TAdmin tAdmin = tAdminService.getById(tEquipment.getAdminId());
  744. return ResponseEntity.status(HttpStatus.OK)
  745. .body(new ResultMessage().setCode(false).setData(tAdmin).setMessage(""));
  746. }
  747. @ApiOperation(value = "根据机器编号获取用户信息")
  748. @PostMapping("/getEquipmentListLikeClientId")
  749. public ResponseEntity<?> getEquipmentListLikeClientId(@RequestBody TEquipment equipment) {
  750. if (StringUtils.isEmpty(equipment.getClientId())) {
  751. return ResponseEntity.status(HttpStatus.OK)
  752. .body(new ResultMessage().setCode(false).setData("").setMessage("设备编号为空"));
  753. }
  754. LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
  755. query.like(TEquipment::getClientId, equipment.getClientId());
  756. List<TEquipment> list = tEquipmentService.list(query);
  757. return ResponseEntity.status(HttpStatus.OK)
  758. .body(new ResultMessage().setCode(true).setData(list).setMessage(""));
  759. }
  760. @ApiOperation(value = "脱机")
  761. @PostMapping("/tuoji")
  762. @Audit(type = AuditEnum.OFFLINE, content = "#equipment.adminUserName + '对设备' + #equipment.clientId + '进行了脱机操作'")
  763. public ResponseEntity<?> tuoji(@RequestBody TEquipment equipment) {
  764. if (equipment.getId() == null) {
  765. return ResponseEntity.status(HttpStatus.OK)
  766. .body(new ResultMessage().setCode(false).setData("").setMessage(""));
  767. }
  768. TEquipment tEquipment = tEquipmentService.getById(equipment.getId());
  769. tEquipmentService.sentMessage(tEquipment.getClientId(), PushUtils.buildJson("tuoji", "0").toString());
  770. if ("xxx".equals(tEquipment.getClientId().substring(tEquipment.getClientId().length() - 3))) {
  771. return ResponseEntity.status(HttpStatus.OK)
  772. .body(new ResultMessage().setCode(true).setData("").setMessage("发送成功!"));
  773. }
  774. tEquipment.setClientId(tEquipment.getClientId() + "xxx");
  775. tEquipmentService.updateById(tEquipment);
  776. return ResponseEntity.status(HttpStatus.OK)
  777. .body(new ResultMessage().setCode(true).setData("").setMessage("发送成功!"));
  778. }
  779. @ApiOperation(value = "一键补料")
  780. @GetMapping("/buliao")
  781. public ResponseModel<?> buliao(String equipmentId) {
  782. TEquipment equipment = tEquipmentService.getById(equipmentId);
  783. if (equipment == null || equipment.getId() == null) {
  784. return R.fail(ResponseCodesEnum.A0001, "找不到设备");
  785. }
  786. TEquipmentDesc tEquipmentDesc = equipmentDescService.getById(equipment.getId());
  787. if (tEquipmentDesc != null) {
  788. tEquipmentDesc.setBlueSugar("100");
  789. tEquipmentDesc.setRedSugar("100");
  790. tEquipmentDesc.setStick("100");
  791. tEquipmentDesc.setWhiteSugar("100");
  792. tEquipmentDesc.setYellowSugar("100");
  793. tEquipmentDesc.setWater("100");
  794. tEquipmentDesc.setWasteWater("0");
  795. equipmentDescService.updateById(tEquipmentDesc);
  796. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("buliao", "buliao").toString());
  797. } else {
  798. return R.fail(ResponseCodesEnum.A0001, "找不到设备");
  799. }
  800. return R.ok(null, "发送请求成功");
  801. }
  802. @ApiOperation(value = "修改优惠券开关状态")
  803. @GetMapping("/updateCouponStatus")
  804. public ResponseModel<?> updateCouponStatus(String equipmentId, String couponStatus) {
  805. if (StringUtils.isEmpty(couponStatus) || StringUtils.isEmpty(equipmentId)) {
  806. return R.fail(ResponseCodesEnum.A0001, "参数有空");
  807. }
  808. TEquipment equipment = tEquipmentService.getById(equipmentId);
  809. if (equipment == null || equipment.getId() == null) {
  810. return R.fail(ResponseCodesEnum.A0001, "找不到设备");
  811. }
  812. TEquipmentDesc tEquipmentDesc = equipmentDescService.getById(equipment.getId());
  813. if (tEquipmentDesc != null) {
  814. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("couponStatus", couponStatus).toString());
  815. } else {
  816. return R.fail(ResponseCodesEnum.A0001, "找不到设备");
  817. }
  818. return R.ok(null, "修改成功");
  819. }
  820. @ApiOperation(value = "查找设备")
  821. @PostMapping("/findEquipment")
  822. public ResponseEntity<?> findEquipment(@RequestBody TEquipment equipment) {
  823. TEquipment tEquipment = tEquipmentService.getById(equipment.getId());
  824. return ResponseEntity.status(HttpStatus.OK)
  825. .body(new ResultMessage().setCode(false).setData(tEquipment).setMessage(""));
  826. }
  827. @ApiOperation(value = "获取机器数量")
  828. @PostMapping("/getMachineNum")
  829. public ResponseModel<?> getMachineNum(@RequestBody StatisticsParam param) {
  830. String machineTotalNum = "";
  831. String machineUseNum = "";
  832. String equipmentId = param.getEquipmentId();
  833. String paramAdminId = param.getAdminId();
  834. TAdmin admin = tAdminService.getById(paramAdminId);
  835. Integer type = admin.getType();
  836. if (type < 2) {
  837. param.setAdminId(null);
  838. }
  839. // 公司平台
  840. // 申泽平台管理员
  841. if (admin.getId() == 2738) {
  842. param.setCompanyType("0");
  843. }
  844. // 七云平台管理员
  845. if (admin.getId() == 2739) {
  846. param.setCompanyType("1");
  847. }
  848. //判断是否有机器id传入
  849. if (equipmentId != null && equipmentId != "") {
  850. Long id = Long.valueOf(equipmentId);
  851. TEquipment equipment = tEquipmentService.getById(id);
  852. Long adminId = equipment.getAdminId();
  853. String dminId = String.valueOf(adminId);
  854. param.setAdminId(dminId);
  855. // 需要区分是否商家子账户
  856. }
  857. // 如果是子账户商家
  858. if (type == 3) {
  859. // 查找属于这个子账户的设备
  860. TAdminEquipment adminEquipment = tAdminEquipmentService.getById(paramAdminId);
  861. if (!adminEquipment.getType().equals("0")) {
  862. //全部机器
  863. // } else {
  864. String adminEquipmentIds = adminEquipment.getEquipmentIds();
  865. List<String> equipmentIds = Arrays.asList(adminEquipmentIds.split(","));
  866. param.setEquipmentIds(equipmentIds);
  867. }
  868. param.setAdminId(String.valueOf(admin.getParentId()));
  869. }
  870. machineTotalNum = tEquipmentService.findMachineTotalNum(param);
  871. machineUseNum = tEquipmentService.findMachineUseNum(param);
  872. Map<String, String> map = new HashMap<>();
  873. map.put("machineTotalNum", machineTotalNum);
  874. map.put("machineUseNum", machineUseNum);
  875. List<String> list = new ArrayList<>();
  876. list.add(machineTotalNum);
  877. list.add(machineUseNum);
  878. return R.ok(map, "获取成功");
  879. }
  880. @ApiOperation(value = "推送设备密码")
  881. @PostMapping("/updatePassword")
  882. public ResponseModel<?> updatePassword(@RequestBody PasswordParam passwordParam) {
  883. String equipmentId = passwordParam.getEquipmentId();
  884. String adminPwd = passwordParam.getAdminPwd();
  885. String guestPwd = passwordParam.getGuestPwd();
  886. TEquipment tEquipment = tEquipmentService.getById(equipmentId);
  887. if (tEquipment == null) {
  888. return R.fail(ResponseCodesEnum.A0001, "找不到设备");
  889. }
  890. if (StringUtils.isNotEmpty(guestPwd)) {
  891. tEquipmentService.sentMessage(tEquipment.getClientId(), PushUtils.buildJson("guestPwd", guestPwd).toString());
  892. tEquipment.setGuestPwd(guestPwd);
  893. }
  894. if (StringUtils.isNotEmpty(adminPwd)) {
  895. tEquipmentService.sentMessage(tEquipment.getClientId(), PushUtils.buildJson("adminPwd", adminPwd).toString());
  896. tEquipment.setAdminPwd(adminPwd);
  897. }
  898. tEquipmentService.updateById(tEquipment);
  899. return R.ok(null, "修改成功");
  900. }
  901. @ApiOperation(value = "远程开门")
  902. @PostMapping("/openDoor")
  903. public ResponseEntity<?> openDoor(@RequestBody StatisticsParam param) {
  904. String equipmentId = param.getEquipmentId();
  905. Long id = Long.valueOf(equipmentId);
  906. TEquipment equipment = tEquipmentService.getById(id);
  907. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("openDoor", "0").toString());
  908. // PushUtils.push(equipment.getGtClientId(), "", "", PushUtils.buildJson("openDoor", "0").toString());
  909. return ResponseEntity
  910. .status(HttpStatus.OK)
  911. .body(new ResultMessage()
  912. .setCode(true)
  913. .setData("SUCCESS")
  914. .setMessage("SUCCESS"));
  915. }
  916. //修改机器状态 type(类型,0:外门,1:内门), status(状态:0:关闭,1:开启)
  917. @ApiOperation(value = "远程开门")
  918. @GetMapping("/openDoors")
  919. public ResponseModel<?> openDoor(String equipmentId, String type, String status) {
  920. if (StringUtils.isEmpty(equipmentId) || StringUtils.isEmpty(type) || StringUtils.isEmpty(status)) {
  921. return R.fail(ResponseCodesEnum.A0001, "参数有空");
  922. }
  923. TEquipment equipment = tEquipmentService.getById(equipmentId);
  924. if (equipment == null || equipment.getId() == null) {
  925. return R.fail(ResponseCodesEnum.A0001, "找不到设备");
  926. }
  927. if (type.equals("0")) {
  928. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("outdoor", status).toString());
  929. } else if (type.equals("1")) {
  930. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("indoor", status).toString());
  931. }
  932. return R.ok(null, "修改成功");
  933. }
  934. @ApiOperation(value = "查看是否远程来关机成功")
  935. @PostMapping("/checkStatus")
  936. public ResponseEntity<?> checkStatus(@RequestBody StatisticsParam param) {
  937. String equipmentId = param.getEquipmentId();
  938. Long id = Long.valueOf(equipmentId);
  939. TEquipment equipment = tEquipmentService.getById(id);
  940. String network = equipment.getNetwork();
  941. Long nowTime2 = getNetworkTime();
  942. // Long nowTime2 = new Date().getTime();
  943. if (network != null) {
  944. Long old = Long.valueOf(network);
  945. if (nowTime2 == null) {
  946. nowTime2 = getNetworkTime();
  947. }
  948. if (nowTime2 == null) {
  949. nowTime2 = System.currentTimeMillis();
  950. }
  951. if (nowTime2 - old < 15000) {
  952. return ResponseEntity
  953. .status(HttpStatus.OK)
  954. .body(new ResultMessage()
  955. .setCode(true)
  956. .setData("SUCCESS")
  957. .setMessage("网络良好"));
  958. } else {
  959. // if(equipment.getEqeStatus()==0){
  960. // equipment.setEqeStatus(1);
  961. // tEquipmentService.updateById(equipment);
  962. // }else {
  963. // equipment.setEqeStatus(0);
  964. // tEquipmentService.updateById(equipment);
  965. // }
  966. return ResponseEntity
  967. .status(HttpStatus.OK)
  968. .body(new ResultMessage()
  969. .setCode(true)
  970. .setData("fail")
  971. .setMessage("网络不好,操作失败"));
  972. }
  973. } else {
  974. return ResponseEntity
  975. .status(HttpStatus.OK)
  976. .body(new ResultMessage()
  977. .setCode(true)
  978. .setData("SUCCESS")
  979. .setMessage("该机器尚未更新系统"));
  980. }
  981. }
  982. public static Long getNetworkTime() {
  983. Long time = null;
  984. URL url = null;//取得资源对象http://time.tianqi.com/
  985. try {
  986. url = new URL("http://time.tianqi.com");
  987. URLConnection uc = url.openConnection();//生成连接对象
  988. uc.connect(); //发出连接
  989. long ld = uc.getDate(); //取得网站日期时间
  990. Date date = new Date(ld); //转换为标准时间对象
  991. time = date.getTime();
  992. } catch (Exception e) {
  993. e.printStackTrace();
  994. }
  995. return time;
  996. }
  997. @ApiOperation(value = "机器睡眠")
  998. @PostMapping("/sleep")
  999. public ResponseEntity<?> sleep(@RequestBody StatisticsParam param) {
  1000. String equipmentId = param.getEquipmentId();
  1001. Long id = Long.valueOf(equipmentId);
  1002. TEquipment equipment = tEquipmentService.getById(id);
  1003. if (equipment == null) {
  1004. // return ERROR_MESSAGE;
  1005. }
  1006. String eqeStatus = "0";
  1007. String code = param.getEqeStatus();
  1008. if (code.equals("1")) {
  1009. eqeStatus = "1";
  1010. equipment.setIsSleep(true);
  1011. } else {
  1012. equipment.setIsSleep(false);
  1013. }
  1014. tEquipmentService.updateById(equipment);
  1015. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("is_sleep", eqeStatus).toString());
  1016. // PushUtils.push(equipment.getGtClientId(), "", "", PushUtils.buildJson("is_sleep", eqeStatus).toString());
  1017. return ResponseEntity
  1018. .status(HttpStatus.OK)
  1019. .body(new ResultMessage()
  1020. .setCode(true)
  1021. .setData("SUCCESS")
  1022. .setMessage("SUCCESS"));
  1023. }
  1024. @ApiOperation(value = "获取机器开关机状态")
  1025. @PostMapping("/onoffStatus")
  1026. public ResponseEntity<?> onoffStatus(@RequestBody StatisticsParam param) {
  1027. String equipmentId = param.getEquipmentId();
  1028. Long id = Long.valueOf(equipmentId);
  1029. TEquipment equipments = tEquipmentService.getById(id);
  1030. tEquipmentService.sentMessage(equipments.getClientId(), PushUtils.buildJson("onoffstatus", "0").toString());
  1031. // PushUtils.push(equipments.getGtClientId(), "", "", PushUtils.buildJson("onoffstatus", "0").toString());
  1032. return ResponseEntity
  1033. .status(HttpStatus.OK)
  1034. .body(new ResultMessage()
  1035. .setCode(true)
  1036. .setData("SUCCESS")
  1037. .setMessage("SUCCESS"));
  1038. }
  1039. @ApiOperation(value = "获取所有机器开关机状态")
  1040. @PostMapping("/equipmentStatus")
  1041. public ResponseModel<?> equipmentStatus(@RequestBody StatisticsParam param) {
  1042. String adminId = param.getAdminId();
  1043. //碧桂园的机器太多,不查
  1044. if (adminId.equals("236") || adminId.equals("31")) {
  1045. return R.ok();
  1046. }
  1047. LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
  1048. query.eq(TEquipment::getAdminId, Long.valueOf(adminId));
  1049. List<TEquipment> equipmentList = tEquipmentService.list(query);
  1050. if (equipmentList.size() > 0) {
  1051. for (TEquipment equipment : equipmentList) {
  1052. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("onoffstatus", "0").toString());
  1053. // PushUtils.push(equipment.getGtClientId(), "", "", PushUtils.buildJson("onoffstatus", "0").toString());
  1054. }
  1055. }
  1056. return R.ok();
  1057. }
  1058. @ApiOperation(value = "检验所有机器是否开机")
  1059. @PostMapping("/checkEquipmentStatus")
  1060. public ResponseModel<?> checkEquipmentStatus(@RequestBody StatisticsParam param) {
  1061. // 通过管理员ID查询所有设备
  1062. String adminId = param.getAdminId();
  1063. LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
  1064. query.eq(TEquipment::getAdminId, Long.valueOf(adminId));
  1065. List<TEquipment> equipmentList = tEquipmentService.list(query);
  1066. // 获取当前时间,并检查设备状态是否过期
  1067. long nowTime = System.currentTimeMillis();
  1068. if (equipmentList.size() > 0) {
  1069. for (TEquipment equipment : equipmentList) {
  1070. // 如果设备的最后修改时间超过310秒前,则清除设备状态信息
  1071. long modifyTime = equipment.getModifyDate().getTime();
  1072. if (nowTime > modifyTime && (nowTime - modifyTime) > 310000) {
  1073. equipment.setCabinetTm("");
  1074. equipment.setCabinetHd("");
  1075. equipment.setFurnaceTm("");
  1076. equipment.setFurnaceSp("");
  1077. tEquipmentService.updateById(equipment);
  1078. }
  1079. }
  1080. }
  1081. // 返回操作成功的响应
  1082. return R.ok();
  1083. }
  1084. @ApiOperation(value = "机器开关机")
  1085. @PostMapping("/onOff")
  1086. public ResponseEntity<?> onOff(@RequestBody StatisticsParam param) {
  1087. String equipmentId = param.getEquipmentId();
  1088. Long id = Long.valueOf(equipmentId);
  1089. // TEquipment equipments = tEquipmentService.selectEntityById(id);
  1090. // PushUtils.push(equipments.getGtClientId(), "", "", PushUtils.buildJson("onoffstatus", "0").toString());
  1091. TEquipment equipment = tEquipmentService.getById(id);
  1092. if (equipment == null) {
  1093. // return ERROR_MESSAGE;
  1094. }
  1095. String eqeStatus = "1";
  1096. String code = param.getEqeStatus();
  1097. //开机为1,关机为0
  1098. Integer intcode = Integer.valueOf(code);
  1099. Integer eqeStatus1 = equipment.getEqeStatus();
  1100. // if(intcode==eqeStatus1){
  1101. // return ResponseEntity
  1102. // .status(HttpStatus.OK)
  1103. // .body(new ResultMessage()
  1104. // .setCode(false)
  1105. // .setData("ERROT")
  1106. // .setMessage("操作异常"));
  1107. // }
  1108. if (code.equals("0")) {
  1109. eqeStatus = "0";
  1110. equipment.setEqeStatus(0);
  1111. } else {
  1112. equipment.setEqeStatus(1);
  1113. }
  1114. Long time = getNetworkTime();
  1115. if (time == null) {
  1116. time = getNetworkTime();
  1117. }
  1118. if (time == null) {
  1119. time = System.currentTimeMillis();
  1120. }
  1121. if (time != null) {
  1122. // System.out.println("time=="+time);
  1123. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("eqeStatus", eqeStatus, String.valueOf(time), "http://time.tianqi.com").toString());
  1124. // PushUtils.push(equipment.getGtClientId(), "", "", PushUtils.buildJson("eqeStatus", eqeStatus,String.valueOf(time),"http://time.tianqi.com").toString());
  1125. // tEquipmentService.updateById(equipment);
  1126. } else {
  1127. return ResponseEntity
  1128. .status(HttpStatus.OK)
  1129. .body(new ResultMessage()
  1130. .setCode(false)
  1131. .setData("error")
  1132. .setMessage("error"));
  1133. }
  1134. return ResponseEntity
  1135. .status(HttpStatus.OK)
  1136. .body(new ResultMessage()
  1137. .setCode(true)
  1138. .setData("SUCCESS")
  1139. .setMessage("SUCCESS"));
  1140. }
  1141. @ApiOperation(value = "获取各省份机器销售情况")
  1142. @PostMapping("/getEquipmentListByProvince")
  1143. public ResponseEntity<?> getEquipmentListByProvince(@RequestBody TAdmin param) {
  1144. List<TAdminDTO> resultList = new ArrayList<>();
  1145. if ("admin".equals(param.getUsername())) { // 管理员查所有商家
  1146. //获取有多少个省份
  1147. List<TArea> list1 = tAreaService.getProvinceList();
  1148. Map<Long, String> map1 = new HashMap<>();
  1149. for (TArea area : list1) {
  1150. String fullname = area.getFullName();
  1151. String provinceName = fullname.substring(0, 3);
  1152. String treePath = area.getTreePath();
  1153. String[] str = treePath.split(",");
  1154. Long s = null;
  1155. if (str.length > 1) {
  1156. s = Long.valueOf(str[1]);
  1157. }
  1158. if (str.length <= 1) {
  1159. s = area.getId();
  1160. }
  1161. map1.put(s, provinceName);
  1162. }
  1163. List<Children3> children3List = new ArrayList<>();
  1164. for (Long key : map1.keySet()) {
  1165. Children3 children3 = new Children3();
  1166. children3.setId(key);
  1167. // children3.setName(map1.get(key));
  1168. int pday = 0;
  1169. int pweek = 0;
  1170. int pmonth = 0;
  1171. int pyear = 0;
  1172. Set<Long> province = new HashSet<>();
  1173. //本省有多少个市
  1174. Map<Long, String> cityMap = new HashMap<>();
  1175. for (TArea carea : list1) {
  1176. String fullName = carea.getFullName();
  1177. if (fullName.substring(0, 3).equals(map1.get(key))) {
  1178. province.add(carea.getId());
  1179. if (key.equals(carea.getParent())) {
  1180. cityMap.put(carea.getId(), carea.getName());
  1181. } else {
  1182. TArea cityArea = tAreaService.getById(carea.getParent());
  1183. cityMap.put(cityArea.getId(), cityArea.getName());
  1184. }
  1185. }
  1186. }
  1187. List<Children2> children2List = new ArrayList<>();
  1188. //有多少个市,市有多少个商家
  1189. for (Long citykey : cityMap.keySet()) {
  1190. for (TArea area : list1) {
  1191. String fullName = area.getFullName();
  1192. if (fullName.substring(0, 3).equals(map1.get(key))) {
  1193. //市级
  1194. Children2 children2 = new Children2();
  1195. //市级下所有商家集合
  1196. List<Child> Children = new ArrayList<>();
  1197. //属于这个市的所以设备的areaid
  1198. Set<Long> city = new HashSet<>();
  1199. //添加市级
  1200. if ((area.getId()).equals(citykey) || (area.getParent()).equals(citykey)) {
  1201. children2.setId(citykey);
  1202. for (TArea cityArea2 : list1) {
  1203. if ((cityArea2.getId()).equals(citykey) || (cityArea2.getParent()).equals(citykey)) {
  1204. city.add(cityArea2.getId());
  1205. }
  1206. }
  1207. children2.setCity(city);
  1208. int i = 0;
  1209. for (Children2 children21 : children2List) {
  1210. if (children21.getId().equals(citykey)) {
  1211. i++;
  1212. }
  1213. }
  1214. if (i == 0) {
  1215. for (Long id : city) {
  1216. // List<Childlast> childlasts = new ArrayList<>();
  1217. Set<Long> adminIds = new HashSet<>();
  1218. // List<TEquipment> equipments = tEquipmentService.findByArea(id);
  1219. LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
  1220. query.eq(TEquipment::getAreaId, id);
  1221. List<TEquipment> equipments = tEquipmentService.list(query);
  1222. for (TEquipment tEquipment : equipments) {
  1223. adminIds.add(tEquipment.getAdminId());
  1224. }
  1225. for (Long adminId3 : adminIds) {
  1226. TAdmin tAdmin = tAdminService.getById(adminId3);
  1227. int k = 0;
  1228. for (Child child : Children) {
  1229. if (child.getId().equals(tAdmin.getId())) {
  1230. k++;
  1231. }
  1232. }
  1233. if (k == 0) {
  1234. //new
  1235. Child child = new Child();
  1236. child.setId(adminId3);
  1237. child.setName(tAdmin.getName());
  1238. List<Childlast> children = new ArrayList<>();
  1239. Childlast childlast1 = new Childlast();
  1240. childlast1.setId(adminId3);
  1241. childlast1.setName("总销售情况");
  1242. children.add(0, childlast1);
  1243. // List<TEquipment> tEquipmentList = tEquipmentService.findByAdmin(adminId3);
  1244. LambdaQueryWrapper<TEquipment> query1 = Wrappers.lambdaQuery();
  1245. query1.eq(TEquipment::getAdminId, adminId3);
  1246. List<TEquipment> tEquipmentList = tEquipmentService.list(query1);
  1247. for (TEquipment tEquipment : tEquipmentList) {
  1248. Long areaId = tEquipment.getAreaId();
  1249. for (Long idd : city) {
  1250. if (idd.equals(areaId)) {
  1251. Childlast childlast2 = new Childlast();
  1252. childlast2.setId(tEquipment.getId());
  1253. childlast2.setName(tEquipment.getName());
  1254. children.add(childlast2);
  1255. }
  1256. }
  1257. }
  1258. child.setChildren(children);
  1259. Children.add(child);
  1260. }
  1261. }
  1262. }
  1263. children2.setChildren(Children);
  1264. //这个市的销售数据 日 周 月 年
  1265. List<Long> cityIds = new ArrayList();
  1266. for (Long cityid : city) {
  1267. cityIds.add(cityid);
  1268. }
  1269. StringBuffer namelast = new StringBuffer();
  1270. namelast.append(cityMap.get(citykey)).append(" ");
  1271. String day = "";
  1272. String week = "";
  1273. String month = "";
  1274. String year = "";
  1275. //数据为空时要处理
  1276. for (int s = 1; s < 5; s++) {
  1277. String startDate = null;
  1278. String endDate = null;
  1279. if (s == 1) {
  1280. //日
  1281. Date date = new Date();
  1282. SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd");
  1283. String format = dateFormat.format(date);
  1284. startDate = format;
  1285. endDate = format;
  1286. Map<String, Object> params = new HashMap<String, Object>();
  1287. params.put("areaIds", cityIds);
  1288. params.put("startDate", startDate);
  1289. params.put("endDate", endDate);
  1290. Double day1 = tOrderService.getAreaPrice(params);
  1291. if (day1 != null) {
  1292. double ceil = Math.ceil(day1);
  1293. int ceil1 = (int) ceil;
  1294. pday += ceil1;
  1295. day = String.valueOf(ceil1);
  1296. namelast.append("-----日:").append(day);
  1297. } else {
  1298. namelast.append("-----日:0 ");
  1299. }
  1300. }
  1301. if (s == 2) {
  1302. //周
  1303. Map<String, String> weekDate = getWeekDate();
  1304. startDate = weekDate.get("mondayDate");
  1305. endDate = weekDate.get("sundayDate");
  1306. Map<String, Object> params = new HashMap<String, Object>();
  1307. params.put("areaIds", cityIds);
  1308. params.put("startDate", startDate);
  1309. params.put("endDate", endDate);
  1310. Double day1 = tOrderService.getAreaPrice(params);
  1311. if (day1 != null) {
  1312. double ceil = Math.ceil(day1);
  1313. int ceil1 = (int) ceil;
  1314. pweek += ceil1;
  1315. week = String.valueOf(ceil1);
  1316. namelast.append(" 周:").append(week);
  1317. } else {
  1318. namelast.append(" 周:0 ");
  1319. }
  1320. }
  1321. if (s == 3) {
  1322. //月
  1323. SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd");
  1324. //获取当前月第一天:
  1325. Calendar c = Calendar.getInstance();
  1326. c.add(Calendar.MONTH, 0);
  1327. c.set(Calendar.DAY_OF_MONTH, 1);//设置为1号,当前日期既为本月第一天
  1328. String first = dateFormat.format(c.getTime());
  1329. //获取当前月最后一天
  1330. Calendar ca = Calendar.getInstance();
  1331. ca.set(Calendar.DAY_OF_MONTH, ca.getActualMaximum(Calendar.DAY_OF_MONTH));
  1332. String last = dateFormat.format(ca.getTime());
  1333. startDate = first;
  1334. endDate = last;
  1335. Map<String, Object> params = new HashMap<String, Object>();
  1336. params.put("areaIds", cityIds);
  1337. params.put("startDate", startDate);
  1338. params.put("endDate", endDate);
  1339. Double day1 = tOrderService.getAreaPrice(params);
  1340. if (day1 != null) {
  1341. double ceil = Math.ceil(day1);
  1342. int ceil1 = (int) ceil;
  1343. pmonth += ceil1;
  1344. month = String.valueOf(ceil1);
  1345. namelast.append(" 月:").append(month);
  1346. } else {
  1347. namelast.append(" 月:0 ");
  1348. }
  1349. }
  1350. if (s == 4) {
  1351. //年
  1352. SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd");
  1353. Calendar cale = Calendar.getInstance();
  1354. int year1 = cale.get(Calendar.YEAR);
  1355. String y = String.valueOf(year1);
  1356. StringBuffer st = new StringBuffer();
  1357. st.append(y).append("/01/01");
  1358. startDate = st.toString();
  1359. StringBuffer e = new StringBuffer();
  1360. e.append(y).append("/12/30");
  1361. endDate = e.toString();
  1362. Map<String, Object> params = new HashMap<String, Object>();
  1363. params.put("areaIds", cityIds);
  1364. params.put("startDate", startDate);
  1365. params.put("endDate", endDate);
  1366. Double day1 = tOrderService.getAreaPrice(params);
  1367. if (day1 != null) {
  1368. double ceil = Math.ceil(day1);
  1369. int ceil1 = (int) ceil;
  1370. pyear += ceil1;
  1371. year = String.valueOf(ceil1);
  1372. namelast.append(" 年:").append(year);
  1373. } else {
  1374. namelast.append(" 年:0 ");
  1375. }
  1376. }
  1377. }
  1378. children2.setName(namelast.toString());
  1379. children2List.add(children2);
  1380. } else {
  1381. i = 0;
  1382. }
  1383. }
  1384. }
  1385. }
  1386. }
  1387. children3.setChildren(children2List);
  1388. children3.setProvince(province);
  1389. StringBuffer pnameLast = new StringBuffer();
  1390. pnameLast.append(map1.get(key)).append("-----日:").append(pday).append(" 周:").append(pweek).append(" 月:").append(pmonth).append(" 年:").append(pyear);
  1391. children3.setName(pnameLast.toString());
  1392. children3List.add(children3);
  1393. }
  1394. return ResponseEntity.status(HttpStatus.OK)
  1395. .body(new ResultMessage().setCode(true).setData(children3List).setMessage("SUCCESS"));
  1396. } else { // 只查当前商家的设备列表
  1397. return ResponseEntity.status(HttpStatus.OK)
  1398. .body(new ResultMessage().setCode(true).setData(resultList).setMessage("SUCCESS"));
  1399. }
  1400. // return ResponseEntity.status(HttpStatus.OK)
  1401. // .body(new ResultMessage().setCode(true).setData(resultList).setMessage("SUCCESS"));
  1402. }
  1403. public static Map<String, String> getWeekDate() {
  1404. Map<String, String> map = new HashMap();
  1405. SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd");
  1406. Calendar cal = Calendar.getInstance();
  1407. cal.setFirstDayOfWeek(Calendar.MONDAY);// 设置一个星期的第一天,按中国的习惯一个星期的第一天是星期一
  1408. int dayWeek = cal.get(Calendar.DAY_OF_WEEK);// 获得当前日期是一个星期的第几天
  1409. if (dayWeek == 1) {
  1410. dayWeek = 8;
  1411. }
  1412. // System.out.println("要计算日期为:" + sdf.format(cal.getTime())); // 输出要计算日期
  1413. cal.add(Calendar.DATE, cal.getFirstDayOfWeek() - dayWeek);// 根据日历的规则,给当前日期减去星期几与一个星期第一天的差值
  1414. Date mondayDate = cal.getTime();
  1415. String weekBegin = sdf.format(mondayDate);
  1416. // System.out.println("所在周星期一的日期:" + weekBegin);
  1417. cal.add(Calendar.DATE, 4 + cal.getFirstDayOfWeek());
  1418. Date sundayDate = cal.getTime();
  1419. String weekEnd = sdf.format(sundayDate);
  1420. // System.out.println("所在周星期日的日期:" + weekEnd);
  1421. map.put("mondayDate", weekBegin);
  1422. map.put("sundayDate", weekEnd);
  1423. return map;
  1424. }
  1425. /**
  1426. * 推送设备共同以及/设备参数
  1427. *
  1428. * @param
  1429. * @return
  1430. */
  1431. @PostMapping("/updateParameters")
  1432. public ResponseEntity<?> updateCommonParam(@RequestBody CommonParamVo commonParamVo) {
  1433. String equipmentId = commonParamVo.getId();
  1434. TEquipment equipment = tEquipmentService.getById(Long.valueOf(equipmentId));
  1435. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("Param", commonParamVo.getName() + ":" + commonParamVo.getVal()).toString());
  1436. // PushUtils.push(equipment.getGtClientId(), "", "", PushUtils.buildJson("Param", commonParamVo.getName() + ":" + commonParamVo.getVal()).toString());
  1437. return ResponseEntity
  1438. .status(HttpStatus.OK)
  1439. .body(new ResultMessage()
  1440. .setCode(true)
  1441. .setData("SUCCESS")
  1442. .setMessage("SUCCESS"));
  1443. }
  1444. /**
  1445. * 推送设备共同以及/设备参数 湿度
  1446. *
  1447. * @param
  1448. * @return
  1449. */
  1450. @PostMapping("/humidityParameters")
  1451. public ResponseEntity<?> humidityParameters(@RequestBody CommonParamVo commonParamVo) {
  1452. String equipmentId = commonParamVo.getId();
  1453. TEquipment equipment = tEquipmentService.getById(equipmentId);
  1454. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("humidityParameters", commonParamVo.getName() + ":" + commonParamVo.getVal()).toString());
  1455. // PushUtils.push(equipment.getGtClientId(), "", "", PushUtils.buildJson("Param", commonParamVo.getName() + ":" + commonParamVo.getVal()).toString());
  1456. return ResponseEntity
  1457. .status(HttpStatus.OK)
  1458. .body(new ResultMessage()
  1459. .setCode(true)
  1460. .setData("SUCCESS")
  1461. .setMessage("SUCCESS"));
  1462. }
  1463. /**
  1464. * 下载日志
  1465. *
  1466. * @param equipmentId
  1467. * @param day
  1468. * @param response
  1469. */
  1470. @ApiOperation(value = "下载日志")
  1471. @GetMapping("/downloadLog")
  1472. public ResponseModel<?> downloadLog(String equipmentId, String day, HttpServletResponse response) throws IOException, InterruptedException {
  1473. // 1、发送MQ到安卓端上传日志
  1474. /* if(day.length()!=8){
  1475. return R.fail(A0001,"日期格式有误");
  1476. }*/
  1477. if (StringUtils.isEmpty(equipmentId)) {
  1478. return R.fail(A0001);
  1479. }
  1480. TEquipment tEquipment = tEquipmentService.getById(equipmentId);
  1481. if (tEquipment == null) {
  1482. return R.fail(A0001, "该设备不存在");
  1483. }
  1484. String clientId = tEquipment.getClientId();
  1485. String kind = day + "-" + clientId;
  1486. String filepath = "/home/hboxs/log/" + kind + ".txt";
  1487. // 1.1 如果文件已存在,直接下载
  1488. if (Files.exists(Paths.get(filepath))) {
  1489. // DownloadUtils.downloadFile(filepath, response);
  1490. // return R.ok();
  1491. try {
  1492. Files.delete(Paths.get(filepath));
  1493. return R.ok();
  1494. } catch (IOException e) {
  1495. e.printStackTrace();
  1496. return R.fail(B0004, "请重试");
  1497. }
  1498. }
  1499. String channel = tEquipment.getChannel();
  1500. String equimentType = tEquipment.getEquimentType();
  1501. if (StringUtils.isEmpty(channel) || channel.equals("1") || StringUtils.isEmpty(equimentType)) {
  1502. //用个推
  1503. PushUtils.push(tEquipment.getGtClientId(), "", "", PushUtils.buildJson("log", kind).toString());
  1504. }
  1505. if (StringUtils.isNotEmpty(channel) && channel.equals("2") && StringUtils.isNotEmpty(equimentType)) {
  1506. //用Mq
  1507. tEquipmentService.sentMessage(tEquipment.getClientId(), PushUtils.buildJson("log", kind).toString());
  1508. }
  1509. // 2、设置定时器查看日志是否已上传
  1510. ScheduledExecutorService exec = Executors.newScheduledThreadPool(1);
  1511. long startTime = System.currentTimeMillis();
  1512. ScheduledFuture<?> future = exec.schedule(() -> {
  1513. // 超时处理逻辑
  1514. if (Files.exists(Paths.get(filepath))) {
  1515. return null;
  1516. } else {
  1517. throw new RuntimeException("找不到日志");
  1518. }
  1519. }, TIMEOUT, TimeUnit.MILLISECONDS);
  1520. while (true) {
  1521. if (Files.exists(Paths.get(filepath))) {
  1522. // 文件存在,取消定时器
  1523. future.cancel(false);
  1524. break;
  1525. } else {
  1526. Thread.sleep(1000);
  1527. if (System.currentTimeMillis() - startTime >= TIMEOUT) {
  1528. // 超过最大等待时间,抛出异常
  1529. future.cancel(false);
  1530. throw new RuntimeException("等待文件生成超时");
  1531. }
  1532. }
  1533. }
  1534. // 3、从服务器下载文件
  1535. DownloadUtils.downloadFile(filepath, response);
  1536. return R.ok();
  1537. }
  1538. // 从服务器下载文件
  1539. public void downloadFile(String filepath, HttpServletResponse response) throws IOException {
  1540. File logFile = new File(filepath);
  1541. response.setHeader("Content-Disposition", "attachment; filename=\"" + logFile.getName() + "\"");
  1542. FileInputStream fis = new FileInputStream(logFile);
  1543. OutputStream os = response.getOutputStream();
  1544. byte[] buffer = new byte[4096];
  1545. int length;
  1546. while ((length = fis.read(buffer)) > 0) {
  1547. os.write(buffer, 0, length);
  1548. os.flush();
  1549. }
  1550. os.close();
  1551. fis.close();
  1552. response.flushBuffer();
  1553. }
  1554. //查找设备
  1555. @ApiOperation(value = "获取对应的机器编号")
  1556. @GetMapping("/findEquipmentByClientIds")
  1557. public ResponseModel<List<TEquipment>> findEquipmentByClientIds(@RequestParam("clientIds") List<String> clientIds) {
  1558. LambdaQueryWrapper<TEquipment> wrapper = new LambdaQueryWrapper<>();
  1559. wrapper.in(TEquipment::getClientId, clientIds);
  1560. List<TEquipment> list = tEquipmentService.list(wrapper);
  1561. return R.ok(list);
  1562. }
  1563. @ApiOperation(value = "修改DIY花型功能开关状态")
  1564. @GetMapping("/updateDIYFlowerStatus")
  1565. public ResponseModel<?> updateDIYFlowerStatus(String equipmentId, String DIYFlowerStatus) {
  1566. if (StringUtils.isEmpty(DIYFlowerStatus) || StringUtils.isEmpty(equipmentId)) {
  1567. return R.fail(ResponseCodesEnum.A0001, "参数有空");
  1568. }
  1569. TEquipment equipment = tEquipmentService.getById(equipmentId);
  1570. if (equipment == null || equipment.getId() == null) {
  1571. return R.fail(ResponseCodesEnum.A0001, "找不到设备");
  1572. }
  1573. TEquipmentDesc tEquipmentDesc = equipmentDescService.getById(equipment.getId());
  1574. if (tEquipmentDesc != null) {
  1575. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("DIYFlowerStatus", DIYFlowerStatus).toString());
  1576. } else {
  1577. return R.fail(ResponseCodesEnum.A0001, "找不到设备");
  1578. }
  1579. return R.ok(null, "发送成功");
  1580. }
  1581. @ApiOperation(value = "修改DIY花型的形状或是否显示")
  1582. @PostMapping("/updateDIYProductShow")
  1583. public ResponseModel<?> updateDIYProductShow(@RequestBody String productList) {
  1584. JSONObject jsonObject = JSONObject.parseObject(productList);
  1585. List<TDiyFlower> products = JSONObject.parseArray(jsonObject.get("productList").toString(), TDiyFlower.class);
  1586. if (products.size() > 0) {
  1587. TDiyFlower diyFlower = products.get(0);
  1588. if (diyFlower == null && diyFlower.getEquipmentId() == null) {
  1589. return R.fail(ResponseCodesEnum.A0001, "找不到当前设备");
  1590. }
  1591. }
  1592. TEquipment equipment = tEquipmentService.getById(products.get(0).getEquipmentId());
  1593. if (equipment == null) {
  1594. return R.fail(ResponseCodesEnum.A0001, "请退出重试");
  1595. }
  1596. List<TProductBean> list = new ArrayList<>();
  1597. for (TDiyFlower product : products) {
  1598. TProductBean productBean = new TProductBean();
  1599. if (product != null && product.getId() != null) {
  1600. productBean.setShowType(product.getShowType());
  1601. if (StringUtils.isEmpty(product.getShowType())) {
  1602. productBean.setShowType("1");
  1603. }
  1604. productBean.setProductName(product.getName());
  1605. list.add(productBean);
  1606. }
  1607. }
  1608. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("updateDIYProductShow", JSON.toJSONString(list)).toString());
  1609. // tDiyFlowerService.updateBatchById(products);
  1610. return R.ok(null, "修改请求发送成功");
  1611. }
  1612. @ApiOperation(value = "查询DIY花型列表信息")
  1613. @GetMapping("/selectDIYFlowers")
  1614. public ResponseModel<?> selectDIYFlowers(String equipmentId) {
  1615. if (StringUtils.isEmpty(equipmentId)) {
  1616. return R.fail(ResponseCodesEnum.A0001, "参数有空");
  1617. }
  1618. LambdaQueryWrapper<TDiyFlower> query = Wrappers.lambdaQuery();
  1619. query.eq(TDiyFlower::getEquipmentId, Long.valueOf(equipmentId));
  1620. List<TDiyFlower> list = tDiyFlowerService.list(query);
  1621. return R.ok(list);
  1622. }
  1623. @ApiOperation(value = "远程修改锁机状态,锁机:1,解锁:0")
  1624. @GetMapping("/updateLockStatus")
  1625. public ResponseModel<?> updateLockStatus(String equipmentId, String status) {
  1626. if (StringUtils.isEmpty(equipmentId) || StringUtils.isEmpty(status)) {
  1627. return R.fail(ResponseCodesEnum.A0001, "参数有空");
  1628. }
  1629. TEquipment equipment = tEquipmentService.getById(equipmentId);
  1630. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("block", status).toString());
  1631. return R.ok();
  1632. }
  1633. /**
  1634. * 上传日志
  1635. *
  1636. * @param equipmentId 设备ID,用于标识上传日志的设备
  1637. * @param day 日期,指定要上传日志的日期
  1638. * @return 返回操作结果,成功则返回成功信息,失败则返回失败原因
  1639. */
  1640. @ApiOperation(value = "上传日志")
  1641. @GetMapping("/uploadLog")
  1642. public ResponseModel<?> uploadLog(String equipmentId, String day) {
  1643. // 检查设备ID是否为空
  1644. if (StringUtils.isEmpty(equipmentId)) {
  1645. return R.fail(A0001);
  1646. }
  1647. // 根据设备ID查询设备信息
  1648. TEquipment tEquipment = tEquipmentService.getById(equipmentId);
  1649. // 检查设备信息是否存在
  1650. if (tEquipment == null) {
  1651. return R.fail(A0001, "该设备不存在");
  1652. }
  1653. // 组装日志信息的标识
  1654. String clientId = tEquipment.getClientId();
  1655. String kind = day + "-" + clientId;
  1656. // 获取设备的渠道号和类型
  1657. String channel = tEquipment.getChannel();
  1658. String equimentType = tEquipment.getEquimentType();
  1659. // 如果渠道号为空或为"1",或设备类型为空,则使用个推推送日志
  1660. if (StringUtils.isEmpty(channel) || channel.equals("1") || StringUtils.isEmpty(equimentType)) {
  1661. PushUtils.push(tEquipment.getGtClientId(), "", "", PushUtils.buildJson("log", kind).toString());
  1662. }
  1663. // 如果渠道号为"2"且设备类型不为空,则使用MQ发送日志
  1664. if (StringUtils.isNotEmpty(channel) && channel.equals("2") && StringUtils.isNotEmpty(equimentType)) {
  1665. tEquipmentService.sentMessage(tEquipment.getClientId(), PushUtils.buildJson("log", kind).toString());
  1666. }
  1667. // 返回操作成功信息
  1668. return R.ok();
  1669. }
  1670. /**
  1671. * 查询指定设备在指定日期的日志是否已上传至七牛云。
  1672. *
  1673. * @param equipmentId 设备ID,用于查询日志所属设备。
  1674. * @param day 日期,格式为"yyyy-MM-dd",用于指定要查询的日志日期。
  1675. * @return 返回一个响应模型对象,如果日志已上传则返回成功信息和日志文件名,否则返回失败信息。
  1676. */
  1677. @ApiOperation(value = "查询日志是否上传成功")
  1678. @GetMapping("/queryLog")
  1679. public ResponseModel<?> queryLog(String equipmentId, String day) {
  1680. // 检查设备ID是否为空
  1681. if (StringUtils.isEmpty(equipmentId)) {
  1682. return R.fail(A0001);
  1683. }
  1684. // 根据设备ID查询设备信息
  1685. TEquipment tEquipment = tEquipmentService.getById(equipmentId);
  1686. if (tEquipment == null) {
  1687. return R.fail(A0001, "该设备不存在");
  1688. }
  1689. // 根据设备ID和日期构造日志文件名
  1690. String clientId = tEquipment.getClientId();
  1691. String key = "log/" + day + "-" + clientId + ".txt";
  1692. // 配置七牛云连接
  1693. Configuration cfg = new Configuration(Region.region2());
  1694. Auth auth = Auth.create(ConfigConsts.QINIU_CLOUD_ACCESS_KEY, ConfigConsts.QINIU_CLOUD_SECRET_KEY);
  1695. BucketManager bucketManager = new BucketManager(auth, cfg);
  1696. boolean flag = true;
  1697. try {
  1698. // 尝试获取指定文件信息,判断文件是否存在
  1699. FileInfo fileInfo = bucketManager.stat(ConfigConsts.QINIU_CLOUD_BUCKET, key);
  1700. } catch (QiniuException ex) {
  1701. System.err.println(ex.response.error);
  1702. flag = false;
  1703. }
  1704. // 根据文件是否存在返回相应结果
  1705. if (flag) {
  1706. return R.ok(key);
  1707. }
  1708. return R.fail(F0002);
  1709. }
  1710. /**
  1711. * 修改DIY功能使用的密码
  1712. *
  1713. * @param diyPassword 新的DIY功能密码
  1714. * @return 返回操作结果,成功返回成功标志,失败返回错误代码
  1715. */
  1716. @ApiOperation(value = "修改diy功能使用密码")
  1717. @GetMapping("/updateDIYPassword")
  1718. public ResponseModel<?> updateDIYPassword(String diyPassword) {
  1719. // 检查传入的DIY密码是否为空
  1720. if (StringUtils.isEmpty(diyPassword)) {
  1721. return R.fail(A0001);
  1722. }
  1723. // 获取管理员对象
  1724. TAdmin admin = tAdminService.getById(1L);
  1725. // 设置新的DIY密码
  1726. admin.setDiyPassword(diyPassword);
  1727. // 更新管理员信息
  1728. tAdminService.updateById(admin);
  1729. // 返回操作成功标志
  1730. return R.ok();
  1731. }
  1732. @ApiOperation(value = "远程开启触摸屏")
  1733. @GetMapping("/openScreen")
  1734. public ResponseModel<?> openScreen(String equipmentId) {
  1735. // 检查设备ID是否为空
  1736. if (StringUtils.isEmpty(equipmentId)) {
  1737. return R.fail(A0001);
  1738. }
  1739. // 根据设备ID查询设备信息
  1740. TEquipment equipment = tEquipmentService.getById(equipmentId);
  1741. if (equipment == null) {
  1742. return R.fail(A0001, "该设备不存在");
  1743. }
  1744. // 远程开启触摸屏
  1745. String clientId = equipment.getClientId();
  1746. tEquipmentService.sentMessage(clientId, PushUtils.buildJson("restartAndroid", "restartAndroid").toString());
  1747. return R.ok();
  1748. }
  1749. }