TEquipmentController.java 89 KB

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