115 Commits

Author SHA1 Message Date
Your Name
84cf4bfc06 修复自定义按键功能的问题,修复后台UI的问题 2025-03-20 22:41:37 +08:00
oopuuu
542e5daf8a Update user_gpio.c 2025-03-20 21:27:09 +08:00
oopuuu
ceb208813a Update build.sh 2025-03-20 19:42:58 +08:00
nhkefus
fe4d037390 修复后台部分模块标题不显示的问题 2025-03-20 18:11:30 +08:00
nhkefus
8e083fe175 修改多击按钮的逻辑判断 2025-03-20 16:04:38 +08:00
nhkefus
9ac9e5e2f1 修复网页按钮配置功能UI错误 2025-03-20 15:14:20 +08:00
nhkefus
36d8330ee3 修复网页按钮配置功能UI错误 2025-03-20 14:56:08 +08:00
nhkefus
a51c7a8eb2 修复网页按钮配置功能UI错误 2025-03-20 14:44:47 +08:00
nhkefus
6ef875879f 修复网页按钮配置功能UI错误 2025-03-20 14:30:58 +08:00
nhkefus
2b2a77b5f5 修复网页按钮配置功能UI错误 2025-03-20 14:19:34 +08:00
nhkefus
787e57439e 修复网页按钮配置功能UI错误 2025-03-20 14:08:05 +08:00
nhkefus
fd157172e3 修复网页按钮配置功能UI错误 2025-03-20 14:07:07 +08:00
nhkefus
989fd0a1ed 修复网页按钮配置功能UI错误 2025-03-20 14:03:50 +08:00
oopuuu
a76afc6ccb Merge pull request #1 from wsuow/master
新增Https的测试
2025-03-20 13:41:06 +08:00
nhkefus
23fcd56109 修复网页按钮配置功能逻辑错误 2025-03-20 13:36:39 +08:00
wsuow
a6bb74f906 Merge branch 'oopuuu:master' into master 2025-03-20 12:53:32 +08:00
nhkefus
fd5d190096 在后台增加 1到10击 功能设置 2025-03-20 12:52:49 +08:00
wsuow
997eda3ef2 Merge branch 'oopuuu:master' into master 2025-03-20 12:50:51 +08:00
nhkefus
e4e0ca969e 在后台增加 1到10击 功能设置 2025-03-20 12:49:42 +08:00
wsuow
4ea9df172b Merge branch 'oopuuu:master' into master 2025-03-20 12:46:51 +08:00
nhkefus
d0a71fe216 在后台增加 1到10击 功能设置 2025-03-20 12:46:19 +08:00
wsuow
c8dd3d513d Merge branch 'oopuuu:master' into master 2025-03-20 12:34:01 +08:00
nhkefus
dd5b282c85 在后台增加 1到10击 功能设置 2025-03-20 12:31:27 +08:00
nhkefus
8acef18406 在后台增加 1到10击 功能设置 2025-03-20 12:24:46 +08:00
吴永福
13df06e546 撤销https关键字 2025-03-20 10:39:46 +08:00
wsuow
9df4b8358b Merge branch 'oopuuu:master' into master 2025-03-20 10:37:17 +08:00
吴永福
bdfed87f1e Merge branch 'master' of https://github.com/wsuow/zTC1 2025-03-20 10:22:12 +08:00
吴永福
7ea87ae4c9 增加https关键字 2025-03-20 10:21:32 +08:00
oopuuu
a87d894c4d Update user_mqtt_client.c 2025-03-19 23:42:42 +08:00
wsuow
d7e695e37e Merge branch 'oopuuu:master' into master 2025-03-19 22:48:28 +08:00
oopuuu
40bdb50a8d Update README.md 2025-03-19 22:27:30 +08:00
Your Name
caffddfb43 后台支持设备重命名 2025-03-19 22:22:17 +08:00
oopuuu
11d3d50265 Update README.md 2025-03-19 18:29:08 +08:00
nhkefus
66d2863fa4 修改固件功能说明 2025-03-19 18:27:08 +08:00
吴永福
56395f62bc 修改生成ota年月日时分秒.bin和all年月日时分秒.bin 2025-03-19 17:20:45 +08:00
wsuow
0d5ba4a7d3 Merge branch 'oopuuu:master' into master 2025-03-19 16:49:34 +08:00
nhkefus
d925c7d805 修复长按5s开启配网模式的逻辑问题 2025-03-19 16:45:09 +08:00
wsuow
b40bb1a022 Merge branch 'oopuuu:master' into master 2025-03-19 15:36:52 +08:00
nhkefus
981c33e3ad 修复后台电量显示数据错误 2025-03-19 15:16:10 +08:00
wsuow
fc631ac9f5 Merge branch 'oopuuu:master' into master 2025-03-19 14:58:12 +08:00
nhkefus
840b0eb374 修复后台电量显示数据错误 2025-03-19 14:51:20 +08:00
wsuow
f2f63625cc Merge branch 'oopuuu:master' into master 2025-03-19 14:36:17 +08:00
nhkefus
78dbc6209b 增加了童锁功能 2025-03-19 14:34:14 +08:00
wsuow
2896243e24 Merge branch 'oopuuu:master' into master 2025-03-19 14:30:44 +08:00
nhkefus
9d80970e9e 增加了童锁功能 2025-03-19 14:29:09 +08:00
wsuow
7bac9096f5 Merge branch 'oopuuu:master' into master 2025-03-19 14:21:22 +08:00
nhkefus
5f81f2ca71 增加了童锁功能 2025-03-19 14:19:09 +08:00
nhkefus
57dbe17175 在后台增加显示昨日今日耗电量 2025-03-19 12:54:01 +08:00
wsuow
a8d5319d52 Merge branch 'oopuuu:master' into master 2025-03-19 12:35:29 +08:00
nhkefus
f41a20f8d0 在后台增加显示昨日今日耗电量 2025-03-19 12:34:53 +08:00
oopuuu
52da5983b5 Update README.md 2025-03-19 12:19:48 +08:00
oopuuu
758abf123b Add files via upload 2025-03-19 12:16:36 +08:00
wsuow
e3de06437b Merge branch 'oopuuu:master' into master 2025-03-19 10:41:53 +08:00
nhkefus
7f0e5d15c8 修复已知问题 2025-03-19 10:41:02 +08:00
wsuow
7656ae998c Merge branch 'oopuuu:master' into master 2025-03-19 10:12:14 +08:00
nhkefus
3aec445e57 修复已知问题 2025-03-19 10:08:10 +08:00
wsuow
7048333ebc Merge branch 'oopuuu:master' into master 2025-03-19 09:59:08 +08:00
nhkefus
bfae22ddd6 修复已知问题 2025-03-19 09:55:47 +08:00
wsuow
520a245ef3 Merge branch 'oopuuu:master' into master 2025-03-19 08:37:27 +08:00
oopuuu
1f92b30ea0 Update user_mqtt_client.c
指定hass中的实体名称,防止新功能导致它变化
2025-03-19 00:51:44 +08:00
Your Name
4a20713693 修复插座命名功能的一些问题 2025-03-18 23:43:17 +08:00
nhkefus
b36fce48f5 修复已知编译问题 2025-03-18 13:56:24 +08:00
nhkefus
1b7d86f1f7 修复已知编译问题 2025-03-18 13:47:20 +08:00
wsuow
d7c83fa125 Merge branch 'oopuuu:master' into master 2025-03-18 13:35:48 +08:00
nhkefus
44ed1d2604 修复已知编译问题 2025-03-18 13:27:03 +08:00
wsuow
f17ca68404 Merge branch 'oopuuu:master' into master 2025-03-18 13:13:41 +08:00
nhkefus
b5cb7b8218 在后台增加6个开关重命名功能,名称将同步到ha mqtt设备中 2025-03-18 13:01:05 +08:00
oopuuu
b099618b91 Update README.md 2025-03-17 20:34:34 +08:00
oopuuu
160f4f5b7f Update README.md 2025-03-17 20:33:20 +08:00
oopuuu
168f89cc82 Add files via upload 2025-03-17 20:31:50 +08:00
wsuow
713dd1a907 Merge branch 'oopuuu:master' into master 2025-03-17 14:12:17 +08:00
nhkefus
59d8809641 修复总开关逻辑问题 2025-03-17 14:08:26 +08:00
wsuow
8537240bbd Merge branch 'oopuuu:master' into master 2025-03-17 13:57:40 +08:00
nhkefus
f1e15500e4 修复总开关逻辑问题 2025-03-17 13:57:08 +08:00
wsuow
5a1b82b728 Merge branch 'oopuuu:master' into master 2025-03-17 13:47:51 +08:00
nhkefus
f56beae55e 修复总开关逻辑问题 2025-03-17 13:44:35 +08:00
wsuow
9caeec8611 Merge branch 'oopuuu:master' into master 2025-03-17 13:22:10 +08:00
nhkefus
65d6c77a1e 修复总开关逻辑问题 2025-03-17 13:21:52 +08:00
wsuow
8a28029940 Merge branch 'oopuuu:master' into master 2025-03-17 13:14:48 +08:00
nhkefus
56f8a2efaa 修复总开关逻辑问题 2025-03-17 13:14:07 +08:00
wsuow
3964703152 Merge branch 'oopuuu:master' into master 2025-03-17 13:10:41 +08:00
nhkefus
b2b9152441 修复总开关逻辑问题 2025-03-17 13:10:04 +08:00
wsuow
4b000d109c Merge branch 'oopuuu:master' into master 2025-03-17 13:07:18 +08:00
nhkefus
6f6c1b700f 修复总开关逻辑问题 2025-03-17 11:38:48 +08:00
wsuow
90ba74b401 Merge branch 'oopuuu:master' into master 2025-03-17 11:16:27 +08:00
nhkefus
c49fc46e15 后台以及ha mqtt增加总开关功能 2025-03-17 10:43:37 +08:00
nhkefus
7113b361e8 后台以及ha mqtt增加总开关功能 2025-03-17 10:40:45 +08:00
oopuuu
a3e3639cf9 Update main.c 2025-03-16 14:38:42 +08:00
oopuuu
d0ff87c8d0 Update main.c 2025-03-16 14:37:17 +08:00
Your Name
b3a074d4c3 修复日耗电量统计的错误,mqtt中增加了TC1设备,传感器和开关现在归属在设备下 2025-03-14 21:35:45 +08:00
oopuuu
a639b58922 Update user_mqtt_client.c
向ha mqtt增加设备,而不是只增加实体
2025-03-14 23:12:06 +08:00
wsuow
208a7b3ef9 Merge branch 'oopuuu:master' into master 2025-03-14 12:53:22 +08:00
nhkefus
9e26335841 调试 2025-03-14 12:51:42 +08:00
wsuow
ba943fe6ae Merge branch 'oopuuu:master' into master 2025-03-14 12:48:35 +08:00
nhkefus
20d3c98bb4 调试 2025-03-14 11:49:51 +08:00
nhkefus
c27b89b82d 调试 2025-03-14 11:47:24 +08:00
wsuow
3fca5b51aa Merge branch 'oopuuu:master' into master 2025-03-14 11:21:48 +08:00
nhkefus
3070e5139f 调试 2025-03-14 11:21:25 +08:00
wsuow
daa3415717 Merge branch 'oopuuu:master' into master 2025-03-14 10:47:21 +08:00
nhkefus
a10788abeb 调试 2025-03-14 09:42:04 +08:00
nhkefus
c88fb23dfe 调试 2025-03-14 09:41:20 +08:00
wsuow
e7d380bf4c Merge branch 'oopuuu:master' into master 2025-03-13 10:55:31 +08:00
nhkefus
997c8695ab 调试 2025-03-13 10:54:56 +08:00
wsuow
eb7241e235 Merge branch 'oopuuu:master' into master 2025-03-13 10:31:51 +08:00
nhkefus
09a36dc351 调试 2025-03-13 09:56:55 +08:00
oopuuu
e6e46bdf39 Update main.c 2025-03-13 09:04:56 +08:00
oopuuu
24188e39c9 Update README.md 2025-03-12 14:42:13 +08:00
oopuuu
b9e6b02217 Update README.md 2025-03-12 14:19:42 +08:00
wsuow
3350aa5446 Merge branch 'oopuuu:master' into master 2025-03-12 08:40:13 +08:00
oopuuu
9f83fbd744 Update main.c
再次修改日电量统计逻辑
2025-03-12 00:49:15 +08:00
Your Name
51817d6b6a Merge branch 'master' of github.com:oopuuu/zTC1 2025-03-11 23:30:02 +08:00
Your Name
ad5f3ecf96 在hass mqtt中增加LED的开关 2025-03-11 23:26:59 +08:00
oopuuu
4e34a88be6 Update README.md 2025-03-11 20:11:01 +08:00
吴永福
c94e8fcd12 修复mico-os SDK库错误 2025-03-11 17:21:17 +08:00
吴永福
4ed9dbd435 更改README.md 2025-03-11 16:31:55 +08:00
24 changed files with 2286 additions and 1148 deletions

125
.cproject Normal file
View File

@@ -0,0 +1,125 @@
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<?fileVersion 4.0.0?><cproject storage_type_id="org.eclipse.cdt.core.XmlProjectDescriptionStorage">
<storageModule moduleId="org.eclipse.cdt.core.settings">
<cconfiguration id="0.2123886510">
<storageModule buildSystemId="org.eclipse.cdt.managedbuilder.core.configurationDataProvider" id="0.2123886510" moduleId="org.eclipse.cdt.core.settings" name="Default">
<externalSettings/>
<extensions>
<extension id="org.eclipse.cdt.core.GASErrorParser" point="org.eclipse.cdt.core.ErrorParser"/>
<extension id="org.eclipse.cdt.core.GmakeErrorParser" point="org.eclipse.cdt.core.ErrorParser"/>
<extension id="org.eclipse.cdt.core.GLDErrorParser" point="org.eclipse.cdt.core.ErrorParser"/>
<extension id="org.eclipse.cdt.core.VCErrorParser" point="org.eclipse.cdt.core.ErrorParser"/>
<extension id="org.eclipse.cdt.core.CWDLocator" point="org.eclipse.cdt.core.ErrorParser"/>
<extension id="org.eclipse.cdt.core.GCCErrorParser" point="org.eclipse.cdt.core.ErrorParser"/>
</extensions>
</storageModule>
<storageModule moduleId="cdtBuildSystem" version="4.0.0">
<configuration artifactName="${ProjName}" buildProperties="" description="" id="0.2123886510" name="Default" parent="org.eclipse.cdt.build.core.prefbase.cfg">
<folderInfo id="0.2123886510." name="/" resourcePath="">
<toolChain id="org.eclipse.cdt.build.core.prefbase.toolchain.1020810961" name="No ToolChain" resourceTypeBasedDiscovery="false" superClass="org.eclipse.cdt.build.core.prefbase.toolchain">
<targetPlatform id="org.eclipse.cdt.build.core.prefbase.toolchain.1020810961.1245561758" name=""/>
<builder buildPath="${ProjDirPath}/" command="${ProjDirPath}/make.exe" id="org.eclipse.cdt.build.core.settings.default.builder.1574076724" keepEnvironmentInBuildfile="false" managedBuildOn="false" name="Gnu Make Builder" superClass="org.eclipse.cdt.build.core.settings.default.builder"/>
<tool id="org.eclipse.cdt.build.core.settings.holder.libs.1419411456" name="holder for library settings" superClass="org.eclipse.cdt.build.core.settings.holder.libs"/>
<tool id="org.eclipse.cdt.build.core.settings.holder.1269034716" name="Assembly" superClass="org.eclipse.cdt.build.core.settings.holder">
<inputType id="org.eclipse.cdt.build.core.settings.holder.inType.2077730760" languageId="org.eclipse.cdt.core.assembly" languageName="Assembly" sourceContentType="org.eclipse.cdt.core.asmSource" superClass="org.eclipse.cdt.build.core.settings.holder.inType"/>
</tool>
<tool id="org.eclipse.cdt.build.core.settings.holder.416463984" name="GNU C++" superClass="org.eclipse.cdt.build.core.settings.holder">
<inputType id="org.eclipse.cdt.build.core.settings.holder.inType.1802293645" languageId="org.eclipse.cdt.core.g++" languageName="GNU C++" sourceContentType="org.eclipse.cdt.core.cxxSource,org.eclipse.cdt.core.cxxHeader" superClass="org.eclipse.cdt.build.core.settings.holder.inType"/>
</tool>
<tool id="org.eclipse.cdt.build.core.settings.holder.545607982" name="GNU C" superClass="org.eclipse.cdt.build.core.settings.holder">
<inputType id="org.eclipse.cdt.build.core.settings.holder.inType.1775218918" languageId="org.eclipse.cdt.core.gcc" languageName="GNU C" sourceContentType="org.eclipse.cdt.core.cSource,org.eclipse.cdt.core.cHeader" superClass="org.eclipse.cdt.build.core.settings.holder.inType"/>
</tool>
</toolChain>
</folderInfo>
</configuration>
</storageModule>
<storageModule moduleId="org.eclipse.cdt.core.externalSettings"/>
<storageModule moduleId="ilg.gnuarmeclipse.managedbuild.packs"/>
</cconfiguration>
</storageModule>
<storageModule moduleId="cdtBuildSystem" version="4.0.0">
<project id="MiCO-3-0.null.804040427" name="MiCO-3-0"/>
</storageModule>
<storageModule moduleId="scannerConfiguration">
<autodiscovery enabled="true" problemReportingEnabled="true" selectedProfileId=""/>
<scannerConfigBuildInfo instanceId="0.2123886510">
<autodiscovery enabled="true" problemReportingEnabled="true" selectedProfileId=""/>
</scannerConfigBuildInfo>
<scannerConfigBuildInfo instanceId="0.1826818492">
<autodiscovery enabled="true" problemReportingEnabled="true" selectedProfileId=""/>
</scannerConfigBuildInfo>
</storageModule>
<storageModule moduleId="org.eclipse.cdt.core.LanguageSettingsProviders"/>
<storageModule moduleId="refreshScope" versionNumber="2">
<configuration configurationName="Default">
<resource resourceType="PROJECT" workspacePath="/MiCO-3-0"/>
</configuration>
</storageModule>
<storageModule moduleId="org.eclipse.cdt.internal.ui.text.commentOwnerProjectMappings"/>
<storageModule moduleId="org.eclipse.cdt.make.core.buildtargets">
<buildTargets>
<target name="clean" path="" targetID="org.eclipse.cdt.build.MakeTargetBuilder">
<buildCommand>make</buildCommand>
<buildTarget>clean</buildTarget>
<stopOnError>true</stopOnError>
<useDefaultCommand>true</useDefaultCommand>
<runAllBuilders>true</runAllBuilders>
</target>
<target name="helloworld@MK3165 total download" path="" targetID="org.eclipse.cdt.build.MakeTargetBuilder">
<buildCommand>${ProjDirPath}/make.exe</buildCommand>
<buildArguments/>
<buildTarget>helloworld@MK3165 total download</buildTarget>
<stopOnError>true</stopOnError>
<useDefaultCommand>true</useDefaultCommand>
<runAllBuilders>true</runAllBuilders>
</target>
<target name="helloworld@MK3165" path="" targetID="org.eclipse.cdt.build.MakeTargetBuilder">
<buildCommand>${ProjDirPath}/make</buildCommand>
<buildArguments/>
<buildTarget>helloworld@MK3165</buildTarget>
<stopOnError>true</stopOnError>
<useDefaultCommand>true</useDefaultCommand>
<runAllBuilders>true</runAllBuilders>
</target>
<target name="standard release" path="" targetID="org.eclipse.cdt.build.MakeTargetBuilder">
<buildCommand>${ProjDirPath}/make.exe</buildCommand>
<buildTarget>standard release</buildTarget>
<stopOnError>true</stopOnError>
<useDefaultCommand>true</useDefaultCommand>
<runAllBuilders>true</runAllBuilders>
</target>
<target name="helloworld@MK3165 total" path="" targetID="org.eclipse.cdt.build.MakeTargetBuilder">
<buildCommand>${ProjDirPath}/make.exe</buildCommand>
<buildArguments/>
<buildTarget>helloworld@MK3165 total</buildTarget>
<stopOnError>true</stopOnError>
<useDefaultCommand>true</useDefaultCommand>
<runAllBuilders>true</runAllBuilders>
</target>
<target name="bluetooth.ble_hello_sensor@MK3238" path="" targetID="org.eclipse.cdt.build.MakeTargetBuilder">
<buildCommand>${ProjDirPath}/make.exe</buildCommand>
<buildArguments/>
<buildTarget>bluetooth.ble_hello_sensor@MK3238</buildTarget>
<stopOnError>true</stopOnError>
<useDefaultCommand>true</useDefaultCommand>
<runAllBuilders>true</runAllBuilders>
</target>
<target name="bluetooth.ble_hello_sensor@MK3238 total" path="" targetID="org.eclipse.cdt.build.MakeTargetBuilder">
<buildCommand>${ProjDirPath}/make.exe</buildCommand>
<buildArguments/>
<buildTarget>bluetooth.ble_hello_sensor@MK3238 total</buildTarget>
<stopOnError>true</stopOnError>
<useDefaultCommand>true</useDefaultCommand>
<runAllBuilders>true</runAllBuilders>
</target>
<target name="bluetooth.ble_hello_sensor@MK3238 total download" path="" targetID="org.eclipse.cdt.build.MakeTargetBuilder">
<buildCommand>${ProjDirPath}/make.exe</buildCommand>
<buildArguments/>
<buildTarget>bluetooth.ble_hello_sensor@MK3238 total download</buildTarget>
<stopOnError>true</stopOnError>
<useDefaultCommand>true</useDefaultCommand>
<runAllBuilders>true</runAllBuilders>
</target>
</buildTargets>
</storageModule>
</cproject>

2
.gdbinit Normal file
View File

@@ -0,0 +1,2 @@
set remotetimeout 20
shell start /B C:\Users\ooo\Desktop\MiCoder/OpenOCD/Win32/openocd_mico.exe -s ./ -f ./mico-os/makefiles/OpenOCD/interface/jlink_swd.cfg -f ./mico-os/makefiles/OpenOCD/mw3xx/mw3xx.cfg -f ./mico-os/makefiles/OpenOCD/mw3xx/mw3xx_gdb_jtag.cfg -l ./build/openocd_log.txt

3
.openocd_cfg Normal file
View File

@@ -0,0 +1,3 @@
source [find C:\Users\ooo\Desktop\MiCoder/OpenOCD/jlink_swd.cfg]
source [find C:\Users\ooo\Desktop\MiCoder/OpenOCD/mw3xx.cfg]
source [find C:\Users\ooo\Desktop\MiCoder/OpenOCD/mw3xx_gdb_jtag.cfg]

27
.project Normal file
View File

@@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<projectDescription>
<name>zTC1</name>
<comment></comment>
<projects>
</projects>
<buildSpec>
<buildCommand>
<name>org.eclipse.cdt.managedbuilder.core.genmakebuilder</name>
<triggers>cleanfullincremental</triggers>
<arguments>
</arguments>
</buildCommand>
<buildCommand>
<name>org.eclipse.cdt.managedbuilder.core.ScannerConfigBuilder</name>
<triggers>fullincremental</triggers>
<arguments>
</arguments>
</buildCommand>
</buildSpec>
<natures>
<nature>org.eclipse.cdt.core.cnature</nature>
<nature>org.eclipse.cdt.core.ccnature</nature>
<nature>org.eclipse.cdt.managedbuilder.core.managedBuildNature</nature>
<nature>org.eclipse.cdt.managedbuilder.core.ScannerConfigNature</nature>
</natures>
</projectDescription>

18
.vscode/c_cpp_properties.json vendored Normal file
View File

@@ -0,0 +1,18 @@
{
"configurations": [
{
"name": "windows-gcc-x64",
"includePath": [
"${workspaceFolder}/**"
],
"compilerPath": "gcc",
"cStandard": "${default}",
"cppStandard": "${default}",
"intelliSenseMode": "windows-gcc-x64",
"compilerArgs": [
""
]
}
],
"version": 4
}

24
.vscode/launch.json vendored Normal file
View File

@@ -0,0 +1,24 @@
{
"version": "0.2.0",
"configurations": [
{
"name": "C/C++ Runner: Debug Session",
"type": "cppdbg",
"request": "launch",
"args": [],
"stopAtEntry": false,
"externalConsole": true,
"cwd": "e:/15_GitHub/TC1/zTC1/TC1",
"program": "e:/15_GitHub/TC1/zTC1/TC1/build/Debug/outDebug",
"MIMode": "gdb",
"miDebuggerPath": "gdb",
"setupCommands": [
{
"description": "Enable pretty-printing for gdb",
"text": "-enable-pretty-printing",
"ignoreFailures": true
}
]
}
]
}

59
.vscode/settings.json vendored Normal file
View File

@@ -0,0 +1,59 @@
{
"C_Cpp_Runner.cCompilerPath": "gcc",
"C_Cpp_Runner.cppCompilerPath": "g++",
"C_Cpp_Runner.debuggerPath": "gdb",
"C_Cpp_Runner.cStandard": "",
"C_Cpp_Runner.cppStandard": "",
"C_Cpp_Runner.msvcBatchPath": "C:/Program Files/Microsoft Visual Studio/VR_NR/Community/VC/Auxiliary/Build/vcvarsall.bat",
"C_Cpp_Runner.useMsvc": false,
"C_Cpp_Runner.warnings": [
"-Wall",
"-Wextra",
"-Wpedantic",
"-Wshadow",
"-Wformat=2",
"-Wcast-align",
"-Wconversion",
"-Wsign-conversion",
"-Wnull-dereference"
],
"C_Cpp_Runner.msvcWarnings": [
"/W4",
"/permissive-",
"/w14242",
"/w14287",
"/w14296",
"/w14311",
"/w14826",
"/w44062",
"/w44242",
"/w14905",
"/w14906",
"/w14263",
"/w44265",
"/w14928"
],
"C_Cpp_Runner.enableWarnings": true,
"C_Cpp_Runner.warningsAsError": false,
"C_Cpp_Runner.compilerArgs": [],
"C_Cpp_Runner.linkerArgs": [],
"C_Cpp_Runner.includePaths": [],
"C_Cpp_Runner.includeSearch": [
"*",
"**/*"
],
"C_Cpp_Runner.excludeSearch": [
"**/build",
"**/build/**",
"**/.*",
"**/.*/**",
"**/.vscode",
"**/.vscode/**"
],
"C_Cpp_Runner.useAddressSanitizer": false,
"C_Cpp_Runner.useUndefinedSanitizer": false,
"C_Cpp_Runner.useLeakSanitizer": false,
"C_Cpp_Runner.showCompilationTime": false,
"C_Cpp_Runner.useLinkTimeOptimization": false,
"C_Cpp_Runner.msvcSecureNoWarnings": false
}

View File

@@ -8,10 +8,10 @@
# 固件web界面
<img src="doc/2.png"><img src="doc/1.png">
<img src="doc/IMG_0863.png"><img src="doc/1.png">
# HASS接入效果
<img src="doc/3.png">
<img src="doc/IMG_0862.png">
固件启动后, 会开启一个热点 TC1-AP-XXXXXX连接热点后, 直接用浏览器访问: http://192.168.0.1 即可看到如上web界面.
@@ -52,17 +52,25 @@ TC1 排插硬件分 A1 A2 两个版本, 本固件仅支持 **A1 版本**. A1 A2
- [x] HomeAssistant中增加总耗电量传感器今日耗电量传感器昨日耗电量传感器数据来自于插座历史统计
- [x] 可以设置mqtt数据上报频率默认2秒
- [x] 可以设置电源 led 是否打开,默认打开(系统自检以及错误指示灯仍会工作)
- [x] 后台和ha mqtt增加总开关控制
- [x] 后台可以自定义6个插座的名称名称将会自动同步到ha mqtt
- [x] 修复了原代码中电源按钮长按 (现在是5秒)重新配网和(10秒)恢复出厂的逻辑错误
- [x] 后台和ha mqtt中增加了童锁开关开启童锁则上电以后不再响应任何电源按钮的事件上电时同时按住按钮的话会开启配网热点防止开了童锁wifi又嗝屁导致插座功能暴毙的救命逻辑
- [x] 后台可自定义设备名称此名称将会同至ha mqtt作为mqtt中插座名称的前缀
# 编译固件
- windows环境先安装python2.7
- 安装[mico-cube 1.0.0](https://files.pythonhosted.org/packages/a8/4e/687a3ef2edabfd9fdd797747d6eeb2ddbe70e65c49fa4062268281a0ded4/mico-cube-1.0.0.tar.gz#sha256=4a930d394344f72c862c203d5d8a832357c3b3dc940c825ca3e528453dd2f17f)
- windows环境先安装python2.7,下载安装的时候添加环境变量到Path默认安装路径需要添加两个环境变量C:\Python27C:\Python27\Scripts
- 安装[mico-cube 1.0.0](https://files.pythonhosted.org/packages/a8/4e/687a3ef2edabfd9fdd797747d6eeb2ddbe70e65c49fa4062268281a0ded4/mico-cube-1.0.0.tar.gz#sha256=4a930d394344f72c862c203d5d8a832357c3b3dc940c825ca3e528453dd2f17f) python2 -m pip install ./mico-cube-1.0.0.tar.gz
- 安装[Micoder](http://firmware.mxchip.com/MiCoder_v1.3_Win32:64.zip)下载完解压出来(不要有中文路径)
- 安装完成后添加micoder路径 mico config --global MICODER (micoder所在路径)/MiCoder
- 最后切换到此项目根目录执行build.sh即可编译固件
# 注意事项
- 使用pip安装mico-cube失败请使用下列命令安装执行命令时注意路径位置
- `python -m pip install mico-cube-1.0.0.tar.gz`

View File

@@ -19,7 +19,7 @@
# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
# WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR
# IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
###############################################################################
###############################################################################
NAME := App_TC1

View File

@@ -52,7 +52,7 @@
static bool is_http_init;
static bool is_handlers_registered;
const struct httpd_wsgi_call g_app_handlers[];
char power_info_json[1552] = {0};
char power_info_json[1952] = {0};
char up_time[16] = "00:00:00";
/*
@@ -149,18 +149,29 @@ static int HttpGetAssets(httpd_request_t *req) {
static int HttpGetTc1Status(httpd_request_t *req) {
char *sockets = GetSocketStatus();
char *tc1_status = malloc(512);
char *short_click_config = GetShortClickConfig();
char *tc1_status = malloc(1024);
char *socket_names = malloc(512);
sprintf(socket_names, "%s,%s,%s,%s,%s,%s",
user_config->socket_names[0],
user_config->socket_names[1],
user_config->socket_names[2],
user_config->socket_names[3],
user_config->socket_names[4],
user_config->socket_names[5]);
sprintf(tc1_status, TC1_STATUS_JSON, sockets, ip_status.mode,
sys_config->micoSystemConfig.ssid, sys_config->micoSystemConfig.user_key,
user_config->ap_name, user_config->ap_key, MQTT_SERVER, MQTT_SERVER_PORT,
MQTT_SERVER_USR, MQTT_SERVER_PWD,
VERSION, ip_status.ip, ip_status.mask, ip_status.gateway, user_config->mqtt_report_freq,
user_config->power_led_enabled, 0L);
user_config->power_led_enabled, 0L, socket_names, childLockEnabled,
sys_config->micoSystemConfig.name, short_click_config);
OSStatus err = kNoErr;
send_http(tc1_status, strlen(tc1_status), exit, &err);
exit:
if (socket_names) free(socket_names);
if (tc1_status) free(tc1_status);
return err;
}
@@ -183,6 +194,89 @@ static int HttpSetSocketStatus(httpd_request_t *req) {
return err;
}
static int HttpSetSocketName(httpd_request_t *req) {
OSStatus err = kNoErr;
int buf_size = 70;
char *buf = malloc(buf_size);
err = httpd_get_data(req, buf, buf_size);
require_noerr(err, exit);
int index;
char name[64];
sscanf(buf, "%d %s", &index, name);
strcpy(user_config->socket_names[index], name);
mico_system_context_update(sys_config);
registerMqttEvents();
send_http("OK", 2, exit, &err);
exit:
if (buf) free(buf);
return err;
}
static int HttpSetShortClickEvent(httpd_request_t *req) {
OSStatus err = kNoErr;
int buf_size = 10;
char *buf = malloc(buf_size);
err = httpd_get_data(req, buf, buf_size);
require_noerr(err, exit);
int index;
int func;
sscanf(buf, "%d %d", &index, &func);
user_config->user[index + 1] = func;
mico_system_context_update(sys_config);
send_http("OK", 2, exit, &err);
exit:
if (buf) free(buf);
return err;
}
static int HttpSetDeviceName(httpd_request_t *req) {
OSStatus err = kNoErr;
int buf_size = 70;
char *buf = malloc(buf_size);
err = httpd_get_data(req, buf, buf_size);
require_noerr(err, exit);
char name[64];
sscanf(buf, "%s", name);
strcpy(sys_config->micoSystemConfig.name, name);
mico_system_context_update(sys_config);
registerMqttEvents();
send_http("OK", 2, exit, &err);
exit:
if (buf) free(buf);
return err;
}
static int HttpSetChildLock(httpd_request_t *req) {
OSStatus err = kNoErr;
int buf_size = 32;
char *buf = malloc(buf_size);
err = httpd_get_data(req, buf, buf_size);
require_noerr(err, exit);
int enableLock;
sscanf(buf, "%d", &enableLock);
user_config->user[0] = enableLock;
childLockEnabled = enableLock;
mico_system_context_update(sys_config);
UserMqttSendChildLockState();
send_http("OK", 2, exit, &err);
exit:
if (buf) free(buf);
return err;
}
static int HttpGetPowerInfo(httpd_request_t *req) {
OSStatus err = kNoErr;
char buf[16];
@@ -204,9 +298,21 @@ static int HttpGetPowerInfo(httpd_request_t *req) {
char *powers = GetPowerRecord(idx);
char *sockets = GetSocketStatus();
char *short_click_config = GetShortClickConfig();
char *socket_names = malloc(512);
sprintf(socket_names, "%s,%s,%s,%s,%s,%s",
user_config->socket_names[0],
user_config->socket_names[1],
user_config->socket_names[2],
user_config->socket_names[3],
user_config->socket_names[4],
user_config->socket_names[5]);
sprintf(power_info_json, POWER_INFO_JSON, sockets, power_record.idx, PW_NUM, p_count, powers,
up_time,user_config->power_led_enabled);
up_time, user_config->power_led_enabled, RelayOut() ? 1 : 0, socket_names,
user_config->p_count_1_day_ago, user_config->p_count_2_days_ago, childLockEnabled,
sys_config->micoSystemConfig.name, short_click_config);
send_http(power_info_json, strlen(power_info_json), exit, &err);
if (socket_names) free(socket_names);
exit:
return err;
}
@@ -328,6 +434,7 @@ static int HttpGetMqttReportFreq(httpd_request_t *req) {
send_http(freq, strlen(freq), exit, &err);
exit:
if (freq) free(freq);
return err;
}
@@ -350,6 +457,16 @@ static int HttpGetTasks(httpd_request_t *req) {
return err;
}
static int HttpGetShortClickEvents(httpd_request_t *req) {
OSStatus err = kNoErr;
char *clicks = GetShortClickConfig();
send_http(clicks, strlen(clicks), exit, &err);
exit:
if (clicks) free(clicks);
return err;
}
static int HttpAddTask(httpd_request_t *req) {
OSStatus err = kNoErr;
@@ -378,6 +495,7 @@ static int HttpAddTask(httpd_request_t *req) {
char *mess = (re == 4 && AddTask(task)) ? "OK" : "NO";
send_http(mess, strlen(mess), exit, &err);
if (mess) free(mess);
exit:
return err;
}
@@ -397,6 +515,7 @@ static int HttpDelTask(httpd_request_t *req) {
send_http(mess, strlen(mess), exit, &err);
exit:
if (time_str) free(time_str);
return err;
}
@@ -409,6 +528,7 @@ static int LedStatus(httpd_request_t *req) {
send_http(led, strlen(led), exit, &err);
exit:
if (led) free(led);
return err;
}
@@ -427,6 +547,7 @@ static int LedSetEnabled(httpd_request_t *req) {
} else {
UserLedSet(0);
}
UserMqttSendLedState();
mico_system_context_update(sys_config);
send_http("OK", 2, exit, &err);
@@ -436,6 +557,30 @@ static int LedSetEnabled(httpd_request_t *req) {
return err;
}
static int TotalSocketSetEnabled(httpd_request_t *req) {
OSStatus err = kNoErr;
int buf_size = 97;
int on;
char *buf = malloc(buf_size);
err = httpd_get_data(req, buf, buf_size);
require_noerr(err, exit);
sscanf(buf, "%d", &on);
UserRelaySetAll(on);
int i = 0;
for (; i < SOCKET_NUM; i++) {
UserMqttSendSocketState(i);
}
UserMqttSendTotalSocketState();
send_http("OK", 2, exit, &err);
exit:
if (buf) free(buf);
return err;
}
static int Otastatus(httpd_request_t *req) {
OSStatus err = kNoErr;
char buf[16] = {0};
@@ -476,6 +621,11 @@ const struct httpd_wsgi_call g_app_handlers[] = {
{"/task", HTTPD_HDR_DEFORT, APP_HTTP_FLAGS_NO_EXACT_MATCH, HttpGetTasks, HttpAddTask, NULL, HttpDelTask},
{"/ota", HTTPD_HDR_DEFORT, 0, Otastatus, OtaStart, NULL, NULL},
{"/led", HTTPD_HDR_DEFORT, 0, LedStatus, LedSetEnabled, NULL, NULL},
{"/socketAll", HTTPD_HDR_DEFORT, 0, NULL, TotalSocketSetEnabled, NULL, NULL},
{"/socketNames", HTTPD_HDR_DEFORT, 0, NULL, HttpSetSocketName, NULL, NULL},
{"/childLock", HTTPD_HDR_DEFORT, 0, NULL, HttpSetChildLock, NULL, NULL},
{"/deviceName", HTTPD_HDR_DEFORT, 0, NULL, HttpSetDeviceName, NULL, NULL},
{"/shortClickEvent", HTTPD_HDR_DEFORT, 0, HttpGetShortClickEvents, HttpSetShortClickEvent, NULL, NULL},
};
static int g_app_handlers_no = sizeof(g_app_handlers) / sizeof(struct httpd_wsgi_call);

View File

@@ -64,10 +64,14 @@
'gateway':'%s',\
'reportFreq':'%d',\
'ledEnabled':%d,\
'up_time':%ld\
'up_time':%ld,\
'socketNames':'%s',\
'child_lock_enabled':%d,\
'deviceName':'%s',\
'shortClicks':'%s'\
}"
#define POWER_INFO_JSON "{'sockets':'%s','idx':%d,'len':%d,'p_count':%ld,'powers':[%s],'up_time':'%s','led_enabled':%d}"
#define POWER_INFO_JSON "{'sockets':'%s','idx':%d,'len':%d,'p_count':%ld,'powers':[%s],'up_time':'%s','led_enabled':%d,'total_switch_on':%d,'socketNames':'%s','p_count_1_day_ago':%d,'p_count_2_days_ago':%d,'child_lock_enabled':%d,'deviceName':'%s','shortClicks':'%s'}"
int AppHttpdStart(void);

View File

@@ -20,27 +20,39 @@
<meta name="msapplication-TileColor" content="#3372DF">
<link rel="shortcut icon" href="http://yuntong.icu/tc1/images/favicon.png">
<link rel="stylesheet" href="assets/css_pack.css">
<style>
.mdl-menu {
z-index: 9999 !important;
}
</style>
</head>
<body>
<div class="demo-layout mdl-layout mdl-js-layout mdl-layout--fixed-drawer mdl-layout--fixed-header">
<header class="demo-header mdl-layout__header">
<div class="mdl-layout__header-row">
<span class="mdl-layout-title">TC1智能插座</span>
<div class="mdl-layout-spacer"></div>
<button class="mdl-button mdl-js-button mdl-js-ripple-effect mdl-button--icon"
id="hdrbtn">
<button class="mdl-button mdl-js-button mdl-js-ripple-effect mdl-button--icon edit-device-name">
<i class="material-icons">
<svg>
<use xlink:href="#icon-translate"/>
<use xlink:href="#icon-edit"/>
</svg>
</i>
</button>
<ul class="mdl-menu mdl-js-menu mdl-js-ripple-effect mdl-menu--bottom-right"
for="hdrbtn">
<li class="mdl-menu__item" onclick="ChangeLanguage('en')">English</li>
<li class="mdl-menu__item" onclick="ChangeLanguage('cn')">中文</li>
<li class="mdl-menu__item" onclick="ChangeLanguage('jp')">日本語</li>
</ul>
<span class="mdl-layout-title">TC1智能插座</span>
<div class="mdl-layout-spacer"></div>
<!-- <button class="mdl-button mdl-js-button mdl-js-ripple-effect mdl-button&#45;&#45;icon"-->
<!-- id="hdrbtn">-->
<!-- <i class="material-icons">-->
<!-- <svg>-->
<!-- <use xlink:href="#icon-translate"/>-->
<!-- </svg>-->
<!-- </i>-->
<!-- </button>-->
<!-- <ul class="mdl-menu mdl-js-menu mdl-js-ripple-effect mdl-menu&#45;&#45;bottom-right"-->
<!-- for="hdrbtn">-->
<!-- <li class="mdl-menu__item" onclick="ChangeLanguage('en')">English</li>-->
<!-- <li class="mdl-menu__item" onclick="ChangeLanguage('cn')">中文</li>-->
<!-- <li class="mdl-menu__item" onclick="ChangeLanguage('jp')">日本語</li>-->
<!-- </ul>-->
<button onclick="reboot()"
class="mdl-button mdl-js-button mdl-js-ripple-effect mdl-button--icon"
id="rebootbtn">
@@ -108,20 +120,27 @@
<div class="mdl-grid demo-content">
<div class="page page1 demo-cards mdl-cell mdl-cell--4-col mdl-cell--8-col-tablet mdl-grid mdl-grid--no-spacing">
<div class="demo-options mdl-card mdl-shadow--2dp mdl-cell mdl-cell--4-col mdl-cell--3-col-tablet mdl-cell--12-col-desktop">
<div class="mdl-card__supporting-text">
<h3>插座控制</h3>
<!--
<span class="mdl-list__item-secondary-action">
<label class="mdl-switch mdl-js-switch mdl-js-ripple-effect" for="list-switch-0">
<input type="checkbox" id="list-switch-0" class="mdl-switch__input" checked />
</label>
</span>
-->
<div class="page page1 mdl-cell mdl-cell--5-col demo-card-square mdl-card mdl-shadow--2dp"
style="overflow: unset;">
<div class="mdl-card__title mdl-card--expand">
<h2 class="mdl-card__title-text">插座控制</h2>
</div>
<ul id="socket_ul" class="demo-list-control mdl-list">
<li class="mdl-list__item">
<span class="mdl-list__item-primary-content">
<span class="lang" langKey="ChildLock">启用童锁</span>
</span>
<span class="mdl-list__item-secondary-action">
<label class="mdl-switch mdl-js-switch mdl-js-ripple-effect"
for="list-switch-child-lock">
<input type="checkbox" id="list-switch-child-lock" class="mdl-switch__input"
checked/>
</label>
</span>
</li>
<li class="mdl-list__item">
<span class="mdl-list__item-primary-content">
<span class="lang" langKey="Led">电源指示灯</span>
</span>
@@ -135,7 +154,26 @@
</li>
<li class="mdl-list__item">
<span class="mdl-list__item-primary-content">
<span class="lang" langKey="Socket">插座</span>-1
<span class="lang" langKey="SocketAll">总开关</span>
</span>
<span class="mdl-list__item-secondary-action">
<label class="mdl-switch mdl-js-switch mdl-js-ripple-effect"
for="list-switch-all">
<input type="checkbox" id="list-switch-all" class="mdl-switch__input"
checked/>
</label>
</span>
</li>
<li class="mdl-list__item">
<span class="mdl-list__item-primary-content">
<button class="mdl-button mdl-js-button mdl-js-ripple-effect mdl-button--icon edit-socket-name">
<i class="material-icons">
<svg>
<use xlink:href="#icon-edit"/>
</svg>
</i>
</button>
<span class="lang" langKey="Socket">插座</span><span class="socket-index">-1</span>
</span>
<span class="mdl-list__item-secondary-action">
<label class="mdl-switch mdl-js-switch mdl-js-ripple-effect"
@@ -147,7 +185,14 @@
</li>
<li class="mdl-list__item">
<span class="mdl-list__item-primary-content">
<span class="lang" langKey="Socket">插座</span>-2
<button class="mdl-button mdl-js-button mdl-js-ripple-effect mdl-button--icon edit-socket-name">
<i class="material-icons">
<svg>
<use xlink:href="#icon-edit"/>
</svg>
</i>
</button>
<span class="lang" langKey="Socket">插座</span><span class="socket-index">-2</span>
</span>
<span class="mdl-list__item-secondary-action">
<label class="mdl-switch mdl-js-switch mdl-js-ripple-effect"
@@ -159,7 +204,14 @@
</li>
<li class="mdl-list__item">
<span class="mdl-list__item-primary-content">
<span class="lang" langKey="Socket">插座</span>-3
<button class="mdl-button mdl-js-button mdl-js-ripple-effect mdl-button--icon edit-socket-name">
<i class="material-icons">
<svg>
<use xlink:href="#icon-edit"/>
</svg>
</i>
</button>
<span class="lang" langKey="Socket">插座</span><span class="socket-index">-3</span>
</span>
<span class="mdl-list__item-secondary-action">
<label class="mdl-switch mdl-js-switch mdl-js-ripple-effect"
@@ -171,7 +223,14 @@
</li>
<li class="mdl-list__item">
<span class="mdl-list__item-primary-content">
<span class="lang" langKey="Socket">插座</span>-4
<button class="mdl-button mdl-js-button mdl-js-ripple-effect mdl-button--icon edit-socket-name">
<i class="material-icons">
<svg>
<use xlink:href="#icon-edit"/>
</svg>
</i>
</button>
<span class="lang" langKey="Socket">插座</span><span class="socket-index">-4</span>
</span>
<span class="mdl-list__item-secondary-action">
<label class="mdl-switch mdl-js-switch mdl-js-ripple-effect"
@@ -183,7 +242,14 @@
</li>
<li class="mdl-list__item">
<span class="mdl-list__item-primary-content">
<span class="lang" langKey="Socket">插座</span>-5
<button class="mdl-button mdl-js-button mdl-js-ripple-effect mdl-button--icon edit-socket-name">
<i class="material-icons">
<svg>
<use xlink:href="#icon-edit"/>
</svg>
</i>
</button>
<span class="lang" langKey="Socket">插座</span><span class="socket-index">-5</span>
</span>
<span class="mdl-list__item-secondary-action">
<label class="mdl-switch mdl-js-switch mdl-js-ripple-effect"
@@ -195,7 +261,14 @@
</li>
<li class="mdl-list__item">
<span class="mdl-list__item-primary-content">
<span class="lang" langKey="Socket">插座</span>-6
<button class="mdl-button mdl-js-button mdl-js-ripple-effect mdl-button--icon edit-socket-name">
<i class="material-icons">
<svg>
<use xlink:href="#icon-edit"/>
</svg>
</i>
</button>
<span class="lang" langKey="Socket">插座</span><span class="socket-index">-6</span>
</span>
<span class="mdl-list__item-secondary-action">
<label class="mdl-switch mdl-js-switch mdl-js-ripple-effect"
@@ -208,21 +281,42 @@
</ul>
</div>
<div class="page page1 mdl-cell mdl-cell--5-col demo-card-square mdl-card mdl-shadow--2dp"
style="overflow: unset;">
<div class="mdl-card__title mdl-card--expand">
<h2 class="mdl-card__title-text">功率图</h2>
</div>
<div id="ct-chart-par"
class="page page1 mdl-card__supporting-text mdl-shadow--2dp mdl-cell mdl-cell--6-col"
style="height:315px;overflow-x:scroll;overflow-y:hidden;">
<table class="pw">
<tr>
<td>当前功率: <span id="p" class="success">0</span> W</td>
<td>今日电量: <span id="w_t" class="error">0</span> kW·h</td>
<td>昨日电量: <span id="w_y" class="error">0</span> kW·h</td>
<td>总电量: <span id="w" class="error">0</span> kW·h</td>
</tr>
</table>
<div id="ct-chart" class="ct-chart ct-perfect-fourth"
style="height:280px;margin-top:40px;"></div>
</div>
</div>
<div id="ct-chart-par"
class="page page1 mdl-card__supporting-text mdl-shadow--2dp mdl-cell mdl-cell--6-col"
style="height:315px;overflow-x:scroll;overflow-y:hidden;">
<table class="pw">
<tr>
<td>P: <span id="p" class="success">0</span> W</td>
<td>W: <span id="w" class="error">0</span> kW·h</td>
</tr>
</table>
<div id="ct-chart" class="ct-chart ct-perfect-fourth"
style="height:280px;margin-top:20px;"></div>
</div>
<div class="page page1 mdl-cell mdl-cell--5-col demo-card-square mdl-card mdl-shadow--2dp"
style="overflow: unset;">
<div class="mdl-card__title mdl-card--expand">
<h2 class="mdl-card__title-text">按键自定义</h2>
</div>
<table id="short_click_events_tb" class="mdl-data-table mdl-js-data-table">
<tr>
<th>按键类型</th>
<th>执行操作</th>
</tr>
</table>
</div>
<div class="page page2 mdl-cell mdl-cell--5-col demo-card-square mdl-card mdl-shadow--2dp"
style="overflow: unset;">
@@ -464,7 +558,8 @@
<td id="uptime">10:13:43</td>
</tr>
</table>
<div class="mdl-card__actions mdl-card--border">
<div class="mdl-card__actions mdl-card--border" style="display: flex; align-items: center; flex-wrap: wrap;">
<span style="font-size:0.8em;">提示长按电源按钮5s指示灯闪烁3次可开启热点重新配网10s指示灯保持闪烁恢复出厂设置</span>
<div class="mdl-layout-spacer"></div>
<i class="material-icons">
<svg>
@@ -532,6 +627,10 @@
<path d="M19 13h-6v6h-2v-6H5v-2h6V5h2v6h6v2z"/>
<path d="M0 0h24v24H0z" fill="none"/>
</g>
<g id="icon-edit">
<path d="M5,3C3.89,3 3,3.89 3,5V19A2,2 0 0,0 5,21H19A2,2 0 0,0 21,19V12H19V19H5V5H12V3H5M17.78,4C17.61,4 17.43,4.07 17.3,4.2L16.08,5.41L18.58,7.91L19.8,6.7C20.06,6.44 20.06,6 19.8,5.75L18.25,4.2C18.12,4.07 17.95,4 17.78,4M15.37,6.12L8,13.5V16H10.5L17.87,8.62L15.37,6.12Z" />
<path d="M0 0h24v24H0z" fill="none"/>
</g>
<g id="icon-translate">
<path d="M0 0h24v24H0z" fill="none"/>
<path d="M12.87 15.07l-2.54-2.51.03-.03c1.74-1.94 2.98-4.17 3.71-6.53H17V4h-7V2H8v2H1v1.99h11.17C11.5 7.92 10.44 9.75 9 11.35 8.07 10.32 7.3 9.19 6.69 8h-2c.73 1.63 1.73 3.17 2.98 4.56l-5.09 5.02L4 19l5-5 3.11 3.11.76-2.04zM18.5 10h-2L12 22h2l1.12-3h4.75L21 22h2l-4.5-12zm-2.62 7l1.62-4.33L19.12 17h-3.24z"/>
@@ -634,7 +733,9 @@
About: {en: "About", cn: "关于"},
//主页
Socket: {en: "Socket", cn: "插座"},
Led:{en: "PowerLed", cn: "电源指示灯"}
Led:{en: "PowerLed", cn: "电源指示灯"},
SocketAll:{en: "Total Switch", cn: "总开关"},
ChildLock:{en: "Child Lock", cn: "童锁"}
}
function ChangeLanguage(lang) {
if (lang == "jp") {
@@ -715,39 +816,6 @@
var mqtt_pwd;
var mqtt_freq;
HttpGet("/status", function (re) {
var status = JSON.parse(re);
var status_arr = status.sockets.split(",");
for (var i = 0; i < status_arr.length; i++) {
//checkboxs[i].checked = status_arr[i] == "1";
if (status_arr[i] == "1") {
switch_lables[i].MaterialSwitch.on();
} else {
switch_lables[i].MaterialSwitch.off();
}
}
if(status.mode == 1) {
$("#custom_station").click();
info_station_name = status.station_ssid;
info_wifi_password = status.station_pwd;
} else {
$("#custom_ap").click();
$("#custom_ssid")[0].parentElement.MaterialTextfield.change(status.ap_ssid);
info_wifi_password = status.ap_pwd;
}
mqtt_addr = status.mqtt_addr;
mqtt_port = status.mqtt_port;
mqtt_usr = status.mqtt_usr;
mqtt_pwd = status.mqtt_pwd;
mqtt_freq = status.reportFreq;
$("#info_version").html(status.version);
$("#info_ip").html(status.ip);
$("#info_mask").html(status.mask);
$("#info_gateway").html(status.gateway);
$("#uptime").html(status.up_time);
});
$("#st-date").html((new Date()).Format("yyyy-MM-dd"));
//Menu-start
@@ -787,16 +855,171 @@
var socket_ul = document.getElementById("socket_ul");
var checkboxs = socket_ul.getElementsByClassName("mdl-switch__input");
var switch_lables = socket_ul.getElementsByClassName("mdl-switch");
HttpGet("/status", function (re) {
var status = JSON.parse(re);
var status_arr = status.sockets.split(",");
var names_arr = status.socketNames.split(",");
var switchTexts = document.querySelectorAll('.mdl-list__item-primary-content');
$(".mdl-layout-title").text(status.deviceName);
document.title=status.deviceName;
for (var i = 0; i < status_arr.length; i++) {
var langSpan = switchTexts[i+3].querySelector('.lang');
var indexSpan = switchTexts[i+3].querySelector('.socket-index');
if (langSpan) langSpan.textContent = names_arr[i]; // 修改插座名称
if (indexSpan) indexSpan.textContent = ""; // 修改序号,可自定义起始数字
//checkboxs[i].checked = status_arr[i] == "1";
if (status_arr[i] == "1") {
switch_lables[i+3].MaterialSwitch.on();
} else {
switch_lables[i+3].MaterialSwitch.off();
}
}
if(status.mode == 1) {
$("#custom_station").click();
info_station_name = status.station_ssid;
info_wifi_password = status.station_pwd;
} else {
$("#custom_ap").click();
$("#custom_ssid")[0].parentElement.MaterialTextfield.change(status.ap_ssid);
info_wifi_password = status.ap_pwd;
}
mqtt_addr = status.mqtt_addr;
mqtt_port = status.mqtt_port;
mqtt_usr = status.mqtt_usr;
mqtt_pwd = status.mqtt_pwd;
mqtt_freq = status.reportFreq;
$("#info_version").html(status.version);
$("#info_ip").html(status.ip);
$("#info_mask").html(status.mask);
$("#info_gateway").html(status.gateway);
$("#uptime").html(status.up_time);
var actions=status.shortClicks.split(",");
//按键操作功能定义
var BTN_OPERATIONS=["切换总开关"];
for (var i = 0; i < names_arr.length; i++) {
BTN_OPERATIONS.push(`切换${names_arr[i]}`);
}
BTN_OPERATIONS.push("切换电源指示灯启用");
var tb_html = `
<tr>
<th>按键类型</th>
<th>执行操作</th>
</tr>
`;
for (var i = 0; i < actions.length; i++) {
var rowId = `select-${i}`;
var index = parseInt(actions[i]);
var valueText = (isNaN(index) || index < 0 || index >= BTN_OPERATIONS.length) ? '未设置' : BTN_OPERATIONS[index];
tb_html += `
<tr>
<td>${i > 0 ? '连续' : ''}短按${i + 1}次</td>
<td>
<div class="mdl-textfield mdl-js-textfield mdl-textfield--floating-label getmdl-select getmdl-select__fix-height">
<input class="mdl-textfield__input" type="text" id="${rowId}-input" readonly value="${valueText}">
<input type="hidden" id="${rowId}-value" value="${index}">
<ul class="mdl-menu mdl-menu--bottom-left mdl-js-menu" for="${rowId}-input">
<li class="mdl-menu__item" data-val="-1" onclick="selectOperation('${rowId}', -1,'${BTN_OPERATIONS[0]}')">未设置</li>
${BTN_OPERATIONS.map((op, idx) =>
`<li class="mdl-menu__item" data-val="${idx}" onclick="selectOperation('${rowId}', ${idx},'${BTN_OPERATIONS[idx]}')">${op}</li>`
).join('')}
</ul>
</div>
</td>
</tr>
`;
}
document.getElementById("short_click_events_tb").innerHTML = tb_html;
componentHandler.upgradeDom();
});
$(".mdl-switch__input").on("click", function() {
if("list-switch-all" == this.id||"list-switch-child-lock"== this.id){
return;
}
var sockets_st = "";
for (var i = 1; i < checkboxs.length; i++) {
for (var i = 3; i < checkboxs.length; i++) {
sockets_st += (checkboxs[i].checked ? "1," : "0,");
}
HttpPost("/socket", function (re) {
}, sockets_st);
HttpPost("/led", function (re) {
}, checkboxs[0].checked ? "1" : "0");
}, checkboxs[1].checked ? "1" : "0");
});
$(".edit-socket-name").on("click", function () {
// 获取当前按钮所在的 li 元素
var $li = $(this).closest(".mdl-list__item");
// 获取当前索引
var index = $(".edit-socket-name").index(this);
// 获取 lang 名称和 socket-index 元素
var $lang = $li.find(".lang");
var $index = $li.find(".socket-index");
// 原名称
var oldName = $lang.text().trim();
// 弹窗编辑
var newName = prompt("请输入新的插座名称", oldName);
if (newName && newName.trim() !== "") {
if(newName.trim().includes(" ")){
ShowToast("名称不能包含空格");
return;
}
if(newName.trim().length>16){
ShowToast("名称不能超过16个字");
return;
}
$lang.text(newName.trim());
// 可选:更新序号
$index.text("");
HttpPost("/socketNames", function (re) {
}, index+' '+newName.trim());}
});
$(".edit-device-name").on("click", function () {
var title = $(".mdl-layout-title");
// 原名称
var oldName = title.text().trim();
// 弹窗编辑
var newName = prompt("请输入新的设备名称", oldName);
if (newName && newName.trim() !== "") {
if(newName.trim().includes(" ")){
ShowToast("名称不能包含空格");
return;
}
if(newName.trim().length>16){
ShowToast("名称不能超过16个字");
return;
}
title.text(newName.trim());
HttpPost("/deviceName", function (re) {
}, newName.trim());}
});
document.getElementById("list-switch-all").addEventListener("click", function() {
HttpPost("/socketAll", function (re) {
}, checkboxs[2].checked ? "1" : "0");});
document.getElementById("list-switch-child-lock").addEventListener("click", function() {
HttpPost("/childLock", function (re) {
}, checkboxs[0].checked ? "1" : "0");});
//Socket-end
//Config-start
@@ -921,6 +1144,9 @@
var chart_wth = 0;
var p = document.getElementById("p");
var w = document.getElementById("w");
var w_t = document.getElementById("w_t");
var w_y = document.getElementById("w_y");
function GetPowerRecord() {
HttpPost("/power", function (re) {
re = re.replace(/'/g, '"');
@@ -946,22 +1172,45 @@
$("#uptime").html(power.up_time);
var w_v = (17.1 * power.p_count) / 1000 / 36000;
w.innerHTML = w_v.toFixed(2);
if (power.led_enabled == 1) {
w.innerHTML = w_v.toFixed(3);
var w_v_t = (17.1 * (power.p_count - power.p_count_1_day_ago)) / 1000 / 36000;
w_v_t = w_v_t < 0 ? 0 : w_v_t;
w_t.innerHTML = w_v_t.toFixed(3);
var w_v_y = (17.1 * (power.p_count_1_day_ago - power.p_count_2_days_ago)) / 1000 / 36000;
w_v_y = w_v_y < 0 ? 0 : w_v_y;
w_y.innerHTML = w_v_y.toFixed(3);
if (power.child_lock_enabled == 1) {
switch_lables[0].MaterialSwitch.on();
} else {
switch_lables[0].MaterialSwitch.off();
}
if (power.led_enabled == 1) {
switch_lables[1].MaterialSwitch.on();
} else {
switch_lables[1].MaterialSwitch.off();
}
if (power.total_switch_on == 1) {
switch_lables[2].MaterialSwitch.on();
} else {
switch_lables[2].MaterialSwitch.off();
}
var status_arr = power.sockets.split(",");
var names_arr = power.socketNames.split(",");
var switchTexts = document.querySelectorAll('.mdl-list__item-primary-content');
$(".mdl-layout-title").text(power.deviceName);
document.title=power.deviceName;
for (var i = 0; i < status_arr.length; i++) {
//checkboxs[i].checked = status_arr[i] == "1";
var langSpan = switchTexts[i+3].querySelector('.lang');
var indexSpan = switchTexts[i+3].querySelector('.socket-index');
if (langSpan) langSpan.textContent = names_arr[i]; // 修改插座名称
if (indexSpan) indexSpan.textContent = ""; // 修改序号,可自定义起始数字
if (status_arr[i] == "1") {
switch_lables[i+1].MaterialSwitch.on();
switch_lables[i+3].MaterialSwitch.on();
} else {
switch_lables[i+1].MaterialSwitch.off();
switch_lables[i+3].MaterialSwitch.off();
}
}
window.setTimeout(GetPowerRecord, 3000);
}, power_idx.toString());
}
@@ -1038,6 +1287,20 @@
GetTimedTask();
}, cmd);
}
function selectOperation(rowId, index, operationText) {
var witch = parseInt(rowId.split('-')[1]);
if (index === -1) {
document.getElementById(`${rowId}-input`).value = '未设置';
document.getElementById(`${rowId}-value`).value = -1;
} else {
document.getElementById(`${rowId}-input`).value = operationText;
document.getElementById(`${rowId}-value`).value = index;
}
HttpPost("/shortClickEvent", function (re) {
ShowToast("已设置按钮事件");
}, `${witch} ${index}`);
}
function DelTimedTask(timestamp) {
HttpDel("/task/"+timestamp, function (re) {
ShowToast("Delete timed task OK!");
@@ -1049,6 +1312,9 @@
//OTA-start
function OtaStart() {
var ota_url = document.getElementById("ota_url").value;
var protocol = window.location.protocol;
var baseUrl = protocol+"//"+window.location.host;
HttpPost("/ota", function (re) {
OtaStatus();
}, ota_url);
@@ -1058,6 +1324,9 @@
this.MaterialProgress.setProgress(0);
});
function OtaStatus() {
var protocol = window.location.protocol;
var baseUrl = protocol+"//"+window.location.host;
HttpGet("/ota", function (re) {
var percent = parseInt(re);
//console.log(re + " " + parseInt(re));

File diff suppressed because it is too large Load Diff

View File

@@ -4,6 +4,7 @@
#include "time.h"
#include "unistd.h"
#include "TimeUtils.h"
#include "mico_system.h"
#include "user_gpio.h"
#include "user_wifi.h"
@@ -16,6 +17,8 @@
char rtc_init = 0; //sntp校时成功标志位
uint32_t total_time = 0;
char str_mac[16] = {0};
int last_check_day = 0;
int childLockEnabled = 0;
system_config_t *sys_config;
user_config_t *user_config;
@@ -31,6 +34,7 @@ void appRestoreDefault_callback(void *const user_config_data, uint32_t size) {
user_config_t *userConfigDefault = user_config_data;
userConfigDefault->user[0] = 0;
userConfigDefault->user[1] = SWITCH_TOTAL_SOCKET;
userConfigDefault->mqtt_ip[0] = 0;
userConfigDefault->mqtt_port = 0;
userConfigDefault->mqtt_user[0] = 0;
@@ -42,10 +46,14 @@ void appRestoreDefault_callback(void *const user_config_data, uint32_t size) {
userConfigDefault->p_count_1_day_ago = 0;
userConfigDefault->power_led_enabled = 1;
userConfigDefault->version = USER_CONFIG_VERSION;
for (int i = 2; i < 11; ++i){
userConfigDefault->user[i] = -1;
}
int i;
for (i = 0; i < SOCKET_NUM; i++) {
userConfigDefault->socket_status[i] = 1;
snprintf(userConfigDefault->socket_names[i], SOCKET_NAME_LENGTH, "插座-%d", i + 1);
}
for (i = 0; i < MAX_TASK_NUM; i++) {
userConfigDefault->timed_tasks[i].on_use = false;
@@ -55,19 +63,38 @@ void appRestoreDefault_callback(void *const user_config_data, uint32_t size) {
void recordDailyPCount() {
// 获取当前时间
time_t now;
time(&now);
struct tm *current_time = localtime(&now);
if (current_time->tm_hour != 0 || current_time->tm_min != 0) {
return;
mico_utc_time_t utc_time;
mico_time_get_utc_time(&utc_time);
utc_time += 28800;
struct tm *current_time = localtime((const time_t *) &utc_time);
// 判断上次检查的时间与当前时间的日期是否不同
if (last_check_day != 0) {
// 如果日期发生变化(即跨天了),则进行记录
if (current_time->tm_mday != last_check_day) { tc1_log(
"WARNGIN: pcount day changed! now day %d hour %d min %d ,lastCheck day %d",
current_time->tm_mday, current_time->tm_hour, current_time->tm_min,
last_check_day);
// tc1_log("WARNGIN: pcount day changed! ");
// 记录数据
if (user_config->p_count_1_day_ago != 0) {
user_config->p_count_2_days_ago = user_config->p_count_1_day_ago;
}
user_config->p_count_1_day_ago = p_count;
// 更新系统配置
mico_system_context_update(sys_config);
tc1_log("WARNGIN: p_count record! p_count_1_day_ago:%d p_count_2_days_ago:%d",
user_config->p_count_1_day_ago, user_config->p_count_2_days_ago);
} else {
// tc1_log("WARNGIN: pcount day not changed , waiting for next run! ");
}
} else { tc1_log("WARNGIN: now day %d hour %d min %d ,lastCheck day %d", current_time->tm_mday,
current_time->tm_hour, current_time->tm_min, last_check_day);
}
if (user_config->p_count_1_day_ago != 0) {
user_config->p_count_2_days_ago = user_config->p_count_1_day_ago;
}
user_config->p_count_1_day_ago = p_count;
mico_system_context_update(sys_config);tc1_log(
"WARNGIN: p_count record! p_count_1_day_ago:%d p_count_2_days_ago:%d",
user_config->p_count_1_day_ago, user_config->p_count_2_days_ago);
// 更新上次检查时间
last_check_day = current_time->tm_mday;
}
void schedule_p_count_task(mico_thread_arg_t arg) {
@@ -105,8 +132,6 @@ int application_start(void) {
err = mico_system_init(sys_config);
require_noerr(err, exit);
p_count = user_config->p_count_1_day_ago;
uint8_t mac[8];
mico_wlan_get_mac_address(mac);
sprintf(str_mac, "%02X%02X%02X%02X%02X%02X",
@@ -116,7 +141,7 @@ int application_start(void) {
MicoGpioInitialize((mico_gpio_t) Button, INPUT_PULL_UP);
if (!MicoGpioInputGet(Button)) { //开机时按钮状态
tc1_log("press ap_init");
ApInit(false);
ApInit(true);
open_ap = true;
}
@@ -127,6 +152,7 @@ int application_start(void) {
}
MicoSysLed(0);
childLockEnabled = (int) user_config->user[0];
if (user_config->version != USER_CONFIG_VERSION) { tc1_log("WARNGIN: user params restored!");
err = mico_system_context_restore(sys_config);
require_noerr(err, exit);
@@ -136,7 +162,7 @@ int application_start(void) {
sprintf(sys_config->micoSystemConfig.name, ZTC1_NAME, str_mac + 8);
}
tc1_log("user:%s", user_config->user);tc1_log("device name:%s",
tc1_log("device name:%s",
sys_config->micoSystemConfig.name);tc1_log(
"mqtt_ip:%s", user_config->mqtt_ip);tc1_log("mqtt_port:%d",
user_config->mqtt_port);tc1_log(

View File

@@ -19,14 +19,14 @@
#define VERSION "v2.1.6"
#define TYPE 1
#define TYPE_NAME "zTC1"
#define TYPE_NAME "TC1"
#define ZTC1_NAME "zTC1-%s"
#define ZTC1_NAME "TC1-%s"
#define USER_CONFIG_VERSION 8
#define USER_CONFIG_VERSION 9
#define SETTING_MQTT_STRING_LENGTH_MAX 32 //必须4字节对齐。
#define SOCKET_NAME_LENGTH 32
#define SOCKET_NAME_LENGTH 64
#define SOCKET_NUM 6 //插座数量
#define Led MICO_GPIO_5
@@ -35,6 +35,7 @@
#define Relay_ON 1
#define Relay_OFF 0
#define Relay_TOGGLE -1
#define Relay_0 MICO_GPIO_6
#define Relay_1 MICO_GPIO_8
@@ -51,6 +52,7 @@ typedef struct
{
char version;
char mqtt_ip[SETTING_MQTT_STRING_LENGTH_MAX];
char socket_names[SOCKET_NUM][SOCKET_NAME_LENGTH];
int mqtt_port;
int mqtt_report_freq;
char mqtt_user[SETTING_MQTT_STRING_LENGTH_MAX];
@@ -74,5 +76,7 @@ extern char str_mac[16];
extern system_config_t* sys_config;
extern user_config_t* user_config;
extern mico_gpio_t Relay[Relay_NUM];
extern int childLockEnabled;
#endif

View File

@@ -27,8 +27,7 @@
#include "user_power.h"
#include "user_mqtt_client.h"
typedef struct
{
typedef struct {
char topic[MAX_MQTT_TOPIC_SIZE];
char qos;
char retained;
@@ -38,11 +37,16 @@ typedef struct
} mqtt_recv_msg_t, *p_mqtt_recv_msg_t, mqtt_send_msg_t, *p_mqtt_send_msg_t;
static void MqttClientThread(mico_thread_arg_t arg);
static void MessageArrived(MessageData* md);
static OSStatus MqttMsgPublish(Client *c, const char* topic, char qos, char retained, const unsigned char* msg, uint32_t msg_len);
static void MessageArrived(MessageData *md);
static OSStatus
MqttMsgPublish(Client *c, const char *topic, char qos, char retained, const unsigned char *msg,
uint32_t msg_len);
OSStatus UserRecvHandler(void *arg);
void ProcessHaCmd(char* cmd);
void ProcessHaCmd(char *cmd);
bool isconnect = false;
mico_queue_t mqtt_msg_send_queue = NULL;
@@ -58,92 +62,93 @@ char topic_set[MAX_MQTT_TOPIC_SIZE];
mico_timer_t timer_handle;
static char timer_status = 0;
void UserMqttTimerFunc(void *arg)
{
void UserMqttTimerFunc(void *arg) {
LinkStatusTypeDef LinkStatus;
micoWlanGetLinkStatus(&LinkStatus);
if (LinkStatus.is_connected != 1)
{
if (LinkStatus.is_connected != 1) {
mico_stop_timer(&timer_handle);
return;
}
if (mico_rtos_is_queue_empty(&mqtt_msg_send_queue))
{
timer_status++;
switch (timer_status)
{
case 1:
case 2:
case 3:
case 4:
case 5:
case 6:
UserMqttHassAuto(timer_status);
break;
case 7:
UserMqttHassAutoPower();
break;
default:
mico_stop_timer(&timer_handle);
break;
if (mico_rtos_is_queue_empty(&mqtt_msg_send_queue)) {
switch (timer_status) {
case 0:
UserMqttHassAutoLed();
UserMqttHassAutoTotalSocket();
UserMqttHassAutoChildLock();
break;
case 1:
case 2:
case 3:
case 4:
case 5:
case 6:
UserMqttHassAuto(timer_status);
break;
case 7:
UserMqttHassAutoPower();
break;
default:
mico_stop_timer(&timer_handle);
break;
}
timer_status++;
}
}
/* Application entrance */
OSStatus UserMqttInit(void)
{
OSStatus UserMqttInit(void) {
OSStatus err = kNoErr;
sprintf(topic_set, MQTT_CLIENT_SUB_TOPIC1);
sprintf(topic_state, MQTT_CLIENT_PUB_TOPIC, str_mac);
//TODO size:0x800
int mqtt_thread_stack_size = 0x2000;
uint32_t mqtt_lib_version = MQTTClientLibVersion();
mqtt_log("MQTT client version: [%ld.%ld.%ld]",
0xFF & (mqtt_lib_version >> 16), 0xFF & (mqtt_lib_version >> 8), 0xFF & mqtt_lib_version);
uint32_t mqtt_lib_version = MQTTClientLibVersion();mqtt_log(
"MQTT client version: [%ld.%ld.%ld]",
0xFF & (mqtt_lib_version >> 16), 0xFF & (mqtt_lib_version >> 8),
0xFF & mqtt_lib_version);
/* create mqtt msg send queue */
err = mico_rtos_init_queue(&mqtt_msg_send_queue, "mqtt_msg_send_queue", sizeof(p_mqtt_send_msg_t),
MAX_MQTT_SEND_QUEUE_SIZE);
err = mico_rtos_init_queue(&mqtt_msg_send_queue, "mqtt_msg_send_queue",
sizeof(p_mqtt_send_msg_t),
MAX_MQTT_SEND_QUEUE_SIZE);
require_noerr_action(err, exit, mqtt_log("ERROR: create mqtt msg send queue err=%d.", err));
/* start mqtt client */
err = mico_rtos_create_thread(NULL, MICO_APPLICATION_PRIORITY, "mqtt_client",
(mico_thread_function_t) MqttClientThread,
mqtt_thread_stack_size, 0);
(mico_thread_function_t) MqttClientThread,
mqtt_thread_stack_size, 0);
require_noerr_string(err, exit, "ERROR: Unable to start the mqtt client thread.");
/* Create a worker thread for user handling MQTT data event */
err = mico_rtos_create_worker_thread(&mqtt_client_worker_thread, MICO_APPLICATION_PRIORITY, 0x800, 5);
err = mico_rtos_create_worker_thread(&mqtt_client_worker_thread, MICO_APPLICATION_PRIORITY,
0x800, 5);
require_noerr_string(err, exit, "ERROR: Unable to start the mqtt client worker thread.");
exit:
if (kNoErr != err) mqtt_log("ERROR2, app thread exit err: %d kNoErr[%d]", err, kNoErr);
if (kNoErr != err)mqtt_log("ERROR2, app thread exit err: %d kNoErr[%d]", err, kNoErr);
return err;
}
static OSStatus UserMqttClientRelease(Client *c, Network *n)
{
static OSStatus UserMqttClientRelease(Client *c, Network *n) {
OSStatus err = kNoErr;
if (c->isconnected) MQTTDisconnect(c);
n->disconnect(n); // close connection
if (MQTT_SUCCESS != MQTTClientDeinit(c))
{
mqtt_log("MQTTClientDeinit failed!");
if (MQTT_SUCCESS != MQTTClientDeinit(c)) { mqtt_log("MQTTClientDeinit failed!");
err = kDeletedErr;
}
return err;
}
// publish msg to mqtt server
static OSStatus MqttMsgPublish(Client *c, const char* topic, char qos, char retained,
const unsigned char* msg,
uint32_t msg_len)
{
static OSStatus MqttMsgPublish(Client *c, const char *topic, char qos, char retained,
const unsigned char *msg,
uint32_t msg_len) {
OSStatus err = kUnknownErr;
int ret = 0;
MQTTMessage publishData = MQTTMessage_publishData_initializer;
@@ -153,19 +158,16 @@ static OSStatus MqttMsgPublish(Client *c, const char* topic, char qos, char reta
// upload data qos0
publishData.qos = (enum QoS) qos;
publishData.retained = retained;
publishData.payload = (void*) msg;
publishData.payload = (void *) msg;
publishData.payloadlen = msg_len;
ret = MQTTPublish(c, topic, &publishData);
if (MQTT_SUCCESS == ret)
{
if (MQTT_SUCCESS == ret) {
err = kNoErr;
} else if (MQTT_SOCKET_ERR == ret)
{
} else if (MQTT_SOCKET_ERR == ret) {
err = kConnectionErr;
} else
{
} else {
err = kUnknownErr;
}
@@ -173,13 +175,17 @@ static OSStatus MqttMsgPublish(Client *c, const char* topic, char qos, char reta
return err;
}
void MqttClientThread(mico_thread_arg_t arg)
{
void registerMqttEvents(void) {
timer_status = 0;
mico_start_timer(&timer_handle);
}
void MqttClientThread(mico_thread_arg_t arg) {
OSStatus err = kUnknownErr;
int rc = -1;
fd_set readfds;
struct timeval t = { 0, MQTT_YIELD_TMIE * 1000 };
struct timeval t = {0, MQTT_YIELD_TMIE * 1000};
ssl_opts ssl_settings;
MQTTPacket_connectData connectData = MQTTPacket_connectData_initializer;
@@ -195,7 +201,8 @@ void MqttClientThread(mico_thread_arg_t arg)
/* create msg send queue event fd */
msg_send_event_fd = mico_create_event_fd(mqtt_msg_send_queue);
require_action(msg_send_event_fd >= 0, exit, mqtt_log("ERROR: create msg send queue event fd failed!!!"));
require_action(msg_send_event_fd >= 0, exit,
mqtt_log("ERROR: create msg send queue event fd failed!!!"));
MQTT_start:
@@ -203,16 +210,15 @@ void MqttClientThread(mico_thread_arg_t arg)
/* 1. create network connection */
ssl_settings.ssl_enable = false;
LinkStatusTypeDef LinkStatus;
while (1)
{
while (1) {
isconnect = false;
mico_rtos_thread_sleep(3);
if (MQTT_SERVER[0] < 0x20 || MQTT_SERVER[0] > 0x7f || MQTT_SERVER_PORT < 1) continue; //鏈厤缃甿qtt鏈嶅姟鍣ㄦ椂涓嶈繛鎺<E7B99B>
if (MQTT_SERVER[0] < 0x20 || MQTT_SERVER[0] > 0x7f || MQTT_SERVER_PORT < 1)
continue; //鏈厤缃甿qtt鏈嶅姟鍣ㄦ椂涓嶈繛鎺<E7B99B>
micoWlanGetLinkStatus(&LinkStatus);
if (LinkStatus.is_connected != 1)
{
mqtt_log("ERROR:WIFI not connect, waiting 3s for connecting and then connecting MQTT ");
if (LinkStatus.is_connected != 1) { mqtt_log(
"ERROR:WIFI not connect, waiting 3s for connecting and then connecting MQTT ");
mico_rtos_thread_sleep(3);
continue;
}
@@ -221,8 +227,7 @@ void MqttClientThread(mico_thread_arg_t arg)
if (rc == MQTT_SUCCESS) break;
//mqtt_log("ERROR: MQTT network connect err=%d, reconnect after 3s...", rc);
}
mqtt_log("MQTT network connect success!");
}mqtt_log("MQTT network connect success!");
/* 2. init mqtt client */
//c.heartbeat_retry_max = 2;
@@ -245,26 +250,28 @@ void MqttClientThread(mico_thread_arg_t arg)
mqtt_log("MQTT client connect success!");
UserLedSet(user_config->power_led_enabled);
UserLedSet(RelayOut() && user_config->power_led_enabled);
/* 4. mqtt client subscribe */
rc = MQTTSubscribe(&c, topic_set, QOS0, MessageArrived);
require_noerr_string(rc, MQTT_reconnect, "ERROR: MQTT client subscribe err.");
mqtt_log("MQTT client subscribe success! recv_topic=[%s].", topic_set);
require_noerr_string(rc, MQTT_reconnect, "ERROR: MQTT client subscribe err.");mqtt_log(
"MQTT client subscribe success! recv_topic=[%s].", topic_set);
/*4.1 杩炴帴鎴愬姛鍚庡厛鏇存柊鍙戦<E98D99>佷竴娆℃暟鎹<E69A9F>*/
isconnect = true;
int i = 0;
for (; i < SOCKET_NUM; i++)
{
for (; i < SOCKET_NUM; i++) {
UserMqttSendSocketState(i);
}
UserMqttSendLedState();
UserMqttSendTotalSocketState();
UserMqttSendChildLockState();
mico_init_timer(&timer_handle, 150, UserMqttTimerFunc, &arg);
mico_start_timer(&timer_handle);
registerMqttEvents();
/* 5. client loop for recv msg && keepalive */
while (1)
{
while (1) {
isconnect = true;
no_mqtt_msg_exchange = true;
FD_ZERO(&readfds);
@@ -273,26 +280,23 @@ void MqttClientThread(mico_thread_arg_t arg)
select(msg_send_event_fd + 1, &readfds, NULL, NULL, &t);
/* recv msg from server */
if (FD_ISSET(c.ipstack->my_socket, &readfds))
{
if (FD_ISSET(c.ipstack->my_socket, &readfds)) {
rc = MQTTYield(&c, (int) MQTT_YIELD_TMIE);
require_noerr(rc, MQTT_reconnect);
no_mqtt_msg_exchange = false;
}
/* recv msg from user worker thread to be sent to server */
if (FD_ISSET(msg_send_event_fd, &readfds))
{
while (mico_rtos_is_queue_empty(&mqtt_msg_send_queue) == false)
{
if (FD_ISSET(msg_send_event_fd, &readfds)) {
while (mico_rtos_is_queue_empty(&mqtt_msg_send_queue) == false) {
// get msg from send queue
mico_rtos_pop_from_queue(&mqtt_msg_send_queue, &p_send_msg, 0);
require_string(p_send_msg, exit, "Wrong data point");
// send message to server
err = MqttMsgPublish(&c, p_send_msg->topic, p_send_msg->qos, p_send_msg->retained,
(const unsigned char*)p_send_msg->data,
p_send_msg->datalen);
(const unsigned char *) p_send_msg->data,
p_send_msg->datalen);
require_noerr_string(err, MQTT_reconnect, "ERROR: MQTT publish data err");
@@ -304,8 +308,7 @@ void MqttClientThread(mico_thread_arg_t arg)
}
/* if no msg exchange, we need to check ping msg to keep alive. */
if (no_mqtt_msg_exchange)
{
if (no_mqtt_msg_exchange) {
rc = keepalive(&c);
require_noerr_string(rc, MQTT_reconnect, "ERROR: keepalive err");
}
@@ -313,9 +316,9 @@ void MqttClientThread(mico_thread_arg_t arg)
MQTT_reconnect:
mqtt_log("Disconnect MQTT client, and reconnect after 5s, reason: mqtt_rc = %d, err = %d", rc, err);
mqtt_log("Disconnect MQTT client, and reconnect after 5s, reason: mqtt_rc = %d, err = %d", rc, err);
timer_status=100;
timer_status = 100;
UserMqttClientRelease(&c, &n);
isconnect = false;
@@ -326,18 +329,16 @@ void MqttClientThread(mico_thread_arg_t arg)
goto MQTT_start;
exit:
isconnect = false;
mqtt_log("EXIT: MQTT client exit with err = %d.", err);
isconnect = false;mqtt_log("EXIT: MQTT client exit with err = %d.", err);
UserMqttClientRelease(&c, &n);
mico_rtos_delete_thread(NULL);
}
// callback, msg received from mqtt server
static void MessageArrived(MessageData* md)
{
static void MessageArrived(MessageData *md) {
OSStatus err = kUnknownErr;
p_mqtt_recv_msg_t p_recv_msg = NULL;
MQTTMessage* message = md->message;
MQTTMessage *message = md->message;
p_recv_msg = (p_mqtt_recv_msg_t) calloc(1, sizeof(mqtt_recv_msg_t));
require_action(p_recv_msg, exit, err = kNoMemoryErr);
@@ -349,26 +350,25 @@ static void MessageArrived(MessageData* md)
memcpy(p_recv_msg->data, message->payload, message->payloadlen);
mqtt_log("MessageArrived topic[%s] data[%s]", p_recv_msg->topic, p_recv_msg->data);
err = mico_rtos_send_asynchronous_event(&mqtt_client_worker_thread, UserRecvHandler, p_recv_msg);
err = mico_rtos_send_asynchronous_event(&mqtt_client_worker_thread, UserRecvHandler,
p_recv_msg);
require_noerr(err, exit);
exit:
if (err != kNoErr)
{
mqtt_log("ERROR: Recv data err = %d", err);
if (err != kNoErr) { mqtt_log("ERROR: Recv data err = %d", err);
if (p_recv_msg) free(p_recv_msg);
}
return;
}
/* Application process MQTT received data */
OSStatus UserRecvHandler(void *arg)
{
OSStatus UserRecvHandler(void *arg) {
OSStatus err = kUnknownErr;
p_mqtt_recv_msg_t p_recv_msg = arg;
require(p_recv_msg, exit);
mqtt_log("user get data success! from_topic=[%s], msg=[%ld].", p_recv_msg->topic, p_recv_msg->datalen);
mqtt_log("user get data success! from_topic=[%s], msg=[%ld].", p_recv_msg->topic,
p_recv_msg->datalen);
//UserFunctionCmdReceived(0, p_recv_msg->data);
ProcessHaCmd(p_recv_msg->data);
@@ -379,33 +379,60 @@ OSStatus UserRecvHandler(void *arg)
return err;
}
void ProcessHaCmd(char* cmd)
{
void ProcessHaCmd(char *cmd) {
mqtt_log("ProcessHaCmd[%s]", cmd);
char mac[20] = { 0 };
char mac[20] = {0};
if (strcmp(cmd, "set socket") == ' ')
{
if (strcmp(cmd, "set socket") == ' ') {
int i, on;
sscanf(cmd, "set socket %s %d %d", mac, &i, &on);
if (strcmp(mac, str_mac)) return;
mqtt_log("set socket[%d] on[%d]", i, on);
if (strcmp(mac, str_mac)) return;mqtt_log("set socket[%d] on[%d]", i, on);
UserRelaySet(i, on);
UserMqttSendSocketState(i);
UserMqttSendTotalSocketState();
mico_system_context_update(sys_config);
} else if (strcmp(cmd, "set led") == ' ') {
int on;
sscanf(cmd, "set led %s %d", mac, &on);
if (strcmp(mac, str_mac)) return;mqtt_log("set led on[%d]", on);
user_config->power_led_enabled = on;
if (RelayOut() && user_config->power_led_enabled) {
UserLedSet(1);
} else {
UserLedSet(0);
}
UserMqttSendLedState();
mico_system_context_update(sys_config);
} else if (strcmp(cmd, "set total_socket") == ' ') {
int on;
sscanf(cmd, "set total_socket %s %d", mac, &on);
if (strcmp(mac, str_mac)) return;mqtt_log("set total_socket on[%d]", on);
UserRelaySetAll(on);
int i = 0;
for (i = 0; i < SOCKET_NUM; i++) {
UserRelaySet(i, user_config->socket_status[i]);
UserMqttSendSocketState(i);
}
UserMqttSendTotalSocketState();
}else if (strcmp(cmd, "set childLock") == ' ') {
int on;
sscanf(cmd, "set childLock %s %d", mac, &on);
if (strcmp(mac, str_mac)) return;mqtt_log("set childLock on[%d]", on);
user_config->user[0] = on;
childLockEnabled = on;
UserMqttSendChildLockState();
mico_system_context_update(sys_config);
}
}
OSStatus UserMqttSendTopic(char *topic, char *arg, char retained)
{
OSStatus UserMqttSendTopic(char *topic, char *arg, char retained) {
OSStatus err = kUnknownErr;
p_mqtt_send_msg_t p_send_msg = NULL;
// mqtt_log("======App prepare to send ![%d]======", MicoGetMemoryInfo()->free_memory);
/* Send queue is full, pop the oldest */
if (mico_rtos_is_queue_full(&mqtt_msg_send_queue) == true)
{
if (mico_rtos_is_queue_full(&mqtt_msg_send_queue) == true) {
mico_rtos_pop_from_queue(&mqtt_msg_send_queue, &p_send_msg, 0);
free(p_send_msg);
p_send_msg = NULL;
@@ -432,21 +459,64 @@ OSStatus UserMqttSendTopic(char *topic, char *arg, char retained)
}
/* Application collect data and seng them to MQTT send queue */
OSStatus UserMqttSend(char *arg)
{
OSStatus UserMqttSend(char *arg) {
return UserMqttSendTopic(topic_state, arg, 0);
}
//鏇存柊ha寮<61>鍏崇姸鎬<E5A7B8>
OSStatus UserMqttSendSocketState(char socket_id)
{
OSStatus UserMqttSendSocketState(char socket_id) {
char *send_buf = malloc(64);
char *topic_buf = malloc(64);
OSStatus oss_status = kUnknownErr;
if (send_buf != NULL && topic_buf != NULL)
{
sprintf(topic_buf, "homeassistant/switch/%s/socket_%d/state", str_mac, (int)socket_id);
sprintf(send_buf, "set socket %s %d %d", str_mac, socket_id, (int)user_config->socket_status[(int)socket_id]);
if (send_buf != NULL && topic_buf != NULL) {
sprintf(topic_buf, "homeassistant/switch/%s/socket_%d/state", str_mac, (int) socket_id);
sprintf(send_buf, "set socket %s %d %d", str_mac, socket_id,
(int) user_config->socket_status[(int) socket_id]);
oss_status = UserMqttSendTopic(topic_buf, send_buf, 1);
}
if (send_buf) free(send_buf);
if (topic_buf) free(topic_buf);
return oss_status;
}
OSStatus UserMqttSendTotalSocketState(void) {
char *send_buf = malloc(64);
char *topic_buf = malloc(64);
OSStatus oss_status = kUnknownErr;
if (send_buf != NULL && topic_buf != NULL) {
sprintf(topic_buf, "homeassistant/switch/%s/total_socket/state", str_mac);
sprintf(send_buf, "set total_socket %s %d", str_mac, RelayOut() ? 1 : 0);
oss_status = UserMqttSendTopic(topic_buf, send_buf, 1);
}
if (send_buf) free(send_buf);
if (topic_buf) free(topic_buf);
return oss_status;
}
OSStatus UserMqttSendLedState(void) {
char *send_buf = malloc(64);
char *topic_buf = malloc(64);
OSStatus oss_status = kUnknownErr;
if (send_buf != NULL && topic_buf != NULL) {
sprintf(topic_buf, "homeassistant/switch/%s/led/state", str_mac);
sprintf(send_buf, "set led %s %d", str_mac, (int) user_config->power_led_enabled);
oss_status = UserMqttSendTopic(topic_buf, send_buf, 1);
}
if (send_buf) free(send_buf);
if (topic_buf) free(topic_buf);
return oss_status;
}
OSStatus UserMqttSendChildLockState(void) {
char *send_buf = malloc(64);
char *topic_buf = malloc(64);
OSStatus oss_status = kUnknownErr;
if (send_buf != NULL && topic_buf != NULL) {
sprintf(topic_buf, "homeassistant/switch/%s/childLock/state", str_mac);
sprintf(send_buf, "set childLock %s %d", str_mac, childLockEnabled);
oss_status = UserMqttSendTopic(topic_buf, send_buf, 1);
}
if (send_buf) free(send_buf);
@@ -456,24 +526,30 @@ OSStatus UserMqttSendSocketState(char socket_id)
}
//hass mqtt鑷姩鍙戠幇鏁版嵁寮<E5B581>鍏冲彂閫<E5BD82>
void UserMqttHassAuto(char socket_id)
{
void UserMqttHassAuto(char socket_id) {
socket_id--;
char *send_buf = NULL;
char *topic_buf = NULL;
send_buf = (char *) malloc(300);
send_buf = (char *) malloc(600);
topic_buf = (char *) malloc(64);
if (send_buf != NULL && topic_buf != NULL)
{
if (send_buf != NULL && topic_buf != NULL) {
sprintf(topic_buf, "homeassistant/switch/%s/socket_%d/config", str_mac, socket_id);
sprintf(send_buf,
"{\"name\":\"TC1_%s_Socket_%d\","
"\"uniq_id\":\"%s_s%d\","
"\"stat_t\":\"homeassistant/switch/%s/socket_%d/state\","
"\"cmd_t\":\"device/ztc1/set\","
"\"pl_on\":\"set socket %s %d 1\","
"\"pl_off\":\"set socket %s %d 0\"}",
str_mac+8, socket_id+1, str_mac, socket_id, str_mac, socket_id, str_mac, socket_id, str_mac, socket_id);
sprintf(send_buf,
"{\"name\":\"%s\","
"\"uniq_id\":\"tc1_%s_s%d\","
"\"object_id\":\"tc1_%s_s%d\","
"\"stat_t\":\"homeassistant/switch/%s/socket_%d/state\","
"\"cmd_t\":\"device/ztc1/set\","
"\"pl_on\":\"set socket %s %d 1\","
"\"pl_off\":\"set socket %s %d 0\","
"\"device\":{"
"\"identifiers\":[\"tc1_%s\"],"
"\"name\":\"%s\","
"\"model\":\"TC1\","
"\"manufacturer\":\"PHICOMM\"}}",
user_config->socket_names[(int)socket_id], str_mac, socket_id,str_mac, socket_id, str_mac, socket_id,
str_mac,
socket_id, str_mac, socket_id, str_mac,sys_config->micoSystemConfig.name);
UserMqttSendTopic(topic_buf, send_buf, 1);
}
if (send_buf)
@@ -481,68 +557,174 @@ void UserMqttHassAuto(char socket_id)
if (topic_buf)
free(topic_buf);
}
//hass mqtt鑷姩鍙戠幇鏁版嵁鍔熺巼鍙戦<E98D99><E688A6>
void UserMqttHassAutoPower(void)
{
void UserMqttHassAutoLed(void) {
char *send_buf = NULL;
char *topic_buf = NULL;
send_buf = malloc(512);
send_buf = (char *) malloc(600);
topic_buf = (char *) malloc(64);
if (send_buf != NULL && topic_buf != NULL) {
sprintf(topic_buf, "homeassistant/switch/%s/led/config", str_mac);
sprintf(send_buf,
"{\"name\":\"LED指示灯\","
"\"uniq_id\":\"tc1_%s_led\","
"\"object_id\":\"tc1_%s_led\","
"\"stat_t\":\"homeassistant/switch/%s/led/state\","
"\"cmd_t\":\"device/ztc1/set\","
"\"pl_on\":\"set led %s 1\","
"\"pl_off\":\"set led %s 0\","
"\"device\":{"
"\"identifiers\":[\"tc1_%s\"],"
"\"name\":\"%s\","
"\"model\":\"TC1\","
"\"manufacturer\":\"PHICOMM\"}}",
str_mac,str_mac,str_mac, str_mac, str_mac, str_mac,sys_config->micoSystemConfig.name);
UserMqttSendTopic(topic_buf, send_buf, 1);
}
if (send_buf)
free(send_buf);
if (topic_buf)
free(topic_buf);
}
void UserMqttHassAutoChildLock(void) {
char *send_buf = NULL;
char *topic_buf = NULL;
send_buf = (char *) malloc(600);
topic_buf = (char *) malloc(64);
if (send_buf != NULL && topic_buf != NULL) {
sprintf(topic_buf, "homeassistant/switch/%s/childLock/config", str_mac);
sprintf(send_buf,
"{\"name\":\"童锁\","
"\"uniq_id\":\"tc1_%s_child_lock\","
"\"object_id\":\"tc1_%s_child_lock\","
"\"stat_t\":\"homeassistant/switch/%s/childLock/state\","
"\"cmd_t\":\"device/ztc1/set\","
"\"pl_on\":\"set childLock %s 1\","
"\"pl_off\":\"set childLock %s 0\","
"\"device\":{"
"\"identifiers\":[\"tc1_%s\"],"
"\"name\":\"%s\","
"\"model\":\"TC1\","
"\"manufacturer\":\"PHICOMM\"}}",
str_mac,str_mac,str_mac, str_mac, str_mac, str_mac,sys_config->micoSystemConfig.name);
UserMqttSendTopic(topic_buf, send_buf, 1);
}
if (send_buf)
free(send_buf);
if (topic_buf)
free(topic_buf);
}
void UserMqttHassAutoTotalSocket(void) {
char *send_buf = NULL;
char *topic_buf = NULL;
send_buf = (char *) malloc(600);
topic_buf = (char *) malloc(64);
if (send_buf != NULL && topic_buf != NULL) {
sprintf(topic_buf, "homeassistant/switch/%s/total_socket/config", str_mac);
sprintf(send_buf,
"{\"name\":\"总开关\","
"\"uniq_id\":\"tc1_%s_total_socket\","
"\"object_id\":\"tc1_%s_total_socket\","
"\"stat_t\":\"homeassistant/switch/%s/total_socket/state\","
"\"cmd_t\":\"device/ztc1/set\","
"\"pl_on\":\"set total_socket %s 1\","
"\"pl_off\":\"set total_socket %s 0\","
"\"device\":{"
"\"identifiers\":[\"tc1_%s\"],"
"\"name\":\"%s\","
"\"model\":\"TC1\","
"\"manufacturer\":\"PHICOMM\"}}",
str_mac, str_mac, str_mac, str_mac, str_mac, str_mac,sys_config->micoSystemConfig.name);
UserMqttSendTopic(topic_buf, send_buf, 1);
}
if (send_buf)
free(send_buf);
if (topic_buf)
free(topic_buf);
}
//hass mqtt鑷姩鍙戠幇鏁版嵁鍔熺巼鍙戦<E98D99><E688A6>
void UserMqttHassAutoPower(void) {
char *send_buf = NULL;
char *topic_buf = NULL;
send_buf = malloc(600);
topic_buf = malloc(128);
if (send_buf != NULL && topic_buf != NULL)
{
if (send_buf != NULL && topic_buf != NULL) {
sprintf(topic_buf, "homeassistant/sensor/%s/power/config", str_mac);
sprintf(send_buf,
"{\"name\":\"TC1_%s_Power\","
"\"uniq_id\":\"%s_p\","
"\"state_topic\":\"homeassistant/sensor/%s/power/state\","
"\"unit_of_measurement\":\"W\","
"\"icon\":\"mdi:gauge\","
"\"value_template\":\"{{ value_json.power }}\"}",
str_mac+8, str_mac, str_mac);
sprintf(send_buf,
"{\"name\":\"功率\","
"\"uniq_id\":\"tc1_%s_p\","
"\"object_id\":\"tc1_%s_p\","
"\"state_topic\":\"homeassistant/sensor/%s/power/state\","
"\"unit_of_measurement\":\"W\","
"\"icon\":\"mdi:gauge\","
"\"value_template\":\"{{ value_json.power }}\",""\"device\":{"
"\"identifiers\":[\"tc1_%s\"],"
"\"name\":\"%s\","
"\"model\":\"TC1\","
"\"manufacturer\":\"PHICOMM\"}}",
str_mac,str_mac, str_mac, str_mac,sys_config->micoSystemConfig.name);
UserMqttSendTopic(topic_buf, send_buf, 1);
sprintf(topic_buf, "homeassistant/sensor/%s/powerConsumption/config", str_mac);
sprintf(send_buf,
"{\"name\":\"TC1_%s_PowerConsumption\","
"\"uniq_id\":\"%s_pc\","
"\"state_topic\":\"homeassistant/sensor/%s/powerConsumption/state\","
"\"unit_of_measurement\":\"kWh\","
"\"icon\":\"mdi:fence-electric\","
"\"value_template\":\"{{ value_json.powerConsumption }}\"}",
str_mac+8, str_mac, str_mac);
"{\"name\":\"总耗电量\","
"\"uniq_id\":\"tc1_%s_pc\","
"\"object_id\":\"tc1_%s_pc\","
"\"state_topic\":\"homeassistant/sensor/%s/powerConsumption/state\","
"\"unit_of_measurement\":\"kWh\","
"\"icon\":\"mdi:fence-electric\","
"\"value_template\":\"{{ value_json.powerConsumption }}\",""\"device\":{"
"\"identifiers\":[\"tc1_%s\"],"
"\"name\":\"%s\","
"\"model\":\"TC1\","
"\"manufacturer\":\"PHICOMM\"}}",
str_mac, str_mac, str_mac, str_mac,sys_config->micoSystemConfig.name);
UserMqttSendTopic(topic_buf, send_buf, 1);
sprintf(topic_buf, "homeassistant/sensor/%s/powerConsumptionToday/config", str_mac);
sprintf(send_buf,
"{\"name\":\"TC1_%s_powerConsumptionToday\","
"\"uniq_id\":\"%s_pc_today\","
"\"state_topic\":\"homeassistant/sensor/%s/powerConsumptionToday/state\","
"\"unit_of_measurement\":\"kWh\","
"\"icon\":\"mdi:fence-electric\","
"\"value_template\":\"{{ value_json.powerConsumptionToday }}\"}",
str_mac+8, str_mac, str_mac);
sprintf(send_buf,
"{\"name\":\"今日耗电量\","
"\"uniq_id\":\"tc1_%s_pc_today\","
"\"object_id\":\"tc1_%s_pc_today\","
"\"state_topic\":\"homeassistant/sensor/%s/powerConsumptionToday/state\","
"\"unit_of_measurement\":\"kWh\","
"\"icon\":\"mdi:fence-electric\","
"\"value_template\":\"{{ value_json.powerConsumptionToday }}\",""\"device\":{"
"\"identifiers\":[\"tc1_%s\"],"
"\"name\":\"%s\","
"\"model\":\"TC1\","
"\"manufacturer\":\"PHICOMM\"}}",
str_mac,str_mac, str_mac, str_mac,sys_config->micoSystemConfig.name);
UserMqttSendTopic(topic_buf, send_buf, 1);
sprintf(topic_buf, "homeassistant/sensor/%s/powerConsumptionYesterday/config", str_mac);
sprintf(send_buf,
"{\"name\":\"TC1_%s_powerConsumptionYesterday\","
"\"uniq_id\":\"%s_pc_yesterday\","
"\"state_topic\":\"homeassistant/sensor/%s/powerConsumptionYesterday/state\","
"\"unit_of_measurement\":\"kWh\","
"\"icon\":\"mdi:fence-electric\","
"\"value_template\":\"{{ value_json.powerConsumptionYesterday }}\"}",
str_mac+8, str_mac, str_mac);
sprintf(send_buf,
"{\"name\":\"昨日耗电量\","
"\"uniq_id\":\"tc1_%s_pc_yesterday\","
"\"object_id\":\"tc1_%s_pc_yesterday\","
"\"state_topic\":\"homeassistant/sensor/%s/powerConsumptionYesterday/state\","
"\"unit_of_measurement\":\"kWh\","
"\"icon\":\"mdi:fence-electric\","
"\"value_template\":\"{{ value_json.powerConsumptionYesterday }}\",""\"device\":{"
"\"identifiers\":[\"tc1_%s\"],"
"\"name\":\"%s\","
"\"model\":\"TC1\","
"\"manufacturer\":\"PHICOMM\"}}",
str_mac,str_mac, str_mac, str_mac,sys_config->micoSystemConfig.name);
UserMqttSendTopic(topic_buf, send_buf, 1);
}
if (send_buf) free(send_buf);
if (topic_buf) free(topic_buf);
}
char topic_buf[128] = { 0 };
char send_buf[128] = { 0 };
void UserMqttHassPower(void)
{
char topic_buf[128] = {0};
char send_buf[128] = {0};
void UserMqttHassPower(void) {
sprintf(topic_buf, "homeassistant/sensor/%s/power/state", str_mac);
sprintf(send_buf, "{\"power\":\"%.3f\"}", real_time_power/10);
sprintf(send_buf, "{\"power\":\"%.3f\"}", real_time_power / 10);
UserMqttSendTopic(topic_buf, send_buf, 0);
sprintf(topic_buf, "homeassistant/sensor/%s/powerConsumption/state", str_mac);
@@ -551,15 +733,24 @@ void UserMqttHassPower(void)
// tc1_log("p_count %ld, p_count_1_day_ago %ld ,p_count_2_days_ago %ld, result %ld",p_count,user_config->p_count_1_day_ago,user_config->p_count_2_days_ago,((p_count-user_config->p_count_1_day_ago)<0?0:(p_count-user_config->p_count_1_day_ago)));
sprintf(topic_buf, "homeassistant/sensor/%s/powerConsumptionToday/state", str_mac);
sprintf(send_buf, "{\"powerConsumptionToday\":\"%.3f\"}", (17.1 * ((p_count-user_config->p_count_1_day_ago)<0?0:(p_count-user_config->p_count_1_day_ago))) / 1000 / 36000);
sprintf(send_buf, "{\"powerConsumptionToday\":\"%.3f\"}", (17.1 * ((p_count -
user_config->p_count_1_day_ago) <
0 ? 0 : (p_count -
user_config->p_count_1_day_ago))) /
1000 / 36000);
UserMqttSendTopic(topic_buf, send_buf, 0);
sprintf(topic_buf, "homeassistant/sensor/%s/powerConsumptionYesterday/state", str_mac);
sprintf(send_buf, "{\"powerConsumptionYesterday\":\"%.3f\"}", (17.1 * ((user_config->p_count_1_day_ago-user_config->p_count_2_days_ago)<0?0:(user_config->p_count_1_day_ago-user_config->p_count_2_days_ago))) / 1000 / 36000);
sprintf(send_buf, "{\"powerConsumptionYesterday\":\"%.3f\"}", (17.1 *
((user_config->p_count_1_day_ago -
user_config->p_count_2_days_ago) <
0 ? 0 : (
user_config->p_count_1_day_ago -
user_config->p_count_2_days_ago))) /
1000 / 36000);
UserMqttSendTopic(topic_buf, send_buf, 0);
}
bool UserMqttIsConnect()
{
bool UserMqttIsConnect() {
return isconnect;
}

View File

@@ -29,10 +29,24 @@ extern bool UserMqttIsConnect(void);
extern OSStatus UserMqttSendSocketState(char socket_id);
extern OSStatus UserMqttSendLedState(void);
extern OSStatus UserMqttSendChildLockState(void);
extern OSStatus UserMqttSendTotalSocketState(void);
extern void UserMqttHassAuto(char socket_id);
extern void UserMqttHassPower(void);
extern void UserMqttHassAutoPower(void);
extern void UserMqttHassAutoLed(void);
extern void UserMqttHassAutoChildLock(void);
extern void UserMqttHassAutoTotalSocket(void);
extern void registerMqttEvents(void);
#endif

View File

@@ -2,13 +2,14 @@
#include "main.h"
#include "user_gpio.h"
#include "user_wifi.h"
#include "mqtt_server/user_mqtt_client.h"
mico_gpio_t relay[Relay_NUM] = { Relay_0, Relay_1, Relay_2, Relay_3, Relay_4, Relay_5 };
char socket_status[32] = { 0 };
mico_gpio_t relay[Relay_NUM] = {Relay_0, Relay_1, Relay_2, Relay_3, Relay_4, Relay_5};
char socket_status[32] = {0};
char short_click_config[32] = {0};
void UserLedSet(char x)
{
void UserLedSet(char x) {
if (x == -1)
MicoGpioOutputTrigger(Led);
else if (x)
@@ -17,75 +18,83 @@ void UserLedSet(char x)
MicoGpioOutputLow(Led);
}
bool RelayOut(void)
{
bool RelayOut(void) {
int i;
for (i = 0; i < SOCKET_NUM; i++)
{
if (user_config->socket_status[i] != 0)
{
for (i = 0; i < SOCKET_NUM; i++) {
if (user_config->socket_status[i] != 0) {
return true;
}
}
return false;
}
char* GetSocketStatus()
{
char *GetSocketStatus() {
sprintf(socket_status, "%d,%d,%d,%d,%d,%d",
user_config->socket_status[0],
user_config->socket_status[1],
user_config->socket_status[2],
user_config->socket_status[3],
user_config->socket_status[4],
user_config->socket_status[5]);
user_config->socket_status[0],
user_config->socket_status[1],
user_config->socket_status[2],
user_config->socket_status[3],
user_config->socket_status[4],
user_config->socket_status[5]);
return socket_status;
}
void SetSocketStatus(char* socket_status)
{
char *GetShortClickConfig() {
sprintf(short_click_config, "%d,%d,%d,%d,%d,%d,%d,%d,%d,%d",
user_config->user[1],
user_config->user[2],
user_config->user[3],
user_config->user[4],
user_config->user[5],
user_config->user[6],
user_config->user[7],
user_config->user[8],
user_config->user[9],
user_config->user[10]);
return short_click_config;
}
void SetSocketStatus(char *socket_status) {
sscanf(socket_status, "%d,%d,%d,%d,%d,%d,",
(int*)&user_config->socket_status[0],
(int*)&user_config->socket_status[1],
(int*)&user_config->socket_status[2],
(int*)&user_config->socket_status[3],
(int*)&user_config->socket_status[4],
(int*)&user_config->socket_status[5]);
(int *) &user_config->socket_status[0],
(int *) &user_config->socket_status[1],
(int *) &user_config->socket_status[2],
(int *) &user_config->socket_status[3],
(int *) &user_config->socket_status[4],
(int *) &user_config->socket_status[5]);
int i = 0;
for (i = 0; i < SOCKET_NUM; i++)
{
for (i = 0; i < SOCKET_NUM; i++) {
UserRelaySet(i, user_config->socket_status[i]);
UserMqttSendSocketState(i);
}
UserMqttSendTotalSocketState();
mico_system_context_update(sys_config);
}
/*UserRelaySet
* 设置继电器开关
* i:编号 0-5
* on:开关 0:关 1:开
* on:开关 0:关 1:开 -1:切换
*/
void UserRelaySet(unsigned char i, unsigned char on)
{
void UserRelaySet(unsigned char i, char on) {
if (i < 0 || i >= SOCKET_NUM) return;
if (on == Relay_ON)
{
if (on == Relay_ON) {
MicoGpioOutputHigh(relay[i]);
}
else
{
} else if (on == Relay_OFF) {
MicoGpioOutputLow(relay[i]);
} else if (on == Relay_TOGGLE) {
if(user_config->socket_status[i]==Relay_OFF){
MicoGpioOutputHigh(relay[i]);
}else{
MicoGpioOutputLow(relay[i]);
}
}
user_config->socket_status[i] = on >= 0 ? on : (user_config->socket_status[i] == 0 ? 1 : 0);
user_config->socket_status[i] = on;
if (RelayOut()&&user_config->power_led_enabled)
{
if (RelayOut() && user_config->power_led_enabled) {
UserLedSet(1);
}
else
{
} else {
UserLedSet(0);
}
}
@@ -95,111 +104,150 @@ void UserRelaySet(unsigned char i, unsigned char on)
* y: 0:全部关 1:全部开
*
*/
void UserRelaySetAll(char y)
{
void UserRelaySetAll(char y) {
int i;
for (i = 0; i < SOCKET_NUM; i++)
UserRelaySet(i, y);
}
static void KeyLongPress(void)
{
// key_log("KeyLongPress");
// UserLedSet(1);
// UserMqttSend("mqtt test");
static void KeyLong5sPress(void) {
key_log("WARNGIN: wifi ap started!");
micoWlanSuspendStation();
ApInit(true);
}
static void KeyLong10sPress(void)
{
static void KeyLong10sPress(void) {
key_log("WARNGIN: user params restored!");
appRestoreDefault_callback(user_config, sizeof(user_config_t));
sys_config->micoSystemConfig.ssid[0] = 0;
mico_system_context_update(mico_system_context_get());
mico_system_context_restore(sys_config);
// appRestoreDefault_callback(user_config, sizeof(user_config_t));
// sys_config->micoSystemConfig.ssid[0] = 0;
// mico_system_context_update(mico_system_context_get());
}
static void KeyShortPress(void)
{
char i;
if (RelayOut())
{
UserRelaySetAll(0);
}
else
{
UserRelaySetAll(1);
}
for (i = 0; i < SOCKET_NUM; i++)
{
UserMqttSendSocketState(i);
static void KeyShortPress(int clickCnt) {
key_log("WARNGIN:Power key quick clicked %d time%s",clickCnt,clickCnt>1?"s":"");
if (clickCnt > 10||clickCnt <= 0)
return;
switch (user_config->user[clickCnt]) {
case SWITCH_TOTAL_SOCKET:
key_log("WARNGIN:SWITCH_TOTAL_SOCKET");
if (RelayOut()) {
UserRelaySetAll(0);
} else {
UserRelaySetAll(1);
}
mico_system_context_update(sys_config);
for (int i = 0; i < SOCKET_NUM; i++) {
UserMqttSendSocketState(i);
}
UserMqttSendTotalSocketState();
break;
case SWITCH_SOCKET_1:
case SWITCH_SOCKET_2:
case SWITCH_SOCKET_3:
case SWITCH_SOCKET_4:
case SWITCH_SOCKET_5:
case SWITCH_SOCKET_6:
key_log("WARNGIN:SWITCH_SOCKET%d %s",user_config->user[clickCnt] - 1,user_config->socket_names[user_config->user[clickCnt] - 1]);
UserRelaySet(user_config->user[clickCnt] - 1, Relay_TOGGLE);
UserMqttSendSocketState(user_config->user[clickCnt] - 1);
UserMqttSendTotalSocketState();
mico_system_context_update(sys_config);
break;
case SWITCH_LED_ENABLE:
key_log("WARNGIN:SWITCH_LED_ENABLE");
MQTT_LED_ENABLED = MQTT_LED_ENABLED == 0 ? 1 : 0;
if (RelayOut() && MQTT_LED_ENABLED) {
UserLedSet(1);
} else {
UserLedSet(0);
}
UserMqttSendLedState();
mico_system_context_update(sys_config);
break;
default:
break;
}
}
mico_timer_t user_key_timer;
// 全局静态变量声明
static uint8_t click_count = 0;
static mico_timer_t click_end_timer;
uint16_t key_time = 0;
#define BUTTON_LONG_PRESS_TIME 10 //100ms*10=1s
static void KeyTimeoutHandler(void* arg)
{
static void ClickEndTimeoutHandler(void *arg) {
if(click_count<=0){
click_count = 0;
return;
}
KeyShortPress(click_count);
click_count = 0;
}
static void KeyTimeoutHandler(void *arg) {
if (childLockEnabled)
return;
static char key_trigger, key_continue;
//按键扫描程序
static uint8_t key_time = 0;
char tmp = ~(0xfe | MicoGpioInputGet(Button));
key_trigger = tmp & (tmp ^ key_continue);
key_continue = tmp;
if (key_trigger != 0) key_time = 0; //新按键按下时,重新开始按键计时
if (key_continue != 0)
{
//any button pressed
key_time++;
if (key_time <= BUTTON_LONG_PRESS_TIME)
{
key_log("button long pressed:%d",key_time);
if (key_time == 30)
{
KeyLongPress();
}
else if (key_time == 100)
{
if (key_trigger != 0)
key_time = 0;
if (key_continue != 0) {
key_time++;
if (key_time > BUTTON_LONG_PRESS_TIME) {
if (key_time == 50) {
KeyLong5sPress();
} else if (key_time > 50 && key_time < 57) {
switch (key_time) {
case 51: UserLedSet(1); break;
case 52: UserLedSet(0); break;
case 53: UserLedSet(1); break;
case 54: UserLedSet(0); break;
case 55: UserLedSet(1); break;
case 56: UserLedSet(0); break;
}
} else if (key_time == 57) {
UserLedSet(RelayOut() && user_config->power_led_enabled);
} else if (key_time == 100) {
KeyLong10sPress();
}
else if (key_time == 102)
{
} else if (key_time == 102) {
UserLedSet(1);
}
else if (key_time == 103)
{
} else if (key_time == 103) {
UserLedSet(0);
key_time = 101;
}
}
}
else
{
//button released
if (key_time < BUTTON_LONG_PRESS_TIME)
{ //100ms*10=1s 大于1s为长按
key_time = 0;
key_log("button short pressed:%d",key_time);
KeyShortPress();
}
else if (key_time > 100)
{
} else {
if (key_time < BUTTON_LONG_PRESS_TIME) {
click_count++;
// 重启 click_end_timer300ms
mico_rtos_stop_timer(&click_end_timer);
mico_rtos_start_timer(&click_end_timer);
} else if (key_time > 100) {
MicoSystemReboot();
}
mico_rtos_stop_timer(&user_key_timer);
}
}
static void KeyFallingIrqHandler(void* arg)
{
static void KeyFallingIrqHandler(void *arg) {
mico_rtos_start_timer(&user_key_timer);
}
void KeyInit(void)
{
void KeyInit(void) {
MicoGpioInitialize(Button, INPUT_PULL_UP);
mico_rtos_init_timer(&user_key_timer, 100, KeyTimeoutHandler, NULL);
mico_rtos_init_timer(&click_end_timer, 400, ClickEndTimeoutHandler, NULL);
MicoGpioEnableIRQ(Button, IRQ_TRIGGER_FALLING_EDGE, KeyFallingIrqHandler, NULL);
}

View File

@@ -4,14 +4,24 @@
#include "mico.h"
#include "micokit_ext.h"
#define SWITCH_TOTAL_SOCKET 0
#define SWITCH_SOCKET_1 1
#define SWITCH_SOCKET_2 2
#define SWITCH_SOCKET_3 3
#define SWITCH_SOCKET_4 4
#define SWITCH_SOCKET_5 5
#define SWITCH_SOCKET_6 6
#define SWITCH_LED_ENABLE 7
extern char socket_status[32];
void UserLedSet(char x);
void KeyInit(void);
void UserRelaySet(unsigned char x,unsigned char y);
void UserRelaySet(unsigned char x, char y);
void UserRelaySetAll(char y);
bool RelayOut(void);
char* GetSocketStatus();
char* GetShortClickConfig();
void SetSocketStatus(char* socket_status);
#endif

View File

@@ -7,26 +7,23 @@
#include "user_power.h"
uint32_t p_count = 0;
PowerRecord power_record = { 1,{ 0 } };
char power_record_str[1101] = { 0 };
PowerRecord power_record = {1, {0}};
char power_record_str[1101] = {0};
float real_time_power = 0;
void SetPowerRecord(PowerRecord* pr, uint32_t pw)
{
pr->powers[(++pr->idx)% PW_NUM] = pw;
void SetPowerRecord(PowerRecord *pr, uint32_t pw) {
pr->powers[(++pr->idx) % PW_NUM] = pw;
}
char* GetPowerRecord(int idx)
{
char *GetPowerRecord(int idx) {
if (idx > power_record.idx) return "";
idx = idx <= power_record.idx - PW_NUM ? 0 : idx;
int i = idx > 0 ? idx : (power_record.idx - PW_NUM + 1);
i = i < 0 ? 0 : i;
char* tmp = power_record_str;
for (; i <= power_record.idx; i++)
{
sprintf(tmp, "%lu,", power_record.powers[i%PW_NUM]);
char *tmp = power_record_str;
for (; i <= power_record.idx; i++) {
sprintf(tmp, "%lu,", power_record.powers[i % PW_NUM]);
tmp += strlen(tmp);
}
*(--tmp) = 0;
@@ -38,9 +35,11 @@ float n_1s = 0; //在当前这一秒功率中断次数
uint64_t past_ns = 0; //系统运行的纳秒数
uint64_t irq_old = 0; //上次中断的时间(纳秒)
static void PowerIrqHandler(void* arg)
{
static void PowerIrqHandler(void *arg) {
//警告! 不能在此函数里调用任何有关moloc()的操作
if (p_count == 0) {
p_count = user_config->p_count_1_day_ago;
}
p_count++;
@@ -48,30 +47,27 @@ static void PowerIrqHandler(void* arg)
past_ns = mico_nanosecond_clock_value(); //系统运行纳秒数
uint64_t spend_ns = past_ns - irq_old;
if (irq_old % NS + spend_ns <= NS)
{
if (irq_old % NS + spend_ns <= NS) {
n_1s += 1;
irq_old = past_ns;
return;
}
int n = (spend_ns - past_ns % NS) / NS;
n_1s += (float)(NS - irq_old % NS) / spend_ns;
n_1s += (float) (NS - irq_old % NS) / spend_ns;
real_time_power = 17.1 * n_1s;
SetPowerRecord(&power_record, (int)real_time_power);
SetPowerRecord(&power_record, (int) real_time_power);
int i = 0;
for (; i < n; i++)
{
for (; i < n; i++) {
real_time_power = 17.1 * NS / spend_ns;
SetPowerRecord(&power_record, (int)real_time_power);
SetPowerRecord(&power_record, (int) real_time_power);
}
irq_old = past_ns;
n_1s = (float)(past_ns % NS) / spend_ns;
n_1s = (float) (past_ns % NS) / spend_ns;
}
void PowerInit(void)
{
void PowerInit(void) {
power_log("PowerInit");
MicoGpioInitialize(POWER, INPUT_PULL_UP);
MicoGpioEnableIRQ(POWER, IRQ_TRIGGER_FALLING_EDGE, PowerIrqHandler, NULL);

View File

@@ -1,11 +1,27 @@
cd ./TC1/http_server
python ./test.py > web_data.c
cd ../..
mico make clean
mico make TC1@MK3031@moc total
cp ./build/TC1\@MK3031\@moc/binary/TC1\@MK3031\@moc.ota.bin ./build/TC1\@MK3031\@moc/binary/ota.bin
version_file=".version"
if [ ! -f $version_file ]; then echo "v1.0.0" > $version_file; fi
# 读当前版本并自增
ver=$(cat $version_file)
major=$(echo $ver | cut -d. -f1 | sed 's/v//')
minor=$(echo $ver | cut -d. -f2)
patch=$(echo $ver | cut -d. -f3)
patch=$((patch + 1))
new_ver="v${major}.${minor}.${patch}"
echo $new_ver > $version_file
cd ./TC1/http_server
python ./test.py > web_data.c
cd ../..
mico make TC1@MK3031@moc total
cp ./build/TC1\@MK3031\@moc/binary/TC1\@MK3031\@moc.ota.bin ./build/TC1\@MK3031\@moc/binary/ota.bin
cp ./build/TC1\@MK3031\@moc/binary/TC1\@MK3031\@moc.ota.bin ./build/TC1\@MK3031\@moc/binary/ota$(date +%Y%m%d%H%M%S).bin
cp ./build/TC1\@MK3031\@moc/binary/TC1\@MK3031\@moc.all.bin ./build/TC1\@MK3031\@moc/binary/all$(date +%Y%m%d%H%M%S).bin

BIN
doc/IMG_0862.png Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 396 KiB

BIN
doc/IMG_0863.png Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 286 KiB

4
mico-os/.gitignore vendored Normal file
View File

@@ -0,0 +1,4 @@
MiCoder/compiler
Projects
MiCoder
tools_root